gluon-mesh-batman-adv-core: Switch from debugfs to batadv netlink
The batadv debugfs requires large memory blocks to write the text debug tables. This is inefficient for large tables like the global translation table or the originators table. The memory requirement can be reduced by using netlink. It copies smaller packets in a binary format to the userspace program. The respondd module of gluon-mesh-batman-adv-core can therefore parse larger originator tables without causing an OOM on systems which are tight on memory. Signed-off-by: Sven Eckelmann <sven@narfation.org>
This commit is contained in:
Sven Eckelmann
parent
4bbd073f73
commit
223ffce972
@ -13,7 +13,7 @@ define Package/gluon-mesh-batman-adv-core
|
||||
SECTION:=gluon
|
||||
CATEGORY:=Gluon
|
||||
TITLE:=Support for batman-adv meshing (core)
|
||||
DEPENDS:=+gluon-core +libgluonutil +gluon-client-bridge +firewall +libiwinfo +kmod-dummy
|
||||
DEPENDS:=+gluon-core +libgluonutil +gluon-client-bridge +firewall +libiwinfo +kmod-dummy +libnl-tiny
|
||||
endef
|
||||
|
||||
define Build/Prepare
|
||||
|
||||
@ -2,5 +2,23 @@ all: respondd.so
|
||||
|
||||
CFLAGS += -Wall
|
||||
|
||||
respondd.so: respondd.c
|
||||
ifeq ($(origin PKG_CONFIG), undefined)
|
||||
PKG_CONFIG = pkg-config
|
||||
ifeq ($(shell which $(PKG_CONFIG) 2>/dev/null),)
|
||||
$(error $(PKG_CONFIG) not found)
|
||||
endif
|
||||
endif
|
||||
|
||||
ifeq ($(origin LIBNL_CFLAGS) $(origin LIBNL_LDLIBS), undefined undefined)
|
||||
LIBNL_NAME ?= libnl-tiny
|
||||
ifeq ($(shell $(PKG_CONFIG) --modversion $(LIBNL_NAME) 2>/dev/null),)
|
||||
$(error No $(LIBNL_NAME) development libraries found!)
|
||||
endif
|
||||
LIBNL_CFLAGS += $(shell $(PKG_CONFIG) --cflags $(LIBNL_NAME))
|
||||
LIBNL_LDLIBS += $(shell $(PKG_CONFIG) --libs $(LIBNL_NAME))
|
||||
endif
|
||||
CFLAGS += $(LIBNL_CFLAGS)
|
||||
LDLIBS += $(LIBNL_LDLIBS)
|
||||
|
||||
respondd.so: respondd.c netlink.c
|
||||
$(CC) $(CPPFLAGS) $(CFLAGS) $(LDFLAGS) -shared -fPIC -D_GNU_SOURCE -o $@ $^ $(LDLIBS) -lgluonutil -liwinfo -luci
|
||||
|
||||
159
package/gluon-mesh-batman-adv-core/src/netlink.c
Normal file
159
package/gluon-mesh-batman-adv-core/src/netlink.c
Normal file
@ -0,0 +1,159 @@
|
||||
/*
|
||||
* Copyright (C) 2009-2016 B.A.T.M.A.N. contributors:
|
||||
*
|
||||
* Marek Lindner <mareklindner@neomailbox.ch>, Andrew Lunn <andrew@lunn.ch>
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or
|
||||
* modify it under the terms of version 2 of the GNU General Public
|
||||
* License 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.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, write to the Free Software
|
||||
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
|
||||
* 02110-1301, USA
|
||||
*
|
||||
*/
|
||||
|
||||
#include "netlink.h"
|
||||
|
||||
#include <stdbool.h>
|
||||
#include <stddef.h>
|
||||
#include <stdio.h>
|
||||
#include <string.h>
|
||||
#include <unistd.h>
|
||||
#include <errno.h>
|
||||
#include <linux/batman_adv.h>
|
||||
#include <net/ethernet.h>
|
||||
#include <net/if.h>
|
||||
#include <netlink/netlink.h>
|
||||
#include <netlink/genl/genl.h>
|
||||
#include <netlink/genl/ctrl.h>
|
||||
#include <net/ethernet.h>
|
||||
|
||||
#ifndef __maybe_unused
|
||||
#define __maybe_unused __attribute__((unused))
|
||||
#endif
|
||||
|
||||
struct nla_policy batadv_netlink_policy[NUM_BATADV_ATTR] = {
|
||||
[BATADV_ATTR_HARD_IFINDEX] = { .type = NLA_U32 },
|
||||
[BATADV_ATTR_ORIG_ADDRESS] = { .type = NLA_UNSPEC,
|
||||
.minlen = ETH_ALEN,
|
||||
.maxlen = ETH_ALEN },
|
||||
[BATADV_ATTR_TT_FLAGS] = { .type = NLA_U32 },
|
||||
[BATADV_ATTR_FLAG_BEST] = { .type = NLA_FLAG },
|
||||
[BATADV_ATTR_LAST_SEEN_MSECS] = { .type = NLA_U32 },
|
||||
[BATADV_ATTR_NEIGH_ADDRESS] = { .type = NLA_UNSPEC,
|
||||
.minlen = ETH_ALEN,
|
||||
.maxlen = ETH_ALEN },
|
||||
[BATADV_ATTR_TQ] = { .type = NLA_U8 },
|
||||
[BATADV_ATTR_ROUTER] = { .type = NLA_UNSPEC,
|
||||
.minlen = ETH_ALEN,
|
||||
.maxlen = ETH_ALEN },
|
||||
};
|
||||
|
||||
int missing_mandatory_attrs(struct nlattr *attrs[], const int mandatory[],
|
||||
size_t num)
|
||||
{
|
||||
size_t i;
|
||||
|
||||
for (i = 0; i < num; i++)
|
||||
if (!attrs[mandatory[i]])
|
||||
return -EINVAL;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int nlquery_error_cb(struct sockaddr_nl *nla __maybe_unused,
|
||||
struct nlmsgerr *nlerr, void *arg)
|
||||
{
|
||||
struct nlquery_opts *query_opts = arg;
|
||||
|
||||
query_opts->err = nlerr->error;
|
||||
|
||||
return NL_STOP;
|
||||
}
|
||||
|
||||
static int nlquery_stop_cb(struct nl_msg *msg, void *arg)
|
||||
{
|
||||
struct nlmsghdr *nlh = nlmsg_hdr(msg);
|
||||
struct nlquery_opts *query_opts = arg;
|
||||
int *error = nlmsg_data(nlh);
|
||||
|
||||
if (*error)
|
||||
query_opts->err = *error;
|
||||
|
||||
return NL_STOP;
|
||||
}
|
||||
|
||||
int netlink_query_common(const char *mesh_iface, uint8_t nl_cmd,
|
||||
nl_recvmsg_msg_cb_t callback,
|
||||
struct nlquery_opts *query_opts)
|
||||
{
|
||||
struct nl_sock *sock;
|
||||
struct nl_msg *msg;
|
||||
struct nl_cb *cb;
|
||||
int ifindex;
|
||||
int family;
|
||||
int ret;
|
||||
|
||||
query_opts->err = 0;
|
||||
|
||||
sock = nl_socket_alloc();
|
||||
if (!sock)
|
||||
return -ENOMEM;
|
||||
|
||||
ret = genl_connect(sock);
|
||||
if (ret < 0) {
|
||||
query_opts->err = ret;
|
||||
goto err_free_sock;
|
||||
}
|
||||
|
||||
family = genl_ctrl_resolve(sock, BATADV_NL_NAME);
|
||||
if (family < 0) {
|
||||
query_opts->err = -EOPNOTSUPP;
|
||||
goto err_free_sock;
|
||||
}
|
||||
|
||||
ifindex = if_nametoindex(mesh_iface);
|
||||
if (!ifindex) {
|
||||
query_opts->err = -ENODEV;
|
||||
goto err_free_sock;
|
||||
}
|
||||
|
||||
cb = nl_cb_alloc(NL_CB_DEFAULT);
|
||||
if (!cb) {
|
||||
query_opts->err = -ENOMEM;
|
||||
goto err_free_sock;
|
||||
}
|
||||
|
||||
nl_cb_set(cb, NL_CB_VALID, NL_CB_CUSTOM, callback, query_opts);
|
||||
nl_cb_set(cb, NL_CB_FINISH, NL_CB_CUSTOM, nlquery_stop_cb, query_opts);
|
||||
nl_cb_err(cb, NL_CB_CUSTOM, nlquery_error_cb, query_opts);
|
||||
|
||||
msg = nlmsg_alloc();
|
||||
if (!msg) {
|
||||
query_opts->err = -ENOMEM;
|
||||
goto err_free_cb;
|
||||
}
|
||||
|
||||
genlmsg_put(msg, NL_AUTO_PID, NL_AUTO_SEQ, family, 0, NLM_F_DUMP,
|
||||
nl_cmd, 1);
|
||||
|
||||
nla_put_u32(msg, BATADV_ATTR_MESH_IFINDEX, ifindex);
|
||||
nl_send_auto_complete(sock, msg);
|
||||
nlmsg_free(msg);
|
||||
|
||||
nl_recvmsgs(sock, cb);
|
||||
|
||||
err_free_cb:
|
||||
nl_cb_put(cb);
|
||||
err_free_sock:
|
||||
nl_socket_free(sock);
|
||||
|
||||
return query_opts->err;
|
||||
}
|
||||
47
package/gluon-mesh-batman-adv-core/src/netlink.h
Normal file
47
package/gluon-mesh-batman-adv-core/src/netlink.h
Normal file
@ -0,0 +1,47 @@
|
||||
/*
|
||||
* Copyright (C) 2009-2016 B.A.T.M.A.N. contributors:
|
||||
*
|
||||
* Marek Lindner <mareklindner@neomailbox.ch>, Andrew Lunn <andrew@lunn.ch>
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or
|
||||
* modify it under the terms of version 2 of the GNU General Public
|
||||
* License 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.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, write to the Free Software
|
||||
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
|
||||
* 02110-1301, USA
|
||||
*
|
||||
*/
|
||||
|
||||
#ifndef _BATADV_NETLINK_H
|
||||
#define _BATADV_NETLINK_H
|
||||
|
||||
#include <netlink/genl/genl.h>
|
||||
#include <netlink/genl/ctrl.h>
|
||||
#include <stddef.h>
|
||||
|
||||
struct nlquery_opts {
|
||||
int err;
|
||||
};
|
||||
|
||||
#ifndef container_of
|
||||
#define container_of(ptr, type, member) __extension__ ({ \
|
||||
const __typeof__(((type *)0)->member) *__pmember = (ptr); \
|
||||
(type *)((char *)__pmember - offsetof(type, member)); })
|
||||
#endif
|
||||
|
||||
int netlink_query_common(const char *mesh_iface, uint8_t nl_cmd,
|
||||
nl_recvmsg_msg_cb_t callback,
|
||||
struct nlquery_opts *query_opts);
|
||||
int missing_mandatory_attrs(struct nlattr *attrs[], const int mandatory[],
|
||||
size_t num);
|
||||
|
||||
extern struct nla_policy batadv_netlink_policy[];
|
||||
|
||||
#endif /* _BATADV_NETLINK_H */
|
||||
@ -47,15 +47,34 @@
|
||||
#include <sys/ioctl.h>
|
||||
#include <sys/socket.h>
|
||||
|
||||
#include <linux/batman_adv.h>
|
||||
#include <linux/ethtool.h>
|
||||
#include <linux/if_addr.h>
|
||||
#include <linux/sockios.h>
|
||||
|
||||
#include "netlink.h"
|
||||
|
||||
|
||||
|
||||
#define _STRINGIFY(s) #s
|
||||
#define STRINGIFY(s) _STRINGIFY(s)
|
||||
|
||||
struct neigh_netlink_opts {
|
||||
struct json_object *interfaces;
|
||||
struct nlquery_opts query_opts;
|
||||
};
|
||||
|
||||
struct gw_netlink_opts {
|
||||
struct json_object *obj;
|
||||
struct nlquery_opts query_opts;
|
||||
};
|
||||
|
||||
struct clients_netlink_opts {
|
||||
size_t total;
|
||||
size_t wifi;
|
||||
struct nlquery_opts query_opts;
|
||||
};
|
||||
|
||||
|
||||
static struct json_object * get_addresses(void) {
|
||||
FILE *f = fopen("/proc/net/if_inet6", "r");
|
||||
@ -223,29 +242,69 @@ static struct json_object * respondd_provider_nodeinfo(void) {
|
||||
return ret;
|
||||
}
|
||||
|
||||
static const int gateways_mandatory[] = {
|
||||
BATADV_ATTR_ORIG_ADDRESS,
|
||||
BATADV_ATTR_ROUTER,
|
||||
};
|
||||
|
||||
static int parse_gw_list_netlink_cb(struct nl_msg *msg, void *arg)
|
||||
{
|
||||
struct nlattr *attrs[BATADV_ATTR_MAX+1];
|
||||
struct nlmsghdr *nlh = nlmsg_hdr(msg);
|
||||
struct nlquery_opts *query_opts = arg;
|
||||
struct genlmsghdr *ghdr;
|
||||
uint8_t *orig;
|
||||
uint8_t *router;
|
||||
struct gw_netlink_opts *opts;
|
||||
char addr[18];
|
||||
|
||||
opts = container_of(query_opts, struct gw_netlink_opts, query_opts);
|
||||
|
||||
if (!genlmsg_valid_hdr(nlh, 0))
|
||||
return NL_OK;
|
||||
|
||||
ghdr = nlmsg_data(nlh);
|
||||
|
||||
if (ghdr->cmd != BATADV_CMD_GET_GATEWAYS)
|
||||
return NL_OK;
|
||||
|
||||
if (nla_parse(attrs, BATADV_ATTR_MAX, genlmsg_attrdata(ghdr, 0),
|
||||
genlmsg_len(ghdr), batadv_netlink_policy))
|
||||
return NL_OK;
|
||||
|
||||
if (missing_mandatory_attrs(attrs, gateways_mandatory,
|
||||
ARRAY_SIZE(gateways_mandatory)))
|
||||
return NL_OK;
|
||||
|
||||
if (!attrs[BATADV_ATTR_FLAG_BEST])
|
||||
return NL_OK;
|
||||
|
||||
orig = nla_data(attrs[BATADV_ATTR_ORIG_ADDRESS]);
|
||||
router = nla_data(attrs[BATADV_ATTR_ROUTER]);
|
||||
|
||||
sprintf(addr, "%02x:%02x:%02x:%02x:%02x:%02x",
|
||||
orig[0], orig[1], orig[2], orig[3], orig[4], orig[5]);
|
||||
|
||||
json_object_object_add(opts->obj, "gateway", json_object_new_string(addr));
|
||||
|
||||
sprintf(addr, "%02x:%02x:%02x:%02x:%02x:%02x",
|
||||
router[0], router[1], router[2], router[3], router[4], router[5]);
|
||||
|
||||
json_object_object_add(opts->obj, "gateway_nexthop", json_object_new_string(addr));
|
||||
|
||||
return NL_STOP;
|
||||
}
|
||||
|
||||
static void add_gateway(struct json_object *obj) {
|
||||
FILE *f = fopen("/sys/kernel/debug/batman_adv/bat0/gateways", "r");
|
||||
if (!f)
|
||||
return;
|
||||
struct gw_netlink_opts opts = {
|
||||
.obj = obj,
|
||||
.query_opts = {
|
||||
.err = 0,
|
||||
},
|
||||
};
|
||||
|
||||
char *line = NULL;
|
||||
size_t len = 0;
|
||||
|
||||
while (getline(&line, &len, f) >= 0) {
|
||||
char addr[18];
|
||||
char nexthop[18];
|
||||
|
||||
if (sscanf(line, "=> %17[0-9a-fA-F:] ( %*u) %17[0-9a-fA-F:]", addr, nexthop) != 2)
|
||||
continue;
|
||||
|
||||
json_object_object_add(obj, "gateway", json_object_new_string(addr));
|
||||
json_object_object_add(obj, "gateway_nexthop", json_object_new_string(nexthop));
|
||||
break;
|
||||
}
|
||||
|
||||
free(line);
|
||||
fclose(f);
|
||||
netlink_query_common("bat0", BATADV_CMD_GET_GATEWAYS,
|
||||
parse_gw_list_netlink_cb, &opts.query_opts);
|
||||
}
|
||||
|
||||
static inline bool ethtool_ioctl(int fd, struct ifreq *ifr, void *data) {
|
||||
@ -421,39 +480,68 @@ static void count_stations(size_t *wifi24, size_t *wifi5) {
|
||||
uci_free_context(ctx);
|
||||
}
|
||||
|
||||
static const int clients_mandatory[] = {
|
||||
BATADV_ATTR_TT_FLAGS,
|
||||
};
|
||||
|
||||
static int parse_clients_list_netlink_cb(struct nl_msg *msg, void *arg)
|
||||
{
|
||||
struct nlattr *attrs[BATADV_ATTR_MAX+1];
|
||||
struct nlmsghdr *nlh = nlmsg_hdr(msg);
|
||||
struct nlquery_opts *query_opts = arg;
|
||||
struct genlmsghdr *ghdr;
|
||||
struct clients_netlink_opts *opts;
|
||||
uint32_t flags;
|
||||
|
||||
opts = container_of(query_opts, struct clients_netlink_opts, query_opts);
|
||||
|
||||
if (!genlmsg_valid_hdr(nlh, 0))
|
||||
return NL_OK;
|
||||
|
||||
ghdr = nlmsg_data(nlh);
|
||||
|
||||
if (ghdr->cmd != BATADV_CMD_GET_TRANSTABLE_LOCAL)
|
||||
return NL_OK;
|
||||
|
||||
if (nla_parse(attrs, BATADV_ATTR_MAX, genlmsg_attrdata(ghdr, 0),
|
||||
genlmsg_len(ghdr), batadv_netlink_policy))
|
||||
return NL_OK;
|
||||
|
||||
if (missing_mandatory_attrs(attrs, clients_mandatory,
|
||||
ARRAY_SIZE(clients_mandatory)))
|
||||
return NL_OK;
|
||||
|
||||
flags = nla_get_u32(attrs[BATADV_ATTR_TT_FLAGS]);
|
||||
|
||||
if (flags & BATADV_TT_CLIENT_NOPURGE)
|
||||
return NL_OK;
|
||||
|
||||
if (flags & BATADV_TT_CLIENT_WIFI)
|
||||
opts->wifi++;
|
||||
|
||||
opts->total++;
|
||||
|
||||
return NL_OK;
|
||||
}
|
||||
|
||||
static struct json_object * get_clients(void) {
|
||||
size_t total = 0, wifi = 0, wifi24 = 0, wifi5 = 0;
|
||||
size_t wifi24 = 0, wifi5 = 0;
|
||||
struct clients_netlink_opts opts = {
|
||||
.total = 0,
|
||||
.wifi = 0,
|
||||
.query_opts = {
|
||||
.err = 0,
|
||||
},
|
||||
};
|
||||
|
||||
FILE *f = fopen("/sys/kernel/debug/batman_adv/bat0/transtable_local", "r");
|
||||
if (!f)
|
||||
return NULL;
|
||||
|
||||
char *line = NULL;
|
||||
size_t len = 0;
|
||||
|
||||
while (getline(&line, &len, f) >= 0) {
|
||||
char flags[16];
|
||||
|
||||
if (sscanf(line, " * %*[^[] [%15[^]]]", flags) != 1)
|
||||
continue;
|
||||
|
||||
if (strchr(flags, 'P'))
|
||||
continue;
|
||||
|
||||
total++;
|
||||
|
||||
if (strchr(flags, 'W'))
|
||||
wifi++;
|
||||
}
|
||||
|
||||
free(line);
|
||||
fclose(f);
|
||||
netlink_query_common("bat0", BATADV_CMD_GET_TRANSTABLE_LOCAL,
|
||||
parse_clients_list_netlink_cb, &opts.query_opts);
|
||||
|
||||
count_stations(&wifi24, &wifi5);
|
||||
|
||||
struct json_object *ret = json_object_new_object();
|
||||
json_object_object_add(ret, "total", json_object_new_int(total));
|
||||
json_object_object_add(ret, "wifi", json_object_new_int(wifi));
|
||||
json_object_object_add(ret, "total", json_object_new_int(opts.total));
|
||||
json_object_object_add(ret, "wifi", json_object_new_int(opts.wifi));
|
||||
json_object_object_add(ret, "wifi24", json_object_new_int(wifi24));
|
||||
json_object_object_add(ret, "wifi5", json_object_new_int(wifi5));
|
||||
return ret;
|
||||
@ -492,49 +580,103 @@ static struct json_object * ifnames2addrs(struct json_object *interfaces) {
|
||||
return ret;
|
||||
}
|
||||
|
||||
static struct json_object * get_batadv(void) {
|
||||
FILE *f = fopen("/sys/kernel/debug/batman_adv/bat0/originators", "r");
|
||||
if (!f)
|
||||
return NULL;
|
||||
static const int parse_orig_list_mandatory[] = {
|
||||
BATADV_ATTR_ORIG_ADDRESS,
|
||||
BATADV_ATTR_NEIGH_ADDRESS,
|
||||
BATADV_ATTR_TQ,
|
||||
BATADV_ATTR_HARD_IFINDEX,
|
||||
BATADV_ATTR_LAST_SEEN_MSECS,
|
||||
};
|
||||
|
||||
char *line = NULL;
|
||||
size_t len = 0;
|
||||
static int parse_orig_list_netlink_cb(struct nl_msg *msg, void *arg)
|
||||
{
|
||||
struct nlattr *attrs[BATADV_ATTR_MAX+1];
|
||||
struct nlmsghdr *nlh = nlmsg_hdr(msg);
|
||||
struct nlquery_opts *query_opts = arg;
|
||||
struct genlmsghdr *ghdr;
|
||||
uint8_t *orig;
|
||||
uint8_t *dest;
|
||||
uint8_t tq;
|
||||
uint32_t hardif;
|
||||
uint32_t lastseen;
|
||||
char ifname_buf[IF_NAMESIZE], *ifname;
|
||||
struct neigh_netlink_opts *opts;
|
||||
char mac1[18];
|
||||
|
||||
struct json_object *interfaces = json_object_new_object();
|
||||
opts = container_of(query_opts, struct neigh_netlink_opts, query_opts);
|
||||
|
||||
while (getline(&line, &len, f) >= 0) {
|
||||
char mac1[18], mac2[18];
|
||||
/* IF_NAMESIZE would be enough, but adding 1 here is simpler than subtracting 1 in the format string */
|
||||
char ifname[IF_NAMESIZE+1];
|
||||
double lastseen;
|
||||
int tq;
|
||||
if (!genlmsg_valid_hdr(nlh, 0))
|
||||
return NL_OK;
|
||||
|
||||
if (sscanf(line,
|
||||
"%17[0-9a-fA-F:] %lfs ( %i ) %17[0-9a-fA-F:] [ %"STRINGIFY(IF_NAMESIZE)"[^]] ]",
|
||||
mac1, &lastseen, &tq, mac2, ifname) != 5)
|
||||
continue;
|
||||
ghdr = nlmsg_data(nlh);
|
||||
|
||||
if (strcmp(mac1, mac2))
|
||||
continue;
|
||||
if (ghdr->cmd != BATADV_CMD_GET_ORIGINATORS)
|
||||
return NL_OK;
|
||||
|
||||
struct json_object *interface;
|
||||
if (!json_object_object_get_ex(interfaces, ifname, &interface)) {
|
||||
interface = json_object_new_object();
|
||||
json_object_object_add(interfaces, ifname, interface);
|
||||
}
|
||||
if (nla_parse(attrs, BATADV_ATTR_MAX, genlmsg_attrdata(ghdr, 0),
|
||||
genlmsg_len(ghdr), batadv_netlink_policy))
|
||||
return NL_OK;
|
||||
|
||||
if (missing_mandatory_attrs(attrs, parse_orig_list_mandatory,
|
||||
ARRAY_SIZE(parse_orig_list_mandatory)))
|
||||
return NL_OK;
|
||||
|
||||
if (!attrs[BATADV_ATTR_FLAG_BEST])
|
||||
return NL_OK;
|
||||
|
||||
orig = nla_data(attrs[BATADV_ATTR_ORIG_ADDRESS]);
|
||||
dest = nla_data(attrs[BATADV_ATTR_NEIGH_ADDRESS]);
|
||||
tq = nla_get_u8(attrs[BATADV_ATTR_TQ]);
|
||||
hardif = nla_get_u32(attrs[BATADV_ATTR_HARD_IFINDEX]);
|
||||
lastseen = nla_get_u32(attrs[BATADV_ATTR_LAST_SEEN_MSECS]);
|
||||
|
||||
if (memcmp(orig, dest, 6) != 0)
|
||||
return NL_OK;
|
||||
|
||||
ifname = if_indextoname(hardif, ifname_buf);
|
||||
if (!ifname)
|
||||
return NL_OK;
|
||||
|
||||
sprintf(mac1, "%02x:%02x:%02x:%02x:%02x:%02x",
|
||||
orig[0], orig[1], orig[2], orig[3], orig[4], orig[5]);
|
||||
|
||||
struct json_object *obj = json_object_new_object();
|
||||
json_object_object_add(obj, "tq", json_object_new_int(tq));
|
||||
struct json_object *jso = json_object_new_double(lastseen);
|
||||
json_object_set_serializer(jso, json_object_double_to_json_string, "%.3f", NULL);
|
||||
json_object_object_add(obj, "lastseen", jso);
|
||||
json_object_object_add(interface, mac1, obj);
|
||||
if (!obj)
|
||||
return NL_OK;
|
||||
|
||||
struct json_object *interface;
|
||||
if (!json_object_object_get_ex(opts->interfaces, ifname, &interface)) {
|
||||
interface = json_object_new_object();
|
||||
json_object_object_add(opts->interfaces, ifname, interface);
|
||||
}
|
||||
|
||||
fclose(f);
|
||||
free(line);
|
||||
json_object_object_add(obj, "tq", json_object_new_int(tq));
|
||||
json_object_object_add(obj, "lastseen", json_object_new_double(lastseen / 1000.));
|
||||
json_object_object_add(interface, mac1, obj);
|
||||
|
||||
return ifnames2addrs(interfaces);
|
||||
return NL_OK;
|
||||
}
|
||||
|
||||
static struct json_object * get_batadv(void) {
|
||||
struct neigh_netlink_opts opts = {
|
||||
.query_opts = {
|
||||
.err = 0,
|
||||
},
|
||||
};
|
||||
int ret;
|
||||
|
||||
opts.interfaces = json_object_new_object();
|
||||
if (!opts.interfaces)
|
||||
return NULL;
|
||||
|
||||
ret = netlink_query_common("bat0", BATADV_CMD_GET_ORIGINATORS,
|
||||
parse_orig_list_netlink_cb, &opts.query_opts);
|
||||
if (ret < 0) {
|
||||
json_object_put(opts.interfaces);
|
||||
return NULL;
|
||||
}
|
||||
|
||||
return ifnames2addrs(opts.interfaces);
|
||||
}
|
||||
|
||||
static struct json_object * get_wifi_neighbours(const char *ifname) {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user