aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp
diff options
context:
space:
mode:
authoralexvru <alexvru@ydb.tech>2023-05-05 19:24:33 +0300
committeralexvru <alexvru@ydb.tech>2023-05-05 19:24:33 +0300
commitbb9f87983378fe1f73272537f39246e0ac4f545d (patch)
treee7d94c2b7b5b622d0c9dd23b87b6e4e9155dce4f /library/cpp
parent4ff405d38632f38b90d7b84f3ce016ba967687be (diff)
downloadydb-bb9f87983378fe1f73272537f39246e0ac4f545d.tar.gz
Fix IC regression
Diffstat (limited to 'library/cpp')
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_session.cpp8
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);