DGNum/ubus
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

examples/client: receive data from the passed file descriptor

Browse source 
Signed-off-by: Felix Fietkau <nbd@openwrt.org>
This commit is contained in:
Felix Fietkau 2014-02-18 15:03:44 +01:00
parent 85dff762f9
commit 54926994e2
1 changed files with 44 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
examples/client.c
View file

@ -14,6 +14,8 @@
#include <sys/time.h> #include <sys/time.h>
#include <unistd.h> #include <unistd.h>
#include <libubox/ustream.h>
#include "libubus.h" #include "libubus.h"
static struct ubus_context *ctx; static struct ubus_context *ctx;
@ -57,8 +59,42 @@ static struct uloop_timeout notify_timer = {
.cb = test_client_notify_cb, .cb = test_client_notify_cb,
}; };
static void test_client_fd_data_cb(struct ustream *s, int bytes)
{
char *data, *sep;
int len;
data = ustream_get_read_buf(s, &len);
if (len < 1)
return;
sep = strchr(data, '\n');
if (!sep)
return;
*sep = 0;
fprintf(stderr, "Got line: %s\n", data);
ustream_consume(s, sep + 1 - data);
}
static void test_client_fd_cb(struct ubus_request *req, int fd)
{
static struct ustream_fd test_fd;
fprintf(stderr, "Got fd from the server, watching...\n");
test_fd.stream.notify_read = test_client_fd_data_cb;
ustream_fd_init(&test_fd, fd);
}
static void test_client_complete_cb(struct ubus_request *req, int ret)
{
fprintf(stderr, "completed request, ret: %d\n", ret);
}
static void client_main(void) static void client_main(void)
{ {
static struct ubus_request req;
uint32_t id; uint32_t id;
int ret; int ret;
@ -77,6 +113,14 @@ static void client_main(void)
blobmsg_add_u32(&b, "id", test_client_object.id); blobmsg_add_u32(&b, "id", test_client_object.id);
ubus_invoke(ctx, id, "watch", b.head, NULL, 0, 3000); ubus_invoke(ctx, id, "watch", b.head, NULL, 0, 3000);
test_client_notify_cb(&notify_timer); test_client_notify_cb(&notify_timer);
blob_buf_init(&b, 0);
blobmsg_add_string(&b, "msg", "blah");
ubus_invoke_async(ctx, id, "hello", b.head, &req);
req.fd_cb = test_client_fd_cb;
req.complete_cb = test_client_complete_cb;
ubus_complete_request_async(ctx, &req);
uloop_run(); uloop_run();
} }