Stasis: Convert network change events into network change stasis messages
[asterisk/asterisk.git] / channels / chan_iax2.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 Implementation of Inter-Asterisk eXchange Version 2
22  *        as specified in RFC 5456
23  *
24  * \author Mark Spencer <markster@digium.com>
25  *
26  * \par See also
27  * \arg \ref Config_iax
28  *
29  * \ingroup channel_drivers
30  * 
31  * \todo Implement musicclass settings for IAX2 devices
32  */
33
34 /*! \li \ref chan_iax2.c uses the configuration file \ref iax.conf
35  * \addtogroup configuration_file
36  */
37
38 /*! \page iax.conf iax.conf
39  * \verbinclude iax.conf.sample
40  */
41
42 /*** MODULEINFO
43         <use type="external">crypto</use>
44         <support_level>core</support_level>
45  ***/
46
47 #include "asterisk.h"
48
49 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
50
51 #include <sys/mman.h>
52 #include <dirent.h>
53 #include <sys/socket.h>
54 #include <netinet/in.h>
55 #include <arpa/inet.h>
56 #include <netinet/in_systm.h>
57 #include <netinet/ip.h>
58 #include <sys/time.h>
59 #include <sys/signal.h>
60 #include <signal.h>
61 #include <strings.h>
62 #include <netdb.h>
63 #include <fcntl.h>
64 #include <sys/stat.h>
65 #include <regex.h>
66
67 #include "asterisk/paths.h"
68
69 #include "asterisk/lock.h"
70 #include "asterisk/frame.h" 
71 #include "asterisk/channel.h"
72 #include "asterisk/module.h"
73 #include "asterisk/pbx.h"
74 #include "asterisk/sched.h"
75 #include "asterisk/io.h"
76 #include "asterisk/config.h"
77 #include "asterisk/cli.h"
78 #include "asterisk/translate.h"
79 #include "asterisk/md5.h"
80 #include "asterisk/cdr.h"
81 #include "asterisk/crypto.h"
82 #include "asterisk/acl.h"
83 #include "asterisk/manager.h"
84 #include "asterisk/callerid.h"
85 #include "asterisk/app.h"
86 #include "asterisk/astdb.h"
87 #include "asterisk/musiconhold.h"
88 #include "asterisk/features.h"
89 #include "asterisk/utils.h"
90 #include "asterisk/causes.h"
91 #include "asterisk/localtime.h"
92 #include "asterisk/dnsmgr.h"
93 #include "asterisk/devicestate.h"
94 #include "asterisk/netsock.h"
95 #include "asterisk/stringfields.h"
96 #include "asterisk/linkedlists.h"
97 #include "asterisk/event.h"
98 #include "asterisk/astobj2.h"
99 #include "asterisk/timing.h"
100 #include "asterisk/taskprocessor.h"
101 #include "asterisk/test.h"
102 #include "asterisk/data.h"
103 #include "asterisk/netsock2.h"
104
105 #include "iax2/include/iax2.h"
106 #include "iax2/include/firmware.h"
107 #include "iax2/include/parser.h"
108 #include "iax2/include/provision.h"
109 #include "jitterbuf.h"
110
111 /*** DOCUMENTATION
112         <application name="IAX2Provision" language="en_US">
113                 <synopsis>
114                         Provision a calling IAXy with a given template.
115                 </synopsis>
116                 <syntax>
117                         <parameter name="template">
118                                 <para>If not specified, defaults to <literal>default</literal>.</para>
119                         </parameter>
120                 </syntax>
121                 <description>
122                         <para>Provisions the calling IAXy (assuming the calling entity is in fact an IAXy) with the
123                         given <replaceable>template</replaceable>. Returns <literal>-1</literal> on error
124                         or <literal>0</literal> on success.</para>
125                 </description>
126         </application>
127         <function name="IAXPEER" language="en_US">
128                 <synopsis>
129                         Gets IAX peer information.
130                 </synopsis>
131                 <syntax>
132                         <parameter name="peername" required="true">
133                                 <enumlist>
134                                         <enum name="CURRENTCHANNEL">
135                                                 <para>If <replaceable>peername</replaceable> is specified to this value, return the IP address of the
136                                                 endpoint of the current channel</para>
137                                         </enum>
138                                 </enumlist>
139                         </parameter>
140                         <parameter name="item">
141                                 <para>If <replaceable>peername</replaceable> is specified, valid items are:</para>
142                                 <enumlist>
143                                         <enum name="ip">
144                                                 <para>(default) The IP address.</para>
145                                         </enum>
146                                         <enum name="status">
147                                                 <para>The peer's status (if <literal>qualify=yes</literal>)</para>
148                                         </enum>
149                                         <enum name="mailbox">
150                                                 <para>The configured mailbox.</para>
151                                         </enum>
152                                         <enum name="context">
153                                                 <para>The configured context.</para>
154                                         </enum>
155                                         <enum name="expire">
156                                                 <para>The epoch time of the next expire.</para>
157                                         </enum>
158                                         <enum name="dynamic">
159                                                 <para>Is it dynamic? (yes/no).</para>
160                                         </enum>
161                                         <enum name="callerid_name">
162                                                 <para>The configured Caller ID name.</para>
163                                         </enum>
164                                         <enum name="callerid_num">
165                                                 <para>The configured Caller ID number.</para>
166                                         </enum>
167                                         <enum name="codecs">
168                                                 <para>The configured codecs.</para>
169                                         </enum>
170                                         <enum name="codec[x]">
171                                                 <para>Preferred codec index number <replaceable>x</replaceable> (beginning
172                                                 with <literal>0</literal>)</para>
173                                         </enum>
174                                 </enumlist>
175                         </parameter>
176                 </syntax>
177                 <description>
178                         <para>Gets information associated with the specified IAX2 peer.</para>
179                 </description>
180                 <see-also>
181                         <ref type="function">SIPPEER</ref>
182                 </see-also>
183         </function>
184         <function name="IAXVAR" language="en_US">
185                 <synopsis>
186                         Sets or retrieves a remote variable.
187                 </synopsis>
188                 <syntax>
189                         <parameter name="varname" required="true" />
190                 </syntax>
191                 <description>
192                         <para>Gets or sets a variable that is sent to a remote IAX2 peer during call setup.</para>
193                 </description>
194         </function>
195         <manager name="IAXpeers" language="en_US">
196                 <synopsis>
197                         List IAX peers.
198                 </synopsis>
199                 <syntax>
200                         <xi:include xpointer="xpointer(/docs/manager[@name='Login']/syntax/parameter[@name='ActionID'])" />
201                 </syntax>
202                 <description>
203                 </description>
204         </manager>
205         <manager name="IAXpeerlist" language="en_US">
206                 <synopsis>
207                         List IAX Peers.
208                 </synopsis>
209                 <syntax>
210                         <xi:include xpointer="xpointer(/docs/manager[@name='Login']/syntax/parameter[@name='ActionID'])" />
211                 </syntax>
212                 <description>
213                         <para>List all the IAX peers.</para>
214                 </description>
215         </manager>
216         <manager name="IAXnetstats" language="en_US">
217                 <synopsis>
218                         Show IAX Netstats.
219                 </synopsis>
220                 <syntax />
221                 <description>
222                         <para>Show IAX channels network statistics.</para>
223                 </description>
224         </manager>
225         <manager name="IAXregistry" language="en_US">
226                 <synopsis>
227                         Show IAX registrations.
228                 </synopsis>
229                 <syntax>
230                         <xi:include xpointer="xpointer(/docs/manager[@name='Login']/syntax/parameter[@name='ActionID'])" />
231                 </syntax>
232                 <description>
233                         <para>Show IAX registrations.</para>
234                 </description>
235         </manager>
236  ***/
237
238 /* Define SCHED_MULTITHREADED to run the scheduler in a special
239    multithreaded mode. */
240 #define SCHED_MULTITHREADED
241
242 /* Define DEBUG_SCHED_MULTITHREADED to keep track of where each
243    thread is actually doing. */
244 #define DEBUG_SCHED_MULTITHREAD
245
246
247 #ifdef SO_NO_CHECK
248 static int nochecksums = 0;
249 #endif
250
251 #define PTR_TO_CALLNO(a) ((unsigned short)(unsigned long)(a))
252 #define CALLNO_TO_PTR(a) ((void *)(unsigned long)(a))
253
254 #define DEFAULT_THREAD_COUNT 10
255 #define DEFAULT_MAX_THREAD_COUNT 100
256 #define DEFAULT_RETRY_TIME 1000
257 #define MEMORY_SIZE 100
258 #define DEFAULT_DROP 3
259
260 #define DEBUG_SUPPORT
261
262 #define MIN_REUSE_TIME          60      /* Don't reuse a call number within 60 seconds */
263
264 /* Sample over last 100 units to determine historic jitter */
265 #define GAMMA (0.01)
266
267 static struct ast_codec_pref prefs;
268
269 static const char tdesc[] = "Inter Asterisk eXchange Driver (Ver 2)";
270
271
272 /*! \brief Maximum transmission unit for the UDP packet in the trunk not to be
273     fragmented. This is based on 1516 - ethernet - ip - udp - iax minus one g711 frame = 1240 */
274 #define MAX_TRUNK_MTU 1240
275
276 static int global_max_trunk_mtu;        /*!< Maximum MTU, 0 if not used */
277 static int trunk_timed, trunk_untimed, trunk_maxmtu, trunk_nmaxmtu ;    /*!< Trunk MTU statistics */
278
279 #define DEFAULT_CONTEXT "default"
280
281 static char default_parkinglot[AST_MAX_CONTEXT];
282
283 static char language[MAX_LANGUAGE] = "";
284 static char regcontext[AST_MAX_CONTEXT] = "";
285
286 static struct stasis_subscription *network_change_sub; /*!< subscription id for network change events */
287 static struct stasis_subscription *acl_change_sub; /*!< subscription id for ACL change events */
288 static int network_change_sched_id = -1;
289
290 static int maxauthreq = 3;
291 static int max_retries = 4;
292 static int ping_time = 21;
293 static int lagrq_time = 10;
294 static int maxjitterbuffer=1000;
295 static int resyncthreshold=1000;
296 static int maxjitterinterps=10;
297 static int jittertargetextra = 40; /* number of milliseconds the new jitter buffer adds on to its size */
298
299 #define MAX_TRUNKDATA           640 * 200       /*!< 40ms, uncompressed linear * 200 channels */
300
301 static int trunkfreq = 20;
302 static int trunkmaxsize = MAX_TRUNKDATA;
303
304 static int authdebug = 0;
305 static int autokill = 0;
306 static int iaxcompat = 0;
307 static int last_authmethod = 0;
308
309 static int iaxdefaultdpcache=10 * 60;   /* Cache dialplan entries for 10 minutes by default */
310
311 static int iaxdefaulttimeout = 5;               /* Default to wait no more than 5 seconds for a reply to come back */
312
313 static struct {
314         unsigned int tos;
315         unsigned int cos;
316 } qos = { 0, 0 };
317
318 static int min_reg_expire;
319 static int max_reg_expire;
320
321 static int srvlookup = 0;
322
323 static struct ast_timer *timer;                         /* Timer for trunking */
324
325 static struct ast_netsock_list *netsock;
326 static struct ast_netsock_list *outsock;                /*!< used if sourceaddress specified and bindaddr == INADDR_ANY */
327 static int defaultsockfd = -1;
328
329 static int (*iax2_regfunk)(const char *username, int onoff) = NULL;
330
331 /* Ethernet, etc */
332 #define IAX_CAPABILITY_FULLBANDWIDTH    0xFFFF
333 /* T1, maybe ISDN */
334 #define IAX_CAPABILITY_MEDBANDWIDTH (IAX_CAPABILITY_FULLBANDWIDTH & \
335                      ~ast_format_id_to_old_bitfield(AST_FORMAT_SLINEAR) &      \
336                      ~ast_format_id_to_old_bitfield(AST_FORMAT_SLINEAR16) &    \
337                      ~ast_format_id_to_old_bitfield(AST_FORMAT_SIREN7) &       \
338                      ~ast_format_id_to_old_bitfield(AST_FORMAT_SIREN14) &      \
339                      ~ast_format_id_to_old_bitfield(AST_FORMAT_G719) &         \
340                      ~ast_format_id_to_old_bitfield(AST_FORMAT_ULAW) &         \
341                      ~ast_format_id_to_old_bitfield(AST_FORMAT_ALAW) &         \
342                      ~ast_format_id_to_old_bitfield(AST_FORMAT_G722))
343 /* A modem */
344 #define IAX_CAPABILITY_LOWBANDWIDTH (IAX_CAPABILITY_MEDBANDWIDTH & \
345                      ~ast_format_id_to_old_bitfield(AST_FORMAT_G726) &         \
346                      ~ast_format_id_to_old_bitfield(AST_FORMAT_G726_AAL2) &    \
347                      ~ast_format_id_to_old_bitfield(AST_FORMAT_ADPCM))
348
349 #define IAX_CAPABILITY_LOWFREE      (IAX_CAPABILITY_LOWBANDWIDTH & \
350                      ~ast_format_id_to_old_bitfield(AST_FORMAT_G723_1))
351
352
353 #define DEFAULT_MAXMS           2000            /* Must be faster than 2 seconds by default */
354 #define DEFAULT_FREQ_OK         60 * 1000       /* How often to check for the host to be up */
355 #define DEFAULT_FREQ_NOTOK      10 * 1000       /* How often to check, if the host is down... */
356
357 /* if a pvt has encryption setup done and is running on the call */
358 #define IAX_CALLENCRYPTED(pvt) \
359         (ast_test_flag64(pvt, IAX_ENCRYPTED) && ast_test_flag64(pvt, IAX_KEYPOPULATED))
360
361 #define IAX_DEBUGDIGEST(msg, key) do { \
362                 int idx; \
363                 char digest[33] = ""; \
364                 \
365                 if (!iaxdebug) \
366                         break; \
367                 \
368                 for (idx = 0; idx < 16; idx++) \
369                         sprintf(digest + (idx << 1), "%2.2x", (unsigned char) key[idx]); \
370                 \
371                 ast_log(LOG_NOTICE, msg " IAX_COMMAND_RTKEY to rotate key to '%s'\n", digest); \
372         } while(0)
373
374 static struct io_context *io;
375 static struct ast_sched_context *sched;
376
377 #define DONT_RESCHEDULE -2
378
379 static iax2_format iax2_capability = IAX_CAPABILITY_FULLBANDWIDTH;
380
381 static int iaxdebug = 0;
382
383 static int iaxtrunkdebug = 0;
384
385 static int test_losspct = 0;
386 #ifdef IAXTESTS
387 static int test_late = 0;
388 static int test_resync = 0;
389 static int test_jit = 0;
390 static int test_jitpct = 0;
391 #endif /* IAXTESTS */
392
393 static char accountcode[AST_MAX_ACCOUNT_CODE];
394 static char mohinterpret[MAX_MUSICCLASS];
395 static char mohsuggest[MAX_MUSICCLASS];
396 static int amaflags = 0;
397 static int adsi = 0;
398 static int delayreject = 0;
399 static int iax2_encryption = 0;
400
401 static struct ast_flags64 globalflags = { 0 };
402
403 static pthread_t netthreadid = AST_PTHREADT_NULL;
404
405 enum iax2_state {
406         IAX_STATE_STARTED =                     (1 << 0),
407         IAX_STATE_AUTHENTICATED =       (1 << 1),
408         IAX_STATE_TBD =                         (1 << 2),
409 };
410
411 struct iax2_context {
412         char context[AST_MAX_CONTEXT];
413         struct iax2_context *next;
414 };
415
416
417 #define IAX_HASCALLERID         (uint64_t)(1 << 0)    /*!< CallerID has been specified */
418 #define IAX_DELME               (uint64_t)(1 << 1)    /*!< Needs to be deleted */
419 #define IAX_TEMPONLY            (uint64_t)(1 << 2)    /*!< Temporary (realtime) */
420 #define IAX_TRUNK               (uint64_t)(1 << 3)    /*!< Treat as a trunk */
421 #define IAX_NOTRANSFER          (uint64_t)(1 << 4)    /*!< Don't native bridge */
422 #define IAX_USEJITTERBUF        (uint64_t)(1 << 5)    /*!< Use jitter buffer */
423 #define IAX_DYNAMIC             (uint64_t)(1 << 6)    /*!< dynamic peer */
424 #define IAX_SENDANI             (uint64_t)(1 << 7)    /*!< Send ANI along with CallerID */
425 #define IAX_RTSAVE_SYSNAME      (uint64_t)(1 << 8)    /*!< Save Systname on Realtime Updates */
426 #define IAX_ALREADYGONE         (uint64_t)(1 << 9)    /*!< Already disconnected */
427 #define IAX_PROVISION           (uint64_t)(1 << 10)   /*!< This is a provisioning request */
428 #define IAX_QUELCH              (uint64_t)(1 << 11)   /*!< Whether or not we quelch audio */
429 #define IAX_ENCRYPTED           (uint64_t)(1 << 12)   /*!< Whether we should assume encrypted tx/rx */
430 #define IAX_KEYPOPULATED        (uint64_t)(1 << 13)   /*!< Whether we have a key populated */
431 #define IAX_CODEC_USER_FIRST    (uint64_t)(1 << 14)   /*!< are we willing to let the other guy choose the codec? */
432 #define IAX_CODEC_NOPREFS       (uint64_t)(1 << 15)   /*!< Force old behaviour by turning off prefs */
433 #define IAX_CODEC_NOCAP         (uint64_t)(1 << 16)   /*!< only consider requested format and ignore capabilities*/
434 #define IAX_RTCACHEFRIENDS      (uint64_t)(1 << 17)   /*!< let realtime stay till your reload */
435 #define IAX_RTUPDATE            (uint64_t)(1 << 18)   /*!< Send a realtime update */
436 #define IAX_RTAUTOCLEAR         (uint64_t)(1 << 19)   /*!< erase me on expire */
437 #define IAX_FORCEJITTERBUF      (uint64_t)(1 << 20)   /*!< Force jitterbuffer, even when bridged to a channel that can take jitter */
438 #define IAX_RTIGNOREREGEXPIRE   (uint64_t)(1 << 21)   /*!< When using realtime, ignore registration expiration */
439 #define IAX_TRUNKTIMESTAMPS     (uint64_t)(1 << 22)   /*!< Send trunk timestamps */
440 #define IAX_TRANSFERMEDIA       (uint64_t)(1 << 23)   /*!< When doing IAX2 transfers, transfer media only */
441 #define IAX_MAXAUTHREQ          (uint64_t)(1 << 24)   /*!< Maximum outstanding AUTHREQ restriction is in place */
442 #define IAX_DELAYPBXSTART       (uint64_t)(1 << 25)   /*!< Don't start a PBX on the channel until the peer sends us a response, so that we've achieved a three-way handshake with them before sending voice or anything else */
443 #define IAX_ALLOWFWDOWNLOAD     (uint64_t)(1 << 26)   /*!< Allow the FWDOWNL command? */
444 #define IAX_IMMEDIATE           (uint64_t)(1 << 27)   /*!< Allow immediate off-hook to extension s */
445 #define IAX_SENDCONNECTEDLINE   (uint64_t)(1 << 28)   /*!< Allow sending of connected line updates */
446 #define IAX_RECVCONNECTEDLINE   (uint64_t)(1 << 29)   /*!< Allow receiving of connected line updates */
447 #define IAX_FORCE_ENCRYPT       (uint64_t)(1 << 30)   /*!< Forces call encryption, if encryption not possible hangup */
448 #define IAX_SHRINKCALLERID      (uint64_t)(1 << 31)   /*!< Turn on and off caller id shrinking */
449 static int global_rtautoclear = 120;
450
451 static int reload_config(int forced_reload);
452
453 /*!
454  * \brief Call token validation settings.
455  */
456 enum calltoken_peer_enum {
457         /*! \brief Default calltoken required unless the ip is in the ignorelist */
458         CALLTOKEN_DEFAULT = 0,
459         /*! \brief Require call token validation. */
460         CALLTOKEN_YES = 1,
461         /*! \brief Require call token validation after a successful registration
462          *         using call token validation occurs. */
463         CALLTOKEN_AUTO = 2,
464         /*! \brief Do not require call token validation. */
465         CALLTOKEN_NO = 3,
466 };
467
468 struct iax2_user {
469         AST_DECLARE_STRING_FIELDS(
470                 AST_STRING_FIELD(name);
471                 AST_STRING_FIELD(secret);
472                 AST_STRING_FIELD(dbsecret);
473                 AST_STRING_FIELD(accountcode);
474                 AST_STRING_FIELD(mohinterpret);
475                 AST_STRING_FIELD(mohsuggest);
476                 AST_STRING_FIELD(inkeys);               /*!< Key(s) this user can use to authenticate to us */
477                 AST_STRING_FIELD(language);
478                 AST_STRING_FIELD(cid_num);
479                 AST_STRING_FIELD(cid_name);
480                 AST_STRING_FIELD(parkinglot);           /*!< Default parkinglot for device */
481         );
482
483         int authmethods;
484         int encmethods;
485         int amaflags;
486         int adsi;
487         uint64_t flags;
488         iax2_format capability;
489         int maxauthreq; /*!< Maximum allowed outstanding AUTHREQs */
490         int curauthreq; /*!< Current number of outstanding AUTHREQs */
491         struct ast_codec_pref prefs;
492         struct ast_acl_list *acl;
493         struct iax2_context *contexts;
494         struct ast_variable *vars;
495         enum calltoken_peer_enum calltoken_required;        /*!< Is calltoken validation required or not, can be YES, NO, or AUTO */
496 };
497
498 struct iax2_peer {
499         AST_DECLARE_STRING_FIELDS(
500                 AST_STRING_FIELD(name);
501                 AST_STRING_FIELD(username);
502                 AST_STRING_FIELD(description);          /*!< Description of the peer */
503                 AST_STRING_FIELD(secret);
504                 AST_STRING_FIELD(dbsecret);
505                 AST_STRING_FIELD(outkey);           /*!< What key we use to talk to this peer */
506
507                 AST_STRING_FIELD(regexten);     /*!< Extension to register (if regcontext is used) */
508                 AST_STRING_FIELD(context);      /*!< For transfers only */
509                 AST_STRING_FIELD(peercontext);  /*!< Context to pass to peer */
510                 AST_STRING_FIELD(mailbox);          /*!< Mailbox */
511                 AST_STRING_FIELD(mohinterpret);
512                 AST_STRING_FIELD(mohsuggest);
513                 AST_STRING_FIELD(inkeys);               /*!< Key(s) this peer can use to authenticate to us */
514                 /* Suggested caller id if registering */
515                 AST_STRING_FIELD(cid_num);              /*!< Default context (for transfer really) */
516                 AST_STRING_FIELD(cid_name);             /*!< Default context (for transfer really) */
517                 AST_STRING_FIELD(zonetag);              /*!< Time Zone */
518                 AST_STRING_FIELD(parkinglot);   /*!< Default parkinglot for device */
519         );
520         struct ast_codec_pref prefs;
521         struct ast_dnsmgr_entry *dnsmgr;                /*!< DNS refresh manager */
522         struct ast_sockaddr addr;
523         int formats;
524         int sockfd;                                     /*!< Socket to use for transmission */
525         struct in_addr mask;
526         int adsi;
527         uint64_t flags;
528
529         /* Dynamic Registration fields */
530         struct sockaddr_in defaddr;                     /*!< Default address if there is one */
531         int authmethods;                                /*!< Authentication methods (IAX_AUTH_*) */
532         int encmethods;                                 /*!< Encryption methods (IAX_ENCRYPT_*) */
533
534         int expire;                                     /*!< Schedule entry for expiry */
535         int expiry;                                     /*!< How soon to expire */
536         iax2_format capability;                         /*!< Capability */
537
538         /* Qualification */
539         int callno;                                     /*!< Call number of POKE request */
540         int pokeexpire;                                 /*!< Scheduled qualification-related task (ie iax2_poke_peer_s or iax2_poke_noanswer) */
541         int lastms;                                     /*!< How long last response took (in ms), or -1 for no response */
542         int maxms;                                      /*!< Max ms we will accept for the host to be up, 0 to not monitor */
543
544         int pokefreqok;                                 /*!< How often to check if the host is up */
545         int pokefreqnotok;                              /*!< How often to check when the host has been determined to be down */
546         int historicms;                                 /*!< How long recent average responses took */
547         int smoothing;                                  /*!< Sample over how many units to determine historic ms */
548         uint16_t maxcallno;                             /*!< Max call number limit for this peer.  Set on registration */
549
550         struct stasis_subscription *mwi_event_sub;      /*!< This subscription lets pollmailboxes know which mailboxes need to be polled */
551
552         struct ast_acl_list *acl;
553         enum calltoken_peer_enum calltoken_required;    /*!< Is calltoken validation required or not, can be YES, NO, or AUTO */
554 };
555
556 #define IAX2_TRUNK_PREFACE (sizeof(struct iax_frame) + sizeof(struct ast_iax2_meta_hdr) + sizeof(struct ast_iax2_meta_trunk_hdr))
557
558 struct iax2_trunk_peer {
559         ast_mutex_t lock;
560         int sockfd;
561         struct sockaddr_in addr;
562         struct timeval txtrunktime;             /*!< Transmit trunktime */
563         struct timeval rxtrunktime;             /*!< Receive trunktime */
564         struct timeval lasttxtime;              /*!< Last transmitted trunktime */
565         struct timeval trunkact;                /*!< Last trunk activity */
566         unsigned int lastsent;                  /*!< Last sent time */
567         /* Trunk data and length */
568         unsigned char *trunkdata;
569         unsigned int trunkdatalen;
570         unsigned int trunkdataalloc;
571         int trunkmaxmtu;
572         int trunkerror;
573         int calls;
574         AST_LIST_ENTRY(iax2_trunk_peer) list;
575 };
576
577 static AST_LIST_HEAD_STATIC(tpeers, iax2_trunk_peer);
578
579 enum iax_reg_state {
580         REG_STATE_UNREGISTERED = 0,
581         REG_STATE_REGSENT,
582         REG_STATE_AUTHSENT,
583         REG_STATE_REGISTERED,
584         REG_STATE_REJECTED,
585         REG_STATE_TIMEOUT,
586         REG_STATE_NOAUTH
587 };
588
589 enum iax_transfer_state {
590         TRANSFER_NONE = 0,
591         TRANSFER_BEGIN,
592         TRANSFER_READY,
593         TRANSFER_RELEASED,
594         TRANSFER_PASSTHROUGH,
595         TRANSFER_MBEGIN,
596         TRANSFER_MREADY,
597         TRANSFER_MRELEASED,
598         TRANSFER_MPASSTHROUGH,
599         TRANSFER_MEDIA,
600         TRANSFER_MEDIAPASS
601 };
602
603 struct iax2_registry {
604         struct ast_sockaddr addr;               /*!< Who we connect to for registration purposes */
605         char username[80];
606         char secret[80];                        /*!< Password or key name in []'s */
607         int expire;                             /*!< Sched ID of expiration */
608         int refresh;                            /*!< How often to refresh */
609         enum iax_reg_state regstate;
610         int messages;                           /*!< Message count, low 8 bits = new, high 8 bits = old */
611         int callno;                             /*!< Associated call number if applicable */
612         struct sockaddr_in us;                  /*!< Who the server thinks we are */
613         struct ast_dnsmgr_entry *dnsmgr;        /*!< DNS refresh manager */
614         AST_LIST_ENTRY(iax2_registry) entry;
615 };
616
617 static AST_LIST_HEAD_STATIC(registrations, iax2_registry);
618
619 /* Don't retry more frequently than every 10 ms, or less frequently than every 5 seconds */
620 #define MIN_RETRY_TIME          100
621 #define MAX_RETRY_TIME          10000
622
623 #define MAX_JITTER_BUFFER       50
624 #define MIN_JITTER_BUFFER       10
625
626 #define DEFAULT_TRUNKDATA       640 * 10        /*!< 40ms, uncompressed linear * 10 channels */
627
628 #define MAX_TIMESTAMP_SKEW      160             /*!< maximum difference between actual and predicted ts for sending */
629
630 /* If consecutive voice frame timestamps jump by more than this many milliseconds, then jitter buffer will resync */
631 #define TS_GAP_FOR_JB_RESYNC    5000
632
633 /* used for first_iax_message and last_iax_message.  If this bit is set it was TX, else RX */
634 #define MARK_IAX_SUBCLASS_TX    0x8000
635
636 static int iaxthreadcount = DEFAULT_THREAD_COUNT;
637 static int iaxmaxthreadcount = DEFAULT_MAX_THREAD_COUNT;
638 static int iaxdynamicthreadcount = 0;
639 static int iaxdynamicthreadnum = 0;
640 static int iaxactivethreadcount = 0;
641
642 struct iax_rr {
643         int jitter;
644         int losspct;
645         int losscnt;
646         int packets;
647         int delay;
648         int dropped;
649         int ooo;
650 };
651
652 struct iax2_pvt_ref;
653
654 /* We use the high order bit as the validated flag, and the lower 15 as the
655  * actual call number */
656 typedef uint16_t callno_entry;
657
658 struct chan_iax2_pvt {
659         /*! Socket to send/receive on for this call */
660         int sockfd;
661         /*! ast_callid bound to dialog */
662         struct ast_callid *callid;
663         /*! Last received voice format */
664         iax2_format voiceformat;
665         /*! Last received video format */
666         iax2_format videoformat;
667         /*! Last sent voice format */
668         iax2_format svoiceformat;
669         /*! Last sent video format */
670         iax2_format svideoformat;
671         /*! What we are capable of sending */
672         iax2_format capability;
673         /*! Last received timestamp */
674         unsigned int last;
675         /*! Last sent timestamp - never send the same timestamp twice in a single call */
676         unsigned int lastsent;
677         /*! Timestamp of the last video frame sent */
678         unsigned int lastvsent;
679         /*! Next outgoing timestamp if everything is good */
680         unsigned int nextpred;
681         /*! iax frame subclass that began iax2_pvt entry. 0x8000 bit is set on TX */
682         int first_iax_message;
683         /*! Last iax frame subclass sent or received for a iax2_pvt. 0x8000 bit is set on TX */
684         int last_iax_message;
685         /*! True if the last voice we transmitted was not silence/CNG */
686         unsigned int notsilenttx:1;
687         /*! Ping time */
688         unsigned int pingtime;
689         /*! Max time for initial response */
690         int maxtime;
691         /*! Peer Address */
692         struct sockaddr_in addr;
693         /*! Actual used codec preferences */
694         struct ast_codec_pref prefs;
695         /*! Requested codec preferences */
696         struct ast_codec_pref rprefs;
697         /*! Our call number */
698         unsigned short callno;
699         /*! Our callno_entry entry */
700         callno_entry callno_entry;
701         /*! Peer callno */
702         unsigned short peercallno;
703         /*! Negotiated format, this is only used to remember what format was
704             chosen for an unauthenticated call so that the channel can get
705             created later using the right format */
706         iax2_format chosenformat;
707         /*! Peer selected format */
708         iax2_format peerformat;
709         /*! Peer capability */
710         iax2_format peercapability;
711         /*! timeval that we base our transmission on */
712         struct timeval offset;
713         /*! timeval that we base our delivery on */
714         struct timeval rxcore;
715         /*! The jitterbuffer */
716         jitterbuf *jb;
717         /*! active jb read scheduler id */
718         int jbid;
719         /*! LAG */
720         int lag;
721         /*! Error, as discovered by the manager */
722         int error;
723         /*! Owner if we have one */
724         struct ast_channel *owner;
725         /*! What's our state? */
726         struct ast_flags state;
727         /*! Expiry (optional) */
728         int expiry;
729         /*! Next outgoing sequence number */
730         unsigned char oseqno;
731         /*! Next sequence number they have not yet acknowledged */
732         unsigned char rseqno;
733         /*! Next incoming sequence number */
734         unsigned char iseqno;
735         /*! Last incoming sequence number we have acknowledged */
736         unsigned char aseqno;
737
738         AST_DECLARE_STRING_FIELDS(
739                 /*! Peer name */
740                 AST_STRING_FIELD(peer);
741                 /*! Default Context */
742                 AST_STRING_FIELD(context);
743                 /*! Caller ID if available */
744                 AST_STRING_FIELD(cid_num);
745                 AST_STRING_FIELD(cid_name);
746                 /*! Hidden Caller ID (i.e. ANI) if appropriate */
747                 AST_STRING_FIELD(ani);
748                 /*! DNID */
749                 AST_STRING_FIELD(dnid);
750                 /*! RDNIS */
751                 AST_STRING_FIELD(rdnis);
752                 /*! Requested Extension */
753                 AST_STRING_FIELD(exten);
754                 /*! Expected Username */
755                 AST_STRING_FIELD(username);
756                 /*! Expected Secret */
757                 AST_STRING_FIELD(secret);
758                 /*! MD5 challenge */
759                 AST_STRING_FIELD(challenge);
760                 /*! Public keys permitted keys for incoming authentication */
761                 AST_STRING_FIELD(inkeys);
762                 /*! Private key for outgoing authentication */
763                 AST_STRING_FIELD(outkey);
764                 /*! Preferred language */
765                 AST_STRING_FIELD(language);
766                 /*! Hostname/peername for naming purposes */
767                 AST_STRING_FIELD(host);
768
769                 AST_STRING_FIELD(dproot);
770                 AST_STRING_FIELD(accountcode);
771                 AST_STRING_FIELD(mohinterpret);
772                 AST_STRING_FIELD(mohsuggest);
773                 /*! received OSP token */
774                 AST_STRING_FIELD(osptoken);
775                 /*! Default parkinglot */
776                 AST_STRING_FIELD(parkinglot);
777         );
778         /*! AUTHREJ all AUTHREP frames */
779         int authrej;
780         /*! permitted authentication methods */
781         int authmethods;
782         /*! permitted encryption methods */
783         int encmethods;
784         /*! Encryption AES-128 Key */
785         ast_aes_encrypt_key ecx;
786         /*! Decryption AES-128 Key corresponding to ecx */
787         ast_aes_decrypt_key mydcx;
788         /*! Decryption AES-128 Key used to decrypt peer frames */
789         ast_aes_decrypt_key dcx;
790         /*! scheduler id associated with iax_key_rotate 
791          * for encrypted calls*/
792         int keyrotateid;
793         /*! 32 bytes of semi-random data */
794         unsigned char semirand[32];
795         /*! Associated registry */
796         struct iax2_registry *reg;
797         /*! Associated peer for poking */
798         struct iax2_peer *peerpoke;
799         /*! IAX_ flags */
800         uint64_t flags;
801         int adsi;
802
803         /*! Transferring status */
804         enum iax_transfer_state transferring;
805         /*! Transfer identifier */
806         int transferid;
807         /*! Who we are IAX transferring to */
808         struct sockaddr_in transfer;
809         /*! What's the new call number for the transfer */
810         unsigned short transfercallno;
811         /*! Transfer encrypt AES-128 Key */
812         ast_aes_encrypt_key tdcx;
813
814         /*! Status of knowledge of peer ADSI capability */
815         int peeradsicpe;
816
817         /*! Who we are bridged to */
818         unsigned short bridgecallno;
819
820         int pingid;                     /*!< Transmit PING request */
821         int lagid;                      /*!< Retransmit lag request */
822         int autoid;                     /*!< Auto hangup for Dialplan requestor */
823         int authid;                     /*!< Authentication rejection ID */
824         int authfail;                   /*!< Reason to report failure */
825         int initid;                     /*!< Initial peer auto-congest ID (based on qualified peers) */
826         int calling_ton;
827         int calling_tns;
828         int calling_pres;
829         int amaflags;
830         AST_LIST_HEAD_NOLOCK(, iax2_dpcache) dpentries;
831         /*! variables inherited from the user definition */
832         struct ast_variable *vars;
833         /*! variables transmitted in a NEW packet */
834         struct ast_variable *iaxvars;
835         /*! last received remote rr */
836         struct iax_rr remote_rr;
837         /*! Current base time: (just for stats) */
838         int min;
839         /*! Dropped frame count: (just for stats) */
840         int frames_dropped;
841         /*! received frame count: (just for stats) */
842         int frames_received;
843         /*! num bytes used for calltoken ie, even an empty ie should contain 2 */
844         unsigned char calltoken_ie_len;
845         /*! hold all signaling frames from the pbx thread until we have a destination callno */
846         char hold_signaling;
847         /*! frame queue for signaling frames from pbx thread waiting for destination callno */
848         AST_LIST_HEAD_NOLOCK(signaling_queue, signaling_queue_entry) signaling_queue;
849 };
850
851 struct signaling_queue_entry {
852         struct ast_frame f;
853         AST_LIST_ENTRY(signaling_queue_entry) next;
854 };
855
856 enum callno_type {
857         CALLNO_TYPE_NORMAL,
858         CALLNO_TYPE_TRUNK,
859 };
860
861 #define PTR_TO_CALLNO_ENTRY(a) ((uint16_t)(unsigned long)(a))
862 #define CALLNO_ENTRY_TO_PTR(a) ((void *)(unsigned long)(a))
863
864 #define CALLNO_ENTRY_SET_VALIDATED(a) ((a) |= 0x8000)
865 #define CALLNO_ENTRY_IS_VALIDATED(a)  ((a) & 0x8000)
866 #define CALLNO_ENTRY_GET_CALLNO(a)    ((a) & 0x7FFF)
867
868 struct call_number_pool {
869         size_t capacity;
870         size_t available;
871         callno_entry numbers[IAX_MAX_CALLS / 2 + 1];
872 };
873
874 AST_MUTEX_DEFINE_STATIC(callno_pool_lock);
875
876 /*! table of available call numbers */
877 static struct call_number_pool callno_pool;
878
879 /*! table of available trunk call numbers */
880 static struct call_number_pool callno_pool_trunk;
881
882 /*!
883  * \brief a list of frames that may need to be retransmitted
884  *
885  * \note The contents of this list do not need to be explicitly destroyed
886  * on module unload.  This is because all active calls are destroyed, and
887  * all frames in this queue will get destroyed as a part of that process.
888  *
889  * \note Contents protected by the iaxsl[] locks
890  */
891 static AST_LIST_HEAD_NOLOCK(, iax_frame) frame_queue[IAX_MAX_CALLS];
892
893 static struct ast_taskprocessor *transmit_processor;
894
895 static int randomcalltokendata;
896
897 static const time_t MAX_CALLTOKEN_DELAY = 10;
898
899 /*!
900  * This module will get much higher performance when doing a lot of
901  * user and peer lookups if the number of buckets is increased from 1.
902  * However, to maintain old behavior for Asterisk 1.4, these are set to
903  * 1 by default.  When using multiple buckets, search order through these
904  * containers is considered random, so you will not be able to depend on
905  * the order the entires are specified in iax.conf for matching order. */
906 #ifdef LOW_MEMORY
907 #define MAX_PEER_BUCKETS 17
908 #else
909 #define MAX_PEER_BUCKETS 563
910 #endif
911 static struct ao2_container *peers;
912
913 #define MAX_USER_BUCKETS MAX_PEER_BUCKETS
914 static struct ao2_container *users;
915
916 /*! Table containing peercnt objects for every ip address consuming a callno */
917 static struct ao2_container *peercnts;
918
919 /*! Table containing custom callno limit rules for a range of ip addresses. */
920 static struct ao2_container *callno_limits;
921
922 /*! Table containing ip addresses not requiring calltoken validation */
923 static struct ao2_container *calltoken_ignores;
924
925 static uint16_t DEFAULT_MAXCALLNO_LIMIT = 2048;
926
927 static uint16_t DEFAULT_MAXCALLNO_LIMIT_NONVAL = 8192;
928
929 static uint16_t global_maxcallno;
930
931 /*! Total num of call numbers allowed to be allocated without calltoken validation */
932 static uint16_t global_maxcallno_nonval;
933
934 static uint16_t total_nonval_callno_used = 0;
935
936 /*! peer connection private, keeps track of all the call numbers
937  *  consumed by a single ip address */
938 struct peercnt {
939         /*! ip address consuming call numbers */
940         unsigned long addr;
941         /*! Number of call numbers currently used by this ip address */
942         uint16_t cur;
943         /*! Max call numbers allowed for this ip address */
944         uint16_t limit;
945         /*! Specifies whether limit is set by a registration or not, if so normal
946          *  limit setting rules do not apply to this address. */
947         unsigned char reg;
948 };
949
950 /*! used by both callno_limits and calltoken_ignores containers */
951 struct addr_range {
952         /*! ip address range for custom callno limit rule */
953         struct ast_ha ha;
954         /*! callno limit for this ip address range, only used in callno_limits container */
955         uint16_t limit;
956         /*! delete me marker for reloads */
957         unsigned char delme;
958 };
959
960 enum {
961         /*! Extension exists */
962         CACHE_FLAG_EXISTS      = (1 << 0),
963         /*! Extension is nonexistent */
964         CACHE_FLAG_NONEXISTENT = (1 << 1),
965         /*! Extension can exist */
966         CACHE_FLAG_CANEXIST    = (1 << 2),
967         /*! Waiting to hear back response */
968         CACHE_FLAG_PENDING     = (1 << 3),
969         /*! Timed out */
970         CACHE_FLAG_TIMEOUT     = (1 << 4),
971         /*! Request transmitted */
972         CACHE_FLAG_TRANSMITTED = (1 << 5),
973         /*! Timeout */
974         CACHE_FLAG_UNKNOWN     = (1 << 6),
975         /*! Matchmore */
976         CACHE_FLAG_MATCHMORE   = (1 << 7),
977 };
978
979 struct iax2_dpcache {
980         char peercontext[AST_MAX_CONTEXT];
981         char exten[AST_MAX_EXTENSION];
982         struct timeval orig;
983         struct timeval expiry;
984         int flags;
985         unsigned short callno;
986         int waiters[256];
987         AST_LIST_ENTRY(iax2_dpcache) cache_list;
988         AST_LIST_ENTRY(iax2_dpcache) peer_list;
989 };
990
991 static AST_LIST_HEAD_STATIC(dpcache, iax2_dpcache);
992
993 static void reg_source_db(struct iax2_peer *p);
994 static struct iax2_peer *realtime_peer(const char *peername, struct sockaddr_in *sin);
995 static struct iax2_user *realtime_user(const char *username, struct sockaddr_in *sin);
996
997 static int ast_cli_netstats(struct mansession *s, int fd, int limit_fmt);
998 static char *complete_iax2_peers(const char *line, const char *word, int pos, int state, uint64_t flags);
999 static char *complete_iax2_unregister(const char *line, const char *word, int pos, int state);
1000
1001 enum iax2_thread_iostate {
1002         IAX_IOSTATE_IDLE,
1003         IAX_IOSTATE_READY,
1004         IAX_IOSTATE_PROCESSING,
1005         IAX_IOSTATE_SCHEDREADY,
1006 };
1007
1008 enum iax2_thread_type {
1009         IAX_THREAD_TYPE_POOL,
1010         IAX_THREAD_TYPE_DYNAMIC,
1011 };
1012
1013 struct iax2_pkt_buf {
1014         AST_LIST_ENTRY(iax2_pkt_buf) entry;
1015         size_t len;
1016         unsigned char buf[1];
1017 };
1018
1019 struct iax2_thread {
1020         AST_LIST_ENTRY(iax2_thread) list;
1021         enum iax2_thread_type type;
1022         enum iax2_thread_iostate iostate;
1023 #ifdef SCHED_MULTITHREADED
1024         void (*schedfunc)(const void *);
1025         const void *scheddata;
1026 #endif
1027 #ifdef DEBUG_SCHED_MULTITHREAD
1028         char curfunc[80];
1029 #endif  
1030         int actions;
1031         pthread_t threadid;
1032         int threadnum;
1033         struct sockaddr_in iosin;
1034         unsigned char readbuf[4096]; 
1035         unsigned char *buf;
1036         ssize_t buf_len;
1037         size_t buf_size;
1038         int iofd;
1039         time_t checktime;
1040         ast_mutex_t lock;
1041         ast_cond_t cond;
1042         ast_mutex_t init_lock;
1043         ast_cond_t init_cond;
1044         /*! if this thread is processing a full frame,
1045           some information about that frame will be stored
1046           here, so we can avoid dispatching any more full
1047           frames for that callno to other threads */
1048         struct {
1049                 unsigned short callno;
1050                 struct sockaddr_in sin;
1051                 unsigned char type;
1052                 unsigned char csub;
1053         } ffinfo;
1054         /*! Queued up full frames for processing.  If more full frames arrive for
1055          *  a call which this thread is already processing a full frame for, they
1056          *  are queued up here. */
1057         AST_LIST_HEAD_NOLOCK(, iax2_pkt_buf) full_frames;
1058         unsigned char stop;
1059 };
1060
1061 /* Thread lists */
1062 static AST_LIST_HEAD_STATIC(idle_list, iax2_thread);
1063 static AST_LIST_HEAD_STATIC(active_list, iax2_thread);
1064 static AST_LIST_HEAD_STATIC(dynamic_list, iax2_thread);
1065
1066 static void *iax2_process_thread(void *data);
1067 static void iax2_destroy(int callno);
1068
1069 static void signal_condition(ast_mutex_t *lock, ast_cond_t *cond)
1070 {
1071         ast_mutex_lock(lock);
1072         ast_cond_signal(cond);
1073         ast_mutex_unlock(lock);
1074 }
1075
1076 /*!
1077  * \brief an array of iax2 pvt structures
1078  *
1079  * The container for active chan_iax2_pvt structures is implemented as an
1080  * array for extremely quick direct access to the correct pvt structure
1081  * based on the local call number.  The local call number is used as the
1082  * index into the array where the associated pvt structure is stored.
1083  */
1084 static struct chan_iax2_pvt *iaxs[IAX_MAX_CALLS];
1085
1086 static struct ast_callid *iax_pvt_callid_get(int callno)
1087 {
1088         if (iaxs[callno]->callid) {
1089                 return ast_callid_ref(iaxs[callno]->callid);
1090         }
1091         return NULL;
1092 }
1093
1094 static void iax_pvt_callid_set(int callno, struct ast_callid *callid)
1095 {
1096         if (iaxs[callno]->callid) {
1097                 ast_callid_unref(iaxs[callno]->callid);
1098         }
1099         ast_callid_ref(callid);
1100         iaxs[callno]->callid = callid;
1101 }
1102
1103 static void iax_pvt_callid_new(int callno)
1104 {
1105         struct ast_callid *callid = ast_create_callid();
1106         char buffer[AST_CALLID_BUFFER_LENGTH];
1107         ast_callid_strnprint(buffer, sizeof(buffer), callid);
1108         iax_pvt_callid_set(callno, callid);
1109         ast_callid_unref(callid);
1110 }
1111
1112 /*!
1113  * \brief Another container of iax2_pvt structures
1114  *
1115  * Active IAX2 pvt structs are also stored in this container, if they are a part
1116  * of an active call where we know the remote side's call number.  The reason
1117  * for this is that incoming media frames do not contain our call number.  So,
1118  * instead of having to iterate the entire iaxs array, we use this container to
1119  * look up calls where the remote side is using a given call number.
1120  */
1121 static struct ao2_container *iax_peercallno_pvts;
1122
1123 /*!
1124  * \brief chan_iax2_pvt structure locks
1125  *
1126  * These locks are used when accessing a pvt structure in the iaxs array.
1127  * The index used here is the same as used in the iaxs array.  It is the
1128  * local call number for the associated pvt struct.
1129  */
1130 static ast_mutex_t iaxsl[ARRAY_LEN(iaxs)];
1131
1132 /*!
1133  *  * \brief Another container of iax2_pvt structures
1134  *  
1135  *  Active IAX2 pvt stucts used during transfering a call are stored here.  
1136  */
1137 static struct ao2_container *iax_transfercallno_pvts;
1138
1139 /* Flag to use with trunk calls, keeping these calls high up.  It halves our effective use
1140    but keeps the division between trunked and non-trunked better. */
1141 #define TRUNK_CALL_START        (IAX_MAX_CALLS / 2)
1142
1143 /* Debug routines... */
1144 static struct sockaddr_in debugaddr;
1145
1146 static void iax_outputframe(struct iax_frame *f, struct ast_iax2_full_hdr *fhi, int rx, struct sockaddr_in *sin, int datalen)
1147 {
1148         if (iaxdebug ||
1149             (sin && debugaddr.sin_addr.s_addr && 
1150              (!ntohs(debugaddr.sin_port) ||
1151               debugaddr.sin_port == sin->sin_port) &&
1152              debugaddr.sin_addr.s_addr == sin->sin_addr.s_addr)) {
1153                 if (iaxdebug) {
1154                         iax_showframe(f, fhi, rx, sin, datalen);
1155                 } else {
1156                         iaxdebug = 1;
1157                         iax_showframe(f, fhi, rx, sin, datalen);
1158                         iaxdebug = 0;
1159                 }
1160         }
1161 }
1162
1163 static void iax_debug_output(const char *data)
1164 {
1165         if (iaxdebug)
1166                 ast_verbose("%s", data);
1167 }
1168
1169 static void iax_error_output(const char *data)
1170 {
1171         ast_log(LOG_WARNING, "%s", data);
1172 }
1173
1174 static void __attribute__((format(printf, 1, 2))) jb_error_output(const char *fmt, ...)
1175 {
1176         va_list args;
1177         char buf[1024];
1178
1179         va_start(args, fmt);
1180         vsnprintf(buf, sizeof(buf), fmt, args);
1181         va_end(args);
1182
1183         ast_log(LOG_ERROR, "%s", buf);
1184 }
1185
1186 static void __attribute__((format(printf, 1, 2))) jb_warning_output(const char *fmt, ...)
1187 {
1188         va_list args;
1189         char buf[1024];
1190
1191         va_start(args, fmt);
1192         vsnprintf(buf, sizeof(buf), fmt, args);
1193         va_end(args);
1194
1195         ast_log(LOG_WARNING, "%s", buf);
1196 }
1197
1198 static void __attribute__((format(printf, 1, 2))) jb_debug_output(const char *fmt, ...)
1199 {
1200         va_list args;
1201         char buf[1024];
1202
1203         va_start(args, fmt);
1204         vsnprintf(buf, sizeof(buf), fmt, args);
1205         va_end(args);
1206
1207         ast_verbose("%s", buf);
1208 }
1209
1210 static enum ast_bridge_result iax2_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, struct ast_frame **fo, struct ast_channel **rc, int timeoutms);
1211 static int expire_registry(const void *data);
1212 static int iax2_answer(struct ast_channel *c);
1213 static int iax2_call(struct ast_channel *c, const char *dest, int timeout);
1214 static int iax2_devicestate(const char *data);
1215 static int iax2_digit_begin(struct ast_channel *c, char digit);
1216 static int iax2_digit_end(struct ast_channel *c, char digit, unsigned int duration);
1217 static int iax2_do_register(struct iax2_registry *reg);
1218 static int iax2_fixup(struct ast_channel *oldchannel, struct ast_channel *newchan);
1219 static int iax2_hangup(struct ast_channel *c);
1220 static int iax2_indicate(struct ast_channel *c, int condition, const void *data, size_t datalen);
1221 static int iax2_poke_peer(struct iax2_peer *peer, int heldcall);
1222 static int iax2_provision(struct sockaddr_in *end, int sockfd, const char *dest, const char *template, int force);
1223 static int iax2_send(struct chan_iax2_pvt *pvt, struct ast_frame *f, unsigned int ts, int seqno, int now, int transfer, int final);
1224 static int iax2_sendhtml(struct ast_channel *c, int subclass, const char *data, int datalen);
1225 static int iax2_sendimage(struct ast_channel *c, struct ast_frame *img);
1226 static int iax2_sendtext(struct ast_channel *c, const char *text);
1227 static int iax2_setoption(struct ast_channel *c, int option, void *data, int datalen);
1228 static int iax2_queryoption(struct ast_channel *c, int option, void *data, int *datalen);
1229 static int iax2_transfer(struct ast_channel *c, const char *dest);
1230 static int iax2_write(struct ast_channel *c, struct ast_frame *f);
1231 static int iax2_sched_add(struct ast_sched_context *sched, int when, ast_sched_cb callback, const void *data);
1232
1233 static int send_trunk(struct iax2_trunk_peer *tpeer, struct timeval *now);
1234 static int send_command(struct chan_iax2_pvt *, char, int, unsigned int, const unsigned char *, int, int);
1235 static int send_command_final(struct chan_iax2_pvt *, char, int, unsigned int, const unsigned char *, int, int);
1236 static int send_command_immediate(struct chan_iax2_pvt *, char, int, unsigned int, const unsigned char *, int, int);
1237 static int send_command_locked(unsigned short callno, char, int, unsigned int, const unsigned char *, int, int);
1238 static int send_command_transfer(struct chan_iax2_pvt *, char, int, unsigned int, const unsigned char *, int);
1239 static struct ast_channel *iax2_request(const char *type, struct ast_format_cap *cap, const struct ast_channel *requestor, const char *data, int *cause);
1240 static struct ast_frame *iax2_read(struct ast_channel *c);
1241 static struct iax2_peer *build_peer(const char *name, struct ast_variable *v, struct ast_variable *alt, int temponly);
1242 static struct iax2_user *build_user(const char *name, struct ast_variable *v, struct ast_variable *alt, int temponly);
1243 static void realtime_update_peer(const char *peername, struct ast_sockaddr *sockaddr, time_t regtime);
1244 static void *iax2_dup_variable_datastore(void *);
1245 static void prune_peers(void);
1246 static void prune_users(void);
1247 static void iax2_free_variable_datastore(void *);
1248
1249 static int acf_channel_read(struct ast_channel *chan, const char *funcname, char *preparse, char *buf, size_t buflen);
1250 static int decode_frame(ast_aes_decrypt_key *dcx, struct ast_iax2_full_hdr *fh, struct ast_frame *f, int *datalen);
1251 static int encrypt_frame(ast_aes_encrypt_key *ecx, struct ast_iax2_full_hdr *fh, unsigned char *poo, int *datalen);
1252 static void build_ecx_key(const unsigned char *digest, struct chan_iax2_pvt *pvt);
1253 static void build_rand_pad(unsigned char *buf, ssize_t len);
1254 static int get_unused_callno(enum callno_type type, int validated, callno_entry *entry);
1255 static int replace_callno(const void *obj);
1256 static void sched_delay_remove(struct sockaddr_in *sin, callno_entry entry);
1257 static void network_change_stasis_cb(void *data, struct stasis_subscription *sub, struct stasis_topic *topic, struct stasis_message *message);
1258 static void acl_change_stasis_cb(void *data, struct stasis_subscription *sub, struct stasis_topic *topic, struct stasis_message *message);
1259
1260 static struct ast_channel_tech iax2_tech = {
1261         .type = "IAX2",
1262         .description = tdesc,
1263         .properties = AST_CHAN_TP_WANTSJITTER,
1264         .requester = iax2_request,
1265         .devicestate = iax2_devicestate,
1266         .send_digit_begin = iax2_digit_begin,
1267         .send_digit_end = iax2_digit_end,
1268         .send_text = iax2_sendtext,
1269         .send_image = iax2_sendimage,
1270         .send_html = iax2_sendhtml,
1271         .call = iax2_call,
1272         .hangup = iax2_hangup,
1273         .answer = iax2_answer,
1274         .read = iax2_read,
1275         .write = iax2_write,
1276         .write_video = iax2_write,
1277         .indicate = iax2_indicate,
1278         .setoption = iax2_setoption,
1279         .queryoption = iax2_queryoption,
1280         .bridge = iax2_bridge,
1281         .transfer = iax2_transfer,
1282         .fixup = iax2_fixup,
1283         .func_channel_read = acf_channel_read,
1284 };
1285
1286 /*!
1287  * \internal
1288  * \brief Obtain the owner channel lock if the owner exists.
1289  *
1290  * \param callno IAX2 call id.
1291  *
1292  * \note Assumes the iaxsl[callno] lock is already obtained.
1293  *
1294  * \note
1295  * IMPORTANT NOTE!!!  Any time this function is used, even if
1296  * iaxs[callno] was valid before calling it, it may no longer be
1297  * valid after calling it.  This function may unlock and lock
1298  * the mutex associated with this callno, meaning that another
1299  * thread may grab it and destroy the call.
1300  *
1301  * \return Nothing
1302  */
1303 static void iax2_lock_owner(int callno)
1304 {
1305         for (;;) {
1306                 if (!iaxs[callno] || !iaxs[callno]->owner) {
1307                         /* There is no owner lock to get. */
1308                         break;
1309                 }
1310                 if (!ast_channel_trylock(iaxs[callno]->owner)) {
1311                         /* We got the lock */
1312                         break;
1313                 }
1314                 /* Avoid deadlock by pausing and trying again */
1315                 DEADLOCK_AVOIDANCE(&iaxsl[callno]);
1316         }
1317 }
1318
1319 static void mwi_event_cb(void *userdata, struct stasis_subscription *sub, struct stasis_topic *topic, struct stasis_message *msg)
1320 {
1321         /* The MWI subscriptions exist just so the core knows we care about those
1322          * mailboxes.  However, we just grab the events out of the cache when it
1323          * is time to send MWI, since it is only sent with a REGACK. */
1324 }
1325
1326 static void network_change_stasis_subscribe(void)
1327 {
1328         if (!network_change_sub) {
1329                 network_change_sub = stasis_subscribe(ast_system_topic(),
1330                         network_change_stasis_cb, NULL);
1331         }
1332 }
1333
1334 static void network_change_stasis_unsubscribe(void)
1335 {
1336         if (network_change_sub) {
1337                 network_change_sub = stasis_unsubscribe(network_change_sub);
1338         }
1339 }
1340
1341 static void acl_change_stasis_subscribe(void)
1342 {
1343         if (!acl_change_sub) {
1344                 acl_change_sub = stasis_subscribe(ast_acl_topic(),
1345                         acl_change_stasis_cb, NULL);
1346         }
1347 }
1348
1349 static void acl_change_stasis_unsubscribe(void)
1350 {
1351         if (acl_change_sub) {
1352                 acl_change_sub = stasis_unsubscribe(acl_change_sub);
1353         }
1354 }
1355
1356 static int network_change_sched_cb(const void *data)
1357 {
1358         struct iax2_registry *reg;
1359         network_change_sched_id = -1;
1360         AST_LIST_LOCK(&registrations);
1361         AST_LIST_TRAVERSE(&registrations, reg, entry) {
1362                 iax2_do_register(reg);
1363         }
1364         AST_LIST_UNLOCK(&registrations);
1365
1366         return 0;
1367 }
1368
1369 static void network_change_stasis_cb(void *data, struct stasis_subscription *sub,
1370         struct stasis_topic *topic, struct stasis_message *message)
1371 {
1372         /* This callback is only concerned with network change messages from the system topic. */
1373         if (stasis_message_type(message) != ast_network_change_type()) {
1374                 return;
1375         }
1376
1377         ast_verb(1, "IAX, got a network change message, renewing all IAX registrations.\n");
1378         if (network_change_sched_id == -1) {
1379                 network_change_sched_id = iax2_sched_add(sched, 1000, network_change_sched_cb, NULL);
1380         }
1381 }
1382
1383 static void acl_change_stasis_cb(void *data, struct stasis_subscription *sub,
1384         struct stasis_topic *topic, struct stasis_message *message)
1385 {
1386         if (stasis_message_type(message) != ast_named_acl_change_type()) {
1387                 return;
1388         }
1389
1390         ast_log(LOG_NOTICE, "Reloading chan_iax2 in response to ACL change event.\n");
1391         reload_config(1);
1392 }
1393
1394
1395 /*! \brief Send manager event at call setup to link between Asterisk channel name
1396         and IAX2 call identifiers */
1397 static void iax2_ami_channelupdate(struct chan_iax2_pvt *pvt)
1398 {
1399         manager_event(EVENT_FLAG_SYSTEM, "ChannelUpdate",
1400                 "Channel: %s\r\nChanneltype: IAX2\r\nIAX2-callno-local: %d\r\nIAX2-callno-remote: %d\r\nIAX2-peer: %s\r\n",
1401                 pvt->owner ? ast_channel_name(pvt->owner) : "",
1402                 pvt->callno, pvt->peercallno, pvt->peer ? pvt->peer : "");
1403 }
1404
1405 static const struct ast_datastore_info iax2_variable_datastore_info = {
1406         .type = "IAX2_VARIABLE",
1407         .duplicate = iax2_dup_variable_datastore,
1408         .destroy = iax2_free_variable_datastore,
1409 };
1410
1411 static void *iax2_dup_variable_datastore(void *old)
1412 {
1413         AST_LIST_HEAD(, ast_var_t) *oldlist = old, *newlist;
1414         struct ast_var_t *oldvar, *newvar;
1415
1416         newlist = ast_calloc(sizeof(*newlist), 1);
1417         if (!newlist) {
1418                 ast_log(LOG_ERROR, "Unable to duplicate iax2 variables\n");
1419                 return NULL;
1420         }
1421
1422         AST_LIST_HEAD_INIT(newlist);
1423         AST_LIST_LOCK(oldlist);
1424         AST_LIST_TRAVERSE(oldlist, oldvar, entries) {
1425                 newvar = ast_var_assign(ast_var_name(oldvar), ast_var_value(oldvar));
1426                 if (newvar)
1427                         AST_LIST_INSERT_TAIL(newlist, newvar, entries);
1428                 else
1429                         ast_log(LOG_ERROR, "Unable to duplicate iax2 variable '%s'\n", ast_var_name(oldvar));
1430         }
1431         AST_LIST_UNLOCK(oldlist);
1432         return newlist;
1433 }
1434
1435 static void iax2_free_variable_datastore(void *old)
1436 {
1437         AST_LIST_HEAD(, ast_var_t) *oldlist = old;
1438         struct ast_var_t *oldvar;
1439
1440         AST_LIST_LOCK(oldlist);
1441         while ((oldvar = AST_LIST_REMOVE_HEAD(oldlist, entries))) {
1442                 ast_free(oldvar);
1443         }
1444         AST_LIST_UNLOCK(oldlist);
1445         AST_LIST_HEAD_DESTROY(oldlist);
1446         ast_free(oldlist);
1447 }
1448
1449
1450 /* WARNING: insert_idle_thread should only ever be called within the
1451  * context of an iax2_process_thread() thread.
1452  */
1453 static void insert_idle_thread(struct iax2_thread *thread)
1454 {
1455         if (thread->type == IAX_THREAD_TYPE_DYNAMIC) {
1456                 AST_LIST_LOCK(&dynamic_list);
1457                 AST_LIST_INSERT_TAIL(&dynamic_list, thread, list);
1458                 AST_LIST_UNLOCK(&dynamic_list);
1459         } else {
1460                 AST_LIST_LOCK(&idle_list);
1461                 AST_LIST_INSERT_TAIL(&idle_list, thread, list);
1462                 AST_LIST_UNLOCK(&idle_list);
1463         }
1464
1465         return;
1466 }
1467
1468 static struct iax2_thread *find_idle_thread(void)
1469 {
1470         struct iax2_thread *thread = NULL;
1471
1472         /* Pop the head of the idle list off */
1473         AST_LIST_LOCK(&idle_list);
1474         thread = AST_LIST_REMOVE_HEAD(&idle_list, list);
1475         AST_LIST_UNLOCK(&idle_list);
1476
1477         /* If we popped a thread off the idle list, just return it */
1478         if (thread) {
1479                 memset(&thread->ffinfo, 0, sizeof(thread->ffinfo));
1480                 return thread;
1481         }
1482
1483         /* Pop the head of the dynamic list off */
1484         AST_LIST_LOCK(&dynamic_list);
1485         thread = AST_LIST_REMOVE_HEAD(&dynamic_list, list);
1486         AST_LIST_UNLOCK(&dynamic_list);
1487
1488         /* If we popped a thread off the dynamic list, just return it */
1489         if (thread) {
1490                 memset(&thread->ffinfo, 0, sizeof(thread->ffinfo));
1491                 return thread;
1492         }
1493
1494         /* If we can't create a new dynamic thread for any reason, return no thread at all */
1495         if (iaxdynamicthreadcount >= iaxmaxthreadcount || !(thread = ast_calloc(1, sizeof(*thread))))
1496                 return NULL;
1497
1498         /* Set default values */
1499         ast_atomic_fetchadd_int(&iaxdynamicthreadcount, 1);
1500         thread->threadnum = ast_atomic_fetchadd_int(&iaxdynamicthreadnum, 1);
1501         thread->type = IAX_THREAD_TYPE_DYNAMIC;
1502
1503         /* Initialize lock and condition */
1504         ast_mutex_init(&thread->lock);
1505         ast_cond_init(&thread->cond, NULL);
1506         ast_mutex_init(&thread->init_lock);
1507         ast_cond_init(&thread->init_cond, NULL);
1508         ast_mutex_lock(&thread->init_lock);
1509
1510         /* Create thread and send it on it's way */
1511         if (ast_pthread_create_background(&thread->threadid, NULL, iax2_process_thread, thread)) {
1512                 ast_cond_destroy(&thread->cond);
1513                 ast_mutex_destroy(&thread->lock);
1514                 ast_mutex_unlock(&thread->init_lock);
1515                 ast_cond_destroy(&thread->init_cond);
1516                 ast_mutex_destroy(&thread->init_lock);
1517                 ast_free(thread);
1518                 return NULL;
1519         }
1520
1521         /* this thread is not processing a full frame (since it is idle),
1522            so ensure that the field for the full frame call number is empty */
1523         memset(&thread->ffinfo, 0, sizeof(thread->ffinfo));
1524
1525         /* Wait for the thread to be ready before returning it to the caller */
1526         ast_cond_wait(&thread->init_cond, &thread->init_lock);
1527
1528         /* Done with init_lock */
1529         ast_mutex_unlock(&thread->init_lock);
1530
1531         return thread;
1532 }
1533
1534 #ifdef SCHED_MULTITHREADED
1535 static int __schedule_action(void (*func)(const void *data), const void *data, const char *funcname)
1536 {
1537         struct iax2_thread *thread = NULL;
1538         static time_t lasterror;
1539         static time_t t;
1540
1541         thread = find_idle_thread();
1542
1543         if (thread != NULL) {
1544                 thread->schedfunc = func;
1545                 thread->scheddata = data;
1546                 thread->iostate = IAX_IOSTATE_SCHEDREADY;
1547 #ifdef DEBUG_SCHED_MULTITHREAD
1548                 ast_copy_string(thread->curfunc, funcname, sizeof(thread->curfunc));
1549 #endif
1550                 signal_condition(&thread->lock, &thread->cond);
1551                 return 0;
1552         }
1553         time(&t);
1554         if (t != lasterror)
1555                 ast_debug(1, "Out of idle IAX2 threads for scheduling!\n");
1556         lasterror = t;
1557
1558         return -1;
1559 }
1560 #define schedule_action(func, data) __schedule_action(func, data, __PRETTY_FUNCTION__)
1561 #endif
1562
1563 static int iax2_sched_replace(int id, struct ast_sched_context *con, int when,
1564                 ast_sched_cb callback, const void *data)
1565 {
1566         return ast_sched_replace(id, con, when, callback, data);
1567 }
1568
1569 static int iax2_sched_add(struct ast_sched_context *con, int when,
1570                 ast_sched_cb callback, const void *data)
1571 {
1572         return ast_sched_add(con, when, callback, data);
1573 }
1574
1575 static int send_ping(const void *data);
1576
1577 static void __send_ping(const void *data)
1578 {
1579         int callno = (long) data;
1580
1581         ast_mutex_lock(&iaxsl[callno]);
1582
1583         if (iaxs[callno]) {
1584                 if (iaxs[callno]->peercallno) {
1585                         send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_PING, 0, NULL, 0, -1);
1586                         if (iaxs[callno]->pingid != DONT_RESCHEDULE) {
1587                                 iaxs[callno]->pingid = iax2_sched_add(sched, ping_time * 1000, send_ping, data);
1588                         }
1589                 }
1590         } else {
1591                 ast_debug(1, "I was supposed to send a PING with callno %d, but no such call exists.\n", callno);
1592         }
1593
1594         ast_mutex_unlock(&iaxsl[callno]);
1595 }
1596
1597 static int send_ping(const void *data)
1598 {
1599         int callno = (long) data;
1600         ast_mutex_lock(&iaxsl[callno]);
1601         if (iaxs[callno] && iaxs[callno]->pingid != DONT_RESCHEDULE) {
1602                 iaxs[callno]->pingid = -1;
1603         }
1604         ast_mutex_unlock(&iaxsl[callno]);
1605
1606 #ifdef SCHED_MULTITHREADED
1607         if (schedule_action(__send_ping, data))
1608 #endif
1609                 __send_ping(data);
1610
1611         return 0;
1612 }
1613
1614 static void encmethods_to_str(int e, struct ast_str **buf)
1615 {
1616         ast_str_set(buf, 0, "(");
1617         if (e & IAX_ENCRYPT_AES128) {
1618                 ast_str_append(buf, 0, "aes128");
1619         }
1620         if (e & IAX_ENCRYPT_KEYROTATE) {
1621                 ast_str_append(buf, 0, ",keyrotate");
1622         }
1623         if (ast_str_strlen(*buf) > 1) {
1624                 ast_str_append(buf, 0, ")");
1625         } else {
1626                 ast_str_set(buf, 0, "No");
1627         }
1628 }
1629
1630 static int get_encrypt_methods(const char *s)
1631 {
1632         int e;
1633         if (!strcasecmp(s, "aes128"))
1634                 e = IAX_ENCRYPT_AES128 | IAX_ENCRYPT_KEYROTATE;
1635         else if (ast_true(s))
1636                 e = IAX_ENCRYPT_AES128 | IAX_ENCRYPT_KEYROTATE;
1637         else
1638                 e = 0;
1639         return e;
1640 }
1641
1642 static int send_lagrq(const void *data);
1643
1644 static void __send_lagrq(const void *data)
1645 {
1646         int callno = (long) data;
1647
1648         ast_mutex_lock(&iaxsl[callno]);
1649
1650         if (iaxs[callno]) {
1651                 if (iaxs[callno]->peercallno) {
1652                         send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_LAGRQ, 0, NULL, 0, -1);
1653                         if (iaxs[callno]->lagid != DONT_RESCHEDULE) {
1654                                 iaxs[callno]->lagid = iax2_sched_add(sched, lagrq_time * 1000, send_lagrq, data);
1655                         }
1656                 }
1657         } else {
1658                 ast_debug(1, "I was supposed to send a LAGRQ with callno %d, but no such call exists.\n", callno);
1659         }
1660
1661         ast_mutex_unlock(&iaxsl[callno]);
1662 }
1663
1664 static int send_lagrq(const void *data)
1665 {
1666         int callno = (long) data;
1667         ast_mutex_lock(&iaxsl[callno]);
1668         if (iaxs[callno] && iaxs[callno]->lagid != DONT_RESCHEDULE) {
1669                 iaxs[callno]->lagid = -1;
1670         }
1671         ast_mutex_unlock(&iaxsl[callno]);
1672
1673 #ifdef SCHED_MULTITHREADED
1674         if (schedule_action(__send_lagrq, data))
1675 #endif
1676                 __send_lagrq(data);
1677         return 0;
1678 }
1679
1680 static unsigned char compress_subclass(iax2_format subclass)
1681 {
1682         int x;
1683         int power=-1;
1684         /* If it's 64 or smaller, just return it */
1685         if (subclass < IAX_FLAG_SC_LOG)
1686                 return subclass;
1687         /* Otherwise find its power */
1688         for (x = 0; x < IAX_MAX_SHIFT; x++) {
1689                 if (subclass & (1LL << x)) {
1690                         if (power > -1) {
1691                                 ast_log(LOG_WARNING, "Can't compress subclass %lld\n", (long long) subclass);
1692                                 return 0;
1693                         } else
1694                                 power = x;
1695                 }
1696         }
1697         return power | IAX_FLAG_SC_LOG;
1698 }
1699
1700 static iax2_format uncompress_subclass(unsigned char csub)
1701 {
1702         /* If the SC_LOG flag is set, return 2^csub otherwise csub */
1703         if (csub & IAX_FLAG_SC_LOG) {
1704                 /* special case for 'compressed' -1 */
1705                 if (csub == 0xff)
1706                         return -1;
1707                 else
1708                         return 1LL << (csub & ~IAX_FLAG_SC_LOG & IAX_MAX_SHIFT);
1709         }
1710         else
1711                 return csub;
1712 }
1713
1714 static iax2_format iax2_codec_choose(struct ast_codec_pref *pref, iax2_format formats, int find_best)
1715 {
1716         struct ast_format_cap *cap;
1717         struct ast_format tmpfmt;
1718         iax2_format format = 0;
1719         if ((cap = ast_format_cap_alloc_nolock())) {
1720                 ast_format_clear(&tmpfmt);
1721                 ast_format_cap_from_old_bitfield(cap, formats);
1722                 ast_codec_choose(pref, cap, find_best, &tmpfmt);
1723                 format = ast_format_to_old_bitfield(&tmpfmt);
1724                 cap = ast_format_cap_destroy(cap);
1725         }
1726
1727         return format;
1728 }
1729
1730 static iax2_format iax2_best_codec(iax2_format formats)
1731 {
1732         struct ast_format_cap *cap = ast_format_cap_alloc_nolock();
1733         struct ast_format tmpfmt;
1734         if (!cap) {
1735                 return 0;
1736         }
1737
1738         ast_format_clear(&tmpfmt);
1739         ast_format_cap_from_old_bitfield(cap, formats);
1740         ast_best_codec(cap, &tmpfmt);
1741         cap = ast_format_cap_destroy(cap);
1742         return ast_format_to_old_bitfield(&tmpfmt);
1743 }
1744
1745 const char *iax2_getformatname(iax2_format format)
1746 {
1747         struct ast_format tmpfmt;
1748         if (!(ast_format_from_old_bitfield(&tmpfmt, format))) {
1749                 return "Unknown";
1750         }
1751
1752         return ast_getformatname(&tmpfmt);
1753 }
1754
1755 static char *iax2_getformatname_multiple(char *codec_buf, size_t len, iax2_format format)
1756 {
1757         struct ast_format_cap *cap = ast_format_cap_alloc_nolock();
1758
1759         if (!cap) {
1760                 return "(Nothing)";
1761         }
1762         ast_format_cap_from_old_bitfield(cap, format);
1763         ast_getformatname_multiple(codec_buf, len, cap);
1764         cap = ast_format_cap_destroy(cap);
1765
1766         return codec_buf;
1767 }
1768
1769 static int iax2_parse_allow_disallow(struct ast_codec_pref *pref, iax2_format *formats, const char *list, int allowing)
1770 {
1771         int res;
1772         struct ast_format_cap *cap = ast_format_cap_alloc_nolock();
1773         if (!cap) {
1774                 return 1;
1775         }
1776
1777         ast_format_cap_from_old_bitfield(cap, *formats);
1778         res = ast_parse_allow_disallow(pref, cap, list, allowing);
1779         *formats = ast_format_cap_to_old_bitfield(cap);
1780         cap = ast_format_cap_destroy(cap);
1781
1782         return res;
1783 }
1784
1785 static int iax2_data_add_codecs(struct ast_data *root, const char *node_name, iax2_format formats)
1786 {
1787         int res;
1788         struct ast_format_cap *cap = ast_format_cap_alloc_nolock();
1789         if (!cap) {
1790                 return -1;
1791         }
1792         ast_format_cap_from_old_bitfield(cap, formats);
1793         res = ast_data_add_codecs(root, node_name, cap);
1794         cap = ast_format_cap_destroy(cap);
1795         return res;
1796 }
1797
1798 /*!
1799  * \note The only member of the peer passed here guaranteed to be set is the name field
1800  */
1801 static int peer_hash_cb(const void *obj, const int flags)
1802 {
1803         const struct iax2_peer *peer = obj;
1804         const char *name = obj;
1805
1806         return ast_str_hash(flags & OBJ_KEY ? name : peer->name);
1807 }
1808
1809 /*!
1810  * \note The only member of the peer passed here guaranteed to be set is the name field
1811  */
1812 static int peer_cmp_cb(void *obj, void *arg, int flags)
1813 {
1814         struct iax2_peer *peer = obj, *peer2 = arg;
1815         const char *name = arg;
1816
1817         return !strcmp(peer->name, flags & OBJ_KEY ? name : peer2->name) ?
1818                         CMP_MATCH | CMP_STOP : 0;
1819 }
1820
1821 /*!
1822  * \note The only member of the user passed here guaranteed to be set is the name field
1823  */
1824 static int user_hash_cb(const void *obj, const int flags)
1825 {
1826         const struct iax2_user *user = obj;
1827         const char *name = obj;
1828
1829         return ast_str_hash(flags & OBJ_KEY ? name : user->name);
1830 }
1831
1832 /*!
1833  * \note The only member of the user passed here guaranteed to be set is the name field
1834  */
1835 static int user_cmp_cb(void *obj, void *arg, int flags)
1836 {
1837         struct iax2_user *user = obj, *user2 = arg;
1838         const char *name = arg;
1839
1840         return !strcmp(user->name, flags & OBJ_KEY ? name : user2->name) ?
1841                         CMP_MATCH | CMP_STOP : 0;
1842 }
1843
1844 /*!
1845  * \note This funtion calls realtime_peer -> reg_source_db -> iax2_poke_peer -> find_callno,
1846  *       so do not call it with a pvt lock held.
1847  */
1848 static struct iax2_peer *find_peer(const char *name, int realtime) 
1849 {
1850         struct iax2_peer *peer = NULL;
1851
1852         peer = ao2_find(peers, name, OBJ_KEY);
1853
1854         /* Now go for realtime if applicable */
1855         if(!peer && realtime)
1856                 peer = realtime_peer(name, NULL);
1857
1858         return peer;
1859 }
1860
1861 static struct iax2_peer *peer_ref(struct iax2_peer *peer)
1862 {
1863         ao2_ref(peer, +1);
1864         return peer;
1865 }
1866
1867 static inline struct iax2_peer *peer_unref(struct iax2_peer *peer)
1868 {
1869         ao2_ref(peer, -1);
1870         return NULL;
1871 }
1872
1873 static struct iax2_user *find_user(const char *name)
1874 {
1875         return ao2_find(users, name, OBJ_KEY);
1876 }
1877 static inline struct iax2_user *user_ref(struct iax2_user *user)
1878 {
1879         ao2_ref(user, +1);
1880         return user;
1881 }
1882
1883 static inline struct iax2_user *user_unref(struct iax2_user *user)
1884 {
1885         ao2_ref(user, -1);
1886         return NULL;
1887 }
1888
1889 static int iax2_getpeername(struct sockaddr_in sin, char *host, int len)
1890 {
1891         struct iax2_peer *peer = NULL;
1892         int res = 0;
1893         struct ao2_iterator i;
1894
1895         i = ao2_iterator_init(peers, 0);
1896         while ((peer = ao2_iterator_next(&i))) {
1897                 struct sockaddr_in peer_addr;
1898
1899                 ast_sockaddr_to_sin(&peer->addr, &peer_addr);
1900
1901                 if ((peer_addr.sin_addr.s_addr == sin.sin_addr.s_addr) &&
1902                     (peer_addr.sin_port == sin.sin_port)) {
1903                         ast_copy_string(host, peer->name, len);
1904                         peer_unref(peer);
1905                         res = 1;
1906                         break;
1907                 }
1908                 peer_unref(peer);
1909         }
1910         ao2_iterator_destroy(&i);
1911
1912         if (!peer) {
1913                 peer = realtime_peer(NULL, &sin);
1914                 if (peer) {
1915                         ast_copy_string(host, peer->name, len);
1916                         peer_unref(peer);
1917                         res = 1;
1918                 }
1919         }
1920
1921         return res;
1922 }
1923
1924 /*!\note Assumes the lock on the pvt is already held, when
1925  * iax2_destroy_helper() is called. */
1926 static void iax2_destroy_helper(struct chan_iax2_pvt *pvt)
1927 {
1928         /* Decrement AUTHREQ count if needed */
1929         if (ast_test_flag64(pvt, IAX_MAXAUTHREQ)) {
1930                 struct iax2_user *user;
1931
1932                 user = ao2_find(users, pvt->username, OBJ_KEY);
1933                 if (user) {
1934                         ast_atomic_fetchadd_int(&user->curauthreq, -1);
1935                         user_unref(user);
1936                 }
1937
1938                 ast_clear_flag64(pvt, IAX_MAXAUTHREQ);
1939         }
1940         /* No more pings or lagrq's */
1941         AST_SCHED_DEL_SPINLOCK(sched, pvt->pingid, &iaxsl[pvt->callno]);
1942         pvt->pingid = DONT_RESCHEDULE;
1943         AST_SCHED_DEL_SPINLOCK(sched, pvt->lagid, &iaxsl[pvt->callno]);
1944         pvt->lagid = DONT_RESCHEDULE;
1945         AST_SCHED_DEL(sched, pvt->autoid);
1946         AST_SCHED_DEL(sched, pvt->authid);
1947         AST_SCHED_DEL(sched, pvt->initid);
1948         AST_SCHED_DEL(sched, pvt->jbid);
1949         AST_SCHED_DEL(sched, pvt->keyrotateid);
1950 }
1951
1952 static void iax2_frame_free(struct iax_frame *fr)
1953 {
1954         AST_SCHED_DEL(sched, fr->retrans);
1955         iax_frame_free(fr);
1956 }
1957
1958 static int scheduled_destroy(const void *vid)
1959 {
1960         unsigned short callno = PTR_TO_CALLNO(vid);
1961         ast_mutex_lock(&iaxsl[callno]);
1962         if (iaxs[callno]) {
1963                 ast_debug(1, "Really destroying %d now...\n", callno);
1964                 iax2_destroy(callno);
1965         }
1966         ast_mutex_unlock(&iaxsl[callno]);
1967         return 0;
1968 }
1969
1970 static void free_signaling_queue_entry(struct signaling_queue_entry *s)
1971 {
1972         if (s->f.datalen) {
1973                 ast_free(s->f.data.ptr);
1974         }
1975         ast_free(s);
1976 }
1977
1978 /*! \brief This function must be called once we are sure the other side has
1979  *  given us a call number.  All signaling is held here until that point. */
1980 static void send_signaling(struct chan_iax2_pvt *pvt)
1981 {
1982         struct signaling_queue_entry *s = NULL;
1983
1984         while ((s = AST_LIST_REMOVE_HEAD(&pvt->signaling_queue, next))) {
1985                 iax2_send(pvt, &s->f, 0, -1, 0, 0, 0);
1986                 free_signaling_queue_entry(s);
1987         }
1988         pvt->hold_signaling = 0;
1989 }
1990
1991 /*! \brief All frames other than that of type AST_FRAME_IAX must be held until
1992  *  we have received a destination call number. */
1993 static int queue_signalling(struct chan_iax2_pvt *pvt, struct ast_frame *f)
1994 {
1995         struct signaling_queue_entry *qe;
1996
1997         if (f->frametype == AST_FRAME_IAX || !pvt->hold_signaling) {
1998                 return 1; /* do not queue this frame */
1999         } else if (!(qe = ast_calloc(1, sizeof(struct signaling_queue_entry)))) {
2000                 return -1;  /* out of memory */
2001         }
2002
2003         /* copy ast_frame into our queue entry */
2004         qe->f = *f;
2005         if (qe->f.datalen) {
2006                 /* if there is data in this frame copy it over as well */
2007                 if (!(qe->f.data.ptr = ast_malloc(qe->f.datalen))) {
2008                         free_signaling_queue_entry(qe);
2009                         return -1;
2010                 }
2011                 memcpy(qe->f.data.ptr, f->data.ptr, qe->f.datalen);
2012         }
2013         AST_LIST_INSERT_TAIL(&pvt->signaling_queue, qe, next);
2014
2015         return 0;
2016 }
2017
2018 static void pvt_destructor(void *obj)
2019 {
2020         struct chan_iax2_pvt *pvt = obj;
2021         struct iax_frame *cur = NULL;
2022         struct signaling_queue_entry *s = NULL;
2023
2024         ast_mutex_lock(&iaxsl[pvt->callno]);
2025
2026         iax2_destroy_helper(pvt);
2027
2028         sched_delay_remove(&pvt->addr, pvt->callno_entry);
2029         pvt->callno_entry = 0;
2030
2031         /* Already gone */
2032         ast_set_flag64(pvt, IAX_ALREADYGONE);
2033
2034         AST_LIST_TRAVERSE(&frame_queue[pvt->callno], cur, list) {
2035                 /* Cancel any pending transmissions */
2036                 cur->retries = -1;
2037         }
2038
2039         ast_mutex_unlock(&iaxsl[pvt->callno]);
2040
2041         while ((s = AST_LIST_REMOVE_HEAD(&pvt->signaling_queue, next))) {
2042                 free_signaling_queue_entry(s);
2043         }
2044
2045         if (pvt->reg) {
2046                 pvt->reg->callno = 0;
2047         }
2048
2049         if (!pvt->owner) {
2050                 jb_frame frame;
2051                 if (pvt->vars) {
2052                     ast_variables_destroy(pvt->vars);
2053                     pvt->vars = NULL;
2054                 }
2055
2056                 while (jb_getall(pvt->jb, &frame) == JB_OK) {
2057                         iax2_frame_free(frame.data);
2058                 }
2059
2060                 jb_destroy(pvt->jb);
2061                 ast_string_field_free_memory(pvt);
2062         }
2063
2064         if (pvt->callid) {
2065                 ast_callid_unref(pvt->callid);
2066         }
2067
2068 }
2069
2070 static struct chan_iax2_pvt *new_iax(struct sockaddr_in *sin, const char *host)
2071 {
2072         struct chan_iax2_pvt *tmp;
2073         jb_conf jbconf;
2074
2075         if (!(tmp = ao2_alloc(sizeof(*tmp), pvt_destructor))) {
2076                 return NULL;
2077         }
2078
2079         if (ast_string_field_init(tmp, 32)) {
2080                 ao2_ref(tmp, -1);
2081                 tmp = NULL;
2082                 return NULL;
2083         }
2084                 
2085         tmp->prefs = prefs;
2086         tmp->pingid = -1;
2087         tmp->lagid = -1;
2088         tmp->autoid = -1;
2089         tmp->authid = -1;
2090         tmp->initid = -1;
2091         tmp->keyrotateid = -1;
2092
2093         ast_string_field_set(tmp,exten, "s");
2094         ast_string_field_set(tmp,host, host);
2095
2096         tmp->jb = jb_new();
2097         tmp->jbid = -1;
2098         jbconf.max_jitterbuf = maxjitterbuffer;
2099         jbconf.resync_threshold = resyncthreshold;
2100         jbconf.max_contig_interp = maxjitterinterps;
2101         jbconf.target_extra = jittertargetextra;
2102         jb_setconf(tmp->jb,&jbconf);
2103
2104         AST_LIST_HEAD_INIT_NOLOCK(&tmp->dpentries);
2105
2106         tmp->hold_signaling = 1;
2107         AST_LIST_HEAD_INIT_NOLOCK(&tmp->signaling_queue);
2108
2109         return tmp;
2110 }
2111
2112 static struct iax_frame *iaxfrdup2(struct iax_frame *fr)
2113 {
2114         struct iax_frame *new = iax_frame_new(DIRECTION_INGRESS, fr->af.datalen, fr->cacheable);
2115         if (new) {
2116                 size_t afdatalen = new->afdatalen;
2117                 memcpy(new, fr, sizeof(*new));
2118                 iax_frame_wrap(new, &fr->af);
2119                 new->afdatalen = afdatalen;
2120                 new->data = NULL;
2121                 new->datalen = 0;
2122                 new->direction = DIRECTION_INGRESS;
2123                 new->retrans = -1;
2124         }
2125         return new;
2126 }
2127 /* keep these defined in this order.  They are used in find_callno to
2128  * determine whether or not a new call number should be allowed. */
2129 enum {
2130         /* do not allow a new call number, only search ones in use for match */
2131         NEW_PREVENT = 0,
2132         /* search for match first, then allow a new one to be allocated */
2133         NEW_ALLOW = 1,
2134         /* do not search for match, force a new call number */
2135         NEW_FORCE = 2,
2136         /* do not search for match, force a new call number.  Signifies call number
2137          * has been calltoken validated */
2138         NEW_ALLOW_CALLTOKEN_VALIDATED = 3,
2139 };
2140
2141 static int match(struct sockaddr_in *sin, unsigned short callno, unsigned short dcallno, const struct chan_iax2_pvt *cur, int check_dcallno)
2142 {
2143         if ((cur->addr.sin_addr.s_addr == sin->sin_addr.s_addr) &&
2144                 (cur->addr.sin_port == sin->sin_port)) {
2145                 /* This is the main host */
2146                 if ( (cur->peercallno == 0 || cur->peercallno == callno) &&
2147                          (check_dcallno ? dcallno == cur->callno : 1) ) {
2148                         /* That's us.  Be sure we keep track of the peer call number */
2149                         return 1;
2150                 }
2151         }
2152         if ((cur->transfer.sin_addr.s_addr == sin->sin_addr.s_addr) &&
2153             (cur->transfer.sin_port == sin->sin_port) && (cur->transferring)) {
2154                 /* We're transferring */
2155                 if ((dcallno == cur->callno) || (cur->transferring == TRANSFER_MEDIAPASS && cur->transfercallno == callno))
2156                         return 1;
2157         }
2158         return 0;
2159 }
2160
2161 static int make_trunk(unsigned short callno, int locked)
2162 {
2163         int x;
2164         int res= 0;
2165         callno_entry entry;
2166         if (iaxs[callno]->oseqno) {
2167                 ast_log(LOG_WARNING, "Can't make trunk once a call has started!\n");
2168                 return -1;
2169         }
2170         if (callno >= TRUNK_CALL_START) {
2171                 ast_log(LOG_WARNING, "Call %d is already a trunk\n", callno);
2172                 return -1;
2173         }
2174
2175         if (get_unused_callno(
2176                         CALLNO_TYPE_TRUNK,
2177                         CALLNO_ENTRY_IS_VALIDATED(iaxs[callno]->callno_entry),
2178                         &entry)) {
2179                 ast_log(LOG_WARNING, "Unable to trunk call: Insufficient space\n");
2180                 return -1;
2181         }
2182
2183         x = CALLNO_ENTRY_GET_CALLNO(entry);
2184         ast_mutex_lock(&iaxsl[x]);
2185
2186         /*!
2187          * \note We delete these before switching the slot, because if
2188          * they fire in the meantime, they will generate a warning.
2189          */
2190         AST_SCHED_DEL(sched, iaxs[callno]->pingid);
2191         AST_SCHED_DEL(sched, iaxs[callno]->lagid);
2192         iaxs[callno]->lagid = iaxs[callno]->pingid = -1;
2193         iaxs[x] = iaxs[callno];
2194         iaxs[x]->callno = x;
2195
2196         /* since we copied over the pvt from a different callno, make sure the old entry is replaced
2197          * before assigning the new one */
2198         if (iaxs[x]->callno_entry) {
2199                 iax2_sched_add(
2200                         sched,
2201                         MIN_REUSE_TIME * 1000,
2202                         replace_callno,
2203                         CALLNO_ENTRY_TO_PTR(iaxs[x]->callno_entry));
2204
2205         }
2206         iaxs[x]->callno_entry = entry;
2207
2208         iaxs[callno] = NULL;
2209         /* Update the two timers that should have been started */
2210         iaxs[x]->pingid = iax2_sched_add(sched, 
2211                 ping_time * 1000, send_ping, (void *)(long)x);
2212         iaxs[x]->lagid = iax2_sched_add(sched, 
2213                 lagrq_time * 1000, send_lagrq, (void *)(long)x);
2214
2215         if (locked)
2216                 ast_mutex_unlock(&iaxsl[callno]);
2217         res = x;
2218         if (!locked)
2219                 ast_mutex_unlock(&iaxsl[x]);
2220
2221         /* We moved this call from a non-trunked to a trunked call */
2222         ast_debug(1, "Made call %d into trunk call %d\n", callno, x);
2223
2224         return res;
2225 }
2226
2227 static void store_by_transfercallno(struct chan_iax2_pvt *pvt)
2228 {
2229         if (!pvt->transfercallno) {
2230                 ast_log(LOG_ERROR, "This should not be called without a transfer call number.\n");
2231                 return;
2232         }
2233
2234         ao2_link(iax_transfercallno_pvts, pvt);
2235 }
2236
2237 static void remove_by_transfercallno(struct chan_iax2_pvt *pvt)
2238 {
2239         if (!pvt->transfercallno) {
2240                 ast_log(LOG_ERROR, "This should not be called without a transfer call number.\n");
2241                 return;
2242         }
2243
2244         ao2_unlink(iax_transfercallno_pvts, pvt);
2245 }
2246 static void store_by_peercallno(struct chan_iax2_pvt *pvt)
2247 {
2248         if (!pvt->peercallno) {
2249                 ast_log(LOG_ERROR, "This should not be called without a peer call number.\n");
2250                 return;
2251         }
2252
2253         ao2_link(iax_peercallno_pvts, pvt);
2254 }
2255
2256 static void remove_by_peercallno(struct chan_iax2_pvt *pvt)
2257 {
2258         if (!pvt->peercallno) {
2259                 ast_log(LOG_ERROR, "This should not be called without a peer call number.\n");
2260                 return;
2261         }
2262
2263         ao2_unlink(iax_peercallno_pvts, pvt);
2264 }
2265
2266 static int addr_range_delme_cb(void *obj, void *arg, int flags)
2267 {
2268         struct addr_range *lim = obj;
2269         lim->delme = 1;
2270         return 0;
2271 }
2272
2273 static int addr_range_hash_cb(const void *obj, const int flags)
2274 {
2275         const struct addr_range *lim = obj;
2276         struct sockaddr_in sin;
2277         ast_sockaddr_to_sin(&lim->ha.addr, &sin);
2278         return abs((int) sin.sin_addr.s_addr);
2279 }
2280
2281 static int addr_range_cmp_cb(void *obj, void *arg, int flags)
2282 {
2283         struct addr_range *lim1 = obj, *lim2 = arg;
2284         return (!(ast_sockaddr_cmp_addr(&lim1->ha.addr, &lim2->ha.addr)) &&
2285                         !(ast_sockaddr_cmp_addr(&lim1->ha.netmask, &lim2->ha.netmask))) ?
2286                         CMP_MATCH | CMP_STOP : 0;
2287 }
2288
2289 static int peercnt_hash_cb(const void *obj, const int flags)
2290 {
2291         const struct peercnt *peercnt = obj;
2292         return abs((int) peercnt->addr);
2293 }
2294
2295 static int peercnt_cmp_cb(void *obj, void *arg, int flags)
2296 {
2297         struct peercnt *peercnt1 = obj, *peercnt2 = arg;
2298         return (peercnt1->addr == peercnt2->addr) ? CMP_MATCH | CMP_STOP : 0;
2299 }
2300
2301 static int addr_range_match_address_cb(void *obj, void *arg, int flags)
2302 {
2303         struct addr_range *addr_range = obj;
2304         struct sockaddr_in *sin = arg;
2305         struct sockaddr_in ha_netmask_sin;
2306         struct sockaddr_in ha_addr_sin;
2307
2308         ast_sockaddr_to_sin(&addr_range->ha.netmask, &ha_netmask_sin);
2309         ast_sockaddr_to_sin(&addr_range->ha.addr, &ha_addr_sin);
2310
2311         if ((sin->sin_addr.s_addr & ha_netmask_sin.sin_addr.s_addr) == ha_addr_sin.sin_addr.s_addr) {
2312                 return CMP_MATCH | CMP_STOP;
2313         }
2314         return 0;
2315 }
2316
2317 /*! 
2318  * \internal
2319  *
2320  * \brief compares sin to calltoken_ignores table to determine if validation is required.
2321  */
2322 static int calltoken_required(struct sockaddr_in *sin, const char *name, int subclass)
2323 {
2324         struct addr_range *addr_range;
2325         struct iax2_peer *peer = NULL;
2326         struct iax2_user *user = NULL;
2327         /* if no username is given, check for guest accounts */
2328         const char *find = S_OR(name, "guest");
2329         int res = 1;  /* required by default */
2330         int optional = 0;
2331         enum calltoken_peer_enum calltoken_required = CALLTOKEN_DEFAULT;
2332         /* There are only two cases in which calltoken validation is not required.
2333          * Case 1. sin falls within the list of address ranges specified in the calltoken optional table and
2334          *         the peer definition has not set the requirecalltoken option.
2335          * Case 2. Username is a valid peer/user, and that peer has requirecalltoken set either auto or no.
2336          */
2337
2338         /* ----- Case 1 ----- */
2339         if ((addr_range = ao2_callback(calltoken_ignores, 0, addr_range_match_address_cb, sin))) {
2340                 ao2_ref(addr_range, -1);
2341                 optional = 1;
2342         }
2343
2344         /* ----- Case 2 ----- */
2345         if ((subclass == IAX_COMMAND_NEW) && (user = find_user(find))) {
2346                 calltoken_required = user->calltoken_required;
2347         } else if ((subclass == IAX_COMMAND_NEW) && (user = realtime_user(find, sin))) {
2348                 calltoken_required = user->calltoken_required;
2349         } else if ((subclass != IAX_COMMAND_NEW) && (peer = find_peer(find, 0))) {
2350                 calltoken_required = peer->calltoken_required;
2351         } else if ((subclass != IAX_COMMAND_NEW) && (peer = realtime_peer(find, sin))) {
2352                 calltoken_required = peer->calltoken_required;
2353         }
2354
2355         if (peer) {
2356                 peer_unref(peer);
2357         }
2358         if (user) {
2359                 user_unref(user);
2360         }
2361
2362         ast_debug(1, "Determining if address %s with username %s requires calltoken validation.  Optional = %d  calltoken_required = %d \n", ast_inet_ntoa(sin->sin_addr), name, optional, calltoken_required);
2363         if (((calltoken_required == CALLTOKEN_NO) || (calltoken_required == CALLTOKEN_AUTO)) ||
2364                 (optional && (calltoken_required == CALLTOKEN_DEFAULT))) {
2365                 res = 0;
2366         }
2367
2368         return res;
2369 }
2370
2371 /*! 
2372  * \internal
2373  *
2374  * \brief set peercnt callno limit.
2375  *
2376  * \details 
2377  * First looks in custom definitions. If not found, global limit
2378  * is used.  Entries marked as reg already have
2379  * a custom limit set by a registration and are not modified.
2380  */
2381 static void set_peercnt_limit(struct peercnt *peercnt)
2382 {
2383         uint16_t limit = global_maxcallno;
2384         struct addr_range *addr_range;
2385         struct sockaddr_in sin = {
2386                 .sin_addr.s_addr = peercnt->addr,
2387         };
2388
2389
2390         if (peercnt->reg && peercnt->limit) {
2391                 return; /* this peercnt has a custom limit set by a registration */
2392         }
2393
2394         if ((addr_range = ao2_callback(callno_limits, 0, addr_range_match_address_cb, &sin))) {
2395                 limit = addr_range->limit;
2396                 ast_debug(1, "custom addr_range %d found for %s\n", limit, ast_inet_ntoa(sin.sin_addr));
2397                 ao2_ref(addr_range, -1);
2398         }
2399
2400         peercnt->limit = limit;
2401 }
2402
2403 /*! 
2404  * \internal
2405  * \brief sets limits for all peercnts in table. done on reload to reflect changes in conf.
2406  */
2407 static int set_peercnt_limit_all_cb(void *obj, void *arg, int flags)
2408 {
2409         struct peercnt *peercnt = obj;
2410
2411         set_peercnt_limit(peercnt);
2412         ast_debug(1, "Reset limits for peercnts table\n");
2413
2414         return 0;
2415 }
2416
2417 /*! 
2418  * \internal
2419  * \brief returns match if delme is set. 
2420  */
2421 static int prune_addr_range_cb(void *obj, void *arg, int flags)
2422 {
2423         struct addr_range *addr_range = obj;
2424
2425         return addr_range->delme ? CMP_MATCH : 0;
2426 }
2427
2428 /*! 
2429  * \internal
2430  * \brief modifies peercnt entry in peercnts table. Used to set custom limit or mark a registered ip
2431  */
2432 static void peercnt_modify(unsigned char reg, uint16_t limit, struct ast_sockaddr *sockaddr)
2433 {
2434         /* this function turns off and on custom callno limits set by peer registration */
2435         struct peercnt *peercnt;
2436         struct peercnt tmp = {
2437                 .addr = 0,
2438         };
2439         struct sockaddr_in sin;
2440
2441         ast_sockaddr_to_sin(sockaddr, &sin);
2442
2443         tmp.addr = sin.sin_addr.s_addr;
2444
2445         if ((peercnt = ao2_find(peercnts, &tmp, OBJ_POINTER))) {
2446                 peercnt->reg = reg;
2447                 if (limit) {
2448                         peercnt->limit = limit;
2449                 } else {
2450                         set_peercnt_limit(peercnt);
2451                 }
2452                 ast_debug(1, "peercnt entry %s modified limit:%d registered:%d", ast_inet_ntoa(sin.sin_addr), peercnt->limit, peercnt->reg);
2453                 ao2_ref(peercnt, -1); /* decrement ref from find */
2454         }
2455 }
2456
2457 /*! 
2458  * \internal
2459  * \brief adds an ip to the peercnts table, increments connection count if it already exists
2460  *
2461  * \details First searches for the address in the peercnts table.  If found
2462  * the current count is incremented.  If not found a new peercnt is allocated
2463  * and linked into the peercnts table with a call number count of 1.
2464  */
2465 static int peercnt_add(struct sockaddr_in *sin)
2466 {
2467         struct peercnt *peercnt;
2468         unsigned long addr = sin->sin_addr.s_addr;
2469         int res = 0;
2470         struct peercnt tmp = {
2471                 .addr = addr,
2472         };
2473
2474         /* Reasoning for peercnts container lock:  Two identical ip addresses
2475          * could be added by different threads at the "same time". Without the container
2476          * lock, both threads could alloc space for the same object and attempt
2477          * to link to table.  With the lock, one would create the object and link
2478          * to table while the other would find the already created peercnt object
2479          * rather than creating a new one. */
2480         ao2_lock(peercnts);
2481         if ((peercnt = ao2_find(peercnts, &tmp, OBJ_POINTER))) {
2482                 ao2_lock(peercnt);
2483         } else if ((peercnt = ao2_alloc(sizeof(*peercnt), NULL))) {
2484                 ao2_lock(peercnt);
2485                 /* create and set defaults */
2486                 peercnt->addr = addr;
2487                 set_peercnt_limit(peercnt);
2488                 /* guarantees it does not go away after unlocking table
2489                  * ao2_find automatically adds this */
2490                 ao2_link(peercnts, peercnt);
2491         } else {
2492                 ao2_unlock(peercnts);
2493                 return -1;
2494         }
2495
2496         /* check to see if the address has hit its callno limit.  If not increment cur. */
2497         if (peercnt->limit > peercnt->cur) {
2498                 peercnt->cur++;
2499                 ast_debug(1, "ip callno count incremented to %d for %s\n", peercnt->cur, ast_inet_ntoa(sin->sin_addr));
2500         } else { /* max num call numbers for this peer has been reached! */
2501                 ast_log(LOG_ERROR, "maxcallnumber limit of %d for %s has been reached!\n", peercnt->limit, ast_inet_ntoa(sin->sin_addr));
2502                 res = -1;
2503         }
2504
2505         /* clean up locks and ref count */
2506         ao2_unlock(peercnt);
2507         ao2_unlock(peercnts);
2508         ao2_ref(peercnt, -1); /* decrement ref from find/alloc, only the container ref remains. */
2509
2510         return res;
2511 }
2512
2513 /*! 
2514  * \internal
2515  * \brief decrements a peercnts table entry
2516  */
2517 static void peercnt_remove(struct peercnt *peercnt)
2518 {
2519         struct sockaddr_in sin = {
2520                 .sin_addr.s_addr = peercnt->addr,
2521         };
2522
2523         /*
2524          * Container locked here since peercnt may be unlinked from
2525          * list.  If left unlocked, peercnt_add could try and grab this
2526          * entry from the table and modify it at the "same time" this
2527          * thread attemps to unlink it.
2528          */
2529         ao2_lock(peercnts);
2530         peercnt->cur--;
2531         ast_debug(1, "ip callno count decremented to %d for %s\n", peercnt->cur, ast_inet_ntoa(sin.sin_addr));
2532         /* if this was the last connection from the peer remove it from table */
2533         if (peercnt->cur == 0) {
2534                 ao2_unlink(peercnts, peercnt);/* decrements ref from table, last ref is left to scheduler */
2535         }
2536         ao2_unlock(peercnts);
2537 }
2538
2539 /*! 
2540  * \internal
2541  * \brief called by scheduler to decrement object
2542  */
2543 static int peercnt_remove_cb(const void *obj)
2544 {
2545         struct peercnt *peercnt = (struct peercnt *) obj;
2546
2547         peercnt_remove(peercnt);
2548         ao2_ref(peercnt, -1); /* decrement ref from scheduler */
2549
2550         return 0;
2551 }
2552
2553 /*! 
2554  * \internal
2555  * \brief decrements peercnts connection count, finds by addr
2556  */
2557 static int peercnt_remove_by_addr(struct sockaddr_in *sin)
2558 {
2559         struct peercnt *peercnt;
2560         struct peercnt tmp = {
2561                 .addr = sin->sin_addr.s_addr,
2562         };
2563
2564         if ((peercnt = ao2_find(peercnts, &tmp, OBJ_POINTER))) {
2565                 peercnt_remove(peercnt);
2566                 ao2_ref(peercnt, -1); /* decrement ref from find */
2567         }
2568         return 0;
2569 }
2570
2571 /*! 
2572  * \internal
2573  * \brief Create callno_limit entry based on configuration
2574  */
2575 static void build_callno_limits(struct ast_variable *v)
2576 {
2577         struct addr_range *addr_range = NULL;
2578         struct addr_range tmp;
2579         struct ast_ha *ha;
2580         int limit;
2581         int error;
2582         int found;
2583
2584         for (; v; v = v->next) {
2585                 limit = -1;
2586                 error = 0;
2587                 found = 0;
2588                 ha = ast_append_ha("permit", v->name, NULL, &error);
2589
2590                 /* check for valid config information */
2591                 if (error) {
2592                         ast_log(LOG_ERROR, "Call number limit for %s could not be added, Invalid address range\n.", v->name);
2593                         continue;
2594                 } else if ((sscanf(v->value, "%d", &limit) != 1) || (limit < 0)) {
2595                         ast_log(LOG_ERROR, "Call number limit for %s could not be added. Invalid limit %s\n.", v->name, v->value);
2596                         ast_free_ha(ha);
2597                         continue;
2598                 }
2599
2600                 ast_copy_ha(ha, &tmp.ha);
2601                 /* find or create the addr_range */
2602                 if ((addr_range = ao2_find(callno_limits, &tmp, OBJ_POINTER))) {
2603                         ao2_lock(addr_range);
2604                         found = 1;
2605                 } else if (!(addr_range = ao2_alloc(sizeof(*addr_range), NULL))) {
2606                         ast_free_ha(ha);
2607                         return; /* out of memory */
2608                 }
2609
2610                 /* copy over config data into addr_range object */
2611                 ast_copy_ha(ha, &addr_range->ha); /* this is safe because only one ha is possible for each limit */
2612                 ast_free_ha(ha); /* cleanup the tmp ha */
2613                 addr_range->limit = limit;
2614                 addr_range->delme = 0;
2615
2616                 /* cleanup */
2617                 if (found) {
2618                         ao2_unlock(addr_range);
2619                 } else {
2620                         ao2_link(callno_limits, addr_range);
2621                 }
2622                 ao2_ref(addr_range, -1); /* decrement ref from ao2_find and ao2_alloc, only container ref remains */
2623         }
2624 }
2625
2626 /*! 
2627  * \internal
2628  * \brief Create calltoken_ignores entry based on configuration
2629  */
2630 static int add_calltoken_ignore(const char *addr)
2631 {
2632         struct addr_range tmp;
2633         struct addr_range *addr_range = NULL;
2634         struct ast_ha *ha = NULL;
2635         int error = 0;
2636
2637         if (ast_strlen_zero(addr)) {
2638                 ast_log(LOG_WARNING, "invalid calltokenoptional %s\n", addr);
2639                 return -1;
2640         }
2641
2642         ha = ast_append_ha("permit", addr, NULL, &error);
2643
2644         /* check for valid config information */
2645         if (error) {
2646                 ast_log(LOG_WARNING, "Error %d creating calltokenoptional entry %s\n", error, addr);
2647                 return -1;
2648         }
2649
2650         ast_copy_ha(ha, &tmp.ha);
2651         /* find or create the addr_range */
2652         if ((addr_range = ao2_find(calltoken_ignores, &tmp, OBJ_POINTER))) {
2653                 ao2_lock(addr_range);
2654                 addr_range->delme = 0;
2655                 ao2_unlock(addr_range);
2656         } else if ((addr_range = ao2_alloc(sizeof(*addr_range), NULL))) {
2657                 /* copy over config data into addr_range object */
2658                 ast_copy_ha(ha, &addr_range->ha); /* this is safe because only one ha is possible */
2659                 ao2_link(calltoken_ignores, addr_range);
2660         } else {
2661                 ast_free_ha(ha);
2662                 return -1;
2663         }
2664
2665         ast_free_ha(ha);
2666         ao2_ref(addr_range, -1); /* decrement ref from ao2_find and ao2_alloc, only container ref remains */
2667
2668         return 0;
2669 }
2670
2671 static char *handle_cli_iax2_show_callno_limits(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
2672 {
2673         struct ao2_iterator i;
2674         struct peercnt *peercnt;
2675         struct sockaddr_in sin;
2676         int found = 0;
2677
2678         switch (cmd) {
2679         case CLI_INIT:
2680                 e->command = "iax2 show callnumber usage";
2681                 e->usage =
2682                         "Usage: iax2 show callnumber usage [IP address]\n"
2683                         "       Shows current IP addresses which are consuming iax2 call numbers\n";
2684                 return NULL;
2685         case CLI_GENERATE:
2686                 return NULL;
2687         case CLI_HANDLER:
2688                 if (a->argc < 4 || a->argc > 5)
2689                         return CLI_SHOWUSAGE;
2690
2691                 if (a->argc == 4) {
2692                         ast_cli(a->fd, "%-15s %-12s %-12s\n", "Address", "Callno Usage", "Callno Limit");
2693                 }
2694
2695                 i = ao2_iterator_init(peercnts, 0);
2696                 while ((peercnt = ao2_iterator_next(&i))) {
2697                         sin.sin_addr.s_addr = peercnt->addr;
2698                         if (a->argc == 5) {
2699                                 if (!strcasecmp(a->argv[4], ast_inet_ntoa(sin.sin_addr))) {
2700                                         ast_cli(a->fd, "%-15s %-12s %-12s\n", "Address", "Callno Usage", "Callno Limit");
2701                                         ast_cli(a->fd, "%-15s %-12d %-12d\n", ast_inet_ntoa(sin.sin_addr), peercnt->cur, peercnt->limit);
2702                                         ao2_ref(peercnt, -1);
2703                                         found = 1;
2704                                         break;
2705                                 }
2706                         } else {
2707                                 ast_cli(a->fd, "%-15s %-12d %-12d\n", ast_inet_ntoa(sin.sin_addr), peercnt->cur, peercnt->limit);
2708                         }
2709                         ao2_ref(peercnt, -1);
2710                 }
2711                 ao2_iterator_destroy(&i);
2712
2713                 if (a->argc == 4) {
2714                         size_t pool_avail = callno_pool.available;
2715                         size_t trunk_pool_avail = callno_pool_trunk.available;
2716
2717                         ast_cli(a->fd, "\nNon-CallToken Validation Callno Limit: %d\n"
2718                                          "Non-CallToken Validated Callno Used:   %d\n",
2719                                 global_maxcallno_nonval,
2720                                 total_nonval_callno_used);
2721
2722                         ast_cli(a->fd,   "Total Available Callno:                %zu\n"
2723                                          "Regular Callno Available:              %zu\n"
2724                                          "Trunk Callno Available:                %zu\n",
2725                                 pool_avail + trunk_pool_avail,
2726                                 pool_avail,
2727                                 trunk_pool_avail);
2728                 } else if (a->argc == 5 && !found) {
2729                         ast_cli(a->fd, "No call number table entries for %s found\n", a->argv[4] );
2730                 }
2731
2732
2733                 return CLI_SUCCESS;
2734         default:
2735                 return NULL;
2736         }
2737 }
2738
2739 static int get_unused_callno(enum callno_type type, int validated, callno_entry *entry)
2740 {
2741         struct call_number_pool *pool = NULL;
2742         callno_entry swap;
2743         size_t choice;
2744
2745         switch (type) {
2746         case CALLNO_TYPE_NORMAL:
2747                 pool = &callno_pool;
2748                 break;
2749         case CALLNO_TYPE_TRUNK:
2750                 pool = &callno_pool_trunk;
2751                 break;
2752         default:
2753                 ast_assert(0);
2754                 break;
2755         }
2756
2757         /* If we fail, make sure this has a defined value */
2758         *entry = 0;
2759
2760         /* We lock here primarily to ensure thread safety of the
2761          * total_nonval_callno_used check and increment */
2762         ast_mutex_lock(&callno_pool_lock);
2763
2764         /* Bail out if we don't have any available call numbers */
2765         if (!pool->available) {
2766                 ast_log(LOG_WARNING, "Out of call numbers\n");
2767                 ast_mutex_unlock(&callno_pool_lock);
2768                 return 1;
2769         }
2770
2771         /* Only a certain number of non-validated call numbers should be allocated.
2772          * If there ever is an attack, this separates the calltoken validating users
2773          * from the non-calltoken validating users. */
2774         if (!validated && total_nonval_callno_used >= global_maxcallno_nonval) {
2775                 ast_log(LOG_WARNING,
2776                         "NON-CallToken callnumber limit is reached. Current: %d Max: %d\n",
2777                         total_nonval_callno_used,
2778                         global_maxcallno_nonval);
2779                 ast_mutex_unlock(&callno_pool_lock);
2780                 return 1;
2781         }
2782
2783         /* We use a modified Fisher-Yates-Durstenfeld Shuffle to maintain a list of
2784          * available call numbers.  The array of call numbers begins as an ordered
2785          * list from 1 -> n, and we keep a running tally of how many remain unclaimed
2786          * - let's call that x.  When a call number is needed we pick a random index
2787          * into the array between 0 and x and use that as our call number.  In a
2788          * typical FYD shuffle, we would swap the value that we are extracting with
2789          * the number at x, but in our case we swap and don't touch the value at x
2790          * because it is effectively invisible.  We rely on the rest of the IAX2 core
2791          * to return the number to us at some point.  Finally, we decrement x by 1
2792          * which establishes our new unused range.
2793          *
2794          * When numbers are returned to the pool, we put them just past x and bump x
2795          * by 1 so that this number is now available for re-use. */
2796
2797         choice = ast_random() % pool->available;
2798
2799         *entry = pool->numbers[choice];
2800         swap = pool->numbers[pool->available - 1];
2801
2802         pool->numbers[choice] = swap;
2803         pool->available--;
2804
2805         if (validated) {
2806                 CALLNO_ENTRY_SET_VALIDATED(*entry);
2807         } else {
2808                 total_nonval_callno_used++;
2809         }
2810
2811         ast_mutex_unlock(&callno_pool_lock);
2812
2813         return 0;
2814 }
2815
2816 static int replace_callno(const void *obj)
2817 {
2818         callno_entry entry = PTR_TO_CALLNO_ENTRY(obj);
2819         struct call_number_pool *pool;
2820
2821         /* We lock here primarily to ensure thread safety of the
2822          * total_nonval_callno_used check and decrement */
2823         ast_mutex_lock(&callno_pool_lock);
2824
2825         if (!CALLNO_ENTRY_IS_VALIDATED(entry)) {
2826                 if (total_nonval_callno_used) {
2827                         total_nonval_callno_used--;
2828                 } else {
2829                         ast_log(LOG_ERROR,
2830                                 "Attempted to decrement total non calltoken validated "
2831                                 "callnumbers below zero.  Callno is: %d\n",
2832                                 CALLNO_ENTRY_GET_CALLNO(entry));
2833                 }
2834         }
2835
2836         if (CALLNO_ENTRY_GET_CALLNO(entry) < TRUNK_CALL_START) {
2837                 pool = &callno_pool;
2838         } else {
2839                 pool = &callno_pool_trunk;
2840         }
2841
2842         ast_assert(pool->capacity > pool->available);
2843
2844         /* This clears the validated flag */
2845         entry = CALLNO_ENTRY_GET_CALLNO(entry);
2846
2847         pool->numbers[pool->available] = entry;
2848         pool->available++;
2849
2850         ast_mutex_unlock(&callno_pool_lock);
2851
2852         return 0;
2853 }
2854
2855 static int create_callno_pools(void)
2856 {
2857         uint16_t i;
2858
2859         callno_pool.available = callno_pool_trunk.available = 0;
2860
2861         /* We start at 2.  0 and 1 are reserved. */
2862         for (i = 2; i < TRUNK_CALL_START; i++) {
2863                 callno_pool.numbers[callno_pool.available] = i;
2864                 callno_pool.available++;
2865         }
2866
2867         for (i = TRUNK_CALL_START; i < IAX_MAX_CALLS; i++) {
2868                 callno_pool_trunk.numbers[callno_pool_trunk.available] = i;
2869                 callno_pool_trunk.available++;
2870         }
2871
2872         callno_pool.capacity = callno_pool.available;
2873         callno_pool_trunk.capacity = callno_pool_trunk.available;
2874
2875         ast_assert(callno_pool.capacity && callno_pool_trunk.capacity);
2876
2877         return 0;
2878 }
2879
2880 /*!
2881  * \internal
2882  * \brief Schedules delayed removal of iax2_pvt call number data
2883  *
2884  * \note After MIN_REUSE_TIME has passed for a destroyed iax2_pvt, the callno is
2885  * avaliable again, and the address from the previous connection must be decremented
2886  * from the peercnts table.  This function schedules these operations to take place.
2887  */
2888 static void sched_delay_remove(struct sockaddr_in *sin, callno_entry entry)
2889 {
2890         int i;
2891         struct peercnt *peercnt;
2892         struct peercnt tmp = {
2893                 .addr = sin->sin_addr.s_addr,
2894         };
2895
2896         if ((peercnt = ao2_find(peercnts, &tmp, OBJ_POINTER))) {
2897                 /* refcount is incremented with ao2_find.  keep that ref for the scheduler */
2898                 ast_debug(1, "schedule decrement of callno used for %s in %d seconds\n", ast_inet_ntoa(sin->sin_addr), MIN_REUSE_TIME);
2899                 i = iax2_sched_add(sched, MIN_REUSE_TIME * 1000, peercnt_remove_cb, peercnt);
2900                 if (i == -1) {
2901                         ao2_ref(peercnt, -1);
2902                 }
2903         }
2904
2905         iax2_sched_add(
2906                 sched,
2907                 MIN_REUSE_TIME * 1000,
2908                 replace_callno,
2909                 CALLNO_ENTRY_TO_PTR(entry));
2910 }
2911
2912 /*! 
2913  * \internal
2914  * \brief returns whether or not a frame is capable of starting a new IAX2 dialog. 
2915  *
2916  * \note For this implementation, inbound pokes should _NOT_ be capable of allocating
2917  * a new callno.
2918  */
2919 static inline int attribute_pure iax2_allow_new(int frametype, int subclass, int inbound)
2920 {
2921         if (frametype != AST_FRAME_IAX) {
2922                 return 0;
2923         }
2924         switch (subclass) {
2925         case IAX_COMMAND_NEW:
2926         case IAX_COMMAND_REGREQ:
2927         case IAX_COMMAND_FWDOWNL:
2928         case IAX_COMMAND_REGREL:
2929                 return 1;
2930         case IAX_COMMAND_POKE:
2931                 if (!inbound) {
2932                         return 1;
2933                 }
2934                 break;
2935         }
2936         return 0;
2937 }
2938
2939 /*
2940  * \note Calling this function while holding another pvt lock can cause a deadlock.
2941  */
2942 static int __find_callno(unsigned short callno, unsigned short dcallno, struct sockaddr_in *sin, int new, int sockfd, int return_locked, int check_dcallno)
2943 {
2944         int res = 0;
2945         int x;
2946         /* this call is calltoken validated as long as it is either NEW_FORCE
2947          * or NEW_ALLOW_CALLTOKEN_VALIDATED */
2948         int validated = (new > NEW_ALLOW) ? 1 : 0;
2949         char host[80];
2950
2951         if (new <= NEW_ALLOW) {
2952                 if (callno) {
2953                         struct chan_iax2_pvt *pvt;
2954                         struct chan_iax2_pvt tmp_pvt = {
2955                                 .callno = dcallno,
2956                                 .peercallno = callno,
2957                                 .transfercallno = callno,
2958                                 /* hack!! */
2959                                 .frames_received = check_dcallno,
2960                         };
2961
2962                         memcpy(&tmp_pvt.addr, sin, sizeof(tmp_pvt.addr));
2963                         /* this works for finding normal call numbers not involving transfering */ 
2964                         if ((pvt = ao2_find(iax_peercallno_pvts, &tmp_pvt, OBJ_POINTER))) {
2965                                 if (return_locked) {
2966                                         ast_mutex_lock(&iaxsl[pvt->callno]);
2967                                 }
2968                                 res = pvt->callno;
2969                                 ao2_ref(pvt, -1);
2970                                 pvt = NULL;
2971                                 return res;
2972                         }
2973                         /* this searches for transfer call numbers that might not get caught otherwise */
2974                         memset(&tmp_pvt.addr, 0, sizeof(tmp_pvt.addr));
2975                         memcpy(&tmp_pvt.transfer, sin, sizeof(tmp_pvt.transfer));
2976                         if ((pvt = ao2_find(iax_transfercallno_pvts, &tmp_pvt, OBJ_POINTER))) {
2977                                 if (return_locked) {
2978                                         ast_mutex_lock(&iaxsl[pvt->callno]);
2979                                 }
2980                                 res = pvt->callno;
2981                                 ao2_ref(pvt, -1);
2982                                 pvt = NULL;
2983                                 return res;
2984                         }
2985                 }
2986                         /* This will occur on the first response to a message that we initiated,
2987                  * such as a PING. */
2988                 if (dcallno) {
2989                         ast_mutex_lock(&iaxsl[dcallno]);
2990                 }
2991                 if (callno && dcallno && iaxs[dcallno] && !iaxs[dcallno]->peercallno && match(sin, callno, dcallno, iaxs[dcallno], check_dcallno)) {
2992                         iaxs[dcallno]->peercallno = callno;
2993                         res = dcallno;
2994                         store_by_peercallno(iaxs[dcallno]);
2995                         if (!res || !return_locked) {
2996                                 ast_mutex_unlock(&iaxsl[dcallno]);
2997                         }
2998                         return res;
2999                 }
3000                 if (dcallno) {
3001                         ast_mutex_unlock(&iaxsl[dcallno]);
3002                 }
3003         }
3004         if (!res && (new >= NEW_ALLOW)) {
3005                 callno_entry entry;
3006                 /* It may seem odd that we look through the peer list for a name for
3007                  * this *incoming* call.  Well, it is weird.  However, users don't
3008                  * have an IP address/port number that we can match against.  So,
3009                  * this is just checking for a peer that has that IP/port and
3010                  * assuming that we have a user of the same name.  This isn't always
3011                  * correct, but it will be changed if needed after authentication. */
3012                 if (!iax2_getpeername(*sin, host, sizeof(host)))
3013                         snprintf(host, sizeof(host), "%s:%d", ast_inet_ntoa(sin->sin_addr), ntohs(sin->sin_port));
3014
3015                 if (peercnt_add(sin)) {
3016                         /* This address has hit its callnumber limit.  When the limit
3017                          * is reached, the connection is not added to the peercnts table.*/
3018                         return 0;
3019                 }
3020
3021                 if (get_unused_callno(CALLNO_TYPE_NORMAL, validated, &entry)) {
3022                         /* since we ran out of space, remove the peercnt
3023                          * entry we added earlier */
3024                         peercnt_remove_by_addr(sin);
3025                         ast_log(LOG_WARNING, "No more space\n");
3026                         return 0;
3027                 }
3028                 x = CALLNO_ENTRY_GET_CALLNO(entry);
3029                 ast_mutex_lock(&iaxsl[x]);
3030
3031                 iaxs[x] = new_iax(sin, host);
3032                 if (iaxs[x]) {
3033                         if (iaxdebug)
3034                                 ast_debug(1, "Creating new call structure %d\n", x);
3035                         iaxs[x]->callno_entry = entry;
3036                         iaxs[x]->sockfd = sockfd;
3037                         iaxs[x]->addr.sin_port = sin->sin_port;
3038                         iaxs[x]->addr.sin_family = sin->sin_family;
3039                         iaxs[x]->addr.sin_addr.s_addr = sin->sin_addr.s_addr;
3040                         iaxs[x]->peercallno = callno;
3041                         iaxs[x]->callno = x;
3042                         iaxs[x]->pingtime = DEFAULT_RETRY_TIME;
3043                         iaxs[x]->expiry = min_reg_expire;
3044                         iaxs[x]->pingid = iax2_sched_add(sched, ping_time * 1000, send_ping, (void *)(long)x);
3045                         iaxs[x]->lagid = iax2_sched_add(sched, lagrq_time * 1000, send_lagrq, (void *)(long)x);
3046                         iaxs[x]->amaflags = amaflags;
3047                         ast_copy_flags64(iaxs[x], &globalflags, IAX_NOTRANSFER | IAX_TRANSFERMEDIA | IAX_USEJITTERBUF | IAX_FORCEJITTERBUF | IAX_SENDCONNECTEDLINE | IAX_RECVCONNECTEDLINE | IAX_FORCE_ENCRYPT);
3048                         ast_string_field_set(iaxs[x], accountcode, accountcode);
3049                         ast_string_field_set(iaxs[x], mohinterpret, mohinterpret);
3050                         ast_string_field_set(iaxs[x], mohsuggest, mohsuggest);
3051                         ast_string_field_set(iaxs[x], parkinglot, default_parkinglot);
3052
3053                         if (iaxs[x]->peercallno) {
3054                                 store_by_peercallno(iaxs[x]);
3055                         }
3056                 } else {
3057                         ast_log(LOG_WARNING, "Out of resources\n");
3058                         ast_mutex_unlock(&iaxsl[x]);
3059                         replace_callno(CALLNO_ENTRY_TO_PTR(entry));
3060                         return 0;
3061                 }
3062                 if (!return_locked)
3063                         ast_mutex_unlock(&iaxsl[x]);
3064                 res = x;
3065         }
3066         return res;
3067 }
3068
3069 static int find_callno(unsigned short callno, unsigned short dcallno, struct sockaddr_in *sin, int new, int sockfd, int full_frame) { 
3070         return __find_callno(callno, dcallno, sin, new, sockfd, 0, full_frame);
3071 }
3072
3073 static int find_callno_locked(unsigned short callno, unsigned short dcallno, struct sockaddr_in *sin, int new, int sockfd, int full_frame) {
3074
3075         return __find_callno(callno, dcallno, sin, new, sockfd, 1, full_frame);
3076 }
3077
3078 /*!
3079  * \brief Queue a frame to a call's owning asterisk channel
3080  *
3081  * \pre This function assumes that iaxsl[callno] is locked when called.
3082  *
3083  * \note IMPORTANT NOTE!!! Any time this function is used, even if iaxs[callno]
3084  * was valid before calling it, it may no longer be valid after calling it.
3085  * This function may unlock and lock the mutex associated with this callno,
3086  * meaning that another thread may grab it and destroy the call.
3087  */
3088 static int iax2_queue_frame(int callno, struct ast_frame *f)
3089 {
3090         iax2_lock_owner(callno);
3091         if (iaxs[callno] && iaxs[callno]->owner) {
3092                 ast_queue_frame(iaxs[callno]->owner, f);
3093                 ast_channel_unlock(iaxs[callno]->owner);
3094         }
3095         return 0;
3096 }
3097
3098 /*!
3099  * \brief Queue a hangup frame on the ast_channel owner
3100  *
3101  * This function queues a hangup frame on the owner of the IAX2 pvt struct that
3102  * is active for the given call number.
3103  *
3104  * \pre Assumes lock for callno is already held.
3105  *
3106  * \note IMPORTANT NOTE!!! Any time this function is used, even if iaxs[callno]
3107  * was valid before calling it, it may no longer be valid after calling it.
3108  * This function may unlock and lock the mutex associated with this callno,
3109  * meaning that another thread may grab it and destroy the call.
3110  */
3111 static int iax2_queue_hangup(int callno)
3112 {
3113         iax2_lock_owner(callno);
3114         if (iaxs[callno] && iaxs[callno]->owner) {
3115                 ast_queue_hangup(iaxs[callno]->owner);
3116                 ast_channel_unlock(iaxs[callno]->owner);
3117         }
3118         return 0;
3119 }
3120
3121 /*!
3122  * \brief Queue a control frame on the ast_channel owner
3123  *
3124  * This function queues a control frame on the owner of the IAX2 pvt struct that
3125  * is active for the given call number.
3126  *
3127  * \pre Assumes lock for callno is already held.
3128  *
3129  * \note IMPORTANT NOTE!!! Any time this function is used, even if iaxs[callno]
3130  * was valid before calling it, it may no longer be valid after calling it.
3131  * This function may unlock and lock the mutex associated with this callno,
3132  * meaning that another thread may grab it and destroy the call.
3133  */
3134 static int iax2_queue_control_data(int callno, 
3135         enum ast_control_frame_type control, const void *data, size_t datalen)
3136 {
3137         iax2_lock_owner(callno);
3138         if (iaxs[callno] && iaxs[callno]->owner) {
3139                 ast_queue_control_data(iaxs[callno]->owner, control, data, datalen);
3140                 ast_channel_unlock(iaxs[callno]->owner);
3141         }
3142         return 0;
3143 }
3144
3145 /*!
3146  * \note This function assumes that iaxsl[callno] is locked when called.
3147  *
3148  * \note IMPORTANT NOTE!!! Any time this function is used, even if iaxs[callno]
3149  * was valid before calling it, it may no longer be valid after calling it.
3150  * This function calls iax2_queue_frame(), which may unlock and lock the mutex 
3151  * associated with this callno, meaning that another thread may grab it and destroy the call.
3152  */
3153 static int __do_deliver(void *data)
3154 {
3155         /* Just deliver the packet by using queueing.  This is called by
3156           the IAX thread with the iaxsl lock held. */
3157         struct iax_frame *fr = data;
3158         fr->retrans = -1;
3159         ast_clear_flag(&fr->af, AST_FRFLAG_HAS_TIMING_INFO);
3160         if (iaxs[fr->callno] && !ast_test_flag64(iaxs[fr->callno], IAX_ALREADYGONE))
3161                 iax2_queue_frame(fr->callno, &fr->af);
3162         /* Free our iax frame */
3163         iax2_frame_free(fr);
3164         /* And don't run again */
3165         return 0;
3166 }
3167
3168 static int handle_error(void)
3169 {
3170         /* XXX Ideally we should figure out why an error occurred and then abort those
3171            rather than continuing to try.  Unfortunately, the published interface does
3172            not seem to work XXX */
3173 #if 0
3174         struct sockaddr_in *sin;
3175         int res;
3176         struct msghdr m;
3177         struct sock_extended_err e;
3178         m.msg_name = NULL;
3179         m.msg_namelen = 0;
3180         m.msg_iov = NULL;
3181         m.msg_control = &e;
3182         m.msg_controllen = sizeof(e);
3183         m.msg_flags = 0;
3184         res = recvmsg(netsocket, &m, MSG_ERRQUEUE);
3185         if (res < 0)
3186                 ast_log(LOG_WARNING, "Error detected, but unable to read error: %s\n", strerror(errno));
3187         else {
3188                 if (m.msg_controllen) {
3189                         sin = (struct sockaddr_in *)SO_EE_OFFENDER(&e);
3190                         if (sin) 
3191                                 ast_log(LOG_WARNING, "Receive error from %s\n", ast_inet_ntoa(sin->sin_addr));
3192                         else
3193                                 ast_log(LOG_WARNING, "No address detected??\n");
3194                 } else {
3195                         ast_log(LOG_WARNING, "Local error: %s\n", strerror(e.ee_errno));
3196                 }
3197         }
3198 #endif
3199         return 0;
3200 }
3201
3202 static int transmit_trunk(struct iax_frame *f, struct sockaddr_in *sin, int sockfd)
3203 {
3204         int res;
3205         res = sendto(sockfd, f->data, f->datalen, 0,(struct sockaddr *)sin,
3206                                         sizeof(*sin));
3207         if (res < 0) {
3208                 ast_debug(1, "Received error: %s\n", strerror(errno));
3209                 handle_error();
3210         } else
3211                 res = 0;
3212         return res;
3213 }
3214
3215 static int send_packet(struct iax_frame *f)
3216 {
3217         int res;
3218         int callno = f->callno;
3219
3220         /* Don't send if there was an error, but return error instead */
3221         if (!callno || !iaxs[callno] || iaxs[callno]->error)
3222             return -1;
3223
3224         /* Called with iaxsl held */
3225         if (iaxdebug)
3226                 ast_debug(3, "Sending %d on %d/%d to %s:%d\n", f->ts, callno, iaxs[callno]->peercallno, ast_inet_ntoa(iaxs[callno]->addr.sin_addr), ntohs(iaxs[callno]->addr.sin_port));
3227
3228         if (f->transfer) {
3229                 iax_outputframe(f, NULL, 0, &iaxs[callno]->transfer, f->datalen - sizeof(struct ast_iax2_full_hdr));
3230                 res = sendto(iaxs[callno]->sockfd, f->data, f->datalen, 0,(struct sockaddr *)&iaxs[callno]->transfer, sizeof(iaxs[callno]->transfer));
3231         } else {
3232                 iax_outputframe(f, NULL, 0, &iaxs[callno]->addr, f->datalen - sizeof(struct ast_iax2_full_hdr));
3233                 res = sendto(iaxs[callno]->sockfd, f->data, f->datalen, 0,(struct sockaddr *)&iaxs[callno]->addr, sizeof(iaxs[callno]->addr));
3234         }
3235         if (res < 0) {
3236                 if (iaxdebug)
3237                         ast_debug(1, "Received error: %s\n", strerror(errno));
3238                 handle_error();
3239         } else
3240                 res = 0;
3241
3242         return res;
3243 }
3244
3245 /*!
3246  * \note Since this function calls iax2_queue_hangup(), the pvt struct
3247  *       for the given call number may disappear during its execution.
3248  */
3249 static int iax2_predestroy(int callno)
3250 {
3251         struct ast_channel *c = NULL;
3252         struct chan_iax2_pvt *pvt = iaxs[callno];
3253
3254         if (!pvt)
3255                 return -1;
3256
3257         if (!ast_test_flag64(pvt, IAX_ALREADYGONE)) {
3258                 iax2_destroy_helper(pvt);
3259                 ast_set_flag64(pvt, IAX_ALREADYGONE);
3260         }
3261
3262         if ((c = pvt->owner)) {
3263                 ast_channel_tech_pvt_set(c, NULL);
3264                 iax2_queue_hangup(callno);
3265                 pvt->owner = NULL;
3266                 ast_module_unref(ast_module_info->self);
3267         }
3268
3269         return 0;
3270 }
3271
3272 static void iax2_destroy(int callno)
3273 {
3274         struct chan_iax2_pvt *pvt = NULL;
3275         struct ast_channel *owner = NULL;
3276
3277 retry:
3278         if ((pvt = iaxs[callno])) {
3279 #if 0
3280                 /* iax2_destroy_helper gets called from this function later on.  When
3281                  * called twice, we get the (previously) familiar FRACK! errors in
3282                  * devmode, from the scheduler.  An alternative to this approach is to
3283                  * reset the scheduler entries to -1 when they're deleted in
3284                  * iax2_destroy_helper().  That approach was previously decided to be
3285   &n