Compare commits
No commits in common. "8aa11dccbad04a8a9b1021a06b8047af08cf07b0" and "1598abee34dcb662e72f878d13661149178532df" have entirely different histories.
8aa11dccba
...
1598abee34
@ -17,6 +17,7 @@ LIBS+=-lmavl
|
||||
LIBS+=-lcw
|
||||
LIBS+=-lrt
|
||||
LIBS+=-lpthread
|
||||
LIBS+=-lconfuse
|
||||
LIBS+=-lc
|
||||
LIBS+=-lnettle
|
||||
LIBS+=-lssl
|
||||
|
||||
@ -223,7 +223,7 @@ int main (int argc, char *argv[])
|
||||
|
||||
cw_cfg_dump(global_cfg);
|
||||
|
||||
cw_log (LOG_INFO, "Starting AC-Tube, Name=%s, ID=%s", cw_cfg_get(global_cfg,"capwap/ac-name",NULL), conf_acid);
|
||||
cw_log (LOG_INFO, "Starting AC-Tube, Name=%s, ID=%s", conf_acname, conf_acid);
|
||||
rc = ac_run(global_cfg);
|
||||
|
||||
errX:
|
||||
@ -246,52 +246,42 @@ void process_ctrl_packet (int index, struct sockaddr *addr, uint8_t * buffer, in
|
||||
void process_cw_data_packet (int index, struct sockaddr *addr, uint8_t * buffer, int len);
|
||||
|
||||
|
||||
static void pcb(char *dst, struct mavlnode *node)
|
||||
{
|
||||
struct cw_Cfg_entry *e = mavlnode_dataptr(node);
|
||||
sprintf(dst, "%s", e->key);
|
||||
}
|
||||
|
||||
|
||||
int ac_run(cw_Cfg_t * cfg)
|
||||
{
|
||||
struct cw_Cfg_iter cfi;
|
||||
const char *s;
|
||||
int i;
|
||||
|
||||
if (1 /*!conf_listen_addrs_len*/) {
|
||||
cw_log (LOG_ERR, "Fatal error: No listen addresses found.");
|
||||
// return 1;
|
||||
}
|
||||
|
||||
extern void cw_cfg_iterate(cw_Cfg_t *);
|
||||
cw_cfg_iterate(cfg);
|
||||
|
||||
return 1;
|
||||
|
||||
/* it is important to create the unicast sockets first,
|
||||
* because when we create the mcast an bcast sockets next
|
||||
* we will look for already created sockets to find a
|
||||
* good unicast reply socket */
|
||||
|
||||
cw_cfg_iter_init(cfg, &cfi, "actube/listen");
|
||||
for (i=0; (s = cw_cfg_iter_next(&cfi, NULL)) != NULL; i++) {
|
||||
int i;
|
||||
|
||||
/* for (i = 0; i < conf_listen_addrs_len; i++) {
|
||||
char addr[100];
|
||||
char port[50];
|
||||
int proto;
|
||||
|
||||
conf_parse_listen_addr (s, addr, port, &proto);
|
||||
socklist_add_unicast (addr, port, proto,
|
||||
cw_cfg_get_bool(cfg,"actube/ipv4","true"),
|
||||
cw_cfg_get_bool(cfg,"actube/ipv6","true")
|
||||
);
|
||||
}
|
||||
if (!i) {
|
||||
cw_log (LOG_ERR, "Fatal error: No listen addresses found.");
|
||||
return 1;
|
||||
conf_parse_listen_addr (conf_listen_addrs[i], addr, port, &proto);
|
||||
|
||||
socklist_add_unicast (addr, port, proto);
|
||||
}
|
||||
*/
|
||||
|
||||
if (socklist_len == 0) {
|
||||
cw_log (LOG_ERR, "Fatal error: Could not setup any listen socket");
|
||||
return 1;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
/* create multicast sockets */
|
||||
for (i = 0; i < conf_mcast_groups_len; i++) {
|
||||
|
||||
@ -308,20 +298,13 @@ int ac_run(cw_Cfg_t * cfg)
|
||||
}
|
||||
|
||||
/* broadcast socket ipv4 only */
|
||||
|
||||
//mavl_print(cfg,pcb,180);
|
||||
|
||||
cw_cfg_iter_init(cfg, &cfi, "actube/bcast");
|
||||
for (i=0; (s = cw_cfg_iter_next(&cfi, NULL)) != NULL; i++) {
|
||||
// for (i = 0; i < conf_bcast_addrs_len; i++) {
|
||||
for (i = 0; i < conf_bcast_addrs_len; i++) {
|
||||
|
||||
char addr[50], port[50];
|
||||
int proto;
|
||||
conf_parse_listen_addr (s, addr, port, &proto);
|
||||
conf_parse_listen_addr (conf_bcast_addrs[i], addr, port, &proto);
|
||||
|
||||
socklist_add_broadcast (addr, port, proto);
|
||||
|
||||
|
||||
#ifdef WITH_LWAPP
|
||||
|
||||
// printf("Adding %d\n",socklist_len);
|
||||
|
||||
315
src/ac/conf.c
315
src/ac/conf.c
@ -19,6 +19,7 @@
|
||||
#include <string.h>
|
||||
#include <sys/utsname.h>
|
||||
|
||||
#include <confuse.h>
|
||||
|
||||
#include "cw/capwap.h"
|
||||
#include "cw/sock.h"
|
||||
@ -39,9 +40,9 @@
|
||||
|
||||
#include "cw/mavltypes.h"
|
||||
|
||||
/*uint8_t conf_macaddress[12];
|
||||
uint8_t conf_macaddress[12];
|
||||
uint8_t conf_macaddress_len = 0;
|
||||
*/
|
||||
|
||||
|
||||
long conf_strict_capwap = 1;
|
||||
long conf_strict_headers = 0;
|
||||
@ -49,6 +50,9 @@ long conf_strict_headers = 0;
|
||||
|
||||
|
||||
|
||||
const char *conf_acname = NULL;
|
||||
int conf_acname_len = 0;
|
||||
|
||||
char *conf_acid = NULL;
|
||||
|
||||
char *conf_primary_if = NULL;
|
||||
@ -62,6 +66,9 @@ struct sockaddr_storage *conf_salist = NULL;
|
||||
char **conf_mcast_groups = 0;
|
||||
int conf_mcast_groups_len = 0;
|
||||
|
||||
char **conf_bcast_addrs = 0;
|
||||
int conf_bcast_addrs_len;
|
||||
|
||||
|
||||
struct sockaddr_storage *conf_bsalist = NULL;
|
||||
|
||||
@ -112,44 +119,14 @@ char *conf_control_port = 0;
|
||||
|
||||
int conf_dtls_verify_peer = 1;
|
||||
|
||||
static int init_ac_name(cw_Cfg_t * cfg)
|
||||
static int init_acname()
|
||||
{
|
||||
char *s;
|
||||
char *primary_if=NULL;
|
||||
char ac_name[CAPWAP_MAX_AC_NAME_LEN+1];
|
||||
uint8_t macaddress[128];
|
||||
uint8_t macaddress_len;
|
||||
char acid[128];
|
||||
int i;
|
||||
|
||||
|
||||
s= cw_cfg_get(cfg,"capwap/ac-name",NULL);
|
||||
if (s!=NULL)
|
||||
return 1;
|
||||
|
||||
// primary_if = sock_get_primary_if(AF_INET6);
|
||||
if (!primary_if)
|
||||
primary_if = sock_get_primary_if(AF_INET);
|
||||
|
||||
acid[0]=0;
|
||||
|
||||
if (primary_if) {
|
||||
macaddress_len=8;
|
||||
if (!sock_getifhwaddr(primary_if, macaddress, &macaddress_len)) {
|
||||
cw_dbg(DBG_INFO, "Fatal: Unable to detect link layer address for %s\n",
|
||||
primary_if);
|
||||
if (conf_acname == NULL) {
|
||||
char *s = malloc(strlen(CONF_DEFAULT_ACNAME) + strlen(conf_acid) + 1);
|
||||
sprintf(s, "%s%s", CONF_DEFAULT_ACNAME, conf_acid);
|
||||
conf_acname = s;
|
||||
}
|
||||
else{
|
||||
s=acid;
|
||||
for (i = 0; i < macaddress_len; i++) {
|
||||
s += sprintf(s, "%02X", macaddress[i]);
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
sprintf(ac_name,"actube%s",acid);
|
||||
cw_cfg_set(cfg,"capwap/ac-name",ac_name);
|
||||
conf_acname_len = strlen(conf_acname);
|
||||
return 1;
|
||||
}
|
||||
|
||||
@ -158,6 +135,49 @@ static int init_ac_name(cw_Cfg_t * cfg)
|
||||
|
||||
|
||||
|
||||
static int init_acid()
|
||||
{
|
||||
int i;
|
||||
char *s;
|
||||
|
||||
if (conf_acid != NULL)
|
||||
return 1;
|
||||
|
||||
|
||||
#ifdef WITH_IPV6
|
||||
conf_primary_if = sock_get_primary_if(AF_INET6);
|
||||
if (!conf_primary_if)
|
||||
conf_primary_if = sock_get_primary_if(AF_INET);
|
||||
#else
|
||||
conf_primary_if = get_primary_if(AF_INET);
|
||||
#endif
|
||||
|
||||
if (!conf_primary_if) {
|
||||
cw_log(LOG_ERR,
|
||||
"Fatal: Unable to detect primary interface, needed to set ac_id. Pleas use confiPleas u to set ac_id");
|
||||
return 0;
|
||||
}
|
||||
|
||||
if (!sock_getifhwaddr(conf_primary_if, conf_macaddress, &conf_macaddress_len)) {
|
||||
cw_log(LOG_ERR, "Fatal: Unable to detect link layer address for %s\n",
|
||||
conf_primary_if);
|
||||
return 0;
|
||||
};
|
||||
|
||||
|
||||
|
||||
|
||||
conf_acid = malloc(2 * conf_macaddress_len + 1);
|
||||
s = conf_acid;
|
||||
|
||||
for (i = 0; i < conf_macaddress_len; i++) {
|
||||
s += sprintf(s, "%02X", conf_macaddress[i]);
|
||||
}
|
||||
return 1;
|
||||
|
||||
}
|
||||
|
||||
|
||||
static int init_dtls()
|
||||
{
|
||||
if (conf_dtls_psk != NULL) {
|
||||
@ -201,13 +221,11 @@ static int init_listen_addrs(cw_Cfg_t * cfg)
|
||||
struct ifaddrs *ifap, *ifa;
|
||||
int rc;
|
||||
int ctr;
|
||||
struct cw_Cfg_iter cfi;
|
||||
const char * a0;
|
||||
|
||||
|
||||
|
||||
cw_cfg_iter_init(cfg, &cfi, "actube/listen");
|
||||
if (cw_cfg_iter_next(&cfi,NULL) != NULL)
|
||||
return 0;
|
||||
a0 = cw_cfg_get(cfg,"actube/listen.0",NULL);
|
||||
if (a0)
|
||||
return 1;
|
||||
|
||||
rc = getifaddrs(&ifap);
|
||||
if (rc == -1)
|
||||
@ -292,24 +310,18 @@ static int add_bcast_addr(void *priv, void *addr)
|
||||
/*
|
||||
* Initialize broadcast addresses (ipv4 only)
|
||||
*/
|
||||
int init_bcast_addrs(cw_Cfg_t *cfg)
|
||||
int init_bcast_addrs()
|
||||
{
|
||||
int rc;
|
||||
char str[100];
|
||||
char key[100];
|
||||
struct ifaddrs *ifa0, *ifa;
|
||||
mavl_t t;
|
||||
mavliter_t it;
|
||||
struct cw_Cfg_iter cfi;
|
||||
int i;
|
||||
|
||||
//printf("BCAST INIT\n");
|
||||
cw_cfg_iter_init(cfg, &cfi, "actube/bcast");
|
||||
if (cw_cfg_iter_next(&cfi,NULL) != NULL)
|
||||
return 0;
|
||||
if (conf_bcast_addrs)
|
||||
return 1;
|
||||
|
||||
|
||||
if (!cw_cfg_get_bool(cfg,"actube/ipv4", "true"))
|
||||
if (!conf_ipv4)
|
||||
return 1;
|
||||
|
||||
/*t = mavl_create_ptr(); */
|
||||
@ -347,34 +359,22 @@ int init_bcast_addrs(cw_Cfg_t *cfg)
|
||||
|
||||
|
||||
if (ifa->ifa_broadaddr) {
|
||||
char *s,*sr;
|
||||
sock_addrtostr(ifa->ifa_broadaddr, str, 100,1);
|
||||
*strchr(str, ':') = 0;
|
||||
|
||||
|
||||
s = cw_strdup(str);
|
||||
sr = mavl_add_str(t, s);
|
||||
|
||||
|
||||
printf("BCAST = %p --- %p: %s\n",str,s,str);
|
||||
mavl_add_str(t, cw_strdup(str));
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
// conf_bcast_addrs = malloc(t->count * sizeof(char *));
|
||||
conf_bcast_addrs = malloc(t->count * sizeof(char *));
|
||||
|
||||
i=0;
|
||||
mavliter_init(&it,t);
|
||||
mavliter_foreach(&it){
|
||||
char * d;
|
||||
d = mavliter_get_str(&it);
|
||||
// conf_bcast_addrs[conf_bcast_addrs_len] = cw_strdup(d);
|
||||
// if (conf_bcast_addrs[conf_bcast_addrs_len] != 0)
|
||||
// conf_bcast_addrs_len++;
|
||||
|
||||
sprintf(key,"actube/bcast.%d",i++);
|
||||
cw_cfg_set(cfg,key,d);
|
||||
|
||||
conf_bcast_addrs[conf_bcast_addrs_len] = cw_strdup(d);
|
||||
if (conf_bcast_addrs[conf_bcast_addrs_len] != 0)
|
||||
conf_bcast_addrs_len++;
|
||||
|
||||
}
|
||||
|
||||
@ -386,7 +386,7 @@ int init_bcast_addrs(cw_Cfg_t *cfg)
|
||||
return 1;
|
||||
}
|
||||
|
||||
int init_mcast_groups(cw_Cfg_t * cfg)
|
||||
int init_mcast_groups()
|
||||
{
|
||||
int ctr;
|
||||
int i;
|
||||
@ -440,7 +440,6 @@ int init_mcast_groups(cw_Cfg_t * cfg)
|
||||
|
||||
}
|
||||
|
||||
/*
|
||||
static int conf_read_strings(cfg_t * cfg, char *name, char ***dst, int *len)
|
||||
{
|
||||
|
||||
@ -466,9 +465,8 @@ static int conf_read_strings(cfg_t * cfg, char *name, char ***dst, int *len)
|
||||
return 1;
|
||||
}
|
||||
|
||||
*/
|
||||
|
||||
/*
|
||||
|
||||
static int conf_read_dbg_level(cfg_t * cfg)
|
||||
{
|
||||
const char *name = "dbg";
|
||||
@ -486,7 +484,6 @@ static int conf_read_dbg_level(cfg_t * cfg)
|
||||
}
|
||||
return 1;
|
||||
}
|
||||
*/
|
||||
|
||||
struct cw_Mod ** conf_mods;
|
||||
char *conf_mods_dir = NULL;
|
||||
@ -494,28 +491,19 @@ char *conf_mods_dir = NULL;
|
||||
/*
|
||||
* Read the module names from config file
|
||||
*/
|
||||
static int init_mods(cw_Cfg_t *cfg){
|
||||
static int conf_read_mods(cfg_t *cfg){
|
||||
|
||||
int n, i;
|
||||
const char * modname;
|
||||
n = cfg_size(cfg,CFG_ENTRY_MODS);
|
||||
|
||||
struct cw_Cfg_iter cfi;
|
||||
cw_cfg_iter_init(cfg, &cfi, "actube/mod");
|
||||
if (cw_cfg_iter_next(&cfi,NULL) == NULL){
|
||||
cw_cfg_set(cfg,"actube/mod.0","capwap");
|
||||
cw_cfg_set(cfg,"actube/mod.1","capwap80211");
|
||||
}
|
||||
conf_mods = malloc(sizeof(struct cw_Mod *)*(n+1));
|
||||
|
||||
// cw_dbg(DBG_INFO,"Mods directory: %s",conf_mods_dir);
|
||||
// cw_mod_set_path(conf_mods_dir);
|
||||
cw_dbg(DBG_INFO,"Mods directory: %s",conf_mods_dir);
|
||||
cw_mod_set_path(conf_mods_dir);
|
||||
|
||||
cw_cfg_iter_init(cfg, &cfi, "actube/mod");
|
||||
printf("iter mods\n");
|
||||
for (i=0; (modname = cw_cfg_iter_next(&cfi, NULL)) != NULL; i++) {
|
||||
|
||||
printf("init mod name: %s\n",modname);
|
||||
|
||||
struct cw_Mod * mod = cw_mod_load(modname, cfg, CW_ROLE_AC);
|
||||
for (i=0; i < n; i++){
|
||||
char *modname = cfg_getnstr(cfg, CFG_ENTRY_MODS, i);
|
||||
struct cw_Mod * mod = cw_mod_load(modname, actube_global_cfg, CW_ROLE_AC);
|
||||
|
||||
if (!mod)
|
||||
return 0;
|
||||
@ -616,6 +604,143 @@ static void errfunc(cfg_t *cfg, const char *fmt, va_list ap){
|
||||
fprintf(stderr,"\n");
|
||||
}
|
||||
|
||||
|
||||
int read_config(const char *filename)
|
||||
{
|
||||
int i, n;
|
||||
|
||||
cfg_opt_t opts[] = {
|
||||
CFG_STR_LIST("mods", "{}", CFGF_NONE),
|
||||
CFG_SIMPLE_STR("mods_dir", &conf_mods_dir),
|
||||
|
||||
CFG_STR_LIST("dbg", "{}", CFGF_NONE),
|
||||
CFG_STR_LIST("listen", "{}", CFGF_NONE),
|
||||
CFG_STR_LIST("mcast_groups", "{}", CFGF_NONE),
|
||||
CFG_STR_LIST("broadcast_listen", "{}", CFGF_NONE),
|
||||
CFG_STR_LIST("ac_ips", "{}", CFGF_NONE),
|
||||
CFG_SIMPLE_STR("control_port", &conf_control_port),
|
||||
|
||||
CFG_SIMPLE_BOOL("strict_capwap", &conf_strict_capwap),
|
||||
CFG_SIMPLE_BOOL("strict_headers", &conf_strict_headers),
|
||||
CFG_SIMPLE_BOOL("use_loopback", &conf_use_loopback),
|
||||
/*// CFG_SIMPLE_STR("capwap_mode", &conf_capwap_mode_str),*/
|
||||
|
||||
|
||||
#ifdef WITH_LWAPP
|
||||
CFG_SIMPLE_STR("lw_control_port", &conf_lw_control_port),
|
||||
CFG_SIMPLE_BOOL("lwapp", &conf_lwapp),
|
||||
#endif
|
||||
|
||||
CFG_SIMPLE_INT("max_wtps", &conf_max_wtps),
|
||||
CFG_SIMPLE_INT("debug_level", &conf_debug_level),
|
||||
|
||||
|
||||
CFG_SIMPLE_INT("vendor_id", &conf_vendor_id),
|
||||
CFG_SIMPLE_STR("ac_id", &conf_acid),
|
||||
CFG_SIMPLE_STR("ac_name", &conf_acname),
|
||||
CFG_SIMPLE_STR("hardware_version", &conf_hardware_version),
|
||||
CFG_SIMPLE_STR("software_version", &conf_software_version),
|
||||
|
||||
CFG_SIMPLE_STR("cisco_hardware_version", &conf_cisco_hardware_version),
|
||||
CFG_SIMPLE_STR("cisco_software_version", &conf_cisco_software_version),
|
||||
|
||||
|
||||
|
||||
CFG_SIMPLE_STR("ssl_cert", &conf_sslcertfilename),
|
||||
CFG_SIMPLE_STR("ssl_key", &conf_sslkeyfilename),
|
||||
CFG_SIMPLE_STR("ssl_key_pass", &conf_sslkeypass),
|
||||
CFG_SIMPLE_STR("dtls_psk", &conf_dtls_psk),
|
||||
|
||||
CFG_SIMPLE_BOOL("dtls_verify_peer", &conf_dtls_verify_peer),
|
||||
CFG_SIMPLE_BOOL("ipv4", &conf_ipv4),
|
||||
CFG_SIMPLE_BOOL("ipv6", &conf_ipv6),
|
||||
CFG_SIMPLE_STR("db_file", &conf_db_file),
|
||||
CFG_SIMPLE_STR("image_dir", &conf_image_dir),
|
||||
|
||||
CFG_END()
|
||||
};
|
||||
cfg_t *cfg;
|
||||
|
||||
conf_mods_dir=cw_strdup("");
|
||||
|
||||
if (!init_control_port())
|
||||
return 0;
|
||||
|
||||
|
||||
cfg = cfg_init(opts, CFGF_NONE);
|
||||
cfg_set_error_function(cfg, errfunc);
|
||||
|
||||
if (cfg_parse(cfg, filename))
|
||||
return 0;
|
||||
|
||||
|
||||
/* read debug options */
|
||||
conf_read_dbg_level(cfg);
|
||||
|
||||
/* read multi cast groups */
|
||||
conf_read_strings(cfg, "mcast_groups", &conf_mcast_groups,
|
||||
&conf_mcast_groups_len);
|
||||
|
||||
/* read ipv4 broadcast addresses */
|
||||
conf_read_strings(cfg, "broadcast_listen", &conf_bcast_addrs, &conf_bcast_addrs_len);
|
||||
|
||||
|
||||
/* read ac_ips */
|
||||
n = cfg_size(cfg, "ac_ips");
|
||||
if (!(conf_ac_ips = malloc(sizeof(struct sockaddr) * n)))
|
||||
return 0;
|
||||
|
||||
conf_ac_ips_len = n;
|
||||
for (i = 0; i < n; i++) {
|
||||
struct sockaddr sa;
|
||||
char *str = cfg_getnstr(cfg, "ac_ips", i);
|
||||
if (sock_strtoaddr(cfg_getnstr(cfg, "ac_ips", i), &sa))
|
||||
conf_ac_ips[i] = sa;
|
||||
else {
|
||||
perror(str);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
if (!conf_read_mods(cfg)){
|
||||
cfg_free(cfg);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
cfg_free(cfg);
|
||||
|
||||
if (!init_acid())
|
||||
return 0;
|
||||
|
||||
if (!init_acname())
|
||||
return 0;
|
||||
|
||||
/* if (!init_version())
|
||||
return 0;
|
||||
*/
|
||||
|
||||
if (!init_vendor_id())
|
||||
return 0;
|
||||
|
||||
if (!init_dtls())
|
||||
return 0;
|
||||
|
||||
/* if (!conf_sslcipher)
|
||||
conf_sslcipher = CAPWAP_CIPHER;
|
||||
|
||||
*/ if (!conf_image_dir)
|
||||
conf_image_dir = CONF_DEFAULT_IMAGE_DIR;
|
||||
|
||||
|
||||
|
||||
init_mcast_groups();
|
||||
init_bcast_addrs();
|
||||
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
void free_config()
|
||||
{
|
||||
|
||||
@ -628,7 +753,5 @@ void ac_conf_init(cw_Cfg_t *cfg)
|
||||
{
|
||||
printf("ac conf\n");
|
||||
init_listen_addrs(cfg);
|
||||
init_bcast_addrs(cfg);
|
||||
init_ac_name(cfg);
|
||||
init_mods(cfg);
|
||||
|
||||
}
|
||||
|
||||
@ -1,12 +1,4 @@
|
||||
#Cfg
|
||||
|
||||
#
|
||||
# AC Name
|
||||
# Deafults to actube + mac address of primary interface
|
||||
#
|
||||
#capwap/ac-name
|
||||
#
|
||||
|
||||
capwap/ssl-cipher: DHE-RSA:RSA:AES-256-CBC:AES-128-CBC:SHA1:PSK
|
||||
capwap/ssl-psk-enable: false
|
||||
capwap/ssl-psk: 123456
|
||||
@ -17,23 +9,6 @@ cisco/ssl-certfile: "../../ssl/intermediate-ca/int-ca.crt"
|
||||
cisco/ssl-cipher: DEFAULT
|
||||
cisco/ssl-dhbits: 2048
|
||||
|
||||
|
||||
#
|
||||
# Whether or not to use IPv4/IPv6
|
||||
#
|
||||
#actube/ipv4: true
|
||||
#actube/ipv6: true
|
||||
#
|
||||
actube/ipv6: false
|
||||
|
||||
#
|
||||
# List of Mods
|
||||
#
|
||||
#actube/mod.1: capwap
|
||||
#actube/mod.2: capwap80211
|
||||
#
|
||||
|
||||
actube/mod.0: cisco
|
||||
actube/mod.1: capwap
|
||||
actube/mod.2: capwap80211
|
||||
#actube/listen.hitler : 123456789
|
||||
actube/listen.17 : 123456789
|
||||
|
||||
|
||||
@ -335,7 +335,7 @@ static int socklist_check_size()
|
||||
}
|
||||
|
||||
|
||||
int socklist_add_unicast(const char *addr, const char *port, int ac_proto, int ipv4, int ipv6)
|
||||
int socklist_add_unicast(const char *addr, const char *port, int ac_proto)
|
||||
{
|
||||
char sock_buf[SOCK_ADDR_BUFSIZE];
|
||||
struct addrinfo hints;
|
||||
@ -365,14 +365,6 @@ int socklist_add_unicast(const char *addr, const char *port, int ac_proto, int i
|
||||
struct sockaddr *sa;
|
||||
int sockfd;
|
||||
|
||||
if (res->ai_addr->sa_family == AF_INET && !ipv4){
|
||||
continue;
|
||||
}
|
||||
if (res->ai_addr->sa_family == AF_INET6 && !ipv6){
|
||||
continue;
|
||||
}
|
||||
|
||||
|
||||
ifname[0] = 0;
|
||||
rc = sock_getifinfo(res->ai_addr, ifname, &broadcast, &netmask);
|
||||
if (!rc) {
|
||||
@ -380,7 +372,6 @@ int socklist_add_unicast(const char *addr, const char *port, int ac_proto, int i
|
||||
continue;
|
||||
}
|
||||
|
||||
|
||||
/* Bind the control port */
|
||||
sa = res->ai_addr;
|
||||
sockfd = socket(res->ai_addr->sa_family, SOCK_DGRAM, 0);
|
||||
|
||||
@ -40,7 +40,7 @@ struct socklistelem{
|
||||
|
||||
|
||||
extern int socklist_add_multicast(const char * addr, const char * port, int ac_proto);
|
||||
extern int socklist_add_unicast(const char *addr, const char * port, int ac_proto, int ipv4, int ipv6);
|
||||
extern int socklist_add_unicast(const char *addr, const char * port, int ac_proto);
|
||||
extern int socklist_add_broadcast(const char *addr, const char * port,int ac_proto);
|
||||
extern int socklist_init();
|
||||
extern void socklist_destroy();
|
||||
|
||||
@ -1743,7 +1743,7 @@ RTF_EXTENSIONS_FILE =
|
||||
# classes and files.
|
||||
# The default value is: NO.
|
||||
|
||||
GENERATE_MAN = YES
|
||||
GENERATE_MAN = NO
|
||||
|
||||
# The MAN_OUTPUT tag is used to specify where the man pages will be put. If a
|
||||
# relative path is entered the value of OUTPUT_DIRECTORY will be put in front of
|
||||
|
||||
456
src/cw/cfg.c
456
src/cw/cfg.c
@ -7,82 +7,28 @@
|
||||
#include "cfg.h"
|
||||
#include "val.h"
|
||||
|
||||
static const char *nextc(const char *s)
|
||||
{
|
||||
while (isdigit(*s))
|
||||
s++;
|
||||
return s;
|
||||
}
|
||||
|
||||
static int cmp0(const char *s1, const char *s2)
|
||||
{
|
||||
|
||||
const char *d1, *d2;
|
||||
int i1, i2, i;
|
||||
|
||||
d1 = strchr(s1, '.');
|
||||
if (d1 == NULL)
|
||||
return strcmp(s1, s2);
|
||||
|
||||
d2 = strchr(s2, '.');
|
||||
if (d2 == NULL)
|
||||
return strcmp(s1, s2);
|
||||
|
||||
if ((d1 - s1) != (d2 - s2))
|
||||
return strcmp(s1, s2);
|
||||
|
||||
if (strncmp(s1, s2, (d1 - s1)) != 0)
|
||||
return strcmp(s1, s2);
|
||||
|
||||
|
||||
|
||||
if (isdigit(d1[1])) {
|
||||
i1 = atoi(d1 + 1);
|
||||
} else {
|
||||
return cmp0(d1 + 1, d2 + 1);
|
||||
}
|
||||
|
||||
if (isdigit(d2[1])) {
|
||||
i2 = atoi(d2 + 1);
|
||||
} else {
|
||||
return cmp0(d1 + 1, d2 + 1);
|
||||
}
|
||||
|
||||
i = i1 - i2;
|
||||
if (i == 0) {
|
||||
return cmp0(nextc(d1 + 1), nextc(d2 + 1));
|
||||
}
|
||||
return i;
|
||||
|
||||
|
||||
}
|
||||
|
||||
static int cmp(const void *k1, const void *k2)
|
||||
{
|
||||
struct cw_Cfg_entry *e1, *e2;
|
||||
e1 = (struct cw_Cfg_entry *) k1;
|
||||
e2 = (struct cw_Cfg_entry *) k2;
|
||||
|
||||
|
||||
return cmp0(e1->key, e2->key);
|
||||
/* return strcmp(e1->key,e2->key);*/
|
||||
static int cmp(const void *k1,const void*k2){
|
||||
struct cw_Cfg_entry * e1,*e2;
|
||||
e1=(struct cw_Cfg_entry *)k1;
|
||||
e2=(struct cw_Cfg_entry *)k2;
|
||||
return strcmp(e1->key,e2->key);
|
||||
}
|
||||
|
||||
static void del(void *ptr)
|
||||
{
|
||||
struct cw_Cfg_entry *e;
|
||||
e = (struct cw_Cfg_entry *) ptr;
|
||||
free((void *) e->key);
|
||||
free((void *) e->val);
|
||||
struct cw_Cfg_entry * e;
|
||||
e=(struct cw_Cfg_entry *)ptr;
|
||||
free(e->key);
|
||||
free(e->val);
|
||||
}
|
||||
|
||||
|
||||
cw_Cfg_t *cw_cfg_create()
|
||||
cw_Cfg_t * cw_cfg_create()
|
||||
{
|
||||
return mavl_create(cmp, del, sizeof(struct cw_Cfg_entry));
|
||||
}
|
||||
|
||||
int cw_cfg_set(cw_Cfg_t * cfg, const char *key, const char *val)
|
||||
int cw_cfg_set(cw_Cfg_t * cfg,const char *key, const char *val)
|
||||
{
|
||||
struct cw_Cfg_entry e;
|
||||
int replaced;
|
||||
@ -91,12 +37,12 @@ int cw_cfg_set(cw_Cfg_t * cfg, const char *key, const char *val)
|
||||
if (!e.key)
|
||||
return 0;
|
||||
e.val = cw_strdup(val);
|
||||
if (!e.val) {
|
||||
free((void *) e.key);
|
||||
if (!e.val){
|
||||
free(e.key);
|
||||
return 0;
|
||||
}
|
||||
void *rc = mavl_replace(cfg, &e, &replaced);
|
||||
if (!rc) {
|
||||
void * rc = mavl_replace(cfg,&e,&replaced);
|
||||
if (!rc){
|
||||
del(&e);
|
||||
return 0;
|
||||
}
|
||||
@ -106,27 +52,32 @@ int cw_cfg_set(cw_Cfg_t * cfg, const char *key, const char *val)
|
||||
return -1;
|
||||
}
|
||||
|
||||
const char *cw_cfg_get(cw_Cfg_t * cfg, const char *key, const char *def)
|
||||
const char * cw_cfg_get(cw_Cfg_t * cfg, char *key, const char *def)
|
||||
{
|
||||
struct cw_Cfg_entry e, *r;
|
||||
struct cw_Cfg_entry e,*r;
|
||||
e.key = key;
|
||||
r = mavl_get(cfg, &e);
|
||||
r = mavl_get(cfg,&e);
|
||||
if (!r)
|
||||
return def;
|
||||
return r->val;
|
||||
}
|
||||
|
||||
|
||||
uint16_t cw_cfg_get_word(cw_Cfg_t * cfg, char *key)
|
||||
{
|
||||
|
||||
void cw_cfg_dump(cw_Cfg_t * cfg)
|
||||
}
|
||||
|
||||
|
||||
void cw_cfg_dump(cw_Cfg_t *cfg)
|
||||
{
|
||||
mavliter_t it;
|
||||
struct cw_Cfg_entry *e;
|
||||
mavliter_init(&it, cfg);
|
||||
mavliter_foreach(&it) {
|
||||
mavliter_init(&it,cfg);
|
||||
mavliter_foreach(&it){
|
||||
|
||||
e = mavliter_get(&it);
|
||||
printf("%s: '%s'\n", e->key, e->val);
|
||||
printf("%s: '%s'\n",e->key,e->val);
|
||||
//cw_dbg(dbglevel,"%s%s :%s: %s",prefix,data->key,type->get_type_name(data), value);
|
||||
}
|
||||
}
|
||||
@ -146,23 +97,23 @@ struct parser {
|
||||
static int get_char(struct parser *p)
|
||||
{
|
||||
int c;
|
||||
c = fgetc(p->f);
|
||||
c = fgetc (p->f);
|
||||
p->pos++;
|
||||
if (c == '\n') {
|
||||
p->prevpos = p->pos;
|
||||
p->line++;
|
||||
p->pos = 0;
|
||||
if (c=='\n'){
|
||||
p->prevpos=p->pos;
|
||||
p->line ++;
|
||||
p->pos=0;
|
||||
}
|
||||
return c;
|
||||
}
|
||||
|
||||
static void unget_char(struct parser *p, int c)
|
||||
{
|
||||
ungetc(c, p->f);
|
||||
if (c == '\n') {
|
||||
static void unget_char(struct parser *p,int c){
|
||||
ungetc(c,p->f);
|
||||
if (c=='\n'){
|
||||
p->line--;
|
||||
p->pos = p->prevpos;
|
||||
} else
|
||||
p->pos=p->prevpos;
|
||||
}
|
||||
else
|
||||
p->pos--;
|
||||
}
|
||||
|
||||
@ -172,17 +123,17 @@ static int get_char_q(struct parser *p)
|
||||
{
|
||||
int c;
|
||||
|
||||
while (1) {
|
||||
while(1) {
|
||||
c = get_char(p);
|
||||
if (c == EOF || c == '\n')
|
||||
if (c==EOF || c=='\n')
|
||||
return c;
|
||||
|
||||
if (c == '"' && !p->quote) {
|
||||
p->quote = 1;
|
||||
if(c=='"' && !p->quote){
|
||||
p->quote=1;
|
||||
continue;
|
||||
}
|
||||
if (c == '"' && p->quote) {
|
||||
p->quote = 0;
|
||||
if(c=='"' && p->quote){
|
||||
p->quote=0;
|
||||
continue;
|
||||
}
|
||||
break;
|
||||
@ -192,11 +143,11 @@ static int get_char_q(struct parser *p)
|
||||
if (!p->quote)
|
||||
return c;
|
||||
|
||||
if (c != '\\')
|
||||
if (c!='\\')
|
||||
return c;
|
||||
|
||||
c = get_char(p);
|
||||
switch (c) {
|
||||
switch(c){
|
||||
case EOF:
|
||||
return c;
|
||||
case 'n':
|
||||
@ -207,32 +158,32 @@ static int get_char_q(struct parser *p)
|
||||
case '"':
|
||||
return '"';
|
||||
default:
|
||||
unget_char(p, c);
|
||||
unget_char(p,c);
|
||||
return '\\';
|
||||
}
|
||||
|
||||
/* We will never reach here */
|
||||
/* return c; */
|
||||
/* return c;*/
|
||||
}
|
||||
|
||||
static int skip_chars(struct parser *p, const char *chars)
|
||||
static int skip_chars (struct parser *p, const char * chars)
|
||||
{
|
||||
int c;
|
||||
|
||||
while ((c = get_char(p)) != EOF) {
|
||||
if (strchr(chars, c))
|
||||
while ( (c = get_char (p)) != EOF) {
|
||||
if (strchr (chars, c))
|
||||
continue;
|
||||
return c;
|
||||
}
|
||||
return c;
|
||||
}
|
||||
|
||||
static int skip_to_chars(struct parser *p, const char *chars)
|
||||
static int skip_to_chars (struct parser *p, const char *chars)
|
||||
{
|
||||
int c;
|
||||
|
||||
while ((c = get_char(p)) != EOF) {
|
||||
if (strchr(chars, c))
|
||||
while ( (c = get_char (p)) != EOF) {
|
||||
if (strchr (chars, c))
|
||||
return c;
|
||||
}
|
||||
return c;
|
||||
@ -240,56 +191,52 @@ static int skip_to_chars(struct parser *p, const char *chars)
|
||||
|
||||
|
||||
|
||||
static int read_key(struct parser *p, char *key, int max_len)
|
||||
static int read_key (struct parser *p, char *key, int max_len)
|
||||
{
|
||||
int c, n;
|
||||
int c,n;
|
||||
|
||||
do {
|
||||
c = skip_chars(p, " \t\n\a\v");
|
||||
c = skip_chars (p, " \t\n\a\v");
|
||||
if (c == '#') {
|
||||
c = skip_to_chars(p, "\n\a");
|
||||
c = skip_to_chars (p, "\n\a");
|
||||
|
||||
} else {
|
||||
break;
|
||||
}
|
||||
} while (c != EOF);
|
||||
|
||||
unget_char(p, c);
|
||||
c = get_char_q(p);
|
||||
unget_char(p,c);
|
||||
c=get_char_q(p);
|
||||
|
||||
n = 0;
|
||||
while (c != EOF && n < max_len) {
|
||||
if (!p->quote && !isalnum(c)
|
||||
&& !strchr("._/-()@#|{}[]\\", c) /*strchr(": \t\n\a",c) */ ) {
|
||||
unget_char(p, c);
|
||||
n=0;
|
||||
while(c!=EOF && n<max_len){
|
||||
if (!p->quote && !isalnum(c) && !strchr("._/-()@#|{}[]\\",c)/*strchr(": \t\n\a",c)*/){
|
||||
unget_char(p,c);
|
||||
break;
|
||||
}
|
||||
|
||||
key[n] = c;
|
||||
key[n]=c;
|
||||
|
||||
c = get_char_q(p);
|
||||
c=get_char_q(p);
|
||||
n++;
|
||||
|
||||
}
|
||||
key[n] = 0;
|
||||
key[n]=0;
|
||||
return n;
|
||||
}
|
||||
|
||||
|
||||
static int skip_to_colon(FILE * f, struct parser *p)
|
||||
static int skip_to_colon(FILE *f,struct parser * p)
|
||||
{
|
||||
int c;
|
||||
c = skip_chars(p, " \t");
|
||||
if (c != ':') {
|
||||
if (c == '\n') {
|
||||
unget_char(p, c);
|
||||
sprintf(p->error,
|
||||
"Error at line %d, pos %d: Unexpected EOL, collon expected.",
|
||||
p->line, p->pos);
|
||||
c = skip_chars (p, " \t");
|
||||
if (c!=':'){
|
||||
if (c=='\n'){
|
||||
unget_char(p,c);
|
||||
sprintf(p->error,"Error at line %d, pos %d: Unexpected EOL, collon expected.", p->line, p->pos);
|
||||
return 0;
|
||||
}
|
||||
sprintf(p->error, "Error at line %d, pos %d: Collon expected.",
|
||||
p->line, p->pos);
|
||||
sprintf(p->error,"Error at line %d, pos %d: Collon expected.", p->line, p->pos);
|
||||
return 0;
|
||||
}
|
||||
return 1;
|
||||
@ -297,58 +244,58 @@ static int skip_to_colon(FILE * f, struct parser *p)
|
||||
|
||||
|
||||
|
||||
static int read_val(struct parser *p, char *val, int max_len)
|
||||
{
|
||||
int c, n, quote;
|
||||
if (!skip_to_colon(p->f, p))
|
||||
static int read_val(struct parser *p, char *val, int max_len){
|
||||
int c,n,quote;
|
||||
if (!skip_to_colon(p->f,p))
|
||||
return -1;
|
||||
c = skip_chars(p, " \t");
|
||||
if (c == '"') {
|
||||
quote = 1;
|
||||
c = get_char(p);
|
||||
} else {
|
||||
quote = 0;
|
||||
c = skip_chars (p, " \t");
|
||||
if (c=='"'){
|
||||
quote=1;
|
||||
c=get_char(p);
|
||||
}
|
||||
n = 0;
|
||||
while (c != EOF && n < max_len) {
|
||||
if (quote && c == '"') {
|
||||
else{
|
||||
quote=0;
|
||||
}
|
||||
n=0;
|
||||
while(c!=EOF && n<max_len){
|
||||
if (quote && c=='"'){
|
||||
break;
|
||||
}
|
||||
if (c == '\n') {
|
||||
if (c=='\n'){
|
||||
break;
|
||||
}
|
||||
if (quote) {
|
||||
if (c == '\\') {
|
||||
if (quote){
|
||||
if (c=='\\'){
|
||||
c = get_char(p);
|
||||
switch (c) {
|
||||
switch(c){
|
||||
case 'n':
|
||||
c = '\n';
|
||||
c='\n';
|
||||
break;
|
||||
case '\\':
|
||||
break;
|
||||
case '"':
|
||||
break;
|
||||
default:
|
||||
unget_char(p, c);
|
||||
c = '\\';
|
||||
unget_char(p,c);
|
||||
c='\\';
|
||||
}
|
||||
}
|
||||
}
|
||||
val[n++] = c;
|
||||
c = get_char(p);
|
||||
val[n++]=c;
|
||||
c=get_char(p);
|
||||
}
|
||||
|
||||
|
||||
if (!quote && n > 0) {
|
||||
while (n > 0) {
|
||||
if (isspace(val[n - 1]))
|
||||
if(!quote && n>0){
|
||||
while(n>0){
|
||||
if (isspace(val[n-1]))
|
||||
n--;
|
||||
else
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
val[n] = 0;
|
||||
val[n]=0;
|
||||
|
||||
return n;
|
||||
|
||||
@ -356,20 +303,20 @@ static int read_val(struct parser *p, char *val, int max_len)
|
||||
|
||||
|
||||
|
||||
int cw_cfg_read_line(FILE * f, struct parser *p, char *key, char *val)
|
||||
int cw_cfg_read_line (FILE *f, struct parser *p, char * key, char *val)
|
||||
{
|
||||
int n;
|
||||
|
||||
|
||||
n = read_key(p, key, CW_CFG_MAX_KEY_LEN);
|
||||
if (n == 0)
|
||||
n = read_key (p,key,CW_CFG_MAX_KEY_LEN);
|
||||
if (n==0)
|
||||
return 1;
|
||||
if (n == -1) {
|
||||
if (n==-1){
|
||||
return -1;
|
||||
}
|
||||
|
||||
n = read_val(p, val, CW_CFG_MAX_KEY_LEN);
|
||||
if (n == -1) {
|
||||
n = read_val (p,val,CW_CFG_MAX_KEY_LEN);
|
||||
if (n==-1){
|
||||
return -1;
|
||||
}
|
||||
return 0;
|
||||
@ -381,45 +328,45 @@ int cw_cfg_read_from_file(FILE * f, cw_Cfg_t * cfg)
|
||||
char val[2048];
|
||||
struct parser p;
|
||||
|
||||
p.line = 1;
|
||||
p.pos = 0;
|
||||
p.prevpos = 0;
|
||||
p.quote = 0;
|
||||
p.f = f;
|
||||
p.line=1;
|
||||
p.pos=0;
|
||||
p.prevpos=0;
|
||||
p.quote=0;
|
||||
p.f=f;
|
||||
|
||||
int rc;
|
||||
int errs = 0;
|
||||
int errs=0;
|
||||
|
||||
|
||||
do {
|
||||
|
||||
rc = cw_cfg_read_line(f, &p, key, val);
|
||||
if (rc == -1) {
|
||||
fprintf(stderr, "Error: %s\n", p.error);
|
||||
rc = cw_cfg_read_line(f,&p,key,val);
|
||||
if (rc==-1){
|
||||
fprintf(stderr,"Error: %s\n",p.error);
|
||||
errs++;
|
||||
}
|
||||
|
||||
|
||||
if (rc != 0) {
|
||||
if (rc != 0){
|
||||
continue;
|
||||
}
|
||||
|
||||
cw_cfg_set(cfg, key, val);
|
||||
cw_cfg_set(cfg,key,val);
|
||||
|
||||
|
||||
} while (rc == 0);
|
||||
}while(rc==0);
|
||||
|
||||
return errs;
|
||||
}
|
||||
|
||||
|
||||
int cw_cfg_load(const char *filename, cw_Cfg_t * cfg)
|
||||
int cw_cfg_load(const char *filename,cw_Cfg_t * cfg)
|
||||
{
|
||||
int errs;
|
||||
FILE *f = fopen(filename, "rb");
|
||||
FILE *f = fopen(filename,"rb");
|
||||
if (!f)
|
||||
return errno;
|
||||
errs = cw_cfg_read_from_file(f, cfg);
|
||||
errs = cw_cfg_read_from_file(f,cfg);
|
||||
fclose(f);
|
||||
|
||||
if (errs)
|
||||
@ -431,148 +378,64 @@ int cw_cfg_load(const char *filename, cw_Cfg_t * cfg)
|
||||
static int cw_cfg_get_next_idx(cw_Cfg_t * cfg, const char *key, int n)
|
||||
{
|
||||
char ikey[CW_CFG_MAX_KEY_LEN];
|
||||
struct cw_Cfg_entry search, *result;
|
||||
const char *d;
|
||||
struct cw_Cfg_entry search, * result;
|
||||
char *d;
|
||||
int i;
|
||||
|
||||
sprintf(ikey, "%s.%d", key, n);
|
||||
sprintf(ikey,"%s.%d",key,n);
|
||||
|
||||
search.key = ikey;
|
||||
result = mavl_get_first(cfg, &search);
|
||||
search.key=ikey;
|
||||
result = mavl_get_first(cfg,&search);
|
||||
|
||||
printf("KEY: %s\n", search.key);
|
||||
printf("NNNNN: %s\n", result->key);
|
||||
printf("KEY: %s\n",search.key);
|
||||
printf("NNNNN: %s\n",result->key);
|
||||
|
||||
|
||||
if (result == NULL)
|
||||
if (result==NULL)
|
||||
return -1;
|
||||
|
||||
d = NULL;
|
||||
for (i = strlen(ikey); i >= 0; i--) {
|
||||
d=NULL;
|
||||
for (i = strlen(ikey); i>=0; i--){
|
||||
|
||||
if (ikey[i] == '.') {
|
||||
d = result->key + i;
|
||||
if (ikey[i]=='.'){
|
||||
d = result->key+i;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (d == NULL) {
|
||||
if (d==NULL){
|
||||
return -1;
|
||||
}
|
||||
|
||||
if (result->key[i] != '.') {
|
||||
if(result->key[i]!='.'){
|
||||
return -1;
|
||||
}
|
||||
|
||||
if (strncmp(result->key, ikey, i) != 0)
|
||||
if (strncmp(result->key,ikey,i)!=0)
|
||||
return -1;
|
||||
|
||||
printf("TRANSFER %s\n", result->key + i + 1);
|
||||
return atoi(result->key + i + 1);
|
||||
printf("TRANSFER %s\n",result->key+i+1);
|
||||
return atoi(result->key+i+1);
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
static void pcb(char *dst, struct mavlnode *node)
|
||||
{
|
||||
struct cw_Cfg_entry *e = mavlnode_dataptr(node);
|
||||
sprintf(dst, "%s", e->key);
|
||||
}
|
||||
|
||||
|
||||
void cw_cfg_iter_init(cw_Cfg_t * cfg, struct cw_Cfg_iter *cfi, const char *base)
|
||||
{
|
||||
struct cw_Cfg_entry search;
|
||||
search.key = base;
|
||||
|
||||
mavliter_init(&(cfi->it), cfg);
|
||||
mavliter_seek(&(cfi->it), &search, 0);
|
||||
cfi->base = base;
|
||||
}
|
||||
|
||||
|
||||
const char *cw_cfg_iter_next(struct cw_Cfg_iter *cfi, const char *key)
|
||||
{
|
||||
struct cw_Cfg_entry *e;
|
||||
int bl, kl;
|
||||
const char *d;
|
||||
|
||||
e = mavliter_get(&(cfi->it));
|
||||
if (e == NULL)
|
||||
return NULL;
|
||||
|
||||
|
||||
bl = strlen(cfi->base);
|
||||
kl = strlen(e->key);
|
||||
|
||||
if (bl > kl)
|
||||
return NULL;
|
||||
|
||||
if (bl == kl) {
|
||||
if (strcmp(cfi->base, e->key) != 0)
|
||||
return NULL;
|
||||
else {
|
||||
mavliter_next(&(cfi->it));
|
||||
return e->val;
|
||||
}
|
||||
|
||||
}
|
||||
d = strchr(e->key, '.');
|
||||
if (d == NULL)
|
||||
return NULL;
|
||||
|
||||
if (d - e->key != bl)
|
||||
return NULL;
|
||||
|
||||
if (strncmp(cfi->base, e->key, bl) != 0)
|
||||
return NULL;
|
||||
|
||||
mavliter_next(&(cfi->it));
|
||||
return e->val;
|
||||
}
|
||||
|
||||
void cw_cfg_iterate(cw_Cfg_t * cfg, const char *key)
|
||||
void cw_cfg_iterate(cw_Cfg_t * cfg)
|
||||
{
|
||||
printf("Iterate\n");
|
||||
struct cw_Cfg_entry *e;
|
||||
struct cw_Cfg_entry search;
|
||||
search.key = key;
|
||||
struct mavliter it;
|
||||
struct mavlnode *first;
|
||||
search.key="actube/listen";
|
||||
|
||||
mavl_print(cfg,pcb,180);
|
||||
int i=0;
|
||||
i = cw_cfg_get_next_idx(cfg,"actube/listen",i);
|
||||
|
||||
printf("SEEK TO %s\n", search.key);
|
||||
printf("This i %d\n",i);
|
||||
|
||||
struct cw_Cfg_iter cfi;
|
||||
cw_cfg_iter_init(cfg, &cfi, key);
|
||||
const char *kee;
|
||||
while ( (i = cw_cfg_get_next_idx(cfg,"actube/listen",i))!=-1) {
|
||||
|
||||
while ((kee = cw_cfg_iter_next(&cfi, NULL)) != NULL) {
|
||||
printf("KEY===%s\n", kee);
|
||||
}
|
||||
|
||||
|
||||
|
||||
return;
|
||||
|
||||
|
||||
mavliter_init(&it, cfg);
|
||||
mavliter_seek(&it, &search, 0);
|
||||
struct cw_Cfg_entry *en;
|
||||
return;
|
||||
|
||||
int i = 0;
|
||||
i = cw_cfg_get_next_idx(cfg, "actube/listen", i);
|
||||
|
||||
printf("This i %d\n", i);
|
||||
|
||||
while ((i = cw_cfg_get_next_idx(cfg, "actube/listen", i)) != -1) {
|
||||
|
||||
printf("Here i %d\n", i);
|
||||
printf("we have key: %s.%d\n", "actube/listen", i);
|
||||
printf("Next=%d\n", i);
|
||||
printf("Here i %d\n",i);
|
||||
printf("we have key: %s.%d\n","actube/listen",i);
|
||||
printf("Next=%d\n",i);
|
||||
i++;
|
||||
};
|
||||
|
||||
@ -580,30 +443,11 @@ void cw_cfg_iterate(cw_Cfg_t * cfg, const char *key)
|
||||
|
||||
|
||||
|
||||
e = mavl_get_first(cfg, &search);
|
||||
if (!e) {
|
||||
e = mavl_get_first(cfg,&search);
|
||||
if (!e){
|
||||
printf("NULL\n");
|
||||
return;
|
||||
}
|
||||
printf("%s : %s\n", e->key, e->val);
|
||||
printf("%s : %s\n",e->key,e->val);
|
||||
}
|
||||
|
||||
|
||||
|
||||
int cw_cfg_get_bool(cw_Cfg_t * cfg, const char * key, const char *def)
|
||||
{
|
||||
struct cw_Val v;
|
||||
const char *s = cw_cfg_get(cfg,key,def);
|
||||
CW_TYPE_BOOL->from_str(&v,s);
|
||||
return v.val.boolean;
|
||||
}
|
||||
|
||||
uint16_t cw_cfg_get_word(cw_Cfg_t * cfg, char *key, const char * def)
|
||||
{
|
||||
struct cw_Val v;
|
||||
const char *s = cw_cfg_get(cfg,key,def);
|
||||
CW_TYPE_WORD->from_str(&v,s);
|
||||
return v.val.word;
|
||||
}
|
||||
|
||||
|
||||
|
||||
18
src/cw/cfg.h
18
src/cw/cfg.h
@ -14,23 +14,11 @@ int cw_cfg_read_from_file(FILE * file, cw_Cfg_t * cfg);
|
||||
int cw_cfg_load(const char *filename,cw_Cfg_t * cfg);
|
||||
|
||||
struct cw_Cfg_entry{
|
||||
const char *key;
|
||||
const char *val;
|
||||
char *key;
|
||||
char *val;
|
||||
};
|
||||
|
||||
|
||||
struct cw_Cfg_iter{
|
||||
struct mavliter it;
|
||||
const char *base;
|
||||
};
|
||||
|
||||
const char * cw_cfg_get(cw_Cfg_t * cfg, const char *key, const char *def);
|
||||
|
||||
const char *cw_cfg_iter_next(struct cw_Cfg_iter *cfi, const char *key);
|
||||
void cw_cfg_iter_init(cw_Cfg_t * cfg, struct cw_Cfg_iter *cfi, const char *base);
|
||||
|
||||
int cw_cfg_get_bool(cw_Cfg_t * cfg, const char * key, const char *def);
|
||||
uint16_t cw_cfg_get_word(cw_Cfg_t * cfg, char *key, const char * def);
|
||||
const char * cw_cfg_get(cw_Cfg_t * cfg, char *key, const char *def);
|
||||
|
||||
|
||||
#endif
|
||||
|
||||
@ -5,7 +5,6 @@
|
||||
#include "cw/val.h"
|
||||
#include "cw/keys.h"
|
||||
#include "cw/dtls.h"
|
||||
#include "cw/cfg.h"
|
||||
|
||||
#include "mod_capwap.h"
|
||||
|
||||
@ -16,15 +15,16 @@ static int init(struct cw_Mod * mod, mavl_t global_cfg, int role)
|
||||
switch (role){
|
||||
case CW_ROLE_AC:{
|
||||
cw_dbg(DBG_MOD, "CAPWAP: Initialiazing mod_capwap in AC mode");
|
||||
cw_cfg_set(global_cfg,
|
||||
cw_ktv_add_from_str(global_cfg,
|
||||
"capwap/ac-descriptor/hardware/version",
|
||||
"0.0.0.1");
|
||||
cw_cfg_set(global_cfg,
|
||||
"capwap/ac-descriptor/hardware/vendor","0");
|
||||
cw_cfg_set(global_cfg,
|
||||
"capwap/ac-descriptor/software/version","0.0.0.1");
|
||||
cw_cfg_set(global_cfg,
|
||||
"capwap/ac-descriptor/software/vendor", "0");
|
||||
CW_TYPE_BSTR16,NULL,"0.0.0.1");
|
||||
cw_ktv_add_from_str(global_cfg,
|
||||
"capwap/ac-descriptor/hardware/vendor",CW_TYPE_DWORD,NULL,"0");
|
||||
cw_ktv_add_from_str(global_cfg,
|
||||
"capwap/ac-descriptor/software/version",
|
||||
CW_TYPE_BSTR16, NULL, "0.0.0.1");
|
||||
cw_ktv_add_from_str(global_cfg,
|
||||
"capwap/ac-descriptor/software/vendor",CW_TYPE_DWORD, NULL, "0");
|
||||
}
|
||||
break;
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user