diff options
Diffstat (limited to 'tinySDP/src/tsdp_message.c')
-rwxr-xr-x | tinySDP/src/tsdp_message.c | 649 |
1 files changed, 324 insertions, 325 deletions
diff --git a/tinySDP/src/tsdp_message.c b/tinySDP/src/tsdp_message.c index 7be242f..d69767d 100755 --- a/tinySDP/src/tsdp_message.c +++ b/tinySDP/src/tsdp_message.c @@ -7,12 +7,12 @@ * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. -* +* * DOUBANGO is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. -* +* * You should have received a copy of the GNU General Public License * along with DOUBANGO. * @@ -40,328 +40,328 @@ /*== Predicate function to find tsdp_header_t object by type. */ static int __pred_find_header_by_type(const tsk_list_item_t *item, const void *tsdp_htype) { - if(item && item->data){ - tsdp_header_t *header = item->data; - tsdp_header_type_t htype = *((tsdp_header_type_t*)tsdp_htype); - return (header->type - htype); - } - return -1; + if(item && item->data) { + tsdp_header_t *header = item->data; + tsdp_header_type_t htype = *((tsdp_header_type_t*)tsdp_htype); + return (header->type - htype); + } + return -1; } /*== Predicate function to find tsdp_header_t object by name. */ static int __pred_find_header_by_name(const tsk_list_item_t *item, const void *name) { - if(item && item->data && name){ - tsdp_header_t *header = item->data; - return tsdp_header_get_nameex(header) - *((const char*)name); - } - return -1; + if(item && item->data && name) { + tsdp_header_t *header = item->data; + return tsdp_header_get_nameex(header) - *((const char*)name); + } + return -1; } /*== Predicate function to find media object by name. */ static int __pred_find_media_by_name(const tsk_list_item_t *item, const void *name) { - if(item && item->data && name){ - tsdp_header_t *header = item->data; - if(header->type == tsdp_htype_M){ - return tsk_stricmp(((tsdp_header_M_t*)header)->media, (const char*)name); - } - } - return -1; + if(item && item->data && name) { + tsdp_header_t *header = item->data; + if(header->type == tsdp_htype_M) { + return tsk_stricmp(((tsdp_header_M_t*)header)->media, (const char*)name); + } + } + return -1; } tsdp_message_t* tsdp_message_create() { - return tsk_object_new(tsdp_message_def_t); + return tsk_object_new(tsdp_message_def_t); } /*== Add headers/fmt to the media line */ int __add_headers(tsdp_header_M_t* m, va_list *ap) { - const tsk_object_def_t* objdef; - tsdp_header_t *header; - tsdp_fmt_t* fmt; - - if(!m){ - return -1; - } - - while((objdef = va_arg(*ap, const tsk_object_def_t*))){ - if(objdef == tsdp_fmt_def_t){ - if((fmt = tsk_object_new_2(objdef, ap))){ - tsk_list_push_back_data(m->FMTs, (void**)&fmt); - } - } - else{ - if((header = tsk_object_new_2(objdef, ap))){ - tsdp_header_M_add(m, header); - TSK_OBJECT_SAFE_FREE(header); - } - } - } - return 0; + const tsk_object_def_t* objdef; + tsdp_header_t *header; + tsdp_fmt_t* fmt; + + if(!m) { + return -1; + } + + while((objdef = va_arg(*ap, const tsk_object_def_t*))) { + if(objdef == tsdp_fmt_def_t) { + if((fmt = tsk_object_new_2(objdef, ap))) { + tsk_list_push_back_data(m->FMTs, (void**)&fmt); + } + } + else { + if((header = tsk_object_new_2(objdef, ap))) { + tsdp_header_M_add(m, header); + TSK_OBJECT_SAFE_FREE(header); + } + } + } + return 0; } int tsdp_message_add_header(tsdp_message_t *self, const tsdp_header_t *hdr) { - if(self && hdr){ - tsdp_header_t *header = tsk_object_ref((void*)hdr); - tsk_list_push_ascending_data(self->headers, (void**)&header); // Very important: Headers MUST appear in a fixed order (see ranks def). + if(self && hdr) { + tsdp_header_t *header = tsk_object_ref((void*)hdr); + tsk_list_push_ascending_data(self->headers, (void**)&header); // Very important: Headers MUST appear in a fixed order (see ranks def). - return 0; - } - return -1; + return 0; + } + return -1; } int tsdp_message_add_headers(tsdp_message_t *self, ...) { - const tsk_object_def_t* objdef; - tsdp_header_t *header; - va_list ap; - - if(!self){ - return -1; - } - - va_start(ap, self); - while((objdef = va_arg(ap, const tsk_object_def_t*))){ - if((header = tsk_object_new_2(objdef, &ap))){ - tsdp_message_add_header(self, header); - TSK_OBJECT_SAFE_FREE(header); - } - } - va_end(ap); - - return 0; + const tsk_object_def_t* objdef; + tsdp_header_t *header; + va_list ap; + + if(!self) { + return -1; + } + + va_start(ap, self); + while((objdef = va_arg(ap, const tsk_object_def_t*))) { + if((header = tsk_object_new_2(objdef, &ap))) { + tsdp_message_add_header(self, header); + TSK_OBJECT_SAFE_FREE(header); + } + } + va_end(ap); + + return 0; } const tsdp_header_t *tsdp_message_get_headerAt(const tsdp_message_t *self, tsdp_header_type_t type, tsk_size_t index) { - tsk_size_t pos = 0; - const tsk_list_item_t *item; - const tsdp_header_t *hdr; - - if(!self || !self->headers){ - return tsk_null; - } - - tsk_list_foreach(item, self->headers){ - hdr = item->data; - if(hdr->type == type){ - if(pos++ >= index){ - return hdr; - } - } - } - - return tsk_null; + tsk_size_t pos = 0; + const tsk_list_item_t *item; + const tsdp_header_t *hdr; + + if(!self || !self->headers) { + return tsk_null; + } + + tsk_list_foreach(item, self->headers) { + hdr = item->data; + if(hdr->type == type) { + if(pos++ >= index) { + return hdr; + } + } + } + + return tsk_null; } const tsdp_header_t *tsdp_message_get_header(const tsdp_message_t *self, tsdp_header_type_t type) { - return tsdp_message_get_headerAt(self, type, 0); + return tsdp_message_get_headerAt(self, type, 0); } const tsdp_header_A_t* tsdp_message_get_headerA_at(const tsdp_message_t* self, const char* field, tsk_size_t index) { - tsk_size_t pos = 0; - const tsk_list_item_t *item; - const tsdp_header_t *hdr; - const tsdp_header_A_t *hdrA; - - if(!self || !self->headers){ - return tsk_null; - } - - tsk_list_foreach(item, self->headers){ - hdr = item->data; - if((hdr->type == tsdp_htype_A) && (hdrA = (const tsdp_header_A_t *)hdr) && (tsk_striequals(hdrA->field, field))){ - if(pos++ >= index){ - return hdrA; - } - } - } - - return tsk_null; + tsk_size_t pos = 0; + const tsk_list_item_t *item; + const tsdp_header_t *hdr; + const tsdp_header_A_t *hdrA; + + if(!self || !self->headers) { + return tsk_null; + } + + tsk_list_foreach(item, self->headers) { + hdr = item->data; + if((hdr->type == tsdp_htype_A) && (hdrA = (const tsdp_header_A_t *)hdr) && (tsk_striequals(hdrA->field, field))) { + if(pos++ >= index) { + return hdrA; + } + } + } + + return tsk_null; } const tsdp_header_A_t* tsdp_message_get_headerA(const tsdp_message_t* self, const char* field) { - return tsdp_message_get_headerA_at(self, field, 0); + return tsdp_message_get_headerA_at(self, field, 0); } const tsdp_header_t *tsdp_message_get_headerByName(const tsdp_message_t *self, char name) { - if(self){ - return tsk_list_find_object_by_pred(self->headers, __pred_find_header_by_name, &name); - } - else{ - TSK_DEBUG_ERROR("Invalid parameter"); - return tsk_null; - } + if(self) { + return tsk_list_find_object_by_pred(self->headers, __pred_find_header_by_name, &name); + } + else { + TSK_DEBUG_ERROR("Invalid parameter"); + return tsk_null; + } } int tsdp_message_get_sess_version(const tsdp_message_t *self, uint32_t *version) { - const tsdp_header_O_t* O; - if (!self || !version) { - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - if ((O = (const tsdp_header_O_t*)tsdp_message_get_header(self, tsdp_htype_O))) { - *version = O->sess_version; - return 0; - } - return -2; + const tsdp_header_O_t* O; + if (!self || !version) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + if ((O = (const tsdp_header_O_t*)tsdp_message_get_header(self, tsdp_htype_O))) { + *version = O->sess_version; + return 0; + } + return -2; } int tsdp_message_serialize(const tsdp_message_t *self, tsk_buffer_t *output) { - const tsk_list_item_t* item; - - if(!self || !output){ - return -1; - } - - tsk_list_foreach(item, self->headers){ - if(tsdp_header_serialize(TSDP_HEADER(item->data), output)){ - // Abort? - } - } - - return 0; + const tsk_list_item_t* item; + + if(!self || !output) { + return -1; + } + + tsk_list_foreach(item, self->headers) { + if(tsdp_header_serialize(TSDP_HEADER(item->data), output)) { + // Abort? + } + } + + return 0; } char* tsdp_message_tostring(const tsdp_message_t *self) { - tsk_buffer_t* output = tsk_buffer_create_null(); - char* ret = tsk_null; + tsk_buffer_t* output = tsk_buffer_create_null(); + char* ret = tsk_null; - if(!tsdp_message_serialize(self, output)){ - ret = tsk_strndup(TSK_BUFFER_DATA(output), TSK_BUFFER_SIZE(output)); - } + if(!tsdp_message_serialize(self, output)) { + ret = tsk_strndup(TSK_BUFFER_DATA(output), TSK_BUFFER_SIZE(output)); + } - TSK_OBJECT_SAFE_FREE(output); - return ret; + TSK_OBJECT_SAFE_FREE(output); + return ret; } tsdp_message_t* tsdp_message_create_empty(const char* addr, tsk_bool_t ipv6, uint32_t version) { - tsdp_message_t* ret = 0; - - if(!(ret = tsdp_message_create())){ - return tsk_null; - } - - /* RFC 3264 - 5 Generating the Initial Offer - The numeric value of the session id and version in the o line MUST be - representable with a 64 bit signed integer. The initial value of the version MUST be less than - (2**62)-1, to avoid rollovers. - */ - TSDP_MESSAGE_ADD_HEADER(ret, TSDP_HEADER_V_VA_ARGS(0)); - TSDP_MESSAGE_ADD_HEADER(ret, TSDP_HEADER_O_VA_ARGS( - TSDP_LINE_O_USERNAME_DEFAULT, - TSDP_LINE_O_SESSION_ID_DEFAULT, - version, - "IN", - ipv6 ? "IP6" : "IP4", - addr)); - - /* RFC 3264 - 5 Generating the Initial Offer - The SDP "s=" line conveys the subject of the session, which is - reasonably defined for multicast, but ill defined for unicast. For - unicast sessions, it is RECOMMENDED that it consist of a single space - character (0x20) or a dash (-). - - Unfortunately, SDP does not allow the "s=" line to be empty. - */ - TSDP_MESSAGE_ADD_HEADER(ret, TSDP_HEADER_S_VA_ARGS(TSDP_LINE_S_VALUE_DEFAULT)); - - /* RFC 3264 - 5 Generating the Initial Offer - The SDP "t=" line conveys the time of the session. Generally, - streams for unicast sessions are created and destroyed through - external signaling means, such as SIP. In that case, the "t=" line - SHOULD have a value of "0 0". - */ - TSDP_MESSAGE_ADD_HEADER(ret, TSDP_HEADER_T_VA_ARGS(0, 0)); - - return ret; + tsdp_message_t* ret = 0; + + if(!(ret = tsdp_message_create())) { + return tsk_null; + } + + /* RFC 3264 - 5 Generating the Initial Offer + The numeric value of the session id and version in the o line MUST be + representable with a 64 bit signed integer. The initial value of the version MUST be less than + (2**62)-1, to avoid rollovers. + */ + TSDP_MESSAGE_ADD_HEADER(ret, TSDP_HEADER_V_VA_ARGS(0)); + TSDP_MESSAGE_ADD_HEADER(ret, TSDP_HEADER_O_VA_ARGS( + TSDP_LINE_O_USERNAME_DEFAULT, + TSDP_LINE_O_SESSION_ID_DEFAULT, + version, + "IN", + ipv6 ? "IP6" : "IP4", + addr)); + + /* RFC 3264 - 5 Generating the Initial Offer + The SDP "s=" line conveys the subject of the session, which is + reasonably defined for multicast, but ill defined for unicast. For + unicast sessions, it is RECOMMENDED that it consist of a single space + character (0x20) or a dash (-). + + Unfortunately, SDP does not allow the "s=" line to be empty. + */ + TSDP_MESSAGE_ADD_HEADER(ret, TSDP_HEADER_S_VA_ARGS(TSDP_LINE_S_VALUE_DEFAULT)); + + /* RFC 3264 - 5 Generating the Initial Offer + The SDP "t=" line conveys the time of the session. Generally, + streams for unicast sessions are created and destroyed through + external signaling means, such as SIP. In that case, the "t=" line + SHOULD have a value of "0 0". + */ + TSDP_MESSAGE_ADD_HEADER(ret, TSDP_HEADER_T_VA_ARGS(0, 0)); + + return ret; } tsdp_message_t* tsdp_message_clone(const tsdp_message_t *self) { - tsdp_message_t* clone = tsk_null; - tsk_list_item_t* item; - tsdp_header_t* header; + tsdp_message_t* clone = tsk_null; + tsk_list_item_t* item; + tsdp_header_t* header; - if(!self){ - goto bail; - } + if(!self) { + goto bail; + } - if((clone = tsdp_message_create())){ - tsk_list_foreach(item, self->headers){ - if((header = tsdp_header_clone(TSDP_HEADER(item->data)))){ - tsk_list_push_back_data(clone->headers, (void**)&header); - } - } - } + if((clone = tsdp_message_create())) { + tsk_list_foreach(item, self->headers) { + if((header = tsdp_header_clone(TSDP_HEADER(item->data)))) { + tsk_list_push_back_data(clone->headers, (void**)&header); + } + } + } bail: - return clone; + return clone; } int tsdp_message_add_media(tsdp_message_t *self, const char* media, uint32_t port, const char* proto, ...) { - va_list ap; - int ret; - - va_start(ap, proto); - ret = tsdp_message_add_media_2(self, media, port, proto, &ap); - va_end(ap); - - return ret; + va_list ap; + int ret; + + va_start(ap, proto); + ret = tsdp_message_add_media_2(self, media, port, proto, &ap); + va_end(ap); + + return ret; } int tsdp_message_add_media_2(tsdp_message_t *self, const char* media, uint32_t port, const char* proto, va_list *ap) { - int ret = -1; - tsdp_header_M_t* m; - - if(!self){ - return -1; - } - - if((m = tsdp_header_M_create(media, port, proto))){ - __add_headers(m, ap); - - ret = tsdp_message_add_header(self, TSDP_HEADER(m)); - TSK_OBJECT_SAFE_FREE(m); - } - - return ret; + int ret = -1; + tsdp_header_M_t* m; + + if(!self) { + return -1; + } + + if((m = tsdp_header_M_create(media, port, proto))) { + __add_headers(m, ap); + + ret = tsdp_message_add_header(self, TSDP_HEADER(m)); + TSK_OBJECT_SAFE_FREE(m); + } + + return ret; } int tsdp_message_remove_media(tsdp_message_t *self, const char* media) { - if(!self || !media){ - return 0; - } + if(!self || !media) { + return 0; + } - tsk_list_remove_item_by_pred(self->headers, __pred_find_media_by_name, media); - return 0; + tsk_list_remove_item_by_pred(self->headers, __pred_find_media_by_name, media); + return 0; } const tsdp_header_M_t* tsdp_message_find_media(const tsdp_message_t *self, const char* media) { - if(self && media){ - const tsk_list_item_t* item; - if((item = tsk_list_find_item_by_pred(self->headers, __pred_find_media_by_name, media))){ - return TSDP_HEADER_M(item->data); - } - } - return tsk_null; + if(self && media) { + const tsk_list_item_t* item; + if((item = tsk_list_find_item_by_pred(self->headers, __pred_find_media_by_name, media))) { + return TSDP_HEADER_M(item->data); + } + } + return tsk_null; } @@ -369,95 +369,95 @@ const tsdp_header_M_t* tsdp_message_find_media(const tsdp_message_t *self, const /* ================= 3GPP TS 34.610 :: Communication HOLD (HOLD) using IP Multimedia (IM) Core ================*/ int tsdp_message_hold(tsdp_message_t* self, const char* media) { - tsdp_header_M_t* M; - const tsk_list_item_t* item; - - if(!self){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - // 3GPP TS 34.610-900 - 4.5.2.1 Actions at the invoking UE - if((item = tsk_list_find_item_by_pred(self->headers, __pred_find_media_by_name, media))){ - M = TSDP_HEADER_M(item->data); - tsdp_header_M_hold(M, tsk_true); - } - - return 0; + tsdp_header_M_t* M; + const tsk_list_item_t* item; + + if(!self) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + // 3GPP TS 34.610-900 - 4.5.2.1 Actions at the invoking UE + if((item = tsk_list_find_item_by_pred(self->headers, __pred_find_media_by_name, media))) { + M = TSDP_HEADER_M(item->data); + tsdp_header_M_hold(M, tsk_true); + } + + return 0; } int tsdp_message_resume(tsdp_message_t* self, const char* media) { - tsdp_header_M_t* M; - const tsk_list_item_t* item; - - if(!self){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - // 3GPP TS 34.610-900 - 4.5.2.1 Actions at the invoking UE - if((item = tsk_list_find_item_by_pred(self->headers, __pred_find_media_by_name, media))){ - M = TSDP_HEADER_M(item->data); - tsdp_header_M_resume(M, tsk_true); - } - - return 0; + tsdp_header_M_t* M; + const tsk_list_item_t* item; + + if(!self) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + // 3GPP TS 34.610-900 - 4.5.2.1 Actions at the invoking UE + if((item = tsk_list_find_item_by_pred(self->headers, __pred_find_media_by_name, media))) { + M = TSDP_HEADER_M(item->data); + tsdp_header_M_resume(M, tsk_true); + } + + return 0; } tsk_bool_t tsdp_message_is_ice_enabled(const tsdp_message_t *self, tsk_size_t media_index) { - if (self) { - const tsdp_header_A_t *A; - const tsdp_header_M_t *M; - tsk_bool_t have_ufrag = tsk_false, have_pwd = tsk_false, have_candidates = tsk_false; - tsk_size_t index0 = 0; - - // session level attributes - if ((A = tsdp_message_get_headerA(self, "ice-ufrag"))) { - have_ufrag = tsk_true; - } - if ((A = tsdp_message_get_headerA(self, "ice-pwd"))) { - have_pwd = tsk_true; - } - while ((M = (const tsdp_header_M_t*)tsdp_message_get_headerAt(self, tsdp_htype_M, index0))) { - if (index0 == media_index) { - if ((A = tsdp_header_M_findA(M, "ice-ufrag"))) { - have_ufrag = tsk_true; - } - if ((A = tsdp_header_M_findA(M, "ice-pwd"))) { - have_pwd = tsk_true; - } - have_candidates = (tsdp_header_M_findA_at(M, "candidate", 0) != tsk_null); - return have_ufrag && have_pwd && have_candidates; - } - ++index0; - } - } - return tsk_false; + if (self) { + const tsdp_header_A_t *A; + const tsdp_header_M_t *M; + tsk_bool_t have_ufrag = tsk_false, have_pwd = tsk_false, have_candidates = tsk_false; + tsk_size_t index0 = 0; + + // session level attributes + if ((A = tsdp_message_get_headerA(self, "ice-ufrag"))) { + have_ufrag = tsk_true; + } + if ((A = tsdp_message_get_headerA(self, "ice-pwd"))) { + have_pwd = tsk_true; + } + while ((M = (const tsdp_header_M_t*)tsdp_message_get_headerAt(self, tsdp_htype_M, index0))) { + if (index0 == media_index) { + if ((A = tsdp_header_M_findA(M, "ice-ufrag"))) { + have_ufrag = tsk_true; + } + if ((A = tsdp_header_M_findA(M, "ice-pwd"))) { + have_pwd = tsk_true; + } + have_candidates = (tsdp_header_M_findA_at(M, "candidate", 0) != tsk_null); + return have_ufrag && have_pwd && have_candidates; + } + ++index0; + } + } + return tsk_false; } tsk_bool_t tsdp_message_is_ice_restart(const tsdp_message_t *self, tsk_size_t media_index) { - // https://tools.ietf.org/html/rfc5245#section-9.1.1.1 - if (self) { - const tsdp_header_C_t *C; - const tsdp_header_M_t *M; - tsk_size_t index0 = 0; - - // Session level - if ((C = (const tsdp_header_C_t*)tsdp_message_get_header(self, tsdp_htype_C)) && C->addr){ - if (tsk_striequals("0.0.0.0", C->addr)) { - return tsk_true; - } - } - // Media level - while ((M = (const tsdp_header_M_t*)tsdp_message_get_headerAt(self, tsdp_htype_M, index0))) { - if (index0 == media_index) { - return (M->C && M->C->addr && tsk_striequals("0.0.0.0", M->C->addr)); - } - ++index0; - } - } - return tsk_false; + // https://tools.ietf.org/html/rfc5245#section-9.1.1.1 + if (self) { + const tsdp_header_C_t *C; + const tsdp_header_M_t *M; + tsk_size_t index0 = 0; + + // Session level + if ((C = (const tsdp_header_C_t*)tsdp_message_get_header(self, tsdp_htype_C)) && C->addr) { + if (tsk_striequals("0.0.0.0", C->addr)) { + return tsk_true; + } + } + // Media level + while ((M = (const tsdp_header_M_t*)tsdp_message_get_headerAt(self, tsdp_htype_M, index0))) { + if (index0 == media_index) { + return (M->C && M->C->addr && tsk_striequals("0.0.0.0", M->C->addr)); + } + ++index0; + } + } + return tsk_false; } @@ -477,27 +477,26 @@ tsk_bool_t tsdp_message_is_ice_restart(const tsdp_message_t *self, tsk_size_t me // static void* tsdp_message_ctor(void * self, va_list * app) { - tsdp_message_t *message = self; - if(message){ - message->headers = tsk_list_create(); - } - return self; + tsdp_message_t *message = self; + if(message) { + message->headers = tsk_list_create(); + } + return self; } static void* tsdp_message_dtor(void * self) -{ - tsdp_message_t *message = self; - if(message){ - TSK_OBJECT_SAFE_FREE(message->headers); - } - return self; +{ + tsdp_message_t *message = self; + if(message) { + TSK_OBJECT_SAFE_FREE(message->headers); + } + return self; } -static const tsk_object_def_t tsdp_message_def_s = -{ - sizeof(tsdp_message_t), - tsdp_message_ctor, - tsdp_message_dtor, - tsk_null, +static const tsk_object_def_t tsdp_message_def_s = { + sizeof(tsdp_message_t), + tsdp_message_ctor, + tsdp_message_dtor, + tsk_null, }; const tsk_object_def_t *tsdp_message_def_t = &tsdp_message_def_s; |