summaryrefslogtreecommitdiff
path: root/toxav/rtp.c
diff options
context:
space:
mode:
Diffstat (limited to 'toxav/rtp.c')
-rw-r--r--toxav/rtp.c22
1 files changed, 11 insertions, 11 deletions
diff --git a/toxav/rtp.c b/toxav/rtp.c
index ca37bf47..9ba3b6a3 100644
--- a/toxav/rtp.c
+++ b/toxav/rtp.c
@@ -105,16 +105,16 @@ RTPHeader *extract_header ( const uint8_t *payload, int length )
105 } 105 }
106 106
107 RTPHeader *_retu = calloc(1, sizeof (RTPHeader)); 107 RTPHeader *_retu = calloc(1, sizeof (RTPHeader));
108 108
109 if ( !_retu ) { 109 if ( !_retu ) {
110 LOGGER_WARNING("Alloc failed! Program might misbehave!"); 110 LOGGER_WARNING("Alloc failed! Program might misbehave!");
111 return NULL; 111 return NULL;
112 } 112 }
113 113
114 bytes_to_U16(&_retu->sequnum, payload); 114 bytes_to_U16(&_retu->sequnum, payload);
115 115
116 const uint8_t *_it = payload + 2; 116 const uint8_t *_it = payload + 2;
117 117
118 _retu->flags = *_it; 118 _retu->flags = *_it;
119 ++_it; 119 ++_it;
120 120
@@ -178,7 +178,7 @@ RTPExtHeader *extract_ext_header ( const uint8_t *payload, uint16_t length )
178 const uint8_t *_it = payload; 178 const uint8_t *_it = payload;
179 179
180 RTPExtHeader *_retu = calloc(1, sizeof (RTPExtHeader)); 180 RTPExtHeader *_retu = calloc(1, sizeof (RTPExtHeader));
181 181
182 if ( !_retu ) { 182 if ( !_retu ) {
183 LOGGER_WARNING("Alloc failed! Program might misbehave!"); 183 LOGGER_WARNING("Alloc failed! Program might misbehave!");
184 return NULL; 184 return NULL;
@@ -290,7 +290,7 @@ uint8_t *add_ext_header ( RTPExtHeader *header, uint8_t *payload )
290RTPHeader *build_header ( RTPSession *session ) 290RTPHeader *build_header ( RTPSession *session )
291{ 291{
292 RTPHeader *_retu = calloc ( 1, sizeof (RTPHeader) ); 292 RTPHeader *_retu = calloc ( 1, sizeof (RTPHeader) );
293 293
294 if ( !_retu ) { 294 if ( !_retu ) {
295 LOGGER_WARNING("Alloc failed! Program might misbehave!"); 295 LOGGER_WARNING("Alloc failed! Program might misbehave!");
296 return NULL; 296 return NULL;
@@ -386,7 +386,7 @@ RTPMessage *msg_parse ( const uint8_t *data, int length )
386 * @retval -1 Error occurred. 386 * @retval -1 Error occurred.
387 * @retval 0 Success. 387 * @retval 0 Success.
388 */ 388 */
389int rtp_handle_packet ( void *object, uint8_t *data, uint32_t length ) 389int rtp_handle_packet ( void *object, const uint8_t *data, uint32_t length )
390{ 390{
391 RTPSession *_session = object; 391 RTPSession *_session = object;
392 RTPMessage *_msg; 392 RTPMessage *_msg;
@@ -451,7 +451,7 @@ RTPMessage *rtp_new_message ( RTPSession *session, const uint8_t *data, uint32_t
451 451
452 uint8_t *_from_pos; 452 uint8_t *_from_pos;
453 RTPMessage *_retu = calloc(1, sizeof (RTPMessage)); 453 RTPMessage *_retu = calloc(1, sizeof (RTPMessage));
454 454
455 if ( !_retu ) { 455 if ( !_retu ) {
456 LOGGER_WARNING("Alloc failed! Program might misbehave!"); 456 LOGGER_WARNING("Alloc failed! Program might misbehave!");
457 return NULL; 457 return NULL;
@@ -465,7 +465,7 @@ RTPMessage *rtp_new_message ( RTPSession *session, const uint8_t *data, uint32_t
465 uint32_t _total_length = length + _retu->header->length + 1; 465 uint32_t _total_length = length + _retu->header->length + 1;
466 466
467 _retu->data[0] = session->prefix; 467 _retu->data[0] = session->prefix;
468 468
469 if ( _retu->ext_header ) { 469 if ( _retu->ext_header ) {
470 _total_length += ( 4 /* Minimum ext header len */ + _retu->ext_header->length * size_32 ); 470 _total_length += ( 4 /* Minimum ext header len */ + _retu->ext_header->length * size_32 );
471 471
@@ -617,10 +617,10 @@ int rtp_send_msg ( RTPSession *session, Messenger *messenger, const uint8_t *dat
617 } 617 }
618 618
619 619
620 /* Set sequ number */ 620 /* Set sequ number */
621 session->sequnum = session->sequnum >= MAX_SEQU_NUM ? 0 : session->sequnum + 1; 621 session->sequnum = session->sequnum >= MAX_SEQU_NUM ? 0 : session->sequnum + 1;
622 rtp_free_msg ( session, msg ); 622 rtp_free_msg ( session, msg );
623 623
624 return 0; 624 return 0;
625} 625}
626 626
@@ -665,7 +665,7 @@ void rtp_free_msg ( RTPSession *session, RTPMessage *msg )
665RTPSession *rtp_init_session ( int payload_type, Messenger *messenger, int friend_num ) 665RTPSession *rtp_init_session ( int payload_type, Messenger *messenger, int friend_num )
666{ 666{
667 RTPSession *_retu = calloc(1, sizeof(RTPSession)); 667 RTPSession *_retu = calloc(1, sizeof(RTPSession));
668 668
669 if ( !_retu ) { 669 if ( !_retu ) {
670 LOGGER_WARNING("Alloc failed! Program might misbehave!"); 670 LOGGER_WARNING("Alloc failed! Program might misbehave!");
671 return NULL; 671 return NULL;