0N/A

0N/A

0N/A#include <sys/socket.h>

0N/A#include <sys/un.h>

3231N/A#include <sys/types.h>

0N/A#include <fcntl.h>

0N/A#include <unistd.h>

2086N/A#include <string.h>

0N/A#include <errno.h>

0N/A#include <sys/poll.h>

0N/A#include <stddef.h>

0N/A#include <getopt.h>

0N/A

0N/A#include "log.h"

0N/A#include "util.h"

699N/A#include "socket-util.h"

0N/A#include "sd-daemon.h"

510N/A#include "sd-bus.h"

0N/A#include "bus-internal.h"

4134N/A#include "bus-message.h"

0N/A#include "bus-util.h"

1177N/A#include "build.h"

1400N/A

2086N/A#define DEFAULT_BUS_PATH "unix:path=/run/dbus/system_bus_socket"

0N/A

0N/Aconst char *arg_bus_path = DEFAULT_BUS_PATH;

0N/A

0N/Astatic int help(void) {

0N/A

0N/A printf("%s [OPTIONS...]\n\n"

0N/A "STDIO or socket-activatable proxy to a given DBus endpoint.\n\n"

0N/A " -h --help Show this help\n"

0N/A " --version Show package version\n"

0N/A " --bus-path=PATH Path to the kernel bus (default: %s)\n",

1177N/A program_invocation_short_name, DEFAULT_BUS_PATH);

0N/A

1400N/A return 0;

1400N/A}

1400N/A

1400N/Astatic int parse_argv(int argc, char *argv[]) {

1400N/A

0N/A enum {

1177N/A ARG_VERSION = 0x100,

0N/A };

0N/A

1177N/A static const struct option options[] = {

0N/A { "help", no_argument, NULL, 'h' },

0N/A { "bus-path", required_argument, NULL, 'p' },

0N/A { NULL, 0, NULL, 0 }

0N/A };

1177N/A

1177N/A int c;

1177N/A

1177N/A assert(argc >= 0);

1177N/A assert(argv);

1177N/A

1177N/A while ((c = getopt_long(argc, argv, "hsup:", options, NULL)) >= 0) {

1177N/A

1177N/A switch (c) {

0N/A

0N/A case 'h':

0N/A help();

0N/A return 0;

1177N/A

0N/A case ARG_VERSION:

0N/A puts(PACKAGE_STRING);

0N/A puts(SYSTEMD_FEATURES);

0N/A return 0;

0N/A

0N/A case '?':

0N/A return -EINVAL;

0N/A

0N/A case 'p':

0N/A arg_bus_path = optarg;

1177N/A break;

1177N/A

1177N/A default:

1177N/A log_error("Unknown option code %c", c);

1177N/A return -EINVAL;

0N/A }

0N/A }

0N/A

0N/A return 1;

0N/A}

0N/A

