summaryrefslogtreecommitdiffstats
path: root/searchlib
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-02-07 14:13:46 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2019-02-07 14:13:46 +0000
commitbf8b420f07e23bb5320b66e7eb1d8f2a7cd0b7bb (patch)
treecb1b186793412a7fb7b70b097fcd128a102e0bd8 /searchlib
parentb856689444b618a4031fecd76fdaa7f719afe8f7 (diff)
Move to common code to common path.
Diffstat (limited to 'searchlib')
-rw-r--r--searchlib/src/vespa/searchlib/docstore/writeablefilechunk.cpp3
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;
}
}