summaryrefslogtreecommitdiff
path: root/src/mongo/db/s
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2015-08-19 15:48:17 -0400
committerRandolph Tan <randolph@10gen.com>2015-08-28 10:42:48 -0400
commit71e4682f00f160488df4aaeb47be7c0ab476c3aa (patch)
tree91bcbf908893371f92a7a927e4b56c5765df764e /src/mongo/db/s
parentf5a31bb5a1e835eb4248bca1a7d61ae76850ca3c (diff)
downloadmongo-71e4682f00f160488df4aaeb47be7c0ab476c3aa.tar.gz
SERVER-19903 Dist lock pinger not running for config RS
Diffstat (limited to 'src/mongo/db/s')
-rw-r--r--src/mongo/db/s/merge_chunks_command.cpp2
-rw-r--r--src/mongo/db/s/set_shard_version_command.cpp2
-rw-r--r--src/mongo/db/s/sharding_state.cpp4
-rw-r--r--src/mongo/db/s/sharding_state.h2
4 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/db/s/merge_chunks_command.cpp b/src/mongo/db/s/merge_chunks_command.cpp
index 58fc9c71ac3..813be2a8aa7 100644
--- a/src/mongo/db/s/merge_chunks_command.cpp
+++ b/src/mongo/db/s/merge_chunks_command.cpp
@@ -152,7 +152,7 @@ public:
return false;
}
- shardingState->initialize(config);
+ shardingState->initialize(txn, config);
}
// ShardName is optional, but might not be set yet
diff --git a/src/mongo/db/s/set_shard_version_command.cpp b/src/mongo/db/s/set_shard_version_command.cpp
index 03b96373844..6febcbaffa2 100644
--- a/src/mongo/db/s/set_shard_version_command.cpp
+++ b/src/mongo/db/s/set_shard_version_command.cpp
@@ -328,7 +328,7 @@ private:
}
if (locked) {
- ShardingState::get(txn)->initialize(configdb);
+ ShardingState::get(txn)->initialize(txn, configdb);
return true;
}
diff --git a/src/mongo/db/s/sharding_state.cpp b/src/mongo/db/s/sharding_state.cpp
index 90b1a83af2a..1013fddd32e 100644
--- a/src/mongo/db/s/sharding_state.cpp
+++ b/src/mongo/db/s/sharding_state.cpp
@@ -140,7 +140,7 @@ string ShardingState::getShardName() {
return _shardName;
}
-void ShardingState::initialize(const string& server) {
+void ShardingState::initialize(OperationContext* txn, const string& server) {
uassert(18509,
"Unable to obtain host name during sharding initialization.",
!getHostName().empty());
@@ -156,7 +156,7 @@ void ShardingState::initialize(const string& server) {
ShardedConnectionInfo::addHook();
ConnectionString configServerCS = uassertStatusOK(ConnectionString::parse(server));
- uassertStatusOK(initializeGlobalShardingState(configServerCS));
+ uassertStatusOK(initializeGlobalShardingState(txn, configServerCS, false));
_enabled = true;
}
diff --git a/src/mongo/db/s/sharding_state.h b/src/mongo/db/s/sharding_state.h
index 0f7168355d8..b794a31df5d 100644
--- a/src/mongo/db/s/sharding_state.h
+++ b/src/mongo/db/s/sharding_state.h
@@ -88,7 +88,7 @@ public:
// Initialize sharding state and begin authenticating outgoing connections and handling
// shard versions. If this is not run before sharded operations occur auth will not work
// and versions will not be tracked.
- void initialize(const std::string& server);
+ void initialize(OperationContext* txn, const std::string& server);
// TODO: The only reason we need this method and cannot merge it together with the initialize
// call is the setShardVersion request being sent by the config coordinator to the config server