diff options
| author | alexvru <[email protected]> | 2023-05-04 18:26:27 +0300 |
|---|---|---|
| committer | alexvru <[email protected]> | 2023-05-04 18:26:27 +0300 |
| commit | 82951621d9c50b5360d435b26f44d38adfd03f0d (patch) | |
| tree | 501ad80b2c6e500985329392f4376cd829d61d64 /library/cpp/actors/interconnect/interconnect_tcp_session.cpp | |
| parent | 4e5d5c7da7468ccd5fbd7f7a7af5146939839635 (diff) | |
Improve IC
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_tcp_session.cpp')
| -rw-r--r-- | library/cpp/actors/interconnect/interconnect_tcp_session.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp index 0ca9f2f1365..3ee04be6042 100644 --- a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp +++ b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp @@ -232,7 +232,7 @@ namespace NActors { ReceiveContext->UnlockLastPacketSerialToConfirm(); auto actor = MakeHolder<TInputSessionTCP>(SelfId(), Socket, XdcSocket, ReceiveContext, Proxy->Common, Proxy->Metrics, Proxy->PeerNodeId, nextPacket, GetDeadPeerTimeout(), Params); - ReceiverId = Params.Encryption ? RegisterWithSameMailbox(actor.Release()) : Register(actor.Release(), TMailboxType::ReadAsFilled); + ReceiverId = RegisterWithSameMailbox(actor.Release()); // register our socket in poller actor LOG_DEBUG_IC_SESSION("ICS11", "registering socket in PollerActor"); @@ -806,7 +806,7 @@ namespace NActors { Y_VERIFY(outgoingStreamSizeAfter == outgoingStreamSizeBefore + packetSize && xdcStreamSizeAfter == xdcStreamSizeBefore + packet.GetExternalSize(), "outgoingStreamSizeBefore# %zu outgoingStreamSizeAfter# %zu packetSize# %zu" - " xdcStreamSizeBefore# %zu xdcStreamSizeAfter# %zu externalSize# %zu", + " xdcStreamSizeBefore# %zu xdcStreamSizeAfter# %zu externalSize# %" PRIu32, outgoingStreamSizeBefore, outgoingStreamSizeAfter, packetSize, xdcStreamSizeBefore, xdcStreamSizeAfter, packet.GetExternalSize()); #endif @@ -819,7 +819,7 @@ namespace NActors { }); } - LOG_DEBUG_IC_SESSION("ICS22", "outgoing packet Serial# %" PRIu64 " Confirm# %" PRIu64 " DataSize# %zu" + LOG_DEBUG_IC_SESSION("ICS22", "outgoing packet Serial# %" PRIu64 " Confirm# %" PRIu64 " DataSize# %" PRIu32 " InflightDataAmount# %" PRIu64, serial, lastInputSerial, packet.GetDataSize(), InflightDataAmount); // reset forced packet sending timestamp as we have confirmed all received data |