January 2008 - Freeswitch-svn - FreeSWITCH Mailing Lists

[commit] r7153 - freeswitch/trunk/conf/autoload_configs
by Freeswitch SVN 09 Jan '08

09 Jan '08

Author: brian Date: Wed Jan 9 14:23:10 2008 New Revision: 7153 Modified: freeswitch/trunk/conf/autoload_configs/cdr_csv.conf.xml Log: log record file for the snom profile this way you know the filename from the CDR that goes with that call Modified: freeswitch/trunk/conf/autoload_configs/cdr_csv.conf.xml ============================================================================== --- freeswitch/trunk/conf/autoload_configs/cdr_csv.conf.xml (original) +++ freeswitch/trunk/conf/autoload_configs/cdr_csv.conf.xml Wed Jan 9 14:23:10 2008 @@ -10,7 +10,7 @@ <templates> <template name="sql">INSERT INTO cdr VALUES ("${caller_id_name}","${caller_id_number}","${destination_number}","${context}","${start_stamp}","${answer_stamp}","${end_stamp}","${duration}","${billsec}","${hangup_cause}","${uuid}","${bleg_uuid}", "${accountcode}");</template> <template name="example">"${caller_id_name}","${caller_id_number}","${destination_number}","${context}","${start_stamp}","${answer_stamp}","${end_stamp}","${duration}","${billsec}","${hangup_cause}","${uuid}","${bleg_uuid}", "${accountcode}","${read_codec}","${write_codec}"</template> - <template name="snom">"${caller_id_name}","${caller_id_number}","${destination_number}","${context}","${start_stamp}","${answer_stamp}","${end_stamp}","${duration}","${billsec}","${hangup_cause}","${uuid}","${bleg_uuid}", "${accountcode}","${read_codec}","${write_codec},"${sip_user_agent}","${call_clientcode}","${sip_rtp_rxstat}","${sip_rtp_txstat}"</template> + <template name="snom">"${caller_id_name}","${caller_id_number}","${destination_number}","${context}","${start_stamp}","${answer_stamp}","${end_stamp}","${duration}","${billsec}","${hangup_cause}","${uuid}","${bleg_uuid}", "${accountcode}","${read_codec}","${write_codec},"${sip_user_agent}","${call_clientcode}","${sip_rtp_rxstat}","${sip_rtp_txstat}","${sofia_record_file}"</template> <template name="asterisk">"${accountcode}","${caller_id_number}","${destination_number}","${context}","${caller_id}","${channel_name}","${bridge_channel}","${last_app}","${last_arg}","${start_stamp}","${answer_stamp}","${end_stamp}","${duration}","${billsec}","${hangup_cause}","${amaflags}","${uuid}","${userfield}"</template> </templates> </configuration>

1 0

[commit] r7150 - freeswitch/trunk/src
by Freeswitch SVN 09 Jan '08

09 Jan '08

