X-Git-Url: http://git.archive.openwrt.org/?a=blobdiff_plain;f=libubus-io.c;h=9a6c7cd77ec168be2b6779fc9fe05aea751c0fa2;hb=1d5ac421a5b3dca60562e876ba70d0c2fe46b3d2;hp=bc054b8d0ff263a807482b48c093a6309ddcee72;hpb=47a9ab0c645d4d49def8080ae68c7c477e733530;p=project%2Fubus.git

diff --git a/libubus-io.c b/libubus-io.c
index bc054b8..9a6c7cd 100644
--- a/libubus-io.c
+++ b/libubus-io.c
@@ -142,6 +142,9 @@ int __hidden ubus_send_msg(struct ubus_context *ctx, uint32_t seq,
 	if (ret < 0)
 		ctx->sock.eof = true;
 
+	if (fd >= 0)
+		close(fd);
+
 	return ret;
 }
 
@@ -261,6 +264,17 @@ void __hidden ubus_handle_data(struct uloop_fd *u, unsigned int events)
 		ctx->connection_lost(ctx);
 }
 
+void __hidden ubus_poll_data(struct ubus_context *ctx, int timeout)
+{
+	struct pollfd pfd = {
+		.fd = ctx->sock.fd,
+		.events = POLLIN | POLLERR,
+	};
+
+	poll(&pfd, 1, timeout);
+	ubus_handle_data(&ctx->sock, ULOOP_READ);
+}
+
 static void
 ubus_refresh_state(struct ubus_context *ctx)
 {