summaryrefslogtreecommitdiff
path: root/src/mongo/client
diff options
context:
space:
mode:
authorWilliam Schultz <william.schultz@mongodb.com>2018-08-28 12:05:35 -0400
committerWilliam Schultz <william.schultz@mongodb.com>2018-08-28 12:05:35 -0400
commit2eb308afe270f9443d60f2f8ae574f5b1ea1fd37 (patch)
tree5c166fb04ba8997c74b0bd9f2e69cd92f9e25fea /src/mongo/client
parent15d627c3b7b9b1b2ca4d2f729102f730a0568c1c (diff)
downloadmongo-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.cpp4
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());