diff options
Diffstat (limited to 'tinySIP/src/tsip_action.c')
| -rwxr-xr-x | tinySIP/src/tsip_action.c | 317 |
1 files changed, 158 insertions, 159 deletions
diff --git a/tinySIP/src/tsip_action.c b/tinySIP/src/tsip_action.c index d34235b..a5d2feb 100755 --- a/tinySIP/src/tsip_action.c +++ b/tinySIP/src/tsip_action.c @@ -2,19 +2,19 @@ * Copyright (C) 2010-2011 Mamadou Diop. * * Contact: Mamadou Diop <diopmamadou(at)doubango[dot]org> -* +* * This file is part of Open Source Doubango Framework. * * DOUBANGO is free software: you can redistribute it and/or modify * 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. * @@ -70,14 +70,14 @@ TSK_OBJECT_SAFE_FREE(handle); */ tsip_action_handle_t* tsip_action_create(tsip_action_type_t type, ...) { - va_list ap; - tsip_action_t* handle; - - va_start(ap, type); - handle = _tsip_action_create(type, &ap); - va_end(ap); - - return handle; + va_list ap; + tsip_action_t* handle; + + va_start(ap, type); + handle = _tsip_action_create(type, &ap); + va_end(ap); + + return handle; } /**@ingroup tsip_action_group @@ -100,143 +100,143 @@ TSK_OBJECT_SAFE_FREE(handle); */ int tsip_action_set(tsip_action_handle_t* self, ...) { - int ret; - va_list ap; - - va_start(ap, self); - ret = _tsip_action_set(self, &ap); - va_end(ap); - - return ret; + int ret; + va_list ap; + + va_start(ap, self); + ret = _tsip_action_set(self, &ap); + va_end(ap); + + return ret; } /** internal fuction used to config a SIP action */ int _tsip_action_set(tsip_action_handle_t* self, va_list* app) { - tsip_action_param_type_t curr; - tsip_action_t* action = self; - - if(!action){ /* Nothing to do */ - return 0; - } - - while((curr = va_arg(*app, tsip_action_param_type_t)) != aptype_null){ - - switch(curr){ - case aptype_header: - { /* (const char*)NAME_STR, (const char*)VALUE_STR */ - const char* name = va_arg(*app, const char *); - const char* value = va_arg(*app, const char *); - - tsk_params_add_param(&action->headers, name, value); - break; - } - case aptype_config: - { /* (const tsip_action_handle_t*)ACTION_CONFIG_HANDLE */ - const tsip_action_t* handle = va_arg(*app, const tsip_action_handle_t *); - if(handle && handle->type == tsip_atype_config){ - /* Copy headers */ - if(!TSK_LIST_IS_EMPTY(handle->headers)){ - tsk_list_pushback_list(action->headers, handle->headers); - } - /* Copy payload */ - if(handle->payload && handle->payload->data && handle->payload->size){ - TSK_OBJECT_SAFE_FREE(action->payload); - action->payload = tsk_buffer_create(handle->payload->data, handle->payload->size); - } - /* Copy resp line */ - action->line_resp.code = handle->line_resp.code; - tsk_strupdate(&action->line_resp.phrase, handle->line_resp.phrase); - /* Copy media type */ - action->media.type = handle->media.type; - /* Copy media params */ - if(!TSK_LIST_IS_EMPTY(handle->media.params)){ - if(!action->media.params){ - action->media.params = tmedia_params_create(); - } - tsk_list_pushback_list(action->media.params, handle->media.params); - } - } - else if(handle){ /* Only invalid type should cause error */ - TSK_DEBUG_ERROR("Invalid action configuration handle."); - return -2; - } - break; - } - case aptype_payload: - { /* (const void*)PAY_PTR, (tsk_size_t)PAY_SIZE */ - const void* payload = va_arg(*app, const void *); - tsk_size_t size = va_arg(*app, tsk_size_t); - if(payload && size){ - TSK_OBJECT_SAFE_FREE(action->payload); - action->payload = tsk_buffer_create(payload, size); - } - break; - } - - case aptype_resp_line: - { /* (int32_t)CODE_INT, (const char*)PHRASE_STR */ - int32_t code = va_arg(*app, int32_t); - const char* phrase = va_arg(*app, const void *); - action->line_resp.code = (short)code; - tsk_strupdate(&action->line_resp.phrase, phrase); - break; - } - - case aptype_media_type: - { /* (enum tmedia_type_e)TYPE_ENUM */ - action->media.type = va_arg(*app, tmedia_type_t); - break; - } - - case aptype_media: - { /* ... */ - tmedia_params_L_t* params; - if((params = tmedia_params_create_2(app))){ - if(action->media.params){ - tsk_list_pushback_list(action->media.params, params); - } - else{ - action->media.params = tsk_object_ref(params); - } - TSK_OBJECT_SAFE_FREE(params); - } - break; - } - - default: - { /* va_list will be unsafe ==> exit */ - TSK_DEBUG_ERROR("NOT SUPPORTED."); - return -3; - } - } /* switch */ - } /* while */ - - return 0; + tsip_action_param_type_t curr; + tsip_action_t* action = self; + + if(!action) { /* Nothing to do */ + return 0; + } + + while((curr = va_arg(*app, tsip_action_param_type_t)) != aptype_null) { + + switch(curr) { + case aptype_header: { + /* (const char*)NAME_STR, (const char*)VALUE_STR */ + const char* name = va_arg(*app, const char *); + const char* value = va_arg(*app, const char *); + + tsk_params_add_param(&action->headers, name, value); + break; + } + case aptype_config: { + /* (const tsip_action_handle_t*)ACTION_CONFIG_HANDLE */ + const tsip_action_t* handle = va_arg(*app, const tsip_action_handle_t *); + if(handle && handle->type == tsip_atype_config) { + /* Copy headers */ + if(!TSK_LIST_IS_EMPTY(handle->headers)) { + tsk_list_pushback_list(action->headers, handle->headers); + } + /* Copy payload */ + if(handle->payload && handle->payload->data && handle->payload->size) { + TSK_OBJECT_SAFE_FREE(action->payload); + action->payload = tsk_buffer_create(handle->payload->data, handle->payload->size); + } + /* Copy resp line */ + action->line_resp.code = handle->line_resp.code; + tsk_strupdate(&action->line_resp.phrase, handle->line_resp.phrase); + /* Copy media type */ + action->media.type = handle->media.type; + /* Copy media params */ + if(!TSK_LIST_IS_EMPTY(handle->media.params)) { + if(!action->media.params) { + action->media.params = tmedia_params_create(); + } + tsk_list_pushback_list(action->media.params, handle->media.params); + } + } + else if(handle) { /* Only invalid type should cause error */ + TSK_DEBUG_ERROR("Invalid action configuration handle."); + return -2; + } + break; + } + case aptype_payload: { + /* (const void*)PAY_PTR, (tsk_size_t)PAY_SIZE */ + const void* payload = va_arg(*app, const void *); + tsk_size_t size = va_arg(*app, tsk_size_t); + if(payload && size) { + TSK_OBJECT_SAFE_FREE(action->payload); + action->payload = tsk_buffer_create(payload, size); + } + break; + } + + case aptype_resp_line: { + /* (int32_t)CODE_INT, (const char*)PHRASE_STR */ + int32_t code = va_arg(*app, int32_t); + const char* phrase = va_arg(*app, const void *); + action->line_resp.code = (short)code; + tsk_strupdate(&action->line_resp.phrase, phrase); + break; + } + + case aptype_media_type: { + /* (enum tmedia_type_e)TYPE_ENUM */ + action->media.type = va_arg(*app, tmedia_type_t); + break; + } + + case aptype_media: { + /* ... */ + tmedia_params_L_t* params; + if((params = tmedia_params_create_2(app))) { + if(action->media.params) { + tsk_list_pushback_list(action->media.params, params); + } + else { + action->media.params = tsk_object_ref(params); + } + TSK_OBJECT_SAFE_FREE(params); + } + break; + } + + default: { + /* va_list will be unsafe ==> exit */ + TSK_DEBUG_ERROR("NOT SUPPORTED."); + return -3; + } + } /* switch */ + } /* while */ + + return 0; } /** internal function used to create new SIP action */ tsip_action_t* _tsip_action_create(tsip_action_type_t type, va_list* app) { - tsip_action_t* action = tsk_null; - - /* create the action */ - if(!(action = tsk_object_new(tsip_action_def_t))){ - TSK_DEBUG_ERROR("Failed to create new SIP action."); - return tsk_null; - } - else{ - action->type = type; - } - - /* configure the action */ - if(_tsip_action_set(action, app)){ - TSK_DEBUG_ERROR("Invalid parameter"); - TSK_OBJECT_SAFE_FREE(action); - } - - return action; + tsip_action_t* action = tsk_null; + + /* create the action */ + if(!(action = tsk_object_new(tsip_action_def_t))) { + TSK_DEBUG_ERROR("Failed to create new SIP action."); + return tsk_null; + } + else { + action->type = type; + } + + /* configure the action */ + if(_tsip_action_set(action, app)) { + TSK_DEBUG_ERROR("Invalid parameter"); + TSK_OBJECT_SAFE_FREE(action); + } + + return action; } @@ -248,36 +248,35 @@ tsip_action_t* _tsip_action_create(tsip_action_type_t type, va_list* app) // static tsk_object_t* tsip_action_ctor(tsk_object_t * self, va_list * app) { - tsip_action_t *action = self; - if(action){ - action->headers = tsk_list_create(); - action->media.type = tmedia_none; - } - return self; + tsip_action_t *action = self; + if(action) { + action->headers = tsk_list_create(); + action->media.type = tmedia_none; + } + return self; } static tsk_object_t* tsip_action_dtor(tsk_object_t * self) -{ - tsip_action_t *action = self; - if(action){ - TSK_OBJECT_SAFE_FREE(action->headers); - TSK_OBJECT_SAFE_FREE(action->payload); +{ + tsip_action_t *action = self; + if(action) { + TSK_OBJECT_SAFE_FREE(action->headers); + TSK_OBJECT_SAFE_FREE(action->payload); - TSK_OBJECT_SAFE_FREE(action->media.params); + TSK_OBJECT_SAFE_FREE(action->media.params); - TSK_FREE(action->line_resp.phrase); + TSK_FREE(action->line_resp.phrase); - TSK_FREE(action->ect.to); - } + TSK_FREE(action->ect.to); + } - return self; + return self; } -static const tsk_object_def_t tsip_action_def_s = -{ - sizeof(tsip_action_t), - tsip_action_ctor, - tsip_action_dtor, - tsk_null, +static const tsk_object_def_t tsip_action_def_s = { + sizeof(tsip_action_t), + tsip_action_ctor, + tsip_action_dtor, + tsk_null, }; const tsk_object_def_t *tsip_action_def_t = &tsip_action_def_s; |
