return 0;
}
-typedef struct ubus_msg_buf *(*event_fill_cb)(void *priv, const char *id);
-
static void ubusd_send_event_msg(struct ubus_msg_buf **ub, struct ubus_client *cl,
struct ubus_object *obj, const char *id,
event_fill_cb fill_cb, void *cb_priv)
*objid_ptr = htonl(obj->id.id);
(*ub)->hdr.seq = ++event_seq;
- ubus_msg_send(obj->client, *ub, false);
+ ubus_msg_send(obj->client, *ub);
}
static bool strmatch_len(const char *s1, const char *s2, int *len)
return false;
}
-static int ubusd_send_event(struct ubus_client *cl, const char *id,
- event_fill_cb fill_cb, void *cb_priv)
+int ubusd_send_event(struct ubus_client *cl, const char *id,
+ event_fill_cb fill_cb, void *cb_priv)
{
struct ubus_msg_buf *ub = NULL;
struct event_source *ev;
return ubusd_send_event(cl, id, ubusd_create_event_from_msg, data);
}
-static int ubusd_event_recv(struct ubus_client *cl, const char *method, struct blob_attr *msg)
+static int ubusd_event_recv(struct ubus_client *cl, struct ubus_msg_buf *ub, const char *method, struct blob_attr *msg)
{
if (!strcmp(method, "register"))
return ubusd_alloc_event_pattern(cl, msg);