diff options
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_impl.h')
| -rw-r--r-- | src/mongo/db/repl/replication_coordinator_impl.h | 59 |
1 files changed, 30 insertions, 29 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl.h b/src/mongo/db/repl/replication_coordinator_impl.h index 5b2722eaab2..1fa82993ff6 100644 --- a/src/mongo/db/repl/replication_coordinator_impl.h +++ b/src/mongo/db/repl/replication_coordinator_impl.h @@ -101,9 +101,9 @@ public: // ================== Members of public ReplicationCoordinator API =================== - virtual void startup(OperationContext* txn) override; + virtual void startup(OperationContext* opCtx) override; - virtual void shutdown(OperationContext* txn) override; + virtual void shutdown(OperationContext* opCtx) override; virtual ReplicationExecutor* getExecutor() override { return &_replExecutor; @@ -124,34 +124,34 @@ public: virtual void clearSyncSourceBlacklist() override; virtual ReplicationCoordinator::StatusAndDuration awaitReplication( - OperationContext* txn, const OpTime& opTime, const WriteConcernOptions& writeConcern); + OperationContext* opCtx, const OpTime& opTime, const WriteConcernOptions& writeConcern); virtual ReplicationCoordinator::StatusAndDuration awaitReplicationOfLastOpForClient( - OperationContext* txn, const WriteConcernOptions& writeConcern); + OperationContext* opCtx, const WriteConcernOptions& writeConcern); - virtual Status stepDown(OperationContext* txn, + virtual Status stepDown(OperationContext* opCtx, bool force, const Milliseconds& waitTime, const Milliseconds& stepdownTime); virtual bool isMasterForReportingPurposes(); - virtual bool canAcceptWritesForDatabase(OperationContext* txn, StringData dbName); - virtual bool canAcceptWritesForDatabase_UNSAFE(OperationContext* txn, StringData dbName); + virtual bool canAcceptWritesForDatabase(OperationContext* opCtx, StringData dbName); + virtual bool canAcceptWritesForDatabase_UNSAFE(OperationContext* opCtx, StringData dbName); - bool canAcceptWritesFor(OperationContext* txn, const NamespaceString& ns) override; - bool canAcceptWritesFor_UNSAFE(OperationContext* txn, const NamespaceString& ns) override; + bool canAcceptWritesFor(OperationContext* opCtx, const NamespaceString& ns) override; + bool canAcceptWritesFor_UNSAFE(OperationContext* opCtx, const NamespaceString& ns) override; virtual Status checkIfWriteConcernCanBeSatisfied(const WriteConcernOptions& writeConcern) const; - virtual Status checkCanServeReadsFor(OperationContext* txn, + virtual Status checkCanServeReadsFor(OperationContext* opCtx, const NamespaceString& ns, bool slaveOk); - virtual Status checkCanServeReadsFor_UNSAFE(OperationContext* txn, + virtual Status checkCanServeReadsFor_UNSAFE(OperationContext* opCtx, const NamespaceString& ns, bool slaveOk); - virtual bool shouldRelaxIndexConstraints(OperationContext* txn, const NamespaceString& ns); + virtual bool shouldRelaxIndexConstraints(OperationContext* opCtx, const NamespaceString& ns); virtual Status setLastOptimeForSlave(const OID& rid, const Timestamp& ts); @@ -168,7 +168,7 @@ public: virtual OpTime getMyLastAppliedOpTime() const override; virtual OpTime getMyLastDurableOpTime() const override; - virtual Status waitUntilOpTimeForRead(OperationContext* txn, + virtual Status waitUntilOpTimeForRead(OperationContext* opCtx, const ReadConcernArgs& settings) override; virtual OID getElectionId() override; @@ -181,14 +181,14 @@ public: virtual ApplierState getApplierState() override; - virtual void signalDrainComplete(OperationContext* txn, + virtual void signalDrainComplete(OperationContext* opCtx, long long termWhenBufferIsEmpty) override; virtual Status waitForDrainFinish(Milliseconds timeout) override; virtual void signalUpstreamUpdater() override; - virtual Status resyncData(OperationContext* txn, bool waitUntilCompleted) override; + virtual Status resyncData(OperationContext* opCtx, bool waitUntilCompleted) override; virtual StatusWith<BSONObj> prepareReplSetUpdatePositionCommand( ReplSetUpdatePositionCommandStyle commandStyle) const override; @@ -214,7 +214,7 @@ public: virtual bool getMaintenanceMode() override; - virtual Status processReplSetSyncFrom(OperationContext* txn, + virtual Status processReplSetSyncFrom(OperationContext* opCtx, const HostAndPort& target, BSONObjBuilder* resultObj) override; @@ -223,11 +223,11 @@ public: virtual Status processHeartbeat(const ReplSetHeartbeatArgs& args, ReplSetHeartbeatResponse* response) override; - virtual Status processReplSetReconfig(OperationContext* txn, + virtual Status processReplSetReconfig(OperationContext* opCtx, const ReplSetReconfigArgs& args, BSONObjBuilder* resultObj) override; - virtual Status processReplSetInitiate(OperationContext* txn, + virtual Status processReplSetInitiate(OperationContext* opCtx, const BSONObj& configObj, BSONObjBuilder* resultObj) override; @@ -246,7 +246,8 @@ public: virtual Status processReplSetUpdatePosition(const UpdatePositionArgs& updates, long long* configVersion) override; - virtual Status processHandshake(OperationContext* txn, const HandshakeArgs& handshake) override; + virtual Status processHandshake(OperationContext* opCtx, + const HandshakeArgs& handshake) override; virtual bool buildsIndexes() override; @@ -265,7 +266,7 @@ public: virtual void blacklistSyncSource(const HostAndPort& host, Date_t until) override; - virtual void resetLastOpTimesFromOplog(OperationContext* txn) override; + virtual void resetLastOpTimesFromOplog(OperationContext* opCtx) override; virtual bool shouldChangeSyncSource( const HostAndPort& currentSource, @@ -274,7 +275,7 @@ public: virtual OpTime getLastCommittedOpTime() const override; - virtual Status processReplSetRequestVotes(OperationContext* txn, + virtual Status processReplSetRequestVotes(OperationContext* opCtx, const ReplSetRequestVotesArgs& args, ReplSetRequestVotesResponse* response) override; @@ -302,19 +303,19 @@ public: return _service; } - virtual Status updateTerm(OperationContext* txn, long long term) override; + virtual Status updateTerm(OperationContext* opCtx, long long term) override; - virtual SnapshotName reserveSnapshotName(OperationContext* txn) override; + virtual SnapshotName reserveSnapshotName(OperationContext* opCtx) override; virtual void forceSnapshotCreation() override; - virtual void createSnapshot(OperationContext* txn, + virtual void createSnapshot(OperationContext* opCtx, OpTime timeOfSnapshot, SnapshotName name) override; virtual OpTime getCurrentCommittedSnapshotOpTime() const override; - virtual void waitUntilSnapshotCommitted(OperationContext* txn, + virtual void waitUntilSnapshotCommitted(OperationContext* opCtx, const SnapshotName& untilSnapshot) override; virtual void appendConnectionStats(executor::ConnectionPoolStats* stats) const override; @@ -622,7 +623,7 @@ private: * operation timing to the caller. */ Status _awaitReplication_inlock(stdx::unique_lock<stdx::mutex>* lock, - OperationContext* txn, + OperationContext* opCtx, const OpTime& opTime, SnapshotName minSnapshot, const WriteConcernOptions& writeConcern); @@ -793,7 +794,7 @@ private: * config detected but more work is needed to set it as the local config (which will be * handled by the callback to _finishLoadLocalConfig). */ - bool _startLoadLocalConfig(OperationContext* txn); + bool _startLoadLocalConfig(OperationContext* opCtx); /** * Callback that finishes the work started in _startLoadLocalConfig and sets _rsConfigState @@ -807,13 +808,13 @@ private: /** * Start replicating data, and does an initial sync if needed first. */ - void _startDataReplication(OperationContext* txn, + void _startDataReplication(OperationContext* opCtx, stdx::function<void()> startCompleted = nullptr); /** * Stops replicating data by stopping the applier, fetcher and such. */ - void _stopDataReplication(OperationContext* txn); + void _stopDataReplication(OperationContext* opCtx); /** * Finishes the work of processReplSetInitiate() while holding _topoMutex, in the event of |