voltando a versao de n aberturas e fechamentos de sockets data 19/09
Dependencies: EthernetInterface NTPClient mbed-rtos mbed EALib
Fork of header_main_publish by
Diff: main.cpp
- Revision:
- 8:e3bfe62a477e
- Parent:
- 7:019b08223b87
- Child:
- 9:ffa64f38ef9c
diff -r 019b08223b87 -r e3bfe62a477e main.cpp --- a/main.cpp Sat Sep 13 19:21:48 2014 +0000 +++ b/main.cpp Mon Sep 15 15:13:52 2014 +0000 @@ -7,8 +7,6 @@ #include "debug.h" #include "utils.h" -//#define debug_telos - /* #define set_status(a,b) _set_status(a,b) #define _set_status(a,b) { \ @@ -32,7 +30,10 @@ /* referencia e inicio da conexao com a ethernet */ EthernetInterface eth; - __init_eth__( ð ); + volatile int eth_status = __init_eth__( ð ); + if( eth_status ){ + debug_msg("Falha ao conectar com a Eth"); + } /* debugs */ // debug_server.set_address( "192.168.120.144", 9897 ); @@ -106,24 +107,8 @@ data = __parse_cb_buffer__( &ext, &port, &type, buffer ); if( data != NULL ){ - //if( type == __CB_BYE__ ){ - // debug_msg("--> %s <--", buffer); - //} - //debug_msg("Procurando pelo CBx :: %d -- Type :: %d", ext, type ); + debug_msg("Procurando pelo CBx :: %d -- Type :: %d", ext, type ); if( type != __AUDIO__ ){ -#ifdef debug_telos - debug_msg(""); - debug_32( data ); - debug_msg(""); - __send_to_cb__( buffer ); - debug_msg(""); - type = __DO_NOTHING__; - debug_msg(""); - continue; - debug_msg(""); - } -#endif -#ifndef debug_telos Call_Box * cb = __find_CB__( v_cb, ext ); if( cb != NULL ){ cb->reset_elapsed_time(); @@ -133,26 +118,24 @@ if( type == __BOOT__ ) type = __REGISTRY__; __send_to_cb__( __build_cb_package__( ext, port, type, ( char * )data, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) ); + cb->set_msg_id( 0x11 ); type = __DO_NOTHING__; debug_msg("-- Renviado ultimo pkg --"); }else if( data[ 0 ] == ( cb->get_msg_id() | BIT7 ) ){ // ack from CBx debug_msg("-- ACK do meu pkg --"); type = __DO_NOTHING__; - cb->reset_elapsed_time(); - if( type == __REGISTRY__ ) cb->set_msg_id( cb->get_msg_id() + 10 ); } } } } -#endif }else type = __DO_NOTHING__; } //---------------------- if( t.read() > 5 ){ for( register uint8_t i = 0; i < v_cb->size(); i++ ){ Call_Box * cb = ( Call_Box * )v_cb->get_element( i ); - debug_msg(" Type :: %d -- Ext :: %d -- TimeSlice :: %d -- remain_timeslices :: %d :: v_call->size() :: %d :: Status :: %d :: SIP Status %d", type , cb->get_ext(), cb->get_timeslice(), ts->remain_timeslices(), v_call->size(), cb->status, cb->sip->status ); + debug_msg("~Type :: %d -- Ext :: %d -- TimeSlice :: %d -- remain_timeslices :: %d :: v_call->size() :: %d :: Status :: %d :: SIP Status %d", type , cb->get_ext(), cb->get_timeslice(), ts->remain_timeslices(), v_call->size(), cb->status, cb->sip->status ); } t.reset(); led3 = !led3; @@ -214,17 +197,27 @@ }break; case cb_trying : { + if( v_call->size() != 0 ){ + data[ 0 ] |= BIT7; + cb->set_msg_id( data[ 0 ] ); + set_status(cb->status,cb_idle); + cb->set_timeslice( 0x00 ); + data[ __TIMESLICE_PLACE__ ] = 0x00; + __send_to_cb__( __build_cb_package__( ext, port, __INVITE__, + ( char * )data, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) ); + debug_msg( "-- Negando chamada, uma ja em andamento -- " ); + break; + } data[ 0 ] |= BIT7; cb->set_msg_id( data[ 0 ] ); cb->set_timeslice( ts->get_timeslice() ); if( cb->get_timeslice() == 0x00 ){ //sem timeslice pra tratar com o * - set_status(cb->status,cb_idle); data[ __TIMESLICE_PLACE__ ] = 0x00; __send_to_cb__( __build_cb_package__( ext, port, __INVITE__, ( char * )data, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) ); set_status( cb->sip->status, sip_idle); - debug_msg( "-- Trying -- Sem TS -- %s ", write_buffer ); + debug_msg( "-- Trying -- Sem TS -- " ); }else{ set_status(cb->status,cb_busy); data[ __TIMESLICE_PLACE__ ] = cb->get_timeslice(); @@ -243,7 +236,7 @@ debug_msg(" -- %d on %d -- ", cb->get_ext(), data[ __TIMESLICE_PLACE__ ] ); __send_to_cb__( __build_cb_package__( ext, port, __INVITE__, ( char * )data, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) ); - debug_msg( "-- Trying -- aceitando pedido de invite -- %s ", write_buffer ); + debug_msg( "-- Trying -- aceitando pedido de invite -- "); //debug_pkg( 300, write_buffer ); }else{ set_status( cb->status,cb_idle); @@ -253,8 +246,9 @@ debug_msg(" -- %d on %d -- ", cb->get_ext(), data[ __TIMESLICE_PLACE__ ] ); __send_to_cb__( __build_cb_package__( ext, port, __CB_BYE__, ( char * )data, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) ); - debug_msg( "-- Trying -- Negando pedido de invite -- %s ", write_buffer ); + debug_msg( "-- Trying -- Negando pedido de invite -- " ); set_status( cb->sip->status, sip_idle); + debug_msg( "-- Trying -- Negando pedido de invite -- " ); } } }break; @@ -272,7 +266,7 @@ cb->reset_elapsed_time(); debug_msg(" reset_elapsed_time CBx -- %d", ext ); }else{ - debug_msg("Nao encontrado CBx :: %d -- Type :: %d", ext, type ); + debug_msg("criando CBx :: %d -- Type :: %d", ext, type ); cb = new Call_Box( ext, port ); v_cb->add( cb ); debug_msg(" Criado CBx -- %d", ext ); @@ -285,7 +279,19 @@ ( char * )data, data[ 0 ], __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) ); }break; case __TELEMETRY__ : { - debug_msg("Leitura da bateria :: ( Id : %x, MSB : %x, LSB : %x )", data[ 0 ], data[ 1 ], data[ 2 ] ); + debug_msg("Ext :: %d ::", ext ); + //TODO implementar que quando, a header recebe um pacote de telemetria + //verifica se o call box esta alocado, caso contratio, manda um pacote + //pro cbx pedindo esse registro. + /* + data[ 0 ] |= BIT7 ; + Call_Box * cb = __find_CB__( v_cb, ext ); + if( cb == NULL ){ + __send_to_cb__( __build_cb_package__( ext, port, __REGISTRY__, + ( char * )buffer, 0, __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) ); + } + debug_msg("fim telemetry"); + */ }break; case __AUDIO__ : { Call_Box * cb; @@ -297,7 +303,7 @@ //debug_pkg( 242, data ); //char * pkg = call->build_eth_package( oitocentos ); //char * pkg = call->build_eth_package( data ); - char * pkg = call->build_eth_package( data + 2 ); + char * pkg = call->build_eth_package( data ); call->send_message( pkg ); cb = __find_CB__( v_cb, ext ); if( cb != NULL ) cb->reset_elapsed_time(); @@ -305,8 +311,8 @@ debug_msg("Nao encontrado CBx :: %d -- Type :: %d", ext, type ); } }break; - }// fim switch -#ifndef debug_telos + }// fim switch + //if( type != __DO_NOTHING__ ) debug_msg( "sai do switch" ); for( register int i = 0; i < v_call->size(); i++ ){ VZ_call * call = ( VZ_call * )v_call->get_element( i ); int length = 0; @@ -326,9 +332,7 @@ __send_to_cb__( pkg2cb ); } } -#endif - //nessa funcao eu deveria me registar a cada 2 min por exemplo - registry_aging( v_cb, data, write_buffer ); + registry_aging( v_cb, buffer, write_buffer ); int ret = sip_manager( v_cb, v_call, write_buffer ); if( ret > 0x00 ){ @@ -347,6 +351,7 @@ delete( call ); } } + cb->set_msg_id( ( ( cb->get_msg_id() ) + 1 ) & ( BIT7 ^ 0xff ) ); __send_to_cb__( __build_cb_package__( ext, port, __CB_BYE__, ( char * )buffer, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) ); cb->reset_sip(); @@ -355,7 +360,7 @@ }else debug_msg("Nao encontrado CBx :: %d -- Type :: %d", ext, type ); } - call_manager( v_call, v_cb, data, write_buffer, ts ); + call_manager( v_call, v_cb, buffer, write_buffer, ts ); static uint8_t flag = 0; if( v_call->size() == 0 ){