diff options
| author | danlark <danlark@yandex-team.ru> | 2022-02-10 16:46:08 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:46:08 +0300 |
| commit | 3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (patch) | |
| tree | 26154e1e9990f1bb4525d3e3fb5b6dac2c2c1da2 /library/cpp/actors/interconnect/interconnect_handshake.cpp | |
| parent | cb68f224c46a8ee52ac3fdd2a32534b8bb8dc134 (diff) | |
| download | ydb-3426a9bc7f169ae9da54cef557ad2a33f6e8eee0.tar.gz | |
Restoring authorship annotation for <danlark@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_handshake.cpp')
| -rw-r--r-- | library/cpp/actors/interconnect/interconnect_handshake.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_handshake.cpp b/library/cpp/actors/interconnect/interconnect_handshake.cpp index 9ede998d8e..2f0399fd9e 100644 --- a/library/cpp/actors/interconnect/interconnect_handshake.cpp +++ b/library/cpp/actors/interconnect/interconnect_handshake.cpp @@ -128,7 +128,7 @@ namespace NActors { Y_VERIFY(Socket); PeerAddr = TString::Uninitialized(1024); if (GetRemoteAddr(*Socket, PeerAddr.Detach(), PeerAddr.size())) { - PeerAddr.resize(strlen(PeerAddr.data())); + PeerAddr.resize(strlen(PeerAddr.data())); } else { PeerAddr.clear(); } @@ -223,7 +223,7 @@ namespace NActors { void ProcessUnexpectedEvent(TAutoPtr<IEventHandle> ev) override { switch (const ui32 type = ev->GetTypeRewrite()) { case TEvents::TSystem::Wakeup: - Fail(TEvHandshakeFail::HANDSHAKE_FAIL_TRANSIENT, Sprintf("Handshake timed out, State# %s", State.data()), true); + Fail(TEvHandshakeFail::HANDSHAKE_FAIL_TRANSIENT, Sprintf("Handshake timed out, State# %s", State.data()), true); [[fallthrough]]; case ui32(ENetwork::NodeInfo): @@ -318,7 +318,7 @@ namespace NActors { } } if (!matching) { - errorCallback(Sprintf("Peer ClusterUUID# %s mismatch, AcceptUUID# %s", uuid->data(), formatList(Common->AcceptUUID).data())); + errorCallback(Sprintf("Peer ClusterUUID# %s mismatch, AcceptUUID# %s", uuid->data(), formatList(Common->AcceptUUID).data())); } } return; // remote side did not fill in this field -- old version, symmetric protocol is not supported @@ -342,7 +342,7 @@ namespace NActors { } // no match - errorCallback(Sprintf("Peer ClusterUUID# %s mismatch, AcceptUUID# %s", remoteUUID.data(), formatList(Common->AcceptUUID).data())); + errorCallback(Sprintf("Peer ClusterUUID# %s mismatch, AcceptUUID# %s", remoteUUID.data(), formatList(Common->AcceptUUID).data())); } void ParsePeerScopeId(const NActorsInterconnect::TScopeId& proto) { @@ -562,7 +562,7 @@ namespace NActors { // extract peer node id from the peer PeerNodeId = request.Header.SelfVirtualId.NodeId(); if (!PeerNodeId) { - Y_VERIFY_DEBUG(false, "PeerNodeId is zero request# %s", request.ToString().data()); + Y_VERIFY_DEBUG(false, "PeerNodeId is zero request# %s", request.ToString().data()); Fail(TEvHandshakeFail::HANDSHAKE_FAIL_PERMANENT, "SelfVirtualId.NodeId is empty in initial packet"); } UpdatePrefix(); @@ -646,8 +646,8 @@ namespace NActors { generateError(Sprintf("Incorrect ReceiverNodeId# %" PRIu32 " from the peer, expected# %" PRIu32, request.GetReceiverNodeId(), SelfActorId.NodeId())); } else if (request.GetReceiverHostName() != Common->TechnicalSelfHostName) { - generateError(Sprintf("ReceiverHostName# %s mismatch, expected# %s", request.GetReceiverHostName().data(), - Common->TechnicalSelfHostName.data())); + generateError(Sprintf("ReceiverHostName# %s mismatch, expected# %s", request.GetReceiverHostName().data(), + Common->TechnicalSelfHostName.data())); } ValidateVersionTag(request, generateError); |