main_src - Modularizando o src

VZTECH » Code » main_src

Modularizando o src

Dependencies: EALib EthernetInterface_vz mbed-rtos mbed

Fork of header_main_colinas_V0-20-09-14 by VZTECH

main.cpp@109:a5b8264ffbbc, 2015-04-07 (annotated)

Committer:: klauss
Date:: Tue Apr 07 14:27:44 2015 +0000
Revision:: 109:a5b8264ffbbc
Parent:: 108:18a3702650f3
Child:: 111:c0833f2455ed

bl wip

Who changed what in which revision?

User	Revision	Line number	New contents of line
klauss	109:a5b8264ffbbc	1	#include "telemetry.h"
klauss	109:a5b8264ffbbc	2	#include "eth.h"
klauss	109:a5b8264ffbbc	3	#include "bits.h"
klauss	109:a5b8264ffbbc	4	#include "UART3Interrupt.h" // for RXBuffer[ __CB_BUFFER_SIZE__ ];
klauss	109:a5b8264ffbbc	5	#include "utils.h"
klauss	109:a5b8264ffbbc	6	#include "parallelcpld.h"
klauss	109:a5b8264ffbbc	7	#include "debug.h"
klauss	109:a5b8264ffbbc	8	#include "flood.h"
klauss	109:a5b8264ffbbc	9	#include "bootloader_cbx.h"
klauss	109:a5b8264ffbbc	10	#include "call_manager.h"
klauss	109:a5b8264ffbbc	11	#include "call_box_manager.h"
klauss	109:a5b8264ffbbc	12	#include "sip_manager.h"
klauss	109:a5b8264ffbbc	13	#include "shared_variables.h"
klauss	109:a5b8264ffbbc	14	#include "prompt.h"
klauss	109:a5b8264ffbbc	15	#include "configs.h"
klauss	109:a5b8264ffbbc	16	#include "sdram.h"
klauss	109:a5b8264ffbbc	17	#include "fw.h"
klauss	0:4d17cd9c8f9d	18
klauss	87:679ee0d594a9	19	volatile u16_t lpc_low_level_input_counter = 0;
klauss	85:b6f2dc1d0f4f	20
klauss	91:c2a86b1f8aaa	21	int main()
klauss	109:a5b8264ffbbc	22	{
klauss	81:3656f00ab3db	23	init_wdt();
klauss	91:c2a86b1f8aaa	24
klauss	81:3656f00ab3db	25	config_lpc();
klauss	91:c2a86b1f8aaa	26
klauss	0:4d17cd9c8f9d	27	start_cpld();
klauss	91:c2a86b1f8aaa	28
klauss	100:09a23fcd3bdf	29	debug_uart3 = true;
klauss	91:c2a86b1f8aaa	30	if( sdram_init() == 1 ) {
klauss	109:a5b8264ffbbc	31	send_msg("***** Failed to initialize SDRAM *****");
klauss	87:679ee0d594a9	32	return 1;
klauss	89:0fe315117b00	33	} else {
klauss	109:a5b8264ffbbc	34	send_msg("***** Success to initialize SDRAM *****");
klauss	87:679ee0d594a9	35	}
klauss	91:c2a86b1f8aaa	36
klauss	43:455522f98de5	37	init_fsystem();
klauss	91:c2a86b1f8aaa	38
klauss	89:0fe315117b00	39	{
klauss	89:0fe315117b00	40	char s[ 32 ];
klauss	89:0fe315117b00	41	mbed_mac_address( s );
klauss	109:a5b8264ffbbc	42	send_msg( "::Mac::%02x:%02x:%02x:%02x:%02x:%02x:: ", s[0],s[1],s[2],s[3],s[4],s[5] );
klauss	89:0fe315117b00	43	}
klauss	91:c2a86b1f8aaa	44
klauss	78:1353744f01e1	45	short int eth_status = __init_eth__();
klauss	91:c2a86b1f8aaa	46	if( eth_status ) {
klauss	109:a5b8264ffbbc	47	send_msg("***** Cannot connect to eth *****");
klauss	91:c2a86b1f8aaa	48	} else {
klauss	109:a5b8264ffbbc	49	send_msg("***** Connection eth - ok *****");
klauss	78:1353744f01e1	50	init_prompt_eth();
klauss	82:f55d13babca0	51	init_external_wdt()
klauss	8:e3bfe62a477e	52	}
klauss	91:c2a86b1f8aaa	53
klauss	78:1353744f01e1	54	Timer sync_timer, led_sync_timer;
klauss	109:a5b8264ffbbc	55	sync_timer.start(), led_sync_timer.start();
klauss	91:c2a86b1f8aaa	56
klauss	109:a5b8264ffbbc	57	/* representa ramal do call box */
klauss	0:4d17cd9c8f9d	58	int ext = 0;
klauss	91:c2a86b1f8aaa	59
klauss	109:a5b8264ffbbc	60	/* representa porta do call box */
klauss	78:1353744f01e1	61	int port = 0;
klauss	91:c2a86b1f8aaa	62
klauss	109:a5b8264ffbbc	63	/* buffer para onde se copia os dados vindos do cb para tratameno interno */
klauss	109:a5b8264ffbbc	64	uint8_t buffer[ __CB_BUFFER_SIZE__ ];
klauss	91:c2a86b1f8aaa	65
klauss	109:a5b8264ffbbc	66	/* buffer de escrita do pacote de saida que sera enviado pro cb / servidor */
klauss	109:a5b8264ffbbc	67	uint8_t write_buffer[ __CB_BUFFER_SIZE__ ];
klauss	91:c2a86b1f8aaa	68
klauss	109:a5b8264ffbbc	69	/* ponteiro que aponta para os dados vindo do CPLD */
klauss	0:4d17cd9c8f9d	70	uint8_t * buffer_from_cb_ptr = ( uint8_t * )RXBuffer;
klauss	91:c2a86b1f8aaa	71
klauss	109:a5b8264ffbbc	72	/* Armazena o ultimo pacote recebido dos CBx */
klauss	109:a5b8264ffbbc	73	uint8_t cb_rx_buffer[ __CB_BUFFER_SIZE__ ];
klauss	91:c2a86b1f8aaa	74
klauss	109:a5b8264ffbbc	75	/* referencia para os dados contidos no pacote, sem o header */
klauss	0:4d17cd9c8f9d	76	uint8_t * data = NULL;
klauss	91:c2a86b1f8aaa	77
klauss	109:a5b8264ffbbc	78	/* gerencia o tipo do pacote para providenciar tratamento adequado */
klauss	0:4d17cd9c8f9d	79	volatile uint8_t type = __DO_NOTHING__;
klauss	91:c2a86b1f8aaa	80
klauss	109:a5b8264ffbbc	81	/* representa a lista dos Call Boxes atualmente recfonhecidos pela cabeceira */
klauss	0:4d17cd9c8f9d	82	Vector * v_cb = new Vector();
klauss	91:c2a86b1f8aaa	83
klauss	109:a5b8264ffbbc	84	/* representa a lista de ligacoes ativas na cabeceira */
klauss	0:4d17cd9c8f9d	85	Vector * v_call = new Vector();
klauss	91:c2a86b1f8aaa	86
klauss	109:a5b8264ffbbc	87	/* gerencia a distribuicao de timeslice para os call boxes */
klauss	0:4d17cd9c8f9d	88	Timeslice * ts = new Timeslice();
klauss	91:c2a86b1f8aaa	89	if( ts == NULL ) {
klauss	89:0fe315117b00	90	memory_is_over = true;
klauss	89:0fe315117b00	91	if( debug_memory ) debug_msg("TS allocation fail");
klauss	89:0fe315117b00	92	}
klauss	91:c2a86b1f8aaa	93
klauss	109:a5b8264ffbbc	94	/* instancia o vetor de call boxes // calls */
klauss	91:c2a86b1f8aaa	95	if( v_cb == NULL ) {
klauss	91:c2a86b1f8aaa	96	while( v_cb == NULL ) {
klauss	0:4d17cd9c8f9d	97	Vector * v_cb = new Vector();
klauss	91:c2a86b1f8aaa	98	if( sync_timer.read() > 5 ) {
klauss	48:195c97f12e8e	99	send_msg("Erro ao alocar o vetor de CBx");
klauss	78:1353744f01e1	100	sync_timer.reset();
klauss	0:4d17cd9c8f9d	101	}
klauss	0:4d17cd9c8f9d	102	}
klauss	109:a5b8264ffbbc	103	} else if( v_call == NULL ) {
klauss	91:c2a86b1f8aaa	104	while( v_call == NULL ) {
klauss	0:4d17cd9c8f9d	105	Vector * v_call = new Vector();
klauss	91:c2a86b1f8aaa	106	if( sync_timer.read() > 5 ) {
klauss	48:195c97f12e8e	107	send_msg("Erro ao alocar o vetor de Calls");
klauss	78:1353744f01e1	108	sync_timer.reset();
klauss	0:4d17cd9c8f9d	109	}
klauss	0:4d17cd9c8f9d	110	}
klauss	0:4d17cd9c8f9d	111	}
klauss	91:c2a86b1f8aaa	112
klauss	91:c2a86b1f8aaa	113	if( v_cb == NULL ) {
klauss	89:0fe315117b00	114	memory_is_over = true;
klauss	89:0fe315117b00	115	if( debug_memory ) debug_msg("Call_Box vector allocation fail");
klauss	89:0fe315117b00	116	}
klauss	91:c2a86b1f8aaa	117
klauss	91:c2a86b1f8aaa	118	if( v_call == NULL ) {
klauss	89:0fe315117b00	119	memory_is_over = true;
klauss	89:0fe315117b00	120	if( debug_memory ) debug_msg("Call vector allocation fail");
klauss	89:0fe315117b00	121	}
klauss	91:c2a86b1f8aaa	122
klauss	109:a5b8264ffbbc	123	for( register uint16_t i = 0; i < __CB_BUFFER_SIZE__; i++ ) {
klauss	63:0d95da692bb4	124	cb_rx_buffer[ i ] = 0;
klauss	63:0d95da692bb4	125	cb_tx_buffer[ i ] = 0;
klauss	63:0d95da692bb4	126	}
klauss	91:c2a86b1f8aaa	127
klauss	0:4d17cd9c8f9d	128	reset_leds();
klauss	91:c2a86b1f8aaa	129
klauss	33:735fd60e96d8	130	udp_timer.start();
klauss	109:a5b8264ffbbc	131
klauss	109:a5b8264ffbbc	132	init_telemetry_handler();
klauss	99:e80850c51106	133
klauss	109:a5b8264ffbbc	134	//debug_msg("");
klauss	99:e80850c51106	135	init_fw_handler();
klauss	109:a5b8264ffbbc	136	//debug_msg("");
klauss	99:e80850c51106	137
klauss	99:e80850c51106	138	led2 = 0;
klauss	81:3656f00ab3db	139	init_ranges();
klauss	109:a5b8264ffbbc	140
klauss	80:61d61c9eb75c	141	init_refresh();
klauss	91:c2a86b1f8aaa	142
klauss	78:1353744f01e1	143	init_aging();
klauss	91:c2a86b1f8aaa	144
klauss	89:0fe315117b00	145	init_sync_refresh();
klauss	91:c2a86b1f8aaa	146
klauss	109:a5b8264ffbbc	147	//init_invite_pgk_retry_manager();
klauss	109:a5b8264ffbbc	148
klauss	109:a5b8264ffbbc	149	//void init_bye_pgk_retry_manager();
klauss	109:a5b8264ffbbc	150
klauss	62:07e5bdc9f8f7	151	static uint8_t count = 0;
klauss	91:c2a86b1f8aaa	152
klauss	109:a5b8264ffbbc	153	//short int bl_ret = init_bl_handler();
klauss	109:a5b8264ffbbc	154	//if( dbl ) send_msg("Valor de retorno do bl_habdler = %d", bl_ret );
klauss	109:a5b8264ffbbc	155
klauss	78:1353744f01e1	156	uint8_t max_registered_cbx = 0;
klauss	91:c2a86b1f8aaa	157
klauss	81:3656f00ab3db	158	bool wake_all = false;
klauss	91:c2a86b1f8aaa	159
klauss	81:3656f00ab3db	160	uint16_t pkg_wdt = RX_CB_IDLE;
klauss	81:3656f00ab3db	161	uint16_t eth_wdt = ETH_CONNECT_TIMEOUT;
klauss	109:a5b8264ffbbc	162	uint32_t uptime = 0;
klauss	109:a5b8264ffbbc	163	led1 = 0;
klauss	109:a5b8264ffbbc	164	send_msg("Ready");
klauss	109:a5b8264ffbbc	165
klauss	109:a5b8264ffbbc	166	//bool registry_test = false;
klauss	109:a5b8264ffbbc	167	//static int next_value = 5002;
klauss	109:a5b8264ffbbc	168	//static int nex_test_registry = next_value;
klauss	105:a930035b6556	169
klauss	109:a5b8264ffbbc	170	//bool invite_retry_time = false;
klauss	99:e80850c51106	171	Timer invite_retry_timer;
klauss	99:e80850c51106	172	invite_retry_timer.start();
klauss	109:a5b8264ffbbc	173	debug_uart3 = false;
klauss	105:a930035b6556	174
klauss	109:a5b8264ffbbc	175	Timer test_timer;
klauss	91:c2a86b1f8aaa	176
klauss	78:1353744f01e1	177	/------------------------------------------ main loop ---------------------------------------------------------------/
klauss	91:c2a86b1f8aaa	178	while( true ) {
klauss	109:a5b8264ffbbc	179	reset_leds();
klauss	109:a5b8264ffbbc	180	// need be removed;
klauss	99:e80850c51106	181
klauss	78:1353744f01e1	182	if( v_cb->size() > max_registered_cbx ) max_registered_cbx = v_cb->size();
klauss	91:c2a86b1f8aaa	183
klauss	91:c2a86b1f8aaa	184	if( sync_timer.read() > 5 ) {
klauss	78:1353744f01e1	185	sync_timer.reset();
klauss	91:c2a86b1f8aaa	186
klauss	91:c2a86b1f8aaa	187	if( debug_cks == true ) {
klauss	81:3656f00ab3db	188	pcks_s = true;
klauss	78:1353744f01e1	189	}
klauss	91:c2a86b1f8aaa	190
klauss	91:c2a86b1f8aaa	191	if( debug_alive == true ) {
klauss	81:3656f00ab3db	192	pshowcb = true;
klauss	78:1353744f01e1	193	}
klauss	100:09a23fcd3bdf	194
klauss	109:a5b8264ffbbc	195
klauss	105:a930035b6556	196	{
klauss	109:a5b8264ffbbc	197	// debug_msg("Enviei");
klauss	109:a5b8264ffbbc	198	// send2callboxes( __build_cb_package__( 5000, 5000, __INVITE__,
klauss	109:a5b8264ffbbc	199	// ( char * )buffer, 0x12, __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	109:a5b8264ffbbc	200	// v_cb -> add ( new Call_Box ( 5010, 5010 ) );
klauss	105:a930035b6556	201	}
klauss	105:a930035b6556	202
klauss	109:a5b8264ffbbc	203	if( !( ++count % 15 ) ) {
klauss	91:c2a86b1f8aaa	204	if( eth_status ) {
klauss	78:1353744f01e1	205	eth_status = __init_eth__();
klauss	91:c2a86b1f8aaa	206	if( eth_status ) {
klauss	109:a5b8264ffbbc	207	if( debug_main ) debug_msg("Cannot connect to eth");
klauss	91:c2a86b1f8aaa	208	} else {
klauss	109:a5b8264ffbbc	209	if( debug_main ) debug_msg("Connection eth - ok");
klauss	78:1353744f01e1	210	init_prompt_eth();
klauss	82:f55d13babca0	211	init_external_wdt()
klauss	78:1353744f01e1	212	}
klauss	78:1353744f01e1	213	}
klauss	78:1353744f01e1	214	}
klauss	100:09a23fcd3bdf	215
klauss	109:a5b8264ffbbc	216	//35 sec.
klauss	91:c2a86b1f8aaa	217	if( ( count > 7 ) && ( wake_all == false ) ) {
klauss	81:3656f00ab3db	218	wake_all = true;
klauss	78:1353744f01e1	219	if( debug_wake == true ) send_msg( "Time to wake" );
klauss	78:1353744f01e1	220	}
klauss	109:a5b8264ffbbc	221	}
klauss	91:c2a86b1f8aaa	222
klauss	109:a5b8264ffbbc	223	//FIXMEj colocar uma condicao aqui caso necessario pra nao comprometer ligacoes ...
klauss	109:a5b8264ffbbc	224	prompt_process( NULL );
klauss	109:a5b8264ffbbc	225
klauss	91:c2a86b1f8aaa	226	if( r_stats ) {
klauss	91:c2a86b1f8aaa	227	boot_counter = 0;
klauss	91:c2a86b1f8aaa	228	registry_counter = 0;
klauss	91:c2a86b1f8aaa	229	invite_counter = 0;
klauss	91:c2a86b1f8aaa	230	audio_counter = 0;
klauss	91:c2a86b1f8aaa	231	telemetry_counter = 0;
klauss	91:c2a86b1f8aaa	232	cb_bye_counter = 0;
klauss	91:c2a86b1f8aaa	233	prompt_counter = 0;
klauss	91:c2a86b1f8aaa	234	flood_counter = 0;
klauss	67:cdedc64d9921	235	bootloader_cbx_counter = 0;
klauss	99:e80850c51106	236	cb_stats_counter = 0;
klauss	63:0d95da692bb4	237	r_stats = false;
klauss	63:0d95da692bb4	238	stats = true;
klauss	63:0d95da692bb4	239	}
klauss	91:c2a86b1f8aaa	240
klauss	91:c2a86b1f8aaa	241	if( stats ) {
klauss	63:0d95da692bb4	242	char str[ 200 ];
klauss	109:a5b8264ffbbc	243	snprintf( str, 200, "\n\rReceived Pkgs::\n\r Boot :: %u\n\r Registry :: %u\n\r Invite :: %u\n\r Audio :: %u\n\r Telemetry :: %u\n\r CB_stats :: %u\n\r CB_bye :: %u\n\r Prompt :: %u\n\r Flood :: %u\n\r Bootloader_cbx :: %u\n\r",
klauss	109:a5b8264ffbbc	244	boot_counter, registry_counter, invite_counter, audio_counter, telemetry_counter, cb_stats_counter, cb_bye_counter, prompt_counter, flood_counter, bootloader_cbx_counter );
klauss	63:0d95da692bb4	245	send_msg( str );
klauss	63:0d95da692bb4	246	stats =false;
klauss	63:0d95da692bb4	247	}
klauss	109:a5b8264ffbbc	248
klauss	109:a5b8264ffbbc	249	if( list ) {
klauss	78:1353744f01e1	250	uint8_t missed_cb = ( ( max_ext - min_ext ) + 1 ) - v_cb->size();
klauss	91:c2a86b1f8aaa	251
klauss	78:1353744f01e1	252	if( ( max_ext % 2 ) == 0 ) missed_cb++;
klauss	91:c2a86b1f8aaa	253
klauss	78:1353744f01e1	254	if( min_ext % 2 ) missed_cb++;
klauss	91:c2a86b1f8aaa	255
klauss	78:1353744f01e1	256	if( min_ext == 0 && max_ext == 0 ) missed_cb = 0;
klauss	91:c2a86b1f8aaa	257
klauss	78:1353744f01e1	258	send_msg("Registered %d[ %d ] CBx ( %d - %d ) - Missed %d -- Remain_timeslices :: %d :: v_call->size() :: %d", v_cb->size(), max_registered_cbx, min_ext, max_ext, missed_cb, ts->remain_timeslices(), v_call->size() );
klauss	91:c2a86b1f8aaa	259	if( v_cb->size() == 1 ) {
klauss	78:1353744f01e1	260	send_msg(" %d ", ( ( Call_Box * )v_cb->get_element( 0 ) )->get_ext() );
klauss	91:c2a86b1f8aaa	261	} else if( v_cb->size() > 1 ) {
klauss	62:07e5bdc9f8f7	262	char str[ 1024 ];
klauss	78:1353744f01e1	263	int ext_list[ __MAX_CB_IN_A_BRANCH__ ];
klauss	62:07e5bdc9f8f7	264	register int i = 0;
klauss	91:c2a86b1f8aaa	265	for( ; i < v_cb->size(); i++ ) {
klauss	78:1353744f01e1	266	ext_list[ i ] = ( ( Call_Box * )v_cb->get_element( i ) )->get_ext();
klauss	62:07e5bdc9f8f7	267	}
klauss	91:c2a86b1f8aaa	268
klauss	62:07e5bdc9f8f7	269	qsort( ext_list, v_cb->size(), sizeof( int ), ls_comp );
klauss	91:c2a86b1f8aaa	270
klauss	62:07e5bdc9f8f7	271	char aux[ 16 ];
klauss	78:1353744f01e1	272	strcpy( str, "\r\n> " );
klauss	91:c2a86b1f8aaa	273	for( i = 0; i < v_cb->size() - 1; i++ ) {
klauss	62:07e5bdc9f8f7	274	sprintf( aux, "%i, ", ext_list[ i ] );
klauss	62:07e5bdc9f8f7	275	strcat( str, aux );
klauss	78:1353744f01e1	276	if( ( i != 0 ) && !( ( i + 1 ) % 16 ) ) strcat( str, "\r\n> " );
klauss	62:07e5bdc9f8f7	277	}
klauss	62:07e5bdc9f8f7	278	sprintf( aux, "%i ", ext_list[ i ] );
klauss	62:07e5bdc9f8f7	279	strcat( str, aux );
klauss	62:07e5bdc9f8f7	280	send_msg( "%s", str );
klauss	62:07e5bdc9f8f7	281	}
klauss	91:c2a86b1f8aaa	282	list = false;
klauss	109:a5b8264ffbbc	283	}
klauss	109:a5b8264ffbbc	284
klauss	106:a34fcf9f0e02	285	if( long_list )
klauss	106:a34fcf9f0e02	286	{
klauss	106:a34fcf9f0e02	287	uint8_t missed_cb = ( ( max_ext - min_ext ) + 1 ) - v_cb->size();
klauss	91:c2a86b1f8aaa	288
klauss	106:a34fcf9f0e02	289	if( ( max_ext % 2 ) == 0 ) missed_cb++;
klauss	106:a34fcf9f0e02	290
klauss	106:a34fcf9f0e02	291	if( min_ext % 2 ) missed_cb++;
klauss	106:a34fcf9f0e02	292
klauss	106:a34fcf9f0e02	293	if( min_ext == 0 && max_ext == 0 ) missed_cb = 0;
klauss	106:a34fcf9f0e02	294
klauss	106:a34fcf9f0e02	295	{
klauss	106:a34fcf9f0e02	296	int ext_list[ __MAX_CB_IN_A_BRANCH__ ];
klauss	106:a34fcf9f0e02	297
klauss	106:a34fcf9f0e02	298	if( v_cb->size() >= 1 ) {
klauss	106:a34fcf9f0e02	299	for( register int i = 0; i < v_cb->size(); i++ )
klauss	106:a34fcf9f0e02	300	{
klauss	106:a34fcf9f0e02	301	ext_list[ i ] = ( ( Call_Box * )v_cb->get_element( i ) )->get_ext();
klauss	106:a34fcf9f0e02	302	}
klauss	106:a34fcf9f0e02	303	qsort( ext_list, v_cb->size(), sizeof( int ), ls_comp );
klauss	106:a34fcf9f0e02	304	}
klauss	106:a34fcf9f0e02	305
klauss	106:a34fcf9f0e02	306	send_msg("Registered %d[ %d ] CBx ( %d - %d ) - Missed %d -- Remain_timeslices :: %d :: v_call->size() :: %d", v_cb->size(), max_registered_cbx, min_ext, max_ext, missed_cb, ts->remain_timeslices(), v_call->size() );
klauss	106:a34fcf9f0e02	307
klauss	106:a34fcf9f0e02	308	for( register uint8_t i = 0; i < v_cb->size(); i++ ) {
klauss	106:a34fcf9f0e02	309
klauss	106:a34fcf9f0e02	310	Call_Box * cb = __find_CB__( v_cb, ext_list[ i ] );
klauss	106:a34fcf9f0e02	311
klauss	106:a34fcf9f0e02	312	if( cb != NULL )
klauss	106:a34fcf9f0e02	313	{
klauss	106:a34fcf9f0e02	314	char cb_status[ 32 ];
klauss	106:a34fcf9f0e02	315	char cb_sip_status[ 32 ];
klauss	106:a34fcf9f0e02	316	switch( cb->status ) {
klauss	106:a34fcf9f0e02	317	case cb_idle : {
klauss	106:a34fcf9f0e02	318	strcpy( cb_status, "cb_idle" );
klauss	106:a34fcf9f0e02	319	break;
klauss	106:a34fcf9f0e02	320	}
klauss	106:a34fcf9f0e02	321	case cb_ringing : {
klauss	106:a34fcf9f0e02	322	strcpy( cb_status, "cb_ringing" );
klauss	106:a34fcf9f0e02	323	break;
klauss	106:a34fcf9f0e02	324	}
klauss	106:a34fcf9f0e02	325	case cb_trying : {
klauss	106:a34fcf9f0e02	326	strcpy( cb_status,"cb_trying" );
klauss	106:a34fcf9f0e02	327	break;
klauss	106:a34fcf9f0e02	328	}
klauss	106:a34fcf9f0e02	329	case cb_on_call : {
klauss	106:a34fcf9f0e02	330	strcpy( cb_status, "cb_on_call" );
klauss	106:a34fcf9f0e02	331	break;
klauss	106:a34fcf9f0e02	332	}
klauss	106:a34fcf9f0e02	333	case cb_busy : {
klauss	106:a34fcf9f0e02	334	strcpy( cb_status, "cb_busy" );
klauss	106:a34fcf9f0e02	335	break;
klauss	106:a34fcf9f0e02	336	}
klauss	106:a34fcf9f0e02	337	case cb_denied : {
klauss	106:a34fcf9f0e02	338	strcpy( cb_status, "cb_denied" );
klauss	106:a34fcf9f0e02	339	break;
klauss	106:a34fcf9f0e02	340	}
klauss	106:a34fcf9f0e02	341	}
klauss	106:a34fcf9f0e02	342	switch( cb->sip->status ) {
klauss	106:a34fcf9f0e02	343	case sip_idle : {
klauss	106:a34fcf9f0e02	344	strcpy( cb_sip_status, "sip_idle" );
klauss	106:a34fcf9f0e02	345	break;
klauss	106:a34fcf9f0e02	346	}
klauss	106:a34fcf9f0e02	347	case sip_waiting_trying : {
klauss	106:a34fcf9f0e02	348	strcpy( cb_sip_status, "sip_waiting_trying" );
klauss	106:a34fcf9f0e02	349	break;
klauss	106:a34fcf9f0e02	350	}
klauss	106:a34fcf9f0e02	351	case sip_trying : {
klauss	106:a34fcf9f0e02	352	strcpy( cb_sip_status, "sip_trying" );
klauss	106:a34fcf9f0e02	353	break;
klauss	106:a34fcf9f0e02	354	}
klauss	106:a34fcf9f0e02	355	case sip_ringing : {
klauss	106:a34fcf9f0e02	356	strcpy( cb_sip_status, "sip_ringing" );
klauss	106:a34fcf9f0e02	357	break;
klauss	106:a34fcf9f0e02	358	}
klauss	106:a34fcf9f0e02	359	case sip_busy : {
klauss	106:a34fcf9f0e02	360	strcpy( cb_sip_status, "sip_busy" );
klauss	106:a34fcf9f0e02	361	break;
klauss	106:a34fcf9f0e02	362	}
klauss	106:a34fcf9f0e02	363	case sip_ok : {
klauss	106:a34fcf9f0e02	364	strcpy( cb_sip_status, "sip_ok" );
klauss	106:a34fcf9f0e02	365	break;
klauss	106:a34fcf9f0e02	366	}
klauss	106:a34fcf9f0e02	367	case sip_on_call : {
klauss	106:a34fcf9f0e02	368	strcpy( cb_sip_status, "sip_on_call" );
klauss	106:a34fcf9f0e02	369	break;
klauss	106:a34fcf9f0e02	370	}
klauss	106:a34fcf9f0e02	371	case sip_denied : {
klauss	106:a34fcf9f0e02	372	strcpy( cb_sip_status, "sip_denied" );
klauss	106:a34fcf9f0e02	373	break;
klauss	106:a34fcf9f0e02	374	}
klauss	106:a34fcf9f0e02	375	}
klauss	106:a34fcf9f0e02	376	char cbx_to_string[ 254 ];
klauss	106:a34fcf9f0e02	377	char aux[ 16 ];
klauss	106:a34fcf9f0e02	378	strcpy( cbx_to_string, "Ext :: " );
klauss	106:a34fcf9f0e02	379	itoa( cb->get_ext(), aux , 10 );
klauss	106:a34fcf9f0e02	380	strcat( cbx_to_string, aux );
klauss	106:a34fcf9f0e02	381	strcat( cbx_to_string, " :: Port :: " );
klauss	106:a34fcf9f0e02	382	itoa( cb->get_port(), aux , 10 );
klauss	106:a34fcf9f0e02	383	strcat( cbx_to_string, aux );
klauss	106:a34fcf9f0e02	384	strcat( cbx_to_string, " :: Status -- " );
klauss	106:a34fcf9f0e02	385	strcat( cbx_to_string, cb_status );
klauss	106:a34fcf9f0e02	386	strcat( cbx_to_string, " - " );
klauss	106:a34fcf9f0e02	387	strcat( cbx_to_string, cb_sip_status );
klauss	106:a34fcf9f0e02	388	if( cb->get_timeslice() != 0 ) {
klauss	106:a34fcf9f0e02	389	strcat( cbx_to_string, " -- on TimeSlice :: " );
klauss	106:a34fcf9f0e02	390	itoa( cb->get_timeslice(), aux , 10 );
klauss	106:a34fcf9f0e02	391	strcat( cbx_to_string, aux );
klauss	106:a34fcf9f0e02	392	}
klauss	106:a34fcf9f0e02	393	send_msg( cbx_to_string );
klauss	106:a34fcf9f0e02	394	}
klauss	106:a34fcf9f0e02	395	}
klauss	106:a34fcf9f0e02	396
klauss	106:a34fcf9f0e02	397	}
klauss	91:c2a86b1f8aaa	398	long_list = false;
klauss	52:12930cef17c4	399	}
klauss	91:c2a86b1f8aaa	400
klauss	109:a5b8264ffbbc	401	if( pshowcb == true ) {
klauss	78:1353744f01e1	402	send_msg("Registered %d ( of %d ) CBx ( %d - %d ) -- Remain_timeslices :: %d :: v_call->size() :: %d", v_cb->size(), max_registered_cbx, min_ext, max_ext, ts->remain_timeslices(), v_call->size() );
klauss	91:c2a86b1f8aaa	403	for( register uint8_t i = 0; i < v_cb->size(); i++ ) {
klauss	30:8dfb6d8de53d	404	Call_Box * cb = ( Call_Box * )v_cb->get_element( i );
klauss	78:1353744f01e1	405	char cb_status[ 32 ];
klauss	78:1353744f01e1	406	char cb_sip_status[ 32 ];
klauss	91:c2a86b1f8aaa	407	switch( cb->status ) {
klauss	91:c2a86b1f8aaa	408	case cb_idle : {
klauss	91:c2a86b1f8aaa	409	strcpy( cb_status, "cb_idle" );
klauss	91:c2a86b1f8aaa	410	break;
klauss	91:c2a86b1f8aaa	411	}
klauss	91:c2a86b1f8aaa	412	case cb_ringing : {
klauss	91:c2a86b1f8aaa	413	strcpy( cb_status, "cb_ringing" );
klauss	91:c2a86b1f8aaa	414	break;
klauss	91:c2a86b1f8aaa	415	}
klauss	91:c2a86b1f8aaa	416	case cb_trying : {
klauss	91:c2a86b1f8aaa	417	strcpy( cb_status,"cb_trying" );
klauss	91:c2a86b1f8aaa	418	break;
klauss	91:c2a86b1f8aaa	419	}
klauss	91:c2a86b1f8aaa	420	case cb_on_call : {
klauss	91:c2a86b1f8aaa	421	strcpy( cb_status, "cb_on_call" );
klauss	91:c2a86b1f8aaa	422	break;
klauss	91:c2a86b1f8aaa	423	}
klauss	91:c2a86b1f8aaa	424	case cb_busy : {
klauss	91:c2a86b1f8aaa	425	strcpy( cb_status, "cb_busy" );
klauss	91:c2a86b1f8aaa	426	break;
klauss	91:c2a86b1f8aaa	427	}
klauss	91:c2a86b1f8aaa	428	case cb_denied : {
klauss	91:c2a86b1f8aaa	429	strcpy( cb_status, "cb_denied" );
klauss	91:c2a86b1f8aaa	430	break;
klauss	91:c2a86b1f8aaa	431	}
klauss	78:1353744f01e1	432	}
klauss	91:c2a86b1f8aaa	433	switch( cb->sip->status ) {
klauss	91:c2a86b1f8aaa	434	case sip_idle : {
klauss	91:c2a86b1f8aaa	435	strcpy( cb_sip_status, "sip_idle" );
klauss	91:c2a86b1f8aaa	436	break;
klauss	91:c2a86b1f8aaa	437	}
klauss	91:c2a86b1f8aaa	438	case sip_waiting_trying : {
klauss	91:c2a86b1f8aaa	439	strcpy( cb_sip_status, "sip_waiting_trying" );
klauss	91:c2a86b1f8aaa	440	break;
klauss	91:c2a86b1f8aaa	441	}
klauss	91:c2a86b1f8aaa	442	case sip_trying : {
klauss	91:c2a86b1f8aaa	443	strcpy( cb_sip_status, "sip_trying" );
klauss	91:c2a86b1f8aaa	444	break;
klauss	91:c2a86b1f8aaa	445	}
klauss	91:c2a86b1f8aaa	446	case sip_ringing : {
klauss	91:c2a86b1f8aaa	447	strcpy( cb_sip_status, "sip_ringing" );
klauss	91:c2a86b1f8aaa	448	break;
klauss	91:c2a86b1f8aaa	449	}
klauss	91:c2a86b1f8aaa	450	case sip_busy : {
klauss	91:c2a86b1f8aaa	451	strcpy( cb_sip_status, "sip_busy" );
klauss	91:c2a86b1f8aaa	452	break;
klauss	91:c2a86b1f8aaa	453	}
klauss	91:c2a86b1f8aaa	454	case sip_ok : {
klauss	91:c2a86b1f8aaa	455	strcpy( cb_sip_status, "sip_ok" );
klauss	91:c2a86b1f8aaa	456	break;
klauss	91:c2a86b1f8aaa	457	}
klauss	91:c2a86b1f8aaa	458	case sip_on_call : {
klauss	91:c2a86b1f8aaa	459	strcpy( cb_sip_status, "sip_on_call" );
klauss	91:c2a86b1f8aaa	460	break;
klauss	91:c2a86b1f8aaa	461	}
klauss	91:c2a86b1f8aaa	462	case sip_denied : {
klauss	91:c2a86b1f8aaa	463	strcpy( cb_sip_status, "sip_denied" );
klauss	91:c2a86b1f8aaa	464	break;
klauss	91:c2a86b1f8aaa	465	}
klauss	78:1353744f01e1	466	}
klauss	78:1353744f01e1	467	char cbx_to_string[ 254 ];
klauss	78:1353744f01e1	468	char aux[ 16 ];
klauss	78:1353744f01e1	469	strcpy( cbx_to_string, "Ext :: " );
klauss	78:1353744f01e1	470	itoa( cb->get_ext(), aux , 10 );
klauss	98:43b45f26b430	471	strcat( cbx_to_string, aux );
klauss	97:8985817e8847	472	strcat( cbx_to_string, " :: Port :: " );
klauss	97:8985817e8847	473	itoa( cb->get_port(), aux , 10 );
klauss	78:1353744f01e1	474	strcat( cbx_to_string, aux );
klauss	78:1353744f01e1	475	strcat( cbx_to_string, " :: Status -- " );
klauss	78:1353744f01e1	476	strcat( cbx_to_string, cb_status );
klauss	78:1353744f01e1	477	strcat( cbx_to_string, " - " );
klauss	78:1353744f01e1	478	strcat( cbx_to_string, cb_sip_status );
klauss	91:c2a86b1f8aaa	479	if( cb->get_timeslice() != 0 ) {
klauss	78:1353744f01e1	480	strcat( cbx_to_string, " -- on TimeSlice :: " );
klauss	78:1353744f01e1	481	itoa( cb->get_timeslice(), aux , 10 );
klauss	78:1353744f01e1	482	strcat( cbx_to_string, aux );
klauss	78:1353744f01e1	483	}
klauss	78:1353744f01e1	484	send_msg( cbx_to_string );
klauss	48:195c97f12e8e	485	}
klauss	78:1353744f01e1	486	pshowcb = false;
klauss	48:195c97f12e8e	487	}
klauss	97:8985817e8847	488
klauss	97:8985817e8847	489	if( show_sip == true ){
klauss	97:8985817e8847	490	show_sip = false;
klauss	99:e80850c51106	491	send_msg(":: Sip :: %u", v_cb->size() );
klauss	97:8985817e8847	492	for( register uint8_t i = 0; i < v_cb->size(); i++ ) {
klauss	97:8985817e8847	493	Call_Box * cb = ( Call_Box * )v_cb->get_element( i );
klauss	109:a5b8264ffbbc	494	send_msg("ext :: %d -- port :: %d -- timer %d", cb->get_sip_ext(), cb->get_sip_port(), cb->get_timer() );
klauss	97:8985817e8847	495	}
klauss	97:8985817e8847	496	}
klauss	91:c2a86b1f8aaa	497
klauss	81:3656f00ab3db	498	if( pflood == true ) flood();
klauss	91:c2a86b1f8aaa	499
klauss	91:c2a86b1f8aaa	500	if( debug_eth ) {
klauss	81:3656f00ab3db	501	debug_eth = false;
klauss	81:3656f00ab3db	502	send_msg("Eth status %s", ( eth_status == 0 ) ? "Connected" : "Disconnected" );
klauss	81:3656f00ab3db	503	}
klauss	91:c2a86b1f8aaa	504
klauss	91:c2a86b1f8aaa	505	if( status != __WAITING__ ) {
klauss	81:3656f00ab3db	506	pkg_wdt = RX_CB_IDLE;
klauss	109:a5b8264ffbbc	507	xmemcpy( cb_rx_buffer, buffer_from_cb_ptr, __CB_BUFFER_SIZE__ );
klauss	0:4d17cd9c8f9d	508	status = __WAITING__;
klauss	81:3656f00ab3db	509	missed_pkg--;
klauss	109:a5b8264ffbbc	510	xmemcpy( buffer, cb_rx_buffer, __CB_BUFFER_SIZE__ );
klauss	109:a5b8264ffbbc	511
klauss	109:a5b8264ffbbc	512	/*
klauss	109:a5b8264ffbbc	513	{
klauss	109:a5b8264ffbbc	514	uint16_t e, p;
klauss	109:a5b8264ffbbc	515	e = buffer[0];
klauss	109:a5b8264ffbbc	516	e <<= 8;
klauss	109:a5b8264ffbbc	517	e \|= buffer[1];
klauss	109:a5b8264ffbbc	518	p = buffer[2];
klauss	109:a5b8264ffbbc	519	p <<= 8;
klauss	109:a5b8264ffbbc	520	p \|= buffer[3];
klauss	109:a5b8264ffbbc	521	//if (e != (p+100)) {
klauss	109:a5b8264ffbbc	522	if( ( buffer[0] == 0x14 ) && ( buffer[1] == 0x0a ) ) {
klauss	109:a5b8264ffbbc	523	int i;
klauss	109:a5b8264ffbbc	524	char s[400], ss[4];;
klauss	109:a5b8264ffbbc	525	strcpy(s,"OPS-PKG:");
klauss	109:a5b8264ffbbc	526	for (i=0; i<40; i++) {
klauss	109:a5b8264ffbbc	527	sprintf(ss," %02x",buffer[i]);
klauss	109:a5b8264ffbbc	528	strcat(s,ss);
klauss	109:a5b8264ffbbc	529	}
klauss	109:a5b8264ffbbc	530	debug_msg( s );
klauss	109:a5b8264ffbbc	531	}
klauss	109:a5b8264ffbbc	532	}
klauss	109:a5b8264ffbbc	533	*/
klauss	109:a5b8264ffbbc	534
klauss	109:a5b8264ffbbc	535	if( debug_cpld ) {
klauss	109:a5b8264ffbbc	536	rx = true;
klauss	109:a5b8264ffbbc	537	tx = true;
klauss	109:a5b8264ffbbc	538	}
klauss	91:c2a86b1f8aaa	539
klauss	91:c2a86b1f8aaa	540	if( rx ) {
klauss	81:3656f00ab3db	541	char str[ 1024 ];
klauss	81:3656f00ab3db	542	strcpy( str, "RX :: \n\r " );
klauss	109:a5b8264ffbbc	543	for( register uint16_t i = 0; i < __CB_BUFFER_SIZE__; i++ ) {
klauss	81:3656f00ab3db	544	char tmp[ 16 ];
klauss	81:3656f00ab3db	545	strcat( str, itoa( cb_rx_buffer[ i ], tmp, 16 ) );
klauss	81:3656f00ab3db	546	if( ( i != 0 ) && !( ( i + 1 ) % 50 ) ) strcat( str, "\n\r " );
klauss	91:c2a86b1f8aaa	547
klauss	81:3656f00ab3db	548	else strcat( str, " " );
klauss	81:3656f00ab3db	549	}
klauss	81:3656f00ab3db	550	send_msg( "%s", str );
klauss	91:c2a86b1f8aaa	551	rx = false;
klauss	81:3656f00ab3db	552	}
klauss	91:c2a86b1f8aaa	553
klauss	109:a5b8264ffbbc	554	data = __parse_vz_pkg__( &ext, &port, &type, buffer );
klauss	109:a5b8264ffbbc	555
klauss	91:c2a86b1f8aaa	556	if( data != NULL ) {
klauss	78:1353744f01e1	557	if( min_ext == 0 ) min_ext = ext;
klauss	91:c2a86b1f8aaa	558
klauss	78:1353744f01e1	559	if( ext > max_ext ) max_ext = ext;
klauss	91:c2a86b1f8aaa	560
klauss	78:1353744f01e1	561	if( ext < min_ext ) min_ext = ext;
klauss	99:e80850c51106	562
klauss	99:e80850c51106	563	if( debug_fw ){
klauss	99:e80850c51106	564	fw_cbx_pkg( ext, port, ( char *)buffer );
klauss	99:e80850c51106	565	}
klauss	99:e80850c51106	566
klauss	109:a5b8264ffbbc	567	if( type == __TELEMETRY__ ) telemetry_counter++;
klauss	109:a5b8264ffbbc	568
klauss	109:a5b8264ffbbc	569	if( type != __AUDIO__ ) {
klauss	99:e80850c51106	570	if(
klauss	99:e80850c51106	571	type == __TELEMETRY__ \|\|
klauss	99:e80850c51106	572	type == __CB_STATS__ \|\|
klauss	99:e80850c51106	573	type == __FW1__ \|\|
klauss	99:e80850c51106	574	type == __FW2__ \|\|
klauss	99:e80850c51106	575	type == __FW3__ \|\|
klauss	99:e80850c51106	576	type == __FW4__ \|\|
klauss	99:e80850c51106	577	type == __FW5__ \|\|
klauss	99:e80850c51106	578	type == __FW6__
klauss	99:e80850c51106	579	) type = __FW__;
klauss	99:e80850c51106	580
klauss	99:e80850c51106	581	if( debug_cb_rx == true ){
klauss	99:e80850c51106	582	send_msg("Pkg from CBx :: ( %d, %d ) -- Type :: %d", ext, port, type );
klauss	99:e80850c51106	583	}
klauss	99:e80850c51106	584
klauss	0:4d17cd9c8f9d	585	Call_Box * cb = __find_CB__( v_cb, ext );
klauss	91:c2a86b1f8aaa	586	if( cb != NULL ) {
klauss	92:92df17f538a8	587	if( data[ 0 ] & BIT7 ) {
klauss	91:c2a86b1f8aaa	588	if( type == __BOOT__ ) {
klauss	109:a5b8264ffbbc	589	send2callboxes( __build_cb_package__( ext, port, __REGISTRY__,
klauss	109:a5b8264ffbbc	590	( char * )data, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	92:92df17f538a8	591	} else {
klauss	81:3656f00ab3db	592	if( debug_main ) debug_msg("Received ack pkg with seq_num %d", data[ 0 ] );
klauss	91:c2a86b1f8aaa	593
klauss	91:c2a86b1f8aaa	594	switch( type ) {
klauss	81:3656f00ab3db	595	case __INVITE__ : {
klauss	81:3656f00ab3db	596	if( debug_main \|\| debug_invite ) debug_msg("Invite Ack from %d on msg_id %d", ext, cb->get_msg_id() );
klauss	109:a5b8264ffbbc	597	//cb->first_invite_response_ok();
klauss	91:c2a86b1f8aaa	598	break;
klauss	81:3656f00ab3db	599	}
klauss	81:3656f00ab3db	600	case __CB_BYE__ : {
klauss	81:3656f00ab3db	601	if( debug_main \|\| debug_invite ) debug_msg("BYE Ack from %d on msg_id %d", ext, cb->get_msg_id() );
klauss	81:3656f00ab3db	602	cb->set_bye_response_ok();
klauss	91:c2a86b1f8aaa	603	break;
klauss	81:3656f00ab3db	604	}
klauss	81:3656f00ab3db	605	case __REGISTRY__ : {
klauss	81:3656f00ab3db	606	if( debug_main \|\| debug_aging ) debug_msg("Registry ACK from %d in pkg :: %d", ext, cb->get_msg_id() );
klauss	81:3656f00ab3db	607	break;
klauss	81:3656f00ab3db	608	}
klauss	81:3656f00ab3db	609	default : {
klauss	91:c2a86b1f8aaa	610	if( debug_main \|\| debug_aging ) debug_msg("ACK from %d in pkg :: %d :: type %d", ext, cb->get_msg_id(), type );
klauss	91:c2a86b1f8aaa	611	}
klauss	81:3656f00ab3db	612	}
klauss	92:92df17f538a8	613	if( type != __REGISTRY__ && type != __CB_BYE__ ) type = __DO_NOTHING__;
klauss	92:92df17f538a8	614	if( type == __CB_BYE__ ){
klauss	92:92df17f538a8	615	VZ_call * call = __find_Call__( v_call, ext );
klauss	92:92df17f538a8	616	if( call != NULL ){
klauss	92:92df17f538a8	617	if( call->get_elapsed_time() < 120000 ){
klauss	92:92df17f538a8	618	if( debug_invite ) debug_msg("%d ack bye ignored", ext );
klauss	92:92df17f538a8	619	type = __DO_NOTHING__;
klauss	92:92df17f538a8	620	}
klauss	92:92df17f538a8	621	}
klauss	92:92df17f538a8	622	}
klauss	0:4d17cd9c8f9d	623	}
klauss	0:4d17cd9c8f9d	624	}
klauss	0:4d17cd9c8f9d	625	}
klauss	0:4d17cd9c8f9d	626	}
klauss	91:c2a86b1f8aaa	627	} else type = __DO_NOTHING__;
klauss	0:4d17cd9c8f9d	628	}
klauss	91:c2a86b1f8aaa	629
klauss	109:a5b8264ffbbc	630	if( main_test == true ) {
klauss	109:a5b8264ffbbc	631	main_test = false;
klauss	85:b6f2dc1d0f4f	632	send_msg("CB_New (%u) -- CB_Delete (%u)", cb_new_counter, cb_delete_counter );
klauss	85:b6f2dc1d0f4f	633	send_msg("SIP_New (%u) -- SIP_Delete (%u)", sip_new_counter, sip_delete_counter );
klauss	87:679ee0d594a9	634	send_msg("RTP_header_New (%u) -- RTP_header_Delete (%u)", rtp_header_new_counter, rtp_header_delete_counter );
klauss	87:679ee0d594a9	635	send_msg("RTP_body_New (%u) -- RTP_body_Delete (%u)", rtp_body_new_counter, rtp_body_delete_counter );
klauss	109:a5b8264ffbbc	636	send_msg("Call_New (%u) -- Call_Delete (%u)", call_new_counter, call_delete_counter );
klauss	87:679ee0d594a9	637	send_msg("lpc_low_level_input_counter :: %d", lpc_low_level_input_counter );
klauss	87:679ee0d594a9	638	send_msg("Memory is %s", ( memory_is_over ) ? "Over" : "Ok" );
klauss	81:3656f00ab3db	639	send_msg("Missed_Pkg :: %d ::", missed_pkg );
klauss	87:679ee0d594a9	640	send_msg("Sizeof Sip :: %u", sizeof( Sip ) );
klauss	87:679ee0d594a9	641	send_msg("Sizeof VZ_call :: %u", sizeof( VZ_call ) );
klauss	87:679ee0d594a9	642	send_msg("Sizeof RTP :: %u", sizeof( RTP ) );
klauss	87:679ee0d594a9	643	send_msg("Sizeof RTP_Header :: %u", sizeof( RTP_Header ) );
klauss	87:679ee0d594a9	644	send_msg("Sizeof RTP_Body :: %u", sizeof( RTP_Body ) );
klauss	87:679ee0d594a9	645	send_msg("Sizeof Vector :: %u", sizeof( Vector ) );
klauss	87:679ee0d594a9	646	send_msg("Sizeof Timeslice :: %u", sizeof( Timeslice ) );
klauss	87:679ee0d594a9	647	send_msg("Sizeof Watchdog :: %u", sizeof( Watchdog ) );
klauss	109:a5b8264ffbbc	648	VZ_call * call = new VZ_call( 1234, 9876, 413, 12093 );
klauss	109:a5b8264ffbbc	649	v_call -> add ( call );
klauss	109:a5b8264ffbbc	650	}
klauss	109:a5b8264ffbbc	651
klauss	109:a5b8264ffbbc	652	//static int wdt_count = 0;
klauss	109:a5b8264ffbbc	653	/*
klauss	109:a5b8264ffbbc	654	if( registry_test == true ) {
klauss	109:a5b8264ffbbc	655	registry_test = false;
klauss	109:a5b8264ffbbc	656
klauss	109:a5b8264ffbbc	657	if( wdt_count++ > 5 \|\| v_cb->size() < 66 ) {
klauss	109:a5b8264ffbbc	658	wdt_count = 0;
klauss	109:a5b8264ffbbc	659
klauss	109:a5b8264ffbbc	660	if( type == __DO_NOTHING__ ) {
klauss	109:a5b8264ffbbc	661	if( next_value < ( 5002 + __MAX_CB_IN_A_BRANCH__ - 2 ) ) {
klauss	109:a5b8264ffbbc	662	//type = __REGISTRY__;
klauss	109:a5b8264ffbbc	663	data = buffer;
klauss	109:a5b8264ffbbc	664	ext = next_value;
klauss	109:a5b8264ffbbc	665	port = next_value++;
klauss	109:a5b8264ffbbc	666	} else {
klauss	109:a5b8264ffbbc	667	if( nex_test_registry > ( 5002 + __MAX_CB_IN_A_BRANCH__ - 1 - 2 ) ) nex_test_registry = 5002;
klauss	109:a5b8264ffbbc	668	//type = __REGISTRY__;
klauss	109:a5b8264ffbbc	669	data = buffer;
klauss	109:a5b8264ffbbc	670	ext = nex_test_registry;
klauss	109:a5b8264ffbbc	671	port = nex_test_registry++;
klauss	109:a5b8264ffbbc	672	}
klauss	109:a5b8264ffbbc	673	}
klauss	109:a5b8264ffbbc	674	}
klauss	109:a5b8264ffbbc	675	}
klauss	109:a5b8264ffbbc	676	*/
klauss	109:a5b8264ffbbc	677
klauss	109:a5b8264ffbbc	678	{
klauss	109:a5b8264ffbbc	679	fd_set fdSet;
klauss	109:a5b8264ffbbc	680	FD_ZERO(&fdSet);
klauss	109:a5b8264ffbbc	681
klauss	109:a5b8264ffbbc	682	for( register uint8_t i = 0; i < v_cb->size(); i++ ) {
klauss	109:a5b8264ffbbc	683	Call_Box * cb = (Call_Box *)v_cb->get_element( i );
klauss	109:a5b8264ffbbc	684	FD_SET( cb->get_sip_socket_fd(), &fdSet);
klauss	109:a5b8264ffbbc	685	}
klauss	109:a5b8264ffbbc	686
klauss	109:a5b8264ffbbc	687	FD_SET( udp_wdt_client.get_fd(), &fdSet);
klauss	109:a5b8264ffbbc	688
klauss	109:a5b8264ffbbc	689	struct timeval t;
klauss	109:a5b8264ffbbc	690	t.tv_sec = 0;
klauss	109:a5b8264ffbbc	691	t.tv_usec = 0;
klauss	109:a5b8264ffbbc	692	int ret = lwip_select( FD_SETSIZE, &fdSet, NULL, NULL, &t );
klauss	109:a5b8264ffbbc	693
klauss	109:a5b8264ffbbc	694	if(ret > 0 ) {
klauss	109:a5b8264ffbbc	695	for( register uint8_t i = 0; i < v_cb->size(); i++ ) {
klauss	109:a5b8264ffbbc	696	Call_Box * cb = (Call_Box *)v_cb->get_element( i );
klauss	109:a5b8264ffbbc	697	int fd = cb->get_sip_socket_fd();
klauss	109:a5b8264ffbbc	698	if( FD_ISSET( fd, &fdSet ) ) {
klauss	109:a5b8264ffbbc	699	int rcv = cb->sip_udp_incomming_pkg();
klauss	109:a5b8264ffbbc	700	}
klauss	109:a5b8264ffbbc	701	}
klauss	109:a5b8264ffbbc	702	if( FD_ISSET( udp_wdt_client.get_fd(), &fdSet ) ) {
klauss	109:a5b8264ffbbc	703	char wake_msg[ 768 ];
klauss	109:a5b8264ffbbc	704	Endpoint udp_wdt_server;
klauss	109:a5b8264ffbbc	705
klauss	109:a5b8264ffbbc	706	if( udp_wdt_client.receiveFrom( udp_wdt_server, wake_msg, sizeof( wake_msg ) ) > 0 ){
klauss	109:a5b8264ffbbc	707	if( !( strncmp( wake_msg, "alive", 5 ) ) ) {
klauss	109:a5b8264ffbbc	708	// Just ckeck but not set 'alive?'
klauss	109:a5b8264ffbbc	709	// 'alive*' - force wdt tick right now
klauss	109:a5b8264ffbbc	710	// Ckecking and set 'alive'
klauss	109:a5b8264ffbbc	711	bool question_alive = ( wake_msg[ 5 ] == '?' );
klauss	109:a5b8264ffbbc	712	if( wake_msg[ 5 ] == '*' ) wdt.kick();
klauss	109:a5b8264ffbbc	713
klauss	109:a5b8264ffbbc	714	/*
klauss	109:a5b8264ffbbc	715	uint8_t registered_cbx = v_cb->size();
klauss	109:a5b8264ffbbc	716	for( register int i = 0; i < v_cb->size(); i++ ){
klauss	109:a5b8264ffbbc	717	Call_Box * cb = (Call_Box * )v_cb->get_element( i );
klauss	109:a5b8264ffbbc	718	if( cb->is_timeout() ){ if( registered_cbx ) registered_cbx--; }
klauss	109:a5b8264ffbbc	719	}
klauss	109:a5b8264ffbbc	720	*/
klauss	109:a5b8264ffbbc	721
klauss	109:a5b8264ffbbc	722	snprintf( wake_msg, 48,"wdt:%u,%u,%u,%c,%u,%u,%u,%u,%u:",
klauss	109:a5b8264ffbbc	723	uptime,
klauss	109:a5b8264ffbbc	724	invite_counter,
klauss	109:a5b8264ffbbc	725	external_wdt,
klauss	109:a5b8264ffbbc	726	( wdt.WatchdogCausedReset() ) ? '1' : '0',
klauss	109:a5b8264ffbbc	727	cb_new_counter,
klauss	109:a5b8264ffbbc	728	v_cb->size(),
klauss	109:a5b8264ffbbc	729	ts->remain_timeslices(),
klauss	109:a5b8264ffbbc	730	sip_socket_send_failure,
klauss	109:a5b8264ffbbc	731	v_call->size()
klauss	109:a5b8264ffbbc	732	// registered_cbx
klauss	109:a5b8264ffbbc	733	);
klauss	109:a5b8264ffbbc	734	wake_msg[ 768 - 1 ] = 0;
klauss	109:a5b8264ffbbc	735	udp_wdt_client.sendTo( udp_wdt_server, wake_msg, strlen( wake_msg ) );
klauss	109:a5b8264ffbbc	736
klauss	109:a5b8264ffbbc	737	if( ( (!question_alive) && ( cb_new_counter <= __MAX_CB_IN_A_BRANCH__ ) && ( cb_new_counter >= 2 ) ) ) {
klauss	109:a5b8264ffbbc	738	external_wdt = EXTERN_WDT_IDLE;
klauss	109:a5b8264ffbbc	739	}
klauss	109:a5b8264ffbbc	740	} else if( !( strncmp( wake_msg, "reset", 5 ) ) ) {
klauss	109:a5b8264ffbbc	741	external_wdt = 0;
klauss	109:a5b8264ffbbc	742
klauss	109:a5b8264ffbbc	743	sprintf( wake_msg, "rst:%u:", uptime );
klauss	109:a5b8264ffbbc	744	udp_wdt_client.sendTo( udp_wdt_server, wake_msg, strlen( wake_msg ) );
klauss	109:a5b8264ffbbc	745	}
klauss	109:a5b8264ffbbc	746	}
klauss	109:a5b8264ffbbc	747	}
klauss	109:a5b8264ffbbc	748	}
klauss	109:a5b8264ffbbc	749	}
klauss	109:a5b8264ffbbc	750
klauss	109:a5b8264ffbbc	751	if( dshow_rtp == true ){
klauss	109:a5b8264ffbbc	752	dshow_rtp = false;
klauss	109:a5b8264ffbbc	753	send_msg(":: RTP :: %u", v_cb->size() );
klauss	109:a5b8264ffbbc	754
klauss	109:a5b8264ffbbc	755	int ext_list[ __MAX_CB_IN_A_BRANCH__ ];
klauss	109:a5b8264ffbbc	756
klauss	109:a5b8264ffbbc	757	if( v_cb->size() >= 1 ) {
klauss	109:a5b8264ffbbc	758	for( register int i = 0; i < v_cb->size(); i++ )
klauss	109:a5b8264ffbbc	759	{
klauss	109:a5b8264ffbbc	760	ext_list[ i ] = ( ( Call_Box * )v_cb->get_element( i ) )->get_ext();
klauss	109:a5b8264ffbbc	761	}
klauss	109:a5b8264ffbbc	762	qsort( ext_list, v_cb->size(), sizeof( int ), ls_comp );
klauss	109:a5b8264ffbbc	763	}
klauss	109:a5b8264ffbbc	764
klauss	109:a5b8264ffbbc	765	for ( register uint8_t i = 0; i < v_cb->size(); i++ )
klauss	109:a5b8264ffbbc	766	{
klauss	109:a5b8264ffbbc	767	Call_Box * cb = __find_CB__( v_cb, ext_list[ i ] );
klauss	109:a5b8264ffbbc	768	if( cb != NULL )
klauss	109:a5b8264ffbbc	769	{
klauss	109:a5b8264ffbbc	770	send_msg("CBX ( %d, %d ) - SIP ( %d, %d ) - RTP ( %d )",
klauss	109:a5b8264ffbbc	771	cb -> get_ext (),
klauss	109:a5b8264ffbbc	772	cb -> get_port (),
klauss	109:a5b8264ffbbc	773	cb -> get_sip_ext (),
klauss	109:a5b8264ffbbc	774	cb -> get_sip_port (),
klauss	109:a5b8264ffbbc	775	cb -> get_rtp_port ()
klauss	109:a5b8264ffbbc	776	);
klauss	109:a5b8264ffbbc	777	}
klauss	109:a5b8264ffbbc	778	}
klauss	109:a5b8264ffbbc	779	}
klauss	109:a5b8264ffbbc	780
klauss	109:a5b8264ffbbc	781	if( malasia )
klauss	109:a5b8264ffbbc	782	{
klauss	109:a5b8264ffbbc	783	malasia = false;
klauss	109:a5b8264ffbbc	784	// conclusao, mudar o nro nao impala, talvez mudar o nro no pacote ...
klauss	109:a5b8264ffbbc	785	Call_Box * cb = __find_CB__( v_cb, 5016 );
klauss	109:a5b8264ffbbc	786	if( cb != NULL )
klauss	109:a5b8264ffbbc	787	{
klauss	109:a5b8264ffbbc	788	cb -> set_rtp_port ( cb -> get_rtp_port () * 10 + 1 );
klauss	109:a5b8264ffbbc	789	send_msg("CBX ( %d, %d ) - SIP ( %d, %d ) - RTP ( %d )",
klauss	109:a5b8264ffbbc	790	cb -> get_ext (),
klauss	109:a5b8264ffbbc	791	cb -> get_port (),
klauss	109:a5b8264ffbbc	792	cb -> get_sip_ext (),
klauss	109:a5b8264ffbbc	793	cb -> get_sip_port (),
klauss	109:a5b8264ffbbc	794	cb -> get_rtp_port ()
klauss	109:a5b8264ffbbc	795	);
klauss	109:a5b8264ffbbc	796	}
klauss	109:a5b8264ffbbc	797	}
klauss	109:a5b8264ffbbc	798
klauss	109:a5b8264ffbbc	799	if( york )
klauss	109:a5b8264ffbbc	800	{
klauss	109:a5b8264ffbbc	801	york = false;
klauss	109:a5b8264ffbbc	802	Call_Box * cb = __find_CB__( v_cb, 5016 );
klauss	109:a5b8264ffbbc	803	if( cb != NULL )
klauss	109:a5b8264ffbbc	804	{
klauss	109:a5b8264ffbbc	805	cb -> set_rtp_port ( 80 );
klauss	109:a5b8264ffbbc	806	send_msg("CBX ( %d, %d ) - SIP ( %d, %d ) - RTP ( %d )",
klauss	109:a5b8264ffbbc	807	cb -> get_ext (),
klauss	109:a5b8264ffbbc	808	cb -> get_port (),
klauss	109:a5b8264ffbbc	809	cb -> get_sip_ext (),
klauss	109:a5b8264ffbbc	810	cb -> get_sip_port (),
klauss	109:a5b8264ffbbc	811	cb -> get_rtp_port ()
klauss	109:a5b8264ffbbc	812	);
klauss	109:a5b8264ffbbc	813	}
klauss	109:a5b8264ffbbc	814	}
klauss	109:a5b8264ffbbc	815
klauss	109:a5b8264ffbbc	816	if ( frtp )
klauss	109:a5b8264ffbbc	817	{
klauss	109:a5b8264ffbbc	818	frtp = false;
klauss	109:a5b8264ffbbc	819	Call_Box * cb = __find_CB__( v_cb, frtp_target );
klauss	109:a5b8264ffbbc	820	if ( cb != NULL )
klauss	109:a5b8264ffbbc	821	{
klauss	109:a5b8264ffbbc	822	cb -> set_rtp_port ( -1008789032 );
klauss	109:a5b8264ffbbc	823	}
klauss	109:a5b8264ffbbc	824	else
klauss	109:a5b8264ffbbc	825	{
klauss	109:a5b8264ffbbc	826	debug_msg("frtp fail");
klauss	109:a5b8264ffbbc	827	}
klauss	109:a5b8264ffbbc	828
klauss	109:a5b8264ffbbc	829	}
klauss	109:a5b8264ffbbc	830
klauss	109:a5b8264ffbbc	831	if ( rescue_rtp )
klauss	109:a5b8264ffbbc	832	{
klauss	109:a5b8264ffbbc	833	rescue_rtp = false;
klauss	109:a5b8264ffbbc	834	Call_Box * cb = __find_CB__( v_cb, rescue_rtp_target );
klauss	109:a5b8264ffbbc	835	if ( cb != NULL )
klauss	109:a5b8264ffbbc	836	{
klauss	109:a5b8264ffbbc	837	cb -> set_rtp_port ( rescue_rtp_value );
klauss	109:a5b8264ffbbc	838	}
klauss	109:a5b8264ffbbc	839	else
klauss	109:a5b8264ffbbc	840	{
klauss	109:a5b8264ffbbc	841	debug_msg("rescue rtp fail");
klauss	109:a5b8264ffbbc	842	}
klauss	109:a5b8264ffbbc	843
klauss	109:a5b8264ffbbc	844	}
klauss	109:a5b8264ffbbc	845
klauss	109:a5b8264ffbbc	846	if( america )
klauss	109:a5b8264ffbbc	847	{
klauss	109:a5b8264ffbbc	848	america = false;
klauss	109:a5b8264ffbbc	849	Call_Box * cb = __find_CB__( v_cb, 5016 );
klauss	109:a5b8264ffbbc	850	if( cb != NULL )
klauss	109:a5b8264ffbbc	851	{
klauss	109:a5b8264ffbbc	852	cb -> set_rtp_port ( 8929415 );
klauss	109:a5b8264ffbbc	853	send_msg("CBX ( %d, %d ) - SIP ( %d, %d ) - RTP ( %d )",
klauss	109:a5b8264ffbbc	854	cb -> get_ext (),
klauss	109:a5b8264ffbbc	855	cb -> get_port (),
klauss	109:a5b8264ffbbc	856	cb -> get_sip_ext (),
klauss	109:a5b8264ffbbc	857	cb -> get_sip_port (),
klauss	109:a5b8264ffbbc	858	cb -> get_rtp_port ()
klauss	109:a5b8264ffbbc	859	);
klauss	109:a5b8264ffbbc	860	}
klauss	109:a5b8264ffbbc	861	}
klauss	109:a5b8264ffbbc	862
klauss	109:a5b8264ffbbc	863	//begin debug_print
klauss	109:a5b8264ffbbc	864	if ( print_v_cb )
klauss	109:a5b8264ffbbc	865	{
klauss	109:a5b8264ffbbc	866	print_v_cb = false;
klauss	109:a5b8264ffbbc	867	v_cb->print_yourself ();
klauss	109:a5b8264ffbbc	868	}
klauss	109:a5b8264ffbbc	869
klauss	109:a5b8264ffbbc	870	if ( print_v_call )
klauss	109:a5b8264ffbbc	871	{
klauss	109:a5b8264ffbbc	872	print_v_call = false;
klauss	109:a5b8264ffbbc	873	v_call->print_yourself ();
klauss	109:a5b8264ffbbc	874	}
klauss	109:a5b8264ffbbc	875
klauss	109:a5b8264ffbbc	876	if ( print_cb_var )
klauss	109:a5b8264ffbbc	877	{
klauss	109:a5b8264ffbbc	878	print_cb_var = false;
klauss	109:a5b8264ffbbc	879	Call_Box * cb = __find_CB__ ( v_cb, print_this_cb );
klauss	109:a5b8264ffbbc	880	if ( cb != NULL )
klauss	109:a5b8264ffbbc	881	{
klauss	109:a5b8264ffbbc	882	cb -> print_yourself ();
klauss	109:a5b8264ffbbc	883	}
klauss	109:a5b8264ffbbc	884	else
klauss	109:a5b8264ffbbc	885	{
klauss	109:a5b8264ffbbc	886	if( print_values )
klauss	109:a5b8264ffbbc	887	{
klauss	109:a5b8264ffbbc	888	debug_msg ("Objeto CBx ( %d ) nao encontrado", print_this_cb );
klauss	109:a5b8264ffbbc	889	}
klauss	109:a5b8264ffbbc	890	else
klauss	109:a5b8264ffbbc	891	{
klauss	109:a5b8264ffbbc	892	send_msg ("Objeto CBx ( %d ) nao encontrado", print_this_cb );
klauss	109:a5b8264ffbbc	893	}
klauss	109:a5b8264ffbbc	894	}
klauss	109:a5b8264ffbbc	895	}
klauss	109:a5b8264ffbbc	896
klauss	109:a5b8264ffbbc	897	if ( print_cb_all )
klauss	109:a5b8264ffbbc	898	{
klauss	109:a5b8264ffbbc	899	print_cb_all = false;
klauss	109:a5b8264ffbbc	900
klauss	109:a5b8264ffbbc	901	if ( v_cb -> size () == 0 )
klauss	109:a5b8264ffbbc	902	{
klauss	109:a5b8264ffbbc	903	send_msg("known CBx :: 0");
klauss	109:a5b8264ffbbc	904	}
klauss	109:a5b8264ffbbc	905
klauss	109:a5b8264ffbbc	906	for ( register uint8_t i = 0; i < v_cb->size(); i++ )
klauss	109:a5b8264ffbbc	907	{
klauss	109:a5b8264ffbbc	908	Call_Box * cb = (Call_Box *)v_cb->get_element( i );
klauss	109:a5b8264ffbbc	909
klauss	109:a5b8264ffbbc	910	if ( cb != NULL )
klauss	109:a5b8264ffbbc	911	{
klauss	109:a5b8264ffbbc	912	cb -> print_yourself ();
klauss	109:a5b8264ffbbc	913	}
klauss	109:a5b8264ffbbc	914	else
klauss	109:a5b8264ffbbc	915	{
klauss	109:a5b8264ffbbc	916	if ( print_values ) debug_msg ("Objeto CBx ( %d ) nao encontrado", i );
klauss	109:a5b8264ffbbc	917	}
klauss	109:a5b8264ffbbc	918	}
klauss	109:a5b8264ffbbc	919	}
klauss	109:a5b8264ffbbc	920
klauss	109:a5b8264ffbbc	921	if ( print_hex_cb_var )
klauss	109:a5b8264ffbbc	922	{
klauss	109:a5b8264ffbbc	923	print_hex_cb_var = false;
klauss	109:a5b8264ffbbc	924	uint8_t * ptr = ( uint8_t * ) __find_CB__ ( v_cb, print_hex_this_cb );
klauss	109:a5b8264ffbbc	925
klauss	109:a5b8264ffbbc	926	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	927	{
klauss	109:a5b8264ffbbc	928	send_msg ("Values :: %p\r\n", ( void *) ptr );
klauss	109:a5b8264ffbbc	929	for ( register int i = 0; i < sizeof( Call_Box ); i++ )
klauss	109:a5b8264ffbbc	930	{
klauss	109:a5b8264ffbbc	931	if( debug_uart3 ) pc.printf("%x", *ptr++ );
klauss	109:a5b8264ffbbc	932
klauss	109:a5b8264ffbbc	933	if ( ( i % 32 ) == 0 )
klauss	109:a5b8264ffbbc	934	{
klauss	109:a5b8264ffbbc	935	if( i != 0 )
klauss	109:a5b8264ffbbc	936	{
klauss	109:a5b8264ffbbc	937	if( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	938	}
klauss	109:a5b8264ffbbc	939	else
klauss	109:a5b8264ffbbc	940	{
klauss	109:a5b8264ffbbc	941	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	942	}
klauss	109:a5b8264ffbbc	943	}
klauss	109:a5b8264ffbbc	944	else
klauss	109:a5b8264ffbbc	945	{
klauss	109:a5b8264ffbbc	946	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	947	}
klauss	109:a5b8264ffbbc	948	}
klauss	109:a5b8264ffbbc	949	if ( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	950
klauss	109:a5b8264ffbbc	951	if ( tcp_session ) {
klauss	109:a5b8264ffbbc	952	char aux[ ( sizeof( Call_Box ) * 3 ) + 3 ];
klauss	109:a5b8264ffbbc	953
klauss	109:a5b8264ffbbc	954	for ( register int i = 0; i < ( sizeof( Call_Box ) * 3 ) + 3 ; i++ ) aux [ i ] = 0;
klauss	109:a5b8264ffbbc	955
klauss	109:a5b8264ffbbc	956	uint8_t * ptr = ( uint8_t * ) __find_CB__ ( v_cb, print_hex_this_cb );
klauss	109:a5b8264ffbbc	957
klauss	109:a5b8264ffbbc	958	for ( register int i = 0; i < sizeof( Call_Box ); i++ )
klauss	109:a5b8264ffbbc	959	{
klauss	109:a5b8264ffbbc	960	char tmp[ 16 ];
klauss	109:a5b8264ffbbc	961	sprintf( tmp, "%x ", *ptr++ );
klauss	109:a5b8264ffbbc	962	strcat( aux, tmp );
klauss	109:a5b8264ffbbc	963	}
klauss	109:a5b8264ffbbc	964
klauss	109:a5b8264ffbbc	965	strcat( aux, "\n\r\0" );
klauss	109:a5b8264ffbbc	966	tcp_client.send_all( ( char )aux, strlen( (char )aux ) );
klauss	109:a5b8264ffbbc	967	tcp_client.send_all( "\r\n> ", strlen( "\r\n> " ) );
klauss	109:a5b8264ffbbc	968	}
klauss	109:a5b8264ffbbc	969	}
klauss	109:a5b8264ffbbc	970	else
klauss	109:a5b8264ffbbc	971	{
klauss	109:a5b8264ffbbc	972	if ( print_values ) debug_msg ("Objeto CBx ( %d ) nao encontrado", print_this_cb );
klauss	109:a5b8264ffbbc	973	}
klauss	81:3656f00ab3db	974	}
klauss	106:a34fcf9f0e02	975
klauss	109:a5b8264ffbbc	976	if ( print_hex_cb_all )
klauss	109:a5b8264ffbbc	977	{
klauss	109:a5b8264ffbbc	978	print_hex_cb_all = false;
klauss	109:a5b8264ffbbc	979
klauss	109:a5b8264ffbbc	980	if ( v_cb -> size () == 0 )
klauss	109:a5b8264ffbbc	981	{
klauss	109:a5b8264ffbbc	982	send_msg("known CBx :: 0");
klauss	109:a5b8264ffbbc	983	}
klauss	109:a5b8264ffbbc	984
klauss	109:a5b8264ffbbc	985	for ( register uint8_t j = 0; j < v_cb->size(); j++ )
klauss	109:a5b8264ffbbc	986	{
klauss	109:a5b8264ffbbc	987	uint8_t * ptr = ( uint8_t * ) v_cb->get_element( j );
klauss	109:a5b8264ffbbc	988
klauss	109:a5b8264ffbbc	989	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	990	{
klauss	109:a5b8264ffbbc	991	send_msg ("Values :: %p\r\n", ( void *) ptr );
klauss	109:a5b8264ffbbc	992	for ( register int i = 0; i < sizeof( Call_Box ); i++ )
klauss	109:a5b8264ffbbc	993	{
klauss	109:a5b8264ffbbc	994	if( debug_uart3 ) pc.printf("%x", *ptr++ );
klauss	109:a5b8264ffbbc	995
klauss	109:a5b8264ffbbc	996	if ( ( i % 32 ) == 0 )
klauss	109:a5b8264ffbbc	997	{
klauss	109:a5b8264ffbbc	998	if( i != 0 )
klauss	109:a5b8264ffbbc	999	{
klauss	109:a5b8264ffbbc	1000	if( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1001	}
klauss	109:a5b8264ffbbc	1002	else
klauss	109:a5b8264ffbbc	1003	{
klauss	109:a5b8264ffbbc	1004	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1005	}
klauss	109:a5b8264ffbbc	1006	}
klauss	109:a5b8264ffbbc	1007	else
klauss	109:a5b8264ffbbc	1008	{
klauss	109:a5b8264ffbbc	1009	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1010	}
klauss	109:a5b8264ffbbc	1011	}
klauss	109:a5b8264ffbbc	1012	if ( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1013
klauss	109:a5b8264ffbbc	1014	if ( tcp_session ) {
klauss	109:a5b8264ffbbc	1015	char aux[ ( sizeof( Call_Box ) * 3 ) + 3 ];
klauss	109:a5b8264ffbbc	1016
klauss	109:a5b8264ffbbc	1017	for ( register int i = 0; i < ( sizeof( Call_Box ) * 3 ) + 3 ; i++ ) aux [ i ] = 0;
klauss	109:a5b8264ffbbc	1018
klauss	109:a5b8264ffbbc	1019	uint8_t * ptr = ( uint8_t * ) v_cb->get_element( j );
klauss	109:a5b8264ffbbc	1020
klauss	109:a5b8264ffbbc	1021	for ( register int i = 0; i < sizeof( Call_Box ); i++ )
klauss	109:a5b8264ffbbc	1022	{
klauss	109:a5b8264ffbbc	1023	char tmp[ 16 ];
klauss	109:a5b8264ffbbc	1024	sprintf( tmp, "%x ", *ptr++ );
klauss	109:a5b8264ffbbc	1025	strcat( aux, tmp );
klauss	109:a5b8264ffbbc	1026	}
klauss	109:a5b8264ffbbc	1027
klauss	109:a5b8264ffbbc	1028	strcat( aux, "\n\r\0" );
klauss	109:a5b8264ffbbc	1029	tcp_client.send_all( ( char )aux, strlen( (char )aux ) );
klauss	109:a5b8264ffbbc	1030	tcp_client.send_all( "\r\n> ", strlen( "\r\n> " ) );
klauss	109:a5b8264ffbbc	1031	}
klauss	109:a5b8264ffbbc	1032	}
klauss	109:a5b8264ffbbc	1033	else
klauss	109:a5b8264ffbbc	1034	{
klauss	109:a5b8264ffbbc	1035	if ( print_values )
klauss	109:a5b8264ffbbc	1036	{
klauss	109:a5b8264ffbbc	1037	debug_msg ("Objeto CBx ( %d ) nao encontrado", j );
klauss	109:a5b8264ffbbc	1038	}
klauss	109:a5b8264ffbbc	1039	else
klauss	109:a5b8264ffbbc	1040	{
klauss	109:a5b8264ffbbc	1041	send_msg ("Objeto CBx ( %d ) nao encontrado", j );
klauss	109:a5b8264ffbbc	1042	}
klauss	109:a5b8264ffbbc	1043	}
klauss	109:a5b8264ffbbc	1044	}
klauss	109:a5b8264ffbbc	1045	}
klauss	106:a34fcf9f0e02	1046
klauss	109:a5b8264ffbbc	1047	//begin Sip debug print
klauss	109:a5b8264ffbbc	1048	{
klauss	109:a5b8264ffbbc	1049	if ( print_sip_var )
klauss	109:a5b8264ffbbc	1050	{
klauss	109:a5b8264ffbbc	1051	print_sip_var = false;
klauss	109:a5b8264ffbbc	1052	Call_Box * cb = __find_CB__ ( v_cb, print_this_sip );
klauss	109:a5b8264ffbbc	1053	if ( cb != NULL )
klauss	109:a5b8264ffbbc	1054	{
klauss	109:a5b8264ffbbc	1055	if( ( cb -> sip ) != NULL )
klauss	109:a5b8264ffbbc	1056	{
klauss	109:a5b8264ffbbc	1057	cb -> sip -> print_yourself ();
klauss	109:a5b8264ffbbc	1058	}
klauss	109:a5b8264ffbbc	1059	else
klauss	109:a5b8264ffbbc	1060	{
klauss	109:a5b8264ffbbc	1061	if( print_values )
klauss	109:a5b8264ffbbc	1062	{
klauss	109:a5b8264ffbbc	1063	debug_msg("Sip param of %d equals NULL", print_this_sip );
klauss	109:a5b8264ffbbc	1064	}
klauss	109:a5b8264ffbbc	1065	else
klauss	109:a5b8264ffbbc	1066	{
klauss	109:a5b8264ffbbc	1067	send_msg("Sip param of %d equals NULL", print_this_sip );
klauss	109:a5b8264ffbbc	1068	}
klauss	109:a5b8264ffbbc	1069	}
klauss	109:a5b8264ffbbc	1070	}
klauss	109:a5b8264ffbbc	1071	else
klauss	109:a5b8264ffbbc	1072	{
klauss	109:a5b8264ffbbc	1073	if ( print_values )
klauss	109:a5b8264ffbbc	1074	{
klauss	109:a5b8264ffbbc	1075	debug_msg ("Objeto CBx ( %d ) nao encontrado", print_this_cb );
klauss	109:a5b8264ffbbc	1076	}
klauss	109:a5b8264ffbbc	1077	else
klauss	109:a5b8264ffbbc	1078	{
klauss	109:a5b8264ffbbc	1079	send_msg ("Objeto CBx ( %d ) nao encontrado", print_this_cb );
klauss	109:a5b8264ffbbc	1080	} }
klauss	109:a5b8264ffbbc	1081	}
klauss	109:a5b8264ffbbc	1082
klauss	109:a5b8264ffbbc	1083	if ( print_sip_all )
klauss	109:a5b8264ffbbc	1084	{
klauss	109:a5b8264ffbbc	1085	print_sip_all = false;
klauss	109:a5b8264ffbbc	1086
klauss	109:a5b8264ffbbc	1087	if ( v_cb -> size () == 0 )
klauss	109:a5b8264ffbbc	1088	{
klauss	109:a5b8264ffbbc	1089	send_msg("known CBx :: 0");
klauss	109:a5b8264ffbbc	1090	}
klauss	109:a5b8264ffbbc	1091
klauss	109:a5b8264ffbbc	1092	for ( register uint8_t i = 0; i < v_cb->size(); i++ )
klauss	109:a5b8264ffbbc	1093	{
klauss	109:a5b8264ffbbc	1094	Call_Box * cb = (Call_Box *)v_cb->get_element( i );
klauss	109:a5b8264ffbbc	1095
klauss	109:a5b8264ffbbc	1096	if ( cb != NULL )
klauss	109:a5b8264ffbbc	1097	{
klauss	109:a5b8264ffbbc	1098	if( ( cb -> sip ) != NULL )
klauss	109:a5b8264ffbbc	1099	{
klauss	109:a5b8264ffbbc	1100	cb -> sip -> print_yourself ();
klauss	109:a5b8264ffbbc	1101	}
klauss	109:a5b8264ffbbc	1102	else
klauss	109:a5b8264ffbbc	1103	{
klauss	109:a5b8264ffbbc	1104	if( print_values )
klauss	109:a5b8264ffbbc	1105	{
klauss	109:a5b8264ffbbc	1106	debug_msg("Sip param of %d equals NULL", print_this_sip );
klauss	109:a5b8264ffbbc	1107	}
klauss	109:a5b8264ffbbc	1108	else
klauss	109:a5b8264ffbbc	1109	{
klauss	109:a5b8264ffbbc	1110	send_msg("Sip param of %d equals NULL", print_this_sip );
klauss	109:a5b8264ffbbc	1111	}
klauss	109:a5b8264ffbbc	1112	}
klauss	109:a5b8264ffbbc	1113	}
klauss	109:a5b8264ffbbc	1114	else
klauss	109:a5b8264ffbbc	1115	{
klauss	109:a5b8264ffbbc	1116	if( print_values )
klauss	109:a5b8264ffbbc	1117	{
klauss	109:a5b8264ffbbc	1118	debug_msg("CBx %d not found", print_this_sip );
klauss	109:a5b8264ffbbc	1119	}
klauss	109:a5b8264ffbbc	1120	else
klauss	109:a5b8264ffbbc	1121	{
klauss	109:a5b8264ffbbc	1122	send_msg("CBx %d not found", print_this_sip );
klauss	109:a5b8264ffbbc	1123	}
klauss	109:a5b8264ffbbc	1124	}
klauss	109:a5b8264ffbbc	1125	}
klauss	109:a5b8264ffbbc	1126	}
klauss	109:a5b8264ffbbc	1127
klauss	109:a5b8264ffbbc	1128	if ( print_hex_sip_var )
klauss	109:a5b8264ffbbc	1129	{
klauss	109:a5b8264ffbbc	1130	uint8_t * ptr = NULL;
klauss	109:a5b8264ffbbc	1131
klauss	109:a5b8264ffbbc	1132	print_hex_sip_var = false;
klauss	109:a5b8264ffbbc	1133	Call_Box * cb = __find_CB__ ( v_cb, print_hex_this_sip );
klauss	109:a5b8264ffbbc	1134	if( cb != NULL )
klauss	109:a5b8264ffbbc	1135	{
klauss	109:a5b8264ffbbc	1136	if( ( cb -> sip ) != NULL )
klauss	109:a5b8264ffbbc	1137	ptr = ( uint8_t * ) cb -> sip;
klauss	109:a5b8264ffbbc	1138	}
klauss	109:a5b8264ffbbc	1139
klauss	109:a5b8264ffbbc	1140	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	1141	{
klauss	109:a5b8264ffbbc	1142	send_msg ("Values :: %p\r\n", ( void *) ptr );
klauss	109:a5b8264ffbbc	1143	for ( register int i = 0; i < sizeof( Sip ); i++ )
klauss	109:a5b8264ffbbc	1144	{
klauss	109:a5b8264ffbbc	1145	if( debug_uart3 ) pc.printf("%x", *ptr++ );
klauss	109:a5b8264ffbbc	1146
klauss	109:a5b8264ffbbc	1147	if ( ( i % 32 ) == 0 )
klauss	109:a5b8264ffbbc	1148	{
klauss	109:a5b8264ffbbc	1149	if( i != 0 )
klauss	109:a5b8264ffbbc	1150	{
klauss	109:a5b8264ffbbc	1151	if( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1152	}
klauss	109:a5b8264ffbbc	1153	else
klauss	109:a5b8264ffbbc	1154	{
klauss	109:a5b8264ffbbc	1155	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1156	}
klauss	109:a5b8264ffbbc	1157	}
klauss	109:a5b8264ffbbc	1158	else
klauss	109:a5b8264ffbbc	1159	{
klauss	109:a5b8264ffbbc	1160	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1161	}
klauss	109:a5b8264ffbbc	1162	}
klauss	109:a5b8264ffbbc	1163	if ( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1164
klauss	109:a5b8264ffbbc	1165	if ( tcp_session ) {
klauss	109:a5b8264ffbbc	1166	char aux[ ( 32 * 3 ) + 5 ];
klauss	109:a5b8264ffbbc	1167
klauss	109:a5b8264ffbbc	1168	for ( register int i = 0; i < ( 32 * 3 ) + 5 ; i++ ) aux [ i ] = 0;
klauss	109:a5b8264ffbbc	1169
klauss	109:a5b8264ffbbc	1170	ptr = NULL;
klauss	109:a5b8264ffbbc	1171
klauss	109:a5b8264ffbbc	1172	print_hex_sip_var = false;
klauss	109:a5b8264ffbbc	1173	Call_Box * cb = __find_CB__ ( v_cb, print_hex_this_sip );
klauss	109:a5b8264ffbbc	1174	if( cb != NULL )
klauss	109:a5b8264ffbbc	1175	{
klauss	109:a5b8264ffbbc	1176	if( ( cb -> sip ) != NULL )
klauss	109:a5b8264ffbbc	1177	ptr = ( uint8_t * ) cb -> sip;
klauss	109:a5b8264ffbbc	1178	}
klauss	109:a5b8264ffbbc	1179
klauss	109:a5b8264ffbbc	1180	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	1181	{
klauss	109:a5b8264ffbbc	1182	bool finished = false;
klauss	109:a5b8264ffbbc	1183	volatile int i = 0;
klauss	109:a5b8264ffbbc	1184	int count = 0;
klauss	109:a5b8264ffbbc	1185	Timer dont_overwrite_tcp_buffer;
klauss	109:a5b8264ffbbc	1186	dont_overwrite_tcp_buffer.reset ();
klauss	109:a5b8264ffbbc	1187	dont_overwrite_tcp_buffer.start ();
klauss	109:a5b8264ffbbc	1188
klauss	109:a5b8264ffbbc	1189	while ( !finished )
klauss	109:a5b8264ffbbc	1190	{
klauss	109:a5b8264ffbbc	1191	if( dont_overwrite_tcp_buffer.read_ms () >= 500 )
klauss	109:a5b8264ffbbc	1192	{
klauss	109:a5b8264ffbbc	1193	dont_overwrite_tcp_buffer.reset();
klauss	109:a5b8264ffbbc	1194	for ( ; i < sizeof( Sip ); i++ )
klauss	109:a5b8264ffbbc	1195	{
klauss	109:a5b8264ffbbc	1196	char tmp[ 16 ];
klauss	109:a5b8264ffbbc	1197	sprintf( tmp, "%x ", *ptr++ );
klauss	109:a5b8264ffbbc	1198	strcat( aux, tmp );
klauss	109:a5b8264ffbbc	1199	count++;
klauss	109:a5b8264ffbbc	1200
klauss	109:a5b8264ffbbc	1201	if ( count >= 32 )
klauss	109:a5b8264ffbbc	1202	{
klauss	109:a5b8264ffbbc	1203	count = 0;
klauss	109:a5b8264ffbbc	1204	i++;
klauss	109:a5b8264ffbbc	1205	break;
klauss	109:a5b8264ffbbc	1206	}
klauss	109:a5b8264ffbbc	1207	}
klauss	109:a5b8264ffbbc	1208	strcat ( aux, "\n\r\0" );
klauss	109:a5b8264ffbbc	1209	tcp_client.send_all ( ( char )aux, strlen( (char )aux ) );
klauss	109:a5b8264ffbbc	1210	if ( i >= sizeof ( Sip ) ) finished = true;
klauss	109:a5b8264ffbbc	1211	strcpy ( aux, "\0" );
klauss	109:a5b8264ffbbc	1212	}
klauss	109:a5b8264ffbbc	1213	}
klauss	109:a5b8264ffbbc	1214	dont_overwrite_tcp_buffer.reset();
klauss	109:a5b8264ffbbc	1215	dont_overwrite_tcp_buffer.stop();
klauss	109:a5b8264ffbbc	1216	tcp_client.send_all ( "\r\n> ", strlen( "\r\n> " ) );
klauss	109:a5b8264ffbbc	1217	}
klauss	109:a5b8264ffbbc	1218	}
klauss	109:a5b8264ffbbc	1219	}
klauss	109:a5b8264ffbbc	1220	else
klauss	109:a5b8264ffbbc	1221	{
klauss	109:a5b8264ffbbc	1222	if ( print_values ) debug_msg ("Objeto CBx ( %d ) nao encontrado", print_this_cb );
klauss	109:a5b8264ffbbc	1223	}
klauss	109:a5b8264ffbbc	1224	}
klauss	109:a5b8264ffbbc	1225	/*
klauss	109:a5b8264ffbbc	1226	if ( print_hex_cb_all )
klauss	109:a5b8264ffbbc	1227	{
klauss	109:a5b8264ffbbc	1228	print_hex_cb_all = false;
klauss	109:a5b8264ffbbc	1229
klauss	109:a5b8264ffbbc	1230	if ( v_cb -> size () == 0 )
klauss	109:a5b8264ffbbc	1231	{
klauss	109:a5b8264ffbbc	1232	send_msg("known CBx :: 0");
klauss	109:a5b8264ffbbc	1233	}
klauss	109:a5b8264ffbbc	1234
klauss	109:a5b8264ffbbc	1235	for ( register uint8_t j = 0; j < v_cb->size(); j++ )
klauss	109:a5b8264ffbbc	1236	{
klauss	109:a5b8264ffbbc	1237	uint8_t * ptr = ( uint8_t * ) v_cb->get_element( j );
klauss	109:a5b8264ffbbc	1238
klauss	109:a5b8264ffbbc	1239	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	1240	{
klauss	109:a5b8264ffbbc	1241	send_msg ("Values :: %p\r\n", ( void *) ptr );
klauss	109:a5b8264ffbbc	1242	for ( register int i = 0; i < sizeof( Call_Box ); i++ )
klauss	109:a5b8264ffbbc	1243	{
klauss	109:a5b8264ffbbc	1244	if( debug_uart3 ) pc.printf("%x", *ptr++ );
klauss	109:a5b8264ffbbc	1245
klauss	109:a5b8264ffbbc	1246	if ( ( i % 32 ) == 0 )
klauss	109:a5b8264ffbbc	1247	{
klauss	109:a5b8264ffbbc	1248	if( i != 0 )
klauss	109:a5b8264ffbbc	1249	{
klauss	109:a5b8264ffbbc	1250	if( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1251	}
klauss	109:a5b8264ffbbc	1252	else
klauss	109:a5b8264ffbbc	1253	{
klauss	109:a5b8264ffbbc	1254	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1255	}
klauss	109:a5b8264ffbbc	1256	}
klauss	109:a5b8264ffbbc	1257	else
klauss	109:a5b8264ffbbc	1258	{
klauss	109:a5b8264ffbbc	1259	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1260	}
klauss	109:a5b8264ffbbc	1261	}
klauss	109:a5b8264ffbbc	1262	if ( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1263
klauss	109:a5b8264ffbbc	1264	if ( tcp_session ) {
klauss	109:a5b8264ffbbc	1265	char aux[ ( sizeof( Call_Box ) * 3 ) + 3 ];
klauss	109:a5b8264ffbbc	1266
klauss	109:a5b8264ffbbc	1267	for ( register int i = 0; i < ( sizeof( Call_Box ) * 3 ) + 3 ; i++ ) aux [ i ] = 0;
klauss	109:a5b8264ffbbc	1268
klauss	109:a5b8264ffbbc	1269	uint8_t * ptr = ( uint8_t * ) v_cb->get_element( j );
klauss	109:a5b8264ffbbc	1270
klauss	109:a5b8264ffbbc	1271	for ( register int i = 0; i < sizeof( Call_Box ); i++ )
klauss	109:a5b8264ffbbc	1272	{
klauss	109:a5b8264ffbbc	1273	char tmp[ 16 ];
klauss	109:a5b8264ffbbc	1274	sprintf( tmp, "%x ", *ptr++ );
klauss	109:a5b8264ffbbc	1275	strcat( aux, tmp );
klauss	109:a5b8264ffbbc	1276	}
klauss	109:a5b8264ffbbc	1277
klauss	109:a5b8264ffbbc	1278	strcat( aux, "\n\r\0" );
klauss	109:a5b8264ffbbc	1279	tcp_client.send_all( ( char )aux, strlen( (char )aux ) );
klauss	109:a5b8264ffbbc	1280	tcp_client.send_all( "\r\n> ", strlen( "\r\n> " ) );
klauss	109:a5b8264ffbbc	1281	}
klauss	109:a5b8264ffbbc	1282	}
klauss	109:a5b8264ffbbc	1283	else
klauss	109:a5b8264ffbbc	1284	{
klauss	109:a5b8264ffbbc	1285	if ( print_values ) debug_msg ("Objeto CBx ( %d ) nao encontrado", j );
klauss	109:a5b8264ffbbc	1286	}
klauss	109:a5b8264ffbbc	1287	}
klauss	109:a5b8264ffbbc	1288	}
klauss	109:a5b8264ffbbc	1289	*/
klauss	109:a5b8264ffbbc	1290	}//end Sip debug print
klauss	109:a5b8264ffbbc	1291
klauss	109:a5b8264ffbbc	1292	if( dcallshow_rtp == true ){
klauss	109:a5b8264ffbbc	1293	dcallshow_rtp = false;
klauss	109:a5b8264ffbbc	1294	send_msg(":: CAll RTP :: %u", v_call->size() );
klauss	109:a5b8264ffbbc	1295	for( register uint8_t i = 0; i < v_call->size(); i++ ) {
klauss	109:a5b8264ffbbc	1296	VZ_call * call = ( VZ_call * )v_call->get_element( i );
klauss	109:a5b8264ffbbc	1297	if( call != NULL )
klauss	109:a5b8264ffbbc	1298	{
klauss	109:a5b8264ffbbc	1299	send_msg("CBX ( %d, %d ) - Server ( %d, %d )",
klauss	109:a5b8264ffbbc	1300	call->get_cb_ext(),
klauss	109:a5b8264ffbbc	1301	call->get_cb_port(),
klauss	109:a5b8264ffbbc	1302	call->get_rtp_server_ext(),
klauss	109:a5b8264ffbbc	1303	call->get_rtp_server_port()
klauss	109:a5b8264ffbbc	1304	);
klauss	109:a5b8264ffbbc	1305	}
klauss	109:a5b8264ffbbc	1306	}
klauss	109:a5b8264ffbbc	1307	}
klauss	109:a5b8264ffbbc	1308
klauss	109:a5b8264ffbbc	1309	if ( print_call_var )
klauss	109:a5b8264ffbbc	1310	{
klauss	109:a5b8264ffbbc	1311	print_call_var = false;
klauss	109:a5b8264ffbbc	1312	VZ_call * call = __find_Call__( v_call, print_this_call );
klauss	109:a5b8264ffbbc	1313	if ( call != NULL )
klauss	109:a5b8264ffbbc	1314	{
klauss	109:a5b8264ffbbc	1315	send_msg ("Values :: %p\r\n", ( void *) call );
klauss	109:a5b8264ffbbc	1316	call -> print_yourself ();
klauss	109:a5b8264ffbbc	1317	}
klauss	109:a5b8264ffbbc	1318	else
klauss	109:a5b8264ffbbc	1319	{
klauss	109:a5b8264ffbbc	1320	if( print_values )
klauss	109:a5b8264ffbbc	1321	{
klauss	109:a5b8264ffbbc	1322	debug_msg("Call %d not found", print_this_call );
klauss	109:a5b8264ffbbc	1323	}
klauss	109:a5b8264ffbbc	1324	else
klauss	109:a5b8264ffbbc	1325	{
klauss	109:a5b8264ffbbc	1326	send_msg("Call %d not found", print_this_call );
klauss	109:a5b8264ffbbc	1327	}
klauss	109:a5b8264ffbbc	1328	}
klauss	109:a5b8264ffbbc	1329	}
klauss	109:a5b8264ffbbc	1330
klauss	109:a5b8264ffbbc	1331	if ( print_hex_call_var )
klauss	109:a5b8264ffbbc	1332	{
klauss	109:a5b8264ffbbc	1333	print_hex_call_var = false;
klauss	109:a5b8264ffbbc	1334	VZ_call * call = __find_Call__( v_call, print_hex_this_call );
klauss	109:a5b8264ffbbc	1335
klauss	109:a5b8264ffbbc	1336	uint8_t * ptr = NULL;
klauss	109:a5b8264ffbbc	1337	if( call != NULL )
klauss	109:a5b8264ffbbc	1338	{
klauss	109:a5b8264ffbbc	1339	ptr = ( uint8_t * ) call;
klauss	109:a5b8264ffbbc	1340	}
klauss	109:a5b8264ffbbc	1341
klauss	109:a5b8264ffbbc	1342	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	1343	{
klauss	109:a5b8264ffbbc	1344	send_msg ("Values :: %p\r\n", ( void *) ptr );
klauss	109:a5b8264ffbbc	1345	for ( register int i = 0; i < sizeof( VZ_call ); i++ )
klauss	109:a5b8264ffbbc	1346	{
klauss	109:a5b8264ffbbc	1347	if( debug_uart3 ) pc.printf("%x", *ptr++ );
klauss	109:a5b8264ffbbc	1348
klauss	109:a5b8264ffbbc	1349	if ( ( i % 32 ) == 0 )
klauss	109:a5b8264ffbbc	1350	{
klauss	109:a5b8264ffbbc	1351	if( i != 0 )
klauss	109:a5b8264ffbbc	1352	{
klauss	109:a5b8264ffbbc	1353	if( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1354	}
klauss	109:a5b8264ffbbc	1355	else
klauss	109:a5b8264ffbbc	1356	{
klauss	109:a5b8264ffbbc	1357	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1358	}
klauss	109:a5b8264ffbbc	1359	}
klauss	109:a5b8264ffbbc	1360	else
klauss	109:a5b8264ffbbc	1361	{
klauss	109:a5b8264ffbbc	1362	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1363	}
klauss	109:a5b8264ffbbc	1364	}
klauss	109:a5b8264ffbbc	1365	if ( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1366
klauss	109:a5b8264ffbbc	1367	if ( tcp_session ) {
klauss	109:a5b8264ffbbc	1368	char aux[ ( 32 * 3 ) + 5 ];
klauss	109:a5b8264ffbbc	1369
klauss	109:a5b8264ffbbc	1370	for ( register int i = 0; i < ( 32 * 3 ) + 5 ; i++ ) aux [ i ] = 0;
klauss	109:a5b8264ffbbc	1371
klauss	109:a5b8264ffbbc	1372	ptr = NULL;
klauss	109:a5b8264ffbbc	1373
klauss	109:a5b8264ffbbc	1374	VZ_call * call = __find_Call__( v_call, print_hex_this_call );
klauss	109:a5b8264ffbbc	1375
klauss	109:a5b8264ffbbc	1376	uint8_t * ptr = NULL;
klauss	109:a5b8264ffbbc	1377	if( call != NULL )
klauss	109:a5b8264ffbbc	1378	{
klauss	109:a5b8264ffbbc	1379	ptr = ( uint8_t * ) call;
klauss	109:a5b8264ffbbc	1380	}
klauss	109:a5b8264ffbbc	1381
klauss	109:a5b8264ffbbc	1382	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	1383	{
klauss	109:a5b8264ffbbc	1384	bool finished = false;
klauss	109:a5b8264ffbbc	1385	volatile int i = 0;
klauss	109:a5b8264ffbbc	1386	int count = 0;
klauss	109:a5b8264ffbbc	1387	Timer dont_overwrite_tcp_buffer;
klauss	109:a5b8264ffbbc	1388	dont_overwrite_tcp_buffer.reset ();
klauss	109:a5b8264ffbbc	1389	dont_overwrite_tcp_buffer.start ();
klauss	109:a5b8264ffbbc	1390
klauss	109:a5b8264ffbbc	1391	while ( !finished )
klauss	109:a5b8264ffbbc	1392	{
klauss	109:a5b8264ffbbc	1393	if( dont_overwrite_tcp_buffer.read_ms () >= 20 )
klauss	109:a5b8264ffbbc	1394	{
klauss	109:a5b8264ffbbc	1395	dont_overwrite_tcp_buffer.reset();
klauss	109:a5b8264ffbbc	1396	for ( ; i < sizeof( VZ_call ); i++ )
klauss	109:a5b8264ffbbc	1397	{
klauss	109:a5b8264ffbbc	1398	char tmp[ 16 ];
klauss	109:a5b8264ffbbc	1399	sprintf( tmp, "%x ", *ptr++ );
klauss	109:a5b8264ffbbc	1400	strcat( aux, tmp );
klauss	109:a5b8264ffbbc	1401	count++;
klauss	109:a5b8264ffbbc	1402
klauss	109:a5b8264ffbbc	1403	if ( count >= 32 )
klauss	109:a5b8264ffbbc	1404	{
klauss	109:a5b8264ffbbc	1405	count = 0;
klauss	109:a5b8264ffbbc	1406	i++;
klauss	109:a5b8264ffbbc	1407	break;
klauss	109:a5b8264ffbbc	1408	}
klauss	109:a5b8264ffbbc	1409	}
klauss	109:a5b8264ffbbc	1410	strcat ( aux, "\n\r\0" );
klauss	109:a5b8264ffbbc	1411	tcp_client.send_all ( ( char )aux, strlen( (char )aux ) );
klauss	109:a5b8264ffbbc	1412	if ( i >= sizeof ( VZ_call ) ) finished = true;
klauss	109:a5b8264ffbbc	1413	strcpy ( aux, "\0" );
klauss	109:a5b8264ffbbc	1414	}
klauss	109:a5b8264ffbbc	1415	}
klauss	109:a5b8264ffbbc	1416	dont_overwrite_tcp_buffer.reset();
klauss	109:a5b8264ffbbc	1417	dont_overwrite_tcp_buffer.stop();
klauss	109:a5b8264ffbbc	1418	tcp_client.send_all ( "\r\n> ", strlen( "\r\n> " ) );
klauss	109:a5b8264ffbbc	1419	}
klauss	109:a5b8264ffbbc	1420	}
klauss	109:a5b8264ffbbc	1421	}
klauss	109:a5b8264ffbbc	1422	else
klauss	109:a5b8264ffbbc	1423	{
klauss	109:a5b8264ffbbc	1424	if( print_values )
klauss	109:a5b8264ffbbc	1425	{
klauss	109:a5b8264ffbbc	1426	debug_msg("Call %d not found", print_this_call );
klauss	109:a5b8264ffbbc	1427	}
klauss	109:a5b8264ffbbc	1428	else
klauss	109:a5b8264ffbbc	1429	{
klauss	109:a5b8264ffbbc	1430	send_msg("Call %d not found", print_this_call );
klauss	109:a5b8264ffbbc	1431	}
klauss	109:a5b8264ffbbc	1432	}
klauss	109:a5b8264ffbbc	1433	}
klauss	109:a5b8264ffbbc	1434
klauss	109:a5b8264ffbbc	1435
klauss	109:a5b8264ffbbc	1436	if ( print_hex_rtp_var )
klauss	109:a5b8264ffbbc	1437	{
klauss	109:a5b8264ffbbc	1438	print_hex_rtp_var = false;
klauss	109:a5b8264ffbbc	1439	VZ_call * call = __find_Call__( v_call, print_hex_this_rtp );
klauss	109:a5b8264ffbbc	1440
klauss	109:a5b8264ffbbc	1441	uint8_t * ptr = NULL;
klauss	109:a5b8264ffbbc	1442	if( call != NULL )
klauss	109:a5b8264ffbbc	1443	{
klauss	109:a5b8264ffbbc	1444	ptr = ( uint8_t * ) call -> check_rtp ();
klauss	109:a5b8264ffbbc	1445	}
klauss	109:a5b8264ffbbc	1446
klauss	109:a5b8264ffbbc	1447	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	1448	{
klauss	109:a5b8264ffbbc	1449	send_msg ("Values :: %p\r\n", ( void *) ptr );
klauss	109:a5b8264ffbbc	1450	for ( register int i = 0; i < sizeof( RTP ); i++ )
klauss	109:a5b8264ffbbc	1451	{
klauss	109:a5b8264ffbbc	1452	if( debug_uart3 ) pc.printf("%x", *ptr++ );
klauss	109:a5b8264ffbbc	1453
klauss	109:a5b8264ffbbc	1454	if ( ( i % 32 ) == 0 )
klauss	109:a5b8264ffbbc	1455	{
klauss	109:a5b8264ffbbc	1456	if( i != 0 )
klauss	109:a5b8264ffbbc	1457	{
klauss	109:a5b8264ffbbc	1458	if( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1459	}
klauss	109:a5b8264ffbbc	1460	else
klauss	109:a5b8264ffbbc	1461	{
klauss	109:a5b8264ffbbc	1462	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1463	}
klauss	109:a5b8264ffbbc	1464	}
klauss	109:a5b8264ffbbc	1465	else
klauss	109:a5b8264ffbbc	1466	{
klauss	109:a5b8264ffbbc	1467	if( debug_uart3 ) pc.printf(" ");
klauss	109:a5b8264ffbbc	1468	}
klauss	109:a5b8264ffbbc	1469	}
klauss	109:a5b8264ffbbc	1470	if ( debug_uart3 ) pc.printf("\n\r> ");
klauss	109:a5b8264ffbbc	1471
klauss	109:a5b8264ffbbc	1472	if ( tcp_session ) {
klauss	109:a5b8264ffbbc	1473	char aux[ ( 32 * 3 ) + 5 ];
klauss	109:a5b8264ffbbc	1474
klauss	109:a5b8264ffbbc	1475	for ( register int i = 0; i < ( 32 * 3 ) + 5 ; i++ ) aux [ i ] = 0;
klauss	109:a5b8264ffbbc	1476
klauss	109:a5b8264ffbbc	1477	ptr = NULL;
klauss	109:a5b8264ffbbc	1478
klauss	109:a5b8264ffbbc	1479	VZ_call * call = __find_Call__( v_call, print_hex_this_rtp );
klauss	109:a5b8264ffbbc	1480
klauss	109:a5b8264ffbbc	1481	uint8_t * ptr = NULL;
klauss	109:a5b8264ffbbc	1482	if( call != NULL )
klauss	109:a5b8264ffbbc	1483	{
klauss	109:a5b8264ffbbc	1484	ptr = ( uint8_t * ) call -> check_rtp ();
klauss	109:a5b8264ffbbc	1485	}
klauss	109:a5b8264ffbbc	1486
klauss	109:a5b8264ffbbc	1487	if ( ptr != NULL )
klauss	109:a5b8264ffbbc	1488	{
klauss	109:a5b8264ffbbc	1489	bool finished = false;
klauss	109:a5b8264ffbbc	1490	volatile int i = 0;
klauss	109:a5b8264ffbbc	1491	int count = 0;
klauss	109:a5b8264ffbbc	1492	Timer dont_overwrite_tcp_buffer;
klauss	109:a5b8264ffbbc	1493	dont_overwrite_tcp_buffer.reset ();
klauss	109:a5b8264ffbbc	1494	dont_overwrite_tcp_buffer.start ();
klauss	109:a5b8264ffbbc	1495
klauss	109:a5b8264ffbbc	1496	while ( !finished )
klauss	109:a5b8264ffbbc	1497	{
klauss	109:a5b8264ffbbc	1498	if( dont_overwrite_tcp_buffer.read_ms () >= 20 )
klauss	109:a5b8264ffbbc	1499	{
klauss	109:a5b8264ffbbc	1500	dont_overwrite_tcp_buffer.reset();
klauss	109:a5b8264ffbbc	1501	for ( ; i < sizeof( RTP ); i++ )
klauss	109:a5b8264ffbbc	1502	{
klauss	109:a5b8264ffbbc	1503	char tmp[ 16 ];
klauss	109:a5b8264ffbbc	1504	sprintf( tmp, "%x ", *ptr++ );
klauss	109:a5b8264ffbbc	1505	strcat( aux, tmp );
klauss	109:a5b8264ffbbc	1506	count++;
klauss	109:a5b8264ffbbc	1507
klauss	109:a5b8264ffbbc	1508	if ( count >= 32 )
klauss	109:a5b8264ffbbc	1509	{
klauss	109:a5b8264ffbbc	1510	count = 0;
klauss	109:a5b8264ffbbc	1511	i++;
klauss	109:a5b8264ffbbc	1512	break;
klauss	109:a5b8264ffbbc	1513	}
klauss	109:a5b8264ffbbc	1514	}
klauss	109:a5b8264ffbbc	1515	strcat ( aux, "\n\r\0" );
klauss	109:a5b8264ffbbc	1516	tcp_client.send_all ( ( char )aux, strlen( (char )aux ) );
klauss	109:a5b8264ffbbc	1517	if ( i >= sizeof ( RTP ) ) finished = true;
klauss	109:a5b8264ffbbc	1518	strcpy ( aux, "\0" );
klauss	109:a5b8264ffbbc	1519	}
klauss	109:a5b8264ffbbc	1520	}
klauss	109:a5b8264ffbbc	1521	dont_overwrite_tcp_buffer.reset();
klauss	109:a5b8264ffbbc	1522	dont_overwrite_tcp_buffer.stop();
klauss	109:a5b8264ffbbc	1523	tcp_client.send_all ( "\r\n> ", strlen( "\r\n> " ) );
klauss	109:a5b8264ffbbc	1524	}
klauss	109:a5b8264ffbbc	1525	}
klauss	109:a5b8264ffbbc	1526	}
klauss	109:a5b8264ffbbc	1527	else
klauss	109:a5b8264ffbbc	1528	{
klauss	109:a5b8264ffbbc	1529	if( print_values )
klauss	109:a5b8264ffbbc	1530	{
klauss	109:a5b8264ffbbc	1531	debug_msg("Call %d not found", print_this_rtp );
klauss	109:a5b8264ffbbc	1532	}
klauss	109:a5b8264ffbbc	1533	else
klauss	109:a5b8264ffbbc	1534	{
klauss	109:a5b8264ffbbc	1535	send_msg("Call %d not found", print_this_rtp );
klauss	109:a5b8264ffbbc	1536	}
klauss	109:a5b8264ffbbc	1537	}
klauss	109:a5b8264ffbbc	1538	}
klauss	109:a5b8264ffbbc	1539
klauss	109:a5b8264ffbbc	1540	if ( print_rtp_var )
klauss	109:a5b8264ffbbc	1541	{
klauss	109:a5b8264ffbbc	1542	print_rtp_var = false;
klauss	109:a5b8264ffbbc	1543	VZ_call * call = __find_Call__( v_call, print_this_rtp );
klauss	109:a5b8264ffbbc	1544	if ( call != NULL )
klauss	109:a5b8264ffbbc	1545	{
klauss	109:a5b8264ffbbc	1546	if ( call -> check_rtp () != NULL )
klauss	109:a5b8264ffbbc	1547	{
klauss	109:a5b8264ffbbc	1548	send_msg ("Values :: %p\r\n", ( void *) call -> check_rtp () );
klauss	109:a5b8264ffbbc	1549	call -> rtp_print_yourself ();
klauss	109:a5b8264ffbbc	1550	}
klauss	109:a5b8264ffbbc	1551	else
klauss	109:a5b8264ffbbc	1552	{
klauss	109:a5b8264ffbbc	1553	if( print_values )
klauss	109:a5b8264ffbbc	1554	{
klauss	109:a5b8264ffbbc	1555	debug_msg("Call->RTP %d not found", print_this_rtp );
klauss	109:a5b8264ffbbc	1556	}
klauss	109:a5b8264ffbbc	1557	else
klauss	109:a5b8264ffbbc	1558	{
klauss	109:a5b8264ffbbc	1559	send_msg("Call->RTP %d not found", print_this_rtp );
klauss	109:a5b8264ffbbc	1560	}
klauss	109:a5b8264ffbbc	1561	}
klauss	109:a5b8264ffbbc	1562	}
klauss	109:a5b8264ffbbc	1563	else
klauss	109:a5b8264ffbbc	1564	{
klauss	109:a5b8264ffbbc	1565	if( print_values )
klauss	109:a5b8264ffbbc	1566	{
klauss	109:a5b8264ffbbc	1567	debug_msg("Call->RTP %d not found", print_this_rtp );
klauss	109:a5b8264ffbbc	1568	}
klauss	109:a5b8264ffbbc	1569	else
klauss	109:a5b8264ffbbc	1570	{
klauss	109:a5b8264ffbbc	1571	send_msg("Call->RTP %d not found", print_this_rtp );
klauss	109:a5b8264ffbbc	1572	}
klauss	109:a5b8264ffbbc	1573	}
klauss	109:a5b8264ffbbc	1574	}
klauss	109:a5b8264ffbbc	1575
klauss	109:a5b8264ffbbc	1576	//end debug_print
klauss	91:c2a86b1f8aaa	1577
klauss	91:c2a86b1f8aaa	1578	if( reset_cks == true ) {
klauss	81:3656f00ab3db	1579	pkg_cksok = 0;
klauss	81:3656f00ab3db	1580	pkg_ckserr = 0;
klauss	99:e80850c51106	1581	pkg_zero = 0;
klauss	81:3656f00ab3db	1582	reset_cks = false;
klauss	99:e80850c51106	1583	out_of_range = 0;
klauss	99:e80850c51106	1584	missed_pkg = 0;
klauss	100:09a23fcd3bdf	1585	delayed_pkg_to_cb = 0;
klauss	99:e80850c51106	1586	cpld_pkg_tx_counter = 0;
klauss	99:e80850c51106	1587	cpld_pkg_rx_counter = 0;
klauss	81:3656f00ab3db	1588	pcks_s = true;
klauss	81:3656f00ab3db	1589	}
klauss	91:c2a86b1f8aaa	1590
klauss	91:c2a86b1f8aaa	1591	if( pcks_s == true ) {
klauss	109:a5b8264ffbbc	1592	send_msg("PKG_CKS OK: %d :: PKG_CKS ERR: %d :: PKG_0: %d :: Out_of_range: %d :: Miss_Pkg :: %d"
klauss	109:a5b8264ffbbc	1593	"\n\r> TX_delayed :: %d :: TX_Counter :: %d :: RX_Counter :: %d", pkg_cksok, pkg_ckserr, pkg_zero, out_of_range, missed_pkg, delayed_pkg_to_cb, cpld_pkg_tx_counter, cpld_pkg_rx_counter );
klauss	81:3656f00ab3db	1594	pcks_s = false;
klauss	81:3656f00ab3db	1595	}
klauss	109:a5b8264ffbbc	1596
klauss	100:09a23fcd3bdf	1597	if( flood_bug_pkg ){
klauss	100:09a23fcd3bdf	1598	static int id = 0x10;
klauss	100:09a23fcd3bdf	1599	if( id < 10 ) id = 0x0b;
klauss	109:a5b8264ffbbc	1600	send2callboxes( __build_cb_package__( 5828, 5123, __REGISTRY__,
klauss	109:a5b8264ffbbc	1601	( char * )buffer, id++, __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	100:09a23fcd3bdf	1602	}
klauss	100:09a23fcd3bdf	1603
klauss	109:a5b8264ffbbc	1604	if( led_sync_timer.read() > 1 ) {
klauss	78:1353744f01e1	1605	led_sync_timer.reset();
klauss	78:1353744f01e1	1606	led3 = !led3;
klauss	78:1353744f01e1	1607	CAB_LED = !CAB_LED;
klauss	78:1353744f01e1	1608	}
klauss	109:a5b8264ffbbc	1609
klauss	109:a5b8264ffbbc	1610	static int test_ext = 5102;
klauss	109:a5b8264ffbbc	1611	static int test_port = 5102;
klauss	109:a5b8264ffbbc	1612
klauss	109:a5b8264ffbbc	1613	if ( tango )
klauss	109:a5b8264ffbbc	1614	{
klauss	109:a5b8264ffbbc	1615	if ( v_cb -> size () >= 27 )
klauss	108:18a3702650f3	1616	{
klauss	109:a5b8264ffbbc	1617	tango = false;
klauss	109:a5b8264ffbbc	1618	test_timer.start ();
klauss	109:a5b8264ffbbc	1619	}
klauss	109:a5b8264ffbbc	1620
klauss	109:a5b8264ffbbc	1621	ext = test_ext++;
klauss	109:a5b8264ffbbc	1622	port = test_port++;
klauss	109:a5b8264ffbbc	1623	type = __REGISTRY__;
klauss	109:a5b8264ffbbc	1624	data = buffer;
klauss	105:a930035b6556	1625	}
klauss	109:a5b8264ffbbc	1626
klauss	109:a5b8264ffbbc	1627	if( v_cb -> size () >= 27 )
klauss	109:a5b8264ffbbc	1628	{
klauss	109:a5b8264ffbbc	1629	if( ( test_timer.read_ms () > 500 ) && ( type == __DO_NOTHING__ ) )
klauss	109:a5b8264ffbbc	1630	{
klauss	109:a5b8264ffbbc	1631	if( test_ext >= ( 5102 + 26 ) ) test_ext = 5102;
klauss	109:a5b8264ffbbc	1632	if( test_port >= ( 5102 + 26 ) ) test_port = 5102;
klauss	109:a5b8264ffbbc	1633
klauss	109:a5b8264ffbbc	1634	ext = test_ext++;
klauss	109:a5b8264ffbbc	1635	port = test_port++;
klauss	109:a5b8264ffbbc	1636	type = __REGISTRY__;
klauss	109:a5b8264ffbbc	1637	data = buffer;
klauss	109:a5b8264ffbbc	1638	test_timer.reset ();
klauss	109:a5b8264ffbbc	1639	}
klauss	109:a5b8264ffbbc	1640	}
klauss	109:a5b8264ffbbc	1641
klauss	91:c2a86b1f8aaa	1642	switch( type ) {
klauss	91:c2a86b1f8aaa	1643	case __DO_NOTHING__ :
klauss	91:c2a86b1f8aaa	1644	{}
klauss	91:c2a86b1f8aaa	1645	break;
klauss	91:c2a86b1f8aaa	1646
klauss	0:4d17cd9c8f9d	1647	case __CB_BYE__ : {
klauss	63:0d95da692bb4	1648	cb_bye_counter++;
klauss	0:4d17cd9c8f9d	1649	Call_Box * cb = __find_CB__( v_cb, ext );
klauss	91:c2a86b1f8aaa	1650	if( cb != NULL ) {
klauss	81:3656f00ab3db	1651	if( debug_invite \|\| debug_main ) debug_msg("Received bye pkg with msg_id %d e pkg_id %d", cb->get_msg_id(), data[ 0 ] );
klauss	0:4d17cd9c8f9d	1652	data[ 0 ] \|= BIT7;
klauss	0:4d17cd9c8f9d	1653	cb->set_msg_id( data[ 0 ] );
klauss	81:3656f00ab3db	1654	if( debug_main \|\| debug_invite ) debug_msg( "Request bye from CBx " );
klauss	92:92df17f538a8	1655
klauss	81:3656f00ab3db	1656	bool already_removed = true;
klauss	91:c2a86b1f8aaa	1657	for( register uint8_t i = 0; i < v_call->size(); i++ ) {
klauss	0:4d17cd9c8f9d	1658	VZ_call * call = (VZ_call *)v_call->get_element( i );
klauss	91:c2a86b1f8aaa	1659	if( call->get_cb_ext() == ext ) {
klauss	81:3656f00ab3db	1660	already_removed = false;
klauss	4:de46f0d9b14d	1661	cb->send_bye();
klauss	91:c2a86b1f8aaa	1662
klauss	0:4d17cd9c8f9d	1663	ts->return_timeslice( cb->get_timeslice() );
klauss	0:4d17cd9c8f9d	1664	cb->set_timeslice( 0x00 );
klauss	78:1353744f01e1	1665	data[ __TIMESLICE_PLACE__ ] = 0x00;
klauss	91:c2a86b1f8aaa	1666
klauss	0:4d17cd9c8f9d	1667	set_status( cb->status, cb_idle );
klauss	78:1353744f01e1	1668	set_status( cb->sip->status, sip_idle );
klauss	91:c2a86b1f8aaa	1669
klauss	81:3656f00ab3db	1670	v_call->remove_element( i );
klauss	109:a5b8264ffbbc	1671
klauss	109:a5b8264ffbbc	1672	//cb->set_msg_id( ( cb->get_msg_id() & ~BIT7 ) + 1 );
klauss	109:a5b8264ffbbc	1673	//cb->set_msg_id( ( cb->get_msg_id() + 1 ) & ~BIT7 );
klauss	91:c2a86b1f8aaa	1674
klauss	109:a5b8264ffbbc	1675	send2callboxes( __build_cb_package__( ext, port, __CB_BYE__,
klauss	109:a5b8264ffbbc	1676	( char * )data, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	92:92df17f538a8	1677
klauss	92:92df17f538a8	1678	// envia o ack bye depois atualiza o msg_id
klauss	92:92df17f538a8	1679	cb->set_msg_id( ( cb->get_msg_id() + 1 ) & ~BIT7 );
klauss	91:c2a86b1f8aaa	1680
klauss	3:cd9148672e25	1681	delete( call );
klauss	109:a5b8264ffbbc	1682	//cb->re_start_timer();
klauss	0:4d17cd9c8f9d	1683	}
klauss	0:4d17cd9c8f9d	1684	}
klauss	82:f55d13babca0	1685	if( already_removed ) if( debug_main \|\| debug_invite ) debug_msg( "Already removed from vector call" );
klauss	109:a5b8264ffbbc	1686
klauss	109:a5b8264ffbbc	1687	//ok, mas nem sempre o cbx "entrou em call
klauss	82:f55d13babca0	1688	for( register uint8_t i = 0; i < v_cb->size(); i++ ) {
klauss	82:f55d13babca0	1689	Call_Box * cb = (Call_Box *)v_cb->get_element( i );
klauss	82:f55d13babca0	1690	if( cb->get_ext() == ext ) {
klauss	82:f55d13babca0	1691	already_removed = true;
klauss	82:f55d13babca0	1692	if( cb->get_status() != cb_idle ) {
klauss	82:f55d13babca0	1693	already_removed = false;
klauss	82:f55d13babca0	1694	cb->send_bye();
klauss	82:f55d13babca0	1695
klauss	82:f55d13babca0	1696	ts->return_timeslice( cb->get_timeslice() );
klauss	82:f55d13babca0	1697	cb->set_timeslice( 0x00 );
klauss	82:f55d13babca0	1698	data[ __TIMESLICE_PLACE__ ] = 0x00;
klauss	82:f55d13babca0	1699
klauss	82:f55d13babca0	1700	set_status( cb->status, cb_idle );
klauss	82:f55d13babca0	1701	set_status( cb->sip->status, sip_idle );
klauss	82:f55d13babca0	1702
klauss	109:a5b8264ffbbc	1703	send2callboxes( __build_cb_package__( ext, port, __CB_BYE__,
klauss	109:a5b8264ffbbc	1704	( char * )data, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	82:f55d13babca0	1705
klauss	109:a5b8264ffbbc	1706	//cb->set_msg_id( ( cb->get_msg_id() & ~BIT7 ) + 1 );
klauss	92:92df17f538a8	1707	cb->set_msg_id( ( cb->get_msg_id() + 1 ) & ~BIT7 );
klauss	109:a5b8264ffbbc	1708
klauss	109:a5b8264ffbbc	1709	//cb->re_start_timer();
klauss	82:f55d13babca0	1710	}
klauss	82:f55d13babca0	1711	}
klauss	82:f55d13babca0	1712	}
klauss	91:c2a86b1f8aaa	1713
klauss	82:f55d13babca0	1714	if( already_removed ) if( debug_main \|\| debug_invite ) debug_msg( "Already removed from inviting queue" );
klauss	91:c2a86b1f8aaa	1715
klauss	78:1353744f01e1	1716	cb->registry();
klauss	91:c2a86b1f8aaa	1717	} else if( debug_invite \|\| debug_main ) debug_msg("Bye from who ? %d", ext );
klauss	91:c2a86b1f8aaa	1718	}
klauss	91:c2a86b1f8aaa	1719	break;
klauss	91:c2a86b1f8aaa	1720
klauss	0:4d17cd9c8f9d	1721	case __INVITE__ : {
klauss	109:a5b8264ffbbc	1722	if( drop_invite_pkg ){
klauss	109:a5b8264ffbbc	1723	debug_msg("Dropando invite pck msg id :: %d", data[ 0 ] );
klauss	109:a5b8264ffbbc	1724	break;
klauss	109:a5b8264ffbbc	1725	}
klauss	63:0d95da692bb4	1726	invite_counter++;
klauss	78:1353744f01e1	1727	if( debug_invite ) debug_msg("Request Invite received from Cbx %i", ext);
klauss	0:4d17cd9c8f9d	1728	Call_Box * cb = __find_CB__( v_cb, ext );
klauss	91:c2a86b1f8aaa	1729	if( cb == NULL ) {
klauss	91:c2a86b1f8aaa	1730	if( v_cb->size() < __MAX_CB_IN_A_BRANCH__ ) {
klauss	91:c2a86b1f8aaa	1731	if( debug_main ) debug_msg( "Adding CBx :: %i", ext );
klauss	91:c2a86b1f8aaa	1732	cb = new Call_Box( ext, port );
klauss	91:c2a86b1f8aaa	1733
klauss	91:c2a86b1f8aaa	1734	if( cb == NULL ) {
klauss	91:c2a86b1f8aaa	1735	memory_is_over = true;
klauss	91:c2a86b1f8aaa	1736	if( debug_memory ) debug_msg("Invite allocation cb fail");
klauss	91:c2a86b1f8aaa	1737	} else {
klauss	91:c2a86b1f8aaa	1738	v_cb->add( cb );
klauss	91:c2a86b1f8aaa	1739	}
klauss	89:0fe315117b00	1740	}
klauss	0:4d17cd9c8f9d	1741	}
klauss	91:c2a86b1f8aaa	1742	if( cb != NULL ) {
klauss	91:c2a86b1f8aaa	1743	cb->set_msg_id( data[ 0 ] );
klauss	92:92df17f538a8	1744	if( cb->status == cb_idle ){
klauss	92:92df17f538a8	1745	cb->set_invite_response_ok();
klauss	92:92df17f538a8	1746	cb->invite_retry_count_reset();
klauss	92:92df17f538a8	1747	}
klauss	87:679ee0d594a9	1748	invite_handler( v_call, v_cb, ts, cb );
klauss	87:679ee0d594a9	1749	}
klauss	91:c2a86b1f8aaa	1750	}
klauss	91:c2a86b1f8aaa	1751	break;
klauss	4:de46f0d9b14d	1752	case __REGISTRY__ : {
klauss	63:0d95da692bb4	1753	registry_counter++;
klauss	78:1353744f01e1	1754	Call_Box * cb = __find_CB__( v_cb, ext );
klauss	91:c2a86b1f8aaa	1755	if( v_cb->size() < __MAX_CB_IN_A_BRANCH__ ) {
klauss	91:c2a86b1f8aaa	1756	if( cb == NULL ) {
klauss	91:c2a86b1f8aaa	1757	if( debug_main ) debug_msg("Adding Cbx :: %d", ext );
klauss	91:c2a86b1f8aaa	1758	cb = new Call_Box( ext, port );
klauss	91:c2a86b1f8aaa	1759
klauss	91:c2a86b1f8aaa	1760	if( cb == NULL ) {
klauss	91:c2a86b1f8aaa	1761	memory_is_over = true;
klauss	91:c2a86b1f8aaa	1762	if( debug_memory ) debug_msg("Registry cb allocation fail");
klauss	91:c2a86b1f8aaa	1763	} else {
klauss	91:c2a86b1f8aaa	1764	v_cb->add( cb );
klauss	91:c2a86b1f8aaa	1765	if( debug_main ) debug_msg("Added CBx -- %d", ext );
klauss	91:c2a86b1f8aaa	1766	}
klauss	87:679ee0d594a9	1767	}
klauss	0:4d17cd9c8f9d	1768	}
klauss	78:1353744f01e1	1769	if( debug_main ) debug_msg("Registered %d - %d", ext, port );
klauss	91:c2a86b1f8aaa	1770
klauss	87:679ee0d594a9	1771	if( cb != NULL ) cb->registry();
klauss	109:a5b8264ffbbc	1772
klauss	91:c2a86b1f8aaa	1773	}
klauss	91:c2a86b1f8aaa	1774	break;
klauss	4:de46f0d9b14d	1775	case __BOOT__ : {
klauss	63:0d95da692bb4	1776	boot_counter++;
klauss	99:e80850c51106	1777	if( debug_boot == true ){
klauss	99:e80850c51106	1778	send_msg("Rcv boot pkg from (%d, %d) pkg-id %d", ext, port, data[ 0 ] );
klauss	99:e80850c51106	1779	}
klauss	109:a5b8264ffbbc	1780	send2callboxes( __build_cb_package__( ext, port, __REGISTRY__,
klauss	109:a5b8264ffbbc	1781	( char * )data, data[ 0 ] \| BIT7, __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	109:a5b8264ffbbc	1782	}
klauss	109:a5b8264ffbbc	1783	break;
klauss	109:a5b8264ffbbc	1784
klauss	109:a5b8264ffbbc	1785	case __TELEMETRY__ : {
klauss	109:a5b8264ffbbc	1786	if( debug_telemetry ) send_msg("::Telemetry from %d - %d::", ext, port );
klauss	109:a5b8264ffbbc	1787	build_telemetry_report( ext, port, ( char *)data );
klauss	91:c2a86b1f8aaa	1788	}
klauss	91:c2a86b1f8aaa	1789	break;
klauss	99:e80850c51106	1790
klauss	99:e80850c51106	1791	case __FW__ : {
klauss	99:e80850c51106	1792	if( debug_fw_print ) send_msg("::FW pkg from %d - %d::", ext, port );
klauss	99:e80850c51106	1793	fw_cbx_pkg( ext, port, ( char *)buffer );
klauss	99:e80850c51106	1794	}
klauss	99:e80850c51106	1795	break;
klauss	91:c2a86b1f8aaa	1796
klauss	67:cdedc64d9921	1797	case __BOOTLOADER_CBX__ : {
klauss	67:cdedc64d9921	1798	bootloader_cbx_counter++;
klauss	109:a5b8264ffbbc	1799	//int ret = bl_cbx_reply_to_eth( ext, ( char * )data );
klauss	91:c2a86b1f8aaa	1800	}
klauss	91:c2a86b1f8aaa	1801	break;
klauss	91:c2a86b1f8aaa	1802
klauss	109:a5b8264ffbbc	1803	case __PROMPT__ : {
klauss	78:1353744f01e1	1804	Call_Box * cb = __find_CB__( v_cb, ext );
klauss	91:c2a86b1f8aaa	1805
klauss	91:c2a86b1f8aaa	1806	if( cb == NULL ) {
klauss	109:a5b8264ffbbc	1807	// send2callboxes( __build_cb_package__( ext, port, __REGISTRY__,
klauss	109:a5b8264ffbbc	1808	// ( char * )data, ( ( data[ 0 ] & ~BIT7 ) + 1 ), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	109:a5b8264ffbbc	1809
klauss	109:a5b8264ffbbc	1810	if( debug_main ) debug_msg("Adding Cbx :: %d", ext );
klauss	109:a5b8264ffbbc	1811	cb = new Call_Box( ext, port );
klauss	109:a5b8264ffbbc	1812	if( cb == NULL ){
klauss	109:a5b8264ffbbc	1813	memory_is_over = true;
klauss	109:a5b8264ffbbc	1814	}else{
klauss	109:a5b8264ffbbc	1815	v_cb->add( cb );
klauss	109:a5b8264ffbbc	1816	if( debug_main ) debug_msg("Added CBx -- %d", ext );
klauss	87:679ee0d594a9	1817	}
klauss	48:195c97f12e8e	1818	}
klauss	91:c2a86b1f8aaa	1819
klauss	92:92df17f538a8	1820	if( cb!= NULL ) cb->registry();
klauss	91:c2a86b1f8aaa	1821
klauss	91:c2a86b1f8aaa	1822	if( xstrmatch( ( uint8_t * )data, ( uint8_t * )"ping" ) ) {
klauss	78:1353744f01e1	1823	if( debug_ping ) send_msg( "Prompt pkg from ( %i, %i ) :: Ping", ext, port );
klauss	91:c2a86b1f8aaa	1824	} else {
klauss	78:1353744f01e1	1825	prompt_counter++;
klauss	109:a5b8264ffbbc	1826	//fixme isso nao poderia ser resolvido com um sendmsg ?
klauss	78:1353744f01e1	1827	send_msg( "Prompt pkg from ( %i, %i ) ::", ext, port );
klauss	91:c2a86b1f8aaa	1828	for( register uint8_t i = 0; i < 32; i++ ) {
klauss	100:09a23fcd3bdf	1829	if( debug_uart3 ) pc.printf("%c", data[ i ] );
klauss	100:09a23fcd3bdf	1830	if( i == 15 ) if( debug_uart3 ) pc.printf( "\r\n" );
klauss	78:1353744f01e1	1831	}
klauss	100:09a23fcd3bdf	1832	if( debug_uart3 ) pc.printf("\n\r> ");
klauss	91:c2a86b1f8aaa	1833
klauss	109:a5b8264ffbbc	1834	if( tcp_session ) {
klauss	109:a5b8264ffbbc	1835	char aux[ __CB_BUFFER_SIZE__ + 3 ];
klauss	109:a5b8264ffbbc	1836	strncpy( aux, (char * )data, __CB_BUFFER_SIZE__ );
klauss	78:1353744f01e1	1837	strcat( aux, "\n\r\0" );
klauss	78:1353744f01e1	1838	tcp_client.send_all( ( char )data, strlen( (char )data ) );
klauss	78:1353744f01e1	1839	tcp_client.send_all( "\r\n> ", strlen( "\r\n> " ) );
klauss	78:1353744f01e1	1840	}
klauss	48:195c97f12e8e	1841	}
klauss	91:c2a86b1f8aaa	1842	}
klauss	91:c2a86b1f8aaa	1843	break;
klauss	0:4d17cd9c8f9d	1844	case __AUDIO__ : {
klauss	63:0d95da692bb4	1845	audio_counter++;
klauss	78:1353744f01e1	1846	VZ_call * call = __find_Call__( v_call, ext );
klauss	91:c2a86b1f8aaa	1847	if( call != NULL ) {
klauss	91:c2a86b1f8aaa	1848	char * pkg = call->build_eth_package( data + 2 );
klauss	0:4d17cd9c8f9d	1849	call->send_message( pkg );
klauss	92:92df17f538a8	1850	call->cbx_pkg_idle_timer_reset();
klauss	78:1353744f01e1	1851	Call_Box * cb = __find_CB__( v_cb, ext );
klauss	109:a5b8264ffbbc	1852
klauss	109:a5b8264ffbbc	1853	if ( drop_rtp_from_cbx_pkg )
klauss	109:a5b8264ffbbc	1854	{
klauss	109:a5b8264ffbbc	1855	led2 = !led2;
klauss	109:a5b8264ffbbc	1856	break;
klauss	109:a5b8264ffbbc	1857	}
klauss	109:a5b8264ffbbc	1858
klauss	109:a5b8264ffbbc	1859	if( cb != NULL ){
klauss	109:a5b8264ffbbc	1860	//cb->reset_elapsed_time();
klauss	92:92df17f538a8	1861	cb->set_invite_response_ok();
klauss	92:92df17f538a8	1862	cb->invite_retry_count_reset();
klauss	92:92df17f538a8	1863	}
klauss	91:c2a86b1f8aaa	1864	} else {
klauss	78:1353744f01e1	1865	if( debug_main ) debug_msg("received missed package from CBx :: %i", ext );
klauss	0:4d17cd9c8f9d	1866	}
klauss	91:c2a86b1f8aaa	1867	}
klauss	91:c2a86b1f8aaa	1868	break;
klauss	109:a5b8264ffbbc	1869	}// fim switch
klauss	105:a930035b6556	1870
klauss	99:e80850c51106	1871	{ // rajada
klauss	109:a5b8264ffbbc	1872	//if( invite_retry_time == true ){
klauss	109:a5b8264ffbbc	1873	// invite_retry_time = false;
klauss	99:e80850c51106	1874	if( invite_retry_timer.read_ms() > 30 ) {
klauss	99:e80850c51106	1875	invite_retry_timer.reset();
klauss	92:92df17f538a8	1876	static int retry_invite_pkg = 0;
klauss	99:e80850c51106	1877
klauss	92:92df17f538a8	1878	if( retry_invite_pkg >= v_cb->size() ) retry_invite_pkg = 0;
klauss	99:e80850c51106	1879
klauss	109:a5b8264ffbbc	1880	register int i = 0;
klauss	109:a5b8264ffbbc	1881	for( ; i < v_cb->size(); i++ ) {
klauss	99:e80850c51106	1882	Call_Box * cb = (Call_Box * )v_cb->get_element( i );
klauss	99:e80850c51106	1883	if( ( cb->status == cb_ringing ) \|\| ( cb->status == cb_trying ) \|\| ( cb->status == cb_on_call ) ) {
klauss	99:e80850c51106	1884	if( i > retry_invite_pkg ) {
klauss	99:e80850c51106	1885	retry_invite_pkg = i;
klauss	99:e80850c51106	1886	break;
klauss	99:e80850c51106	1887	}
klauss	92:92df17f538a8	1888	}
klauss	99:e80850c51106	1889	}
klauss	109:a5b8264ffbbc	1890
klauss	99:e80850c51106	1891	if( i != v_cb->size() ){
klauss	99:e80850c51106	1892	Call_Box * cb = (Call_Box *)v_cb->get_element( retry_invite_pkg++ );
klauss	109:a5b8264ffbbc	1893
klauss	99:e80850c51106	1894	if( ( cb->status == cb_ringing ) \|\| ( cb->status == cb_trying ) \|\| ( cb->status == cb_on_call ) ) {
klauss	99:e80850c51106	1895	if( cb->get_invite_response() == false ) {
klauss	109:a5b8264ffbbc	1896	//cb->set_msg_id( ( cb->get_msg_id() & ~BIT7 ) + 1 );
klauss	99:e80850c51106	1897	cb->set_msg_id( ( cb->get_msg_id() + 1 ) & ~BIT7 );
klauss	99:e80850c51106	1898
klauss	99:e80850c51106	1899	buffer[ __TIMESLICE_PLACE__ ] = cb->get_timeslice();
klauss	109:a5b8264ffbbc	1900
klauss	109:a5b8264ffbbc	1901	send2callboxes( __build_cb_package__( cb->get_ext(), cb->get_port(), __INVITE__, ( char * )buffer,
klauss	109:a5b8264ffbbc	1902	cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	99:e80850c51106	1903	if( debug_invite ) debug_msg("resend invite OK to Cbx : ( %d, %d )", cb->get_ext(), cb->get_port() );
klauss	99:e80850c51106	1904	}
klauss	99:e80850c51106	1905	if( cb->get_invite_retry_count() == 0 ) {
klauss	99:e80850c51106	1906	cb->send_bye();
klauss	92:92df17f538a8	1907
klauss	99:e80850c51106	1908	ts->return_timeslice( cb->get_timeslice() );
klauss	99:e80850c51106	1909	cb->set_timeslice( 0x00 );
klauss	99:e80850c51106	1910
klauss	109:a5b8264ffbbc	1911	//cb->set_msg_id( ( cb->get_msg_id() & ~BIT7 ) + 1 );
klauss	99:e80850c51106	1912	cb->set_msg_id( ( cb->get_msg_id() + 1 ) & ~BIT7 );
klauss	99:e80850c51106	1913
klauss	99:e80850c51106	1914	for( register uint8_t i = 0; i < v_call->size(); i++ ) {
klauss	99:e80850c51106	1915	VZ_call * call = ( VZ_call * )v_call->get_element( i );
klauss	99:e80850c51106	1916	if( call->get_cb_ext() == cb->get_ext() ) {
klauss	99:e80850c51106	1917	v_call->remove_element( i );
klauss	99:e80850c51106	1918	if( call != NULL ) delete( call );
klauss	99:e80850c51106	1919	break;
klauss	99:e80850c51106	1920	}
klauss	92:92df17f538a8	1921	}
klauss	99:e80850c51106	1922
klauss	99:e80850c51106	1923	if( debug_invite ) debug_msg( "-- No audio pkgs --" );
klauss	99:e80850c51106	1924	set_status( cb->status, cb_idle );
klauss	99:e80850c51106	1925	set_status( cb->sip->status, sip_idle );
klauss	92:92df17f538a8	1926	}
klauss	92:92df17f538a8	1927	}
klauss	92:92df17f538a8	1928	}
klauss	92:92df17f538a8	1929	}
klauss	109:a5b8264ffbbc	1930	} // fim rajada
klauss	109:a5b8264ffbbc	1931
klauss	91:c2a86b1f8aaa	1932	for( register uint8_t i = 0; i < v_call->size(); i++ ) {
klauss	0:4d17cd9c8f9d	1933	VZ_call * call = ( VZ_call * )v_call->get_element( i );
klauss	109:a5b8264ffbbc	1934	int length = 0;
klauss	109:a5b8264ffbbc	1935	char * tmp = call->get_eth_message( &length );
klauss	109:a5b8264ffbbc	1936	if( tmp != NULL ) {
klauss	109:a5b8264ffbbc	1937	int cb_port = 0xffff;
klauss	109:a5b8264ffbbc	1938	Call_Box * cb = __find_CB__( v_cb, call->get_cb_ext() );
klauss	109:a5b8264ffbbc	1939
klauss	109:a5b8264ffbbc	1940	if( cb != NULL ) {
klauss	109:a5b8264ffbbc	1941	cb_port = cb->get_port();
klauss	109:a5b8264ffbbc	1942
klauss	109:a5b8264ffbbc	1943	if ( drop_rtp_from_ast_pkg )
klauss	109:a5b8264ffbbc	1944	{
klauss	109:a5b8264ffbbc	1945	led1 = !led1;
klauss	109:a5b8264ffbbc	1946	}
klauss	109:a5b8264ffbbc	1947	else
klauss	109:a5b8264ffbbc	1948	{
klauss	109:a5b8264ffbbc	1949	uint8_t * pkg2cb = __build_cb_package__( call->get_cb_ext(), cb_port, __AUDIO__,
klauss	108:18a3702650f3	1950	tmp, __AUDIO__, length, write_buffer );
klauss	109:a5b8264ffbbc	1951
klauss	108:18a3702650f3	1952	send2callboxes( pkg2cb );
klauss	109:a5b8264ffbbc	1953	}
klauss	109:a5b8264ffbbc	1954
klauss	109:a5b8264ffbbc	1955	} else if( debug_main ) debug_msg("received missed package from CBx :: %i -- Type :: %i", ext, type );
klauss	0:4d17cd9c8f9d	1956	}
klauss	14:22a35f575502	1957	}
klauss	109:a5b8264ffbbc	1958
klauss	109:a5b8264ffbbc	1959	//if( v_call->size() == 0 ) refresh( v_cb, buffer, write_buffer, NULL );
klauss	109:a5b8264ffbbc	1960
klauss	109:a5b8264ffbbc	1961	if( timer_sync_refresh.read_ms() > 250 ) {
klauss	109:a5b8264ffbbc	1962	timer_sync_refresh.reset();
klauss	106:a34fcf9f0e02	1963
klauss	109:a5b8264ffbbc	1964	static uint8_t mode = TIME_TO_REFRESH;
klauss	109:a5b8264ffbbc	1965
klauss	109:a5b8264ffbbc	1966	if( mode == TIME_TO_REFRESH ) {
klauss	109:a5b8264ffbbc	1967	mode = TIME_TO_WAKE_UP;
klauss	109:a5b8264ffbbc	1968	refresh( v_cb, buffer, write_buffer, NULL );
klauss	109:a5b8264ffbbc	1969	} else {
klauss	109:a5b8264ffbbc	1970	mode = TIME_TO_REFRESH;
klauss	109:a5b8264ffbbc	1971	if( wake_all ) if( v_call->size() == 0 ) wake_all_up( v_cb, buffer, write_buffer );
klauss	89:0fe315117b00	1972	}
klauss	89:0fe315117b00	1973	}
klauss	108:18a3702650f3	1974
klauss	109:a5b8264ffbbc	1975
klauss	109:a5b8264ffbbc	1976	//refresh( v_cb, buffer, write_buffer, NULL );
klauss	109:a5b8264ffbbc	1977
klauss	109:a5b8264ffbbc	1978	//Fixme pensar melhor nessa parte durante ligacoes, pode complicar com muitos cbx ...
klauss	109:a5b8264ffbbc	1979	//if( v_call->size() == 0 ) registry_aging( v_cb, buffer, write_buffer );
klauss	109:a5b8264ffbbc	1980
klauss	78:1353744f01e1	1981	// check sip messages only for cbx in call ?
klauss	78:1353744f01e1	1982	int ext_to__be_removed = sip_manager( v_cb );
klauss	91:c2a86b1f8aaa	1983	if( ext_to__be_removed > 0x00 ) {
klauss	78:1353744f01e1	1984	Call_Box * cb = __find_CB__( v_cb, ext_to__be_removed );
klauss	91:c2a86b1f8aaa	1985	if( cb != NULL ) {
klauss	91:c2a86b1f8aaa	1986	if( cb->status == cb_on_call ) {
klauss	4:de46f0d9b14d	1987	ts->return_timeslice( cb->get_timeslice() );
klauss	4:de46f0d9b14d	1988	cb->set_timeslice( 0x00 );
klauss	4:de46f0d9b14d	1989	buffer[ __TIMESLICE_PLACE__ ] = 0x00;
klauss	91:c2a86b1f8aaa	1990
klauss	78:1353744f01e1	1991	set_status( cb->status, cb_idle );
klauss	78:1353744f01e1	1992	set_status( cb->sip->status, sip_idle );
klauss	91:c2a86b1f8aaa	1993
klauss	91:c2a86b1f8aaa	1994	for( register uint8_t i = 0; i < v_call->size(); i++ ) {
klauss	4:de46f0d9b14d	1995	VZ_call * call = ( VZ_call * )v_call->get_element( i );
klauss	91:c2a86b1f8aaa	1996	if( call->get_cb_ext() == ext_to__be_removed ) {
klauss	4:de46f0d9b14d	1997	v_call->remove_element( i );
klauss	4:de46f0d9b14d	1998	delete( call );
klauss	4:de46f0d9b14d	1999	}
klauss	2:93bec7313ccc	2000	}
klauss	91:c2a86b1f8aaa	2001
klauss	109:a5b8264ffbbc	2002	//cb->set_msg_id( ( cb->get_msg_id() & ~BIT7 ) + 1 );
klauss	92:92df17f538a8	2003	cb->set_msg_id( ( cb->get_msg_id() + 1 ) & ~BIT7 );
klauss	109:a5b8264ffbbc	2004
klauss	109:a5b8264ffbbc	2005	//debug_msg("msg_id -- %d", cb->get_msg_id() );
klauss	91:c2a86b1f8aaa	2006
klauss	109:a5b8264ffbbc	2007	send2callboxes( __build_cb_package__( ext, port, __CB_BYE__,
klauss	109:a5b8264ffbbc	2008	( char * )buffer, cb->get_msg_id(), __CB_BUFFER_SIZE__ - __VZ_HEADER_OFFSET__, write_buffer ) );
klauss	91:c2a86b1f8aaa	2009
klauss	91:c2a86b1f8aaa	2010	if( debug_invite ) debug_msg("Received Bye from *");
klauss	109:a5b8264ffbbc	2011	//cb->re_start_timer();
klauss	0:4d17cd9c8f9d	2012	}
klauss	91:c2a86b1f8aaa	2013	} else if( debug_main ) debug_msg("Missed bye request from * CBx :: %d", ext );
klauss	109:a5b8264ffbbc	2014	}
klauss	91:c2a86b1f8aaa	2015
klauss	81:3656f00ab3db	2016	/* Verifica andamento de ligações para eventualmente encerra-las por timeout */
klauss	109:a5b8264ffbbc	2017	call_manager( v_call, v_cb, buffer, write_buffer, ts );
klauss	91:c2a86b1f8aaa	2018
klauss	109:a5b8264ffbbc	2019	/* tratamento de pedidos de ligação */
klauss	81:3656f00ab3db	2020	invite_handler( v_call, v_cb, ts, NULL );
klauss	109:a5b8264ffbbc	2021
klauss	81:3656f00ab3db	2022	/* rotina de verificação de TS's perdidos */
klauss	91:c2a86b1f8aaa	2023	if( ( v_call->size() == 0 ) && ( ts->remain_timeslices() != __MAX_TIMESLICES__ ) ) {
klauss	91:c2a86b1f8aaa	2024	bool ts_reset = true;
klauss	91:c2a86b1f8aaa	2025	for( register uint8_t i = 0; i < v_cb->size(); i++ ) {
klauss	82:f55d13babca0	2026	if ( ( ( Call_Box * )v_cb->get_element( i ) )->get_status() != cb_idle &&
klauss	91:c2a86b1f8aaa	2027	( ( Call_Box * )v_cb->get_element( i ) )->get_sip_status() != sip_idle ) {
klauss	78:1353744f01e1	2028	ts_reset = false;
klauss	78:1353744f01e1	2029	break;
klauss	78:1353744f01e1	2030	}
klauss	91:c2a86b1f8aaa	2031	}
klauss	109:a5b8264ffbbc	2032	if( ts_reset ) {
klauss	109:a5b8264ffbbc	2033	if( debug_invite ) debug_msg("Resetando TS");
klauss	109:a5b8264ffbbc	2034	ts->reset();
klauss	78:1353744f01e1	2035	}
klauss	0:4d17cd9c8f9d	2036	}
klauss	109:a5b8264ffbbc	2037
klauss	109:a5b8264ffbbc	2038	//invite_pgk_retry_manager( v_call, v_cb, buffer, write_buffer );
klauss	109:a5b8264ffbbc	2039
klauss	109:a5b8264ffbbc	2040	/* escuta se existe algum procedimento de gravação de cbx */
klauss	109:a5b8264ffbbc	2041	//bl_handler();
klauss	109:a5b8264ffbbc	2042
klauss	81:3656f00ab3db	2043	/* rotina que esvazia possiveis pacotes que não foram transmitidos para evitar conflito */
klauss	72:895ca792c647	2044	tx_buffer_ring_buffer_handler();
klauss	91:c2a86b1f8aaa	2045
klauss	30:8dfb6d8de53d	2046	type = __DO_NOTHING__;
klauss	109:a5b8264ffbbc	2047
klauss	81:3656f00ab3db	2048	if( eth_status == 0 ) eth_wdt = ETH_CONNECT_TIMEOUT;
klauss	109:a5b8264ffbbc	2049
klauss	91:c2a86b1f8aaa	2050	if( wdt_timer.read() >= 1 ) {
klauss	91:c2a86b1f8aaa	2051	//FIXME remove myself
klauss	109:a5b8264ffbbc	2052	//registry_test = true;
klauss	109:a5b8264ffbbc	2053	//invite_retry_time = true;
klauss	109:a5b8264ffbbc	2054
klauss	83:b8a1d8fdeaeb	2055	uptime++;
klauss	91:c2a86b1f8aaa	2056
klauss	81:3656f00ab3db	2057	wdt_timer.reset();
klauss	91:c2a86b1f8aaa	2058
klauss	81:3656f00ab3db	2059	if( wdt_show ) debug_wdt = true;
klauss	91:c2a86b1f8aaa	2060
klauss	81:3656f00ab3db	2061	if( external_wdt ) external_wdt--;
klauss	81:3656f00ab3db	2062	if( pkg_wdt ) pkg_wdt--;
klauss	81:3656f00ab3db	2063	if( eth_wdt ) eth_wdt--;
klauss	91:c2a86b1f8aaa	2064
klauss	91:c2a86b1f8aaa	2065	if( eth_wdt && external_wdt && pkg_wdt ){
klauss	81:3656f00ab3db	2066	wdt.kick();
klauss	81:3656f00ab3db	2067	}
klauss	109:a5b8264ffbbc	2068	}
klauss	109:a5b8264ffbbc	2069
klauss	91:c2a86b1f8aaa	2070	if( debug_wdt ) {
klauss	87:679ee0d594a9	2071	send_msg("lpc_low_level_input_counter :: %d", lpc_low_level_input_counter );
klauss	87:679ee0d594a9	2072	lpc_low_level_input_counter = 0;
klauss	91:c2a86b1f8aaa	2073
klauss	81:3656f00ab3db	2074	debug_wdt = false;
klauss	91:c2a86b1f8aaa	2075	if( eth_status == 0 ) {
klauss	91:c2a86b1f8aaa	2076	send_msg( "Wdt last reset: %s - status_eth :: Connected - Extern Wdt idle for :: %3d sec ( %3d ) - Rx from CBx idle for :: %3d sec ( %3d )",
klauss	91:c2a86b1f8aaa	2077	( wdt.WatchdogCausedReset() ) ? "true" : "false",
klauss	91:c2a86b1f8aaa	2078	EXTERN_WDT_IDLE - external_wdt,
klauss	91:c2a86b1f8aaa	2079	EXTERN_WDT_IDLE,
klauss	91:c2a86b1f8aaa	2080	RX_CB_IDLE - pkg_wdt,
klauss	91:c2a86b1f8aaa	2081	RX_CB_IDLE
klauss	91:c2a86b1f8aaa	2082	);
klauss	91:c2a86b1f8aaa	2083	} else {
klauss	91:c2a86b1f8aaa	2084	send_msg( "Wdt last reset: %s - status_eth :: Disconnected :: since %3d sec - Extern Wdt idle for :: %3d sec ( %3d ) - Rx from CBx idle for :: %3d sec ( %3d )",
klauss	91:c2a86b1f8aaa	2085	( wdt.WatchdogCausedReset() ) ? "true" : "false",
klauss	91:c2a86b1f8aaa	2086	ETH_CONNECT_TIMEOUT - eth_wdt,
klauss	91:c2a86b1f8aaa	2087	EXTERN_WDT_IDLE - external_wdt,
klauss	91:c2a86b1f8aaa	2088	EXTERN_WDT_IDLE,
klauss	91:c2a86b1f8aaa	2089	RX_CB_IDLE - pkg_wdt,
klauss	91:c2a86b1f8aaa	2090	RX_CB_IDLE
klauss	91:c2a86b1f8aaa	2091	);
klauss	81:3656f00ab3db	2092	}
klauss	109:a5b8264ffbbc	2093	}
klauss	109:a5b8264ffbbc	2094	}
klauss	0:4d17cd9c8f9d	2095	}

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	19 Nov 2014
Imports:	18
Forks:	0
Commits:	138
Dependents:	0
Dependencies:	4
Followers:	6

main.cpp@109:a5b8264ffbbc, 2015-04-07 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning