diff options
author | William Schultz <william.schultz@mongodb.com> | 2018-08-28 12:05:35 -0400 |
---|---|---|
committer | William Schultz <william.schultz@mongodb.com> | 2018-08-28 12:05:35 -0400 |
commit | 2eb308afe270f9443d60f2f8ae574f5b1ea1fd37 (patch) | |
tree | 5c166fb04ba8997c74b0bd9f2e69cd92f9e25fea /src/mongo/client | |
parent | 15d627c3b7b9b1b2ca4d2f729102f730a0568c1c (diff) | |
download | mongo-2eb308afe270f9443d60f2f8ae574f5b1ea1fd37.tar.gz |
SERVER-36299 Ensure that dbclient_cursor_test clears last sent message in between requests
Diffstat (limited to 'src/mongo/client')
-rw-r--r-- | src/mongo/client/dbclient_cursor_test.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/client/dbclient_cursor_test.cpp b/src/mongo/client/dbclient_cursor_test.cpp index 9a9eb793a7f..b57cdadf435 100644 --- a/src/mongo/client/dbclient_cursor_test.cpp +++ b/src/mongo/client/dbclient_cursor_test.cpp @@ -177,6 +177,7 @@ TEST_F(DBClientCursorTest, DBClientCursorHandlesOpMsgExhaustCorrectly) { // Request more results. This call should trigger the first 'getMore' request with exhaust // flag set. + conn.clearLastSentMessage(); ASSERT(cursor.more()); m = conn.getLastSentMessage(); @@ -240,6 +241,7 @@ TEST_F(DBClientCursorTest, DBClientCursorResendsGetMoreIfMoreToComeFlagIsOmitted // Request more results. This call should trigger the first 'getMore' request with exhaust // flag set. + conn.clearLastSentMessage(); ASSERT(cursor.more()); m = conn.getLastSentMessage(); ASSERT(!m.empty()); @@ -262,6 +264,7 @@ TEST_F(DBClientCursorTest, DBClientCursorResendsGetMoreIfMoreToComeFlagIsOmitted // Request more results again. This call should trigger another 'getMore' request, since the // previous response had no 'moreToCome' flag set. This time the mock server will respond with // the 'moreToCome' flag set. + conn.clearLastSentMessage(); ASSERT(cursor.more()); m = conn.getLastSentMessage(); ASSERT(!m.empty()); @@ -280,6 +283,7 @@ TEST_F(DBClientCursorTest, DBClientCursorResendsGetMoreIfMoreToComeFlagIsOmitted conn.setRecvResponse(terminalGetMoreResponseMsg); // Get the last returned document. + conn.clearLastSentMessage(); ASSERT(cursor.more()); ASSERT_BSONOBJ_EQ(terminalDoc, cursor.next()); |