February 2007 - Freeswitch-trunk - FreeSWITCH Mailing Lists

[commit] r4349 - freeswitch/trunk/src
by Freeswitch SVN 22 Feb '07

22 Feb '07

Author: anthm Date: Thu Feb 22 16:13:36 2007 New Revision: 4349 Modified: freeswitch/trunk/src/switch_core.c Log: add mode goodies to ilbc Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Thu Feb 22 16:13:36 2007 @@ -821,7 +821,7 @@ return SWITCH_STATUS_GENERR; } - if (mode && strncasecmp(mode, "mode=", 5)) { + if (!strcasecmp(codec_name, "ilbc") && mode && strncasecmp(mode, "mode=", 5)) { int mms; mode += 5; if (mode) {

1 0

[commit] r4348 - in freeswitch/trunk/src: . mod/codecs/mod_ilbc
by Freeswitch SVN 22 Feb '07

22 Feb '07

Author: anthm Date: Thu Feb 22 15:56:23 2007 New Revision: 4348 Modified: freeswitch/trunk/src/mod/codecs/mod_ilbc/mod_ilbc.c freeswitch/trunk/src/switch_core.c Log: add mode goodies to ilbc Modified: freeswitch/trunk/src/mod/codecs/mod_ilbc/mod_ilbc.c ============================================================================== --- freeswitch/trunk/src/mod/codecs/mod_ilbc/mod_ilbc.c (original) +++ freeswitch/trunk/src/mod/codecs/mod_ilbc/mod_ilbc.c Thu Feb 22 15:56:23 2007 @@ -190,7 +190,7 @@ /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, /*.ianacode */ 97, /*.iananame */ "iLBC", - /*.fmtp */ NULL, + /*.fmtp */ "mode=30", /*.samples_per_second */ 8000, /*.bits_per_second */ NO_OF_BYTES_30MS*8*8000/BLOCKL_30MS, /*.microseconds_per_frame */ 30000, @@ -210,7 +210,7 @@ /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, /*.ianacode */ 97, /*.iananame */ "iLBC", - /*.fmtp */ NULL, + /*.fmtp */ "mode=20", /*.samples_per_second */ 8000, /*.bits_per_second */ NO_OF_BYTES_20MS*8*8000/BLOCKL_20MS, /*.microseconds_per_frame */ 20000, @@ -233,7 +233,7 @@ /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, /*.ianacode */ 102, /*.iananame */ "iLBC", - /*.fmtp */ NULL, + /*.fmtp */ "mode=30", /*.samples_per_second */ 8000, /*.bits_per_second */ NO_OF_BYTES_30MS*8*8000/BLOCKL_30MS, /*.microseconds_per_frame */ 30000, @@ -253,7 +253,7 @@ /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, /*.ianacode */ 102, /*.iananame */ "iLBC102", - /*.fmtp */ NULL, + /*.fmtp */ "mode=20", /*.samples_per_second */ 8000, /*.bits_per_second */ NO_OF_BYTES_20MS*8*8000/BLOCKL_20MS, /*.microseconds_per_frame */ 20000, @@ -275,7 +275,7 @@ /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, /*.ianacode */ 97, /*.iananame */ "iLBC20ms", - /*.fmtp */ NULL, + /*.fmtp */ "mode=20", /*.samples_per_second */ 8000, /*.bits_per_second */ NO_OF_BYTES_20MS*8*8000/BLOCKL_20MS, /*.microseconds_per_frame */ 20000, Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Thu Feb 22 15:56:23 2007 @@ -809,6 +809,7 @@ { const switch_codec_interface_t *codec_interface; const switch_codec_implementation_t *iptr, *implementation = NULL; + char *mode = fmtp; assert(codec != NULL); assert(codec_name != NULL); @@ -820,6 +821,17 @@ return SWITCH_STATUS_GENERR; } + if (mode && strncasecmp(mode, "mode=", 5)) { + int mms; + mode += 5; + if (mode) { + mms = atoi(mode); + if (mms > 0 && mms < 120) { + ms = mms; + } + } + } + /* If no specific codec interval is requested opt for 20ms above all else because lots of stuff assumes it */ if (!ms) { for (iptr = codec_interface->implementations; iptr; iptr = iptr->next) {

1 0

[commit] r4347 - in freeswitch/trunk/src: . include
by Freeswitch SVN 22 Feb '07

22 Feb '07

Author: anthm Date: Thu Feb 22 12:38:34 2007 New Revision: 4347 Modified: freeswitch/trunk/src/include/switch_core.h freeswitch/trunk/src/include/switch_types.h freeswitch/trunk/src/switch_core.c freeswitch/trunk/src/switch_event.c Log: add heartbeat event and core uuid Modified: freeswitch/trunk/src/include/switch_core.h ============================================================================== --- freeswitch/trunk/src/include/switch_core.h (original) +++ freeswitch/trunk/src/include/switch_core.h Thu Feb 22 12:38:34 2007 @@ -477,6 +477,12 @@ */ SWITCH_DECLARE(char *) switch_core_session_get_uuid(switch_core_session_t *session); +/*! + \brief Retrieve the unique identifier from the core + \return a string representing the uuid +*/ +SWITCH_DECLARE(char *) switch_core_get_uuid(void); + #ifdef SWITCH_DEBUG_RWLOCKS SWITCH_DECLARE(switch_core_session_t *) switch_core_session_perform_locate(char *uuid_str, const char *file, Modified: freeswitch/trunk/src/include/switch_types.h ============================================================================== --- freeswitch/trunk/src/include/switch_types.h (original) +++ freeswitch/trunk/src/include/switch_types.h Thu Feb 22 12:38:34 2007 @@ -747,6 +747,7 @@ SWITCH_EVENT_BACKGROUND_JOB - Background Job SWITCH_EVENT_DETECTED_SPEECH - Detected Speech SWITCH_EVENT_PRIVATE_COMMAND - A private command event + SWITCH_EVENT_HEARTBEAT - Machine is alive SWITCH_EVENT_ALL - All events at once </pre> @@ -787,6 +788,7 @@ SWITCH_EVENT_BACKGROUND_JOB, SWITCH_EVENT_DETECTED_SPEECH, SWITCH_EVENT_PRIVATE_COMMAND, + SWITCH_EVENT_HEARTBEAT, SWITCH_EVENT_ALL } switch_event_types_t; Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Thu Feb 22 12:38:34 2007 @@ -145,6 +145,7 @@ uint32_t no_new_sessions; uint32_t shutting_down; uint8_t running; + char uuid_str[SWITCH_UUID_FORMATTED_LENGTH + 1]; }; /* Prototypes */ @@ -748,6 +749,11 @@ return status; } +SWITCH_DECLARE(char *) switch_core_get_uuid(void) +{ + return runtime.uuid_str; +} + SWITCH_DECLARE(char *) switch_core_session_get_uuid(switch_core_session_t *session) { return session->uuid_str; @@ -3808,7 +3814,7 @@ void *pop; uint32_t itterations = 0; uint8_t trans = 0, nothing_in_queue = 0; - uint32_t freq = 1000, target = 1000; + uint32_t target = 1000; switch_size_t len = 0, sql_len = SQLLEN; const char *begin_sql = "BEGIN DEFERRED TRANSACTION CORE1;\n"; char *end_sql = "END TRANSACTION CORE1"; @@ -3817,13 +3823,15 @@ char *sqlbuf = (char *) malloc(sql_len); char *sql; switch_size_t newlen; - + uint32_t loops = 0; if (!runtime.event_db) { runtime.event_db = switch_core_db_handle(); } switch_queue_create(&runtime.sql_queue, SWITCH_SQL_QUEUE_LEN, runtime.memory_pool); + + for(;;) { if (switch_queue_trypop(runtime.sql_queue, &pop) == SWITCH_STATUS_SUCCESS) { sql = (char *) pop; @@ -3873,10 +3881,42 @@ len = 0; *sqlbuf = '\0'; } + + if (loops++ >= 5000) { + switch_event_t *event; + switch_core_time_duration_t duration; + + switch_core_measure_time(switch_core_uptime(), &duration); + + if (switch_event_create(&event, SWITCH_EVENT_HEARTBEAT) == SWITCH_STATUS_SUCCESS) { + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Event-Info", "System Ready"); + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Up-Time", + "%u year%s, " + "%u day%s, " + "%u hour%s, " + "%u minute%s, " + "%u second%s, " + "%u millisecond%s, " + "%u microsecond%s\n", + duration.yr, duration.yr == 1 ? "" : "s", + duration.day, duration.day == 1 ? "" : "s", + duration.hr, duration.hr == 1 ? "" : "s", + duration.min, duration.min == 1 ? "" : "s", + duration.sec, duration.sec == 1 ? "" : "s", + duration.ms, duration.ms == 1 ? "" : "s", + duration.mms, duration.mms == 1 ? "" : "s" + ); + + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Session-Count", "%u", switch_core_session_count()); + switch_event_fire(&event); + } + + loops = 0; + } if (nothing_in_queue) { - switch_yield(freq); - } + switch_yield(1000); + } } @@ -4130,6 +4170,7 @@ switch_xml_t xml = NULL, cfg = NULL; memset(&runtime, 0, sizeof(runtime)); runtime.session_limit = 1000; + switch_uuid_t uuid; switch_core_set_globals(); @@ -4276,6 +4317,11 @@ switch_core_hash_init(&runtime.stack_table, runtime.memory_pool); #endif runtime.initiated = switch_time_now(); + + + switch_uuid_get(&uuid); + switch_uuid_format(runtime.uuid_str, &uuid); + return SWITCH_STATUS_SUCCESS; } Modified: freeswitch/trunk/src/switch_event.c ============================================================================== --- freeswitch/trunk/src/switch_event.c (original) +++ freeswitch/trunk/src/switch_event.c Thu Feb 22 12:38:34 2007 @@ -131,6 +131,7 @@ "BACKGROUND_JOB", "DETECTED_SPEECH", "PRIVATE_COMMAND", + "HEARTBEAT", "ALL" }; @@ -811,21 +812,21 @@ return SWITCH_STATUS_FALSE; } - - switch_event_add_header(*event, SWITCH_STACK_TOP, "Event-Calling-Line-Number", "%d", line); - switch_event_add_header(*event, SWITCH_STACK_TOP, "Event-Calling-Function", "%s", func); - switch_event_add_header(*event, SWITCH_STACK_TOP, "Event-Calling-File", "%s", switch_cut_path(file)); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Event-Name", "%s", switch_event_name((*event)->event_id)); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Core-UUID", "%s", switch_core_get_uuid()); switch_time_exp_lt(&tm, switch_time_now()); switch_strftime(date, &retsize, sizeof(date), "%Y-%m-%d %T", &tm); - switch_event_add_header(*event, SWITCH_STACK_TOP, "Event-Date-Local", "%s", date); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Event-Date-Local", "%s", date); switch_rfc822_date(date, switch_time_now()); - switch_event_add_header(*event, SWITCH_STACK_TOP, "Event-Date-GMT", "%s", date); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Event-Date-GMT", "%s", date); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Event-Calling-File", "%s", switch_cut_path(file)); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Event-Calling-Function", "%s", func); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Event-Calling-Line-Number", "%d", line); + if ((*event)->subclass) { - switch_event_add_header(*event, SWITCH_STACK_TOP, "Event-Subclass", "%s", (*event)->subclass->name); - switch_event_add_header(*event, SWITCH_STACK_TOP, "Event-Subclass-Owner", "%s", (*event)->subclass->owner); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Event-Subclass", "%s", (*event)->subclass->name); + switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Event-Subclass-Owner", "%s", (*event)->subclass->owner); } - switch_event_add_header(*event, SWITCH_STACK_TOP, "Event-Name", "%s", switch_event_name((*event)->event_id)); - if (user_data) { (*event)->event_user_data = user_data;

1 0

[commit] r4346 - freeswitch/trunk/src
by Freeswitch SVN 22 Feb '07

22 Feb '07

Author: anthm Date: Thu Feb 22 11:06:42 2007 New Revision: 4346 Modified: freeswitch/trunk/src/switch_core.c Log: send break sig after sending messages and events to sessions Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Thu Feb 22 11:06:42 2007 @@ -1761,6 +1761,7 @@ } } } + switch_core_session_kill_channel(session, SWITCH_SIG_BREAK); return status; } @@ -1864,7 +1865,9 @@ } switch_core_session_rwunlock(session); } - + + switch_core_session_kill_channel(session, SWITCH_SIG_BREAK); + return status; }

