Index/src / corosio / src / local_stream_socket.cpp

src/corosio/src/local_stream_socket.cpp

94.8% Lines (55/0/58) 100.0% List of functions (13/0/13)
[ ] prev/next file n p prev/next uncovered line
local_stream_socket.cpp
f(x) Functions (13)
Function Calls Lines Blocks
boost::corosio::local_stream_socket::~local_stream_socket() :26 234x 100.0% 100.0% boost::corosio::local_stream_socket::local_stream_socket(boost::capy::execution_context&) :31 190x 100.0% 100.0% boost::corosio::local_stream_socket::open(boost::corosio::local_stream) :37 45x 75.0% 70.0% boost::corosio::local_stream_socket::open_for_family(int, int, int) :45 45x 100.0% 100.0% boost::corosio::local_stream_socket::close() :55 242x 100.0% 100.0% boost::corosio::local_stream_socket::cancel() :63 8x 100.0% 100.0% boost::corosio::local_stream_socket::shutdown(boost::corosio::shutdown_type) :71 6x 100.0% 100.0% boost::corosio::local_stream_socket::assign(int) :79 114x 100.0% 100.0% boost::corosio::local_stream_socket::native_handle() const :88 10x 100.0% 100.0% boost::corosio::local_stream_socket::release() :100 6x 100.0% 100.0% boost::corosio::local_stream_socket::available() const :110 6x 77.8% 79.0% boost::corosio::local_stream_socket::local_endpoint() const :135 6x 100.0% 100.0% boost::corosio::local_stream_socket::remote_endpoint() const :143 6x 100.0% 100.0%
Line TLA 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 234x local_stream_socket::~local_stream_socket()
27 {
28 234x close();
29 234x }
30
31 190x local_stream_socket::local_stream_socket(capy::execution_context& ctx)
32 190x : io_object(create_handle<detail::local_stream_service>(ctx))
33 {
34 190x }
35
36 std::error_code
37 45x local_stream_socket::open(local_stream proto) noexcept
38 {
39 45x if (is_open())
40 ✗ return {};
41 45x return open_for_family(proto.family(), proto.type(), proto.protocol());
42 }
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 45x std::error_code ec = svc.open_socket(
49 45x static_cast<local_stream_socket::implementation&>(*h_.get()),
50 family, type, protocol);
51 45x return ec;
52 }
53
54 void
55 242x local_stream_socket::close() noexcept
56 {
57 242x if (!is_open())
58 73x return;
59 169x h_.service().close(h_);
60 }
61
62 void
63 8x local_stream_socket::cancel() noexcept
64 {
65 8x if (!is_open())
66 2x return;
67 6x get().cancel();
68 }
69
70 std::error_code
71 6x local_stream_socket::shutdown(shutdown_type what) noexcept
72 {
73 6x if (!is_open())
74 2x return make_error_code(std::errc::bad_file_descriptor);
75 4x return get().shutdown(what);
76 }
77
78 std::error_code
79 114x local_stream_socket::assign(native_handle_type fd) noexcept
80 {
81 114x auto& svc = static_cast<detail::local_stream_service&>(h_.service());
82 114x std::error_code ec = svc.assign_socket(
83 114x static_cast<local_stream_socket::implementation&>(*h_.get()), fd);
84 114x return ec;
85 }
86
87 native_handle_type
88 10x local_stream_socket::native_handle() const noexcept
89 {
90 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 }
98
99 native_handle_type
100 6x local_stream_socket::release()
101 {
102 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 6x if (!is_open())
113 2x detail::throw_system_error(
114 4x 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 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 6x if (!is_open())
138 2x return corosio::local_endpoint{};
139 4x return get().local_endpoint();
140 }
141
142 local_endpoint
143 6x local_stream_socket::remote_endpoint() const noexcept
144 {
145 6x if (!is_open())
146 2x return corosio::local_endpoint{};
147 4x return get().remote_endpoint();
148 }
149
150 } // namespace boost::corosio
151
152 #endif // BOOST_COROSIO_POSIX || BOOST_COROSIO_HAS_IOCP
153