summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_executor_test.cpp
diff options
context:
space:
mode:
authorKaloian Manassiev <kaloian.manassiev@mongodb.com>2015-05-07 11:35:33 -0400
committerKaloian Manassiev <kaloian.manassiev@mongodb.com>2015-05-10 22:03:40 -0400
commite06508fe119710ca06ee06504e0a33163af0708f (patch)
tree0712d33d484bfeafeb779de7eaa7b2f8b22aaaea /src/mongo/db/repl/replication_executor_test.cpp
parent69bfdbc80fd2e66a6eb8cd1fbd4503537c97d7fc (diff)
downloadmongo-e06508fe119710ca06ee06504e0a33163af0708f.tar.gz
SERVER-18353 Move the remote command executor to a separate library
Diffstat (limited to 'src/mongo/db/repl/replication_executor_test.cpp')
-rw-r--r--src/mongo/db/repl/replication_executor_test.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/mongo/db/repl/replication_executor_test.cpp b/src/mongo/db/repl/replication_executor_test.cpp
index f5ec39f3f8e..5b1c62ea13d 100644
--- a/src/mongo/db/repl/replication_executor_test.cpp
+++ b/src/mongo/db/repl/replication_executor_test.cpp
@@ -48,15 +48,15 @@ namespace repl {
namespace {
- bool operator==(const ReplicationExecutor::RemoteCommandRequest lhs,
- const ReplicationExecutor::RemoteCommandRequest rhs) {
+ bool operator==(const RemoteCommandRequest lhs,
+ const RemoteCommandRequest rhs) {
return lhs.target == rhs.target &&
lhs.dbname == rhs.dbname &&
lhs.cmdObj == rhs.cmdObj;
}
- bool operator!=(const ReplicationExecutor::RemoteCommandRequest lhs,
- const ReplicationExecutor::RemoteCommandRequest rhs) {
+ bool operator!=(const RemoteCommandRequest lhs,
+ const RemoteCommandRequest rhs) {
return !(lhs == rhs);
}
@@ -309,14 +309,14 @@ namespace {
ASSERT_EQUALS(status3, ErrorCodes::CallbackCanceled);
}
- std::string getRequestDescription(const ReplicationExecutor::RemoteCommandRequest& request) {
+ std::string getRequestDescription(const RemoteCommandRequest& request) {
return mongoutils::str::stream() << "Request(" << request.target.toString() << ", " <<
request.dbname << ", " << request.cmdObj << ')';
}
static void setStatusOnRemoteCommandCompletion(
const ReplicationExecutor::RemoteCommandCallbackData& cbData,
- const ReplicationExecutor::RemoteCommandRequest& expectedRequest,
+ const RemoteCommandRequest& expectedRequest,
Status* outStatus) {
if (cbData.request != expectedRequest) {
@@ -335,7 +335,7 @@ namespace {
ReplicationExecutor& executor = getExecutor();
launchExecutorThread();
Status status1(ErrorCodes::InternalError, "Not mutated");
- const ReplicationExecutor::RemoteCommandRequest request(
+ const RemoteCommandRequest request(
HostAndPort("localhost", 27017),
"mydb",
BSON("whatsUp" << "doc"));
@@ -362,7 +362,7 @@ namespace {
TEST_F(ReplicationExecutorTest, ScheduleAndCancelRemoteCommand) {
ReplicationExecutor& executor = getExecutor();
Status status1(ErrorCodes::InternalError, "Not mutated");
- const ReplicationExecutor::RemoteCommandRequest request(
+ const RemoteCommandRequest request(
HostAndPort("localhost", 27017),
"mydb",
BSON("whatsUp" << "doc"));
@@ -453,7 +453,7 @@ namespace {
ReplicationExecutor& executor = getExecutor();
Status status(ErrorCodes::InternalError, "");
launchExecutorThread();
- const ReplicationExecutor::RemoteCommandRequest request(
+ const RemoteCommandRequest request(
HostAndPort("lazy", 27017),
"admin",
BSON("sleep" << 1),
@@ -480,7 +480,7 @@ namespace {
TEST_F(ReplicationExecutorTest, CallbackHandleComparison) {
ReplicationExecutor& executor = getExecutor();
Status status(ErrorCodes::InternalError, "");
- const ReplicationExecutor::RemoteCommandRequest request(
+ const RemoteCommandRequest request(
HostAndPort("lazy", 27017),
"admin",
BSON("cmd" << 1));