src/corosio/src/tcp_socket.cpp
82.9% Lines (34/41)
90.0% Functions (9/10)
| Line | TLA | Hits | Source Code |
|---|---|---|---|
| 1 | // | ||
| 2 | // Copyright (c) 2025 Vinnie Falco (vinnie.falco@gmail.com) | ||
| 3 | // Copyright (c) 2026 Steve Gerbino | ||
| 4 | // | ||
| 5 | // Distributed under the Boost Software License, Version 1.0. (See accompanying | ||
| 6 | // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) | ||
| 7 | // | ||
| 8 | // Official repository: https://github.com/cppalliance/corosio | ||
| 9 | // | ||
| 10 | |||
| 11 | #include <boost/corosio/tcp_socket.hpp> | ||
| 12 | #include <boost/corosio/detail/except.hpp> | ||
| 13 | #include <boost/corosio/detail/platform.hpp> | ||
| 14 | |||
| 15 | #if BOOST_COROSIO_HAS_IOCP | ||
| 16 | #include <boost/corosio/native/detail/iocp/win_acceptor_service.hpp> | ||
| 17 | #else | ||
| 18 | #include <boost/corosio/detail/socket_service.hpp> | ||
| 19 | #endif | ||
| 20 | |||
| 21 | namespace boost::corosio { | ||
| 22 | |||
| 23 | 13911x | tcp_socket::~tcp_socket() | |
| 24 | { | ||
| 25 | 13911x | close(); | |
| 26 | 13911x | } | |
| 27 | |||
| 28 | 13725x | tcp_socket::tcp_socket(capy::execution_context& ctx) | |
| 29 | #if BOOST_COROSIO_HAS_IOCP | ||
| 30 | : io_object(create_handle<detail::win_sockets>(ctx)) | ||
| 31 | #else | ||
| 32 | 13725x | : io_object(create_handle<detail::socket_service>(ctx)) | |
| 33 | #endif | ||
| 34 | { | ||
| 35 | 13725x | } | |
| 36 | |||
| 37 | void | ||
| 38 | 6857x | tcp_socket::open(tcp proto) | |
| 39 | { | ||
| 40 | 6857x | if (is_open()) | |
| 41 | ✗ | return; | |
| 42 | 6857x | open_for_family(proto.family(), proto.type(), proto.protocol()); | |
| 43 | } | ||
| 44 | |||
| 45 | void | ||
| 46 | 6857x | tcp_socket::open_for_family(int family, int type, int protocol) | |
| 47 | { | ||
| 48 | #if BOOST_COROSIO_HAS_IOCP | ||
| 49 | auto& svc = static_cast<detail::win_sockets&>(h_.service()); | ||
| 50 | auto& wrapper = static_cast<tcp_socket::implementation&>(*h_.get()); | ||
| 51 | std::error_code ec = svc.open_socket( | ||
| 52 | *static_cast<detail::win_socket&>(wrapper).get_internal(), family, type, | ||
| 53 | protocol); | ||
| 54 | #else | ||
| 55 | 6857x | auto& svc = static_cast<detail::socket_service&>(h_.service()); | |
| 56 | 6857x | std::error_code ec = svc.open_socket( | |
| 57 | 6857x | static_cast<tcp_socket::implementation&>(*h_.get()), family, type, | |
| 58 | protocol); | ||
| 59 | #endif | ||
| 60 | 6857x | if (ec) | |
| 61 | ✗ | detail::throw_system_error(ec, "tcp_socket::open"); | |
| 62 | 6857x | } | |
| 63 | |||
| 64 | void | ||
| 65 | 27615x | tcp_socket::close() | |
| 66 | { | ||
| 67 | 27615x | if (!is_open()) | |
| 68 | 13935x | return; | |
| 69 | 13680x | h_.service().close(h_); | |
| 70 | } | ||
| 71 | |||
| 72 | void | ||
| 73 | 364x | tcp_socket::cancel() | |
| 74 | { | ||
| 75 | 364x | if (!is_open()) | |
| 76 | ✗ | return; | |
| 77 | 364x | get().cancel(); | |
| 78 | } | ||
| 79 | |||
| 80 | void | ||
| 81 | 12x | tcp_socket::shutdown(shutdown_type what) | |
| 82 | { | ||
| 83 | 12x | if (is_open()) | |
| 84 | { | ||
| 85 | // Best-effort: errors like ENOTCONN are expected and unhelpful | ||
| 86 | 6x | [[maybe_unused]] auto ec = get().shutdown(what); | |
| 87 | } | ||
| 88 | 12x | } | |
| 89 | |||
| 90 | native_handle_type | ||
| 91 | ✗ | tcp_socket::native_handle() const noexcept | |
| 92 | { | ||
| 93 | ✗ | if (!is_open()) | |
| 94 | { | ||
| 95 | #if BOOST_COROSIO_HAS_IOCP | ||
| 96 | return static_cast<native_handle_type>(~0ull); // INVALID_SOCKET | ||
| 97 | #else | ||
| 98 | ✗ | return -1; | |
| 99 | #endif | ||
| 100 | } | ||
| 101 | ✗ | return get().native_handle(); | |
| 102 | } | ||
| 103 | |||
| 104 | endpoint | ||
| 105 | 48x | tcp_socket::local_endpoint() const noexcept | |
| 106 | { | ||
| 107 | 48x | if (!is_open()) | |
| 108 | 10x | return endpoint{}; | |
| 109 | 38x | return get().local_endpoint(); | |
| 110 | } | ||
| 111 | |||
| 112 | endpoint | ||
| 113 | 52x | tcp_socket::remote_endpoint() const noexcept | |
| 114 | { | ||
| 115 | 52x | if (!is_open()) | |
| 116 | 10x | return endpoint{}; | |
| 117 | 42x | return get().remote_endpoint(); | |
| 118 | } | ||
| 119 | |||
| 120 | } // namespace boost::corosio | ||
| 121 |