From 55fa8c7df8dba9a6fda8a807e529a9d04bd88580 Mon Sep 17 00:00:00 2001
From: mihaild <mihaild@yandex-team.ru>
Date: Thu, 10 Feb 2022 16:46:59 +0300
Subject: Restoring authorship annotation for <mihaild@yandex-team.ru>. Commit
2 of 2.
---
library/cpp/messagebus/session_impl.cpp | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
(limited to 'library/cpp/messagebus/session_impl.cpp')
diff --git a/library/cpp/messagebus/session_impl.cpp b/library/cpp/messagebus/session_impl.cpp
index 28bac5058c..ddf9f360c4 100644
--- a/library/cpp/messagebus/session_impl.cpp
+++ b/library/cpp/messagebus/session_impl.cpp
@@ -525,12 +525,12 @@ void TBusSessionImpl::SendSnapshotToStatusActor() {
void TBusSessionImpl::InsertConnectionLockAcquired(TRemoteConnection* connection) {
//Y_ASSERT(ConnectionsLock.IsLocked());
- Connections.insert(std::make_pair(connection->PeerAddrSocketAddr, connection));
+ Connections.insert(std::make_pair(connection->PeerAddrSocketAddr, connection));
// connection for given adds may already exist at this point
// (so we overwrite old connection)
// after reconnect, if previous connections wasn't shutdown yet
- bool inserted2 = ConnectionsById.insert(std::make_pair(connection->ConnectionId, connection)).second;
+ bool inserted2 = ConnectionsById.insert(std::make_pair(connection->ConnectionId, connection)).second;
Y_VERIFY(inserted2, "state check: must be inserted (2)");
SendSnapshotToStatusActor();
--
cgit v1.2.3