aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authordanilalexeev <danilalexeev@yandex-team.com>2024-04-15 11:23:05 +0300
committerdanilalexeev <danilalexeev@yandex-team.com>2024-04-15 11:31:18 +0300
commite6558ec33cb53027bbab8d213015113b7f15be4e (patch)
tree58dfce6a5de79532b7be16625fda9fec63689f24
parentc015541a60f8d93070c53511daaff81db730d194 (diff)
downloadydb-e6558ec33cb53027bbab8d213015113b7f15be4e.tar.gz
Cosmetics
f10145b8872b6c43c4808c82c377ca34feb7d015
-rw-r--r--yt/yt/client/hive/public.h2
-rw-r--r--yt/yt/core/rpc/dynamic_channel_pool.cpp4
-rw-r--r--yt/yt/core/rpc/peer_discovery.cpp2
-rw-r--r--yt/yt/core/rpc/peer_discovery.h2
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);