diff options
| author | danlark <[email protected]> | 2022-02-10 16:46:10 +0300 |
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:46:10 +0300 |
| commit | baa58daefa91fde4b4769facdbd2903763b9c6a8 (patch) | |
| tree | 1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp | |
| parent | 3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp')
| -rw-r--r-- | library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp index 01e3ecb24c1..0abe9fe6598 100644 --- a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp +++ b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp @@ -36,7 +36,7 @@ namespace NActors { } void TInputSessionTCP::Bootstrap() { - SetPrefix(Sprintf("InputSession %s [node %" PRIu32 "]", SelfId().ToString().data(), NodeId)); + SetPrefix(Sprintf("InputSession %s [node %" PRIu32 "]", SelfId().ToString().data(), NodeId)); Become(&TThis::WorkingState, DeadPeerTimeout, new TEvCheckDeadPeer); LOG_DEBUG_IC_SESSION("ICIS01", "InputSession created"); LastReceiveTimestamp = TActivationContext::Now(); @@ -371,7 +371,7 @@ namespace NActors { : recvres == 0 ? "connection closed by peer" : err ? err : Sprintf("socket: %s", strerror(-recvres)); - LOG_NOTICE_NET(NodeId, "%s", message.data()); + LOG_NOTICE_NET(NodeId, "%s", message.data()); ReestablishConnection(CloseInputSessionRequested ? TDisconnectReason::Debug() : recvres == 0 ? TDisconnectReason::EndOfStream() : TDisconnectReason::FromErrno(-recvres)); } else if (PollerToken && !std::exchange(Context->ReadPending, true)) { |