- Freeswitch-trunk - FreeSWITCH Mailing Lists

[commit] r3049 - freeswitch/trunk
by Freeswitch SVN 15 Oct '06

15 Oct '06

Author: anthm Date: Sat Oct 14 21:32:44 2006 New Revision: 3049 Modified: freeswitch/trunk/.indent.pro Log: update .indent.pro Modified: freeswitch/trunk/.indent.pro ============================================================================== --- freeswitch/trunk/.indent.pro (original) +++ freeswitch/trunk/.indent.pro Sat Oct 14 21:32:44 2006 @@ -1 +1 @@ --brs -npsl -di0 -br -ce -d0 -cli0 -npcs -nfc1 -ut -i4 -ts4 -l120 -cs -T size_t -T pieces -T switch_file_t -T switch_thread_cond_t -T switch_thread -T switch_threadattr_t -T switch_thread_start_t -T switch_socket_t -T switch_sockaddr_t -T switch_memory_pool -T switch_pollfd_t -T switch_pollset_t -T switch_time_t -T switch_time_exp_t -T switch_hash -T switch_hash_index_t -T switch_strmatch_pattern -T switch_uuid_t -T switch_queue_t -T switch_mutex_t -T __int8 -T __int16 -T __int32 -T __int64 -T int8_t -T int16_t -T int32_t -T int64_t -T long -T switch_core_db -T switch_core_session_message -T switch_audio_resampler -T switch_event_header -T switch_event -T switch_event_subclass -T switch_event_node -T switch_loadable_module -T switch_frame -T switch_channel -T switch_endpoint_interface -T switch_timer_interface -T switch_dialplan_interface -T switch_codec_interface -T switch_application_interface -T switch_api_interface -T switch_file_interface -T switch_file_handle -T switch_core_session -T switch_loadable_module_interface -T switch_caller_profile -T switch_caller_step -T switch_caller_extension -T switch_caller_application -T switch_event_handler_table -T switch_timer -T switch_codec -T switch_core_thread_session -T switch_codec_implementation -T switch_io_event_hook_outgoing_channel -T switch_io_event_hook_answer_channel -T switch_io_event_hook_receive_message -T switch_io_event_hook_read_frame -T switch_io_event_hook_write_frame -T switch_io_event_hook_kill_channel -T switch_io_event_hook_waitfor_read -T switch_io_event_hook_waitfor_write -T switch_io_event_hook_send_dtmf -T switch_io_routines -T switch_io_event_hooks -T switch_buffer -T switch_codec_settings -T switch_config -T switch_lock_flag -T switch_core_session_message_t -T switch_stack_t -T switch_status -T switch_text_channel -T switch_channel_state -T switch_channel_flag -T switch_signal -T switch_codec_flag -T switch_codec_type -T switch_timer_flag -T switch_file_flag -T switch_io_flag -T switch_event_t \ No newline at end of file +-brs -npsl -di0 -br -ce -d0 -cli0 -npcs -nfc1 -ut -i4 -ts4 -l120 -cs -T size_t -T pieces -T swtich_size_t -T switch_int16_t -T switch_size_t -T switch_file_t -T switch_thread_cond_t -T switch_thread_id_t -T switch_thread_t -T switch_threadattr_t -T switch_thread_start_t -T switch_socket_t -T switch_sockaddr_t -T switch_port_t -T switch_memory_pool_t -T switch_pollfd_t -T switch_pollset_t -T switch_time_t -T switch_interval_time_t -T switch_time_exp_t -T switch_hash_t -T switch_hash_index_t -T switch_strmatch_pattern -T switch_uuid_t -T switch_queue_t -T switch_thread_rwlock_t -T switch_mutex_t -T switch_channel_timetable -T __int8 -T __int16 -T __int32 -T __int64 -T int8_t -T int16_t -T int32_t -T int64_t -T long -T switch_core_db_t -T switch_core_db_stmt_t -T switch_byte_t -T switch_directories -T switch_payload_t -T switch_rtp -T switch_core_session_message -T switch_event_header -T switch_event -T switch_event_subclass -T switch_event_node -T switch_loadable_module -T switch_frame -T switch_channel -T switch_file_handle -T switch_core_session -T switch_caller_profile -T switch_caller_extension -T switch_caller_application -T switch_state_handler_table -T switch_timer -T switch_codec -T switch_core_thread_session -T switch_codec_implementation -T switch_buffer -T switch_codec_settings -T switch_config -T switch_io_event_hook_outgoing_channel -T switch_io_event_hook_answer_channel -T switch_io_event_hook_receive_message -T switch_io_event_hook_receive_event -T switch_io_event_hook_read_frame -T switch_io_event_hook_write_frame -T switch_io_event_hook_kill_channel -T switch_io_event_hook_waitfor_read -T switch_io_event_hook_waitfor_write -T switch_io_event_hook_send_dtmf -T switch_io_routines -T switch_io_event_hooks -T switch_speech_handle -T switch_directory_handle -T switch_loadable_module_interface -T switch_endpoint_interface -T switch_timer_interface -T switch_dialplan_interface -T switch_codec_interface -T switch_application_interface -T switch_api_interface -T switch_file_interface -T switch_speech_interface -T switch_directory_interface -T switch_core_port_allocator -T switch_media_bug -T switch_stream_handle -T switch_core_time_duration -T switch_log_node_t -T switch_audio_resampler_t -T switch_stun_message_t -T switch_stun_attribute_t -T switch_stun_error_t -T switch_stun_type_t -T switch_stun_packet_header_t -T switch_stun_packet_attribute_t -T switch_stun_packet_t -T switch_stun_ip_t -T switch_bitpack_mode_t -T switch_abc_type_t -T switch_bitpack_t -T switch_audio_col_t -T switch_xml_section_t -T switch_vad_flag_t -T switch_rtp_flag_t -T switch_priority_t -T switch_ivr_option_t -T switch_core_session_message_types_t -T switch_stack_t -T switch_status_t -T switch_log_level_t -T switch_text_channel_t -T switch_core_session_message_flag_t -T switch_channel_state_t -T switch_channel_flag_t -T switch_frame_flag_t -T switch_signal_t -T switch_codec_flag_t -T switch_speech_flag_t -T switch_directory_flag_t -T switch_codec_type_t -T switch_timer_flag_t -T switch_file_flag_t -T switch_io_flag_t -T switch_event_types_t -T switch_input_type_t -T switch_call_cause_t -T switch_session_ctl_t -T switch_xml_flag_t \ No newline at end of file

1 0

[commit] r3045 - freeswitch/trunk/src/mod/event_handlers/mod_event_socket
by Freeswitch SVN 13 Oct '06

13 Oct '06

Author: anthm Date: Fri Oct 13 10:32:38 2006 New Revision: 3045 Modified: freeswitch/trunk/src/mod/event_handlers/mod_event_socket/mod_event_socket.c Log: dont write nulls in event_socket Modified: freeswitch/trunk/src/mod/event_handlers/mod_event_socket/mod_event_socket.c ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_event_socket/mod_event_socket.c (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_event_socket/mod_event_socket.c Fri Oct 13 10:32:38 2006 @@ -327,9 +327,9 @@ if (data) { snprintf(buf, sizeof(buf), "Content-Type: log/data\nContent-Length: %"APR_SSIZE_T_FMT"\n\n", strlen(data)); - len = strlen(buf) + 1; + len = strlen(buf); switch_socket_send(listener->sock, buf, &len); - len = strlen(data) + 1; + len = strlen(data); switch_socket_send(listener->sock, data, &len); free(data); @@ -367,16 +367,16 @@ } } - len = strlen(packet) + 1; + len = strlen(packet); snprintf(hbuf, sizeof(hbuf), "Content-Length: %"APR_SSIZE_T_FMT"\n" "Content-Type: text/event-%s\n" "\n", len, etype); - len = strlen(hbuf) + 1; + len = strlen(hbuf); switch_socket_send(listener->sock, hbuf, &len); - len = strlen(packet) + 1; + len = strlen(packet); switch_socket_send(listener->sock, packet, &len); if (xmlstr) { @@ -430,11 +430,11 @@ } else { switch_size_t len; char buf[1024]; - len = strlen(stream.data) + 1; + len = strlen(stream.data); snprintf(buf, sizeof(buf), "Content-Type: api/response\nContent-Length: %"APR_SSIZE_T_FMT"\n\n", len); - len = strlen(buf) + 1; + len = strlen(buf); switch_socket_send(acs->listener->sock, buf, &len); - len = strlen(stream.data) + 1; + len = strlen(stream.data); switch_socket_send(acs->listener->sock, stream.data, &len); } } @@ -781,7 +781,7 @@ snprintf(buf, sizeof(buf), "Content-Type: auth/request\n\n"); - len = strlen(buf) + 1; + len = strlen(buf); switch_socket_send(listener->sock, buf, &len); @@ -800,7 +800,7 @@ } if (!switch_strlen_zero(reply)) { snprintf(buf, sizeof(buf), "Content-Type: command/reply\nReply-Text: %s\n\n", reply); - len = strlen(buf) + 1; + len = strlen(buf); switch_socket_send(listener->sock, buf, &len); } break; @@ -830,7 +830,7 @@ if (!switch_strlen_zero(reply)) { snprintf(buf, sizeof(buf), "Content-Type: command/reply\nReply-Text: %s\n\n", reply); - len = strlen(buf) + 1; + len = strlen(buf); switch_socket_send(listener->sock, buf, &len); }

