summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/interconnect_tcp_server.cpp
diff options
context:
space:
mode:
authoralexvru <[email protected]>2023-11-17 21:51:27 +0300
committeralexvru <[email protected]>2023-11-17 22:24:31 +0300
commit9fb3a015a1c695b4f6ee2196404e7b2a06e6d677 (patch)
treedfef740b72a2662862caf1eadb53da9b53c97456 /library/cpp/actors/interconnect/interconnect_tcp_server.cpp
parent983dd8625f86eab8f1af1b53c44ad49df392dadc (diff)
Fix EPOLLET logic to keep old behaviour for inoptimal user code KIKIMR-20021
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_tcp_server.cpp')
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_server.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_server.cpp b/library/cpp/actors/interconnect/interconnect_tcp_server.cpp
index 09c5987e81f..df0c172dc18 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_server.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_server.cpp
@@ -109,8 +109,8 @@ namespace NActors {
Listener.Reset();
PollerToken.Reset();
Become(&TThis::Initial, TDuration::Seconds(1), new TEvents::TEvBootstrap);
- } else if (PollerToken) {
- PollerToken->Request(true, false);
+ } else if (PollerToken && PollerToken->RequestReadNotificationAfterWouldBlock()) {
+ continue;
}
break;
}