src/corosio/src/local_stream_socket.cpp

94.0% Lines (63/67) 100.0% List of functions (14/14)

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

local_stream_socket.cpp

f(x) Functions (14)

Function Calls Lines Blocks

Line	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	130x	local_stream_socket::~local_stream_socket()
27		{
28	130x	close();
29	130x	}
30
31	92x	local_stream_socket::local_stream_socket(capy::execution_context& ctx)
32	92x	: io_object(create_handle<detail::local_stream_service>(ctx))
33		{
34	92x	}
35
36		void
37	38x	local_stream_socket::open(local_stream proto)
38		{
39	38x	if (is_open())
40	✗	return;
41	38x	open_for_family(proto.family(), proto.type(), proto.protocol());
42		}
43
44		void
45	38x	local_stream_socket::open_for_family(int family, int type, int protocol)
46		{
47	38x	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
48	38x	std::error_code ec = svc.open_socket(
49	38x	static_cast<local_stream_socket::implementation&>(*h_.get()),
50		family, type, protocol);
51	38x	if (ec)
52	✗	detail::throw_system_error(ec, "local_stream_socket::open");
53	38x	}
54
55		void
56	138x	local_stream_socket::close()
57		{
58	138x	if (!is_open())
59	46x	return;
60	92x	h_.service().close(h_);
61		}
62
63		void
64	4x	local_stream_socket::cancel()
65		{
66	4x	if (!is_open())
67	2x	return;
68	2x	get().cancel();
69		}
70
71		void
72	4x	local_stream_socket::shutdown(shutdown_type what)
73		{
74	4x	if (is_open())
75		{
76		// Best-effort: errors like ENOTCONN are expected and unhelpful
77	2x	[[maybe_unused]] auto ec = get().shutdown(what);
78		}
79	4x	}
80
81		void
82	4x	local_stream_socket::shutdown(shutdown_type what, std::error_code& ec) noexcept
83		{
84	4x	ec = {};
85	4x	if (is_open())
86	2x	ec = get().shutdown(what);
87	4x	}
88
89		void
90	44x	local_stream_socket::assign(native_handle_type fd)
91		{
92	44x	if (is_open())
93	2x	detail::throw_logic_error("assign: socket already open");
94	42x	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
95	42x	std::error_code ec = svc.assign_socket(
96	42x	static_cast<local_stream_socket::implementation&>(*h_.get()), fd);
97	42x	if (ec)
98	2x	detail::throw_system_error(ec, "local_stream_socket::assign");
99	40x	}
100
101		native_handle_type
102	8x	local_stream_socket::native_handle() const noexcept
103		{
104	8x	if (!is_open())
105		#if BOOST_COROSIO_HAS_IOCP
106		return ~native_handle_type(0);
107		#else
108	2x	return -1;
109		#endif
110	6x	return get().native_handle();
111		}
112
113		native_handle_type
114	4x	local_stream_socket::release()
115		{
116	4x	if (!is_open())
117	2x	detail::throw_logic_error("release: socket not open");
118	2x	return get().release_socket();
119		}
120
121		std::size_t
122	6x	local_stream_socket::available() const
123		{
124	6x	if (!is_open())
125	2x	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	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	6x	local_stream_socket::local_endpoint() const noexcept
146		{
147	6x	if (!is_open())
148	2x	return corosio::local_endpoint{};
149	4x	return get().local_endpoint();
150		}
151
152		local_endpoint
153	6x	local_stream_socket::remote_endpoint() const noexcept
154		{
155	6x	if (!is_open())
156	2x	return corosio::local_endpoint{};
157	4x	return get().remote_endpoint();
158		}
159
160		} // namespace boost::corosio
161
162		#endif // BOOST_COROSIO_POSIX \|\| BOOST_COROSIO_HAS_IOCP
163