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