src/corosio/src/local_stream_socket.cpp

95.6% Lines (65/68) 100.0% List of functions (13/13) 76.7% Branches (23/30)

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

local_stream_socket.cpp

f(x) Functions (13)

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		428x	local_stream_socket::~local_stream_socket()
27		428x	{
28		232x	close();
29		428x	}
30
31		376x	local_stream_socket::local_stream_socket(capy::execution_context& ctx)
32		188x	: io_object(create_handle<detail::local_stream_service>(ctx))
33		376x	{
34		188x	}
35
36			std::error_code
37		45x	local_stream_socket::open(local_stream proto) noexcept
38			{
39	1/2 ✗ Branch 0 not taken. ✓ Branch 1 taken 45 times.	45x	if (is_open())
40		✗	return {};
41		45x	return open_for_family(proto.family(), proto.type(), proto.protocol());
42		45x	}
43
44			std::error_code
45		45x	local_stream_socket::open_for_family(int family, int type, int protocol) noexcept
46			{
47		45x	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
48	2/4 ✓ Branch 0 taken 45 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 45 times. ✗ Branch 3 not taken.	90x	std::error_code ec = svc.open_socket(
49		45x	static_cast<local_stream_socket::implementation&>(*h_.get()),
50		45x	family, type, protocol);
51		45x	return ec;
52			}
53
54			void
55		240x	local_stream_socket::close() noexcept
56			{
57	2/2 ✓ Branch 0 taken 167 times. ✓ Branch 1 taken 73 times.	240x	if (!is_open())
58		73x	return;
59	1/2 ✓ Branch 0 taken 167 times. ✗ Branch 1 not taken.	167x	h_.service().close(h_);
60		240x	}
61
62			void
63		8x	local_stream_socket::cancel() noexcept
64			{
65	2/2 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 6 times.	8x	if (!is_open())
66		2x	return;
67		6x	get().cancel();
68		8x	}
69
70			std::error_code
71		6x	local_stream_socket::shutdown(shutdown_type what) noexcept
72			{
73	2/2 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 4 times.	6x	if (!is_open())
74		2x	return make_error_code(std::errc::bad_file_descriptor);
75		4x	return get().shutdown(what);
76		6x	}
77
78			std::error_code
79		112x	local_stream_socket::assign(native_handle_type fd) noexcept
80			{
81		112x	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
82	2/4 ✓ Branch 0 taken 112 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 112 times. ✗ Branch 3 not taken.	224x	std::error_code ec = svc.assign_socket(
83		112x	static_cast<local_stream_socket::implementation&>(*h_.get()), fd);
84		112x	return ec;
85			}
86
87			native_handle_type
88		10x	local_stream_socket::native_handle() const noexcept
89			{
90	2/2 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 8 times.	10x	if (!is_open())
91			#if BOOST_COROSIO_HAS_IOCP
92			return ~native_handle_type(0);
93			#else
94		2x	return -1;
95			#endif
96		8x	return get().native_handle();
97		10x	}
98
99			native_handle_type
100		6x	local_stream_socket::release()
101			{
102	2/2 ✓ Branch 0 taken 4 times. ✓ Branch 1 taken 2 times.	6x	if (!is_open())
103		2x	detail::throw_system_error(
104		2x	make_error_code(std::errc::bad_file_descriptor),
105			"local_stream_socket::release");
106		4x	return get().release_socket();
107			}
108
109			std::size_t
110		6x	local_stream_socket::available() const
111			{
112	2/2 ✓ Branch 0 taken 4 times. ✓ Branch 1 taken 2 times.	6x	if (!is_open())
113		2x	detail::throw_system_error(
114		2x	make_error_code(std::errc::bad_file_descriptor),
115			"local_stream_socket::available");
116			#if BOOST_COROSIO_HAS_IOCP
117			u_long value = 0;
118			if (::ioctlsocket(
119			static_cast<SOCKET>(native_handle()), FIONREAD, &value) != 0)
120			detail::throw_system_error(
121			std::error_code(::WSAGetLastError(), std::system_category()),
122			"local_stream_socket::available");
123			return static_cast<std::size_t>(value);
124			#else
125		4x	int value = 0;
126	1/2 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken.	4x	if (::ioctl(native_handle(), FIONREAD, &value) < 0)
127		✗	detail::throw_system_error(
128		✗	std::error_code(errno, std::system_category()),
129			"local_stream_socket::available");
130		4x	return static_cast<std::size_t>(value);
131			#endif
132			}
133
134			local_endpoint
135		6x	local_stream_socket::local_endpoint() const noexcept
136			{
137	2/2 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 4 times.	6x	if (!is_open())
138		2x	return corosio::local_endpoint{};
139		4x	return get().local_endpoint();
140		6x	}
141
142			local_endpoint
143		6x	local_stream_socket::remote_endpoint() const noexcept
144			{
145	2/2 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 4 times.	6x	if (!is_open())
146		2x	return corosio::local_endpoint{};
147		4x	return get().remote_endpoint();
148		6x	}
149
150			} // namespace boost::corosio
151
152			#endif // BOOST_COROSIO_POSIX \|\| BOOST_COROSIO_HAS_IOCP
153