diff options
Diffstat (limited to 'searchlib/src')
-rw-r--r-- | searchlib/src/vespa/searchlib/docstore/writeablefilechunk.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/searchlib/src/vespa/searchlib/docstore/writeablefilechunk.cpp b/searchlib/src/vespa/searchlib/docstore/writeablefilechunk.cpp index e6a78b21a0b..35d75300cb1 100644 --- a/searchlib/src/vespa/searchlib/docstore/writeablefilechunk.cpp +++ b/searchlib/src/vespa/searchlib/docstore/writeablefilechunk.cpp @@ -515,17 +515,16 @@ WriteableFileChunk::fileWriter(const uint32_t firstChunkId) LOG(debug, "Stopping the filewriter with startchunkid = %d and ending chunkid = %d done=%d", firstChunkId, nextChunkId, done); assert(_writeQ.empty()); + _writeTaskIsRunning = false; if (done) { assert(_chunkMap.empty()); for (const ChunkInfo & cm : _chunkInfo) { (void) cm; assert(cm.valid() && cm.getSize() != 0); } - _writeTaskIsRunning = false; guard.broadcast(); } else { _firstChunkIdToBeWritten = nextChunkId; - _writeTaskIsRunning = false; } } |