summaryrefslogtreecommitdiff
path: root/src/mongo/s/request_types
diff options
context:
space:
mode:
authorPaolo Polato <paolo.polato@mongodb.com>2022-02-03 10:10:59 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-02-03 10:40:08 +0000
commitca8259ffef3ec2947ce6a5761f6c433e0e0c4663 (patch)
treeaeecc91348c8339fff088ac4df4e80c76c0da246 /src/mongo/s/request_types
parentec97c7f137a73faa8579c5616e364b86e6cf56c8 (diff)
downloadmongo-ca8259ffef3ec2947ce6a5761f6c433e0e0c4663.tar.gz
SERVER-63168 remove hidden parameter from moveChunk command
Diffstat (limited to 'src/mongo/s/request_types')
-rw-r--r--src/mongo/s/request_types/balance_chunk_request_type.cpp14
-rw-r--r--src/mongo/s/request_types/balance_chunk_request_type.h9
2 files changed, 0 insertions, 23 deletions
diff --git a/src/mongo/s/request_types/balance_chunk_request_type.cpp b/src/mongo/s/request_types/balance_chunk_request_type.cpp
index 0223a94f782..6ab71252633 100644
--- a/src/mongo/s/request_types/balance_chunk_request_type.cpp
+++ b/src/mongo/s/request_types/balance_chunk_request_type.cpp
@@ -41,7 +41,6 @@ namespace {
const char kConfigSvrMoveChunk[] = "_configsvrMoveChunk";
const char kNS[] = "ns";
-const char kMaxChunkSizeBytes[] = "maxChunkSizeBytes";
const char kToShardId[] = "toShard";
const char kSecondaryThrottle[] = "secondaryThrottle";
const char kWaitForDelete[] = "waitForDelete";
@@ -120,17 +119,6 @@ StatusWith<BalanceChunkRequest> BalanceChunkRequest::parseFromConfigCommand(cons
}
{
- long long maxChunkSizeBytes;
- Status status =
- bsonExtractIntegerFieldWithDefault(obj, kMaxChunkSizeBytes, 0, &maxChunkSizeBytes);
- if (!status.isOK()) {
- return status;
- }
-
- request._maxChunkSizeBytes = static_cast<int64_t>(maxChunkSizeBytes);
- }
-
- {
std::string toShardId;
Status status = bsonExtractStringField(obj, kToShardId, &toShardId);
if (status.isOK()) {
@@ -159,7 +147,6 @@ BSONObj BalanceChunkRequest::serializeToMoveCommandForConfig(
const NamespaceString& nss,
const ChunkType& chunk,
const ShardId& newShardId,
- int64_t maxChunkSizeBytes,
const MigrationSecondaryThrottleOptions& secondaryThrottle,
bool waitForDelete,
bool forceJumbo) {
@@ -173,7 +160,6 @@ BSONObj BalanceChunkRequest::serializeToMoveCommandForConfig(
cmdBuilder.append(ChunkType::lastmod() + "Epoch", chunk.getVersion().epoch());
cmdBuilder.append(ChunkType::lastmod() + "Timestamp", chunk.getVersion().getTimestamp());
cmdBuilder.append(kToShardId, newShardId.toString());
- cmdBuilder.append(kMaxChunkSizeBytes, static_cast<long long>(maxChunkSizeBytes));
{
BSONObjBuilder secondaryThrottleBuilder(cmdBuilder.subobjStart(kSecondaryThrottle));
secondaryThrottle.append(&secondaryThrottleBuilder);
diff --git a/src/mongo/s/request_types/balance_chunk_request_type.h b/src/mongo/s/request_types/balance_chunk_request_type.h
index 77d4e99afce..04c513c70de 100644
--- a/src/mongo/s/request_types/balance_chunk_request_type.h
+++ b/src/mongo/s/request_types/balance_chunk_request_type.h
@@ -65,7 +65,6 @@ public:
const NamespaceString& nss,
const ChunkType& chunk,
const ShardId& newShardId,
- int64_t maxChunkSizeBytes,
const MigrationSecondaryThrottleOptions& secondaryThrottle,
bool waitForDelete,
bool forceJumbo);
@@ -100,10 +99,6 @@ public:
return *_toShardId;
}
- int64_t getMaxChunkSizeBytes() const {
- return _maxChunkSizeBytes;
- }
-
const MigrationSecondaryThrottleOptions& getSecondaryThrottle() const {
return _secondaryThrottle;
}
@@ -127,10 +122,6 @@ private:
// Id of the shard to which it should be moved (if specified)
boost::optional<ShardId> _toShardId;
- // This value is used by the migration source to determine the data size threshold above which a
- // chunk would be considered jumbo and migrations will not proceed.
- int64_t _maxChunkSizeBytes;
-
// The parsed secondary throttle options
MigrationSecondaryThrottleOptions _secondaryThrottle;