Modularizando o src
Dependencies: EALib EthernetInterface_vz mbed-rtos mbed
Fork of header_main_colinas_V0-20-09-14 by
call.cpp
- Committer:
- klauss
- Date:
- 2014-12-30
- Revision:
- 81:3656f00ab3db
- Parent:
- 78:1353744f01e1
- Child:
- 85:b6f2dc1d0f4f
File content as of revision 81:3656f00ab3db:
#include "call.h" VZ_call::VZ_call( int cb_ext, int cb_port, int rtp_server_ext, int rtp_server_port ){ this->cb_ext = cb_ext; this->cb_port = cb_port; this->rtp_server_ext = rtp_server_ext; this->rtp_server_port = rtp_server_port; this->rtp_server.set_address( __RTP_SEVER_IP__, rtp_server_port ); rtp_sock.set_blocking( false, 3 ); this->rtp_sock.bind( cb_port ); // rtp port this->rtp_sock.init(); this->rtp = new RTP( this->cb_ext ); t.start(); finish.start(); rtpbuf_clear( &( this->rtpbuf ) ); } VZ_call::~VZ_call(){ rtp_sock.close(); delete( this->rtp ); } char * VZ_call::get_eth_message( int * length ){ uint8_t * pkg; *length = rtp_sock.receiveFrom( rtp_server, server2cb, sizeof( server2cb ) ); t.reset(); rtpbuf_next( &rtpbuf ); if( *length > 0 ){ rtpbuf_put( &rtpbuf, *length - ( __RTP_HEADER_SIZE__ + ( server2cb[ 0 ] & 0xf ) ), ( uint8_t * )server2cb + ( __RTP_HEADER_OFFSET__ + ( server2cb[ 0 ] & 0xf ) ) ); } pkg = rtpbuf_get( &rtpbuf ); if (pkg != NULL) { *length = 240; return (char *) pkg; } *length = 0; return NULL; } int VZ_call::send_message( char * buffer ){ t.reset(); return( this->rtp_sock.sendTo( this->rtp_server, buffer, __CB_AUDIO_DATA_SIZE__ + this->rtp->header_size() ) ); /* //FIXME verificar como fica se eu esperar o sendTo chegar em != 0 int8_t sent = 0; do{ sent = this->rtp_sock.sendTo( this->rtp_server, buffer, __CB_AUDIO_DATA_SIZE__ + this->rtp->header_size() ) ); }while( sent == 0 ); return( sent ); */ } uint8_t * VZ_call::build_cb_package( void ){ // return __build_cb_package__( cb_ext, cb_port, __AUDIO__, server2cb, buffer ); // colocar esta funcao novamente pra envio de msg, assim como encapsular melhor a funcao // de criacao dos pacotes pro cb em algumas funcoes. return 0x00; } char * VZ_call::build_eth_package( uint8_t * buffer ){ return this->rtp->build_eth_package( ( char * )buffer ); } int VZ_call::get_cb_ext(){ return this->cb_ext; } int VZ_call::get_cb_port(){ return this->cb_port; } int VZ_call::get_rtp_server_ext(){ return rtp_server_ext; } int VZ_call::get_rtp_server_port(){ return rtp_server_port; } uint8_t * VZ_call::get_cb2server_buffer(){ return cb2server; } char * VZ_call::get_server2cb_buffer(){ return server2cb; } inline uint8_t * VZ_call::get_buffer(){ return buffer; } bool VZ_call::is_timeout( void ){ return ( t.read() > __CALL_MAX_IDLE_TIME__ ) ? true : false; } bool VZ_call::is_timetofinish( void ){ return ( finish.read() > __MAX_CALL_TIME__ ) ? true : false; }