summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/bgsync.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/bgsync.h')
-rw-r--r--src/mongo/db/repl/bgsync.h22
1 files changed, 11 insertions, 11 deletions
diff --git a/src/mongo/db/repl/bgsync.h b/src/mongo/db/repl/bgsync.h
index 479caabaee8..85069066cdd 100644
--- a/src/mongo/db/repl/bgsync.h
+++ b/src/mongo/db/repl/bgsync.h
@@ -84,17 +84,17 @@ public:
/**
* Starts oplog buffer, task executor and producer thread, in that order.
*/
- void startup(OperationContext* txn);
+ void startup(OperationContext* opCtx);
/**
* Signals producer thread to stop.
*/
- void shutdown(OperationContext* txn);
+ void shutdown(OperationContext* opCtx);
/**
* Waits for producer thread to stop before shutting down the task executor and oplog buffer.
*/
- void join(OperationContext* txn);
+ void join(OperationContext* opCtx);
/**
* Returns true if shutdown() has been called.
@@ -109,8 +109,8 @@ public:
// Interface implementation
- bool peek(OperationContext* txn, BSONObj* op);
- void consume(OperationContext* txn);
+ bool peek(OperationContext* opCtx, BSONObj* op);
+ void consume(OperationContext* opCtx);
void clearSyncTarget();
void waitForMore();
@@ -118,7 +118,7 @@ public:
BSONObj getCounters();
// Clears any fetched and buffered oplog entries.
- void clearBuffer(OperationContext* txn);
+ void clearBuffer(OperationContext* opCtx);
/**
* Returns true if any of the following is true:
@@ -134,7 +134,7 @@ public:
void startProducerIfStopped();
// Adds a fake oplog entry to buffer. Used for testing only.
- void pushTestOpToBuffer(OperationContext* txn, const BSONObj& op);
+ void pushTestOpToBuffer(OperationContext* opCtx, const BSONObj& op);
private:
bool _inShutdown_inlock() const;
@@ -148,7 +148,7 @@ private:
void _run();
// Production thread inner loop.
void _runProducer();
- void _produce(OperationContext* txn);
+ void _produce(OperationContext* opCtx);
/**
* Checks current background sync state before pushing operations into blocking queue and
@@ -165,15 +165,15 @@ private:
* Executes a rollback.
* 'getConnection' returns a connection to the sync source.
*/
- void _rollback(OperationContext* txn,
+ void _rollback(OperationContext* opCtx,
const HostAndPort& source,
boost::optional<int> requiredRBID,
stdx::function<DBClientBase*()> getConnection);
// restart syncing
- void start(OperationContext* txn);
+ void start(OperationContext* opCtx);
- OpTimeWithHash _readLastAppliedOpTimeWithHash(OperationContext* txn);
+ OpTimeWithHash _readLastAppliedOpTimeWithHash(OperationContext* opCtx);
// Production thread
std::unique_ptr<OplogBuffer> _oplogBuffer;