#include "asterisk/channel.h"
#include "asterisk/frame.h"
#include <fcntl.h>
Go to the source code of this file.
Data Structures | |
struct | ast_filestream |
struct | ast_format |
struct | ast_format_lock |
Defines | |
#define | AST_DIGIT_ANY "0123456789#*ABCD" |
#define | AST_DIGIT_ANYNUM "0123456789" |
#define | ast_format_register(f) __ast_format_register(f, ast_module_info->self) |
#define | AST_MAX_FORMATS 10 |
#define | AST_RESERVED_POINTERS 20 |
#define | SEEK_FORCECUR 10 |
Functions | |
int | __ast_format_register (const struct ast_format *f, struct ast_module *mod) |
int | ast_applystream (struct ast_channel *chan, struct ast_filestream *s) |
int | ast_closestream (struct ast_filestream *f) |
int | ast_file_init (void) |
int | ast_filecopy (const char *oldname, const char *newname, const char *fmt) |
int | ast_filedelete (const char *filename, const char *fmt) |
int | ast_fileexists (const char *filename, const char *fmt, const char *preflang) |
int | ast_filerename (const char *oldname, const char *newname, const char *fmt) |
char * | ast_format_str_reduce (char *fmts) |
int | ast_format_unregister (const char *name) |
ast_filestream * | ast_openstream (struct ast_channel *chan, const char *filename, const char *preflang) |
ast_filestream * | ast_openstream_full (struct ast_channel *chan, const char *filename, const char *preflang, int asis) |
ast_filestream * | ast_openvstream (struct ast_channel *chan, const char *filename, const char *preflang) |
int | ast_playstream (struct ast_filestream *s) |
ast_filestream * | ast_readfile (const char *filename, const char *type, const char *comment, int flags, int check, mode_t mode) |
ast_frame * | ast_readframe (struct ast_filestream *s) |
int | ast_seekstream (struct ast_filestream *fs, off_t sample_offset, int whence) |
int | ast_stopstream (struct ast_channel *c) |
Stops a stream. | |
int | ast_stream_and_wait (struct ast_channel *chan, const char *file, const char *language, const char *digits) |
int | ast_stream_fastforward (struct ast_filestream *fs, off_t ms) |
int | ast_stream_rewind (struct ast_filestream *fs, off_t ms) |
int | ast_streamfile (struct ast_channel *c, const char *filename, const char *preflang) |
off_t | ast_tellstream (struct ast_filestream *fs) |
int | ast_truncstream (struct ast_filestream *fs) |
int | ast_waitstream (struct ast_channel *c, const char *breakon) |
int | ast_waitstream_exten (struct ast_channel *c, const char *context) |
int | ast_waitstream_fr (struct ast_channel *c, const char *breakon, const char *forward, const char *rewind, int ms) |
int | ast_waitstream_full (struct ast_channel *c, const char *breakon, int audiofd, int monfd) |
ast_filestream * | ast_writefile (const char *filename, const char *type, const char *comment, int flags, int check, mode_t mode) |
int | ast_writestream (struct ast_filestream *fs, struct ast_frame *f) |
Definition in file file.h.
#define AST_DIGIT_ANY "0123456789#*ABCD" |
Convenient for waiting
Definition at line 42 of file file.h.
Referenced by __login_exec(), ast_ivr_menu_run_internal(), ast_play_and_wait(), ast_readstring_full(), ast_record_review(), bridge_playfile(), builtin_atxfer(), builtin_blindtransfer(), conf_exec(), conf_run(), dictate_exec(), directory_exec(), festival_exec(), get_folder(), ivr_dispatch(), pbx_builtin_background(), play_file(), play_mailbox_owner(), play_message(), play_message_callerid(), play_message_datetime(), play_message_duration(), play_record_review(), retrydial_exec(), say_and_wait(), say_position(), sayunixtime_exec(), vm_intro_gr(), vm_intro_he(), vm_intro_multilang(), vm_intro_pt(), vm_intro_pt_BR(), and wait_file2().
#define AST_DIGIT_ANYNUM "0123456789" |
#define ast_format_register | ( | f | ) | __ast_format_register(f, ast_module_info->self) |
#define AST_MAX_FORMATS 10 |
#define SEEK_FORCECUR 10 |
Definition at line 147 of file file.h.
Referenced by __ast_read(), ast_write(), au_seek(), g729_seek(), gsm_seek(), ilbc_seek(), pcm_seek(), slinear_seek(), vox_seek(), and wav_seek().
int __ast_format_register | ( | const struct ast_format * | f, | |
struct ast_module * | mod | |||
) |
Register a new file format capability Adds a format to Asterisk's format abilities. returns 0 on success, -1 on failure
Definition at line 70 of file file.c.
References ast_calloc, AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log(), ast_verbose(), ast_format::buf_size, ast_format::exts, f, ast_format::list, LOG_WARNING, ast_format::module, ast_format::name, option_verbose, and VERBOSE_PREFIX_2.
00071 { 00072 struct ast_format *tmp; 00073 00074 if (AST_LIST_LOCK(&formats)) { 00075 ast_log(LOG_WARNING, "Unable to lock format list\n"); 00076 return -1; 00077 } 00078 AST_LIST_TRAVERSE(&formats, tmp, list) { 00079 if (!strcasecmp(f->name, tmp->name)) { 00080 AST_LIST_UNLOCK(&formats); 00081 ast_log(LOG_WARNING, "Tried to register '%s' format, already registered\n", f->name); 00082 return -1; 00083 } 00084 } 00085 if (!(tmp = ast_calloc(1, sizeof(*tmp)))) { 00086 AST_LIST_UNLOCK(&formats); 00087 return -1; 00088 } 00089 *tmp = *f; 00090 tmp->module = mod; 00091 if (tmp->buf_size) { 00092 /* 00093 * Align buf_size properly, rounding up to the machine-specific 00094 * alignment for pointers. 00095 */ 00096 struct _test_align { void *a, *b; } p; 00097 int align = (char *)&p.b - (char *)&p.a; 00098 tmp->buf_size = ((f->buf_size + align - 1)/align)*align; 00099 } 00100 00101 memset(&tmp->list, 0, sizeof(tmp->list)); 00102 00103 AST_LIST_INSERT_HEAD(&formats, tmp, list); 00104 AST_LIST_UNLOCK(&formats); 00105 if (option_verbose > 1) 00106 ast_verbose( VERBOSE_PREFIX_2 "Registered file format %s, extension(s) %s\n", f->name, f->exts); 00107 00108 return 0; 00109 }
int ast_applystream | ( | struct ast_channel * | chan, | |
struct ast_filestream * | s | |||
) |
chan | channel to work | |
s | ast_filestream to apply Returns 0 for success, -1 on failure |
Definition at line 869 of file file.c.
References s.
Referenced by ast_streamfile(), handle_getoption(), handle_recordfile(), handle_streamfile(), and speech_streamfile().
00870 { 00871 s->owner = chan; 00872 return 0; 00873 }
int ast_closestream | ( | struct ast_filestream * | f | ) |
f | filestream to close Close a playback or recording stream Returns 0 on success, -1 on failure |
Definition at line 912 of file file.c.
References ao2_ref(), AST_FORMAT_AUDIO_MASK, AST_SCHED_DEL, ast_settimeout(), f, and ast_format::format.
Referenced by __ast_play_and_record(), ast_filehelper(), ast_hangup(), ast_moh_files_next(), ast_monitor_start(), ast_monitor_stop(), ast_readfile(), ast_stopstream(), ast_writefile(), cli_audio_convert(), cli_audio_convert_deprecated(), dictate_exec(), filestream_destructor(), gen_closestream(), handle_recordfile(), local_ast_moh_stop(), mixmonitor_ds_close_fs(), moh_files_release(), and rpt().
00913 { 00914 /* This used to destroy the filestream, but it now just decrements a refcount. 00915 * We need to force the stream to quit queuing frames now, because we might 00916 * change the writeformat, which could result in a subsequent write error, if 00917 * the format is different. */ 00918 00919 /* Stop a running stream if there is one */ 00920 if (f->owner) { 00921 if (f->fmt->format < AST_FORMAT_AUDIO_MASK) { 00922 f->owner->stream = NULL; 00923 AST_SCHED_DEL(f->owner->sched, f->owner->streamid); 00924 ast_settimeout(f->owner, 0, NULL, NULL); 00925 } else { 00926 f->owner->vstream = NULL; 00927 AST_SCHED_DEL(f->owner->sched, f->owner->vstreamid); 00928 } 00929 } 00930 00931 ao2_ref(f, -1); 00932 return 0; 00933 }
int ast_file_init | ( | void | ) |
Initializes all the various file stuff. Basically just registers the cli stuff Returns 0 all the time
Definition at line 1513 of file file.c.
References ast_cli_register_multiple(), and cli_file.
Referenced by main().
01514 { 01515 ast_cli_register_multiple(cli_file, sizeof(cli_file) / sizeof(struct ast_cli_entry)); 01516 return 0; 01517 }
int ast_filecopy | ( | const char * | oldname, | |
const char * | newname, | |||
const char * | fmt | |||
) |
oldname | name of the file you wish to copy (minus extension) | |
newname | name you wish the file to be copied to (minus extension) | |
fmt | the format of the file Copy a given file in a given format, or if fmt is NULL, then do so for all |
Definition at line 963 of file file.c.
References ast_filehelper().
Referenced by copy_plain_file(), and vm_forwardoptions().
00964 { 00965 return ast_filehelper(filename, filename2, fmt, ACTION_COPY); 00966 }
int ast_filedelete | ( | const char * | filename, | |
const char * | fmt | |||
) |
filename | name of the file you wish to delete (minus the extension) | |
fmt | of the file Delete a given file in a given format, or if fmt is NULL, then do so for all |
Definition at line 953 of file file.c.
References ACTION_DELETE, and ast_filehelper().
Referenced by __ast_play_and_record(), announce_thread(), ast_monitor_start(), ast_monitor_stop(), cli_audio_convert(), cli_audio_convert_deprecated(), conf_free(), leave_voicemail(), play_mailbox_owner(), play_record_review(), and vm_delete().
00954 { 00955 return ast_filehelper(filename, NULL, fmt, ACTION_DELETE); 00956 }
int ast_fileexists | ( | const char * | filename, | |
const char * | fmt, | |||
const char * | preflang | |||
) |
filename | name of the file you wish to check, minus the extension | |
fmt | the format you wish to check (the extension) | |
preflang | (the preferred language you wisht to find the file in) See if a given file exists in a given format. If fmt is NULL, any format is accepted. Returns 0 if file does not exist, non-zero positive otherwise. |
Definition at line 939 of file file.c.
References ast_filestream::buf, and fileexists_core().
Referenced by announce_thread(), app_exec(), ast_moh_files_next(), ast_monitor_start(), ast_monitor_stop(), common_exec(), forward_message(), leave_voicemail(), play_file(), play_greeting(), play_mailbox_owner(), play_message_callerid(), record_exec(), retrydial_exec(), say_character_str_full(), say_digit_str_full(), say_phonetic_str_full(), vm_intro(), vm_newuser(), vm_options(), and vm_tempgreeting().
00940 { 00941 char *buf; 00942 int buflen; 00943 00944 if (preflang == NULL) 00945 preflang = ""; 00946 buflen = strlen(preflang) + strlen(filename) + 4; /* room for everything */ 00947 buf = alloca(buflen); 00948 if (buf == NULL) 00949 return 0; 00950 return fileexists_core(filename, fmt, preflang, buf, buflen); 00951 }
int ast_filerename | ( | const char * | oldname, | |
const char * | newname, | |||
const char * | fmt | |||
) |
oldname | the name of the file you wish to act upon (minus the extension) | |
newname | the name you wish to rename the file to (minus the extension) | |
fmt | the format of the file Rename a given file in a given format, or if fmt is NULL, then do so for all Returns -1 on failure |
Definition at line 958 of file file.c.
References ACTION_RENAME, and ast_filehelper().
Referenced by __ast_play_and_record(), ast_monitor_stop(), forward_message(), leave_voicemail(), play_record_review(), rename_file(), and vm_forwardoptions().
00959 { 00960 return ast_filehelper(filename, filename2, fmt, ACTION_RENAME); 00961 }
char* ast_format_str_reduce | ( | char * | fmts | ) |
fmts | a format string, this string will be modified |
NULL | error |
Definition at line 1368 of file file.c.
References AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log(), AST_MAX_FORMATS, ast_strdupa, ast_format::exts, exts_compare(), f, first, len(), ast_format::list, LOG_WARNING, and type.
Referenced by load_config().
01369 { 01370 struct ast_format *f; 01371 struct ast_format *fmts_ptr[AST_MAX_FORMATS]; 01372 char *fmts_str[AST_MAX_FORMATS]; 01373 char *stringp, *type; 01374 char *orig = fmts; 01375 int i, j, x, first, found = 0; 01376 int len = strlen(fmts) + 1; 01377 int res; 01378 01379 if (AST_LIST_LOCK(&formats)) { 01380 ast_log(LOG_WARNING, "Unable to lock format list\n"); 01381 return NULL; 01382 } 01383 01384 stringp = ast_strdupa(fmts); 01385 01386 for (x = 0; (type = strsep(&stringp, "|")) && x < AST_MAX_FORMATS; x++) { 01387 AST_LIST_TRAVERSE(&formats, f, list) { 01388 if (exts_compare(f->exts, type)) { 01389 found = 1; 01390 break; 01391 } 01392 } 01393 01394 fmts_str[x] = type; 01395 if (found) { 01396 fmts_ptr[x] = f; 01397 } else { 01398 fmts_ptr[x] = NULL; 01399 } 01400 } 01401 AST_LIST_UNLOCK(&formats); 01402 01403 first = 1; 01404 for (i = 0; i < x; i++) { 01405 /* ignore invalid entries */ 01406 if (!fmts_ptr[i]) { 01407 ast_log(LOG_WARNING, "ignoring unknown format '%s'\n", fmts_str[i]); 01408 continue; 01409 } 01410 01411 /* special handling for the first entry */ 01412 if (first) { 01413 res = snprintf(fmts, len, "%s", fmts_str[i]); 01414 fmts += res; 01415 len -= res; 01416 first = 0; 01417 continue; 01418 } 01419 01420 found = 0; 01421 for (j = 0; j < i; j++) { 01422 /* this is a duplicate */ 01423 if (fmts_ptr[j] == fmts_ptr[i]) { 01424 found = 1; 01425 break; 01426 } 01427 } 01428 01429 if (!found) { 01430 res = snprintf(fmts, len, "|%s", fmts_str[i]); 01431 fmts += res; 01432 len -= res; 01433 } 01434 } 01435 01436 if (first) { 01437 ast_log(LOG_WARNING, "no known formats found in format list (%s)\n", orig); 01438 return NULL; 01439 } 01440 01441 return orig; 01442 }
int ast_format_unregister | ( | const char * | name | ) |
name | the name of the format you wish to unregister Unregisters a format based on the name of the format. Returns 0 on success, -1 on failure to unregister |
Definition at line 111 of file file.c.
References AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log(), ast_verbose(), free, ast_format::list, LOG_WARNING, ast_format::name, option_verbose, and VERBOSE_PREFIX_2.
Referenced by unload_module().
00112 { 00113 struct ast_format *tmp; 00114 int res = -1; 00115 00116 if (AST_LIST_LOCK(&formats)) { 00117 ast_log(LOG_WARNING, "Unable to lock format list\n"); 00118 return -1; 00119 } 00120 AST_LIST_TRAVERSE_SAFE_BEGIN(&formats, tmp, list) { 00121 if (!strcasecmp(name, tmp->name)) { 00122 AST_LIST_REMOVE_CURRENT(&formats, list); 00123 free(tmp); 00124 res = 0; 00125 } 00126 } 00127 AST_LIST_TRAVERSE_SAFE_END 00128 AST_LIST_UNLOCK(&formats); 00129 00130 if (!res) { 00131 if (option_verbose > 1) 00132 ast_verbose( VERBOSE_PREFIX_2 "Unregistered format %s\n", name); 00133 } else 00134 ast_log(LOG_WARNING, "Tried to unregister format %s, already unregistered\n", name); 00135 00136 return res; 00137 }
struct ast_filestream* ast_openstream | ( | struct ast_channel * | chan, | |
const char * | filename, | |||
const char * | preflang | |||
) |
chan | channel to work with | |
filename | to use | |
preflang | prefered language to use Returns a ast_filestream pointer if it opens the file, NULL on error |
Definition at line 634 of file file.c.
References ast_openstream_full().
Referenced by ast_streamfile(), dictate_exec(), handle_getoption(), handle_streamfile(), and speech_streamfile().
00635 { 00636 return ast_openstream_full(chan, filename, preflang, 0); 00637 }
struct ast_filestream* ast_openstream_full | ( | struct ast_channel * | chan, | |
const char * | filename, | |||
const char * | preflang, | |||
int | asis | |||
) |
chan | channel to work with | |
filename | to use | |
preflang | prefered language to use | |
asis | if set, don't clear generators Returns a ast_filestream pointer if it opens the file, NULL on error |
Definition at line 639 of file file.c.
References ACTION_OPEN, ast_deactivate_generator(), ast_filehelper(), AST_FORMAT_AUDIO_MASK, ast_log(), ast_set_write_format(), ast_stopstream(), ast_filestream::buf, fileexists_core(), LOG_WARNING, ast_channel::oldwriteformat, ast_channel::stream, and ast_channel::writeformat.
Referenced by ast_openstream(), and gen_nextfile().
00640 { 00641 /* 00642 * Use fileexists_core() to find a file in a compatible 00643 * language and format, set up a suitable translator, 00644 * and open the stream. 00645 */ 00646 int fmts, res, buflen; 00647 char *buf; 00648 00649 if (!asis) { 00650 /* do this first, otherwise we detect the wrong writeformat */ 00651 ast_stopstream(chan); 00652 if (chan->generator) 00653 ast_deactivate_generator(chan); 00654 } 00655 if (preflang == NULL) 00656 preflang = ""; 00657 buflen = strlen(preflang) + strlen(filename) + 4; 00658 buf = alloca(buflen); 00659 if (buf == NULL) 00660 return NULL; 00661 fmts = fileexists_core(filename, NULL, preflang, buf, buflen); 00662 if (fmts > 0) 00663 fmts &= AST_FORMAT_AUDIO_MASK; 00664 if (fmts < 1) { 00665 ast_log(LOG_WARNING, "File %s does not exist in any format\n", filename); 00666 return NULL; 00667 } 00668 chan->oldwriteformat = chan->writeformat; 00669 /* Set the channel to a format we can work with */ 00670 res = ast_set_write_format(chan, fmts); 00671 if (res == -1) { /* No format available that works with this channel */ 00672 return NULL; 00673 } 00674 res = ast_filehelper(buf, chan, NULL, ACTION_OPEN); 00675 if (res >= 0) 00676 return chan->stream; 00677 return NULL; 00678 }
struct ast_filestream* ast_openvstream | ( | struct ast_channel * | chan, | |
const char * | filename, | |||
const char * | preflang | |||
) |
chan | channel to work with | |
filename | to use | |
preflang | prefered language to use Returns a ast_filestream pointer if it opens the file, NULL on error |
Definition at line 680 of file file.c.
References ACTION_OPEN, ast_filehelper(), AST_FORMAT_MAX_AUDIO, AST_FORMAT_MAX_VIDEO, ast_getformatname(), ast_log(), ast_filestream::buf, fileexists_core(), ast_filestream::fmt, format, LOG_WARNING, ast_channel::nativeformats, and ast_channel::vstream.
Referenced by ast_streamfile(), handle_getoption(), and handle_streamfile().
00681 { 00682 /* As above, but for video. But here we don't have translators 00683 * so we must enforce a format. 00684 */ 00685 unsigned int format; 00686 char *buf; 00687 int buflen; 00688 00689 if (preflang == NULL) 00690 preflang = ""; 00691 buflen = strlen(preflang) + strlen(filename) + 4; 00692 buf = alloca(buflen); 00693 if (buf == NULL) 00694 return NULL; 00695 00696 for (format = AST_FORMAT_MAX_AUDIO << 1; format <= AST_FORMAT_MAX_VIDEO; format = format << 1) { 00697 int fd; 00698 const char *fmt; 00699 00700 if (!(chan->nativeformats & format)) 00701 continue; 00702 fmt = ast_getformatname(format); 00703 if ( fileexists_core(filename, fmt, preflang, buf, buflen) < 1) /* no valid format */ 00704 continue; 00705 fd = ast_filehelper(buf, chan, fmt, ACTION_OPEN); 00706 if (fd >= 0) 00707 return chan->vstream; 00708 ast_log(LOG_WARNING, "File %s has video but couldn't be opened\n", filename); 00709 } 00710 return NULL; 00711 }
int ast_playstream | ( | struct ast_filestream * | s | ) |
s | filestream to play Returns 0 for success, -1 on failure |
Definition at line 875 of file file.c.
References AST_FORMAT_MAX_AUDIO, ast_readaudio_callback(), ast_readvideo_callback(), FSREAD_FAILURE, and s.
Referenced by ast_streamfile(), handle_getoption(), handle_streamfile(), and speech_streamfile().
00876 { 00877 enum fsread_res res; 00878 00879 if (s->fmt->format < AST_FORMAT_MAX_AUDIO) 00880 res = ast_readaudio_callback(s); 00881 else 00882 res = ast_readvideo_callback(s); 00883 00884 return (res == FSREAD_FAILURE) ? -1 : 0; 00885 }
struct ast_filestream* ast_readfile | ( | const char * | filename, | |
const char * | type, | |||
const char * | comment, | |||
int | flags, | |||
int | check, | |||
mode_t | mode | |||
) |
filename | the name of the file to read from | |
type | format of file you wish to read from | |
comment | comment to go with | |
flags | file flags | |
check | (unimplemented, hence negligible) | |
mode | Open mode Open an incoming file stream. flags are flags for the open() command, and if check is non-zero, then it will not read a file if there are any files that start with that name and have an extension Please note, this is a blocking function. Program execution will not return until ast_waitstream completes it's execution. Returns a struct ast_filestream on success, NULL on failure |
Definition at line 999 of file file.c.
References ast_closestream(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log(), build_filename(), errno, ast_format::exts, exts_compare(), f, ast_filestream::filename, ast_filestream::flags, ast_filestream::fmt, free, get_filestream(), LOG_WARNING, ast_filestream::mode, open_wrapper(), strdup, ast_filestream::trans, and ast_filestream::vfs.
Referenced by __ast_play_and_record(), cli_audio_convert(), and cli_audio_convert_deprecated().
01000 { 01001 FILE *bfile; 01002 struct ast_format *f; 01003 struct ast_filestream *fs = NULL; 01004 char *fn; 01005 01006 if (AST_LIST_LOCK(&formats)) { 01007 ast_log(LOG_WARNING, "Unable to lock format list\n"); 01008 return NULL; 01009 } 01010 01011 AST_LIST_TRAVERSE(&formats, f, list) { 01012 fs = NULL; 01013 if (!exts_compare(f->exts, type)) 01014 continue; 01015 01016 fn = build_filename(filename, type); 01017 errno = 0; 01018 bfile = fopen(fn, "r"); 01019 if (!bfile || (fs = get_filestream(f, bfile)) == NULL || 01020 open_wrapper(fs) ) { 01021 ast_log(LOG_WARNING, "Unable to open %s\n", fn); 01022 if (fs) { 01023 ast_closestream(fs); 01024 } 01025 fs = NULL; 01026 bfile = NULL; 01027 free(fn); 01028 continue; 01029 } 01030 /* found it */ 01031 fs->trans = NULL; 01032 fs->fmt = f; 01033 fs->flags = flags; 01034 fs->mode = mode; 01035 fs->filename = strdup(filename); 01036 fs->vfs = NULL; 01037 break; 01038 } 01039 01040 AST_LIST_UNLOCK(&formats); 01041 if (!fs) 01042 ast_log(LOG_WARNING, "No such format '%s'\n", type); 01043 01044 return fs; 01045 }
struct ast_frame* ast_readframe | ( | struct ast_filestream * | s | ) |
s | ast_filestream to act on Returns a frame or NULL if read failed |
Definition at line 738 of file file.c.
References read_frame(), and s.
Referenced by __ast_play_and_record(), cli_audio_convert(), cli_audio_convert_deprecated(), dictate_exec(), gen_readframe(), and moh_files_readframe().
00739 { 00740 int whennext = 0; 00741 00742 return read_frame(s, &whennext); 00743 }
int ast_seekstream | ( | struct ast_filestream * | fs, | |
off_t | sample_offset, | |||
int | whence | |||
) |
fs | ast_filestream to perform seek on | |
sample_offset | numbers of samples to seek | |
whence | SEEK_SET, SEEK_CUR, SEEK_END Returns 0 for success, or -1 for error |
Definition at line 887 of file file.c.
References ast_filestream::fmt, and ast_format::seek.
Referenced by __ast_read(), ast_control_streamfile(), ast_stream_fastforward(), ast_stream_rewind(), ast_write(), dictate_exec(), handle_getoption(), handle_recordfile(), and handle_streamfile().
int ast_stopstream | ( | struct ast_channel * | c | ) |
Stops a stream.
c | The channel you wish to stop playback on |
0 | always |
Definition at line 139 of file file.c.
References ast_channel_lock, ast_channel_unlock, ast_closestream(), ast_log(), ast_set_write_format(), LOG_WARNING, ast_channel::oldwriteformat, ast_channel::stream, and ast_channel::vstream.
Referenced by ast_adsi_transmit_message_full(), ast_control_streamfile(), ast_openstream_full(), ast_play_and_wait(), ast_readstring_full(), ast_say_enumeration_full_da(), ast_say_enumeration_full_de(), ast_say_enumeration_full_en(), ast_say_enumeration_full_he(), ast_say_number_full_cs(), ast_say_number_full_da(), ast_say_number_full_de(), ast_say_number_full_en(), ast_say_number_full_en_GB(), ast_say_number_full_es(), ast_say_number_full_fr(), ast_say_number_full_gr(), ast_say_number_full_he(), ast_say_number_full_it(), ast_say_number_full_ka(), ast_say_number_full_nl(), ast_say_number_full_no(), ast_say_number_full_pt(), ast_say_number_full_ru(), ast_say_number_full_se(), ast_say_number_full_zh(), background_detect_exec(), builtin_blindtransfer(), conf_exec(), conf_run(), directory_exec(), handle_getoption(), handle_streamfile(), ices_exec(), ivr_dispatch(), leave_voicemail(), mp3_exec(), NBScat_exec(), parkandannounce_exec(), pbx_builtin_background(), pl_odtworz_plik(), play_file(), play_mailbox_owner(), playback_exec(), queue_exec(), read_exec(), recordthread(), rpt_tele_thread(), s_streamwait3(), say_character_str_full(), say_digit_str_full(), say_phonetic_str_full(), saycharstr(), sayfile(), saynum(), send_morse(), send_tone_telemetry(), send_waveform_to_channel(), speech_background(), vm_authenticate(), vm_execmain(), wait_for_winner(), waitstream_core(), and zapateller_exec().
00140 { 00141 ast_channel_lock(tmp); 00142 00143 /* Stop a running stream if there is one */ 00144 if (tmp->stream) { 00145 ast_closestream(tmp->stream); 00146 tmp->stream = NULL; 00147 if (tmp->oldwriteformat && ast_set_write_format(tmp, tmp->oldwriteformat)) 00148 ast_log(LOG_WARNING, "Unable to restore format back to %d\n", tmp->oldwriteformat); 00149 } 00150 /* Stop the video stream too */ 00151 if (tmp->vstream != NULL) { 00152 ast_closestream(tmp->vstream); 00153 tmp->vstream = NULL; 00154 } 00155 00156 ast_channel_unlock(tmp); 00157 00158 return 0; 00159 }
int ast_stream_and_wait | ( | struct ast_channel * | chan, | |
const char * | file, | |||
const char * | language, | |||
const char * | digits | |||
) |
Definition at line 1356 of file file.c.
References ast_streamfile(), ast_strlen_zero(), and ast_waitstream().
Referenced by __ast_play_and_record(), app_exec(), ast_record_review(), bridge_playfile(), builtin_atxfer(), builtin_automonitor(), builtin_blindtransfer(), directory_exec(), invent_message(), ivr_dispatch(), leave_voicemail(), masq_park_call(), park_exec(), play_mailbox_owner(), play_message_callerid(), play_record_review(), and wait_file2().
01358 { 01359 int res = 0; 01360 if (!ast_strlen_zero(file)) { 01361 res = ast_streamfile(chan, file, language); 01362 if (!res) 01363 res = ast_waitstream(chan, digits); 01364 } 01365 return res; 01366 }
int ast_stream_fastforward | ( | struct ast_filestream * | fs, | |
off_t | ms | |||
) |
fs | filestream to act on | |
ms | milliseconds to move Returns 0 for success, or -1 for error |
Definition at line 902 of file file.c.
References ast_seekstream(), and DEFAULT_SAMPLES_PER_MS.
Referenced by waitstream_core().
00903 { 00904 return ast_seekstream(fs, ms * DEFAULT_SAMPLES_PER_MS, SEEK_CUR); 00905 }
int ast_stream_rewind | ( | struct ast_filestream * | fs, | |
off_t | ms | |||
) |
fs | filestream to act on | |
ms | milliseconds to move Returns 0 for success, or -1 for error |
Definition at line 907 of file file.c.
References ast_seekstream(), and DEFAULT_SAMPLES_PER_MS.
Referenced by __ast_play_and_record(), handle_recordfile(), and waitstream_core().
00908 { 00909 return ast_seekstream(fs, -ms * DEFAULT_SAMPLES_PER_MS, SEEK_CUR); 00910 }
int ast_streamfile | ( | struct ast_channel * | c, | |
const char * | filename, | |||
const char * | preflang | |||
) |
c | channel to stream the file to | |
filename | the name of the file you wish to stream, minus the extension | |
preflang | the preferred language you wish to have the file streamed to you in Prepares a channel for the streaming of a file. To start the stream, afterward do a ast_waitstream() on the channel Also, it will stop any existing streams on the channel. Returns 0 on success, or -1 on failure. |
Definition at line 968 of file file.c.
References ast_applystream(), AST_FLAG_MASQ_NOSTREAM, ast_getformatname(), ast_getformatname_multiple(), ast_log(), ast_openstream(), ast_openvstream(), ast_playstream(), ast_strdup, ast_test_flag, ast_verbose(), errno, ast_filestream::fmt, ast_format::format, LOG_DEBUG, LOG_WARNING, ast_channel::name, ast_channel::nativeformats, option_verbose, ast_filestream::orig_chan_name, VERBOSE_PREFIX_3, and ast_filestream::vfs.
Referenced by __login_exec(), agent_call(), announce_thread(), app_exec(), ast_app_getdata(), ast_app_getdata_full(), ast_control_streamfile(), ast_play_and_wait(), ast_say_date_da(), ast_say_date_de(), ast_say_date_en(), ast_say_date_fr(), ast_say_date_gr(), ast_say_date_he(), ast_say_date_ka(), ast_say_date_nl(), ast_say_date_with_format_gr(), ast_say_datetime_en(), ast_say_datetime_fr(), ast_say_datetime_from_now_en(), ast_say_datetime_from_now_fr(), ast_say_datetime_from_now_he(), ast_say_datetime_from_now_ka(), ast_say_datetime_gr(), ast_say_datetime_he(), ast_say_datetime_nl(), ast_say_datetime_pt(), ast_say_datetime_zh(), ast_say_enumeration_full_da(), ast_say_enumeration_full_de(), ast_say_enumeration_full_en(), ast_say_enumeration_full_he(), ast_say_number_full_cs(), ast_say_number_full_da(), ast_say_number_full_de(), ast_say_number_full_en(), ast_say_number_full_en_GB(), ast_say_number_full_es(), ast_say_number_full_fr(), ast_say_number_full_gr(), ast_say_number_full_he(), ast_say_number_full_it(), ast_say_number_full_ka(), ast_say_number_full_nl(), ast_say_number_full_no(), ast_say_number_full_pt(), ast_say_number_full_ru(), ast_say_number_full_se(), ast_say_number_full_zh(), ast_say_time_de(), ast_say_time_en(), ast_say_time_fr(), ast_say_time_gr(), ast_say_time_ka(), ast_say_time_nl(), ast_say_time_zh(), ast_stream_and_wait(), background_detect_exec(), check_availability(), check_beep(), common_exec(), conf_exec(), conf_run(), do_directory(), forward_message(), gr_say_number_female(), handle_recordfile(), leave_voicemail(), page_exec(), park_exec(), parkandannounce_exec(), pbx_builtin_background(), pl_odtworz_plik(), play_and_wait(), play_file(), play_greeting(), playback_exec(), privacy_exec(), retrydial_exec(), rpt_tele_thread(), s_streamwait3(), say_character_str_full(), say_digit_str_full(), say_phonetic_str_full(), sayfile(), ss_thread(), vm_authenticate(), wait_file(), and wait_for_winner().
00969 { 00970 struct ast_filestream *fs; 00971 struct ast_filestream *vfs=NULL; 00972 char fmt[256]; 00973 00974 fs = ast_openstream(chan, filename, preflang); 00975 if (fs) 00976 vfs = ast_openvstream(chan, filename, preflang); 00977 if (vfs) 00978 ast_log(LOG_DEBUG, "Ooh, found a video stream, too, format %s\n", ast_getformatname(vfs->fmt->format)); 00979 if (fs){ 00980 int res; 00981 if (ast_test_flag(chan, AST_FLAG_MASQ_NOSTREAM)) 00982 fs->orig_chan_name = ast_strdup(chan->name); 00983 if (ast_applystream(chan, fs)) 00984 return -1; 00985 if (vfs && ast_applystream(chan, vfs)) 00986 return -1; 00987 res = ast_playstream(fs); 00988 if (!res && vfs) 00989 res = ast_playstream(vfs); 00990 if (option_verbose > 2) 00991 ast_verbose(VERBOSE_PREFIX_3 "<%s> Playing '%s' (language '%s')\n", chan->name, filename, preflang ? preflang : "default"); 00992 00993 return res; 00994 } 00995 ast_log(LOG_WARNING, "Unable to open %s (format %s): %s\n", filename, ast_getformatname_multiple(fmt, sizeof(fmt), chan->nativeformats), strerror(errno)); 00996 return -1; 00997 }
off_t ast_tellstream | ( | struct ast_filestream * | fs | ) |
fs | fs to act on Returns a long as a sample offset into stream |
Definition at line 897 of file file.c.
References ast_filestream::fmt, and ast_format::tell.
Referenced by __ast_play_and_record(), ast_control_streamfile(), handle_getoption(), handle_recordfile(), and handle_streamfile().
int ast_truncstream | ( | struct ast_filestream * | fs | ) |
fs | filestream to act on Returns 0 for success, or -1 for error |
Definition at line 892 of file file.c.
References ast_filestream::fmt, and ast_format::trunc.
Referenced by __ast_play_and_record(), and handle_recordfile().
int ast_waitstream | ( | struct ast_channel * | c, | |
const char * | breakon | |||
) |
c | channel to waitstream on | |
breakon | string of DTMF digits to break upon Begins playback of a stream... Wait for a stream to stop or for any one of a given digit to arrive, Returns 0 if the stream finishes, the character if it was interrupted, and -1 on error |
Definition at line 1329 of file file.c.
References waitstream_core().
Referenced by __login_exec(), agent_call(), announce_thread(), app_exec(), ast_play_and_wait(), ast_say_date_da(), ast_say_date_de(), ast_say_date_en(), ast_say_date_es(), ast_say_date_fr(), ast_say_date_gr(), ast_say_date_he(), ast_say_date_ka(), ast_say_date_nl(), ast_say_date_with_format_gr(), ast_say_datetime_en(), ast_say_datetime_fr(), ast_say_datetime_from_now_en(), ast_say_datetime_from_now_fr(), ast_say_datetime_from_now_he(), ast_say_datetime_from_now_ka(), ast_say_datetime_gr(), ast_say_datetime_he(), ast_say_datetime_nl(), ast_say_datetime_pt(), ast_say_datetime_zh(), ast_say_enumeration_full_da(), ast_say_enumeration_full_de(), ast_say_enumeration_full_en(), ast_say_enumeration_full_he(), ast_say_number_full_cs(), ast_say_number_full_da(), ast_say_number_full_de(), ast_say_number_full_en(), ast_say_number_full_en_GB(), ast_say_number_full_es(), ast_say_number_full_fr(), ast_say_number_full_gr(), ast_say_number_full_he(), ast_say_number_full_it(), ast_say_number_full_ka(), ast_say_number_full_nl(), ast_say_number_full_no(), ast_say_number_full_pt(), ast_say_number_full_ru(), ast_say_number_full_se(), ast_say_number_full_zh(), ast_say_time_de(), ast_say_time_en(), ast_say_time_gr(), ast_say_time_he(), ast_say_time_ka(), ast_say_time_nl(), ast_say_time_zh(), ast_stream_and_wait(), check_availability(), check_beep(), common_exec(), conf_exec(), conf_run(), directory_exec(), gr_say_number_female(), handle_recordfile(), leave_voicemail(), page_exec(), park_exec(), parkandannounce_exec(), pbx_builtin_background(), pl_odtworz_plik(), play_and_wait(), play_file(), play_greeting(), playback_exec(), privacy_exec(), retrydial_exec(), rpt_tele_thread(), s_streamwait3(), say_character_str_full(), say_digit_str_full(), say_phonetic_str_full(), saycharstr(), sayfile(), saynum(), send_morse(), send_tone_telemetry(), ss_thread(), vm_authenticate(), and wait_file().
01330 { 01331 return waitstream_core(c, breakon, NULL, NULL, 0, -1, -1, NULL); 01332 }
int ast_waitstream_exten | ( | struct ast_channel * | c, | |
const char * | context | |||
) |
c | channel to waitstream on | |
context | string of context to match digits to break upon Begins playback of a stream... Wait for a stream to stop or for any one of a valid extension digit to arrive, Returns 0 if the stream finishes, the character if it was interrupted, and -1 on error |
Definition at line 1340 of file file.c.
References ast_channel::context, and waitstream_core().
Referenced by pbx_builtin_background().
01341 { 01342 /* Waitstream, with return in the case of a valid 1 digit extension */ 01343 /* in the current or specified context being pressed */ 01344 01345 if (!context) 01346 context = c->context; 01347 return waitstream_core(c, NULL, NULL, NULL, 0, 01348 -1, -1, context); 01349 }
int ast_waitstream_fr | ( | struct ast_channel * | c, | |
const char * | breakon, | |||
const char * | forward, | |||
const char * | rewind, | |||
int | ms | |||
) |
c | channel to waitstream on | |
breakon | string of DTMF digits to break upon | |
forward | DTMF digit to fast forward upon | |
rewind | DTMF digit to rewind upon | |
ms | How many miliseconds to skip forward/back Begins playback of a stream... Wait for a stream to stop or for any one of a given digit to arrive, Returns 0 if the stream finishes, the character if it was interrupted, and -1 on error |
Definition at line 1323 of file file.c.
References waitstream_core().
Referenced by ast_control_streamfile().
01324 { 01325 return waitstream_core(c, breakon, forward, rewind, ms, 01326 -1 /* no audiofd */, -1 /* no cmdfd */, NULL /* no context */); 01327 }
int ast_waitstream_full | ( | struct ast_channel * | c, | |
const char * | breakon, | |||
int | audiofd, | |||
int | monfd | |||
) |
Definition at line 1334 of file file.c.
References waitstream_core().
Referenced by ast_readstring_full(), ast_say_enumeration_full_da(), ast_say_enumeration_full_de(), ast_say_enumeration_full_en(), ast_say_enumeration_full_he(), ast_say_number_full_cs(), ast_say_number_full_da(), ast_say_number_full_de(), ast_say_number_full_en(), ast_say_number_full_en_GB(), ast_say_number_full_es(), ast_say_number_full_fr(), ast_say_number_full_gr(), ast_say_number_full_he(), ast_say_number_full_it(), ast_say_number_full_ka(), ast_say_number_full_nl(), ast_say_number_full_no(), ast_say_number_full_pt(), ast_say_number_full_ru(), ast_say_number_full_se(), ast_say_number_full_zh(), handle_getoption(), handle_streamfile(), pl_odtworz_plik(), s_streamwait3(), say_character_str_full(), say_digit_str_full(), and say_phonetic_str_full().
01335 { 01336 return waitstream_core(c, breakon, NULL, NULL, 0, 01337 audiofd, cmdfd, NULL /* no context */); 01338 }
struct ast_filestream* ast_writefile | ( | const char * | filename, | |
const char * | type, | |||
const char * | comment, | |||
int | flags, | |||
int | check, | |||
mode_t | mode | |||
) |
filename | the name of the file to write to | |
type | format of file you wish to write out to | |
comment | comment to go with | |
flags | output file flags | |
check | (unimplemented, hence negligible) | |
mode | Open mode Create an outgoing file stream. oflags are flags for the open() command, and if check is non-zero, then it will not write a file if there are any files that start with that name and have an extension Please note, this is a blocking function. Program execution will not return until ast_waitstream completes it's execution. Returns a struct ast_filestream on success, NULL on failure |
Definition at line 1047 of file file.c.
References ast_closestream(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log(), ast_opt_cache_record_files, ast_strdupa, ast_filestream::buf, build_filename(), errno, ast_format::exts, exts_compare(), f, ast_filestream::filename, ast_filestream::flags, ast_filestream::fmt, free, get_filestream(), LOG_WARNING, ast_filestream::mode, ast_filestream::realfilename, record_cache_dir, rewrite_wrapper(), ast_format::seek, strdup, ast_filestream::trans, and ast_filestream::vfs.
Referenced by __ast_play_and_record(), ast_monitor_start(), ast_writestream(), cli_audio_convert(), cli_audio_convert_deprecated(), dictate_exec(), handle_recordfile(), mixmonitor_thread(), recordthread(), and rpt().
01048 { 01049 int fd, myflags = 0; 01050 /* compiler claims this variable can be used before initialization... */ 01051 FILE *bfile = NULL; 01052 struct ast_format *f; 01053 struct ast_filestream *fs = NULL; 01054 char *buf = NULL; 01055 size_t size = 0; 01056 int format_found = 0; 01057 01058 if (AST_LIST_LOCK(&formats)) { 01059 ast_log(LOG_WARNING, "Unable to lock format list\n"); 01060 return NULL; 01061 } 01062 01063 /* set the O_TRUNC flag if and only if there is no O_APPEND specified */ 01064 /* We really can't use O_APPEND as it will break WAV header updates */ 01065 if (flags & O_APPEND) { 01066 flags &= ~O_APPEND; 01067 } else { 01068 myflags = O_TRUNC; 01069 } 01070 01071 myflags |= O_WRONLY | O_CREAT; 01072 01073 /* XXX need to fix this - we should just do the fopen, 01074 * not open followed by fdopen() 01075 */ 01076 AST_LIST_TRAVERSE(&formats, f, list) { 01077 char *fn, *orig_fn = NULL; 01078 if (fs) 01079 break; 01080 01081 if (!exts_compare(f->exts, type)) 01082 continue; 01083 else 01084 format_found = 1; 01085 01086 fn = build_filename(filename, type); 01087 fd = open(fn, flags | myflags, mode); 01088 if (fd > -1) { 01089 /* fdopen() the resulting file stream */ 01090 bfile = fdopen(fd, ((flags | myflags) & O_RDWR) ? "w+" : "w"); 01091 if (!bfile) { 01092 ast_log(LOG_WARNING, "Whoa, fdopen failed: %s!\n", strerror(errno)); 01093 close(fd); 01094 fd = -1; 01095 } 01096 } 01097 01098 if (ast_opt_cache_record_files && (fd > -1)) { 01099 char *c; 01100 01101 fclose(bfile); /* this also closes fd */ 01102 /* 01103 We touch orig_fn just as a place-holder so other things (like vmail) see the file is there. 01104 What we are really doing is writing to record_cache_dir until we are done then we will mv the file into place. 01105 */ 01106 orig_fn = ast_strdupa(fn); 01107 for (c = fn; *c; c++) 01108 if (*c == '/') 01109 *c = '_'; 01110 01111 size = strlen(fn) + strlen(record_cache_dir) + 2; 01112 buf = alloca(size); 01113 strcpy(buf, record_cache_dir); 01114 strcat(buf, "/"); 01115 strcat(buf, fn); 01116 free(fn); 01117 fn = buf; 01118 fd = open(fn, flags | myflags, mode); 01119 if (fd > -1) { 01120 /* fdopen() the resulting file stream */ 01121 bfile = fdopen(fd, ((flags | myflags) & O_RDWR) ? "w+" : "w"); 01122 if (!bfile) { 01123 ast_log(LOG_WARNING, "Whoa, fdopen failed: %s!\n", strerror(errno)); 01124 close(fd); 01125 fd = -1; 01126 } 01127 } 01128 } 01129 if (fd > -1) { 01130 errno = 0; 01131 fs = get_filestream(f, bfile); 01132 if (!fs || rewrite_wrapper(fs, comment)) { 01133 ast_log(LOG_WARNING, "Unable to rewrite %s\n", fn); 01134 close(fd); 01135 if (orig_fn) { 01136 unlink(fn); 01137 unlink(orig_fn); 01138 } 01139 if (fs) { 01140 ast_closestream(fs); 01141 fs = NULL; 01142 } 01143 continue; 01144 } 01145 fs->trans = NULL; 01146 fs->fmt = f; 01147 fs->flags = flags; 01148 fs->mode = mode; 01149 if (orig_fn) { 01150 fs->realfilename = strdup(orig_fn); 01151 fs->filename = strdup(fn); 01152 } else { 01153 fs->realfilename = NULL; 01154 fs->filename = strdup(filename); 01155 } 01156 fs->vfs = NULL; 01157 /* If truncated, we'll be at the beginning; if not truncated, then append */ 01158 f->seek(fs, 0, SEEK_END); 01159 } else if (errno != EEXIST) { 01160 ast_log(LOG_WARNING, "Unable to open file %s: %s\n", fn, strerror(errno)); 01161 if (orig_fn) 01162 unlink(orig_fn); 01163 } 01164 /* if buf != NULL then fn is already free and pointing to it */ 01165 if (!buf) 01166 free(fn); 01167 } 01168 01169 AST_LIST_UNLOCK(&formats); 01170 01171 if (!format_found) 01172 ast_log(LOG_WARNING, "No such format '%s'\n", type); 01173 01174 return fs; 01175 }
int ast_writestream | ( | struct ast_filestream * | fs, | |
struct ast_frame * | f | |||
) |
fs | filestream to write to | |
f | frame to write to the filestream Send a frame to a filestream -- note: does NOT free the frame, call ast_frfree manually Returns 0 on success, -1 on failure. |
Definition at line 161 of file file.c.
References AST_FORMAT_MAX_AUDIO, AST_FRAME_VIDEO, AST_FRAME_VOICE, ast_frfree, ast_getformatname(), AST_LIST_NEXT, ast_log(), ast_translate(), ast_translator_build_path(), ast_translator_free_path(), ast_writefile(), ast_writestream(), f, ast_filestream::filename, ast_filestream::flags, ast_filestream::fmt, ast_format::format, ast_filestream::lastwriteformat, LOG_DEBUG, LOG_WARNING, ast_filestream::mode, ast_format::name, ast_filestream::trans, type, ast_filestream::vfs, and ast_format::write.
Referenced by __ast_play_and_record(), __ast_read(), ast_write(), ast_writestream(), cli_audio_convert(), cli_audio_convert_deprecated(), dictate_exec(), handle_recordfile(), mixmonitor_thread(), recordthread(), and rpt().
00162 { 00163 int res = -1; 00164 int alt = 0; 00165 if (f->frametype == AST_FRAME_VIDEO) { 00166 if (fs->fmt->format < AST_FORMAT_MAX_AUDIO) { 00167 /* This is the audio portion. Call the video one... */ 00168 if (!fs->vfs && fs->filename) { 00169 const char *type = ast_getformatname(f->subclass & ~0x1); 00170 fs->vfs = ast_writefile(fs->filename, type, NULL, fs->flags, 0, fs->mode); 00171 ast_log(LOG_DEBUG, "Opened video output file\n"); 00172 } 00173 if (fs->vfs) 00174 return ast_writestream(fs->vfs, f); 00175 /* else ignore */ 00176 return 0; 00177 } else { 00178 /* Might / might not have mark set */ 00179 alt = 1; 00180 } 00181 } else if (f->frametype != AST_FRAME_VOICE) { 00182 ast_log(LOG_WARNING, "Tried to write non-voice frame\n"); 00183 return -1; 00184 } 00185 if (((fs->fmt->format | alt) & f->subclass) == f->subclass) { 00186 res = fs->fmt->write(fs, f); 00187 if (res < 0) 00188 ast_log(LOG_WARNING, "Natural write failed\n"); 00189 else if (res > 0) 00190 ast_log(LOG_WARNING, "Huh??\n"); 00191 } else { 00192 /* XXX If they try to send us a type of frame that isn't the normal frame, and isn't 00193 the one we've setup a translator for, we do the "wrong thing" XXX */ 00194 if (fs->trans && f->subclass != fs->lastwriteformat) { 00195 ast_translator_free_path(fs->trans); 00196 fs->trans = NULL; 00197 } 00198 if (!fs->trans) 00199 fs->trans = ast_translator_build_path(fs->fmt->format, f->subclass); 00200 if (!fs->trans) 00201 ast_log(LOG_WARNING, "Unable to translate to format %s, source format %s\n", 00202 fs->fmt->name, ast_getformatname(f->subclass)); 00203 else { 00204 struct ast_frame *trf; 00205 fs->lastwriteformat = f->subclass; 00206 /* Get the translated frame but don't consume the original in case they're using it on another stream */ 00207 if ((trf = ast_translate(fs->trans, f, 0))) { 00208 struct ast_frame *cur; 00209 00210 /* the translator may have returned multiple frames, so process them */ 00211 for (cur = trf; cur; cur = AST_LIST_NEXT(cur, frame_list)) { 00212 if ((res = fs->fmt->write(fs, trf))) { 00213 ast_log(LOG_WARNING, "Translated frame write failed\n"); 00214 break; 00215 } 00216 } 00217 ast_frfree(trf); 00218 } else { 00219 res = 0; 00220 } 00221 } 00222 } 00223 return res; 00224 }