Author: anthm Date: Wed Jan 9 12:20:05 2008 New Revision: 7150 Modified: freeswitch/trunk/src/switch_rtp.c Log: update Modified: freeswitch/trunk/src/switch_rtp.c ============================================================================== --- freeswitch/trunk/src/switch_rtp.c (original) +++ freeswitch/trunk/src/switch_rtp.c Wed Jan 9 12:20:05 2008 @@ -839,6 +839,8 @@ if (switch_queue_trypop(rtp_session->dtmf_data.dtmf_queue, &pop) == SWITCH_STATUS_SUCCESS) { switch_dtmf_t *rdigit = pop; + rtp_session->sending_dtmf = 1; + memset(rtp_session->dtmf_data.out_digit_packet, 0, 4); rtp_session->dtmf_data.out_digit_sofar = samples; rtp_session->dtmf_data.out_digit_dur = rdigit->duration; @@ -847,12 +849,12 @@ rtp_session->dtmf_data.out_digit_packet[1] = 7; if (rtp_session->timer.timer_interface) { - rtp_session->dtmf_data.timestamp_dtmf = rtp_session->timer.samplecount; + rtp_session->dtmf_data.timestamp_dtmf = rtp_session->timer.samplecount + samples; } else { rtp_session->dtmf_data.timestamp_dtmf = rtp_session->last_write_ts + samples; } - rtp_session->sending_dtmf = 1; + rtp_session->seq++;

1 0

[commit] r7149 - freeswitch/trunk/src/mod/applications/mod_conference
by Freeswitch SVN 09 Jan '08

09 Jan '08

Author: mikej Date: Wed Jan 9 01:44:16 2008 New Revision: 7149 Modified: freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c Log: add conference pin/nopin api commands (MODAPP-71) 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 Wed Jan 9 01:44:16 2008 @@ -3350,6 +3350,25 @@ return ret_status; } +static switch_status_t conf_api_sub_pin(conference_obj_t * conference, switch_stream_handle_t *stream, int argc, char **argv) +{ + switch_assert(conference != NULL); + switch_assert(stream != NULL); + + if ((argc == 3) && (!strcmp(argv[1], "pin"))) { + conference->pin = switch_core_strdup(conference->pool, argv[2]); + stream->write_function(stream, "Pin for conference %s set: %s\n", argv[0], conference->pin); + return SWITCH_STATUS_SUCCESS; + } else if (argc == 2 && (!strcmp(argv[1], "nopin"))) { + conference->pin = NULL; + stream->write_function(stream, "Pin for conference %s deleted\n", argv[0]); + return SWITCH_STATUS_SUCCESS; + } else { + stream->write_function(stream, "Invalid parameters:\n"); + return SWITCH_STATUS_GENERR; + } +} + typedef enum { CONF_API_COMMAND_LIST = 0, CONF_API_COMMAND_ENERGY, @@ -3412,6 +3431,8 @@ "<confname> transfer <conference_name> <member id> [...<member id>]"}, {"record", (void_fn_t) & conf_api_sub_record, CONF_API_SUB_ARGS_SPLIT, "<confname> record <filename>"}, {"norecord", (void_fn_t) & conf_api_sub_norecord, CONF_API_SUB_ARGS_SPLIT, "<confname> norecord <[filename|all]>"}, + {"pin", (void_fn_t) & conf_api_sub_pin, CONF_API_SUB_ARGS_SPLIT, "<confname> pin <pin#>"}, + {"nopin", (void_fn_t) & conf_api_sub_pin, CONF_API_SUB_ARGS_SPLIT, "<confname> nopin"}, }; #define CONFFUNCAPISIZE (sizeof(conf_api_sub_commands)/sizeof(conf_api_sub_commands[0]))

1 0

[commit] r7148 - freeswitch/trunk/src
by Freeswitch SVN 08 Jan '08

08 Jan '08

Author: anthm Date: Tue Jan 8 17:30:52 2008 New Revision: 7148 Modified: freeswitch/trunk/src/switch_rtp.c Log: refactor Modified: freeswitch/trunk/src/switch_rtp.c ============================================================================== --- freeswitch/trunk/src/switch_rtp.c (original) +++ freeswitch/trunk/src/switch_rtp.c Tue Jan 8 17:30:52 2008 @@ -795,7 +795,7 @@ uint32_t samples = rtp_session->samples_per_interval; if (rtp_session->dtmf_data.out_digit_dur > 0) { - int x, loops = 1, duration; + int x, loops = 1; rtp_session->dtmf_data.out_digit_sofar += samples; if (rtp_session->dtmf_data.out_digit_sofar > 0xFFFF) { @@ -804,16 +804,13 @@ } if (rtp_session->dtmf_data.out_digit_sofar >= rtp_session->dtmf_data.out_digit_dur) { - duration = rtp_session->dtmf_data.out_digit_dur; rtp_session->dtmf_data.out_digit_packet[1] |= 0x80; rtp_session->dtmf_data.out_digit_dur = 0; loops = 3; - } else { - duration = rtp_session->dtmf_data.out_digit_sofar; } - - rtp_session->dtmf_data.out_digit_packet[2] = (unsigned char) (duration >> 8); - rtp_session->dtmf_data.out_digit_packet[3] = (unsigned char) duration; + + rtp_session->dtmf_data.out_digit_packet[2] = (unsigned char) (rtp_session->dtmf_data.out_digit_sofar >> 8); + rtp_session->dtmf_data.out_digit_packet[3] = (unsigned char) rtp_session->dtmf_data.out_digit_sofar; for (x = 0; x < loops; x++) { @@ -826,9 +823,9 @@ rtp_session->te, rtp_session->dtmf_data.timestamp_dtmf, rtp_session->seq, rtp_session->dtmf_data.out_digit_ssrc, &flags); - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Send %s packet for [%c] ts=%d sofar=%u dur=%d seq=%d\n", + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Send %s packet for [%c] ts=%d dur=%d seq=%d\n", loops == 1 ? "middle" : "end", rtp_session->dtmf_data.out_digit, rtp_session->dtmf_data.timestamp_dtmf, - rtp_session->dtmf_data.out_digit_sofar, duration, rtp_session->seq); + rtp_session->dtmf_data.out_digit_sofar, rtp_session->seq); } if (loops != 1) { @@ -870,11 +867,10 @@ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, - "Send start packet for [%c] ts=%d sofar=%u dur=%d seq=%d\n", + "Send start packet for [%c] ts=%d dur=%d seq=%d\n", rtp_session->dtmf_data.out_digit, rtp_session->dtmf_data.timestamp_dtmf, rtp_session->dtmf_data.out_digit_sofar, - 0, rtp_session->seq); free(rdigit);

