Frame and codec manipulation routines. More...
#include "asterisk.h"#include "asterisk/_private.h"#include "asterisk/lock.h"#include "asterisk/frame.h"#include "asterisk/channel.h"#include "asterisk/cli.h"#include "asterisk/term.h"#include "asterisk/utils.h"#include "asterisk/threadstorage.h"#include "asterisk/linkedlists.h"#include "asterisk/translate.h"#include "asterisk/dsp.h"#include "asterisk/file.h"
Go to the source code of this file.
Data Structures | |
| struct | ast_codec_alias_table |
| struct | ast_frame_cache |
| struct | ast_frames |
| This is just so ast_frames, a list head struct for holding a list of ast_frame structures, is defined. More... | |
| struct | ast_smoother |
Defines | |
| #define | FRAME_CACHE_MAX_SIZE 10 |
| Maximum ast_frame cache size. | |
| #define | SMOOTHER_SIZE 8000 |
| #define | TYPE_MASK 0x3 |
Enumerations | |
| enum | frame_type { TYPE_HIGH, TYPE_LOW, TYPE_SILENCE, TYPE_DONTSEND } |
Functions | |
| int | __ast_smoother_feed (struct ast_smoother *s, struct ast_frame *f, int swap) |
| static void | __frame_free (struct ast_frame *fr, int cache) |
| static void | __init_frame_cache (void) |
| A per-thread cache of frame headers. | |
| char * | ast_codec2str (int codec) |
| Get a name from a format Gets a name from a format. | |
| int | ast_codec_choose (struct ast_codec_pref *pref, int formats, int find_best) |
| Pick a codec. | |
| int | ast_codec_get_len (int format, int samples) |
| Returns the number of bytes for the number of samples of the given format. | |
| int | ast_codec_get_samples (struct ast_frame *f) |
| Returns the number of samples contained in the frame. | |
| int | ast_codec_pref_append (struct ast_codec_pref *pref, int format) |
| Append codec to list. | |
| void | ast_codec_pref_convert (struct ast_codec_pref *pref, char *buf, size_t size, int right) |
| Shift an audio codec preference list up or down 65 bytes so that it becomes an ASCII string. | |
| struct ast_format_list | ast_codec_pref_getsize (struct ast_codec_pref *pref, int format) |
| Get packet size for codec. | |
| int | ast_codec_pref_index (struct ast_codec_pref *pref, int idx) |
| Codec located at a particular place in the preference index. | |
| void | ast_codec_pref_prepend (struct ast_codec_pref *pref, int format, int only_if_existing) |
| Prepend codec to list. | |
| void | ast_codec_pref_remove (struct ast_codec_pref *pref, int format) |
| Remove codec from pref list. | |
| int | ast_codec_pref_setsize (struct ast_codec_pref *pref, int format, int framems) |
| Set packet size for codec. | |
| int | ast_codec_pref_string (struct ast_codec_pref *pref, char *buf, size_t size) |
| Dump audio codec preference list into a string. | |
| static const char * | ast_expand_codec_alias (const char *in) |
| int | ast_frame_adjust_volume (struct ast_frame *f, int adjustment) |
| Adjusts the volume of the audio samples contained in a frame. | |
| void | ast_frame_dump (const char *name, struct ast_frame *f, char *prefix) |
| void | ast_frame_free (struct ast_frame *frame, int cache) |
| Requests a frame to be allocated. | |
| static struct ast_frame * | ast_frame_header_new (void) |
| int | ast_frame_slinear_sum (struct ast_frame *f1, struct ast_frame *f2) |
| Sums two frames of audio samples. | |
| struct ast_frame * | ast_frdup (const struct ast_frame *f) |
| Copies a frame. | |
| struct ast_frame * | ast_frisolate (struct ast_frame *fr) |
| 'isolates' a frame by duplicating non-malloc'ed components (header, src, data). On return all components are malloc'ed | |
| struct ast_format_list * | ast_get_format_list (size_t *size) |
| struct ast_format_list * | ast_get_format_list_index (int idx) |
| int | ast_getformatbyname (const char *name) |
| Gets a format from a name. | |
| char * | ast_getformatname (int format) |
| Get the name of a format. | |
| char * | ast_getformatname_multiple (char *buf, size_t size, int format) |
| Get the names of a set of formats. | |
| int | ast_parse_allow_disallow (struct ast_codec_pref *pref, int *mask, const char *list, int allowing) |
| Parse an "allow" or "deny" line in a channel or device configuration and update the capabilities mask and pref if provided. Video codecs are not added to codec preference lists, since we can not transcode. | |
| void | ast_smoother_free (struct ast_smoother *s) |
| int | ast_smoother_get_flags (struct ast_smoother *s) |
| struct ast_smoother * | ast_smoother_new (int size) |
| struct ast_frame * | ast_smoother_read (struct ast_smoother *s) |
| void | ast_smoother_reconfigure (struct ast_smoother *s, int bytes) |
| Reconfigure an existing smoother to output a different number of bytes per frame. | |
| void | ast_smoother_reset (struct ast_smoother *s, int bytes) |
| void | ast_smoother_set_flags (struct ast_smoother *s, int flags) |
| int | ast_smoother_test_flag (struct ast_smoother *s, int flag) |
| void | ast_swapcopy_samples (void *dst, const void *src, int samples) |
| static void | frame_cache_cleanup (void *data) |
| static int | g723_len (unsigned char buf) |
| static int | g723_samples (unsigned char *buf, int maxlen) |
| static unsigned char | get_n_bits_at (unsigned char *data, int n, int bit) |
| int | init_framer (void) |
| static char * | show_codec_n (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a) |
| static char * | show_codecs (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a) |
| static int | smoother_frame_feed (struct ast_smoother *s, struct ast_frame *f, int swap) |
| static int | speex_get_wb_sz_at (unsigned char *data, int len, int bit) |
| static int | speex_samples (unsigned char *data, int len) |
Variables | |
| static struct ast_format_list | AST_FORMAT_LIST [] |
| Definition of supported media formats (codecs). | |
| struct ast_frame | ast_null_frame = { AST_FRAME_NULL, } |
| static struct ast_threadstorage | frame_cache = { .once = PTHREAD_ONCE_INIT , .key_init = __init_frame_cache , .custom_init = NULL , } |
| static struct ast_cli_entry | my_clis [] |
Frame and codec manipulation routines.
Definition in file frame.c.
| #define FRAME_CACHE_MAX_SIZE 10 |
Maximum ast_frame cache size.
In most cases where the frame header cache will be useful, the size of the cache will stay very small. However, it is not always the case that the same thread that allocates the frame will be the one freeing them, so sometimes a thread will never have any frames in its cache, or the cache will never be pulled from. For the latter case, we limit the maximum size.
| #define SMOOTHER_SIZE 8000 |
Definition at line 70 of file frame.c.
Referenced by __ast_smoother_feed().
| enum frame_type |
Definition at line 72 of file frame.c.
00072 { 00073 TYPE_HIGH, /* 0x0 */ 00074 TYPE_LOW, /* 0x1 */ 00075 TYPE_SILENCE, /* 0x2 */ 00076 TYPE_DONTSEND /* 0x3 */ 00077 };
| int __ast_smoother_feed | ( | struct ast_smoother * | s, | |
| struct ast_frame * | f, | |||
| int | swap | |||
| ) |
Definition at line 201 of file frame.c.
References AST_FRAME_VOICE, ast_log(), AST_MIN_OFFSET, AST_SMOOTHER_FLAG_G729, ast_swapcopy_samples(), ast_frame::data, ast_frame::datalen, ast_smoother::flags, ast_smoother::format, ast_frame::frametype, ast_smoother::len, LOG_WARNING, ast_frame::offset, ast_smoother::opt, ast_smoother::opt_needs_swap, ast_frame::ptr, ast_frame::samples, ast_smoother::samplesperbyte, ast_smoother::size, smoother_frame_feed(), SMOOTHER_SIZE, and ast_frame::subclass.
00202 { 00203 if (f->frametype != AST_FRAME_VOICE) { 00204 ast_log(LOG_WARNING, "Huh? Can't smooth a non-voice frame!\n"); 00205 return -1; 00206 } 00207 if (!s->format) { 00208 s->format = f->subclass; 00209 s->samplesperbyte = (float)f->samples / (float)f->datalen; 00210 } else if (s->format != f->subclass) { 00211 ast_log(LOG_WARNING, "Smoother was working on %d format frames, now trying to feed %d?\n", s->format, f->subclass); 00212 return -1; 00213 } 00214 if (s->len + f->datalen > SMOOTHER_SIZE) { 00215 ast_log(LOG_WARNING, "Out of smoother space\n"); 00216 return -1; 00217 } 00218 if (((f->datalen == s->size) || 00219 ((f->datalen < 10) && (s->flags & AST_SMOOTHER_FLAG_G729))) && 00220 !s->opt && 00221 !s->len && 00222 (f->offset >= AST_MIN_OFFSET)) { 00223 /* Optimize by sending the frame we just got 00224 on the next read, thus eliminating the douple 00225 copy */ 00226 if (swap) 00227 ast_swapcopy_samples(f->data.ptr, f->data.ptr, f->samples); 00228 s->opt = f; 00229 s->opt_needs_swap = swap ? 1 : 0; 00230 return 0; 00231 } 00232 00233 return smoother_frame_feed(s, f, swap); 00234 }
| static void __frame_free | ( | struct ast_frame * | fr, | |
| int | cache | |||
| ) | [static] |
Definition at line 333 of file frame.c.
References ast_dsp_frame_freed(), ast_free, AST_FRFLAG_FROM_DSP, AST_FRFLAG_FROM_TRANSLATOR, AST_LIST_INSERT_HEAD, AST_MALLOCD_DATA, AST_MALLOCD_HDR, AST_MALLOCD_SRC, ast_test_flag, ast_threadstorage_get(), ast_translate_frame_freed(), ast_frame::data, frame_cache, FRAME_CACHE_MAX_SIZE, frames, ast_frame_cache::list, ast_frame::mallocd, ast_frame::offset, ast_frame::ptr, ast_frame_cache::size, and ast_frame::src.
Referenced by ast_frame_free().
00334 { 00335 if (ast_test_flag(fr, AST_FRFLAG_FROM_TRANSLATOR)) { 00336 ast_translate_frame_freed(fr); 00337 } else if (ast_test_flag(fr, AST_FRFLAG_FROM_DSP)) { 00338 ast_dsp_frame_freed(fr); 00339 } 00340 00341 if (!fr->mallocd) 00342 return; 00343 00344 #if !defined(LOW_MEMORY) 00345 if (cache && fr->mallocd == AST_MALLOCD_HDR) { 00346 /* Cool, only the header is malloc'd, let's just cache those for now 00347 * to keep things simple... */ 00348 struct ast_frame_cache *frames; 00349 00350 if ((frames = ast_threadstorage_get(&frame_cache, sizeof(*frames))) && 00351 (frames->size < FRAME_CACHE_MAX_SIZE)) { 00352 AST_LIST_INSERT_HEAD(&frames->list, fr, frame_list); 00353 frames->size++; 00354 return; 00355 } 00356 } 00357 #endif 00358 00359 if (fr->mallocd & AST_MALLOCD_DATA) { 00360 if (fr->data.ptr) 00361 ast_free(fr->data.ptr - fr->offset); 00362 } 00363 if (fr->mallocd & AST_MALLOCD_SRC) { 00364 if (fr->src) 00365 ast_free((void *) fr->src); 00366 } 00367 if (fr->mallocd & AST_MALLOCD_HDR) { 00368 ast_free(fr); 00369 } 00370 }
| static void __init_frame_cache | ( | void | ) | [static] |
| char* ast_codec2str | ( | int | codec | ) |
Get a name from a format Gets a name from a format.
| codec | codec number (1,2,4,8,16,etc.) |
Definition at line 654 of file frame.c.
References ARRAY_LEN, and ast_format_list::desc.
Referenced by moh_alloc(), show_codec_n(), and show_codecs().
00655 { 00656 int x; 00657 char *ret = "unknown"; 00658 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 00659 if (AST_FORMAT_LIST[x].bits == codec) { 00660 ret = AST_FORMAT_LIST[x].desc; 00661 break; 00662 } 00663 } 00664 return ret; 00665 }
| int ast_codec_choose | ( | struct ast_codec_pref * | pref, | |
| int | formats, | |||
| int | find_best | |||
| ) |
Pick a codec.
Select the best audio format according to preference list from supplied options. If "find_best" is non-zero then if nothing is found, the "Best" format of the format list is selected, otherwise 0 is returned.
Definition at line 1211 of file frame.c.
References ARRAY_LEN, ast_best_codec(), ast_debug, AST_FORMAT_AUDIO_MASK, ast_format_list::bits, and ast_codec_pref::order.
Referenced by __oh323_new(), gtalk_new(), jingle_new(), process_sdp(), sip_new(), and socket_process().
01212 { 01213 int x, ret = 0, slot; 01214 01215 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01216 slot = pref->order[x]; 01217 01218 if (!slot) 01219 break; 01220 if (formats & AST_FORMAT_LIST[slot-1].bits) { 01221 ret = AST_FORMAT_LIST[slot-1].bits; 01222 break; 01223 } 01224 } 01225 if (ret & AST_FORMAT_AUDIO_MASK) 01226 return ret; 01227 01228 ast_debug(4, "Could not find preferred codec - %s\n", find_best ? "Going for the best codec" : "Returning zero codec"); 01229 01230 return find_best ? ast_best_codec(formats) : 0; 01231 }
| int ast_codec_get_len | ( | int | format, | |
| int | samples | |||
| ) |
Returns the number of bytes for the number of samples of the given format.
Definition at line 1484 of file frame.c.
References AST_FORMAT_ADPCM, AST_FORMAT_ALAW, AST_FORMAT_G722, AST_FORMAT_G723_1, AST_FORMAT_G726, AST_FORMAT_G726_AAL2, AST_FORMAT_G729A, AST_FORMAT_GSM, AST_FORMAT_ILBC, AST_FORMAT_SIREN14, AST_FORMAT_SIREN7, AST_FORMAT_SLINEAR, AST_FORMAT_SLINEAR16, AST_FORMAT_ULAW, ast_getformatname(), ast_log(), len(), and LOG_WARNING.
Referenced by moh_generate(), and monmp3thread().
01485 { 01486 int len = 0; 01487 01488 /* XXX Still need speex, and lpc10 XXX */ 01489 switch(format) { 01490 case AST_FORMAT_G723_1: 01491 len = (samples / 240) * 20; 01492 break; 01493 case AST_FORMAT_ILBC: 01494 len = (samples / 240) * 50; 01495 break; 01496 case AST_FORMAT_GSM: 01497 len = (samples / 160) * 33; 01498 break; 01499 case AST_FORMAT_G729A: 01500 len = samples / 8; 01501 break; 01502 case AST_FORMAT_SLINEAR: 01503 case AST_FORMAT_SLINEAR16: 01504 len = samples * 2; 01505 break; 01506 case AST_FORMAT_ULAW: 01507 case AST_FORMAT_ALAW: 01508 len = samples; 01509 break; 01510 case AST_FORMAT_G722: 01511 case AST_FORMAT_ADPCM: 01512 case AST_FORMAT_G726: 01513 case AST_FORMAT_G726_AAL2: 01514 len = samples / 2; 01515 break; 01516 case AST_FORMAT_SIREN7: 01517 /* 16,000 samples per second at 32kbps is 4,000 bytes per second */ 01518 len = samples / (16000 / 4000); 01519 break; 01520 case AST_FORMAT_SIREN14: 01521 /* 32,000 samples per second at 48kbps is 6,000 bytes per second */ 01522 len = (int) samples / ((float) 32000 / 6000); 01523 break; 01524 default: 01525 ast_log(LOG_WARNING, "Unable to calculate sample length for format %s\n", ast_getformatname(format)); 01526 } 01527 01528 return len; 01529 }
| int ast_codec_get_samples | ( | struct ast_frame * | f | ) |
Returns the number of samples contained in the frame.
Definition at line 1431 of file frame.c.
References AST_FORMAT_ADPCM, AST_FORMAT_ALAW, AST_FORMAT_G722, AST_FORMAT_G723_1, AST_FORMAT_G726, AST_FORMAT_G726_AAL2, AST_FORMAT_G729A, AST_FORMAT_GSM, AST_FORMAT_ILBC, AST_FORMAT_LPC10, AST_FORMAT_SIREN14, AST_FORMAT_SIREN7, AST_FORMAT_SLINEAR, AST_FORMAT_SLINEAR16, AST_FORMAT_SPEEX, AST_FORMAT_ULAW, ast_getformatname(), ast_log(), ast_frame::data, ast_frame::datalen, g723_samples(), LOG_WARNING, ast_frame::ptr, speex_samples(), and ast_frame::subclass.
Referenced by ast_rtp_read(), isAnsweringMachine(), moh_generate(), schedule_delivery(), socket_process(), and socket_process_meta().
01432 { 01433 int samples = 0; 01434 01435 switch(f->subclass) { 01436 case AST_FORMAT_SPEEX: 01437 samples = speex_samples(f->data.ptr, f->datalen); 01438 break; 01439 case AST_FORMAT_G723_1: 01440 samples = g723_samples(f->data.ptr, f->datalen); 01441 break; 01442 case AST_FORMAT_ILBC: 01443 samples = 240 * (f->datalen / 50); 01444 break; 01445 case AST_FORMAT_GSM: 01446 samples = 160 * (f->datalen / 33); 01447 break; 01448 case AST_FORMAT_G729A: 01449 samples = f->datalen * 8; 01450 break; 01451 case AST_FORMAT_SLINEAR: 01452 case AST_FORMAT_SLINEAR16: 01453 samples = f->datalen / 2; 01454 break; 01455 case AST_FORMAT_LPC10: 01456 /* assumes that the RTP packet contains one LPC10 frame */ 01457 samples = 22 * 8; 01458 samples += (((char *)(f->data.ptr))[7] & 0x1) * 8; 01459 break; 01460 case AST_FORMAT_ULAW: 01461 case AST_FORMAT_ALAW: 01462 samples = f->datalen; 01463 break; 01464 case AST_FORMAT_G722: 01465 case AST_FORMAT_ADPCM: 01466 case AST_FORMAT_G726: 01467 case AST_FORMAT_G726_AAL2: 01468 samples = f->datalen * 2; 01469 break; 01470 case AST_FORMAT_SIREN7: 01471 /* 16,000 samples per second at 32kbps is 4,000 bytes per second */ 01472 samples = f->datalen * (16000 / 4000); 01473 break; 01474 case AST_FORMAT_SIREN14: 01475 /* 32,000 samples per second at 48kbps is 6,000 bytes per second */ 01476 samples = (int) f->datalen * ((float) 32000 / 6000); 01477 break; 01478 default: 01479 ast_log(LOG_WARNING, "Unable to calculate samples for format %s\n", ast_getformatname(f->subclass)); 01480 } 01481 return samples; 01482 }
| int ast_codec_pref_append | ( | struct ast_codec_pref * | pref, | |
| int | format | |||
| ) |
Append codec to list.
Append a audio codec to a preference list, removing it first if it was already there.
Definition at line 1071 of file frame.c.
References ARRAY_LEN, ast_codec_pref_remove(), and ast_codec_pref::order.
Referenced by ast_parse_allow_disallow().
01072 { 01073 int x, newindex = 0; 01074 01075 ast_codec_pref_remove(pref, format); 01076 01077 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01078 if (AST_FORMAT_LIST[x].bits == format) { 01079 newindex = x + 1; 01080 break; 01081 } 01082 } 01083 01084 if (newindex) { 01085 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01086 if (!pref->order[x]) { 01087 pref->order[x] = newindex; 01088 break; 01089 } 01090 } 01091 } 01092 01093 return x; 01094 }
| void ast_codec_pref_convert | ( | struct ast_codec_pref * | pref, | |
| char * | buf, | |||
| size_t | size, | |||
| int | right | |||
| ) |
Shift an audio codec preference list up or down 65 bytes so that it becomes an ASCII string.
Definition at line 974 of file frame.c.
References ast_codec_pref::order.
Referenced by check_access(), create_addr(), dump_prefs(), and socket_process().
00975 { 00976 int x, differential = (int) 'A', mem; 00977 char *from, *to; 00978 00979 if (right) { 00980 from = pref->order; 00981 to = buf; 00982 mem = size; 00983 } else { 00984 to = pref->order; 00985 from = buf; 00986 mem = 32; 00987 } 00988 00989 memset(to, 0, mem); 00990 for (x = 0; x < 32 ; x++) { 00991 if (!from[x]) 00992 break; 00993 to[x] = right ? (from[x] + differential) : (from[x] - differential); 00994 } 00995 }
| struct ast_format_list ast_codec_pref_getsize | ( | struct ast_codec_pref * | pref, | |
| int | format | |||
| ) | [read] |
Get packet size for codec.
Definition at line 1172 of file frame.c.
References ARRAY_LEN, ast_format_list::bits, ast_format_list::cur_ms, ast_format_list::def_ms, format, ast_format_list::inc_ms, ast_format_list::max_ms, and ast_format_list::min_ms.
Referenced by add_codec_to_sdp(), ast_rtp_bridge(), ast_rtp_codec_setpref(), ast_rtp_write(), handle_open_receive_channel_ack_message(), skinny_set_rtp_peer(), and transmit_connect().
01173 { 01174 int x, idx = -1, framems = 0; 01175 struct ast_format_list fmt = { 0, }; 01176 01177 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01178 if (AST_FORMAT_LIST[x].bits == format) { 01179 fmt = AST_FORMAT_LIST[x]; 01180 idx = x; 01181 break; 01182 } 01183 } 01184 01185 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01186 if (pref->order[x] == (idx + 1)) { 01187 framems = pref->framing[x]; 01188 break; 01189 } 01190 } 01191 01192 /* size validation */ 01193 if (!framems) 01194 framems = AST_FORMAT_LIST[idx].def_ms; 01195 01196 if (AST_FORMAT_LIST[idx].inc_ms && framems % AST_FORMAT_LIST[idx].inc_ms) /* avoid division by zero */ 01197 framems -= framems % AST_FORMAT_LIST[idx].inc_ms; 01198 01199 if (framems < AST_FORMAT_LIST[idx].min_ms) 01200 framems = AST_FORMAT_LIST[idx].min_ms; 01201 01202 if (framems > AST_FORMAT_LIST[idx].max_ms) 01203 framems = AST_FORMAT_LIST[idx].max_ms; 01204 01205 fmt.cur_ms = framems; 01206 01207 return fmt; 01208 }
| int ast_codec_pref_index | ( | struct ast_codec_pref * | pref, | |
| int | index | |||
| ) |
Codec located at a particular place in the preference index.
Definition at line 1032 of file frame.c.
References ast_format_list::bits, and ast_codec_pref::order.
Referenced by _sip_show_peer(), _skinny_show_line(), add_sdp(), ast_codec_pref_string(), function_iaxpeer(), function_sippeer(), gtalk_invite(), handle_cli_iax2_show_peer(), jingle_accept_call(), print_codec_to_cli(), and socket_process().
01033 { 01034 int slot = 0; 01035 01036 if ((idx >= 0) && (idx < sizeof(pref->order))) { 01037 slot = pref->order[idx]; 01038 } 01039 01040 return slot ? AST_FORMAT_LIST[slot - 1].bits : 0; 01041 }
| void ast_codec_pref_prepend | ( | struct ast_codec_pref * | pref, | |
| int | format, | |||
| int | only_if_existing | |||
| ) |
Prepend codec to list.
Prepend an audio codec to a preference list, removing it first if it was already there.
Definition at line 1097 of file frame.c.
References ARRAY_LEN, ast_codec_pref::framing, and ast_codec_pref::order.
Referenced by create_addr().
01098 { 01099 int x, newindex = 0; 01100 01101 /* First step is to get the codecs "index number" */ 01102 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01103 if (AST_FORMAT_LIST[x].bits == format) { 01104 newindex = x + 1; 01105 break; 01106 } 01107 } 01108 /* Done if its unknown */ 01109 if (!newindex) 01110 return; 01111 01112 /* Now find any existing occurrence, or the end */ 01113 for (x = 0; x < 32; x++) { 01114 if (!pref->order[x] || pref->order[x] == newindex) 01115 break; 01116 } 01117 01118 if (only_if_existing && !pref->order[x]) 01119 return; 01120 01121 /* Move down to make space to insert - either all the way to the end, 01122 or as far as the existing location (which will be overwritten) */ 01123 for (; x > 0; x--) { 01124 pref->order[x] = pref->order[x - 1]; 01125 pref->framing[x] = pref->framing[x - 1]; 01126 } 01127 01128 /* And insert the new entry */ 01129 pref->order[0] = newindex; 01130 pref->framing[0] = 0; /* ? */ 01131 }
| void ast_codec_pref_remove | ( | struct ast_codec_pref * | pref, | |
| int | format | |||
| ) |
Remove codec from pref list.
Remove audio a codec from a preference list.
Definition at line 1044 of file frame.c.
References ARRAY_LEN, ast_codec_pref::framing, and ast_codec_pref::order.
Referenced by ast_codec_pref_append(), and ast_parse_allow_disallow().
01045 { 01046 struct ast_codec_pref oldorder; 01047 int x, y = 0; 01048 int slot; 01049 int size; 01050 01051 if (!pref->order[0]) 01052 return; 01053 01054 memcpy(&oldorder, pref, sizeof(oldorder)); 01055 memset(pref, 0, sizeof(*pref)); 01056 01057 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01058 slot = oldorder.order[x]; 01059 size = oldorder.framing[x]; 01060 if (! slot) 01061 break; 01062 if (AST_FORMAT_LIST[slot-1].bits != format) { 01063 pref->order[y] = slot; 01064 pref->framing[y++] = size; 01065 } 01066 } 01067 01068 }
| int ast_codec_pref_setsize | ( | struct ast_codec_pref * | pref, | |
| int | format, | |||
| int | framems | |||
| ) |
Set packet size for codec.
Definition at line 1134 of file frame.c.
References ARRAY_LEN, ast_format_list::def_ms, ast_codec_pref::framing, ast_format_list::inc_ms, ast_format_list::max_ms, ast_format_list::min_ms, and ast_codec_pref::order.
Referenced by ast_parse_allow_disallow(), and process_sdp_a_audio().
01135 { 01136 int x, idx = -1; 01137 01138 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01139 if (AST_FORMAT_LIST[x].bits == format) { 01140 idx = x; 01141 break; 01142 } 01143 } 01144 01145 if (idx < 0) 01146 return -1; 01147 01148 /* size validation */ 01149 if (!framems) 01150 framems = AST_FORMAT_LIST[idx].def_ms; 01151 01152 if (AST_FORMAT_LIST[idx].inc_ms && framems % AST_FORMAT_LIST[idx].inc_ms) /* avoid division by zero */ 01153 framems -= framems % AST_FORMAT_LIST[idx].inc_ms; 01154 01155 if (framems < AST_FORMAT_LIST[idx].min_ms) 01156 framems = AST_FORMAT_LIST[idx].min_ms; 01157 01158 if (framems > AST_FORMAT_LIST[idx].max_ms) 01159 framems = AST_FORMAT_LIST[idx].max_ms; 01160 01161 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 01162 if (pref->order[x] == (idx + 1)) { 01163 pref->framing[x] = framems; 01164 break; 01165 } 01166 } 01167 01168 return x; 01169 }
| int ast_codec_pref_string | ( | struct ast_codec_pref * | pref, | |
| char * | buf, | |||
| size_t | size | |||
| ) |
Dump audio codec preference list into a string.
Definition at line 997 of file frame.c.
References ast_codec_pref_index(), and ast_getformatname().
Referenced by dump_prefs(), and socket_process().
00998 { 00999 int x, codec; 01000 size_t total_len, slen; 01001 char *formatname; 01002 01003 memset(buf,0,size); 01004 total_len = size; 01005 buf[0] = '('; 01006 total_len--; 01007 for(x = 0; x < 32 ; x++) { 01008 if (total_len <= 0) 01009 break; 01010 if (!(codec = ast_codec_pref_index(pref,x))) 01011 break; 01012 if ((formatname = ast_getformatname(codec))) { 01013 slen = strlen(formatname); 01014 if (slen > total_len) 01015 break; 01016 strncat(buf, formatname, total_len - 1); /* safe */ 01017 total_len -= slen; 01018 } 01019 if (total_len && x < 31 && ast_codec_pref_index(pref , x + 1)) { 01020 strncat(buf, "|", total_len - 1); /* safe */ 01021 total_len--; 01022 } 01023 } 01024 if (total_len) { 01025 strncat(buf, ")", total_len - 1); /* safe */ 01026 total_len--; 01027 } 01028 01029 return size - total_len; 01030 }
| static const char* ast_expand_codec_alias | ( | const char * | in | ) | [static] |
Definition at line 625 of file frame.c.
References ARRAY_LEN.
Referenced by ast_getformatbyname().
00626 { 00627 int x; 00628 00629 for (x = 0; x < ARRAY_LEN(ast_codec_alias_table); x++) { 00630 if (!strcmp(in,ast_codec_alias_table[x].alias)) 00631 return ast_codec_alias_table[x].realname; 00632 } 00633 return in; 00634 }
| int ast_frame_adjust_volume | ( | struct ast_frame * | f, | |
| int | adjustment | |||
| ) |
Adjusts the volume of the audio samples contained in a frame.
| f | The frame containing the samples (must be AST_FRAME_VOICE and AST_FORMAT_SLINEAR) | |
| adjustment | The number of dB to adjust up or down. |
Definition at line 1531 of file frame.c.
References AST_FORMAT_SLINEAR, AST_FRAME_VOICE, ast_slinear_saturated_divide(), ast_slinear_saturated_multiply(), ast_frame::data, ast_frame::frametype, ast_frame::ptr, ast_frame::samples, and ast_frame::subclass.
Referenced by audiohook_read_frame_single(), audiohook_volume_callback(), conf_run(), and volume_callback().
01532 { 01533 int count; 01534 short *fdata = f->data.ptr; 01535 short adjust_value = abs(adjustment); 01536 01537 if ((f->frametype != AST_FRAME_VOICE) || (f->subclass != AST_FORMAT_SLINEAR)) 01538 return -1; 01539 01540 if (!adjustment) 01541 return 0; 01542 01543 for (count = 0; count < f->samples; count++) { 01544 if (adjustment > 0) { 01545 ast_slinear_saturated_multiply(&fdata[count], &adjust_value); 01546 } else if (adjustment < 0) { 01547 ast_slinear_saturated_divide(&fdata[count], &adjust_value); 01548 } 01549 } 01550 01551 return 0; 01552 }
| void ast_frame_dump | ( | const char * | name, | |
| struct ast_frame * | f, | |||
| char * | prefix | |||
| ) |
Dump a frame for debugging purposes
Definition at line 756 of file frame.c.
References AST_CONTROL_ANSWER, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_CONTROL_FLASH, AST_CONTROL_HANGUP, AST_CONTROL_HOLD, AST_CONTROL_OFFHOOK, AST_CONTROL_OPTION, AST_CONTROL_RADIO_KEY, AST_CONTROL_RADIO_UNKEY, AST_CONTROL_RING, AST_CONTROL_RINGING, AST_CONTROL_T38_PARAMETERS, AST_CONTROL_TAKEOFFHOOK, AST_CONTROL_UNHOLD, AST_CONTROL_WINK, ast_copy_string(), AST_FRAME_CONTROL, AST_FRAME_DTMF_BEGIN, AST_FRAME_DTMF_END, AST_FRAME_HTML, AST_FRAME_IAX, AST_FRAME_IMAGE, AST_FRAME_MODEM, AST_FRAME_NULL, AST_FRAME_TEXT, AST_FRAME_VIDEO, AST_FRAME_VOICE, ast_getformatname(), AST_HTML_BEGIN, AST_HTML_DATA, AST_HTML_END, AST_HTML_LDCOMPLETE, AST_HTML_LINKREJECT, AST_HTML_LINKURL, AST_HTML_NOSUPPORT, AST_HTML_UNLINK, AST_HTML_URL, AST_MODEM_T38, AST_MODEM_V150, ast_strlen_zero(), AST_T38_NEGOTIATED, AST_T38_REFUSED, AST_T38_REQUEST_NEGOTIATE, AST_T38_REQUEST_TERMINATE, AST_T38_TERMINATED, ast_verbose, COLOR_BLACK, COLOR_BRCYAN, COLOR_BRGREEN, COLOR_BRMAGENTA, COLOR_BRRED, COLOR_YELLOW, ast_frame::data, ast_frame::datalen, ast_frame::frametype, ast_frame::ptr, ast_control_t38_parameters::request_response, ast_frame::subclass, and term_color().
Referenced by __ast_read(), and ast_write().
00757 { 00758 const char noname[] = "unknown"; 00759 char ftype[40] = "Unknown Frametype"; 00760 char cft[80]; 00761 char subclass[40] = "Unknown Subclass"; 00762 char csub[80]; 00763 char moreinfo[40] = ""; 00764 char cn[60]; 00765 char cp[40]; 00766 char cmn[40]; 00767 const char *message = "Unknown"; 00768 00769 if (!name) 00770 name = noname; 00771 00772 00773 if (!f) { 00774 ast_verbose("%s [ %s (NULL) ] [%s]\n", 00775 term_color(cp, prefix, COLOR_BRMAGENTA, COLOR_BLACK, sizeof(cp)), 00776 term_color(cft, "HANGUP", COLOR_BRRED, COLOR_BLACK, sizeof(cft)), 00777 term_color(cn, name, COLOR_YELLOW, COLOR_BLACK, sizeof(cn))); 00778 return; 00779 } 00780 /* XXX We should probably print one each of voice and video when the format changes XXX */ 00781 if (f->frametype == AST_FRAME_VOICE) 00782 return; 00783 if (f->frametype == AST_FRAME_VIDEO) 00784 return; 00785 switch(f->frametype) { 00786 case AST_FRAME_DTMF_BEGIN: 00787 strcpy(ftype, "DTMF Begin"); 00788 subclass[0] = f->subclass; 00789 subclass[1] = '\0'; 00790 break; 00791 case AST_FRAME_DTMF_END: 00792 strcpy(ftype, "DTMF End"); 00793 subclass[0] = f->subclass; 00794 subclass[1] = '\0'; 00795 break; 00796 case AST_FRAME_CONTROL: 00797 strcpy(ftype, "Control"); 00798 switch(f->subclass) { 00799 case AST_CONTROL_HANGUP: 00800 strcpy(subclass, "Hangup"); 00801 break; 00802 case AST_CONTROL_RING: 00803 strcpy(subclass, "Ring"); 00804 break; 00805 case AST_CONTROL_RINGING: 00806 strcpy(subclass, "Ringing"); 00807 break; 00808 case AST_CONTROL_ANSWER: 00809 strcpy(subclass, "Answer"); 00810 break; 00811 case AST_CONTROL_BUSY: 00812 strcpy(subclass, "Busy"); 00813 break; 00814 case AST_CONTROL_TAKEOFFHOOK: 00815 strcpy(subclass, "Take Off Hook"); 00816 break; 00817 case AST_CONTROL_OFFHOOK: 00818 strcpy(subclass, "Line Off Hook"); 00819 break; 00820 case AST_CONTROL_CONGESTION: 00821 strcpy(subclass, "Congestion"); 00822 break; 00823 case AST_CONTROL_FLASH: 00824 strcpy(subclass, "Flash"); 00825 break; 00826 case AST_CONTROL_WINK: 00827 strcpy(subclass, "Wink"); 00828 break; 00829 case AST_CONTROL_OPTION: 00830 strcpy(subclass, "Option"); 00831 break; 00832 case AST_CONTROL_RADIO_KEY: 00833 strcpy(subclass, "Key Radio"); 00834 break; 00835 case AST_CONTROL_RADIO_UNKEY: 00836 strcpy(subclass, "Unkey Radio"); 00837 break; 00838 case AST_CONTROL_HOLD: 00839 strcpy(subclass, "Hold"); 00840 break; 00841 case AST_CONTROL_UNHOLD: 00842 strcpy(subclass, "Unhold"); 00843 break; 00844 case AST_CONTROL_T38_PARAMETERS: 00845 if (f->datalen != sizeof(struct ast_control_t38_parameters)) { 00846 message = "Invalid"; 00847 } else { 00848 struct ast_control_t38_parameters *parameters = f->data.ptr; 00849 enum ast_control_t38 state = parameters->request_response; 00850 if (state == AST_T38_REQUEST_NEGOTIATE) 00851 message = "Negotiation Requested"; 00852 else if (state == AST_T38_REQUEST_TERMINATE) 00853 message = "Negotiation Request Terminated"; 00854 else if (state == AST_T38_NEGOTIATED) 00855 message = "Negotiated"; 00856 else if (state == AST_T38_TERMINATED) 00857 message = "Terminated"; 00858 else if (state == AST_T38_REFUSED) 00859 message = "Refused"; 00860 } 00861 snprintf(subclass, sizeof(subclass), "T38_Parameters/%s", message); 00862 break; 00863 case -1: 00864 strcpy(subclass, "Stop generators"); 00865 break; 00866 default: 00867 snprintf(subclass, sizeof(subclass), "Unknown control '%d'", f->subclass); 00868 } 00869 break; 00870 case AST_FRAME_NULL: 00871 strcpy(ftype, "Null Frame"); 00872 strcpy(subclass, "N/A"); 00873 break; 00874 case AST_FRAME_IAX: 00875 /* Should never happen */ 00876 strcpy(ftype, "IAX Specific"); 00877 snprintf(subclass, sizeof(subclass), "IAX Frametype %d", f->subclass); 00878 break; 00879 case AST_FRAME_TEXT: 00880 strcpy(ftype, "Text"); 00881 strcpy(subclass, "N/A"); 00882 ast_copy_string(moreinfo, f->data.ptr, sizeof(moreinfo)); 00883 break; 00884 case AST_FRAME_IMAGE: 00885 strcpy(ftype, "Image"); 00886 snprintf(subclass, sizeof(subclass), "Image format %s\n", ast_getformatname(f->subclass)); 00887 break; 00888 case AST_FRAME_HTML: 00889 strcpy(ftype, "HTML"); 00890 switch(f->subclass) { 00891 case AST_HTML_URL: 00892 strcpy(subclass, "URL"); 00893 ast_copy_string(moreinfo, f->data.ptr, sizeof(moreinfo)); 00894 break; 00895 case AST_HTML_DATA: 00896 strcpy(subclass, "Data"); 00897 break; 00898 case AST_HTML_BEGIN: 00899 strcpy(subclass, "Begin"); 00900 break; 00901 case AST_HTML_END: 00902 strcpy(subclass, "End"); 00903 break; 00904 case AST_HTML_LDCOMPLETE: 00905 strcpy(subclass, "Load Complete"); 00906 break; 00907 case AST_HTML_NOSUPPORT: 00908 strcpy(subclass, "No Support"); 00909 break; 00910 case AST_HTML_LINKURL: 00911 strcpy(subclass, "Link URL"); 00912 ast_copy_string(moreinfo, f->data.ptr, sizeof(moreinfo)); 00913 break; 00914 case AST_HTML_UNLINK: 00915 strcpy(subclass, "Unlink"); 00916 break; 00917 case AST_HTML_LINKREJECT: 00918 strcpy(subclass, "Link Reject"); 00919 break; 00920 default: 00921 snprintf(subclass, sizeof(subclass), "Unknown HTML frame '%d'\n", f->subclass); 00922 break; 00923 } 00924 break; 00925 case AST_FRAME_MODEM: 00926 strcpy(ftype, "Modem"); 00927 switch (f->subclass) { 00928 case AST_MODEM_T38: 00929 strcpy(subclass, "T.38"); 00930 break; 00931 case AST_MODEM_V150: 00932 strcpy(subclass, "V.150"); 00933 break; 00934 default: 00935 snprintf(subclass, sizeof(subclass), "Unknown MODEM frame '%d'\n", f->subclass); 00936 break; 00937 } 00938 break; 00939 default: 00940 snprintf(ftype, sizeof(ftype), "Unknown Frametype '%d'", f->frametype); 00941 } 00942 if (!ast_strlen_zero(moreinfo)) 00943 ast_verbose("%s [ TYPE: %s (%d) SUBCLASS: %s (%d) '%s' ] [%s]\n", 00944 term_color(cp, prefix, COLOR_BRMAGENTA, COLOR_BLACK, sizeof(cp)), 00945 term_color(cft, ftype, COLOR_BRRED, COLOR_BLACK, sizeof(cft)), 00946 f->frametype, 00947 term_color(csub, subclass, COLOR_BRCYAN, COLOR_BLACK, sizeof(csub)), 00948 f->subclass, 00949 term_color(cmn, moreinfo, COLOR_BRGREEN, COLOR_BLACK, sizeof(cmn)), 00950 term_color(cn, name, COLOR_YELLOW, COLOR_BLACK, sizeof(cn))); 00951 else 00952 ast_verbose("%s [ TYPE: %s (%d) SUBCLASS: %s (%d) ] [%s]\n", 00953 term_color(cp, prefix, COLOR_BRMAGENTA, COLOR_BLACK, sizeof(cp)), 00954 term_color(cft, ftype, COLOR_BRRED, COLOR_BLACK, sizeof(cft)), 00955 f->frametype, 00956 term_color(csub, subclass, COLOR_BRCYAN, COLOR_BLACK, sizeof(csub)), 00957 f->subclass, 00958 term_color(cn, name, COLOR_YELLOW, COLOR_BLACK, sizeof(cn))); 00959 }
| void ast_frame_free | ( | struct ast_frame * | fr, | |
| int | cache | |||
| ) |
Requests a frame to be allocated.
| source | Request a frame be allocated. source is an optional source of the frame, len is the requested length, or "0" if the caller will supply the buffer |
Frees a frame or list of frames
| fr | Frame to free, or head of list to free | |
| cache | Whether to consider this frame for frame caching |
Definition at line 373 of file frame.c.
References __frame_free(), AST_LIST_NEXT, ast_frame::frame_list, and ast_frame::next.
Referenced by mixmonitor_thread().
00374 { 00375 struct ast_frame *next; 00376 00377 for (next = AST_LIST_NEXT(frame, frame_list); 00378 frame; 00379 frame = next, next = frame ? AST_LIST_NEXT(frame, frame_list) : NULL) { 00380 __frame_free(frame, cache); 00381 } 00382 }
| static struct ast_frame* ast_frame_header_new | ( | void | ) | [static, read] |
Definition at line 291 of file frame.c.
References ast_calloc, ast_calloc_cache, AST_LIST_REMOVE_HEAD, AST_MALLOCD_HDR, ast_threadstorage_get(), f, frame_cache, frames, ast_frame_cache::list, ast_frame::mallocd, ast_frame::mallocd_hdr_len, and ast_frame_cache::size.
Referenced by ast_frisolate().
00292 { 00293 struct ast_frame *f; 00294 00295 #if !defined(LOW_MEMORY) 00296 struct ast_frame_cache *frames; 00297 00298 if ((frames = ast_threadstorage_get(&frame_cache, sizeof(*frames)))) { 00299 if ((f = AST_LIST_REMOVE_HEAD(&frames->list, frame_list))) { 00300 size_t mallocd_len = f->mallocd_hdr_len; 00301 memset(f, 0, sizeof(*f)); 00302 f->mallocd_hdr_len = mallocd_len; 00303 f->mallocd = AST_MALLOCD_HDR; 00304 frames->size--; 00305 return f; 00306 } 00307 } 00308 if (!(f = ast_calloc_cache(1, sizeof(*f)))) 00309 return NULL; 00310 #else 00311 if (!(f = ast_calloc(1, sizeof(*f)))) 00312 return NULL; 00313 #endif 00314 00315 f->mallocd_hdr_len = sizeof(*f); 00316 00317 return f; 00318 }
Sums two frames of audio samples.
| f1 | The first frame (which will contain the result) | |
| f2 | The second frame |
The frames must be AST_FRAME_VOICE and must contain AST_FORMAT_SLINEAR samples, and must contain the same number of samples.
Definition at line 1554 of file frame.c.
References AST_FORMAT_SLINEAR, AST_FRAME_VOICE, ast_slinear_saturated_add(), ast_frame::data, ast_frame::frametype, ast_frame::ptr, ast_frame::samples, and ast_frame::subclass.
01555 { 01556 int count; 01557 short *data1, *data2; 01558 01559 if ((f1->frametype != AST_FRAME_VOICE) || (f1->subclass != AST_FORMAT_SLINEAR)) 01560 return -1; 01561 01562 if ((f2->frametype != AST_FRAME_VOICE) || (f2->subclass != AST_FORMAT_SLINEAR)) 01563 return -1; 01564 01565 if (f1->samples != f2->samples) 01566 return -1; 01567 01568 for (count = 0, data1 = f1->data.ptr, data2 = f2->data.ptr; 01569 count < f1->samples; 01570 count++, data1++, data2++) 01571 ast_slinear_saturated_add(data1, data2); 01572 01573 return 0; 01574 }
Copies a frame.
| fr | frame to copy Duplicates a frame -- should only rarely be used, typically frisolate is good enough |
Definition at line 474 of file frame.c.
References ast_calloc_cache, ast_copy_flags, AST_FRFLAG_HAS_TIMING_INFO, AST_FRIENDLY_OFFSET, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_MALLOCD_HDR, ast_threadstorage_get(), buf, ast_frame::data, ast_frame::datalen, ast_frame::delivery, frame_cache, frames, ast_frame::frametype, ast_frame::len, len(), ast_frame_cache::list, ast_frame::mallocd, ast_frame::mallocd_hdr_len, ast_frame::offset, ast_frame::ptr, ast_frame::samples, ast_frame::seqno, ast_frame_cache::size, ast_frame::src, ast_frame::subclass, ast_frame::ts, and ast_frame::uint32.
Referenced by __ast_queue_frame(), ast_frisolate(), ast_jb_put(), ast_rtp_write(), ast_slinfactory_feed(), audiohook_read_frame_both(), audiohook_read_frame_single(), autoservice_run(), recordthread(), rpt(), and rpt_exec().
00475 { 00476 struct ast_frame *out = NULL; 00477 int len, srclen = 0; 00478 void *buf = NULL; 00479 00480 #if !defined(LOW_MEMORY) 00481 struct ast_frame_cache *frames; 00482 #endif 00483 00484 /* Start with standard stuff */ 00485 len = sizeof(*out) + AST_FRIENDLY_OFFSET + f->datalen; 00486 /* If we have a source, add space for it */ 00487 /* 00488 * XXX Watch out here - if we receive a src which is not terminated 00489 * properly, we can be easily attacked. Should limit the size we deal with. 00490 */ 00491 if (f->src) 00492 srclen = strlen(f->src); 00493 if (srclen > 0) 00494 len += srclen + 1; 00495 00496 #if !defined(LOW_MEMORY) 00497 if ((frames = ast_threadstorage_get(&frame_cache, sizeof(*frames)))) { 00498 AST_LIST_TRAVERSE_SAFE_BEGIN(&frames->list, out, frame_list) { 00499 if (out->mallocd_hdr_len >= len) { 00500 size_t mallocd_len = out->mallocd_hdr_len; 00501 00502 AST_LIST_REMOVE_CURRENT(frame_list); 00503 memset(out, 0, sizeof(*out)); 00504 out->mallocd_hdr_len = mallocd_len; 00505 buf = out; 00506 frames->size--; 00507 break; 00508 } 00509 } 00510 AST_LIST_TRAVERSE_SAFE_END; 00511 } 00512 #endif 00513 00514 if (!buf) { 00515 if (!(buf = ast_calloc_cache(1, len))) 00516 return NULL; 00517 out = buf; 00518 out->mallocd_hdr_len = len; 00519 } 00520 00521 out->frametype = f->frametype; 00522 out->subclass = f->subclass; 00523 out->datalen = f->datalen; 00524 out->samples = f->samples; 00525 out->delivery = f->delivery; 00526 /* Set us as having malloc'd header only, so it will eventually 00527 get freed. */ 00528 out->mallocd = AST_MALLOCD_HDR; 00529 out->offset = AST_FRIENDLY_OFFSET; 00530 if (out->datalen) { 00531 out->data.ptr = buf + sizeof(*out) + AST_FRIENDLY_OFFSET; 00532 memcpy(out->data.ptr, f->data.ptr, out->datalen); 00533 } else { 00534 out->data.uint32 = f->data.uint32; 00535 } 00536 if (srclen > 0) { 00537 /* This may seem a little strange, but it's to avoid a gcc (4.2.4) compiler warning */ 00538 char *src; 00539 out->src = buf + sizeof(*out) + AST_FRIENDLY_OFFSET + f->datalen; 00540 src = (char *) out->src; 00541 /* Must have space since we allocated for it */ 00542 strcpy(src, f->src); 00543 } 00544 ast_copy_flags(out, f, AST_FRFLAG_HAS_TIMING_INFO); 00545 out->ts = f->ts; 00546 out->len = f->len; 00547 out->seqno = f->seqno; 00548 return out; 00549 }
'isolates' a frame by duplicating non-malloc'ed components (header, src, data). On return all components are malloc'ed
Makes a frame independent of any static storage.
Definition at line 389 of file frame.c.
References ast_clear_flag, ast_copy_flags, ast_frame_header_new(), ast_frdup(), ast_free, AST_FRFLAG_FROM_DSP, AST_FRFLAG_FROM_TRANSLATOR, AST_FRFLAG_HAS_TIMING_INFO, AST_FRIENDLY_OFFSET, ast_malloc, AST_MALLOCD_DATA, AST_MALLOCD_HDR, AST_MALLOCD_SRC, ast_strdup, ast_test_flag, ast_frame::data, ast_frame::datalen, ast_frame::frametype, ast_frame::len, ast_frame::mallocd, ast_frame::offset, ast_frame::ptr, ast_frame::samples, ast_frame::seqno, ast_frame::src, ast_frame::subclass, ast_frame::ts, and ast_frame::uint32.
Referenced by __ast_answer(), ast_slinfactory_feed(), ast_write(), autoservice_run(), jpeg_read_image(), and read_frame().
00390 { 00391 struct ast_frame *out; 00392 void *newdata; 00393 00394 /* if none of the existing frame is malloc'd, let ast_frdup() do it 00395 since it is more efficient 00396 */ 00397 if (fr->mallocd == 0) { 00398 return ast_frdup(fr); 00399 } 00400 00401 /* if everything is already malloc'd, we are done */ 00402 if ((fr->mallocd & (AST_MALLOCD_HDR | AST_MALLOCD_SRC | AST_MALLOCD_DATA)) == 00403 (AST_MALLOCD_HDR | AST_MALLOCD_SRC | AST_MALLOCD_DATA)) { 00404 return fr; 00405 } 00406 00407 if (!(fr->mallocd & AST_MALLOCD_HDR)) { 00408 /* Allocate a new header if needed */ 00409 if (!(out = ast_frame_header_new())) { 00410 return NULL; 00411 } 00412 out->frametype = fr->frametype; 00413 out->subclass = fr->subclass; 00414 out->datalen = fr->datalen; 00415 out->samples = fr->samples; 00416 out->offset = fr->offset; 00417 /* Copy the timing data */ 00418 ast_copy_flags(out, fr, AST_FRFLAG_HAS_TIMING_INFO); 00419 if (ast_test_flag(fr, AST_FRFLAG_HAS_TIMING_INFO)) { 00420 out->ts = fr->ts; 00421 out->len = fr->len; 00422 out->seqno = fr->seqno; 00423 } 00424 } else { 00425 ast_clear_flag(fr, AST_FRFLAG_FROM_TRANSLATOR); 00426 ast_clear_flag(fr, AST_FRFLAG_FROM_DSP); 00427 out = fr; 00428 } 00429 00430 if (!(fr->mallocd & AST_MALLOCD_SRC) && fr->src) { 00431 if (!(out->src = ast_strdup(fr->src))) { 00432 if (out != fr) { 00433 ast_free(out); 00434 } 00435 return NULL; 00436 } 00437 } else { 00438 out->src = fr->src; 00439 fr->src = NULL; 00440 fr->mallocd &= ~AST_MALLOCD_SRC; 00441 } 00442 00443 if (!(fr->mallocd & AST_MALLOCD_DATA)) { 00444 if (!fr->datalen) { 00445 out->data.uint32 = fr->data.uint32; 00446 out->mallocd = AST_MALLOCD_HDR | AST_MALLOCD_SRC; 00447 return out; 00448 } 00449 if (!(newdata = ast_malloc(fr->datalen + AST_FRIENDLY_OFFSET))) { 00450 if (out->src != fr->src) { 00451 ast_free((void *) out->src); 00452 } 00453 if (out != fr) { 00454 ast_free(out); 00455 } 00456 return NULL; 00457 } 00458 newdata += AST_FRIENDLY_OFFSET; 00459 out->offset = AST_FRIENDLY_OFFSET; 00460 out->datalen = fr->datalen; 00461 memcpy(newdata, fr->data.ptr, fr->datalen); 00462 out->data.ptr = newdata; 00463 } else { 00464 out->data = fr->data; 00465 memset(&fr->data, 0, sizeof(fr->data)); 00466 fr->mallocd &= ~AST_MALLOCD_DATA; 00467 } 00468 00469 out->mallocd = AST_MALLOCD_HDR | AST_MALLOCD_SRC | AST_MALLOCD_DATA; 00470 00471 return out; 00472 }
| struct ast_format_list* ast_get_format_list | ( | size_t * | size | ) | [read] |
Definition at line 567 of file frame.c.
References ARRAY_LEN.
00568 { 00569 *size = ARRAY_LEN(AST_FORMAT_LIST); 00570 return AST_FORMAT_LIST; 00571 }
| struct ast_format_list* ast_get_format_list_index | ( | int | idx | ) | [read] |
Definition at line 562 of file frame.c.
00563 { 00564 return &AST_FORMAT_LIST[idx]; 00565 }
| int ast_getformatbyname | ( | const char * | name | ) |
Gets a format from a name.
| name | string of format |
Definition at line 636 of file frame.c.
References ARRAY_LEN, ast_expand_codec_alias(), ast_format_list::bits, and format.
Referenced by ast_parse_allow_disallow(), iax_template_parse(), load_moh_classes(), local_ast_moh_start(), reload_config(), and try_suggested_sip_codec().
00637 { 00638 int x, all, format = 0; 00639 00640 all = strcasecmp(name, "all") ? 0 : 1; 00641 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 00642 if (all || 00643 !strcasecmp(AST_FORMAT_LIST[x].name,name) || 00644 !strcasecmp(AST_FORMAT_LIST[x].name, ast_expand_codec_alias(name))) { 00645 format |= AST_FORMAT_LIST[x].bits; 00646 if (!all) 00647 break; 00648 } 00649 } 00650 00651 return format; 00652 }
| char* ast_getformatname | ( | int | format | ) |
Get the name of a format.
| format | id of format |
Definition at line 573 of file frame.c.
References ARRAY_LEN, ast_format_list::bits, and ast_format_list::name.
Referenced by __ast_play_and_record(), __ast_read(), __ast_register_translator(), _sip_show_peer(), _skinny_show_line(), add_codec_to_answer(), add_codec_to_sdp(), add_tcodec_to_sdp(), add_vcodec_to_sdp(), agent_call(), ast_codec_get_len(), ast_codec_get_samples(), ast_codec_pref_string(), ast_dsp_process(), ast_frame_dump(), ast_openvstream(), ast_rtp_write(), ast_slinfactory_feed(), ast_streamfile(), ast_translator_build_path(), ast_unregister_translator(), ast_writestream(), background_detect_exec(), bridge_channel_join(), bridge_make_compatible(), dahdi_read(), do_waiting(), eagi_exec(), func_channel_read(), function_iaxpeer(), function_sippeer(), gtalk_show_channels(), handle_cli_core_show_file_formats(), handle_cli_core_show_translation(), handle_cli_iax2_show_channels(), handle_cli_iax2_show_peer(), handle_cli_moh_show_classes(), handle_core_show_image_formats(), iax2_request(), iax_show_provisioning(), jingle_show_channels(), login_exec(), moh_release(), oh323_rtp_read(), phone_setup(), print_codec_to_cli(), rebuild_matrix(), register_translator(), set_format(), set_local_capabilities(), set_peer_capabilities(), show_codecs(), sip_request_call(), sip_rtp_read(), socket_process(), start_rtp(), unistim_request(), unistim_rtp_read(), and unistim_write().
00574 { 00575 int x; 00576 char *ret = "unknown"; 00577 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 00578 if (AST_FORMAT_LIST[x].bits == format) { 00579 ret = AST_FORMAT_LIST[x].name; 00580 break; 00581 } 00582 } 00583 return ret; 00584 }
| char* ast_getformatname_multiple | ( | char * | buf, | |
| size_t | size, | |||
| int | format | |||
| ) |
Get the names of a set of formats.
| buf | a buffer for the output string | |
| size | size of buf (bytes) | |
| format | the format (combined IDs of codecs) Prints a list of readable codec names corresponding to "format". ex: for format=AST_FORMAT_GSM|AST_FORMAT_SPEEX|AST_FORMAT_ILBC it will return "0x602 (GSM|SPEEX|ILBC)" |
Definition at line 586 of file frame.c.
References ARRAY_LEN, ast_copy_string(), ast_format_list::bits, len(), and name.
Referenced by __ast_read(), _sip_show_peer(), _skinny_show_device(), _skinny_show_line(), add_sdp(), ast_streamfile(), bridge_make_compatible(), function_iaxpeer(), function_sippeer(), gtalk_is_answered(), gtalk_newcall(), handle_cli_iax2_show_peer(), handle_showchan(), iax2_bridge(), process_sdp(), serialize_showchan(), set_format(), show_channels_cb(), sip_new(), sip_request_call(), sip_show_channel(), sip_show_settings(), and sip_write().
00587 { 00588 int x; 00589 unsigned len; 00590 char *start, *end = buf; 00591 00592 if (!size) 00593 return buf; 00594 snprintf(end, size, "0x%x (", format); 00595 len = strlen(end); 00596 end += len; 00597 size -= len; 00598 start = end; 00599 for (x = 0; x < ARRAY_LEN(AST_FORMAT_LIST); x++) { 00600 if (AST_FORMAT_LIST[x].bits & format) { 00601 snprintf(end, size,"%s|",AST_FORMAT_LIST[x].name); 00602 len = strlen(end); 00603 end += len; 00604 size -= len; 00605 } 00606 } 00607 if (start == end) 00608 ast_copy_string(start, "nothing)", size); 00609 else if (size > 1) 00610 *(end -1) = ')'; 00611 return buf; 00612 }
| int ast_parse_allow_disallow | ( | struct ast_codec_pref * | pref, | |
| int * | mask, | |||
| const char * | list, | |||
| int | allowing | |||
| ) |
Parse an "allow" or "deny" line in a channel or device configuration and update the capabilities mask and pref if provided. Video codecs are not added to codec preference lists, since we can not transcode.
Definition at line 1233 of file frame.c.
References ast_codec_pref_append(), ast_codec_pref_remove(), ast_codec_pref_setsize(), ast_debug, AST_FORMAT_AUDIO_MASK, ast_getformatbyname(), ast_log(), format, LOG_WARNING, and parse().
Referenced by action_originate(), apply_outgoing(), build_peer(), build_user(), config_parse_variables(), gtalk_create_member(), gtalk_load_config(), jingle_create_member(), jingle_load_config(), reload_config(), set_config(), skinny_unregister(), and update_common_options().
01234 { 01235 int errors = 0; 01236 char *parse = NULL, *this = NULL, *psize = NULL; 01237 int format = 0, framems = 0; 01238 01239 parse = ast_strdupa(list); 01240 while ((this = strsep(&parse, ","))) { 01241 framems = 0; 01242 if ((psize = strrchr(this, ':'))) { 01243 *psize++ = '\0'; 01244 ast_debug(1, "Packetization for codec: %s is %s\n", this, psize); 01245 framems = atoi(psize); 01246 if (framems < 0) { 01247 framems = 0; 01248 errors++; 01249 ast_log(LOG_WARNING, "Bad packetization value for codec %s\n", this); 01250 } 01251 } 01252 if (!(format = ast_getformatbyname(this))) { 01253 ast_log(LOG_WARNING, "Cannot %s unknown format '%s'\n", allowing ? "allow" : "disallow", this); 01254 errors++; 01255 continue; 01256 } 01257 01258 if (mask) { 01259 if (allowing) 01260 *mask |= format; 01261 else 01262 *mask &= ~format; 01263 } 01264 01265 /* Set up a preference list for audio. Do not include video in preferences 01266 since we can not transcode video and have to use whatever is offered 01267 */ 01268 if (pref && (format & AST_FORMAT_AUDIO_MASK)) { 01269 if (strcasecmp(this, "all")) { 01270 if (allowing) { 01271 ast_codec_pref_append(pref, format); 01272 ast_codec_pref_setsize(pref, format, framems); 01273 } 01274 else 01275 ast_codec_pref_remove(pref, format); 01276 } else if (!allowing) { 01277 memset(pref, 0, sizeof(*pref)); 01278 } 01279 } 01280 } 01281 return errors; 01282 }
| void ast_smoother_free | ( | struct ast_smoother * | s | ) |
Definition at line 286 of file frame.c.
References ast_free.
Referenced by ast_rtp_destroy(), and ast_rtp_write().
00287 { 00288 ast_free(s); 00289 }
| int ast_smoother_get_flags | ( | struct ast_smoother * | s | ) |
Definition at line 186 of file frame.c.
References ast_smoother::flags.
00187 { 00188 return s->flags; 00189 }
| struct ast_smoother* ast_smoother_new | ( | int | size | ) | [read] |
Definition at line 176 of file frame.c.
References ast_malloc, ast_smoother_reset(), and s.
Referenced by ast_rtp_codec_setpref(), and ast_rtp_write().
00177 { 00178 struct ast_smoother *s; 00179 if (size < 1) 00180 return NULL; 00181 if ((s = ast_malloc(sizeof(*s)))) 00182 ast_smoother_reset(s, size); 00183 return s; 00184 }
| struct ast_frame* ast_smoother_read | ( | struct ast_smoother * | s | ) | [read] |
Definition at line 236 of file frame.c.
References ast_format_rate(), AST_FRAME_VOICE, AST_FRIENDLY_OFFSET, ast_log(), ast_samp2tv(), AST_SMOOTHER_FLAG_G729, ast_tvadd(), ast_tvzero(), ast_smoother::data, ast_frame::data, ast_frame::datalen, ast_smoother::delivery, ast_frame::delivery, ast_smoother::f, ast_smoother::flags, ast_smoother::format, ast_smoother::framedata, ast_frame::frametype, ast_smoother::len, len(), LOG_WARNING, ast_frame::offset, ast_smoother::opt, ast_frame::ptr, ast_frame::samples, ast_smoother::samplesperbyte, ast_smoother::size, and ast_frame::subclass.
Referenced by ast_rtp_write().
00237 { 00238 struct ast_frame *opt; 00239 int len; 00240 00241 /* IF we have an optimization frame, send it */ 00242 if (s->opt) { 00243 if (s->opt->offset < AST_FRIENDLY_OFFSET) 00244 ast_log(LOG_WARNING, "Returning a frame of inappropriate offset (%d).\n", 00245 s->opt->offset); 00246 opt = s->opt; 00247 s->opt = NULL; 00248 return opt; 00249 } 00250 00251 /* Make sure we have enough data */ 00252 if (s->len < s->size) { 00253 /* Or, if this is a G.729 frame with VAD on it, send it immediately anyway */ 00254 if (!((s->flags & AST_SMOOTHER_FLAG_G729) && (s->len % 10))) 00255 return NULL; 00256 } 00257 len = s->size; 00258 if (len > s->len) 00259 len = s->len; 00260 /* Make frame */ 00261 s->f.frametype = AST_FRAME_VOICE; 00262 s->f.subclass = s->format; 00263 s->f.data.ptr = s->framedata + AST_FRIENDLY_OFFSET; 00264 s->f.offset = AST_FRIENDLY_OFFSET; 00265 s->f.datalen = len; 00266 /* Samples will be improper given VAD, but with VAD the concept really doesn't even exist */ 00267 s->f.samples = len * s->samplesperbyte; /* XXX rounding */ 00268 s->f.delivery = s->delivery; 00269 /* Fill Data */ 00270 memcpy(s->f.data.ptr, s->data, len); 00271 s->len -= len; 00272 /* Move remaining data to the front if applicable */ 00273 if (s->len) { 00274 /* In principle this should all be fine because if we are sending 00275 G.729 VAD, the next timestamp will take over anyawy */ 00276 memmove(s->data, s->data + len, s->len); 00277 if (!ast_tvzero(s->delivery)) { 00278 /* If we have delivery time, increment it, otherwise, leave it at 0 */ 00279 s->delivery = ast_tvadd(s->delivery, ast_samp2tv(s->f.samples, ast_format_rate(s->format))); 00280 } 00281 } 00282 /* Return frame */ 00283 return &s->f; 00284 }
| void ast_smoother_reconfigure | ( | struct ast_smoother * | s, | |
| int | bytes | |||
| ) |
Reconfigure an existing smoother to output a different number of bytes per frame.
| s | the smoother to reconfigure | |
| bytes | the desired number of bytes per output frame |
Definition at line 154 of file frame.c.
References ast_smoother::opt, ast_smoother::opt_needs_swap, ast_smoother::size, and smoother_frame_feed().
Referenced by ast_rtp_codec_setpref().
00155 { 00156 /* if there is no change, then nothing to do */ 00157 if (s->size == bytes) { 00158 return; 00159 } 00160 /* set the new desired output size */ 00161 s->size = bytes; 00162 /* if there is no 'optimized' frame in the smoother, 00163 * then there is nothing left to do 00164 */ 00165 if (!s->opt) { 00166 return; 00167 } 00168 /* there is an 'optimized' frame here at the old size, 00169 * but it must now be put into the buffer so the data 00170 * can be extracted at the new size 00171 */ 00172 smoother_frame_feed(s, s->opt, s->opt_needs_swap); 00173 s->opt = NULL; 00174 }
| void ast_smoother_reset | ( | struct ast_smoother * | s, | |
| int | bytes | |||
| ) |
Definition at line 148 of file frame.c.
References ast_smoother::size.
Referenced by ast_smoother_new().
00149 { 00150 memset(s, 0, sizeof(*s)); 00151 s->size = bytes; 00152 }
| void ast_smoother_set_flags | ( | struct ast_smoother * | s, | |
| int | flags | |||
| ) |
Definition at line 191 of file frame.c.
References ast_smoother::flags.
Referenced by ast_rtp_codec_setpref(), and ast_rtp_write().
| int ast_smoother_test_flag | ( | struct ast_smoother * | s, | |
| int | flag | |||
| ) |
Definition at line 196 of file frame.c.
References ast_smoother::flags.
Referenced by ast_rtp_write().
00197 { 00198 return (s->flags & flag); 00199 }
| void ast_swapcopy_samples | ( | void * | dst, | |
| const void * | src, | |||
| int | samples | |||
| ) |
Definition at line 551 of file frame.c.
Referenced by __ast_smoother_feed(), iax_frame_wrap(), phone_write_buf(), and smoother_frame_feed().
| static void frame_cache_cleanup | ( | void * | data | ) | [static] |
Definition at line 321 of file frame.c.
References ast_free, AST_LIST_REMOVE_HEAD, f, ast_frame::frame_list, frames, and ast_frame_cache::list.
00322 { 00323 struct ast_frame_cache *frames = data; 00324 struct ast_frame *f; 00325 00326 while ((f = AST_LIST_REMOVE_HEAD(&frames->list, frame_list))) 00327 ast_free(f); 00328 00329 ast_free(frames); 00330 }
| static int g723_len | ( | unsigned char | buf | ) | [static] |
Definition at line 1284 of file frame.c.
References ast_log(), LOG_WARNING, type, TYPE_DONTSEND, TYPE_HIGH, TYPE_LOW, TYPE_MASK, and TYPE_SILENCE.
Referenced by g723_samples().
01285 { 01286 enum frame_type type = buf & TYPE_MASK; 01287 01288 switch(type) { 01289 case TYPE_DONTSEND: 01290 return 0; 01291 break; 01292 case TYPE_SILENCE: 01293 return 4; 01294 break; 01295 case TYPE_HIGH: 01296 return 24; 01297 break; 01298 case TYPE_LOW: 01299 return 20; 01300 break; 01301 default: 01302 ast_log(LOG_WARNING, "Badly encoded frame (%d)\n", type); 01303 } 01304 return -1; 01305 }
| static int g723_samples | ( | unsigned char * | buf, | |
| int | maxlen | |||
| ) | [static] |
Definition at line 1307 of file frame.c.
References g723_len().
Referenced by ast_codec_get_samples().
| static unsigned char get_n_bits_at | ( | unsigned char * | data, | |
| int | n, | |||
| int | bit | |||
| ) | [static] |
Definition at line 1322 of file frame.c.
Referenced by speex_get_wb_sz_at(), and speex_samples().
01323 { 01324 int byte = bit / 8; /* byte containing first bit */ 01325 int rem = 8 - (bit % 8); /* remaining bits in first byte */ 01326 unsigned char ret = 0; 01327 01328 if (n <= 0 || n > 8) 01329 return 0; 01330 01331 if (rem < n) { 01332 ret = (data[byte] << (n - rem)); 01333 ret |= (data[byte + 1] >> (8 - n + rem)); 01334 } else { 01335 ret = (data[byte] >> (rem - n)); 01336 } 01337 01338 return (ret & (0xff >> (8 - n))); 01339 }
| int init_framer | ( | void | ) |
Provided by frame.c
Definition at line 968 of file frame.c.
References ARRAY_LEN, and ast_cli_register_multiple().
Referenced by main().
00969 { 00970 ast_cli_register_multiple(my_clis, ARRAY_LEN(my_clis)); 00971 return 0; 00972 }
| static char* show_codec_n | ( | struct ast_cli_entry * | e, | |
| int | cmd, | |||
| struct ast_cli_args * | a | |||
| ) | [static] |
Definition at line 722 of file frame.c.
References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), ast_codec2str(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, ast_cli_args::fd, and ast_cli_entry::usage.
00723 { 00724 int codec, i, found=0; 00725 00726 switch (cmd) { 00727 case CLI_INIT: 00728 e->command = "core show codec"; 00729 e->usage = 00730 "Usage: core show codec <number>\n" 00731 " Displays codec mapping\n"; 00732 return NULL; 00733 case CLI_GENERATE: 00734 return NULL; 00735 } 00736 00737 if (a->argc != 4) 00738 return CLI_SHOWUSAGE; 00739 00740 if (sscanf(a->argv[3], "%30d", &codec) != 1) 00741 return CLI_SHOWUSAGE; 00742 00743 for (i = 0; i < 32; i++) 00744 if (codec & (1 << i)) { 00745 found = 1; 00746 ast_cli(a->fd, "%11u (1 << %2d) %s\n",1 << i,i,ast_codec2str(1<<i)); 00747 } 00748 00749 if (!found) 00750 ast_cli(a->fd, "Codec %d not found\n", codec); 00751 00752 return CLI_SUCCESS; 00753 }
| static char* show_codecs | ( | struct ast_cli_entry * | e, | |
| int | cmd, | |||
| struct ast_cli_args * | a | |||
| ) | [static] |
Definition at line 667 of file frame.c.
References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), ast_codec2str(), ast_getformatname(), ast_opt_dont_warn, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, ast_cli_args::fd, and ast_cli_entry::usage.
00668 { 00669 int i, found=0; 00670 char hex[25]; 00671 00672 switch (cmd) { 00673 case CLI_INIT: 00674 e->command = "core show codecs [audio|video|image]"; 00675 e->usage = 00676 "Usage: core show codecs [audio|video|image]\n" 00677 " Displays codec mapping\n"; 00678 return NULL; 00679 case CLI_GENERATE: 00680 return NULL; 00681 } 00682 00683 if ((a->argc < 3) || (a->argc > 4)) 00684 return CLI_SHOWUSAGE; 00685 00686 if (!ast_opt_dont_warn) 00687 ast_cli(a->fd, "Disclaimer: this command is for informational purposes only.\n" 00688 "\tIt does not indicate anything about your configuration.\n"); 00689 00690 ast_cli(a->fd, "%11s %9s %10s TYPE %8s %s\n","INT","BINARY","HEX","NAME","DESC"); 00691 ast_cli(a->fd, "--------------------------------------------------------------------------------\n"); 00692 if ((a->argc == 3) || (!strcasecmp(a->argv[3],"audio"))) { 00693 found = 1; 00694 for (i=0;i<13;i++) { 00695 snprintf(hex,25,"(0x%x)",1<<i); 00696 ast_cli(a->fd, "%11u (1 << %2d) %10s audio %8s (%s)\n",1 << i,i,hex,ast_getformatname(1<<i),ast_codec2str(1<<i)); 00697 } 00698 } 00699 00700 if ((a->argc == 3) || (!strcasecmp(a->argv[3],"image"))) { 00701 found = 1; 00702 for (i=16;i<18;i++) { 00703 snprintf(hex,25,"(0x%x)",1<<i); 00704 ast_cli(a->fd, "%11u (1 << %2d) %10s image %8s (%s)\n",1 << i,i,hex,ast_getformatname(1<<i),ast_codec2str(1<<i)); 00705 } 00706 } 00707 00708 if ((a->argc == 3) || (!strcasecmp(a->argv[3],"video"))) { 00709 found = 1; 00710 for (i=18;i<22;i++) { 00711 snprintf(hex,25,"(0x%x)",1<<i); 00712 ast_cli(a->fd, "%11u (1 << %2d) %10s video %8s (%s)\n",1 << i,i,hex,ast_getformatname(1<<i),ast_codec2str(1<<i)); 00713 } 00714 } 00715 00716 if (!found) 00717 return CLI_SHOWUSAGE; 00718 else 00719 return CLI_SUCCESS; 00720 }
| static int smoother_frame_feed | ( | struct ast_smoother * | s, | |
| struct ast_frame * | f, | |||
| int | swap | |||
| ) | [static] |
Definition at line 126 of file frame.c.
References ast_log(), AST_SMOOTHER_FLAG_G729, ast_swapcopy_samples(), ast_tvzero(), ast_frame::data, ast_smoother::data, ast_frame::datalen, ast_smoother::delivery, ast_frame::delivery, ast_smoother::flags, ast_smoother::len, LOG_NOTICE, ast_frame::ptr, and ast_frame::samples.
Referenced by __ast_smoother_feed(), and ast_smoother_reconfigure().
00127 { 00128 if (s->flags & AST_SMOOTHER_FLAG_G729) { 00129 if (s->len % 10) { 00130 ast_log(LOG_NOTICE, "Dropping extra frame of G.729 since we already have a VAD frame at the end\n"); 00131 return 0; 00132 } 00133 } 00134 if (swap) { 00135 ast_swapcopy_samples(s->data + s->len, f->data.ptr, f->samples); 00136 } else { 00137 memcpy(s->data + s->len, f->data.ptr, f->datalen); 00138 } 00139 /* If either side is empty, reset the delivery time */ 00140 if (!s->len || ast_tvzero(f->delivery) || ast_tvzero(s->delivery)) { /* XXX really ? */ 00141 s->delivery = f->delivery; 00142 } 00143 s->len += f->datalen; 00144 00145 return 0; 00146 }
| static int speex_get_wb_sz_at | ( | unsigned char * | data, | |
| int | len, | |||
| int | bit | |||
| ) | [static] |
Definition at line 1341 of file frame.c.
References ast_log(), get_n_bits_at(), and LOG_WARNING.
Referenced by speex_samples().
01342 { 01343 static int SpeexWBSubModeSz[] = { 01344 0, 36, 112, 192, 01345 352, 0, 0, 0 }; 01346 int off = bit; 01347 unsigned char c; 01348 01349 /* skip up to two wideband frames */ 01350 if (((len * 8 - off) >= 5) && 01351 get_n_bits_at(data, 1, off)) { 01352 c = get_n_bits_at(data, 3, off + 1); 01353 off += SpeexWBSubModeSz[c]; 01354 01355 if (((len * 8 - off) >= 5) && 01356 get_n_bits_at(data, 1, off)) { 01357 c = get_n_bits_at(data, 3, off + 1); 01358 off += SpeexWBSubModeSz[c]; 01359 01360 if (((len * 8 - off) >= 5) && 01361 get_n_bits_at(data, 1, off)) { 01362 ast_log(LOG_WARNING, "Encountered corrupt speex frame; too many wideband frames in a row.\n"); 01363 return -1; 01364 } 01365 } 01366 01367 } 01368 return off - bit; 01369 }
| static int speex_samples | ( | unsigned char * | data, | |
| int | len | |||
| ) | [static] |
Definition at line 1371 of file frame.c.
References ast_log(), get_n_bits_at(), LOG_WARNING, and speex_get_wb_sz_at().
Referenced by ast_codec_get_samples().
01372 { 01373 static int SpeexSubModeSz[] = { 01374 5, 43, 119, 160, 01375 220, 300, 364, 492, 01376 79, 0, 0, 0, 01377 0, 0, 0, 0 }; 01378 static int SpeexInBandSz[] = { 01379 1, 1, 4, 4, 01380 4, 4, 4, 4, 01381 8, 8, 16, 16, 01382 32, 32, 64, 64 }; 01383 int bit = 0; 01384 int cnt = 0; 01385 int off; 01386 unsigned char c; 01387 01388 while ((len * 8 - bit) >= 5) { 01389 /* skip wideband frames */ 01390 off = speex_get_wb_sz_at(data, len, bit); 01391 if (off < 0) { 01392 ast_log(LOG_WARNING, "Had error while reading wideband frames for speex samples\n"); 01393 break; 01394 } 01395 bit += off; 01396 01397 if ((len * 8 - bit) < 5) { 01398 ast_log(LOG_WARNING, "Not enough bits remaining after wide band for speex samples.\n"); 01399 break; 01400 } 01401 01402 /* get control bits */ 01403 c = get_n_bits_at(data, 5, bit); 01404 bit += 5; 01405 01406 if (c == 15) { 01407 /* terminator */ 01408 break; 01409 } else if (c == 14) { 01410 /* in-band signal; next 4 bits contain signal id */ 01411 c = get_n_bits_at(data, 4, bit); 01412 bit += 4; 01413 bit += SpeexInBandSz[c]; 01414 } else if (c == 13) { 01415 /* user in-band; next 5 bits contain msg len */ 01416 c = get_n_bits_at(data, 5, bit); 01417 bit += 5; 01418 bit += c * 8; 01419 } else if (c > 8) { 01420 /* unknown */ 01421 break; 01422 } else { 01423 /* skip number bits for submode (less the 5 control bits) */ 01424 bit += SpeexSubModeSz[c] - 5; 01425 cnt += 160; /* new frame */ 01426 } 01427 } 01428 return cnt; 01429 }
struct ast_format_list AST_FORMAT_LIST[] [static] |
| struct ast_frame ast_null_frame = { AST_FRAME_NULL, } |
Queueing a null frame is fairly common, so we declare a global null frame object for this purpose instead of having to declare one on the stack
Definition at line 124 of file frame.c.
Referenced by __ast_read(), __oh323_rtp_create(), __oh323_update_info(), agent_new(), agent_read(), ast_channel_masquerade(), ast_channel_setwhentohangup_tv(), ast_do_masquerade(), ast_rtcp_read(), ast_rtp_read(), ast_softhangup_nolock(), ast_udptl_read(), bridge_read(), conf_run(), console_read(), dahdi_read(), gtalk_rtp_read(), handle_request_invite(), handle_response_invite(), iax2_read(), jingle_rtp_read(), local_read(), mgcp_rtp_read(), oh323_read(), oh323_rtp_read(), process_rfc2833(), process_sdp(), send_dtmf(), sip_read(), sip_rtp_read(), skinny_rtp_read(), unistim_rtp_read(), and wakeup_sub().
struct ast_threadstorage frame_cache = { .once = PTHREAD_ONCE_INIT , .key_init = __init_frame_cache , .custom_init = NULL , } [static] |
Definition at line 47 of file frame.c.
Referenced by __frame_free(), ast_frame_header_new(), and ast_frdup().
struct ast_cli_entry my_clis[] [static] |
{
AST_CLI_DEFINE(show_codecs, "Displays a list of codecs"),
AST_CLI_DEFINE(show_codec_n, "Shows a specific codec"),
}
1.6.2