Index/src / corosio / src / tcp_socket.cpp

src/corosio/src/tcp_socket.cpp

98.0% Lines (48/49) 100.0% List of functions (11/11) 95.0% Branches (19/20)
[ ] prev/next file n p prev/next uncovered line
tcp_socket.cpp
f(x) Functions (11)
Function Calls Lines Branches Blocks
boost::corosio::tcp_socket::~tcp_socket() :23 5363x 0.0% – 100.0% boost::corosio::tcp_socket::tcp_socket(boost::capy::execution_context&) :28 2827x 100.0% 100.0% 100.0% boost::corosio::tcp_socket::open(boost::corosio::tcp) :38 1386x 100.0% 100.0% 100.0% boost::corosio::tcp_socket::open_for_family(int, int, int) :46 1385x 87.5% 66.7% 88.9% boost::corosio::tcp_socket::bind(boost::corosio::endpoint) :65 8x 100.0% 100.0% 100.0% boost::corosio::tcp_socket::close() :82 8135x 100.0% 100.0% 100.0% boost::corosio::tcp_socket::cancel() :90 2112x 100.0% 100.0% 100.0% boost::corosio::tcp_socket::shutdown(boost::corosio::shutdown_type) :98 6x 100.0% 100.0% 100.0% boost::corosio::tcp_socket::native_handle() const :108 2x 100.0% 100.0% 100.0% boost::corosio::tcp_socket::local_endpoint() const :122 31x 100.0% 100.0% 100.0% boost::corosio::tcp_socket::remote_endpoint() const :130 30x 100.0% 100.0% 100.0%
Line Branch TLA Hits Source Code
1 //
2 // Copyright (c) 2025 Vinnie Falco ([email protected])
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_tcp_acceptor_service.hpp>
17 #else
18 #include <boost/corosio/detail/tcp_service.hpp>
19 #endif
20
21 namespace boost::corosio {
22
23 5363x tcp_socket::~tcp_socket()
24 {
25 5363x close();
26 5363x }
27
28 2827x tcp_socket::tcp_socket(capy::execution_context& ctx)
29 #if BOOST_COROSIO_HAS_IOCP
30
1/1
✓ Branch 2 → 3 taken 2827 times.
 2827x : io_object(create_handle<detail::win_tcp_service>(ctx))
31 #else
32 : io_object(create_handle<detail::tcp_service>(ctx))
33 #endif
34 {
35 2827x }
36
37 void
38 1386x tcp_socket::open(tcp proto)
39 {
40
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 1385 times.
 1386x if (is_open())
41 1x return;
42 1385x open_for_family(proto.family(), proto.type(), proto.protocol());
43 }
44
45 void
46 1385x tcp_socket::open_for_family(int family, int type, int protocol)
47 {
48 #if BOOST_COROSIO_HAS_IOCP
49 1385x auto& svc = static_cast<detail::win_tcp_service&>(h_.service());
50 1385x auto& wrapper = static_cast<tcp_socket::implementation&>(*h_.get());
51
1/1
✓ Branch 5 → 6 taken 1385 times.
 1385x std::error_code ec = svc.open_socket(
52 1385x *static_cast<detail::win_tcp_socket&>(wrapper).get_internal(), family, type,
53 protocol);
54 #else
55 auto& svc = static_cast<detail::tcp_service&>(h_.service());
56 std::error_code ec = svc.open_socket(
57 static_cast<tcp_socket::implementation&>(*h_.get()), family, type,
58 protocol);
59 #endif
60
1/2
✗ Branch 7 → 8 not taken.
✓ Branch 7 → 9 taken 1385 times.
 1385x if (ec)
61 ✗ detail::throw_system_error(ec, "tcp_socket::open");
62 1385x }
63
64 std::error_code
65 8x tcp_socket::bind(endpoint ep)
66 {
67
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 7 times.
 8x if (!is_open())
68 1x detail::throw_logic_error("bind: socket not open");
69 #if BOOST_COROSIO_HAS_IOCP
70 7x auto& svc = static_cast<detail::win_tcp_service&>(h_.service());
71 7x auto& wrapper = static_cast<tcp_socket::implementation&>(*h_.get());
72 7x return svc.bind_socket(
73 14x *static_cast<detail::win_tcp_socket&>(wrapper).get_internal(), ep);
74 #else
75 auto& svc = static_cast<detail::tcp_service&>(h_.service());
76 return svc.bind_socket(
77 static_cast<tcp_socket::implementation&>(*h_.get()), ep);
78 #endif
79 }
80
81 void
82 8135x tcp_socket::close()
83 {
84
2/2
✓ Branch 3 → 4 taken 5402 times.
✓ Branch 3 → 5 taken 2733 times.
 8135x if (!is_open())
85 5402x return;
86 2733x h_.service().close(h_);
87 }
88
89 void
90 2112x tcp_socket::cancel()
91 {
92
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 2111 times.
 2112x if (!is_open())
93 1x return;
94 2111x get().cancel();
95 }
96
97 void
98 6x tcp_socket::shutdown(shutdown_type what)
99 {
100
2/2
✓ Branch 3 → 4 taken 3 times.
✓ Branch 3 → 7 taken 3 times.
 6x if (is_open())
101 {
102 // Best-effort: errors like ENOTCONN are expected and unhelpful
103 3x [[maybe_unused]] auto ec = get().shutdown(what);
104 }
105 6x }
106
107 native_handle_type
108 2x tcp_socket::native_handle() const noexcept
109 {
110
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 1 time.
 2x if (!is_open())
111 {
112 #if BOOST_COROSIO_HAS_IOCP
113 1x return static_cast<native_handle_type>(~0ull); // INVALID_SOCKET
114 #else
115 return -1;
116 #endif
117 }
118 1x return get().native_handle();
119 }
120
121 endpoint
122 31x tcp_socket::local_endpoint() const noexcept
123 {
124
2/2
✓ Branch 3 → 4 taken 5 times.
✓ Branch 3 → 5 taken 26 times.
 31x if (!is_open())
125 5x return endpoint{};
126 26x return get().local_endpoint();
127 }
128
129 endpoint
130 30x tcp_socket::remote_endpoint() const noexcept
131 {
132
2/2
✓ Branch 3 → 4 taken 5 times.
✓ Branch 3 → 5 taken 25 times.
 30x if (!is_open())
133 5x return endpoint{};
134 25x return get().remote_endpoint();
135 }
136
137 } // namespace boost::corosio
138