[LEDE-DEV] [PATCH odhcpd v2] dhcpv4: notify DHCP ACK and RELEASE via ubus

[Borja Salazar]

if the ubus object has any subscription
notify DHCP ACK and DHCP RELEASE events
using ubus notifications.

Signed-off-by: Borja Salazar <borja.sala...@fon.com>
---
 src/dhcpv4.c | 16 ++++++++++++++++
 src/odhcpd.h |  2 ++
 src/ubus.c   | 24 ++++++++++++++++++++++++
 3 files changed, 42 insertions(+)

diff --git a/src/dhcpv4.c b/src/dhcpv4.c
index 166582e..9fd6a8d 100644
--- a/src/dhcpv4.c
+++ b/src/dhcpv4.c
@@ -723,6 +723,14 @@ static void handle_dhcpv4(void *addr, void *data, size_t 
len,
                        req->chaddr[0],req->chaddr[1],req->chaddr[2],
                        req->chaddr[3],req->chaddr[4],req->chaddr[5]);
 
+#ifdef WITH_UBUS
+       if (ubus_has_subscribers() && reqmsg == DHCPV4_MSG_RELEASE) {
+               char req_chaddr_str[13];
+               memset(&req_chaddr_str, 0, sizeof(req_chaddr_str));
+               odhcpd_hexlify(req_chaddr_str, req->chaddr, ETH_ALEN);
+               ubus_event_bcast("dhcp.release", req_chaddr_str, 
inet_ntoa(req->ciaddr), hostname, iface->ifname);
+       }
+#endif
        if (reqmsg == DHCPV4_MSG_DECLINE || reqmsg == DHCPV4_MSG_RELEASE)
                return;
 
@@ -870,6 +878,14 @@ static void handle_dhcpv4(void *addr, void *data, size_t 
len,
                                req->chaddr[3],req->chaddr[4],req->chaddr[5],
                                inet_ntoa(dest.sin_addr));
 
+#ifdef WITH_UBUS
+       if (ubus_has_subscribers() && msg == DHCPV4_MSG_ACK) {
+               char reply_chaddr_str[13];
+               memset(&reply_chaddr_str, 0, sizeof(reply_chaddr_str));
+               odhcpd_hexlify(reply_chaddr_str, reply.chaddr, ETH_ALEN);
+               ubus_event_bcast("dhcp.ack", reply_chaddr_str, 
inet_ntoa(reply.yiaddr), hostname, iface->ifname);
+       }
+#endif
        sendto(sock, &reply, sizeof(reply), MSG_DONTWAIT,
                        (struct sockaddr*)&dest, sizeof(dest));
 }
diff --git a/src/odhcpd.h b/src/odhcpd.h
index 45badd3..7ee4f44 100644
--- a/src/odhcpd.h
+++ b/src/odhcpd.h
@@ -296,6 +296,8 @@ int ubus_init(void);
 const char* ubus_get_ifname(const char *name);
 void ubus_apply_network(void);
 bool ubus_has_prefix(const char *name, const char *ifname);
+void ubus_event_bcast(const char *type, const char *mac, const char *ip, const 
char *name, const char *interface);
+bool ubus_has_subscribers(void);
 #endif
 
 int netlink_add_netevent_handler(struct netevent_handler *hdlr);
diff --git a/src/ubus.c b/src/ubus.c
index 95eeff7..741daed 100644
--- a/src/ubus.c
+++ b/src/ubus.c
@@ -311,6 +311,30 @@ static const struct blobmsg_policy obj_attrs[OBJ_ATTR_MAX] 
= {
        [OBJ_ATTR_PATH] = { .name = "path", .type = BLOBMSG_TYPE_STRING },
 };
 
+bool ubus_has_subscribers(void)
+{
+       return main_object.has_subscribers;
+}
+
+void ubus_event_bcast(const char *type, const char *mac, const char *ip, const 
char *name, const char *interface)
+{
+
+       if (!ubus || !main_object.has_subscribers)
+               return;
+
+       blob_buf_init(&b, 0);
+       if (mac)
+               blobmsg_add_string(&b, "mac", mac);
+       if (ip)
+               blobmsg_add_string(&b, "ip", ip);
+       if (name)
+               blobmsg_add_string(&b, "name", name);
+       if (interface)
+               blobmsg_add_string(&b, "interface", interface);
+
+       ubus_notify(ubus, &main_object, type, b.head, -1);
+
+}
 
 static void handle_event(_unused struct ubus_context *ctx, _unused struct 
ubus_event_handler *ev,
                 _unused const char *type, struct blob_attr *msg)
-- 
2.11.0


_______________________________________________
Lede-dev mailing list
Lede-dev@lists.infradead.org
http://lists.infradead.org/mailman/listinfo/lede-dev