diff options
| -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) { |