examples/client.c

   1 /*
   2  * Copyright (C) 2011 Felix Fietkau <nbd@openwrt.org>
   3  *
   4  * This program is free software; you can redistribute it and/or modify
   5  * it under the terms of the GNU Lesser General Public License version 2.1
   6  * as published by the Free Software Foundation
   7  *
   8  * This program is distributed in the hope that it will be useful,
   9  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  10  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11  * GNU General Public License for more details.
  12  */
  13
  14 #include <unistd.h>
  15
  16 #include "libubus.h"
  17
  18 static struct ubus_context *ctx;
  19 static struct blob_buf b;
  20
  21 static void test_client_subscribe_cb(struct ubus_context *ctx, struct ubus_object *obj)
  22 {
  23         fprintf(stderr, "Subscribers active: %d\n", obj->has_subscribers);
  24 }
  25
  26 static struct ubus_object test_client_object = {
  27         .subscribe_cb = test_client_subscribe_cb,
  28 };
  29
  30 static void client_main(void)
  31 {
  32         uint32_t id;
  33         int ret;
  34
  35         ret = ubus_add_object(ctx, &test_client_object);
  36         if (ret) {
  37                 fprintf(stderr, "Failed to add_object object: %s\n", ubus_strerror(ret));
  38                 return;
  39         }
  40
  41         if (ubus_lookup_id(ctx, "test", &id)) {
  42                 fprintf(stderr, "Failed to look up test object\n");
  43                 return;
  44         }
  45
  46         blob_buf_init(&b, 0);
  47         blobmsg_add_u32(&b, "id", test_client_object.id);
  48         ubus_invoke(ctx, id, "watch", b.head, NULL, 0, 3000);
  49         uloop_run();
  50 }
  51
  52 int main(int argc, char **argv)
  53 {
  54         const char *ubus_socket = NULL;
  55         int ch;
  56
  57         while ((ch = getopt(argc, argv, "cs:")) != -1) {
  58                 switch (ch) {
  59                 case 's':
  60                         ubus_socket = optarg;
  61                         break;
  62                 default:
  63                         break;
  64                 }
  65         }
  66
  67         argc -= optind;
  68         argv += optind;
  69
  70         uloop_init();
  71
  72         ctx = ubus_connect(ubus_socket);
  73         if (!ctx) {
  74                 fprintf(stderr, "Failed to connect to ubus\n");
  75                 return -1;
  76         }
  77
  78         ubus_add_uloop(ctx);
  79
  80         client_main();
  81
  82         ubus_free(ctx);
  83         uloop_done();
  84
  85         return 0;
  86 }