cloud/filestore/apps/client/lib/mount.cpp - main - githubmirror/nbs

cloud/filestore/apps/client/lib/mount.cpp
124 строки3 KB
Andrey Nasonov
[Filestore] Refactoring: extract TFileRingBuffer, TDynamicPersistentTable, TPersistentTable to a separate library (#5982)
22 май 2026, 16:17
Не верифицирован
22 май 2026, 16:178455dc8
#include "command.h"

#include <cloud/filestore/libs/client/config.h>
#include <cloud/filestore/libs/client/session.h>
#include <cloud/filestore/libs/diagnostics/filesystem_counters.h>
#include <cloud/filestore/libs/diagnostics/module_stats.h>
#include <cloud/filestore/libs/diagnostics/profile_log.h>
#include <cloud/filestore/libs/diagnostics/request_stats.h>
#include <cloud/filestore/libs/vfs/config.h>
#include <cloud/filestore/libs/vfs/loop.h>
#include <cloud/filestore/libs/vfs_fuse/loop.h>

#include <cloud/storage/core/libs/file_backed_containers/file_map_memory_limiter.h>

namespace NCloud::NFileStore::NClient {

namespace {

////////////////////////////////////////////////////////////////////////////////

class TMountCommand final
    : public TFileStoreCommand
{
private:
    TString MountPath;
    bool MountReadOnly = false;
    ui64 MountSeqNo = 0;

    NVFS::IFileSystemLoopPtr FileSystemLoop;

public:
    TMountCommand()
    {
        Opts.AddLongOption("mount-path")
            .Required()
            .RequiredArgument("STR")
            .StoreResult(&MountPath);

        Opts.AddLongOption("mount-readonly")
            .NoArgument()
            .SetFlag(&MountReadOnly);

        Opts.AddLongOption("mount-seqno")
            .RequiredArgument("NUM")
            .StoreResult(&MountSeqNo);
    }

    void Init() override
    {
        TFileStoreCommand::Init();

        NProto::TSessionConfig sessionConfig;
        sessionConfig.SetFileSystemId(FileSystemId);
        sessionConfig.SetClientId(ClientId);
        auto session = NClient::CreateSession(
            Logging,
            Timer,
            Scheduler,
            Client,
            std::make_shared<TSessionConfig>(sessionConfig));

        NProto::TVFSConfig proto;
        proto.SetFileSystemId(FileSystemId);
        proto.SetClientId(ClientId);
        proto.SetMountPath(MountPath);
        proto.SetReadOnly(MountReadOnly);
        proto.SetMountSeqNumber(MountSeqNo);
        if (LogSettings.FiltrationLevel > TLOG_DEBUG) {
            proto.SetDebug(true);
        }

        auto config = std::make_shared<NVFS::TVFSConfig>(std::move(proto));
        FileSystemLoop = NFuse::CreateFuseLoop(
            config,
            Logging,
            CreateRequestStatsRegistryStub(),
            CreateModuleStatsRegistryStub(),
            CreateFsCountersProviderStub(),
            Scheduler,
            Timer,
            CreateProfileLogStub(),
            session,
            CreateFileMapMemoryLimiterStub());
    }

    void Start() override
    {
        TFileStoreCommand::Start();

        if (FileSystemLoop) {
            auto error = FileSystemLoop->StartAsync().GetValueSync();
            if (FAILED(error.GetCode())) {
                STORAGE_ERROR("failed to start driver: " << FormatError(error))
                STORAGE_THROW_SERVICE_ERROR(error);
            }
        }
    }

    void Stop() override
    {
        if (FileSystemLoop) {
            FileSystemLoop->StopAsync().GetValueSync();
        }

        TFileStoreCommand::Stop();
    }

    bool Execute() override
    {
        // wait until stopped by user
        return false;
    }
};

}   // namespace

////////////////////////////////////////////////////////////////////////////////

TCommandPtr NewMountCommand()
{
    return std::make_shared<TMountCommand>();
}

}   // namespace NCloud::NFileStore::NClient