src/corosio/src/local_stream_socket.cpp

55.2% Lines (37/67) 64.3% List of functions (9/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	52x	local_stream_socket::~local_stream_socket()
27		{
28	52x	close();
29	52x	}
30
31	30x	local_stream_socket::local_stream_socket(capy::execution_context& ctx)
32	30x	: io_object(create_handle<detail::local_stream_service>(ctx))
33		{
34	30x	}
35
36		void
37	8x	local_stream_socket::open(local_stream proto)
38		{
39	8x	if (is_open())
40	✗	return;
41	8x	open_for_family(proto.family(), proto.type(), proto.protocol());
42		}
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	8x	std::error_code ec = svc.open_socket(
49	8x	static_cast<local_stream_socket::implementation&>(*h_.get()),
50		family, type, protocol);
51	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	54x	if (!is_open())
59	28x	return;
60	26x	h_.service().close(h_);
61		}
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(int fd)
91		{
92	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	16x	std::error_code ec = svc.assign_socket(
96	16x	static_cast<local_stream_socket::implementation&>(*h_.get()), fd);
97	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	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		}
112
113		native_handle_type
114	2x	local_stream_socket::release()
115		{
116	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	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	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