diff options
| author | Vesselina Ratcheva <vesselina.ratcheva@mongodb.com> | 2020-01-16 23:26:34 +0000 |
|---|---|---|
| committer | evergreen <evergreen@mongodb.com> | 2020-01-16 23:26:34 +0000 |
| commit | 8003fc047c5c742829ba80b86ec2e6c5bb4e8453 (patch) | |
| tree | 9aad28e028559b1832035ec9c40bafb2169f6e1c /src/mongo/client/dbclient_cursor.cpp | |
| parent | 02f3b3a204bdc0e1b157a3839be91dc56f685077 (diff) | |
| download | mongo-8003fc047c5c742829ba80b86ec2e6c5bb4e8453.tar.gz | |
SERVER-43276 Implement resume after network error functionality in CollectionCloner query
Diffstat (limited to 'src/mongo/client/dbclient_cursor.cpp')
| -rw-r--r-- | src/mongo/client/dbclient_cursor.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/mongo/client/dbclient_cursor.cpp b/src/mongo/client/dbclient_cursor.cpp index 244e893f88b..3c167ee1205 100644 --- a/src/mongo/client/dbclient_cursor.cpp +++ b/src/mongo/client/dbclient_cursor.cpp @@ -332,6 +332,8 @@ void DBClientCursor::dataReceived(const Message& reply, bool& retry, string& hos !(_connectionHasPendingReplies && cursorId == 0)); ns = cr.getNSS(); // Unlike OP_REPLY, find command can change the ns to use for getMores. + // Store the resume token, if we got one. + _postBatchResumeToken = cr.getPostBatchResumeToken(); batch.objs = cr.releaseBatch(); return; } |