summaryrefslogtreecommitdiff
path: root/src/mongo/db/storage/storage_engine_init.cpp
diff options
context:
space:
mode:
authorLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-11 15:07:35 -0300
committerLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-11 15:07:35 -0300
commit4cb8841196d0625dfa3825aa326f071cd27c7b8b (patch)
tree1682a647d4463397c119183369ae6f750d5fdcff /src/mongo/db/storage/storage_engine_init.cpp
parentaa03c6362cbaa767638e6eed9b031d86dd2643d1 (diff)
parent8f0827553e09872941945a093b647a4211a9db7f (diff)
Update upstream source from tag 'upstream/6.0.0'master
Update to upstream version '6.0.0' with Debian dir 5604a80ec1c96ca76f25f40d78e6ef855abec322
Diffstat (limited to 'src/mongo/db/storage/storage_engine_init.cpp')
-rw-r--r--src/mongo/db/storage/storage_engine_init.cpp51
1 files changed, 13 insertions, 38 deletions
diff --git a/src/mongo/db/storage/storage_engine_init.cpp b/src/mongo/db/storage/storage_engine_init.cpp
index f16cb0e3c2d..7c345ddcfe6 100644
--- a/src/mongo/db/storage/storage_engine_init.cpp
+++ b/src/mongo/db/storage/storage_engine_init.cpp
@@ -39,7 +39,6 @@
#include "mongo/base/init.h"
#include "mongo/bson/bsonobjbuilder.h"
#include "mongo/db/concurrency/lock_state.h"
-#include "mongo/db/exec/scoped_timer.h"
#include "mongo/db/operation_context.h"
#include "mongo/db/storage/control/storage_control.h"
#include "mongo/db/storage/recovery_unit_noop.h"
@@ -66,10 +65,8 @@ namespace {
void createLockFile(ServiceContext* service);
} // namespace
-StorageEngine::LastShutdownState initializeStorageEngine(
- OperationContext* opCtx,
- const StorageEngineInitFlags initFlags,
- BSONObjBuilder* startupTimeElapsedBuilder) {
+StorageEngine::LastShutdownState initializeStorageEngine(OperationContext* opCtx,
+ const StorageEngineInitFlags initFlags) {
ServiceContext* service = opCtx->getServiceContext();
if (storageGlobalParams.restore) {
@@ -83,10 +80,6 @@ StorageEngine::LastShutdownState initializeStorageEngine(
invariant(!service->getStorageEngine());
if ((initFlags & StorageEngineInitFlags::kAllowNoLockFile) == StorageEngineInitFlags{}) {
- auto scopedTimer = createTimeElapsedBuilderScopedTimer(
- service->getFastClockSource(),
- "Create storage engine lock file in the data directory",
- startupTimeElapsedBuilder);
createLockFile(service);
}
@@ -151,10 +144,6 @@ StorageEngine::LastShutdownState initializeStorageEngine(
std::unique_ptr<StorageEngineMetadata> metadata;
if ((initFlags & StorageEngineInitFlags::kSkipMetadataFile) == StorageEngineInitFlags{}) {
- auto scopedTimer =
- createTimeElapsedBuilderScopedTimer(service->getFastClockSource(),
- "Get metadata describing storage engine",
- startupTimeElapsedBuilder);
metadata = StorageEngineMetadata::forPath(dbpath);
}
@@ -167,10 +156,6 @@ StorageEngine::LastShutdownState initializeStorageEngine(
// Validate options in metadata against current startup options.
if (metadata.get()) {
- auto scopedTimer = createTimeElapsedBuilderScopedTimer(
- service->getFastClockSource(),
- "Validate options in metadata against current startup options",
- startupTimeElapsedBuilder);
uassertStatusOK(factory->validateMetadata(*metadata, storageGlobalParams));
}
@@ -216,26 +201,20 @@ StorageEngine::LastShutdownState initializeStorageEngine(
});
auto& lockFile = StorageEngineLockFile::get(service);
- {
- auto scopedTimer = createTimeElapsedBuilderScopedTimer(
- service->getFastClockSource(), "Create storage engine", startupTimeElapsedBuilder);
- if ((initFlags & StorageEngineInitFlags::kForRestart) == StorageEngineInitFlags{}) {
- auto storageEngine = std::unique_ptr<StorageEngine>(
- factory->create(opCtx, storageGlobalParams, lockFile ? &*lockFile : nullptr));
- service->setStorageEngine(std::move(storageEngine));
- } else {
- auto storageEngineChangeContext = StorageEngineChangeContext::get(service);
- auto token = storageEngineChangeContext->killOpsForStorageEngineChange(service);
- auto storageEngine = std::unique_ptr<StorageEngine>(
- factory->create(opCtx, storageGlobalParams, lockFile ? &*lockFile : nullptr));
- storageEngineChangeContext->changeStorageEngine(
- service, std::move(token), std::move(storageEngine));
- }
+ if ((initFlags & StorageEngineInitFlags::kForRestart) == StorageEngineInitFlags{}) {
+ auto storageEngine = std::unique_ptr<StorageEngine>(
+ factory->create(opCtx, storageGlobalParams, lockFile ? &*lockFile : nullptr));
+ service->setStorageEngine(std::move(storageEngine));
+ } else {
+ auto storageEngineChangeContext = StorageEngineChangeContext::get(service);
+ auto token = storageEngineChangeContext->killOpsForStorageEngineChange(service);
+ auto storageEngine = std::unique_ptr<StorageEngine>(
+ factory->create(opCtx, storageGlobalParams, lockFile ? &*lockFile : nullptr));
+ storageEngineChangeContext->changeStorageEngine(
+ service, std::move(token), std::move(storageEngine));
}
if (lockFile) {
- auto scopedTimer = createTimeElapsedBuilderScopedTimer(
- service->getFastClockSource(), "Write current PID to file", startupTimeElapsedBuilder);
uassertStatusOK(lockFile->writePid());
}
@@ -243,10 +222,6 @@ StorageEngine::LastShutdownState initializeStorageEngine(
if (!metadata.get() &&
(initFlags & StorageEngineInitFlags::kSkipMetadataFile) == StorageEngineInitFlags{}) {
invariant(!storageGlobalParams.readOnly);
- auto scopedTimer =
- createTimeElapsedBuilderScopedTimer(service->getFastClockSource(),
- "Write a new metadata for storage engine",
- startupTimeElapsedBuilder);
metadata.reset(new StorageEngineMetadata(storageGlobalParams.dbpath));
metadata->setStorageEngine(factory->getCanonicalName().toString());
metadata->setStorageEngineOptions(factory->createMetadataOptions(storageGlobalParams));