diff options
author | danilalexeev <danilalexeev@yandex-team.com> | 2024-04-15 11:23:05 +0300 |
---|---|---|
committer | danilalexeev <danilalexeev@yandex-team.com> | 2024-04-15 11:31:18 +0300 |
commit | e6558ec33cb53027bbab8d213015113b7f15be4e (patch) | |
tree | 58dfce6a5de79532b7be16625fda9fec63689f24 | |
parent | c015541a60f8d93070c53511daaff81db730d194 (diff) | |
download | ydb-e6558ec33cb53027bbab8d213015113b7f15be4e.tar.gz |
Cosmetics
f10145b8872b6c43c4808c82c377ca34feb7d015
-rw-r--r-- | yt/yt/client/hive/public.h | 2 | ||||
-rw-r--r-- | yt/yt/core/rpc/dynamic_channel_pool.cpp | 4 | ||||
-rw-r--r-- | yt/yt/core/rpc/peer_discovery.cpp | 2 | ||||
-rw-r--r-- | yt/yt/core/rpc/peer_discovery.h | 2 |
4 files changed, 5 insertions, 5 deletions
diff --git a/yt/yt/client/hive/public.h b/yt/yt/client/hive/public.h index 5143ae3c79a..0c8d010ecc5 100644 --- a/yt/yt/client/hive/public.h +++ b/yt/yt/client/hive/public.h @@ -34,7 +34,7 @@ DECLARE_REFCOUNTED_STRUCT(ITransactionParticipant) YT_DEFINE_ERROR_ENUM( ((MailboxNotCreatedYet) (2200)) ((ParticipantUnregistered) (2201)) - ((EntryNotFound) (2202)) + ((TimeEntryNotFound) (2202)) ); //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/yt/core/rpc/dynamic_channel_pool.cpp b/yt/yt/core/rpc/dynamic_channel_pool.cpp index cc404497a3b..efe0fbb1525 100644 --- a/yt/yt/core/rpc/dynamic_channel_pool.cpp +++ b/yt/yt/core/rpc/dynamic_channel_pool.cpp @@ -848,7 +848,7 @@ private: ViablePeerRegistry_->UnregisterPeer(address); } - TError MaybeTransformChannelError(TError error) + TError TransformChannelError(TError error) { auto guard = ReaderGuard(SpinLock_); @@ -888,7 +888,7 @@ private: BIND(&IsChannelFailureError), BIND([this_ = MakeWeak(this)] (TError error) { if (auto strongThis = this_.Lock()) { - return strongThis->MaybeTransformChannelError(std::move(error)); + return strongThis->TransformChannelError(std::move(error)); } else { return error; } diff --git a/yt/yt/core/rpc/peer_discovery.cpp b/yt/yt/core/rpc/peer_discovery.cpp index 24595961e65..3b4ab1549d1 100644 --- a/yt/yt/core/rpc/peer_discovery.cpp +++ b/yt/yt/core/rpc/peer_discovery.cpp @@ -43,7 +43,7 @@ private: TPeerDiscoveryResponse ConvertResponse(const TIntrusivePtr<TTypedClientResponse<NProto::TRspDiscover>>& rsp) { if (Hook_) { - Hook_->OnResponse(rsp.Get()); + Hook_->HandleResponse(rsp.Get()); } return TPeerDiscoveryResponse{ diff --git a/yt/yt/core/rpc/peer_discovery.h b/yt/yt/core/rpc/peer_discovery.h index 091a31bd356..09a4149dc95 100644 --- a/yt/yt/core/rpc/peer_discovery.h +++ b/yt/yt/core/rpc/peer_discovery.h @@ -10,7 +10,7 @@ struct IDiscoverRequestHook : public TRefCounted { virtual void EnrichRequest(NProto::TReqDiscover* request) const = 0; - virtual void OnResponse(NProto::TRspDiscover* response) const = 0; + virtual void HandleResponse(NProto::TRspDiscover* response) const = 0; }; DEFINE_REFCOUNTED_TYPE(IDiscoverRequestHook); |