/Users/brunogarcia/projects/bitcoin-core-dev/src/util/tokenpipe.cpp
Line | Count | Source |
1 | | // Copyright (c) 2021-present The Bitcoin Core developers |
2 | | // Distributed under the MIT software license, see the accompanying |
3 | | // file COPYING or http://www.opensource.org/licenses/mit-license.php. |
4 | | |
5 | | #include <bitcoin-build-config.h> // IWYU pragma: keep |
6 | | |
7 | | #include <util/tokenpipe.h> |
8 | | |
9 | | #ifndef WIN32 |
10 | | |
11 | | #include <cerrno> |
12 | | #include <optional> |
13 | | |
14 | | #include <fcntl.h> |
15 | | #include <sys/types.h> |
16 | | #include <unistd.h> |
17 | | |
18 | | TokenPipeEnd TokenPipe::TakeReadEnd() |
19 | 0 | { |
20 | 0 | TokenPipeEnd res(m_fds[0]); |
21 | 0 | m_fds[0] = -1; |
22 | 0 | return res; |
23 | 0 | } |
24 | | |
25 | | TokenPipeEnd TokenPipe::TakeWriteEnd() |
26 | 0 | { |
27 | 0 | TokenPipeEnd res(m_fds[1]); |
28 | 0 | m_fds[1] = -1; |
29 | 0 | return res; |
30 | 0 | } |
31 | | |
32 | 0 | TokenPipeEnd::TokenPipeEnd(int fd) : m_fd(fd) |
33 | 0 | { |
34 | 0 | } |
35 | | |
36 | | TokenPipeEnd::~TokenPipeEnd() |
37 | 2 | { |
38 | 2 | Close(); |
39 | 2 | } |
40 | | |
41 | | int TokenPipeEnd::TokenWrite(uint8_t token) |
42 | 0 | { |
43 | 0 | while (true) { |
44 | 0 | ssize_t result = write(m_fd, &token, 1); |
45 | 0 | if (result < 0) { |
46 | | // Failure. It's possible that the write was interrupted by a signal, |
47 | | // in that case retry. |
48 | 0 | if (errno != EINTR) { |
49 | 0 | return TS_ERR; |
50 | 0 | } |
51 | 0 | } else if (result == 0) { |
52 | 0 | return TS_EOS; |
53 | 0 | } else { // ==1 |
54 | 0 | return 0; |
55 | 0 | } |
56 | 0 | } |
57 | 0 | } |
58 | | |
59 | | int TokenPipeEnd::TokenRead() |
60 | 0 | { |
61 | 0 | uint8_t token; |
62 | 0 | while (true) { |
63 | 0 | ssize_t result = read(m_fd, &token, 1); |
64 | 0 | if (result < 0) { |
65 | | // Failure. Check if the read was interrupted by a signal, |
66 | | // in that case retry. |
67 | 0 | if (errno != EINTR) { |
68 | 0 | return TS_ERR; |
69 | 0 | } |
70 | 0 | } else if (result == 0) { |
71 | 0 | return TS_EOS; |
72 | 0 | } else { // ==1 |
73 | 0 | return token; |
74 | 0 | } |
75 | 0 | } |
76 | 0 | return token; |
77 | 0 | } |
78 | | |
79 | | void TokenPipeEnd::Close() |
80 | 2 | { |
81 | 2 | if (m_fd != -1) close(m_fd); |
82 | 2 | m_fd = -1; |
83 | 2 | } |
84 | | |
85 | | std::optional<TokenPipe> TokenPipe::Make() |
86 | 0 | { |
87 | 0 | int fds[2] = {-1, -1}; |
88 | | #if HAVE_O_CLOEXEC && HAVE_DECL_PIPE2 |
89 | | if (pipe2(fds, O_CLOEXEC) != 0) { |
90 | | return std::nullopt; |
91 | | } |
92 | | #else |
93 | 0 | if (pipe(fds) != 0) { |
94 | 0 | return std::nullopt; |
95 | 0 | } |
96 | 0 | #endif |
97 | 0 | return TokenPipe(fds); |
98 | 0 | } |
99 | | |
100 | | TokenPipe::~TokenPipe() |
101 | 0 | { |
102 | 0 | Close(); |
103 | 0 | } |
104 | | |
105 | | void TokenPipe::Close() |
106 | 0 | { |
107 | 0 | if (m_fds[0] != -1) close(m_fds[0]); |
108 | 0 | if (m_fds[1] != -1) close(m_fds[1]); |
109 | 0 | m_fds[0] = m_fds[1] = -1; |
110 | 0 | } |
111 | | |
112 | | #endif // WIN32 |