summaryrefslogtreecommitdiff
path: root/src/mongo/s/config_server_client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/s/config_server_client.cpp')
-rw-r--r--src/mongo/s/config_server_client.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/s/config_server_client.cpp b/src/mongo/s/config_server_client.cpp
index d3dd7f88dea..bf290d58199 100644
--- a/src/mongo/s/config_server_client.cpp
+++ b/src/mongo/s/config_server_client.cpp
@@ -43,16 +43,16 @@ const ReadPreferenceSetting kPrimaryOnlyReadPreference{ReadPreference::PrimaryOn
} // namespace
-Status moveChunk(OperationContext* txn,
+Status moveChunk(OperationContext* opCtx,
const ChunkType& chunk,
const ShardId& newShardId,
int64_t maxChunkSizeBytes,
const MigrationSecondaryThrottleOptions& secondaryThrottle,
bool waitForDelete) {
- auto shardRegistry = Grid::get(txn)->shardRegistry();
+ auto shardRegistry = Grid::get(opCtx)->shardRegistry();
auto shard = shardRegistry->getConfigShard();
auto cmdResponseStatus = shard->runCommand(
- txn,
+ opCtx,
kPrimaryOnlyReadPreference,
"admin",
BalanceChunkRequest::serializeToMoveCommandForConfig(
@@ -65,11 +65,11 @@ Status moveChunk(OperationContext* txn,
return cmdResponseStatus.getValue().commandStatus;
}
-Status rebalanceChunk(OperationContext* txn, const ChunkType& chunk) {
- auto shardRegistry = Grid::get(txn)->shardRegistry();
+Status rebalanceChunk(OperationContext* opCtx, const ChunkType& chunk) {
+ auto shardRegistry = Grid::get(opCtx)->shardRegistry();
auto shard = shardRegistry->getConfigShard();
auto cmdResponseStatus = shard->runCommandWithFixedRetryAttempts(
- txn,
+ opCtx,
kPrimaryOnlyReadPreference,
"admin",
BalanceChunkRequest::serializeToRebalanceCommandForConfig(chunk),