X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fubus.git;a=blobdiff_plain;f=libubus.c;h=8683fcc30069c017377c5467006269046d43a504;hp=e435200150ef02c48be73c25fd693b366cd7a515;hb=47a9ab0c645d4d49def8080ae68c7c477e733530;hpb=37cc5d2f25c162c1e125922e91bbc741e2e4a6d1 diff --git a/libubus.c b/libubus.c index e435200..8683fcc 100644 --- a/libubus.c +++ b/libubus.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2011-2012 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 @@ -84,13 +84,13 @@ ubus_queue_msg(struct ubus_context *ctx, struct ubus_msghdr *hdr) } void __hidden -ubus_process_msg(struct ubus_context *ctx, struct ubus_msghdr *hdr) +ubus_process_msg(struct ubus_context *ctx, struct ubus_msghdr *hdr, int fd) { switch(hdr->type) { case UBUS_MSG_STATUS: case UBUS_MSG_DATA: - ubus_process_req_msg(ctx, hdr); + ubus_process_req_msg(ctx, hdr, fd); break; case UBUS_MSG_INVOKE: @@ -113,7 +113,7 @@ void __hidden ubus_process_pending_msg(struct ubus_context *ctx) while (!list_empty(&ctx->pending)) { pending = list_first_entry(&ctx->pending, struct ubus_pending_msg, list); list_del(&pending->list); - ubus_process_msg(ctx, &pending->hdr); + ubus_process_msg(ctx, &pending->hdr, -1); free(pending); if (ctx->stack_depth > 2) break;