diff options
| author | Arun Banala <arun.banala@mongodb.com> | 2020-11-02 18:09:28 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-01-07 20:04:53 +0000 |
| commit | c8ddb496f147e5a977eb668247b81da313d06e1d (patch) | |
| tree | 34ba0cc443ec6294c5585d0951d5430cc69349e2 /src/mongo/client/dbclient_cursor.cpp | |
| parent | d0cfd1d0c0fcfd75525a8d8f3a050876bc9d1e40 (diff) | |
| download | mongo-c8ddb496f147e5a977eb668247b81da313d06e1d.tar.gz | |
SERVER-51619 Convert find command input to IDL
Diffstat (limited to 'src/mongo/client/dbclient_cursor.cpp')
| -rw-r--r-- | src/mongo/client/dbclient_cursor.cpp | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/mongo/client/dbclient_cursor.cpp b/src/mongo/client/dbclient_cursor.cpp index f38a70f50b5..999a382b6ff 100644 --- a/src/mongo/client/dbclient_cursor.cpp +++ b/src/mongo/client/dbclient_cursor.cpp @@ -133,15 +133,16 @@ Message DBClientCursor::_assembleInit() { // Legacy queries don't handle readOnce. qr.getValue()->setReadOnce(true); } - if (query.getBoolField("$_requestResumeToken")) { + if (query.getBoolField(FindCommand::kRequestResumeTokenFieldName)) { // Legacy queries don't handle requestResumeToken. qr.getValue()->setRequestResumeToken(true); } - if (query.hasField("$_resumeAfter")) { + if (query.hasField(FindCommand::kResumeAfterFieldName)) { // Legacy queries don't handle resumeAfter. - qr.getValue()->setResumeAfter(query.getObjectField("$_resumeAfter")); + qr.getValue()->setResumeAfter( + query.getObjectField(FindCommand::kResumeAfterFieldName)); } - if (auto replTerm = query[QueryRequest::kTermField]) { + if (auto replTerm = query[FindCommand::kTermFieldName]) { // Legacy queries don't handle term. qr.getValue()->setReplicationTerm(replTerm.numberLong()); } @@ -152,8 +153,8 @@ Message DBClientCursor::_assembleInit() { } else if (_readConcernObj) { qr.getValue()->setReadConcern(*_readConcernObj); } - BSONObj cmd = _nsOrUuid.uuid() ? qr.getValue()->asFindCommandWithUuid() - : qr.getValue()->asFindCommand(); + BSONObj cmd = qr.getValue()->asFindCommand(); + if (auto readPref = query["$readPreference"]) { // QueryRequest doesn't handle $readPreference. cmd = BSONObjBuilder(std::move(cmd)).append(readPref).obj(); |