diff options
Diffstat (limited to 'src/mongo/db/query/find.cpp')
-rw-r--r-- | src/mongo/db/query/find.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/query/find.cpp b/src/mongo/db/query/find.cpp index fb6218fc800..a6a13db1fc8 100644 --- a/src/mongo/db/query/find.cpp +++ b/src/mongo/db/query/find.cpp @@ -377,7 +377,7 @@ namespace mongo { } // If we're replaying the oplog, we save the last time that we read. - OpTime slaveReadTill; + Timestamp slaveReadTill; // What number result are we starting at? Used to fill out the reply. startingResult = cc->pos(); @@ -401,8 +401,8 @@ namespace mongo { // Possibly note slave's position in the oplog. if (queryOptions & QueryOption_OplogReplay) { BSONElement e = obj["ts"]; - if (Date == e.type() || Timestamp == e.type()) { - slaveReadTill = e._opTime(); + if (Date == e.type() || bsonTimestamp == e.type()) { + slaveReadTill = e.timestamp(); } } @@ -615,7 +615,7 @@ namespace mongo { int numResults = 0; // If we're replaying the oplog, we save the last time that we read. - OpTime slaveReadTill; + Timestamp slaveReadTill; BSONObj obj; PlanExecutor::ExecState state; @@ -634,8 +634,8 @@ namespace mongo { // Possibly note slave's position in the oplog. if (pq.isOplogReplay()) { BSONElement e = obj["ts"]; - if (Date == e.type() || Timestamp == e.type()) { - slaveReadTill = e._opTime(); + if (Date == e.type() || bsonTimestamp == e.type()) { + slaveReadTill = e.timestamp(); } } |