diff options
author | monster <monster@ydb.tech> | 2022-07-07 14:41:37 +0300 |
---|---|---|
committer | monster <monster@ydb.tech> | 2022-07-07 14:41:37 +0300 |
commit | 06e5c21a835c0e923506c4ff27929f34e00761c2 (patch) | |
tree | 75efcbc6854ef9bd476eb8bf00cc5c900da436a2 /library/cpp/neh/utils.cpp | |
parent | 03f024c4412e3aa613bb543cf1660176320ba8f4 (diff) | |
download | ydb-06e5c21a835c0e923506c4ff27929f34e00761c2.tar.gz |
fix ya.make
Diffstat (limited to 'library/cpp/neh/utils.cpp')
-rw-r--r-- | library/cpp/neh/utils.cpp | 47 |
1 files changed, 47 insertions, 0 deletions
diff --git a/library/cpp/neh/utils.cpp b/library/cpp/neh/utils.cpp new file mode 100644 index 0000000000..2f8671c581 --- /dev/null +++ b/library/cpp/neh/utils.cpp @@ -0,0 +1,47 @@ +#include "utils.h" + +#include <util/generic/utility.h> +#include <util/stream/output.h> +#include <util/stream/str.h> +#include <util/system/error.h> + +#if defined(_unix_) +#include <pthread.h> +#endif + +#if defined(_win_) +#include <windows.h> +#endif + +using namespace NNeh; + +size_t NNeh::RealStackSize(size_t len) noexcept { +#if defined(NDEBUG) && !defined(_san_enabled_) + return len; +#else + return Max<size_t>(len, 64000); +#endif +} + +TString NNeh::PrintHostByRfc(const NAddr::IRemoteAddr& addr) { + TStringStream ss; + + if (addr.Addr()->sa_family == AF_INET) { + NAddr::PrintHost(ss, addr); + } else if (addr.Addr()->sa_family == AF_INET6) { + ss << '['; + NAddr::PrintHost(ss, addr); + ss << ']'; + } + return ss.Str(); +} + +NAddr::IRemoteAddrPtr NNeh::GetPeerAddr(SOCKET s) { + TAutoPtr<NAddr::TOpaqueAddr> addr(new NAddr::TOpaqueAddr()); + + if (getpeername(s, addr->MutableAddr(), addr->LenPtr()) < 0) { + ythrow TSystemError() << "getpeername() failed"; + } + + return NAddr::IRemoteAddrPtr(addr.Release()); +} |