diff options
Diffstat (limited to 'src/mongo/db/repl/operation_context_repl_mock.cpp')
-rw-r--r-- | src/mongo/db/repl/operation_context_repl_mock.cpp | 68 |
1 files changed, 33 insertions, 35 deletions
diff --git a/src/mongo/db/repl/operation_context_repl_mock.cpp b/src/mongo/db/repl/operation_context_repl_mock.cpp index 78587bda2f3..8b66c6b800f 100644 --- a/src/mongo/db/repl/operation_context_repl_mock.cpp +++ b/src/mongo/db/repl/operation_context_repl_mock.cpp @@ -36,52 +36,50 @@ namespace mongo { namespace repl { - OperationContextReplMock::OperationContextReplMock() : OperationContextReplMock(0) {} +OperationContextReplMock::OperationContextReplMock() : OperationContextReplMock(0) {} - OperationContextReplMock::OperationContextReplMock(unsigned int opNum) : - OperationContextReplMock(nullptr, opNum) { - } +OperationContextReplMock::OperationContextReplMock(unsigned int opNum) + : OperationContextReplMock(nullptr, opNum) {} - OperationContextReplMock::OperationContextReplMock(Client* client, unsigned int opNum) : - OperationContextNoop(client, opNum, new MMAPV1LockerImpl()), - _checkForInterruptStatus(Status::OK()), - _maxTimeMicrosRemaining(0), - _writesAreReplicated(true) { - } +OperationContextReplMock::OperationContextReplMock(Client* client, unsigned int opNum) + : OperationContextNoop(client, opNum, new MMAPV1LockerImpl()), + _checkForInterruptStatus(Status::OK()), + _maxTimeMicrosRemaining(0), + _writesAreReplicated(true) {} - OperationContextReplMock::~OperationContextReplMock() = default; +OperationContextReplMock::~OperationContextReplMock() = default; - void OperationContextReplMock::checkForInterrupt() { - uassertStatusOK(checkForInterruptNoAssert()); - } +void OperationContextReplMock::checkForInterrupt() { + uassertStatusOK(checkForInterruptNoAssert()); +} - Status OperationContextReplMock::checkForInterruptNoAssert() { - if (!_checkForInterruptStatus.isOK()) { - return _checkForInterruptStatus; - } - - return Status::OK(); +Status OperationContextReplMock::checkForInterruptNoAssert() { + if (!_checkForInterruptStatus.isOK()) { + return _checkForInterruptStatus; } - void OperationContextReplMock::setCheckForInterruptStatus(Status status) { - _checkForInterruptStatus = std::move(status); - } + return Status::OK(); +} - uint64_t OperationContextReplMock::getRemainingMaxTimeMicros() const { - return _maxTimeMicrosRemaining; - } +void OperationContextReplMock::setCheckForInterruptStatus(Status status) { + _checkForInterruptStatus = std::move(status); +} - void OperationContextReplMock::setRemainingMaxTimeMicros(uint64_t micros) { - _maxTimeMicrosRemaining = micros; - } +uint64_t OperationContextReplMock::getRemainingMaxTimeMicros() const { + return _maxTimeMicrosRemaining; +} - void OperationContextReplMock::setReplicatedWrites(bool writesAreReplicated) { - _writesAreReplicated = writesAreReplicated; - } +void OperationContextReplMock::setRemainingMaxTimeMicros(uint64_t micros) { + _maxTimeMicrosRemaining = micros; +} - bool OperationContextReplMock::writesAreReplicated() const { - return _writesAreReplicated; - } +void OperationContextReplMock::setReplicatedWrites(bool writesAreReplicated) { + _writesAreReplicated = writesAreReplicated; +} + +bool OperationContextReplMock::writesAreReplicated() const { + return _writesAreReplicated; +} } // namespace repl } // namespace mongo |