diff options
| author | Ben Caimano <ben.caimano@10gen.com> | 2019-03-05 13:40:25 -0500 |
|---|---|---|
| committer | Ben Caimano <ben.caimano@10gen.com> | 2019-04-02 18:23:23 -0400 |
| commit | 04ea1d46eb6c4c78e19409f120ae2e61f2a35204 (patch) | |
| tree | da810936cb90baafd1a40a598a0420107b9506bc /src/mongo/db/concurrency | |
| parent | 374ae184764e7fb13c60bfa4a731715d22d56d17 (diff) | |
| download | mongo-04ea1d46eb6c4c78e19409f120ae2e61f2a35204.tar.gz | |
SERVER-39965 OutOfLineExecutor Tasks are now unique_function(Status)
Diffstat (limited to 'src/mongo/db/concurrency')
| -rw-r--r-- | src/mongo/db/concurrency/deferred_writer.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/mongo/db/concurrency/deferred_writer.cpp b/src/mongo/db/concurrency/deferred_writer.cpp index 3e609009931..2dbda1013c4 100644 --- a/src/mongo/db/concurrency/deferred_writer.cpp +++ b/src/mongo/db/concurrency/deferred_writer.cpp @@ -178,7 +178,11 @@ bool DeferredWriter::insertDocument(BSONObj obj) { // Add the object to the buffer. _numBytes += obj.objsize(); - fassert(40588, _pool->schedule([this, obj] { _worker(InsertStatement(obj.getOwned())); })); + _pool->schedule([this, obj](auto status) { + fassert(40588, status); + + _worker(InsertStatement(obj.getOwned())); + }); return true; } |