From b1683877992937b1040baa621c4b216ed8405729 Mon Sep 17 00:00:00 2001
From: nohttp <nohttp@yandex-team.ru>
Date: Thu, 10 Feb 2022 16:50:31 +0300
Subject: Restoring authorship annotation for <nohttp@yandex-team.ru>. Commit 2
of 2.
---
library/cpp/messagebus/session_impl.cpp | 28 ++++++++++++++--------------
1 file changed, 14 insertions(+), 14 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 d9163d3f3a..ddf9f360c4 100644
--- a/library/cpp/messagebus/session_impl.cpp
+++ b/library/cpp/messagebus/session_impl.cpp
@@ -211,22 +211,22 @@ void TBusSessionImpl::GetInFlightBulk(TArrayRef<const TNetAddr> addrs, TArrayRef
}
}
-size_t TBusSessionImpl::GetConnectSyscallsNumForTestImpl(const TNetAddr& addr) const {
- TRemoteConnectionPtr conn = const_cast<TBusSessionImpl*>(this)->GetConnection(addr, false);
- if (!!conn) {
- return conn->GetConnectSyscallsNumForTest();
- } else {
- return 0;
- }
-}
-
+size_t TBusSessionImpl::GetConnectSyscallsNumForTestImpl(const TNetAddr& addr) const {
+ TRemoteConnectionPtr conn = const_cast<TBusSessionImpl*>(this)->GetConnection(addr, false);
+ if (!!conn) {
+ return conn->GetConnectSyscallsNumForTest();
+ } else {
+ return 0;
+ }
+}
+
void TBusSessionImpl::GetConnectSyscallsNumBulkForTest(TArrayRef<const TNetAddr> addrs, TArrayRef<size_t> results) const {
Y_VERIFY(addrs.size() == results.size(), "input.size != output.size");
- for (size_t i = 0; i < addrs.size(); ++i) {
- results[i] = GetConnectSyscallsNumForTestImpl(addrs[i]);
- }
-}
-
+ for (size_t i = 0; i < addrs.size(); ++i) {
+ results[i] = GetConnectSyscallsNumForTestImpl(addrs[i]);
+ }
+}
+
void TBusSessionImpl::FillStatus() {
}
--
cgit v1.2.3