aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/remote_client_connection.cpp
diff options
context:
space:
mode:
authorvegayours <vegayours@yandex-team.ru>2022-02-10 16:50:31 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:31 +0300
commitb9b7aa7f3855cbc4d6cd032a89adbc25e680a4df (patch)
tree84d4a0f0857da118debdb9684b64ab00acb42206 /library/cpp/messagebus/remote_client_connection.cpp
parentb1683877992937b1040baa621c4b216ed8405729 (diff)
downloadydb-b9b7aa7f3855cbc4d6cd032a89adbc25e680a4df.tar.gz
Restoring authorship annotation for <vegayours@yandex-team.ru>. Commit 1 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 8c7a6db3a8..eabbbbeaf4 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;