Mercurial > hg > audiostuff
diff spandsp-0.0.3/spandsp-0.0.3/tests/fax_tests.c @ 5:f762bf195c4b
import spandsp-0.0.3
author | Peter Meerwald <pmeerw@cosy.sbg.ac.at> |
---|---|
date | Fri, 25 Jun 2010 16:00:21 +0200 |
parents | |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/spandsp-0.0.3/spandsp-0.0.3/tests/fax_tests.c Fri Jun 25 16:00:21 2010 +0200 @@ -0,0 +1,434 @@ +/* + * SpanDSP - a series of DSP components for telephony + * + * fax_tests.c + * + * Written by Steve Underwood <steveu@coppice.org> + * + * Copyright (C) 2003 Steve Underwood + * + * All rights reserved. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2, as + * published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + * + * $Id: fax_tests.c,v 1.60 2006/11/19 14:07:27 steveu Exp $ + */ + +/*! \page fax_tests_page FAX tests +\section fax_tests_page_sec_1 What does it do? +\section fax_tests_page_sec_2 How does it work? +*/ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include <inttypes.h> +#include <stdlib.h> +#include <stdio.h> +#include <string.h> +#if defined(HAVE_TGMATH_H) +#include <tgmath.h> +#endif +#if defined(HAVE_MATH_H) +#include <math.h> +#endif +#include <assert.h> +#include <audiofile.h> +#include <tiffio.h> + +#include "spandsp.h" + +#define SAMPLES_PER_CHUNK 160 + +#define INPUT_TIFF_FILE_NAME "../itutests/fax/itutests.tif" + +#define OUTPUT_FILE_NAME_WAVE "fax_tests.wav" + +#define FAX_MACHINES 2 + +struct machine_s +{ + int chan; + int16_t amp[SAMPLES_PER_CHUNK]; + int len; + fax_state_t fax; + int done; + int succeeded; + char tag[50]; + int error_delay; +} machines[FAX_MACHINES]; + +int test_local_interrupt = FALSE; + +static void phase_b_handler(t30_state_t *s, void *user_data, int result) +{ + int i; + + i = (intptr_t) user_data; + printf("%d: Phase B handler on channel %d - (0x%X) %s\n", i, i, result, t30_frametype(result)); +} +/*- End of function --------------------------------------------------------*/ + +static void phase_d_handler(t30_state_t *s, void *user_data, int result) +{ + int i; + t30_stats_t t; + char ident[21]; + + i = (intptr_t) user_data; + printf("%d: Phase D handler on channel %d - (0x%X) %s\n", i, i, result, t30_frametype(result)); + t30_get_transfer_statistics(s, &t); + printf("%d: Phase D: bit rate %d\n", i, t.bit_rate); + printf("%d: Phase D: ECM %s\n", i, (t.error_correcting_mode) ? "on" : "off"); + printf("%d: Phase D: pages transferred %d\n", i, t.pages_transferred); + printf("%d: Phase D: image size %d x %d\n", i, t.width, t.length); + printf("%d: Phase D: image resolution %d x %d\n", i, t.x_resolution, t.y_resolution); + printf("%d: Phase D: bad rows %d\n", i, t.bad_rows); + printf("%d: Phase D: longest bad row run %d\n", i, t.longest_bad_row_run); + printf("%d: Phase D: compression type %d\n", i, t.encoding); + printf("%d: Phase D: image size %d\n", i, t.image_size); + t30_get_local_ident(s, ident); + printf("%d: Phase D: local ident '%s'\n", i, ident); + t30_get_far_ident(s, ident); + printf("%d: Phase D: remote ident '%s'\n", i, ident); + + if (test_local_interrupt) + { + if (i == 0) + { + printf("%d: Initiating interrupt request\n", i); + t30_local_interrupt_request(s, TRUE); + } + else + { + switch (result) + { + case T30_PIP: + case T30_PRI_MPS: + case T30_PRI_EOM: + case T30_PRI_EOP: + printf("%d: Accepting interrupt request\n", i); + t30_local_interrupt_request(s, TRUE); + break; + case T30_PIN: + break; + } + } + } +} +/*- End of function --------------------------------------------------------*/ + +static void phase_e_handler(t30_state_t *s, void *user_data, int result) +{ + int i; + t30_stats_t t; + const char *u; + char ident[21]; + + i = (intptr_t) user_data; + printf("%d: Phase E handler on channel %d - (%d) %s\n", i, i, result, t30_completion_code_to_str(result)); + t30_get_transfer_statistics(s, &t); + printf("%d: Phase E: bit rate %d\n", i, t.bit_rate); + printf("%d: Phase E: ECM %s\n", i, (t.error_correcting_mode) ? "on" : "off"); + printf("%d: Phase E: pages transferred %d\n", i, t.pages_transferred); + printf("%d: Phase E: image size %d x %d\n", i, t.width, t.length); + printf("%d: Phase E: image resolution %d x %d\n", i, t.x_resolution, t.y_resolution); + printf("%d: Phase E: bad rows %d\n", i, t.bad_rows); + printf("%d: Phase E: longest bad row run %d\n", i, t.longest_bad_row_run); + printf("%d: Phase E: coding method %s\n", i, t4_encoding_to_str(t.encoding)); + printf("%d: Phase E: image size %d bytes\n", i, t.image_size); + t30_get_local_ident(s, ident); + printf("%d: Phase E: local ident '%s'\n", i, ident); + t30_get_far_ident(s, ident); + printf("%d: Phase E: remote ident '%s'\n", i, ident); + if ((u = t30_get_far_country(s))) + printf("%d: Phase E: Remote was made in '%s'\n", i, u); + if ((u = t30_get_far_vendor(s))) + printf("%d: Phase E: Remote was made by '%s'\n", i, u); + if ((u = t30_get_far_model(s))) + printf("%d: Phase E: Remote is model '%s'\n", i, u); + machines[i].succeeded = (result == T30_ERR_OK) && (t.pages_transferred == 12); + machines[i].done = TRUE; +} +/*- End of function --------------------------------------------------------*/ + +static int document_handler(t30_state_t *s, void *user_data, int event) +{ + int i; + + i = (intptr_t) user_data; + printf("%d: Document handler on channel %d - event %d\n", i, i, event); + return FALSE; +} +/*- End of function --------------------------------------------------------*/ + +int main(int argc, char *argv[]) +{ + AFfilesetup filesetup; + AFfilehandle wave_handle; + AFfilehandle input_wave_handle; + int i; + int j; + int k; + struct machine_s *mc; + int outframes; + char buf[128 + 1]; + int16_t silence[SAMPLES_PER_CHUNK]; + int16_t out_amp[2*SAMPLES_PER_CHUNK]; + int alldone; + const char *input_tiff_file_name; + const char *input_audio_file_name; + int log_audio; + int use_ecm; + int use_tep; + int use_line_hits; + int polled_mode; + char *page_header_info; + + log_audio = FALSE; + input_tiff_file_name = INPUT_TIFF_FILE_NAME; + input_audio_file_name = NULL; + use_ecm = FALSE; + use_line_hits = FALSE; + use_tep = FALSE; + polled_mode = FALSE; + page_header_info = NULL; + for (i = 1; i < argc; i++) + { + if (strcmp(argv[i], "-e") == 0) + { + use_ecm = TRUE; + continue; + } + if (strcmp(argv[i], "-h") == 0) + { + use_line_hits = TRUE; + continue; + } + if (strcmp(argv[i], "-H") == 0) + { + page_header_info = argv[++i]; + continue; + } + if (strcmp(argv[i], "-i") == 0) + { + input_tiff_file_name = argv[++i]; + continue; + } + if (strcmp(argv[i], "-I") == 0) + { + input_audio_file_name = argv[++i]; + continue; + } + if (strcmp(argv[i], "-l") == 0) + { + log_audio = TRUE; + continue; + } + if (strcmp(argv[i], "-p") == 0) + { + polled_mode = TRUE; + continue; + } + if (strcmp(argv[i], "-t") == 0) + { + use_tep = TRUE; + continue; + } + } + + input_wave_handle = AF_NULL_FILEHANDLE; + if (input_audio_file_name) + { + if ((input_wave_handle = afOpenFile(input_audio_file_name, "r", NULL)) == AF_NULL_FILEHANDLE) + { + fprintf(stderr, " Cannot open wave file '%s'\n", input_audio_file_name); + exit(2); + } + } + + filesetup = AF_NULL_FILESETUP; + wave_handle = AF_NULL_FILEHANDLE; + if (log_audio) + { + if ((filesetup = afNewFileSetup()) == AF_NULL_FILESETUP) + { + fprintf(stderr, " Failed to create file setup\n"); + exit(2); + } + afInitSampleFormat(filesetup, AF_DEFAULT_TRACK, AF_SAMPFMT_TWOSCOMP, 16); + afInitRate(filesetup, AF_DEFAULT_TRACK, (float) SAMPLE_RATE); + afInitFileFormat(filesetup, AF_FILE_WAVE); + afInitChannels(filesetup, AF_DEFAULT_TRACK, 2); + + if ((wave_handle = afOpenFile(OUTPUT_FILE_NAME_WAVE, "w", filesetup)) == AF_NULL_FILEHANDLE) + { + fprintf(stderr, " Cannot create wave file '%s'\n", OUTPUT_FILE_NAME_WAVE); + exit(2); + } + } + + memset(silence, 0, sizeof(silence)); + for (j = 0; j < FAX_MACHINES; j++) + { + machines[j].chan = j; + mc = &machines[j]; + + i = mc->chan + 1; + sprintf(buf, "%d%d%d%d%d%d%d%d", i, i, i, i, i, i, i, i); + fax_init(&mc->fax, (mc->chan & 1) ? FALSE : TRUE); + fax_set_tep_mode(&mc->fax, use_tep); + t30_set_local_ident(&mc->fax.t30_state, buf); + t30_set_header_info(&mc->fax.t30_state, page_header_info); + t30_set_local_nsf(&mc->fax.t30_state, (const uint8_t *) "\x50\x00\x00\x00Spandsp\x00", 12); + t30_set_ecm_capability(&mc->fax.t30_state, use_ecm); + t30_set_supported_image_sizes(&mc->fax.t30_state, T30_SUPPORT_US_LETTER_LENGTH | T30_SUPPORT_US_LEGAL_LENGTH | T30_SUPPORT_UNLIMITED_LENGTH + | T30_SUPPORT_215MM_WIDTH | T30_SUPPORT_255MM_WIDTH | T30_SUPPORT_303MM_WIDTH); + t30_set_supported_resolutions(&mc->fax.t30_state, T30_SUPPORT_STANDARD_RESOLUTION | T30_SUPPORT_FINE_RESOLUTION | T30_SUPPORT_SUPERFINE_RESOLUTION + | T30_SUPPORT_R8_RESOLUTION | T30_SUPPORT_R16_RESOLUTION); + if (use_ecm) + t30_set_supported_compressions(&mc->fax.t30_state, T30_SUPPORT_T4_1D_COMPRESSION | T30_SUPPORT_T4_2D_COMPRESSION | T30_SUPPORT_T6_COMPRESSION); + if ((mc->chan & 1)) + { + if (polled_mode) + { + t30_set_tx_file(&mc->fax.t30_state, input_tiff_file_name, -1, -1); + } + else + { + sprintf(buf, "fax_tests_%d.tif", (mc->chan + 1)/2); + t30_set_rx_file(&mc->fax.t30_state, buf, -1); + } + } + else + { + if (polled_mode) + { + sprintf(buf, "fax_tests_%d.tif", (mc->chan + 1)/2); + t30_set_rx_file(&mc->fax.t30_state, buf, -1); + } + else + { + t30_set_tx_file(&mc->fax.t30_state, input_tiff_file_name, -1, -1); + } + } + t30_set_phase_b_handler(&mc->fax.t30_state, phase_b_handler, (void *) (intptr_t) mc->chan); + t30_set_phase_d_handler(&mc->fax.t30_state, phase_d_handler, (void *) (intptr_t) mc->chan); + t30_set_phase_e_handler(&mc->fax.t30_state, phase_e_handler, (void *) (intptr_t) mc->chan); + t30_set_document_handler(&mc->fax.t30_state, document_handler, (void *) (intptr_t) mc->chan); + sprintf(mc->tag, "FAX-%d", j + 1); + span_log_set_level(&mc->fax.t30_state.logging, SPAN_LOG_SHOW_SEVERITY | SPAN_LOG_SHOW_PROTOCOL | SPAN_LOG_SHOW_TAG | SPAN_LOG_SHOW_SAMPLE_TIME | SPAN_LOG_FLOW); + span_log_set_tag(&mc->fax.t30_state.logging, mc->tag); + span_log_set_level(&mc->fax.v29rx.logging, SPAN_LOG_SHOW_SEVERITY | SPAN_LOG_SHOW_PROTOCOL | SPAN_LOG_SHOW_TAG | SPAN_LOG_SHOW_SAMPLE_TIME | SPAN_LOG_FLOW); + span_log_set_tag(&mc->fax.v29rx.logging, mc->tag); + span_log_set_level(&mc->fax.logging, SPAN_LOG_SHOW_SEVERITY | SPAN_LOG_SHOW_PROTOCOL | SPAN_LOG_SHOW_TAG | SPAN_LOG_SHOW_SAMPLE_TIME | SPAN_LOG_FLOW); + span_log_set_tag(&mc->fax.logging, mc->tag); + memset(mc->amp, 0, sizeof(mc->amp)); + mc->done = FALSE; + } + for (;;) + { + alldone = TRUE; + for (j = 0; j < FAX_MACHINES; j++) + { + mc = &machines[j]; + + if ((j & 1) == 0 && input_audio_file_name) + { + mc->len = afReadFrames(input_wave_handle, AF_DEFAULT_TRACK, mc->amp, SAMPLES_PER_CHUNK); + if (mc->len == 0) + break; + } + else + { + mc->len = fax_tx(&mc->fax, mc->amp, SAMPLES_PER_CHUNK); + } + /* The receive side always expects a full block of samples, but the + transmit side may not be sending any when it doesn't need to. We + may need to pad with some silence. */ + if (mc->len < SAMPLES_PER_CHUNK) + { + memset(mc->amp + mc->len, 0, sizeof(int16_t)*(SAMPLES_PER_CHUNK - mc->len)); + mc->len = SAMPLES_PER_CHUNK; + } + + span_log_bump_samples(&mc->fax.t30_state.logging, mc->len); + span_log_bump_samples(&mc->fax.v29rx.logging, mc->len); + span_log_bump_samples(&mc->fax.logging, mc->len); + + if (log_audio) + { + for (k = 0; k < mc->len; k++) + out_amp[2*k + j] = mc->amp[k]; + } + if (machines[j ^ 1].len < SAMPLES_PER_CHUNK) + memset(machines[j ^ 1].amp + machines[j ^ 1].len, 0, sizeof(int16_t)*(SAMPLES_PER_CHUNK - machines[j ^ 1].len)); + if (use_line_hits) + { + /* TODO: This applied very crude line hits. improve it */ + if (mc->fax.t30_state.state == 22) + { + if (++mc->error_delay == 100) + { + fprintf(stderr, "HIT %d!\n", j); + mc->error_delay = 0; + for (k = 0; k < 5; k++) + mc->amp[k] = 0; + } + } + } + if (fax_rx(&mc->fax, machines[j ^ 1].amp, SAMPLES_PER_CHUNK)) + break; + if (!mc->done) + alldone = FALSE; + } + + if (log_audio) + { + outframes = afWriteFrames(wave_handle, AF_DEFAULT_TRACK, out_amp, SAMPLES_PER_CHUNK); + if (outframes != SAMPLES_PER_CHUNK) + break; + } + + if (alldone || j < FAX_MACHINES) + break; + } + for (j = 0; j < FAX_MACHINES; j++) + { + mc = &machines[j]; + fax_release(&mc->fax); + } + if (log_audio) + { + if (afCloseFile(wave_handle)) + { + fprintf(stderr, " Cannot close wave file '%s'\n", OUTPUT_FILE_NAME_WAVE); + exit(2); + } + afFreeFileSetup(filesetup); + } + if (input_audio_file_name) + { + if (afCloseFile(input_wave_handle)) + { + fprintf(stderr, " Cannot close wave file '%s'\n", input_audio_file_name); + exit(2); + } + afFreeFileSetup(filesetup); + } + return 0; +} +/*- End of function --------------------------------------------------------*/ +/*- End of file ------------------------------------------------------------*/