commit requires full sync.
@@ -135,6 +135,11 @@ public:
commit();
}
+ template <typename FunctionType>
+ void runInMasterAndSyncAll(FunctionType func) {
+ test::runInMasterAndSyncAll(_writeService, func);
+ }
+
template <typename FunctionType>
void runInMasterAndSync(FunctionType func) {
test::runInMasterAndSync(_writeService, func);
@@ -163,7 +168,7 @@ public:
}
void commit() {
- runInMasterAndSync([&]() { cycleLids(_lidReuseDelayer->getReuseLids()); });
+ runInMasterAndSyncAll([&]() { cycleLids(_lidReuseDelayer->getReuseLids()); });
}
};
