src/libsystemd/sd-bus/test-bus-chat.c

   1 /***
   2   This file is part of systemd.
   3
   4   Copyright 2013 Lennart Poettering
   5
   6   systemd is free software; you can redistribute it and/or modify it
   7   under the terms of the GNU Lesser General Public License as published by
   8   the Free Software Foundation; either version 2.1 of the License, or
   9   (at your option) any later version.
  10
  11   systemd is distributed in the hope that it will be useful, but
  12   WITHOUT ANY WARRANTY; without even the implied warranty of
  13   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  14   Lesser General Public License for more details.
  15
  16   You should have received a copy of the GNU Lesser General Public License
  17   along with systemd; If not, see <http://www.gnu.org/licenses/>.
  18 ***/
  19
  20 #include <fcntl.h>
  21 #include <pthread.h>
  22 #include <stdlib.h>
  23 #include <unistd.h>
  24
  25 #include "sd-bus.h"
  26
  27 #include "alloc-util.h"
  28 #include "bus-error.h"
  29 #include "bus-internal.h"
  30 #include "bus-match.h"
  31 #include "bus-util.h"
  32 #include "fd-util.h"
  33 #include "format-util.h"
  34 #include "log.h"
  35 #include "macro.h"
  36 #include "util.h"
  37
  38 static int match_callback(sd_bus_message *m, void *userdata, sd_bus_error *ret_error) {
  39         log_info("Match triggered! interface=%s member=%s", strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member(m)));
  40         return 0;
  41 }
  42
  43 static int object_callback(sd_bus_message *m, void *userdata, sd_bus_error *ret_error) {
  44         int r;
  45
  46         if (sd_bus_message_is_method_error(m, NULL))
  47                 return 0;
  48
  49         if (sd_bus_message_is_method_call(m, "org.object.test", "Foobar")) {
  50                 log_info("Invoked Foobar() on %s", sd_bus_message_get_path(m));
  51
  52                 r = sd_bus_reply_method_return(m, NULL);
  53                 if (r < 0)
  54                         return log_error_errno(r, "Failed to send reply: %m");
  55
  56                 return 1;
  57         }
  58
  59         return 0;
  60 }
  61
  62 static int server_init(sd_bus **_bus) {
  63         sd_bus *bus = NULL;
  64         sd_id128_t id;
  65         int r;
  66         const char *unique;
  67
  68         assert_se(_bus);
  69
  70         r = sd_bus_open_user(&bus);
  71         if (r < 0) {
  72                 log_error_errno(r, "Failed to connect to user bus: %m");
  73                 goto fail;
  74         }
  75
  76         r = sd_bus_get_bus_id(bus, &id);
  77         if (r < 0) {
  78                 log_error_errno(r, "Failed to get server ID: %m");
  79                 goto fail;
  80         }
  81
  82         r = sd_bus_get_unique_name(bus, &unique);
  83         if (r < 0) {
  84                 log_error_errno(r, "Failed to get unique name: %m");
  85                 goto fail;
  86         }
  87
  88         log_info("Peer ID is " SD_ID128_FORMAT_STR ".", SD_ID128_FORMAT_VAL(id));
  89         log_info("Unique ID: %s", unique);
  90         log_info("Can send file handles: %i", sd_bus_can_send(bus, 'h'));
  91
  92         r = sd_bus_request_name(bus, "org.freedesktop.systemd.test", 0);
  93         if (r < 0) {
  94                 log_error_errno(r, "Failed to acquire name: %m");
  95                 goto fail;
  96         }
  97
  98         r = sd_bus_add_fallback(bus, NULL, "/foo/bar", object_callback, NULL);
  99         if (r < 0) {
 100                 log_error_errno(r, "Failed to add object: %m");
 101                 goto fail;
 102         }
 103
 104         r = sd_bus_add_match(bus, NULL, "type='signal',interface='foo.bar',member='Notify'", match_callback, NULL);
 105         if (r < 0) {
 106                 log_error_errno(r, "Failed to add match: %m");
 107                 goto fail;
 108         }
 109
 110         r = sd_bus_add_match(bus, NULL, "type='signal',interface='org.freedesktop.DBus',member='NameOwnerChanged'", match_callback, NULL);
 111         if (r < 0) {
 112                 log_error_errno(r, "Failed to add match: %m");
 113                 goto fail;
 114         }
 115
 116         bus_match_dump(&bus->match_callbacks, 0);
 117
 118         *_bus = bus;
 119         return 0;
 120
 121 fail:
 122         sd_bus_unref(bus);
 123         return r;
 124 }
 125
 126 static int server(sd_bus *bus) {
 127         int r;
 128         bool client1_gone = false, client2_gone = false;
 129
 130         while (!client1_gone || !client2_gone) {
 131                 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
 132                 pid_t pid = 0;
 133                 const char *label = NULL;
 134
 135                 r = sd_bus_process(bus, &m);
 136                 if (r < 0) {
 137                         log_error_errno(r, "Failed to process requests: %m");
 138                         goto fail;
 139                 }
 140
 141                 if (r == 0) {
 142                         r = sd_bus_wait(bus, (uint64_t) -1);
 143                         if (r < 0) {
 144                                 log_error_errno(r, "Failed to wait: %m");
 145                                 goto fail;
 146                         }
 147
 148                         continue;
 149                 }
 150
 151                 if (!m)
 152                         continue;
 153
 154                 sd_bus_creds_get_pid(sd_bus_message_get_creds(m), &pid);
 155                 sd_bus_creds_get_selinux_context(sd_bus_message_get_creds(m), &label);
 156                 log_info("Got message! member=%s pid="PID_FMT" label=%s",
 157                          strna(sd_bus_message_get_member(m)),
 158                          pid,
 159                          strna(label));
 160                 /* bus_message_dump(m); */
 161                 /* sd_bus_message_rewind(m, true); */
 162
 163                 if (sd_bus_message_is_method_call(m, "org.freedesktop.systemd.test", "LowerCase")) {
 164                         const char *hello;
 165                         _cleanup_free_ char *lowercase = NULL;
 166
 167                         r = sd_bus_message_read(m, "s", &hello);
 168                         if (r < 0) {
 169                                 log_error_errno(r, "Failed to get parameter: %m");
 170                                 goto fail;
 171                         }
 172
 173                         lowercase = strdup(hello);
 174                         if (!lowercase) {
 175                                 r = log_oom();
 176                                 goto fail;
 177                         }
 178
 179                         ascii_strlower(lowercase);
 180
 181                         r = sd_bus_reply_method_return(m, "s", lowercase);
 182                         if (r < 0) {
 183                                 log_error_errno(r, "Failed to send reply: %m");
 184                                 goto fail;
 185                         }
 186                 } else if (sd_bus_message_is_method_call(m, "org.freedesktop.systemd.test", "ExitClient1")) {
 187
 188                         r = sd_bus_reply_method_return(m, NULL);
 189                         if (r < 0) {
 190                                 log_error_errno(r, "Failed to send reply: %m");
 191                                 goto fail;
 192                         }
 193
 194                         client1_gone = true;
 195                 } else if (sd_bus_message_is_method_call(m, "org.freedesktop.systemd.test", "ExitClient2")) {
 196
 197                         r = sd_bus_reply_method_return(m, NULL);
 198                         if (r < 0) {
 199                                 log_error_errno(r, "Failed to send reply: %m");
 200                                 goto fail;
 201                         }
 202
 203                         client2_gone = true;
 204                 } else if (sd_bus_message_is_method_call(m, "org.freedesktop.systemd.test", "Slow")) {
 205
 206                         sleep(1);
 207
 208                         r = sd_bus_reply_method_return(m, NULL);
 209                         if (r < 0) {
 210                                 log_error_errno(r, "Failed to send reply: %m");
 211                                 goto fail;
 212                         }
 213
 214                 } else if (sd_bus_message_is_method_call(m, "org.freedesktop.systemd.test", "FileDescriptor")) {
 215                         int fd;
 216                         static const char x = 'X';
 217
 218                         r = sd_bus_message_read(m, "h", &fd);
 219                         if (r < 0) {
 220                                 log_error_errno(r, "Failed to get parameter: %m");
 221                                 goto fail;
 222                         }
 223
 224                         log_info("Received fd=%d", fd);
 225
 226                         if (write(fd, &x, 1) < 0) {
 227                                 log_error_errno(errno, "Failed to write to fd: %m");
 228                                 safe_close(fd);
 229                                 goto fail;
 230                         }
 231
 232                         r = sd_bus_reply_method_return(m, NULL);
 233                         if (r < 0) {
 234                                 log_error_errno(r, "Failed to send reply: %m");
 235                                 goto fail;
 236                         }
 237
 238                 } else if (sd_bus_message_is_method_call(m, NULL, NULL)) {
 239
 240                         r = sd_bus_reply_method_error(
 241                                         m,
 242                                         &SD_BUS_ERROR_MAKE_CONST(SD_BUS_ERROR_UNKNOWN_METHOD, "Unknown method."));
 243                         if (r < 0) {
 244                                 log_error_errno(r, "Failed to send reply: %m");
 245                                 goto fail;
 246                         }
 247                 }
 248         }
 249
 250         r = 0;
 251
 252 fail:
 253         if (bus) {
 254                 sd_bus_flush(bus);
 255                 sd_bus_unref(bus);
 256         }
 257
 258         return r;
 259 }
 260
 261 static void* client1(void*p) {
 262         _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
 263         _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
 264         _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
 265         const char *hello;
 266         int r;
 267         _cleanup_close_pair_ int pp[2] = { -1, -1 };
 268         char x;
 269
 270         r = sd_bus_open_user(&bus);
 271         if (r < 0) {
 272                 log_error_errno(r, "Failed to connect to user bus: %m");
 273                 goto finish;
 274         }
 275
 276         r = sd_bus_call_method(
 277                         bus,
 278                         "org.freedesktop.systemd.test",
 279                         "/",
 280                         "org.freedesktop.systemd.test",
 281                         "LowerCase",
 282                         &error,
 283                         &reply,
 284                         "s",
 285                         "HELLO");
 286         if (r < 0) {
 287                 log_error_errno(r, "Failed to issue method call: %m");
 288                 goto finish;
 289         }
 290
 291         r = sd_bus_message_read(reply, "s", &hello);
 292         if (r < 0) {
 293                 log_error_errno(r, "Failed to get string: %m");
 294                 goto finish;
 295         }
 296
 297         assert_se(streq(hello, "hello"));
 298
 299         if (pipe2(pp, O_CLOEXEC|O_NONBLOCK) < 0) {
 300                 log_error_errno(errno, "Failed to allocate pipe: %m");
 301                 r = -errno;
 302                 goto finish;
 303         }
 304
 305         log_info("Sending fd=%d", pp[1]);
 306
 307         r = sd_bus_call_method(
 308                         bus,
 309                         "org.freedesktop.systemd.test",
 310                         "/",
 311                         "org.freedesktop.systemd.test",
 312                         "FileDescriptor",
 313                         &error,
 314                         NULL,
 315                         "h",
 316                         pp[1]);
 317         if (r < 0) {
 318                 log_error_errno(r, "Failed to issue method call: %m");
 319                 goto finish;
 320         }
 321
 322         errno = 0;
 323         if (read(pp[0], &x, 1) <= 0) {
 324                 log_error("Failed to read from pipe: %s", errno ? strerror(errno) : "early read");
 325                 goto finish;
 326         }
 327
 328         r = 0;
 329
 330 finish:
 331         if (bus) {
 332                 _cleanup_(sd_bus_message_unrefp) sd_bus_message *q;
 333
 334                 r = sd_bus_message_new_method_call(
 335                                 bus,
 336                                 &q,
 337                                 "org.freedesktop.systemd.test",
 338                                 "/",
 339                                 "org.freedesktop.systemd.test",
 340                                 "ExitClient1");
 341                 if (r < 0)
 342                         log_error_errno(r, "Failed to allocate method call: %m");
 343                 else
 344                         sd_bus_send(bus, q, NULL);
 345
 346         }
 347
 348         return INT_TO_PTR(r);
 349 }
 350
 351 static int quit_callback(sd_bus_message *m, void *userdata, sd_bus_error *ret_error) {
 352         bool *x = userdata;
 353
 354         log_error_errno(sd_bus_message_get_errno(m), "Quit callback: %m");
 355
 356         *x = 1;
 357         return 1;
 358 }
 359
 360 static void* client2(void*p) {
 361         _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL, *reply = NULL;
 362         _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
 363         _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
 364         bool quit = false;
 365         const char *mid;
 366         int r;
 367
 368         r = sd_bus_open_user(&bus);
 369         if (r < 0) {
 370                 log_error_errno(r, "Failed to connect to user bus: %m");
 371                 goto finish;
 372         }
 373
 374         r = sd_bus_message_new_method_call(
 375                         bus,
 376                         &m,
 377                         "org.freedesktop.systemd.test",
 378                         "/foo/bar/waldo/piep",
 379                         "org.object.test",
 380                         "Foobar");
 381         if (r < 0) {
 382                 log_error_errno(r, "Failed to allocate method call: %m");
 383                 goto finish;
 384         }
 385
 386         r = sd_bus_send(bus, m, NULL);
 387         if (r < 0) {
 388                 log_error("Failed to issue method call: %s", bus_error_message(&error, -r));
 389                 goto finish;
 390         }
 391
 392         m = sd_bus_message_unref(m);
 393
 394         r = sd_bus_message_new_signal(
 395                         bus,
 396                         &m,
 397                         "/foobar",
 398                         "foo.bar",
 399                         "Notify");
 400         if (r < 0) {
 401                 log_error_errno(r, "Failed to allocate signal: %m");
 402                 goto finish;
 403         }
 404
 405         r = sd_bus_send(bus, m, NULL);
 406         if (r < 0) {
 407                 log_error("Failed to issue signal: %s", bus_error_message(&error, -r));
 408                 goto finish;
 409         }
 410
 411         m = sd_bus_message_unref(m);
 412
 413         r = sd_bus_message_new_method_call(
 414                         bus,
 415                         &m,
 416                         "org.freedesktop.systemd.test",
 417                         "/",
 418                         "org.freedesktop.DBus.Peer",
 419                         "GetMachineId");
 420         if (r < 0) {
 421                 log_error_errno(r, "Failed to allocate method call: %m");
 422                 goto finish;
 423         }
 424
 425         r = sd_bus_call(bus, m, 0, &error, &reply);
 426         if (r < 0) {
 427                 log_error("Failed to issue method call: %s", bus_error_message(&error, -r));
 428                 goto finish;
 429         }
 430
 431         r = sd_bus_message_read(reply, "s", &mid);
 432         if (r < 0) {
 433                 log_error_errno(r, "Failed to parse machine ID: %m");
 434                 goto finish;
 435         }
 436
 437         log_info("Machine ID is %s.", mid);
 438
 439         m = sd_bus_message_unref(m);
 440
 441         r = sd_bus_message_new_method_call(
 442                         bus,
 443                         &m,
 444                         "org.freedesktop.systemd.test",
 445                         "/",
 446                         "org.freedesktop.systemd.test",
 447                         "Slow");
 448         if (r < 0) {
 449                 log_error_errno(r, "Failed to allocate method call: %m");
 450                 goto finish;
 451         }
 452
 453         reply = sd_bus_message_unref(reply);
 454
 455         r = sd_bus_call(bus, m, 200 * USEC_PER_MSEC, &error, &reply);
 456         if (r < 0)
 457                 log_info("Failed to issue method call: %s", bus_error_message(&error, -r));
 458         else
 459                 log_info("Slow call succeed.");
 460
 461         m = sd_bus_message_unref(m);
 462
 463         r = sd_bus_message_new_method_call(
 464                         bus,
 465                         &m,
 466                         "org.freedesktop.systemd.test",
 467                         "/",
 468                         "org.freedesktop.systemd.test",
 469                         "Slow");
 470         if (r < 0) {
 471                 log_error_errno(r, "Failed to allocate method call: %m");
 472                 goto finish;
 473         }
 474
 475         r = sd_bus_call_async(bus, NULL, m, quit_callback, &quit, 200 * USEC_PER_MSEC);
 476         if (r < 0) {
 477                 log_info("Failed to issue method call: %s", bus_error_message(&error, -r));
 478                 goto finish;
 479         }
 480
 481         while (!quit) {
 482                 r = sd_bus_process(bus, NULL);
 483                 if (r < 0) {
 484                         log_error_errno(r, "Failed to process requests: %m");
 485                         goto finish;
 486                 }
 487                 if (r == 0) {
 488                         r = sd_bus_wait(bus, (uint64_t) -1);
 489                         if (r < 0) {
 490                                 log_error_errno(r, "Failed to wait: %m");
 491                                 goto finish;
 492                         }
 493                 }
 494         }
 495
 496         r = 0;
 497
 498 finish:
 499         if (bus) {
 500                 _cleanup_(sd_bus_message_unrefp) sd_bus_message *q;
 501
 502                 r = sd_bus_message_new_method_call(
 503                                 bus,
 504                                 &q,
 505                                 "org.freedesktop.systemd.test",
 506                                 "/",
 507                                 "org.freedesktop.systemd.test",
 508                                 "ExitClient2");
 509                 if (r < 0) {
 510                         log_error_errno(r, "Failed to allocate method call: %m");
 511                         goto finish;
 512                 }
 513
 514                 (void) sd_bus_send(bus, q, NULL);
 515         }
 516
 517         return INT_TO_PTR(r);
 518 }
 519
 520 int main(int argc, char *argv[]) {
 521         pthread_t c1, c2;
 522         sd_bus *bus;
 523         void *p;
 524         int q, r;
 525
 526         r = server_init(&bus);
 527         if (r < 0) {
 528                 log_info("Failed to connect to bus, skipping tests.");
 529                 return EXIT_TEST_SKIP;
 530         }
 531
 532         log_info("Initialized...");
 533
 534         r = pthread_create(&c1, NULL, client1, bus);
 535         if (r != 0)
 536                 return EXIT_FAILURE;
 537
 538         r = pthread_create(&c2, NULL, client2, bus);
 539         if (r != 0)
 540                 return EXIT_FAILURE;
 541
 542         r = server(bus);
 543
 544         q = pthread_join(c1, &p);
 545         if (q != 0)
 546                 return EXIT_FAILURE;
 547         if (PTR_TO_INT(p) < 0)
 548                 return EXIT_FAILURE;
 549
 550         q = pthread_join(c2, &p);
 551         if (q != 0)
 552                 return EXIT_FAILURE;
 553         if (PTR_TO_INT(p) < 0)
 554                 return EXIT_FAILURE;
 555
 556         if (r < 0)
 557                 return EXIT_FAILURE;
 558
 559         return EXIT_SUCCESS;
 560 }