00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032 #include "asterisk.h"
00033
00034 ASTERISK_FILE_VERSION(__FILE__, "$Revision: 364578 $")
00035
00036 #include "asterisk/mod_format.h"
00037 #include "asterisk/module.h"
00038
00039 #define G723_MAX_SIZE 1024
00040
00041 static struct ast_frame *g723_read(struct ast_filestream *s, int *whennext)
00042 {
00043 unsigned short size;
00044 int res;
00045 int delay;
00046
00047
00048 if (fread(&delay, 1, 4, s->f) == 4)
00049 delay = ntohl(delay);
00050 else
00051 delay = -1;
00052 if (fread(&size, 1, 2, s->f) != 2) {
00053
00054
00055 return NULL;
00056 }
00057
00058 size = ntohs(size);
00059 if (size > G723_MAX_SIZE) {
00060 ast_log(LOG_WARNING, "Size %d is invalid\n", size);
00061
00062
00063
00064 return NULL;
00065 }
00066
00067 s->fr.frametype = AST_FRAME_VOICE;
00068 s->fr.subclass.codec = AST_FORMAT_G723_1;
00069 s->fr.mallocd = 0;
00070 AST_FRAME_SET_BUFFER(&s->fr, s->buf, AST_FRIENDLY_OFFSET, size);
00071 if ((res = fread(s->fr.data.ptr, 1, s->fr.datalen, s->f)) != size) {
00072 ast_log(LOG_WARNING, "Short read (%d of %d bytes) (%s)!\n", res, size, strerror(errno));
00073 return NULL;
00074 }
00075 *whennext = s->fr.samples = 240;
00076 return &s->fr;
00077 }
00078
00079 static int g723_write(struct ast_filestream *s, struct ast_frame *f)
00080 {
00081 uint32_t delay;
00082 uint16_t size;
00083 int res;
00084
00085 if (f->frametype != AST_FRAME_VOICE) {
00086 ast_log(LOG_WARNING, "Asked to write non-voice frame!\n");
00087 return -1;
00088 }
00089 if (f->subclass.codec != AST_FORMAT_G723_1) {
00090 ast_log(LOG_WARNING, "Asked to write non-g723 frame!\n");
00091 return -1;
00092 }
00093 delay = 0;
00094 if (f->datalen <= 0) {
00095 ast_log(LOG_WARNING, "Short frame ignored (%d bytes long?)\n", f->datalen);
00096 return 0;
00097 }
00098 if ((res = fwrite(&delay, 1, 4, s->f)) != 4) {
00099 ast_log(LOG_WARNING, "Unable to write delay: res=%d (%s)\n", res, strerror(errno));
00100 return -1;
00101 }
00102 size = htons(f->datalen);
00103 if ((res = fwrite(&size, 1, 2, s->f)) != 2) {
00104 ast_log(LOG_WARNING, "Unable to write size: res=%d (%s)\n", res, strerror(errno));
00105 return -1;
00106 }
00107 if ((res = fwrite(f->data.ptr, 1, f->datalen, s->f)) != f->datalen) {
00108 ast_log(LOG_WARNING, "Unable to write frame: res=%d (%s)\n", res, strerror(errno));
00109 return -1;
00110 }
00111 return 0;
00112 }
00113
00114 static int g723_seek(struct ast_filestream *fs, off_t sample_offset, int whence)
00115 {
00116 return -1;
00117 }
00118
00119 static int g723_trunc(struct ast_filestream *fs)
00120 {
00121 int fd;
00122 off_t cur;
00123
00124 if ((fd = fileno(fs->f)) < 0) {
00125 ast_log(AST_LOG_WARNING, "Unable to determine file descriptor for g723 filestream %p: %s\n", fs, strerror(errno));
00126 return -1;
00127 }
00128 if ((cur = ftello(fs->f)) < 0) {
00129 ast_log(AST_LOG_WARNING, "Unable to determine current position in g723 filestream %p: %s\n", fs, strerror(errno));
00130 return -1;
00131 }
00132
00133 return ftruncate(fd, cur);
00134 }
00135
00136 static off_t g723_tell(struct ast_filestream *fs)
00137 {
00138 return -1;
00139 }
00140
00141 static const struct ast_format g723_1_f = {
00142 .name = "g723sf",
00143 .exts = "g723|g723sf",
00144 .format = AST_FORMAT_G723_1,
00145 .write = g723_write,
00146 .seek = g723_seek,
00147 .trunc = g723_trunc,
00148 .tell = g723_tell,
00149 .read = g723_read,
00150 .buf_size = G723_MAX_SIZE + AST_FRIENDLY_OFFSET,
00151 };
00152
00153 static int load_module(void)
00154 {
00155 if (ast_format_register(&g723_1_f))
00156 return AST_MODULE_LOAD_FAILURE;
00157 return AST_MODULE_LOAD_SUCCESS;
00158 }
00159
00160 static int unload_module(void)
00161 {
00162 return ast_format_unregister(g723_1_f.name);
00163 }
00164
00165 AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_LOAD_ORDER, "G.723.1 Simple Timestamp File Format",
00166 .load = load_module,
00167 .unload = unload_module,
00168 .load_pri = AST_MODPRI_APP_DEPEND
00169 );