diff options
| author | Gabriel Russell <gabriel.russell@mongodb.com> | 2018-01-17 17:03:32 -0500 |
|---|---|---|
| committer | Gabriel Russell <gabriel.russell@mongodb.com> | 2018-02-15 10:42:55 -0500 |
| commit | dd1441218307fa6b1a141da4d1327de9f42dd8a9 (patch) | |
| tree | 3408c6cb31187e82c30cb8266c8e6b5a86ae1f7e | |
| parent | 537e479caf3c6a2db67c0fa1c5d6769c9aea8786 (diff) | |
| download | mongo-dd1441218307fa6b1a141da4d1327de9f42dd8a9.tar.gz | |
SERVER-32644 only the begining of the protocol messages must be at least 4 bytes
| -rw-r--r-- | src/mongo/client/embedded/embedded_transport_layer.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/client/embedded/embedded_transport_layer.cpp b/src/mongo/client/embedded/embedded_transport_layer.cpp index 696c2552c5f..bc89a7da7d1 100644 --- a/src/mongo/client/embedded/embedded_transport_layer.cpp +++ b/src/mongo/client/embedded/embedded_transport_layer.cpp @@ -90,11 +90,11 @@ extern "C" ssize_t mongoc_stream_embedded_writev(mongoc_stream_t* s, char* current_loc = static_cast<char*>(iov[i].iov_base); u_long remaining_iov = iov[i].iov_len; - // @TODO for now just not handling vecs of this size - invariant(remaining_iov >= 4); - // do we need a new message? if (stream->state == RPCState::WaitingForMessageLength) { + + invariant(remaining_iov >= 4); + // message length is the first four bytes // Should use dataview from mongo server stream->input_length_to_go = |