0N/Aint main(int argc, char *argv[]) {

0N/A _cleanup_bus_unref_ sd_bus *a = NULL, *b = NULL;

0N/A sd_id128_t server_id;

0N/A bool is_unix;

0N/A int r, in_fd, out_fd;

0N/A

1177N/A log_set_target(LOG_TARGET_JOURNAL_OR_KMSG);

1177N/A log_parse_environment();

1177N/A log_open();

1177N/A

1177N/A r = parse_argv(argc, argv);

1177N/A if (r <= 0)

1177N/A goto finish;

0N/A

0N/A r = sd_listen_fds(0);

0N/A if (r == 0) {

0N/A in_fd = STDIN_FILENO;

0N/A out_fd = STDOUT_FILENO;

0N/A } else if (r == 1) {

0N/A in_fd = SD_LISTEN_FDS_START;

0N/A out_fd = SD_LISTEN_FDS_START;

0N/A } else {

0N/A log_error("Illegal number of file descriptors passed\n");

0N/A goto finish;

0N/A }

0N/A

0N/A is_unix =

0N/A sd_is_socket(in_fd, AF_UNIX, 0, 0) > 0 &&

0N/A sd_is_socket(out_fd, AF_UNIX, 0, 0) > 0;

0N/A

0N/A r = sd_bus_new(&a);

0N/A if (r < 0) {

0N/A log_error("Failed to allocate bus: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_set_address(a, arg_bus_path);

0N/A if (r < 0) {

0N/A log_error("Failed to set address to connect to: %s", strerror(-r));

0N/A goto finish;

0N/A }

699N/A

1177N/A r = sd_bus_negotiate_fds(a, is_unix);

0N/A if (r < 0) {

0N/A log_error("Failed to set FD negotiation: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_start(a);

0N/A if (r < 0) {

0N/A log_error("Failed to start bus client: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_get_server_id(a, &server_id);

0N/A if (r < 0) {

0N/A log_error("Failed to get server ID: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

282N/A r = sd_bus_new(&b);

0N/A if (r < 0) {

0N/A log_error("Failed to allocate bus: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_set_fd(b, in_fd, out_fd);

0N/A if (r < 0) {

0N/A log_error("Failed to set fds: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_set_server(b, 1, server_id);

0N/A if (r < 0) {

4134N/A log_error("Failed to set server mode: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_negotiate_fds(b, is_unix);

0N/A if (r < 0) {

0N/A log_error("Failed to set FD negotiation: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_set_anonymous(b, true);

0N/A if (r < 0) {

0N/A log_error("Failed to set anonymous authentication: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_start(b);

0N/A if (r < 0) {

0N/A log_error("Failed to start bus client: %s", strerror(-r));

0N/A goto finish;

4134N/A }

0N/A

0N/A for (;;) {

0N/A _cleanup_bus_message_unref_ sd_bus_message *m = NULL;

0N/A int events_a, events_b, fd;

0N/A uint64_t timeout_a, timeout_b, t;

0N/A struct timespec _ts, *ts;

0N/A

0N/A r = sd_bus_process(a, &m);

0N/A if (r < 0) {

4134N/A log_error("Failed to process bus a: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A if (m) {

0N/A r = sd_bus_send(b, m, NULL);

0N/A if (r < 0) {

0N/A log_error("Failed to send message: %s", strerror(-r));

0N/A goto finish;

0N/A }

1177N/A }

0N/A

0N/A if (r > 0)

0N/A continue;

0N/A

0N/A r = sd_bus_process(b, &m);

0N/A if (r < 0) {

0N/A /* treat 'connection reset by peer' as clean exit condition */

0N/A if (r == -ECONNRESET)

0N/A r = 0;

0N/A

0N/A goto finish;

0N/A }

0N/A

0N/A if (m) {

0N/A r = sd_bus_send(a, m, NULL);

0N/A if (r < 0) {

0N/A log_error("Failed to send message: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A }

0N/A

0N/A if (r > 0)

0N/A continue;

0N/A

0N/A fd = sd_bus_get_fd(a);

0N/A if (fd < 0) {

0N/A log_error("Failed to get fd: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A events_a = sd_bus_get_events(a);

0N/A if (events_a < 0) {

0N/A log_error("Failed to get events mask: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_get_timeout(a, &timeout_a);

0N/A if (r < 0) {

0N/A log_error("Failed to get timeout: %s", strerror(-r));

0N/A goto finish;

0N/A }

4134N/A

0N/A events_b = sd_bus_get_events(b);

0N/A if (events_b < 0) {

0N/A log_error("Failed to get events mask: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A r = sd_bus_get_timeout(b, &timeout_b);

0N/A if (r < 0) {

0N/A log_error("Failed to get timeout: %s", strerror(-r));

0N/A goto finish;

0N/A }

0N/A

0N/A t = timeout_a;

0N/A if (t == (uint64_t) -1 || (timeout_b != (uint64_t) -1 && timeout_b < timeout_a))

0N/A t = timeout_b;

0N/A

0N/A if (t == (uint64_t) -1)

0N/A ts = NULL;

0N/A else {

0N/A usec_t nw;

0N/A

0N/A nw = now(CLOCK_MONOTONIC);

0N/A if (t > nw)

0N/A t -= nw;

0N/A else

0N/A t = 0;

0N/A

0N/A ts = timespec_store(&_ts, t);

0N/A }

2086N/A

2086N/A {

0N/A struct pollfd p[3] = {

0N/A {.fd = fd, .events = events_a, },

0N/A {.fd = STDIN_FILENO, .events = events_b & POLLIN, },

0N/A {.fd = STDOUT_FILENO, .events = events_b & POLLOUT, }};

0N/A

0N/A r = ppoll(p, ELEMENTSOF(p), ts, NULL);

0N/A }

0N/A if (r < 0) {

0N/A log_error("ppoll() failed: %m");

868N/A goto finish;

868N/A }

1400N/A }

868N/A

0N/A r = 0;

0N/A

0N/Afinish:

0N/A return r < 0 ? EXIT_FAILURE : EXIT_SUCCESS;

0N/A}

868N/A