src/libelogind/sd-bus/test-bus-kernel.c

   1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
   2
   3 /***
   4   This file is part of systemd.
   5
   6   Copyright 2013 Lennart Poettering
   7
   8   systemd is free software; you can redistribute it and/or modify it
   9   under the terms of the GNU Lesser General Public License as published by
  10   the Free Software Foundation; either version 2.1 of the License, or
  11   (at your option) any later version.
  12
  13   systemd is distributed in the hope that it will be useful, but
  14   WITHOUT ANY WARRANTY; without even the implied warranty of
  15   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  16   Lesser General Public License for more details.
  17
  18   You should have received a copy of the GNU Lesser General Public License
  19   along with systemd; If not, see <http://www.gnu.org/licenses/>.
  20 ***/
  21
  22 #include <fcntl.h>
  23
  24 #include "util.h"
  25 #include "log.h"
  26
  27 #include "sd-bus.h"
  28 #include "bus-kernel.h"
  29 #include "bus-util.h"
  30 #include "bus-dump.h"
  31
  32 int main(int argc, char *argv[]) {
  33         _cleanup_close_ int bus_ref = -1;
  34         _cleanup_free_ char *name = NULL, *bus_name = NULL, *address = NULL, *bname = NULL;
  35         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
  36         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
  37         const char *ua = NULL, *ub = NULL, *the_string = NULL;
  38         sd_bus *a, *b;
  39         int r, pipe_fds[2];
  40         const char *nn;
  41
  42         log_set_max_level(LOG_DEBUG);
  43
  44         assert_se(asprintf(&name, "deine-mutter-%u", (unsigned) getpid()) >= 0);
  45
  46         bus_kernel_fix_attach_mask();
  47
  48         bus_ref = bus_kernel_create_bus(name, false, &bus_name);
  49         if (bus_ref == -ENOENT)
  50                 return EXIT_TEST_SKIP;
  51
  52         assert_se(bus_ref >= 0);
  53
  54         address = strappend("kernel:path=", bus_name);
  55         assert_se(address);
  56
  57         r = sd_bus_new(&a);
  58         assert_se(r >= 0);
  59
  60         r = sd_bus_new(&b);
  61         assert_se(r >= 0);
  62
  63         r = sd_bus_set_description(a, "a");
  64         assert_se(r >= 0);
  65
  66         r = sd_bus_set_address(a, address);
  67         assert_se(r >= 0);
  68
  69         r = sd_bus_set_address(b, address);
  70         assert_se(r >= 0);
  71
  72         assert_se(sd_bus_negotiate_timestamp(a, 1) >= 0);
  73         assert_se(sd_bus_negotiate_creds(a, true, _SD_BUS_CREDS_ALL) >= 0);
  74
  75         assert_se(sd_bus_negotiate_timestamp(b, 0) >= 0);
  76         assert_se(sd_bus_negotiate_creds(b, true, 0) >= 0);
  77
  78         r = sd_bus_start(a);
  79         assert_se(r >= 0);
  80
  81         r = sd_bus_start(b);
  82         assert_se(r >= 0);
  83
  84         assert_se(sd_bus_negotiate_timestamp(b, 1) >= 0);
  85         assert_se(sd_bus_negotiate_creds(b, true, _SD_BUS_CREDS_ALL) >= 0);
  86
  87         r = sd_bus_get_unique_name(a, &ua);
  88         assert_se(r >= 0);
  89         printf("unique a: %s\n", ua);
  90
  91         r = sd_bus_get_description(a, &nn);
  92         assert_se(r >= 0);
  93         printf("name of a: %s\n", nn);
  94
  95         r = sd_bus_get_unique_name(b, &ub);
  96         assert_se(r >= 0);
  97         printf("unique b: %s\n", ub);
  98
  99         r = sd_bus_get_description(b, &nn);
 100         assert_se(r >= 0);
 101         printf("name of b: %s\n", nn);
 102
 103         assert_se(bus_kernel_get_bus_name(b, &bname) >= 0);
 104         assert_se(endswith(bname, name));
 105
 106         r = sd_bus_call_method(a, "this.doesnt.exist", "/foo", "meh.mah", "muh", &error, NULL, "s", "yayayay");
 107         assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_SERVICE_UNKNOWN));
 108         assert_se(r == -EHOSTUNREACH);
 109
 110         r = sd_bus_add_match(b, NULL, "interface='waldo.com',member='Piep'", NULL, NULL);
 111         assert_se(r >= 0);
 112
 113         r = sd_bus_emit_signal(a, "/foo/bar/waldo", "waldo.com", "Piep", "sss", "I am a string", "/this/is/a/path", "and.this.a.domain.name");
 114         assert_se(r >= 0);
 115
 116         r = sd_bus_try_close(b);
 117         assert_se(r == -EBUSY);
 118
 119         r = sd_bus_process_priority(b, -10, &m);
 120         assert_se(r == 0);
 121
 122         r = sd_bus_process(b, &m);
 123         assert_se(r > 0);
 124         assert_se(m);
 125
 126         bus_message_dump(m, stdout, BUS_MESSAGE_DUMP_WITH_HEADER);
 127         assert_se(sd_bus_message_rewind(m, true) >= 0);
 128
 129         r = sd_bus_message_read(m, "s", &the_string);
 130         assert_se(r >= 0);
 131         assert_se(streq(the_string, "I am a string"));
 132
 133         sd_bus_message_unref(m);
 134         m = NULL;
 135
 136         r = sd_bus_request_name(a, "net.x0pointer.foobar", 0);
 137         assert_se(r >= 0);
 138
 139         r = sd_bus_message_new_method_call(b, &m, "net.x0pointer.foobar", "/a/path", "an.inter.face", "AMethod");
 140         assert_se(r >= 0);
 141
 142         assert_se(pipe2(pipe_fds, O_CLOEXEC) >= 0);
 143
 144         assert_se(write(pipe_fds[1], "x", 1) == 1);
 145
 146         pipe_fds[1] = safe_close(pipe_fds[1]);
 147
 148         r = sd_bus_message_append(m, "h", pipe_fds[0]);
 149         assert_se(r >= 0);
 150
 151         pipe_fds[0] = safe_close(pipe_fds[0]);
 152
 153         r = sd_bus_send(b, m, NULL);
 154         assert_se(r >= 0);
 155
 156         for (;;) {
 157                 sd_bus_message_unref(m);
 158                 m = NULL;
 159                 r = sd_bus_process(a, &m);
 160                 assert_se(r > 0);
 161                 assert_se(m);
 162
 163                 bus_message_dump(m, stdout, BUS_MESSAGE_DUMP_WITH_HEADER);
 164                 assert_se(sd_bus_message_rewind(m, true) >= 0);
 165
 166                 if (sd_bus_message_is_method_call(m, "an.inter.face", "AMethod")) {
 167                         int fd;
 168                         char x;
 169
 170                         r = sd_bus_message_read(m, "h", &fd);
 171                         assert_se(r >= 0);
 172
 173                         assert_se(read(fd, &x, 1) == 1);
 174                         assert_se(x == 'x');
 175                         break;
 176                 }
 177         }
 178
 179         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 180         assert_se(r >= 0);
 181
 182         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 183         assert_se(r == -ESRCH);
 184
 185         r = sd_bus_try_close(a);
 186         assert_se(r >= 0);
 187
 188         sd_bus_unref(a);
 189         sd_bus_unref(b);
 190
 191         return 0;
 192 }