MVCC: Error on TxLog initialization. This closes
@@ -298,8 +298,10 @@ public class MvccProcessorImpl extends GridProcessorAdapter implements MvccProce
if (!ctx.clientNode()) {
assert mvccEnabled && mvccSupported;
+ synchronized (mux) {
if (txLog == null)
txLog = new TxLog(ctx, ctx.cache().context().database());
+ }
startVacuumWorkers();
@@ -1088,7 +1090,8 @@ public class MvccProcessorImpl extends GridProcessorAdapter implements MvccProce
* Launches vacuum workers and scheduler.
*/
void startVacuumWorkers() {
- if (!ctx.clientNode()) {
+ assert !ctx.clientNode();
+
synchronized (mux) {
if (vacuumWorkers == null) {
assert cleanupQueue == null;
@@ -1111,7 +1114,6 @@ public class MvccProcessorImpl extends GridProcessorAdapter implements MvccProce
U.warn(log, "Attempting to start active vacuum.");
}
- }
/**
* Stops vacuum worker and scheduler.
