summaryrefslogtreecommitdiffstats
path: root/tinyDEMO/subscribe.c
diff options
context:
space:
mode:
Diffstat (limited to 'tinyDEMO/subscribe.c')
-rwxr-xr-xtinyDEMO/subscribe.c174
1 files changed, 85 insertions, 89 deletions
diff --git a/tinyDEMO/subscribe.c b/tinyDEMO/subscribe.c
index 54a0375..60626a5 100755
--- a/tinyDEMO/subscribe.c
+++ b/tinyDEMO/subscribe.c
@@ -2,19 +2,19 @@
* Copyright (C) 2009 Mamadou Diop.
*
* Contact: Mamadou Diop <diopmamadou(at)doubango.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.
*
@@ -26,104 +26,100 @@ extern const session_t* session_handle_cmd(cmd_type_t , const opts_L_t*);
int subscribe_handle_event(const tsip_event_t *_event)
{
- const tsip_subscribe_event_t* sub_event = TSIP_SUBSCRIBE_EVENT(_event);
- const session_t* session;
- tsip_ssession_id_t sid;
+ const tsip_subscribe_event_t* sub_event = TSIP_SUBSCRIBE_EVENT(_event);
+ const session_t* session;
+ tsip_ssession_id_t sid;
+
+ /* Find associated session */
+ sid = tsip_ssession_get_id(_event->ss);
+ if(!(session = session_get_by_sid(ctx->sessions, sid))) {
+ TSK_DEBUG_WARN("Failed to match session event.");
+ return -1;
+ }
+
- /* Find associated session */
- sid = tsip_ssession_get_id(_event->ss);
- if(!(session = session_get_by_sid(ctx->sessions, sid))){
- TSK_DEBUG_WARN("Failed to match session event.");
- return -1;
- }
-
+ switch(sub_event->type) {
+ case tsip_ao_subscribe: { /* Answer to outgoing SUBSCRIBE */
+ if(_event->sipmessage) {
+ if(TSIP_MESSAGE_IS_RESPONSE(_event->sipmessage)) {
+ TSK_DEBUG_INFO("Event: Answer to outgoing SUBSCRIBE. Code=%d and phrase=%s",
+ _event->sipmessage->line.response.status_code, _event->sipmessage->line.response.reason_phrase);
+ }
+ else {
+ // request
+ }
+ }
+ break;
+ }
- switch(sub_event->type){
- case tsip_ao_subscribe: /* Answer to outgoing SUBSCRIBE */
- {
- if(_event->sipmessage){
- if(TSIP_MESSAGE_IS_RESPONSE(_event->sipmessage)){
- TSK_DEBUG_INFO("Event: Answer to outgoing SUBSCRIBE. Code=%d and phrase=%s",
- _event->sipmessage->line.response.status_code, _event->sipmessage->line.response.reason_phrase);
- }
- else{
- // request
- }
- }
- break;
- }
-
- case tsip_ao_unsubscribe: /* Answer to outgoing unSUBSCRIBE */
- {
- if(_event->sipmessage){
- if(TSIP_MESSAGE_IS_RESPONSE(_event->sipmessage)){
- TSK_DEBUG_INFO("Event: Answer to outgoing unSUBSCRIBE. Code=%d and phrase=%s",
- _event->sipmessage->line.response.status_code, _event->sipmessage->line.response.reason_phrase);
- }
- else{
- // request
- }
- }
- break;
- }
+ case tsip_ao_unsubscribe: { /* Answer to outgoing unSUBSCRIBE */
+ if(_event->sipmessage) {
+ if(TSIP_MESSAGE_IS_RESPONSE(_event->sipmessage)) {
+ TSK_DEBUG_INFO("Event: Answer to outgoing unSUBSCRIBE. Code=%d and phrase=%s",
+ _event->sipmessage->line.response.status_code, _event->sipmessage->line.response.reason_phrase);
+ }
+ else {
+ // request
+ }
+ }
+ break;
+ }
- case tsip_i_notify: /* Incoming NOTIFY */
- {
- TSK_DEBUG_INFO("Event: Incoming NOTIFY.");
- if(TSIP_MESSAGE_HAS_CONTENT(_event->sipmessage)){
- const tsk_buffer_t* content = TSIP_MESSAGE_CONTENT(_event->sipmessage);
- TSK_DEBUG_INFO("NOTIFY Content-Type: %s", TSIP_MESSAGE_CONTENT_TYPE(_event->sipmessage));
- TSK_DEBUG_INFO("NOTIFY Content: %s", content->data);
- }
- break;
- }
+ case tsip_i_notify: { /* Incoming NOTIFY */
+ TSK_DEBUG_INFO("Event: Incoming NOTIFY.");
+ if(TSIP_MESSAGE_HAS_CONTENT(_event->sipmessage)) {
+ const tsk_buffer_t* content = TSIP_MESSAGE_CONTENT(_event->sipmessage);
+ TSK_DEBUG_INFO("NOTIFY Content-Type: %s", TSIP_MESSAGE_CONTENT_TYPE(_event->sipmessage));
+ TSK_DEBUG_INFO("NOTIFY Content: %s", content->data);
+ }
+ break;
+ }
- /* Server events (For whose dev. Server Side IMS Services) */
- case tsip_i_subscribe: /* Incoming SUBSCRIBE */
- case tsip_i_unsubscribe: /* Incoming unSUBSCRIBE */
- {
- TSK_DEBUG_WARN("Event not support by Client Framework.");
- break;
- }
+ /* Server events (For whose dev. Server Side IMS Services) */
+ case tsip_i_subscribe: /* Incoming SUBSCRIBE */
+ case tsip_i_unsubscribe: { /* Incoming unSUBSCRIBE */
+ TSK_DEBUG_WARN("Event not support by Client Framework.");
+ break;
+ }
- default:
- { /* Any other event */
- TSK_DEBUG_WARN("%d not a valid SIP Subscription event.", sub_event->type);
- break;
- }
- }
+ default: {
+ /* Any other event */
+ TSK_DEBUG_WARN("%d not a valid SIP Subscription event.", sub_event->type);
+ break;
+ }
+ }
- return 0;
+ return 0;
}
tsip_ssession_id_t subscribe_handle_cmd(cmd_type_t cmd, const opts_L_t* opts)
{
- const session_t* session = tsk_null;
- tsip_ssession_id_t id = TSIP_SSESSION_INVALID_ID;
+ const session_t* session = tsk_null;
+ tsip_ssession_id_t id = TSIP_SSESSION_INVALID_ID;
- if(!(session = session_handle_cmd(cmd, opts))){
- goto bail;
- }
- else{
- id = tsip_ssession_get_id(session->handle);
- }
+ if(!(session = session_handle_cmd(cmd, opts))) {
+ goto bail;
+ }
+ else {
+ id = tsip_ssession_get_id(session->handle);
+ }
- switch(cmd){
- case cmd_subscribe:
- { /* Send SIP SUBSCRIBE */
- tsip_action_handle_t* action_config = action_get_config(opts);
- tsip_api_subscribe_send_subscribe(session->handle,
- TSIP_ACTION_SET_CONFIG(action_config),
- /* Any other TSIP_ACTION_SET_*() macros */
- TSIP_ACTION_SET_NULL());
- TSK_OBJECT_SAFE_FREE(action_config);
- break;
- }
- default:
- /* already handled by session_handle_cmd() */
- break;
- }
+ switch(cmd) {
+ case cmd_subscribe: {
+ /* Send SIP SUBSCRIBE */
+ tsip_action_handle_t* action_config = action_get_config(opts);
+ tsip_api_subscribe_send_subscribe(session->handle,
+ TSIP_ACTION_SET_CONFIG(action_config),
+ /* Any other TSIP_ACTION_SET_*() macros */
+ TSIP_ACTION_SET_NULL());
+ TSK_OBJECT_SAFE_FREE(action_config);
+ break;
+ }
+ default:
+ /* already handled by session_handle_cmd() */
+ break;
+ }
bail:
- return id;
+ return id;
}
OpenPOWER on IntegriCloud