X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fubox.git;a=blobdiff_plain;f=log%2Flogd.c;fp=log%2Flogd.c;h=5dd993298c680e76fd6ed8c1ca5c140cda4cb789;hp=0407f4c7b82392817fb1f7558a9c3617668548e1;hb=3587778a620ae3ee50a3262cbed941344db3d4db;hpb=12728c38621c6271dd2102d3e11cf95ff42eeff8

diff --git a/log/logd.c b/log/logd.c
index 0407f4c..5dd9932 100644
--- a/log/logd.c
+++ b/log/logd.c
@@ -57,17 +57,12 @@ client_close(struct ustream *s)
 static void
 client_notify_write(struct ustream *s, int bytes)
 {
-	if (s->w.data_bytes < 128 && ustream_read_blocked(s))
-		ustream_set_read_blocked(s, false);
+	client_close(s);
 }
 
 static void client_notify_state(struct ustream *s)
 {
-	if (!s->eof)
-		return;
-
-	if (!s->w.data_bytes)
-		return client_close(s);
+	return client_close(s);
 }
 
 static int
@@ -89,7 +84,6 @@ read_log(struct ubus_context *ctx, struct ubus_object *obj,
 
 	pipe(fds);
 	ubus_request_set_fd(ctx, req, fds[0]);
-
 	cl = calloc(1, sizeof(*cl));
 	cl->s.stream.notify_write = client_notify_write;
 	cl->s.stream.notify_state = client_notify_state;