From 85dff762f9676699d2dd133178c274d5def36748 Mon Sep 17 00:00:00 2001 From: Felix Fietkau Date: Tue, 18 Feb 2014 15:03:22 +0100 Subject: [PATCH] examples/server: send a file descriptor as part of the request to the "hello" method Signed-off-by: Felix Fietkau --- examples/server.c | 32 ++++++++++++++++++++++++++++++-- 1 file changed, 30 insertions(+), 2 deletions(-) diff --git a/examples/server.c b/examples/server.c index 230048a..bfad363 100644 --- a/examples/server.c +++ b/examples/server.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2011 Felix Fietkau + * Copyright (C) 2011-2014 Felix Fietkau * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU Lesser General Public License version 2.1 @@ -12,6 +12,7 @@ */ #include +#include #include #include "libubus.h" @@ -34,18 +35,44 @@ static const struct blobmsg_policy hello_policy[] = { struct hello_request { struct ubus_request_data req; struct uloop_timeout timeout; + int fd; + int idx; char data[]; }; +static void test_hello_fd_reply(struct uloop_timeout *t) +{ + struct hello_request *req = container_of(t, struct hello_request, timeout); + char *data; + + data = alloca(strlen(req->data) + 32); + sprintf(data, "msg%d: %s\n", ++req->idx, req->data); + if (write(req->fd, data, strlen(data)) < 0) { + close(req->fd); + free(req); + return; + } + + uloop_timeout_set(&req->timeout, 1000); +} + static void test_hello_reply(struct uloop_timeout *t) { struct hello_request *req = container_of(t, struct hello_request, timeout); + int fds[2]; blob_buf_init(&b, 0); blobmsg_add_string(&b, "message", req->data); ubus_send_reply(ctx, &req->req, b.head); + + pipe(fds); + ubus_request_set_fd(ctx, &req->req, fds[0]); ubus_complete_deferred_request(ctx, &req->req, 0); - free(req); + close(fds[0]); + req->fd = fds[1]; + + req->timeout.cb = test_hello_fd_reply; + test_hello_fd_reply(t); } static int test_hello(struct ubus_context *ctx, struct ubus_object *obj, @@ -172,6 +199,7 @@ int main(int argc, char **argv) argv += optind; uloop_init(); + signal(SIGPIPE, SIG_IGN); ctx = ubus_connect(ubus_socket); if (!ctx) { -- 2.11.0