summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/bgsync.h
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2016-06-10 19:17:33 -0400
committerBenety Goh <benety@mongodb.com>2016-06-16 11:01:16 -0400
commitecf94af392c33b88fadb444c8868cd540fd8d316 (patch)
tree1ab385f72e29041d7a2196b5596e6a661955ba3e /src/mongo/db/repl/bgsync.h
parent5bbf5083162d1982f579dcfaea254c32aa30805b (diff)
downloadmongo-ecf94af392c33b88fadb444c8868cd540fd8d316.tar.gz
SERVER-24577 added OperationContext argument to OplogBuffer interface
Diffstat (limited to 'src/mongo/db/repl/bgsync.h')
-rw-r--r--src/mongo/db/repl/bgsync.h14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/mongo/db/repl/bgsync.h b/src/mongo/db/repl/bgsync.h
index 817746350d8..a62fa90c69b 100644
--- a/src/mongo/db/repl/bgsync.h
+++ b/src/mongo/db/repl/bgsync.h
@@ -68,7 +68,7 @@ public:
// stop syncing (when this node becomes a primary, e.g.)
void stop();
- void shutdown();
+ void shutdown(OperationContext* txn);
bool isStopped() const;
@@ -86,16 +86,16 @@ public:
// Interface implementation
- bool peek(BSONObj* op);
- void consume();
+ bool peek(OperationContext* txn, BSONObj* op);
+ void consume(OperationContext* txn);
void clearSyncTarget();
- void waitForMore();
+ void waitForMore(OperationContext* txn);
// For monitoring
BSONObj getCounters();
// Clears any fetched and buffered oplog entries.
- void clearBuffer();
+ void clearBuffer(OperationContext* txn);
/**
* Cancel existing find/getMore commands on the sync source's oplog collection.
@@ -112,7 +112,7 @@ public:
bool shouldStopFetching() const;
// Testing related stuff
- void pushTestOpToBuffer(const BSONObj& op);
+ void pushTestOpToBuffer(OperationContext* txn, const BSONObj& op);
private:
// Production thread
@@ -126,7 +126,7 @@ private:
*
* NOTE: Used after rollback and during draining to transition to Primary role;
*/
- void _signalNoNewDataForApplier();
+ void _signalNoNewDataForApplier(OperationContext* txn);
/**
* Record metrics.