summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/repl_coordinator_impl_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/repl_coordinator_impl_test.cpp')
-rw-r--r--src/mongo/db/repl/repl_coordinator_impl_test.cpp42
1 files changed, 25 insertions, 17 deletions
diff --git a/src/mongo/db/repl/repl_coordinator_impl_test.cpp b/src/mongo/db/repl/repl_coordinator_impl_test.cpp
index a7109982678..9a39426d504 100644
--- a/src/mongo/db/repl/repl_coordinator_impl_test.cpp
+++ b/src/mongo/db/repl/repl_coordinator_impl_test.cpp
@@ -46,13 +46,17 @@ namespace repl {
namespace {
TEST(ReplicationCoordinator, StartupShutdown) {
- ReplicationCoordinatorImpl coordinator;
+ ReplSettings settings;
+ // Make sure we think we're a replSet
+ settings.replSet = "mySet/node1:12345,node2:54321";
+ ReplicationCoordinatorImpl coordinator(settings);
coordinator.startReplication(new TopologyCoordinatorMock, new NetworkInterfaceMock);
coordinator.shutdown();
}
TEST(ReplicationCoordinator, AwaitReplicationNumberBaseCases) {
- ReplicationCoordinatorImpl coordinator;
+ ReplSettings settings;
+ ReplicationCoordinatorImpl coordinator(settings);
OperationContextNoop txn;
OpTime time(1, 1);
@@ -60,14 +64,14 @@ namespace {
writeConcern.wTimeout = WriteConcernOptions::kNoWaiting;
writeConcern.wNumNodes = 2;
- // Because we didn't set replSettings.replSet, it will think we're a standalone so
+ // Because we didn't set ReplSettings.replSet, it will think we're a standalone so
// awaitReplication will always work.
ReplicationCoordinator::StatusAndDuration statusAndDur = coordinator.awaitReplication(
&txn, time, writeConcern);
ASSERT_OK(statusAndDur.status);
// Now make us a master in master/slave
- replSettings.master = true;
+ coordinator.getSettings().master = true;
writeConcern.wNumNodes = 0;
writeConcern.wMode = "majority";
@@ -76,7 +80,7 @@ namespace {
ASSERT_OK(statusAndDur.status);
// Now make us a replica set
- replSettings.replSet = "mySet/node1:12345,node2:54321";
+ coordinator.getSettings().replSet = "mySet/node1:12345,node2:54321";
// Waiting for 1 nodes always works
writeConcern.wNumNodes = 1;
@@ -86,10 +90,11 @@ namespace {
}
TEST(ReplicationCoordinator, AwaitReplicationNumberOfNodesNonBlocking) {
- ReplicationCoordinatorImpl coordinator;
- OperationContextNoop txn;
+ ReplSettings settings;
// Make sure we think we're a replSet
- replSettings.replSet = "mySet/node1:12345,node2:54321";
+ settings.replSet = "mySet/node1:12345,node2:54321";
+ ReplicationCoordinatorImpl coordinator(settings);
+ OperationContextNoop txn;
OID client1 = OID::gen();
OID client2 = OID::gen();
@@ -192,11 +197,12 @@ namespace {
};
TEST(ReplicationCoordinator, AwaitReplicationNumberOfNodesBlocking) {
- ReplicationCoordinatorImpl coordinator;
+ ReplSettings settings;
+ // Make sure we think we're a replSet
+ settings.replSet = "mySet/node1:12345,node2:54321";
+ ReplicationCoordinatorImpl coordinator(settings);
OperationContextNoop txn;
ReplicationAwaiter awaiter(&coordinator, &txn);
- // Make sure we think we're a replSet
- replSettings.replSet = "mySet/node1:12345,node2:54321";
OID client1 = OID::gen();
OID client2 = OID::gen();
@@ -238,11 +244,12 @@ namespace {
}
TEST(ReplicationCoordinator, AwaitReplicationTimeout) {
- ReplicationCoordinatorImpl coordinator;
+ ReplSettings settings;
+ // Make sure we think we're a replSet
+ settings.replSet = "mySet/node1:12345,node2:54321";
+ ReplicationCoordinatorImpl coordinator(settings);
OperationContextNoop txn;
ReplicationAwaiter awaiter(&coordinator, &txn);
- // Make sure we think we're a replSet
- replSettings.replSet = "mySet/node1:12345,node2:54321";
OID client1 = OID::gen();
OID client2 = OID::gen();
@@ -265,12 +272,13 @@ namespace {
}
TEST(ReplicationCoordinator, AwaitReplicationShutdown) {
- ReplicationCoordinatorImpl coordinator;
+ ReplSettings settings;
+ // Make sure we think we're a replSet
+ settings.replSet = "mySet/node1:12345,node2:54321";
+ ReplicationCoordinatorImpl coordinator(settings);
coordinator.startReplication(new TopologyCoordinatorMock, new NetworkInterfaceMock);
OperationContextNoop txn;
ReplicationAwaiter awaiter(&coordinator, &txn);
- // Make sure we think we're a replSet
- replSettings.replSet = "mySet/node1:12345,node2:54321";
OID client1 = OID::gen();
OID client2 = OID::gen();