diff options
| -rw-r--r-- | src/mongo/db/s/collmod_coordinator.cpp | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/src/mongo/db/s/collmod_coordinator.cpp b/src/mongo/db/s/collmod_coordinator.cpp index ecd23800b69..3ec0db50ec5 100644 --- a/src/mongo/db/s/collmod_coordinator.cpp +++ b/src/mongo/db/s/collmod_coordinator.cpp @@ -208,9 +208,10 @@ ExecutorFuture<void> CollModCoordinator::_runImpl( _saveCollectionInfoOnCoordinatorIfNecessary(opCtx); if (_collInfo->isSharded) { - _doc.setCollUUID( - sharding_ddl_util::getCollectionUUID(opCtx, nss(), true /* allowViews */)); - sharding_ddl_util::stopMigrations(opCtx, nss(), _doc.getCollUUID()); + _doc.setCollUUID(sharding_ddl_util::getCollectionUUID( + opCtx, _collInfo->nsForTargeting, true /* allowViews */)); + sharding_ddl_util::stopMigrations( + opCtx, _collInfo->nsForTargeting, _doc.getCollUUID()); } _saveShardingInfoOnCoordinatorIfNecessary(opCtx); @@ -309,7 +310,8 @@ ExecutorFuture<void> CollModCoordinator::_runImpl( CommandHelpers::appendSimpleCommandStatus(builder, ok, errmsg); } _result = builder.obj(); - sharding_ddl_util::resumeMigrations(opCtx, nss(), _doc.getCollUUID()); + sharding_ddl_util::resumeMigrations( + opCtx, _collInfo->nsForTargeting, _doc.getCollUUID()); } else { CollMod cmd(nss()); cmd.setCollModRequest(_request); @@ -344,7 +346,8 @@ ExecutorFuture<void> CollModCoordinator::_runImpl( auto* opCtx = opCtxHolder.get(); getForwardableOpMetadata().setOn(opCtx); - sharding_ddl_util::resumeMigrations(opCtx, nss(), _doc.getCollUUID()); + sharding_ddl_util::resumeMigrations( + opCtx, _collInfo->nsForTargeting, _doc.getCollUUID()); } } return status; |