src/corosio/src/local_stream_socket.cpp

57.4% Lines (39/68) 71.4% List of functions (10/14) 42.4% Branches (14/33)

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

local_stream_socket.cpp

f(x) Functions (14)

Function Calls Lines Branches Blocks

Line	Branch	Hits	Source Code
1			//
2			// Copyright (c) 2026 Michael Vandeberg
3			//
4			// Distributed under the Boost Software License, Version 1.0. (See accompanying
5			// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
6			//
7			// Official repository: https://github.com/cppalliance/corosio
8			//
9
10			#include <boost/corosio/detail/platform.hpp>
11
12			#if BOOST_COROSIO_POSIX \|\| BOOST_COROSIO_HAS_IOCP
13
14			#include <boost/corosio/local_stream_socket.hpp>
15			#include <boost/corosio/detail/except.hpp>
16			#include <boost/corosio/detail/local_stream_service.hpp>
17
18			#if BOOST_COROSIO_POSIX
19			#include <sys/ioctl.h>
20			#elif BOOST_COROSIO_HAS_IOCP
21			#include <boost/corosio/native/detail/iocp/win_windows.hpp>
22			#endif
23
24			namespace boost::corosio {
25
26		38x	local_stream_socket::~local_stream_socket()
27			{
28		38x	close();
29		38x	}
30
31		19x	local_stream_socket::local_stream_socket(capy::execution_context& ctx)
32	1/1 ✓ Branch 2 → 3 taken 19 times.	19x	: io_object(create_handle<detail::local_stream_service>(ctx))
33			{
34		19x	}
35
36			void
37		16x	local_stream_socket::open(local_stream proto)
38			{
39	1/2 ✗ Branch 3 → 4 not taken. ✓ Branch 3 → 5 taken 16 times.	16x	if (is_open())
40		✗	return;
41		16x	open_for_family(proto.family(), proto.type(), proto.protocol());
42			}
43
44			void
45		16x	local_stream_socket::open_for_family(int family, int type, int protocol)
46			{
47		16x	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
48	1/1 ✓ Branch 4 → 5 taken 16 times.	16x	std::error_code ec = svc.open_socket(
49		16x	static_cast<local_stream_socket::implementation&>(*h_.get()),
50			family, type, protocol);
51	1/2 ✗ Branch 6 → 7 not taken. ✓ Branch 6 → 8 taken 16 times.	16x	if (ec)
52		✗	detail::throw_system_error(ec, "local_stream_socket::open");
53		16x	}
54
55			void
56		42x	local_stream_socket::close()
57			{
58	2/2 ✓ Branch 3 → 4 taken 17 times. ✓ Branch 3 → 5 taken 25 times.	42x	if (!is_open())
59		17x	return;
60		25x	h_.service().close(h_);
61			}
62
63			void
64		1x	local_stream_socket::cancel()
65			{
66	1/2 ✓ Branch 3 → 4 taken 1 time. ✗ Branch 3 → 5 not taken.	1x	if (!is_open())
67		1x	return;
68		✗	get().cancel();
69			}
70
71			void
72		✗	local_stream_socket::shutdown(shutdown_type what)
73			{
74		✗	if (is_open())
75			{
76			// Best-effort: errors like ENOTCONN are expected and unhelpful
77		✗	[[maybe_unused]] auto ec = get().shutdown(what);
78			}
79		✗	}
80
81			void
82		✗	local_stream_socket::shutdown(shutdown_type what, std::error_code& ec) noexcept
83			{
84		✗	ec = {};
85		✗	if (is_open())
86		✗	ec = get().shutdown(what);
87		✗	}
88
89			void
90		2x	local_stream_socket::assign(native_handle_type fd)
91			{
92	1/2 ✗ Branch 3 → 4 not taken. ✓ Branch 3 → 5 taken 2 times.	2x	if (is_open())
93		✗	detail::throw_logic_error("assign: socket already open");
94		2x	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
95	1/1 ✓ Branch 7 → 8 taken 2 times.	2x	std::error_code ec = svc.assign_socket(
96		2x	static_cast<local_stream_socket::implementation&>(*h_.get()), fd);
97	1/2 ✗ Branch 9 → 10 not taken. ✓ Branch 9 → 11 taken 2 times.	2x	if (ec)
98		✗	detail::throw_system_error(ec, "local_stream_socket::assign");
99		2x	}
100
101			native_handle_type
102		2x	local_stream_socket::native_handle() const noexcept
103			{
104	2/2 ✓ Branch 3 → 4 taken 1 time. ✓ Branch 3 → 5 taken 1 time.	2x	if (!is_open())
105			#if BOOST_COROSIO_HAS_IOCP
106		1x	return ~native_handle_type(0);
107			#else
108			return -1;
109			#endif
110		1x	return get().native_handle();
111			}
112
113			native_handle_type
114		✗	local_stream_socket::release()
115			{
116		✗	if (!is_open())
117		✗	detail::throw_logic_error("release: socket not open");
118		✗	return get().release_socket();
119			}
120
121			std::size_t
122		✗	local_stream_socket::available() const
123			{
124		✗	if (!is_open())
125		✗	detail::throw_logic_error("available: socket not open");
126			#if BOOST_COROSIO_HAS_IOCP
127		✗	u_long value = 0;
128		✗	if (::ioctlsocket(
129		✗	static_cast<SOCKET>(native_handle()), FIONREAD, &value) != 0)
130		✗	detail::throw_system_error(
131		✗	std::error_code(::WSAGetLastError(), std::system_category()),
132			"local_stream_socket::available");
133		✗	return static_cast<std::size_t>(value);
134			#else
135			int value = 0;
136			if (::ioctl(native_handle(), FIONREAD, &value) < 0)
137			detail::throw_system_error(
138			std::error_code(errno, std::system_category()),
139			"local_stream_socket::available");
140			return static_cast<std::size_t>(value);
141			#endif
142			}
143
144			local_endpoint
145		1x	local_stream_socket::local_endpoint() const noexcept
146			{
147	1/2 ✓ Branch 3 → 4 taken 1 time. ✗ Branch 3 → 5 not taken.	1x	if (!is_open())
148		1x	return corosio::local_endpoint{};
149		✗	return get().local_endpoint();
150			}
151
152			local_endpoint
153		1x	local_stream_socket::remote_endpoint() const noexcept
154			{
155	1/2 ✓ Branch 3 → 4 taken 1 time. ✗ Branch 3 → 5 not taken.	1x	if (!is_open())
156		1x	return corosio::local_endpoint{};
157		✗	return get().remote_endpoint();
158			}
159
160			} // namespace boost::corosio
161
162			#endif // BOOST_COROSIO_POSIX \|\| BOOST_COROSIO_HAS_IOCP
163