summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/operation_context_repl_mock.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/operation_context_repl_mock.cpp')
-rw-r--r--src/mongo/db/repl/operation_context_repl_mock.cpp68
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