aboutsummaryrefslogtreecommitdiffstats
path: root/yt
diff options
context:
space:
mode:
authorrobot-piglet <robot-piglet@yandex-team.com>2023-08-02 11:23:22 +0300
committerrobot-piglet <robot-piglet@yandex-team.com>2023-08-02 11:23:22 +0300
commitf488cdc92db6276892f75bc57cd95bcbcce5aeb7 (patch)
tree76555adb2256df06e5f7f9959dfd508ace233da3 /yt
parent3d55f8dfc54006f3d6a8b943c034ead23214800e (diff)
downloadydb-f488cdc92db6276892f75bc57cd95bcbcce5aeb7.tar.gz
Intermediate changes
Diffstat (limited to 'yt')
-rw-r--r--yt/yt/core/bus/tcp/client.cpp2
-rw-r--r--yt/yt/core/rpc/bus/channel.cpp8
2 files changed, 10 insertions, 0 deletions
diff --git a/yt/yt/core/bus/tcp/client.cpp b/yt/yt/core/bus/tcp/client.cpp
index 84b60f63b9..049727b860 100644
--- a/yt/yt/core/bus/tcp/client.cpp
+++ b/yt/yt/core/bus/tcp/client.cpp
@@ -154,6 +154,8 @@ public:
EndpointAttributes_ = ConvertToAttributes(BuildYsonStringFluently()
.BeginMap()
.Item("address").Value(EndpointDescription_)
+ .Item("encryption_mode").Value(Config_->EncryptionMode)
+ .Item("verification_mode").Value(Config_->VerificationMode)
.EndMap());
}
diff --git a/yt/yt/core/rpc/bus/channel.cpp b/yt/yt/core/rpc/bus/channel.cpp
index d9162b0336..eaf04705b0 100644
--- a/yt/yt/core/rpc/bus/channel.cpp
+++ b/yt/yt/core/rpc/bus/channel.cpp
@@ -184,11 +184,19 @@ private:
while (bucket.Sessions.size() <= index) {
auto session = New<TSession>(options.MultiplexingBand);
auto messageHandler = New<TMessageHandler>(session);
+
auto bus = Client_->CreateBus(
messageHandler,
{
.MultiplexingBand = options.MultiplexingBand
});
+
+ auto& attrs = bus->GetEndpointAttributes();
+ YT_LOG_DEBUG("Created bus (ConnectionType: Client, VerificationMode: %v, EncryptionMode: %v, Endpoint: %v)",
+ attrs.Get<EVerificationMode>("verification_mode"),
+ attrs.Get<EEncryptionMode>("encryption_mode"),
+ attrs.Get<TString>("address"));
+
session->Initialize(bus);
bucket.Sessions.push_back(session);
results.emplace_back(std::move(bus), std::move(session));