1 0

[commit] r4344 - in freeswitch/trunk/src: . include mod/endpoints/mod_sofia
by Freeswitch SVN 21 Feb '07

21 Feb '07

Author: anthm Date: Wed Feb 21 16:46:32 2007 New Revision: 4344 Modified: freeswitch/trunk/src/include/switch_core.h freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c freeswitch/trunk/src/switch_core.c Log: try to pass 2833-pt across calls Modified: freeswitch/trunk/src/include/switch_core.h ============================================================================== --- freeswitch/trunk/src/include/switch_core.h (original) +++ freeswitch/trunk/src/include/switch_core.h Wed Feb 21 16:46:32 2007 @@ -1454,6 +1454,14 @@ \brief Initiate Globals */ SWITCH_DECLARE(void) switch_core_set_globals(void); + +/*! + \brief indicate if 2 sessions are the same type + \param a the first session + \param b the second session + \return TRUE or FALSE +*/ +SWITCH_DECLARE(uint8_t) switch_core_session_compare(switch_core_session_t *a, switch_core_session_t *b); ///\} /*! 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 Feb 21 16:46:32 2007 @@ -317,6 +317,7 @@ switch_payload_t pt; switch_mutex_t *flag_mutex; switch_payload_t te; + switch_payload_t bte; nua_handle_t *nh; nua_handle_t *nh2; su_home_t *home; @@ -859,7 +860,11 @@ tech_pvt->flags = profile->flags; switch_mutex_unlock(tech_pvt->flag_mutex); tech_pvt->profile = profile; - tech_pvt->te = profile->te; + if (tech_pvt->bte) { + tech_pvt->te = tech_pvt->bte; + } else { + tech_pvt->te = profile->te; + } tech_pvt->session = session; tech_pvt->home = su_home_new(sizeof(*tech_pvt->home)); @@ -2310,7 +2315,15 @@ //switch_channel_t *channel = switch_core_session_get_channel(session); switch_ivr_transfer_variable(session, nsession, SOFIA_REPLACES_HEADER); switch_ivr_transfer_variable(session, nsession, SOFIA_SIP_HEADER_PREFIX_T); - + if (switch_core_session_compare(session, nsession)) { + /* It's another sofia channel! so lets cache what they use as a pt for telephone event so + we can keep it the same + */ + private_object_t *ctech_pvt; + ctech_pvt = switch_core_session_get_private(session); + assert(ctech_pvt != NULL); + tech_pvt->bte = ctech_pvt->te; + } } done: @@ -2328,7 +2341,7 @@ int ptime = 0, dptime = 0; tech_pvt = switch_core_session_get_private(session); - assert(tech_pvt != NULL); + assert(tech_pvt != NULL); channel = switch_core_session_get_channel(session); Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Wed Feb 21 16:46:32 2007 @@ -4466,6 +4466,14 @@ return SWITCH_STATUS_SUCCESS; } +SWITCH_DECLARE(uint8_t) switch_core_session_compare(switch_core_session_t *a, switch_core_session_t *b) +{ + assert(a != NULL); + assert(b != NULL); + + return (a->endpoint_interface == b->endpoint_interface); +} + /* For Emacs: * Local Variables: * mode:c

