]>
Commit | Line | Data |
---|---|---|
db9ecf05 | 1 | /* SPDX-License-Identifier: LGPL-2.1-or-later */ |
a7893c6b | 2 | |
a7893c6b | 3 | #include <fcntl.h> |
cf0fbc49 | 4 | #include <unistd.h> |
a7893c6b | 5 | |
3ffd4af2 | 6 | #include "bus-container.h" |
a7893c6b LP |
7 | #include "bus-internal.h" |
8 | #include "bus-socket.h" | |
3ffd4af2 | 9 | #include "fd-util.h" |
0cb8e3d1 | 10 | #include "namespace-util.h" |
3ffd4af2 | 11 | #include "process-util.h" |
165fee86 | 12 | #include "string-util.h" |
a7893c6b | 13 | |
bc9fd78c | 14 | int bus_container_connect_socket(sd_bus *b) { |
71136404 | 15 | _cleanup_close_pair_ int pair[2] = EBADF_PAIR; |
254d1313 | 16 | _cleanup_close_ int pidnsfd = -EBADF, mntnsfd = -EBADF, usernsfd = -EBADF, rootfd = -EBADF; |
2b7d6d33 | 17 | int r, error_buf = 0; |
2e87a1fd | 18 | pid_t child; |
2b7d6d33 | 19 | ssize_t n; |
a7893c6b LP |
20 | |
21 | assert(b); | |
22 | assert(b->input_fd < 0); | |
23 | assert(b->output_fd < 0); | |
ee502e0c | 24 | assert(b->nspid > 0 || b->machine); |
a7893c6b | 25 | |
ee502e0c | 26 | if (b->nspid <= 0) { |
165fee86 ZJS |
27 | log_debug("sd-bus: connecting bus%s%s to machine %s...", |
28 | b->description ? " " : "", strempty(b->description), b->machine); | |
29 | ||
ee502e0c LP |
30 | r = container_get_leader(b->machine, &b->nspid); |
31 | if (r < 0) | |
32 | return r; | |
165fee86 ZJS |
33 | } else |
34 | log_debug("sd-bus: connecting bus%s%s to namespace of PID "PID_FMT"...", | |
35 | b->description ? " " : "", strempty(b->description), b->nspid); | |
a7893c6b | 36 | |
671c3419 | 37 | r = namespace_open(b->nspid, &pidnsfd, &mntnsfd, NULL, &usernsfd, &rootfd); |
a7893c6b | 38 | if (r < 0) |
0c201ca9 | 39 | return log_debug_errno(r, "Failed to open namespace of PID "PID_FMT": %m", b->nspid); |
a7893c6b LP |
40 | |
41 | b->input_fd = socket(b->sockaddr.sa.sa_family, SOCK_STREAM|SOCK_CLOEXEC|SOCK_NONBLOCK, 0); | |
42 | if (b->input_fd < 0) | |
0c201ca9 | 43 | return log_debug_errno(errno, "Failed to create a socket: %m"); |
a7893c6b | 44 | |
7fe2903c LP |
45 | b->input_fd = fd_move_above_stdio(b->input_fd); |
46 | ||
a7893c6b LP |
47 | b->output_fd = b->input_fd; |
48 | ||
8f04d2eb | 49 | bus_socket_setup(b); |
a7893c6b | 50 | |
68a3d915 | 51 | if (socketpair(AF_UNIX, SOCK_SEQPACKET|SOCK_CLOEXEC, 0, pair) < 0) |
0c201ca9 | 52 | return log_debug_errno(errno, "Failed to create a socket pair: %m"); |
2b7d6d33 | 53 | |
e9ccae31 | 54 | r = namespace_fork("(sd-buscntrns)", "(sd-buscntr)", NULL, 0, FORK_RESET_SIGNALS|FORK_DEATHSIG_SIGKILL, |
0a885dd0 | 55 | pidnsfd, mntnsfd, -1, usernsfd, rootfd, &child); |
4c253ed1 | 56 | if (r < 0) |
0c201ca9 | 57 | return log_debug_errno(r, "Failed to create namespace for (sd-buscntr): %m"); |
4c253ed1 | 58 | if (r == 0) { |
2b7d6d33 LP |
59 | pair[0] = safe_close(pair[0]); |
60 | ||
0a885dd0 LP |
61 | r = connect(b->input_fd, &b->sockaddr.sa, b->sockaddr_size); |
62 | if (r < 0) { | |
63 | /* Try to send error up */ | |
64 | error_buf = errno; | |
65 | (void) write(pair[1], &error_buf, sizeof(error_buf)); | |
2b7d6d33 | 66 | _exit(EXIT_FAILURE); |
a7893c6b LP |
67 | } |
68 | ||
0a885dd0 | 69 | _exit(EXIT_SUCCESS); |
a7893c6b LP |
70 | } |
71 | ||
2b7d6d33 LP |
72 | pair[1] = safe_close(pair[1]); |
73 | ||
0a885dd0 | 74 | r = wait_for_terminate_and_check("(sd-buscntrns)", child, 0); |
a7893c6b LP |
75 | if (r < 0) |
76 | return r; | |
405a028e | 77 | bool nonzero_exit_status = r != EXIT_SUCCESS; |
a7893c6b | 78 | |
2b7d6d33 LP |
79 | n = read(pair[0], &error_buf, sizeof(error_buf)); |
80 | if (n < 0) | |
0c201ca9 | 81 | return log_debug_errno(errno, "Failed to read error status from (sd-buscntr): %m"); |
2b7d6d33 LP |
82 | |
83 | if (n > 0) { | |
84 | if (n != sizeof(error_buf)) | |
0c201ca9 ZJS |
85 | return log_debug_errno(SYNTHETIC_ERRNO(EIO), |
86 | "Read error status of unexpected length %zd from (sd-buscntr): %m", n); | |
2b7d6d33 LP |
87 | |
88 | if (error_buf < 0) | |
0c201ca9 ZJS |
89 | return log_debug_errno(SYNTHETIC_ERRNO(EBADMSG), |
90 | "Got unexpected error status from (sd-buscntr): %m"); | |
2b7d6d33 LP |
91 | |
92 | if (error_buf == EINPROGRESS) | |
93 | return 1; | |
94 | ||
95 | if (error_buf > 0) | |
e4cdadf3 | 96 | return log_debug_errno(error_buf, "(sd-buscntr) failed to connect to D-Bus socket: %m"); |
2b7d6d33 LP |
97 | } |
98 | ||
405a028e DDM |
99 | if (nonzero_exit_status) |
100 | return -EPROTO; | |
101 | ||
a7893c6b LP |
102 | return bus_socket_start_auth(b); |
103 | } |