1 0

[commit] r7147 - in freeswitch/trunk/scripts/contrib/intralanman/PHP: . fs_sock
by Freeswitch SVN 08 Jan '08

08 Jan '08

Author: intralanman Date: Tue Jan 8 16:55:23 2008 New Revision: 7147 Added: freeswitch/trunk/scripts/contrib/intralanman/PHP/ freeswitch/trunk/scripts/contrib/intralanman/PHP/fs_sock/ freeswitch/trunk/scripts/contrib/intralanman/PHP/fs_sock/fs_sock.php freeswitch/trunk/scripts/contrib/intralanman/PHP/fs_sock/socktest.php Log: adding PHP class for event socket Added: freeswitch/trunk/scripts/contrib/intralanman/PHP/fs_sock/fs_sock.php ============================================================================== --- (empty file) +++ freeswitch/trunk/scripts/contrib/intralanman/PHP/fs_sock/fs_sock.php Tue Jan 8 16:55:23 2008 @@ -0,0 +1,420 @@ +<?php +/** + * Class for FreeSWITCH event socket + * + */ + +/** + * Class for FreeSWITCH event socket + * + */ +class fs_sock { + /** + * file handler for FreeSWITCH socket connection + * + * @var file pointer + */ + public $sock; + + /** + * Sets Whether auth was successful or not + * Used to not send further commands until auth is successful + * + * @var boolean + */ + public $auth; + + /** + * Variable to hold current command + * + * @var string + */ + private $command = 'initial_read'; + + private $input_buffer; + private $output_buffer; + + /** + * Class instantiation + * This method will connect to the socket and authenticate + * + * @param array $vars + * @return fs_sock + */ + function fs_sock($vars=null) { + if (!defined('BUFFER_SIZE')) { + /** + * This is the buffer size for fread/fgets operations (default 4096) + * Define BUFFER_SIZE before instantiation to use a different size + */ + define('BUFFER_SIZE', 4096); + } + $vars_array = is_array($vars) ? $vars : array(); + $initial_vars = $this -> set_initial_vars($vars_array); + //$this -> debug($initial_vars); + $this -> sock_connect($initial_vars); + $initial_output = $this -> sock_get(); + if ($initial_output['Content-Type'] == 'auth/request') { + $this -> debug('---- authentication requested ----'); + $this -> sock_auth($initial_vars['pass']); + } + } + + /** + * Close the connection to the event socket + * + */ + function sock_close() { + $this -> send_command('exit'); + fclose($this -> sock); + } + + /** + * Sets connection info from array passed, or used a set of defaults if nothing is passed + * + * @param array $var_array array of connection settings to use (host|port|pass|timeout) + * @return array + */ + function set_initial_vars($var_array) { + $defaults = array( + 'host' => '127.0.0.1', + 'port' => '8021', + 'pass' => 'ClueCon', + 'timeout' => 30, + 'stream_timeout' => 5 + ); + if (array_key_exists('host', $var_array) + && $var_array['host'] == 'localhost') { + //$this -> debug('Replacing localhost with 127.0.0.1'); + $var_array['host'] = '127.0.0.1'; + } + foreach ($defaults as $key => $val) { + if (array_key_exists($key, $var_array)) { + //$this -> debug("$key found in vars"); + $connection_settings[$key] = $var_array[$key]; + } else { + //$this -> debug("$key not found in vars"); + $connection_settings[$key] = $val; + } + } + //$this -> debug($connection_settings); + return $connection_settings; + } + + /** + * Connect to the event socket using the array determined by set_initial_vars + * + * @param array $sock_array array of connection parameters + * @return boolean + */ + function sock_connect($sock_array) { + //$this -> debug($sock_array); + $host = $sock_array['host']; + $port = $sock_array['port']; + $timeout = $sock_array['timeout']; + $this -> sock = fsockopen($host, $port, $errno, $errstr, $timeout); + if (!$this -> sock) { + $error = sprintf('Unable to connect to %s:%s Error #%s: %s' + , $host, $port, $errno, $errstr + ); + trigger_error($error, E_USER_ERROR); + return false; + } else { + //$this -> debug(stream_get_meta_data($this -> sock)); + $this -> set_stream_opts($sock_array); + return true; + } + } + + /** + * Set the stream timeout to not block for long periods of time + * + * @param array $opts initial options passed to class instantiation + * @return void + */ + function set_stream_opts($opts) { + //$this -> debug($opts); + if (ereg('^[0-9]*\.[0-9]+$', $opts['stream_timeout'])) { + //$this -> debug($opts['stream_timeout'] . ' seems to be a float'); + $time_opts = split('\.', $opts['stream_timeout']); + //$this -> debug($time_opts); + $secs = sprintf('%d', $time_opts[0]); + $ms = ($time_opts[1] * 100000); + } else { + $secs = $opts['stream_timeout']; + $ms = 0; + } + if (!stream_set_timeout($this -> sock, $secs, $ms)) { + $this -> debug( + "Failed to set timeout to $secs seconds and $ms microseconds" + ); + } + } + + /** + * Authenticate to the FreeSWITCH event socket + * + * @param string $pass FreeSWITCH event socket password + * @return void + */ + function sock_auth($pass) { + $reply = $this -> send_command("auth $pass"); + if (is_array($reply) && array_key_exists('Reply-Text', $reply) + && ereg('^\+?OK', $reply['Reply-Text'])) { + $this -> debug('Successfully authenticated'); + $this -> debug($reply); + $this -> auth = true; + } else { + $this -> debug('Failed to authenticate'); + $this -> debug($reply); + $this -> auth = false; + } + } + + /** + * write raw data to the FreeSWITCH socket + * + * @param string $input command to write to the socket + */ + private function sock_put($input) { + fputs($this -> sock, $input); + } + + /** + * Read an event from the FreeSWITCH event socket + * + * @return array multi-dimentional array of the event + */ + private function sock_get() { + $this -> debug('---- Event Start ----'); + while ($orig_line = fgets($this -> sock, BUFFER_SIZE)) { + $trim_line = trim($orig_line); + $this -> debug($trim_line); + if (strlen($trim_line) > 0) { + if (strstr($trim_line, ":")) { + $split = split(":", $trim_line); + $header = trim($split[0]); + $value = trim($split[1]); + $event[$header] = $value; + } + } elseif (is_array($event) + && array_key_exists('Content-Length', $event)) { + $this -> debug("line is empty: " . (empty($trim_line) ? 'true' : 'false')); + $event['Body'] = $this -> sock_get_length($event['Content-Length']); + break; + } else { + break; + } + } + $this -> debug('---- Event Finish ----'); + $this -> debug($event); + return $event; + } + + /** + * Read $content_len bytes from the socket + * + * @param integer $content_len + * @return array + */ + private function sock_get_length($content_len) { + $this -> debug("calling sock_get_length with length of $content_len"); + //for ($i=0; $i<$content_len; $i+=strlen($orig_line)) { + while ($orig_line = fgets($this -> sock, BUFFER_SIZE)) { + $len += strlen($orig_line); + $trim_line = trim($orig_line); + $this -> debug("$trim_line - $len"); + if (strstr($orig_line, ":")) { + $split = split(":", $orig_line); + $attribute = trim($split[0]); + $value = trim($split[1]); + $content[$attribute] = urldecode($value); + } elseif (empty($trim_line) && is_array($content) + && array_key_exists('Content-Length', $content)) { + $content['Body'] = $this -> sock_get_length($content['Content-Length']); + $len += $content['Content-Length']; + break; + } elseif (!empty($trim_line)) { + $content .= $trim_line; + } + if ($len >= $content_len) { + break; + } + } + $this -> debug("leaving after $len bytes"); + //$this -> debug($content); + return $content; + } + + /** + * Send a command to the FreeSWITCH event socket + * This method sends a command string to the FreeSWITCH event socket and + * returns true upon success and false upon failure + * @param string $cmd command string to send to socket excluding any \r or \n + * @return boolean + */ + public function send_command($cmd) { + $this -> debug('command is ' . $cmd); + $cmd_split = split(' ', $cmd); + //$this -> debug($cmd_split); + $this -> command = $cmd_split[0]; + if ($this -> auth != true && $this -> command != 'auth') { + unset($this -> command); + return false; + } + $this -> debug("sending command: '$cmd'"); + $this -> sock_put("$cmd\r\n\r\n"); + if ($this -> command != 'exit') { + $reply = $this -> sock_get(); + //$this -> debug($reply); + } else { + unset($this -> command); + return; + } + if (is_array($reply)) { + unset($this -> command); + return $reply; + } else { + unset($this -> command); + $this -> debug("Didn't get an array as a reply"); + return false; + } + } + + /** + * Execute an api command + * + * @param string $cmd_str + * @return array of the response or false + */ + function api_command($cmd_str) { + $reply = $this -> send_command("api $cmd_str"); + while ($reply['Content-Type'] != 'api/response') { + if (count($reply) > 0) { + $debug_text = sprintf( + "%s - (%s) != (api/response) adding an event to the output buffer" + , count($reply), $reply['Content-Type'] + ); + $this -> debug($debug_text); + $this -> output_buffer[] = $reply; + } + $reply = $this -> sock_get(); + } + return $reply; + } + + /** + * Execute a backgrounded api command + * + * @param string $cmd_str + * @return array of the response or false + */ + function bgapi_command($cmd_str) { + $reply = $this -> send_command("bgapi $cmd_str"); + while ($reply['Content-Type'] != 'command/reply') { + if (count($reply) > 0) { + $debug_text = sprintf( + "%s - (%s) != (command/reply) adding an event to the output buffer" + , count($reply), $reply['Content-Type'] + ); + $this -> debug($debug_text); + $this -> output_buffer[] = $reply; + } + $reply = $this -> sock_get(); + } + if (array_key_exists('Reply-Text', $reply)) { + $split = split(':', $reply['Reply-Text']); + $uuid = trim($split[1]); + $reply['Job-UUID'] = $uuid; + } + return $reply; + } + + /** + * Pop an event off of the buffer or try to get one from the socket + * + * @return array + */ + function read_event() { + if (count($this -> output_buffer) > 0) { + return array_shift($this -> output_buffer); + } else { + $reply = $this -> sock_get(); + return $reply; + } + } + + /** + * Keep trying read_event until we actually get one + * + * @return array + */ + function wait_for_event() { + $event = array(); + while (count($event) < 1) { + $event = $this -> read_event(); + } + return $event; + } + + /** + * Subscribe to event notifications + * + * @param mixed $events comma-separated or array of events + * @return boolean + */ + function subscribe_events($events) { + if (is_array($events)) { + if (count($events) > 1) { + $events_str = implode(',', $events); + } else { + $events_str = $events[0]; + } + } else { + $events_str = $events; + } + $reply = $this -> send_command("event plain $events_str"); + $this -> debug($reply); + if (ereg('^\+?OK', $reply['Reply-Text'])) { + return true; + } else { + return false; + } + } + + /** + * Function to print out debugging info + * This method will recieve arbitrary data and print it to the screen + * enable/disable by defining FS_SOCK_DEBUG to true/false + * @param mixed $input what to debug, arrays and strings tested, objects MAY work + * @param integer $spaces + */ + function debug($input, $spaces=0) { + if (defined('FS_SOCK_DEBUG') && FS_SOCK_DEBUG == true) { + if (is_array($input)) { + foreach ($input as $key=>$val) { + if (is_array($val) || is_object($val)) { + $this -> debug("[$key] => $val", $spaces+4); + $this -> debug('(', $spaces + 8); + $this -> debug($val, $spaces + 8); + } else { + $this -> debug("[$key] => '$val'", $spaces + 4); + } + } + $this -> debug(")", $spaces); + } else { + if (is_array($_SERVER) + && array_key_exists('HTTP_HOST', $_SERVER)) { + printf("<pre>%s%s</pre>\r\n" + , str_repeat(' ', $spaces) + , htmlentities($input) + ); + } else { + $input = trim($input); + printf("%s%s\r\n", str_repeat(' ', $spaces), $input); + } + } + } + } +} +?> \ No newline at end of file Added: freeswitch/trunk/scripts/contrib/intralanman/PHP/fs_sock/socktest.php ============================================================================== --- (empty file) +++ freeswitch/trunk/scripts/contrib/intralanman/PHP/fs_sock/socktest.php Tue Jan 8 16:55:23 2008 @@ -0,0 +1,62 @@ +<?php +require_once('fs_sock.php'); + +// uncommenting this will produce LARGE amounts of output +// define('FS_SOCK_DEBUG', true); + +// different connection settings, all of these should work with a fresh install +$array[] = array('host'=>'127.0.0.1'); +$array[] = array('host'=>'127.0.0.1', 'port'=>'8021'); +$array[] = array('pass'=>'ClueCon', 'timeout'=>7); +$array[] = array( +'host'=>'localhost', +'port'=>'8021', +'pass'=>'ClueCon', +'timeout'=>3, +'stream_timeout'=>0.5 +); + +// commands to run, initially this was how i caught a few of my bugs +$cmds[] = 'status'; +$cmds[] = 'originate'; +$cmds[] = 'reloadxml'; +$cmds[] = 'invalidapp'; +$cmds[] = 'craptest'; + +$obj = new fs_sock($array[3]); +if ($obj -> auth != true) { + die(printf("Unable to authenticate\r\n")); +} + +if (!$obj -> subscribe_events('ALL')) { + die(printf("Unable to subscribe to events")); +} + +for ($x=0; $x<count($cmds); $x++) { + $debug_string = sprintf("Return ouput from (%s) is:", $cmds[$x]); + $return = $obj -> api_command($cmds[$x]); + $bg_return = $obj -> bgapi_command($cmds[$x]); + + $obj -> debug("$debug_string\r\n"); + $obj -> debug($return); + $obj -> debug($bg_return); +} + + + +//get $items number of items from the event buffer +$output = array(); +$items = 25; +for ($i=0; count($output)<$items; $i++) { + $count = count($output); + printf("%s - %s\r\n", $i+1, $count); + //$output[] = $obj -> read_event(); + $output[] = $obj -> wait_for_event(); +} +$obj -> debug($output); + + + + +$obj -> sock_close(); +?> \ No newline at end of file

1 0

[commit] r7146 - freeswitch/trunk/src
by Freeswitch SVN 08 Jan '08

08 Jan '08

Author: anthm Date: Tue Jan 8 16:43:09 2008 New Revision: 7146 Modified: freeswitch/trunk/src/switch_rtp.c Log: dtmf nightmare continues Modified: freeswitch/trunk/src/switch_rtp.c ============================================================================== --- freeswitch/trunk/src/switch_rtp.c (original) +++ freeswitch/trunk/src/switch_rtp.c Tue Jan 8 16:43:09 2008 @@ -798,6 +798,11 @@ int x, loops = 1, duration; rtp_session->dtmf_data.out_digit_sofar += samples; + if (rtp_session->dtmf_data.out_digit_sofar > 0xFFFF) { + rtp_session->dtmf_data.out_digit_sofar = samples; + rtp_session->dtmf_data.timestamp_dtmf += 0xFFFF; + } + if (rtp_session->dtmf_data.out_digit_sofar >= rtp_session->dtmf_data.out_digit_dur) { duration = rtp_session->dtmf_data.out_digit_dur; rtp_session->dtmf_data.out_digit_packet[1] |= 0x80; @@ -809,11 +814,11 @@ rtp_session->dtmf_data.out_digit_packet[2] = (unsigned char) (duration >> 8); rtp_session->dtmf_data.out_digit_packet[3] = (unsigned char) duration; - rtp_session->dtmf_data.timestamp_dtmf += samples; + for (x = 0; x < loops; x++) { rtp_session->seq++; - + switch_rtp_write_manual(rtp_session, rtp_session->dtmf_data.out_digit_packet, 4, @@ -835,11 +840,10 @@ void *pop; if (switch_queue_trypop(rtp_session->dtmf_data.dtmf_queue, &pop) == SWITCH_STATUS_SUCCESS) { - int x; switch_dtmf_t *rdigit = pop; memset(rtp_session->dtmf_data.out_digit_packet, 0, 4); - rtp_session->dtmf_data.out_digit_sofar = 0; + rtp_session->dtmf_data.out_digit_sofar = samples; rtp_session->dtmf_data.out_digit_dur = rdigit->duration; rtp_session->dtmf_data.out_digit = rdigit->digit; rtp_session->dtmf_data.out_digit_packet[0] = (unsigned char) switch_char_to_rfc2833(rdigit->digit); @@ -853,22 +857,26 @@ rtp_session->sending_dtmf = 1; - for (x = 0; x < 3; x++) { - rtp_session->seq++; - switch_rtp_write_manual(rtp_session, - rtp_session->dtmf_data.out_digit_packet, - 4, - switch_test_flag(rtp_session, SWITCH_RTP_FLAG_BUGGY_2833) ? 0 : 1, - rtp_session->te, - rtp_session->dtmf_data.timestamp_dtmf, - rtp_session->seq, - rtp_session->dtmf_data.out_digit_ssrc, &flags); - switch_log_printf(SWITCH_CHANNEL_LOG, - SWITCH_LOG_DEBUG, - "Send start packet for [%c] ts=%d sofar=%u dur=%d seq=%d\n", - rtp_session->dtmf_data.out_digit, - rtp_session->dtmf_data.timestamp_dtmf, rtp_session->dtmf_data.out_digit_sofar, 0, rtp_session->seq); - } + + rtp_session->seq++; + switch_rtp_write_manual(rtp_session, + rtp_session->dtmf_data.out_digit_packet, + 4, + switch_test_flag(rtp_session, SWITCH_RTP_FLAG_BUGGY_2833) ? 0 : 1, + rtp_session->te, + rtp_session->dtmf_data.timestamp_dtmf, + rtp_session->seq, + rtp_session->dtmf_data.out_digit_ssrc, &flags); + + switch_log_printf(SWITCH_CHANNEL_LOG, + SWITCH_LOG_DEBUG, + "Send start packet for [%c] ts=%d sofar=%u dur=%d seq=%d\n", + rtp_session->dtmf_data.out_digit, + rtp_session->dtmf_data.timestamp_dtmf, + rtp_session->dtmf_data.out_digit_sofar, + 0, + rtp_session->seq); + free(rdigit); } }

1 0

[commit] r7145 - freeswitch/trunk/conf/dialplan
by Freeswitch SVN 08 Jan '08

08 Jan '08

Author: brian Date: Tue Jan 8 16:10:07 2008 New Revision: 7145 Modified: freeswitch/trunk/conf/dialplan/default.xml Log: continue is an extension flag ONLY dont do anything on conditions Modified: freeswitch/trunk/conf/dialplan/default.xml ============================================================================== --- freeswitch/trunk/conf/dialplan/default.xml (original) +++ freeswitch/trunk/conf/dialplan/default.xml Tue Jan 8 16:10:07 2008 @@ -55,7 +55,7 @@  <!-- <extension name="refer"> - <condition field="${sip_refer_to}" expression="<sip:${destination_number}@$${domain}>" continue="on_false"/> + <condition field="${sip_refer_to}" expression="<sip:${destination_number}@$${domain}>"/> <condition field="${sip_refer_to}" expression="<sip:(.*)@(.*)>"> <action application="set" data="refer_user=$1"/> <action application="set" data="refer_domain=$2"/>

1 0

[commit] r7144 - freeswitch/trunk/conf/dialplan
by Freeswitch SVN 08 Jan '08

08 Jan '08

Author: brian Date: Tue Jan 8 16:08:31 2008 New Revision: 7144 Modified: freeswitch/trunk/conf/dialplan/default.xml Log: continue is an extension flag ONLY dont do anything on conditions Modified: freeswitch/trunk/conf/dialplan/default.xml ============================================================================== --- freeswitch/trunk/conf/dialplan/default.xml (original) +++ freeswitch/trunk/conf/dialplan/default.xml Tue Jan 8 16:08:31 2008 @@ -4,7 +4,7 @@ <context name="default"> <extension name="unloop"> - <condition field="${unroll_loops}" expression="^true$" continue="on-true"/> + <condition field="${unroll_loops}" expression="^true$"/> <condition field="${sip_looped_call}" expression="^true$"> <action application="deflect" data="${destination_number}"/> </condition> @@ -108,7 +108,7 @@ </extension> <extension name="extension-intercom"> - <condition field="${sip_to_params}" expression="intercom\=true" continue="on-true"/> + <condition field="${sip_to_params}" expression="intercom\=true"/> <condition field="destination_number" expression="^8(10[01][0-9])$"> <action application="set" data="dialed_ext=$1"/> <action application="export" data="sip_h_Call-Info=<sip:$${domain}>;answer-after=0"/> @@ -125,7 +125,7 @@ successful bridge (hangup_after-bridge=true) --> <extension name="Local_Extension"> - <condition field="destination_number" expression="^(10[01][0-9])$" continue="on-true"> + <condition field="destination_number" expression="^(10[01][0-9])$"> <action application="set" data="dialed_ext=$1"/> </condition> <condition field="destination_number" expression="^${caller_id_number}$"> @@ -209,8 +209,8 @@ the softkey on the phone. Should work with other phones. --> <extension name="park"> - <condition field="source" expression="mod_sofia" continue="on-true"/> - <condition field="destination_number" expression="park\+(\d+)" continue="on-true"> + <condition field="source" expression="mod_sofia"/> + <condition field="destination_number" expression="park\+(\d+)"> <action application="fifo" data="$1@$${domain} in undef $${moh_uri}"/> </condition> </extension> @@ -219,8 +219,8 @@ Some phones send things like orbit= and you can extract that info. --> <extension name="unpark"> - <condition field="source" expression="mod_sofia" continue="on-true"/> - <condition field="destination_number" expression="^parking$" continue="on-true"/> + <condition field="source" expression="mod_sofia"/> + <condition field="destination_number" expression="^parking$"/> <condition field="${sip_to_params}" expression="fifo\=(\d+)"> <action application="answer"/> <action application="fifo" data="$1@$${domain} out nowait"/>

1 0

[commit] r7143 - freeswitch/trunk/src
by Freeswitch SVN 08 Jan '08

08 Jan '08

Author: anthm Date: Tue Jan 8 14:38:57 2008 New Revision: 7143 Modified: freeswitch/trunk/src/switch_core_state_machine.c Log: why not Modified: freeswitch/trunk/src/switch_core_state_machine.c ============================================================================== --- freeswitch/trunk/src/switch_core_state_machine.c (original) +++ freeswitch/trunk/src/switch_core_state_machine.c Tue Jan 8 14:38:57 2008 @@ -60,6 +60,8 @@ switch_dialplan_interface_t *dialplan_interface = NULL; switch_caller_profile_t *caller_profile; switch_caller_extension_t *extension = NULL; + char *expanded = NULL; + char *dpstr = NULL; switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Standard RING %s\n", switch_channel_get_name(session->channel)); @@ -69,16 +71,16 @@ return; } else { char *dp[25]; - char *dpstr; int argc, x, count = 0; - + if (!switch_strlen_zero(caller_profile->dialplan)) { if ((dpstr = switch_core_session_strdup(session, caller_profile->dialplan))) { - argc = switch_separate_string(dpstr, ',', dp, (sizeof(dp) / sizeof(dp[0]))); + expanded = switch_channel_expand_variables(session->channel, dpstr); + argc = switch_separate_string(expanded, ',', dp, (sizeof(dp) / sizeof(dp[0]))); for (x = 0; x < argc; x++) { char *dpname = dp[x]; char *dparg = NULL; - + if (dpname) { if ((dparg = strchr(dpname, ':'))) { *dparg++ = '\0'; @@ -87,12 +89,12 @@ if (!(dialplan_interface = switch_loadable_module_get_dialplan_interface(dpname))) { continue; } - + count++; if ((extension = dialplan_interface->hunt_function(session, dparg, NULL)) != 0) { switch_channel_set_caller_extension(session->channel, extension); - return; + goto end; } } } @@ -102,7 +104,7 @@ if (switch_channel_test_flag(session->channel, CF_OUTBOUND)) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "No Dialplan, changing state to HOLD\n"); switch_channel_set_state(session->channel, CS_HOLD); - return; + goto end; } } } @@ -111,6 +113,13 @@ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "No Route, Aborting\n"); switch_channel_hangup(session->channel, SWITCH_CAUSE_NO_ROUTE_DESTINATION); } + + end: + + if (expanded && dpstr && expanded != dpstr) { + free(expanded); + } + } static void switch_core_standard_on_execute(switch_core_session_t *session)

1 0

[commit] r7142 - freeswitch/trunk/src/mod/applications/mod_conference
by Freeswitch SVN 08 Jan '08

08 Jan '08

Author: anthm Date: Tue Jan 8 14:03:47 2008 New Revision: 7142 Modified: freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c Log: fix typo 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 Jan 8 14:03:47 2008 @@ -749,7 +749,7 @@ switch_size_t file_data_len = samples * 2; int has_file_data = 0; - if (conference->perpetual_sound && !conference->fnode) { + if (conference->perpetual_sound && !conference->async_fnode) { conference_play_file(conference, conference->perpetual_sound, CONF_DEFAULT_LEADIN, NULL, 1); } else if (conference->moh_sound && conference->count == 1 && !conference->async_fnode) { conference_play_file(conference, conference->moh_sound, CONF_DEFAULT_LEADIN, NULL, 1);

1 0