Generic File Format Support. Should be included by clients of the file handling routines. File service providers should instead include mod_format.h. More...
#include <fcntl.h>
#include <sys/mman.h>
Go to the source code of this file.
Defines | |
#define | AST_DIGIT_ANY "0123456789#*ABCD" |
#define | AST_DIGIT_ANYNUM "0123456789" |
#define | AST_MAX_FORMATS 10 |
#define | AST_RESERVED_POINTERS 20 |
#define | SEEK_FORCECUR 10 |
Functions | |
int | ast_applystream (struct ast_channel *chan, struct ast_filestream *s) |
Applys a open stream to a channel. | |
int | ast_closestream (struct ast_filestream *f) |
Closes a stream. | |
int | ast_file_init (void) |
int | ast_filecopy (const char *oldname, const char *newname, const char *fmt) |
Copies a file. | |
int | ast_filedelete (const char *filename, const char *fmt) |
Deletes a file. | |
int | ast_fileexists (const char *filename, const char *fmt, const char *preflang) |
Checks for the existence of a given file. | |
int | ast_filerename (const char *oldname, const char *newname, const char *fmt) |
Renames a file. | |
char * | ast_format_str_reduce (char *fmts) |
struct ast_filestream * | ast_openstream (struct ast_channel *chan, const char *filename, const char *preflang) |
Opens stream for use in seeking, playing. | |
struct ast_filestream * | ast_openstream_full (struct ast_channel *chan, const char *filename, const char *preflang, int asis) |
Opens stream for use in seeking, playing. | |
struct ast_filestream * | ast_openvstream (struct ast_channel *chan, const char *filename, const char *preflang) |
Opens stream for use in seeking, playing. | |
int | ast_playstream (struct ast_filestream *s) |
Play a open stream on a channel. | |
struct ast_filestream * | ast_readfile (const char *filename, const char *type, const char *comment, int flags, int check, mode_t mode) |
Starts reading from a file. | |
struct ast_frame * | ast_readframe (struct ast_filestream *s) |
Read a frame from a filestream. | |
int | ast_seekstream (struct ast_filestream *fs, off_t sample_offset, int whence) |
Seeks into stream. | |
int | ast_stopstream (struct ast_channel *c) |
Stops a stream. | |
int | ast_stream_and_wait (struct ast_channel *chan, const char *file, const char *digits) |
stream file until digit If the file name is non-empty, try to play it. | |
int | ast_stream_fastforward (struct ast_filestream *fs, off_t ms) |
Fast forward stream ms. | |
int | ast_stream_rewind (struct ast_filestream *fs, off_t ms) |
Rewind stream ms. | |
int | ast_streamfile (struct ast_channel *c, const char *filename, const char *preflang) |
Streams a file. | |
off_t | ast_tellstream (struct ast_filestream *fs) |
Tell where we are in a stream. | |
int | ast_truncstream (struct ast_filestream *fs) |
Trunc stream at current location. | |
int | ast_waitstream (struct ast_channel *c, const char *breakon) |
Waits for a stream to stop or digit to be pressed. | |
int | ast_waitstream_exten (struct ast_channel *c, const char *context) |
Waits for a stream to stop or digit matching a valid one digit exten to be pressed. | |
int | ast_waitstream_fr (struct ast_channel *c, const char *breakon, const char *forward, const char *rewind, int ms) |
Same as waitstream but allows stream to be forwarded or rewound. | |
int | ast_waitstream_full (struct ast_channel *c, const char *breakon, int audiofd, int monfd) |
struct ast_filestream * | ast_writefile (const char *filename, const char *type, const char *comment, int flags, int check, mode_t mode) |
Starts writing a file. | |
int | ast_writestream (struct ast_filestream *fs, struct ast_frame *f) |
Writes a frame to a stream. |
Generic File Format Support. Should be included by clients of the file handling routines. File service providers should instead include mod_format.h.
Definition in file file.h.
#define AST_DIGIT_ANY "0123456789#*ABCD" |
Convenient for waiting
Definition at line 47 of file file.h.
Referenced by 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(), dial_exec_full(), dictate_exec(), directory_exec(), feature_attended_transfer(), feature_blind_transfer(), festival_exec(), get_folder(), grab_transfer(), ivr_dispatch(), meetme_menu_admin(), meetme_menu_admin_extended(), menu_callback(), 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(), sayname(), sayunixtime_exec(), select_item_menu(), select_item_seq(), try_calling(), vm_intro_gr(), vm_intro_he(), vm_intro_multilang(), vm_intro_pt(), vm_intro_pt_BR(), vmsayname_exec(), and wait_file2().
#define AST_DIGIT_ANYNUM "0123456789" |
Definition at line 48 of file file.h.
Referenced by initreqprep().
#define AST_MAX_FORMATS 10 |
The maximum number of formats we expect to see in a format string
Definition at line 44 of file file.h.
Referenced by __ast_play_and_record(), and ast_format_str_reduce().
#define SEEK_FORCECUR 10 |
Definition at line 50 of file file.h.
Referenced by __ast_read(), ast_write(), au_seek(), g719seek(), g729_seek(), gsm_seek(), ilbc_seek(), pcm_seek(), siren14seek(), siren7seek(), slinear_seek(), vox_seek(), and wav_seek().
int ast_applystream | ( | struct ast_channel * | chan, | |
struct ast_filestream * | s | |||
) |
Applys a open stream to a channel.
chan | channel to work | |
s | ast_filestream to apply |
0 | on success. | |
-1 | on failure. |
Definition at line 861 of file file.c.
References ast_filestream::owner.
Referenced by ast_streamfile(), handle_getoption(), handle_recordfile(), handle_streamfile(), and speech_streamfile().
00862 { 00863 s->owner = chan; 00864 return 0; 00865 }
int ast_closestream | ( | struct ast_filestream * | f | ) |
Closes a stream.
f | filestream to close Close a playback or recording stream |
0 | on success. | |
-1 | on failure. |
Definition at line 904 of file file.c.
References ao2_ref, and filestream_close().
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(), dictate_exec(), filestream_destructor(), gen_closestream(), handle_cli_file_convert(), handle_recordfile(), local_ast_moh_stop(), mixmonitor_ds_close_fs(), moh_files_release(), record_exec(), and recordthread().
00905 { 00906 /* This used to destroy the filestream, but it now just decrements a refcount. 00907 * We close the stream in order to quit queuing frames now, because we might 00908 * change the writeformat, which could result in a subsequent write error, if 00909 * the format is different. */ 00910 filestream_close(f); 00911 ao2_ref(f, -1); 00912 return 0; 00913 }
int ast_file_init | ( | void | ) |
Initialize file stuff
Initializes all the various file stuff. Basically just registers the cli stuff Returns 0 all the time
Provided by file.c
Definition at line 1503 of file file.c.
References ARRAY_LEN, ast_cli_register_multiple(), ast_register_atexit(), and file_shutdown().
01504 { 01505 ast_cli_register_multiple(cli_file, ARRAY_LEN(cli_file)); 01506 ast_register_atexit(file_shutdown); 01507 return 0; 01508 }
int ast_filecopy | ( | const char * | oldname, | |
const char * | newname, | |||
const char * | fmt | |||
) |
Copies a file.
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 941 of file file.c.
References ACTION_COPY, and ast_filehelper().
Referenced by copy_plain_file(), and vm_forwardoptions().
00942 { 00943 return ast_filehelper(filename, filename2, fmt, ACTION_COPY); 00944 }
int ast_filedelete | ( | const char * | filename, | |
const char * | fmt | |||
) |
Deletes a file.
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 931 of file file.c.
References ACTION_DELETE, and ast_filehelper().
Referenced by __ast_play_and_record(), announce_thread(), ast_monitor_start(), ast_monitor_stop(), conf_free(), conf_run(), dial_exec_full(), handle_cli_file_convert(), leave_voicemail(), play_record_review(), record_exec(), setup_privacy_args(), and vm_delete().
00932 { 00933 return ast_filehelper(filename, NULL, fmt, ACTION_DELETE); 00934 }
int ast_fileexists | ( | const char * | filename, | |
const char * | fmt, | |||
const char * | preflang | |||
) |
Checks for the existence of a given file.
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. |
Definition at line 919 of file file.c.
References ast_alloca, ast_filestream::buf, and fileexists_core().
Referenced by announce_thread(), app_exec(), ast_moh_files_next(), ast_monitor_start(), ast_monitor_stop(), common_exec(), dial_exec_full(), eivr_comm(), forward_message(), get_folder(), invent_message(), leave_voicemail(), meetme_menu_admin_extended(), minivm_delete_exec(), play_file(), play_message(), play_message_callerid(), readexten_exec(), record_exec(), retrydial_exec(), say_character_str_full(), say_digit_str_full(), say_phonetic_str_full(), sayname(), setup_privacy_args(), vm_intro(), vm_newuser(), vm_options(), and vm_tempgreeting().
00920 { 00921 char *buf; 00922 int buflen; 00923 00924 if (preflang == NULL) 00925 preflang = ""; 00926 buflen = strlen(preflang) + strlen(filename) + 4; /* room for everything */ 00927 buf = ast_alloca(buflen); 00928 return fileexists_core(filename, fmt, preflang, buf, buflen); 00929 }
int ast_filerename | ( | const char * | oldname, | |
const char * | newname, | |||
const char * | fmt | |||
) |
Renames a file.
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 |
Definition at line 936 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().
00937 { 00938 return ast_filehelper(filename, filename2, fmt, ACTION_RENAME); 00939 }
char* ast_format_str_reduce | ( | char * | fmts | ) |
Remove duplicate formats from a format string.
fmts | a format string, this string will be modified |
NULL | error |
Definition at line 1382 of file file.c.
References ast_log(), AST_MAX_FORMATS, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, ast_strdupa, ast_format::exts, exts_compare(), f, first, len(), ast_format::list, LOG_WARNING, and type.
Referenced by actual_load_config().
01383 { 01384 struct ast_format *f; 01385 struct ast_format *fmts_ptr[AST_MAX_FORMATS]; 01386 char *fmts_str[AST_MAX_FORMATS]; 01387 char *stringp, *type; 01388 char *orig = fmts; 01389 int i, j, x, first, found = 0; 01390 int len = strlen(fmts) + 1; 01391 int res; 01392 01393 if (AST_RWLIST_RDLOCK(&formats)) { 01394 ast_log(LOG_WARNING, "Unable to lock format list\n"); 01395 return NULL; 01396 } 01397 01398 stringp = ast_strdupa(fmts); 01399 01400 for (x = 0; (type = strsep(&stringp, "|")) && x < AST_MAX_FORMATS; x++) { 01401 AST_RWLIST_TRAVERSE(&formats, f, list) { 01402 if (exts_compare(f->exts, type)) { 01403 found = 1; 01404 break; 01405 } 01406 } 01407 01408 fmts_str[x] = type; 01409 if (found) { 01410 fmts_ptr[x] = f; 01411 } else { 01412 fmts_ptr[x] = NULL; 01413 } 01414 } 01415 AST_RWLIST_UNLOCK(&formats); 01416 01417 first = 1; 01418 for (i = 0; i < x; i++) { 01419 /* ignore invalid entries */ 01420 if (!fmts_ptr[i]) { 01421 ast_log(LOG_WARNING, "ignoring unknown format '%s'\n", fmts_str[i]); 01422 continue; 01423 } 01424 01425 /* special handling for the first entry */ 01426 if (first) { 01427 res = snprintf(fmts, len, "%s", fmts_str[i]); 01428 fmts += res; 01429 len -= res; 01430 first = 0; 01431 continue; 01432 } 01433 01434 found = 0; 01435 for (j = 0; j < i; j++) { 01436 /* this is a duplicate */ 01437 if (fmts_ptr[j] == fmts_ptr[i]) { 01438 found = 1; 01439 break; 01440 } 01441 } 01442 01443 if (!found) { 01444 res = snprintf(fmts, len, "|%s", fmts_str[i]); 01445 fmts += res; 01446 len -= res; 01447 } 01448 } 01449 01450 if (first) { 01451 ast_log(LOG_WARNING, "no known formats found in format list (%s)\n", orig); 01452 return NULL; 01453 } 01454 01455 return orig; 01456 }
struct ast_filestream* ast_openstream | ( | struct ast_channel * | chan, | |
const char * | filename, | |||
const char * | preflang | |||
) | [read] |
Opens stream for use in seeking, playing.
chan | channel to work with | |
filename | to use | |
preflang | prefered language to use |
a | ast_filestream pointer if it opens the file. | |
NULL | on error. |
Definition at line 636 of file file.c.
References ast_openstream_full().
Referenced by ast_streamfile(), dictate_exec(), handle_getoption(), handle_streamfile(), and speech_streamfile().
00637 { 00638 return ast_openstream_full(chan, filename, preflang, 0); 00639 }
struct ast_filestream* ast_openstream_full | ( | struct ast_channel * | chan, | |
const char * | filename, | |||
const char * | preflang, | |||
int | asis | |||
) | [read] |
Opens stream for use in seeking, playing.
chan | channel to work with | |
filename | to use | |
preflang | prefered language to use | |
asis | if set, don't clear generators |
a | ast_filestream pointer if it opens the file. | |
NULL | on error. |
Definition at line 641 of file file.c.
References ACTION_OPEN, ast_alloca, ast_deactivate_generator(), ast_filehelper(), AST_FORMAT_AUDIO_MASK, ast_log(), ast_set_write_format(), ast_stopstream(), ast_filestream::buf, fileexists_core(), ast_channel::generator, LOG_WARNING, ast_channel::oldwriteformat, ast_channel::stream, and ast_channel::writeformat.
Referenced by ast_moh_files_next(), ast_openstream(), and gen_nextfile().
00642 { 00643 /* 00644 * Use fileexists_core() to find a file in a compatible 00645 * language and format, set up a suitable translator, 00646 * and open the stream. 00647 */ 00648 format_t fmts, res; 00649 int buflen; 00650 char *buf; 00651 00652 if (!asis) { 00653 /* do this first, otherwise we detect the wrong writeformat */ 00654 ast_stopstream(chan); 00655 if (chan->generator) 00656 ast_deactivate_generator(chan); 00657 } 00658 if (preflang == NULL) 00659 preflang = ""; 00660 buflen = strlen(preflang) + strlen(filename) + 4; 00661 buf = ast_alloca(buflen); 00662 fmts = fileexists_core(filename, NULL, preflang, buf, buflen); 00663 if (fmts > 0) 00664 fmts &= AST_FORMAT_AUDIO_MASK; 00665 if (fmts < 1) { 00666 ast_log(LOG_WARNING, "File %s does not exist in any format\n", filename); 00667 return NULL; 00668 } 00669 chan->oldwriteformat = chan->writeformat; 00670 /* Set the channel to a format we can work with */ 00671 res = ast_set_write_format(chan, fmts); 00672 if (res == -1) { /* No format available that works with this channel */ 00673 return NULL; 00674 } 00675 res = ast_filehelper(buf, chan, NULL, ACTION_OPEN); 00676 if (res >= 0) 00677 return chan->stream; 00678 return NULL; 00679 }
struct ast_filestream* ast_openvstream | ( | struct ast_channel * | chan, | |
const char * | filename, | |||
const char * | preflang | |||
) | [read] |
Opens stream for use in seeking, playing.
chan | channel to work with | |
filename | to use | |
preflang | prefered language to use |
a | ast_filestream pointer if it opens the file. | |
NULL | on error. |
Definition at line 681 of file file.c.
References ACTION_OPEN, ast_alloca, ast_filehelper(), AST_FORMAT_FIRST_VIDEO_BIT, AST_FORMAT_VIDEO_MASK, 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().
00682 { 00683 /* As above, but for video. But here we don't have translators 00684 * so we must enforce a format. 00685 */ 00686 format_t format; 00687 char *buf; 00688 int buflen; 00689 00690 if (preflang == NULL) 00691 preflang = ""; 00692 buflen = strlen(preflang) + strlen(filename) + 4; 00693 buf = ast_alloca(buflen); 00694 00695 for (format = AST_FORMAT_FIRST_VIDEO_BIT; format <= AST_FORMAT_VIDEO_MASK; format = format << 1) { 00696 int fd; 00697 const char *fmt; 00698 00699 if (!(chan->nativeformats & format)) 00700 continue; 00701 fmt = ast_getformatname(format); 00702 if ( fileexists_core(filename, fmt, preflang, buf, buflen) < 1) /* no valid format */ 00703 continue; 00704 fd = ast_filehelper(buf, chan, fmt, ACTION_OPEN); 00705 if (fd >= 0) 00706 return chan->vstream; 00707 ast_log(LOG_WARNING, "File %s has video but couldn't be opened\n", filename); 00708 } 00709 return NULL; 00710 }
int ast_playstream | ( | struct ast_filestream * | s | ) |
Play a open stream on a channel.
s | filestream to play |
0 | on success. | |
-1 | on failure. |
Definition at line 867 of file file.c.
References AST_FORMAT_AUDIO_MASK, ast_readaudio_callback(), ast_readvideo_callback(), ast_filestream::fmt, ast_format::format, and FSREAD_FAILURE.
Referenced by ast_streamfile(), handle_getoption(), handle_streamfile(), and speech_streamfile().
00868 { 00869 enum fsread_res res; 00870 00871 if (s->fmt->format & AST_FORMAT_AUDIO_MASK) 00872 res = ast_readaudio_callback(s); 00873 else 00874 res = ast_readvideo_callback(s); 00875 00876 return (res == FSREAD_FAILURE) ? -1 : 0; 00877 }
struct ast_filestream* ast_readfile | ( | const char * | filename, | |
const char * | type, | |||
const char * | comment, | |||
int | flags, | |||
int | check, | |||
mode_t | mode | |||
) | [read] |
Starts reading from a file.
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. |
a | struct ast_filestream on success. | |
NULL | on failure. |
Definition at line 997 of file file.c.
References ast_closestream(), ast_free, ast_log(), AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, ast_strdup, build_filename(), errno, ast_format::exts, exts_compare(), f, ast_filestream::filename, ast_filestream::flags, ast_filestream::fmt, get_filestream(), LOG_WARNING, ast_filestream::mode, open_wrapper(), ast_filestream::trans, and ast_filestream::vfs.
Referenced by __ast_play_and_record(), and handle_cli_file_convert().
00998 { 00999 FILE *bfile; 01000 struct ast_format *f; 01001 struct ast_filestream *fs = NULL; 01002 char *fn; 01003 int format_found = 0; 01004 01005 AST_RWLIST_RDLOCK(&formats); 01006 01007 AST_RWLIST_TRAVERSE(&formats, f, list) { 01008 fs = NULL; 01009 if (!exts_compare(f->exts, type)) 01010 continue; 01011 else 01012 format_found = 1; 01013 01014 fn = build_filename(filename, type); 01015 if (!fn) { 01016 continue; 01017 } 01018 errno = 0; 01019 bfile = fopen(fn, "r"); 01020 01021 if (!bfile || (fs = get_filestream(f, bfile)) == NULL || open_wrapper(fs) ) { 01022 ast_log(LOG_WARNING, "Unable to open %s\n", fn); 01023 if (fs) { 01024 ast_closestream(fs); 01025 } 01026 fs = NULL; 01027 bfile = NULL; 01028 ast_free(fn); 01029 break; 01030 } 01031 /* found it */ 01032 fs->trans = NULL; 01033 fs->fmt = f; 01034 fs->flags = flags; 01035 fs->mode = mode; 01036 fs->filename = ast_strdup(filename); 01037 fs->vfs = NULL; 01038 ast_free(fn); 01039 break; 01040 } 01041 01042 AST_RWLIST_UNLOCK(&formats); 01043 if (!format_found) 01044 ast_log(LOG_WARNING, "No such format '%s'\n", type); 01045 01046 return fs; 01047 }
struct ast_frame* ast_readframe | ( | struct ast_filestream * | s | ) | [read] |
Read a frame from a filestream.
s | ast_filestream to act on |
NULL | if read failed. |
Definition at line 737 of file file.c.
References read_frame().
Referenced by __ast_play_and_record(), dictate_exec(), gen_readframe(), handle_cli_file_convert(), and moh_files_readframe().
00738 { 00739 int whennext = 0; 00740 00741 return read_frame(s, &whennext); 00742 }
int ast_seekstream | ( | struct ast_filestream * | fs, | |
off_t | sample_offset, | |||
int | whence | |||
) |
Seeks into stream.
fs | ast_filestream to perform seek on | |
sample_offset | numbers of samples to seek | |
whence | SEEK_SET, SEEK_CUR, SEEK_END |
0 | on success. | |
-1 | on failure. |
Definition at line 879 of file file.c.
References ast_filestream::fmt, and ast_format::seek.
Referenced by __ast_read(), ast_control_streamfile(), ast_moh_files_next(), ast_stream_fastforward(), ast_stream_rewind(), ast_streamfile(), ast_write(), dictate_exec(), handle_getoption(), handle_recordfile(), handle_streamfile(), and speech_streamfile().
int ast_stopstream | ( | struct ast_channel * | c | ) |
Stops a stream.
c | The channel you wish to stop playback on |
Stop playback of a stream
0 | always |
Definition at line 128 of file file.c.
References ast_channel_lock, ast_channel_unlock, ast_closestream(), ast_getformatname(), ast_log(), ast_set_write_format(), LOG_WARNING, ast_channel::oldwriteformat, ast_channel::stream, and ast_channel::vstream.
Referenced by adsi_transmit_message_full(), ast_control_streamfile(), AST_LIST_HEAD(), 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_enumeration_full_vi(), 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_hu(), 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_th(), ast_say_number_full_ur(), ast_say_number_full_vi(), ast_say_number_full_zh(), background_detect_exec(), conf_exec(), conf_run(), dial_exec_full(), directory_exec(), grab_transfer(), handle_getoption(), handle_speechrecognize(), handle_streamfile(), ices_exec(), ivr_dispatch(), leave_voicemail(), meetme_menu_admin(), meetme_menu_admin_extended(), menu_callback(), minivm_greet_exec(), mp3_exec(), NBScat_exec(), parkandannounce_exec(), pbx_builtin_background(), pl_odtworz_plik(), play_file(), play_mailbox_owner(), playback_exec(), queue_exec(), readexten_exec(), record_exec(), recordthread(), s_streamwait3(), say_character_str_full(), say_digit_str_full(), say_phonetic_str_full(), select_item_seq(), send_waveform_to_channel(), speech_background(), vm_authenticate(), vm_execmain(), wait_for_winner(), waitstream_core(), and zapateller_exec().
00129 { 00130 ast_channel_lock(tmp); 00131 00132 /* Stop a running stream if there is one */ 00133 if (tmp->stream) { 00134 ast_closestream(tmp->stream); 00135 tmp->stream = NULL; 00136 if (tmp->oldwriteformat && ast_set_write_format(tmp, tmp->oldwriteformat)) 00137 ast_log(LOG_WARNING, "Unable to restore format back to %s\n", ast_getformatname(tmp->oldwriteformat)); 00138 } 00139 /* Stop the video stream too */ 00140 if (tmp->vstream != NULL) { 00141 ast_closestream(tmp->vstream); 00142 tmp->vstream = NULL; 00143 } 00144 00145 ast_channel_unlock(tmp); 00146 00147 return 0; 00148 }
int ast_stream_and_wait | ( | struct ast_channel * | chan, | |
const char * | file, | |||
const char * | digits | |||
) |
stream file until digit If the file name is non-empty, try to play it.
-1 | if error. | |
digit | if interrupted by a digit. |
Definition at line 1370 of file file.c.
References ast_streamfile(), ast_strlen_zero(), and ast_waitstream().
Referenced by __ast_play_and_record(), announce_user_count(), app_exec(), ast_pickup_call(), ast_record_review(), bridge_playfile(), builtin_atxfer(), builtin_automixmonitor(), builtin_blindtransfer(), confbridge_exec(), directory_exec(), feature_attended_transfer(), feature_blind_transfer(), forward_message(), grab_transfer(), invent_message(), ivr_dispatch(), join_conference_bridge(), leave_voicemail(), masq_park_call(), menu_callback(), park_call_exec(), parked_call_exec(), play_mailbox_owner(), play_message_callerid(), play_message_on_chan(), play_prompt_to_channel(), play_record_review(), play_sound_file(), sayname(), select_item_seq(), vm_forwardoptions(), vmsayname_exec(), wait_file2(), and xfer_park_call_helper().
01371 { 01372 int res = 0; 01373 if (!ast_strlen_zero(file)) { 01374 res = ast_streamfile(chan, file, chan->language); 01375 if (!res) { 01376 res = ast_waitstream(chan, digits); 01377 } 01378 } 01379 return res; 01380 }
int ast_stream_fastforward | ( | struct ast_filestream * | fs, | |
off_t | ms | |||
) |
Fast forward stream ms.
fs | filestream to act on | |
ms | milliseconds to move |
0 | on success. | |
-1 | on failure. |
Definition at line 894 of file file.c.
References ast_seekstream(), and DEFAULT_SAMPLES_PER_MS.
Referenced by waitstream_core().
00895 { 00896 return ast_seekstream(fs, ms * DEFAULT_SAMPLES_PER_MS, SEEK_CUR); 00897 }
int ast_stream_rewind | ( | struct ast_filestream * | fs, | |
off_t | ms | |||
) |
Rewind stream ms.
fs | filestream to act on | |
ms | milliseconds to move |
0 | on success. | |
-1 | on failure. |
Definition at line 899 of file file.c.
References ast_seekstream(), and DEFAULT_SAMPLES_PER_MS.
Referenced by __ast_play_and_record(), handle_recordfile(), record_exec(), and waitstream_core().
00900 { 00901 return ast_seekstream(fs, -ms * DEFAULT_SAMPLES_PER_MS, SEEK_CUR); 00902 }
int ast_streamfile | ( | struct ast_channel * | c, | |
const char * | filename, | |||
const char * | preflang | |||
) |
Streams a file.
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. |
0 | on success. | |
-1 | on failure. |
Definition at line 946 of file file.c.
References ast_applystream(), ast_debug, AST_FLAG_MASQ_NOSTREAM, ast_getformatname(), ast_getformatname_multiple(), ast_log(), ast_openstream(), ast_openvstream(), ast_playstream(), ast_seekstream(), ast_strdup, ast_test_flag, ast_test_suite_event_notify, ast_verb, errno, ast_filestream::f, ast_filestream::fmt, ast_format::format, LOG_WARNING, ast_channel::nativeformats, ast_filestream::orig_chan_name, ast_filestream::vfs, and ast_channel::writeformat.
Referenced by __analog_ss_thread(), action_bridge(), agent_call(), analog_ss_thread(), 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_hu(), ast_say_date_ka(), ast_say_date_nl(), ast_say_date_th(), 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_th(), 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_enumeration_full_vi(), 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_hu(), 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_th(), ast_say_number_full_ur(), ast_say_number_full_vi(), ast_say_number_full_zh(), ast_say_time_de(), ast_say_time_en(), ast_say_time_fr(), ast_say_time_gr(), ast_say_time_hu(), ast_say_time_ka(), ast_say_time_nl(), ast_say_time_zh(), ast_stream_and_wait(), auth_exec(), background_detect_exec(), bridge_exec(), check_availability(), check_beep(), common_exec(), conf_exec(), conf_run(), dial_exec_full(), do_directory(), find_conf_realtime(), forward_message(), gr_say_number_female(), handle_recordfile(), invent_message(), leave_voicemail(), local_attended_transfer(), login_exec(), meetme_menu_admin(), meetme_menu_admin_extended(), meetme_menu_normal(), menu_callback(), minivm_greet_exec(), page_exec(), parkandannounce_exec(), pbx_builtin_background(), pl_odtworz_plik(), play_and_wait(), play_file(), play_record_review(), playback_exec(), privacy_exec(), readexten_exec(), record_exec(), retrydial_exec(), s_streamwait3(), say_character_str_full(), say_digit_str_full(), say_phonetic_str_full(), select_item_menu(), setup_privacy_args(), vm_authenticate(), wait_file(), and wait_for_winner().
00947 { 00948 struct ast_filestream *fs; 00949 struct ast_filestream *vfs=NULL; 00950 char fmt[256]; 00951 off_t pos; 00952 int seekattempt; 00953 int res; 00954 00955 fs = ast_openstream(chan, filename, preflang); 00956 if (!fs) { 00957 ast_log(LOG_WARNING, "Unable to open %s (format %s): %s\n", filename, ast_getformatname_multiple(fmt, sizeof(fmt), chan->nativeformats), strerror(errno)); 00958 return -1; 00959 } 00960 00961 /* check to see if there is any data present (not a zero length file), 00962 * done this way because there is no where for ast_openstream_full to 00963 * return the file had no data. */ 00964 pos = ftello(fs->f); 00965 seekattempt = fseeko(fs->f, -1, SEEK_END); 00966 if (seekattempt) { 00967 if (errno == EINVAL) { 00968 /* Zero-length file, as opposed to a pipe */ 00969 return 0; 00970 } else { 00971 ast_seekstream(fs, 0, SEEK_SET); 00972 } 00973 } else { 00974 fseeko(fs->f, pos, SEEK_SET); 00975 } 00976 00977 vfs = ast_openvstream(chan, filename, preflang); 00978 if (vfs) { 00979 ast_debug(1, "Ooh, found a video stream, too, format %s\n", ast_getformatname(vfs->fmt->format)); 00980 } 00981 00982 if (ast_test_flag(chan, AST_FLAG_MASQ_NOSTREAM)) 00983 fs->orig_chan_name = ast_strdup(chan->name); 00984 if (ast_applystream(chan, fs)) 00985 return -1; 00986 if (vfs && ast_applystream(chan, vfs)) 00987 return -1; 00988 ast_test_suite_event_notify("PLAYBACK", "Message: %s\r\nChannel: %s", filename, chan->name); 00989 res = ast_playstream(fs); 00990 if (!res && vfs) 00991 res = ast_playstream(vfs); 00992 ast_verb(3, "<%s> Playing '%s.%s' (language '%s')\n", chan->name, filename, ast_getformatname(chan->writeformat), preflang ? preflang : "default"); 00993 00994 return res; 00995 }
off_t ast_tellstream | ( | struct ast_filestream * | fs | ) |
Tell where we are in a stream.
fs | fs to act on |
Definition at line 889 of file file.c.
References ast_filestream::fmt, and ast_format::tell.
Referenced by __ast_play_and_record(), ast_control_streamfile(), ast_moh_files_next(), handle_getoption(), handle_recordfile(), handle_speechrecognize(), and handle_streamfile().
int ast_truncstream | ( | struct ast_filestream * | fs | ) |
Trunc stream at current location.
fs | filestream to act on |
0 | on success. | |
-1 | on failure. |
Definition at line 884 of file file.c.
References ast_filestream::fmt, and ast_format::trunc.
Referenced by __ast_play_and_record(), handle_recordfile(), and record_exec().
int ast_waitstream | ( | struct ast_channel * | c, | |
const char * | breakon | |||
) |
Waits for a stream to stop or digit to be pressed.
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, |
0 | if the stream finishes | |
the | character if it was interrupted, | |
-1 | on error |
Definition at line 1343 of file file.c.
References waitstream_core().
Referenced by __analog_ss_thread(), action_bridge(), agent_call(), analog_ss_thread(), announce_thread(), app_exec(), 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_hu(), ast_say_date_ka(), ast_say_date_nl(), ast_say_date_th(), 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_th(), 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_enumeration_full_vi(), 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_hu(), 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_th(), ast_say_number_full_ur(), ast_say_number_full_vi(), ast_say_number_full_zh(), ast_say_time_de(), ast_say_time_en(), ast_say_time_gr(), ast_say_time_he(), ast_say_time_hu(), ast_say_time_ka(), ast_say_time_nl(), ast_say_time_zh(), ast_stream_and_wait(), auth_exec(), bridge_exec(), check_availability(), check_beep(), common_exec(), conf_exec(), conf_run(), directory_exec(), find_conf_realtime(), gr_say_number_female(), handle_recordfile(), invent_message(), leave_voicemail(), local_attended_transfer(), login_exec(), meetme_menu_admin(), meetme_menu_admin_extended(), meetme_menu_normal(), menu_callback(), minivm_greet_exec(), page_exec(), parkandannounce_exec(), pbx_builtin_background(), pl_odtworz_plik(), play_and_wait(), play_file(), play_record_review(), playback_exec(), privacy_exec(), record_exec(), retrydial_exec(), s_streamwait3(), say_character_str_full(), say_digit_str_full(), say_phonetic_str_full(), select_item_menu(), setup_privacy_args(), vm_authenticate(), and wait_file().
01344 { 01345 return waitstream_core(c, breakon, NULL, NULL, 0, -1, -1, NULL); 01346 }
int ast_waitstream_exten | ( | struct ast_channel * | c, | |
const char * | context | |||
) |
Waits for a stream to stop or digit matching a valid one digit exten to be pressed.
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, |
0 | if the stream finishes. | |
the | character if it was interrupted. | |
-1 | on error. |
Definition at line 1354 of file file.c.
References ast_channel::context, and waitstream_core().
Referenced by pbx_builtin_background().
01355 { 01356 /* Waitstream, with return in the case of a valid 1 digit extension */ 01357 /* in the current or specified context being pressed */ 01358 01359 if (!context) 01360 context = c->context; 01361 return waitstream_core(c, NULL, NULL, NULL, 0, 01362 -1, -1, context); 01363 }
int ast_waitstream_fr | ( | struct ast_channel * | c, | |
const char * | breakon, | |||
const char * | forward, | |||
const char * | rewind, | |||
int | ms | |||
) |
Same as waitstream but allows stream to be forwarded or rewound.
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, |
0 | if the stream finishes. | |
the | character if it was interrupted. | |
-1 | on error. |
Definition at line 1337 of file file.c.
References waitstream_core().
Referenced by ast_control_streamfile().
01338 { 01339 return waitstream_core(c, breakon, forward, reverse, ms, 01340 -1 /* no audiofd */, -1 /* no cmdfd */, NULL /* no context */); 01341 }
int ast_waitstream_full | ( | struct ast_channel * | c, | |
const char * | breakon, | |||
int | audiofd, | |||
int | monfd | |||
) |
Same as waitstream, but with audio output to fd and monitored fd checking.
Definition at line 1348 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_enumeration_full_vi(), 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_hu(), 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_th(), ast_say_number_full_ur(), ast_say_number_full_vi(), 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().
01349 { 01350 return waitstream_core(c, breakon, NULL, NULL, 0, 01351 audiofd, cmdfd, NULL /* no context */); 01352 }
struct ast_filestream* ast_writefile | ( | const char * | filename, | |
const char * | type, | |||
const char * | comment, | |||
int | flags, | |||
int | check, | |||
mode_t | mode | |||
) | [read] |
Starts writing a file.
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. |
a | struct ast_filestream on success. | |
NULL | on failure. |
Definition at line 1049 of file file.c.
References ast_alloca, ast_closestream(), ast_free, ast_log(), ast_malloc, ast_opt_cache_record_files, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, ast_strdup, ast_strdupa, ast_filestream::buf, build_filename(), errno, ast_format::exts, exts_compare(), ast_filestream::f, f, ast_filestream::filename, ast_filestream::flags, ast_filestream::fmt, get_filestream(), LOG_WARNING, ast_filestream::mode, ast_filestream::realfilename, record_cache_dir, rewrite_wrapper(), ast_format::seek, ast_filestream::trans, ast_filestream::vfs, and ast_filestream::write_buffer.
Referenced by __ast_play_and_record(), ast_monitor_start(), ast_writestream(), dictate_exec(), handle_cli_file_convert(), handle_recordfile(), mixmonitor_thread(), record_exec(), and recordthread().
01050 { 01051 int fd, myflags = 0; 01052 /* compiler claims this variable can be used before initialization... */ 01053 FILE *bfile = NULL; 01054 struct ast_format *f; 01055 struct ast_filestream *fs = NULL; 01056 char *buf = NULL; 01057 size_t size = 0; 01058 int format_found = 0; 01059 01060 AST_RWLIST_RDLOCK(&formats); 01061 01062 /* set the O_TRUNC flag if and only if there is no O_APPEND specified */ 01063 /* We really can't use O_APPEND as it will break WAV header updates */ 01064 if (flags & O_APPEND) { 01065 flags &= ~O_APPEND; 01066 } else { 01067 myflags = O_TRUNC; 01068 } 01069 01070 myflags |= O_WRONLY | O_CREAT; 01071 01072 /* XXX need to fix this - we should just do the fopen, 01073 * not open followed by fdopen() 01074 */ 01075 AST_RWLIST_TRAVERSE(&formats, f, list) { 01076 char *fn, *orig_fn = NULL; 01077 if (fs) 01078 break; 01079 01080 if (!exts_compare(f->exts, type)) 01081 continue; 01082 else 01083 format_found = 1; 01084 01085 fn = build_filename(filename, type); 01086 if (!fn) { 01087 continue; 01088 } 01089 fd = open(fn, flags | myflags, mode); 01090 if (fd > -1) { 01091 /* fdopen() the resulting file stream */ 01092 bfile = fdopen(fd, ((flags | myflags) & O_RDWR) ? "w+" : "w"); 01093 if (!bfile) { 01094 ast_log(LOG_WARNING, "Whoa, fdopen failed: %s!\n", strerror(errno)); 01095 close(fd); 01096 fd = -1; 01097 } 01098 } 01099 01100 if (ast_opt_cache_record_files && (fd > -1)) { 01101 char *c; 01102 01103 fclose(bfile); /* this also closes fd */ 01104 /* 01105 We touch orig_fn just as a place-holder so other things (like vmail) see the file is there. 01106 What we are really doing is writing to record_cache_dir until we are done then we will mv the file into place. 01107 */ 01108 orig_fn = ast_strdupa(fn); 01109 for (c = fn; *c; c++) 01110 if (*c == '/') 01111 *c = '_'; 01112 01113 size = strlen(fn) + strlen(record_cache_dir) + 2; 01114 buf = ast_alloca(size); 01115 strcpy(buf, record_cache_dir); 01116 strcat(buf, "/"); 01117 strcat(buf, fn); 01118 ast_free(fn); 01119 fn = buf; 01120 fd = open(fn, flags | myflags, mode); 01121 if (fd > -1) { 01122 /* fdopen() the resulting file stream */ 01123 bfile = fdopen(fd, ((flags | myflags) & O_RDWR) ? "w+" : "w"); 01124 if (!bfile) { 01125 ast_log(LOG_WARNING, "Whoa, fdopen failed: %s!\n", strerror(errno)); 01126 close(fd); 01127 fd = -1; 01128 } 01129 } 01130 } 01131 if (fd > -1) { 01132 errno = 0; 01133 fs = get_filestream(f, bfile); 01134 if (fs) { 01135 if ((fs->write_buffer = ast_malloc(32768))) { 01136 setvbuf(fs->f, fs->write_buffer, _IOFBF, 32768); 01137 } 01138 } 01139 if (!fs || rewrite_wrapper(fs, comment)) { 01140 ast_log(LOG_WARNING, "Unable to rewrite %s\n", fn); 01141 close(fd); 01142 if (orig_fn) { 01143 unlink(fn); 01144 unlink(orig_fn); 01145 } 01146 if (fs) { 01147 ast_closestream(fs); 01148 fs = NULL; 01149 } 01150 if (!buf) { 01151 ast_free(fn); 01152 } 01153 continue; 01154 } 01155 fs->trans = NULL; 01156 fs->fmt = f; 01157 fs->flags = flags; 01158 fs->mode = mode; 01159 if (orig_fn) { 01160 fs->realfilename = ast_strdup(orig_fn); 01161 fs->filename = ast_strdup(fn); 01162 } else { 01163 fs->realfilename = NULL; 01164 fs->filename = ast_strdup(filename); 01165 } 01166 fs->vfs = NULL; 01167 /* If truncated, we'll be at the beginning; if not truncated, then append */ 01168 f->seek(fs, 0, SEEK_END); 01169 } else if (errno != EEXIST) { 01170 ast_log(LOG_WARNING, "Unable to open file %s: %s\n", fn, strerror(errno)); 01171 if (orig_fn) 01172 unlink(orig_fn); 01173 } 01174 /* if buf != NULL then fn is already free and pointing to it */ 01175 if (!buf) 01176 ast_free(fn); 01177 } 01178 01179 AST_RWLIST_UNLOCK(&formats); 01180 01181 if (!format_found) 01182 ast_log(LOG_WARNING, "No such format '%s'\n", type); 01183 01184 return fs; 01185 }
int ast_writestream | ( | struct ast_filestream * | fs, | |
struct ast_frame * | f | |||
) |
Writes a frame to a stream.
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 |
0 | on success. | |
-1 | on failure. |
Definition at line 150 of file file.c.
References ast_debug, AST_FORMAT_AUDIO_MASK, 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(), ast_frame_subclass::codec, ast_filestream::filename, ast_filestream::flags, ast_filestream::fmt, ast_format::format, ast_frame::frametype, ast_filestream::lastwriteformat, LOG_WARNING, ast_filestream::mode, ast_format::name, ast_frame::subclass, ast_filestream::trans, type, ast_filestream::vfs, and ast_format::write.
Referenced by __ast_play_and_record(), __ast_read(), ast_write(), ast_writestream(), dictate_exec(), handle_cli_file_convert(), handle_recordfile(), mixmonitor_thread(), record_exec(), and recordthread().
00151 { 00152 int res = -1; 00153 int alt = 0; 00154 if (f->frametype == AST_FRAME_VIDEO) { 00155 if (fs->fmt->format & AST_FORMAT_AUDIO_MASK) { 00156 /* This is the audio portion. Call the video one... */ 00157 if (!fs->vfs && fs->filename) { 00158 const char *type = ast_getformatname(f->subclass.codec & ~0x1); 00159 fs->vfs = ast_writefile(fs->filename, type, NULL, fs->flags, 0, fs->mode); 00160 ast_debug(1, "Opened video output file\n"); 00161 } 00162 if (fs->vfs) 00163 return ast_writestream(fs->vfs, f); 00164 /* else ignore */ 00165 return 0; 00166 } else { 00167 /* Might / might not have mark set */ 00168 alt = 1; 00169 } 00170 } else if (f->frametype != AST_FRAME_VOICE) { 00171 ast_log(LOG_WARNING, "Tried to write non-voice frame\n"); 00172 return -1; 00173 } 00174 if (((fs->fmt->format | alt) & f->subclass.codec) == f->subclass.codec) { 00175 res = fs->fmt->write(fs, f); 00176 if (res < 0) 00177 ast_log(LOG_WARNING, "Natural write failed\n"); 00178 else if (res > 0) 00179 ast_log(LOG_WARNING, "Huh??\n"); 00180 } else { 00181 /* XXX If they try to send us a type of frame that isn't the normal frame, and isn't 00182 the one we've setup a translator for, we do the "wrong thing" XXX */ 00183 if (fs->trans && f->subclass.codec != fs->lastwriteformat) { 00184 ast_translator_free_path(fs->trans); 00185 fs->trans = NULL; 00186 } 00187 if (!fs->trans) 00188 fs->trans = ast_translator_build_path(fs->fmt->format, f->subclass.codec); 00189 if (!fs->trans) 00190 ast_log(LOG_WARNING, "Unable to translate to format %s, source format %s\n", 00191 fs->fmt->name, ast_getformatname(f->subclass.codec)); 00192 else { 00193 struct ast_frame *trf; 00194 fs->lastwriteformat = f->subclass.codec; 00195 /* Get the translated frame but don't consume the original in case they're using it on another stream */ 00196 if ((trf = ast_translate(fs->trans, f, 0))) { 00197 struct ast_frame *cur; 00198 00199 /* the translator may have returned multiple frames, so process them */ 00200 for (cur = trf; cur; cur = AST_LIST_NEXT(cur, frame_list)) { 00201 if ((res = fs->fmt->write(fs, trf))) { 00202 ast_log(LOG_WARNING, "Translated frame write failed\n"); 00203 break; 00204 } 00205 } 00206 ast_frfree(trf); 00207 } else { 00208 res = 0; 00209 } 00210 } 00211 } 00212 return res; 00213 }