src/libsystemd/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-message.h"
  29 #include "bus-error.h"
  30 #include "bus-kernel.h"
  31 #include "bus-util.h"
  32 #include "bus-dump.h"
  33
  34 int main(int argc, char *argv[]) {
  35         _cleanup_close_ int bus_ref = -1;
  36         _cleanup_free_ char *name = NULL, *bus_name = NULL, *address = NULL;
  37         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
  38         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
  39         const char *ua = NULL, *ub = NULL, *the_string = NULL;
  40         sd_bus *a, *b;
  41         int r, pipe_fds[2];
  42         const char *nn;
  43
  44         log_set_max_level(LOG_DEBUG);
  45
  46         assert_se(asprintf(&name, "deine-mutter-%u", (unsigned) getpid()) >= 0);
  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         r = sd_bus_call_method(a, "this.doesnt.exist", "/foo", "meh.mah", "muh", &error, NULL, "s", "yayayay");
 104         assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_SERVICE_UNKNOWN));
 105         assert_se(r == -EHOSTUNREACH);
 106
 107         r = sd_bus_add_match(b, NULL, "interface='waldo.com',member='Piep'", NULL, NULL);
 108         assert_se(r >= 0);
 109
 110         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");
 111         assert_se(r >= 0);
 112
 113         r = sd_bus_try_close(b);
 114         assert_se(r == -EBUSY);
 115
 116         r = sd_bus_process_priority(b, -10, &m);
 117         assert_se(r == -ENOMSG);
 118
 119         r = sd_bus_process(b, &m);
 120         assert_se(r > 0);
 121         assert_se(m);
 122
 123         bus_message_dump(m, stdout, BUS_MESSAGE_DUMP_WITH_HEADER);
 124         assert_se(sd_bus_message_rewind(m, true) >= 0);
 125
 126         r = sd_bus_message_read(m, "s", &the_string);
 127         assert_se(r >= 0);
 128         assert_se(streq(the_string, "I am a string"));
 129
 130         sd_bus_message_unref(m);
 131         m = NULL;
 132
 133         r = sd_bus_request_name(a, "net.x0pointer.foobar", 0);
 134         assert_se(r >= 0);
 135
 136         r = sd_bus_message_new_method_call(b, &m, "net.x0pointer.foobar", "/a/path", "an.inter.face", "AMethod");
 137         assert_se(r >= 0);
 138
 139         assert_se(pipe2(pipe_fds, O_CLOEXEC) >= 0);
 140
 141         assert_se(write(pipe_fds[1], "x", 1) == 1);
 142
 143         pipe_fds[1] = safe_close(pipe_fds[1]);
 144
 145         r = sd_bus_message_append(m, "h", pipe_fds[0]);
 146         assert_se(r >= 0);
 147
 148         pipe_fds[0] = safe_close(pipe_fds[0]);
 149
 150         r = sd_bus_send(b, m, NULL);
 151         assert_se(r >= 0);
 152
 153         for (;;) {
 154                 sd_bus_message_unref(m);
 155                 m = NULL;
 156                 r = sd_bus_process(a, &m);
 157                 assert_se(r > 0);
 158                 assert_se(m);
 159
 160                 bus_message_dump(m, stdout, BUS_MESSAGE_DUMP_WITH_HEADER);
 161                 assert_se(sd_bus_message_rewind(m, true) >= 0);
 162
 163                 if (sd_bus_message_is_method_call(m, "an.inter.face", "AMethod")) {
 164                         int fd;
 165                         char x;
 166
 167                         r = sd_bus_message_read(m, "h", &fd);
 168                         assert_se(r >= 0);
 169
 170                         assert_se(read(fd, &x, 1) == 1);
 171                         assert_se(x == 'x');
 172                         break;
 173                 }
 174         }
 175
 176         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 177         assert_se(r >= 0);
 178
 179         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 180         assert_se(r == -ESRCH);
 181
 182         r = sd_bus_try_close(a);
 183         assert_se(r >= 0);
 184
 185         sd_bus_unref(a);
 186         sd_bus_unref(b);
 187
 188         return 0;
 189 }