channels/chan_zap.c

   1 /*
   2  * Asterisk -- An open source telephony toolkit.
   3  *
   4  * Copyright (C) 1999 - 2006, Digium, Inc.
   5  *
   6  * Mark Spencer <markster@digium.com>
   7  *
   8  * See http://www.asterisk.org for more information about
   9  * the Asterisk project. Please do not directly contact
  10  * any of the maintainers of this project for assistance;
  11  * the project provides a web site, mailing lists and IRC
  12  * channels for your use.
  13  *
  14  * This program is free software, distributed under the terms of
  15  * the GNU General Public License Version 2. See the LICENSE file
  16  * at the top of the source tree.
  17  */
  18
  19 /*! \file
  20  *
  21  * \brief Zaptel Pseudo TDM interface
  22  *
  23  * \author Mark Spencer <markster@digium.com>
  24  *
  25  * Connects to the zaptel telephony library as well as
  26  * libpri. Libpri is optional and needed only if you are
  27  * going to use ISDN connections.
  28  *
  29  * You need to install libraries before you attempt to compile
  30  * and install the zaptel channel.
  31  *
  32  * \par See also
  33  * \arg \ref Config_zap
  34  *
  35  * \ingroup channel_drivers
  36  *
  37  * \todo Deprecate the "musiconhold" configuration option post 1.4
  38  */
  39
  40 /*** MODULEINFO
  41         <depend>res_smdi</depend>
  42         <depend>zaptel_vldtmf</depend>
  43         <depend>zaptel</depend>
  44         <depend>tonezone</depend>
  45         <use>pri</use>
  46         <use>ss7</use>
  47  ***/
  48
  49 #include "asterisk.h"
  50
  51 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
  52
  53 #include <stdio.h>
  54 #include <string.h>
  55 #ifdef __NetBSD__
  56 #include <pthread.h>
  57 #include <signal.h>
  58 #else
  59 #include <sys/signal.h>
  60 #endif
  61 #include <errno.h>
  62 #include <stdlib.h>
  63 #if !defined(SOLARIS) && !defined(__FreeBSD__)
  64 #include <stdint.h>
  65 #endif
  66 #include <unistd.h>
  67 #include <sys/ioctl.h>
  68 #include <math.h>
  69 #include <ctype.h>
  70 #include "asterisk/zapata.h"
  71
  72 #ifdef HAVE_PRI
  73 #include <libpri.h>
  74 #endif
  75
  76 #ifdef HAVE_SS7
  77 #include <libss7.h>
  78 #endif
  79
  80 #include "asterisk/lock.h"
  81 #include "asterisk/channel.h"
  82 #include "asterisk/config.h"
  83 #include "asterisk/logger.h"
  84 #include "asterisk/module.h"
  85 #include "asterisk/pbx.h"
  86 #include "asterisk/options.h"
  87 #include "asterisk/file.h"
  88 #include "asterisk/ulaw.h"
  89 #include "asterisk/alaw.h"
  90 #include "asterisk/callerid.h"
  91 #include "asterisk/adsi.h"
  92 #include "asterisk/cli.h"
  93 #include "asterisk/cdr.h"
  94 #include "asterisk/features.h"
  95 #include "asterisk/musiconhold.h"
  96 #include "asterisk/say.h"
  97 #include "asterisk/tdd.h"
  98 #include "asterisk/app.h"
  99 #include "asterisk/dsp.h"
 100 #include "asterisk/astdb.h"
 101 #include "asterisk/manager.h"
 102 #include "asterisk/causes.h"
 103 #include "asterisk/term.h"
 104 #include "asterisk/utils.h"
 105 #include "asterisk/transcap.h"
 106 #include "asterisk/stringfields.h"
 107 #include "asterisk/abstract_jb.h"
 108 #include "asterisk/smdi.h"
 109 #include "asterisk/astobj.h"
 110 #include "asterisk/event.h"
 111
 112 #define SMDI_MD_WAIT_TIMEOUT 1500 /* 1.5 seconds */
 113
 114 /*! Global jitterbuffer configuration - by default, jb is disabled */
 115 static struct ast_jb_conf default_jbconf =
 116 {
 117         .flags = 0,
 118         .max_size = -1,
 119         .resync_threshold = -1,
 120         .impl = ""
 121 };
 122 static struct ast_jb_conf global_jbconf;
 123
 124 #if !defined(ZT_SIG_EM_E1) || (defined(HAVE_PRI) && !defined(ZT_SIG_HARDHDLC))
 125 #error "Your zaptel is too old.  Please update"
 126 #endif
 127
 128 #ifndef ZT_TONEDETECT
 129 /* Work around older code with no tone detect */
 130 #define ZT_EVENT_DTMFDOWN 0
 131 #define ZT_EVENT_DTMFUP 0
 132 #endif
 133
 134 /* define this to send PRI user-user information elements */
 135 #undef SUPPORT_USERUSER
 136
 137 /*!
 138  * \note Define ZHONE_HACK to cause us to go off hook and then back on hook when
 139  * the user hangs up to reset the state machine so ring works properly.
 140  * This is used to be able to support kewlstart by putting the zhone in
 141  * groundstart mode since their forward disconnect supervision is entirely
 142  * broken even though their documentation says it isn't and their support
 143  * is entirely unwilling to provide any assistance with their channel banks
 144  * even though their web site says they support their products for life.
 145  */
 146 /* #define ZHONE_HACK */
 147
 148 /*! \note
 149  * Define if you want to check the hook state for an FXO (FXS signalled) interface
 150  * before dialing on it.  Certain FXO interfaces always think they're out of
 151  * service with this method however.
 152  */
 153 /* #define ZAP_CHECK_HOOKSTATE */
 154
 155 /*! \brief Typically, how many rings before we should send Caller*ID */
 156 #define DEFAULT_CIDRINGS 1
 157
 158 #define CHANNEL_PSEUDO -12
 159
 160 #define AST_LAW(p) (((p)->law == ZT_LAW_ALAW) ? AST_FORMAT_ALAW : AST_FORMAT_ULAW)
 161
 162 /*! \brief Signaling types that need to use MF detection should be placed in this macro */
 163 #define NEED_MFDETECT(p) (((p)->sig == SIG_FEATDMF) || ((p)->sig == SIG_FEATDMF_TA) || ((p)->sig == SIG_E911) || ((p)->sig == SIG_FGC_CAMA) || ((p)->sig == SIG_FGC_CAMAMF) || ((p)->sig == SIG_FEATB))
 164
 165 static const char tdesc[] = "Zapata Telephony Driver"
 166 #ifdef HAVE_PRI
 167                " w/PRI"
 168 #endif
 169 #ifdef HAVE_SS7
 170                " w/SS7"
 171 #endif
 172 ;
 173
 174 static const char config[] = "zapata.conf";
 175
 176 #define SIG_EM          ZT_SIG_EM
 177 #define SIG_EMWINK      (0x0100000 | ZT_SIG_EM)
 178 #define SIG_FEATD       (0x0200000 | ZT_SIG_EM)
 179 #define SIG_FEATDMF     (0x0400000 | ZT_SIG_EM)
 180 #define SIG_FEATB       (0x0800000 | ZT_SIG_EM)
 181 #define SIG_E911        (0x1000000 | ZT_SIG_EM)
 182 #define SIG_FEATDMF_TA  (0x2000000 | ZT_SIG_EM)
 183 #define SIG_FGC_CAMA    (0x4000000 | ZT_SIG_EM)
 184 #define SIG_FGC_CAMAMF  (0x8000000 | ZT_SIG_EM)
 185 #define SIG_FXSLS       ZT_SIG_FXSLS
 186 #define SIG_FXSGS       ZT_SIG_FXSGS
 187 #define SIG_FXSKS       ZT_SIG_FXSKS
 188 #define SIG_FXOLS       ZT_SIG_FXOLS
 189 #define SIG_FXOGS       ZT_SIG_FXOGS
 190 #define SIG_FXOKS       ZT_SIG_FXOKS
 191 #define SIG_PRI         ZT_SIG_CLEAR
 192 #define SIG_SS7         (0x1000000 | ZT_SIG_CLEAR)
 193 #define SIG_SF          ZT_SIG_SF
 194 #define SIG_SFWINK      (0x0100000 | ZT_SIG_SF)
 195 #define SIG_SF_FEATD    (0x0200000 | ZT_SIG_SF)
 196 #define SIG_SF_FEATDMF  (0x0400000 | ZT_SIG_SF)
 197 #define SIG_SF_FEATB    (0x0800000 | ZT_SIG_SF)
 198 #define SIG_EM_E1       ZT_SIG_EM_E1
 199 #define SIG_GR303FXOKS  (0x0100000 | ZT_SIG_FXOKS)
 200 #define SIG_GR303FXSKS  (0x0100000 | ZT_SIG_FXSKS)
 201
 202 #define NUM_SPANS               32
 203 #define NUM_DCHANS              4       /*!< No more than 4 d-channels */
 204 #define MAX_CHANNELS    672             /*!< No more than a DS3 per trunk group */
 205
 206 #define CHAN_PSEUDO     -2
 207
 208 #define DCHAN_PROVISIONED (1 << 0)
 209 #define DCHAN_NOTINALARM  (1 << 1)
 210 #define DCHAN_UP          (1 << 2)
 211
 212 #define DCHAN_AVAILABLE (DCHAN_PROVISIONED | DCHAN_NOTINALARM | DCHAN_UP)
 213
 214 /* Overlap dialing option types */
 215 #define ZAP_OVERLAPDIAL_NONE 0
 216 #define ZAP_OVERLAPDIAL_OUTGOING 1
 217 #define ZAP_OVERLAPDIAL_INCOMING 2
 218 #define ZAP_OVERLAPDIAL_BOTH (ZAP_OVERLAPDIAL_INCOMING|ZAP_OVERLAPDIAL_OUTGOING)
 219
 220 static char defaultcic[64] = "";
 221 static char defaultozz[64] = "";
 222
 223 static char progzone[10] = "";
 224
 225 static int usedistinctiveringdetection = 0;
 226 static int distinctiveringaftercid = 0;
 227
 228 static int numbufs = 4;
 229
 230 #ifdef HAVE_PRI
 231 static struct ast_channel inuse;
 232 #ifdef PRI_GETSET_TIMERS
 233 static int pritimers[PRI_MAX_TIMERS];
 234 #endif
 235 static int pridebugfd = -1;
 236 static char pridebugfilename[1024] = "";
 237 #endif
 238
 239 /*! \brief Wait up to 16 seconds for first digit (FXO logic) */
 240 static int firstdigittimeout = 16000;
 241
 242 /*! \brief How long to wait for following digits (FXO logic) */
 243 static int gendigittimeout = 8000;
 244
 245 /*! \brief How long to wait for an extra digit, if there is an ambiguous match */
 246 static int matchdigittimeout = 3000;
 247
 248 /*! \brief Protect the interface list (of zt_pvt's) */
 249 AST_MUTEX_DEFINE_STATIC(iflock);
 250
 251
 252 static int ifcount = 0;
 253
 254 #ifdef HAVE_PRI
 255 AST_MUTEX_DEFINE_STATIC(pridebugfdlock);
 256 #endif
 257
 258 /*! \brief Protect the monitoring thread, so only one process can kill or start it, and not
 259    when it's doing something critical. */
 260 AST_MUTEX_DEFINE_STATIC(monlock);
 261
 262 /*! \brief This is the thread for the monitor which checks for input on the channels
 263    which are not currently in use. */
 264 static pthread_t monitor_thread = AST_PTHREADT_NULL;
 265
 266 static int restart_monitor(void);
 267
 268 static enum ast_bridge_result zt_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, struct ast_frame **fo, struct ast_channel **rc, int timeoutms);
 269
 270 static int zt_sendtext(struct ast_channel *c, const char *text);
 271
 272 static void mwi_event_cb(const struct ast_event *event, void *userdata)
 273 {
 274         /* This module does not handle MWI in an event-based manner.  However, it
 275          * subscribes to MWI for each mailbox that is configured so that the core
 276          * knows that we care about it.  Then, chan_zap will get the MWI from the
 277          * event cache instead of checking the mailbox directly. */
 278 }
 279
 280 /*! \brief Avoid the silly zt_getevent which ignores a bunch of events */
 281 static inline int zt_get_event(int fd)
 282 {
 283         int j;
 284         if (ioctl(fd, ZT_GETEVENT, &j) == -1)
 285                 return -1;
 286         return j;
 287 }
 288
 289 /*! \brief Avoid the silly zt_waitevent which ignores a bunch of events */
 290 static inline int zt_wait_event(int fd)
 291 {
 292         int i, j = 0;
 293         i = ZT_IOMUX_SIGEVENT;
 294         if (ioctl(fd, ZT_IOMUX, &i) == -1)
 295                 return -1;
 296         if (ioctl(fd, ZT_GETEVENT, &j) == -1)
 297                 return -1;
 298         return j;
 299 }
 300
 301 /*! Chunk size to read -- we use 20ms chunks to make things happy. */
 302 #define READ_SIZE 160
 303
 304 #define MASK_AVAIL              (1 << 0)        /*!< Channel available for PRI use */
 305 #define MASK_INUSE              (1 << 1)        /*!< Channel currently in use */
 306
 307 #define CALLWAITING_SILENT_SAMPLES      ( (300 * 8) / READ_SIZE) /*!< 300 ms */
 308 #define CALLWAITING_REPEAT_SAMPLES      ( (10000 * 8) / READ_SIZE) /*!< 300 ms */
 309 #define CIDCW_EXPIRE_SAMPLES            ( (500 * 8) / READ_SIZE) /*!< 500 ms */
 310 #define MIN_MS_SINCE_FLASH                      ( (2000) )      /*!< 2000 ms */
 311 #define DEFAULT_RINGT                           ( (8000 * 8) / READ_SIZE)
 312
 313 struct zt_pvt;
 314
 315 static int ringt_base = DEFAULT_RINGT;
 316
 317 #ifdef HAVE_SS7
 318
 319 #define LINKSTATE_INALARM       (1 << 0)
 320 #define LINKSTATE_STARTING      (1 << 1)
 321 #define LINKSTATE_UP            (1 << 2)
 322 #define LINKSTATE_DOWN          (1 << 3)
 323
 324 #define SS7_NAI_DYNAMIC         -1
 325
 326 struct zt_ss7 {
 327         pthread_t master;                                               /*!< Thread of master */
 328         ast_mutex_t lock;
 329         int fds[NUM_DCHANS];
 330         int numsigchans;
 331         int linkstate[NUM_DCHANS];
 332         int numchans;
 333         int type;
 334         enum {
 335                 LINKSET_STATE_DOWN = 0,
 336                 LINKSET_STATE_UP
 337         } state;
 338         char called_nai;                                                /*!< Called Nature of Address Indicator */
 339         char calling_nai;                                               /*!< Calling Nature of Address Indicator */
 340         char internationalprefix[10];                                   /*!< country access code ('00' for european dialplans) */
 341         char nationalprefix[10];                                        /*!< area access code ('0' for european dialplans) */
 342         char subscriberprefix[20];                                      /*!< area access code + area code ('0'+area code for european dialplans) */
 343         char unknownprefix[20];                                         /*!< for unknown dialplans */
 344         struct ss7 *ss7;
 345         struct zt_pvt *pvts[MAX_CHANNELS];                              /*!< Member channel pvt structs */
 346 };
 347
 348 static struct zt_ss7 linksets[NUM_SPANS];
 349
 350 static int cur_ss7type = -1;
 351 static int cur_linkset = -1;
 352 static int cur_pointcode = -1;
 353 static int cur_cicbeginswith = -1;
 354 static int cur_adjpointcode = -1;
 355 static int cur_networkindicator = -1;
 356 static int cur_defaultdpc = -1;
 357 #endif /* HAVE_SS7 */
 358
 359 #ifdef HAVE_PRI
 360
 361 #define PVT_TO_CHANNEL(p) (((p)->prioffset) | ((p)->logicalspan << 8) | (p->pri->mastertrunkgroup ? 0x10000 : 0))
 362 #define PRI_CHANNEL(p) ((p) & 0xff)
 363 #define PRI_SPAN(p) (((p) >> 8) & 0xff)
 364 #define PRI_EXPLICIT(p) (((p) >> 16) & 0x01)
 365
 366 struct zt_pri {
 367         pthread_t master;                                               /*!< Thread of master */
 368         ast_mutex_t lock;                                               /*!< Mutex */
 369         char idleext[AST_MAX_EXTENSION];                                /*!< Where to idle extra calls */
 370         char idlecontext[AST_MAX_CONTEXT];                              /*!< What context to use for idle */
 371         char idledial[AST_MAX_EXTENSION];                               /*!< What to dial before dumping */
 372         int minunused;                                                  /*!< Min # of channels to keep empty */
 373         int minidle;                                                    /*!< Min # of "idling" calls to keep active */
 374         int nodetype;                                                   /*!< Node type */
 375         int switchtype;                                                 /*!< Type of switch to emulate */
 376         int nsf;                                                        /*!< Network-Specific Facilities */
 377         int dialplan;                                                   /*!< Dialing plan */
 378         int localdialplan;                                              /*!< Local dialing plan */
 379         char internationalprefix[10];                                   /*!< country access code ('00' for european dialplans) */
 380         char nationalprefix[10];                                        /*!< area access code ('0' for european dialplans) */
 381         char localprefix[20];                                           /*!< area access code + area code ('0'+area code for european dialplans) */
 382         char privateprefix[20];                                         /*!< for private dialplans */
 383         char unknownprefix[20];                                         /*!< for unknown dialplans */
 384         int dchannels[NUM_DCHANS];                                      /*!< What channel are the dchannels on */
 385         int trunkgroup;                                                 /*!< What our trunkgroup is */
 386         int mastertrunkgroup;                                           /*!< What trunk group is our master */
 387         int prilogicalspan;                                             /*!< Logical span number within trunk group */
 388         int numchans;                                                   /*!< Num of channels we represent */
 389         int overlapdial;                                                /*!< In overlap dialing mode */
 390         int facilityenable;                                             /*!< Enable facility IEs */
 391         struct pri *dchans[NUM_DCHANS];                                 /*!< Actual d-channels */
 392         int dchanavail[NUM_DCHANS];                                     /*!< Whether each channel is available */
 393         struct pri *pri;                                                /*!< Currently active D-channel */
 394         int debug;
 395         int fds[NUM_DCHANS];                                            /*!< FD's for d-channels */
 396         int offset;
 397         int span;
 398         int resetting;
 399         int resetpos;
 400         time_t lastreset;                                               /*!< time when unused channels were last reset */
 401         long resetinterval;                                             /*!< Interval (in seconds) for resetting unused channels */
 402         struct zt_pvt *pvts[MAX_CHANNELS];                              /*!< Member channel pvt structs */
 403         struct zt_pvt *crvs;                                            /*!< Member CRV structs */
 404         struct zt_pvt *crvend;                                          /*!< Pointer to end of CRV structs */
 405 };
 406
 407
 408 static struct zt_pri pris[NUM_SPANS];
 409
 410 #if 0
 411 #define DEFAULT_PRI_DEBUG (PRI_DEBUG_Q931_DUMP | PRI_DEBUG_Q921_DUMP | PRI_DEBUG_Q921_RAW | PRI_DEBUG_Q921_STATE)
 412 #else
 413 #define DEFAULT_PRI_DEBUG 0
 414 #endif
 415
 416 static inline void pri_rel(struct zt_pri *pri)
 417 {
 418         ast_mutex_unlock(&pri->lock);
 419 }
 420
 421 #else
 422 /*! Shut up the compiler */
 423 struct zt_pri;
 424 #endif
 425
 426 #define SUB_REAL        0                       /*!< Active call */
 427 #define SUB_CALLWAIT    1                       /*!< Call-Waiting call on hold */
 428 #define SUB_THREEWAY    2                       /*!< Three-way call */
 429
 430 /* Polarity states */
 431 #define POLARITY_IDLE   0
 432 #define POLARITY_REV    1
 433
 434
 435 static struct zt_distRings drings;
 436
 437 struct distRingData {
 438         int ring[3];
 439         int range;
 440 };
 441 struct ringContextData {
 442         char contextData[AST_MAX_CONTEXT];
 443 };
 444 struct zt_distRings {
 445         struct distRingData ringnum[3];
 446         struct ringContextData ringContext[3];
 447 };
 448
 449 static char *subnames[] = {
 450         "Real",
 451         "Callwait",
 452         "Threeway"
 453 };
 454
 455 struct zt_subchannel {
 456         int zfd;
 457         struct ast_channel *owner;
 458         int chan;
 459         short buffer[AST_FRIENDLY_OFFSET/2 + READ_SIZE];
 460         struct ast_frame f;             /*!< One frame for each channel.  How did this ever work before? */
 461         unsigned int needringing:1;
 462         unsigned int needbusy:1;
 463         unsigned int needcongestion:1;
 464         unsigned int needcallerid:1;
 465         unsigned int needanswer:1;
 466         unsigned int needflash:1;
 467         unsigned int needhold:1;
 468         unsigned int needunhold:1;
 469         unsigned int linear:1;
 470         unsigned int inthreeway:1;
 471         ZT_CONFINFO curconf;
 472 };
 473
 474 #define CONF_USER_REAL          (1 << 0)
 475 #define CONF_USER_THIRDCALL     (1 << 1)
 476
 477 #define MAX_SLAVES      4
 478
 479 static struct zt_pvt {
 480         ast_mutex_t lock;
 481         struct ast_channel *owner;                      /*!< Our current active owner (if applicable) */
 482                                                         /*!< Up to three channels can be associated with this call */
 483
 484         struct zt_subchannel sub_unused;                /*!< Just a safety precaution */
 485         struct zt_subchannel subs[3];                   /*!< Sub-channels */
 486         struct zt_confinfo saveconf;                    /*!< Saved conference info */
 487
 488         struct zt_pvt *slaves[MAX_SLAVES];              /*!< Slave to us (follows our conferencing) */
 489         struct zt_pvt *master;                          /*!< Master to us (we follow their conferencing) */
 490         int inconference;                               /*!< If our real should be in the conference */
 491
 492         int sig;                                        /*!< Signalling style */
 493         int radio;                                      /*!< radio type */
 494         int outsigmod;                                  /*!< Outbound Signalling style (modifier) */
 495         int oprmode;                                    /*!< "Operator Services" mode */
 496         struct zt_pvt *oprpeer;                         /*!< "Operator Services" peer tech_pvt ptr */
 497         float cid_rxgain;                                       /*!< "Gain to apply during caller id */
 498         float rxgain;
 499         float txgain;
 500         int tonezone;                                   /*!< tone zone for this chan, or -1 for default */
 501         struct zt_pvt *next;                            /*!< Next channel in list */
 502         struct zt_pvt *prev;                            /*!< Prev channel in list */
 503
 504         /* flags */
 505         unsigned int adsi:1;
 506         unsigned int answeronpolarityswitch:1;
 507         unsigned int busydetect:1;
 508         unsigned int callreturn:1;
 509         unsigned int callwaiting:1;
 510         unsigned int callwaitingcallerid:1;
 511         unsigned int cancallforward:1;
 512         unsigned int canpark:1;
 513         unsigned int confirmanswer:1;                   /*!< Wait for '#' to confirm answer */
 514         unsigned int destroy:1;
 515         unsigned int didtdd:1;                          /*!< flag to say its done it once */
 516         unsigned int dialednone:1;
 517         unsigned int dialing:1;
 518         unsigned int digital:1;
 519         unsigned int dnd:1;
 520         unsigned int echobreak:1;
 521         unsigned int echocanbridged:1;
 522         unsigned int echocanon:1;
 523         unsigned int faxhandled:1;                      /*!< Has a fax tone already been handled? */
 524         unsigned int firstradio:1;
 525         unsigned int hanguponpolarityswitch:1;
 526         unsigned int hardwaredtmf:1;
 527         unsigned int hidecallerid:1;
 528         unsigned int hidecalleridname:1;      /*!< Hide just the name not the number for legacy PBX use */
 529         unsigned int ignoredtmf:1;
 530         unsigned int immediate:1;                       /*!< Answer before getting digits? */
 531         unsigned int inalarm:1;
 532         unsigned int mate:1;                            /*!< flag to say its in MATE mode */
 533         unsigned int outgoing:1;
 534         /* unsigned int overlapdial:1;                  unused and potentially confusing */
 535         unsigned int permcallwaiting:1;
 536         unsigned int permhidecallerid:1;                /*!< Whether to hide our outgoing caller ID or not */
 537         unsigned int priindication_oob:1;
 538         unsigned int priexclusive:1;
 539         unsigned int pulse:1;
 540         unsigned int pulsedial:1;                       /*!< whether a pulse dial phone is detected */
 541         unsigned int restrictcid:1;                     /*!< Whether restrict the callerid -> only send ANI */
 542         unsigned int threewaycalling:1;
 543         unsigned int transfer:1;
 544         unsigned int use_callerid:1;                    /*!< Whether or not to use caller id on this channel */
 545         unsigned int use_callingpres:1;                 /*!< Whether to use the callingpres the calling switch sends */
 546         unsigned int usedistinctiveringdetection:1;
 547         unsigned int zaptrcallerid:1;                   /*!< should we use the callerid from incoming call on zap transfer or not */
 548         unsigned int transfertobusy:1;                  /*!< allow flash-transfers to busy channels */
 549         /* Channel state or unavilability flags */
 550         unsigned int inservice:1;
 551         unsigned int locallyblocked:1;
 552         unsigned int remotelyblocked:1;
 553 #if defined(HAVE_PRI)
 554         unsigned int alerting:1;
 555         unsigned int alreadyhungup:1;
 556         unsigned int isidlecall:1;
 557         unsigned int proceeding:1;
 558         unsigned int progress:1;
 559         unsigned int resetting:1;
 560         unsigned int setup_ack:1;
 561 #endif
 562         unsigned int use_smdi:1;                /* Whether to use SMDI on this channel */
 563         struct ast_smdi_interface *smdi_iface;  /* The serial port to listen for SMDI data on */
 564
 565         struct zt_distRings drings;
 566
 567         char context[AST_MAX_CONTEXT];
 568         char defcontext[AST_MAX_CONTEXT];
 569         char exten[AST_MAX_EXTENSION];
 570         char language[MAX_LANGUAGE];
 571         char mohinterpret[MAX_MUSICCLASS];
 572         char mohsuggest[MAX_MUSICCLASS];
 573 #ifdef PRI_ANI
 574         char cid_ani[AST_MAX_EXTENSION];
 575 #endif
 576         char cid_num[AST_MAX_EXTENSION];
 577         int cid_ton;                                    /*!< Type Of Number (TON) */
 578         char cid_name[AST_MAX_EXTENSION];
 579         char lastcid_num[AST_MAX_EXTENSION];
 580         char lastcid_name[AST_MAX_EXTENSION];
 581         char *origcid_num;                              /*!< malloced original callerid */
 582         char *origcid_name;                             /*!< malloced original callerid */
 583         char callwait_num[AST_MAX_EXTENSION];
 584         char callwait_name[AST_MAX_EXTENSION];
 585         char rdnis[AST_MAX_EXTENSION];
 586         char dnid[AST_MAX_EXTENSION];
 587         ast_group_t group;
 588         int law;
 589         int confno;                                     /*!< Our conference */
 590         int confusers;                                  /*!< Who is using our conference */
 591         int propconfno;                                 /*!< Propagated conference number */
 592         ast_group_t callgroup;
 593         ast_group_t pickupgroup;
 594         int channel;                                    /*!< Channel Number or CRV */
 595         int span;                                       /*!< Span number */
 596         time_t guardtime;                               /*!< Must wait this much time before using for new call */
 597         int cid_signalling;                             /*!< CID signalling type bell202 or v23 */
 598         int cid_start;                                  /*!< CID start indicator, polarity or ring */
 599         int callingpres;                                /*!< The value of callling presentation that we're going to use when placing a PRI call */
 600         int callwaitingrepeat;                          /*!< How many samples to wait before repeating call waiting */
 601         int cidcwexpire;                                /*!< When to expire our muting for CID/CW */
 602         unsigned char *cidspill;
 603         int cidpos;
 604         int cidlen;
 605         int ringt;
 606         int ringt_base;
 607         int stripmsd;
 608         int callwaitcas;
 609         int callwaitrings;
 610         int echocancel;
 611         int echotraining;
 612         char echorest[20];
 613         int busycount;
 614         int busy_tonelength;
 615         int busy_quietlength;
 616         int callprogress;
 617         struct timeval flashtime;                       /*!< Last flash-hook time */
 618         struct ast_dsp *dsp;
 619         int cref;                                       /*!< Call reference number */
 620         ZT_DIAL_OPERATION dop;
 621         int whichwink;                                  /*!< SIG_FEATDMF_TA Which wink are we on? */
 622         char finaldial[64];
 623         char accountcode[AST_MAX_ACCOUNT_CODE];         /*!< Account code */
 624         int amaflags;                                   /*!< AMA Flags */
 625         struct tdd_state *tdd;                          /*!< TDD flag */
 626         char call_forward[AST_MAX_EXTENSION];
 627         char mailbox[AST_MAX_EXTENSION];
 628         struct ast_event_sub *mwi_event_sub;
 629         char dialdest[256];
 630         int onhooktime;
 631         int msgstate;
 632         int distinctivering;                            /*!< Which distinctivering to use */
 633         int cidrings;                                   /*!< Which ring to deliver CID on */
 634         int dtmfrelax;                                  /*!< whether to run in relaxed DTMF mode */
 635         int fake_event;
 636         int polarityonanswerdelay;
 637         struct timeval polaritydelaytv;
 638         int sendcalleridafter;
 639 #ifdef HAVE_PRI
 640         struct zt_pri *pri;
 641         struct zt_pvt *bearer;
 642         struct zt_pvt *realcall;
 643         q931_call *call;
 644         int prioffset;
 645         int logicalspan;
 646 #endif
 647         int polarity;
 648         int dsp_features;
 649 #ifdef HAVE_SS7
 650         struct zt_ss7 *ss7;
 651         struct isup_call *ss7call;
 652         int transcap;
 653         int cic;                                                        /*!< CIC associated with channel */
 654         unsigned int dpc;                                               /*!< CIC's DPC */
 655 #endif
 656         char begindigit;
 657 } *iflist = NULL, *ifend = NULL;
 658
 659 /*! \brief Channel configuration from zapata.conf .
 660  * This struct is used for parsing the [channels] section of zapata.conf.
 661  * Generally there is a field here for every possible configuration item.
 662  *
 663  * The state of fields is saved along the parsing and whenever a 'channel'
 664  * statement is reached, the current zt_chan_conf is used to configure the
 665  * channel (struct zt_pvt)
 666  *
 667  * \see zt_chan_init for the default values.
 668  */
 669 struct zt_chan_conf {
 670         struct zt_pvt chan;
 671 #ifdef HAVE_PRI
 672         struct zt_pri pri;
 673 #endif
 674
 675 #ifdef HAVE_SS7
 676         struct zt_ss7 ss7;
 677 #endif
 678         ZT_PARAMS timing;
 679
 680         char smdi_port[SMDI_MAX_FILENAME_LEN];
 681 };
 682
 683 /** returns a new zt_chan_conf with default values (by-value) */
 684 static struct zt_chan_conf zt_chan_conf_default(void) {
 685         /* recall that if a field is not included here it is initialized
 686          * to 0 or equivalent
 687          */
 688         struct zt_chan_conf conf = {
 689 #ifdef HAVE_PRI
 690                 .pri = {
 691                         .nsf = PRI_NSF_NONE,
 692                         .switchtype = PRI_SWITCH_NI2,
 693                         .dialplan = PRI_NATIONAL_ISDN + 1,
 694                         .localdialplan = PRI_NATIONAL_ISDN + 1,
 695                         .nodetype = PRI_CPE,
 696
 697                         .minunused = 2,
 698                         .idleext = "",
 699                         .idledial = "",
 700                         .internationalprefix = "",
 701                         .nationalprefix = "",
 702                         .localprefix = "",
 703                         .privateprefix = "",
 704                         .unknownprefix = "",
 705
 706                         .resetinterval = 3600
 707                 },
 708 #endif
 709 #ifdef HAVE_SS7
 710                 .ss7 = {
 711                         .called_nai = SS7_NAI_NATIONAL,
 712                         .calling_nai = SS7_NAI_NATIONAL,
 713                         .internationalprefix = "",
 714                         .nationalprefix = "",
 715                         .subscriberprefix = "",
 716                         .unknownprefix = ""
 717                 },
 718 #endif
 719                 .chan = {
 720                         .context = "default",
 721                         .cid_num = "",
 722                         .cid_name = "",
 723                         .mohinterpret = "default",
 724                         .mohsuggest = "",
 725                         .transfertobusy = 1,
 726
 727                         .cid_signalling = CID_SIG_BELL,
 728                         .cid_start = CID_START_RING,
 729                         .zaptrcallerid = 0,
 730                         .use_callerid = 1,
 731                         .sig = -1,
 732                         .outsigmod = -1,
 733
 734                         .cid_rxgain = +5.0,
 735
 736                         .tonezone = -1,
 737
 738                         .echocancel = 1,
 739
 740                         .busycount = 3,
 741
 742                         .accountcode = "",
 743
 744                         .mailbox = "",
 745
 746
 747                         .polarityonanswerdelay = 600,
 748
 749                         .sendcalleridafter = DEFAULT_CIDRINGS
 750                 },
 751                 .timing = {
 752                         .prewinktime = -1,
 753                         .preflashtime = -1,
 754                         .winktime = -1,
 755                         .flashtime = -1,
 756                         .starttime = -1,
 757                         .rxwinktime = -1,
 758                         .rxflashtime = -1,
 759                         .debouncetime = -1
 760                 },
 761                 .smdi_port = "/dev/ttyS0",
 762         };
 763
 764         return conf;
 765 }
 766
 767
 768 static struct ast_channel *zt_request(const char *type, int format, void *data, int *cause);
 769 static int zt_digit_begin(struct ast_channel *ast, char digit);
 770 static int zt_digit_end(struct ast_channel *ast, char digit, unsigned int duration);
 771 static int zt_sendtext(struct ast_channel *c, const char *text);
 772 static int zt_call(struct ast_channel *ast, char *rdest, int timeout);
 773 static int zt_hangup(struct ast_channel *ast);
 774 static int zt_answer(struct ast_channel *ast);
 775 static struct ast_frame *zt_read(struct ast_channel *ast);
 776 static int zt_write(struct ast_channel *ast, struct ast_frame *frame);
 777 static struct ast_frame *zt_exception(struct ast_channel *ast);
 778 static int zt_indicate(struct ast_channel *chan, int condition, const void *data, size_t datalen);
 779 static int zt_fixup(struct ast_channel *oldchan, struct ast_channel *newchan);
 780 static int zt_setoption(struct ast_channel *chan, int option, void *data, int datalen);
 781 static int zt_func_read(struct ast_channel *chan, const char *function, char *data, char *buf, size_t len);
 782
 783 static const struct ast_channel_tech zap_tech = {
 784         .type = "Zap",
 785         .description = tdesc,
 786         .capabilities = AST_FORMAT_SLINEAR | AST_FORMAT_ULAW | AST_FORMAT_ALAW,
 787         .requester = zt_request,
 788         .send_digit_begin = zt_digit_begin,
 789         .send_digit_end = zt_digit_end,
 790         .send_text = zt_sendtext,
 791         .call = zt_call,
 792         .hangup = zt_hangup,
 793         .answer = zt_answer,
 794         .read = zt_read,
 795         .write = zt_write,
 796         .bridge = zt_bridge,
 797         .exception = zt_exception,
 798         .indicate = zt_indicate,
 799         .fixup = zt_fixup,
 800         .setoption = zt_setoption,
 801         .func_channel_read = zt_func_read,
 802 };
 803
 804 #ifdef HAVE_PRI
 805 #define GET_CHANNEL(p) ((p)->bearer ? (p)->bearer->channel : p->channel)
 806 #else
 807 #define GET_CHANNEL(p) ((p)->channel)
 808 #endif
 809
 810 struct zt_pvt *round_robin[32];
 811
 812 #ifdef HAVE_PRI
 813 static inline int pri_grab(struct zt_pvt *pvt, struct zt_pri *pri)
 814 {
 815         int res;
 816         /* Grab the lock first */
 817         do {
 818                 res = ast_mutex_trylock(&pri->lock);
 819                 if (res) {
 820                         ast_mutex_unlock(&pvt->lock);
 821                         /* Release the lock and try again */
 822                         usleep(1);
 823                         ast_mutex_lock(&pvt->lock);
 824                 }
 825         } while (res);
 826         /* Then break the poll */
 827         pthread_kill(pri->master, SIGURG);
 828         return 0;
 829 }
 830 #endif
 831
 832 #ifdef HAVE_SS7
 833 static inline void ss7_rel(struct zt_ss7 *ss7)
 834 {
 835         ast_mutex_unlock(&ss7->lock);
 836 }
 837
 838 static inline int ss7_grab(struct zt_pvt *pvt, struct zt_ss7 *pri)
 839 {
 840         int res;
 841         /* Grab the lock first */
 842         do {
 843                 res = ast_mutex_trylock(&pri->lock);
 844                 if (res) {
 845                         ast_mutex_unlock(&pvt->lock);
 846                         /* Release the lock and try again */
 847                         usleep(1);
 848                         ast_mutex_lock(&pvt->lock);
 849                 }
 850         } while (res);
 851         /* Then break the poll */
 852         pthread_kill(pri->master, SIGURG);
 853         return 0;
 854 }
 855 #endif
 856 #define NUM_CADENCE_MAX 25
 857 static int num_cadence = 4;
 858 static int user_has_defined_cadences = 0;
 859
 860 static struct zt_ring_cadence cadences[NUM_CADENCE_MAX] = {
 861         { { 125, 125, 2000, 4000 } },                   /*!< Quick chirp followed by normal ring */
 862         { { 250, 250, 500, 1000, 250, 250, 500, 4000 } }, /*!< British style ring */
 863         { { 125, 125, 125, 125, 125, 4000 } },  /*!< Three short bursts */
 864         { { 1000, 500, 2500, 5000 } },  /*!< Long ring */
 865 };
 866
 867 /*! \brief cidrings says in which pause to transmit the cid information, where the first pause
 868  * is 1, the second pause is 2 and so on.
 869  */
 870
 871 static int cidrings[NUM_CADENCE_MAX] = {
 872         2,                                                                              /*!< Right after first long ring */
 873         4,                                                                              /*!< Right after long part */
 874         3,                                                                              /*!< After third chirp */
 875         2,                                                                              /*!< Second spell */
 876 };
 877
 878 #define ISTRUNK(p) ((p->sig == SIG_FXSLS) || (p->sig == SIG_FXSKS) || \
 879                         (p->sig == SIG_FXSGS) || (p->sig == SIG_PRI))
 880
 881 #define CANBUSYDETECT(p) (ISTRUNK(p) || (p->sig & (SIG_EM | SIG_EM_E1 | SIG_SF)) /* || (p->sig & __ZT_SIG_FXO) */)
 882 #define CANPROGRESSDETECT(p) (ISTRUNK(p) || (p->sig & (SIG_EM | SIG_EM_E1 | SIG_SF)) /* || (p->sig & __ZT_SIG_FXO) */)
 883
 884 static int zt_get_index(struct ast_channel *ast, struct zt_pvt *p, int nullok)
 885 {
 886         int res;
 887         if (p->subs[0].owner == ast)
 888                 res = 0;
 889         else if (p->subs[1].owner == ast)
 890                 res = 1;
 891         else if (p->subs[2].owner == ast)
 892                 res = 2;
 893         else {
 894                 res = -1;
 895                 if (!nullok)
 896                         ast_log(LOG_WARNING, "Unable to get index, and nullok is not asserted\n");
 897         }
 898         return res;
 899 }
 900
 901 #ifdef HAVE_PRI
 902 static void wakeup_sub(struct zt_pvt *p, int a, struct zt_pri *pri)
 903 #else
 904 static void wakeup_sub(struct zt_pvt *p, int a, void *pri)
 905 #endif
 906 {
 907 #ifdef HAVE_PRI
 908         if (pri)
 909                 ast_mutex_unlock(&pri->lock);
 910 #endif
 911         for (;;) {
 912                 if (p->subs[a].owner) {
 913                         if (ast_mutex_trylock(&p->subs[a].owner->lock)) {
 914                                 ast_mutex_unlock(&p->lock);
 915                                 usleep(1);
 916                                 ast_mutex_lock(&p->lock);
 917                         } else {
 918                                 ast_queue_frame(p->subs[a].owner, &ast_null_frame);
 919                                 ast_mutex_unlock(&p->subs[a].owner->lock);
 920                                 break;
 921                         }
 922                 } else
 923                         break;
 924         }
 925 #ifdef HAVE_PRI
 926         if (pri)
 927                 ast_mutex_lock(&pri->lock);
 928 #endif
 929 }
 930
 931 static void zap_queue_frame(struct zt_pvt *p, struct ast_frame *f, void *data)
 932 {
 933 #ifdef HAVE_PRI
 934         struct zt_pri *pri = (struct zt_pri*) data;
 935 #endif
 936 #ifdef HAVE_SS7
 937         struct zt_ss7 *ss7 = (struct zt_ss7*) data;
 938 #endif
 939         /* We must unlock the PRI to avoid the possibility of a deadlock */
 940 #if defined(HAVE_PRI) || defined(HAVE_SS7)
 941         if (data) {
 942                 switch (p->sig) {
 943 #ifdef HAVE_PRI
 944                 case SIG_PRI:
 945                         ast_mutex_unlock(&pri->lock);
 946                         break;
 947 #endif
 948 #ifdef HAVE_SS7
 949                 case SIG_SS7:
 950                         ast_mutex_unlock(&ss7->lock);
 951                         break;
 952 #endif
 953                 default:
 954                         break;
 955                 }
 956         }
 957 #endif
 958         for (;;) {
 959                 if (p->owner) {
 960                         if (ast_mutex_trylock(&p->owner->lock)) {
 961                                 ast_mutex_unlock(&p->lock);
 962                                 usleep(1);
 963                                 ast_mutex_lock(&p->lock);
 964                         } else {
 965                                 ast_queue_frame(p->owner, f);
 966                                 ast_mutex_unlock(&p->owner->lock);
 967                                 break;
 968                         }
 969                 } else
 970                         break;
 971         }
 972 #if defined(HAVE_PRI) || defined(HAVE_SS7)
 973         if (data) {
 974                 switch (p->sig) {
 975 #ifdef HAVE_PRI
 976                 case SIG_PRI:
 977                         ast_mutex_lock(&pri->lock);
 978                         break;
 979 #endif
 980 #ifdef HAVE_SS7
 981                 case SIG_SS7:
 982                         ast_mutex_lock(&ss7->lock);
 983                         break;
 984 #endif
 985                 default:
 986                         break;
 987                 }
 988         }
 989
 990 #endif
 991 }
 992
 993 static int restore_gains(struct zt_pvt *p);
 994
 995 static void swap_subs(struct zt_pvt *p, int a, int b)
 996 {
 997         int tchan;
 998         int tinthreeway;
 999         struct ast_channel *towner;
1000
1001         ast_debug(1, "Swapping %d and %d\n", a, b);
1002
1003         tchan = p->subs[a].chan;
1004         towner = p->subs[a].owner;
1005         tinthreeway = p->subs[a].inthreeway;
1006
1007         p->subs[a].chan = p->subs[b].chan;
1008         p->subs[a].owner = p->subs[b].owner;
1009         p->subs[a].inthreeway = p->subs[b].inthreeway;
1010
1011         p->subs[b].chan = tchan;
1012         p->subs[b].owner = towner;
1013         p->subs[b].inthreeway = tinthreeway;
1014
1015         if (p->subs[a].owner)
1016                 ast_channel_set_fd(p->subs[a].owner, 0, p->subs[a].zfd);
1017         if (p->subs[b].owner)
1018                 ast_channel_set_fd(p->subs[b].owner, 0, p->subs[b].zfd);
1019         wakeup_sub(p, a, NULL);
1020         wakeup_sub(p, b, NULL);
1021 }
1022
1023 static int zt_open(char *fn)
1024 {
1025         int fd;
1026         int isnum;
1027         int chan = 0;
1028         int bs;
1029         int x;
1030         isnum = 1;
1031         for (x = 0; x < strlen(fn); x++) {
1032                 if (!isdigit(fn[x])) {
1033                         isnum = 0;
1034                         break;
1035                 }
1036         }
1037         if (isnum) {
1038                 chan = atoi(fn);
1039                 if (chan < 1) {
1040                         ast_log(LOG_WARNING, "Invalid channel number '%s'\n", fn);
1041                         return -1;
1042                 }
1043                 fn = "/dev/zap/channel";
1044         }
1045         fd = open(fn, O_RDWR | O_NONBLOCK);
1046         if (fd < 0) {
1047                 ast_log(LOG_WARNING, "Unable to open '%s': %s\n", fn, strerror(errno));
1048                 return -1;
1049         }
1050         if (chan) {
1051                 if (ioctl(fd, ZT_SPECIFY, &chan)) {
1052                         x = errno;
1053                         close(fd);
1054                         errno = x;
1055                         ast_log(LOG_WARNING, "Unable to specify channel %d: %s\n", chan, strerror(errno));
1056                         return -1;
1057                 }
1058         }
1059         bs = READ_SIZE;
1060         if (ioctl(fd, ZT_SET_BLOCKSIZE, &bs) == -1) return -1;
1061         return fd;
1062 }
1063
1064 static void zt_close(int fd)
1065 {
1066         if (fd > 0)
1067                 close(fd);
1068 }
1069
1070 static int zt_setlinear(int zfd, int linear)
1071 {
1072         int res;
1073         res = ioctl(zfd, ZT_SETLINEAR, &linear);
1074         if (res)
1075                 return res;
1076         return 0;
1077 }
1078
1079
1080 static int alloc_sub(struct zt_pvt *p, int x)
1081 {
1082         ZT_BUFFERINFO bi;
1083         int res;
1084         if (p->subs[x].zfd < 0) {
1085                 p->subs[x].zfd = zt_open("/dev/zap/pseudo");
1086                 if (p->subs[x].zfd > -1) {
1087                         res = ioctl(p->subs[x].zfd, ZT_GET_BUFINFO, &bi);
1088                         if (!res) {
1089                                 bi.txbufpolicy = ZT_POLICY_IMMEDIATE;
1090                                 bi.rxbufpolicy = ZT_POLICY_IMMEDIATE;
1091                                 bi.numbufs = numbufs;
1092                                 res = ioctl(p->subs[x].zfd, ZT_SET_BUFINFO, &bi);
1093                                 if (res < 0) {
1094                                         ast_log(LOG_WARNING, "Unable to set buffer policy on channel %d\n", x);
1095                                 }
1096                         } else
1097                                 ast_log(LOG_WARNING, "Unable to check buffer policy on channel %d\n", x);
1098                         if (ioctl(p->subs[x].zfd, ZT_CHANNO, &p->subs[x].chan) == 1) {
1099                                 ast_log(LOG_WARNING, "Unable to get channel number for pseudo channel on FD %d\n", p->subs[x].zfd);
1100                                 zt_close(p->subs[x].zfd);
1101                                 p->subs[x].zfd = -1;
1102                                 return -1;
1103                         }
1104                         ast_debug(1, "Allocated %s subchannel on FD %d channel %d\n", subnames[x], p->subs[x].zfd, p->subs[x].chan);
1105                         return 0;
1106                 } else
1107                         ast_log(LOG_WARNING, "Unable to open pseudo channel: %s\n", strerror(errno));
1108                 return -1;
1109         }
1110         ast_log(LOG_WARNING, "%s subchannel of %d already in use\n", subnames[x], p->channel);
1111         return -1;
1112 }
1113
1114 static int unalloc_sub(struct zt_pvt *p, int x)
1115 {
1116         if (!x) {
1117                 ast_log(LOG_WARNING, "Trying to unalloc the real channel %d?!?\n", p->channel);
1118                 return -1;
1119         }
1120         ast_debug(1, "Released sub %d of channel %d\n", x, p->channel);
1121         if (p->subs[x].zfd > -1) {
1122                 zt_close(p->subs[x].zfd);
1123         }
1124         p->subs[x].zfd = -1;
1125         p->subs[x].linear = 0;
1126         p->subs[x].chan = 0;
1127         p->subs[x].owner = NULL;
1128         p->subs[x].inthreeway = 0;
1129         p->polarity = POLARITY_IDLE;
1130         memset(&p->subs[x].curconf, 0, sizeof(p->subs[x].curconf));
1131         return 0;
1132 }
1133
1134 static int digit_to_dtmfindex(char digit)
1135 {
1136         if (isdigit(digit))
1137                 return ZT_TONE_DTMF_BASE + (digit - '0');
1138         else if (digit >= 'A' && digit <= 'D')
1139                 return ZT_TONE_DTMF_A + (digit - 'A');
1140         else if (digit >= 'a' && digit <= 'd')
1141                 return ZT_TONE_DTMF_A + (digit - 'a');
1142         else if (digit == '*')
1143                 return ZT_TONE_DTMF_s;
1144         else if (digit == '#')
1145                 return ZT_TONE_DTMF_p;
1146         else
1147                 return -1;
1148 }
1149
1150 static int zt_digit_begin(struct ast_channel *chan, char digit)
1151 {
1152         struct zt_pvt *pvt;
1153         int index;
1154         int dtmf = -1;
1155
1156         pvt = chan->tech_pvt;
1157
1158         ast_mutex_lock(&pvt->lock);
1159
1160         index = zt_get_index(chan, pvt, 0);
1161
1162         if ((index != SUB_REAL) || !pvt->owner)
1163                 goto out;
1164
1165 #ifdef HAVE_PRI
1166         if ((pvt->sig == SIG_PRI) && (chan->_state == AST_STATE_DIALING) && !pvt->proceeding) {
1167                 if (pvt->setup_ack) {
1168                         if (!pri_grab(pvt, pvt->pri)) {
1169                                 pri_information(pvt->pri->pri, pvt->call, digit);
1170                                 pri_rel(pvt->pri);
1171                         } else
1172                                 ast_log(LOG_WARNING, "Unable to grab PRI on span %d\n", pvt->span);
1173                 } else if (strlen(pvt->dialdest) < sizeof(pvt->dialdest) - 1) {
1174                         int res;
1175                         ast_debug(1, "Queueing digit '%c' since setup_ack not yet received\n", digit);
1176                         res = strlen(pvt->dialdest);
1177                         pvt->dialdest[res++] = digit;
1178                         pvt->dialdest[res] = '\0';
1179                 }
1180                 goto out;
1181         }
1182 #endif
1183         if ((dtmf = digit_to_dtmfindex(digit)) == -1)
1184                 goto out;
1185
1186         if (pvt->pulse || ioctl(pvt->subs[SUB_REAL].zfd, ZT_SENDTONE, &dtmf)) {
1187                 int res;
1188                 ZT_DIAL_OPERATION zo = {
1189                         .op = ZT_DIAL_OP_APPEND,
1190                 };
1191
1192                 zo.dialstr[0] = 'T';
1193                 zo.dialstr[1] = digit;
1194                 zo.dialstr[2] = '\0';
1195                 if ((res = ioctl(pvt->subs[SUB_REAL].zfd, ZT_DIAL, &zo)))
1196                         ast_log(LOG_WARNING, "Couldn't dial digit %c\n", digit);
1197                 else
1198                         pvt->dialing = 1;
1199         } else {
1200                 ast_debug(1, "Started VLDTMF digit '%c'\n", digit);
1201                 pvt->dialing = 1;
1202                 pvt->begindigit = digit;
1203         }
1204
1205 out:
1206         ast_mutex_unlock(&pvt->lock);
1207
1208         return 0;
1209 }
1210
1211 static int zt_digit_end(struct ast_channel *chan, char digit, unsigned int duration)
1212 {
1213         struct zt_pvt *pvt;
1214         int res = 0;
1215         int index;
1216         int x;
1217
1218         pvt = chan->tech_pvt;
1219
1220         ast_mutex_lock(&pvt->lock);
1221
1222         index = zt_get_index(chan, pvt, 0);
1223
1224         if ((index != SUB_REAL) || !pvt->owner || pvt->pulse)
1225                 goto out;
1226
1227 #ifdef HAVE_PRI
1228         /* This means that the digit was already sent via PRI signalling */
1229         if (pvt->sig == SIG_PRI && !pvt->begindigit)
1230                 goto out;
1231 #endif
1232
1233         if (pvt->begindigit) {
1234                 x = -1;
1235                 ast_debug(1, "Ending VLDTMF digit '%c'\n", digit);
1236                 res = ioctl(pvt->subs[SUB_REAL].zfd, ZT_SENDTONE, &x);
1237                 pvt->dialing = 0;
1238                 pvt->begindigit = 0;
1239         }
1240
1241 out:
1242         ast_mutex_unlock(&pvt->lock);
1243
1244         return res;
1245 }
1246
1247 static char *events[] = {
1248         "No event",
1249         "On hook",
1250         "Ring/Answered",
1251         "Wink/Flash",
1252         "Alarm",
1253         "No more alarm",
1254         "HDLC Abort",
1255         "HDLC Overrun",
1256         "HDLC Bad FCS",
1257         "Dial Complete",
1258         "Ringer On",
1259         "Ringer Off",
1260         "Hook Transition Complete",
1261         "Bits Changed",
1262         "Pulse Start",
1263         "Timer Expired",
1264         "Timer Ping",
1265         "Polarity Reversal",
1266         "Ring Begin",
1267 };
1268
1269 static struct {
1270         int alarm;
1271         char *name;
1272 } alarms[] = {
1273         { ZT_ALARM_RED, "Red Alarm" },
1274         { ZT_ALARM_YELLOW, "Yellow Alarm" },
1275         { ZT_ALARM_BLUE, "Blue Alarm" },
1276         { ZT_ALARM_RECOVER, "Recovering" },
1277         { ZT_ALARM_LOOPBACK, "Loopback" },
1278         { ZT_ALARM_NOTOPEN, "Not Open" },
1279         { ZT_ALARM_NONE, "None" },
1280 };
1281
1282 static char *alarm2str(int alarm)
1283 {
1284         int x;
1285         for (x = 0; x < sizeof(alarms) / sizeof(alarms[0]); x++) {
1286                 if (alarms[x].alarm & alarm)
1287                         return alarms[x].name;
1288         }
1289         return alarm ? "Unknown Alarm" : "No Alarm";
1290 }
1291
1292 static char *event2str(int event)
1293 {
1294         static char buf[256];
1295         if ((event < (sizeof(events) / sizeof(events[0]))) && (event > -1))
1296                 return events[event];
1297         sprintf(buf, "Event %d", event); /* safe */
1298         return buf;
1299 }
1300
1301 #ifdef HAVE_PRI
1302 static char *dialplan2str(int dialplan)
1303 {
1304         if (dialplan == -1 || dialplan == -2) {
1305                 return("Dynamically set dialplan in ISDN");
1306         }
1307         return (pri_plan2str(dialplan));
1308 }
1309 #endif
1310
1311 static char *zap_sig2str(int sig)
1312 {
1313         static char buf[256];
1314         switch (sig) {
1315         case SIG_EM:
1316                 return "E & M Immediate";
1317         case SIG_EMWINK:
1318                 return "E & M Wink";
1319         case SIG_EM_E1:
1320                 return "E & M E1";
1321         case SIG_FEATD:
1322                 return "Feature Group D (DTMF)";
1323         case SIG_FEATDMF:
1324                 return "Feature Group D (MF)";
1325         case SIG_FEATDMF_TA:
1326                 return "Feature Groud D (MF) Tandem Access";
1327         case SIG_FEATB:
1328                 return "Feature Group B (MF)";
1329         case SIG_E911:
1330                 return "E911 (MF)";
1331         case SIG_FGC_CAMA:
1332                 return "FGC/CAMA (Dialpulse)";
1333         case SIG_FGC_CAMAMF:
1334                 return "FGC/CAMA (MF)";
1335         case SIG_FXSLS:
1336                 return "FXS Loopstart";
1337         case SIG_FXSGS:
1338                 return "FXS Groundstart";
1339         case SIG_FXSKS:
1340                 return "FXS Kewlstart";
1341         case SIG_FXOLS:
1342                 return "FXO Loopstart";
1343         case SIG_FXOGS:
1344                 return "FXO Groundstart";
1345         case SIG_FXOKS:
1346                 return "FXO Kewlstart";
1347         case SIG_PRI:
1348                 return "PRI Signalling";
1349         case SIG_SS7:
1350                 return "SS7 Signalling";
1351         case SIG_SF:
1352                 return "SF (Tone) Signalling Immediate";
1353         case SIG_SFWINK:
1354                 return "SF (Tone) Signalling Wink";
1355         case SIG_SF_FEATD:
1356                 return "SF (Tone) Signalling with Feature Group D (DTMF)";
1357         case SIG_SF_FEATDMF:
1358                 return "SF (Tone) Signalling with Feature Group D (MF)";
1359         case SIG_SF_FEATB:
1360                 return "SF (Tone) Signalling with Feature Group B (MF)";
1361         case SIG_GR303FXOKS:
1362                 return "GR-303 Signalling with FXOKS";
1363         case SIG_GR303FXSKS:
1364                 return "GR-303 Signalling with FXSKS";
1365         case 0:
1366                 return "Pseudo Signalling";
1367         default:
1368                 snprintf(buf, sizeof(buf), "Unknown signalling %d", sig);
1369                 return buf;
1370         }
1371 }
1372
1373 #define sig2str zap_sig2str
1374
1375 static int conf_add(struct zt_pvt *p, struct zt_subchannel *c, int index, int slavechannel)
1376 {
1377         /* If the conference already exists, and we're already in it
1378            don't bother doing anything */
1379         ZT_CONFINFO zi;
1380
1381         memset(&zi, 0, sizeof(zi));
1382         zi.chan = 0;
1383
1384         if (slavechannel > 0) {
1385                 /* If we have only one slave, do a digital mon */
1386                 zi.confmode = ZT_CONF_DIGITALMON;
1387                 zi.confno = slavechannel;
1388         } else {
1389                 if (!index) {
1390                         /* Real-side and pseudo-side both participate in conference */
1391                         zi.confmode = ZT_CONF_REALANDPSEUDO | ZT_CONF_TALKER | ZT_CONF_LISTENER |
1392                                 ZT_CONF_PSEUDO_TALKER | ZT_CONF_PSEUDO_LISTENER;
1393                 } else
1394                         zi.confmode = ZT_CONF_CONF | ZT_CONF_TALKER | ZT_CONF_LISTENER;
1395                 zi.confno = p->confno;
1396         }
1397         if ((zi.confno == c->curconf.confno) && (zi.confmode == c->curconf.confmode))
1398                 return 0;
1399         if (c->zfd < 0)
1400                 return 0;
1401         if (ioctl(c->zfd, ZT_SETCONF, &zi)) {
1402                 ast_log(LOG_WARNING, "Failed to add %d to conference %d/%d\n", c->zfd, zi.confmode, zi.confno);
1403                 return -1;
1404         }
1405         if (slavechannel < 1) {
1406                 p->confno = zi.confno;
1407         }
1408         memcpy(&c->curconf, &zi, sizeof(c->curconf));
1409         ast_debug(1, "Added %d to conference %d/%d\n", c->zfd, c->curconf.confmode, c->curconf.confno);
1410         return 0;
1411 }
1412
1413 static int isourconf(struct zt_pvt *p, struct zt_subchannel *c)
1414 {
1415         /* If they're listening to our channel, they're ours */
1416         if ((p->channel == c->curconf.confno) && (c->curconf.confmode == ZT_CONF_DIGITALMON))
1417                 return 1;
1418         /* If they're a talker on our (allocated) conference, they're ours */
1419         if ((p->confno > 0) && (p->confno == c->curconf.confno) && (c->curconf.confmode & ZT_CONF_TALKER))
1420                 return 1;
1421         return 0;
1422 }
1423
1424 static int conf_del(struct zt_pvt *p, struct zt_subchannel *c, int index)
1425 {
1426         ZT_CONFINFO zi;
1427         if (/* Can't delete if there's no zfd */
1428                 (c->zfd < 0) ||
1429                 /* Don't delete from the conference if it's not our conference */
1430                 !isourconf(p, c)
1431                 /* Don't delete if we don't think it's conferenced at all (implied) */
1432                 ) return 0;
1433         memset(&zi, 0, sizeof(zi));
1434         zi.chan = 0;
1435         zi.confno = 0;
1436         zi.confmode = 0;
1437         if (ioctl(c->zfd, ZT_SETCONF, &zi)) {
1438                 ast_log(LOG_WARNING, "Failed to drop %d from conference %d/%d\n", c->zfd, c->curconf.confmode, c->curconf.confno);
1439                 return -1;
1440         }
1441         ast_debug(1, "Removed %d from conference %d/%d\n", c->zfd, c->curconf.confmode, c->curconf.confno);
1442         memcpy(&c->curconf, &zi, sizeof(c->curconf));
1443         return 0;
1444 }
1445
1446 static int isslavenative(struct zt_pvt *p, struct zt_pvt **out)
1447 {
1448         int x;
1449         int useslavenative;
1450         struct zt_pvt *slave = NULL;
1451         /* Start out optimistic */
1452         useslavenative = 1;
1453         /* Update conference state in a stateless fashion */
1454         for (x = 0; x < 3; x++) {
1455                 /* Any three-way calling makes slave native mode *definitely* out
1456                    of the question */
1457                 if ((p->subs[x].zfd > -1) && p->subs[x].inthreeway)
1458                         useslavenative = 0;
1459         }
1460         /* If we don't have any 3-way calls, check to see if we have
1461            precisely one slave */
1462         if (useslavenative) {
1463                 for (x = 0; x < MAX_SLAVES; x++) {
1464                         if (p->slaves[x]) {
1465                                 if (slave) {
1466                                         /* Whoops already have a slave!  No
1467                                            slave native and stop right away */
1468                                         slave = NULL;
1469                                         useslavenative = 0;
1470                                         break;
1471                                 } else {
1472                                         /* We have one slave so far */
1473                                         slave = p->slaves[x];
1474                                 }
1475                         }
1476                 }
1477         }
1478         /* If no slave, slave native definitely out */
1479         if (!slave)
1480                 useslavenative = 0;
1481         else if (slave->law != p->law) {
1482                 useslavenative = 0;
1483                 slave = NULL;
1484         }
1485         if (out)
1486                 *out = slave;
1487         return useslavenative;
1488 }
1489
1490 static int reset_conf(struct zt_pvt *p)
1491 {
1492         ZT_CONFINFO zi;
1493         memset(&zi, 0, sizeof(zi));
1494         p->confno = -1;
1495         memset(&p->subs[SUB_REAL].curconf, 0, sizeof(p->subs[SUB_REAL].curconf));
1496         if (p->subs[SUB_REAL].zfd > -1) {
1497                 if (ioctl(p->subs[SUB_REAL].zfd, ZT_SETCONF, &zi))
1498                         ast_log(LOG_WARNING, "Failed to reset conferencing on channel %d!\n", p->channel);
1499         }
1500         return 0;
1501 }
1502
1503 static int update_conf(struct zt_pvt *p)
1504 {
1505         int needconf = 0;
1506         int x;
1507         int useslavenative;
1508         struct zt_pvt *slave = NULL;
1509
1510         useslavenative = isslavenative(p, &slave);
1511         /* Start with the obvious, general stuff */
1512         for (x = 0; x < 3; x++) {
1513                 /* Look for three way calls */
1514                 if ((p->subs[x].zfd > -1) && p->subs[x].inthreeway) {
1515                         conf_add(p, &p->subs[x], x, 0);
1516                         needconf++;
1517                 } else {
1518                         conf_del(p, &p->subs[x], x);
1519                 }
1520         }
1521         /* If we have a slave, add him to our conference now. or DAX
1522            if this is slave native */
1523         for (x = 0; x < MAX_SLAVES; x++) {
1524                 if (p->slaves[x]) {
1525                         if (useslavenative)
1526                                 conf_add(p, &p->slaves[x]->subs[SUB_REAL], SUB_REAL, GET_CHANNEL(p));
1527                         else {
1528                                 conf_add(p, &p->slaves[x]->subs[SUB_REAL], SUB_REAL, 0);
1529                                 needconf++;
1530                         }
1531                 }
1532         }
1533         /* If we're supposed to be in there, do so now */
1534         if (p->inconference && !p->subs[SUB_REAL].inthreeway) {
1535                 if (useslavenative)
1536                         conf_add(p, &p->subs[SUB_REAL], SUB_REAL, GET_CHANNEL(slave));
1537                 else {
1538                         conf_add(p, &p->subs[SUB_REAL], SUB_REAL, 0);
1539                         needconf++;
1540                 }
1541         }
1542         /* If we have a master, add ourselves to his conference */
1543         if (p->master) {
1544                 if (isslavenative(p->master, NULL)) {
1545                         conf_add(p->master, &p->subs[SUB_REAL], SUB_REAL, GET_CHANNEL(p->master));
1546                 } else {
1547                         conf_add(p->master, &p->subs[SUB_REAL], SUB_REAL, 0);
1548                 }
1549         }
1550         if (!needconf) {
1551                 /* Nobody is left (or should be left) in our conference.
1552                    Kill it. */
1553                 p->confno = -1;
1554         }
1555         ast_debug(1, "Updated conferencing on %d, with %d conference users\n", p->channel, needconf);
1556         return 0;
1557 }
1558
1559 static void zt_enable_ec(struct zt_pvt *p)
1560 {
1561         int x;
1562         int res;
1563         if (!p)
1564                 return;
1565         if (p->echocanon) {
1566                 ast_debug(1, "Echo cancellation already on\n");
1567                 return;
1568         }
1569         if (p->digital) {
1570                 ast_debug(1, "Echo cancellation isn't required on digital connection\n");
1571                 return;
1572         }
1573         if (p->echocancel) {
1574                 if ((p->sig == SIG_PRI) || (p->sig == SIG_SS7)) {
1575                         x = 1;
1576                         res = ioctl(p->subs[SUB_REAL].zfd, ZT_AUDIOMODE, &x);
1577                         if (res)
1578                                 ast_log(LOG_WARNING, "Unable to enable echo cancellation on channel %d\n", p->channel);
1579                 }
1580                 x = p->echocancel;
1581                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_ECHOCANCEL, &x);
1582                 if (res)
1583                         ast_log(LOG_WARNING, "Unable to enable echo cancellation on channel %d\n", p->channel);
1584                 else {
1585                         p->echocanon = 1;
1586                         ast_debug(1, "Enabled echo cancellation on channel %d\n", p->channel);
1587                 }
1588         } else
1589                 ast_debug(1, "No echo cancellation requested\n");
1590 }
1591
1592 static void zt_train_ec(struct zt_pvt *p)
1593 {
1594         int x;
1595         int res;
1596         if (p && p->echocancel && p->echotraining) {
1597                 x = p->echotraining;
1598                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_ECHOTRAIN, &x);
1599                 if (res)
1600                         ast_log(LOG_WARNING, "Unable to request echo training on channel %d\n", p->channel);
1601                 else
1602                         ast_debug(1, "Engaged echo training on channel %d\n", p->channel);
1603         } else
1604                 ast_debug(1, "No echo training requested\n");
1605 }
1606
1607 static void zt_disable_ec(struct zt_pvt *p)
1608 {
1609         int x;
1610         int res;
1611         if (p->echocancel) {
1612                 x = 0;
1613                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_ECHOCANCEL, &x);
1614                 if (res)
1615                         ast_log(LOG_WARNING, "Unable to disable echo cancellation on channel %d\n", p->channel);
1616                 else
1617                         ast_debug(1, "disabled echo cancellation on channel %d\n", p->channel);
1618         }
1619         p->echocanon = 0;
1620 }
1621
1622 static void fill_txgain(struct zt_gains *g, float gain, int law)
1623 {
1624         int j;
1625         int k;
1626         float linear_gain = pow(10.0, gain / 20.0);
1627
1628         switch (law) {
1629         case ZT_LAW_ALAW:
1630                 for (j = 0; j < (sizeof(g->txgain) / sizeof(g->txgain[0])); j++) {
1631                         if (gain) {
1632                                 k = (int) (((float) AST_ALAW(j)) * linear_gain);
1633                                 if (k > 32767) k = 32767;
1634                                 if (k < -32767) k = -32767;
1635                                 g->txgain[j] = AST_LIN2A(k);
1636                         } else {
1637                                 g->txgain[j] = j;
1638                         }
1639                 }
1640                 break;
1641         case ZT_LAW_MULAW:
1642                 for (j = 0; j < (sizeof(g->txgain) / sizeof(g->txgain[0])); j++) {
1643                         if (gain) {
1644                                 k = (int) (((float) AST_MULAW(j)) * linear_gain);
1645                                 if (k > 32767) k = 32767;
1646                                 if (k < -32767) k = -32767;
1647                                 g->txgain[j] = AST_LIN2MU(k);
1648                         } else {
1649                                 g->txgain[j] = j;
1650                         }
1651                 }
1652                 break;
1653         }
1654 }
1655
1656 static void fill_rxgain(struct zt_gains *g, float gain, int law)
1657 {
1658         int j;
1659         int k;
1660         float linear_gain = pow(10.0, gain / 20.0);
1661
1662         switch (law) {
1663         case ZT_LAW_ALAW:
1664                 for (j = 0; j < (sizeof(g->rxgain) / sizeof(g->rxgain[0])); j++) {
1665                         if (gain) {
1666                                 k = (int) (((float) AST_ALAW(j)) * linear_gain);
1667                                 if (k > 32767) k = 32767;
1668                                 if (k < -32767) k = -32767;
1669                                 g->rxgain[j] = AST_LIN2A(k);
1670                         } else {
1671                                 g->rxgain[j] = j;
1672                         }
1673                 }
1674                 break;
1675         case ZT_LAW_MULAW:
1676                 for (j = 0; j < (sizeof(g->rxgain) / sizeof(g->rxgain[0])); j++) {
1677                         if (gain) {
1678                                 k = (int) (((float) AST_MULAW(j)) * linear_gain);
1679                                 if (k > 32767) k = 32767;
1680                                 if (k < -32767) k = -32767;
1681                                 g->rxgain[j] = AST_LIN2MU(k);
1682                         } else {
1683                                 g->rxgain[j] = j;
1684                         }
1685                 }
1686                 break;
1687         }
1688 }
1689
1690 static int set_actual_txgain(int fd, int chan, float gain, int law)
1691 {
1692         struct zt_gains g;
1693         int res;
1694
1695         memset(&g, 0, sizeof(g));
1696         g.chan = chan;
1697         res = ioctl(fd, ZT_GETGAINS, &g);
1698         if (res) {
1699                 ast_debug(1, "Failed to read gains: %s\n", strerror(errno));
1700                 return res;
1701         }
1702
1703         fill_txgain(&g, gain, law);
1704
1705         return ioctl(fd, ZT_SETGAINS, &g);
1706 }
1707
1708 static int set_actual_rxgain(int fd, int chan, float gain, int law)
1709 {
1710         struct zt_gains g;
1711         int res;
1712
1713         memset(&g, 0, sizeof(g));
1714         g.chan = chan;
1715         res = ioctl(fd, ZT_GETGAINS, &g);
1716         if (res) {
1717                 ast_debug(1, "Failed to read gains: %s\n", strerror(errno));
1718                 return res;
1719         }
1720
1721         fill_rxgain(&g, gain, law);
1722
1723         return ioctl(fd, ZT_SETGAINS, &g);
1724 }
1725
1726 static int set_actual_gain(int fd, int chan, float rxgain, float txgain, int law)
1727 {
1728         return set_actual_txgain(fd, chan, txgain, law) | set_actual_rxgain(fd, chan, rxgain, law);
1729 }
1730
1731 static int bump_gains(struct zt_pvt *p)
1732 {
1733         int res;
1734
1735         /* Bump receive gain by value stored in cid_rxgain */
1736         res = set_actual_gain(p->subs[SUB_REAL].zfd, 0, p->rxgain + p->cid_rxgain, p->txgain, p->law);
1737         if (res) {
1738                 ast_log(LOG_WARNING, "Unable to bump gain: %s\n", strerror(errno));
1739                 return -1;
1740         }
1741
1742         return 0;
1743 }
1744
1745 static int restore_gains(struct zt_pvt *p)
1746 {
1747         int res;
1748
1749         res = set_actual_gain(p->subs[SUB_REAL].zfd, 0, p->rxgain, p->txgain, p->law);
1750         if (res) {
1751                 ast_log(LOG_WARNING, "Unable to restore gains: %s\n", strerror(errno));
1752                 return -1;
1753         }
1754
1755         return 0;
1756 }
1757
1758 static inline int zt_set_hook(int fd, int hs)
1759 {
1760         int x, res;
1761
1762         x = hs;
1763         res = ioctl(fd, ZT_HOOK, &x);
1764
1765         if (res < 0) {
1766                 if (errno == EINPROGRESS)
1767                         return 0;
1768                 ast_log(LOG_WARNING, "zt hook failed: %s\n", strerror(errno));
1769         }
1770
1771         return res;
1772 }
1773
1774 static inline int zt_confmute(struct zt_pvt *p, int muted)
1775 {
1776         int x, y, res;
1777         x = muted;
1778         if ((p->sig == SIG_PRI) || (p->sig == SIG_SS7)) {
1779                 y = 1;
1780                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_AUDIOMODE, &y);
1781                 if (res)
1782                         ast_log(LOG_WARNING, "Unable to set audio mode on '%d'\n", p->channel);
1783         }
1784         res = ioctl(p->subs[SUB_REAL].zfd, ZT_CONFMUTE, &x);
1785         if (res < 0)
1786                 ast_log(LOG_WARNING, "zt confmute(%d) failed on channel %d: %s\n", muted, p->channel, strerror(errno));
1787         return res;
1788 }
1789
1790 static int save_conference(struct zt_pvt *p)
1791 {
1792         struct zt_confinfo c;
1793         int res;
1794         if (p->saveconf.confmode) {
1795                 ast_log(LOG_WARNING, "Can't save conference -- already in use\n");
1796                 return -1;
1797         }
1798         p->saveconf.chan = 0;
1799         res = ioctl(p->subs[SUB_REAL].zfd, ZT_GETCONF, &p->saveconf);
1800         if (res) {
1801                 ast_log(LOG_WARNING, "Unable to get conference info: %s\n", strerror(errno));
1802                 p->saveconf.confmode = 0;
1803                 return -1;
1804         }
1805         c.chan = 0;
1806         c.confno = 0;
1807         c.confmode = ZT_CONF_NORMAL;
1808         res = ioctl(p->subs[SUB_REAL].zfd, ZT_SETCONF, &c);
1809         if (res) {
1810                 ast_log(LOG_WARNING, "Unable to set conference info: %s\n", strerror(errno));
1811                 return -1;
1812         }
1813         ast_debug(1, "Disabled conferencing\n");
1814         return 0;
1815 }
1816
1817 static int restore_conference(struct zt_pvt *p)
1818 {
1819         int res;
1820         if (p->saveconf.confmode) {
1821                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_SETCONF, &p->saveconf);
1822                 p->saveconf.confmode = 0;
1823                 if (res) {
1824                         ast_log(LOG_WARNING, "Unable to restore conference info: %s\n", strerror(errno));
1825                         return -1;
1826                 }
1827         }
1828         ast_debug(1, "Restored conferencing\n");
1829         return 0;
1830 }
1831
1832 static int send_callerid(struct zt_pvt *p);
1833
1834 static int send_cwcidspill(struct zt_pvt *p)
1835 {
1836         p->callwaitcas = 0;
1837         p->cidcwexpire = 0;
1838         if (!(p->cidspill = ast_malloc(MAX_CALLERID_SIZE)))
1839                 return -1;
1840         p->cidlen = ast_callerid_callwaiting_generate(p->cidspill, p->callwait_name, p->callwait_num, AST_LAW(p));
1841         /* Make sure we account for the end */
1842         p->cidlen += READ_SIZE * 4;
1843         p->cidpos = 0;
1844         send_callerid(p);
1845         ast_verb(3, "CPE supports Call Waiting Caller*ID.  Sending '%s/%s'\n", p->callwait_name, p->callwait_num);
1846         return 0;
1847 }
1848
1849 static int has_voicemail(struct zt_pvt *p)
1850 {
1851         int new_msgs;
1852         struct ast_event *event;
1853         char *mailbox, *context;
1854
1855         mailbox = context = ast_strdupa(p->mailbox);
1856         strsep(&context, "@");
1857         if (ast_strlen_zero(context))
1858                 context = "default";
1859
1860         event = ast_event_get_cached(AST_EVENT_MWI,
1861                 AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_STR, mailbox,
1862                 AST_EVENT_IE_CONTEXT, AST_EVENT_IE_PLTYPE_STR, context,
1863                 AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_EXISTS,
1864                 AST_EVENT_IE_END);
1865
1866         if (event) {
1867                 new_msgs = ast_event_get_ie_uint(event, AST_EVENT_IE_NEWMSGS);
1868                 ast_event_destroy(event);
1869         } else
1870                 new_msgs = ast_app_has_voicemail(p->mailbox, NULL);
1871
1872         return new_msgs;
1873 }
1874
1875 static int send_callerid(struct zt_pvt *p)
1876 {
1877         /* Assumes spill in p->cidspill, p->cidlen in length and we're p->cidpos into it */
1878         int res;
1879         /* Take out of linear mode if necessary */
1880         if (p->subs[SUB_REAL].linear) {
1881                 p->subs[SUB_REAL].linear = 0;
1882                 zt_setlinear(p->subs[SUB_REAL].zfd, 0);
1883         }
1884         while (p->cidpos < p->cidlen) {
1885                 res = write(p->subs[SUB_REAL].zfd, p->cidspill + p->cidpos, p->cidlen - p->cidpos);
1886                 if (res < 0) {
1887                         if (errno == EAGAIN)
1888                                 return 0;
1889                         else {
1890                                 ast_log(LOG_WARNING, "write failed: %s\n", strerror(errno));
1891                                 return -1;
1892                         }
1893                 }
1894                 if (!res)
1895                         return 0;
1896                 p->cidpos += res;
1897         }
1898         ast_free(p->cidspill);
1899         p->cidspill = NULL;
1900         if (p->callwaitcas) {
1901                 /* Wait for CID/CW to expire */
1902                 p->cidcwexpire = CIDCW_EXPIRE_SAMPLES;
1903         } else
1904                 restore_conference(p);
1905         return 0;
1906 }
1907
1908 static int zt_callwait(struct ast_channel *ast)
1909 {
1910         struct zt_pvt *p = ast->tech_pvt;
1911         p->callwaitingrepeat = CALLWAITING_REPEAT_SAMPLES;
1912         if (p->cidspill) {
1913                 ast_log(LOG_WARNING, "Spill already exists?!?\n");
1914                 ast_free(p->cidspill);
1915         }
1916         if (!(p->cidspill = ast_malloc(2400 /* SAS */ + 680 /* CAS */ + READ_SIZE * 4)))
1917                 return -1;
1918         save_conference(p);
1919         /* Silence */
1920         memset(p->cidspill, 0x7f, 2400 + 600 + READ_SIZE * 4);
1921         if (!p->callwaitrings && p->callwaitingcallerid) {
1922                 ast_gen_cas(p->cidspill, 1, 2400 + 680, AST_LAW(p));
1923                 p->callwaitcas = 1;
1924                 p->cidlen = 2400 + 680 + READ_SIZE * 4;
1925         } else {
1926                 ast_gen_cas(p->cidspill, 1, 2400, AST_LAW(p));
1927                 p->callwaitcas = 0;
1928                 p->cidlen = 2400 + READ_SIZE * 4;
1929         }
1930         p->cidpos = 0;
1931         send_callerid(p);
1932
1933         return 0;
1934 }
1935
1936 #ifdef HAVE_SS7
1937 static unsigned char cid_pres2ss7pres(int cid_pres)
1938 {
1939          return (cid_pres >> 5) & 0x03;
1940 }
1941
1942 static unsigned char cid_pres2ss7screen(int cid_pres)
1943 {
1944         return cid_pres & 0x03;
1945 }
1946 #endif
1947
1948 static int zt_call(struct ast_channel *ast, char *rdest, int timeout)
1949 {
1950         struct zt_pvt *p = ast->tech_pvt;
1951         int x, res, index,mysig;
1952         char *c, *n, *l;
1953 #ifdef HAVE_PRI
1954         char *s = NULL;
1955 #endif
1956         char dest[256]; /* must be same length as p->dialdest */
1957         ast_mutex_lock(&p->lock);
1958         ast_copy_string(dest, rdest, sizeof(dest));
1959         ast_copy_string(p->dialdest, rdest, sizeof(p->dialdest));
1960         if ((ast->_state == AST_STATE_BUSY)) {
1961                 p->subs[SUB_REAL].needbusy = 1;
1962                 ast_mutex_unlock(&p->lock);
1963                 return 0;
1964         }
1965         if ((ast->_state != AST_STATE_DOWN) && (ast->_state != AST_STATE_RESERVED)) {
1966                 ast_log(LOG_WARNING, "zt_call called on %s, neither down nor reserved\n", ast->name);
1967                 ast_mutex_unlock(&p->lock);
1968                 return -1;
1969         }
1970         p->dialednone = 0;
1971         if ((p->radio || (p->oprmode < 0)))  /* if a radio channel, up immediately */
1972         {
1973                 /* Special pseudo -- automatically up */
1974                 ast_setstate(ast, AST_STATE_UP);
1975                 ast_mutex_unlock(&p->lock);
1976                 return 0;
1977         }
1978         x = ZT_FLUSH_READ | ZT_FLUSH_WRITE;
1979         res = ioctl(p->subs[SUB_REAL].zfd, ZT_FLUSH, &x);
1980         if (res)
1981                 ast_log(LOG_WARNING, "Unable to flush input on channel %d\n", p->channel);
1982         p->outgoing = 1;
1983
1984         set_actual_gain(p->subs[SUB_REAL].zfd, 0, p->rxgain, p->txgain, p->law);
1985
1986         mysig = p->sig;
1987         if (p->outsigmod > -1)
1988                 mysig = p->outsigmod;
1989
1990         switch (mysig) {
1991         case SIG_FXOLS:
1992         case SIG_FXOGS:
1993         case SIG_FXOKS:
1994                 if (p->owner == ast) {
1995                         /* Normal ring, on hook */
1996
1997                         /* Don't send audio while on hook, until the call is answered */
1998                         p->dialing = 1;
1999                         if (p->use_callerid) {
2000                                 /* Generate the Caller-ID spill if desired */
2001                                 if (p->cidspill) {
2002                                         ast_log(LOG_WARNING, "cidspill already exists??\n");
2003                                         ast_free(p->cidspill);
2004                                 }
2005                                 p->callwaitcas = 0;
2006                                 if ((p->cidspill = ast_malloc(MAX_CALLERID_SIZE))) {
2007                                         p->cidlen = ast_callerid_generate(p->cidspill, ast->cid.cid_name, ast->cid.cid_num, AST_LAW(p));
2008                                         p->cidpos = 0;
2009                                         send_callerid(p);
2010                                 }
2011                         }
2012                         /* Choose proper cadence */
2013                         if ((p->distinctivering > 0) && (p->distinctivering <= num_cadence)) {
2014                                 if (ioctl(p->subs[SUB_REAL].zfd, ZT_SETCADENCE, &cadences[p->distinctivering - 1]))
2015                                         ast_log(LOG_WARNING, "Unable to set distinctive ring cadence %d on '%s'\n", p->distinctivering, ast->name);
2016                                 p->cidrings = cidrings[p->distinctivering - 1];
2017                         } else {
2018                                 if (ioctl(p->subs[SUB_REAL].zfd, ZT_SETCADENCE, NULL))
2019                                         ast_log(LOG_WARNING, "Unable to reset default ring on '%s'\n", ast->name);
2020                                 p->cidrings = p->sendcalleridafter;
2021                         }
2022
2023                         /* nick@dccinc.com 4/3/03 mods to allow for deferred dialing */
2024                         c = strchr(dest, '/');
2025                         if (c)
2026                                 c++;
2027                         if (c && (strlen(c) < p->stripmsd)) {
2028                                 ast_log(LOG_WARNING, "Number '%s' is shorter than stripmsd (%d)\n", c, p->stripmsd);
2029                                 c = NULL;
2030                         }
2031                         if (c) {
2032                                 p->dop.op = ZT_DIAL_OP_REPLACE;
2033                                 snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "Tw%s", c);
2034                                 ast_debug(1, "FXO: setup deferred dialstring: %s\n", c);
2035                         } else {
2036                                 p->dop.dialstr[0] = '\0';
2037                         }
2038                         x = ZT_RING;
2039                         if (ioctl(p->subs[SUB_REAL].zfd, ZT_HOOK, &x) && (errno != EINPROGRESS)) {
2040                                 ast_log(LOG_WARNING, "Unable to ring phone: %s\n", strerror(errno));
2041                                 ast_mutex_unlock(&p->lock);
2042                                 return -1;
2043                         }
2044                         p->dialing = 1;
2045                 } else {
2046                         /* Call waiting call */
2047                         p->callwaitrings = 0;
2048                         if (ast->cid.cid_num)
2049                                 ast_copy_string(p->callwait_num, ast->cid.cid_num, sizeof(p->callwait_num));
2050                         else
2051                                 p->callwait_num[0] = '\0';
2052                         if (ast->cid.cid_name)
2053                                 ast_copy_string(p->callwait_name, ast->cid.cid_name, sizeof(p->callwait_name));
2054                         else
2055                                 p->callwait_name[0] = '\0';
2056                         /* Call waiting tone instead */
2057                         if (zt_callwait(ast)) {
2058                                 ast_mutex_unlock(&p->lock);
2059                                 return -1;
2060                         }
2061                         /* Make ring-back */
2062                         if (tone_zone_play_tone(p->subs[SUB_CALLWAIT].zfd, ZT_TONE_RINGTONE))
2063                                 ast_log(LOG_WARNING, "Unable to generate call-wait ring-back on channel %s\n", ast->name);
2064
2065                 }
2066                 n = ast->cid.cid_name;
2067                 l = ast->cid.cid_num;
2068                 if (l)
2069                         ast_copy_string(p->lastcid_num, l, sizeof(p->lastcid_num));
2070                 else
2071                         p->lastcid_num[0] = '\0';
2072                 if (n)
2073                         ast_copy_string(p->lastcid_name, n, sizeof(p->lastcid_name));
2074                 else
2075                         p->lastcid_name[0] = '\0';
2076                 ast_setstate(ast, AST_STATE_RINGING);
2077                 index = zt_get_index(ast, p, 0);
2078                 if (index > -1) {
2079                         p->subs[index].needringing = 1;
2080                 }
2081                 break;
2082         case SIG_FXSLS:
2083         case SIG_FXSGS:
2084         case SIG_FXSKS:
2085         case SIG_EMWINK:
2086         case SIG_EM:
2087         case SIG_EM_E1:
2088         case SIG_FEATD:
2089         case SIG_FEATDMF:
2090         case SIG_E911:
2091         case SIG_FGC_CAMA:
2092         case SIG_FGC_CAMAMF:
2093         case SIG_FEATB:
2094         case SIG_SFWINK:
2095         case SIG_SF:
2096         case SIG_SF_FEATD:
2097         case SIG_SF_FEATDMF:
2098         case SIG_FEATDMF_TA:
2099         case SIG_SF_FEATB:
2100                 c = strchr(dest, '/');
2101                 if (c)
2102                         c++;
2103                 else
2104                         c = "";
2105                 if (strlen(c) < p->stripmsd) {
2106                         ast_log(LOG_WARNING, "Number '%s' is shorter than stripmsd (%d)\n", c, p->stripmsd);
2107                         ast_mutex_unlock(&p->lock);
2108                         return -1;
2109                 }
2110 #ifdef HAVE_PRI
2111                 /* Start the trunk, if not GR-303 */
2112                 if (!p->pri) {
2113 #endif
2114                         x = ZT_START;
2115                         res = ioctl(p->subs[SUB_REAL].zfd, ZT_HOOK, &x);
2116                         if (res < 0) {
2117                                 if (errno != EINPROGRESS) {
2118                                         ast_log(LOG_WARNING, "Unable to start channel: %s\n", strerror(errno));
2119                                         ast_mutex_unlock(&p->lock);
2120                                         return -1;
2121                                 }
2122                         }
2123 #ifdef HAVE_PRI
2124                 }
2125 #endif
2126                 ast_debug(1, "Dialing '%s'\n", c);
2127                 p->dop.op = ZT_DIAL_OP_REPLACE;
2128
2129                 c += p->stripmsd;
2130
2131                 switch (mysig) {
2132                 case SIG_FEATD:
2133                         l = ast->cid.cid_num;
2134                         if (l)
2135                                 snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "T*%s*%s*", l, c);
2136                         else
2137                                 snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "T**%s*", c);
2138                         break;
2139                 case SIG_FEATDMF:
2140                         l = ast->cid.cid_num;
2141                         if (l)
2142                                 snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "M*00%s#*%s#", l, c);
2143                         else
2144                                 snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "M*02#*%s#", c);
2145                         break;
2146                 case SIG_FEATDMF_TA:
2147                 {
2148                         const char *cic, *ozz;
2149
2150                         /* If you have to go through a Tandem Access point you need to use this */
2151                         ozz = pbx_builtin_getvar_helper(p->owner, "FEATDMF_OZZ");
2152                         if (!ozz)
2153                                 ozz = defaultozz;
2154                         cic = pbx_builtin_getvar_helper(p->owner, "FEATDMF_CIC");
2155                         if (!cic)
2156                                 cic = defaultcic;
2157                         if (!ozz || !cic) {
2158                                 ast_log(LOG_WARNING, "Unable to dial channel of type feature group D MF tandem access without CIC or OZZ set\n");
2159                                 ast_mutex_unlock(&p->lock);
2160                                 return -1;
2161                         }
2162                         snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "M*%s%s#", ozz, cic);
2163                         snprintf(p->finaldial, sizeof(p->finaldial), "M*%s#", c);
2164                         p->whichwink = 0;
2165                 }
2166                         break;
2167                 case SIG_E911:
2168                         ast_copy_string(p->dop.dialstr, "M*911#", sizeof(p->dop.dialstr));
2169                         break;
2170                 case SIG_FGC_CAMA:
2171                         snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "P%s", c);
2172                         break;
2173                 case SIG_FGC_CAMAMF:
2174                 case SIG_FEATB:
2175                         snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "M*%s#", c);
2176                         break;
2177                 default:
2178                         if (p->pulse)
2179                                 snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "P%sw", c);
2180                         else
2181                                 snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "T%sw", c);
2182                         break;
2183                 }
2184
2185                 if (p->echotraining && (strlen(p->dop.dialstr) > 4)) {
2186                         memset(p->echorest, 'w', sizeof(p->echorest) - 1);
2187                         strcpy(p->echorest + (p->echotraining / 400) + 1, p->dop.dialstr + strlen(p->dop.dialstr) - 2);
2188                         p->echorest[sizeof(p->echorest) - 1] = '\0';
2189                         p->echobreak = 1;
2190                         p->dop.dialstr[strlen(p->dop.dialstr)-2] = '\0';
2191                 } else
2192                         p->echobreak = 0;
2193                 if (!res) {
2194                         if (ioctl(p->subs[SUB_REAL].zfd, ZT_DIAL, &p->dop)) {
2195                                 x = ZT_ONHOOK;
2196                                 ioctl(p->subs[SUB_REAL].zfd, ZT_HOOK, &x);
2197                                 ast_log(LOG_WARNING, "Dialing failed on channel %d: %s\n", p->channel, strerror(errno));
2198                                 ast_mutex_unlock(&p->lock);
2199                                 return -1;
2200                         }
2201                 } else
2202                         ast_debug(1, "Deferring dialing...\n");
2203
2204                 p->dialing = 1;
2205                 if (ast_strlen_zero(c))
2206                         p->dialednone = 1;
2207                 ast_setstate(ast, AST_STATE_DIALING);
2208                 break;
2209         case 0:
2210                 /* Special pseudo -- automatically up*/
2211                 ast_setstate(ast, AST_STATE_UP);
2212                 break;
2213         case SIG_PRI:
2214         case SIG_SS7:
2215                 /* We'll get it in a moment -- but use dialdest to store pre-setup_ack digits */
2216                 p->dialdest[0] = '\0';
2217                 break;
2218         default:
2219                 ast_debug(1, "not yet implemented\n");
2220                 ast_mutex_unlock(&p->lock);
2221                 return -1;
2222         }
2223 #ifdef HAVE_SS7
2224         if (p->ss7) {
2225                 char ss7_called_nai;
2226                 int called_nai_strip;
2227                 char ss7_calling_nai;
2228                 int calling_nai_strip;
2229
2230                 c = strchr(dest, '/');
2231                 if (c)
2232                         c++;
2233                 else
2234                         c = dest;
2235
2236                 if (!p->hidecallerid) {
2237                         l = ast->cid.cid_num;
2238                 } else {
2239                         l = NULL;
2240                 }
2241
2242                 if (ss7_grab(p, p->ss7)) {
2243                         ast_log(LOG_WARNING, "Failed to grab SS7!\n");
2244                         ast_mutex_unlock(&p->lock);
2245                         return -1;
2246                 }
2247                 p->digital = IS_DIGITAL(ast->transfercapability);
2248                 p->ss7call = isup_new_call(p->ss7->ss7);
2249
2250                 if (!p->ss7call) {
2251                         ss7_rel(p->ss7);
2252                         ast_mutex_unlock(&p->lock);
2253                         ast_log(LOG_ERROR, "Unable to allocate new SS7 call!\n");
2254                         return -1;
2255                 }
2256
2257                 called_nai_strip = 0;
2258                 ss7_called_nai = p->ss7->called_nai;
2259                 if (ss7_called_nai == SS7_NAI_DYNAMIC) { /* compute dynamically */
2260                         if (strncmp(c + p->stripmsd, p->ss7->internationalprefix, strlen(p->ss7->internationalprefix)) == 0) {
2261                                 called_nai_strip = strlen(p->ss7->internationalprefix);
2262                                 ss7_called_nai = SS7_NAI_INTERNATIONAL;
2263                         } else if (strncmp(c + p->stripmsd, p->ss7->nationalprefix, strlen(p->ss7->nationalprefix)) == 0) {
2264                                 called_nai_strip = strlen(p->ss7->nationalprefix);
2265                                 ss7_called_nai = SS7_NAI_NATIONAL;
2266                         } else {
2267                                 ss7_called_nai = SS7_NAI_SUBSCRIBER;
2268                         }
2269                 }
2270                 isup_set_called(p->ss7call, c + p->stripmsd + called_nai_strip, ss7_called_nai, p->ss7->ss7);
2271
2272                 calling_nai_strip = 0;
2273                 ss7_calling_nai = p->ss7->calling_nai;
2274                 if ((l != NULL) && (ss7_calling_nai == SS7_NAI_DYNAMIC)) { /* compute dynamically */
2275                         if (strncmp(l, p->ss7->internationalprefix, strlen(p->ss7->internationalprefix)) == 0) {
2276                                 calling_nai_strip = strlen(p->ss7->internationalprefix);
2277                                 ss7_calling_nai = SS7_NAI_INTERNATIONAL;
2278                         } else if (strncmp(l, p->ss7->nationalprefix, strlen(p->ss7->nationalprefix)) == 0) {
2279                                 calling_nai_strip = strlen(p->ss7->nationalprefix);
2280                                 ss7_calling_nai = SS7_NAI_NATIONAL;
2281                         } else {
2282                                 ss7_calling_nai = SS7_NAI_SUBSCRIBER;
2283                         }
2284                 }
2285                 isup_set_calling(p->ss7call, l ? (l + calling_nai_strip) : NULL, ss7_calling_nai,
2286                         p->use_callingpres ? cid_pres2ss7pres(ast->cid.cid_pres) : (l ? SS7_PRESENTATION_ALLOWED : SS7_PRESENTATION_RESTRICTED),
2287                         p->use_callingpres ? cid_pres2ss7screen(ast->cid.cid_pres) : SS7_SCREENING_USER_PROVIDED );
2288
2289                 isup_init_call(p->ss7->ss7, p->ss7call, p->cic, p->dpc);
2290
2291                 isup_iam(p->ss7->ss7, p->ss7call);
2292                 ast_setstate(ast, AST_STATE_DIALING);
2293                 ss7_rel(p->ss7);
2294         }
2295 #endif /* HAVE_SS7 */
2296 #ifdef HAVE_PRI
2297         if (p->pri) {
2298                 struct pri_sr *sr;
2299 #ifdef SUPPORT_USERUSER
2300                 const char *useruser;
2301 #endif
2302                 int pridialplan;
2303                 int dp_strip;
2304                 int prilocaldialplan;
2305                 int ldp_strip;
2306                 int exclusive;
2307                 const char *rr_str;
2308                 int redirect_reason;
2309
2310                 c = strchr(dest, '/');
2311                 if (c)
2312                         c++;
2313                 else
2314                         c = dest;
2315                 if (!p->hidecalleridname)
2316                         n = ast->cid.cid_name;
2317                 else
2318                         n = NULL;
2319                 if (!p->hidecallerid) {
2320                         l = ast->cid.cid_num;
2321                         n = ast->cid.cid_name;
2322                 } else {
2323                         l = NULL;
2324                         n = NULL;
2325                 }
2326                 if (strlen(c) < p->stripmsd) {
2327                         ast_log(LOG_WARNING, "Number '%s' is shorter than stripmsd (%d)\n", c, p->stripmsd);
2328                         ast_mutex_unlock(&p->lock);
2329                         return -1;
2330                 }
2331                 if (mysig != SIG_FXSKS) {
2332                         p->dop.op = ZT_DIAL_OP_REPLACE;
2333                         s = strchr(c + p->stripmsd, 'w');
2334                         if (s) {
2335                                 if (strlen(s) > 1)
2336                                         snprintf(p->dop.dialstr, sizeof(p->dop.dialstr), "T%s", s);
2337                                 else
2338                                         p->dop.dialstr[0] = '\0';
2339                                 *s = '\0';
2340                         } else {
2341                                 p->dop.dialstr[0] = '\0';
2342                         }
2343                 }
2344                 if (pri_grab(p, p->pri)) {
2345                         ast_log(LOG_WARNING, "Failed to grab PRI!\n");
2346                         ast_mutex_unlock(&p->lock);
2347                         return -1;
2348                 }
2349                 if (!(p->call = pri_new_call(p->pri->pri))) {
2350                         ast_log(LOG_WARNING, "Unable to create call on channel %d\n", p->channel);
2351                         pri_rel(p->pri);
2352                         ast_mutex_unlock(&p->lock);
2353                         return -1;
2354                 }
2355                 if (!(sr = pri_sr_new())) {
2356                         ast_log(LOG_WARNING, "Failed to allocate setup request channel %d\n", p->channel);
2357                         pri_rel(p->pri);
2358                         ast_mutex_unlock(&p->lock);
2359                 }
2360                 if (p->bearer || (mysig == SIG_FXSKS)) {
2361                         if (p->bearer) {
2362                                 ast_debug(1, "Oooh, I have a bearer on %d (%d:%d)\n", PVT_TO_CHANNEL(p->bearer), p->bearer->logicalspan, p->bearer->channel);
2363                                 p->bearer->call = p->call;
2364                         } else
2365                                 ast_debug(1, "I'm being setup with no bearer right now...\n");
2366
2367                         pri_set_crv(p->pri->pri, p->call, p->channel, 0);
2368                 }
2369                 p->digital = IS_DIGITAL(ast->transfercapability);
2370                 /* Add support for exclusive override */
2371                 if (p->priexclusive)
2372                         exclusive = 1;
2373                 else {
2374                 /* otherwise, traditional behavior */
2375                         if (p->pri->nodetype == PRI_NETWORK)
2376                                 exclusive = 0;
2377                         else
2378                                 exclusive = 1;
2379                 }
2380
2381                 pri_sr_set_channel(sr, p->bearer ? PVT_TO_CHANNEL(p->bearer) : PVT_TO_CHANNEL(p), exclusive, 1);
2382                 pri_sr_set_bearer(sr, p->digital ? PRI_TRANS_CAP_DIGITAL : ast->transfercapability,
2383                                         (p->digital ? -1 :
2384                                                 ((p->law == ZT_LAW_ALAW) ? PRI_LAYER_1_ALAW : PRI_LAYER_1_ULAW)));
2385                 if (p->pri->facilityenable)
2386                         pri_facility_enable(p->pri->pri);
2387
2388                 ast_verb(3, "Requested transfer capability: 0x%.2x - %s\n", ast->transfercapability, ast_transfercapability2str(ast->transfercapability));
2389                 dp_strip = 0;
2390                 pridialplan = p->pri->dialplan - 1;
2391                 if (pridialplan == -2 || pridialplan == -3) { /* compute dynamically */
2392                         if (strncmp(c + p->stripmsd, p->pri->internationalprefix, strlen(p->pri->internationalprefix)) == 0) {
2393                                 if (pridialplan == -2) {
2394                                         dp_strip = strlen(p->pri->internationalprefix);
2395                                 }
2396                                 pridialplan = PRI_INTERNATIONAL_ISDN;
2397                         } else if (strncmp(c + p->stripmsd, p->pri->nationalprefix, strlen(p->pri->nationalprefix)) == 0) {
2398                                 if (pridialplan == -2) {
2399                                         dp_strip = strlen(p->pri->nationalprefix);
2400                                 }
2401                                 pridialplan = PRI_NATIONAL_ISDN;
2402                         } else {
2403                                 pridialplan = PRI_LOCAL_ISDN;
2404                         }
2405                 }
2406                 pri_sr_set_called(sr, c + p->stripmsd + dp_strip, pridialplan, s ? 1 : 0);
2407
2408                 ldp_strip = 0;
2409                 prilocaldialplan = p->pri->localdialplan - 1;
2410                 if ((l != NULL) && (prilocaldialplan == -2 || prilocaldialplan == -3)) { /* compute dynamically */
2411                         if (strncmp(l, p->pri->internationalprefix, strlen(p->pri->internationalprefix)) == 0) {
2412                                 if (prilocaldialplan == -2) {
2413                                         ldp_strip = strlen(p->pri->internationalprefix);
2414                                 }
2415                                 prilocaldialplan = PRI_INTERNATIONAL_ISDN;
2416                         } else if (strncmp(l, p->pri->nationalprefix, strlen(p->pri->nationalprefix)) == 0) {
2417                                 if (prilocaldialplan == -2) {
2418                                         ldp_strip = strlen(p->pri->nationalprefix);
2419                                 }
2420                                 prilocaldialplan = PRI_NATIONAL_ISDN;
2421                         } else {
2422                                 prilocaldialplan = PRI_LOCAL_ISDN;
2423                         }
2424                 }
2425                 pri_sr_set_caller(sr, l ? (l + ldp_strip) : NULL, n, prilocaldialplan,
2426                         p->use_callingpres ? ast->cid.cid_pres : (l ? PRES_ALLOWED_USER_NUMBER_PASSED_SCREEN : PRES_NUMBER_NOT_AVAILABLE));
2427                 if ((rr_str = pbx_builtin_getvar_helper(ast, "PRIREDIRECTREASON"))) {
2428                         if (!strcasecmp(rr_str, "UNKNOWN"))
2429                                 redirect_reason = 0;
2430                         else if (!strcasecmp(rr_str, "BUSY"))
2431                                 redirect_reason = 1;
2432                         else if (!strcasecmp(rr_str, "NO_REPLY"))
2433                                 redirect_reason = 2;
2434                         else if (!strcasecmp(rr_str, "UNCONDITIONAL"))
2435                                 redirect_reason = 15;
2436                         else
2437                                 redirect_reason = PRI_REDIR_UNCONDITIONAL;
2438                 } else
2439                         redirect_reason = PRI_REDIR_UNCONDITIONAL;
2440                 pri_sr_set_redirecting(sr, ast->cid.cid_rdnis, p->pri->localdialplan - 1, PRES_ALLOWED_USER_NUMBER_PASSED_SCREEN, redirect_reason);
2441
2442 #ifdef SUPPORT_USERUSER
2443                 /* User-user info */
2444                 useruser = pbx_builtin_getvar_helper(p->owner, "USERUSERINFO");
2445
2446                 if (useruser)
2447                         pri_sr_set_useruser(sr, useruser);
2448 #endif
2449
2450                 if (pri_setup(p->pri->pri, p->call, sr)) {
2451                         ast_log(LOG_WARNING, "Unable to setup call to %s (using %s)\n",
2452                                 c + p->stripmsd + dp_strip, dialplan2str(p->pri->dialplan));
2453                         pri_rel(p->pri);
2454                         ast_mutex_unlock(&p->lock);
2455                         pri_sr_free(sr);
2456                         return -1;
2457                 }
2458                 pri_sr_free(sr);
2459                 ast_setstate(ast, AST_STATE_DIALING);
2460                 pri_rel(p->pri);
2461         }
2462 #endif
2463         ast_mutex_unlock(&p->lock);
2464         return 0;
2465 }
2466
2467 static void destroy_zt_pvt(struct zt_pvt **pvt)
2468 {
2469         struct zt_pvt *p = *pvt;
2470         /* Remove channel from the list */
2471         if (p->prev)
2472                 p->prev->next = p->next;
2473         if (p->next)
2474                 p->next->prev = p->prev;
2475         if (p->use_smdi)
2476                 ASTOBJ_UNREF(p->smdi_iface, ast_smdi_interface_destroy);
2477         if (p->mwi_event_sub)
2478                 ast_event_unsubscribe(p->mwi_event_sub);
2479         ast_mutex_destroy(&p->lock);
2480         ast_free(p);
2481         *pvt = NULL;
2482 }
2483
2484 static int destroy_channel(struct zt_pvt *prev, struct zt_pvt *cur, int now)
2485 {
2486         int owned = 0;
2487         int i = 0;
2488
2489         if (!now) {
2490                 if (cur->owner) {
2491                         owned = 1;
2492                 }
2493
2494                 for (i = 0; i < 3; i++) {
2495                         if (cur->subs[i].owner) {
2496                                 owned = 1;
2497                         }
2498                 }
2499                 if (!owned) {
2500                         if (prev) {
2501                                 prev->next = cur->next;
2502                                 if (prev->next)
2503                                         prev->next->prev = prev;
2504                                 else
2505                                         ifend = prev;
2506                         } else {
2507                                 iflist = cur->next;
2508                                 if (iflist)
2509                                         iflist->prev = NULL;
2510                                 else
2511                                         ifend = NULL;
2512                         }
2513                         if (cur->subs[SUB_REAL].zfd > -1) {
2514                                 zt_close(cur->subs[SUB_REAL].zfd);
2515                         }
2516                         destroy_zt_pvt(&cur);
2517                 }
2518         } else {
2519                 if (prev) {
2520                         prev->next = cur->next;
2521                         if (prev->next)
2522                                 prev->next->prev = prev;
2523                         else
2524                                 ifend = prev;
2525                 } else {
2526                         iflist = cur->next;
2527                         if (iflist)
2528                                 iflist->prev = NULL;
2529                         else
2530                                 ifend = NULL;
2531                 }
2532                 if (cur->subs[SUB_REAL].zfd > -1) {
2533                         zt_close(cur->subs[SUB_REAL].zfd);
2534                 }
2535                 destroy_zt_pvt(&cur);
2536         }
2537         return 0;
2538 }
2539
2540 #ifdef HAVE_PRI
2541 static char *zap_send_keypad_facility_app = "ZapSendKeypadFacility";
2542
2543 static char *zap_send_keypad_facility_synopsis = "Send digits out of band over a PRI";
2544
2545 static char *zap_send_keypad_facility_descrip =
2546 "  ZapSendKeypadFacility(): This application will send the given string of digits in a Keypad Facility\n"
2547 "  IE over the current channel.\n";
2548
2549 static int zap_send_keypad_facility_exec(struct ast_channel *chan, void *data)
2550 {
2551         /* Data will be our digit string */
2552         struct zt_pvt *p;
2553         char *digits = (char *) data;
2554
2555         if (ast_strlen_zero(digits)) {
2556                 ast_debug(1, "No digit string sent to application!\n");
2557                 return -1;
2558         }
2559
2560         p = (struct zt_pvt *)chan->tech_pvt;
2561
2562         if (!p) {
2563                 ast_debug(1, "Unable to find technology private\n");
2564                 return -1;
2565         }
2566
2567         ast_mutex_lock(&p->lock);
2568
2569         if (!p->pri || !p->call) {
2570                 ast_debug(1, "Unable to find pri or call on channel!\n");
2571                 ast_mutex_unlock(&p->lock);
2572                 return -1;
2573         }
2574
2575         if (!pri_grab(p, p->pri)) {
2576                 pri_keypad_facility(p->pri->pri, p->call, digits);
2577                 pri_rel(p->pri);
2578         } else {
2579                 ast_debug(1, "Unable to grab pri to send keypad facility!\n");
2580                 ast_mutex_unlock(&p->lock);
2581                 return -1;
2582         }
2583
2584         ast_mutex_unlock(&p->lock);
2585
2586         return 0;
2587 }
2588
2589 static int pri_is_up(struct zt_pri *pri)
2590 {
2591         int x;
2592         for (x = 0; x < NUM_DCHANS; x++) {
2593                 if (pri->dchanavail[x] == DCHAN_AVAILABLE)
2594                         return 1;
2595         }
2596         return 0;
2597 }
2598
2599 static int pri_assign_bearer(struct zt_pvt *crv, struct zt_pri *pri, struct zt_pvt *bearer)
2600 {
2601         bearer->owner = &inuse;
2602         bearer->realcall = crv;
2603         crv->subs[SUB_REAL].zfd = bearer->subs[SUB_REAL].zfd;
2604         if (crv->subs[SUB_REAL].owner)
2605                 ast_channel_set_fd(crv->subs[SUB_REAL].owner, 0, crv->subs[SUB_REAL].zfd);
2606         crv->bearer = bearer;
2607         crv->call = bearer->call;
2608         crv->pri = pri;
2609         return 0;
2610 }
2611
2612 static char *pri_order(int level)
2613 {
2614         switch (level) {
2615         case 0:
2616                 return "Primary";
2617         case 1:
2618                 return "Secondary";
2619         case 2:
2620                 return "Tertiary";
2621         case 3:
2622                 return "Quaternary";
2623         default:
2624                 return "<Unknown>";
2625         }
2626 }
2627
2628 /* Returns fd of the active dchan */
2629 static int pri_active_dchan_fd(struct zt_pri *pri)
2630 {
2631         int x = -1;
2632
2633         for (x = 0; x < NUM_DCHANS; x++) {
2634                 if ((pri->dchans[x] == pri->pri))
2635                         break;
2636         }
2637
2638         return pri->fds[x];
2639 }
2640
2641 static int pri_find_dchan(struct zt_pri *pri)
2642 {
2643         int oldslot = -1;
2644         struct pri *old;
2645         int newslot = -1;
2646         int x;
2647         old = pri->pri;
2648         for (x = 0; x < NUM_DCHANS; x++) {
2649                 if ((pri->dchanavail[x] == DCHAN_AVAILABLE) && (newslot < 0))
2650                         newslot = x;
2651                 if (pri->dchans[x] == old) {
2652                         oldslot = x;
2653                 }
2654         }
2655         if (newslot < 0) {
2656                 newslot = 0;
2657                 ast_log(LOG_WARNING, "No D-channels available!  Using Primary channel %d as D-channel anyway!\n",
2658                         pri->dchannels[newslot]);
2659         }
2660         if (old && (oldslot != newslot))
2661                 ast_log(LOG_NOTICE, "Switching from from d-channel %d to channel %d!\n",
2662                         pri->dchannels[oldslot], pri->dchannels[newslot]);
2663         pri->pri = pri->dchans[newslot];
2664         return 0;
2665 }
2666 #endif
2667
2668 static int zt_hangup(struct ast_channel *ast)
2669 {
2670         int res;
2671         int index,x, law;
2672         /*static int restore_gains(struct zt_pvt *p);*/
2673         struct zt_pvt *p = ast->tech_pvt;
2674         struct zt_pvt *tmp = NULL;
2675         struct zt_pvt *prev = NULL;
2676         ZT_PARAMS par;
2677
2678         ast_debug(1, "zt_hangup(%s)\n", ast->name);
2679         if (!ast->tech_pvt) {
2680                 ast_log(LOG_WARNING, "Asked to hangup channel not connected\n");
2681                 return 0;
2682         }
2683
2684         ast_mutex_lock(&p->lock);
2685
2686         index = zt_get_index(ast, p, 1);
2687
2688         if ((p->sig == SIG_PRI) || (p->sig == SIG_SS7)) {
2689                 x = 1;
2690                 ast_channel_setoption(ast,AST_OPTION_AUDIO_MODE,&x,sizeof(char),0);
2691         }
2692
2693         x = 0;
2694         zt_confmute(p, 0);
2695         restore_gains(p);
2696         if (p->origcid_num) {
2697                 ast_copy_string(p->cid_num, p->origcid_num, sizeof(p->cid_num));
2698                 ast_free(p->origcid_num);
2699                 p->origcid_num = NULL;
2700         }
2701         if (p->origcid_name) {
2702                 ast_copy_string(p->cid_name, p->origcid_name, sizeof(p->cid_name));
2703                 ast_free(p->origcid_name);
2704                 p->origcid_name = NULL;
2705         }
2706         if (p->dsp)
2707                 ast_dsp_digitmode(p->dsp,DSP_DIGITMODE_DTMF | p->dtmfrelax);
2708         if (p->exten)
2709                 p->exten[0] = '\0';
2710
2711         ast_debug(1, "Hangup: channel: %d index = %d, normal = %d, callwait = %d, thirdcall = %d\n",
2712                 p->channel, index, p->subs[SUB_REAL].zfd, p->subs[SUB_CALLWAIT].zfd, p->subs[SUB_THREEWAY].zfd);
2713         p->ignoredtmf = 0;
2714
2715         if (index > -1) {
2716                 /* Real channel, do some fixup */
2717                 p->subs[index].owner = NULL;
2718                 p->subs[index].needanswer = 0;
2719                 p->subs[index].needflash = 0;
2720                 p->subs[index].needringing = 0;
2721                 p->subs[index].needbusy = 0;
2722                 p->subs[index].needcongestion = 0;
2723                 p->subs[index].linear = 0;
2724                 p->subs[index].needcallerid = 0;
2725                 p->polarity = POLARITY_IDLE;
2726                 zt_setlinear(p->subs[index].zfd, 0);
2727                 if (index == SUB_REAL) {
2728                         if ((p->subs[SUB_CALLWAIT].zfd > -1) && (p->subs[SUB_THREEWAY].zfd > -1)) {
2729                                 ast_debug(1, "Normal call hung up with both three way call and a call waiting call in place?\n");
2730                                 if (p->subs[SUB_CALLWAIT].inthreeway) {
2731                                         /* We had flipped over to answer a callwait and now it's gone */
2732                                         ast_debug(1, "We were flipped over to the callwait, moving back and unowning.\n");
2733                                         /* Move to the call-wait, but un-own us until they flip back. */
2734                                         swap_subs(p, SUB_CALLWAIT, SUB_REAL);
2735                                         unalloc_sub(p, SUB_CALLWAIT);
2736                                         p->owner = NULL;
2737                                 } else {
2738                                         /* The three way hung up, but we still have a call wait */
2739                                         ast_debug(1, "We were in the threeway and have a callwait still.  Ditching the threeway.\n");
2740                                         swap_subs(p, SUB_THREEWAY, SUB_REAL);
2741                                         unalloc_sub(p, SUB_THREEWAY);
2742                                         if (p->subs[SUB_REAL].inthreeway) {
2743                                                 /* This was part of a three way call.  Immediately make way for
2744                                                    another call */
2745                                                 ast_debug(1, "Call was complete, setting owner to former third call\n");
2746                                                 p->owner = p->subs[SUB_REAL].owner;
2747                                         } else {
2748                                                 /* This call hasn't been completed yet...  Set owner to NULL */
2749                                                 ast_debug(1, "Call was incomplete, setting owner to NULL\n");
2750                                                 p->owner = NULL;
2751                                         }
2752                                         p->subs[SUB_REAL].inthreeway = 0;
2753                                 }
2754                         } else if (p->subs[SUB_CALLWAIT].zfd > -1) {
2755                                 /* Move to the call-wait and switch back to them. */
2756                                 swap_subs(p, SUB_CALLWAIT, SUB_REAL);
2757                                 unalloc_sub(p, SUB_CALLWAIT);
2758                                 p->owner = p->subs[SUB_REAL].owner;
2759                                 if (p->owner->_state != AST_STATE_UP)
2760                                         p->subs[SUB_REAL].needanswer = 1;
2761                                 if (ast_bridged_channel(p->subs[SUB_REAL].owner))
2762                                         ast_queue_control(p->subs[SUB_REAL].owner, AST_CONTROL_UNHOLD);
2763                         } else if (p->subs[SUB_THREEWAY].zfd > -1) {
2764                                 swap_subs(p, SUB_THREEWAY, SUB_REAL);
2765                                 unalloc_sub(p, SUB_THREEWAY);
2766                                 if (p->subs[SUB_REAL].inthreeway) {
2767                                         /* This was part of a three way call.  Immediately make way for
2768                                            another call */
2769                                         ast_debug(1, "Call was complete, setting owner to former third call\n");
2770                                         p->owner = p->subs[SUB_REAL].owner;
2771                                 } else {
2772                                         /* This call hasn't been completed yet...  Set owner to NULL */
2773                                         ast_debug(1, "Call was incomplete, setting owner to NULL\n");
2774                                         p->owner = NULL;
2775                                 }
2776                                 p->subs[SUB_REAL].inthreeway = 0;
2777                         }
2778                 } else if (index == SUB_CALLWAIT) {
2779                         /* Ditch the holding callwait call, and immediately make it availabe */
2780                         if (p->subs[SUB_CALLWAIT].inthreeway) {
2781                                 /* This is actually part of a three way, placed on hold.  Place the third part
2782                                    on music on hold now */
2783                                 if (p->subs[SUB_THREEWAY].owner && ast_bridged_channel(p->subs[SUB_THREEWAY].owner)) {
2784                                         ast_queue_control_data(p->subs[SUB_THREEWAY].owner, AST_CONTROL_HOLD,
2785                                                 S_OR(p->mohsuggest, NULL),
2786                                                 !ast_strlen_zero(p->mohsuggest) ? strlen(p->mohsuggest) + 1 : 0);
2787                                 }
2788                                 p->subs[SUB_THREEWAY].inthreeway = 0;
2789                                 /* Make it the call wait now */
2790                                 swap_subs(p, SUB_CALLWAIT, SUB_THREEWAY);
2791                                 unalloc_sub(p, SUB_THREEWAY);
2792                         } else
2793                                 unalloc_sub(p, SUB_CALLWAIT);
2794                 } else if (index == SUB_THREEWAY) {
2795                         if (p->subs[SUB_CALLWAIT].inthreeway) {
2796                                 /* The other party of the three way call is currently in a call-wait state.
2797                                    Start music on hold for them, and take the main guy out of the third call */
2798                                 if (p->subs[SUB_CALLWAIT].owner && ast_bridged_channel(p->subs[SUB_CALLWAIT].owner)) {
2799                                         ast_queue_control_data(p->subs[SUB_CALLWAIT].owner, AST_CONTROL_HOLD,
2800                                                 S_OR(p->mohsuggest, NULL),
2801                                                 !ast_strlen_zero(p->mohsuggest) ? strlen(p->mohsuggest) + 1 : 0);
2802                                 }
2803                                 p->subs[SUB_CALLWAIT].inthreeway = 0;
2804                         }
2805                         p->subs[SUB_REAL].inthreeway = 0;
2806                         /* If this was part of a three way call index, let us make
2807                            another three way call */
2808                         unalloc_sub(p, SUB_THREEWAY);
2809                 } else {
2810                         /* This wasn't any sort of call, but how are we an index? */
2811                         ast_log(LOG_WARNING, "Index found but not any type of call?\n");
2812                 }
2813         }
2814
2815         if (!p->subs[SUB_REAL].owner && !p->subs[SUB_CALLWAIT].owner && !p->subs[SUB_THREEWAY].owner) {
2816                 p->owner = NULL;
2817                 p->ringt = 0;
2818                 p->distinctivering = 0;
2819                 p->confirmanswer = 0;
2820                 p->cidrings = 1;
2821                 p->outgoing = 0;
2822                 p->digital = 0;
2823                 p->faxhandled = 0;
2824                 p->pulsedial = 0;
2825                 p->onhooktime = time(NULL);
2826 #ifdef HAVE_PRI
2827                 p->proceeding = 0;
2828                 p->progress = 0;
2829                 p->alerting = 0;
2830                 p->setup_ack = 0;
2831 #endif
2832                 if (p->dsp) {
2833                         ast_dsp_free(p->dsp);
2834                         p->dsp = NULL;
2835                 }
2836
2837                 law = ZT_LAW_DEFAULT;
2838                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_SETLAW, &law);
2839                 if (res < 0)
2840                         ast_log(LOG_WARNING, "Unable to set law on channel %d to default\n", p->channel);
2841                 /* Perform low level hangup if no owner left */
2842 #ifdef HAVE_SS7
2843                 if (p->ss7) {
2844                         if (p->ss7call) {
2845                                 if (!ss7_grab(p, p->ss7)) {
2846                                         if (!p->alreadyhungup) {
2847                                                 const char *cause = pbx_builtin_getvar_helper(ast,"SS7_CAUSE");
2848                                                 int icause = ast->hangupcause ? ast->hangupcause : -1;
2849
2850                                                 if (cause) {
2851                                                         if (atoi(cause))
2852                                                                 icause = atoi(cause);
2853                                                 }
2854                                                 isup_rel(p->ss7->ss7, p->ss7call, icause);
2855                                                 ss7_rel(p->ss7);
2856                                                 p->alreadyhungup = 1;
2857                                         } else
2858                                                 ast_log(LOG_WARNING, "Trying to hangup twice!\n");
2859                                 } else {
2860                                         ast_log(LOG_WARNING, "Unable to grab SS7 on CIC %d\n", p->cic);
2861                                         res = -1;
2862                                 }
2863                         }
2864                 }
2865 #endif
2866 #ifdef HAVE_PRI
2867                 if (p->pri) {
2868 #ifdef SUPPORT_USERUSER
2869                         const char *useruser = pbx_builtin_getvar_helper(ast,"USERUSERINFO");
2870 #endif
2871
2872                         /* Make sure we have a call (or REALLY have a call in the case of a PRI) */
2873                         if (p->call && (!p->bearer || (p->bearer->call == p->call))) {
2874                                 if (!pri_grab(p, p->pri)) {
2875                                         if (p->alreadyhungup) {
2876                                                 ast_debug(1, "Already hungup...  Calling hangup once, and clearing call\n");
2877
2878 #ifdef SUPPORT_USERUSER
2879                                                 pri_call_set_useruser(p->call, useruser);
2880 #endif
2881
2882                                                 pri_hangup(p->pri->pri, p->call, -1);
2883                                                 p->call = NULL;
2884                                                 if (p->bearer)
2885                                                         p->bearer->call = NULL;
2886                                         } else {
2887                                                 const char *cause = pbx_builtin_getvar_helper(ast,"PRI_CAUSE");
2888                                                 int icause = ast->hangupcause ? ast->hangupcause : -1;
2889                                                 ast_debug(1, "Not yet hungup...  Calling hangup once with icause, and clearing call\n");
2890
2891 #ifdef SUPPORT_USERUSER
2892                                                 pri_call_set_useruser(p->call, useruser);
2893 #endif
2894
2895                                                 p->alreadyhungup = 1;
2896                                                 if (p->bearer)
2897                                                         p->bearer->alreadyhungup = 1;
2898                                                 if (cause) {
2899                                                         if (atoi(cause))
2900                                                                 icause = atoi(cause);
2901                                                 }
2902                                                 pri_hangup(p->pri->pri, p->call, icause);
2903                                         }
2904                                         if (res < 0)
2905                                                 ast_log(LOG_WARNING, "pri_disconnect failed\n");
2906                                         pri_rel(p->pri);
2907                                 } else {
2908                                         ast_log(LOG_WARNING, "Unable to grab PRI on span %d\n", p->span);
2909                                         res = -1;
2910                                 }
2911                         } else {
2912                                 if (p->bearer)
2913                                         ast_debug(1, "Bearer call is %p, while ours is still %p\n", p->bearer->call, p->call);
2914                                 p->call = NULL;
2915                                 res = 0;
2916                         }
2917                 }
2918 #endif
2919                 if (p->sig && ((p->sig != SIG_PRI) && (p->sig != SIG_SS7)))
2920                         res = zt_set_hook(p->subs[SUB_REAL].zfd, ZT_ONHOOK);
2921                 if (res < 0) {
2922                         ast_log(LOG_WARNING, "Unable to hangup line %s\n", ast->name);
2923                 }
2924                 switch (p->sig) {
2925                 case SIG_FXOGS:
2926                 case SIG_FXOLS:
2927                 case SIG_FXOKS:
2928                         res = ioctl(p->subs[SUB_REAL].zfd, ZT_GET_PARAMS, &par);
2929                         if (!res) {
2930 #if 0
2931                                 ast_debug(1, "Hanging up channel %d, offhook = %d\n", p->channel, par.rxisoffhook);
2932 #endif
2933                                 /* If they're off hook, try playing congestion */
2934                                 if ((par.rxisoffhook) && (!(p->radio || (p->oprmode < 0))))
2935                                         tone_zone_play_tone(p->subs[SUB_REAL].zfd, ZT_TONE_CONGESTION);
2936                                 else
2937                                         tone_zone_play_tone(p->subs[SUB_REAL].zfd, -1);
2938                         }
2939                         break;
2940                 case SIG_FXSGS:
2941                 case SIG_FXSLS:
2942                 case SIG_FXSKS:
2943                         /* Make sure we're not made available for at least two seconds assuming
2944                            we were actually used for an inbound or outbound call. */
2945                         if (ast->_state != AST_STATE_RESERVED) {
2946                                 time(&p->guardtime);
2947                                 p->guardtime += 2;
2948                         }
2949                         break;
2950                 default:
2951                         tone_zone_play_tone(p->subs[SUB_REAL].zfd, -1);
2952                 }
2953                 if (p->cidspill)
2954                         ast_free(p->cidspill);
2955                 if (p->sig)
2956                         zt_disable_ec(p);
2957                 x = 0;
2958                 ast_channel_setoption(ast,AST_OPTION_TONE_VERIFY,&x,sizeof(char),0);
2959                 ast_channel_setoption(ast,AST_OPTION_TDD,&x,sizeof(char),0);
2960                 p->didtdd = 0;
2961                 p->cidspill = NULL;
2962                 p->callwaitcas = 0;
2963                 p->callwaiting = p->permcallwaiting;
2964                 p->hidecallerid = p->permhidecallerid;
2965                 p->dialing = 0;
2966                 p->rdnis[0] = '\0';
2967                 update_conf(p);
2968                 reset_conf(p);
2969                 /* Restore data mode */
2970                 if ((p->sig == SIG_PRI) || (p->sig == SIG_SS7)) {
2971                         x = 0;
2972                         ast_channel_setoption(ast,AST_OPTION_AUDIO_MODE,&x,sizeof(char),0);
2973                 }
2974 #ifdef HAVE_PRI
2975                 if (p->bearer) {
2976                         ast_debug(1, "Freeing up bearer channel %d\n", p->bearer->channel);
2977                         /* Free up the bearer channel as well, and
2978                            don't use its file descriptor anymore */
2979                         update_conf(p->bearer);
2980                         reset_conf(p->bearer);
2981                         p->bearer->owner = NULL;
2982                         p->bearer->realcall = NULL;
2983                         p->bearer = NULL;
2984                         p->subs[SUB_REAL].zfd = -1;
2985                         p->pri = NULL;
2986                 }
2987 #endif
2988                 restart_monitor();
2989         }
2990
2991         p->callwaitingrepeat = 0;
2992         p->cidcwexpire = 0;
2993         p->oprmode = 0;
2994         ast->tech_pvt = NULL;
2995         ast_mutex_unlock(&p->lock);
2996         ast_module_unref(ast_module_info->self);
2997         ast_verb(3, "Hungup '%s'\n", ast->name);
2998
2999         ast_mutex_lock(&iflock);
3000         tmp = iflist;
3001         prev = NULL;
3002         if (p->destroy) {
3003                 while (tmp) {
3004                         if (tmp == p) {
3005                                 destroy_channel(prev, tmp, 0);
3006                                 break;
3007                         } else {
3008                                 prev = tmp;
3009                                 tmp = tmp->next;
3010                         }
3011                 }
3012         }
3013         ast_mutex_unlock(&iflock);
3014         return 0;
3015 }
3016
3017 static int zt_answer(struct ast_channel *ast)
3018 {
3019         struct zt_pvt *p = ast->tech_pvt;
3020         int res = 0;
3021         int index;
3022         int oldstate = ast->_state;
3023         ast_setstate(ast, AST_STATE_UP);
3024         ast_mutex_lock(&p->lock);
3025         index = zt_get_index(ast, p, 0);
3026         if (index < 0)
3027                 index = SUB_REAL;
3028         /* nothing to do if a radio channel */
3029         if ((p->radio || (p->oprmode < 0))) {
3030                 ast_mutex_unlock(&p->lock);
3031                 return 0;
3032         }
3033         switch (p->sig) {
3034         case SIG_FXSLS:
3035         case SIG_FXSGS:
3036         case SIG_FXSKS:
3037                 p->ringt = 0;
3038                 /* Fall through */
3039         case SIG_EM:
3040         case SIG_EM_E1:
3041         case SIG_EMWINK:
3042         case SIG_FEATD:
3043         case SIG_FEATDMF:
3044         case SIG_FEATDMF_TA:
3045         case SIG_E911:
3046         case SIG_FGC_CAMA:
3047         case SIG_FGC_CAMAMF:
3048         case SIG_FEATB:
3049         case SIG_SF:
3050         case SIG_SFWINK:
3051         case SIG_SF_FEATD:
3052         case SIG_SF_FEATDMF:
3053         case SIG_SF_FEATB:
3054         case SIG_FXOLS:
3055         case SIG_FXOGS:
3056         case SIG_FXOKS:
3057                 /* Pick up the line */
3058                 ast_debug(1, "Took %s off hook\n", ast->name);
3059                 if (p->hanguponpolarityswitch) {
3060                         p->polaritydelaytv = ast_tvnow();
3061                 }
3062                 res = zt_set_hook(p->subs[SUB_REAL].zfd, ZT_OFFHOOK);
3063                 tone_zone_play_tone(p->subs[index].zfd, -1);
3064                 p->dialing = 0;
3065                 if ((index == SUB_REAL) && p->subs[SUB_THREEWAY].inthreeway) {
3066                         if (oldstate == AST_STATE_RINGING) {
3067                                 ast_debug(1, "Finally swapping real and threeway\n");
3068                                 tone_zone_play_tone(p->subs[SUB_THREEWAY].zfd, -1);
3069                                 swap_subs(p, SUB_THREEWAY, SUB_REAL);
3070                                 p->owner = p->subs[SUB_REAL].owner;
3071                         }
3072                 }
3073                 if (p->sig & __ZT_SIG_FXS) {
3074                         zt_enable_ec(p);
3075                         zt_train_ec(p);
3076                 }
3077                 break;
3078 #ifdef HAVE_PRI
3079         case SIG_PRI:
3080                 /* Send a pri acknowledge */
3081                 if (!pri_grab(p, p->pri)) {
3082                         p->proceeding = 1;
3083                         res = pri_answer(p->pri->pri, p->call, 0, !p->digital);
3084                         pri_rel(p->pri);
3085                 } else {
3086                         ast_log(LOG_WARNING, "Unable to grab PRI on span %d\n", p->span);
3087                         res = -1;
3088                 }
3089                 break;
3090 #endif
3091 #ifdef HAVE_SS7
3092         case SIG_SS7:
3093                 if (!ss7_grab(p, p->ss7)) {
3094                         p->proceeding = 1;
3095                         res = isup_anm(p->ss7->ss7, p->ss7call);
3096                         ss7_rel(p->ss7);
3097                 } else {
3098                         ast_log(LOG_WARNING, "Unable to grab SS7 on span %d\n", p->span);
3099                         res = -1;
3100                 }
3101                 break;
3102 #endif
3103         case 0:
3104                 ast_mutex_unlock(&p->lock);
3105                 return 0;
3106         default:
3107                 ast_log(LOG_WARNING, "Don't know how to answer signalling %d (channel %d)\n", p->sig, p->channel);
3108                 res = -1;
3109         }
3110         ast_mutex_unlock(&p->lock);
3111         return res;
3112 }
3113
3114 static int zt_setoption(struct ast_channel *chan, int option, void *data, int datalen)
3115 {
3116         char *cp;
3117         signed char *scp;
3118         int x;
3119         int index;
3120         struct zt_pvt *p = chan->tech_pvt, *pp;
3121         struct oprmode *oprmode;
3122
3123
3124         /* all supported options require data */
3125         if (!data || (datalen < 1)) {
3126                 errno = EINVAL;
3127                 return -1;
3128         }
3129
3130         switch (option) {
3131         case AST_OPTION_TXGAIN:
3132                 scp = (signed char *) data;
3133                 index = zt_get_index(chan, p, 0);
3134                 if (index < 0) {
3135                         ast_log(LOG_WARNING, "No index in TXGAIN?\n");
3136                         return -1;
3137                 }
3138                 ast_debug(1, "Setting actual tx gain on %s to %f\n", chan->name, p->txgain + (float) *scp);
3139                 return set_actual_txgain(p->subs[index].zfd, 0, p->txgain + (float) *scp, p->law);
3140         case AST_OPTION_RXGAIN:
3141                 scp = (signed char *) data;
3142                 index = zt_get_index(chan, p, 0);
3143                 if (index < 0) {
3144                         ast_log(LOG_WARNING, "No index in RXGAIN?\n");
3145                         return -1;
3146                 }
3147                 ast_debug(1, "Setting actual rx gain on %s to %f\n", chan->name, p->rxgain + (float) *scp);
3148                 return set_actual_rxgain(p->subs[index].zfd, 0, p->rxgain + (float) *scp, p->law);
3149         case AST_OPTION_TONE_VERIFY:
3150                 if (!p->dsp)
3151                         break;
3152                 cp = (char *) data;
3153                 switch (*cp) {
3154                 case 1:
3155                         ast_debug(1, "Set option TONE VERIFY, mode: MUTECONF(1) on %s\n",chan->name);
3156                         ast_dsp_digitmode(p->dsp,DSP_DIGITMODE_MUTECONF | p->dtmfrelax);  /* set mute mode if desired */
3157                         break;
3158                 case 2:
3159                         ast_debug(1, "Set option TONE VERIFY, mode: MUTECONF/MAX(2) on %s\n",chan->name);
3160                         ast_dsp_digitmode(p->dsp,DSP_DIGITMODE_MUTECONF | DSP_DIGITMODE_MUTEMAX | p->dtmfrelax);  /* set mute mode if desired */
3161                         break;
3162                 default:
3163                         ast_debug(1, "Set option TONE VERIFY, mode: OFF(0) on %s\n",chan->name);
3164                         ast_dsp_digitmode(p->dsp,DSP_DIGITMODE_DTMF | p->dtmfrelax);  /* set mute mode if desired */
3165                         break;
3166                 }
3167                 break;
3168         case AST_OPTION_TDD:
3169                 /* turn on or off TDD */
3170                 cp = (char *) data;
3171                 p->mate = 0;
3172                 if (!*cp) { /* turn it off */
3173                         ast_debug(1, "Set option TDD MODE, value: OFF(0) on %s\n",chan->name);
3174                         if (p->tdd)
3175                                 tdd_free(p->tdd);
3176                         p->tdd = 0;
3177                         break;
3178                 }
3179                 ast_debug(1, "Set option TDD MODE, value: %s(%d) on %s\n",
3180                         (*cp == 2) ? "MATE" : "ON", (int) *cp, chan->name);
3181                 zt_disable_ec(p);
3182                 /* otherwise, turn it on */
3183                 if (!p->didtdd) { /* if havent done it yet */
3184                         unsigned char mybuf[41000], *buf;
3185                         int size, res, fd, len;
3186                         struct pollfd fds[1];
3187
3188                         buf = mybuf;
3189                         memset(buf, 0x7f, sizeof(mybuf)); /* set to silence */
3190                         ast_tdd_gen_ecdisa(buf + 16000, 16000);  /* put in tone */
3191                         len = 40000;
3192                         index = zt_get_index(chan, p, 0);
3193                         if (index < 0) {
3194                                 ast_log(LOG_WARNING, "No index in TDD?\n");
3195                                 return -1;
3196                         }
3197                         fd = p->subs[index].zfd;
3198                         while (len) {
3199                                 if (ast_check_hangup(chan))
3200                                         return -1;
3201                                 size = len;
3202                                 if (size > READ_SIZE)
3203                                         size = READ_SIZE;
3204                                 fds[0].fd = fd;
3205                                 fds[0].events = POLLPRI | POLLOUT;
3206                                 fds[0].revents = 0;
3207                                 res = poll(fds, 1, -1);
3208                                 if (!res) {
3209                                         ast_debug(1, "poll (for write) ret. 0 on channel %d\n", p->channel);
3210                                         continue;
3211                                 }
3212                                 /* if got exception */
3213                                 if (fds[0].revents & POLLPRI)
3214                                         return -1;
3215                                 if (!(fds[0].revents & POLLOUT)) {
3216                                         ast_debug(1, "write fd not ready on channel %d\n", p->channel);
3217                                         continue;
3218                                 }
3219                                 res = write(fd, buf, size);
3220                                 if (res != size) {
3221                                         if (res == -1) return -1;
3222                                         ast_debug(1, "Write returned %d (%s) on channel %d\n", res, strerror(errno), p->channel);
3223                                         break;
3224                                 }
3225                                 len -= size;
3226                                 buf += size;
3227                         }
3228                         p->didtdd = 1; /* set to have done it now */
3229                 }
3230                 if (*cp == 2) { /* Mate mode */
3231                         if (p->tdd)
3232                                 tdd_free(p->tdd);
3233                         p->tdd = 0;
3234                         p->mate = 1;
3235                         break;
3236                 }
3237                 if (!p->tdd) { /* if we dont have one yet */
3238                         p->tdd = tdd_new(); /* allocate one */
3239                 }
3240                 break;
3241         case AST_OPTION_RELAXDTMF:  /* Relax DTMF decoding (or not) */
3242                 if (!p->dsp)
3243                         break;
3244                 cp = (char *) data;
3245                 ast_debug(1, "Set option RELAX DTMF, value: %s(%d) on %s\n",
3246                         *cp ? "ON" : "OFF", (int) *cp, chan->name);
3247                 ast_dsp_digitmode(p->dsp, ((*cp) ? DSP_DIGITMODE_RELAXDTMF : DSP_DIGITMODE_DTMF) | p->dtmfrelax);
3248                 break;
3249         case AST_OPTION_AUDIO_MODE:  /* Set AUDIO mode (or not) */
3250                 cp = (char *) data;
3251                 if (!*cp) {
3252                         ast_debug(1, "Set option AUDIO MODE, value: OFF(0) on %s\n", chan->name);
3253                         x = 0;
3254                         zt_disable_ec(p);
3255                 } else {
3256                         ast_debug(1, "Set option AUDIO MODE, value: ON(1) on %s\n", chan->name);
3257                         x = 1;
3258                 }
3259                 if (ioctl(p->subs[SUB_REAL].zfd, ZT_AUDIOMODE, &x) == -1)
3260                         ast_log(LOG_WARNING, "Unable to set audio mode on channel %d to %d\n", p->channel, x);
3261                 break;
3262         case AST_OPTION_OPRMODE:  /* Operator services mode */
3263                 oprmode = (struct oprmode *) data;
3264                 pp = oprmode->peer->tech_pvt;
3265                 p->oprmode = pp->oprmode = 0;
3266                 /* setup peers */
3267                 p->oprpeer = pp;
3268                 pp->oprpeer = p;
3269                 /* setup modes, if any */
3270                 if (oprmode->mode)
3271                 {
3272                         pp->oprmode = oprmode->mode;
3273                         p->oprmode = -oprmode->mode;
3274                 }
3275                 ast_debug(1, "Set Operator Services mode, value: %d on %s/%s\n",
3276                         oprmode->mode, chan->name,oprmode->peer->name);
3277                 break;
3278         case AST_OPTION_ECHOCAN:
3279                 cp = (char *) data;
3280                 if (*cp) {
3281                         ast_debug(1, "Enabling echo cancelation on %s\n", chan->name);
3282                         zt_enable_ec(p);
3283                 } else {
3284                         ast_debug(1, "Disabling echo cancelation on %s\n", chan->name);
3285                         zt_disable_ec(p);
3286                 }
3287                 break;
3288         }
3289         errno = 0;
3290
3291         return 0;
3292 }
3293
3294 static int zt_func_read(struct ast_channel *chan, const char *function, char *data, char *buf, size_t len)
3295 {
3296         struct zt_pvt *p = chan->tech_pvt;
3297
3298         if (!strcasecmp(data, "rxgain")) {
3299                 ast_mutex_lock(&p->lock);
3300                 snprintf(buf, len, "%f", p->rxgain);
3301                 ast_mutex_unlock(&p->lock);
3302         } else if (!strcasecmp(data, "txgain")) {
3303                 ast_mutex_lock(&p->lock);
3304                 snprintf(buf, len, "%f", p->txgain);
3305                 ast_mutex_unlock(&p->lock);
3306         } else {
3307                 ast_copy_string(buf, "", len);
3308         }
3309         return 0;
3310 }
3311
3312
3313 static void zt_unlink(struct zt_pvt *slave, struct zt_pvt *master, int needlock)
3314 {
3315         /* Unlink a specific slave or all slaves/masters from a given master */
3316         int x;
3317         int hasslaves;
3318         if (!master)
3319                 return;
3320         if (needlock) {
3321                 ast_mutex_lock(&master->lock);
3322                 if (slave) {
3323                         while (ast_mutex_trylock(&slave->lock)) {
3324                                 ast_mutex_unlock(&master->lock);
3325                                 usleep(1);
3326                                 ast_mutex_lock(&master->lock);
3327                         }
3328                 }
3329         }
3330         hasslaves = 0;
3331         for (x = 0; x < MAX_SLAVES; x++) {
3332                 if (master->slaves[x]) {
3333                         if (!slave || (master->slaves[x] == slave)) {
3334                                 /* Take slave out of the conference */
3335                                 ast_debug(1, "Unlinking slave %d from %d\n", master->slaves[x]->channel, master->channel);
3336                                 conf_del(master, &master->slaves[x]->subs[SUB_REAL], SUB_REAL);
3337                                 conf_del(master->slaves[x], &master->subs[SUB_REAL], SUB_REAL);
3338                                 master->slaves[x]->master = NULL;
3339                                 master->slaves[x] = NULL;
3340                         } else
3341                                 hasslaves = 1;
3342                 }
3343                 if (!hasslaves)
3344                         master->inconference = 0;
3345         }
3346         if (!slave) {
3347                 if (master->master) {
3348                         /* Take master out of the conference */
3349                         conf_del(master->master, &master->subs[SUB_REAL], SUB_REAL);
3350                         conf_del(master, &master->master->subs[SUB_REAL], SUB_REAL);
3351                         hasslaves = 0;
3352                         for (x = 0; x < MAX_SLAVES; x++) {
3353                                 if (master->master->slaves[x] == master)
3354                                         master->master->slaves[x] = NULL;
3355                                 else if (master->master->slaves[x])
3356                                         hasslaves = 1;
3357                         }
3358                         if (!hasslaves)
3359                                 master->master->inconference = 0;
3360                 }
3361                 master->master = NULL;
3362         }
3363         update_conf(master);
3364         if (needlock) {
3365                 if (slave)
3366                         ast_mutex_unlock(&slave->lock);
3367                 ast_mutex_unlock(&master->lock);
3368         }
3369 }
3370
3371 static void zt_link(struct zt_pvt *slave, struct zt_pvt *master) {
3372         int x;
3373         if (!slave || !master) {
3374                 ast_log(LOG_WARNING, "Tried to link to/from NULL??\n");
3375                 return;
3376         }
3377         for (x = 0; x < MAX_SLAVES; x++) {
3378                 if (!master->slaves[x]) {
3379                         master->slaves[x] = slave;
3380                         break;
3381                 }
3382         }
3383         if (x >= MAX_SLAVES) {
3384                 ast_log(LOG_WARNING, "Replacing slave %d with new slave, %d\n", master->slaves[MAX_SLAVES - 1]->channel, slave->channel);
3385                 master->slaves[MAX_SLAVES - 1] = slave;
3386         }
3387         if (slave->master)
3388                 ast_log(LOG_WARNING, "Replacing master %d with new master, %d\n", slave->master->channel, master->channel);
3389         slave->master = master;
3390
3391         ast_debug(1, "Making %d slave to master %d at %d\n", slave->channel, master->channel, x);
3392 }
3393
3394 static void disable_dtmf_detect(struct zt_pvt *p)
3395 {
3396 #ifdef ZT_TONEDETECT
3397         int val;
3398 #endif
3399
3400         p->ignoredtmf = 1;
3401
3402 #ifdef ZT_TONEDETECT
3403         val = 0;
3404         ioctl(p->subs[SUB_REAL].zfd, ZT_TONEDETECT, &val);
3405 #endif
3406         if (!p->hardwaredtmf && p->dsp) {
3407                 p->dsp_features &= ~DSP_FEATURE_DTMF_DETECT;
3408                 ast_dsp_set_features(p->dsp, p->dsp_features);
3409         }
3410 }
3411
3412 static void enable_dtmf_detect(struct zt_pvt *p)
3413 {
3414 #ifdef ZT_TONEDETECT
3415         int val;
3416 #endif
3417
3418         if (p->channel == CHAN_PSEUDO)
3419                 return;
3420
3421         p->ignoredtmf = 0;
3422
3423 #ifdef ZT_TONEDETECT
3424         val = ZT_TONEDETECT_ON | ZT_TONEDETECT_MUTE;
3425         ioctl(p->subs[SUB_REAL].zfd, ZT_TONEDETECT, &val);
3426 #endif
3427         if (!p->hardwaredtmf && p->dsp) {
3428                 p->dsp_features |= DSP_FEATURE_DTMF_DETECT;
3429                 ast_dsp_set_features(p->dsp, p->dsp_features);
3430         }
3431 }
3432
3433 static enum ast_bridge_result zt_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, struct ast_frame **fo, struct ast_channel **rc, int timeoutms)
3434 {
3435         struct ast_channel *who;
3436         struct zt_pvt *p0, *p1, *op0, *op1;
3437         struct zt_pvt *master = NULL, *slave = NULL;
3438         struct ast_frame *f;
3439         int inconf = 0;
3440         int nothingok = 1;