aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorilnaz <ilnaz@ydb.tech>2023-06-09 10:35:33 +0300
committerilnaz <ilnaz@ydb.tech>2023-06-09 10:35:33 +0300
commit083db20c17c2cf642bbac27c41ba1fa68645b4a8 (patch)
tree26e84d7601cf2edca25f17c4365c3a75858d124b
parentd81b7265e37dd8b5b5100509cd456d449cea58ae (diff)
downloadydb-083db20c17c2cf642bbac27c41ba1fa68645b4a8.tar.gz
(refactoring) TWalleTaskInfo -> TTaskInfo
-rw-r--r--ydb/core/cms/cms.h2
-rw-r--r--ydb/core/cms/cms_impl.h2
-rw-r--r--ydb/core/cms/cms_state.h4
-rw-r--r--ydb/core/cms/cms_tx_load_state.cpp2
-rw-r--r--ydb/core/cms/cms_tx_store_walle_task.cpp6
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));
}