diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:17 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:17 +0300 |
commit | d3a398281c6fd1d3672036cb2d63f842d2cb28c5 (patch) | |
tree | dd4bd3ca0f36b817e96812825ffaf10d645803f2 /library/cpp/messagebus/locator.h | |
parent | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (diff) | |
download | ydb-d3a398281c6fd1d3672036cb2d63f842d2cb28c5.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/locator.h')
-rw-r--r-- | library/cpp/messagebus/locator.h | 116 |
1 files changed, 58 insertions, 58 deletions
diff --git a/library/cpp/messagebus/locator.h b/library/cpp/messagebus/locator.h index 2c455ac53e..f8556a3fce 100644 --- a/library/cpp/messagebus/locator.h +++ b/library/cpp/messagebus/locator.h @@ -10,84 +10,84 @@ #include <util/system/mutex.h> namespace NBus { - /////////////////////////////////////////////// - /// \brief Client interface to locator service + /////////////////////////////////////////////// + /// \brief Client interface to locator service - /// This interface abstracts clustering/location service that - /// allows clients find servers (address, port) using "name" and "key". - /// The instance lives in TBusMessageQueue-object, but can be shared by different queues. - class TBusLocator: public TAtomicRefCount<TBusLocator>, public TNonCopyable { - private: - typedef ui64 TServiceId; - typedef TSet<TString> TServiceIdSet; - TServiceIdSet ServiceIdSet; - TServiceId GetServiceId(const char* name); + /// This interface abstracts clustering/location service that + /// allows clients find servers (address, port) using "name" and "key". + /// The instance lives in TBusMessageQueue-object, but can be shared by different queues. + class TBusLocator: public TAtomicRefCount<TBusLocator>, public TNonCopyable { + private: + typedef ui64 TServiceId; + typedef TSet<TString> TServiceIdSet; + TServiceIdSet ServiceIdSet; + TServiceId GetServiceId(const char* name); - typedef TMap<TNetAddr, TString> THostAddrMap; - THostAddrMap HostAddrMap; + typedef TMap<TNetAddr, TString> THostAddrMap; + THostAddrMap HostAddrMap; - TNetworkInterfaceList MyInterfaces; + TNetworkInterfaceList MyInterfaces; - struct TItem { - TServiceId ServiceId; - TBusKey Start; - TBusKey End; - TNetAddr Addr; + struct TItem { + TServiceId ServiceId; + TBusKey Start; + TBusKey End; + TNetAddr Addr; - bool operator<(const TItem& y) const; + bool operator<(const TItem& y) const; - bool operator==(const TItem& y) const; + bool operator==(const TItem& y) const; - TItem(TServiceId serviceId, TBusKey start, TBusKey end, const TNetAddr& addr); - }; + TItem(TServiceId serviceId, TBusKey start, TBusKey end, const TNetAddr& addr); + }; - typedef TMultiSet<TItem> TItems; - TItems Items; - TMutex Lock; + typedef TMultiSet<TItem> TItems; + TItems Items; + TMutex Lock; - int RegisterBreak(TServiceId serviceId, const TBusKey start, const TNetAddr& addr); - int UnregisterBreak(TServiceId serviceId, const TNetAddr& addr); + int RegisterBreak(TServiceId serviceId, const TBusKey start, const TNetAddr& addr); + int UnregisterBreak(TServiceId serviceId, const TNetAddr& addr); - void NormalizeBreaks(TServiceId serviceId); + void NormalizeBreaks(TServiceId serviceId); - private: - int Register(TBusService service, TBusKey start, TBusKey end, const TNetAddr& addr); + private: + int Register(TBusService service, TBusKey start, TBusKey end, const TNetAddr& addr); - public: - /// creates instance that obtains location table from locator server (not implemented) - TBusLocator(); + public: + /// creates instance that obtains location table from locator server (not implemented) + TBusLocator(); - /// returns true if this address is on the same node for YBUS_KEYLOCAL - bool IsLocal(const TNetAddr& addr); + /// returns true if this address is on the same node for YBUS_KEYLOCAL + bool IsLocal(const TNetAddr& addr); - /// returns first address for service and key - int Locate(TBusService service, TBusKey key, TNetAddr* addr); + /// returns first address for service and key + int Locate(TBusService service, TBusKey key, TNetAddr* addr); - /// returns all addresses mathing service and key - int LocateAll(TBusService service, TBusKey key, TVector<TNetAddr>& addrs); + /// returns all addresses mathing service and key + int LocateAll(TBusService service, TBusKey key, TVector<TNetAddr>& addrs); - /// returns actual host name for service and key - int LocateHost(TBusService service, TBusKey key, TString* host, int* port, bool* isLocal = nullptr); + /// returns actual host name for service and key + int LocateHost(TBusService service, TBusKey key, TString* host, int* port, bool* isLocal = nullptr); - /// returns all key ranges for the given service - int LocateKeys(TBusService service, TBusKeyVec& keys, bool onlyLocal = false); + /// returns all key ranges for the given service + int LocateKeys(TBusService service, TBusKeyVec& keys, bool onlyLocal = false); - /// returns port on the local node for the service - int GetLocalPort(TBusService service); + /// returns port on the local node for the service + int GetLocalPort(TBusService service); - /// returns addresses of the local node for the service - int GetLocalAddresses(TBusService service, TVector<TNetAddr>& addrs); + /// returns addresses of the local node for the service + int GetLocalAddresses(TBusService service, TVector<TNetAddr>& addrs); - /// register service instance - int Register(TBusService service, TBusKey start, TBusKey end, const TNetworkAddress& addr, EIpVersion requireVersion = EIP_VERSION_4, EIpVersion preferVersion = EIP_VERSION_ANY); - /// @throws yexception - int Register(TBusService service, const char* host, int port, TBusKey start = YBUS_KEYMIN, TBusKey end = YBUS_KEYMAX, EIpVersion requireVersion = EIP_VERSION_4, EIpVersion preferVersion = EIP_VERSION_ANY); + /// register service instance + int Register(TBusService service, TBusKey start, TBusKey end, const TNetworkAddress& addr, EIpVersion requireVersion = EIP_VERSION_4, EIpVersion preferVersion = EIP_VERSION_ANY); + /// @throws yexception + int Register(TBusService service, const char* host, int port, TBusKey start = YBUS_KEYMIN, TBusKey end = YBUS_KEYMAX, EIpVersion requireVersion = EIP_VERSION_4, EIpVersion preferVersion = EIP_VERSION_ANY); - /// unregister service instance - int Unregister(TBusService service, TBusKey start, TBusKey end); + /// unregister service instance + int Unregister(TBusService service, TBusKey start, TBusKey end); - int RegisterBreak(TBusService service, const TVector<TBusKey>& starts, const TNetAddr& addr); - int UnregisterBreak(TBusService service, const TNetAddr& addr); - }; + int RegisterBreak(TBusService service, const TVector<TBusKey>& starts, const TNetAddr& addr); + int UnregisterBreak(TBusService service, const TNetAddr& addr); + }; -} +} |