diff options
author | alexvru <alexvru@ydb.tech> | 2023-05-05 19:24:33 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2023-05-05 19:24:33 +0300 |
commit | bb9f87983378fe1f73272537f39246e0ac4f545d (patch) | |
tree | e7d94c2b7b5b622d0c9dd23b87b6e4e9155dce4f /library/cpp | |
parent | 4ff405d38632f38b90d7b84f3ce016ba967687be (diff) | |
download | ydb-bb9f87983378fe1f73272537f39246e0ac4f545d.tar.gz |
Fix IC regression
Diffstat (limited to 'library/cpp')
-rw-r--r-- | library/cpp/actors/interconnect/interconnect_tcp_session.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp index 3ee04be6042..3274a6367ca 100644 --- a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp +++ b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp @@ -276,7 +276,7 @@ namespace NActors { LastHandshakeDone = TActivationContext::Now(); - IssueRam(false); + GenerateTraffic(); } void TInterconnectSessionTCP::Handle(TEvUpdateFromInputSession::TPtr& ev) { @@ -380,13 +380,15 @@ namespace NActors { return; } ProducePackets(); - canProducePackets = NumEventsInReadyChannels && InflightDataAmount < GetTotalInflightAmountOfData() && - GetUnsentSize() < GetUnsentLimit(); if (!Socket) { return; } WriteData(); + + canProducePackets = NumEventsInReadyChannels && InflightDataAmount < GetTotalInflightAmountOfData() && + GetUnsentSize() < GetUnsentLimit(); + canWriteData = ((OutgoingStream || OutOfBandStream) && !ReceiveContext->MainWriteBlocked) || (XdcStream && !ReceiveContext->XdcWriteBlocked); |