c8b4feb768f1fea5248cb3cdb56e9ce0391c7440
[asterisk/asterisk.git] / 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 HAVEL_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                 p->subs[a].owner->fds[0] = p->subs[a].zfd;
1017         if (p->subs[b].owner) 
1018                 p->subs[b].owner->fds[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, count = 0;
1761
1762         x = hs;
1763         res = ioctl(fd, ZT_HOOK, &x);
1764
1765         while (res < 0 && count < 20) {
1766                 usleep(100000); /* 1/10 sec. */
1767                 x = hs;
1768                 res = ioctl(fd, ZT_HOOK, &x);
1769                 count++;
1770         }
1771
1772         if (res < 0) {
1773                 if (errno == EINPROGRESS) return 0;
1774                 ast_log(LOG_WARNING, "zt hook failed: %s\n", strerror(errno));
1775         }
1776
1777         return res;
1778 }
1779
1780 static inline int zt_confmute(struct zt_pvt *p, int muted)
1781 {
1782         int x, y, res;
1783         x = muted;
1784         if ((p->sig == SIG_PRI) || (p->sig == SIG_SS7)) {
1785                 y = 1;
1786                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_AUDIOMODE, &y);
1787                 if (res)
1788                         ast_log(LOG_WARNING, "Unable to set audio mode on '%d'\n", p->channel);
1789         }
1790         res = ioctl(p->subs[SUB_REAL].zfd, ZT_CONFMUTE, &x);
1791         if (res < 0)
1792                 ast_log(LOG_WARNING, "zt confmute(%d) failed on channel %d: %s\n", muted, p->channel, strerror(errno));
1793         return res;
1794 }
1795
1796 static int save_conference(struct zt_pvt *p)
1797 {
1798         struct zt_confinfo c;
1799         int res;
1800         if (p->saveconf.confmode) {
1801                 ast_log(LOG_WARNING, "Can't save conference -- already in use\n");
1802                 return -1;
1803         }
1804         p->saveconf.chan = 0;
1805         res = ioctl(p->subs[SUB_REAL].zfd, ZT_GETCONF, &p->saveconf);
1806         if (res) {
1807                 ast_log(LOG_WARNING, "Unable to get conference info: %s\n", strerror(errno));
1808                 p->saveconf.confmode = 0;
1809                 return -1;
1810         }
1811         c.chan = 0;
1812         c.confno = 0;
1813         c.confmode = ZT_CONF_NORMAL;
1814         res = ioctl(p->subs[SUB_REAL].zfd, ZT_SETCONF, &c);
1815         if (res) {
1816                 ast_log(LOG_WARNING, "Unable to set conference info: %s\n", strerror(errno));
1817                 return -1;
1818         }
1819         ast_debug(1, "Disabled conferencing\n");
1820         return 0;
1821 }
1822
1823 static int restore_conference(struct zt_pvt *p)
1824 {
1825         int res;
1826         if (p->saveconf.confmode) {
1827                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_SETCONF, &p->saveconf);
1828                 p->saveconf.confmode = 0;
1829                 if (res) {
1830                         ast_log(LOG_WARNING, "Unable to restore conference info: %s\n", strerror(errno));
1831                         return -1;
1832                 }
1833         }
1834         ast_debug(1, "Restored conferencing\n");
1835         return 0;
1836 }
1837
1838 static int send_callerid(struct zt_pvt *p);
1839
1840 static int send_cwcidspill(struct zt_pvt *p)
1841 {
1842         p->callwaitcas = 0;
1843         p->cidcwexpire = 0;
1844         if (!(p->cidspill = ast_malloc(MAX_CALLERID_SIZE)))
1845                 return -1;
1846         p->cidlen = ast_callerid_callwaiting_generate(p->cidspill, p->callwait_name, p->callwait_num, AST_LAW(p));
1847         /* Make sure we account for the end */
1848         p->cidlen += READ_SIZE * 4;
1849         p->cidpos = 0;
1850         send_callerid(p);
1851         if (option_verbose > 2)
1852                 ast_verbose(VERBOSE_PREFIX_3 "CPE supports Call Waiting Caller*ID.  Sending '%s/%s'\n", p->callwait_name, p->callwait_num);
1853         return 0;
1854 }
1855
1856 static int has_voicemail(struct zt_pvt *p)
1857 {
1858         int new_msgs;
1859         struct ast_event *event;
1860
1861         event = ast_event_get_cached(AST_EVENT_MWI,
1862                 AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_STR, p->mailbox,
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                 if (option_verbose > 2)
2389                         ast_verbose(VERBOSE_PREFIX_3 "Requested transfer capability: 0x%.2x - %s\n", ast->transfercapability, ast_transfercapability2str(ast->transfercapability));
2390                 dp_strip = 0;
2391                 pridialplan = p->pri->dialplan - 1;
2392                 if (pridialplan == -2 || pridialplan == -3) { /* compute dynamically */
2393                         if (strncmp(c + p->stripmsd, p->pri->internationalprefix, strlen(p->pri->internationalprefix)) == 0) {
2394                                 if (pridialplan == -2) {
2395                                         dp_strip = strlen(p->pri->internationalprefix);
2396                                 }
2397                                 pridialplan = PRI_INTERNATIONAL_ISDN;
2398                         } else if (strncmp(c + p->stripmsd, p->pri->nationalprefix, strlen(p->pri->nationalprefix)) == 0) {
2399                                 if (pridialplan == -2) {
2400                                         dp_strip = strlen(p->pri->nationalprefix);
2401                                 }
2402                                 pridialplan = PRI_NATIONAL_ISDN;
2403                         } else {
2404                                 pridialplan = PRI_LOCAL_ISDN;
2405                         }
2406                 }
2407                 pri_sr_set_called(sr, c + p->stripmsd + dp_strip, pridialplan, s ? 1 : 0);
2408
2409                 ldp_strip = 0;
2410                 prilocaldialplan = p->pri->localdialplan - 1;
2411                 if ((l != NULL) && (prilocaldialplan == -2 || prilocaldialplan == -3)) { /* compute dynamically */
2412                         if (strncmp(l, p->pri->internationalprefix, strlen(p->pri->internationalprefix)) == 0) {
2413                                 if (prilocaldialplan == -2) {
2414                                         ldp_strip = strlen(p->pri->internationalprefix);
2415                                 }
2416                                 prilocaldialplan = PRI_INTERNATIONAL_ISDN;
2417                         } else if (strncmp(l, p->pri->nationalprefix, strlen(p->pri->nationalprefix)) == 0) {
2418                                 if (prilocaldialplan == -2) {
2419                                         ldp_strip = strlen(p->pri->nationalprefix);
2420                                 }
2421                                 prilocaldialplan = PRI_NATIONAL_ISDN;
2422                         } else {
2423                                 prilocaldialplan = PRI_LOCAL_ISDN;
2424                         }
2425                 }
2426                 pri_sr_set_caller(sr, l ? (l + ldp_strip) : NULL, n, prilocaldialplan,
2427                         p->use_callingpres ? ast->cid.cid_pres : (l ? PRES_ALLOWED_USER_NUMBER_PASSED_SCREEN : PRES_NUMBER_NOT_AVAILABLE));
2428                 if ((rr_str = pbx_builtin_getvar_helper(ast, "PRIREDIRECTREASON"))) {
2429                         if (!strcasecmp(rr_str, "UNKNOWN"))
2430                                 redirect_reason = 0;
2431                         else if (!strcasecmp(rr_str, "BUSY"))
2432                                 redirect_reason = 1;
2433                         else if (!strcasecmp(rr_str, "NO_REPLY"))
2434                                 redirect_reason = 2;
2435                         else if (!strcasecmp(rr_str, "UNCONDITIONAL"))
2436                                 redirect_reason = 15;
2437                         else
2438                                 redirect_reason = PRI_REDIR_UNCONDITIONAL;
2439                 } else
2440                         redirect_reason = PRI_REDIR_UNCONDITIONAL;
2441                 pri_sr_set_redirecting(sr, ast->cid.cid_rdnis, p->pri->localdialplan - 1, PRES_ALLOWED_USER_NUMBER_PASSED_SCREEN, redirect_reason);
2442
2443 #ifdef SUPPORT_USERUSER
2444                 /* User-user info */
2445                 useruser = pbx_builtin_getvar_helper(p->owner, "USERUSERINFO");
2446
2447                 if (useruser)
2448                         pri_sr_set_useruser(sr, useruser);
2449 #endif
2450
2451                 if (pri_setup(p->pri->pri, p->call, sr)) {
2452                         ast_log(LOG_WARNING, "Unable to setup call to %s (using %s)\n", 
2453                                 c + p->stripmsd + dp_strip, dialplan2str(p->pri->dialplan));
2454                         pri_rel(p->pri);
2455                         ast_mutex_unlock(&p->lock);
2456                         pri_sr_free(sr);
2457                         return -1;
2458                 }
2459                 pri_sr_free(sr);
2460                 ast_setstate(ast, AST_STATE_DIALING);
2461                 pri_rel(p->pri);
2462         }
2463 #endif          
2464         ast_mutex_unlock(&p->lock);
2465         return 0;
2466 }
2467
2468 static void destroy_zt_pvt(struct zt_pvt **pvt)
2469 {
2470         struct zt_pvt *p = *pvt;
2471         /* Remove channel from the list */
2472         if (p->prev)
2473                 p->prev->next = p->next;
2474         if (p->next)
2475                 p->next->prev = p->prev;
2476         if (p->use_smdi)
2477                 ASTOBJ_UNREF(p->smdi_iface, ast_smdi_interface_destroy);
2478         if (p->mwi_event_sub)
2479                 ast_event_unsubscribe(p->mwi_event_sub);
2480         ast_mutex_destroy(&p->lock);
2481         ast_free(p);
2482         *pvt = NULL;
2483 }
2484
2485 static int destroy_channel(struct zt_pvt *prev, struct zt_pvt *cur, int now)
2486 {
2487         int owned = 0;
2488         int i = 0;
2489
2490         if (!now) {
2491                 if (cur->owner) {
2492                         owned = 1;
2493                 }
2494
2495                 for (i = 0; i < 3; i++) {
2496                         if (cur->subs[i].owner) {
2497                                 owned = 1;
2498                         }
2499                 }
2500                 if (!owned) {
2501                         if (prev) {
2502                                 prev->next = cur->next;
2503                                 if (prev->next)
2504                                         prev->next->prev = prev;
2505                                 else
2506                                         ifend = prev;
2507                         } else {
2508                                 iflist = cur->next;
2509                                 if (iflist)
2510                                         iflist->prev = NULL;
2511                                 else
2512                                         ifend = NULL;
2513                         }
2514                         if (cur->subs[SUB_REAL].zfd > -1) {
2515                                 zt_close(cur->subs[SUB_REAL].zfd);
2516                         }
2517                         destroy_zt_pvt(&cur);
2518                 }
2519         } else {
2520                 if (prev) {
2521                         prev->next = cur->next;
2522                         if (prev->next)
2523                                 prev->next->prev = prev;
2524                         else
2525                                 ifend = prev;
2526                 } else {
2527                         iflist = cur->next;
2528                         if (iflist)
2529                                 iflist->prev = NULL;
2530                         else
2531                                 ifend = NULL;
2532                 }
2533                 if (cur->subs[SUB_REAL].zfd > -1) {
2534                         zt_close(cur->subs[SUB_REAL].zfd);
2535                 }
2536                 destroy_zt_pvt(&cur);
2537         }
2538         return 0;
2539 }
2540
2541 #ifdef HAVE_PRI
2542 static char *zap_send_keypad_facility_app = "ZapSendKeypadFacility";
2543
2544 static char *zap_send_keypad_facility_synopsis = "Send digits out of band over a PRI";
2545
2546 static char *zap_send_keypad_facility_descrip = 
2547 "  ZapSendKeypadFacility(): This application will send the given string of digits in a Keypad Facility\n"
2548 "  IE over the current channel.\n";
2549
2550 static int zap_send_keypad_facility_exec(struct ast_channel *chan, void *data)
2551 {
2552         /* Data will be our digit string */
2553         struct zt_pvt *p;
2554         char *digits = (char *) data;
2555
2556         if (ast_strlen_zero(digits)) {
2557                 ast_debug(1, "No digit string sent to application!\n");
2558                 return -1;
2559         }
2560
2561         p = (struct zt_pvt *)chan->tech_pvt;
2562
2563         if (!p) {
2564                 ast_debug(1, "Unable to find technology private\n");
2565                 return -1;
2566         }
2567
2568         ast_mutex_lock(&p->lock);
2569
2570         if (!p->pri || !p->call) {
2571                 ast_debug(1, "Unable to find pri or call on channel!\n");
2572                 ast_mutex_unlock(&p->lock);
2573                 return -1;
2574         }
2575
2576         if (!pri_grab(p, p->pri)) {
2577                 pri_keypad_facility(p->pri->pri, p->call, digits);
2578                 pri_rel(p->pri);
2579         } else {
2580                 ast_debug(1, "Unable to grab pri to send keypad facility!\n");
2581                 ast_mutex_unlock(&p->lock);
2582                 return -1;
2583         }
2584
2585         ast_mutex_unlock(&p->lock);
2586
2587         return 0;
2588 }
2589
2590 static int pri_is_up(struct zt_pri *pri)
2591 {
2592         int x;
2593         for (x = 0; x < NUM_DCHANS; x++) {
2594                 if (pri->dchanavail[x] == DCHAN_AVAILABLE)
2595                         return 1;
2596         }
2597         return 0;
2598 }
2599
2600 static int pri_assign_bearer(struct zt_pvt *crv, struct zt_pri *pri, struct zt_pvt *bearer)
2601 {
2602         bearer->owner = &inuse;
2603         bearer->realcall = crv;
2604         crv->subs[SUB_REAL].zfd = bearer->subs[SUB_REAL].zfd;
2605         if (crv->subs[SUB_REAL].owner)
2606                 crv->subs[SUB_REAL].owner->fds[0] = crv->subs[SUB_REAL].zfd;
2607         crv->bearer = bearer;
2608         crv->call = bearer->call;
2609         crv->pri = pri;
2610         return 0;
2611 }
2612
2613 static char *pri_order(int level)
2614 {
2615         switch (level) {
2616         case 0:
2617                 return "Primary";
2618         case 1:
2619                 return "Secondary";
2620         case 2:
2621                 return "Tertiary";
2622         case 3:
2623                 return "Quaternary";
2624         default:
2625                 return "<Unknown>";
2626         }               
2627 }
2628
2629 /* Returns fd of the active dchan */
2630 static int pri_active_dchan_fd(struct zt_pri *pri)
2631 {
2632         int x = -1;
2633
2634         for (x = 0; x < NUM_DCHANS; x++) {
2635                 if ((pri->dchans[x] == pri->pri))
2636                         break;
2637         }
2638
2639         return pri->fds[x];
2640 }
2641
2642 static int pri_find_dchan(struct zt_pri *pri)
2643 {
2644         int oldslot = -1;
2645         struct pri *old;
2646         int newslot = -1;
2647         int x;
2648         old = pri->pri;
2649         for (x = 0; x < NUM_DCHANS; x++) {
2650                 if ((pri->dchanavail[x] == DCHAN_AVAILABLE) && (newslot < 0))
2651                         newslot = x;
2652                 if (pri->dchans[x] == old) {
2653                         oldslot = x;
2654                 }
2655         }
2656         if (newslot < 0) {
2657                 newslot = 0;
2658                 ast_log(LOG_WARNING, "No D-channels available!  Using Primary channel %d as D-channel anyway!\n",
2659                         pri->dchannels[newslot]);
2660         }
2661         if (old && (oldslot != newslot))
2662                 ast_log(LOG_NOTICE, "Switching from from d-channel %d to channel %d!\n",
2663                         pri->dchannels[oldslot], pri->dchannels[newslot]);
2664         pri->pri = pri->dchans[newslot];
2665         return 0;
2666 }
2667 #endif
2668
2669 static int zt_hangup(struct ast_channel *ast)
2670 {
2671         int res;
2672         int index,x, law;
2673         /*static int restore_gains(struct zt_pvt *p);*/
2674         struct zt_pvt *p = ast->tech_pvt;
2675         struct zt_pvt *tmp = NULL;
2676         struct zt_pvt *prev = NULL;
2677         ZT_PARAMS par;
2678
2679         ast_debug(1, "zt_hangup(%s)\n", ast->name);
2680         if (!ast->tech_pvt) {
2681                 ast_log(LOG_WARNING, "Asked to hangup channel not connected\n");
2682                 return 0;
2683         }
2684         
2685         ast_mutex_lock(&p->lock);
2686         
2687         index = zt_get_index(ast, p, 1);
2688
2689         if ((p->sig == SIG_PRI) || (p->sig == SIG_SS7)) {
2690                 x = 1;
2691                 ast_channel_setoption(ast,AST_OPTION_AUDIO_MODE,&x,sizeof(char),0);
2692         }
2693
2694         x = 0;
2695         zt_confmute(p, 0);
2696         restore_gains(p);
2697         if (p->origcid_num) {
2698                 ast_copy_string(p->cid_num, p->origcid_num, sizeof(p->cid_num));
2699                 ast_free(p->origcid_num);
2700                 p->origcid_num = NULL;
2701         }       
2702         if (p->origcid_name) {
2703                 ast_copy_string(p->cid_name, p->origcid_name, sizeof(p->cid_name));
2704                 ast_free(p->origcid_name);
2705                 p->origcid_name = NULL;
2706         }       
2707         if (p->dsp)
2708                 ast_dsp_digitmode(p->dsp,DSP_DIGITMODE_DTMF | p->dtmfrelax);
2709         if (p->exten)
2710                 p->exten[0] = '\0';
2711
2712         ast_debug(1, "Hangup: channel: %d index = %d, normal = %d, callwait = %d, thirdcall = %d\n",
2713                 p->channel, index, p->subs[SUB_REAL].zfd, p->subs[SUB_CALLWAIT].zfd, p->subs[SUB_THREEWAY].zfd);
2714         p->ignoredtmf = 0;
2715         
2716         if (index > -1) {
2717                 /* Real channel, do some fixup */
2718                 p->subs[index].owner = NULL;
2719                 p->subs[index].needanswer = 0;
2720                 p->subs[index].needflash = 0;
2721                 p->subs[index].needringing = 0;
2722                 p->subs[index].needbusy = 0;
2723                 p->subs[index].needcongestion = 0;
2724                 p->subs[index].linear = 0;
2725                 p->subs[index].needcallerid = 0;
2726                 p->polarity = POLARITY_IDLE;
2727                 zt_setlinear(p->subs[index].zfd, 0);
2728                 if (index == SUB_REAL) {
2729                         if ((p->subs[SUB_CALLWAIT].zfd > -1) && (p->subs[SUB_THREEWAY].zfd > -1)) {
2730                                 ast_debug(1, "Normal call hung up with both three way call and a call waiting call in place?\n");
2731                                 if (p->subs[SUB_CALLWAIT].inthreeway) {
2732                                         /* We had flipped over to answer a callwait and now it's gone */
2733                                         ast_debug(1, "We were flipped over to the callwait, moving back and unowning.\n");
2734                                         /* Move to the call-wait, but un-own us until they flip back. */
2735                                         swap_subs(p, SUB_CALLWAIT, SUB_REAL);
2736                                         unalloc_sub(p, SUB_CALLWAIT);
2737                                         p->owner = NULL;
2738                                 } else {
2739                                         /* The three way hung up, but we still have a call wait */
2740                                         ast_debug(1, "We were in the threeway and have a callwait still.  Ditching the threeway.\n");
2741                                         swap_subs(p, SUB_THREEWAY, SUB_REAL);
2742                                         unalloc_sub(p, SUB_THREEWAY);
2743                                         if (p->subs[SUB_REAL].inthreeway) {
2744                                                 /* This was part of a three way call.  Immediately make way for
2745                                                    another call */
2746                                                 ast_debug(1, "Call was complete, setting owner to former third call\n");
2747                                                 p->owner = p->subs[SUB_REAL].owner;
2748                                         } else {
2749                                                 /* This call hasn't been completed yet...  Set owner to NULL */
2750                                                 ast_debug(1, "Call was incomplete, setting owner to NULL\n");
2751                                                 p->owner = NULL;
2752                                         }
2753                                         p->subs[SUB_REAL].inthreeway = 0;
2754                                 }
2755                         } else if (p->subs[SUB_CALLWAIT].zfd > -1) {
2756                                 /* Move to the call-wait and switch back to them. */
2757                                 swap_subs(p, SUB_CALLWAIT, SUB_REAL);
2758                                 unalloc_sub(p, SUB_CALLWAIT);
2759                                 p->owner = p->subs[SUB_REAL].owner;
2760                                 if (p->owner->_state != AST_STATE_UP)
2761                                         p->subs[SUB_REAL].needanswer = 1;
2762                                 if (ast_bridged_channel(p->subs[SUB_REAL].owner))
2763                                         ast_queue_control(p->subs[SUB_REAL].owner, AST_CONTROL_UNHOLD);
2764                         } else if (p->subs[SUB_THREEWAY].zfd > -1) {
2765                                 swap_subs(p, SUB_THREEWAY, SUB_REAL);
2766                                 unalloc_sub(p, SUB_THREEWAY);
2767                                 if (p->subs[SUB_REAL].inthreeway) {
2768                                         /* This was part of a three way call.  Immediately make way for
2769                                            another call */
2770                                         ast_debug(1, "Call was complete, setting owner to former third call\n");
2771                                         p->owner = p->subs[SUB_REAL].owner;
2772                                 } else {
2773                                         /* This call hasn't been completed yet...  Set owner to NULL */
2774                                         ast_debug(1, "Call was incomplete, setting owner to NULL\n");
2775                                         p->owner = NULL;
2776                                 }
2777                                 p->subs[SUB_REAL].inthreeway = 0;
2778                         }
2779                 } else if (index == SUB_CALLWAIT) {
2780                         /* Ditch the holding callwait call, and immediately make it availabe */
2781                         if (p->subs[SUB_CALLWAIT].inthreeway) {
2782                                 /* This is actually part of a three way, placed on hold.  Place the third part
2783                                    on music on hold now */
2784                                 if (p->subs[SUB_THREEWAY].owner && ast_bridged_channel(p->subs[SUB_THREEWAY].owner)) {
2785                                         ast_queue_control_data(p->subs[SUB_THREEWAY].owner, AST_CONTROL_HOLD, 
2786                                                 S_OR(p->mohsuggest, NULL),
2787                                                 !ast_strlen_zero(p->mohsuggest) ? strlen(p->mohsuggest) + 1 : 0);
2788                                 }
2789                                 p->subs[SUB_THREEWAY].inthreeway = 0;
2790                                 /* Make it the call wait now */
2791                                 swap_subs(p, SUB_CALLWAIT, SUB_THREEWAY);
2792                                 unalloc_sub(p, SUB_THREEWAY);
2793                         } else
2794                                 unalloc_sub(p, SUB_CALLWAIT);
2795                 } else if (index == SUB_THREEWAY) {
2796                         if (p->subs[SUB_CALLWAIT].inthreeway) {
2797                                 /* The other party of the three way call is currently in a call-wait state.
2798                                    Start music on hold for them, and take the main guy out of the third call */
2799                                 if (p->subs[SUB_CALLWAIT].owner && ast_bridged_channel(p->subs[SUB_CALLWAIT].owner)) {
2800                                         ast_queue_control_data(p->subs[SUB_CALLWAIT].owner, AST_CONTROL_HOLD, 
2801                                                 S_OR(p->mohsuggest, NULL),
2802                                                 !ast_strlen_zero(p->mohsuggest) ? strlen(p->mohsuggest) + 1 : 0);
2803                                 }
2804                                 p->subs[SUB_CALLWAIT].inthreeway = 0;
2805                         }
2806                         p->subs[SUB_REAL].inthreeway = 0;
2807                         /* If this was part of a three way call index, let us make
2808                            another three way call */
2809                         unalloc_sub(p, SUB_THREEWAY);
2810                 } else {
2811                         /* This wasn't any sort of call, but how are we an index? */
2812                         ast_log(LOG_WARNING, "Index found but not any type of call?\n");
2813                 }
2814         }
2815
2816         if (!p->subs[SUB_REAL].owner && !p->subs[SUB_CALLWAIT].owner && !p->subs[SUB_THREEWAY].owner) {
2817                 p->owner = NULL;
2818                 p->ringt = 0;
2819                 p->distinctivering = 0;
2820                 p->confirmanswer = 0;
2821                 p->cidrings = 1;
2822                 p->outgoing = 0;
2823                 p->digital = 0;
2824                 p->faxhandled = 0;
2825                 p->pulsedial = 0;
2826                 p->onhooktime = time(NULL);
2827 #ifdef HAVE_PRI
2828                 p->proceeding = 0;
2829                 p->progress = 0;
2830                 p->alerting = 0;
2831                 p->setup_ack = 0;
2832 #endif          
2833                 if (p->dsp) {
2834                         ast_dsp_free(p->dsp);
2835                         p->dsp = NULL;
2836                 }
2837
2838                 law = ZT_LAW_DEFAULT;
2839                 res = ioctl(p->subs[SUB_REAL].zfd, ZT_SETLAW, &law);
2840                 if (res < 0) 
2841                         ast_log(LOG_WARNING, "Unable to set law on channel %d to default\n", p->channel);
2842                 /* Perform low level hangup if no owner left */
2843 #ifdef HAVE_SS7
2844                 if (p->ss7) {
2845                         if (p->ss7call) {
2846                                 if (!ss7_grab(p, p->ss7)) {
2847                                         if (!p->alreadyhungup) {
2848                                                 const char *cause = pbx_builtin_getvar_helper(ast,"SS7_CAUSE");
2849                                                 int icause = ast->hangupcause ? ast->hangupcause : -1;
2850
2851                                                 if (cause) {
2852                                                         if (atoi(cause))
2853                                                                 icause = atoi(cause);
2854                                                 }
2855                                                 isup_rel(p->ss7->ss7, p->ss7call, icause);
2856                                                 ss7_rel(p->ss7);
2857                                                 p->alreadyhungup = 1;
2858                                         } else
2859                                                 ast_log(LOG_WARNING, "Trying to hangup twice!\n");
2860                                 } else {
2861                                         ast_log(LOG_WARNING, "Unable to grab SS7 on CIC %d\n", p->cic);
2862                                         res = -1;
2863                                 }
2864                         }
2865                 }
2866 #endif
2867 #ifdef HAVE_PRI
2868                 if (p->pri) {
2869 #ifdef SUPPORT_USERUSER
2870                         const char *useruser = pbx_builtin_getvar_helper(ast,"USERUSERINFO");
2871 #endif
2872
2873                         /* Make sure we have a call (or REALLY have a call in the case of a PRI) */
2874                         if (p->call && (!p->bearer || (p->bearer->call == p->call))) {
2875                                 if (!pri_grab(p, p->pri)) {
2876                                         if (p->alreadyhungup) {
2877                                                 ast_debug(1, "Already hungup...  Calling hangup once, and clearing call\n");
2878
2879 #ifdef SUPPORT_USERUSER
2880                                                 pri_call_set_useruser(p->call, useruser);
2881 #endif
2882
2883                                                 pri_hangup(p->pri->pri, p->call, -1);
2884                                                 p->call = NULL;
2885                                                 if (p->bearer) 
2886                                                         p->bearer->call = NULL;
2887                                         } else {
2888                                                 const char *cause = pbx_builtin_getvar_helper(ast,"PRI_CAUSE");
2889                                                 int icause = ast->hangupcause ? ast->hangupcause : -1;
2890                                                 ast_debug(1, "Not yet hungup...  Calling hangup once with icause, and clearing call\n");
2891
2892 #ifdef SUPPORT_USERUSER
2893                                                 pri_call_set_useruser(p->call, useruser);
2894 #endif
2895
2896                                                 p->alreadyhungup = 1;
2897                                                 if (p->bearer)
2898                                                         p->bearer->alreadyhungup = 1;
2899                                                 if (cause) {
2900                                                         if (atoi(cause))
2901                                                                 icause = atoi(cause);
2902                                                 }
2903                                                 pri_hangup(p->pri->pri, p->call, icause);
2904                                         }
2905                                         if (res < 0) 
2906                                                 ast_log(LOG_WARNING, "pri_disconnect failed\n");
2907                                         pri_rel(p->pri);                        
2908                                 } else {
2909                                         ast_log(LOG_WARNING, "Unable to grab PRI on span %d\n", p->span);
2910                                         res = -1;
2911                                 }
2912                         } else {
2913                                 if (p->bearer)
2914                                         ast_debug(1, "Bearer call is %p, while ours is still %p\n", p->bearer->call, p->call);
2915                                 p->call = NULL;
2916                                 res = 0;
2917                         }
2918                 }
2919 #endif
2920                 if (p->sig && ((p->sig != SIG_PRI) && (p->sig != SIG_SS7)))
2921                         res = zt_set_hook(p->subs[SUB_REAL].zfd, ZT_ONHOOK);
2922                 if (res < 0) {
2923                         ast_log(LOG_WARNING, "Unable to hangup line %s\n", ast->name);
2924                 }
2925                 switch (p->sig) {
2926                 case SIG_FXOGS:
2927                 case SIG_FXOLS:
2928                 case SIG_FXOKS:
2929                         res = ioctl(p->subs[SUB_REAL].zfd, ZT_GET_PARAMS, &par);
2930                         if (!res) {
2931 #if 0
2932                                 ast_debug(1, "Hanging up channel %d, offhook = %d\n", p->channel, par.rxisoffhook);
2933 #endif
2934                                 /* If they're off hook, try playing congestion */
2935                                 if ((par.rxisoffhook) && (!(p->radio || (p->oprmode < 0))))
2936                                         tone_zone_play_tone(p->subs[SUB_REAL].zfd, ZT_TONE_CONGESTION);
2937                                 else
2938                                         tone_zone_play_tone(p->subs[SUB_REAL].zfd, -1);
2939                         }
2940                         break;
2941                 case SIG_FXSGS:
2942                 case SIG_FXSLS:
2943                 case SIG_FXSKS:
2944                         /* Make sure we're not made available for at least two seconds assuming
2945                            we were actually used for an inbound or outbound call. */
2946                         if (ast->_state != AST_STATE_RESERVED) {
2947                                 time(&p->guardtime);
2948                                 p->guardtime += 2;
2949                         }
2950                         break;
2951                 default:
2952                         tone_zone_play_tone(p->subs[SUB_REAL].zfd, -1);
2953                 }
2954                 if (p->cidspill)
2955                         ast_free(p->cidspill);
2956                 if (p->sig)
2957                         zt_disable_ec(p);
2958                 x = 0;
2959                 ast_channel_setoption(ast,AST_OPTION_TONE_VERIFY,&x,sizeof(char),0);
2960                 ast_channel_setoption(ast,AST_OPTION_TDD,&x,sizeof(char),0);
2961                 p->didtdd = 0;
2962                 p->cidspill = NULL;
2963                 p->callwaitcas = 0;
2964                 p->callwaiting = p->permcallwaiting;
2965                 p->hidecallerid = p->permhidecallerid;
2966                 p->dialing = 0;
2967                 p->rdnis[0] = '\0';
2968                 update_conf(p);
2969                 reset_conf(p);
2970                 /* Restore data mode */
2971                 if ((p->sig == SIG_PRI) || (p->sig == SIG_SS7)) {
2972                         x = 0;
2973                         ast_channel_setoption(ast,AST_OPTION_AUDIO_MODE,&x,sizeof(char),0);
2974                 }
2975 #ifdef HAVE_PRI
2976                 if (p->bearer) {
2977                         ast_debug(1, "Freeing up bearer channel %d\n", p->bearer->channel);
2978                         /* Free up the bearer channel as well, and
2979                            don't use its file descriptor anymore */
2980                         update_conf(p->bearer);
2981                         reset_conf(p->bearer);
2982                         p->bearer->owner = NULL;
2983                         p->bearer->realcall = NULL;
2984                         p->bearer = NULL;
2985                         p->subs[SUB_REAL].zfd = -1;
2986                         p->pri = NULL;
2987                 }
2988 #endif
2989                 restart_monitor();
2990         }
2991
2992         p->callwaitingrepeat = 0;
2993         p->cidcwexpire = 0;
2994         p->oprmode = 0;
2995         ast->tech_pvt = NULL;
2996         ast_mutex_unlock(&p->lock);
2997         ast_module_unref(ast_module_info->self);
2998         if (option_verbose > 2) 
2999                 ast_verbose( VERBOSE_PREFIX_3 "Hungup '%s'\n", ast->name);
3000
3001         ast_mutex_lock(&iflock);
3002         tmp = iflist;
3003         prev = NULL;
3004         if (p->destroy) {
3005                 while (tmp) {
3006                         if (tmp == p) {
3007                                 destroy_channel(prev, tmp, 0);
3008                                 break;
3009                         } else {
3010                                 prev = tmp;
3011                                 tmp = tmp->next;
3012                         }
3013                 }
3014         }
3015         ast_mutex_unlock(&iflock);
3016         return 0;
3017 }
3018
3019 static int zt_answer(struct ast_channel *ast)
3020 {
3021         struct zt_pvt *p = ast->tech_pvt;
3022         int res = 0;
3023         int index;
3024         int oldstate = ast->_state;
3025         ast_setstate(ast, AST_STATE_UP);
3026         ast_mutex_lock(&p->lock);
3027         index = zt_get_index(ast, p, 0);
3028         if (index < 0)
3029                 index = SUB_REAL;
3030         /* nothing to do if a radio channel */
3031         if ((p->radio || (p->oprmode < 0))) {
3032