retronetworking
/
freeswitch
13
0
Fork 0
Code Pull Requests Releases Activity
freeswitch/libs/spandsp/src/t38_gateway.c

2436 lines
93 KiB
C
Raw Blame History

//#define LOG_FAX_AUDIO
/*
* SpanDSP - a series of DSP components for telephony
*
* t38_gateway.c - A T.38 gateway, less the packet exchange part
*
* Written by Steve Underwood <steveu@coppice.org>
*
* Copyright (C) 2005, 2006, 2007, 2008 Steve Underwood
*
* All rights reserved.
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License version 2.1,
* 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 Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this program; if not, write to the Free Software
* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/
/*! \file */
#if defined(HAVE_CONFIG_H)
#include "config.h"
#endif
#include <inttypes.h>
#include <stdlib.h>
#include <stdio.h>
#include <fcntl.h>
#include <time.h>
#include <string.h>
#if defined(HAVE_TGMATH_H)
#include <tgmath.h>
#endif
#if defined(HAVE_MATH_H)
#include <math.h>
#endif
#if defined(HAVE_STDBOOL_H)
#include <stdbool.h>
#else
#include "spandsp/stdbool.h"
#endif
#include "floating_fudge.h"
#include <assert.h>
#if defined(LOG_FAX_AUDIO)
#include <unistd.h>
#endif
#include <tiffio.h>
#include "spandsp/telephony.h"
#include "spandsp/alloc.h"
#include "spandsp/logging.h"
#include "spandsp/queue.h"
#include "spandsp/vector_int.h"
#include "spandsp/dc_restore.h"
#include "spandsp/bit_operations.h"
#include "spandsp/power_meter.h"
#include "spandsp/complex.h"
#include "spandsp/tone_detect.h"
#include "spandsp/tone_generate.h"
#include "spandsp/async.h"
#include "spandsp/crc.h"
#include "spandsp/hdlc.h"
#include "spandsp/silence_gen.h"
#include "spandsp/fsk.h"
#include "spandsp/v29tx.h"
#include "spandsp/v29rx.h"
#include "spandsp/v27ter_tx.h"
#include "spandsp/v27ter_rx.h"
#include "spandsp/v17tx.h"
#include "spandsp/v17rx.h"
#if defined(SPANDSP_SUPPORT_V34)
#include "spandsp/bitstream.h"
#include "spandsp/v34.h"
#endif
#include "spandsp/super_tone_rx.h"
#include "spandsp/modem_connect_tones.h"
#include "spandsp/timezone.h"
#include "spandsp/t4_rx.h"
#include "spandsp/t4_tx.h"
#include "spandsp/image_translate.h"
#include "spandsp/t81_t82_arith_coding.h"
#include "spandsp/t85.h"
#include "spandsp/t42.h"
#include "spandsp/t43.h"
#include "spandsp/t4_t6_decode.h"
#include "spandsp/t4_t6_encode.h"
#include "spandsp/t30_fcf.h"
#include "spandsp/t35.h"
#include "spandsp/t30.h"
#include "spandsp/t30_logging.h"
#include "spandsp/fax_modems.h"
#include "spandsp/t38_core.h"
#include "spandsp/t38_non_ecm_buffer.h"
#include "spandsp/t38_gateway.h"
#include "spandsp/private/logging.h"
#include "spandsp/private/silence_gen.h"
#include "spandsp/private/power_meter.h"
#include "spandsp/private/fsk.h"
#if defined(SPANDSP_SUPPORT_V34)
#include "spandsp/private/bitstream.h"
#include "spandsp/private/v34.h"
#endif
#include "spandsp/private/v17tx.h"
#include "spandsp/private/v17rx.h"
#include "spandsp/private/v27ter_tx.h"
#include "spandsp/private/v27ter_rx.h"
#include "spandsp/private/v29tx.h"
#include "spandsp/private/v29rx.h"
#include "spandsp/private/modem_connect_tones.h"
#include "spandsp/private/hdlc.h"
#include "spandsp/private/fax_modems.h"
#include "spandsp/private/timezone.h"
#include "spandsp/private/t81_t82_arith_coding.h"
#include "spandsp/private/t85.h"
#include "spandsp/private/t42.h"
#include "spandsp/private/t43.h"
#include "spandsp/private/t4_t6_decode.h"
#include "spandsp/private/t4_t6_encode.h"
#include "spandsp/private/image_translate.h"
#include "spandsp/private/t4_rx.h"
#include "spandsp/private/t4_tx.h"
#include "spandsp/private/t30.h"
#include "spandsp/private/t38_core.h"
#include "spandsp/private/t38_non_ecm_buffer.h"
#include "spandsp/private/t38_gateway.h"
/* This is the target time per transmission chunk. The actual
packet timing will sync to the data octets. */
/*! The default number of milliseconds per transmitted IFP when sending bulk T.38 data */
#define DEFAULT_MS_PER_TX_CHUNK 30
/*! The number of bytes which must be in the audio to T.38 HDLC buffer before we start
outputting them as IFP messages. */
#define HDLC_START_BUFFER_LEVEL 8
/*! The number of transmissions of indicator IFP packets */
#define INDICATOR_TX_COUNT 3
/*! The number of transmissions of data IFP packets */
#define DATA_TX_COUNT 1
/*! The number of transmissions of terminating data IFP packets */
#define DATA_END_TX_COUNT 3
/*! The number of consecutive flags to declare HDLC framing is OK. */
#define HDLC_FRAMING_OK_THRESHOLD 5
#define HDLC_TRAMISSION_LAG_OCTETS 2
enum
{
DISBIT1 = 0x01,
DISBIT2 = 0x02,
DISBIT3 = 0x04,
DISBIT4 = 0x08,
DISBIT5 = 0x10,
DISBIT6 = 0x20,
DISBIT7 = 0x40,
DISBIT8 = 0x80
};
enum
{
HDLC_FLAG_FINISHED = 0x01,
HDLC_FLAG_CORRUPT_CRC = 0x02,
HDLC_FLAG_PROCEED_WITH_OUTPUT = 0x04,
HDLC_FLAG_MISSING_DATA = 0x08
};
enum
{
FLAG_INDICATOR = 0x100,
FLAG_DATA = 0x200
};
enum
{
TIMED_MODE_STARTUP = 0,
TIMED_MODE_IDLE,
TIMED_MODE_TCF_PREDICTABLE_MODEM_START_FAST_MODEM_ANNOUNCED,
TIMED_MODE_TCF_PREDICTABLE_MODEM_START_FAST_MODEM_SEEN,
TIMED_MODE_TCF_PREDICTABLE_MODEM_START_PAST_V21_MODEM,
TIMED_MODE_TCF_PREDICTABLE_MODEM_START_BEGIN,
};
static int restart_rx_modem(t38_gateway_state_t *s);
static int process_rx_indicator(t38_core_state_t *t, void *user_data, int indicator);
static void hdlc_underflow_handler(void *user_data);
static void to_t38_buffer_init(t38_gateway_to_t38_state_t *s);
static void t38_hdlc_rx_put_bit(hdlc_rx_state_t *t, int new_bit);
static void non_ecm_put_bit(void *user_data, int bit);
static void non_ecm_remove_fill_and_put_bit(void *user_data, int bit);
static void non_ecm_push_residue(t38_gateway_state_t *s);
static void tone_detected(void *user_data, int tone, int level, int delay);
static void tone_detected(void *user_data, int tone, int level, int delay)
{
t38_gateway_state_t *s;
s = (t38_gateway_state_t *) user_data;
span_log(&s->logging, SPAN_LOG_FLOW, "%s detected (%ddBm0)\n", modem_connect_tone_to_str(tone), level);
}
/*- End of function --------------------------------------------------------*/
static void hdlc_underflow_handler(void *user_data)
{
t38_gateway_state_t *s;
t38_gateway_hdlc_state_t *t;
s = (t38_gateway_state_t *) user_data;
t = &s->core.hdlc_to_modem;
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC underflow at %d\n", t->out);
/* If the current HDLC buffer is not at the HDLC_FLAG_PROCEED_WITH_OUTPUT stage, this
underflow must be an end of preamble condition. */
if ((t->buf[t->out].flags & HDLC_FLAG_PROCEED_WITH_OUTPUT))
{
t->buf[t->out].len = 0;
t->buf[t->out].flags = 0;
t->buf[t->out].contents = 0;
if (++t->out >= T38_TX_HDLC_BUFS)
t->out = 0;
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC next is 0x%X\n", t->buf[t->out].contents);
if ((t->buf[t->out].contents & FLAG_INDICATOR))
{
/* The next thing in the queue is an indicator, so we need to stop this modem. */
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC shutdown\n");
hdlc_tx_frame(&s->audio.modems.hdlc_tx, NULL, 0);
}
else if ((t->buf[t->out].contents & FLAG_DATA))
{
/* Check if we should start sending the next frame */
if ((t->buf[t->out].flags & HDLC_FLAG_PROCEED_WITH_OUTPUT))
{
/* This frame is ready to go, and uses the same modem we are running now. So, send
whatever we have. This might or might not be an entire frame. */
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC start next frame\n");
hdlc_tx_frame(&s->audio.modems.hdlc_tx, t->buf[t->out].buf, t->buf[t->out].len);
if ((t->buf[t->out].flags & HDLC_FLAG_CORRUPT_CRC))
hdlc_tx_corrupt_frame(&s->audio.modems.hdlc_tx);
/*endif*/
}
/*endif*/
}
/*endif*/
}
/*endif*/
}
/*- End of function --------------------------------------------------------*/
static int set_next_tx_type(t38_gateway_state_t *s)
{
int indicator;
fax_modems_state_t *t;
t38_gateway_hdlc_state_t *u;
int short_train;
int use_hdlc;
t = &s->audio.modems;
t38_non_ecm_buffer_report_output_status(&s->core.non_ecm_to_modem, &s->logging);
if (t->next_tx_handler)
{
/* There is a handler queued, so that is the next one. */
fax_modems_set_tx_handler(t, t->next_tx_handler, t->next_tx_user_data);
fax_modems_set_next_tx_handler(t, NULL, NULL);
if (t->tx_handler == (span_tx_handler_t) &silence_gen
||
t->tx_handler == (span_tx_handler_t) &tone_gen)
{
fax_modems_set_rx_active(t, true);
}
else
{
fax_modems_set_rx_active(t, false);
}
/*endif*/
return true;
}
/*endif*/
u = &s->core.hdlc_to_modem;
if (u->in == u->out)
return false;
/*endif*/
if ((u->buf[u->out].contents & FLAG_INDICATOR) == 0)
return false;
/*endif*/
indicator = (u->buf[u->out].contents & 0xFF);
u->buf[u->out].len = 0;
u->buf[u->out].flags = 0;
u->buf[u->out].contents = 0;
if (++u->out >= T38_TX_HDLC_BUFS)
u->out = 0;
/*endif*/
span_log(&s->logging, SPAN_LOG_FLOW, "Changing to %s\n", t38_indicator_to_str(indicator));
if (s->core.image_data_mode && s->core.ecm_mode)
{
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC mode\n");
hdlc_tx_init(&t->hdlc_tx, false, 2, true, hdlc_underflow_handler, s);
fax_modems_set_get_bit(t, (get_bit_func_t) hdlc_tx_get_bit, &t->hdlc_tx);
use_hdlc = true;
}
else
{
span_log(&s->logging, SPAN_LOG_FLOW, "Non-ECM mode\n");
fax_modems_set_get_bit(t, (get_bit_func_t) t38_non_ecm_buffer_get_bit, &s->core.non_ecm_to_modem);
use_hdlc = false;
}
/*endif*/
switch (indicator)
{
case T38_IND_NO_SIGNAL:
t->tx_bit_rate = 0;
/* Impose 75ms minimum on transmitted silence */
//silence_gen_set(&t->silence_gen, ms_to_samples(75));
fax_modems_set_tx_handler(t, (span_tx_handler_t) &silence_gen, &t->silence_gen);
fax_modems_set_next_tx_handler(t, (span_tx_handler_t) NULL, NULL);
fax_modems_set_rx_active(t, true);
break;
case T38_IND_CNG:
t->tx_bit_rate = 0;
fax_modems_start_slow_modem(t, FAX_MODEM_CNG_TONE_TX);
silence_gen_set(&t->silence_gen, 0);
fax_modems_set_next_tx_handler(t, (span_tx_handler_t) &silence_gen, &t->silence_gen);
fax_modems_set_rx_active(t, true);
break;
case T38_IND_CED:
t->tx_bit_rate = 0;
fax_modems_start_slow_modem(t, FAX_MODEM_CED_TONE_TX);
fax_modems_set_next_tx_handler(t, (span_tx_handler_t) NULL, NULL);
fax_modems_set_rx_active(t, true);
break;
case T38_IND_V21_PREAMBLE:
t->tx_bit_rate = 300;
hdlc_tx_init(&t->hdlc_tx, false, 2, true, hdlc_underflow_handler, s);
hdlc_tx_flags(&t->hdlc_tx, 32);
silence_gen_alter(&t->silence_gen, ms_to_samples(75));
u->buf[u->in].len = 0;
fax_modems_start_slow_modem(t, FAX_MODEM_V21_TX);
fax_modems_set_tx_handler(t, (span_tx_handler_t) &silence_gen, &t->silence_gen);
fax_modems_set_next_tx_handler(t, (span_tx_handler_t) &fsk_tx, &t->v21_tx);
fax_modems_set_rx_active(t, true);
break;
case T38_IND_V27TER_2400_TRAINING:
case T38_IND_V27TER_4800_TRAINING:
t->tx_bit_rate = (indicator == T38_IND_V27TER_4800_TRAINING) ? 4800 : 2400;
silence_gen_alter(&t->silence_gen, ms_to_samples(75));
fax_modems_start_fast_modem(t, FAX_MODEM_V27TER_TX, t->tx_bit_rate, s->core.short_train, use_hdlc);
fax_modems_set_tx_handler(t, (span_tx_handler_t) &silence_gen, &t->silence_gen);
fax_modems_set_next_tx_handler(t, (span_tx_handler_t) &v27ter_tx, &t->fast_modems.v27ter_tx);
fax_modems_set_rx_active(t, true);
break;
case T38_IND_V29_7200_TRAINING:
case T38_IND_V29_9600_TRAINING:
t->tx_bit_rate = (indicator == T38_IND_V29_9600_TRAINING) ? 9600 : 7200;
silence_gen_alter(&t->silence_gen, ms_to_samples(75));
fax_modems_start_fast_modem(t, FAX_MODEM_V29_TX, t->tx_bit_rate, s->core.short_train, use_hdlc);
fax_modems_set_tx_handler(t, (span_tx_handler_t) &silence_gen, &t->silence_gen);
fax_modems_set_next_tx_handler(t, (span_tx_handler_t) &v29_tx, &t->fast_modems.v29_tx);
fax_modems_set_rx_active(t, true);
break;
case T38_IND_V17_7200_SHORT_TRAINING:
case T38_IND_V17_7200_LONG_TRAINING:
case T38_IND_V17_9600_SHORT_TRAINING:
case T38_IND_V17_9600_LONG_TRAINING:
case T38_IND_V17_12000_SHORT_TRAINING:
case T38_IND_V17_12000_LONG_TRAINING:
case T38_IND_V17_14400_SHORT_TRAINING:
case T38_IND_V17_14400_LONG_TRAINING:
short_train = false;
switch (indicator)
{
case T38_IND_V17_7200_SHORT_TRAINING:
short_train = true;
t->tx_bit_rate = 7200;
break;
case T38_IND_V17_7200_LONG_TRAINING:
t->tx_bit_rate = 7200;
break;
case T38_IND_V17_9600_SHORT_TRAINING:
short_train = true;
t->tx_bit_rate = 9600;
break;
case T38_IND_V17_9600_LONG_TRAINING:
t->tx_bit_rate = 9600;
break;
case T38_IND_V17_12000_SHORT_TRAINING:
short_train = true;
t->tx_bit_rate = 12000;
break;
case T38_IND_V17_12000_LONG_TRAINING:
t->tx_bit_rate = 12000;
break;
case T38_IND_V17_14400_SHORT_TRAINING:
short_train = true;
t->tx_bit_rate = 14400;
break;
case T38_IND_V17_14400_LONG_TRAINING:
t->tx_bit_rate = 14400;
break;
}
/*endswitch*/
silence_gen_alter(&t->silence_gen, ms_to_samples(75));
fax_modems_start_fast_modem(t, FAX_MODEM_V17_TX, t->tx_bit_rate, short_train, use_hdlc);
fax_modems_set_tx_handler(t, (span_tx_handler_t) &silence_gen, &t->silence_gen);
fax_modems_set_next_tx_handler(t, (span_tx_handler_t) &v17_tx, &t->fast_modems.v17_tx);
fax_modems_set_rx_active(t, true);
break;
case T38_IND_V8_ANSAM:
t->tx_bit_rate = 300;
break;
case T38_IND_V8_SIGNAL:
t->tx_bit_rate = 300;
break;
case T38_IND_V34_CNTL_CHANNEL_1200:
t->tx_bit_rate = 1200;
break;
case T38_IND_V34_PRI_CHANNEL:
t->tx_bit_rate = 33600;
break;
case T38_IND_V34_CC_RETRAIN:
t->tx_bit_rate = 0;
break;
case T38_IND_V33_12000_TRAINING:
t->tx_bit_rate = 12000;
break;
case T38_IND_V33_14400_TRAINING:
t->tx_bit_rate = 14400;
break;
default:
break;
}
/*endswitch*/
/* For any fast modem, set 200ms of preamble flags */
if (t->tx_bit_rate > 300)
hdlc_tx_flags(&t->hdlc_tx, t->tx_bit_rate/(8*5));
/*endif*/
s->t38x.in_progress_rx_indicator = indicator;
return true;
}
/*- End of function --------------------------------------------------------*/
static void finalise_hdlc_frame(t38_gateway_state_t *s, int good_fcs)
{
t38_gateway_hdlc_buf_t *hdlc_buf;
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
if (!good_fcs || (hdlc_buf->flags & HDLC_FLAG_MISSING_DATA))
hdlc_buf->flags |= HDLC_FLAG_CORRUPT_CRC;
/*endif*/
if (s->core.hdlc_to_modem.in == s->core.hdlc_to_modem.out)
{
/* This is the frame in progress at the output. */
if ((hdlc_buf->flags & HDLC_FLAG_PROCEED_WITH_OUTPUT) == 0)
{
/* Output of this frame has not yet begun. Throw it all out now. */
hdlc_tx_frame(&s->audio.modems.hdlc_tx, hdlc_buf->buf, hdlc_buf->len);
}
/*endif*/
if ((hdlc_buf->flags & HDLC_FLAG_CORRUPT_CRC))
hdlc_tx_corrupt_frame(&s->audio.modems.hdlc_tx);
/*endif*/
}
/*endif*/
hdlc_buf->flags |= (HDLC_FLAG_PROCEED_WITH_OUTPUT | HDLC_FLAG_FINISHED);
if (++s->core.hdlc_to_modem.in >= T38_TX_HDLC_BUFS)
s->core.hdlc_to_modem.in = 0;
/*endif*/
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
hdlc_buf->len = 0;
hdlc_buf->flags = 0;
hdlc_buf->contents = 0;
}
/*- End of function --------------------------------------------------------*/
static void edit_control_messages(t38_gateway_state_t *s, bool from_modem, uint8_t *buf, int len)
{
/* Frames need to be fed to this routine byte by byte as they arrive. It basically just
edits the last byte received, based on the frame up to that point. */
if (s->t38x.corrupt_current_frame[(from_modem) ? 1 : 0])
{
/* We simply need to overwrite a section of the message, so it is not recognisable at
the receiver. This is used for the NSF, NSC, and NSS messages. Several strategies are
possible for the replacement data. If you have a manufacturer code of your own, the
sane thing is to overwrite the original data with that. */
if (len <= s->t38x.suppress_nsx_len[(from_modem) ? 1 : 0])
buf[len - 1] = s->t38x.suppress_nsx_string[(from_modem) ? 1 : 0][len - 1 - 3];
/*endif*/
return;
}
/*endif*/
/* Edit the message, if we need to control the communication between the end points. */
switch (len)
{
case 3:
switch (buf[2])
{
case T30_NSF:
case T30_NSC:
case T30_NSS:
if (s->t38x.suppress_nsx_len[(from_modem) ? 1 : 0])
{
/* Corrupt the message, so it will be ignored by the far end. If it were
processed, 2 machines which recognise each other might do special things
we cannot handle as a middle man. */
span_log(&s->logging, SPAN_LOG_FLOW, "Corrupting %s message to prevent recognition\n", t30_frametype(buf[2]));
s->t38x.corrupt_current_frame[(from_modem) ? 1 : 0] = true;
}
/*endif*/
break;
}
/*endswitch*/
break;
case 4:
switch (buf[2])
{
case T30_DIS:
/* Make sure the V.8 capability doesn't pass through. If it
did, two V.34 capable FAX machines might start some
V.8 re-negotiation. */
buf[3] &= ~DISBIT6;
break;
}
/*endswitch*/
break;
case 5:
switch (buf[2])
{
case T30_DIS:
/* We may need to adjust the capabilities, so they do not exceed our own */
span_log(&s->logging, SPAN_LOG_FLOW, "Applying fast modem type constraints.\n");
switch (buf[4] & (DISBIT6 | DISBIT5 | DISBIT4 | DISBIT3))
{
case 0:
case DISBIT4:
/* V.27ter only */
break;
case DISBIT3:
case (DISBIT4 | DISBIT3):
/* V.27ter and V.29 */
if (!(s->core.supported_modems & T30_SUPPORT_V29))
buf[4] &= ~DISBIT3;
/*endif*/
break;
case (DISBIT6 | DISBIT4 | DISBIT3):
/* V.27ter, V.29 and V.17 */
if (!(s->core.supported_modems & T30_SUPPORT_V17))
buf[4] &= ~DISBIT6;
/*endif*/
if (!(s->core.supported_modems & T30_SUPPORT_V29))
buf[4] &= ~DISBIT3;
/*endif*/
break;
case (DISBIT5 | DISBIT4):
case (DISBIT6 | DISBIT4):
case (DISBIT6 | DISBIT5 | DISBIT4):
case (DISBIT6 | DISBIT5 | DISBIT4 | DISBIT3):
/* Reserved */
buf[4] &= ~(DISBIT6 | DISBIT5);
buf[4] |= (DISBIT4 | DISBIT3);
break;
default:
/* Not used */
buf[4] &= ~(DISBIT6 | DISBIT5);
buf[4] |= (DISBIT4 | DISBIT3);
break;
}
/*endswitch*/
break;
}
/*endswitch*/
break;
case 7:
switch (buf[2])
{
case T30_DIS:
if (!s->core.ecm_allowed)
{
/* Do not allow ECM or T.6 coding */
span_log(&s->logging, SPAN_LOG_FLOW, "Inhibiting ECM\n");
buf[6] &= ~(DISBIT3 | DISBIT7);
}
/*endif*/
break;
}
/*endswitch*/
break;
}
/*endswitch*/
}
/*- End of function --------------------------------------------------------*/
static void monitor_control_messages(t38_gateway_state_t *s,
bool from_modem,
const uint8_t *buf,
int len)
{
static const struct
{
int bit_rate;
int modem_type;
uint8_t dcs_code;
} modem_codes[] =
{
{14400, FAX_MODEM_V17_RX, (DISBIT6 )},
{12000, FAX_MODEM_V17_RX, (DISBIT6 | DISBIT4 )},
{ 9600, FAX_MODEM_V17_RX, (DISBIT6 | DISBIT3)},
{ 9600, FAX_MODEM_V29_RX, ( DISBIT3)},
{ 7200, FAX_MODEM_V17_RX, (DISBIT6 | DISBIT4 | DISBIT3)},
{ 7200, FAX_MODEM_V29_RX, ( DISBIT4 | DISBIT3)},
{ 4800, FAX_MODEM_V27TER_RX, ( DISBIT4 )},
{ 2400, FAX_MODEM_V27TER_RX, (0 )},
{ 0, FAX_MODEM_NONE, (0 )}
};
static const int minimum_scan_line_times[8] =
{
20, 5, 10, 0, 40, 0, 0, 0
};
int dcs_code;
int i;
int j;
/* Monitor the control messages, at the point where we have the whole message, so we can
see what is happening to things like training success/failure. */
span_log(&s->logging, SPAN_LOG_FLOW, "Monitoring %s\n", t30_frametype(buf[2]));
if (len < 3)
return;
/*endif*/
s->core.timed_mode = TIMED_MODE_IDLE;
switch (buf[2])
{
case T30_CFR:
/* We are changing from TCF exchange to image exchange */
/* Successful training means we should change to short training */
s->core.image_data_mode = true;
s->core.short_train = true;
span_log(&s->logging, SPAN_LOG_FLOW, "CFR - short train = %d, ECM = %d\n", s->core.short_train, s->core.ecm_mode);
if (!from_modem)
restart_rx_modem(s);
/*endif*/
break;
case T30_RTN:
case T30_RTP:
/* We are going back to the exchange of fresh TCF */
s->core.image_data_mode = false;
s->core.short_train = false;
break;
case T30_CTC:
if (len >= 5)
{
/* The table is short, and not searched often, so a brain-dead linear scan seems OK */
dcs_code = buf[4] & (DISBIT6 | DISBIT5 | DISBIT4 | DISBIT3);
for (i = 0; modem_codes[i].bit_rate; i++)
{
if (modem_codes[i].dcs_code == dcs_code)
break;
/*endif*/
}
/*endfor*/
/* If we are processing a message from the modem side, the contents determine the fast
receive modem we are to use. If it comes from the T.38 side the contents do not. */
s->core.fast_bit_rate = modem_codes[i].bit_rate;
if (from_modem)
s->core.fast_rx_modem = modem_codes[i].modem_type;
/*endif*/
}
/*endif*/
break;
case T30_CTR:
/* T.30 says the first image data after this does full training, yet does not
return to TCF. This seems to be the sole case of long training for image
data. */
s->core.short_train = false;
break;
case T30_DTC:
case T30_DCS:
case T30_DCS | 1:
/* We need to check which modem type is about to be used, so we can start the
correct modem. */
s->core.fast_bit_rate = 0;
s->core.fast_rx_modem = FAX_MODEM_NONE;
s->core.image_data_mode = false;
s->core.short_train = false;
if (from_modem)
s->core.timed_mode = TIMED_MODE_TCF_PREDICTABLE_MODEM_START_BEGIN;
/*endif*/
if (len >= 5)
{
/* The table is short, and not searched often, so a brain-dead linear scan seems OK */
dcs_code = buf[4] & (DISBIT6 | DISBIT5 | DISBIT4 | DISBIT3);
for (i = 0; modem_codes[i].bit_rate; i++)
{
if (modem_codes[i].dcs_code == dcs_code)
break;
/*endif*/
}
/*endfor*/
/* If we are processing a DCS message from the modem side, the contents determine the fast
receive modem we are to use. If it comes from the T.38 side the contents do not. For a
DTC message this is reversed. */
s->core.fast_bit_rate = modem_codes[i].bit_rate;
if ((buf[2] == T30_DTC && !from_modem) || (buf[2] != T30_DTC && from_modem))
s->core.fast_rx_modem = modem_codes[i].modem_type;
/*endif*/
}
/*endif*/
if (len >= 6)
{
j = (buf[5] & (DISBIT7 | DISBIT6 | DISBIT5)) >> 4;
s->core.min_row_bits = (s->core.fast_bit_rate*minimum_scan_line_times[j])/1000;
}
else
{
s->core.min_row_bits = 0;
}
/*endif*/
s->core.ecm_mode = (len >= 7) && (buf[6] & DISBIT3);
span_log(&s->logging, SPAN_LOG_FLOW, "Fast rx modem = %d/%d, ECM = %d, Min bits per row = %d\n", s->core.fast_rx_modem, s->core.fast_bit_rate, s->core.ecm_mode, s->core.min_row_bits);
break;
case T30_PPS:
case T30_PPS | 1:
switch (buf[3] & 0xFE)
{
case T30_EOP:
case T30_PRI_EOP:
case T30_EOM:
case T30_PRI_EOM:
case T30_EOS:
#if 0
/* If we are hitting one of these conditions, it will take another DCS/DTC to select
the fast modem again, so abandon our idea of it. */
s->core.fast_bit_rate = 0;
s->core.fast_rx_modem = FAX_MODEM_NONE;
s->core.image_data_mode = false;
s->core.short_train = false;
#endif
/* Fall through */
case T30_MPS:
case T30_PRI_MPS:
s->core.count_page_on_mcf = true;
break;
}
/*endswitch*/
break;
case T30_EOP:
case T30_EOP | 1:
case T30_PRI_EOP:
case T30_PRI_EOP | 1:
case T30_EOM:
case T30_EOM | 1:
case T30_PRI_EOM:
case T30_PRI_EOM | 1:
case T30_EOS:
case T30_EOS | 1:
#if 0
/* If we are hitting one of these conditions, it will take another DCS/DTC to select
the fast modem again, so abandon our idea of it. */
s->core.fast_bit_rate = 0;
s->core.fast_rx_modem = FAX_MODEM_NONE;
s->core.image_data_mode = false;
s->core.short_train = false;
#endif
/* Fall through */
case T30_MPS:
case T30_MPS | 1:
case T30_PRI_MPS:
case T30_PRI_MPS | 1:
s->core.count_page_on_mcf = true;
break;
case T30_MCF:
case T30_MCF | 1:
if (s->core.count_page_on_mcf)
{
s->core.pages_confirmed++;
span_log(&s->logging, SPAN_LOG_FLOW, "Pages confirmed = %d\n", s->core.pages_confirmed);
s->core.count_page_on_mcf = false;
}
/*endif*/
break;
default:
break;
}
/*endswitch*/
}
/*- End of function --------------------------------------------------------*/
static void queue_missing_indicator(t38_gateway_state_t *s, int data_type)
{
t38_core_state_t *t;
int expected;
int expected_alt;
t = &s->t38x.t38;
expected = -1;
expected_alt = -1;
/* Missing packets might have lost us the indicator that should have put us in
the required mode of operation. It might be a bit late to fill in such a gap
now, but we should try. We may also want to force indicators into the queue,
such as when the data says 'end of signal'. */
/* We have an expectation of whether long or short training should occur, but be
tolerant of either kind of indicator being present. */
switch (data_type)
{
case T38_DATA_NONE:
expected = T38_IND_NO_SIGNAL;
break;
case T38_DATA_V21:
expected = T38_IND_V21_PREAMBLE;
break;
case T38_DATA_V27TER_2400:
expected = T38_IND_V27TER_2400_TRAINING;
break;
case T38_DATA_V27TER_4800:
expected = T38_IND_V27TER_4800_TRAINING;
break;
case T38_DATA_V29_7200:
expected = T38_IND_V29_7200_TRAINING;
break;
case T38_DATA_V29_9600:
expected = T38_IND_V29_9600_TRAINING;
break;
case T38_DATA_V17_7200:
expected = (s->core.short_train) ? T38_IND_V17_7200_SHORT_TRAINING : T38_IND_V17_7200_LONG_TRAINING;
expected_alt = (s->core.short_train) ? T38_IND_V17_7200_LONG_TRAINING : T38_IND_V17_7200_SHORT_TRAINING;
break;
case T38_DATA_V17_9600:
expected = (s->core.short_train) ? T38_IND_V17_9600_SHORT_TRAINING : T38_IND_V17_9600_LONG_TRAINING;
expected_alt = (s->core.short_train) ? T38_IND_V17_9600_LONG_TRAINING : T38_IND_V17_9600_SHORT_TRAINING;
break;
case T38_DATA_V17_12000:
expected = (s->core.short_train) ? T38_IND_V17_12000_SHORT_TRAINING : T38_IND_V17_12000_LONG_TRAINING;
expected_alt = (s->core.short_train) ? T38_IND_V17_12000_LONG_TRAINING : T38_IND_V17_12000_SHORT_TRAINING;
break;
case T38_DATA_V17_14400:
expected = (s->core.short_train) ? T38_IND_V17_14400_SHORT_TRAINING : T38_IND_V17_14400_LONG_TRAINING;
expected_alt = (s->core.short_train) ? T38_IND_V17_14400_LONG_TRAINING : T38_IND_V17_14400_SHORT_TRAINING;
break;
case T38_DATA_V8:
break;
case T38_DATA_V34_PRI_RATE:
break;
case T38_DATA_V34_CC_1200:
break;
case T38_DATA_V34_PRI_CH:
break;
case T38_DATA_V33_12000:
break;
case T38_DATA_V33_14400:
break;
}
/*endswitch*/
if (expected < 0)
return;
/*endif*/
if (t->current_rx_indicator == expected)
return;
/*endif*/
if (expected_alt >= 0 && t->current_rx_indicator == expected_alt)
return;
/*endif*/
span_log(&s->logging,
SPAN_LOG_FLOW,
"Queuing missing indicator - %s\n",
t38_indicator_to_str(expected));
process_rx_indicator(t, (void *) s, expected);
/* Force the indicator setting here, as the core won't set in when its missing. */
t->current_rx_indicator = expected;
}
/*- End of function --------------------------------------------------------*/
static int process_rx_missing(t38_core_state_t *t, void *user_data, int rx_seq_no, int expected_seq_no)
{
t38_gateway_state_t *s;
s = (t38_gateway_state_t *) user_data;
s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in].flags |= HDLC_FLAG_MISSING_DATA;
return 0;
}
/*- End of function --------------------------------------------------------*/
static int process_rx_indicator(t38_core_state_t *t, void *user_data, int indicator)
{
t38_gateway_state_t *s;
t38_gateway_hdlc_state_t *u;
int immediate;
s = (t38_gateway_state_t *) user_data;
t38_non_ecm_buffer_report_input_status(&s->core.non_ecm_to_modem, &s->logging);
if (t->current_rx_indicator == indicator)
{
/* This is probably due to the far end repeating itself. Ignore it. Its harmless */
return 0;
}
/*endif*/
u = &s->core.hdlc_to_modem;
immediate = (u->in == u->out);
if (u->buf[u->in].contents)
{
if (++u->in >= T38_TX_HDLC_BUFS)
u->in = 0;
/*endif*/
}
/*endif*/
u->buf[u->in].contents = (indicator | FLAG_INDICATOR);
if (++u->in >= T38_TX_HDLC_BUFS)
u->in = 0;
/*endif*/
if (immediate)
{
span_log(&s->logging,
SPAN_LOG_FLOW,
"Changing - (%d) %s -> %s\n",
silence_gen_remainder(&s->audio.modems.silence_gen),
t38_indicator_to_str(t->current_rx_indicator),
t38_indicator_to_str(indicator));
switch (s->t38x.current_rx_field_class)
{
case T38_FIELD_CLASS_NONE:
break;
case T38_FIELD_CLASS_HDLC:
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC shutdown\n");
hdlc_tx_frame(&s->audio.modems.hdlc_tx, NULL, 0);
break;
case T38_FIELD_CLASS_NON_ECM:
break;
}
}
else
{
span_log(&s->logging,
SPAN_LOG_FLOW,
"Queued change - (%d) %s -> %s\n",
silence_gen_remainder(&s->audio.modems.silence_gen),
t38_indicator_to_str(t->current_rx_indicator),
t38_indicator_to_str(indicator));
}
s->t38x.current_rx_field_class = T38_FIELD_CLASS_NONE;
/* We need to set this here, since we might have been called as a fake
indication when the real one was missing */
t->current_rx_indicator = indicator;
return 0;
}
/*- End of function --------------------------------------------------------*/
static void process_hdlc_data(t38_gateway_state_t *s, int data_type, const uint8_t *buf, int len)
{
t38_gateway_hdlc_buf_t *hdlc_buf;
int i;
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
/* Check if this data would overflow the buffer. */
if (hdlc_buf->len + len > T38_MAX_HDLC_LEN)
{
s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in].flags |= HDLC_FLAG_MISSING_DATA;
return;
}
/*endif*/
hdlc_buf->contents = (data_type | FLAG_DATA);
bit_reverse(&hdlc_buf->buf[hdlc_buf->len], buf, len);
/* We need to send out the control messages as they are arriving. They are
too slow to capture a whole frame before starting to pass it on.
For the faster frames, take in the whole frame before sending it out. Also, there
is no need to monitor, or modify, the contents of the faster frames. */
if (data_type == T38_DATA_V21)
{
for (i = 1; i <= len; i++)
edit_control_messages(s, 0, hdlc_buf->buf, hdlc_buf->len + i);
/*endfor*/
/* Don't start pumping data into the actual output stream until there is
enough backlog to create some elasticity for jitter tolerance. */
if (hdlc_buf->len + len >= HDLC_START_BUFFER_LEVEL)
{
if (s->core.hdlc_to_modem.in == s->core.hdlc_to_modem.out)
{
/* Output is not running, so kick it into life. */
if ((hdlc_buf->flags & HDLC_FLAG_PROCEED_WITH_OUTPUT) == 0)
hdlc_tx_frame(&s->audio.modems.hdlc_tx, hdlc_buf->buf, hdlc_buf->len + len);
else
hdlc_tx_frame(&s->audio.modems.hdlc_tx, hdlc_buf->buf + hdlc_buf->len, len);
/*endif*/
}
/*endif*/
hdlc_buf->flags |= HDLC_FLAG_PROCEED_WITH_OUTPUT;
}
/*endif*/
}
/*endif*/
hdlc_buf->len += len;
}
/*- End of function --------------------------------------------------------*/
static int process_rx_data(t38_core_state_t *t, void *user_data, int data_type, int field_type, const uint8_t *buf, int len)
{
t38_gateway_state_t *s;
t38_gateway_t38_state_t *xx;
t38_gateway_hdlc_buf_t *hdlc_buf;
s = (t38_gateway_state_t *) user_data;
xx = &s->t38x;
/* There are a couple of special cases of data type that need their own treatment. */
switch (data_type)
{
case T38_DATA_V8:
switch (field_type)
{
case T38_FIELD_CM_MESSAGE:
if (len >= 1)
span_log(&s->logging, SPAN_LOG_FLOW, "CM profile %d - %s\n", buf[0] - '0', t38_cm_profile_to_str(buf[0]));
else
span_log(&s->logging, SPAN_LOG_FLOW, "Bad length for CM message - %d\n", len);
/*endif*/
break;
case T38_FIELD_JM_MESSAGE:
if (len >= 2)
span_log(&s->logging, SPAN_LOG_FLOW, "JM - %s\n", t38_jm_to_str(buf, len));
else
span_log(&s->logging, SPAN_LOG_FLOW, "Bad length for JM message - %d\n", len);
/*endif*/
break;
case T38_FIELD_CI_MESSAGE:
if (len >= 1)
span_log(&s->logging, SPAN_LOG_FLOW, "CI 0x%X\n", buf[0]);
else
span_log(&s->logging, SPAN_LOG_FLOW, "Bad length for CI message - %d\n", len);
/*endif*/
break;
default:
break;
}
/*endswitch*/
return 0;
case T38_DATA_V34_PRI_RATE:
switch (field_type)
{
case T38_FIELD_V34RATE:
if (len >= 3)
{
xx->t38.v34_rate = t38_v34rate_to_bps(buf, len);
span_log(&s->logging, SPAN_LOG_FLOW, "V.34 rate %d bps\n", xx->t38.v34_rate);
}
else
{
span_log(&s->logging, SPAN_LOG_FLOW, "Bad length for V34rate message - %d\n", len);
}
/*endif*/
break;
default:
break;
}
/*endswitch*/
return 0;
default:
break;
}
/*endswitch*/
switch (field_type)
{
case T38_FIELD_HDLC_DATA:
xx->current_rx_field_class = T38_FIELD_CLASS_HDLC;
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
if (hdlc_buf->contents != (data_type | FLAG_DATA))
{
queue_missing_indicator(s, data_type);
/* All real HDLC messages in the FAX world start with 0xFF. If this one is not starting
with 0xFF it would appear some octets must have been missed before this one. */
if (len <= 0 || buf[0] != 0xFF)
s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in].flags |= HDLC_FLAG_MISSING_DATA;
/*endif*/
}
/*endif*/
if (len > 0)
process_hdlc_data(s, data_type, buf, len);
/*endif*/
break;
case T38_FIELD_HDLC_FCS_OK:
xx->current_rx_field_class = T38_FIELD_CLASS_HDLC;
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
if (len > 0)
{
span_log(&s->logging, SPAN_LOG_WARNING, "There is data in a T38_FIELD_HDLC_FCS_OK!\n");
/* The sender has incorrectly included data in this message. Cisco implemented inserting
HDLC data here and Commetrex followed for compatibility reasons. We should, too. */
process_hdlc_data(s, data_type, buf, len);
}
/*endif*/
/* Some T.38 implementations send multiple T38_FIELD_HDLC_FCS_OK messages, in IFP packets with
incrementing sequence numbers, which are actually repeats. They get through to this point because
of the incrementing sequence numbers. We need to filter them here in a context sensitive manner. */
if (hdlc_buf->len > 0)
{
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC frame type %s - CRC OK\n", t30_frametype(hdlc_buf->buf[2]));
if (hdlc_buf->contents != (data_type | FLAG_DATA))
{
queue_missing_indicator(s, data_type);
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
}
/*endif*/
if (data_type == T38_DATA_V21)
{
if ((hdlc_buf->flags & HDLC_FLAG_MISSING_DATA) == 0)
{
monitor_control_messages(s, false, hdlc_buf->buf, hdlc_buf->len);
if (s->core.real_time_frame_handler)
s->core.real_time_frame_handler(s->core.real_time_frame_user_data, false, hdlc_buf->buf, hdlc_buf->len);
/*endif*/
}
/*endif*/
}
else
{
/* Make sure we go back to short training if CTC/CTR has kicked us into
long training. There has to be more than one value HDLC frame in a
chunk of image data, so just setting short training mode here should
be enough. */
s->core.short_train = true;
}
/*endif*/
hdlc_buf->contents = (data_type | FLAG_DATA);
finalise_hdlc_frame(s, true);
}
else
{
/* Just restart using the current frame buffer */
hdlc_buf->contents = 0;
}
/*endif*/
xx->corrupt_current_frame[0] = false;
break;
case T38_FIELD_HDLC_FCS_BAD:
xx->current_rx_field_class = T38_FIELD_CLASS_HDLC;
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
if (len > 0)
{
span_log(&s->logging, SPAN_LOG_WARNING, "There is data in a T38_FIELD_HDLC_FCS_BAD!\n");
/* The sender has incorrectly included data in this message. Cisco implemented inserting
HDLC data here and Commetrex followed for compatibility reasons. We should, too. */
process_hdlc_data(s, data_type, buf, len);
}
/*endif*/
/* Some T.38 implementations send multiple T38_FIELD_HDLC_FCS_BAD messages, in IFP packets with
incrementing sequence numbers, which are actually repeats. They get through to this point because
of the incrementing sequence numbers. We need to filter them here in a context sensitive manner. */
if (hdlc_buf->len > 0)
{
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC frame type %s - CRC bad\n", t30_frametype(hdlc_buf->buf[2]));
if (hdlc_buf->contents != (data_type | FLAG_DATA))
{
queue_missing_indicator(s, data_type);
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
}
/*endif*/
hdlc_buf->contents = (data_type | FLAG_DATA);
finalise_hdlc_frame(s, false);
}
else
{
/* Just restart using the current frame buffer */
hdlc_buf->contents = 0;
}
/*endif*/
xx->corrupt_current_frame[0] = false;
break;
case T38_FIELD_HDLC_FCS_OK_SIG_END:
xx->current_rx_field_class = T38_FIELD_CLASS_HDLC;
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
if (len > 0)
{
span_log(&s->logging, SPAN_LOG_WARNING, "There is data in a T38_FIELD_HDLC_FCS_OK_SIG_END!\n");
/* The sender has incorrectly included data in this message. Cisco implemented inserting
HDLC data here and Commetrex followed for compatibility reasons. We should, too. */
process_hdlc_data(s, data_type, buf, len);
}
/*endif*/
/* Some T.38 implementations send multiple T38_FIELD_HDLC_FCS_OK_SIG_END messages, in IFP packets with
incrementing sequence numbers, which are actually repeats. They get through to this point because
of the incrementing sequence numbers. We need to filter them here in a context sensitive manner. */
if (hdlc_buf->len > 0)
{
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC frame type %s - CRC OK, sig end\n", t30_frametype(hdlc_buf->buf[2]));
if (hdlc_buf->contents != (data_type | FLAG_DATA))
{
queue_missing_indicator(s, data_type);
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
}
/*endif*/
if (data_type == T38_DATA_V21)
{
if ((hdlc_buf->flags & HDLC_FLAG_MISSING_DATA) == 0)
{
monitor_control_messages(s, false, hdlc_buf->buf, hdlc_buf->len);
if (s->core.real_time_frame_handler)
s->core.real_time_frame_handler(s->core.real_time_frame_user_data, false, hdlc_buf->buf, hdlc_buf->len);
/*endif*/
}
/*endif*/
}
else
{
/* Make sure we go back to short training if CTC/CTR has kicked us into
long training. There has to be more than one value HDLC frame in a
chunk of image data, so just setting short training mode here should
be enough. */
s->core.short_train = true;
}
/*endif*/
hdlc_buf->contents = (data_type | FLAG_DATA);
finalise_hdlc_frame(s, true);
}
else
{
/* Just restart using the current frame buffer */
hdlc_buf->contents = 0;
}
/*endif*/
if (t->current_rx_data_type != data_type || t->current_rx_field_type != field_type)
{
queue_missing_indicator(s, T38_DATA_NONE);
xx->current_rx_field_class = T38_FIELD_CLASS_NONE;
}
/*endif*/
xx->corrupt_current_frame[0] = false;
break;
case T38_FIELD_HDLC_FCS_BAD_SIG_END:
xx->current_rx_field_class = T38_FIELD_CLASS_HDLC;
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
if (len > 0)
{
span_log(&s->logging, SPAN_LOG_WARNING, "There is data in a T38_FIELD_HDLC_FCS_BAD_SIG_END!\n");
/* The sender has incorrectly included data in this message. Cisco implemented inserting
HDLC data here and Commetrex followed for compatibility reasons. We should, too. */
process_hdlc_data(s, data_type, buf, len);
}
/*endif*/
/* Some T.38 implementations send multiple T38_FIELD_HDLC_FCS_BAD_SIG_END messages, in IFP packets with
incrementing sequence numbers, which are actually repeats. They get through to this point because
of the incrementing sequence numbers. We need to filter them here in a context sensitive manner. */
if (hdlc_buf->len > 0)
{
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC frame type %s - CRC bad, sig end\n", t30_frametype(hdlc_buf->buf[2]));
if (hdlc_buf->contents != (data_type | FLAG_DATA))
{
queue_missing_indicator(s, data_type);
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
}
/*endif*/
hdlc_buf->contents = (data_type | FLAG_DATA);
finalise_hdlc_frame(s, false);
}
else
{
/* Just restart using the current frame buffer */
hdlc_buf->contents = 0;
}
/*endif*/
if (t->current_rx_data_type != data_type || t->current_rx_field_type != field_type)
{
queue_missing_indicator(s, T38_DATA_NONE);
xx->current_rx_field_class = T38_FIELD_CLASS_NONE;
}
/*endif*/
xx->corrupt_current_frame[0] = false;
break;
case T38_FIELD_HDLC_SIG_END:
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
if (len > 0)
{
span_log(&s->logging, SPAN_LOG_WARNING, "There is data in a T38_FIELD_HDLC_SIG_END!\n");
/* The sender has incorrectly included data in this message, but there seems nothing meaningful
it could be. There could not be an FCS good/bad report beyond this. */
}
/*endif*/
/* Some T.38 implementations send multiple T38_FIELD_HDLC_SIG_END messages, in IFP packets with
incrementing sequence numbers, which are actually repeats. They get through to this point because
of the incrementing sequence numbers. We need to filter them here in a context sensitive manner. */
if (t->current_rx_data_type != data_type || t->current_rx_field_type != field_type)
{
if (hdlc_buf->contents != (data_type | FLAG_DATA))
{
queue_missing_indicator(s, data_type);
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
}
/*endif*/
/* WORKAROUND: At least some Mediatrix boxes have a bug, where they can send this message at the
end of non-ECM data. We need to tolerate this. */
if (xx->current_rx_field_class == T38_FIELD_CLASS_NON_ECM)
{
span_log(&s->logging, SPAN_LOG_WARNING, "T38_FIELD_HDLC_SIG_END received at the end of non-ECM data!\n");
/* Don't flow control the data any more. Just pump out the remainder as fast as we can. */
t38_non_ecm_buffer_push(&s->core.non_ecm_to_modem);
}
else
{
/* This message is expected under 2 circumstances. One is as an alternative to T38_FIELD_HDLC_FCS_OK_SIG_END -
i.e. they send T38_FIELD_HDLC_FCS_OK, and then T38_FIELD_HDLC_SIG_END when the carrier actually drops.
The other is because the HDLC signal drops unexpectedly - i.e. not just after a final frame. In
this case we just clear out any partial frame data that might be in the buffer. */
/* TODO: what if any junk in the buffer has reached the HDLC_FLAG_PROCEED_WITH_OUTPUT stage? */
hdlc_buf->len = 0;
hdlc_buf->flags = 0;
hdlc_buf->contents = 0;
}
/*endif*/
queue_missing_indicator(s, T38_DATA_NONE);
xx->current_rx_field_class = T38_FIELD_CLASS_NONE;
}
/*endif*/
xx->corrupt_current_frame[0] = false;
break;
case T38_FIELD_T4_NON_ECM_DATA:
if (xx->current_rx_field_class == T38_FIELD_CLASS_NONE)
t38_non_ecm_buffer_set_mode(&s->core.non_ecm_to_modem, s->core.image_data_mode, s->core.min_row_bits);
xx->current_rx_field_class = T38_FIELD_CLASS_NON_ECM;
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
if (hdlc_buf->contents != (data_type | FLAG_DATA))
queue_missing_indicator(s, data_type);
/*endif*/
if (len > 0)
t38_non_ecm_buffer_inject(&s->core.non_ecm_to_modem, buf, len);
/*endif*/
xx->corrupt_current_frame[0] = false;
break;
case T38_FIELD_T4_NON_ECM_SIG_END:
if (xx->current_rx_field_class == T38_FIELD_CLASS_NONE)
t38_non_ecm_buffer_set_mode(&s->core.non_ecm_to_modem, s->core.image_data_mode, s->core.min_row_bits);
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
/* Some T.38 implementations send multiple T38_FIELD_T4_NON_ECM_SIG_END messages, in IFP packets with
incrementing sequence numbers, which are actually repeats. They get through to this point because
of the incrementing sequence numbers. We need to filter them here in a context sensitive manner. */
if (t->current_rx_data_type != data_type || t->current_rx_field_type != field_type)
{
/* WORKAROUND: At least some Mediatrix boxes have a bug, where they can send HDLC signal end where
they should send non-ECM signal end. It is possible they also do the opposite.
We need to tolerate this. */
if (xx->current_rx_field_class == T38_FIELD_CLASS_NON_ECM)
{
if (len > 0)
{
if (hdlc_buf->contents != (data_type | FLAG_DATA))
{
queue_missing_indicator(s, data_type);
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
}
/*endif*/
t38_non_ecm_buffer_inject(&s->core.non_ecm_to_modem, buf, len);
}
/*endif*/
if (hdlc_buf->contents != (data_type | FLAG_DATA))
queue_missing_indicator(s, data_type);
/*endif*/
/* Don't flow control the data any more. Just pump out the remainder as fast as we can. */
t38_non_ecm_buffer_push(&s->core.non_ecm_to_modem);
}
else
{
span_log(&s->logging, SPAN_LOG_WARNING, "T38_FIELD_NON_ECM_SIG_END received at the end of HDLC data!\n");
if (s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in].contents != (data_type | FLAG_DATA))
{
queue_missing_indicator(s, data_type);
hdlc_buf = &s->core.hdlc_to_modem.buf[s->core.hdlc_to_modem.in];
}
/*endif*/
/* TODO: what if any junk in the buffer has reached the HDLC_FLAG_PROCEED_WITH_OUTPUT stage? */
hdlc_buf->len = 0;
hdlc_buf->flags = 0;
hdlc_buf->contents = 0;
}
/*endif*/
queue_missing_indicator(s, T38_DATA_NONE);
xx->current_rx_field_class = T38_FIELD_CLASS_NONE;
}
/*endif*/
xx->corrupt_current_frame[0] = false;
break;
default:
break;
}
/*endswitch*/
#if 0
if (span_log_test(&s->logging, SPAN_LOG_FLOW))
{
int i;
if (len > 0)
{
span_log(&s->logging, SPAN_LOG_FLOW, "Data: ");
for (i = 0; i < len; i++)
span_log(&s->logging, SPAN_LOG_FLOW | SPAN_LOG_SUPPRESS_LABELLING, " %02X", buf[i]);
/*endfor*/
}
/*endif*/
}
/*endif*/
span_log(&s->logging, SPAN_LOG_FLOW | SPAN_LOG_SUPPRESS_LABELLING, "\n");
#endif
return 0;
}
/*- End of function --------------------------------------------------------*/
static void set_octets_per_data_packet(t38_gateway_state_t *s, int bit_rate)
{
int octets;
octets = s->core.ms_per_tx_chunk*bit_rate/(8*1000);
if (octets < 1)
octets = 1;
/*endif*/
s->core.to_t38.octets_per_data_packet = octets;
}
/*- End of function --------------------------------------------------------*/
static int set_slow_packetisation(t38_gateway_state_t *s)
{
set_octets_per_data_packet(s, 300);
s->t38x.current_tx_data_type = T38_DATA_V21;
return T38_IND_V21_PREAMBLE;
}
/*- End of function --------------------------------------------------------*/
static int set_fast_packetisation(t38_gateway_state_t *s)
{
int ind;
ind = T38_IND_NO_SIGNAL;
switch (s->core.fast_rx_active)
{
case FAX_MODEM_V17_RX:
set_octets_per_data_packet(s, s->core.fast_bit_rate);
switch (s->core.fast_bit_rate)
{
case 7200:
ind = (s->core.short_train) ? T38_IND_V17_7200_SHORT_TRAINING : T38_IND_V17_7200_LONG_TRAINING;
s->t38x.current_tx_data_type = T38_DATA_V17_7200;
break;
case 9600:
ind = (s->core.short_train) ? T38_IND_V17_9600_SHORT_TRAINING : T38_IND_V17_9600_LONG_TRAINING;
s->t38x.current_tx_data_type = T38_DATA_V17_9600;
break;
case 12000:
ind = (s->core.short_train) ? T38_IND_V17_12000_SHORT_TRAINING : T38_IND_V17_12000_LONG_TRAINING;
s->t38x.current_tx_data_type = T38_DATA_V17_12000;
break;
default:
case 14400:
ind = (s->core.short_train) ? T38_IND_V17_14400_SHORT_TRAINING : T38_IND_V17_14400_LONG_TRAINING;
s->t38x.current_tx_data_type = T38_DATA_V17_14400;
break;
}
/*endswitch*/
break;
case FAX_MODEM_V27TER_RX:
set_octets_per_data_packet(s, s->core.fast_bit_rate);
switch (s->core.fast_bit_rate)
{
case 2400:
ind = T38_IND_V27TER_2400_TRAINING;
s->t38x.current_tx_data_type = T38_DATA_V27TER_2400;
break;
default:
case 4800:
ind = T38_IND_V27TER_4800_TRAINING;
s->t38x.current_tx_data_type = T38_DATA_V27TER_4800;
break;
}
/*endswitch*/
break;
case FAX_MODEM_V29_RX:
set_octets_per_data_packet(s, s->core.fast_bit_rate);
switch (s->core.fast_bit_rate)
{
case 7200:
ind = T38_IND_V29_7200_TRAINING;
s->t38x.current_tx_data_type = T38_DATA_V29_7200;
break;
default:
case 9600:
ind = T38_IND_V29_9600_TRAINING;
s->t38x.current_tx_data_type = T38_DATA_V29_9600;
break;
}
/*endswitch*/
break;
}
/*endswitch*/
return ind;
}
/*- End of function --------------------------------------------------------*/
static void announce_training(t38_gateway_state_t *s)
{
t38_core_send_indicator(&s->t38x.t38, set_fast_packetisation(s));
}
/*- End of function --------------------------------------------------------*/
static void non_ecm_rx_status(void *user_data, int status)
{
t38_gateway_state_t *s;
s = (t38_gateway_state_t *) user_data;
span_log(&s->logging, SPAN_LOG_FLOW, "Non-ECM signal status is %s (%d)\n", signal_status_to_str(status), status);
switch (status)
{
case SIG_STATUS_TRAINING_IN_PROGRESS:
if (s->core.timed_mode == TIMED_MODE_IDLE)
{
announce_training(s);
}
else
{
if (s->core.timed_mode == TIMED_MODE_TCF_PREDICTABLE_MODEM_START_PAST_V21_MODEM)
s->core.timed_mode = TIMED_MODE_TCF_PREDICTABLE_MODEM_START_FAST_MODEM_SEEN;
else
s->core.samples_to_timeout = ms_to_samples(500);
/*endif*/
set_fast_packetisation(s);
}
/*endif*/
break;
case SIG_STATUS_TRAINING_FAILED:
break;
case SIG_STATUS_TRAINING_SUCCEEDED:
/* The modem is now trained */
s->audio.modems.rx_signal_present = true;
s->audio.modems.rx_trained = true;
s->core.timed_mode = TIMED_MODE_IDLE;
s->core.samples_to_timeout = 0;
s->core.short_train = true;
to_t38_buffer_init(&s->core.to_t38);
break;
case SIG_STATUS_CARRIER_UP:
break;
case SIG_STATUS_CARRIER_DOWN:
switch (s->t38x.current_tx_data_type)
{
case T38_DATA_V17_7200:
case T38_DATA_V17_9600:
case T38_DATA_V17_12000:
case T38_DATA_V17_14400:
case T38_DATA_V27TER_2400:
case T38_DATA_V27TER_4800:
case T38_DATA_V29_7200:
case T38_DATA_V29_9600:
if (s->core.timed_mode != TIMED_MODE_TCF_PREDICTABLE_MODEM_START_FAST_MODEM_ANNOUNCED)
{
/* TODO: If the carrier really did fall for good during the 500ms TEP blocking timeout, we
won't declare the no-signal condition. */
non_ecm_push_residue(s);
t38_core_send_indicator(&s->t38x.t38, T38_IND_NO_SIGNAL);
}
/*endif*/
restart_rx_modem(s);
break;
}
/*endswitch*/
break;
default:
span_log(&s->logging, SPAN_LOG_WARNING, "Unexpected non-ECM special bit - %d!\n", status);
break;
}
/*endswitch*/
}
/*- End of function --------------------------------------------------------*/
static void to_t38_buffer_init(t38_gateway_to_t38_state_t *s)
{
s->data_ptr = 0;
s->bit_stream = 0xFFFF;
s->bit_no = 0;
s->in_bits = 0;
s->out_octets = 0;
}
/*- End of function --------------------------------------------------------*/
static void non_ecm_push_residue(t38_gateway_state_t *t)
{
t38_gateway_to_t38_state_t *s;
s = &t->core.to_t38;
if (s->bit_no)
{
/* There is a fractional octet in progress. We might as well send every last bit we can. */
s->data[s->data_ptr++] = (uint8_t) (s->bit_stream << (8 - s->bit_no));
}
/*endif*/
if (t38_core_send_data(&t->t38x.t38, t->t38x.current_tx_data_type, T38_FIELD_T4_NON_ECM_SIG_END, s->data, s->data_ptr, T38_PACKET_CATEGORY_IMAGE_DATA_END) < 0)
span_log(&t->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
s->in_bits += s->bits_absorbed;
s->out_octets += s->data_ptr;
s->data_ptr = 0;
}
/*- End of function --------------------------------------------------------*/
static void non_ecm_push(t38_gateway_state_t *t)
{
t38_gateway_to_t38_state_t *s;
s = &t->core.to_t38;
if (s->data_ptr)
{
if (t38_core_send_data(&t->t38x.t38, t->t38x.current_tx_data_type, T38_FIELD_T4_NON_ECM_DATA, s->data, s->data_ptr, T38_PACKET_CATEGORY_IMAGE_DATA) < 0)
span_log(&t->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
s->in_bits += s->bits_absorbed;
s->out_octets += s->data_ptr;
s->bits_absorbed = 0;
s->data_ptr = 0;
}
/*endif*/
}
/*- End of function --------------------------------------------------------*/
static void non_ecm_put_bit(void *user_data, int bit)
{
t38_gateway_state_t *t;
t38_gateway_to_t38_state_t *s;
if (bit < 0)
{
non_ecm_rx_status(user_data, bit);
return;
}
/*endif*/
t = (t38_gateway_state_t *) user_data;
s = &t->core.to_t38;
s->in_bits++;
bit &= 1;
s->bit_stream = (s->bit_stream << 1) | bit;
if (++s->bit_no >= 8)
{
s->data[s->data_ptr++] = (uint8_t) s->bit_stream & 0xFF;
if (s->data_ptr >= s->octets_per_data_packet)
non_ecm_push(t);
/*endif*/
s->bit_no = 0;
}
/*endif*/
}
/*- End of function --------------------------------------------------------*/
static void non_ecm_remove_fill_and_put_bit(void *user_data, int bit)
{
t38_gateway_state_t *t;
t38_gateway_to_t38_state_t *s;
if (bit < 0)
{
non_ecm_rx_status(user_data, bit);
return;
}
/*endif*/
t = (t38_gateway_state_t *) user_data;
s = &t->core.to_t38;
s->bits_absorbed++;
bit &= 1;
/* Drop any extra zero bits when we already have enough for an EOL symbol. */
/* The snag here is that if we just look for 11 bits, a line ending with
a code that has trailing zero bits will cause problems. The longest run of
trailing zeros for any code is 3, so we need to look for at least 14 zeros
if we don't want to actually analyse the compressed data in depth. This means
we do not strip every fill bit, but we strip most of them. */
if ((s->bit_stream & 0x3FFF) == 0 && bit == 0)
{
if (s->bits_absorbed > 2*8*s->octets_per_data_packet)
{
/* We need to pump out what we have, even though we have not accumulated a full
buffer of data. If we don't, we stand to delay rows excessively, so the far
end gateway (assuming the far end is a gateway) cannot play them out. */
non_ecm_push(t);
}
/*endif*/
return;
}
/*endif*/
s->bit_stream = (s->bit_stream << 1) | bit;
if (++s->bit_no >= 8)
{
s->data[s->data_ptr++] = (uint8_t) s->bit_stream & 0xFF;
if (s->data_ptr >= s->octets_per_data_packet)
non_ecm_push(t);
/*endif*/
s->bit_no = 0;
}
/*endif*/
}
/*- End of function --------------------------------------------------------*/
static void hdlc_rx_status(hdlc_rx_state_t *t, int status)
{
t38_gateway_state_t *s;
int category;
s = (t38_gateway_state_t *) t->frame_user_data;
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC signal status is %s (%d)\n", signal_status_to_str(status), status);
switch (status)
{
case SIG_STATUS_TRAINING_IN_PROGRESS:
announce_training(s);
break;
case SIG_STATUS_TRAINING_FAILED:
break;
case SIG_STATUS_TRAINING_SUCCEEDED:
/* The modem is now trained. */
s->audio.modems.rx_signal_present = true;
s->audio.modems.rx_trained = true;
s->core.short_train = true;
/* Behave like HDLC preamble has been announced. */
t->framing_ok_announced = true;
to_t38_buffer_init(&s->core.to_t38);
break;
case SIG_STATUS_CARRIER_UP:
/* Reset the HDLC receiver. */
t->raw_bit_stream = 0;
t->len = 0;
t->num_bits = 0;
t->flags_seen = 0;
t->framing_ok_announced = false;
to_t38_buffer_init(&s->core.to_t38);
break;
case SIG_STATUS_CARRIER_DOWN:
if (t->framing_ok_announced)
{
category = (s->t38x.current_tx_data_type == T38_DATA_V21) ? T38_PACKET_CATEGORY_CONTROL_DATA_END : T38_PACKET_CATEGORY_IMAGE_DATA_END;
if (t38_core_send_data(&s->t38x.t38, s->t38x.current_tx_data_type, T38_FIELD_HDLC_SIG_END, NULL, 0, category) < 0)
span_log(&s->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
t38_core_send_indicator(&s->t38x.t38, T38_IND_NO_SIGNAL);
t->framing_ok_announced = false;
}
/*endif*/
restart_rx_modem(s);
if (s->core.timed_mode == TIMED_MODE_TCF_PREDICTABLE_MODEM_START_BEGIN)
{
/* If we are doing TCF, we need to announce the fast carrier training very
quickly, to ensure it starts 75+-20ms after the HDLC carrier ends. Waiting until
it trains will be too late. We need to announce the fast modem a fixed time after
the end of the V.21 carrier, in anticipation of its arrival. If we announce it,
and it doesn't arrive, we will worry about that later. */
s->core.samples_to_timeout = ms_to_samples(75);
s->core.timed_mode = TIMED_MODE_TCF_PREDICTABLE_MODEM_START_PAST_V21_MODEM;
}
/*endif*/
break;
default:
span_log(&s->logging, SPAN_LOG_WARNING, "Unexpected HDLC special bit - %d!\n", status);
break;
}
/*endswitch*/
}
/*- End of function --------------------------------------------------------*/
static void rx_flag_or_abort(hdlc_rx_state_t *t)
{
t38_gateway_state_t *s;
t38_gateway_to_t38_state_t *u;
int category;
s = (t38_gateway_state_t *) t->frame_user_data;
u = &s->core.to_t38;
if ((t->raw_bit_stream & 0x01))
{
/* Hit HDLC abort */
t->rx_aborts++;
if (t->flags_seen < t->framing_ok_threshold)
t->flags_seen = 0;
else
t->flags_seen = t->framing_ok_threshold - 1;
/*endif*/
if (t->len > 0)
{
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC frame aborted at %d\n", t->len);
/* If we have sent some of this frame we need to treat the abort as though it is a CRC error,
as reporting a bad CRC is the only way T.38 allows us to scrub a frame in progress. */
/* It seems some boxes may not like us sending a _SIG_END here, and then another
when the carrier actually drops. Lets just send T38_FIELD_HDLC_FCS_OK here. */
if (t->len > 2)
{
category = (s->t38x.current_tx_data_type == T38_DATA_V21) ? T38_PACKET_CATEGORY_CONTROL_DATA : T38_PACKET_CATEGORY_IMAGE_DATA;
if (t38_core_send_data(&s->t38x.t38, s->t38x.current_tx_data_type, T38_FIELD_HDLC_FCS_BAD, NULL, 0, category) < 0)
span_log(&s->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
}
/*endif*/
}
/*endif*/
}
else
{
/* Hit HDLC flag */
if (t->flags_seen >= t->framing_ok_threshold)
{
category = (s->t38x.current_tx_data_type == T38_DATA_V21) ? T38_PACKET_CATEGORY_CONTROL_DATA : T38_PACKET_CATEGORY_IMAGE_DATA;
if (t->len)
{
/* This is not back-to-back flags */
if (t->len >= 2)
{
if (u->data_ptr)
{
bit_reverse(u->data, t->buffer + t->len - 2 - u->data_ptr, u->data_ptr);
if (t38_core_send_data(&s->t38x.t38, s->t38x.current_tx_data_type, T38_FIELD_HDLC_DATA, u->data, u->data_ptr, category) < 0)
span_log(&s->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
}
/*endif*/
if (t->num_bits != 7)
{
t->rx_crc_errors++;
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC frame type %s, misaligned terminating flag at %d\n", t30_frametype(t->buffer[2]), t->len);
/* It seems some boxes may not like us sending a _SIG_END here, and then another
when the carrier actually drops. Lets just send T38_FIELD_HDLC_FCS_OK here. */
if (t->len > 2)
{
if (t38_core_send_data(&s->t38x.t38, s->t38x.current_tx_data_type, T38_FIELD_HDLC_FCS_BAD, NULL, 0, category) < 0)
span_log(&s->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
}
/*endif*/
}
else if ((u->crc & 0xFFFF) != 0xF0B8)
{
t->rx_crc_errors++;
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC frame type %s, bad CRC at %d\n", t30_frametype(t->buffer[2]), t->len);
/* It seems some boxes may not like us sending a _SIG_END here, and then another
when the carrier actually drops. Lets just send T38_FIELD_HDLC_FCS_OK here. */
if (t->len > 2)
{
if (t38_core_send_data(&s->t38x.t38, s->t38x.current_tx_data_type, T38_FIELD_HDLC_FCS_BAD, NULL, 0, category) < 0)
span_log(&s->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
}
/*endif*/
}
else
{
t->rx_frames++;
t->rx_bytes += t->len - 2;
span_log(&s->logging, SPAN_LOG_FLOW, "HDLC frame type %s, CRC OK\n", t30_frametype(t->buffer[2]));
if (s->t38x.current_tx_data_type == T38_DATA_V21)
{
monitor_control_messages(s, true, t->buffer, t->len - 2);
if (s->core.real_time_frame_handler)
s->core.real_time_frame_handler(s->core.real_time_frame_user_data, true, t->buffer, t->len - 2);
/*endif*/
}
else
{
/* Make sure we go back to short training if CTC/CTR has kicked us into
long training. Any successful HDLC frame received at a rate other than
V.21 is an adequate indication we should change. */
s->core.short_train = true;
}
/*endif*/
/* It seems some boxes may not like us sending a _SIG_END here, and then another
when the carrier actually drops. Lets just send T38_FIELD_HDLC_FCS_OK here. */
if (t38_core_send_data(&s->t38x.t38, s->t38x.current_tx_data_type, T38_FIELD_HDLC_FCS_OK, NULL, 0, category) < 0)
span_log(&s->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
}
/*endif*/
}
else
{
/* Frame too short */
t->rx_length_errors++;
}
/*endif*/
}
/*endif*/
}
else
{
/* Check the flags are back-to-back when testing for valid preamble. This
greatly reduces the chances of false preamble detection, and anything
which doesn't send them back-to-back is badly broken. When we are one
flag away from OK we should not apply the back-to-back consition, as
between an abort and the following start of frame things might not be
octet aligned. */
if (t->flags_seen != t->framing_ok_threshold - 1 && t->num_bits != 7)
t->flags_seen = 0;
/*endif*/
if (++t->flags_seen >= t->framing_ok_threshold && !t->framing_ok_announced)
{
if (s->t38x.current_tx_data_type == T38_DATA_V21)
{
t38_core_send_indicator(&s->t38x.t38, set_slow_packetisation(s));
s->audio.modems.rx_signal_present = true;
}
/*endif*/
if (s->t38x.in_progress_rx_indicator == T38_IND_CNG)
set_next_tx_type(s);
/*endif*/
t->framing_ok_announced = true;
}
/*endif*/
}
/*endif*/
}
/*endif*/
t->len = 0;
t->num_bits = 0;
u->crc = 0xFFFF;
u->data_ptr = 0;
s->t38x.corrupt_current_frame[1] = false;
}
/*- End of function --------------------------------------------------------*/
static void t38_hdlc_rx_put_bit(hdlc_rx_state_t *t, int new_bit)
{
t38_gateway_state_t *s;
t38_gateway_to_t38_state_t *u;
int category;
if (new_bit < 0)
{
hdlc_rx_status(t, new_bit);
return;
}
/*endif*/
t->raw_bit_stream = (t->raw_bit_stream << 1) | (new_bit & 1);
if ((t->raw_bit_stream & 0x3E) == 0x3E)
{
/* There are at least 5 ones in a row. We could be at a:
- point where stuffing occurs
- a flag
- an abort
- the result of bit errors */
/* Is this a bit to be skipped for destuffing? */
if ((t->raw_bit_stream & 0x41) == 0)
return;
/*endif*/
/* Is this a flag or abort? */
if ((t->raw_bit_stream & 0xFE) == 0x7E)
{
rx_flag_or_abort(t);
return;
}
/*endif*/
}
/*endif*/
t->num_bits++;
if (t->flags_seen < t->framing_ok_threshold)
return;
/*endif*/
t->byte_in_progress = (t->byte_in_progress >> 1) | ((t->raw_bit_stream & 0x01) << 7);
if (t->num_bits != 8)
return;
/*endif*/
t->num_bits = 0;
s = (t38_gateway_state_t *) t->frame_user_data;
u = &s->core.to_t38;
if (t->len >= (int) sizeof(t->buffer))
{
/* This is too long. Abandon the frame, and wait for the next flag octet. */
if ((t->len + HDLC_TRAMISSION_LAG_OCTETS) >= u->octets_per_data_packet)
{
/* We will have sent some of this frame already, so we need to send termination of this bad HDLC frame. */
category = (s->t38x.current_tx_data_type == T38_DATA_V21) ? T38_PACKET_CATEGORY_CONTROL_DATA : T38_PACKET_CATEGORY_IMAGE_DATA;
if (t38_core_send_data(&s->t38x.t38, s->t38x.current_tx_data_type, T38_FIELD_HDLC_FCS_BAD, NULL, 0, category) < 0)
span_log(&s->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
}
/*endif*/
t->rx_length_errors++;
t->flags_seen = t->framing_ok_threshold - 1;
t->len = 0;
return;
}
/*endif*/
t->buffer[t->len] = (uint8_t) t->byte_in_progress;
if (t->len == 1)
{
/* All valid HDLC frames in FAX communication begin 0xFF 0x03 or 0xFF 0x13.
Anything else is bogus. */
if (t->buffer[0] != 0xFF || (t->buffer[1] & 0xEF) != 0x03)
{
/* Abandon the frame, and wait for the next flag octet. */
/* If this is a real frame, where one of these first two octets has a bit
error, we will fail to forward the frame with a CRC error, as we do for
other bad frames. This will affect the timing of what goes forward.
Hopefully such timing changes will have less frequent bad effects than
the consequences of a bad bit stream simulating an HDLC frame start. */
span_log(&s->logging, SPAN_LOG_FLOW, "Bad HDLC frame header. Abandoning frame.\n");
t->flags_seen = t->framing_ok_threshold - 1;
t->len = 0;
return;
}
/*endif*/
}
/*endif*/
/* Calculate the CRC progressively, before we start altering the frame */
u->crc = crc_itu16_calc(&t->buffer[t->len], 1, u->crc);
/* Make the transmission lag by two octets, so we do not send the CRC, and
do not report the CRC result too late. */
if (++t->len <= HDLC_TRAMISSION_LAG_OCTETS)
return;
/*endif*/
if (s->t38x.current_tx_data_type == T38_DATA_V21)
{
/* The V.21 control messages need to be monitored, and possibly corrupted, to manage the
man-in-the-middle role of T.38 */
edit_control_messages(s, 1, t->buffer, t->len);
}
if (++u->data_ptr >= u->octets_per_data_packet)
{
bit_reverse(u->data, &t->buffer[t->len - HDLC_TRAMISSION_LAG_OCTETS - u->data_ptr], u->data_ptr);
category = (s->t38x.current_tx_data_type == T38_DATA_V21) ? T38_PACKET_CATEGORY_CONTROL_DATA : T38_PACKET_CATEGORY_IMAGE_DATA;
if (t38_core_send_data(&s->t38x.t38, s->t38x.current_tx_data_type, T38_FIELD_HDLC_DATA, u->data, u->data_ptr, category) < 0)
span_log(&s->logging, SPAN_LOG_WARNING, "T.38 send failed\n");
/*endif*/
/* Since we delay transmission by 2 octets, we should now have sent the last of the data octets when
we have just received the last of the CRC octets. */
u->data_ptr = 0;
}
/*endif*/
}
/*- End of function --------------------------------------------------------*/
static int restart_rx_modem(t38_gateway_state_t *s)
{
fax_modems_state_t *t;
if (s->core.to_t38.in_bits || s->core.to_t38.out_octets)
{
span_log(&s->logging,
SPAN_LOG_FLOW,
"%d incoming audio bits. %d outgoing T.38 octets\n",
s->core.to_t38.in_bits,
s->core.to_t38.out_octets);
s->core.to_t38.in_bits = 0;
s->core.to_t38.out_octets = 0;
}
/*endif*/
span_log(&s->logging,
SPAN_LOG_FLOW,
"Restart rx modem - modem = %d, short train = %d, ECM = %d\n",
s->core.fast_rx_modem,
s->core.short_train,
s->core.ecm_mode);
t = &s->audio.modems;
t->rx_signal_present = false;
t->rx_trained = false;
/* Default to the transmit data being V.21, unless a faster modem pops up trained. */
s->t38x.current_tx_data_type = T38_DATA_V21;
//fax_modems_start_slow_modem(t, FAX_MODEM_V21_RX);
fsk_rx_init(&t->v21_rx, &preset_fsk_specs[FSK_V21CH2], FSK_FRAME_MODE_SYNC, (put_bit_func_t) t38_hdlc_rx_put_bit, &t->hdlc_rx);
hdlc_rx_init(&t->hdlc_rx, false, true, HDLC_FRAMING_OK_THRESHOLD, NULL, s);
#if 0
fsk_rx_signal_cutoff(&t->v21_rx, -39.09f);
#endif
if (s->core.image_data_mode && s->core.ecm_mode)
{
fax_modems_set_put_bit(t, (put_bit_func_t) t38_hdlc_rx_put_bit, &t->hdlc_rx);
}
else
{
if (s->core.image_data_mode && s->core.to_t38.fill_bit_removal)
fax_modems_set_put_bit(t, (put_bit_func_t) non_ecm_remove_fill_and_put_bit, s);
else
fax_modems_set_put_bit(t, (put_bit_func_t) non_ecm_put_bit, s);
/*endif*/
}
/*endif*/
to_t38_buffer_init(&s->core.to_t38);
s->core.to_t38.octets_per_data_packet = 1;
t->deferred_rx_handler_updates = true;
switch (s->core.fast_rx_modem)
{
case FAX_MODEM_V27TER_RX:
case FAX_MODEM_V29_RX:
case FAX_MODEM_V17_RX:
fax_modems_start_fast_modem(t, s->core.fast_rx_modem, s->core.fast_bit_rate, s->core.short_train, false);
s->core.fast_rx_active = s->core.fast_rx_modem;
break;
case FAX_MODEM_V21_RX:
default:
//fax_modems_start_slow_modem(t, FAX_MODEM_V21_RX);
fax_modems_set_rx_handler(t, (span_rx_handler_t) &fsk_rx, &t->v21_rx, (span_rx_fillin_handler_t) &fsk_rx_fillin, &t->v21_rx);
s->core.fast_rx_active = FAX_MODEM_NONE;
break;
}
/*endswitch*/
return 0;
}
/*- End of function --------------------------------------------------------*/
static void update_rx_timing(t38_gateway_state_t *s, int len)
{
if (s->core.samples_to_timeout > 0)
{
if ((s->core.samples_to_timeout -= len) <= 0)
{
switch (s->core.timed_mode)
{
case TIMED_MODE_TCF_PREDICTABLE_MODEM_START_PAST_V21_MODEM:
/* Timed announcement of training, 75ms after the DCS carrier fell. */
announce_training(s);
s->core.timed_mode = TIMED_MODE_TCF_PREDICTABLE_MODEM_START_FAST_MODEM_ANNOUNCED;
break;
case TIMED_MODE_TCF_PREDICTABLE_MODEM_START_FAST_MODEM_SEEN:
/* Timed announcement of training, 75ms after the DCS carrier fell. */
announce_training(s);
/* Use a timeout to ride over TEP, if it is present */
s->core.samples_to_timeout = ms_to_samples(500);
s->core.timed_mode = TIMED_MODE_TCF_PREDICTABLE_MODEM_START_FAST_MODEM_ANNOUNCED;
break;
case TIMED_MODE_TCF_PREDICTABLE_MODEM_START_FAST_MODEM_ANNOUNCED:
s->core.timed_mode = TIMED_MODE_IDLE;
span_log(&s->logging, SPAN_LOG_FLOW, "TEP jamming expired\n");
break;
case TIMED_MODE_STARTUP:
/* Ensure a no-signal condition goes out the moment the received audio starts */
t38_core_send_indicator(&s->t38x.t38, T38_IND_NO_SIGNAL);
s->core.timed_mode = TIMED_MODE_IDLE;
break;
}
/*endswitch*/
}
/*endif*/
}
/*endif*/
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE_NONSTD(int) t38_gateway_rx(t38_gateway_state_t *s, int16_t amp[], int len)
{
int i;
#if defined(LOG_FAX_AUDIO)
if (s->audio.modems.audio_rx_log >= 0)
write(s->audio.modems.audio_rx_log, amp, len*sizeof(int16_t));
/*endif*/
#endif
update_rx_timing(s, len);
for (i = 0; i < len; i++)
amp[i] = dc_restore(&s->audio.modems.dc_restore, amp[i]);
/*endfor*/
if (s->audio.modems.rx_handler)
s->audio.modems.rx_handler(s->audio.modems.rx_user_data, amp, len);
return 0;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE_NONSTD(int) t38_gateway_rx_fillin(t38_gateway_state_t *s, int len)
{
/* To mitigate the effect of lost packets on a packet network we should
try to sustain the status quo. If there is no receive modem running, keep
things that way. If there is a receive modem running, try to sustain its
operation, without causing a phase hop, or letting its adaptive functions
diverge. */
#if defined(LOG_FAX_AUDIO)
if (s->audio.modems.audio_rx_log >= 0)
{
int i;
#if defined(_MSC_VER)
int16_t *amp = (int16_t *) _alloca(sizeof(int16_t)*len);
#else
int16_t amp[len];
#endif
vec_zeroi16(amp, len);
write(s->audio.modems.audio_rx_log, amp, len*sizeof(int16_t));
}
#endif
update_rx_timing(s, len);
/* TODO: handle the modems properly */
s->audio.modems.rx_fillin_handler(s->audio.modems.rx_fillin_user_data, len);
return 0;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE_NONSTD(int) t38_gateway_tx(t38_gateway_state_t *s, int16_t amp[], int max_len)
{
int len;
#if defined(LOG_FAX_AUDIO)
int required_len;
required_len = max_len;
#endif
if ((len = s->audio.modems.tx_handler(s->audio.modems.tx_user_data, amp, max_len)) < max_len)
{
if (set_next_tx_type(s))
{
/* Give the new handler a chance to file the remaining buffer space */
len += s->audio.modems.tx_handler(s->audio.modems.tx_user_data, &amp[len], max_len - len);
if (len < max_len)
{
silence_gen_set(&s->audio.modems.silence_gen, 0);
set_next_tx_type(s);
}
/*endif*/
}
/*endif*/
}
/*endif*/
if (s->audio.modems.transmit_on_idle)
{
/* Pad to the requested length with silence */
vec_zeroi16(&amp[len], max_len - len);
len = max_len;
}
/*endif*/
#if defined(LOG_FAX_AUDIO)
if (s->audio.modems.audio_tx_log >= 0)
{
if (len < required_len)
vec_zeroi16(&amp[len], required_len - len);
/*endif*/
write(s->audio.modems.audio_tx_log, amp, required_len*sizeof(int16_t));
}
/*endif*/
#endif
return len;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(void) t38_gateway_get_transfer_statistics(t38_gateway_state_t *s, t38_stats_t *t)
{
memset(t, 0, sizeof(*t));
t->bit_rate = s->core.fast_bit_rate;
t->error_correcting_mode = s->core.ecm_mode;
t->pages_transferred = s->core.pages_confirmed;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(t38_core_state_t *) t38_gateway_get_t38_core_state(t38_gateway_state_t *s)
{
return &s->t38x.t38;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(logging_state_t *) t38_gateway_get_logging_state(t38_gateway_state_t *s)
{
return &s->logging;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(void) t38_gateway_set_ecm_capability(t38_gateway_state_t *s, bool ecm_allowed)
{
s->core.ecm_allowed = ecm_allowed;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(void) t38_gateway_set_transmit_on_idle(t38_gateway_state_t *s, bool transmit_on_idle)
{
s->audio.modems.transmit_on_idle = transmit_on_idle;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(void) t38_gateway_set_supported_modems(t38_gateway_state_t *s, int supported_modems)
{
s->core.supported_modems = supported_modems;
if ((s->core.supported_modems & T30_SUPPORT_V17))
t38_set_fastest_image_data_rate(&s->t38x.t38, 14400);
else if ((s->core.supported_modems & T30_SUPPORT_V29))
t38_set_fastest_image_data_rate(&s->t38x.t38, 9600);
else
t38_set_fastest_image_data_rate(&s->t38x.t38, 4800);
/*endif*/
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(void) t38_gateway_set_nsx_suppression(t38_gateway_state_t *s,
const uint8_t *from_t38,
int from_t38_len,
const uint8_t *from_modem,
int from_modem_len)
{
if (from_t38_len >= 0)
s->t38x.suppress_nsx_len[0] = ((from_t38_len < MAX_NSX_SUPPRESSION) ? from_t38_len : MAX_NSX_SUPPRESSION) + 3;
if (from_t38)
memcpy(s->t38x.suppress_nsx_string[0], from_t38, s->t38x.suppress_nsx_len[0]);
if (from_modem_len >= 0)
s->t38x.suppress_nsx_len[1] = ((from_modem_len < MAX_NSX_SUPPRESSION) ? from_modem_len : MAX_NSX_SUPPRESSION) + 3;
if (from_modem)
memcpy(s->t38x.suppress_nsx_string[1], from_modem, s->t38x.suppress_nsx_len[1]);
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(void) t38_gateway_set_tep_mode(t38_gateway_state_t *s, bool use_tep)
{
fax_modems_set_tep_mode(&s->audio.modems, use_tep);
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(void) t38_gateway_set_fill_bit_removal(t38_gateway_state_t *s, bool remove)
{
s->core.to_t38.fill_bit_removal = remove;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(void) t38_gateway_set_real_time_frame_handler(t38_gateway_state_t *s,
t38_gateway_real_time_frame_handler_t handler,
void *user_data)
{
s->core.real_time_frame_handler = handler;
s->core.real_time_frame_user_data = user_data;
}
/*- End of function --------------------------------------------------------*/
static int t38_gateway_audio_init(t38_gateway_state_t *s)
{
fax_modems_init(&s->audio.modems,
false,
NULL,
hdlc_underflow_handler,
non_ecm_put_bit,
t38_non_ecm_buffer_get_bit,
tone_detected,
s);
/* We need to use progressive HDLC transmit, and a special HDLC receiver, which is different
from the other uses of FAX modems. */
hdlc_tx_init(&s->audio.modems.hdlc_tx, false, 2, true, hdlc_underflow_handler, s);
fsk_rx_set_put_bit(&s->audio.modems.v21_rx, (put_bit_func_t) t38_hdlc_rx_put_bit, &s->audio.modems.hdlc_rx);
/* TODO: Don't use the very low cutoff levels we would like to. We get some quirks if we do.
We need to sort this out. */
fsk_rx_signal_cutoff(&s->audio.modems.v21_rx, -30.0f);
return 0;
}
/*- End of function --------------------------------------------------------*/
static int t38_gateway_t38_init(t38_gateway_state_t *t,
t38_tx_packet_handler_t tx_packet_handler,
void *tx_packet_user_data)
{
t38_gateway_t38_state_t *s;
s = &t->t38x;
t38_core_init(&s->t38,
process_rx_indicator,
process_rx_data,
process_rx_missing,
(void *) t,
tx_packet_handler,
tx_packet_user_data);
t38_set_redundancy_control(&s->t38, T38_PACKET_CATEGORY_INDICATOR, INDICATOR_TX_COUNT);
t38_set_redundancy_control(&s->t38, T38_PACKET_CATEGORY_CONTROL_DATA, DATA_TX_COUNT);
t38_set_redundancy_control(&s->t38, T38_PACKET_CATEGORY_CONTROL_DATA_END, DATA_END_TX_COUNT);
t38_set_redundancy_control(&s->t38, T38_PACKET_CATEGORY_IMAGE_DATA, DATA_TX_COUNT);
t38_set_redundancy_control(&s->t38, T38_PACKET_CATEGORY_IMAGE_DATA_END, DATA_END_TX_COUNT);
return 0;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(t38_gateway_state_t *) t38_gateway_init(t38_gateway_state_t *s,
t38_tx_packet_handler_t tx_packet_handler,
void *tx_packet_user_data)
{
if (tx_packet_handler == NULL)
return NULL;
/*endif*/
if (s == NULL)
{
if ((s = (t38_gateway_state_t *) span_alloc(sizeof(*s))) == NULL)
return NULL;
/*endif*/
}
/*endif*/
memset(s, 0, sizeof(*s));
span_log_init(&s->logging, SPAN_LOG_NONE, NULL);
span_log_set_protocol(&s->logging, "T.38G");
t38_gateway_audio_init(s);
t38_gateway_t38_init(s, tx_packet_handler, tx_packet_user_data);
fax_modems_set_rx_active(&s->audio.modems, true);
t38_gateway_set_supported_modems(s, T30_SUPPORT_V27TER | T30_SUPPORT_V29 | T30_SUPPORT_V17);
t38_gateway_set_nsx_suppression(s, (const uint8_t *) "\xFF\x00\x00", 3, (const uint8_t *) "\xFF\x00\x00", 3);
s->core.to_t38.octets_per_data_packet = 1;
s->core.ecm_allowed = true;
s->core.ms_per_tx_chunk = DEFAULT_MS_PER_TX_CHUNK;
t38_non_ecm_buffer_init(&s->core.non_ecm_to_modem, false, 0);
restart_rx_modem(s);
s->core.timed_mode = TIMED_MODE_STARTUP;
s->core.samples_to_timeout = 1;
#if defined(LOG_FAX_AUDIO)
{
char buf[100 + 1];
struct tm *tm;
time_t now;
time(&now);
tm = localtime(&now);
sprintf(buf,
"/tmp/t38-rx-audio-%p-%02d%02d%02d%02d%02d%02d",
s,
tm->tm_year%100,
tm->tm_mon + 1,
tm->tm_mday,
tm->tm_hour,
tm->tm_min,
tm->tm_sec);
s->audio.modems.audio_rx_log = open(buf, O_CREAT | O_TRUNC | O_WRONLY, 0666);
sprintf(buf,
"/tmp/t38-tx-audio-%p-%02d%02d%02d%02d%02d%02d",
s,
tm->tm_year%100,
tm->tm_mon + 1,
tm->tm_mday,
tm->tm_hour,
tm->tm_min,
tm->tm_sec);
s->audio.modems.audio_tx_log = open(buf, O_CREAT | O_TRUNC | O_WRONLY, 0666);
}
#endif
return s;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(int) t38_gateway_release(t38_gateway_state_t *s)
{
return 0;
}
/*- End of function --------------------------------------------------------*/
SPAN_DECLARE(int) t38_gateway_free(t38_gateway_state_t *s)
{
span_free(s);
return 0;
}
/*- End of function --------------------------------------------------------*/
/*- End of file ------------------------------------------------------------*/
View Git Blame Copy Permalink