1 0

[commit] r3043 - in freeswitch/trunk/src: . include mod/endpoints/mod_sofia
by Freeswitch SVN 12 Oct '06

12 Oct '06

Author: anthm Date: Thu Oct 12 16:37:08 2006 New Revision: 3043 Modified: freeswitch/trunk/src/include/switch_types.h freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c freeswitch/trunk/src/switch_rtp.c Log: in the name of interop Modified: freeswitch/trunk/src/include/switch_types.h ============================================================================== --- freeswitch/trunk/src/include/switch_types.h (original) +++ freeswitch/trunk/src/include/switch_types.h Thu Oct 12 16:37:08 2006 @@ -182,6 +182,7 @@ SWITCH_RTP_FLAG_BREAK - Stop what you are doing and return SWITCH_STATUS_BREAK SWITCH_RTP_FLAG_MINI - Use mini RTP when possible SWITCH_RTP_FLAG_DATAWAIT - Do not return from reads unless there is data even when non blocking + SWITCH_RTP_FLAG_BUGGY_2833 - Emulate the bug in cisco equipment to allow interop </pre> */ typedef enum { @@ -196,7 +197,8 @@ SWITCH_RTP_FLAG_VAD = (1 << 8), SWITCH_RTP_FLAG_BREAK = ( 1 << 9), SWITCH_RTP_FLAG_MINI = ( 1 << 10), - SWITCH_RTP_FLAG_DATAWAIT = (1 << 11) + SWITCH_RTP_FLAG_DATAWAIT = (1 << 11), + SWITCH_RTP_FLAG_BUGGY_2833 = (1 << 12) } switch_rtp_flag_t; /*! Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Thu Oct 12 16:37:08 2006 @@ -142,7 +142,8 @@ TFLAG_REFER = (1 << 17), TFLAG_NOHUP = (1 << 18), TFLAG_XFER = (1 << 19), - TFLAG_NOMEDIA = (1 << 20) + TFLAG_NOMEDIA = (1 << 20), + TFLAG_BUGGY_2833 = (1 << 21) } TFLAGS; static struct { @@ -275,6 +276,7 @@ char *key; char *xferto; char *kick; + char *origin; unsigned long rm_rate; switch_payload_t pt; switch_mutex_t *flag_mutex; @@ -1226,6 +1228,10 @@ flags = (switch_rtp_flag_t) (SWITCH_RTP_FLAG_RAW_WRITE | SWITCH_RTP_FLAG_AUTOADJ | SWITCH_RTP_FLAG_DATAWAIT); + if (switch_test_flag(tech_pvt, TFLAG_BUGGY_2833)) { + flags |= SWITCH_RTP_FLAG_BUGGY_2833; + } + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "RTP [%s] %s:%d->%s:%d codec: %u ms: %d\n", switch_channel_get_name(channel), tech_pvt->local_sdp_audio_ip, @@ -1822,6 +1828,13 @@ tech_pvt = switch_core_session_get_private(session); assert(tech_pvt != NULL); + if ((tech_pvt->origin = switch_core_session_strdup(session, (char *) sdp->sdp_origin->o_username))) { + if (strstr(tech_pvt->origin, "CiscoSystemsSIP-GW-UserAgent")) { + switch_set_flag_locked(tech_pvt, TFLAG_BUGGY_2833); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Activate Buggy RFC2833 Mode!\n"); + } + } + for (m = sdp->sdp_media; m ; m = m->m_next) { if (m->m_type == sdp_media_audio) { sdp_rtpmap_t *map; Modified: freeswitch/trunk/src/switch_rtp.c ============================================================================== --- freeswitch/trunk/src/switch_rtp.c (original) +++ freeswitch/trunk/src/switch_rtp.c Thu Oct 12 16:37:08 2006 @@ -732,7 +732,7 @@ switch_rtp_write_manual(rtp_session, rtp_session->dtmf_data.out_digit_packet, 4, - 1, + switch_test_flag(rtp_session, SWITCH_RTP_FLAG_BUGGY_2833) ? 0 : 1, rtp_session->te, rtp_session->dtmf_data.timestamp_dtmf, rtp_session->dtmf_data.out_digit_seq++,

1 0

[commit] r3041 - in freeswitch/trunk: conf src/mod/endpoints/mod_dingaling
by Freeswitch SVN 12 Oct '06

12 Oct '06

Author: anthm Date: Thu Oct 12 10:06:09 2006 New Revision: 3041 Modified: freeswitch/trunk/conf/freeswitch.xml freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c Log: add auto-reply option to dingaling to allow the gateway bot to auto-reply to chat msgs recieved outside the context of a call Modified: freeswitch/trunk/conf/freeswitch.xml ============================================================================== --- freeswitch/trunk/conf/freeswitch.xml (original) +++ freeswitch/trunk/conf/freeswitch.xml Thu Oct 12 10:06:09 2006 @@ -278,6 +278,7 @@ <param name="message" value="Jingle all the way"/> <param name="rtp-ip" value="10.0.0.1"/> <param name="auto-login" value="true"/> + <param name="auto-reply" value="Press *Call* to call FreeSWITCH and be sure to come to ClueCon! http://www.cluecon.com"/>  <param name="sasl" value="plain"/>  Modified: freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c Thu Oct 12 10:06:09 2006 @@ -95,6 +95,7 @@ char *login; char *password; char *message; + char *auto_reply; char *dialplan; char *ip; char *extip; @@ -1302,6 +1303,8 @@ switch_set_flag(profile, TFLAG_TIMER); } else if (!strcasecmp(var, "dialplan")) { profile->dialplan = switch_core_strdup(module_pool, val); + } else if (!strcasecmp(var, "auto-reply")) { + profile->auto_reply = switch_core_strdup(module_pool, val); } else if (!strcasecmp(var, "name")) { profile->name = switch_core_strdup(module_pool, val); } else if (!strcasecmp(var, "message")) { @@ -1551,6 +1554,11 @@ if (msg) { switch_event_add_body(event, msg); } + + if (profile->auto_reply) { + ldl_handle_send_msg(handle, from, "", profile->auto_reply); + } + switch_event_fire(&event); } break;

1 0

[commit] r3037 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 12 Oct '06

12 Oct '06

Author: anthm Date: Wed Oct 11 22:26:20 2006 New Revision: 3037 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Log: udpate Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Wed Oct 11 22:26:20 2006 @@ -2281,13 +2281,15 @@ break; case nua_callstate_terminated: if (session) { - switch_set_flag_locked(tech_pvt, TFLAG_BYE); - if (switch_test_flag(tech_pvt, TFLAG_NOHUP)) { - switch_clear_flag_locked(tech_pvt, TFLAG_NOHUP); - nua_handle_destroy(tech_pvt->nh); - tech_pvt->nh = NULL; - } else { - terminate_session(&session, sip_cause_to_freeswitch(status), __LINE__); + if (!switch_test_flag(tech_pvt, TFLAG_BYE)) { + switch_set_flag_locked(tech_pvt, TFLAG_BYE); + if (switch_test_flag(tech_pvt, TFLAG_NOHUP)) { + switch_clear_flag_locked(tech_pvt, TFLAG_NOHUP); + nua_handle_destroy(tech_pvt->nh); + tech_pvt->nh = NULL; + } else { + terminate_session(&session, sip_cause_to_freeswitch(status), __LINE__); + } } } break;

1 0

[commit] r3035 - in freeswitch/trunk: libs/libdingaling/src src src/include src/mod/endpoints/mod_dingaling src/mod/endpoints/mod_sofia
by Freeswitch SVN 12 Oct '06

12 Oct '06

Author: anthm Date: Wed Oct 11 20:59:09 2006 New Revision: 3035 Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.c freeswitch/trunk/libs/libdingaling/src/libdingaling.h freeswitch/trunk/src/include/switch_core.h freeswitch/trunk/src/include/switch_types.h freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c freeswitch/trunk/src/switch_core.c freeswitch/trunk/src/switch_event.c freeswitch/trunk/src/switch_ivr.c Log: refactoring and general improvement (do a make sure) Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.c ============================================================================== --- freeswitch/trunk/libs/libdingaling/src/libdingaling.c (original) +++ freeswitch/trunk/libs/libdingaling/src/libdingaling.c Wed Oct 11 20:59:09 2006 @@ -445,11 +445,29 @@ { ldl_handle_t *handle = user_data; char *from = iks_find_attrib(pak->x, "from"); + char *type = iks_find_attrib(pak->x, "type"); + char *show = iks_find_cdata(pak->x, "show"); + char *status = iks_find_cdata(pak->x, "status"); char id[1024]; char *resource; struct ldl_buffer *buffer; size_t x; + ldl_signal_t signal; + + if (type && !strcasecmp(type, "unavailable")) { + signal = LDL_SIGNAL_PRESENCE_OUT; + } else { + signal = LDL_SIGNAL_PRESENCE_IN; + } + + if (!status) { + status = type; + } + if (handle->session_callback) { + handle->session_callback(handle, NULL, signal, from, status ? status : "n/a", show ? show : "n/a"); + } + if (!apr_hash_get(handle->sub_hash, from, APR_HASH_KEY_STRING)) { iks *msg; apr_hash_set(handle->sub_hash, apr_pstrdup(handle->pool, from), APR_HASH_KEY_STRING, &marker); Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.h ============================================================================== --- freeswitch/trunk/libs/libdingaling/src/libdingaling.h (original) +++ freeswitch/trunk/libs/libdingaling/src/libdingaling.h Wed Oct 11 20:59:09 2006 @@ -119,6 +119,8 @@ LDL_SIGNAL_INITIATE, LDL_SIGNAL_CANDIDATES, LDL_SIGNAL_MSG, + LDL_SIGNAL_PRESENCE_IN, + LDL_SIGNAL_PRESENCE_OUT, LDL_SIGNAL_TERMINATE, LDL_SIGNAL_ERROR, LDL_SIGNAL_LOGIN_SUCCESS, Modified: freeswitch/trunk/src/include/switch_core.h ============================================================================== --- freeswitch/trunk/src/include/switch_core.h (original) +++ freeswitch/trunk/src/include/switch_core.h Wed Oct 11 20:59:09 2006 @@ -83,6 +83,8 @@ void *pointer_reply; /*! optional arbitrary pointer reply's size */ switch_size_t pointer_reply_size; + /*! message flags */ + switch_core_session_message_flag_t flags; }; /*! \brief A generic object to pass as a thread's session object to allow mutiple arguements and a pool */ @@ -420,6 +422,22 @@ \return the status returned by the message handler */ SWITCH_DECLARE (switch_status_t) switch_core_session_message_send(char *uuid_str, switch_core_session_message_t *message); + +/*! + \brief Queue a message on a session + \param session the session to queue the message to + \param message the message to queue + \return SWITCH_STATUS_SUCCESS if the message was queued +*/ +SWITCH_DECLARE(switch_status_t) switch_core_session_queue_message(switch_core_session_t *session, switch_core_session_message_t *message); + +/*! + \brief DE-Queue an message on a given session + \param session the session to de-queue the message on + \param message the de-queued message + \return the SWITCH_STATUS_SUCCESS if the message was de-queued +*/ +SWITCH_DECLARE(switch_status_t) switch_core_session_dequeue_message(switch_core_session_t *session, switch_core_session_message_t **message); /*! \brief Queue an event on another session using its uuid Modified: freeswitch/trunk/src/include/switch_types.h ============================================================================== --- freeswitch/trunk/src/include/switch_types.h (original) +++ freeswitch/trunk/src/include/switch_types.h Wed Oct 11 20:59:09 2006 @@ -247,7 +247,8 @@ SWITCH_MESSAGE_INDICATE_PROGRESS, SWITCH_MESSAGE_INDICATE_BRIDGE, SWITCH_MESSAGE_INDICATE_UNBRIDGE, - SWITCH_MESSAGE_INDICATE_TRANSFER + SWITCH_MESSAGE_INDICATE_TRANSFER, + SWITCH_MESSAGE_INDICATE_RINGING } switch_core_session_message_types_t; @@ -348,6 +349,10 @@ SWITCH_CHANNEL_ID_EVENT } switch_text_channel_t; +typedef enum { + SCSMF_DYNAMIC = (1 << 0) +} switch_core_session_message_flag_t; + #define SWITCH_UUID_FORMATTED_LENGTH APR_UUID_FORMATTED_LENGTH #define SWITCH_CHANNEL_LOG SWITCH_CHANNEL_ID_LOG, __FILE__, __FUNCTION__, __LINE__ #define SWITCH_CHANNEL_LOG_CLEAN SWITCH_CHANNEL_ID_LOG_CLEAN, __FILE__, __FUNCTION__, __LINE__ @@ -610,6 +615,7 @@ SWITCH_EVENT_MODULE_LOAD - Module was loaded SWITCH_EVENT_DTMF - DTMF was sent SWITCH_EVENT_MESSAGE - A Basic Message + SWITCH_EVENT_PRESENCE - Presence Info SWITCH_EVENT_CODEC - Codec Change SWITCH_EVENT_BACKGROUND_JOB - Background Job SWITCH_EVENT_ALL - All events at once @@ -644,6 +650,8 @@ SWITCH_EVENT_MODULE_LOAD, SWITCH_EVENT_DTMF, SWITCH_EVENT_MESSAGE, + SWITCH_EVENT_PRESENCE_IN, + SWITCH_EVENT_PRESENCE_OUT, SWITCH_EVENT_CODEC, SWITCH_EVENT_BACKGROUND_JOB, SWITCH_EVENT_ALL Modified: freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c Wed Oct 11 20:59:09 2006 @@ -38,7 +38,6 @@ #define DL_EVENT_LOGIN_SUCCESS "dingaling::login_success" #define DL_EVENT_LOGIN_FAILURE "dingaling::login_failure" -#define DL_EVENT_MESSAGE "dingaling::message" #define DL_EVENT_CONNECTED "dingaling::connected" static const char modname[] = "mod_dingaling"; @@ -1191,11 +1190,6 @@ return SWITCH_STATUS_GENERR; } - if (switch_event_reserve_subclass(DL_EVENT_MESSAGE) != SWITCH_STATUS_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't register subclass %s!", DL_EVENT_MESSAGE); - return SWITCH_STATUS_GENERR; - } - if (switch_event_reserve_subclass(DL_EVENT_CONNECTED) != SWITCH_STATUS_SUCCESS) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't register subclass %s!", DL_EVENT_CONNECTED); return SWITCH_STATUS_GENERR; @@ -1533,12 +1527,30 @@ if (!dlsession) { switch(signal) { + case LDL_SIGNAL_PRESENCE_IN: + if (switch_event_create(&event, SWITCH_EVENT_PRESENCE_IN) == SWITCH_STATUS_SUCCESS) { + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "login", profile->login); + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "from", from); + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "status", subject); + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "show", msg); + switch_event_fire(&event); + } + break; + case LDL_SIGNAL_PRESENCE_OUT: + if (switch_event_create(&event, SWITCH_EVENT_PRESENCE_OUT) == SWITCH_STATUS_SUCCESS) { + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "login", profile->login); + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "from", from); + switch_event_fire(&event); + } + break; case LDL_SIGNAL_MSG: - if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, DL_EVENT_MESSAGE) == SWITCH_STATUS_SUCCESS) { + if (switch_event_create(&event, SWITCH_EVENT_MESSAGE) == SWITCH_STATUS_SUCCESS) { switch_event_add_header(event, SWITCH_STACK_BOTTOM, "login", profile->login); switch_event_add_header(event, SWITCH_STACK_BOTTOM, "from", from); switch_event_add_header(event, SWITCH_STACK_BOTTOM, "subject", subject); - switch_event_add_body(event, msg); + if (msg) { + switch_event_add_body(event, msg); + } switch_event_fire(&event); } break; @@ -1639,12 +1651,13 @@ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "SESSION MSG [%s]\n", msg); } - if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, DL_EVENT_MESSAGE) == SWITCH_STATUS_SUCCESS) { + if (switch_event_create(&event, SWITCH_EVENT_MESSAGE) == SWITCH_STATUS_SUCCESS) { switch_event_add_header(event, SWITCH_STACK_BOTTOM, "login", profile->login); switch_event_add_header(event, SWITCH_STACK_BOTTOM, "from", from); switch_event_add_header(event, SWITCH_STACK_BOTTOM, "subject", subject); - switch_event_add_body(event, msg); - + if (msg) { + switch_event_add_body(event, msg); + } if (switch_core_session_queue_event(tech_pvt->session, &event) != SWITCH_STATUS_SUCCESS) { switch_event_add_header(event, SWITCH_STACK_BOTTOM, "delivery-failure", "true"); switch_event_fire(&event); Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Wed Oct 11 20:59:09 2006 @@ -42,6 +42,9 @@ struct outbound_reg; typedef struct outbound_reg outbound_reg_t; +struct sip_presence; +typedef struct sip_presence sip_presence_t; + struct sofia_profile; typedef struct sofia_profile sofia_profile_t; #define NUA_MAGIC_T sofia_profile_t @@ -49,6 +52,7 @@ struct sofia_private { switch_core_session_t *session; outbound_reg_t *oreg; + sip_presence_t *presence; }; typedef struct sofia_private sofia_private_t; @@ -113,7 +117,8 @@ PFLAG_AUTH_CALLS = (1 << 0), PFLAG_BLIND_REG = (1 << 1), PFLAG_AUTH_ALL = (1 << 2), - PFLAG_FULL_ID = (1 << 3) + PFLAG_FULL_ID = (1 << 3), + PFLAG_PRESENCE = (1 << 4) } PFLAGS; typedef enum { @@ -183,6 +188,14 @@ struct outbound_reg *next; }; + +struct sip_presence { + sofia_private_t sofia_private; + nua_handle_t *nh; + sofia_profile_t *profile; +}; + + struct sofia_profile { int debug; char *name; @@ -216,6 +229,8 @@ switch_mutex_t *ireg_mutex; switch_mutex_t *oreg_mutex; outbound_reg_t *registrations; + sip_presence_t *presence; + su_home_t *home; }; @@ -1311,6 +1326,7 @@ SOATAG_AUDIO_AUX("cn telephone-event"), NUTAG_INCLUDE_EXTRA_SDP(1), TAG_END()); + } } @@ -1605,6 +1621,9 @@ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Re-activate timed RTP!\n"); } break; + case SWITCH_MESSAGE_INDICATE_RINGING: + nua_respond(tech_pvt->nh, SIP_180_RINGING, TAG_END()); + break; case SWITCH_MESSAGE_INDICATE_PROGRESS: { struct private_object *tech_pvt; switch_channel_t *channel = NULL; @@ -1809,11 +1828,11 @@ for (map = m->m_rtpmaps; map; map = map->rm_next) { int32_t i; - + if (!strcasecmp(map->rm_encoding, "telephone-event")) { tech_pvt->te = (switch_payload_t)map->rm_pt; } - + for (i = 0; i < tech_pvt->num_codecs; i++) { const switch_codec_implementation_t *imp = tech_pvt->codecs[i]; switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Codec Compare [%s:%d]/[%s:%d]\n", @@ -1823,7 +1842,7 @@ } else { match = strcasecmp(map->rm_encoding, imp->iananame) ? 0 : 1; } - + if (match && (map->rm_rate == imp->samples_per_second)) { tech_pvt->rm_encoding = switch_core_session_strdup(session, (char *)map->rm_encoding); tech_pvt->pt = (switch_payload_t)map->rm_pt; @@ -1902,6 +1921,76 @@ } } +static void sip_i_message(int status, + char const *phrase, + nua_t *nua, + sofia_profile_t *profile, + nua_handle_t *nh, + sofia_private_t *sofia_private, + sip_t const *sip, + tagi_t tags[]) +{ + if (sip) { + sip_from_t const *from = sip->sip_from; + char *from_user = NULL; + char *from_host = NULL; + sip_to_t const *to = sip->sip_to; + char *to_user = NULL; + char *to_host = NULL; + sip_subject_t const *sip_subject = sip->sip_subject; + sip_payload_t *payload = sip->sip_payload; + const char *subject = "n/a"; + char *msg = ""; + + + if (from) { + from_user = (char *) from->a_url->url_user; + from_host = (char *) from->a_url->url_host; + } + + if (to) { + to_user = (char *) to->a_url->url_user; + to_host = (char *) to->a_url->url_host; + } + + if (payload) { + msg = payload->pl_data; + } + + if (sip_subject) { + subject = sip_subject->g_value; + } + + if (nh) { + char *message = "hello world"; + char buf[256] = ""; + + if (find_reg_url(profile, from_user, from_host, buf, sizeof(buf))) { + nua_handle_t *msg_nh; + + + msg_nh = nua_handle(profile->nua, NULL, + SIPTAG_FROM(sip->sip_to), + SIPTAG_TO_STR(buf), + SIPTAG_CONTACT_STR(profile->url), + TAG_END()); + + + nua_message(msg_nh, + SIPTAG_CONTENT_TYPE_STR("text/plain"), + TAG_IF(message, + SIPTAG_PAYLOAD_STR(message)), + TAG_END()); + + nua_handle_destroy(msg_nh); + } + + } + //printf("==================================\nFrom: %s@%s\nSubject: %s\n\n%s\n\n",from_user,from_host,subject,msg); + } + +} + static void sip_i_state(int status, char const *phrase, nua_t *nua, @@ -1964,6 +2053,27 @@ break; case nua_callstate_proceeding: if (channel) { + if (status == 180) { + if (switch_test_flag(tech_pvt, TFLAG_NOMEDIA)) { + if ((uuid = switch_channel_get_variable(channel, SWITCH_SIGNAL_BRIDGE_VARIABLE)) && (other_session = switch_core_session_locate(uuid))) { + switch_core_session_message_t msg; + msg.message_id = SWITCH_MESSAGE_INDICATE_RINGING; + msg.from = __FILE__; + switch_core_session_receive_message(other_session, &msg); + switch_core_session_rwunlock(other_session); + } + + } else { + switch_core_session_message_t *msg; + if ((msg = malloc(sizeof(*msg)))) { + memset(msg, 0, sizeof(*msg)); + msg->message_id = SWITCH_MESSAGE_INDICATE_RINGING; + msg->from = __FILE__; + switch_core_session_queue_message(session, msg); + switch_set_flag(msg, SCSMF_DYNAMIC); + } + } + } if (r_sdp) { if (switch_test_flag(tech_pvt, TFLAG_NOMEDIA)) { switch_set_flag_locked(tech_pvt, TFLAG_EARLY_MEDIA); @@ -2462,7 +2572,32 @@ } +static void sip_i_subscribe(int status, + char const *phrase, + nua_t *nua, + sofia_profile_t *profile, + nua_handle_t *nh, + sofia_private_t *sofia_private, + sip_t const *sip, + tagi_t tags[]) +{ + nua_respond(nh, SIP_200_OK, + TAG_END()); +} +static void sip_r_subscribe(int status, + char const *phrase, + nua_t *nua, + sofia_profile_t *profile, + nua_handle_t *nh, + sofia_private_t *sofia_private, + sip_t const *sip, + tagi_t tags[]) +{ + +} + + /*---------------------------------------*/ static void sip_i_refer(nua_t *nua, sofia_profile_t *profile, @@ -2850,7 +2985,23 @@ } +static void sip_i_options(int status, + char const *phrase, + nua_t *nua, + sofia_profile_t *profile, + nua_handle_t *nh, + sofia_private_t *sofia_private, + sip_t const *sip, + tagi_t tags[]) +{ + nua_respond(nh, SIP_200_OK, + //SOATAG_USER_SDP_STR(tech_pvt->local_sdp_str), + //SOATAG_AUDIO_AUX("cn telephone-event"), + //NUTAG_INCLUDE_EXTRA_SDP(1), + TAG_END()); +} + static void sip_r_register(int status, char const *phrase, nua_t *nua, @@ -3000,6 +3151,10 @@ //sip_r_options(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; + case nua_i_options: + sip_i_options(status, phrase, nua, profile, nh, sofia_private, sip, tags); + break; + case nua_i_fork: //sip_i_fork(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; @@ -3033,7 +3188,7 @@ break; case nua_i_message: - //sip_i_message(nua, profile, nh, sofia_private, sip, tags); + sip_i_message(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; case nua_r_info: @@ -3053,9 +3208,13 @@ break; case nua_r_subscribe: - //sip_r_subscribe(status, phrase, nua, profile, nh, sofia_private, sip, tags); + sip_r_subscribe(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; + case nua_i_subscribe: + sip_i_subscribe(status, phrase, nua, profile, nh, sofia_private, sip, tags); + break; + case nua_r_unsubscribe: //sip_r_unsubscribe(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; @@ -3063,7 +3222,9 @@ case nua_r_publish: //sip_r_publish(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; - + case nua_r_notifier: + nua_respond(nh, SIP_200_OK, TAG_END()); + break; case nua_r_notify: //sip_r_notify(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; @@ -3180,6 +3341,8 @@ NUTAG_AUTOALERT(0), NUTAG_ALLOW("REGISTER"), NUTAG_ALLOW("REFER"), + TAG_IF((profile->pflags & PFLAG_PRESENCE), NUTAG_ALLOW("PUBLISH")), + TAG_IF((profile->pflags & PFLAG_PRESENCE), NUTAG_ENABLEMESSAGE(1)), SIPTAG_SUPPORTED_STR("100rel, precondition"), SIPTAG_USER_AGENT_STR(SOFIA_USER_AGENT), TAG_END()); @@ -3198,6 +3361,8 @@ NUTAG_AUTOALERT(0), NUTAG_ALLOW("REGISTER"), NUTAG_ALLOW("REFER"), + TAG_IF((profile->pflags & PFLAG_PRESENCE), NUTAG_ALLOW("PUBLISH")), + TAG_IF((profile->pflags & PFLAG_PRESENCE), NUTAG_ENABLEMESSAGE(1)), SIPTAG_SUPPORTED_STR("100rel, precondition"), SIPTAG_USER_AGENT_STR(SOFIA_USER_AGENT), TAG_END()); @@ -3217,10 +3382,6 @@ switch_mutex_init(&profile->ireg_mutex, SWITCH_MUTEX_NESTED, profile->pool); switch_mutex_init(&profile->oreg_mutex, SWITCH_MUTEX_NESTED, profile->pool); - switch_mutex_lock(globals.mutex); - globals.running = 1; - switch_mutex_unlock(globals.mutex); - ireg_loops = IREG_SECONDS; oreg_loops = OREG_SECONDS; @@ -3230,6 +3391,45 @@ switch_event_fire(&s_event); } + if (switch_event_create(&s_event, SWITCH_EVENT_PUBLISH) == SWITCH_STATUS_SUCCESS) { + switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "service", "_sip._tcp"); + switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "port", "%d", profile->sip_port); + switch_event_fire(&s_event); + } + + if (switch_event_create(&s_event, SWITCH_EVENT_PUBLISH) == SWITCH_STATUS_SUCCESS) { + switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "service", "_sip._sctp"); + switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "port", "%d", profile->sip_port); + switch_event_fire(&s_event); + } + + if (profile->pflags & PFLAG_PRESENCE) { + if (!(profile->presence = switch_core_alloc(profile->pool, sizeof(*profile->presence)))) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Memory Error!\n"); + return NULL; + } + + profile->presence->nh = nua_handle(profile->nua, NULL, + TAG_END()); + profile->presence->sofia_private.presence = profile->presence; + nua_handle_bind(profile->presence->nh, &profile->presence->sofia_private); + + nua_notifier(profile->presence->nh, + NUTAG_URL(profile->url), + SIPTAG_EXPIRES_STR("3600"), + SIPTAG_FROM_STR(profile->url), + //SIPTAG_EVENT_STR("presence"), + SIPTAG_EVENT_STR("message-summary"), + //SIPTAG_ALLOW_EVENTS_STR("message-summary"), + SIPTAG_CONTENT_TYPE_STR("text/urllist"), + //SIPTAG_CONTENT_TYPE_STR("application/pidf-partial+xml"), + //SIPTAG_CONTENT_TYPE_STR("text/plain"), + NUTAG_SUBSTATE(nua_substate_pending), + TAG_END()); + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Creating notifier for %s\n", profile->url); + } + while(globals.running == 1) { if (++ireg_loops >= IREG_SECONDS) { check_expire(profile, time(NULL)); @@ -3243,6 +3443,13 @@ su_root_step(profile->s_root, 1000); } + + /* + if (profile->presence && profile->presence->nh) { + nua_handle_destroy(profile->presence->nh); + profile->presence->nh = NULL; + } + */ if (switch_event_create(&s_event, SWITCH_EVENT_UNPUBLISH) == SWITCH_STATUS_SUCCESS) { switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "service", "_sip._udp"); @@ -3251,7 +3458,6 @@ } su_root_destroy(profile->s_root); - pool = profile->pool; switch_core_destroy_memory_pool(&pool); switch_mutex_lock(globals.mutex); @@ -3285,6 +3491,10 @@ sofia_profile_t *profile = NULL; char url[512] = ""; + switch_mutex_lock(globals.mutex); + globals.running = 1; + switch_mutex_unlock(globals.mutex); + if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "open of %s failed\n", cf); status = SWITCH_STATUS_FALSE; @@ -3367,6 +3577,10 @@ profile->sipdomain = switch_core_strdup(profile->pool, val); } else if (!strcasecmp(var, "rtp-timer-name")) { profile->timer_name = switch_core_strdup(profile->pool, val); + } else if (!strcasecmp(var, "manage-presence")) { + if (switch_true(val)) { + profile->pflags |= PFLAG_PRESENCE; + } } else if (!strcasecmp(var, "auth-calls")) { if (switch_true(val)) { profile->pflags |= PFLAG_AUTH_CALLS; @@ -3588,7 +3802,59 @@ } } +static void msg_event_handler(switch_event_t *event) +{ + switch_hash_index_t *hi; + void *val; + sofia_profile_t *profile; + int open = 0; + char *from = switch_event_get_header(event, "from"); + //char *status = switch_event_get_header(event, "status"); + + switch(event->event_id) { + case SWITCH_EVENT_PRESENCE_IN: + open = 1; + break; + case SWITCH_EVENT_PRESENCE_OUT: + open = 0; + break; + default: + break; + } + for (hi = switch_hash_first(apr_hash_pool_get(globals.profile_hash), globals.profile_hash); hi; hi = switch_hash_next(hi)) { + switch_hash_this(hi, NULL, NULL, &val); + profile = (sofia_profile_t *) val; + if (profile && profile->presence) { + char *url; + char *myfrom = strdup(from); + char *p; + for(p = myfrom; *p ; p++) { + if (*p == '@') { + *p = '!'; + } + } + + url = switch_core_db_mprintf("sip:%s", myfrom); + + nua_publish(profile->presence->nh, + SIPTAG_EVENT_STR("presence"), + SIPTAG_CONTENT_TYPE_STR("text/urllist"), + SIPTAG_PAYLOAD_STR(url), + TAG_NULL()); + + switch_safe_free(url); + switch_safe_free(myfrom); + + } + + } + + + +} + + SWITCH_MOD_DECLARE(switch_status_t) switch_module_load(const switch_loadable_module_interface_t **module_interface, char *filename) { @@ -3614,7 +3880,20 @@ config_sofia(0); + if (switch_event_bind((char *) modname, SWITCH_EVENT_MESSAGE, SWITCH_EVENT_SUBCLASS_ANY, msg_event_handler, NULL) != SWITCH_STATUS_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't bind!\n"); + return SWITCH_STATUS_GENERR; + } + if (switch_event_bind((char *) modname, SWITCH_EVENT_PRESENCE_IN, SWITCH_EVENT_SUBCLASS_ANY, msg_event_handler, NULL) != SWITCH_STATUS_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't bind!\n"); + return SWITCH_STATUS_GENERR; + } + + if (switch_event_bind((char *) modname, SWITCH_EVENT_PRESENCE_OUT, SWITCH_EVENT_SUBCLASS_ANY, msg_event_handler, NULL) != SWITCH_STATUS_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't bind!\n"); + return SWITCH_STATUS_GENERR; + } /* connect my internal structure to the blank pointer passed to me */ *module_interface = &sofia_module_interface; Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Wed Oct 11 20:59:09 2006 @@ -50,6 +50,7 @@ #endif #define SWITCH_EVENT_QUEUE_LEN 256 +#define SWITCH_MESSAGE_QUEUE_LEN 256 #define SWITCH_SQL_QUEUE_LEN 2000 #define SWITCH_BUFFER_BLOCK_FRAMES 25 @@ -105,6 +106,7 @@ char uuid_str[SWITCH_UUID_FORMATTED_LENGTH + 1]; void *private_info; switch_queue_t *event_queue; + switch_queue_t *message_queue; switch_queue_t *private_event_queue; switch_thread_rwlock_t *bug_rwlock; switch_media_bug_t *bugs; @@ -1413,8 +1415,7 @@ return status; } -SWITCH_DECLARE(switch_status_t) switch_core_session_receive_message(switch_core_session_t *session, - switch_core_session_message_t *message) +SWITCH_DECLARE(switch_status_t) switch_core_session_receive_message(switch_core_session_t *session, switch_core_session_message_t *message) { switch_io_event_hook_receive_message_t *ptr; switch_status_t status = SWITCH_STATUS_FALSE; @@ -1429,11 +1430,44 @@ } } } - } + } + return status; +} +SWITCH_DECLARE(switch_status_t) switch_core_session_queue_message(switch_core_session_t *session, switch_core_session_message_t *message) +{ + switch_status_t status = SWITCH_STATUS_FALSE; + + assert(session != NULL); + + if (!session->message_queue) { + switch_queue_create(&session->message_queue, SWITCH_MESSAGE_QUEUE_LEN, session->pool); + } + + if (session->message_queue) { + if (switch_queue_trypush(session->message_queue, message) == SWITCH_STATUS_SUCCESS) { + status = SWITCH_STATUS_SUCCESS; + } + } + return status; } +SWITCH_DECLARE(switch_status_t) switch_core_session_dequeue_message(switch_core_session_t *session, switch_core_session_message_t **message) +{ + switch_status_t status = SWITCH_STATUS_FALSE; + void *pop; + + assert(session != NULL); + + if (session->message_queue) { + if ((status = (switch_status_t) switch_queue_trypop(session->message_queue, &pop)) == SWITCH_STATUS_SUCCESS) { + *message = (switch_core_session_message_t *) pop; + } + } + + return status; +} SWITCH_DECLARE(switch_status_t) switch_core_session_receive_event(switch_core_session_t *session, switch_event_t **event) Modified: freeswitch/trunk/src/switch_event.c ============================================================================== --- freeswitch/trunk/src/switch_event.c (original) +++ freeswitch/trunk/src/switch_event.c Wed Oct 11 20:59:09 2006 @@ -123,6 +123,8 @@ "MODULE_LOAD", "DTMF", "MESSAGE", + "PRESENCE_IN", + "PRESENCE_OUT", "CODEC", "BACKGROUND_JOB", "ALL" Modified: freeswitch/trunk/src/switch_ivr.c ============================================================================== --- freeswitch/trunk/src/switch_ivr.c (original) +++ freeswitch/trunk/src/switch_ivr.c Wed Oct 11 20:59:09 2006 @@ -1244,7 +1244,7 @@ int *stream_id_p; int stream_id = 0, pre_b = 0, ans_a = 0, ans_b = 0, originator = 0; switch_input_callback_function_t input_callback; - switch_core_session_message_t msg = {0}; + switch_core_session_message_t *message, msg = {0}; void *user_data; switch_channel_t *chan_a, *chan_b; @@ -1297,62 +1297,65 @@ break; } - if (!switch_channel_test_flag(chan_a, CF_HOLD)) { - - if (!ans_a && originator) { - if (!ans_b && switch_channel_test_flag(chan_b, CF_ANSWERED)) { - switch_channel_answer(chan_a); - ans_a++; - } else if (!pre_b && switch_channel_test_flag(chan_b, CF_EARLY_MEDIA)) { - switch_channel_pre_answer(chan_a); - pre_b++; + if (switch_core_session_dequeue_private_event(session_a, &event) == SWITCH_STATUS_SUCCESS) { + switch_channel_set_flag(chan_b, CF_HOLD); + switch_ivr_parse_event(session_a, event); + switch_channel_clear_flag(chan_b, CF_HOLD); + switch_event_destroy(&event); + } + + /* if 1 channel has DTMF pass it to the other */ + if (switch_channel_has_dtmf(chan_a)) { + char dtmf[128]; + switch_channel_dequeue_dtmf(chan_a, dtmf, sizeof(dtmf)); + switch_core_session_send_dtmf(session_b, dtmf); + + if (input_callback) { + if (input_callback(session_a, dtmf, SWITCH_INPUT_TYPE_DTMF, user_data, 0) != SWITCH_STATUS_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "%s ended call via DTMF\n", switch_channel_get_name(chan_a)); + switch_mutex_lock(data->mutex); + data->running = -1; + switch_mutex_unlock(data->mutex); + break; } - switch_yield(10000); - continue; } + } - if (switch_core_session_dequeue_private_event(session_a, &event) == SWITCH_STATUS_SUCCESS) { - switch_channel_set_flag(chan_b, CF_HOLD); - switch_ivr_parse_event(session_a, event); - switch_channel_clear_flag(chan_b, CF_HOLD); - switch_event_destroy(&event); + if (switch_core_session_dequeue_event(session_a, &event) == SWITCH_STATUS_SUCCESS) { + if (input_callback) { + status = input_callback(session_a, event, SWITCH_INPUT_TYPE_EVENT, user_data, 0); } - /* if 1 channel has DTMF pass it to the other */ - if (switch_channel_has_dtmf(chan_a)) { - char dtmf[128]; - switch_channel_dequeue_dtmf(chan_a, dtmf, sizeof(dtmf)); - switch_core_session_send_dtmf(session_b, dtmf); - - if (input_callback) { - if (input_callback(session_a, dtmf, SWITCH_INPUT_TYPE_DTMF, user_data, 0) != SWITCH_STATUS_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "%s ended call via DTMF\n", switch_channel_get_name(chan_a)); - switch_mutex_lock(data->mutex); - data->running = -1; - switch_mutex_unlock(data->mutex); - break; - } - } + if (switch_core_session_receive_event(session_b, &event) != SWITCH_STATUS_SUCCESS) { + switch_event_destroy(&event); } - if (switch_core_session_dequeue_event(session_a, &event) == SWITCH_STATUS_SUCCESS) { - if (input_callback) { - status = input_callback(session_a, event, SWITCH_INPUT_TYPE_EVENT, user_data, 0); - } + } - if (switch_core_session_receive_event(session_b, &event) != SWITCH_STATUS_SUCCESS) { - switch_event_destroy(&event); - } - + if (switch_core_session_dequeue_message(session_b, &message) == SWITCH_STATUS_SUCCESS) { + switch_core_session_receive_message(session_a, message); + if (switch_test_flag(message, SCSMF_DYNAMIC)) { + switch_safe_free(message); } + } + if (!ans_a && originator) { + if (!ans_b && switch_channel_test_flag(chan_b, CF_ANSWERED)) { + switch_channel_answer(chan_a); + ans_a++; + } else if (!pre_b && switch_channel_test_flag(chan_b, CF_EARLY_MEDIA)) { + switch_channel_pre_answer(chan_a); + pre_b++; + } + switch_yield(10000); + continue; } /* read audio from 1 channel and write it to the other */ status = switch_core_session_read_frame(session_a, &read_frame, -1, stream_id); if (SWITCH_READ_ACCEPTABLE(status)) { - if (status != SWITCH_STATUS_BREAK) { + if (status != SWITCH_STATUS_BREAK && !switch_channel_test_flag(chan_a, CF_HOLD)) { if (switch_core_session_write_frame(session_b, read_frame, -1, stream_id) != SWITCH_STATUS_SUCCESS) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "write: %s Bad Frame....[%u] Bubye!\n", switch_channel_get_name(chan_b), read_frame->datalen); @@ -1367,10 +1370,7 @@ data->running = -1; switch_mutex_unlock(data->mutex); } - - //switch_yield(1000); } - msg.message_id = SWITCH_MESSAGE_INDICATE_UNBRIDGE; msg.from = __FILE__; @@ -1968,6 +1968,15 @@ while ((!caller_channel || switch_channel_ready(caller_channel)) && check_channel_status(peer_channels, peer_sessions, and_argc, &idx, file, key) && ((time(NULL) - start) < (time_t)timelimit_sec)) { + if (or_argc == 1 && and_argc == 1) { /* when there is only 1 channel to call and bridge */ + switch_core_session_message_t *message = NULL; + if (switch_core_session_dequeue_message(peer_sessions[0], &message) == SWITCH_STATUS_SUCCESS) { + switch_core_session_receive_message(session, message); + if (switch_test_flag(message, SCSMF_DYNAMIC)) { + switch_safe_free(message); + } + } + } /* read from the channel while we wait if the audio is up on it */ if (session && !switch_channel_test_flag(caller_channel, CF_NOMEDIA) &&

1 0

[commit] r3026 - in freeswitch/trunk/src/mod/applications: mod_commands mod_conference mod_dptools
by Freeswitch SVN 10 Oct '06

10 Oct '06

Author: mikej Date: Tue Oct 10 08:00:22 2006 New Revision: 3026 Modified: freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c freeswitch/trunk/src/mod/applications/mod_dptools/mod_dptools.c Log: making the world a little less ugly, one commit at a time. Modified: freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c ============================================================================== --- freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c (original) +++ freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c Tue Oct 10 08:00:22 2006 @@ -454,7 +454,7 @@ sprintf (sql, "select type, name from interfaces where type = '%s'", cmd); } else if (!strcmp(cmd,"application") || !strcmp(cmd,"api")) { - sprintf (sql, "select * from interfaces where type = '%s'", cmd); + sprintf (sql, "select name, description, syntax from interfaces where type = '%s'", cmd); } else if ( !strcmp(cmd,"calls")) { sprintf (sql, "select * from calls"); @@ -468,9 +468,9 @@ holder.print_title = 0; if ((cmdname = strchr(cmd, ' ')) != 0) { *cmdname++ = '\0'; - sprintf (sql, "select name, description, syntax from interfaces where type = 'api' and name = '%s'", cmdname); + sprintf (sql, "select name, syntax, description from interfaces where type = 'api' and name = '%s'", cmdname); } else { - sprintf (sql, "select name, description, syntax from interfaces where type = 'api'"); + sprintf (sql, "select name, syntax, description from interfaces where type = 'api'"); } } else { @@ -529,7 +529,7 @@ /*.interface_name */ "help", /*.desc */ "Show help for all the api commands", /*.function */ help_function, - /*.syntax */ "help", + /*.syntax */ "", /*.next */ NULL }; @@ -537,7 +537,7 @@ /*.interface_name */ "fsctl", /*.desc */ "control messages", /*.function */ ctl_function, - /*.syntax */ "fsctl [hupall|pause|resume|shutdown]", + /*.syntax */ "[hupall|pause|resume|shutdown]", /*.next */ &help_api_interface }; @@ -545,7 +545,7 @@ /*.interface_name */ "uuid_bridge", /*.desc */ "uuid_bridge", /*.function */ uuid_bridge_function, - /*.syntax */ "uuid_bridge <uuid> <other_uuid>", + /*.syntax */ "<uuid> <other_uuid>", /*.next */ &ctl_api_interface }; @@ -553,7 +553,7 @@ /*.interface_name */ "status", /*.desc */ "status", /*.function */ status_function, - /*.syntax */ "status", + /*.syntax */ "", /*.next */ &uuid_bridge_api_interface }; @@ -561,7 +561,7 @@ /*.interface_name */ "show", /*.desc */ "Show", /*.function */ show_function, - /*.syntax */ "show <blank>|codec|application|api|dialplan|file|timer|calls|channels", + /*.syntax */ "<blank>|codec|application|api|dialplan|file|timer|calls|channels", /*.next */ &status_api_interface }; @@ -569,7 +569,7 @@ /*.interface_name */ "pause", /*.desc */ "Pause", /*.function */ pause_function, - /*.syntax */ "pause <uuid> <on|off>", + /*.syntax */ "<uuid> <on|off>", /*.next */ &show_api_interface }; @@ -577,7 +577,7 @@ /*.interface_name */ "transfer", /*.desc */ "Transfer", /*.function */ transfer_function, - /*.syntax */ "transfer <uuid> <dest-exten> [<dialplan>] [<context>]", + /*.syntax */ "<uuid> <dest-exten> [<dialplan>] [<context>]", /*.next */ &pause_api_interface }; @@ -585,7 +585,7 @@ /*.interface_name */ "load", /*.desc */ "Load Module", /*.function */ load_function, - /*.syntax */ "load <mod_name>", + /*.syntax */ "<mod_name>", /*.next */ &transfer_api_interface }; @@ -593,7 +593,7 @@ /*.interface_name */ "reloadxml", /*.desc */ "Reload XML", /*.function */ reload_function, - /*.syntax */ "reloadxml", + /*.syntax */ "", /*.next */ &load_api_interface, }; @@ -602,7 +602,7 @@ /*.interface_name */ "killchan", /*.desc */ "Kill Channel", /*.function */ kill_function, - /*.syntax */ "killchan <uuid>", + /*.syntax */ "<uuid>", /*.next */ &reload_api_interface }; @@ -610,7 +610,7 @@ /*.interface_name */ "originate", /*.desc */ "Originate a Call", /*.function */ originate_function, - /*.syntax */ "originate <call url> <exten>|&<application_name>(<app_args>) [<dialplan>] [<context>] [<cid_name>] [<cid_num>] [<timeout_sec>]", + /*.syntax */ "<call url> <exten>|&<application_name>(<app_args>) [<dialplan>] [<context>] [<cid_name>] [<cid_num>] [<timeout_sec>]", /*.next */ &kill_api_interface }; Modified: freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c ============================================================================== --- freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c (original) +++ freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c Tue Oct 10 08:00:22 2006 @@ -2647,26 +2647,25 @@ /*.desc */ "Conference", /*.function */ conf_function, /*.syntax */ - "conference commands\n" - "conference list [delim <string>]\n" - "conference <confname> list [delim <string>]\n" - "conference <confname> energy <member_id> [<newval>]\n" - "conference <confname> volume_in <member_id> [<newval>]\n" - "conference <confname> volume_out <member_id> [<newval>]\n" - "conference <confname> play <file_path> [<member_id>]\n" - "conference <confname> say <text>\n" - "conference <confname> saymember <member_id><text>\n" - "conference <confname> stop <[current|all]> [<member_id>]\n" - "conference <confname> kick <member_id>\n" - "conference <confname> mute <member_id>\n" - "conference <confname> unmute <member_id>\n" - "conference <confname> deaf <member_id>\n" - "conference <confname> undef <member_id>\n" - "conference <confname> relate <member_id> <other_member_id> [nospeak|nohear]\n" - "conference <confname> lock\n" - "conference <confname> unlock\n" - "conference <confname> dial <endpoint_module_name>/<destination>\n" - "conference <confname> transfer <member_id> <conference_name>\n", + "list [delim <string>]\n" + "<confname> list [delim <string>]\n" + "<confname> energy <member_id> [<newval>]\n" + "<confname> volume_in <member_id> [<newval>]\n" + "<confname> volume_out <member_id> [<newval>]\n" + "<confname> play <file_path> [<member_id>]\n" + "<confname> say <text>\n" + "<confname> saymember <member_id><text>\n" + "<confname> stop <[current|all]> [<member_id>]\n" + "<confname> kick <member_id>\n" + "<confname> mute <member_id>\n" + "<confname> unmute <member_id>\n" + "<confname> deaf <member_id>\n" + "<confname> undef <member_id>\n" + "<confname> relate <member_id> <other_member_id> [nospeak|nohear]\n" + "<confname> lock\n" + "<confname> unlock\n" + "<confname> dial <endpoint_module_name>/<destination>\n" + "<confname> transfer <member_id> <conference_name>", /*.next */ }; Modified: freeswitch/trunk/src/mod/applications/mod_dptools/mod_dptools.c ============================================================================== --- freeswitch/trunk/src/mod/applications/mod_dptools/mod_dptools.c (original) +++ freeswitch/trunk/src/mod/applications/mod_dptools/mod_dptools.c Tue Oct 10 08:00:22 2006 @@ -132,7 +132,7 @@ /*.interface_name */ "strftime", /*.desc */ "strftime", /*.function */ strftime_api_function, - /*.syntax */ "strftime <format_string>", + /*.syntax */ "<format_string>", /*.next */ NULL }; @@ -140,7 +140,7 @@ /*.interface_name */ "set", /*.application_function */ set_function, /* long_desc */ "Set a channel varaible for the channel calling the application.", - /* short_desc */ "Set a channel varaible.", + /* short_desc */ "Set a channel varaible", /* syntax */ "<varname>=[<value>|_UNDEF_]", /*.next */ NULL }; @@ -149,7 +149,7 @@ /*.interface_name */ "answer", /*.application_function */ answer_function, /* long_desc */ "Answer the call for a channel.", - /* short_desc */ "Answer the call.", + /* short_desc */ "Answer the call", /* syntax */ "", /*.next */ &set_application_interface

