Signed-off-by: Felix Fietkau <nbd@nbd.name>
static void
log_fill_msg(struct blob_buf *b, struct log_head *l)
{
static void
log_fill_msg(struct blob_buf *b, struct log_head *l)
{
blobmsg_add_string(b, "msg", l->data);
blobmsg_add_u32(b, "id", l->id);
blobmsg_add_u32(b, "priority", l->priority);
blobmsg_add_string(b, "msg", l->data);
blobmsg_add_u32(b, "id", l->id);
blobmsg_add_u32(b, "priority", l->priority);
int fds[2];
int ret;
bool stream = true;
int fds[2];
int ret;
bool stream = true;
if (!stream)
count = 100;
if (!stream)
count = 100;
ustream_fd_init(&cl->s, cl->fd);
list_add(&cl->list, &clients);
while ((!tb[READ_LINES] || count) && l) {
ustream_fd_init(&cl->s, cl->fd);
list_add(&cl->list, &clients);
while ((!tb[READ_LINES] || count) && l) {
log_fill_msg(&b, l);
l = log_list(count, l);
ret = ustream_write(&cl->s.stream, (void *) b.head, blob_len(b.head) + sizeof(struct blob_attr), false);
log_fill_msg(&b, l);
l = log_list(count, l);
ret = ustream_write(&cl->s.stream, (void *) b.head, blob_len(b.head) + sizeof(struct blob_attr), false);
+ blob_buf_init(&b, 0);
+ c = blobmsg_open_array(&b, "log");
while ((!tb[READ_LINES] || count) && l) {
while ((!tb[READ_LINES] || count) && l) {
+ e = blobmsg_open_table(&b, NULL);
- ubus_send_reply(ctx, req, b.head);
+ blobmsg_close_table(&b, e);
l = log_list(count, l);
}
l = log_list(count, l);
}
+ blobmsg_close_array(&b, c);
+ ubus_send_reply(ctx, req, b.head);
}
blob_buf_free(&b);
return 0;
}
blob_buf_free(&b);
return 0;