1 0

[commit] r4343 - freeswitch/trunk/src/include
by Freeswitch SVN 21 Feb '07

21 Feb '07

Author: mikej Date: Wed Feb 21 13:39:10 2007 New Revision: 4343 Modified: freeswitch/trunk/src/include/switch_apr.h Log: added switch_file_lock and switch_file_unlock to the exposed functions from apr to be used to make FSCORE-14 jira ticket cross platform. Modified: freeswitch/trunk/src/include/switch_apr.h ============================================================================== --- freeswitch/trunk/src/include/switch_apr.h (original) +++ freeswitch/trunk/src/include/switch_apr.h Wed Feb 21 13:39:10 2007 @@ -193,6 +193,25 @@ #define switch_file_close apr_file_close /** + * Establish a lock on the specified, open file. The lock may be advisory + * or mandatory, at the discretion of the platform. The lock applies to + * the file as a whole, rather than a specific range. Locks are established + * on a per-thread/process basis; a second lock by the same thread will not + * block. + * @param thefile The file to lock. + * @param type The type of lock to establish on the file. + */ +DoxyDefine(apr_status_t apr_file_lock(switch_file_t *thefile, int type);) +#define switch_file_lock apr_file_lock + +/** + * Remove any outstanding locks on the file. + * @param thefile The file to unlock. + */ +DoxyDefine(apr_status_t apr_file_unlock(switch_file_t *thefile);) +#define switch_file_unlock apr_file_unlock + +/** * Delete the specified file. * @param path The full path to the file (using / on all systems) * @param pool The pool to use.

