47 #define GSM_FRAME_SIZE 33
48 #define MSGSM_FRAME_SIZE 65
49 #define MSGSM_DATA_OFFSET 60
50 #define GSM_SAMPLES 160
51 #define MSGSM_SAMPLES (2*GSM_SAMPLES)
54 static char msgsm_silence[] =
55 {0x48,0x17,0xD6,0x84,0x02,0x80,0x24,0x49,0x92,0x24,0x89,0x02,0x80,0x24,0x49
56 ,0x92,0x24,0x89,0x02,0x80,0x24,0x49,0x92,0x24,0x89,0x02,0x80,0x24,0x49,0x92
57 ,0x24,0x09,0x82,0x74,0x61,0x4D,0x28,0x00,0x48,0x92,0x24,0x49,0x92,0x28,0x00
58 ,0x48,0x92,0x24,0x49,0x92,0x28,0x00,0x48,0x92,0x24,0x49,0x92,0x28,0x00,0x48
59 ,0x92,0x24,0x49,0x92,0x00};
68 #if __BYTE_ORDER == __LITTLE_ENDIAN
74 #if __BYTE_ORDER == __BIG_ENDIAN
76 (((((b) ) & 0xFF) << 24) | \
77 ((( (b) >> 8) & 0xFF) << 16) | \
78 ((( (b) >> 16) & 0xFF) << 8) | \
79 ((( (b) >> 24) & 0xFF) ))
81 (((((b) ) & 0xFF) << 8) | \
82 ((( (b) >> 8) & 0xFF) ))
83 #define ltohl(b) htoll(b)
84 #define ltohs(b) htols(b)
86 #error "Endianess not defined"
91 static int check_header(FILE *f)
93 int type, size, formtype;
98 if (fread(&type, 1, 4, f) != 4) {
99 ast_log(LOG_WARNING,
"Read failed (type)\n");
102 if (fread(&size, 1, 4, f) != 4) {
103 ast_log(LOG_WARNING,
"Read failed (size)\n");
106 #if __BYTE_ORDER == __BIG_ENDIAN
109 if (fread(&formtype, 1, 4, f) != 4) {
110 ast_log(LOG_WARNING,
"Read failed (formtype)\n");
113 if (memcmp(&type,
"RIFF", 4)) {
114 ast_log(LOG_WARNING,
"Does not begin with RIFF\n");
117 if (memcmp(&formtype,
"WAVE", 4)) {
118 ast_log(LOG_WARNING,
"Does not contain WAVE\n");
121 if (fread(&fmt, 1, 4, f) != 4) {
122 ast_log(LOG_WARNING,
"Read failed (fmt)\n");
125 if (memcmp(&fmt,
"fmt ", 4)) {
126 ast_log(LOG_WARNING,
"Does not say fmt\n");
129 if (fread(&hsize, 1, 4, f) != 4) {
130 ast_log(LOG_WARNING,
"Read failed (formtype)\n");
133 if (ltohl(hsize) != 20) {
134 ast_log(LOG_WARNING,
"Unexpected header size %d\n", ltohl(hsize));
137 if (fread(&format, 1, 2, f) != 2) {
138 ast_log(LOG_WARNING,
"Read failed (format)\n");
141 if (ltohs(format) != 49) {
142 ast_log(LOG_WARNING,
"Not a GSM file %d\n", ltohs(format));
145 if (fread(&chans, 1, 2, f) != 2) {
146 ast_log(LOG_WARNING,
"Read failed (format)\n");
149 if (ltohs(chans) != 1) {
150 ast_log(LOG_WARNING,
"Not in mono %d\n", ltohs(chans));
153 if (fread(&freq, 1, 4, f) != 4) {
154 ast_log(LOG_WARNING,
"Read failed (freq)\n");
157 if (ltohl(freq) != DEFAULT_SAMPLE_RATE) {
158 ast_log(LOG_WARNING,
"Unexpected frequency %d\n", ltohl(freq));
162 if (fread(&freq, 1, 4, f) != 4) {
163 ast_log(LOG_WARNING,
"Read failed (X_1)\n");
167 if (fread(&freq, 1, 4, f) != 4) {
168 ast_log(LOG_WARNING,
"Read failed (X_2/X_3)\n");
172 if (fread(&freq, 1, 4, f) != 4) {
173 ast_log(LOG_WARNING,
"Read failed (Y_1)\n");
177 if (fread(&fact, 1, 4, f) != 4) {
178 ast_log(LOG_WARNING,
"Read failed (fact)\n");
181 if (memcmp(&fact,
"fact", 4)) {
182 ast_log(LOG_WARNING,
"Does not say fact\n");
186 if (fread(&fact, 1, 4, f) != 4) {
187 ast_log(LOG_WARNING,
"Read failed (fact header)\n");
190 if (fread(&fact, 1, 4, f) != 4) {
191 ast_log(LOG_WARNING,
"Read failed (fact value)\n");
195 if (fread(&data, 1, 4, f) != 4) {
196 ast_log(LOG_WARNING,
"Read failed (data)\n");
199 if (memcmp(&data,
"data", 4)) {
200 ast_log(LOG_WARNING,
"Does not say data\n");
204 if (fread(&data, 1, 4, f) != 4) {
205 ast_log(LOG_WARNING,
"Read failed (data)\n");
211 static int update_header(FILE *f)
214 int datalen, filelen, samples;
217 fseek(f, 0, SEEK_END);
220 bytes = end - MSGSM_DATA_OFFSET;
221 samples = htoll(bytes / MSGSM_FRAME_SIZE * MSGSM_SAMPLES);
222 datalen = htoll(bytes);
223 filelen = htoll(MSGSM_DATA_OFFSET - 8 + bytes);
225 ast_log(LOG_WARNING,
"Unable to find our position\n");
228 if (fseek(f, 4, SEEK_SET)) {
229 ast_log(LOG_WARNING,
"Unable to set our position\n");
232 if (fwrite(&filelen, 1, 4, f) != 4) {
233 ast_log(LOG_WARNING,
"Unable to write file size\n");
236 if (fseek(f, 48, SEEK_SET)) {
237 ast_log(LOG_WARNING,
"Unable to set our position\n");
240 if (fwrite(&samples, 1, 4, f) != 4) {
241 ast_log(LOG_WARNING,
"Unable to write samples\n");
244 if (fseek(f, 56, SEEK_SET)) {
245 ast_log(LOG_WARNING,
"Unable to set our position\n");
248 if (fwrite(&datalen, 1, 4, f) != 4) {
249 ast_log(LOG_WARNING,
"Unable to write datalen\n");
252 if (fseeko(f, cur, SEEK_SET)) {
253 ast_log(LOG_WARNING,
"Unable to return to position\n");
259 static int write_header(FILE *f)
262 unsigned int sample_rate = htoll(8000);
264 unsigned int byte_sample_rate = htoll(1625);
266 unsigned int fmtsize = htoll(20);
268 unsigned short fmt = htols(49);
270 unsigned short chans = htols(1);
272 unsigned int block_align = htoll(MSGSM_FRAME_SIZE);
274 unsigned short bits_per_sample = htols(2);
276 unsigned short extra_format = htols(MSGSM_SAMPLES);
278 unsigned int factsize = htoll(4);
280 unsigned int num_samples = htoll(0);
282 unsigned int size = htoll(0);
286 if (fwrite(
"RIFF", 1, 4, f) != 4) {
287 ast_log(LOG_WARNING,
"Unable to write header\n");
291 if (fwrite(&size, 1, 4, f) != 4) {
292 ast_log(LOG_WARNING,
"Unable to write header\n");
296 if (fwrite(
"WAVE", 1, 4, f) != 4) {
297 ast_log(LOG_WARNING,
"Unable to write header\n");
301 if (fwrite(
"fmt ", 1, 4, f) != 4) {
302 ast_log(LOG_WARNING,
"Unable to write header\n");
306 if (fwrite(&fmtsize, 1, 4, f) != 4) {
307 ast_log(LOG_WARNING,
"Unable to write header\n");
311 if (fwrite(&fmt, 1, 2, f) != 2) {
312 ast_log(LOG_WARNING,
"Unable to write header\n");
316 if (fwrite(&chans, 1, 2, f) != 2) {
317 ast_log(LOG_WARNING,
"Unable to write header\n");
321 if (fwrite(&sample_rate, 1, 4, f) != 4) {
322 ast_log(LOG_WARNING,
"Unable to write header\n");
326 if (fwrite(&byte_sample_rate, 1, 4, f) != 4) {
327 ast_log(LOG_WARNING,
"Unable to write header\n");
331 if (fwrite(&block_align, 1, 4, f) != 4) {
332 ast_log(LOG_WARNING,
"Unable to write header\n");
336 if (fwrite(&bits_per_sample, 1, 2, f) != 2) {
337 ast_log(LOG_WARNING,
"Unable to write header\n");
341 if (fwrite(&extra_format, 1, 2, f) != 2) {
342 ast_log(LOG_WARNING,
"Unable to write header\n");
346 if (fwrite(
"fact", 1, 4, f) != 4) {
347 ast_log(LOG_WARNING,
"Unable to write header\n");
351 if (fwrite(&factsize, 1, 4, f) != 4) {
352 ast_log(LOG_WARNING,
"Unable to write header\n");
356 if (fwrite(&num_samples, 1, 4, f) != 4) {
357 ast_log(LOG_WARNING,
"Unable to write header\n");
361 if (fwrite(
"data", 1, 4, f) != 4) {
362 ast_log(LOG_WARNING,
"Unable to write header\n");
366 if (fwrite(&size, 1, 4, f) != 4) {
367 ast_log(LOG_WARNING,
"Unable to write header\n");
380 if (check_header(s->f))
386 static int wav_rewrite(
struct ast_filestream *s,
const char *comment)
392 if (write_header(s->f))
399 if (s->mode == O_RDONLY) {
415 if (fs->secondhalf) {
417 s->
fr.
data.ptr = (
char *)s->
fr.
data.ptr + GSM_FRAME_SIZE;
421 unsigned char msdata[MSGSM_FRAME_SIZE];
424 if ((res = fread(msdata, 1, MSGSM_FRAME_SIZE, s->f)) != MSGSM_FRAME_SIZE) {
425 if (res && res != 1) {
426 ast_log(LOG_WARNING,
"Short read of %s data (expected %d bytes, read %zu): %s\n",
433 conv65(msdata, s->
fr.
data.ptr);
435 fs->secondhalf = !fs->secondhalf;
436 *whennext = GSM_SAMPLES;
449 if (!(f->
datalen % MSGSM_FRAME_SIZE)) {
450 size = MSGSM_FRAME_SIZE;
453 size = GSM_FRAME_SIZE;
455 for (len = 0; len < f->
datalen ; len += size) {
457 unsigned char *src, msdata[MSGSM_FRAME_SIZE];
458 if (fs->secondhalf) {
459 memcpy(s->
buf + GSM_FRAME_SIZE, f->
data.ptr + len, GSM_FRAME_SIZE);
460 conv66((
unsigned char *) s->
buf, msdata);
463 }
else if (size == GSM_FRAME_SIZE) {
464 memcpy(s->
buf, f->
data.ptr + len, GSM_FRAME_SIZE);
468 src = f->
data.ptr + len;
470 if (src && (res = fwrite(src, 1, MSGSM_FRAME_SIZE, s->f)) != MSGSM_FRAME_SIZE) {
471 ast_log(LOG_WARNING,
"Bad write (%d/65): %s\n", res, strerror(errno));
478 static int wav_seek(
struct ast_filestream *fs, off_t sample_offset,
int whence)
480 off_t offset = 0, min = MSGSM_DATA_OFFSET, distance, max, cur;
483 if ((cur = ftello(fs->f)) < 0) {
484 ast_log(AST_LOG_WARNING,
"Unable to determine current position in WAV filestream %p: %s\n", fs, strerror(errno));
488 if (fseeko(fs->f, 0, SEEK_END) < 0) {
489 ast_log(AST_LOG_WARNING,
"Unable to seek to end of WAV filestream %p: %s\n", fs, strerror(errno));
494 if ((max = ftello(fs->f)) < 0) {
495 ast_log(AST_LOG_WARNING,
"Unable to determine max position in WAV filestream %p: %s\n", fs, strerror(errno));
500 distance = (sample_offset/MSGSM_SAMPLES) * MSGSM_FRAME_SIZE;
501 if (whence == SEEK_SET)
502 offset = distance + min;
503 else if (whence == SEEK_CUR || whence == SEEK_FORCECUR)
504 offset = distance + cur;
505 else if (whence == SEEK_END)
506 offset = max - distance;
510 if (whence != SEEK_FORCECUR) {
513 }
else if (offset > max) {
515 fseek(fs->f, 0, SEEK_END);
516 for (i=0; i< (offset - max) / MSGSM_FRAME_SIZE; i++) {
517 if (fwrite(msgsm_silence, 1, MSGSM_FRAME_SIZE, fs->f) != MSGSM_FRAME_SIZE) {
518 ast_log(LOG_WARNING,
"fwrite() failed: %s\n", strerror(errno));
523 return fseeko(fs->f, offset, SEEK_SET);
531 if ((fd = fileno(fs->f)) < 0) {
532 ast_log(AST_LOG_WARNING,
"Unable to determine file descriptor for WAV filestream %p: %s\n", fs, strerror(errno));
535 if ((cur = ftello(fs->f)) < 0) {
536 ast_log(AST_LOG_WARNING,
"Unable to determine current position in WAV filestream %p: %s\n", fs, strerror(errno));
540 if (ftruncate(fd, cur)) {
543 return update_header(fs->f);
549 offset = ftello(fs->f);
552 return (offset - MSGSM_DATA_OFFSET)/MSGSM_FRAME_SIZE*MSGSM_SAMPLES;
559 .rewrite = wav_rewrite,
570 static int load_module(
void)
573 if (ast_format_def_register(&wav49_f))
578 static int unload_module(
void)
583 AST_MODULE_INFO(
ASTERISK_GPL_KEY, AST_MODFLAG_LOAD_ORDER,
"Microsoft WAV format (Proprietary GSM)",
584 .support_level = AST_MODULE_SUPPORT_CORE,
586 .unload = unload_module,
Asterisk main include file. File version handling, generic pbx functions.
struct ast_frame_subclass subclass
#define AST_FRIENDLY_OFFSET
Offset into a frame's data buffer.
Asterisk architecture endianess compatibility definitions.
struct ast_frame fr
frame produced by read, typically
#define AST_FRAME_SET_BUFFER(fr, _base, _ofs, _datalen)
union ast_frame::@224 data
Module has failed to load, may be in an inconsistent state.
This structure is allocated by file.c in one chunk, together with buf_size and desc_size bytes of mem...
Data structure associated with a single frame of data.
struct ast_format * format
#define ASTERISK_GPL_KEY
The text the key() function should return.
Asterisk module definitions.