diff options
author | robot-piglet <robot-piglet@yandex-team.com> | 2023-08-02 11:23:22 +0300 |
---|---|---|
committer | robot-piglet <robot-piglet@yandex-team.com> | 2023-08-02 11:23:22 +0300 |
commit | f488cdc92db6276892f75bc57cd95bcbcce5aeb7 (patch) | |
tree | 76555adb2256df06e5f7f9959dfd508ace233da3 | |
parent | 3d55f8dfc54006f3d6a8b943c034ead23214800e (diff) | |
download | ydb-f488cdc92db6276892f75bc57cd95bcbcce5aeb7.tar.gz |
Intermediate changes
-rw-r--r-- | yt/yt/core/bus/tcp/client.cpp | 2 | ||||
-rw-r--r-- | yt/yt/core/rpc/bus/channel.cpp | 8 |
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)); |