diff options
author | lonelly <lonelly@yandex-team.ru> | 2022-02-10 16:49:49 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:49 +0300 |
commit | e01af096d5cd7baca583319f1473a2a2c993ec86 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus | |
parent | f1a86949d52e1185ed4f05de191b50386abc68f4 (diff) | |
download | ydb-e01af096d5cd7baca583319f1473a2a2c993ec86.tar.gz |
Restoring authorship annotation for <lonelly@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r-- | library/cpp/messagebus/locator.cpp | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/library/cpp/messagebus/locator.cpp b/library/cpp/messagebus/locator.cpp index 8d48a30731..e38a35c426 100644 --- a/library/cpp/messagebus/locator.cpp +++ b/library/cpp/messagebus/locator.cpp @@ -146,8 +146,8 @@ namespace NBus { RegisterBreak(serviceId, starts[i], addr); } return 0; - } - + } + 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 = @@ -169,7 +169,7 @@ namespace NBus { if (start < YBUS_KEYMAX) { right.Reset(new TItem(serviceId, start + 1, YBUS_KEYMAX, addr)); } - } + } Items.insert(*left); Items.insert(*right); NormalizeBreaks(serviceId); @@ -182,7 +182,7 @@ namespace NBus { TServiceId serviceId = GetServiceId(service); return UnregisterBreak(serviceId, addr); } - + int TBusLocator::UnregisterBreak(TServiceId serviceId, const TNetAddr& addr) { int deleted = 0; TItems::iterator it = Items.begin(); @@ -198,7 +198,7 @@ namespace NBus { deleted += 1; } } - + if (Items.begin() == Items.end()) { return deleted; } @@ -227,13 +227,13 @@ namespace NBus { } NormalizeBreaks(serviceId); - return deleted; - } - + return deleted; + } + void TBusLocator::NormalizeBreaks(TServiceId serviceId) { TItems::const_iterator first = Items.lower_bound(TItem(serviceId, YBUS_KEYMIN, YBUS_KEYMIN, TNetAddr())); TItems::const_iterator last = Items.end(); - + if ((Items.end() != first) && (first->ServiceId == serviceId)) { if (serviceId != Max<TServiceId>()) { last = Items.lower_bound(TItem(serviceId + 1, YBUS_KEYMIN, YBUS_KEYMIN, TNetAddr())); @@ -246,8 +246,8 @@ namespace NBus { TItem& beg = const_cast<TItem&>(*first); beg.Addr = last->Addr; } - } - + } + int TBusLocator::LocateAll(TBusService service, TBusKey key, TVector<TNetAddr>& addrs) { TGuard<TMutex> G(Lock); Y_VERIFY(addrs.empty(), "Non emtpy addresses"); |