1 0

[commit] r3021 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 10 Oct '06

10 Oct '06

Author: anthm Date: Mon Oct 9 23:19:59 2006 New Revision: 3021 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Log: update Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Mon Oct 9 23:19:59 2006 @@ -61,6 +61,7 @@ #define MY_EVENT_EXPIRE "sofia::expire" #define MULTICAST_EVENT "multicast::event" #define SOFIA_REPLACES_HEADER "_sofia_replaces_" +#define SOFIA_USER_AGENT "FreeSWITCH(mod_sofia)" #include <sofia-sip/nua.h> @@ -3180,6 +3181,7 @@ NUTAG_ALLOW("REGISTER"), NUTAG_ALLOW("REFER"), SIPTAG_SUPPORTED_STR("100rel, precondition"), + SIPTAG_USER_AGENT_STR(SOFIA_USER_AGENT), TAG_END()); @@ -3191,11 +3193,13 @@ TAG_END()); /* Last tag should always finish the sequence */ nua_set_params(node->nua, - NUTAG_EARLY_MEDIA(1), + NUTAG_EARLY_MEDIA(1), NUTAG_AUTOANSWER(0), NUTAG_AUTOALERT(0), NUTAG_ALLOW("REGISTER"), + NUTAG_ALLOW("REFER"), SIPTAG_SUPPORTED_STR("100rel, precondition"), + SIPTAG_USER_AGENT_STR(SOFIA_USER_AGENT), TAG_END()); }

