src/corosio/src/tcp_socket.cpp

84.3% Lines (43/51) 90.0% List of functions (9/10) 66.7% Branches (12/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		34560x	tcp_socket::~tcp_socket()
24		34560x	{
25	1/2 ✓ Branch 0 taken 17303 times. ✗ Branch 1 not taken.	17303x	close();
26		34560x	}
27
28		29830x	tcp_socket::tcp_socket(capy::execution_context& ctx)
29			#if BOOST_COROSIO_HAS_IOCP
30			: io_object(create_handle<detail::win_tcp_service>(ctx))
31			#else
32		14915x	: io_object(create_handle<detail::tcp_service>(ctx))
33			#endif
34		29830x	{
35		14915x	}
36
37			void
38		7441x	tcp_socket::open(tcp proto)
39			{
40	1/2 ✗ Branch 0 not taken. ✓ Branch 1 taken 7441 times.	7441x	if (is_open())
41		✗	return;
42		7441x	open_for_family(proto.family(), proto.type(), proto.protocol());
43		7441x	}
44
45			void
46		7441x	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_tcp_service&>(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_tcp_socket&>(wrapper).get_internal(), family, type,
53			protocol);
54			#else
55		7441x	auto& svc = static_cast<detail::tcp_service&>(h_.service());
56		14882x	std::error_code ec = svc.open_socket(
57		7441x	static_cast<tcp_socket::implementation&>(*h_.get()), family, type,
58		7441x	protocol);
59			#endif
60	1/2 ✓ Branch 0 taken 7441 times. ✗ Branch 1 not taken.	7441x	if (ec)
61		✗	detail::throw_system_error(ec, "tcp_socket::open");
62		7441x	}
63
64			void
65		32222x	tcp_socket::close()
66			{
67	2/2 ✓ Branch 0 taken 17379 times. ✓ Branch 1 taken 14843 times.	32222x	if (!is_open())
68		17379x	return;
69		14843x	h_.service().close(h_);
70		32222x	}
71
72			void
73		162x	tcp_socket::cancel()
74			{
75	1/2 ✗ Branch 0 not taken. ✓ Branch 1 taken 162 times.	162x	if (!is_open())
76		✗	return;
77		162x	get().cancel();
78		162x	}
79
80			void
81		12x	tcp_socket::shutdown(shutdown_type what)
82			{
83	2/2 ✓ Branch 0 taken 6 times. ✓ Branch 1 taken 6 times.	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		6x	}
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	2/2 ✓ Branch 0 taken 10 times. ✓ Branch 1 taken 38 times.	48x	if (!is_open())
108		10x	return endpoint{};
109		38x	return get().local_endpoint();
110		48x	}
111
112			endpoint
113		52x	tcp_socket::remote_endpoint() const noexcept
114			{
115	2/2 ✓ Branch 0 taken 10 times. ✓ Branch 1 taken 42 times.	52x	if (!is_open())
116		10x	return endpoint{};
117		42x	return get().remote_endpoint();
118		52x	}
119
120			} // namespace boost::corosio
121