Annotation of embedaddon/dnsmasq/src/ubus.c, revision 1.1
1.1 ! misho 1: /* dnsmasq is Copyright (c) 2000-2021 Simon Kelley
! 2:
! 3: This program is free software; you can redistribute it and/or modify
! 4: it under the terms of the GNU General Public License as published by
! 5: the Free Software Foundation; version 2 dated June, 1991, or
! 6: (at your option) version 3 dated 29 June, 2007.
! 7:
! 8: This program is distributed in the hope that it will be useful,
! 9: but WITHOUT ANY WARRANTY; without even the implied warranty of
! 10: MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
! 11: GNU General Public License for more details.
! 12:
! 13: You should have received a copy of the GNU General Public License
! 14: along with this program. If not, see <http://www.gnu.org/licenses/>.
! 15: */
! 16:
! 17: #include "dnsmasq.h"
! 18:
! 19: #ifdef HAVE_UBUS
! 20:
! 21: #include <libubus.h>
! 22:
! 23: static struct blob_buf b;
! 24: static int notify;
! 25: static int error_logged = 0;
! 26:
! 27: static int ubus_handle_metrics(struct ubus_context *ctx, struct ubus_object *obj,
! 28: struct ubus_request_data *req, const char *method,
! 29: struct blob_attr *msg);
! 30:
! 31: static void ubus_subscribe_cb(struct ubus_context *ctx, struct ubus_object *obj);
! 32:
! 33: static const struct ubus_method ubus_object_methods[] = {
! 34: UBUS_METHOD_NOARG("metrics", ubus_handle_metrics),
! 35: };
! 36:
! 37: static struct ubus_object_type ubus_object_type =
! 38: UBUS_OBJECT_TYPE("dnsmasq", ubus_object_methods);
! 39:
! 40: static struct ubus_object ubus_object = {
! 41: .name = NULL,
! 42: .type = &ubus_object_type,
! 43: .methods = ubus_object_methods,
! 44: .n_methods = ARRAY_SIZE(ubus_object_methods),
! 45: .subscribe_cb = ubus_subscribe_cb,
! 46: };
! 47:
! 48: static void ubus_subscribe_cb(struct ubus_context *ctx, struct ubus_object *obj)
! 49: {
! 50: (void)ctx;
! 51:
! 52: my_syslog(LOG_DEBUG, _("UBus subscription callback: %s subscriber(s)"), obj->has_subscribers ? "1" : "0");
! 53: notify = obj->has_subscribers;
! 54: }
! 55:
! 56: static void ubus_destroy(struct ubus_context *ubus)
! 57: {
! 58: // Forces re-initialization when we're reusing the same definitions later on.
! 59: ubus_object.id = 0;
! 60: ubus_object_type.id = 0;
! 61:
! 62: ubus_free(ubus);
! 63: daemon->ubus = NULL;
! 64: }
! 65:
! 66: static void ubus_disconnect_cb(struct ubus_context *ubus)
! 67: {
! 68: int ret;
! 69:
! 70: ret = ubus_reconnect(ubus, NULL);
! 71: if (ret)
! 72: {
! 73: my_syslog(LOG_ERR, _("Cannot reconnect to UBus: %s"), ubus_strerror(ret));
! 74:
! 75: ubus_destroy(ubus);
! 76: }
! 77: }
! 78:
! 79: void ubus_init()
! 80: {
! 81: struct ubus_context *ubus = NULL;
! 82: int ret = 0;
! 83:
! 84: ubus = ubus_connect(NULL);
! 85: if (!ubus)
! 86: {
! 87: if (!error_logged)
! 88: {
! 89: my_syslog(LOG_ERR, _("Cannot initialize UBus: connection failed"));
! 90: error_logged = 1;
! 91: }
! 92:
! 93: ubus_destroy(ubus);
! 94: return;
! 95: }
! 96:
! 97: ubus_object.name = daemon->ubus_name;
! 98: ret = ubus_add_object(ubus, &ubus_object);
! 99: if (ret)
! 100: {
! 101: if (!error_logged)
! 102: {
! 103: my_syslog(LOG_ERR, _("Cannot add object to UBus: %s"), ubus_strerror(ret));
! 104: error_logged = 1;
! 105: }
! 106: ubus_destroy(ubus);
! 107: return;
! 108: }
! 109:
! 110: ubus->connection_lost = ubus_disconnect_cb;
! 111: daemon->ubus = ubus;
! 112: error_logged = 0;
! 113:
! 114: my_syslog(LOG_INFO, _("Connected to system UBus"));
! 115: }
! 116:
! 117: void set_ubus_listeners()
! 118: {
! 119: struct ubus_context *ubus = (struct ubus_context *)daemon->ubus;
! 120: if (!ubus)
! 121: {
! 122: if (!error_logged)
! 123: {
! 124: my_syslog(LOG_ERR, _("Cannot set UBus listeners: no connection"));
! 125: error_logged = 1;
! 126: }
! 127: return;
! 128: }
! 129:
! 130: error_logged = 0;
! 131:
! 132: poll_listen(ubus->sock.fd, POLLIN);
! 133: poll_listen(ubus->sock.fd, POLLERR);
! 134: poll_listen(ubus->sock.fd, POLLHUP);
! 135: }
! 136:
! 137: void check_ubus_listeners()
! 138: {
! 139: struct ubus_context *ubus = (struct ubus_context *)daemon->ubus;
! 140: if (!ubus)
! 141: {
! 142: if (!error_logged)
! 143: {
! 144: my_syslog(LOG_ERR, _("Cannot poll UBus listeners: no connection"));
! 145: error_logged = 1;
! 146: }
! 147: return;
! 148: }
! 149:
! 150: error_logged = 0;
! 151:
! 152: if (poll_check(ubus->sock.fd, POLLIN))
! 153: ubus_handle_event(ubus);
! 154:
! 155: if (poll_check(ubus->sock.fd, POLLHUP | POLLERR))
! 156: {
! 157: my_syslog(LOG_INFO, _("Disconnecting from UBus"));
! 158:
! 159: ubus_destroy(ubus);
! 160: }
! 161: }
! 162:
! 163: static int ubus_handle_metrics(struct ubus_context *ctx, struct ubus_object *obj,
! 164: struct ubus_request_data *req, const char *method,
! 165: struct blob_attr *msg)
! 166: {
! 167: int i;
! 168:
! 169: (void)obj;
! 170: (void)method;
! 171: (void)msg;
! 172:
! 173: blob_buf_init(&b, BLOBMSG_TYPE_TABLE);
! 174:
! 175: for (i=0; i < __METRIC_MAX; i++)
! 176: blobmsg_add_u32(&b, get_metric_name(i), daemon->metrics[i]);
! 177:
! 178: return ubus_send_reply(ctx, req, b.head);
! 179: }
! 180:
! 181: void ubus_event_bcast(const char *type, const char *mac, const char *ip, const char *name, const char *interface)
! 182: {
! 183: struct ubus_context *ubus = (struct ubus_context *)daemon->ubus;
! 184: int ret;
! 185:
! 186: if (!ubus || !notify)
! 187: return;
! 188:
! 189: blob_buf_init(&b, BLOBMSG_TYPE_TABLE);
! 190: if (mac)
! 191: blobmsg_add_string(&b, "mac", mac);
! 192: if (ip)
! 193: blobmsg_add_string(&b, "ip", ip);
! 194: if (name)
! 195: blobmsg_add_string(&b, "name", name);
! 196: if (interface)
! 197: blobmsg_add_string(&b, "interface", interface);
! 198:
! 199: ret = ubus_notify(ubus, &ubus_object, type, b.head, -1);
! 200: if (!ret)
! 201: my_syslog(LOG_ERR, _("Failed to send UBus event: %s"), ubus_strerror(ret));
! 202: }
! 203:
! 204:
! 205: #endif /* HAVE_UBUS */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ubus.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / dnsmasq / src