diff --git a/src/mongo/db/commands/get_last_error.cpp b/src/mongo/db/commands/get_last_error.cpp index 1834aa60e6..08ce26a129 100644 --- a/src/mongo/db/commands/get_last_error.cpp +++ b/src/mongo/db/commands/get_last_error.cpp @@ -141,6 +141,8 @@ public: // err is null. // + log() << "~~~getLastError, start"; + LastError* le = &LastError::get(opCtx->getClient()); le->disable(); @@ -291,6 +293,8 @@ public: return true; } + log() << "~~~getLastError, end"; + return CommandHelpers::appendCommandStatusNoThrow(result, status); } diff --git a/src/mongo/db/commands/server_status.cpp b/src/mongo/db/commands/server_status.cpp index 75b5f7fe9e..e690ae71e8 100644 --- a/src/mongo/db/commands/server_status.cpp +++ b/src/mongo/db/commands/server_status.cpp @@ -81,6 +81,8 @@ public: const string& dbname, const BSONObj& cmdObj, BSONObjBuilder& result) { + log() << "~~~serverStatus, start"; + _runCalled = true; const auto service = opCtx->getServiceContext(); @@ -110,6 +112,8 @@ public: for (SectionMap::const_iterator i = _sections.begin(); i != _sections.end(); ++i) { ServerStatusSection* section = i->second; + log() << "~~~serverStatus, section: " << section->getSectionName() << ", start"; + std::vector requiredPrivileges; section->addRequiredPrivileges(&requiredPrivileges); if (!authSession->isAuthorizedForPrivileges(requiredPrivileges)) @@ -129,7 +133,8 @@ public: timeBuilder.appendNumber( static_cast(str::stream() << "after " << section->getSectionName()), durationCount(clock->now() - runStart)); - } + log() << "~~~serverStatus, section: " << section->getSectionName() << ", end"; + } // --- counters bool includeMetricTree = MetricTree::theMetricTree != NULL; @@ -170,6 +175,8 @@ public: } } + log() << "~~~serverStatus, end"; + return true; } diff --git a/src/mongo/db/concurrency/lock_state.cpp b/src/mongo/db/concurrency/lock_state.cpp index 8252ee0781..4a15480288 100644 --- a/src/mongo/db/concurrency/lock_state.cpp +++ b/src/mongo/db/concurrency/lock_state.cpp @@ -815,6 +815,8 @@ void LockerImpl::restoreLockState(OperationContext* opCtx, const Locker::LockSna LockResult LockerImpl::lockBegin(OperationContext* opCtx, ResourceId resId, LockMode mode) { dassert(!getWaitingResource().isValid()); + log() << "~~~lockBegin, hit for lock"; + LockRequest* request; bool isNew = true; diff --git a/src/mongo/db/repl/repl_set_get_status_cmd.cpp b/src/mongo/db/repl/repl_set_get_status_cmd.cpp index 4fcd45073f..b9a827d94e 100644 --- a/src/mongo/db/repl/repl_set_get_status_cmd.cpp +++ b/src/mongo/db/repl/repl_set_get_status_cmd.cpp @@ -27,10 +27,13 @@ * it in the license file. */ +#define MONGO_LOG_DEFAULT_COMPONENT ::mongo::logger::LogComponent::kReplication + #include "mongo/bson/util/bson_extract.h" #include "mongo/db/lasterror.h" #include "mongo/db/repl/repl_set_command.h" #include "mongo/db/repl/replication_coordinator.h" +#include "mongo/util/log.h" namespace mongo { namespace repl { @@ -49,6 +52,8 @@ public: const std::string&, const BSONObj& cmdObj, BSONObjBuilder& result) override { + log() << "~~~replSetGetStatus, start"; + if (cmdObj["forShell"].trueValue()) LastError::get(opCtx->getClient()).disable(); @@ -67,6 +72,9 @@ public: status = ReplicationCoordinator::get(opCtx)->processReplSetGetStatus(&result, responseStyle); uassertStatusOK(status); + + log() << "~~~replSetGetStatus, end"; + return true; } diff --git a/src/mongo/db/repl/replication_info.cpp b/src/mongo/db/repl/replication_info.cpp index 40c1499ef6..6dc9c0ad92 100644 --- a/src/mongo/db/repl/replication_info.cpp +++ b/src/mongo/db/repl/replication_info.cpp @@ -239,6 +239,9 @@ public: const string&, const BSONObj& cmdObj, BSONObjBuilder& result) final { + + log() << "~~~isMaster, start"; + CommandHelpers::handleMarkKillOnClientDisconnect(opCtx); // TODO Unwind after SERVER-41070 @@ -400,6 +403,8 @@ public: auto& saslMechanismRegistry = SASLServerMechanismRegistry::get(opCtx->getServiceContext()); saslMechanismRegistry.advertiseMechanismNamesForUser(opCtx, cmdObj, &result); + log() << "~~~isMaster, end"; + return true; } } cmdismaster;