summaryrefslogtreecommitdiff
path: root/src/mongo/db/query/find.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/query/find.cpp')
-rw-r--r--src/mongo/db/query/find.cpp12
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();
}
}