summaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/remote_client_connection.cpp
diff options
context:
space:
mode:
authorvegayours <[email protected]>2022-02-10 16:50:31 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:50:31 +0300
commit9f9f5936c5b484e8a48c009cf84feeca7ec3d03a (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/remote_client_connection.cpp
parentb9b7aa7f3855cbc4d6cd032a89adbc25e680a4df (diff)
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/remote_client_connection.cpp')
-rw-r--r--library/cpp/messagebus/remote_client_connection.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/library/cpp/messagebus/remote_client_connection.cpp b/library/cpp/messagebus/remote_client_connection.cpp
index eabbbbeaf42..8c7a6db3a8c 100644
--- a/library/cpp/messagebus/remote_client_connection.cpp
+++ b/library/cpp/messagebus/remote_client_connection.cpp
@@ -76,7 +76,7 @@ void TRemoteClientConnection::TryConnect() {
WriterData.SetChannel(Session->WriteEventLoop.Register(connectSocket, this, WriteCookie));
}
- if (BeforeSendQueue.IsEmpty() && WriterData.SendQueue.Empty() && !Config.ReconnectWhenIdle) {
+ if (BeforeSendQueue.IsEmpty() && WriterData.SendQueue.Empty() && !Config.ReconnectWhenIdle) {
// TryConnect is called from Writer::Act, which is called in cycle
// from session's ScheduleTimeoutMessages via Cron. This prevent these excessive connects.
return;