diff options
author | Tor Egge <Tor.Egge@oath.com> | 2017-11-29 12:53:38 +0000 |
---|---|---|
committer | Tor Egge <Tor.Egge@oath.com> | 2017-11-29 12:53:38 +0000 |
commit | f257c3473175f84d63ada2708b39124c1ce8acee (patch) | |
tree | 73dd5cd0c68e47ff0b8bba59dd413229448a5301 /searchcore | |
parent | 57f5ec47aaf7ec84c668b483009f64b1ea8e839a (diff) |
Adjust comments for flushDone() method (called by flush scheduler thread).
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/flushengine/iflushhandler.h | 2 | ||||
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/flushengine/iflushhandler.h b/searchcore/src/vespa/searchcore/proton/flushengine/iflushhandler.h index 421b176bfec..3a24330f8ec 100644 --- a/searchcore/src/vespa/searchcore/proton/flushengine/iflushhandler.h +++ b/searchcore/src/vespa/searchcore/proton/flushengine/iflushhandler.h @@ -65,7 +65,7 @@ public: /** * This method is called after a flush has been completed. All transactions * up to the given serial number can be pruned from the domain of this - * handler. This method is called by an arbitrary worker thread. + * handler. This method is called by the flush scheduler thread. * * @param flushedSerial Serial number flushed for all flush * targets belonging to this handler. diff --git a/searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp b/searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp index cc40435819d..d77be520351 100644 --- a/searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/feedhandler.cpp @@ -392,7 +392,7 @@ FeedHandler::replayTransactionLog(SerialNum flushedIndexMgrSerial, SerialNum flu void FeedHandler::flushDone(SerialNum flushedSerial) { - // Called by flush worker thread after performing a flush task + // Called by flush scheduler thread after flush worker thread has completed a flush task _writeService.master().execute(makeLambdaTask([this, flushedSerial]() { performFlushDone(flushedSerial); })); } |