diff options
author | alexvru <[email protected]> | 2023-11-17 21:51:27 +0300 |
---|---|---|
committer | alexvru <[email protected]> | 2023-11-17 22:24:31 +0300 |
commit | 9fb3a015a1c695b4f6ee2196404e7b2a06e6d677 (patch) | |
tree | dfef740b72a2662862caf1eadb53da9b53c97456 /library/cpp/actors/interconnect/interconnect_tcp_server.cpp | |
parent | 983dd8625f86eab8f1af1b53c44ad49df392dadc (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.cpp | 4 |
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; } |