summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_coordinator_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_impl.cpp')
-rw-r--r--src/mongo/db/repl/replication_coordinator_impl.cpp20
1 files changed, 8 insertions, 12 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl.cpp b/src/mongo/db/repl/replication_coordinator_impl.cpp
index 06fc4f3ed4f..3ce0aab069b 100644
--- a/src/mongo/db/repl/replication_coordinator_impl.cpp
+++ b/src/mongo/db/repl/replication_coordinator_impl.cpp
@@ -59,7 +59,6 @@
#include "mongo/db/repl/repl_settings.h"
#include "mongo/db/repl/replica_set_config_checks.h"
#include "mongo/db/repl/replication_executor.h"
-#include "mongo/db/repl/replication_metadata.h"
#include "mongo/db/repl/rslog.h"
#include "mongo/db/repl/topology_coordinator.h"
#include "mongo/db/repl/update_position_args.h"
@@ -1604,10 +1603,9 @@ void ReplicationCoordinatorImpl::processReplSetGetConfig(BSONObjBuilder* result)
result->append("config", _rsConfig.toBSON());
}
-void ReplicationCoordinatorImpl::processReplicationMetadata(
- const ReplicationMetadata& replMetadata) {
+void ReplicationCoordinatorImpl::processReplSetMetadata(const rpc::ReplSetMetadata& replMetadata) {
CBHStatus cbh = _replExecutor.scheduleWork(
- stdx::bind(&ReplicationCoordinatorImpl::_processReplicationMetadata_helper,
+ stdx::bind(&ReplicationCoordinatorImpl::_processReplSetMetadata_helper,
this,
stdx::placeholders::_1,
replMetadata));
@@ -1618,17 +1616,17 @@ void ReplicationCoordinatorImpl::processReplicationMetadata(
_replExecutor.wait(cbh.getValue());
}
-void ReplicationCoordinatorImpl::_processReplicationMetadata_helper(
- const ReplicationExecutor::CallbackArgs& cbData, const ReplicationMetadata& replMetadata) {
+void ReplicationCoordinatorImpl::_processReplSetMetadata_helper(
+ const ReplicationExecutor::CallbackArgs& cbData, const rpc::ReplSetMetadata& replMetadata) {
if (cbData.status == ErrorCodes::CallbackCanceled) {
return;
}
- _processReplicationMetadata_incallback(replMetadata);
+ _processReplSetMetadata_incallback(replMetadata);
}
-void ReplicationCoordinatorImpl::_processReplicationMetadata_incallback(
- const ReplicationMetadata& replMetadata) {
+void ReplicationCoordinatorImpl::_processReplSetMetadata_incallback(
+ const rpc::ReplSetMetadata& replMetadata) {
if (replMetadata.getConfigVersion() != _rsConfig.getConfigVersion()) {
return;
}
@@ -2748,7 +2746,7 @@ void ReplicationCoordinatorImpl::_processReplSetDeclareElectionWinner_finish(
void ReplicationCoordinatorImpl::prepareReplResponseMetadata(const rpc::RequestInterface& request,
BSONObjBuilder* builder) {
- if (request.getMetadata().hasField(rpc::kReplicationMetadataFieldName)) {
+ if (request.getMetadata().hasField(rpc::kReplSetMetadataFieldName)) {
rpc::ReplSetMetadata metadata;
CBHStatus cbh = _replExecutor.scheduleWork(
@@ -2764,9 +2762,7 @@ void ReplicationCoordinatorImpl::prepareReplResponseMetadata(const rpc::RequestI
fassert(28709, cbh.getStatus());
_replExecutor.wait(cbh.getValue());
- BSONObjBuilder metadataBuilder(builder->subobjStart(rpc::kReplicationMetadataFieldName));
metadata.writeToMetadata(builder);
- metadataBuilder.doneFast();
}
}