1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
/*
* Copyright (C) 2013 Felix Fietkau <nbd@openwrt.org>
* Copyright (C) 2013 John Crispin <blogic@openwrt.org>
*
* 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
* as published by the Free Software Foundation
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*/
#include <stdlib.h>
#include <unistd.h>
#include <libubox/blobmsg_json.h>
#include "../procd.h"
struct watch_object {
struct list_head list;
void *id;
char *name;
};
static struct ubus_event_handler watch_event;
static struct ubus_subscriber watch_subscribe;
static LIST_HEAD(watch_objects);
static void watch_subscribe_cb(struct ubus_context *ctx, struct ubus_event_handler *ev,
const char *type, struct blob_attr *msg)
{
static const struct blobmsg_policy policy = {
"path", BLOBMSG_TYPE_STRING
};
struct watch_object *o;
struct blob_attr *attr;
const char *path;
DEBUG(3, "ubus event %s\n", type);
if (strcmp(type, "ubus.object.add") != 0)
return;
blobmsg_parse(&policy, 1, &attr, blob_data(msg), blob_len(msg));
if (!attr)
return;
path = blobmsg_data(attr);
DEBUG(3, "ubus path %s\n", path);
list_for_each_entry(o, &watch_objects, list) {
unsigned int id;
if (strcmp(o->name, path))
continue;
if (ubus_lookup_id(ctx, path, &id))
continue;
if (!ubus_subscribe(ctx, &watch_subscribe, id))
return;
ERROR("failed to subscribe %d\n", id);
}
}
void
watch_add(const char *_name, void *id)
{
int len = strlen(_name);
char *name;
struct watch_object *o = calloc_a(sizeof(*o), &name, len + 1);
o->name = name;
strcpy(name, _name);
o->id = id;
list_add(&o->list, &watch_objects);
}
void
watch_del(void *id)
{
struct watch_object *t, *n;
list_for_each_entry_safe(t, n, &watch_objects, list) {
if (t->id != id)
continue;
list_del(&t->list);
free(t);
}
}
static int
watch_notify_cb(struct ubus_context *ctx, struct ubus_object *obj,
struct ubus_request_data *req, const char *method,
struct blob_attr *msg)
{
if (debug >= 3) {
char *str;
str = blobmsg_format_json(msg, true);
DEBUG(3, "Received ubus notify '%s': %s\n", method, str);
free(str);
}
trigger_event(method, msg);
return 0;
}
void
watch_ubus(struct ubus_context *ctx)
{
watch_event.cb = watch_subscribe_cb;
watch_subscribe.cb = watch_notify_cb;
if (ubus_register_subscriber(ctx, &watch_subscribe))
ERROR("failed to register ubus subscriber\n");
if (ubus_register_event_handler(ctx, &watch_event, "ubus.object.add"))
ERROR("failed to add ubus event handler\n");
}
|
