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/asio/tcp_acceptor_impl.cpp | |
parent | 03f024c4412e3aa613bb543cf1660176320ba8f4 (diff) | |
download | ydb-06e5c21a835c0e923506c4ff27929f34e00761c2.tar.gz |
fix ya.make
Diffstat (limited to 'library/cpp/neh/asio/tcp_acceptor_impl.cpp')
-rw-r--r-- | library/cpp/neh/asio/tcp_acceptor_impl.cpp | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/library/cpp/neh/asio/tcp_acceptor_impl.cpp b/library/cpp/neh/asio/tcp_acceptor_impl.cpp new file mode 100644 index 0000000000..7e1d75fcf5 --- /dev/null +++ b/library/cpp/neh/asio/tcp_acceptor_impl.cpp @@ -0,0 +1,25 @@ +#include "tcp_acceptor_impl.h" + +using namespace NAsio; + +bool TOperationAccept::Execute(int errorCode) { + if (errorCode) { + H_(errorCode, *this); + + return true; + } + + struct sockaddr_storage addr; + socklen_t sz = sizeof(addr); + + SOCKET res = ::accept(Fd(), (sockaddr*)&addr, &sz); + + if (res == INVALID_SOCKET) { + H_(LastSystemError(), *this); + } else { + NS_.Assign(res, TEndpoint(new NAddr::TOpaqueAddr((sockaddr*)&addr))); + H_(0, *this); + } + + return true; +} |