1 0

[commit] r3020 - freeswitch/trunk/src/mod/codecs/mod_amr
by Freeswitch SVN 10 Oct '06

10 Oct '06

Author: anthm Date: Mon Oct 9 22:16:29 2006 New Revision: 3020 Modified: freeswitch/trunk/src/mod/codecs/mod_amr/mod_amr.c Log: update Modified: freeswitch/trunk/src/mod/codecs/mod_amr/mod_amr.c ============================================================================== --- freeswitch/trunk/src/mod/codecs/mod_amr/mod_amr.c (original) +++ freeswitch/trunk/src/mod/codecs/mod_amr/mod_amr.c Mon Oct 9 22:16:29 2006 @@ -200,7 +200,7 @@ context->decoder_state = NULL; if (encoding) { - context->encoder_state = Encoder_Interface_init(0); + context->encoder_state = Encoder_Interface_init(1); } if (decoding) {

1 0

[commit] r3019 - freeswitch/trunk/src/mod/endpoints/mod_dingaling
by Freeswitch SVN 10 Oct '06

10 Oct '06

Author: anthm Date: Mon Oct 9 20:11:41 2006 New Revision: 3019 Modified: freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c Log: improve dingaling Modified: freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c Mon Oct 9 20:11:41 2006 @@ -68,6 +68,7 @@ TFLAG_TIMER = ( 1 << 19), TFLAG_TERM = ( 1 << 20), TFLAG_TRANSPORT_ACCEPT = (1 << 21), + TFLAG_READY = (1 << 22), } TFLAGS; typedef enum { @@ -188,31 +189,25 @@ tech_pvt = switch_core_session_get_private(*session); + if (!tech_pvt || !switch_test_flag(tech_pvt, TFLAG_READY)) { + switch_core_session_destroy(session); + return; + } - if (state < CS_INIT || !switch_core_session_running(*session)) { - if (state > CS_INIT && state < CS_HANGUP) { - channel_on_hangup(*session); - } + if (switch_test_flag(tech_pvt, TFLAG_TERM)) { + /*once is enough*/ + return; + } - if (tech_pvt && tech_pvt->dlsession) { - ldl_session_set_private(tech_pvt->dlsession, NULL); + if (tech_pvt->dlsession) { + if (!switch_test_flag(tech_pvt, TFLAG_TERM)) { + ldl_session_terminate(tech_pvt->dlsession); } - switch_core_session_destroy(session); - } else if (tech_pvt){ - if (switch_test_flag(tech_pvt, TFLAG_TERM)) { - /*once is enough*/ - return; - } - - if (tech_pvt->dlsession) { - if (!switch_test_flag(tech_pvt, TFLAG_TERM)) { - ldl_session_terminate(tech_pvt->dlsession); - } - ldl_session_destroy(&tech_pvt->dlsession); - } - switch_set_flag_locked(tech_pvt, TFLAG_TERM); + ldl_session_destroy(&tech_pvt->dlsession); } + switch_set_flag_locked(tech_pvt, TFLAG_TERM); + if (state < CS_HANGUP) { switch_channel_hangup(channel, cause); } @@ -525,22 +520,15 @@ return 1; } -static void *SWITCH_THREAD_FUNC negotiate_thread_run(switch_thread_t *thread, void *obj) +static switch_status_t negotiate_media(switch_core_session_t *session) { - switch_core_session_t *session = obj; - + switch_status_t ret = SWITCH_STATUS_FALSE; switch_channel_t *channel; struct private_object *tech_pvt = NULL; switch_time_t started; switch_time_t now; unsigned int elapsed; - if (switch_core_session_read_lock(session) != SWITCH_STATUS_SUCCESS) { - /* too late */ - return NULL; - } - - tech_pvt = switch_core_session_get_private(session); assert(tech_pvt != NULL); @@ -592,7 +580,6 @@ goto done; } switch_yield(1000); - //printf("WAIT %s %d %d %d %d\n", switch_channel_get_name(channel), switch_test_flag(tech_pvt, TFLAG_TRANSPORT), switch_test_flag(tech_pvt, TFLAG_CODEC_READY), switch_test_flag(tech_pvt, TFLAG_RTP_READY), switch_test_flag(tech_pvt, TFLAG_ANSWER)); } if (switch_channel_get_state(channel) >= CS_HANGUP || switch_test_flag(tech_pvt, TFLAG_BYE)) { @@ -608,36 +595,18 @@ goto out; } switch_channel_answer(channel); - //printf("***************************ANSWER\n"); - } else { - switch_core_session_thread_launch(session); - } - switch_channel_set_state(channel, CS_INIT); + } + ret = SWITCH_STATUS_SUCCESS; + goto done; out: terminate_session(&session, __LINE__, SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER); done: - if (session) { - switch_core_session_rwunlock(session); - } - return NULL; -} - -static void negotiate_thread_launch(switch_core_session_t *session) -{ - switch_thread_t *thread; - switch_threadattr_t *thd_attr = NULL; - - switch_threadattr_create(&thd_attr, switch_core_session_get_pool(session)); - switch_threadattr_detach_set(thd_attr, 1); - switch_thread_create(&thread, thd_attr, negotiate_thread_run, session, switch_core_session_get_pool(session)); - + return ret; } - - /* State methods they get called when the state changes to the specific state returning SWITCH_STATUS_SUCCESS tells the core to execute the standard state method next @@ -656,9 +625,13 @@ tech_pvt->read_frame.buflen = SWITCH_RTP_MAX_BUF_LEN; - /* Move Channel's State Machine to RING */ - switch_channel_set_state(channel, CS_RING); + switch_set_flag(tech_pvt, TFLAG_READY); + if (negotiate_media(session) == SWITCH_STATUS_SUCCESS) { + /* Move Channel's State Machine to RING */ + switch_channel_set_state(channel, CS_RING); + } + return SWITCH_STATUS_SUCCESS; } @@ -810,14 +783,11 @@ assert(tech_pvt != NULL); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "DTMF [%s]\n", dtmf); - //snprintf(digits, sizeof(digits), "+%s\n", dtmf); - //ldl_handle_send_msg(tech_pvt->profile->handle, tech_pvt->recip, NULL, digits); return switch_rtp_queue_rfc2833(tech_pvt->rtp_session, dtmf, 100 * (tech_pvt->read_codec.implementation->samples_per_second / 1000)); - //return SWITCH_STATUS_SUCCESS; } static switch_status_t channel_read_frame(switch_core_session_t *session, switch_frame_t **frame, int timeout, @@ -887,7 +857,6 @@ tech_pvt->timestamp_recv += (int32_t) samples; tech_pvt->read_frame.samples = (int) samples; tech_pvt->last_read = tech_pvt->read_frame.datalen; - //printf("READ bytes=%d payload=%d frames=%d samples=%d ms=%d ts=%d sampcount=%d\n", (int)tech_pvt->read_frame.datalen, (int)payload, (int)frames, (int)samples, (int)ms, (int)tech_pvt->timestamp_recv, (int)tech_pvt->read_frame.samples); break; } @@ -946,15 +915,13 @@ samples = frames * tech_pvt->read_codec.implementation->samples_per_frame; - //printf("%s send %d bytes %d samples in %d frames ts=%d\n", switch_channel_get_name(channel), frame->datalen, samples, frames, tech_pvt->timestamp_send); - if (switch_rtp_write_frame(tech_pvt->rtp_session, frame, samples) < 0) { return SWITCH_STATUS_FALSE; } tech_pvt->timestamp_send += (int) samples; switch_clear_flag_locked(tech_pvt, TFLAG_WRITING); - //switch_mutex_unlock(tech_pvt->rtp_lock); + return status; } @@ -969,11 +936,6 @@ tech_pvt = switch_core_session_get_private(session); assert(tech_pvt != NULL); - - - //if (!switch_test_flag(tech_pvt, TFLAG_OUTBOUND)) { - - //} return SWITCH_STATUS_SUCCESS; } @@ -1200,8 +1162,7 @@ terminate_session(new_session, __LINE__, SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER); return SWITCH_STATUS_GENERR; } - //tech_pvt->desc_id = ldl_session_describe(dlsession, NULL, 0, LDL_DESCRIPTION_INITIATE); - negotiate_thread_launch(*new_session); + switch_channel_set_state(channel, CS_INIT); return SWITCH_STATUS_SUCCESS; } @@ -1653,12 +1614,11 @@ status = LDL_STATUS_FALSE; goto done; } - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Creating a session for %s\n", ldl_session_get_id(dlsession)); ldl_session_set_private(dlsession, session); tech_pvt->dlsession = dlsession; - negotiate_thread_launch(session); + switch_channel_set_state(channel, CS_INIT); + switch_core_session_thread_launch(session); } else { status = LDL_STATUS_FALSE; goto done;

1 0