src/corosio/src/tcp_socket.cpp

83.3% Lines (35/42) 90.0% List of functions (9/10) 72.2% Branches (13/18)

[ ] prev/next file n p prev/next uncovered line

f(x) Functions (10)

Function Calls Lines Branches Blocks

Line	Branch	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		4832x	tcp_socket::~tcp_socket()
24			{
25		4832x	close();
26		4832x	}
27
28		2531x	tcp_socket::tcp_socket(capy::execution_context& ctx)
29			#if BOOST_COROSIO_HAS_IOCP
30	1/1 ✓ Branch 2 → 3 taken 2531 times.	2531x	: io_object(create_handle<detail::win_tcp_service>(ctx))
31			#else
32			: io_object(create_handle<detail::tcp_service>(ctx))
33			#endif
34			{
35		2531x	}
36
37			void
38		1238x	tcp_socket::open(tcp proto)
39			{
40	1/2 ✗ Branch 3 → 4 not taken. ✓ Branch 3 → 5 taken 1238 times.	1238x	if (is_open())
41		✗	return;
42		1238x	open_for_family(proto.family(), proto.type(), proto.protocol());
43			}
44
45			void
46		1238x	tcp_socket::open_for_family(int family, int type, int protocol)
47			{
48			#if BOOST_COROSIO_HAS_IOCP
49		1238x	auto& svc = static_cast<detail::win_tcp_service&>(h_.service());
50		1238x	auto& wrapper = static_cast<tcp_socket::implementation&>(*h_.get());
51	1/1 ✓ Branch 5 → 6 taken 1238 times.	1238x	std::error_code ec = svc.open_socket(
52		1238x	*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 1238 times.	1238x	if (ec)
61		✗	detail::throw_system_error(ec, "tcp_socket::open");
62		1238x	}
63
64			void
65		7358x	tcp_socket::close()
66			{
67	2/2 ✓ Branch 3 → 4 taken 4901 times. ✓ Branch 3 → 5 taken 2457 times.	7358x	if (!is_open())
68		4901x	return;
69		2457x	h_.service().close(h_);
70			}
71
72			void
73		2140x	tcp_socket::cancel()
74			{
75	1/2 ✗ Branch 3 → 4 not taken. ✓ Branch 3 → 5 taken 2140 times.	2140x	if (!is_open())
76		✗	return;
77		2140x	get().cancel();
78			}
79
80			void
81		6x	tcp_socket::shutdown(shutdown_type what)
82			{
83	2/2 ✓ Branch 3 → 4 taken 3 times. ✓ Branch 3 → 7 taken 3 times.	6x	if (is_open())
84			{
85			// Best-effort: errors like ENOTCONN are expected and unhelpful
86		3x	[[maybe_unused]] auto ec = get().shutdown(what);
87			}
88		6x	}
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		24x	tcp_socket::local_endpoint() const noexcept
106			{
107	2/2 ✓ Branch 3 → 4 taken 5 times. ✓ Branch 3 → 5 taken 19 times.	24x	if (!is_open())
108		5x	return endpoint{};
109		19x	return get().local_endpoint();
110			}
111
112			endpoint
113		26x	tcp_socket::remote_endpoint() const noexcept
114			{
115	2/2 ✓ Branch 3 → 4 taken 5 times. ✓ Branch 3 → 5 taken 21 times.	26x	if (!is_open())
116		5x	return endpoint{};
117		21x	return get().remote_endpoint();
118			}
119
120			} // namespace boost::corosio
121