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

cloud/filestore/apps/client/lib/start_endpoint.cpp

93 строки2 KB

Andrei Strelkovskii

fixing 'ythrow TServiceError' pattern which breaks exception messages - introduced STORAGE_THROW_SERVICE_ERROR macro which builds much better messages (#4888)

21 дек 2025, 16:41

Не верифицирован

21 дек 2025, 16:418caf308

#include "command.h"

namespace NCloud::NFileStore::NClient {

namespace {

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

class TStartEndpointCommand final
    : public TEndpointCommand
{
private:
    TString FileSystemId;
    TString SocketPath;
    TString ClientId;
    bool MountReadOnly = false;
    ui64 MountSeqNo = 0;
    ui32 VhostQueuesCount = 0;
    bool Persistent = false;

public:
    TStartEndpointCommand()
    {
        Opts.AddLongOption("filesystem")
            .Required()
            .RequiredArgument("STR")
            .StoreResult(&FileSystemId);

        Opts.AddLongOption("socket-path")
            .Required()
            .RequiredArgument("STR")
            .StoreResult(&SocketPath);

        Opts.AddLongOption("client-id")
            .Optional()
            .RequiredArgument("STR")
            .StoreResult(&ClientId);

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

        Opts.AddLongOption("vhost-queue-count")
            .RequiredArgument("NUM")
            .StoreResult(&VhostQueuesCount);

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

        Opts.AddLongOption("persistent")
            .NoArgument()
            .SetFlag(&Persistent);
    }

    bool Execute() override
    {
        auto callContext = PrepareCallContext();

        auto request = std::make_shared<NProto::TStartEndpointRequest>();

        auto* config = request->MutableEndpoint();
        config->SetFileSystemId(FileSystemId);
        config->SetSocketPath(SocketPath);
        config->SetClientId(ClientId);
        config->SetReadOnly(MountReadOnly);
        config->SetMountSeqNumber(MountSeqNo);
        config->SetVhostQueuesCount(VhostQueuesCount);
        config->SetPersistent(Persistent);

        auto response = WaitFor(
            Client->StartEndpoint(
                std::move(callContext),
                std::move(request)));

        if (HasError(response)) {
            STORAGE_THROW_SERVICE_ERROR(response.GetError());
        }

        return true;
    }
};

}   // namespace

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

TCommandPtr NewStartEndpointCommand()
{
    return std::make_shared<TStartEndpointCommand>();
}

}   // namespace NCloud::NFileStore::NClient