Branch data     Line data    Source code

       1                 :            : /* SPDX-License-Identifier: LGPL-2.1+ */
       2                 :            : 
       3                 :            : #include <fcntl.h>
       4                 :            : #include <unistd.h>
       5                 :            : 
       6                 :            : #include "bus-container.h"
       7                 :            : #include "bus-internal.h"
       8                 :            : #include "bus-socket.h"
       9                 :            : #include "fd-util.h"
      10                 :            : #include "namespace-util.h"
      11                 :            : #include "process-util.h"
      12                 :            : #include "util.h"
      13                 :            : 
      14                 :          0 : int bus_container_connect_socket(sd_bus *b) {
      15                 :          0 :         _cleanup_close_pair_ int pair[2] = { -1, -1 };
      16                 :          0 :         _cleanup_close_ int pidnsfd = -1, mntnsfd = -1, usernsfd = -1, rootfd = -1;
      17                 :          0 :         int r, error_buf = 0;
      18                 :            :         pid_t child;
      19                 :            :         ssize_t n;
      20                 :            : 
      21         [ #  # ]:          0 :         assert(b);
      22         [ #  # ]:          0 :         assert(b->input_fd < 0);
      23         [ #  # ]:          0 :         assert(b->output_fd < 0);
      24   [ #  #  #  # ]:          0 :         assert(b->nspid > 0 || b->machine);
      25                 :            : 
      26         [ #  # ]:          0 :         if (b->nspid <= 0) {
      27                 :          0 :                 r = container_get_leader(b->machine, &b->nspid);
      28         [ #  # ]:          0 :                 if (r < 0)
      29                 :          0 :                         return r;
      30                 :            :         }
      31                 :            : 
      32                 :          0 :         r = namespace_open(b->nspid, &pidnsfd, &mntnsfd, NULL, &usernsfd, &rootfd);
      33         [ #  # ]:          0 :         if (r < 0)
      34                 :          0 :                 return r;
      35                 :            : 
      36                 :          0 :         b->input_fd = socket(b->sockaddr.sa.sa_family, SOCK_STREAM|SOCK_CLOEXEC|SOCK_NONBLOCK, 0);
      37         [ #  # ]:          0 :         if (b->input_fd < 0)
      38                 :          0 :                 return -errno;
      39                 :            : 
      40                 :          0 :         b->input_fd = fd_move_above_stdio(b->input_fd);
      41                 :            : 
      42                 :          0 :         b->output_fd = b->input_fd;
      43                 :            : 
      44                 :          0 :         bus_socket_setup(b);
      45                 :            : 
      46         [ #  # ]:          0 :         if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, pair) < 0)
      47                 :          0 :                 return -errno;
      48                 :            : 
      49                 :          0 :         r = namespace_fork("(sd-buscntrns)", "(sd-buscntr)", NULL, 0, FORK_RESET_SIGNALS|FORK_DEATHSIG,
      50                 :            :                            pidnsfd, mntnsfd, -1, usernsfd, rootfd, &child);
      51         [ #  # ]:          0 :         if (r < 0)
      52                 :          0 :                 return r;
      53         [ #  # ]:          0 :         if (r == 0) {
      54                 :          0 :                 pair[0] = safe_close(pair[0]);
      55                 :            : 
      56                 :          0 :                 r = connect(b->input_fd, &b->sockaddr.sa, b->sockaddr_size);
      57         [ #  # ]:          0 :                 if (r < 0) {
      58                 :            :                         /* Try to send error up */
      59                 :          0 :                         error_buf = errno;
      60                 :          0 :                         (void) write(pair[1], &error_buf, sizeof(error_buf));
      61                 :          0 :                         _exit(EXIT_FAILURE);
      62                 :            :                 }
      63                 :            : 
      64                 :          0 :                 _exit(EXIT_SUCCESS);
      65                 :            :         }
      66                 :            : 
      67                 :          0 :         pair[1] = safe_close(pair[1]);
      68                 :            : 
      69                 :          0 :         r = wait_for_terminate_and_check("(sd-buscntrns)", child, 0);
      70         [ #  # ]:          0 :         if (r < 0)
      71                 :          0 :                 return r;
      72         [ #  # ]:          0 :         if (r != EXIT_SUCCESS)
      73                 :          0 :                 return -EPROTO;
      74                 :            : 
      75                 :          0 :         n = read(pair[0], &error_buf, sizeof(error_buf));
      76         [ #  # ]:          0 :         if (n < 0)
      77                 :          0 :                 return -errno;
      78                 :            : 
      79         [ #  # ]:          0 :         if (n > 0) {
      80         [ #  # ]:          0 :                 if (n != sizeof(error_buf))
      81                 :          0 :                         return -EIO;
      82                 :            : 
      83         [ #  # ]:          0 :                 if (error_buf < 0)
      84                 :          0 :                         return -EIO;
      85                 :            : 
      86         [ #  # ]:          0 :                 if (error_buf == EINPROGRESS)
      87                 :          0 :                         return 1;
      88                 :            : 
      89         [ #  # ]:          0 :                 if (error_buf > 0)
      90                 :          0 :                         return -error_buf;
      91                 :            :         }
      92                 :            : 
      93                 :          0 :         return bus_socket_start_auth(b);
      94                 :            : }