Adjust comments for flushDone() method (called by flush scheduler thread).

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); }));
 
 }