mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

SERVER-28489 MockStream hook methods may still be used if the stream gets canceled

Browse Source
This commit is contained in:
samantharitter 2017-03-24 15:36:50 -04:00
parent cdf2e4cc29
commit 0230175542
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/mongo/executor/async_mock_stream_factory.cpp
View File

@ -209,7 +209,7 @@ void AsyncMockStreamFactory::MockStream::read(asio::mutable_buffer buf,
void AsyncMockStreamFactory::MockStream::pushRead(std::vector<uint8_t> toRead) {
stdx::unique_lock<stdx::mutex> lk(_mutex);
invariant(_state != kRunning && _state != kCanceled);
invariant(_state != kRunning);
_readQueue.emplace(std::move(toRead));
}
@ -219,7 +219,7 @@ void AsyncMockStreamFactory::MockStream::setError(std::error_code ec) {
std::vector<uint8_t> AsyncMockStreamFactory::MockStream::popWrite() {
stdx::unique_lock<stdx::mutex> lk(_mutex);
invariant(_state != kRunning && _state != kCanceled);
invariant(_state != kRunning);
auto nextWrite = std::move(_writeQueue.front());
_writeQueue.pop();
return nextWrite;