diff options
| author | Lucas de Castro Borges <lucas@gnuabordo.com.br> | 2025-02-14 14:26:38 -0300 |
|---|---|---|
| committer | Lucas de Castro Borges <lucas@gnuabordo.com.br> | 2025-02-14 14:26:38 -0300 |
| commit | 294bc6ecabf14c09c9bc8644704921dcf97cb44e (patch) | |
| tree | 279b1e0bab53901a1647ac63c1c724f0f789a663 /src/mongo/db/free_mon/free_mon_storage.cpp | |
| parent | 70be7c27a251621187a1de533462ae2bb1e3bd39 (diff) | |
| parent | 1e917fd798aa25b7066d4b414b51184f13d5a092 (diff) | |
Update upstream source from tag 'upstream/6.0.10'debian/6.0.10-1
Update to upstream version '6.0.10'
with Debian dir 2d176fa254eee97b139f712fec5709641335a8c3
Diffstat (limited to 'src/mongo/db/free_mon/free_mon_storage.cpp')
| -rw-r--r-- | src/mongo/db/free_mon/free_mon_storage.cpp | 142 |
1 files changed, 0 insertions, 142 deletions
diff --git a/src/mongo/db/free_mon/free_mon_storage.cpp b/src/mongo/db/free_mon/free_mon_storage.cpp deleted file mode 100644 index 89be39295e1..00000000000 --- a/src/mongo/db/free_mon/free_mon_storage.cpp +++ /dev/null @@ -1,142 +0,0 @@ -/** - * Copyright (C) 2018-present MongoDB, Inc. - * - * This program is free software: you can redistribute it and/or modify - * it under the terms of the Server Side Public License, version 1, - * as published by MongoDB, Inc. - * - * 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 - * Server Side Public License for more details. - * - * You should have received a copy of the Server Side Public License - * along with this program. If not, see - * <http://www.mongodb.com/licensing/server-side-public-license>. - * - * 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 Server Side 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/free_mon/free_mon_storage.h" - -#include "mongo/base/status.h" -#include "mongo/base/string_data.h" -#include "mongo/bson/bsonelement.h" -#include "mongo/bson/bsonmisc.h" -#include "mongo/db/db_raii.h" -#include "mongo/db/namespace_string.h" -#include "mongo/db/operation_context.h" -#include "mongo/db/repl/replication_coordinator.h" -#include "mongo/db/repl/storage_interface.h" -#include "mongo/util/assert_util.h" - -namespace mongo { - -namespace { - -// mms-automation stores its document in local.clustermanager -static const NamespaceString localClusterManagerNss("local.clustermanager"); - -} // namespace - -constexpr StringData FreeMonStorage::kFreeMonDocIdKey; - -boost::optional<FreeMonStorageState> FreeMonStorage::read(OperationContext* opCtx) { - BSONObj deleteKey = BSON("_id" << kFreeMonDocIdKey); - BSONElement elementKey = deleteKey.firstElement(); - - auto storageInterface = repl::StorageInterface::get(opCtx); - - // Ensure we read without a timestamp. - invariant(RecoveryUnit::ReadSource::kNoTimestamp == - opCtx->recoveryUnit()->getTimestampReadSource()); - - AutoGetCollectionForRead autoRead(opCtx, NamespaceString::kServerConfigurationNamespace); - - auto swObj = storageInterface->findById( - opCtx, NamespaceString::kServerConfigurationNamespace, elementKey); - if (!swObj.isOK()) { - if (swObj.getStatus() == ErrorCodes::NoSuchKey || - swObj.getStatus() == ErrorCodes::NamespaceNotFound) { - return {}; - } - - uassertStatusOK(swObj.getStatus()); - } - - return FreeMonStorageState::parse(IDLParserErrorContext("FreeMonStorage"), swObj.getValue()); -} - -void FreeMonStorage::replace(OperationContext* opCtx, const FreeMonStorageState& doc) { - BSONObj deleteKey = BSON("_id" << kFreeMonDocIdKey); - BSONElement elementKey = deleteKey.firstElement(); - - BSONObj obj = doc.toBSON(); - - auto storageInterface = repl::StorageInterface::get(opCtx); - AutoGetCollection autoWrite(opCtx, NamespaceString::kServerConfigurationNamespace, MODE_IX); - - if (repl::ReplicationCoordinator::get(opCtx)->canAcceptWritesFor( - opCtx, NamespaceString::kServerConfigurationNamespace)) { - auto swObj = storageInterface->upsertById( - opCtx, NamespaceString::kServerConfigurationNamespace, elementKey, obj); - if (!swObj.isOK()) { - uassertStatusOK(swObj); - } - } -} - -void FreeMonStorage::deleteState(OperationContext* opCtx) { - BSONObj deleteKey = BSON("_id" << kFreeMonDocIdKey); - BSONElement elementKey = deleteKey.firstElement(); - - auto storageInterface = repl::StorageInterface::get(opCtx); - AutoGetCollection autoWrite(opCtx, NamespaceString::kServerConfigurationNamespace, MODE_IX); - - if (repl::ReplicationCoordinator::get(opCtx)->canAcceptWritesFor( - opCtx, NamespaceString::kServerConfigurationNamespace)) { - - auto swObj = storageInterface->deleteById( - opCtx, NamespaceString::kServerConfigurationNamespace, elementKey); - if (!swObj.isOK()) { - // Ignore errors about no document - if (swObj.getStatus() == ErrorCodes::NoSuchKey) { - return; - } - - uassertStatusOK(swObj); - } - } -} - -boost::optional<BSONObj> FreeMonStorage::readClusterManagerState(OperationContext* opCtx) { - auto storageInterface = repl::StorageInterface::get(opCtx); - - AutoGetCollectionForRead autoRead(opCtx, NamespaceString::kServerConfigurationNamespace); - - auto swObj = storageInterface->findSingleton(opCtx, localClusterManagerNss); - if (!swObj.isOK()) { - // Ignore errors about not-finding documents or having too many documents - if (swObj.getStatus() == ErrorCodes::NamespaceNotFound || - swObj.getStatus() == ErrorCodes::CollectionIsEmpty || - swObj.getStatus() == ErrorCodes::TooManyMatchingDocuments) { - return {}; - } - - uassertStatusOK(swObj.getStatus()); - } - - return swObj.getValue(); -} - -} // namespace mongo |