1 0

[commit] r4342 - freeswitch/trunk/src/mod/codecs/mod_ilbc
by Freeswitch SVN 21 Feb '07

21 Feb '07

Author: anthm Date: Wed Feb 21 12:59:08 2007 New Revision: 4342 Modified: freeswitch/trunk/src/mod/codecs/mod_ilbc/mod_ilbc.c Log: make ilbc fail the call when the frame is wrong Modified: freeswitch/trunk/src/mod/codecs/mod_ilbc/mod_ilbc.c ============================================================================== --- freeswitch/trunk/src/mod/codecs/mod_ilbc/mod_ilbc.c (original) +++ freeswitch/trunk/src/mod/codecs/mod_ilbc/mod_ilbc.c Wed Feb 21 12:59:08 2007 @@ -178,6 +178,7 @@ } } else { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "yo this frame is an odd size [%d]\n", encoded_data_len); + return SWITCH_STATUS_FALSE; } return SWITCH_STATUS_SUCCESS; }

1 0

[commit] r4341 - in freeswitch/trunk/src: . mod/codecs/mod_g711
by Freeswitch SVN 21 Feb '07

21 Feb '07

Author: anthm Date: Wed Feb 21 01:35:55 2007 New Revision: 4341 Modified: freeswitch/trunk/src/mod/codecs/mod_g711/mod_g711.c freeswitch/trunk/src/switch_core.c freeswitch/trunk/src/switch_ivr.c Log: add 120ms to g711, fix errs in g711 alaw defs, tweak buffer in file playback and add kill to hupall Modified: freeswitch/trunk/src/mod/codecs/mod_g711/mod_g711.c ============================================================================== --- freeswitch/trunk/src/mod/codecs/mod_g711/mod_g711.c (original) +++ freeswitch/trunk/src/mod/codecs/mod_g711/mod_g711.c Wed Feb 21 01:35:55 2007 @@ -188,6 +188,26 @@ /* Registration */ +static const switch_codec_implementation_t g711u_8k_120ms_implementation = { + /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, + /*.ianacode */ 0, + /*.iananame */ "PCMU", + /*.fmtp */ NULL, + /*.samples_per_second */ 8000, + /*.bits_per_second */ 64000, + /*.microseconds_per_frame */ 120000, + /*.samples_per_frame */ 960, + /*.bytes_per_frame */ 1920, + /*.encoded_bytes_per_frame */ 960, + /*.number_of_channels */ 1, + /*.pref_frames_per_packet */ 1, + /*.max_frames_per_packet */ 1, + /*.init */ switch_g711u_init, + /*.encode */ switch_g711u_encode, + /*.decode */ switch_g711u_decode, + /*.destroy */ switch_g711u_destroy +}; + static const switch_codec_implementation_t g711u_8k_60ms_implementation = { /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, /*.ianacode */ 0, @@ -205,7 +225,8 @@ /*.init */ switch_g711u_init, /*.encode */ switch_g711u_encode, /*.decode */ switch_g711u_decode, - /*.destroy */ switch_g711u_destroy + /*.destroy */ switch_g711u_destroy, + /*.next*/ &g711u_8k_120ms_implementation }; static const switch_codec_implementation_t g711u_8k_30ms_implementation = { @@ -273,6 +294,25 @@ +static const switch_codec_implementation_t g711a_8k_120ms_implementation = { + /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, + /*.ianacode */ 8, + /*.iananame */ "PCMA", + /*.fmtp */ NULL, + /*.samples_per_second */ 8000, + /*.bits_per_second */ 64000, + /*.microseconds_per_frame */ 120000, + /*.samples_per_frame */ 960, + /*.bytes_per_frame */ 1920, + /*.encoded_bytes_per_frame */ 960, + /*.number_of_channels */ 1, + /*.pref_frames_per_packet */ 1, + /*.max_frames_per_packet */ 1, + /*.init */ switch_g711a_init, + /*.encode */ switch_g711a_encode, + /*.decode */ switch_g711a_decode, + /*.destroy */ switch_g711a_destroy +}; static const switch_codec_implementation_t g711a_8k_60ms_implementation = { /*.codec_type */ SWITCH_CODEC_TYPE_AUDIO, @@ -288,10 +328,11 @@ /*.number_of_channels */ 1, /*.pref_frames_per_packet */ 1, /*.max_frames_per_packet */ 1, - /*.init */ switch_g711u_init, - /*.encode */ switch_g711u_encode, - /*.decode */ switch_g711u_decode, - /*.destroy */ switch_g711u_destroy, + /*.init */ switch_g711a_init, + /*.encode */ switch_g711a_encode, + /*.decode */ switch_g711a_decode, + /*.destroy */ switch_g711a_destroy, + /*.next*/ &g711a_8k_120ms_implementation }; static const switch_codec_implementation_t g711a_8k_30ms_implementation = { @@ -308,10 +349,10 @@ /*.number_of_channels */ 1, /*.pref_frames_per_packet */ 1, /*.max_frames_per_packet */ 1, - /*.init */ switch_g711u_init, - /*.encode */ switch_g711u_encode, - /*.decode */ switch_g711u_decode, - /*.destroy */ switch_g711u_destroy, + /*.init */ switch_g711a_init, + /*.encode */ switch_g711a_encode, + /*.decode */ switch_g711a_decode, + /*.destroy */ switch_g711a_destroy, /*.next*/ &g711a_8k_60ms_implementation }; @@ -350,10 +391,10 @@ /*.number_of_channels */ 1, /*.pref_frames_per_packet */ 1, /*.max_frames_per_packet */ 1, - /*.init */ switch_g711u_init, - /*.encode */ switch_g711u_encode, - /*.decode */ switch_g711u_decode, - /*.destroy */ switch_g711u_destroy, + /*.init */ switch_g711a_init, + /*.encode */ switch_g711a_encode, + /*.decode */ switch_g711a_decode, + /*.destroy */ switch_g711a_destroy, /*.next*/ &g711a_8k_20ms_implementation }; Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Wed Feb 21 01:35:55 2007 @@ -693,6 +693,7 @@ session = (switch_core_session_t *) val; channel = switch_core_session_get_channel(session); switch_channel_hangup(channel, cause); + switch_core_session_kill_channel(session, SWITCH_SIG_KILL); } } switch_mutex_unlock(runtime.session_table_mutex); Modified: freeswitch/trunk/src/switch_ivr.c ============================================================================== --- freeswitch/trunk/src/switch_ivr.c (original) +++ freeswitch/trunk/src/switch_ivr.c Wed Feb 21 01:35:55 2007 @@ -1218,6 +1218,14 @@ if (!fh->audio_buffer) { switch_buffer_create_dynamic(&fh->audio_buffer, FILE_BLOCKSIZE, FILE_BUFSIZE, 0); + if (!fh->audio_buffer) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "setup buffer failed\n"); + + switch_core_file_close(fh); + switch_core_session_reset(session); + + return SWITCH_STATUS_GENERR; + } } if (asis) { @@ -1334,7 +1342,10 @@ olen = asis ? framelen : ilen; do_speed = 0; } else { - olen = 32 * framelen; + olen = sizeof(abuf); + if (!asis) { + olen /= 2; + } switch_core_file_read(fh, abuf, &olen); switch_buffer_write(fh->audio_buffer, abuf, asis ? olen : olen * 2); olen = switch_buffer_read(fh->audio_buffer, abuf, framelen);

1 0

[commit] r4340 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 21 Feb '07

21 Feb '07

Author: brian Date: Tue Feb 20 22:37:17 2007 New Revision: 4340 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Log: change the override to header symbol from : to ^ (beware) 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 Tue Feb 20 22:37:17 2007 @@ -2256,7 +2256,7 @@ goto done; } - if ((dest_to = strchr(dest, ':'))) { + if ((dest_to = strchr(dest, '^'))) { *dest_to++ = '\0'; tech_pvt->dest_to = switch_core_session_alloc(nsession, strlen(dest_to) + 5); snprintf(tech_pvt->dest_to, strlen(dest_to) + 5, "sip:%s", dest_to);

1 0

[commit] r4339 - in freeswitch/trunk/src: . include
by Freeswitch SVN 20 Feb '07

20 Feb '07

Author: mikej Date: Tue Feb 20 16:54:23 2007 New Revision: 4339 Modified: freeswitch/trunk/src/include/switch_core.h freeswitch/trunk/src/switch_core.c Log: add pool allocated printf function switch_core_sprintf Modified: freeswitch/trunk/src/include/switch_core.h ============================================================================== --- freeswitch/trunk/src/include/switch_core.h (original) +++ freeswitch/trunk/src/include/switch_core.h Tue Feb 20 16:54:23 2007 @@ -402,6 +402,15 @@ */ SWITCH_DECLARE(char *) switch_core_session_sprintf(switch_core_session_t *session, const char *fmt, ...); +/*! + \brief printf-style style printing routine. The data is output to a string allocated from the pool + \param pool a pool to use for allocation + \param fmt The format of the string + \param ... The arguments to use while printing the data + \return The new string +*/ +SWITCH_DECLARE(char *) switch_core_sprintf(switch_memory_pool_t *pool, const char *fmt, ...); + /*! \brief Retrieve the memory pool from a session \param session the session to retrieve the pool from Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Tue Feb 20 16:54:23 2007 @@ -1481,6 +1481,21 @@ return result; } +SWITCH_DECLARE(char *) switch_core_sprintf(switch_memory_pool_t *pool, const char *fmt, ...) +{ + va_list ap; + char *result = NULL; + + assert(pool != NULL); + va_start(ap, fmt); + + result = apr_pvsprintf(pool ,fmt, ap); + + va_end(ap); + + return result; +} + SWITCH_DECLARE(char *) switch_core_session_strdup(switch_core_session_t *session, const char *todup) {

1 0