summaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/session_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'library/cpp/messagebus/session_impl.cpp')
-rw-r--r--library/cpp/messagebus/session_impl.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/library/cpp/messagebus/session_impl.cpp b/library/cpp/messagebus/session_impl.cpp
index 28bac5058c2..ddf9f360c43 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();