Index/src / corosio / src / local_socket_pair.cpp

src/corosio/src/local_socket_pair.cpp

59.3% Lines (35/59) 100.0% List of functions (4/4) 20.0% Branches (14/70)
[ ] prev/next file n p prev/next uncovered line
local_socket_pair.cpp
f(x) Functions (4)
Function Calls Lines Branches Blocks
boost::corosio::(anonymous namespace)::make_nonblock_cloexec(int) :30 28x 50.0% 16.7% 23.0% boost::corosio::(anonymous namespace)::create_pair(int, int*) :49 14x 53.8% 18.8% 27.0% boost::corosio::make_local_stream_pair(boost::corosio::io_context&) :77 8x 64.7% 22.2% 22.0% boost::corosio::make_local_datagram_pair(boost::corosio::io_context&) :105 6x 64.7% 22.2% 22.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_socket_pair.hpp>
11 #include <boost/corosio/io_context.hpp>
12 #include <boost/corosio/detail/platform.hpp>
13
14 #if BOOST_COROSIO_POSIX
15
16 #include <stdexcept>
17 #include <system_error>
18 #include <utility>
19
20 #include <fcntl.h>
21 #include <sys/socket.h>
22 #include <unistd.h>
23
24 namespace boost::corosio {
25
26 namespace {
27
28 #ifndef SOCK_NONBLOCK
29 void
30 28x make_nonblock_cloexec(int fd)
31 {
32 28x int fl = ::fcntl(fd, F_GETFL, 0);
33
1/2
✓ Branch 0 taken 28 times.
✗ Branch 1 not taken.
 28x if (fl < 0)
34 ✗ throw std::system_error(
35 ✗ std::error_code(errno, std::system_category()),
36 "fcntl(F_GETFL)");
37
1/2
✓ Branch 0 taken 28 times.
✗ Branch 1 not taken.
 28x if (::fcntl(fd, F_SETFL, fl | O_NONBLOCK) < 0)
38 ✗ throw std::system_error(
39 ✗ std::error_code(errno, std::system_category()),
40 "fcntl(F_SETFL)");
41
1/2
✓ Branch 0 taken 28 times.
✗ Branch 1 not taken.
 28x if (::fcntl(fd, F_SETFD, FD_CLOEXEC) < 0)
42 ✗ throw std::system_error(
43 ✗ std::error_code(errno, std::system_category()),
44 "fcntl(F_SETFD)");
45 28x }
46 #endif
47
48 void
49 14x create_pair(int type, int fds[2])
50 {
51 14x int flags = type;
52 #ifdef SOCK_NONBLOCK
53 flags |= SOCK_NONBLOCK | SOCK_CLOEXEC;
54 #endif
55
1/2
✓ Branch 0 taken 14 times.
✗ Branch 1 not taken.
 14x if (::socketpair(AF_UNIX, flags, 0, fds) != 0)
56 ✗ throw std::system_error(
57 ✗ std::error_code(errno, std::system_category()),
58 "socketpair");
59 #ifndef SOCK_NONBLOCK
60 try
61 {
62
1/2
✓ Branch 0 taken 14 times.
✗ Branch 1 not taken.
 14x make_nonblock_cloexec(fds[0]);
63
1/2
✓ Branch 0 taken 14 times.
✗ Branch 1 not taken.
 14x make_nonblock_cloexec(fds[1]);
64 14x }
65 catch (...)
66 {
67 ✗ ::close(fds[0]);
68 ✗ ::close(fds[1]);
69 ✗ throw;
70 ✗ }
71 #endif
72 14x }
73
74 } // namespace
75
76 std::pair<local_stream_socket, local_stream_socket>
77 8x make_local_stream_pair(io_context& ctx)
78 {
79 int fds[2];
80 8x create_pair(SOCK_STREAM, fds);
81
82 try
83 {
84
1/2
✓ Branch 0 taken 8 times.
✗ Branch 1 not taken.
 8x local_stream_socket s1(ctx);
85
1/2
✓ Branch 0 taken 8 times.
✗ Branch 1 not taken.
 8x local_stream_socket s2(ctx);
86
87
1/2
✓ Branch 0 taken 8 times.
✗ Branch 1 not taken.
 8x s1.assign(fds[0]);
88 8x fds[0] = -1;
89
1/2
✓ Branch 0 taken 8 times.
✗ Branch 1 not taken.
 8x s2.assign(fds[1]);
90 8x fds[1] = -1;
91
92 8x return {std::move(s1), std::move(s2)};
93 8x }
94 catch (...)
95 {
96 ✗ if (fds[0] >= 0)
97 ✗ ::close(fds[0]);
98 ✗ if (fds[1] >= 0)
99 ✗ ::close(fds[1]);
100 ✗ throw;
101 ✗ }
102 8x }
103
104 std::pair<local_datagram_socket, local_datagram_socket>
105 6x make_local_datagram_pair(io_context& ctx)
106 {
107 int fds[2];
108 6x create_pair(SOCK_DGRAM, fds);
109
110 try
111 {
112
1/2
✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
 6x local_datagram_socket s1(ctx);
113
1/2
✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
 6x local_datagram_socket s2(ctx);
114
115
1/2
✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
 6x s1.assign(fds[0]);
116 6x fds[0] = -1;
117
1/2
✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
 6x s2.assign(fds[1]);
118 6x fds[1] = -1;
119
120 6x return {std::move(s1), std::move(s2)};
121 6x }
122 catch (...)
123 {
124 ✗ if (fds[0] >= 0)
125 ✗ ::close(fds[0]);
126 ✗ if (fds[1] >= 0)
127 ✗ ::close(fds[1]);
128 ✗ throw;
129 ✗ }
130 6x }
131
132 } // namespace boost::corosio
133
134 #endif // BOOST_COROSIO_POSIX
135