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