diff options
author | Paolo Polato <paolo.polato@mongodb.com> | 2022-02-03 10:10:59 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-02-03 10:40:08 +0000 |
commit | ca8259ffef3ec2947ce6a5761f6c433e0e0c4663 (patch) | |
tree | aeecc91348c8339fff088ac4df4e80c76c0da246 /src/mongo/s/request_types | |
parent | ec97c7f137a73faa8579c5616e364b86e6cf56c8 (diff) | |
download | mongo-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.cpp | 14 | ||||
-rw-r--r-- | src/mongo/s/request_types/balance_chunk_request_type.h | 9 |
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; |