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
  32 int main(int argc, char *argv[]) {
  33         _cleanup_close_ int bus_ref = -1;
  34         _cleanup_free_ char *bus_name = NULL, *address = NULL;
  35         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
  36         const char *ua = NULL, *ub = NULL, *the_string = NULL;
  37         sd_bus *a, *b;
  38         int r, pipe_fds[2];
  39
  40         log_set_max_level(LOG_DEBUG);
  41
  42         bus_ref = bus_kernel_create("deine-mutter", &bus_name);
  43         if (bus_ref == -ENOENT)
  44                 return EXIT_TEST_SKIP;
  45
  46         assert_se(bus_ref >= 0);
  47
  48         address = strappend("kernel:path=", bus_name);
  49         assert_se(address);
  50
  51         r = sd_bus_new(&a);
  52         assert_se(r >= 0);
  53
  54         r = sd_bus_new(&b);
  55         assert_se(r >= 0);
  56
  57         r = sd_bus_set_address(a, address);
  58         assert_se(r >= 0);
  59
  60         r = sd_bus_set_address(b, address);
  61         assert_se(r >= 0);
  62
  63         r = sd_bus_start(a);
  64         assert_se(r >= 0);
  65
  66         r = sd_bus_start(b);
  67         assert_se(r >= 0);
  68
  69         r = sd_bus_get_unique_name(a, &ua);
  70         assert_se(r >= 0);
  71
  72         printf("unique a: %s\n", ua);
  73
  74         r = sd_bus_get_unique_name(b, &ub);
  75         assert_se(r >= 0);
  76
  77         printf("unique b: %s\n", ub);
  78
  79         {
  80                 //FIXME:
  81                 struct kdbus_cmd_match cmd_match;
  82
  83                 cmd_match.size = sizeof(cmd_match);
  84                 cmd_match.src_id = KDBUS_MATCH_SRC_ID_ANY;
  85
  86                 r = ioctl(sd_bus_get_fd(a), KDBUS_CMD_MATCH_ADD, &cmd_match);
  87                 assert_se(r >= 0);
  88
  89                 r = ioctl(sd_bus_get_fd(b), KDBUS_CMD_MATCH_ADD, &cmd_match);
  90                 assert_se(r >= 0);
  91         }
  92
  93         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");
  94         assert_se(r >= 0);
  95
  96         r = sd_bus_process(b, &m);
  97         assert_se(r > 0);
  98         assert_se(m);
  99
 100         bus_message_dump(m);
 101         assert_se(sd_bus_message_rewind(m, true) >= 0);
 102
 103         r = sd_bus_message_read(m, "s", &the_string);
 104         assert_se(r >= 0);
 105         assert_se(streq(the_string, "I am a string"));
 106
 107         sd_bus_message_unref(m);
 108         m = NULL;
 109
 110         r = sd_bus_request_name(a, "net.x0pointer.foobar", 0);
 111         assert_se(r >= 0);
 112
 113         r = sd_bus_message_new_method_call(b, "net.x0pointer.foobar", "/a/path", "an.inter.face", "AMethod", &m);
 114         assert_se(r >= 0);
 115
 116         assert_se(pipe2(pipe_fds, O_CLOEXEC) >= 0);
 117
 118         assert_se(write(pipe_fds[1], "x", 1) == 1);
 119
 120         close_nointr_nofail(pipe_fds[1]);
 121         pipe_fds[1] = -1;
 122
 123         r = sd_bus_message_append(m, "h", pipe_fds[0]);
 124         assert_se(r >= 0);
 125
 126         close_nointr_nofail(pipe_fds[0]);
 127         pipe_fds[0] = -1;
 128
 129         r = sd_bus_send(b, m, NULL);
 130         assert_se(r >= 0);
 131
 132         for (;;) {
 133                 sd_bus_message_unref(m);
 134                 m = NULL;
 135                 r = sd_bus_process(a, &m);
 136                 assert_se(r > 0);
 137                 assert_se(m);
 138
 139                 bus_message_dump(m);
 140                 assert_se(sd_bus_message_rewind(m, true) >= 0);
 141
 142                 if (sd_bus_message_is_method_call(m, "an.inter.face", "AMethod")) {
 143                         int fd;
 144                         char x;
 145
 146                         r = sd_bus_message_read(m, "h", &fd);
 147                         assert_se(r >= 0);
 148
 149                         assert_se(read(fd, &x, 1) == 1);
 150                         assert_se(x == 'x');
 151                         break;
 152                 }
 153         }
 154
 155         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 156         assert_se(r >= 0);
 157
 158         r = sd_bus_release_name(a, "net.x0pointer.foobar");
 159         assert_se(r == -ESRCH);
 160
 161         sd_bus_unref(a);
 162         sd_bus_unref(b);
 163
 164         return 0;
 165 }