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/socket_addr.cpp | |
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/socket_addr.cpp')
-rw-r--r-- | library/cpp/messagebus/socket_addr.cpp | 76 |
1 files changed, 38 insertions, 38 deletions
diff --git a/library/cpp/messagebus/socket_addr.cpp b/library/cpp/messagebus/socket_addr.cpp index 0b4095abf0..c1b3a28fbe 100644 --- a/library/cpp/messagebus/socket_addr.cpp +++ b/library/cpp/messagebus/socket_addr.cpp @@ -11,66 +11,66 @@ using namespace NAddr; using namespace NBus; using namespace NBus::NPrivate; -static_assert(ADDR_UNSPEC == 0, "expect ADDR_UNSPEC == 0"); +static_assert(ADDR_UNSPEC == 0, "expect ADDR_UNSPEC == 0"); NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(const NAddr::IRemoteAddr* addr) : IPv6ScopeID(0) { const sockaddr* sa = addr->Addr(); - switch ((EAddrFamily)sa->sa_family) { - case AF_UNSPEC: { - IpAddr.Clear(); - Port = 0; - break; - } - case AF_INET: { - IpAddr.SetInAddr(((const sockaddr_in*)sa)->sin_addr); - Port = InetToHost(((const sockaddr_in*)sa)->sin_port); - break; - } - case AF_INET6: { - IpAddr.SetIn6Addr(((const sockaddr_in6*)sa)->sin6_addr); - Port = InetToHost(((const sockaddr_in*)sa)->sin_port); - IPv6ScopeID = InetToHost(((const sockaddr_in6*)sa)->sin6_scope_id); - break; - } - default: - Y_FAIL("unknown address family"); + switch ((EAddrFamily)sa->sa_family) { + case AF_UNSPEC: { + IpAddr.Clear(); + Port = 0; + break; + } + case AF_INET: { + IpAddr.SetInAddr(((const sockaddr_in*)sa)->sin_addr); + Port = InetToHost(((const sockaddr_in*)sa)->sin_port); + break; + } + case AF_INET6: { + IpAddr.SetIn6Addr(((const sockaddr_in6*)sa)->sin6_addr); + Port = InetToHost(((const sockaddr_in*)sa)->sin_port); + IPv6ScopeID = InetToHost(((const sockaddr_in6*)sa)->sin6_scope_id); + break; + } + default: + Y_FAIL("unknown address family"); } } -NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(TStringBuf host, unsigned port) { +NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(TStringBuf host, unsigned port) { *this = TNetAddr(host, port); } -NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(const TNetAddr& addr) { +NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(const TNetAddr& addr) { *this = TBusSocketAddr(&addr); } -TNetAddr NBus::NPrivate::TBusSocketAddr::ToNetAddr() const { +TNetAddr NBus::NPrivate::TBusSocketAddr::ToNetAddr() const { sockaddr_storage storage; Zero(storage); - storage.ss_family = (ui16)IpAddr.GetAddrFamily(); + storage.ss_family = (ui16)IpAddr.GetAddrFamily(); switch (IpAddr.GetAddrFamily()) { - case ADDR_UNSPEC: - return TNetAddr(); - case ADDR_IPV4: { - ((sockaddr_in*)&storage)->sin_addr = IpAddr.GetInAddr(); - ((sockaddr_in*)&storage)->sin_port = HostToInet(Port); - break; - } - case ADDR_IPV6: { - ((sockaddr_in6*)&storage)->sin6_addr = IpAddr.GetIn6Addr(); - ((sockaddr_in6*)&storage)->sin6_port = HostToInet(Port); - ((sockaddr_in6*)&storage)->sin6_scope_id = HostToInet(IPv6ScopeID); - break; - } + case ADDR_UNSPEC: + return TNetAddr(); + case ADDR_IPV4: { + ((sockaddr_in*)&storage)->sin_addr = IpAddr.GetInAddr(); + ((sockaddr_in*)&storage)->sin_port = HostToInet(Port); + break; + } + case ADDR_IPV6: { + ((sockaddr_in6*)&storage)->sin6_addr = IpAddr.GetIn6Addr(); + ((sockaddr_in6*)&storage)->sin6_port = HostToInet(Port); + ((sockaddr_in6*)&storage)->sin6_scope_id = HostToInet(IPv6ScopeID); + break; + } } - return TNetAddr(new TOpaqueAddr((sockaddr*)&storage)); + return TNetAddr(new TOpaqueAddr((sockaddr*)&storage)); } template <> |