2013-05-01 14:52:55 +02:00
|
|
|
#include "ac.h"
|
|
|
|
#include "capwap_dfa.h"
|
|
|
|
#include "capwap_array.h"
|
|
|
|
#include "ac_session.h"
|
|
|
|
|
|
|
|
/* */
|
2013-05-27 21:33:23 +02:00
|
|
|
static int receive_echo_request(struct ac_session_t* session, struct capwap_parsed_packet* packet) {
|
2013-09-16 22:11:32 +02:00
|
|
|
int validsession = 0;
|
|
|
|
struct ac_soap_response* response;
|
2013-05-27 21:33:23 +02:00
|
|
|
struct capwap_header_data capwapheader;
|
|
|
|
struct capwap_packet_txmng* txmngpacket;
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-09-16 22:11:32 +02:00
|
|
|
/* Check session */
|
|
|
|
response = ac_soap_checkwtpsession(session, session->wtpid);
|
|
|
|
if (response) {
|
|
|
|
if ((response->responsecode == HTTP_RESULT_OK) && response->xmlResponseReturn) {
|
|
|
|
xmlChar* xmlResult = xmlNodeGetContent(response->xmlResponseReturn);
|
2013-11-07 22:05:33 +01:00
|
|
|
if (xmlResult) {
|
|
|
|
if (!xmlStrcmp(xmlResult, (const xmlChar *)"true")) {
|
|
|
|
validsession = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
xmlFree(xmlResult);
|
2013-09-16 22:11:32 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
ac_soapclient_free_response(response);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!validsession) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Create response */
|
|
|
|
capwap_header_init(&capwapheader, CAPWAP_RADIOID_NONE, GET_WBID_HEADER(packet->rxmngpacket->header));
|
|
|
|
txmngpacket = capwap_packet_txmng_create_ctrl_message(&capwapheader, CAPWAP_ECHO_RESPONSE, packet->rxmngpacket->ctrlmsg.seq, session->mtu);
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Add message element */
|
2013-08-21 23:00:54 +02:00
|
|
|
/* CAPWAP_ELEMENT_VENDORPAYLOAD */ /* TODO */
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Echo response complete, get fragment packets */
|
|
|
|
ac_free_reference_last_response(session);
|
|
|
|
capwap_packet_txmng_get_fragment_packets(txmngpacket, session->responsefragmentpacket, session->fragmentid);
|
|
|
|
if (session->responsefragmentpacket->count > 1) {
|
|
|
|
session->fragmentid++;
|
|
|
|
}
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Free packets manager */
|
|
|
|
capwap_packet_txmng_free(txmngpacket);
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Save remote sequence number */
|
|
|
|
session->remoteseqnumber = packet->rxmngpacket->ctrlmsg.seq;
|
|
|
|
capwap_get_packet_digest(packet->rxmngpacket, packet->connection, session->lastrecvpackethash);
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Send Configure response to WTP */
|
|
|
|
if (!capwap_crypt_sendto_fragmentpacket(&session->ctrldtls, session->ctrlsocket.socket[session->ctrlsocket.type], session->responsefragmentpacket, &session->acctrladdress, &session->wtpctrladdress)) {
|
|
|
|
/* Response is already created and saved. When receive a re-request, DFA autoresponse */
|
|
|
|
capwap_logging_debug("Warning: error to send echo response packet");
|
2013-05-01 14:52:55 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* */
|
2013-05-27 21:33:23 +02:00
|
|
|
static int ac_send_data_keepalive(struct ac_session_t* session, struct capwap_parsed_packet* packet) {
|
|
|
|
struct capwap_list* txfragpacket;
|
|
|
|
struct capwap_header_data capwapheader;
|
|
|
|
struct capwap_packet_txmng* txmngpacket;
|
|
|
|
int result = -1;
|
|
|
|
|
|
|
|
/* Build packet */
|
|
|
|
capwap_header_init(&capwapheader, CAPWAP_RADIOID_NONE, GET_WBID_HEADER(packet->rxmngpacket->header));
|
|
|
|
capwap_header_set_keepalive_flag(&capwapheader, 1);
|
|
|
|
txmngpacket = capwap_packet_txmng_create_data_message(&capwapheader, session->mtu);
|
|
|
|
|
|
|
|
/* Add message element */
|
|
|
|
capwap_packet_txmng_add_message_element(txmngpacket, CAPWAP_ELEMENT_SESSIONID, &session->sessionid);
|
|
|
|
|
|
|
|
/* Data keepalive complete, get fragment packets into local list */
|
|
|
|
txfragpacket = capwap_list_create();
|
|
|
|
capwap_packet_txmng_get_fragment_packets(txmngpacket, txfragpacket, 0);
|
|
|
|
if (txfragpacket->count == 1) {
|
|
|
|
/* Send Data keepalive to WTP */
|
|
|
|
if (capwap_crypt_sendto_fragmentpacket(&session->datadtls, session->datasocket.socket[session->datasocket.type], txfragpacket, &session->acdataaddress, &session->wtpdataaddress)) {
|
|
|
|
result = 0;
|
|
|
|
} else {
|
|
|
|
capwap_logging_debug("Warning: error to send data channel keepalive packet");
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
capwap_logging_debug("Warning: error to send data channel keepalive packet, fragment packet");
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Free packets manager */
|
|
|
|
capwap_list_free(txfragpacket);
|
|
|
|
capwap_packet_txmng_free(txmngpacket);
|
|
|
|
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* */
|
2013-11-05 17:54:29 +01:00
|
|
|
void ac_dfa_state_run(struct ac_session_t* session, struct capwap_parsed_packet* packet) {
|
2013-05-01 14:52:55 +02:00
|
|
|
ASSERT(session != NULL);
|
|
|
|
|
|
|
|
if (packet) {
|
2013-05-27 21:33:23 +02:00
|
|
|
if (packet->rxmngpacket->isctrlpacket) {
|
|
|
|
if (capwap_is_request_type(packet->rxmngpacket->ctrlmsg.type) || ((session->localseqnumber - 1) == packet->rxmngpacket->ctrlmsg.seq)) {
|
|
|
|
switch (packet->rxmngpacket->ctrlmsg.type) {
|
2013-08-13 17:53:04 +02:00
|
|
|
case CAPWAP_CONFIGURATION_UPDATE_RESPONSE: {
|
2013-05-27 21:33:23 +02:00
|
|
|
/* TODO */
|
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
break;
|
|
|
|
}
|
2013-08-13 17:53:04 +02:00
|
|
|
|
|
|
|
case CAPWAP_CHANGE_STATE_EVENT_REQUEST: {
|
2013-05-27 21:33:23 +02:00
|
|
|
/* TODO */
|
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
break;
|
2013-05-01 14:52:55 +02:00
|
|
|
}
|
2013-08-13 17:53:04 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
case CAPWAP_ECHO_REQUEST: {
|
|
|
|
if (!receive_echo_request(session, packet)) {
|
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
} else {
|
2013-11-05 17:54:29 +01:00
|
|
|
ac_session_teardown(session);
|
2013-05-01 14:52:55 +02:00
|
|
|
}
|
2013-08-13 17:53:04 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
break;
|
|
|
|
}
|
2013-08-13 17:53:04 +02:00
|
|
|
|
|
|
|
case CAPWAP_CLEAR_CONFIGURATION_RESPONSE: {
|
2013-05-27 21:33:23 +02:00
|
|
|
/* TODO */
|
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
break;
|
|
|
|
}
|
2013-08-13 17:53:04 +02:00
|
|
|
|
|
|
|
case CAPWAP_WTP_EVENT_REQUEST: {
|
2013-05-27 21:33:23 +02:00
|
|
|
/* TODO */
|
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
break;
|
|
|
|
}
|
2013-08-13 17:53:04 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
case CAPWAP_DATA_TRANSFER_REQUEST: {
|
2013-05-01 14:52:55 +02:00
|
|
|
/* TODO */
|
2013-05-27 21:33:23 +02:00
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
break;
|
|
|
|
}
|
2013-08-13 17:53:04 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
case CAPWAP_DATA_TRANSFER_RESPONSE: {
|
|
|
|
/* TODO */
|
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
break;
|
|
|
|
}
|
2013-08-13 17:53:04 +02:00
|
|
|
|
|
|
|
case CAPWAP_STATION_CONFIGURATION_RESPONSE: {
|
|
|
|
/* TODO */
|
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
break;
|
|
|
|
}
|
2013-10-20 17:33:57 +02:00
|
|
|
|
|
|
|
case CAPWAP_IEEE80211_WLAN_CONFIGURATION_RESPONSE: {
|
|
|
|
/* TODO */
|
|
|
|
capwap_set_timeout(AC_MAX_ECHO_INTERVAL, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
break;
|
|
|
|
}
|
2013-05-27 21:33:23 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
if (IS_FLAG_K_HEADER(packet->rxmngpacket->header)) {
|
2013-06-09 17:41:52 +02:00
|
|
|
if (!memcmp(capwap_get_message_element_data(packet, CAPWAP_ELEMENT_SESSIONID), &session->sessionid, sizeof(struct capwap_sessionid_element))) {
|
2013-05-27 21:33:23 +02:00
|
|
|
if (ac_send_data_keepalive(session, packet)) {
|
2013-11-05 17:54:29 +01:00
|
|
|
ac_session_teardown(session);
|
2013-05-01 14:52:55 +02:00
|
|
|
}
|
|
|
|
}
|
2013-05-27 21:33:23 +02:00
|
|
|
} else {
|
|
|
|
/* TODO */
|
2013-05-01 14:52:55 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
2013-11-05 17:54:29 +01:00
|
|
|
ac_session_teardown(session);
|
2013-05-01 14:52:55 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* */
|
2013-11-10 22:11:56 +01:00
|
|
|
void ac_session_reset(struct ac_session_t* session, struct capwap_imageidentifier_element* startupimage) {
|
2013-05-27 21:33:23 +02:00
|
|
|
struct capwap_header_data capwapheader;
|
|
|
|
struct capwap_packet_txmng* txmngpacket;
|
2013-05-01 14:52:55 +02:00
|
|
|
|
|
|
|
ASSERT(session != NULL);
|
2013-11-10 22:11:56 +01:00
|
|
|
ASSERT(startupimage != NULL);
|
2013-05-01 14:52:55 +02:00
|
|
|
|
|
|
|
/* Build packet */
|
2013-05-27 21:33:23 +02:00
|
|
|
capwap_header_init(&capwapheader, CAPWAP_RADIOID_NONE, session->binding);
|
|
|
|
txmngpacket = capwap_packet_txmng_create_ctrl_message(&capwapheader, CAPWAP_RESET_REQUEST, session->localseqnumber++, session->mtu);
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Add message element */
|
2013-11-10 22:11:56 +01:00
|
|
|
capwap_packet_txmng_add_message_element(txmngpacket, CAPWAP_ELEMENT_IMAGEIDENTIFIER, startupimage);
|
2013-08-21 23:00:54 +02:00
|
|
|
/* CAPWAP_ELEMENT_VENDORPAYLOAD */ /* TODO */
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Reset request complete, get fragment packets */
|
|
|
|
ac_free_reference_last_request(session);
|
|
|
|
capwap_packet_txmng_get_fragment_packets(txmngpacket, session->requestfragmentpacket, session->fragmentid);
|
|
|
|
if (session->requestfragmentpacket->count > 1) {
|
|
|
|
session->fragmentid++;
|
|
|
|
}
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Free packets manager */
|
|
|
|
capwap_packet_txmng_free(txmngpacket);
|
2013-05-01 14:52:55 +02:00
|
|
|
|
2013-05-27 21:33:23 +02:00
|
|
|
/* Send Configure response to WTP */
|
|
|
|
if (capwap_crypt_sendto_fragmentpacket(&session->ctrldtls, session->ctrlsocket.socket[session->ctrlsocket.type], session->requestfragmentpacket, &session->acctrladdress, &session->wtpctrladdress)) {
|
|
|
|
session->dfa.rfcRetransmitCount = 0;
|
|
|
|
capwap_killall_timeout(&session->timeout);
|
|
|
|
capwap_set_timeout(session->dfa.rfcRetransmitInterval, &session->timeout, CAPWAP_TIMER_CONTROL_CONNECTION);
|
|
|
|
ac_dfa_change_state(session, CAPWAP_RESET_STATE);
|
|
|
|
} else {
|
|
|
|
capwap_logging_debug("Warning: error to send reset request packet");
|
|
|
|
ac_free_reference_last_request(session);
|
2013-11-05 17:54:29 +01:00
|
|
|
ac_session_teardown(session);
|
2013-05-01 14:52:55 +02:00
|
|
|
}
|
|
|
|
}
|