res/res_fax_spandsp.c

   1 /*
   2  * Asterisk -- An open source telephony toolkit.
   3  *
   4  * Copyright (C) 2009-2010, Digium, Inc.
   5  *
   6  * Matthew Nicholson <mnicholson@digium.com>
   7  *
   8  * Initial T.38-gateway code
   9  * 2008, Daniel Ferenci <daniel.ferenci@nethemba.com>
  10  * Created by Nethemba s.r.o. http://www.nethemba.com
  11  * Sponsored by IPEX a.s. http://www.ipex.cz
  12  *
  13  * T.38-gateway integration into asterisk app_fax and rework
  14  * 2008, Gregory Hinton Nietsky <gregory@dnstelecom.co.za>
  15  * dns Telecom http://www.dnstelecom.co.za
  16  *
  17  * Modified to make T.38-gateway compatible with Asterisk 1.6.2
  18  * 2010, Anton Verevkin <mymail@verevkin.it>
  19  * ViaNetTV http://www.vianettv.com
  20  *
  21  * Modified to make T.38-gateway work
  22  * 2010, Klaus Darilion, IPCom GmbH, www.ipcom.at
  23  *
  24  * See http://www.asterisk.org for more information about
  25  * the Asterisk project. Please do not directly contact
  26  * any of the maintainers of this project for assistance;
  27  * the project provides a web site, mailing lists and IRC
  28  * channels for your use.
  29  *
  30  * This program is free software, distributed under the terms of
  31  * the GNU General Public License Version 2. See the LICENSE file
  32  * at the top of the source tree.
  33  */
  34
  35 /*! \file
  36  *
  37  * \brief Spandsp T.38 and G.711 FAX Resource
  38  *
  39  * \author Matthew Nicholson <mnicholson@digium.com>
  40  * \author Gregory H. Nietsky <gregory@distrotech.co.za>
  41  *
  42  * This module registers the Spandsp FAX technology with the res_fax module.
  43  */
  44
  45 /*** MODULEINFO
  46         <depend>spandsp</depend>
  47         <depend>res_fax</depend>
  48         <support_level>extended</support_level>
  49 ***/
  50
  51 #include "asterisk.h"
  52
  53 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
  54
  55 #define SPANDSP_EXPOSE_INTERNAL_STRUCTURES
  56 #include <spandsp.h>
  57 #include <spandsp/version.h>
  58
  59 #include "asterisk/logger.h"
  60 #include "asterisk/module.h"
  61 #include "asterisk/strings.h"
  62 #include "asterisk/cli.h"
  63 #include "asterisk/utils.h"
  64 #include "asterisk/timing.h"
  65 #include "asterisk/astobj2.h"
  66 #include "asterisk/res_fax.h"
  67 #include "asterisk/channel.h"
  68
  69 #define SPANDSP_FAX_SAMPLES 160
  70 #define SPANDSP_FAX_TIMER_RATE 8000 / SPANDSP_FAX_SAMPLES       /* 50 ticks per second, 20ms, 160 samples per second */
  71 #define SPANDSP_ENGAGE_UDPTL_NAT_RETRY 3
  72
  73 static void *spandsp_fax_new(struct ast_fax_session *s, struct ast_fax_tech_token *token);
  74 static void spandsp_fax_destroy(struct ast_fax_session *s);
  75 static struct ast_frame *spandsp_fax_read(struct ast_fax_session *s);
  76 static int spandsp_fax_write(struct ast_fax_session *s, const struct ast_frame *f);
  77 static int spandsp_fax_start(struct ast_fax_session *s);
  78 static int spandsp_fax_cancel(struct ast_fax_session *s);
  79 static int spandsp_fax_switch_to_t38(struct ast_fax_session *s);
  80 static int spandsp_fax_gateway_start(struct ast_fax_session *s);
  81 static int spandsp_fax_gateway_process(struct ast_fax_session *s, const struct ast_frame *f);
  82 static void spandsp_fax_gateway_cleanup(struct ast_fax_session *s);
  83 static int spandsp_v21_detect(struct ast_fax_session *s, const struct ast_frame *f);
  84 static void spandsp_v21_cleanup(struct ast_fax_session *s);
  85 static void spandsp_v21_tone(void *data, int code, int level, int delay);
  86
  87 static char *spandsp_fax_cli_show_capabilities(int fd);
  88 static char *spandsp_fax_cli_show_session(struct ast_fax_session *s, int fd);
  89 static char *spandsp_fax_cli_show_stats(int fd);
  90 static char *spandsp_fax_cli_show_settings(int fd);
  91
  92 static struct ast_fax_tech spandsp_fax_tech = {
  93         .type = "Spandsp",
  94         .description = "Spandsp FAX Driver",
  95 #if SPANDSP_RELEASE_DATE >= 20090220
  96         /* spandsp 0.0.6 */
  97         .version = SPANDSP_RELEASE_DATETIME_STRING,
  98 #else
  99         /* spandsp 0.0.5
 100          * TODO: maybe we should determine the version better way
 101          */
 102         .version = "pre-20090220",
 103 #endif
 104         .caps = AST_FAX_TECH_AUDIO | AST_FAX_TECH_T38 | AST_FAX_TECH_SEND
 105                 | AST_FAX_TECH_RECEIVE | AST_FAX_TECH_GATEWAY
 106                 | AST_FAX_TECH_V21_DETECT,
 107         .new_session = spandsp_fax_new,
 108         .destroy_session = spandsp_fax_destroy,
 109         .read = spandsp_fax_read,
 110         .write = spandsp_fax_write,
 111         .start_session = spandsp_fax_start,
 112         .cancel_session = spandsp_fax_cancel,
 113         .switch_to_t38 = spandsp_fax_switch_to_t38,
 114         .cli_show_capabilities = spandsp_fax_cli_show_capabilities,
 115         .cli_show_session = spandsp_fax_cli_show_session,
 116         .cli_show_stats = spandsp_fax_cli_show_stats,
 117         .cli_show_settings = spandsp_fax_cli_show_settings,
 118 };
 119
 120 struct spandsp_fax_stats {
 121         int success;
 122         int nofax;
 123         int neg_failed;
 124         int failed_to_train;
 125         int rx_protocol_error;
 126         int tx_protocol_error;
 127         int protocol_error;
 128         int retries_exceeded;
 129         int file_error;
 130         int mem_error;
 131         int call_dropped;
 132         int unknown_error;
 133         int switched;
 134 };
 135
 136 static struct {
 137         ast_mutex_t lock;
 138         struct spandsp_fax_stats g711;
 139         struct spandsp_fax_stats t38;
 140 } spandsp_global_stats;
 141
 142 struct spandsp_pvt {
 143         unsigned int ist38:1;
 144         unsigned int isdone:1;
 145         enum ast_t38_state ast_t38_state;
 146         fax_state_t fax_state;
 147         t38_terminal_state_t t38_state;
 148         t30_state_t *t30_state;
 149         t38_core_state_t *t38_core_state;
 150
 151         struct spandsp_fax_stats *stats;
 152
 153         struct spandsp_fax_gw_stats *t38stats;
 154         t38_gateway_state_t t38_gw_state;
 155
 156         struct ast_timer *timer;
 157         AST_LIST_HEAD(frame_queue, ast_frame) read_frames;
 158
 159         int v21_detected;
 160         modem_connect_tones_rx_state_t *tone_state;
 161 };
 162
 163 static int spandsp_v21_new(struct spandsp_pvt *p);
 164 static void session_destroy(struct spandsp_pvt *p);
 165 static int t38_tx_packet_handler(t38_core_state_t *t38_core_state, void *data, const uint8_t *buf, int len, int count);
 166 static void t30_phase_e_handler(t30_state_t *t30_state, void *data, int completion_code);
 167 static void spandsp_log(int level, const char *msg);
 168 static int update_stats(struct spandsp_pvt *p, int completion_code);
 169 static int spandsp_modems(struct ast_fax_session_details *details);
 170
 171 static void set_logging(logging_state_t *state, struct ast_fax_session_details *details);
 172 static void set_local_info(t30_state_t *t30_state, struct ast_fax_session_details *details);
 173 static void set_file(t30_state_t *t30_state, struct ast_fax_session_details *details);
 174 static void set_ecm(t30_state_t *t30_state, struct ast_fax_session_details *details);
 175
 176 static void session_destroy(struct spandsp_pvt *p)
 177 {
 178         struct ast_frame *f;
 179
 180         t30_terminate(p->t30_state);
 181         p->isdone = 1;
 182
 183         ast_timer_close(p->timer);
 184         p->timer = NULL;
 185         fax_release(&p->fax_state);
 186         t38_terminal_release(&p->t38_state);
 187
 188         while ((f = AST_LIST_REMOVE_HEAD(&p->read_frames, frame_list))) {
 189                 ast_frfree(f);
 190         }
 191 }
 192
 193 /*! \brief
 194  *
 195  */
 196 static int t38_tx_packet_handler(t38_core_state_t *t38_core_state, void *data, const uint8_t *buf, int len, int count)
 197 {
 198         int res = -1;
 199         struct ast_fax_session *s = data;
 200         struct spandsp_pvt *p = s->tech_pvt;
 201         struct ast_frame fax_frame = {
 202                 .frametype = AST_FRAME_MODEM,
 203                 .subclass.integer = AST_MODEM_T38,
 204                 .src = "res_fax_spandsp_t38",
 205         };
 206
 207         struct ast_frame *f = &fax_frame;
 208
 209
 210         /* TODO: Asterisk does not provide means of resending the same packet multiple
 211           times so count is ignored at the moment */
 212
 213         AST_FRAME_SET_BUFFER(f, buf, 0, len);
 214
 215         if (!(f = ast_frisolate(f))) {
 216                 return res;
 217         }
 218
 219         if (s->details->caps & AST_FAX_TECH_GATEWAY) {
 220                 ast_set_flag(f, AST_FAX_FRFLAG_GATEWAY);
 221                 if (p->ast_t38_state == T38_STATE_NEGOTIATED) {
 222                         res = ast_write(s->chan, f);
 223                 } else {
 224                         res = ast_queue_frame(s->chan, f);
 225                 }
 226                 ast_frfree(f);
 227         } else {
 228                 /* no need to lock, this all runs in the same thread */
 229                 AST_LIST_INSERT_TAIL(&p->read_frames, f, frame_list);
 230                 res = 0;
 231         }
 232
 233         return res;
 234 }
 235
 236 static int update_stats(struct spandsp_pvt *p, int completion_code)
 237 {
 238         switch (completion_code) {
 239         case T30_ERR_OK:
 240                 ast_atomic_fetchadd_int(&p->stats->success, 1);
 241                 break;
 242
 243         /* Link problems */
 244         case T30_ERR_CEDTONE:            /*! The CED tone exceeded 5s */
 245         case T30_ERR_T0_EXPIRED:         /*! Timed out waiting for initial communication */
 246         case T30_ERR_T1_EXPIRED:         /*! Timed out waiting for the first message */
 247         case T30_ERR_T3_EXPIRED:         /*! Timed out waiting for procedural interrupt */
 248         case T30_ERR_HDLC_CARRIER:       /*! The HDLC carrier did not stop in a timely manner */
 249         case T30_ERR_CANNOT_TRAIN:       /*! Failed to train with any of the compatible modems */
 250                 ast_atomic_fetchadd_int(&p->stats->failed_to_train, 1);
 251                 break;
 252
 253         case T30_ERR_OPER_INT_FAIL:      /*! Operator intervention failed */
 254         case T30_ERR_INCOMPATIBLE:       /*! Far end is not compatible */
 255         case T30_ERR_RX_INCAPABLE:       /*! Far end is not able to receive */
 256         case T30_ERR_TX_INCAPABLE:       /*! Far end is not able to transmit */
 257         case T30_ERR_NORESSUPPORT:       /*! Far end cannot receive at the resolution of the image */
 258         case T30_ERR_NOSIZESUPPORT:      /*! Far end cannot receive at the size of image */
 259                 ast_atomic_fetchadd_int(&p->stats->neg_failed, 1);
 260                 break;
 261
 262         case T30_ERR_UNEXPECTED:         /*! Unexpected message received */
 263                 ast_atomic_fetchadd_int(&p->stats->protocol_error, 1);
 264                 break;
 265
 266         /* Phase E status values returned to a transmitter */
 267         case T30_ERR_TX_BADDCS:          /*! Received bad response to DCS or training */
 268         case T30_ERR_TX_BADPG:           /*! Received a DCN from remote after sending a page */
 269         case T30_ERR_TX_ECMPHD:          /*! Invalid ECM response received from receiver */
 270         case T30_ERR_TX_GOTDCN:          /*! Received a DCN while waiting for a DIS */
 271         case T30_ERR_TX_INVALRSP:        /*! Invalid response after sending a page */
 272         case T30_ERR_TX_NODIS:           /*! Received other than DIS while waiting for DIS */
 273         case T30_ERR_TX_PHBDEAD:         /*! Received no response to DCS, training or TCF */
 274         case T30_ERR_TX_PHDDEAD:         /*! No response after sending a page */
 275         case T30_ERR_TX_T5EXP:           /*! Timed out waiting for receiver ready (ECM mode) */
 276                 ast_atomic_fetchadd_int(&p->stats->tx_protocol_error, 1);
 277                 break;
 278
 279         /* Phase E status values returned to a receiver */
 280         case T30_ERR_RX_ECMPHD:          /*! Invalid ECM response received from transmitter */
 281         case T30_ERR_RX_GOTDCS:          /*! DCS received while waiting for DTC */
 282         case T30_ERR_RX_INVALCMD:        /*! Unexpected command after page received */
 283         case T30_ERR_RX_NOCARRIER:       /*! Carrier lost during fax receive */
 284         case T30_ERR_RX_NOEOL:           /*! Timed out while waiting for EOL (end Of line) */
 285                 ast_atomic_fetchadd_int(&p->stats->rx_protocol_error, 1);
 286                 break;
 287         case T30_ERR_RX_NOFAX:           /*! Timed out while waiting for first line */
 288                 ast_atomic_fetchadd_int(&p->stats->nofax, 1);
 289                 break;
 290         case T30_ERR_RX_T2EXPDCN:        /*! Timer T2 expired while waiting for DCN */
 291         case T30_ERR_RX_T2EXPD:          /*! Timer T2 expired while waiting for phase D */
 292         case T30_ERR_RX_T2EXPFAX:        /*! Timer T2 expired while waiting for fax page */
 293         case T30_ERR_RX_T2EXPMPS:        /*! Timer T2 expired while waiting for next fax page */
 294         case T30_ERR_RX_T2EXPRR:         /*! Timer T2 expired while waiting for RR command */
 295         case T30_ERR_RX_T2EXP:           /*! Timer T2 expired while waiting for NSS, DCS or MCF */
 296         case T30_ERR_RX_DCNWHY:          /*! Unexpected DCN while waiting for DCS or DIS */
 297         case T30_ERR_RX_DCNDATA:         /*! Unexpected DCN while waiting for image data */
 298         case T30_ERR_RX_DCNFAX:          /*! Unexpected DCN while waiting for EOM, EOP or MPS */
 299         case T30_ERR_RX_DCNPHD:          /*! Unexpected DCN after EOM or MPS sequence */
 300         case T30_ERR_RX_DCNRRD:          /*! Unexpected DCN after RR/RNR sequence */
 301         case T30_ERR_RX_DCNNORTN:        /*! Unexpected DCN after requested retransmission */
 302                 ast_atomic_fetchadd_int(&p->stats->rx_protocol_error, 1);
 303                 break;
 304
 305         /* TIFF file problems */
 306         case T30_ERR_FILEERROR:          /*! TIFF/F file cannot be opened */
 307         case T30_ERR_NOPAGE:             /*! TIFF/F page not found */
 308         case T30_ERR_BADTIFF:            /*! TIFF/F format is not compatible */
 309         case T30_ERR_BADPAGE:            /*! TIFF/F page number tag missing */
 310         case T30_ERR_BADTAG:             /*! Incorrect values for TIFF/F tags */
 311         case T30_ERR_BADTIFFHDR:         /*! Bad TIFF/F header - incorrect values in fields */
 312                 ast_atomic_fetchadd_int(&p->stats->file_error, 1);
 313                 break;
 314         case T30_ERR_NOMEM:              /*! Cannot allocate memory for more pages */
 315                 ast_atomic_fetchadd_int(&p->stats->mem_error, 1);
 316                 break;
 317
 318         /* General problems */
 319         case T30_ERR_RETRYDCN:           /*! Disconnected after permitted retries */
 320                 ast_atomic_fetchadd_int(&p->stats->retries_exceeded, 1);
 321                 break;
 322         case T30_ERR_CALLDROPPED:        /*! The call dropped prematurely */
 323                 ast_atomic_fetchadd_int(&p->stats->call_dropped, 1);
 324                 break;
 325
 326         /* Feature negotiation issues */
 327         case T30_ERR_NOPOLL:             /*! Poll not accepted */
 328         case T30_ERR_IDENT_UNACCEPTABLE: /*! Far end's ident is not acceptable */
 329         case T30_ERR_SUB_UNACCEPTABLE:   /*! Far end's sub-address is not acceptable */
 330         case T30_ERR_SEP_UNACCEPTABLE:   /*! Far end's selective polling address is not acceptable */
 331         case T30_ERR_PSA_UNACCEPTABLE:   /*! Far end's polled sub-address is not acceptable */
 332         case T30_ERR_SID_UNACCEPTABLE:   /*! Far end's sender identification is not acceptable */
 333         case T30_ERR_PWD_UNACCEPTABLE:   /*! Far end's password is not acceptable */
 334         case T30_ERR_TSA_UNACCEPTABLE:   /*! Far end's transmitting subscriber internet address is not acceptable */
 335         case T30_ERR_IRA_UNACCEPTABLE:   /*! Far end's internet routing address is not acceptable */
 336         case T30_ERR_CIA_UNACCEPTABLE:   /*! Far end's calling subscriber internet address is not acceptable */
 337         case T30_ERR_ISP_UNACCEPTABLE:   /*! Far end's internet selective polling address is not acceptable */
 338         case T30_ERR_CSA_UNACCEPTABLE:   /*! Far end's called subscriber internet address is not acceptable */
 339                 ast_atomic_fetchadd_int(&p->stats->neg_failed, 1);
 340                 break;
 341         default:
 342                 ast_atomic_fetchadd_int(&p->stats->unknown_error, 1);
 343                 ast_log(LOG_WARNING, "unknown FAX session result '%d' (%s)\n", completion_code, t30_completion_code_to_str(completion_code));
 344                 return -1;
 345         }
 346         return 0;
 347 }
 348
 349 /*! \brief Phase E handler callback.
 350  * \param t30_state the span t30 state
 351  * \param data this will be the ast_fax_session
 352  * \param completion_code the result of the fax session
 353  *
 354  * This function pulls stats from the spandsp stack and stores them for res_fax
 355  * to use later.
 356  */
 357 static void t30_phase_e_handler(t30_state_t *t30_state, void *data, int completion_code)
 358 {
 359         struct ast_fax_session *s = data;
 360         struct spandsp_pvt *p = s->tech_pvt;
 361         char headerinfo[T30_MAX_PAGE_HEADER_INFO + 1];
 362         const char *c;
 363         t30_stats_t stats;
 364
 365         ast_debug(5, "FAX session '%d' entering phase E\n", s->id);
 366
 367         p->isdone = 1;
 368
 369         update_stats(p, completion_code);
 370
 371         t30_get_transfer_statistics(t30_state, &stats);
 372
 373         if (completion_code == T30_ERR_OK) {
 374                 ast_string_field_set(s->details, result, "SUCCESS");
 375         } else {
 376                 ast_string_field_set(s->details, result, "FAILED");
 377                 ast_string_field_set(s->details, error, t30_completion_code_to_str(completion_code));
 378         }
 379
 380         ast_string_field_set(s->details, resultstr, t30_completion_code_to_str(completion_code));
 381
 382         ast_debug(5, "FAX session '%d' completed with result: %s (%s)\n", s->id, s->details->result, s->details->resultstr);
 383
 384         if ((c = t30_get_tx_ident(t30_state))) {
 385                 ast_string_field_set(s->details, localstationid, c);
 386         }
 387
 388         if ((c = t30_get_rx_ident(t30_state))) {
 389                 ast_string_field_set(s->details, remotestationid, c);
 390         }
 391
 392 #if SPANDSP_RELEASE_DATE >= 20090220
 393         s->details->pages_transferred = (s->details->caps & AST_FAX_TECH_RECEIVE) ? stats.pages_rx : stats.pages_tx;
 394 #else
 395         s->details->pages_transferred = stats.pages_transferred;
 396 #endif
 397
 398         ast_string_field_build(s->details, transfer_rate, "%d", stats.bit_rate);
 399
 400         ast_string_field_build(s->details, resolution, "%dx%d", stats.x_resolution, stats.y_resolution);
 401
 402         t30_get_tx_page_header_info(t30_state, headerinfo);
 403         ast_string_field_set(s->details, headerinfo, headerinfo);
 404 }
 405
 406 /*! \brief Send spandsp log messages to asterisk.
 407  * \param level the spandsp logging level
 408  * \param msg the log message
 409  *
 410  * \note This function is a callback function called by spandsp.
 411  */
 412 static void spandsp_log(int level, const char *msg)
 413 {
 414         if (level == SPAN_LOG_ERROR) {
 415                 ast_log(LOG_ERROR, "%s", msg);
 416         } else if (level == SPAN_LOG_WARNING) {
 417                 ast_log(LOG_WARNING, "%s", msg);
 418         } else {
 419                 ast_fax_log(LOG_DEBUG, msg);
 420         }
 421 }
 422
 423 static void set_logging(logging_state_t *state, struct ast_fax_session_details *details)
 424 {
 425         int level = SPAN_LOG_WARNING;
 426
 427         if (details->option.debug) {
 428                 level = SPAN_LOG_DEBUG_3;
 429         }
 430
 431         span_log_set_message_handler(state, spandsp_log);
 432         span_log_set_level(state, SPAN_LOG_SHOW_SEVERITY | SPAN_LOG_SHOW_PROTOCOL | level);
 433 }
 434
 435 static void set_local_info(t30_state_t *t30_state, struct ast_fax_session_details *details)
 436 {
 437         if (!ast_strlen_zero(details->localstationid)) {
 438                 t30_set_tx_ident(t30_state, details->localstationid);
 439         }
 440
 441         if (!ast_strlen_zero(details->headerinfo)) {
 442                 t30_set_tx_page_header_info(t30_state, details->headerinfo);
 443         }
 444 }
 445
 446 static void set_file(t30_state_t *t30_state, struct ast_fax_session_details *details)
 447 {
 448         if (details->caps & AST_FAX_TECH_RECEIVE) {
 449                 t30_set_rx_file(t30_state, AST_LIST_FIRST(&details->documents)->filename, -1);
 450         } else {
 451                 /* if not AST_FAX_TECH_RECEIVE, assume AST_FAX_TECH_SEND, this
 452                  * should be safe because we ensure either RECEIVE or SEND is
 453                  * indicated in spandsp_fax_new() */
 454                 t30_set_tx_file(t30_state, AST_LIST_FIRST(&details->documents)->filename, -1, -1);
 455         }
 456 }
 457
 458 static void set_ecm(t30_state_t *t30_state, struct ast_fax_session_details *details)
 459 {
 460         t30_set_ecm_capability(t30_state, details->option.ecm);
 461         t30_set_supported_compressions(t30_state, T30_SUPPORT_T4_1D_COMPRESSION | T30_SUPPORT_T4_2D_COMPRESSION | T30_SUPPORT_T6_COMPRESSION);
 462 }
 463
 464 static int spandsp_v21_new(struct spandsp_pvt *p)
 465 {
 466         /* XXX Here we use MODEM_CONNECT_TONES_FAX_CED_OR_PREAMBLE even though
 467          * we don't care about CED tones. Using MODEM_CONNECT_TONES_PREAMBLE
 468          * doesn't seem to work right all the time.
 469          */
 470         p->tone_state = modem_connect_tones_rx_init(NULL, MODEM_CONNECT_TONES_FAX_CED_OR_PREAMBLE, spandsp_v21_tone, p);
 471         if (!p->tone_state) {
 472                 return -1;
 473         }
 474
 475         return 0;
 476 }
 477
 478 static int spandsp_modems(struct ast_fax_session_details *details)
 479 {
 480         int modems = 0;
 481         if (AST_FAX_MODEM_V17 & details->modems) {
 482                 modems |= T30_SUPPORT_V17;
 483         }
 484         if (AST_FAX_MODEM_V27 & details->modems) {
 485                 modems |= T30_SUPPORT_V27TER;
 486         }
 487         if (AST_FAX_MODEM_V29 & details->modems) {
 488                 modems |= T30_SUPPORT_V29;
 489         }
 490         if (AST_FAX_MODEM_V34 & details->modems) {
 491 #if defined(T30_SUPPORT_V34)
 492                 modems |= T30_SUPPORT_V34;
 493 #elif defined(T30_SUPPORT_V34HDX)
 494                 modems |= T30_SUPPORT_V34HDX;
 495 #else
 496                 ast_log(LOG_WARNING, "v34 not supported in this version of spandsp\n");
 497 #endif
 498         }
 499
 500         return modems;
 501 }
 502
 503 /*! \brief create an instance of the spandsp tech_pvt for a fax session */
 504 static void *spandsp_fax_new(struct ast_fax_session *s, struct ast_fax_tech_token *token)
 505 {
 506         struct spandsp_pvt *p;
 507         int caller_mode;
 508
 509         if ((!(p = ast_calloc(1, sizeof(*p))))) {
 510                 ast_log(LOG_ERROR, "Cannot initialize the spandsp private FAX technology structure.\n");
 511                 goto e_return;
 512         }
 513
 514         if (s->details->caps & AST_FAX_TECH_V21_DETECT) {
 515                 if (spandsp_v21_new(p)) {
 516                         ast_log(LOG_ERROR, "Cannot initialize the spandsp private v21 technology structure.\n");
 517                         goto e_return;
 518                 }
 519                 s->state = AST_FAX_STATE_ACTIVE;
 520                 return p;
 521         }
 522
 523         if (s->details->caps & AST_FAX_TECH_GATEWAY) {
 524                 s->state = AST_FAX_STATE_INITIALIZED;
 525                 return p;
 526         }
 527
 528         AST_LIST_HEAD_INIT(&p->read_frames);
 529
 530         if (s->details->caps & AST_FAX_TECH_RECEIVE) {
 531                 caller_mode = 0;
 532         } else if (s->details->caps & AST_FAX_TECH_SEND) {
 533                 caller_mode = 1;
 534         } else {
 535                 ast_log(LOG_ERROR, "Are we sending or receiving? The FAX requirements (capabilities: 0x%X) were not properly set.\n", s->details->caps);
 536                 goto e_free;
 537         }
 538
 539         if (!(p->timer = ast_timer_open())) {
 540                 ast_log(LOG_ERROR, "Channel '%s' FAX session '%d' failed to create timing source.\n", s->channame, s->id);
 541                 goto e_free;
 542         }
 543
 544         s->fd = ast_timer_fd(p->timer);
 545
 546         p->stats = &spandsp_global_stats.g711;
 547
 548         if (s->details->caps & AST_FAX_TECH_T38) {
 549                 if ((s->details->caps & AST_FAX_TECH_AUDIO) == 0) {
 550                         /* audio mode was not requested, start in T.38 mode */
 551                         p->ist38 = 1;
 552                         p->stats = &spandsp_global_stats.t38;
 553                 }
 554
 555                 /* init t38 stuff */
 556                 t38_terminal_init(&p->t38_state, caller_mode, t38_tx_packet_handler, s);
 557                 set_logging(&p->t38_state.logging, s->details);
 558         }
 559
 560         if (s->details->caps & AST_FAX_TECH_AUDIO) {
 561                 /* init audio stuff */
 562                 fax_init(&p->fax_state, caller_mode);
 563                 set_logging(&p->fax_state.logging, s->details);
 564         }
 565
 566         s->state = AST_FAX_STATE_INITIALIZED;
 567         return p;
 568
 569 e_free:
 570         ast_free(p);
 571 e_return:
 572         return NULL;
 573 }
 574
 575 static void spandsp_v21_cleanup(struct ast_fax_session *s) {
 576         struct spandsp_pvt *p = s->tech_pvt;
 577         modem_connect_tones_rx_free(p->tone_state);
 578 }
 579
 580 /*! \brief Destroy a spandsp fax session.
 581  */
 582 static void spandsp_fax_destroy(struct ast_fax_session *s)
 583 {
 584         struct spandsp_pvt *p = s->tech_pvt;
 585
 586         if (s->details->caps & AST_FAX_TECH_GATEWAY) {
 587                 spandsp_fax_gateway_cleanup(s);
 588         } else if (s->details->caps & AST_FAX_TECH_V21_DETECT) {
 589                 spandsp_v21_cleanup(s);
 590         } else {
 591                 session_destroy(p);
 592         }
 593
 594         ast_free(p);
 595         s->tech_pvt = NULL;
 596         s->fd = -1;
 597 }
 598
 599 /*! \brief Read a frame from the spandsp fax stack.
 600  */
 601 static struct ast_frame *spandsp_fax_read(struct ast_fax_session *s)
 602 {
 603         struct spandsp_pvt *p = s->tech_pvt;
 604         uint8_t buffer[AST_FRIENDLY_OFFSET + SPANDSP_FAX_SAMPLES * sizeof(uint16_t)];
 605         int16_t *buf = (int16_t *) (buffer + AST_FRIENDLY_OFFSET);
 606         int samples;
 607
 608         struct ast_frame fax_frame = {
 609                 .frametype = AST_FRAME_VOICE,
 610                 .src = "res_fax_spandsp_g711",
 611         };
 612         struct ast_frame *f = &fax_frame;
 613         ast_format_set(&fax_frame.subclass.format, AST_FORMAT_SLINEAR, 0);
 614
 615         if (ast_timer_ack(p->timer, 1) < 0) {
 616                 ast_log(LOG_ERROR, "Failed to acknowledge timer for FAX session '%d'\n", s->id);
 617                 return NULL;
 618         }
 619
 620         /* XXX do we need to lock here? */
 621         if (p->isdone) {
 622                 s->state = AST_FAX_STATE_COMPLETE;
 623                 ast_debug(5, "FAX session '%d' is complete.\n", s->id);
 624                 return NULL;
 625         }
 626
 627         if (p->ist38) {
 628                 t38_terminal_send_timeout(&p->t38_state, SPANDSP_FAX_SAMPLES);
 629                 if ((f = AST_LIST_REMOVE_HEAD(&p->read_frames, frame_list))) {
 630                         return f;
 631                 }
 632         } else {
 633                 if ((samples = fax_tx(&p->fax_state, buf, SPANDSP_FAX_SAMPLES)) > 0) {
 634                         f->samples = samples;
 635                         AST_FRAME_SET_BUFFER(f, buffer, AST_FRIENDLY_OFFSET, samples * sizeof(int16_t));
 636                         return ast_frisolate(f);
 637                 }
 638         }
 639
 640         return &ast_null_frame;
 641 }
 642
 643 static void spandsp_v21_tone(void *data, int code, int level, int delay)
 644 {
 645         struct spandsp_pvt *p = data;
 646
 647         if (code == MODEM_CONNECT_TONES_FAX_PREAMBLE) {
 648                 p->v21_detected = 1;
 649         }
 650 }
 651
 652 static int spandsp_v21_detect(struct ast_fax_session *s, const struct ast_frame *f) {
 653         struct spandsp_pvt *p = s->tech_pvt;
 654
 655         if (p->v21_detected) {
 656                 return 0;
 657         }
 658
 659         /*invalid frame*/
 660         if (!f->data.ptr || !f->datalen) {
 661                 return -1;
 662         }
 663
 664         modem_connect_tones_rx(p->tone_state, f->data.ptr, f->samples);
 665
 666         if (p->v21_detected) {
 667                 s->details->option.v21_detected = 1;
 668         }
 669
 670         return 0;
 671 }
 672
 673 /*! \brief Write a frame to the spandsp fax stack.
 674  * \param s a fax session
 675  * \param f the frame to write
 676  *
 677  * \note res_fax does not currently use the return value of this function.
 678  * Also the fax_rx() function never fails.
 679  *
 680  * \retval 0 success
 681  * \retval -1 failure
 682  */
 683 static int spandsp_fax_write(struct ast_fax_session *s, const struct ast_frame *f)
 684 {
 685         struct spandsp_pvt *p = s->tech_pvt;
 686
 687         if (s->details->caps & AST_FAX_TECH_V21_DETECT) {
 688                 return spandsp_v21_detect(s, f);
 689         }
 690
 691         if (s->details->caps & AST_FAX_TECH_GATEWAY) {
 692                 return spandsp_fax_gateway_process(s, f);
 693         }
 694
 695         /* XXX do we need to lock here? */
 696         if (s->state == AST_FAX_STATE_COMPLETE) {
 697                 ast_log(LOG_WARNING, "FAX session '%d' is in the '%s' state.\n", s->id, ast_fax_state_to_str(s->state));
 698                 return -1;
 699         }
 700
 701         if (p->ist38) {
 702                 return t38_core_rx_ifp_packet(p->t38_core_state, f->data.ptr, f->datalen, f->seqno);
 703         } else {
 704                 return fax_rx(&p->fax_state, f->data.ptr, f->samples);
 705         }
 706 }
 707
 708 /*! \brief generate T.30 packets sent to the T.30 leg of gateway
 709  * \param chan T.30 channel
 710  * \param data fax session structure
 711  * \param len not used
 712  * \param samples no of samples generated
 713  * \return -1 on failure or 0 on sucess*/
 714 static int spandsp_fax_gw_t30_gen(struct ast_channel *chan, void *data, int len, int samples)
 715 {
 716         int res = -1;
 717         struct ast_fax_session *s = data;
 718         struct spandsp_pvt *p = s->tech_pvt;
 719         uint8_t buffer[AST_FRIENDLY_OFFSET + samples * sizeof(uint16_t)];
 720         struct ast_frame *f;
 721         struct ast_frame t30_frame = {
 722                 .frametype = AST_FRAME_VOICE,
 723                 .src = "res_fax_spandsp_g711",
 724                 .samples = samples,
 725                 .flags = AST_FAX_FRFLAG_GATEWAY,
 726         };
 727
 728         AST_FRAME_SET_BUFFER(&t30_frame, buffer, AST_FRIENDLY_OFFSET, t30_frame.samples * sizeof(int16_t));
 729
 730         ast_format_set(&t30_frame.subclass.format, AST_FORMAT_SLINEAR, 0);
 731         if (!(f = ast_frisolate(&t30_frame))) {
 732                 return p->isdone ? -1 : res;
 733         }
 734
 735         /* generate a T.30 packet */
 736         if ((f->samples = t38_gateway_tx(&p->t38_gw_state, f->data.ptr, f->samples))) {
 737                 f->datalen = f->samples * sizeof(int16_t);
 738                 res = ast_write(chan, f);
 739         }
 740         ast_frfree(f);
 741         return p->isdone ? -1 : res;
 742 }
 743
 744 /*! \brief simple routine to allocate data to generator
 745  * \param chan channel
 746  * \param params generator data
 747  * \return data to use in generator call*/
 748 static void *spandsp_fax_gw_gen_alloc(struct ast_channel *chan, void *params) {
 749         ao2_ref(params, +1);
 750         return params;
 751 }
 752
 753 static void spandsp_fax_gw_gen_release(struct ast_channel *chan, void *data) {
 754         ao2_ref(data, -1);
 755 }
 756
 757 /*! \brief activate a spandsp gateway based on the information in the given fax session
 758  * \param s fax session
 759  * \return -1 on error 0 on sucess*/
 760 static int spandsp_fax_gateway_start(struct ast_fax_session *s) {
 761         struct spandsp_pvt *p = s->tech_pvt;
 762         struct ast_fax_t38_parameters *t38_param;
 763         int i;
 764         RAII_VAR(struct ast_channel *, peer, NULL, ao2_cleanup);
 765         static struct ast_generator t30_gen = {
 766                 .alloc = spandsp_fax_gw_gen_alloc,
 767                 .release = spandsp_fax_gw_gen_release,
 768                 .generate = spandsp_fax_gw_t30_gen,
 769         };
 770
 771 #if SPANDSP_RELEASE_DATE >= 20081012
 772         /* for spandsp shaphots 0.0.6 and higher */
 773         p->t38_core_state=&p->t38_gw_state.t38x.t38;
 774 #else
 775         /* for spandsp release 0.0.5 */
 776         p->t38_core_state=&p->t38_gw_state.t38;
 777 #endif
 778
 779         if (!t38_gateway_init(&p->t38_gw_state, t38_tx_packet_handler, s)) {
 780                 return -1;
 781         }
 782
 783         p->ist38 = 1;
 784         p->ast_t38_state = ast_channel_get_t38_state(s->chan);
 785         if (!(peer = ast_channel_bridge_peer(s->chan))) {
 786                 ast_channel_unlock(s->chan);
 787                 return -1;
 788         }
 789
 790         /* we can be in T38_STATE_NEGOTIATING or T38_STATE_NEGOTIATED when the
 791          * gateway is started. We treat both states the same. */
 792         if (p->ast_t38_state == T38_STATE_NEGOTIATING) {
 793                 p->ast_t38_state = T38_STATE_NEGOTIATED;
 794         }
 795
 796         ast_activate_generator(p->ast_t38_state == T38_STATE_NEGOTIATED ? peer : s->chan, &t30_gen , s);
 797
 798         set_logging(&p->t38_gw_state.logging, s->details);
 799         set_logging(&p->t38_core_state->logging, s->details);
 800
 801         t38_param = (p->ast_t38_state == T38_STATE_NEGOTIATED) ? &s->details->our_t38_parameters : &s->details->their_t38_parameters;
 802         t38_set_t38_version(p->t38_core_state, t38_param->version);
 803         t38_gateway_set_ecm_capability(&p->t38_gw_state, s->details->option.ecm);
 804         t38_set_max_datagram_size(p->t38_core_state, t38_param->max_ifp);
 805         t38_set_fill_bit_removal(p->t38_core_state, t38_param->fill_bit_removal);
 806         t38_set_mmr_transcoding(p->t38_core_state, t38_param->transcoding_mmr);
 807         t38_set_jbig_transcoding(p->t38_core_state, t38_param->transcoding_jbig);
 808         t38_set_data_rate_management_method(p->t38_core_state,
 809                         (t38_param->rate_management == AST_T38_RATE_MANAGEMENT_TRANSFERRED_TCF)? 1 : 2);
 810
 811         t38_gateway_set_transmit_on_idle(&p->t38_gw_state, TRUE);
 812         t38_set_sequence_number_handling(p->t38_core_state, TRUE);
 813
 814
 815         t38_gateway_set_supported_modems(&p->t38_gw_state, spandsp_modems(s->details));
 816
 817         /* engage udptl nat on other side of T38 line
 818          * (Asterisk changes media ports thus we send a few packets to reinitialize
 819          * pinholes in NATs and FWs
 820          */
 821         for (i=0; i < SPANDSP_ENGAGE_UDPTL_NAT_RETRY; i++) {
 822 #if SPANDSP_RELEASE_DATE >= 20091228
 823                 t38_core_send_indicator(&p->t38_gw_state.t38x.t38, T38_IND_NO_SIGNAL);
 824 #elif SPANDSP_RELEASE_DATE >= 20081012
 825                 t38_core_send_indicator(&p->t38_gw_state.t38x.t38, T38_IND_NO_SIGNAL, p->t38_gw_state.t38x.t38.indicator_tx_count);
 826 #else
 827                 t38_core_send_indicator(&p->t38_gw_state.t38, T38_IND_NO_SIGNAL, p->t38_gw_state.t38.indicator_tx_count);
 828 #endif
 829         }
 830
 831         s->state = AST_FAX_STATE_ACTIVE;
 832
 833         return 0;
 834 }
 835
 836 /*! \brief process a frame from the bridge
 837  * \param s fax session
 838  * \param f frame to process
 839  * \return 1 on sucess 0 on incorect packet*/
 840 static int spandsp_fax_gateway_process(struct ast_fax_session *s, const struct ast_frame *f)
 841 {
 842         struct spandsp_pvt *p = s->tech_pvt;
 843
 844         /*invalid frame*/
 845         if (!f->data.ptr || !f->datalen) {
 846                 return -1;
 847         }
 848
 849         /* Process a IFP packet */
 850         if ((f->frametype == AST_FRAME_MODEM) && (f->subclass.integer == AST_MODEM_T38)) {
 851                 return t38_core_rx_ifp_packet(p->t38_core_state, f->data.ptr, f->datalen, f->seqno);
 852         } else if ((f->frametype == AST_FRAME_VOICE) && (f->subclass.format.id == AST_FORMAT_SLINEAR)) {
 853                 return t38_gateway_rx(&p->t38_gw_state, f->data.ptr, f->samples);
 854         }
 855
 856         return -1;
 857 }
 858
 859 /*! \brief gather data and clean up after gateway ends
 860  * \param s fax session*/
 861 static void spandsp_fax_gateway_cleanup(struct ast_fax_session *s)
 862 {
 863         struct spandsp_pvt *p = s->tech_pvt;
 864         t38_stats_t t38_stats;
 865
 866         t38_gateway_get_transfer_statistics(&p->t38_gw_state, &t38_stats);
 867
 868         s->details->option.ecm = t38_stats.error_correcting_mode ? AST_FAX_OPTFLAG_TRUE : AST_FAX_OPTFLAG_FALSE;
 869         s->details->pages_transferred = t38_stats.pages_transferred;
 870         ast_string_field_build(s->details, transfer_rate, "%d", t38_stats.bit_rate);
 871 }
 872
 873 /*! \brief */
 874 static int spandsp_fax_start(struct ast_fax_session *s)
 875 {
 876         struct spandsp_pvt *p = s->tech_pvt;
 877
 878         s->state = AST_FAX_STATE_OPEN;
 879
 880         if (s->details->caps & AST_FAX_TECH_GATEWAY) {
 881                 return spandsp_fax_gateway_start(s);
 882         }
 883
 884         if (p->ist38) {
 885 #if SPANDSP_RELEASE_DATE >= 20080725
 886                 /* for spandsp shaphots 0.0.6 and higher */
 887                 p->t30_state = &p->t38_state.t30;
 888                 p->t38_core_state = &p->t38_state.t38_fe.t38;
 889 #else
 890                 /* for spandsp releases 0.0.5 */
 891                 p->t30_state = &p->t38_state.t30_state;
 892                 p->t38_core_state = &p->t38_state.t38;
 893 #endif
 894         } else {
 895 #if SPANDSP_RELEASE_DATE >= 20080725
 896                 /* for spandsp shaphots 0.0.6 and higher */
 897                 p->t30_state = &p->fax_state.t30;
 898 #else
 899                 /* for spandsp release 0.0.5 */
 900                 p->t30_state = &p->fax_state.t30_state;
 901 #endif
 902         }
 903
 904         set_logging(&p->t30_state->logging, s->details);
 905
 906         /* set some parameters */
 907         set_local_info(p->t30_state, s->details);
 908         set_file(p->t30_state, s->details);
 909         set_ecm(p->t30_state, s->details);
 910         t30_set_supported_modems(p->t30_state, spandsp_modems(s->details));
 911
 912         /* perhaps set_transmit_on_idle() should be called */
 913
 914         t30_set_phase_e_handler(p->t30_state, t30_phase_e_handler, s);
 915
 916         /* set T.38 parameters */
 917         if (p->ist38) {
 918                 set_logging(&p->t38_core_state->logging, s->details);
 919
 920                 t38_set_max_datagram_size(p->t38_core_state, s->details->their_t38_parameters.max_ifp);
 921
 922                 if (s->details->their_t38_parameters.fill_bit_removal) {
 923                         t38_set_fill_bit_removal(p->t38_core_state, TRUE);
 924                 }
 925
 926                 if (s->details->their_t38_parameters.transcoding_mmr) {
 927                         t38_set_mmr_transcoding(p->t38_core_state, TRUE);
 928                 }
 929
 930                 if (s->details->their_t38_parameters.transcoding_jbig) {
 931                         t38_set_jbig_transcoding(p->t38_core_state, TRUE);
 932                 }
 933         } else {
 934                 /* have the fax stack generate silence if it has no data to send */
 935                 fax_set_transmit_on_idle(&p->fax_state, 1);
 936         }
 937
 938
 939         /* start the timer */
 940         if (ast_timer_set_rate(p->timer, SPANDSP_FAX_TIMER_RATE)) {
 941                 ast_log(LOG_ERROR, "FAX session '%d' error setting rate on timing source.\n", s->id);
 942                 return -1;
 943         }
 944
 945         s->state = AST_FAX_STATE_ACTIVE;
 946
 947         return 0;
 948 }
 949
 950 /*! \brief */
 951 static int spandsp_fax_cancel(struct ast_fax_session *s)
 952 {
 953         struct spandsp_pvt *p = s->tech_pvt;
 954
 955         if (s->details->caps & AST_FAX_TECH_GATEWAY) {
 956                 p->isdone = 1;
 957                 return 0;
 958         }
 959
 960         t30_terminate(p->t30_state);
 961         p->isdone = 1;
 962         return 0;
 963 }
 964
 965 /*! \brief */
 966 static int spandsp_fax_switch_to_t38(struct ast_fax_session *s)
 967 {
 968         struct spandsp_pvt *p = s->tech_pvt;
 969
 970         /* prevent the phase E handler from running, this is not a real termination */
 971         t30_set_phase_e_handler(p->t30_state, NULL, NULL);
 972
 973         t30_terminate(p->t30_state);
 974
 975         s->details->option.switch_to_t38 = 1;
 976         ast_atomic_fetchadd_int(&p->stats->switched, 1);
 977
 978         p->ist38 = 1;
 979         p->stats = &spandsp_global_stats.t38;
 980         spandsp_fax_start(s);
 981
 982         return 0;
 983 }
 984
 985 /*! \brief */
 986 static char *spandsp_fax_cli_show_capabilities(int fd)
 987 {
 988         ast_cli(fd, "SEND RECEIVE T.38 G.711 GATEWAY\n\n");
 989         return  CLI_SUCCESS;
 990 }
 991
 992 /*! \brief */
 993 static char *spandsp_fax_cli_show_session(struct ast_fax_session *s, int fd)
 994 {
 995         ao2_lock(s);
 996         if (s->details->caps & AST_FAX_TECH_GATEWAY) {
 997                 struct spandsp_pvt *p = s->tech_pvt;
 998
 999                 ast_cli(fd, "%-22s : %d\n", "session", s->id);
1000                 ast_cli(fd, "%-22s : %s\n", "operation", "Gateway");
1001                 ast_cli(fd, "%-22s : %s\n", "state", ast_fax_state_to_str(s->state));
1002                 if (s->state != AST_FAX_STATE_UNINITIALIZED) {
1003                         t38_stats_t stats;
1004                         t38_gateway_get_transfer_statistics(&p->t38_gw_state, &stats);
1005                         ast_cli(fd, "%-22s : %s\n", "ECM Mode", stats.error_correcting_mode ? "Yes" : "No");
1006                         ast_cli(fd, "%-22s : %d\n", "Data Rate", stats.bit_rate);
1007                         ast_cli(fd, "%-22s : %d\n", "Page Number", stats.pages_transferred + 1);
1008                 }
1009         } else if (s->details->caps & AST_FAX_TECH_V21_DETECT) {
1010                 ast_cli(fd, "%-22s : %d\n", "session", s->id);
1011                 ast_cli(fd, "%-22s : %s\n", "operation", "V.21 Detect");
1012                 ast_cli(fd, "%-22s : %s\n", "state", ast_fax_state_to_str(s->state));
1013         } else {
1014                 struct spandsp_pvt *p = s->tech_pvt;
1015
1016                 ast_cli(fd, "%-22s : %d\n", "session", s->id);
1017                 ast_cli(fd, "%-22s : %s\n", "operation", (s->details->caps & AST_FAX_TECH_RECEIVE) ? "Receive" : "Transmit");
1018                 ast_cli(fd, "%-22s : %s\n", "state", ast_fax_state_to_str(s->state));
1019                 if (s->state != AST_FAX_STATE_UNINITIALIZED) {
1020                         t30_stats_t stats;
1021                         t30_get_transfer_statistics(p->t30_state, &stats);
1022                         ast_cli(fd, "%-22s : %s\n", "Last Status", t30_completion_code_to_str(stats.current_status));
1023                         ast_cli(fd, "%-22s : %s\n", "ECM Mode", stats.error_correcting_mode ? "Yes" : "No");
1024                         ast_cli(fd, "%-22s : %d\n", "Data Rate", stats.bit_rate);
1025                         ast_cli(fd, "%-22s : %dx%d\n", "Image Resolution", stats.x_resolution, stats.y_resolution);
1026 #if SPANDSP_RELEASE_DATE >= 20090220
1027                         ast_cli(fd, "%-22s : %d\n", "Page Number", ((s->details->caps & AST_FAX_TECH_RECEIVE) ? stats.pages_rx : stats.pages_tx) + 1);
1028 #else
1029                         ast_cli(fd, "%-22s : %d\n", "Page Number", stats.pages_transferred + 1);
1030 #endif
1031                         ast_cli(fd, "%-22s : %s\n", "File Name", s->details->caps & AST_FAX_TECH_RECEIVE ? p->t30_state->rx_file : p->t30_state->tx_file);
1032
1033                         ast_cli(fd, "\nData Statistics:\n");
1034 #if SPANDSP_RELEASE_DATE >= 20090220
1035                         ast_cli(fd, "%-22s : %d\n", "Tx Pages", stats.pages_tx);
1036                         ast_cli(fd, "%-22s : %d\n", "Rx Pages", stats.pages_rx);
1037 #else
1038                         ast_cli(fd, "%-22s : %d\n", "Tx Pages", (s->details->caps & AST_FAX_TECH_SEND) ? stats.pages_transferred : 0);
1039                         ast_cli(fd, "%-22s : %d\n", "Rx Pages", (s->details->caps & AST_FAX_TECH_RECEIVE) ? stats.pages_transferred : 0);
1040 #endif
1041                         ast_cli(fd, "%-22s : %d\n", "Longest Bad Line Run", stats.longest_bad_row_run);
1042                         ast_cli(fd, "%-22s : %d\n", "Total Bad Lines", stats.bad_rows);
1043                 }
1044         }
1045         ao2_unlock(s);
1046         ast_cli(fd, "\n\n");
1047         return CLI_SUCCESS;
1048 }
1049
1050 /*! \brief */
1051 static char *spandsp_fax_cli_show_stats(int fd)
1052 {
1053         ast_mutex_lock(&spandsp_global_stats.lock);
1054         ast_cli(fd, "\n%-20.20s\n", "Spandsp G.711");
1055         ast_cli(fd, "%-20.20s : %d\n", "Success", spandsp_global_stats.g711.success);
1056         ast_cli(fd, "%-20.20s : %d\n", "Switched to T.38", spandsp_global_stats.g711.switched);
1057         ast_cli(fd, "%-20.20s : %d\n", "Call Dropped", spandsp_global_stats.g711.call_dropped);
1058         ast_cli(fd, "%-20.20s : %d\n", "No FAX", spandsp_global_stats.g711.nofax);
1059         ast_cli(fd, "%-20.20s : %d\n", "Negotiation Failed", spandsp_global_stats.g711.neg_failed);
1060         ast_cli(fd, "%-20.20s : %d\n", "Train Failure", spandsp_global_stats.g711.failed_to_train);
1061         ast_cli(fd, "%-20.20s : %d\n", "Retries Exceeded", spandsp_global_stats.g711.retries_exceeded);
1062         ast_cli(fd, "%-20.20s : %d\n", "Protocol Error", spandsp_global_stats.g711.protocol_error);
1063         ast_cli(fd, "%-20.20s : %d\n", "TX Protocol Error", spandsp_global_stats.g711.tx_protocol_error);
1064         ast_cli(fd, "%-20.20s : %d\n", "RX Protocol Error", spandsp_global_stats.g711.rx_protocol_error);
1065         ast_cli(fd, "%-20.20s : %d\n", "File Error", spandsp_global_stats.g711.file_error);
1066         ast_cli(fd, "%-20.20s : %d\n", "Memory Error", spandsp_global_stats.g711.mem_error);
1067         ast_cli(fd, "%-20.20s : %d\n", "Unknown Error", spandsp_global_stats.g711.unknown_error);
1068
1069         ast_cli(fd, "\n%-20.20s\n", "Spandsp T.38");
1070         ast_cli(fd, "%-20.20s : %d\n", "Success", spandsp_global_stats.t38.success);
1071         ast_cli(fd, "%-20.20s : %d\n", "Call Dropped", spandsp_global_stats.t38.call_dropped);
1072         ast_cli(fd, "%-20.20s : %d\n", "No FAX", spandsp_global_stats.t38.nofax);
1073         ast_cli(fd, "%-20.20s : %d\n", "Negotiation Failed", spandsp_global_stats.t38.neg_failed);
1074         ast_cli(fd, "%-20.20s : %d\n", "Train Failure", spandsp_global_stats.t38.failed_to_train);
1075         ast_cli(fd, "%-20.20s : %d\n", "Retries Exceeded", spandsp_global_stats.t38.retries_exceeded);
1076         ast_cli(fd, "%-20.20s : %d\n", "Protocol Error", spandsp_global_stats.t38.protocol_error);
1077         ast_cli(fd, "%-20.20s : %d\n", "TX Protocol Error", spandsp_global_stats.t38.tx_protocol_error);
1078         ast_cli(fd, "%-20.20s : %d\n", "RX Protocol Error", spandsp_global_stats.t38.rx_protocol_error);
1079         ast_cli(fd, "%-20.20s : %d\n", "File Error", spandsp_global_stats.t38.file_error);
1080         ast_cli(fd, "%-20.20s : %d\n", "Memory Error", spandsp_global_stats.t38.mem_error);
1081         ast_cli(fd, "%-20.20s : %d\n", "Unknown Error", spandsp_global_stats.t38.unknown_error);
1082         ast_mutex_unlock(&spandsp_global_stats.lock);
1083
1084         return CLI_SUCCESS;
1085 }
1086
1087 /*! \brief Show res_fax_spandsp settings */
1088 static char *spandsp_fax_cli_show_settings(int fd)
1089 {
1090         /* no settings at the moment */
1091         return CLI_SUCCESS;
1092 }
1093
1094 /*! \brief unload res_fax_spandsp */
1095 static int unload_module(void)
1096 {
1097         ast_fax_tech_unregister(&spandsp_fax_tech);
1098         ast_mutex_destroy(&spandsp_global_stats.lock);
1099         return AST_MODULE_LOAD_SUCCESS;
1100 }
1101
1102 /*! \brief load res_fax_spandsp */
1103 static int load_module(void)
1104 {
1105         ast_mutex_init(&spandsp_global_stats.lock);
1106         spandsp_fax_tech.module = ast_module_info->self;
1107         if (ast_fax_tech_register(&spandsp_fax_tech) < 0) {
1108                 ast_log(LOG_ERROR, "failed to register FAX technology\n");
1109                 return AST_MODULE_LOAD_DECLINE;
1110         }
1111
1112         /* prevent logging to stderr */
1113         span_set_message_handler(NULL);
1114
1115         return AST_MODULE_LOAD_SUCCESS;
1116 }
1117
1118
1119 AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_DEFAULT, "Spandsp G.711 and T.38 FAX Technologies",
1120                 .load = load_module,
1121                 .unload = unload_module,
1122                );