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

add deferred reply to the ubus server example

Browse source
This commit is contained in:
Felix Fietkau 2012-10-01 14:09:37 +02:00
parent 7864896a1b
commit 600ec9fd73
1 changed files with 27 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
ubus-example.c
View file

@ -17,7 +17,7 @@
static struct ubus_context *ctx; static struct ubus_context *ctx;
static struct ubus_watch_object test_event; static struct ubus_watch_object test_event;
struct blob_buf b; static struct blob_buf b;
enum { enum {
HELLO_ID, HELLO_ID,
@ -30,24 +30,43 @@ static const struct blobmsg_policy hello_policy[] = {
[HELLO_MSG] = { .name = "msg", .type = BLOBMSG_TYPE_STRING }, [HELLO_MSG] = { .name = "msg", .type = BLOBMSG_TYPE_STRING },
}; };
struct hello_request {
struct ubus_request_data req;
struct uloop_timeout timeout;
char data[];
};
static void test_hello_reply(struct uloop_timeout *t)
{
struct hello_request *req = container_of(t, struct hello_request, timeout);
blob_buf_init(&b, 0);
blobmsg_add_string(&b, "message", req->data);
ubus_send_reply(ctx, &req->req, b.head);
ubus_complete_deferred_request(ctx, &req->req, 0);
free(req);
}
static int test_hello(struct ubus_context *ctx, struct ubus_object *obj, static int test_hello(struct ubus_context *ctx, struct ubus_object *obj,
struct ubus_request_data *req, const char *method, struct ubus_request_data *req, const char *method,
struct blob_attr *msg) struct blob_attr *msg)
{ {
struct hello_request *hreq;
struct blob_attr *tb[__HELLO_MAX]; struct blob_attr *tb[__HELLO_MAX];
char *msgstr = "(unknown)"; const char *format = "%s received a message: %s";
char *strbuf; const char *msgstr = "(unknown)";
blobmsg_parse(hello_policy, ARRAY_SIZE(hello_policy), tb, blob_data(msg), blob_len(msg)); blobmsg_parse(hello_policy, ARRAY_SIZE(hello_policy), tb, blob_data(msg), blob_len(msg));
if (tb[HELLO_MSG]) if (tb[HELLO_MSG])
msgstr = blobmsg_data(tb[HELLO_MSG]); msgstr = blobmsg_data(tb[HELLO_MSG]);
blob_buf_init(&b, 0); hreq = calloc(1, sizeof(*hreq) + strlen(format) + strlen(obj->name) + strlen(msgstr) + 1);
strbuf = blobmsg_alloc_string_buffer(&b, "message", 64 + strlen(obj->name) + strlen(msgstr)); sprintf(hreq->data, format, obj->name, msgstr);
sprintf(strbuf, "%s received a message: %s", obj->name, msgstr); ubus_defer_request(ctx, req, &hreq->req);
blobmsg_add_string_buffer(&b); hreq->timeout.cb = test_hello_reply;
ubus_send_reply(ctx, req, b.head); uloop_timeout_set(&hreq->timeout, 1000);
return 0; return 0;
} }