src/corosio/src/local_stream_socket.cpp

0.0% Lines (0/68) 0.0% List of functions (0/14) 0.0% Branches (0/33)

[ ] 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	✗	local_stream_socket::~local_stream_socket()
27		{
28	✗	close();
29	✗	}
30
31	✗	local_stream_socket::local_stream_socket(capy::execution_context& ctx)
32	✗	: io_object(create_handle<detail::local_stream_service>(ctx))
33		{
34	✗	}
35
36		void
37	✗	local_stream_socket::open(local_stream proto)
38		{
39	✗	if (is_open())
40	✗	return;
41	✗	open_for_family(proto.family(), proto.type(), proto.protocol());
42		}
43
44		void
45	✗	local_stream_socket::open_for_family(int family, int type, int protocol)
46		{
47	✗	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
48	✗	std::error_code ec = svc.open_socket(
49	✗	static_cast<local_stream_socket::implementation&>(*h_.get()),
50		family, type, protocol);
51	✗	if (ec)
52	✗	detail::throw_system_error(ec, "local_stream_socket::open");
53	✗	}
54
55		void
56	✗	local_stream_socket::close()
57		{
58	✗	if (!is_open())
59	✗	return;
60	✗	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	✗	local_stream_socket::assign(native_handle_type fd)
91		{
92	✗	if (is_open())
93	✗	detail::throw_logic_error("assign: socket already open");
94	✗	auto& svc = static_cast<detail::local_stream_service&>(h_.service());
95	✗	std::error_code ec = svc.assign_socket(
96	✗	static_cast<local_stream_socket::implementation&>(*h_.get()), fd);
97	✗	if (ec)
98	✗	detail::throw_system_error(ec, "local_stream_socket::assign");
99	✗	}
100
101		native_handle_type
102	✗	local_stream_socket::native_handle() const noexcept
103		{
104	✗	if (!is_open())
105		#if BOOST_COROSIO_HAS_IOCP
106	✗	return ~native_handle_type(0);
107		#else
108		return -1;
109		#endif
110	✗	return get().native_handle();
111		}
112
113		native_handle_type
114	✗	local_stream_socket::release()
115		{
116	✗	if (!is_open())
117	✗	detail::throw_logic_error("release: socket not open");
118	✗	return get().release_socket();
119		}
120
121		std::size_t
122	✗	local_stream_socket::available() const
123		{
124	✗	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		int value = 0;
136		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		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