diff options
| author | Adam Midvidy <amidvidy@gmail.com> | 2015-09-22 11:24:15 -0400 |
|---|---|---|
| committer | Adam Midvidy <amidvidy@gmail.com> | 2015-09-22 21:18:54 -0400 |
| commit | 3be90504806da8f5d55d83e07f456f862fbc90e1 (patch) | |
| tree | a0cc1337f7fc9b6037cb6d6420f009357d4ee15d /src/mongo/executor/network_interface_asio.cpp | |
| parent | 9eeac28ad54382ddf3fa46dddbc704a36da7a5ac (diff) | |
| download | mongo-3be90504806da8f5d55d83e07f456f862fbc90e1.tar.gz | |
SERVER-20556 bump the generation count of AsyncOp after removing it from _inProgress
Diffstat (limited to 'src/mongo/executor/network_interface_asio.cpp')
| -rw-r--r-- | src/mongo/executor/network_interface_asio.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/executor/network_interface_asio.cpp b/src/mongo/executor/network_interface_asio.cpp index 471f79e6100..af387c9dda1 100644 --- a/src/mongo/executor/network_interface_asio.cpp +++ b/src/mongo/executor/network_interface_asio.cpp @@ -192,6 +192,10 @@ void NetworkInterfaceASIO::startCommand(const TaskExecutor::CallbackHandle& cbHa auto ownedOp = conn->releaseAsyncOp(); op = ownedOp.get(); + // Sanity check that we are getting a clean AsyncOp. + invariant(!op->canceled()); + invariant(!op->timedOut()); + _inProgress.emplace(op, std::move(ownedOp)); } |