diff options
author | ilnaz <ilnaz@ydb.tech> | 2023-06-09 10:35:33 +0300 |
---|---|---|
committer | ilnaz <ilnaz@ydb.tech> | 2023-06-09 10:35:33 +0300 |
commit | 083db20c17c2cf642bbac27c41ba1fa68645b4a8 (patch) | |
tree | 26e84d7601cf2edca25f17c4365c3a75858d124b | |
parent | d81b7265e37dd8b5b5100509cd456d449cea58ae (diff) | |
download | ydb-083db20c17c2cf642bbac27c41ba1fa68645b4a8.tar.gz |
(refactoring) TWalleTaskInfo -> TTaskInfo
-rw-r--r-- | ydb/core/cms/cms.h | 2 | ||||
-rw-r--r-- | ydb/core/cms/cms_impl.h | 2 | ||||
-rw-r--r-- | ydb/core/cms/cms_state.h | 4 | ||||
-rw-r--r-- | ydb/core/cms/cms_tx_load_state.cpp | 2 | ||||
-rw-r--r-- | ydb/core/cms/cms_tx_store_walle_task.cpp | 6 |
5 files changed, 8 insertions, 8 deletions
diff --git a/ydb/core/cms/cms.h b/ydb/core/cms/cms.h index c973c47f04a..6b64b952cf0 100644 --- a/ydb/core/cms/cms.h +++ b/ydb/core/cms/cms.h @@ -196,7 +196,7 @@ struct TEvCms { }; struct TEvStoreWalleTask : public TEventLocal<TEvStoreWalleTask, EvStoreWalleTask> { - TWalleTaskInfo Task; + TTaskInfo Task; TString ToString() const override { return Sprintf("%s { Task: %s }", ToStringHeader().data(), Task.ToString().data()); diff --git a/ydb/core/cms/cms_impl.h b/ydb/core/cms/cms_impl.h index 9cb688b125a..cc5b2a846e0 100644 --- a/ydb/core/cms/cms_impl.h +++ b/ydb/core/cms/cms_impl.h @@ -137,7 +137,7 @@ private: ITransaction *CreateTxRemoveWalleTask(const TString &id); ITransaction *CreateTxStorePermissions(THolder<IEventBase> req, TAutoPtr<IEventHandle> resp, const TString &owner, TAutoPtr<TRequestInfo> scheduled); - ITransaction *CreateTxStoreWalleTask(const TWalleTaskInfo &task, THolder<IEventBase> req, TAutoPtr<IEventHandle> resp); + ITransaction *CreateTxStoreWalleTask(const TTaskInfo &task, THolder<IEventBase> req, TAutoPtr<IEventHandle> resp); ITransaction *CreateTxUpdateConfig(TEvCms::TEvSetConfigRequest::TPtr &ev); ITransaction *CreateTxUpdateConfig(TEvConsole::TEvConfigNotificationRequest::TPtr &ev); ITransaction *CreateTxUpdateDowntimes(); diff --git a/ydb/core/cms/cms_state.h b/ydb/core/cms/cms_state.h index 9aaecf4f972..92e4eeea66d 100644 --- a/ydb/core/cms/cms_state.h +++ b/ydb/core/cms/cms_state.h @@ -10,7 +10,7 @@ namespace NKikimr::NCms { -struct TWalleTaskInfo { +struct TTaskInfo { TString TaskId; TString RequestId; TSet<TString> Permissions; @@ -36,7 +36,7 @@ struct TCmsState : public TAtomicRefCount<TCmsState> { ui64 LastLogRecordTimestamp = 0; // State of Wall-E tasks. - THashMap<TString, TWalleTaskInfo> WalleTasks; + THashMap<TString, TTaskInfo> WalleTasks; THashMap<TString, TString> WalleRequests; // CMS config. diff --git a/ydb/core/cms/cms_tx_load_state.cpp b/ydb/core/cms/cms_tx_load_state.cpp index b4f416e87f9..17894caa106 100644 --- a/ydb/core/cms/cms_tx_load_state.cpp +++ b/ydb/core/cms/cms_tx_load_state.cpp @@ -95,7 +95,7 @@ public: TString taskId = walleTaskRowset.GetValue<Schema::WalleTask::TaskID>(); TString requestId = walleTaskRowset.GetValue<Schema::WalleTask::RequestID>(); - TWalleTaskInfo task; + TTaskInfo task; task.TaskId = taskId; task.RequestId = requestId; state->WalleRequests.emplace(requestId, taskId); diff --git a/ydb/core/cms/cms_tx_store_walle_task.cpp b/ydb/core/cms/cms_tx_store_walle_task.cpp index 981ae8c0f33..0fb39e88e56 100644 --- a/ydb/core/cms/cms_tx_store_walle_task.cpp +++ b/ydb/core/cms/cms_tx_store_walle_task.cpp @@ -7,7 +7,7 @@ namespace NKikimr::NCms { class TCms::TTxStoreWalleTask : public TTransactionBase<TCms> { public: - TTxStoreWalleTask(TCms *self, const TWalleTaskInfo &task, THolder<IEventBase> req, TAutoPtr<IEventHandle> resp) + TTxStoreWalleTask(TCms *self, const TTaskInfo &task, THolder<IEventBase> req, TAutoPtr<IEventHandle> resp) : TBase(self) , Task(task) , Request(std::move(req)) @@ -55,12 +55,12 @@ public: } private: - TWalleTaskInfo Task; + TTaskInfo Task; THolder<IEventBase> Request; TAutoPtr<IEventHandle> Response; }; -ITransaction *TCms::CreateTxStoreWalleTask(const TWalleTaskInfo &task, THolder<IEventBase> req, TAutoPtr<IEventHandle> resp) { +ITransaction *TCms::CreateTxStoreWalleTask(const TTaskInfo &task, THolder<IEventBase> req, TAutoPtr<IEventHandle> resp) { return new TTxStoreWalleTask(this, task, std::move(req), std::move(resp)); } |