/** * Copyright (C) 2015 MongoDB Inc. * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License, version 3, * as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * * As a special exception, the copyright holders give permission to link the * code of portions of this program with the OpenSSL library under certain * conditions as described in each individual source file and distribute * linked combinations including the program with the OpenSSL library. You * must comply with the GNU Affero General Public License in all respects for * all of the code used other than as permitted herein. If you modify file(s) * with this exception, you may extend this exception to your version of the * file(s), but you are not obligated to do so. If you do not wish to do so, * delete this exception statement from your version. If you delete this * exception statement from all source files in the program, then also delete * it in the license file. */ #include "mongo/db/stats/fill_locker_info.h" #include #include "mongo/db/concurrency/locker.h" #include "mongo/db/jsobj.h" namespace mongo { void fillLockerInfo(const Locker::LockerInfo& lockerInfo, BSONObjBuilder& infoBuilder) { // "locks" section BSONObjBuilder locks(infoBuilder.subobjStart("locks")); const size_t locksSize = lockerInfo.locks.size(); // Only add the last lock of each type, and use the largest mode encountered LockMode modeForType[ResourceTypesCount] = {}; // default initialize to zero (min value) for (size_t i = 0; i < locksSize; i++) { const Locker::OneLock& lock = lockerInfo.locks[i]; const ResourceType lockType = lock.resourceId.getType(); const LockMode lockMode = std::max(lock.mode, modeForType[lockType]); // Check that lockerInfo is sorted on resource type invariant(i == 0 || lockType >= lockerInfo.locks[i - 1].resourceId.getType()); if (lock.resourceId == resourceIdLocalDB) { locks.append("local", legacyModeName(lock.mode)); continue; } modeForType[lockType] = lockMode; if (i + 1 < locksSize && lockerInfo.locks[i + 1].resourceId.getType() == lockType) { continue; // skip this lock as it is not the last one of its type } else { locks.append(resourceTypeName(lockType), legacyModeName(lockMode)); } } locks.done(); // "waitingForLock" section infoBuilder.append("waitingForLock", lockerInfo.waitingResource.isValid()); // "lockStats" section { BSONObjBuilder lockStats(infoBuilder.subobjStart("lockStats")); lockerInfo.stats.report(&lockStats); lockStats.done(); } } } // namespace mongo