summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_executor_test_fixture.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/replication_executor_test_fixture.cpp')
-rw-r--r--src/mongo/db/repl/replication_executor_test_fixture.cpp65
1 files changed, 32 insertions, 33 deletions
diff --git a/src/mongo/db/repl/replication_executor_test_fixture.cpp b/src/mongo/db/repl/replication_executor_test_fixture.cpp
index bcd07d0db68..6172ca01a33 100644
--- a/src/mongo/db/repl/replication_executor_test_fixture.cpp
+++ b/src/mongo/db/repl/replication_executor_test_fixture.cpp
@@ -39,47 +39,46 @@ namespace repl {
namespace {
- const int64_t prngSeed = 1;
+const int64_t prngSeed = 1;
-} // namespace
+} // namespace
- // static
- Status ReplicationExecutorTest::getDetectableErrorStatus() {
- return Status(ErrorCodes::InternalError, "Not mutated");
- }
+// static
+Status ReplicationExecutorTest::getDetectableErrorStatus() {
+ return Status(ErrorCodes::InternalError, "Not mutated");
+}
- void ReplicationExecutorTest::launchExecutorThread() {
- ASSERT(!_executorThread);
- _executorThread.reset(
- new stdx::thread(stdx::bind(&ReplicationExecutor::run, _executor.get())));
- postExecutorThreadLaunch();
- }
+void ReplicationExecutorTest::launchExecutorThread() {
+ ASSERT(!_executorThread);
+ _executorThread.reset(new stdx::thread(stdx::bind(&ReplicationExecutor::run, _executor.get())));
+ postExecutorThreadLaunch();
+}
- void ReplicationExecutorTest::postExecutorThreadLaunch() {
- _net->enterNetwork();
- }
+void ReplicationExecutorTest::postExecutorThreadLaunch() {
+ _net->enterNetwork();
+}
- void ReplicationExecutorTest::joinExecutorThread() {
- ASSERT(_executorThread);
- getNet()->exitNetwork();
- _executorThread->join();
- _executorThread.reset();
- }
+void ReplicationExecutorTest::joinExecutorThread() {
+ ASSERT(_executorThread);
+ getNet()->exitNetwork();
+ _executorThread->join();
+ _executorThread.reset();
+}
- void ReplicationExecutorTest::setUp() {
- _net = new executor::NetworkInterfaceMock;
- _storage = new StorageInterfaceMock;
- _executor.reset(new ReplicationExecutor(_net, _storage, prngSeed));
- }
+void ReplicationExecutorTest::setUp() {
+ _net = new executor::NetworkInterfaceMock;
+ _storage = new StorageInterfaceMock;
+ _executor.reset(new ReplicationExecutor(_net, _storage, prngSeed));
+}
- void ReplicationExecutorTest::tearDown() {
- if (_executorThread) {
- _executor->shutdown();
- joinExecutorThread();
- }
- _executor.reset();
- _net = nullptr;
+void ReplicationExecutorTest::tearDown() {
+ if (_executorThread) {
+ _executor->shutdown();
+ joinExecutorThread();
}
+ _executor.reset();
+ _net = nullptr;
+}
} // namespace repl
} // namespace mongo