diff options
-rw-r--r-- | src/mongo/db/rs_local_client.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/mongo/db/rs_local_client.cpp b/src/mongo/db/rs_local_client.cpp index 23e82df2de3..dd1643e84dc 100644 --- a/src/mongo/db/rs_local_client.cpp +++ b/src/mongo/db/rs_local_client.cpp @@ -120,6 +120,9 @@ StatusWith<Shard::QueryResponse> RSLocalClient::queryOnce( // Sets up operation context with majority read snapshot so correct optime can be retrieved. opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kMajorityCommitted); Status status = opCtx->recoveryUnit()->majorityCommittedSnapshotAvailable(); + if (!status.isOK()) { + return status; + } // Waits for any writes performed by this ShardLocal instance to be committed and visible. Status readConcernStatus = replCoord->waitUntilOpTimeForRead( |