diff options
Diffstat (limited to 'src/mongo/db/s/set_allow_migrations_coordinator.cpp')
-rw-r--r-- | src/mongo/db/s/set_allow_migrations_coordinator.cpp | 20 |
1 files changed, 3 insertions, 17 deletions
diff --git a/src/mongo/db/s/set_allow_migrations_coordinator.cpp b/src/mongo/db/s/set_allow_migrations_coordinator.cpp index 9362005a11f..d8cb15afb2e 100644 --- a/src/mongo/db/s/set_allow_migrations_coordinator.cpp +++ b/src/mongo/db/s/set_allow_migrations_coordinator.cpp @@ -64,23 +64,9 @@ void SetAllowMigrationsCoordinator::checkIfOptionsConflict(const BSONObj& doc) c otherDoc.getSetAllowMigrationsRequest().toBSON())); } -boost::optional<BSONObj> SetAllowMigrationsCoordinator::reportForCurrentOp( - MongoProcessInterface::CurrentOpConnectionsMode connMode, - MongoProcessInterface::CurrentOpSessionsMode sessionMode) noexcept { - BSONObjBuilder cmdBob; - if (const auto& optComment = getForwardableOpMetadata().getComment()) { - cmdBob.append(optComment.get().firstElement()); - } - cmdBob.appendElements(_doc.getSetAllowMigrationsRequest().toBSON()); - - BSONObjBuilder bob; - bob.append("type", "op"); - bob.append("desc", "SetAllowMigrationsCoordinator"); - bob.append("op", "command"); - bob.append("ns", nss().toString()); - bob.append("command", cmdBob.obj()); - bob.append("active", true); - return bob.obj(); +void SetAllowMigrationsCoordinator::appendCommandInfo(BSONObjBuilder* cmdInfoBuilder) const { + stdx::lock_guard lk{_docMutex}; + cmdInfoBuilder->appendElements(_doc.getSetAllowMigrationsRequest().toBSON()); } ExecutorFuture<void> SetAllowMigrationsCoordinator::_runImpl( |