Index/src / corosio / src / local_stream_acceptor.cpp

src/corosio/src/local_stream_acceptor.cpp

97.1% Lines (68/70) 100.0% List of functions (12/12) 87.1% Branches (27/31)
[ ] prev/next file n p prev/next uncovered line
local_stream_acceptor.cpp
f(x) Functions (12)
Function Calls Lines Branches Blocks
boost::corosio::local_stream_acceptor::~local_stream_acceptor() :31 45x 0.0% – 100.0% boost::corosio::local_stream_acceptor::local_stream_acceptor(boost::capy::execution_context&) :36 36x 100.0% 100.0% 100.0% boost::corosio::local_stream_acceptor::local_stream_acceptor(boost::capy::execution_context&, boost::corosio::local_endpoint, int) :42 2x 80.0% 66.7% 78.9% boost::corosio::local_stream_acceptor::open(boost::corosio::local_stream) :55 34x 100.0% 100.0% 100.0% boost::corosio::local_stream_acceptor::assign(unsigned long long) :68 3x 100.0% – 100.0% boost::corosio::local_stream_acceptor::native_handle() const :78 5x 100.0% 100.0% 100.0% boost::corosio::local_stream_acceptor::bind(boost::corosio::local_endpoint, boost::corosio::bind_option) :92 31x 100.0% 80.0% 100.0% boost::corosio::local_stream_acceptor::listen(int) :120 23x 100.0% 100.0% 100.0% boost::corosio::local_stream_acceptor::close() :132 50x 100.0% 100.0% 100.0% boost::corosio::local_stream_acceptor::release() :140 6x 100.0% 100.0% 100.0% boost::corosio::local_stream_acceptor::cancel() :150 4x 100.0% 100.0% 100.0% boost::corosio::local_stream_acceptor::local_endpoint() const :158 6x 100.0% 100.0% 100.0%
Line Branch 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/local_stream_acceptor.hpp>
11 #include <boost/corosio/detail/except.hpp>
12 #include <boost/corosio/detail/platform.hpp>
13 #include <boost/corosio/detail/local_stream_acceptor_service.hpp>
14
15 #include <cstring>
16
17 #if BOOST_COROSIO_POSIX
18 #include <unistd.h>
19 #else
20 // Windows: AF_UNIX socket files are reparse points with tag
21 // IO_REPARSE_TAG_AF_UNIX. DeleteFileA reliably removes them;
22 // std::filesystem::remove via libstdc++/MS STL was observed to
23 // silently leave them in place on at least some Windows hosts,
24 // so call the Win32 API directly.
25 #define WIN32_LEAN_AND_MEAN
26 #include <windows.h>
27 #endif
28
29 namespace boost::corosio {
30
31 45x local_stream_acceptor::~local_stream_acceptor()
32 {
33 45x close();
34 45x }
35
36 36x local_stream_acceptor::local_stream_acceptor(capy::execution_context& ctx)
37 36x : io_object(create_handle<detail::local_stream_acceptor_service>(ctx))
38
1/1
✓ Branch 2 → 3 taken 36 times.
 36x , ctx_(ctx)
39 {
40 36x }
41
42 2x local_stream_acceptor::local_stream_acceptor(
43 2x capy::execution_context& ctx, corosio::local_endpoint ep, int backlog)
44 2x : local_stream_acceptor(ctx)
45 {
46
1/2
✗ Branch 5 → 6 not taken.
✓ Branch 5 → 7 taken 2 times.
 2x if (auto ec = open())
47 ✗ detail::throw_system_error(ec, "local_stream_acceptor");
48
2/2
✓ Branch 9 → 10 taken 1 time.
✓ Branch 9 → 11 taken 1 time.
 2x if (auto ec = bind(ep))
49 1x detail::throw_system_error(ec, "local_stream_acceptor");
50
1/2
✗ Branch 13 → 14 not taken.
✓ Branch 13 → 15 taken 1 time.
 1x if (auto ec = listen(backlog))
51 ✗ detail::throw_system_error(ec, "local_stream_acceptor");
52 2x }
53
54 std::error_code
55 34x local_stream_acceptor::open(local_stream proto) noexcept
56 {
57
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 33 times.
 34x if (is_open())
58 1x return {};
59 auto& svc =
60 33x static_cast<detail::local_stream_acceptor_service&>(h_.service());
61 66x auto ec = svc.open_acceptor_socket(
62 33x static_cast<local_stream_acceptor::implementation&>(*h_.get()),
63 proto.family(), proto.type(), proto.protocol());
64 33x return ec;
65 }
66
67 std::error_code
68 3x local_stream_acceptor::assign(native_handle_type fd) noexcept
69 {
70 auto& svc =
71 3x static_cast<detail::local_stream_acceptor_service&>(h_.service());
72 3x auto ec = svc.assign_socket(
73 3x static_cast<local_stream_acceptor::implementation&>(*h_.get()), fd);
74 3x return ec;
75 }
76
77 native_handle_type
78 5x local_stream_acceptor::native_handle() const noexcept
79 {
80
2/2
✓ Branch 3 → 4 taken 2 times.
✓ Branch 3 → 5 taken 3 times.
 5x if (!is_open())
81 {
82 #if BOOST_COROSIO_HAS_IOCP
83 2x return static_cast<native_handle_type>(~0ull); // INVALID_SOCKET
84 #else
85 return -1;
86 #endif
87 }
88 3x return get().native_handle();
89 }
90
91 std::error_code
92 31x local_stream_acceptor::bind(corosio::local_endpoint ep, bind_option opt) noexcept
93 {
94
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 30 times.
 31x if (!is_open())
95 1x return make_error_code(std::errc::bad_file_descriptor);
96
97 32x if (opt == bind_option::unlink_existing &&
98
6/8
✓ Branch 5 → 6 taken 2 times.
✓ Branch 5 → 11 taken 28 times.
✓ Branch 7 → 8 taken 2 times.
✗ Branch 7 → 11 not taken.
✓ Branch 9 → 10 taken 2 times.
✗ Branch 9 → 11 not taken.
✓ Branch 12 → 13 taken 2 times.
✓ Branch 12 → 19 taken 28 times.
 30x !ep.empty() && !ep.is_abstract())
99 {
100 // Best-effort removal; missing file is fine.
101 2x auto p = ep.path();
102 char buf[local_endpoint::max_path_length + 1];
103 2x std::memcpy(buf, p.data(), p.size());
104 2x buf[p.size()] = '\0';
105 #if BOOST_COROSIO_POSIX
106 ::unlink(buf);
107 #else
108 2x ::DeleteFileA(buf);
109 #endif
110 }
111
112 auto& svc =
113 30x static_cast<detail::local_stream_acceptor_service&>(h_.service());
114 30x return svc.bind_acceptor(
115 30x static_cast<local_stream_acceptor::implementation&>(*h_.get()),
116 30x ep);
117 }
118
119 std::error_code
120 23x local_stream_acceptor::listen(int backlog) noexcept
121 {
122
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 22 times.
 23x if (!is_open())
123 1x return make_error_code(std::errc::bad_file_descriptor);
124 auto& svc =
125 22x static_cast<detail::local_stream_acceptor_service&>(h_.service());
126 22x return svc.listen_acceptor(
127 22x static_cast<local_stream_acceptor::implementation&>(*h_.get()),
128 22x backlog);
129 }
130
131 void
132 50x local_stream_acceptor::close() noexcept
133 {
134
2/2
✓ Branch 3 → 4 taken 20 times.
✓ Branch 3 → 5 taken 30 times.
 50x if (!is_open())
135 20x return;
136 30x h_.service().close(h_);
137 }
138
139 native_handle_type
140 6x local_stream_acceptor::release()
141 {
142
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 6 taken 5 times.
 6x if (!is_open())
143 1x detail::throw_system_error(
144 1x make_error_code(std::errc::bad_file_descriptor),
145 "local_stream_acceptor::release");
146 5x return get().release_socket();
147 }
148
149 void
150 4x local_stream_acceptor::cancel() noexcept
151 {
152
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 3 times.
 4x if (!is_open())
153 1x return;
154 3x get().cancel();
155 }
156
157 local_endpoint
158 6x local_stream_acceptor::local_endpoint() const noexcept
159 {
160
2/2
✓ Branch 3 → 4 taken 1 time.
✓ Branch 3 → 5 taken 5 times.
 6x if (!is_open())
161 1x return corosio::local_endpoint{};
162 5x return get().local_endpoint();
163 }
164
165 } // namespace boost::corosio
166