diff options
| author | Sophia Tan <sophia_tll@hotmail.com> | 2021-11-05 21:31:15 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-11-05 22:27:52 +0000 |
| commit | a67facc9efe8909f7a6de1d33fbfba5d3307bfac (patch) | |
| tree | bc9f3996da505c4498b6a39f7962de5529a01438 /src | |
| parent | 893b336353cbb74437d73763bbf0c1986d2d2e78 (diff) | |
| download | mongo-a67facc9efe8909f7a6de1d33fbfba5d3307bfac.tar.gz | |
SERVER-61174 scatterGatherVersionedTargetByRoutingTable handles TenantMigrationAborted
Diffstat (limited to 'src')
| -rw-r--r-- | src/mongo/s/cluster_commands_helpers.cpp | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/s/cluster_commands_helpers.cpp b/src/mongo/s/cluster_commands_helpers.cpp index 0b6759c211c..44241865243 100644 --- a/src/mongo/s/cluster_commands_helpers.cpp +++ b/src/mongo/s/cluster_commands_helpers.cpp @@ -223,6 +223,13 @@ std::vector<AsyncRequestsSender::Response> gatherResponsesImpl( if (ErrorCodes::CommandOnShardedViewNotSupportedOnMongod == status) { uassertStatusOK(status); } + + if (ErrorCodes::TenantMigrationAborted == status) { + uassertStatusOK(status.withContext( + str::stream() << "got TenantMigrationAborted response from shard " + << response.shardId << " at host " + << response.shardHostAndPort->toString())); + } } responses.push_back(std::move(response)); } |