src/libsystemd-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 *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
  43         log_set_max_level(LOG_DEBUG);
  44
  45         bus_ref = bus_kernel_create_bus("deine-mutter", &bus_name);
  46         if (bus_ref == -ENOENT)
  47                 return EXIT_TEST_SKIP;
  48
  49         assert_se(bus_ref >= 0);
  50
  51         address = strappend("kernel:path=", bus_name);
  52         assert_se(address);
  53
  54         r = sd_bus_new(&a);
  55         assert_se(r >= 0);
  56
  57         r = sd_bus_new(&b);
  58         assert_se(r >= 0);
  59
  60         r = sd_bus_set_address(a, address);
  61         assert_se(r >= 0);
  62
  63         r = sd_bus_set_address(b, address);
  64         assert_se(r >= 0);
  65
  66         assert_se(sd_bus_negotiate_attach_timestamp(a, 1) >= 0);
  67         assert_se(sd_bus_negotiate_attach_creds(a, _SD_BUS_CREDS_ALL) >= 0);
  68
  69         assert_se(sd_bus_negotiate_attach_timestamp(b, 1) >= 0);
  70         assert_se(sd_bus_negotiate_attach_creds(b, _SD_BUS_CREDS_ALL) >= 0);
  71
  72         r = sd_bus_start(a);
  73         assert_se(r >= 0);
  74
  75         r = sd_bus_start(b);
  76         assert_se(r >= 0);
  77
  78         r = sd_bus_get_unique_name(a, &ua);
  79         assert_se(r >= 0);
  80
  81         printf("unique a: %s\n", ua);
  82
  83         r = sd_bus_get_unique_name(b, &ub);
  84         assert_se(r >= 0);
  85
  86         printf("unique b: %s\n", ub);
  87
  88         r = sd_bus_call_method(a, "this.doesnt.exist", "/foo", "meh.mah", "muh", &error, NULL, "s", "yayayay");
  89         assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_SERVICE_UNKNOWN));
  90         assert_se(r == -EHOSTUNREACH);
  91
  92         r = sd_bus_add_match(b, "interface='waldo.com',member='Piep'", NULL, NULL);
  93         assert_se(r >= 0);
  94
  95         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");
  96         assert_se(r >= 0);
  97
  98         r = sd_bus_process(b, &m);
  99         assert_se(r > 0);
 100         assert_se(m);
 101
 102         bus_message_dump(m, stdout, true);
 103         assert_se(sd_bus_message_rewind(m, true) >= 0);
 104
 105         r = sd_bus_message_read(m, "s", &the_string);
 106         assert_se(r >= 0);
 107         assert_se(streq(the_string, "I am a string"));
 108
 109         sd_bus_message_unref(m);
 110         m = NULL;
 111
 112         r = sd_bus_request_name(a, "net.x0pointer.foobar", 0);
 113         assert_se(r >= 0);
 114
 115         r = sd_bus_message_new_method_call(b, "net.x0pointer.foobar", "/a/path", "an.inter.face", "AMethod", &m);
 116         assert_se(r >= 0);
 117
 118         assert_se(pipe2(pipe_fds, O_CLOEXEC) >= 0);
 119
 120         assert_se(write(pipe_fds[1], "x", 1) == 1);
 121
 122         close_nointr_nofail(pipe_fds[1]);
 123         pipe_fds[1] = -1;
 124
 125         r = sd_bus_message_append(m, "h", pipe_fds[0]);
 126         assert_se(r >= 0);
 127
 128         close_nointr_nofail(pipe_fds[0]);
 129         pipe_fds[0] = -1;
 130
 131         r = sd_bus_send(b, m, NULL);
 132         assert_se(r >= 0);
 133
 134         for (;;) {
 135                 sd_bus_message_unref(m);
 136                 m = NULL;
 137                 r = sd_bus_process(a, &m);
 138                 assert_se(r > 0);
 139                 assert_se(m);
 140
 141                 bus_message_dump(m, stdout, true);
 142                 assert_se(sd_bus_message_rewind(m, true) >= 0);
 143
 144                 if (sd_bus_message_is_method_call(m, "an.inter.face", "AMethod")) {
 145                         int fd;
 146                         char x;
 147
 148                         r = sd_bus_message_read(m, "h", &fd);
 149                         assert_se(r >= 0);
 150
 151                         assert_se(read(fd, &x, 1) == 1);
 152                         assert_se(x == 'x');
 153                         break;
 154                 }
 155         }
 156
 157         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 158         assert_se(r >= 0);
 159
 160         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 161         assert_se(r == -ESRCH);
 162
 163         sd_bus_unref(a);
 164         sd_bus_unref(b);
 165
 166         return 0;
 167 }