aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/locator.cpp
diff options
context:
space:
mode:
authornga <nga@yandex-team.ru>2022-02-10 16:48:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:09 +0300
commit1f553f46fb4f3c5eec631352cdd900a0709016af (patch)
treea231fba2c03b440becaea6c86a2702d0bfb0336e /library/cpp/messagebus/locator.cpp
parentc4de7efdedc25b49cbea74bd589eecb61b55b60a (diff)
downloadydb-1f553f46fb4f3c5eec631352cdd900a0709016af.tar.gz
Restoring authorship annotation for <nga@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/locator.cpp')
-rw-r--r--library/cpp/messagebus/locator.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/messagebus/locator.cpp b/library/cpp/messagebus/locator.cpp
index e38a35c426..31cdf25805 100644
--- a/library/cpp/messagebus/locator.cpp
+++ b/library/cpp/messagebus/locator.cpp
@@ -2,7 +2,7 @@
/// \file
/// \brief Implementation of locator service
-#include "locator.h"
+#include "locator.h"
#include "ybus.h"
@@ -121,7 +121,7 @@ namespace NBus {
, End(end)
, Addr(addr)
{
- }
+ }
bool TBusLocator::IsLocal(const TNetAddr& addr) {
for (const auto& myInterface : MyInterfaces) {
@@ -151,7 +151,7 @@ namespace NBus {
int TBusLocator::RegisterBreak(TServiceId serviceId, const TBusKey start, const TNetAddr& addr) {
TItems::const_iterator it = Items.lower_bound(TItem(serviceId, 0, start, addr));
TItems::const_iterator service_it =
- Items.lower_bound(TItem(serviceId, 0, 0, TNetAddr()));
+ Items.lower_bound(TItem(serviceId, 0, 0, TNetAddr()));
THolder<TItem> left;
THolder<TItem> right;
@@ -220,11 +220,11 @@ namespace NBus {
}
keyItem = item.Start - 1;
} while (it != Items.begin());
-
+
if (first != Items.end() && first->Start != 0) {
TItem item(serviceId, YBUS_KEYMIN, first->Start - 1, first->Addr);
Items.insert(item);
- }
+ }
NormalizeBreaks(serviceId);
return deleted;
@@ -245,7 +245,7 @@ namespace NBus {
TItem& beg = const_cast<TItem&>(*first);
beg.Addr = last->Addr;
- }
+ }
}
int TBusLocator::LocateAll(TBusService service, TBusKey key, TVector<TNetAddr>& addrs) {
@@ -307,7 +307,7 @@ namespace NBus {
}
port = GetAddrPort(item.Addr);
}
- }
+ }
return port;
}
@@ -326,7 +326,7 @@ namespace NBus {
if (IsLocal(item.Addr)) {
addrs.push_back(item.Addr);
}
- }
+ }
if (addrs.size() == 0) {
return -1;