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