diff options
author | Esha Maharishi <esha.maharishi@mongodb.com> | 2017-02-09 15:08:31 -0500 |
---|---|---|
committer | Esha Maharishi <esha.maharishi@mongodb.com> | 2017-02-09 18:19:26 -0500 |
commit | 31e5c31a79b2043d0fa4288c0435fdfce4348343 (patch) | |
tree | 8c02d5cc58ea067dbc5af6722eccdf16707a9b9c /src/mongo/s/query/store_possible_cursor_test.cpp | |
parent | 0e3e4b1dbb3fa475abc29033171e26d194028391 (diff) | |
download | mongo-31e5c31a79b2043d0fa4288c0435fdfce4348343.tar.gz |
SERVER-27965 thread OperationContext* down through ClusterClientCursor's next() and kill() methods
Diffstat (limited to 'src/mongo/s/query/store_possible_cursor_test.cpp')
-rw-r--r-- | src/mongo/s/query/store_possible_cursor_test.cpp | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/mongo/s/query/store_possible_cursor_test.cpp b/src/mongo/s/query/store_possible_cursor_test.cpp index 7e7b5d671f0..d542e1ee760 100644 --- a/src/mongo/s/query/store_possible_cursor_test.cpp +++ b/src/mongo/s/query/store_possible_cursor_test.cpp @@ -62,7 +62,8 @@ TEST_F(StorePossibleCursorTest, ReturnsValidCursorResponse) { std::vector<BSONObj> batch = {fromjson("{_id: 1}"), fromjson("{_id: 2}")}; CursorResponse cursorResponse(nss, CursorId(0), batch); auto outgoingCursorResponse = - storePossibleCursor(hostAndPort, + storePossibleCursor(nullptr, // OperationContext* + hostAndPort, cursorResponse.toBSON(CursorResponse::ResponseType::InitialResponse), nss, nullptr, // TaskExecutor @@ -80,7 +81,8 @@ TEST_F(StorePossibleCursorTest, ReturnsValidCursorResponse) { // Test that storePossibleCursor() propagates an error if it cannot parse the cursor response. TEST_F(StorePossibleCursorTest, FailsGracefullyOnBadCursorResponseDocument) { - auto outgoingCursorResponse = storePossibleCursor(hostAndPort, + auto outgoingCursorResponse = storePossibleCursor(nullptr, // OperationContext* + hostAndPort, fromjson("{ok: 1, cursor: {}}"), nss, nullptr, // TaskExecutor @@ -94,7 +96,8 @@ TEST_F(StorePossibleCursorTest, FailsGracefullyOnBadCursorResponseDocument) { TEST_F(StorePossibleCursorTest, PassesUpCommandResultIfItDoesNotDescribeACursor) { BSONObj notACursorObj = BSON("not" << "cursor"); - auto outgoingCursorResponse = storePossibleCursor(hostAndPort, + auto outgoingCursorResponse = storePossibleCursor(nullptr, // OperationContext* + hostAndPort, notACursorObj, nss, nullptr, // TaskExecutor |