src/corosio/src/local_stream_socket.cpp

55.8% Lines (43/77) 64.3% List of functions (9/14) 36.7% Branches (11/30)

[ ] 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		104x	local_stream_socket::~local_stream_socket()
27		104x	{
28	1/2 ✓ Branch 0 taken 52 times. ✗ Branch 1 not taken.	52x	close();
29		104x	}
30
31		60x	local_stream_socket::local_stream_socket(capy::execution_context& ctx)
32		30x	: io_object(create_handle<detail::local_stream_service>(ctx))
33		60x	{
34		30x	}
35
36			void
37		8x	local_stream_socket::open(local_stream proto)
38			{
39	1/2 ✗ Branch 0 not taken. ✓ Branch 1 taken 8 times.	8x	if (is_open())
40		✗	return;
41		8x	open_for_family(proto.family(), proto.type(), proto.protocol());
42		8x	}
43
44			void
45		8x	local_stream_socket::open_for_family(int family, int type, int protocol)
46			{
47		8x	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
48		16x	std::error_code ec = svc.open_socket(
49		8x	static_cast<local_stream_socket::implementation&>(*h_.get()),
50		8x	family, type, protocol);
51	1/2 ✓ Branch 0 taken 8 times. ✗ Branch 1 not taken.	8x	if (ec)
52		✗	detail::throw_system_error(ec, "local_stream_socket::open");
53		8x	}
54
55			void
56		54x	local_stream_socket::close()
57			{
58	2/2 ✓ Branch 0 taken 28 times. ✓ Branch 1 taken 26 times.	54x	if (!is_open())
59		28x	return;
60		26x	h_.service().close(h_);
61		54x	}
62
63			void
64		✗	local_stream_socket::cancel()
65			{
66		✗	if (!is_open())
67		✗	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		16x	local_stream_socket::assign(native_handle_type fd)
91			{
92	1/2 ✓ Branch 0 taken 16 times. ✗ Branch 1 not taken.	16x	if (is_open())
93		✗	detail::throw_logic_error("assign: socket already open");
94		16x	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
95		32x	std::error_code ec = svc.assign_socket(
96		16x	static_cast<local_stream_socket::implementation&>(*h_.get()), fd);
97	1/2 ✓ Branch 0 taken 16 times. ✗ Branch 1 not taken.	16x	if (ec)
98		✗	detail::throw_system_error(ec, "local_stream_socket::assign");
99		16x	}
100
101			native_handle_type
102		4x	local_stream_socket::native_handle() const noexcept
103			{
104	1/2 ✗ Branch 0 not taken. ✓ Branch 1 taken 4 times.	4x	if (!is_open())
105			#if BOOST_COROSIO_HAS_IOCP
106			return ~native_handle_type(0);
107			#else
108		✗	return -1;
109			#endif
110		4x	return get().native_handle();
111		4x	}
112
113			native_handle_type
114		2x	local_stream_socket::release()
115			{
116	1/2 ✓ Branch 0 taken 2 times. ✗ Branch 1 not taken.	2x	if (!is_open())
117		✗	detail::throw_logic_error("release: socket not open");
118		2x	return get().release_socket();
119			}
120
121			std::size_t
122		4x	local_stream_socket::available() const
123			{
124	1/2 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken.	4x	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		4x	int value = 0;
136	1/2 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken.	4x	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		4x	return static_cast<std::size_t>(value);
141			#endif
142			}
143
144			local_endpoint
145		✗	local_stream_socket::local_endpoint() const noexcept
146			{
147		✗	if (!is_open())
148		✗	return corosio::local_endpoint{};
149		✗	return get().local_endpoint();
150		✗	}
151
152			local_endpoint
153		✗	local_stream_socket::remote_endpoint() const noexcept
154			{
155		✗	if (!is_open())
156		✗	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