aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/socket_addr.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
commitc2a1af049e9deca890e9923abe64fe6c59060348 (patch)
treeb222e5ac2e2e98872661c51ccceee5da0d291e13 /library/cpp/messagebus/socket_addr.cpp
parent1f553f46fb4f3c5eec631352cdd900a0709016af (diff)
downloadydb-c2a1af049e9deca890e9923abe64fe6c59060348.tar.gz
Restoring authorship annotation for <nga@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/socket_addr.cpp')
-rw-r--r--library/cpp/messagebus/socket_addr.cpp70
1 files changed, 35 insertions, 35 deletions
diff --git a/library/cpp/messagebus/socket_addr.cpp b/library/cpp/messagebus/socket_addr.cpp
index ef54da6603..c1b3a28fbe 100644
--- a/library/cpp/messagebus/socket_addr.cpp
+++ b/library/cpp/messagebus/socket_addr.cpp
@@ -1,23 +1,23 @@
#include "socket_addr.h"
-
-#include "netaddr.h"
-
+
+#include "netaddr.h"
+
#include <util/network/address.h>
#include <util/network/init.h>
#include <util/system/yassert.h>
-
-using namespace NAddr;
-
-using namespace NBus;
-using namespace NBus::NPrivate;
-
+
+using namespace NAddr;
+
+using namespace NBus;
+using namespace NBus::NPrivate;
+
static_assert(ADDR_UNSPEC == 0, "expect ADDR_UNSPEC == 0");
-
-NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(const NAddr::IRemoteAddr* addr)
+
+NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(const NAddr::IRemoteAddr* addr)
: IPv6ScopeID(0)
-{
- const sockaddr* sa = addr->Addr();
-
+{
+ const sockaddr* sa = addr->Addr();
+
switch ((EAddrFamily)sa->sa_family) {
case AF_UNSPEC: {
IpAddr.Clear();
@@ -37,24 +37,24 @@ NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(const NAddr::IRemoteAddr* addr)
}
default:
Y_FAIL("unknown address family");
- }
-}
-
+ }
+}
+
NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(TStringBuf host, unsigned port) {
- *this = TNetAddr(host, port);
-}
-
+ *this = TNetAddr(host, port);
+}
+
NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(const TNetAddr& addr) {
- *this = TBusSocketAddr(&addr);
-}
-
+ *this = TBusSocketAddr(&addr);
+}
+
TNetAddr NBus::NPrivate::TBusSocketAddr::ToNetAddr() const {
- sockaddr_storage storage;
- Zero(storage);
-
+ sockaddr_storage storage;
+ Zero(storage);
+
storage.ss_family = (ui16)IpAddr.GetAddrFamily();
-
- switch (IpAddr.GetAddrFamily()) {
+
+ switch (IpAddr.GetAddrFamily()) {
case ADDR_UNSPEC:
return TNetAddr();
case ADDR_IPV4: {
@@ -68,12 +68,12 @@ TNetAddr NBus::NPrivate::TBusSocketAddr::ToNetAddr() const {
((sockaddr_in6*)&storage)->sin6_scope_id = HostToInet(IPv6ScopeID);
break;
}
- }
-
+ }
+
return TNetAddr(new TOpaqueAddr((sockaddr*)&storage));
-}
-
-template <>
+}
+
+template <>
void Out<TBusSocketAddr>(IOutputStream& out, const TBusSocketAddr& addr) {
- out << addr.ToNetAddr();
-}
+ out << addr.ToNetAddr();
+}