diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-11-20 16:34:01 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-11-20 16:34:01 +0000 |
| commit | a891b1db8c58bcfa0b129ef0cbd32ce9502f0f22 (patch) | |
| tree | f9aa076a55fc5463c3256e8ce31011f32f01cf73 /searchcore | |
| parent | 2bb7d79543951bec3bfda4ea88180182ac4ddd8f (diff) | |
Replace sync_all with forceCommit.
Diffstat (limited to 'searchcore')
| -rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp b/searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp index ea63d59c830..cfaf1d7948a 100644 --- a/searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp @@ -303,7 +303,9 @@ void FeedHandler::performEof() { assert(_writeService.master().isCurrentThread()); - _writeService.sync_all_executors(); + vespalib::Gate gate; + _activeFeedView->forceCommit(CommitParam(_serialNum), std::make_shared<vespalib::GateCallback>(gate)); + gate.await(); LOG(debug, "Visiting done for transaction log domain '%s', eof received", _tlsMgr.getDomainName().c_str()); // Replay must be complete if (_replay_end_serial_num != _serialNum) { |