summaryrefslogtreecommitdiff
path: root/db/repl/rs_sync.cpp
diff options
context:
space:
mode:
authorAntonin Kral <a.kral@bobek.cz>2010-12-10 13:05:34 +0100
committerAntonin Kral <a.kral@bobek.cz>2010-12-10 13:05:34 +0100
commited4a804c027562e1bf6a0f45dae7326198c29f8e (patch)
tree9d04736132d5421497a80619e30d4c2e03e76728 /db/repl/rs_sync.cpp
parente598e7ada36302f35a0da8ae0c63c34b51b6a720 (diff)
downloadmongodb-ed4a804c027562e1bf6a0f45dae7326198c29f8e.tar.gz
Imported Upstream version 1.6.5
Diffstat (limited to 'db/repl/rs_sync.cpp')
-rw-r--r--db/repl/rs_sync.cpp9
1 files changed, 8 insertions, 1 deletions
diff --git a/db/repl/rs_sync.cpp b/db/repl/rs_sync.cpp
index 9ea65cf..9de3f60 100644
--- a/db/repl/rs_sync.cpp
+++ b/db/repl/rs_sync.cpp
@@ -70,7 +70,14 @@ namespace mongo {
return false;
}
- r.query(rsoplog, bo());
+ {
+ BSONObjBuilder q;
+ q.appendDate("$gte", applyGTE.asDate());
+ BSONObjBuilder query;
+ query.append("ts", q.done());
+ BSONObj queryObj = query.done();
+ r.query(rsoplog, queryObj);
+ }
assert( r.haveCursor() );
/* we lock outside the loop to avoid the overhead of locking on every operation. server isn't usable yet anyway! */