summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/interconnect_tcp_input_session.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_input_session.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_input_session.cpp')
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
index 49417abd532..1409f2cf0cd 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
@@ -742,7 +742,7 @@ namespace NActors {
throw TExReestablishConnection{CloseInputSessionRequested ? TDisconnectReason::Debug() :
recvres == 0 ? TDisconnectReason::EndOfStream() : TDisconnectReason::FromErrno(-recvres)};
} else if (token && !*readPending) {
- if (socket.RequestEx(*token, true, false)) {
+ if (socket.RequestReadNotificationAfterWouldBlock(*token)) {
continue; // can try again
} else {
*readPending = true;