diff options
author | Benety Goh <benety@mongodb.com> | 2016-06-10 19:17:33 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2016-06-16 11:01:16 -0400 |
commit | ecf94af392c33b88fadb444c8868cd540fd8d316 (patch) | |
tree | 1ab385f72e29041d7a2196b5596e6a661955ba3e /src/mongo/db/repl/bgsync.h | |
parent | 5bbf5083162d1982f579dcfaea254c32aa30805b (diff) | |
download | mongo-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.h | 14 |
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. |