diff options
author | mihaild <mihaild@yandex-team.ru> | 2022-02-10 16:46:59 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:46:59 +0300 |
commit | 55fa8c7df8dba9a6fda8a807e529a9d04bd88580 (patch) | |
tree | b83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/messagebus/session_impl.cpp | |
parent | 246417ad6168d3f7ab4a0cf1c79ba4259f7c45ae (diff) | |
download | ydb-55fa8c7df8dba9a6fda8a807e529a9d04bd88580.tar.gz |
Restoring authorship annotation for <mihaild@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/session_impl.cpp')
-rw-r--r-- | library/cpp/messagebus/session_impl.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
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(); |