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_name(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, _SD_BUS_CREDS_ALL) >= 0);
  74
  75         assert_se(sd_bus_negotiate_timestamp(b, 1) >= 0);
  76         assert_se(sd_bus_negotiate_creds(b, _SD_BUS_CREDS_ALL) >= 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         r = sd_bus_get_unique_name(a, &ua);
  85         assert_se(r >= 0);
  86         printf("unique a: %s\n", ua);
  87
  88         r = sd_bus_get_name(a, &nn);
  89         assert_se(r >= 0);
  90         printf("name of a: %s\n", nn);
  91
  92         r = sd_bus_get_unique_name(b, &ub);
  93         assert_se(r >= 0);
  94         printf("unique b: %s\n", ub);
  95
  96         r = sd_bus_get_name(b, &nn);
  97         assert_se(r >= 0);
  98         printf("name of b: %s\n", nn);
  99
 100         r = sd_bus_call_method(a, "this.doesnt.exist", "/foo", "meh.mah", "muh", &error, NULL, "s", "yayayay");
 101         assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_SERVICE_UNKNOWN));
 102         assert_se(r == -EHOSTUNREACH);
 103
 104         r = sd_bus_add_match(b, "interface='waldo.com',member='Piep'", NULL, NULL);
 105         assert_se(r >= 0);
 106
 107         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");
 108         assert_se(r >= 0);
 109
 110         r = sd_bus_try_close(b);
 111         assert_se(r == -EBUSY);
 112
 113         r = sd_bus_process(b, &m);
 114         assert_se(r > 0);
 115         assert_se(m);
 116
 117         bus_message_dump(m, stdout, true);
 118         assert_se(sd_bus_message_rewind(m, true) >= 0);
 119
 120         r = sd_bus_message_read(m, "s", &the_string);
 121         assert_se(r >= 0);
 122         assert_se(streq(the_string, "I am a string"));
 123
 124         sd_bus_message_unref(m);
 125         m = NULL;
 126
 127         r = sd_bus_request_name(a, "net.x0pointer.foobar", 0);
 128         assert_se(r >= 0);
 129
 130         r = sd_bus_message_new_method_call(b, "net.x0pointer.foobar", "/a/path", "an.inter.face", "AMethod", &m);
 131         assert_se(r >= 0);
 132
 133         assert_se(pipe2(pipe_fds, O_CLOEXEC) >= 0);
 134
 135         assert_se(write(pipe_fds[1], "x", 1) == 1);
 136
 137         close_nointr_nofail(pipe_fds[1]);
 138         pipe_fds[1] = -1;
 139
 140         r = sd_bus_message_append(m, "h", pipe_fds[0]);
 141         assert_se(r >= 0);
 142
 143         close_nointr_nofail(pipe_fds[0]);
 144         pipe_fds[0] = -1;
 145
 146         r = sd_bus_send(b, m, NULL);
 147         assert_se(r >= 0);
 148
 149         for (;;) {
 150                 sd_bus_message_unref(m);
 151                 m = NULL;
 152                 r = sd_bus_process(a, &m);
 153                 assert_se(r > 0);
 154                 assert_se(m);
 155
 156                 bus_message_dump(m, stdout, true);
 157                 assert_se(sd_bus_message_rewind(m, true) >= 0);
 158
 159                 if (sd_bus_message_is_method_call(m, "an.inter.face", "AMethod")) {
 160                         int fd;
 161                         char x;
 162
 163                         r = sd_bus_message_read(m, "h", &fd);
 164                         assert_se(r >= 0);
 165
 166                         assert_se(read(fd, &x, 1) == 1);
 167                         assert_se(x == 'x');
 168                         break;
 169                 }
 170         }
 171
 172         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 173         assert_se(r >= 0);
 174
 175         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 176         assert_se(r == -ESRCH);
 177
 178         r = sd_bus_try_close(a);
 179         assert_se(r >= 0);
 180
 181         sd_bus_unref(a);
 182         sd_bus_unref(b);
 183
 184         return 0;
 185 }