154 lines
3.3 KiB
C
154 lines
3.3 KiB
C
#include <stdlib.h>
|
|
#include <time.h>
|
|
#include <errno.h>
|
|
#include <string.h>
|
|
|
|
#include "cw/cw.h"
|
|
#include "cw/capwap.h"
|
|
#include "cw/conn.h"
|
|
#include "cw/radioinfo.h"
|
|
#include "cw/log.h"
|
|
#include "cw/dtls.h"
|
|
#include "cw/sock.h"
|
|
#include "cw/cw_util.h"
|
|
|
|
|
|
|
|
#include "wtp_conf.h"
|
|
|
|
|
|
#include "cw/timer.h"
|
|
#include "wtp.h"
|
|
|
|
|
|
#include "cw/capwap.h"
|
|
#include "cw/conn.h"
|
|
#include "wtp_interface.h"
|
|
|
|
#include "cw/dbg.h"
|
|
|
|
int update =1;
|
|
|
|
|
|
|
|
static int update_cb(struct cw_ElemHandlerParams * params, uint8_t * elems_ptr, int elems_len)
|
|
{
|
|
// cw_dbg(DBG_X," **** Configuration Update Request Received ***");
|
|
// cw_cfg_dump(params->conn->global_cfg);
|
|
cw_cfg_copy(params->cfg, params->conn->global_cfg,DBG_CFG_UPDATES,"GlobalCfg");
|
|
cw_cfg_save(bootcfg.cfgfilename, params->conn->global_cfg,
|
|
"#\n# This file is igenerated by WAT\n# If you edit this, your cahnges might be overwritten\n#\n");
|
|
// cw_dbg(DBG_X," **** Configuration Update Request Received Saved ***");
|
|
return 0;
|
|
}
|
|
|
|
|
|
|
|
|
|
/*
|
|
static void update_radio(struct cw_Conn * conn, int rid, mbag_t radio_upd, mbag_t radio,mbag_t iresult )
|
|
{
|
|
|
|
printf("Updating radio with rid %d\n",rid);
|
|
}
|
|
*/
|
|
|
|
|
|
/*
|
|
static void update_radios(struct cw_Conn * conn, mbag_t result)
|
|
{
|
|
MAVLITER_DEFINE (it,conn->radios_upd);
|
|
mavliter_foreach(&it){
|
|
struct mbag_item * item = mavliter_get(&it);
|
|
int rid = item->iid;
|
|
mbag_t radio = mbag_i_get_mbag(conn->radios,rid,NULL);
|
|
if (!radio){
|
|
cw_dbg(DBG_ELEM_ERR,"Can't find radio with id %d",rid);
|
|
continue;
|
|
}
|
|
|
|
mbag_t iresult = mbag_create();
|
|
mbag_i_set_mbag(result,rid,iresult);
|
|
update_radio(conn,rid,item->data,radio,iresult);
|
|
}
|
|
|
|
}
|
|
*/
|
|
|
|
|
|
int run(struct cw_Conn * conn)
|
|
{
|
|
|
|
|
|
cw_conn_set_msg_cb(conn,CAPWAP_MSG_CONFIGURATION_UPDATE_REQUEST,update_cb);
|
|
|
|
conn->capwap_state = CAPWAP_STATE_RUN;
|
|
|
|
do {
|
|
|
|
int echo_interval = cw_cfg_get_byte(conn->global_cfg,"capwap-timers/echo-interval",CAPWAP_ECHO_INTERVAL);
|
|
|
|
/*mbag_get_word(conn->config,CW_ITEM_CAPWAP_TIMERS,CW_TIMERS)&0xff;*/
|
|
|
|
time_t timer = cw_timer_start(echo_interval-1);
|
|
int rc;
|
|
|
|
|
|
|
|
|
|
while (!cw_timer_timeout(timer) && conn->capwap_state == CAPWAP_STATE_RUN) {
|
|
cw_cfg_clear(conn->remote_cfg);
|
|
rc = cw_read_messages(conn);
|
|
if (rc < 0 && errno == EAGAIN) {
|
|
continue;
|
|
}
|
|
//printf("--------------------------------------------------------------------------------------\n");
|
|
|
|
if ( !cw_result_is_ok(rc)) {
|
|
//printf("---------------------- cwrsult is not ok\n");
|
|
break;
|
|
}
|
|
|
|
//printf("lalalala\n");
|
|
//cw_dbg_ktv_dump(conn->remote_cfg,DBG_INFO,"KTV DUMP ----------------","Remote:", "DUMP done -------");
|
|
|
|
// printf("Saving Config\n");
|
|
// mavl_merge(conn->local_cfg,conn->remote_cfg);
|
|
// cw_ktv_save(conn->local_cfg,"cisco.ktv");
|
|
// clean_cfg(conn->remote_cfg);
|
|
|
|
// cw_dbg(DBG_X,"We hav a message processed");
|
|
}
|
|
|
|
if (rc<0 && errno == EAGAIN){
|
|
rc = cw_send_request(conn,CAPWAP_MSG_ECHO_REQUEST);
|
|
|
|
if (!cw_result_is_ok(rc)) {
|
|
cw_log(LOG_ERR,"Error in run state: %d %s",rc,cw_strrc(rc));
|
|
break;
|
|
}
|
|
continue;
|
|
}
|
|
|
|
if (!cw_result_is_ok(rc)) {
|
|
cw_log(LOG_ERR,"Error in run state: %d %s",rc,cw_strrc(rc));
|
|
break;
|
|
}
|
|
|
|
} while (conn->capwap_state == CAPWAP_STATE_RUN);
|
|
|
|
|
|
/*
|
|
// int rc = cw_send_request(conn,CW_MSG_CHANGE_STATE_EVENT_REQUEST);
|
|
|
|
// if ( !cw_rcok(rc) ) {
|
|
// cw_strresult(rc);
|
|
// }
|
|
*/
|
|
return 0;
|
|
}
|
|
|
|
|
|
|
|
|