Skip to content
GitLab
Commit f1b50ed8 authored by Anjan Chanda's avatar Anjan Chanda
Browse files

wip1

parent 4ae4fdaf
Hide whitespace changes
Inline Side-by-side
src/Makefile
View file @ f1b50ed8
......@@ -25,6 +25,7 @@ CNTLR_OBJS = \
LIBS = -lubus -lubox -ljson-c -lblobmsg_json -luci -pthread
LIBS += -rdynamic -ldl
LIBS += -lmaputils
plugin_subdirs ?= $(wildcard plugins/*)
plugin_sofile = $(wildcard $(d)/*.so)
......
src/core/cntlr.c
View file @ f1b50ed8
......@@ -902,7 +902,7 @@ static int update_node(struct controller *c, struct node *n)
strlen(ipstr) ? "/" : "", uobj[j]);
ret = ubus_lookup_id(c->ubus_ctx, uobjpath, &n->uobj[j]);
if (ret != UBUS_STATUS_OK) {
n->uobj[j] = WIFI_OBJECT_INVALID;
n->uobj[j] = OBJECT_INVALID;
cntlr_dbg("object '%s' not present!\n", uobjpath);
continue;
}
......@@ -950,7 +950,7 @@ static struct node *alloc_node_init(struct controller *c, char *ipstr)
strlen(ipstr) ? "/" : "", uobj[j]);
ret = ubus_lookup_id(c->ubus_ctx, uobjpath, &n->uobj[j]);
if (ret != UBUS_STATUS_OK) {
n->uobj[j] = WIFI_OBJECT_INVALID;
n->uobj[j] = OBJECT_INVALID;
cntlr_dbg("object '%s' not present!\n", uobjpath);
continue;
}
......@@ -1461,7 +1461,7 @@ static void build_topology_tree(struct ubus_request *req, int utype, struct blob
snprintf(uobjpath, 128, "%s/%s", ipstr, uobj[j]);
ubus_lookup_id(c->ubus_ctx, uobjpath, &n->uobj[j]);
if (n->uobj[j] == 0) {
n->uobj[j] = WIFI_OBJECT_INVALID;
n->uobj[j] = OBJECT_INVALID;
err("object '%s' not present!\n", uobjpath);
continue;
}
......@@ -1659,10 +1659,10 @@ static void perform_tasks_topology_change(struct controller *c)
forall_node_get_fhinfo(c);
}
static void cntlr_event_handler(struct ubus_context *ctx,
struct ubus_event_handler *ev,
const char *type,
struct blob_attr *msg)
static void cntlr_ubusx_event_handler(struct ubus_context *ctx,
struct ubus_event_handler *ev,
const char *type,
struct blob_attr *msg)
{
struct controller *c = container_of(ev, struct controller, ubusx_ev);
const struct blobmsg_policy policy = { "path", BLOBMSG_TYPE_STRING };
......@@ -1723,46 +1723,28 @@ static void cntlr_event_handler(struct ubus_context *ctx,
}
}
static int register_bus_events(struct controller *c)
{
#if 0
if (c->topology != UBUS_OBJECT_INVALID) {
cntlr_dbg("Setting up event handler for 'topology' events\n");
ubus_register_event_handler(c->ubus_ctx, &c->ubus_ev, "topology.*");
}
#endif
cntlr_dbg("Setting up bus event handlers...\n");
ubus_register_event_handler(c->ubus_ctx, &c->ubusx_ev, "ubus.object.add");
ubus_register_event_handler(c->ubus_ctx, &c->ubusx_ev, "ubus.object.remove");
ubus_register_event_handler(c->ubus_ctx, &c->ieee1905_evh, "ieee1905.*");
return 0;
}
static void ieee1905_cmdu_event_handler(void *e, struct blob_attr *msg)
static void cntlr_ieee1905_cmdu_event_handler(void *cntlr, struct blob_attr *msg)
{
#define MAX_TLV_BUF 1500 /* FIXME */
struct controller *c = (struct controller *)e;
uint8_t tlvlist[MAX_TLV_BUF] = { 0 };
char in_ifname[16] = {0};
struct blob_attr *attr;
char src[18] = { 0 };
uint8_t srcmac[6];
int pos = 0;
uint16_t type;
int mid = 0;
struct blob_attr *tb[5];
static const struct blobmsg_policy cmdu_attrs[5] = {
[0] = { .name = "cmdu_type", .type = BLOBMSG_TYPE_INT32 },
[0] = { .name = "type", .type = BLOBMSG_TYPE_INT32 },
[1] = { .name = "mid", .type = BLOBMSG_TYPE_INT32 },
[2] = { .name = "recv_intf", .type = BLOBMSG_TYPE_STRING },
[3] = { .name = "origin", .type = BLOBMSG_TYPE_STRING },
[4] = { .name = "streams", .type = BLOBMSG_TYPE_ARRAY },
[2] = { .name = "ingress", .type = BLOBMSG_TYPE_STRING },
[3] = { .name = "source", .type = BLOBMSG_TYPE_STRING },
[4] = { .name = "tlvs", .type = BLOBMSG_TYPE_STRING },
};
struct controller *c = (struct controller *)cntlr;
char in_ifname[16] = {0};
struct blob_attr *tb[5];
char src[18] = { 0 };
uint8_t *tlv = NULL;
char *tlvstr = NULL;
uint16_t type;
uint8_t srcmac[6];
uint16_t mid = 0;
int len = 0;
trace("%s: ------------>\n", __func__);
dbg("%s: --->\n", __func__);
blobmsg_parse(cmdu_attrs, 5, tb, blob_data(msg), blob_len(msg));
......@@ -1776,7 +1758,7 @@ static void ieee1905_cmdu_event_handler(void *e, struct blob_attr *msg)
}
if (tb[1])
mid = blobmsg_get_u32(tb[1]);
mid = (uint16_t)blobmsg_get_u32(tb[1]);
if (tb[2]) {
......@@ -1789,54 +1771,48 @@ static void ieee1905_cmdu_event_handler(void *e, struct blob_attr *msg)
}
if (tb[4]) {
int rem;
int len;
blobmsg_for_each_attr(attr, tb[4], rem) {
char tlvstr[513] = { 0 };
uint8_t tlv[256] = { 0 };
if (blobmsg_type(attr) != BLOBMSG_TYPE_STRING)
continue;
len = blobmsg_data_len(attr);
memcpy(tlvstr, blobmsg_data(attr), len);
len = (len - 1) / 2;
if (pos + len > MAX_TLV_BUF)
break;
len = blobmsg_data_len(tb[4]);
tlvstr = calloc(len + 1, sizeof(char));
if (!tlvstr)
return;
strtob(tlvstr, len, tlv);
memcpy(&tlvlist[pos], tlv, len);
pos += len;
strncpy(tlvstr, blobmsg_data(tb[4]), len);
len = (len - 1) / 2;
tlv = calloc(len, sizeof(uint8_t));
if (!tlv) {
free(tlvstr);
return;
}
strtob(tlvstr, len, tlv);
free(tlvstr);
}
cntlr_handle_map_event(c, type, mid, tlvlist, pos);
cntlr_handle_map_event(c, type, mid, in_ifname, srcmac, tlv, len);
if (tlv)
free(tlv);
}
static void ubus_1905_event_handler(struct ubus_context *ctx,
struct ubus_event_handler *ev,
const char *type,
struct blob_attr *msg)
static void cntlr_ieee1905_event_handler(struct ubus_context *ctx,
struct ubus_event_handler *ev,
const char *type,
struct blob_attr *msg)
{
int i;
char *str;
struct controller *c = container_of(ev, struct controller, ieee1905_evh);
struct wifi_ev_handler {
struct ev_handler {
const char *ev_type;
void (*handler)(void *ctx, struct blob_attr *ev_data);
} evs[] = { {"ieee1905.data", ieee1905_cmdu_event_handler} };
} evs[] = { {"ieee1905.cmdu", cntlr_ieee1905_cmdu_event_handler} };
char *str;
int i;
str = blobmsg_format_json(msg, true);
if (!str)
return;
info("[ &agent = %p ] Received [event = %s] [val = %s]\n",
c, type, str);
dbg("[ &cntlr = %p ] Received [event = %s][val = %s]\n", c, type, str);
for (i = 0; i < sizeof(evs)/sizeof(evs[0]); i++) {
if (!strcmp(type, evs[i].ev_type)) {
......@@ -1848,6 +1824,26 @@ static void ubus_1905_event_handler(struct ubus_context *ctx,
free(str);
}
static int cntlr_register_events(struct controller *c)
{
#if 0
if (c->topology != OBJECT_INVALID) {
cntlr_dbg("Setting up event handler for 'topology' events\n");
ubus_register_event_handler(c->ubus_ctx, &c->ubus_ev, "topology.*");
}
#endif
cntlr_dbg("Setting up bus event handlers...\n");
c->ubusx_ev.cb = cntlr_ubusx_event_handler;
c->ieee1905_evh.cb = cntlr_ieee1905_event_handler;
ubus_register_event_handler(c->ubus_ctx, &c->ubusx_ev, "ubus.object.add");
ubus_register_event_handler(c->ubus_ctx, &c->ubusx_ev, "ubus.object.remove");
ubus_register_event_handler(c->ubus_ctx, &c->ieee1905_evh, "ieee1905.*");
return 0;
}
/* This function will also be called from topology change event */
static int get_topology(struct controller *c)
{
......@@ -1900,7 +1896,7 @@ static uint32_t ubus_get_topology_object(struct ubus_context *ctx)
status = ubus_lookup_id(ctx, "topology", &id);
if (status != UBUS_STATUS_OK) {
warn("object 'topology' not present!\n");
return WIFI_OBJECT_INVALID;
return OBJECT_INVALID;
}
return id;
......@@ -1953,9 +1949,9 @@ int start_controller(void)
#endif
/* ev = &c->ubus_ev; */
/* ev->cb = cntlr_event_handler_local; */
c->ubusx_ev.cb = cntlr_event_handler;
c->ieee1905_evh.cb = ubus_1905_event_handler;
c->topology = WIFI_OBJECT_INVALID;
//c->ubusx_ev.cb = cntlr_ubusx_event_handler;
//c->ieee1905_evh.cb = cntlr_ieee1905_event_handler;
c->topology = OBJECT_INVALID;
INIT_LIST_HEAD(&c->nodelist);
INIT_LIST_HEAD(&c->watchlist);
as_init_table(&c->as_table);
......@@ -1963,34 +1959,40 @@ int start_controller(void)
c->topology = ubus_get_topology_object(c->ubus_ctx);
info("topology object: %d\n", c->topology);
if (c->topology != WIFI_OBJECT_INVALID) {
if (c->topology != OBJECT_INVALID) {
get_topology(c);
} else {
warn("topologyd may not be running!\n");
#ifdef CONFIG_USE_UBUSX
/* S-tree of the topology is not available. However, from the
* available ubus(x) router/wifi objects, we should be able to
* build an unordered list of the nodes in the network.
*/
enumerate_topology_indirect(c);
#else
goto out_exit;
#endif
}
perform_tasks_topology_init(c);
register_bus_events(c);
cntlr_register_events(c);
c->heartbeat.cb = cntlr_periodic_run;
c->radar_timer.cb = cntlr_radar_exit;
uloop_timeout_set(&c->heartbeat, 2 * 1000);
uloop_timeout_set(&c->heartbeat, 1 * 1000);
cntlr_publish_object(c);
cntlr_publish_object(c, "map.controller");
cntlr_register_module(c);
uloop_run();
/* out_and_exit: */
out_exit:
/* ubus_unregister_event_handler(ctx, ev); */
/* cntlr_remove_object(ctx); */
ubus_free(ctx);
uloop_done();
/* free(c); */ /* TODO */
free(c);
return 0;
}
src/core/cntlr.h
View file @ f1b50ed8
......@@ -16,8 +16,8 @@
extern const char *ubus_socket;
typedef uint32_t ubus_object_t;
#define WIFI_OBJECT_INVALID ((uint32_t)-1)
typedef uint32_t object_t;
#define OBJECT_INVALID ((uint32_t)-1)
/* This struct maps to fronthaul AP-BSS interface
* of neighboring nodes.
......@@ -63,7 +63,7 @@ enum uplink_type {
};
struct uobj_struct {
ubus_object_t id;
object_t id;
int (*req)(int argc, char **argv);
void (*resp)(struct ubus_request *r, int t, struct blob_attr *m);
};
......@@ -93,7 +93,7 @@ struct node {
bool scan_supported; /** whether scanning supported */
struct controller *cntlr;
#define MAX_UOBJECTS 8
ubus_object_t uobj[MAX_UOBJECTS];
object_t uobj[MAX_UOBJECTS];
/* struct uobj_struct uobj[MAX_UOBJECTS]; */
struct uloop_timeout refresh_timer;
struct ubus_event_handler evh;
......@@ -112,12 +112,13 @@ struct node {
struct controller {
void *comm;
struct ubus_object obj;
struct ubus_context *ubus_ctx;
/* struct ubus_event_handler ubus_ev; */ /** for local events */
struct ubus_event_handler ubusx_ev; /** for events from remote objs */
struct ubus_event_handler ieee1905_evh;
struct uloop_timeout heartbeat;
ubus_object_t topology;
object_t topology;
int num_nodes;
struct list_head nodelist;
struct list_head watchlist;
......
src/core/cntlr_map.c
View file @ f1b50ed8
......@@ -38,6 +38,8 @@
#include "worker.h"
#include "cntlr.h"
#include <map1905/map2.h>
#include <map1905/maputils.h>
#define for_each_tlv(e, _buf, _len) \
for ((e) = (struct tlv *)(_buf); \
......@@ -51,134 +53,133 @@ struct tlv {
} __attribute__ ((packed));
typedef int (*map_cmdu_handler_t)(void *cntlr, uint16_t mid, uint8_t *tlvs,
int len);
typedef int (*map_cmdu_handler_t)(void *cntlr, struct cmdu_cstruct *cmdu);
int handle_topology_notification(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_topology_notification(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_topology_response(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_topology_response(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_ap_autoconfig_search(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_ap_autoconfig_search(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_ap_autoconfig_response(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_ap_autoconfig_response(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_ap_autoconfig_wsc(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_ap_autoconfig_wsc(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_1905_ack(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_1905_ack(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_ap_caps_report(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_ap_caps_report(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_channel_pref_report(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_channel_pref_report(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_channel_sel_response(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_channel_sel_response(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_oper_channel_report(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_oper_channel_report(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_sta_caps_report(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_sta_caps_report(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_ap_metrics_response(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_ap_metrics_response(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_sta_link_metrics_response(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_sta_link_metrics_response(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_unassoc_sta_link_metrics_response(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_unassoc_sta_link_metrics_response(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_beacon_metrics_response(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_beacon_metrics_response(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_sta_steer_btm_report(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_sta_steer_btm_report(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_sta_steer_complete(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_sta_steer_complete(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_backhaul_sta_steer_response(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_backhaul_sta_steer_response(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_channel_scan_report(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_channel_scan_report(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_sta_disassoc_stats(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_sta_disassoc_stats(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_assoc_status_notification(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_assoc_status_notification(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_tunneled_message(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_tunneled_message(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_backhaul_sta_caps_report(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_backhaul_sta_caps_report(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
int handle_failed_connection_msg(void *cntlr, uint16_t mid, uint8_t *tlvs, int len)
int handle_failed_connection_msg(void *cntlr, struct cmdu_cstruct *cmdu)
{
return 0;
}
......@@ -225,7 +226,7 @@ static const map_cmdu_handler_t cntlr_mapftable[] = {
bool is_cmdu_for_us(void *module, uint16_t type)
{
struct controller *c = (struct controller *)module;
//struct controller *c = (struct controller *)module;
/* TODO: handle cmdu types relevant for operating profile. */
......@@ -241,12 +242,13 @@ bool is_cmdu_for_us(void *module, uint16_t type)
}
int cntlr_handle_map_event(void *module, uint16_t cmdutype, uint16_t mid,
uint8_t *tlvs, int len)
char *rxif, uint8_t *src, uint8_t *tlvs, int len)
{
struct controller *c = (struct controller *)module;
const map_cmdu_handler_t *f;
struct cmdu_cstruct *cmdu;
int ret = 0;
int idx;
int ret;
trace("%s: ---> cmdu = %d\n", __func__, cmdutype);
......@@ -259,7 +261,13 @@ int cntlr_handle_map_event(void *module, uint16_t cmdutype, uint16_t mid,
}
if (f[idx]) {
ret = f[idx](c, mid, tlvs, len);
cmdu = map_build_cmdu(cmdutype, mid, rxif, src, tlvs);
if (cmdu) {
ret = f[idx](c, cmdu);
map_free_cmdu(cmdu);
} else {
dbg("%s: map_build_cmdu() failed!\n", __func__);
}
}
//TODO: check ret
......
src/core/cntlr_map.h
View file @ f1b50ed8
......@@ -6,8 +6,8 @@
extern bool is_cmdu_for_us(void *module, uint16_t type);
extern int cntlr_handle_map_event(void *module, uint16_t cmdutype, uint16_t mid,
uint8_t *tlvs, int len);
char *rxif, uint8_t *src, uint8_t *tlvs,
int len);
#endif /* CNTLR_MAP_H */
src/core/cntlr_ubus.c
View file @ f1b50ed8
......@@ -32,17 +32,15 @@
#include "map_module.h"
static struct controller *this_cntlr;
static int cntlr_status(struct ubus_context *ctx, struct ubus_object *obj,
struct ubus_request_data *req, const char *method,
struct blob_attr *msg)
struct ubus_request_data *req, const char *method,
struct blob_attr *msg)
{
struct controller *c = this_cntlr;
struct controller *c = container_of(obj, struct controller, obj);
struct hlist_head *stalist = c->as_table;
struct node *n;
struct netif_fhbss *p;
struct blob_buf bb;
struct node *n;
void *a, *b;
int i;
......@@ -120,40 +118,57 @@ static int cntlr_status(struct ubus_context *ctx, struct ubus_object *obj,
return UBUS_STATUS_OK;
}
struct ubus_method wificntlr_methods[] = {
UBUS_METHOD_NOARG("status", cntlr_status),
};
int cntlr_publish_object(struct controller *c, const char *objname)
{
struct ubus_object *obj;
struct ubus_object_type *obj_type;
struct ubus_method *obj_methods;
struct ubus_method m[2] = {
UBUS_METHOD_NOARG("status", cntlr_status),
};
int num_methods = ARRAY_SIZE(m);
int ret;
struct ubus_object_type wificntlr_type =
UBUS_OBJECT_TYPE("map.controller", wificntlr_methods);
obj = &c->obj;
memset(obj, 0, sizeof(*obj));
struct ubus_object wificntlr_object = {
.name = "map.controller",
.type = &wificntlr_type,
.methods = wificntlr_methods,
.n_methods = ARRAY_SIZE(wificntlr_methods),
};
obj_type = calloc(1, sizeof(struct ubus_object_type));