/* * Asterisk -- A telephony toolkit for Linux. * * Implementation of Inter-Asterisk eXchange Version 2 * * Copyright (C) 2003-2004, Digium, Inc. * * Mark Spencer * * This program is free software, distributed under the terms of * the GNU General Public License */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifdef IAX_TRUNKING #include #ifdef __linux__ #include #else #include #endif /* __linux__ */ #endif #ifdef MYSQL_FRIENDS #include #endif #include "iax2.h" #include "iax2-parser.h" #include "iax2-provision.h" #include "../astconf.h" #ifndef IPTOS_MINCOST #define IPTOS_MINCOST 0x02 #endif /* * Uncomment to try experimental IAX bridge optimization, * designed to reduce latency when IAX calls cannot * be trasnferred */ #define BRIDGE_OPTIMIZATION #define PTR_TO_CALLNO(a) ((unsigned short)(unsigned long)(a)) #define CALLNO_TO_PTR(a) ((void *)(unsigned long)(a)) #define DEFAULT_RETRY_TIME 1000 #define MEMORY_SIZE 100 #define DEFAULT_DROP 3 /* Flag to use with trunk calls, keeping these calls high up. It halves our effective use but keeps the division between trunked and non-trunked better. */ #define TRUNK_CALL_START 0x4000 #define DEBUG_SUPPORT #define MIN_REUSE_TIME 60 /* Don't reuse a call number within 60 seconds */ /* Sample over last 100 units to determine historic jitter */ #define GAMMA (0.01) #ifdef MYSQL_FRIENDS AST_MUTEX_DEFINE_STATIC(mysqllock); static MYSQL *mysql; static char mydbuser[80]; static char mydbpass[80]; static char mydbhost[80]; static char mydbname[80]; #endif static char *desc = "Inter Asterisk eXchange (Ver 2)"; static char *tdesc = "Inter Asterisk eXchange Driver (Ver 2)"; static char *type = "IAX2"; static char context[80] = "default"; static char language[MAX_LANGUAGE] = ""; static char regcontext[AST_MAX_EXTENSION] = ""; static int max_retries = 4; static int ping_time = 20; static int lagrq_time = 10; static int maxtrunkcall = TRUNK_CALL_START; static int maxnontrunkcall = 1; static int maxjitterbuffer=1000; static int jittershrinkrate=2; static int trunkfreq = 20; static int authdebug = 1; static int iaxcompat = 0; static int iaxdefaultdpcache=10 * 60; /* Cache dialplan entries for 10 minutes by default */ static int iaxdefaulttimeout = 5; /* Default to wait no more than 5 seconds for a reply to come back */ static int netsocket = -1; static int tos = 0; static int expirey = IAX_DEFAULT_REG_EXPIRE; static int timingfd = -1; /* Timing file descriptor */ static int usecnt; AST_MUTEX_DEFINE_STATIC(usecnt_lock); int (*iax2_regfunk)(char *username, int onoff) = NULL; /* Ethernet, etc */ #define IAX_CAPABILITY_FULLBANDWIDTH 0xFFFF /* T1, maybe ISDN */ #define IAX_CAPABILITY_MEDBANDWIDTH (IAX_CAPABILITY_FULLBANDWIDTH & \ ~AST_FORMAT_SLINEAR & \ ~AST_FORMAT_ULAW & \ ~AST_FORMAT_ALAW) /* A modem */ #define IAX_CAPABILITY_LOWBANDWIDTH (IAX_CAPABILITY_MEDBANDWIDTH & \ ~AST_FORMAT_G726 & \ ~AST_FORMAT_ADPCM) #define IAX_CAPABILITY_LOWFREE (IAX_CAPABILITY_LOWBANDWIDTH & \ ~AST_FORMAT_G723_1) #define DEFAULT_MAXMS 2000 /* Must be faster than 2 seconds by default */ #define DEFAULT_FREQ_OK 60 * 1000 /* How often to check for the host to be up */ #define DEFAULT_FREQ_NOTOK 10 * 1000 /* How often to check, if the host is down... */ static struct io_context *io; static struct sched_context *sched; static int iax2_capability = IAX_CAPABILITY_FULLBANDWIDTH; static int iax2_dropcount = DEFAULT_DROP; static int use_jitterbuffer = 0; static int iaxdebug = 0; static int iaxtrunkdebug = 0; static char accountcode[20]; static int amaflags = 0; static int globalnotransfer = 0; static int delayreject = 0; static int globalmessagedetail = 0; static pthread_t netthreadid = AST_PTHREADT_NULL; #define IAX_STATE_STARTED (1 << 0) #define IAX_STATE_AUTHENTICATED (1 << 1) #define IAX_STATE_TBD (1 << 2) struct iax2_context { char context[AST_MAX_EXTENSION]; struct iax2_context *next; }; struct iax2_user { char name[80]; char secret[80]; int authmethods; char accountcode[20]; char inkeys[80]; /* Key(s) this user can use to authenticate to us */ char language[MAX_LANGUAGE]; int amaflags; int hascallerid; int delme; int temponly; int capability; int trunk; char callerid[AST_MAX_EXTENSION]; struct ast_ha *ha; struct iax2_context *contexts; struct iax2_user *next; int notransfer; }; struct iax2_peer { char name[80]; char username[80]; char secret[80]; char outkey[80]; /* What key we use to talk to this peer */ char context[AST_MAX_EXTENSION]; /* Default context (for transfer really) */ char regexten[AST_MAX_EXTENSION]; /* Extension to register (if regcontext is used) */ char peercontext[AST_MAX_EXTENSION]; /* Context to pass to peer */ char mailbox[AST_MAX_EXTENSION]; /* Mailbox */ struct sockaddr_in addr; int formats; struct in_addr mask; /* Dynamic Registration fields */ int dynamic; /* If this is a dynamic peer */ struct sockaddr_in defaddr; /* Default address if there is one */ int authmethods; /* Authentication methods (IAX_AUTH_*) */ char inkeys[80]; /* Key(s) this peer can use to authenticate to us */ int hascallerid; /* Suggested caller id if registering */ char callerid[AST_MAX_EXTENSION]; /* Whether or not to send ANI */ int sendani; int expire; /* Schedule entry for expirey */ int expirey; /* How soon to expire */ int capability; /* Capability */ int delme; /* I need to be deleted */ int temponly; /* I'm only a temp */ int trunk; /* Treat as an IAX trunking */ int messagedetail; /* Show exact numbers? */ /* Qualification */ int callno; /* Call number of POKE request */ int pokeexpire; /* When to expire poke */ int lastms; /* How long last response took (in ms), or -1 for no response */ int maxms; /* Max ms we will accept for the host to be up, 0 to not monitor */ struct ast_ha *ha; struct iax2_peer *next; int notransfer; }; #define IAX2_TRUNK_PREFACE (sizeof(struct iax_frame) + sizeof(struct ast_iax2_meta_hdr) + sizeof(struct ast_iax2_meta_trunk_hdr)) static struct iax2_trunk_peer { ast_mutex_t lock; struct sockaddr_in addr; struct timeval txtrunktime; /* Transmit trunktime */ struct timeval rxtrunktime; /* Receive trunktime */ struct timeval lasttxtime; /* Last transmitted trunktime */ struct timeval trunkact; /* Last trunk activity */ unsigned int lastsent; /* Last sent time */ /* Trunk data and length */ unsigned char *trunkdata; unsigned int trunkdatalen; unsigned int trunkdataalloc; struct iax2_trunk_peer *next; int trunkerror; int calls; } *tpeers = NULL; AST_MUTEX_DEFINE_STATIC(tpeerlock); struct iax_firmware { struct iax_firmware *next; int fd; int mmaplen; int dead; struct ast_iax2_firmware_header *fwh; unsigned char *buf; }; #define REG_STATE_UNREGISTERED 0 #define REG_STATE_REGSENT 1 #define REG_STATE_AUTHSENT 2 #define REG_STATE_REGISTERED 3 #define REG_STATE_REJECTED 4 #define REG_STATE_TIMEOUT 5 #define REG_STATE_NOAUTH 6 #define TRANSFER_NONE 0 #define TRANSFER_BEGIN 1 #define TRANSFER_READY 2 #define TRANSFER_RELEASED 3 #define TRANSFER_PASSTHROUGH 4 struct iax2_registry { struct sockaddr_in addr; /* Who we connect to for registration purposes */ char username[80]; char secret[80]; /* Password or key name in []'s */ char random[80]; int expire; /* Sched ID of expiration */ int refresh; /* How often to refresh */ int regstate; int messages; /* Message count */ int callno; /* Associated call number if applicable */ struct sockaddr_in us; /* Who the server thinks we are */ struct iax2_registry *next; }; static struct iax2_registry *registrations; /* Don't retry more frequently than every 10 ms, or less frequently than every 5 seconds */ #define MIN_RETRY_TIME 100 #define MAX_RETRY_TIME 10000 #define MAX_JITTER_BUFFER 50 #define MIN_JITTER_BUFFER 10 #define DEFAULT_TRUNKDATA 640 * 10 /* 40ms, uncompressed linear * 10 channels */ #define MAX_TRUNKDATA 640 * 200 /* 40ms, uncompressed linear * 200 channels */ #define MAX_TIMESTAMP_SKEW 640 /* If we have more than this much excess real jitter buffer, shrink it. */ static int max_jitter_buffer = MAX_JITTER_BUFFER; /* If we have less than this much excess real jitter buffer, enlarge it. */ static int min_jitter_buffer = MIN_JITTER_BUFFER; struct chan_iax2_pvt { /* Pipes for communication. pipe[1] belongs to the network thread (write), and pipe[0] belongs to the individual channel (read) */ /* Whether or not we Quelch audio */ int quelch; /* Last received voice format */ int voiceformat; /* Last received voice format */ int videoformat; /* Last sent voice format */ int svoiceformat; /* Last sent video format */ int svideoformat; /* What we are capable of sending */ int capability; /* Last received timestamp */ unsigned int last; /* Last sent timestamp - never send the same timestamp twice in a single call */ unsigned int lastsent; /* Next outgoing timestamp if everything is good */ unsigned int nextpred; /* Ping time */ unsigned int pingtime; /* Max time for initial response */ int maxtime; /* Peer Address */ struct sockaddr_in addr; /* Our call number */ unsigned short callno; /* Peer callno */ unsigned short peercallno; /* Peer selected format */ int peerformat; /* Peer capability */ int peercapability; /* timeval that we base our transmission on */ struct timeval offset; /* timeval that we base our delivery on */ struct timeval rxcore; /* Historical delivery time */ int history[MEMORY_SIZE]; /* Current base jitterbuffer */ int jitterbuffer; /* Current jitter measure */ int jitter; /* Historic jitter value */ int historicjitter; /* LAG */ int lag; /* Error, as discovered by the manager */ int error; /* Owner if we have one */ struct ast_channel *owner; /* What's our state? */ int state; /* Expirey (optional) */ int expirey; /* Next outgoing sequence number */ unsigned char oseqno; /* Next sequence number they have not yet acknowledged */ unsigned char rseqno; /* Next incoming sequence number */ unsigned char iseqno; /* Last incoming sequence number we have acknowledged */ unsigned char aseqno; /* Peer name */ char peer[80]; /* Default Context */ char context[80]; /* Caller ID if available */ char callerid[80]; /* Hidden Caller ID (i.e. ANI) if appropriate */ char ani[80]; /* Whether or not ani should be transmitted in addition to Caller*ID */ int sendani; /* Whether to request autoanswer */ int autoanswer; /* DNID */ char dnid[80]; /* Requested Extension */ char exten[AST_MAX_EXTENSION]; /* Expected Username */ char username[80]; /* Expected Secret */ char secret[80]; /* permitted authentication methods */ int authmethods; /* MD5 challenge */ char challenge[10]; /* Public keys permitted keys for incoming authentication */ char inkeys[80]; /* Private key for outgoing authentication */ char outkey[80]; /* Preferred language */ char language[MAX_LANGUAGE]; /* Hostname/peername for naming purposes */ char host[80]; /* Associated registry */ struct iax2_registry *reg; /* Associated peer for poking */ struct iax2_peer *peerpoke; /* Transferring status */ int transferring; /* Transfer identifier */ int transferid; /* Already disconnected */ int alreadygone; /* Who we are IAX transfering to */ struct sockaddr_in transfer; /* What's the new call number for the transfer */ unsigned short transfercallno; /* Status of knowledge of peer ADSI capability */ int peeradsicpe; /* Who we are bridged to */ unsigned short bridgecallno; unsigned int bridgesfmt; struct ast_trans_pvt *bridgetrans; /* If this is a provisioning request */ int provision; int pingid; /* Transmit PING request */ int lagid; /* Retransmit lag request */ int autoid; /* Auto hangup for Dialplan requestor */ int authid; /* Authentication rejection ID */ int authfail; /* Reason to report failure */ int initid; /* Initial peer auto-congest ID (based on qualified peers) */ char dproot[AST_MAX_EXTENSION]; char accountcode[20]; int amaflags; /* This is part of a trunk interface */ int trunk; struct iax2_dpcache *dpentries; int notransfer; /* do we want native bridging */ }; static struct ast_iax2_queue { struct iax_frame *head; struct iax_frame *tail; int count; ast_mutex_t lock; } iaxq; static struct ast_user_list { struct iax2_user *users; ast_mutex_t lock; } userl; static struct ast_peer_list { struct iax2_peer *peers; ast_mutex_t lock; } peerl; static struct ast_firmware_list { struct iax_firmware *wares; ast_mutex_t lock; } waresl; /* Extension exists */ #define CACHE_FLAG_EXISTS (1 << 0) /* Extension is non-existant */ #define CACHE_FLAG_NONEXISTANT (1 << 1) /* Extension can exist */ #define CACHE_FLAG_CANEXIST (1 << 2) /* Waiting to hear back response */ #define CACHE_FLAG_PENDING (1 << 3) /* Timed out */ #define CACHE_FLAG_TIMEOUT (1 << 4) /* Request transmitted */ #define CACHE_FLAG_TRANSMITTED (1 << 5) /* Timeout */ #define CACHE_FLAG_UNKNOWN (1 << 6) /* Matchmore */ #define CACHE_FLAG_MATCHMORE (1 << 7) static struct iax2_dpcache { char peercontext[AST_MAX_EXTENSION]; char exten[AST_MAX_EXTENSION]; struct timeval orig; struct timeval expirey; int flags; unsigned short callno; int waiters[256]; struct iax2_dpcache *next; struct iax2_dpcache *peer; /* For linking in peers */ } *dpcache; AST_MUTEX_DEFINE_STATIC(dpcache_lock); static void iax_debug_output(const char *data) { if (iaxdebug) ast_verbose(data); } static void iax_error_output(const char *data) { ast_log(LOG_WARNING, data); } /* XXX We probably should use a mutex when working with this XXX */ static struct chan_iax2_pvt *iaxs[IAX_MAX_CALLS]; static ast_mutex_t iaxsl[IAX_MAX_CALLS]; static struct timeval lastused[IAX_MAX_CALLS]; static int send_command(struct chan_iax2_pvt *, char, int, unsigned int, char *, int, int); static int send_command_locked(unsigned short callno, char, int, unsigned int, char *, int, int); static int send_command_immediate(struct chan_iax2_pvt *, char, int, unsigned int, char *, int, int); static int send_command_final(struct chan_iax2_pvt *, char, int, unsigned int, char *, int, int); static int send_command_transfer(struct chan_iax2_pvt *, char, int, unsigned int, char *, int); static unsigned int calc_timestamp(struct chan_iax2_pvt *p, unsigned int ts, struct ast_frame *f); static int send_ping(void *data) { int callno = (long)data; /* Ping only if it's real, not if it's bridged */ if (iaxs[callno]) { #ifdef BRIDGE_OPTIMIZATION if (!iaxs[callno]->bridgecallno) #endif send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_PING, 0, NULL, 0, -1); return 1; } else return 0; } static int send_lagrq(void *data) { int callno = (long)data; /* Ping only if it's real not if it's bridged */ if (iaxs[callno]) { #ifdef BRIDGE_OPTIMIZATION if (!iaxs[callno]->bridgecallno) #endif send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_LAGRQ, 0, NULL, 0, -1); return 1; } else return 0; } static unsigned char compress_subclass(int subclass) { int x; int power=-1; /* If it's 128 or smaller, just return it */ if (subclass < IAX_FLAG_SC_LOG) return subclass; /* Otherwise find its power */ for (x = 0; x < IAX_MAX_SHIFT; x++) { if (subclass & (1 << x)) { if (power > -1) { ast_log(LOG_WARNING, "Can't compress subclass %d\n", subclass); return 0; } else power = x; } } return power | IAX_FLAG_SC_LOG; } static int uncompress_subclass(unsigned char csub) { /* If the SC_LOG flag is set, return 2^csub otherwise csub */ if (csub & IAX_FLAG_SC_LOG) { /* special case for 'compressed' -1 */ if (csub == 0xff) return -1; else return 1 << (csub & ~IAX_FLAG_SC_LOG & IAX_MAX_SHIFT); } else return csub; } static int iax2_getpeername(struct sockaddr_in sin, char *host, int len, int lockpeer) { struct iax2_peer *peer; int res = 0; if (lockpeer) ast_mutex_lock(&peerl.lock); peer = peerl.peers; while(peer) { if ((peer->addr.sin_addr.s_addr == sin.sin_addr.s_addr) && (peer->addr.sin_port == sin.sin_port)) { strncpy(host, peer->name, len-1); res = 1; break; } peer = peer->next; } if (lockpeer) ast_mutex_unlock(&peerl.lock); return res; } static struct chan_iax2_pvt *new_iax(struct sockaddr_in *sin, int lockpeer) { struct chan_iax2_pvt *tmp; char iabuf[INET_ADDRSTRLEN]; tmp = malloc(sizeof(struct chan_iax2_pvt)); if (tmp) { memset(tmp, 0, sizeof(struct chan_iax2_pvt)); tmp->callno = 0; tmp->peercallno = 0; tmp->transfercallno = 0; tmp->bridgecallno = 0; tmp->pingid = -1; tmp->lagid = -1; tmp->autoid = -1; tmp->authid = -1; tmp->initid = -1; /* strncpy(tmp->context, context, sizeof(tmp->context)-1); */ strncpy(tmp->exten, "s", sizeof(tmp->exten)-1); if (!iax2_getpeername(*sin, tmp->host, sizeof(tmp->host), lockpeer)) snprintf(tmp->host, sizeof(tmp->host), "%s:%d", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), ntohs(sin->sin_port)); } return tmp; } static int get_samples(struct ast_frame *f) { int samples=0; switch(f->subclass) { case AST_FORMAT_SPEEX: samples = 160; /* XXX Not necessarily true XXX */ break; case AST_FORMAT_G723_1: samples = 240 /* XXX Not necessarily true XXX */; break; case AST_FORMAT_ILBC: samples = 240 * (f->datalen / 50); break; case AST_FORMAT_GSM: samples = 160 * (f->datalen / 33); break; case AST_FORMAT_G729A: samples = 160 * (f->datalen / 20); break; case AST_FORMAT_SLINEAR: samples = f->datalen / 2; break; case AST_FORMAT_LPC10: samples = 22 * 8; samples += (((char *)(f->data))[7] & 0x1) * 8; break; case AST_FORMAT_ULAW: samples = f->datalen; break; case AST_FORMAT_ALAW: samples = f->datalen; break; case AST_FORMAT_ADPCM: case AST_FORMAT_G726: samples = f->datalen *2; break; default: ast_log(LOG_WARNING, "Don't know how to calculate samples on %d packets\n", f->subclass); } return samples; } static struct iax_frame *iaxfrdup2(struct iax_frame *fr) { /* Malloc() a copy of a frame */ struct iax_frame *new = iax_frame_new(DIRECTION_INGRESS, fr->af.datalen); if (new) { memcpy(new, fr, sizeof(struct iax_frame)); iax_frame_wrap(new, &fr->af); new->data = NULL; new->datalen = 0; new->direction = DIRECTION_INGRESS; new->retrans = -1; } return new; } #define NEW_PREVENT 0 #define NEW_ALLOW 1 #define NEW_FORCE 2 static int match(struct sockaddr_in *sin, unsigned short callno, unsigned short dcallno, struct chan_iax2_pvt *cur) { if ((cur->addr.sin_addr.s_addr == sin->sin_addr.s_addr) && (cur->addr.sin_port == sin->sin_port)) { /* This is the main host */ if ((cur->peercallno == callno) || ((dcallno == cur->callno) && !cur->peercallno)) { /* That's us. Be sure we keep track of the peer call number */ return 1; } } if ((cur->transfer.sin_addr.s_addr == sin->sin_addr.s_addr) && (cur->transfer.sin_port == sin->sin_port) && (cur->transferring)) { /* We're transferring */ if (dcallno == cur->callno) return 1; } return 0; } static void update_max_trunk(void) { int max = TRUNK_CALL_START; int x; /* XXX Prolly don't need locks here XXX */ for (x=TRUNK_CALL_START;xoseqno) { ast_log(LOG_WARNING, "Can't make trunk once a call has started!\n"); return -1; } if (callno & TRUNK_CALL_START) { ast_log(LOG_WARNING, "Call %d is already a trunk\n", callno); return -1; } gettimeofday(&now, NULL); for (x=TRUNK_CALL_START;x MIN_REUSE_TIME)) { iaxs[x] = iaxs[callno]; iaxs[x]->callno = x; iaxs[callno] = NULL; /* Update the two timers that should have been started */ if (iaxs[x]->pingid > -1) ast_sched_del(sched, iaxs[x]->pingid); if (iaxs[x]->lagid > -1) ast_sched_del(sched, iaxs[x]->lagid); iaxs[x]->pingid = ast_sched_add(sched, ping_time * 1000, send_ping, (void *)(long)x); iaxs[x]->lagid = ast_sched_add(sched, lagrq_time * 1000, send_lagrq, (void *)(long)x); if (locked) ast_mutex_unlock(&iaxsl[callno]); res = x; if (!locked) ast_mutex_unlock(&iaxsl[x]); break; } ast_mutex_unlock(&iaxsl[x]); } if (x >= IAX_MAX_CALLS - 1) { ast_log(LOG_WARNING, "Unable to trunk call: Insufficient space\n"); return -1; } ast_log(LOG_DEBUG, "Made call %d into trunk call %d\n", callno, x); /* We move this call from a non-trunked to a trunked call */ update_max_trunk(); update_max_nontrunk(); return res; } static int find_callno(unsigned short callno, unsigned short dcallno, struct sockaddr_in *sin, int new, int lockpeer) { int res = 0; int x; struct timeval now; if (new <= NEW_ALLOW) { /* Look for an existing connection first */ for (x=1;(res < 1) && (x= NEW_ALLOW)) { gettimeofday(&now, NULL); for (x=1;x MIN_REUSE_TIME)) break; ast_mutex_unlock(&iaxsl[x]); } /* We've still got lock held if we found a spot */ if (x >= TRUNK_CALL_START) { ast_log(LOG_WARNING, "No more space\n"); return -1; } iaxs[x] = new_iax(sin, lockpeer); update_max_nontrunk(); if (iaxs[x]) { if (option_debug) ast_log(LOG_DEBUG, "Creating new call structure %d\n", x); iaxs[x]->addr.sin_port = sin->sin_port; iaxs[x]->addr.sin_family = sin->sin_family; iaxs[x]->addr.sin_addr.s_addr = sin->sin_addr.s_addr; iaxs[x]->peercallno = callno; iaxs[x]->callno = x; iaxs[x]->pingtime = DEFAULT_RETRY_TIME; iaxs[x]->expirey = expirey; iaxs[x]->pingid = ast_sched_add(sched, ping_time * 1000, send_ping, (void *)(long)x); iaxs[x]->lagid = ast_sched_add(sched, lagrq_time * 1000, send_lagrq, (void *)(long)x); iaxs[x]->amaflags = amaflags; iaxs[x]->notransfer = globalnotransfer; strncpy(iaxs[x]->accountcode, accountcode, sizeof(iaxs[x]->accountcode)-1); } else { ast_log(LOG_WARNING, "Out of resources\n"); ast_mutex_unlock(&iaxsl[x]); return 0; } ast_mutex_unlock(&iaxsl[x]); res = x; } return res; } static void iax2_frame_free(struct iax_frame *fr) { if (fr->retrans > -1) ast_sched_del(sched, fr->retrans); iax_frame_free(fr); } static int iax2_queue_frame(int callno, struct ast_frame *f) { /* Assumes lock for callno is already held... */ for (;;) { if (iaxs[callno] && iaxs[callno]->owner) { if (ast_mutex_trylock(&iaxs[callno]->owner->lock)) { /* Avoid deadlock by pausing and trying again */ ast_mutex_unlock(&iaxsl[callno]); usleep(1); ast_mutex_lock(&iaxsl[callno]); } else { ast_queue_frame(iaxs[callno]->owner, f); ast_mutex_unlock(&iaxs[callno]->owner->lock); break; } } else break; } return 0; } static void destroy_firmware(struct iax_firmware *cur) { /* Close firmware */ if (cur->fwh) { munmap(cur->fwh, ntohl(cur->fwh->datalen) + sizeof(*(cur->fwh))); } close(cur->fd); free(cur); } static int try_firmware(char *s) { struct stat stbuf; struct iax_firmware *cur; int ifd; int fd; int res; struct ast_iax2_firmware_header *fwh, fwh2; struct MD5Context md5; unsigned char sum[16]; unsigned char buf[1024]; int len, chunk; char *s2; char *last; s2 = alloca(strlen(s) + 100); if (!s2) { ast_log(LOG_WARNING, "Alloca failed!\n"); return -1; } last = strrchr(s, '/'); if (last) last++; else last = s; snprintf(s2, strlen(s) + 100, "/var/tmp/%s-%ld", last, (unsigned long)rand()); res = stat(s, &stbuf); if (res < 0) { ast_log(LOG_WARNING, "Failed to stat '%s': %s\n", s, strerror(errno)); return -1; } /* Make sure it's not a directory */ if (S_ISDIR(stbuf.st_mode)) return -1; ifd = open(s, O_RDONLY); if (ifd < 0) { ast_log(LOG_WARNING, "Cannot open '%s': %s\n", s, strerror(errno)); return -1; } fd = open(s2, O_RDWR | O_CREAT | O_EXCL); if (fd < 0) { ast_log(LOG_WARNING, "Cannot open '%s' for writing: %s\n", s2, strerror(errno)); close(ifd); return -1; } /* Unlink our newly created file */ unlink(s2); /* Now copy the firmware into it */ len = stbuf.st_size; while(len) { chunk = len; if (chunk > sizeof(buf)) chunk = sizeof(buf); res = read(ifd, buf, chunk); if (res != chunk) { ast_log(LOG_WARNING, "Only read %d of %d bytes of data :(: %s\n", res, chunk, strerror(errno)); close(ifd); close(fd); return -1; } res = write(fd, buf, chunk); if (res != chunk) { ast_log(LOG_WARNING, "Only write %d of %d bytes of data :(: %s\n", res, chunk, strerror(errno)); close(ifd); close(fd); return -1; } len -= chunk; } close(ifd); /* Return to the beginning */ lseek(fd, 0, SEEK_SET); if ((res = read(fd, &fwh2, sizeof(fwh2))) != sizeof(fwh2)) { ast_log(LOG_WARNING, "Unable to read firmware header in '%s'\n", s); close(fd); return -1; } if (ntohl(fwh2.magic) != IAX_FIRMWARE_MAGIC) { ast_log(LOG_WARNING, "'%s' is not a valid firmware file\n", s); close(fd); return -1; } if (ntohl(fwh2.datalen) != (stbuf.st_size - sizeof(fwh2))) { ast_log(LOG_WARNING, "Invalid data length in firmware '%s'\n", s); close(fd); return -1; } if (fwh2.devname[sizeof(fwh2.devname) - 1] || ast_strlen_zero(fwh2.devname)) { ast_log(LOG_WARNING, "No or invalid device type specified for '%s'\n", s); close(fd); return -1; } fwh = mmap(NULL, stbuf.st_size, PROT_READ, MAP_PRIVATE, fd, 0); if (!fwh) { ast_log(LOG_WARNING, "mmap failed: %s\n", strerror(errno)); close(fd); return -1; } MD5Init(&md5); MD5Update(&md5, fwh->data, ntohl(fwh->datalen)); MD5Final(sum, &md5); if (memcmp(sum, fwh->chksum, sizeof(sum))) { ast_log(LOG_WARNING, "Firmware file '%s' fails checksum\n", s); munmap(fwh, stbuf.st_size); close(fd); return -1; } cur = waresl.wares; while(cur) { if (!strcmp(cur->fwh->devname, fwh->devname)) { /* Found a candidate */ if (cur->dead || (ntohs(cur->fwh->version) < ntohs(fwh->version))) /* The version we have on loaded is older, load this one instead */ break; /* This version is no newer than what we have. Don't worry about it. We'll consider it a proper load anyhow though */ munmap(fwh, stbuf.st_size); close(fd); return 0; } cur = cur->next; } if (!cur) { /* Allocate a new one and link it */ cur = malloc(sizeof(struct iax_firmware)); if (cur) { memset(cur, 0, sizeof(struct iax_firmware)); cur->fd = -1; cur->next = waresl.wares; waresl.wares = cur; } } if (cur) { if (cur->fwh) { munmap(cur->fwh, cur->mmaplen); } if (cur->fd > -1) close(cur->fd); cur->fwh = fwh; cur->fd = fd; cur->mmaplen = stbuf.st_size; cur->dead = 0; } return 0; } static int iax_check_version(char *dev) { int res = 0; struct iax_firmware *cur; if (dev && !ast_strlen_zero(dev)) { ast_mutex_lock(&waresl.lock); cur = waresl.wares; while(cur) { if (!strcmp(dev, cur->fwh->devname)) { res = ntohs(cur->fwh->version); break; } cur = cur->next; } ast_mutex_unlock(&waresl.lock); } return res; } static int iax_firmware_append(struct iax_ie_data *ied, const unsigned char *dev, unsigned int desc) { int res = -1; unsigned int bs = desc & 0xff; unsigned int start = (desc >> 8) & 0xffffff; unsigned int bytes; struct iax_firmware *cur; if (dev && !ast_strlen_zero(dev) && bs) { start *= bs; ast_mutex_lock(&waresl.lock); cur = waresl.wares; while(cur) { if (!strcmp(dev, cur->fwh->devname)) { iax_ie_append_int(ied, IAX_IE_FWBLOCKDESC, desc); if (start < ntohl(cur->fwh->datalen)) { bytes = ntohl(cur->fwh->datalen) - start; if (bytes > bs) bytes = bs; iax_ie_append_raw(ied, IAX_IE_FWBLOCKDATA, cur->fwh->data + start, bytes); } else { bytes = 0; iax_ie_append(ied, IAX_IE_FWBLOCKDATA); } if (bytes == bs) res = 0; else res = 1; break; } cur = cur->next; } ast_mutex_unlock(&waresl.lock); } return res; } static void reload_firmware(void) { struct iax_firmware *cur, *curl, *curp; DIR *fwd; struct dirent *de; char dir[256]; char fn[256]; /* Mark all as dead */ ast_mutex_lock(&waresl.lock); cur = waresl.wares; while(cur) { cur->dead = 1; cur = cur->next; } /* Now that we've freed them, load the new ones */ snprintf(dir, sizeof(dir), "%s/firmware/iax", (char *)ast_config_AST_VAR_DIR); fwd = opendir(dir); if (fwd) { while((de = readdir(fwd))) { if (de->d_name[0] != '.') { snprintf(fn, sizeof(fn), "%s/%s", dir, de->d_name); if (!try_firmware(fn)) { if (option_verbose > 1) ast_verbose(VERBOSE_PREFIX_2 "Loaded firmware '%s'\n", de->d_name); } } } closedir(fwd); } else ast_log(LOG_WARNING, "Error opening firmware directory '%s': %s\n", dir, strerror(errno)); /* Clean up leftovers */ cur = waresl.wares; curp = NULL; while(cur) { curl = cur; cur = cur->next; if (curl->dead) { if (curp) { curp->next = cur; } else { waresl.wares = cur; } destroy_firmware(curl); } else { curp = cur; } } ast_mutex_unlock(&waresl.lock); } static int iax2_send(struct chan_iax2_pvt *pvt, struct ast_frame *f, unsigned int ts, int seqno, int now, int transfer, int final); static int __do_deliver(void *data) { /* Just deliver the packet by using queueing. This is called by the IAX thread with the iaxsl lock held. */ struct iax_frame *fr = data; fr->retrans = -1; if (iaxs[fr->callno] && !iaxs[fr->callno]->alreadygone) iax2_queue_frame(fr->callno, &fr->af); /* Free our iax frame */ iax2_frame_free(fr); /* And don't run again */ return 0; } static int do_deliver(void *data) { /* Locking version of __do_deliver */ struct iax_frame *fr = data; int callno = fr->callno; int res; ast_mutex_lock(&iaxsl[callno]); res = __do_deliver(data); ast_mutex_unlock(&iaxsl[callno]); return res; } static int handle_error(void) { /* XXX Ideally we should figure out why an error occured and then abort those rather than continuing to try. Unfortunately, the published interface does not seem to work XXX */ #if 0 struct sockaddr_in *sin; int res; struct msghdr m; struct sock_extended_err e; m.msg_name = NULL; m.msg_namelen = 0; m.msg_iov = NULL; m.msg_control = &e; m.msg_controllen = sizeof(e); m.msg_flags = 0; res = recvmsg(netsocket, &m, MSG_ERRQUEUE); if (res < 0) ast_log(LOG_WARNING, "Error detected, but unable to read error: %s\n", strerror(errno)); else { if (m.msg_controllen) { sin = (struct sockaddr_in *)SO_EE_OFFENDER(&e); if (sin) ast_log(LOG_WARNING, "Receive error from %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr)); else ast_log(LOG_WARNING, "No address detected??\n"); } else { ast_log(LOG_WARNING, "Local error: %s\n", strerror(e.ee_errno)); } } #endif return 0; } static int transmit_trunk(struct iax_frame *f, struct sockaddr_in *sin) { int res; res = sendto(netsocket, f->data, f->datalen, 0,(struct sockaddr *)sin, sizeof(*sin)); if (res < 0) { if (option_debug) ast_log(LOG_DEBUG, "Received error: %s\n", strerror(errno)); handle_error(); } else res = 0; return res; } static int send_packet(struct iax_frame *f) { int res; char iabuf[INET_ADDRSTRLEN]; /* Called with iaxsl held */ if (option_debug) ast_log(LOG_DEBUG, "Sending %d on %d/%d to %s:%d\n", f->ts, f->callno, iaxs[f->callno]->peercallno, ast_inet_ntoa(iabuf, sizeof(iabuf), iaxs[f->callno]->addr.sin_addr), ntohs(iaxs[f->callno]->addr.sin_port)); /* Don't send if there was an error, but return error instead */ if (!f->callno) { ast_log(LOG_WARNING, "Call number = %d\n", f->callno); return -1; } if (!iaxs[f->callno]) return -1; if (iaxs[f->callno]->error) return -1; if (f->transfer) { if (iaxdebug) iax_showframe(f, NULL, 0, &iaxs[f->callno]->transfer, f->datalen - sizeof(struct ast_iax2_full_hdr)); res = sendto(netsocket, f->data, f->datalen, 0,(struct sockaddr *)&iaxs[f->callno]->transfer, sizeof(iaxs[f->callno]->transfer)); } else { if (iaxdebug) iax_showframe(f, NULL, 0, &iaxs[f->callno]->addr, f->datalen - sizeof(struct ast_iax2_full_hdr)); res = sendto(netsocket, f->data, f->datalen, 0,(struct sockaddr *)&iaxs[f->callno]->addr, sizeof(iaxs[f->callno]->addr)); } if (res < 0) { if (option_debug) ast_log(LOG_DEBUG, "Received error: %s\n", strerror(errno)); handle_error(); } else res = 0; return res; } static int iax2_predestroy(int callno) { struct ast_channel *c; struct chan_iax2_pvt *pvt; ast_mutex_lock(&iaxsl[callno]); pvt = iaxs[callno]; if (!pvt) { ast_mutex_unlock(&iaxsl[callno]); return -1; } if (!pvt->alreadygone) { /* No more pings or lagrq's */ if (pvt->pingid > -1) ast_sched_del(sched, pvt->pingid); if (pvt->lagid > -1) ast_sched_del(sched, pvt->lagid); if (pvt->autoid > -1) ast_sched_del(sched, pvt->autoid); if (pvt->authid > -1) ast_sched_del(sched, pvt->authid); if (pvt->initid > -1) ast_sched_del(sched, pvt->initid); pvt->pingid = -1; pvt->lagid = -1; pvt->autoid = -1; pvt->initid = -1; pvt->authid = -1; pvt->alreadygone = 1; } c = pvt->owner; if (c) { c->_softhangup |= AST_SOFTHANGUP_DEV; c->pvt->pvt = NULL; ast_queue_hangup(c); pvt->owner = NULL; ast_mutex_lock(&usecnt_lock); usecnt--; if (usecnt < 0) ast_log(LOG_WARNING, "Usecnt < 0???\n"); ast_mutex_unlock(&usecnt_lock); } ast_mutex_unlock(&iaxsl[callno]); ast_update_use_count(); return 0; } static int iax2_predestroy_nolock(int callno) { int res; ast_mutex_unlock(&iaxsl[callno]); res = iax2_predestroy(callno); ast_mutex_lock(&iaxsl[callno]); return res; } static void iax2_destroy(int callno) { struct chan_iax2_pvt *pvt; struct iax_frame *cur; struct ast_channel *owner; retry: ast_mutex_lock(&iaxsl[callno]); pvt = iaxs[callno]; gettimeofday(&lastused[callno], NULL); if (pvt) owner = pvt->owner; else owner = NULL; if (owner) { if (ast_mutex_trylock(&owner->lock)) { ast_log(LOG_NOTICE, "Avoiding IAX destroy deadlock\n"); ast_mutex_unlock(&iaxsl[callno]); usleep(1); goto retry; } } if (!owner) iaxs[callno] = NULL; if (pvt) { if (!owner) pvt->owner = NULL; /* No more pings or lagrq's */ if (pvt->pingid > -1) ast_sched_del(sched, pvt->pingid); if (pvt->lagid > -1) ast_sched_del(sched, pvt->lagid); if (pvt->autoid > -1) ast_sched_del(sched, pvt->autoid); if (pvt->authid > -1) ast_sched_del(sched, pvt->authid); if (pvt->initid > -1) ast_sched_del(sched, pvt->initid); pvt->pingid = -1; pvt->lagid = -1; pvt->autoid = -1; pvt->authid = -1; pvt->initid = -1; if (pvt->bridgetrans) ast_translator_free_path(pvt->bridgetrans); pvt->bridgetrans = NULL; /* Already gone */ pvt->alreadygone = 1; if (owner) { /* If there's an owner, prod it to give up */ owner->_softhangup |= AST_SOFTHANGUP_DEV; ast_queue_hangup(owner); } for (cur = iaxq.head; cur ; cur = cur->next) { /* Cancel any pending transmissions */ if (cur->callno == pvt->callno) cur->retries = -1; } if (pvt->reg) { pvt->reg->callno = 0; } if (!owner) free(pvt); } if (owner) { ast_mutex_unlock(&owner->lock); } ast_mutex_unlock(&iaxsl[callno]); if (callno & 0x4000) update_max_trunk(); } static void iax2_destroy_nolock(int callno) { /* Actually it's easier to unlock, kill it, and relock */ ast_mutex_unlock(&iaxsl[callno]); iax2_destroy(callno); ast_mutex_lock(&iaxsl[callno]); } static int update_packet(struct iax_frame *f) { /* Called with iaxsl lock held, and iaxs[callno] non-NULL */ struct ast_iax2_full_hdr *fh = f->data; /* Mark this as a retransmission */ fh->dcallno = ntohs(IAX_FLAG_RETRANS | f->dcallno); /* Update iseqno */ f->iseqno = iaxs[f->callno]->iseqno; fh->iseqno = f->iseqno; return 0; } static int attempt_transmit(void *data) { /* Attempt to transmit the frame to the remote peer... Called without iaxsl held. */ struct iax_frame *f = data; int freeme=0; int callno = f->callno; char iabuf[INET_ADDRSTRLEN]; /* Make sure this call is still active */ if (callno) ast_mutex_lock(&iaxsl[callno]); if ((f->callno) && iaxs[f->callno]) { if ((f->retries < 0) /* Already ACK'd */ || (f->retries >= max_retries) /* Too many attempts */) { /* Record an error if we've transmitted too many times */ if (f->retries >= max_retries) { if (f->transfer) { /* Transfer timeout */ send_command(iaxs[f->callno], AST_FRAME_IAX, IAX_COMMAND_TXREJ, 0, NULL, 0, -1); } else if (f->final) { if (f->final) iax2_destroy_nolock(f->callno); } else { if (iaxs[f->callno]->owner) ast_log(LOG_WARNING, "Max retries exceeded to host %s on %s (type = %d, subclass = %d, ts=%d, seqno=%d)\n", ast_inet_ntoa(iabuf, sizeof(iabuf), iaxs[f->callno]->addr.sin_addr),iaxs[f->callno]->owner->name , f->af.frametype, f->af.subclass, f->ts, f->oseqno); iaxs[f->callno]->error = ETIMEDOUT; if (iaxs[f->callno]->owner) { struct ast_frame fr = { 0, }; /* Hangup the fd */ fr.frametype = AST_FRAME_CONTROL; fr.subclass = AST_CONTROL_HANGUP; iax2_queue_frame(f->callno, &fr); } else { if (iaxs[f->callno]->reg) { memset(&iaxs[f->callno]->reg->us, 0, sizeof(iaxs[f->callno]->reg->us)); iaxs[f->callno]->reg->regstate = REG_STATE_TIMEOUT; iaxs[f->callno]->reg->refresh = IAX_DEFAULT_REG_EXPIRE; } iax2_destroy_nolock(f->callno); } } } freeme++; } else { /* Update it if it needs it */ update_packet(f); /* Attempt transmission */ send_packet(f); f->retries++; /* Try again later after 10 times as long */ f->retrytime *= 10; if (f->retrytime > MAX_RETRY_TIME) f->retrytime = MAX_RETRY_TIME; /* Transfer messages max out at one second */ if (f->transfer && (f->retrytime > 1000)) f->retrytime = 1000; f->retrans = ast_sched_add(sched, f->retrytime, attempt_transmit, f); } } else { /* Make sure it gets freed */ f->retries = -1; freeme++; } if (callno) ast_mutex_unlock(&iaxsl[callno]); /* Do not try again */ if (freeme) { /* Don't attempt delivery, just remove it from the queue */ ast_mutex_lock(&iaxq.lock); if (f->prev) f->prev->next = f->next; else iaxq.head = f->next; if (f->next) f->next->prev = f->prev; else iaxq.tail = f->prev; iaxq.count--; ast_mutex_unlock(&iaxq.lock); f->retrans = -1; /* Free the IAX frame */ iax2_frame_free(f); } return 0; } static int iax2_set_jitter(int fd, int argc, char *argv[]) { if ((argc != 4) && (argc != 5)) return RESULT_SHOWUSAGE; if (argc == 4) { max_jitter_buffer = atoi(argv[3]); if (max_jitter_buffer < 0) max_jitter_buffer = 0; } else { if (argc == 5) { if ((atoi(argv[3]) >= 0) && (atoi(argv[3]) < IAX_MAX_CALLS)) { if (iaxs[atoi(argv[3])]) { iaxs[atoi(argv[3])]->jitterbuffer = atoi(argv[4]); if (iaxs[atoi(argv[3])]->jitterbuffer < 0) iaxs[atoi(argv[3])]->jitterbuffer = 0; } else ast_cli(fd, "No such call '%d'\n", atoi(argv[3])); } else ast_cli(fd, "%d is not a valid call number\n", atoi(argv[3])); } } return RESULT_SUCCESS; } static char jitter_usage[] = "Usage: iax set jitter [callid] \n" " If used with a callid, it sets the jitter buffer to the given static\n" "value (until its next calculation). If used without a callid, the value is used\n" "to establish the maximum excess jitter buffer that is permitted before the jitter\n" "buffer size is reduced."; static int iax2_show_stats(int fd, int argc, char *argv[]) { struct iax_frame *cur; int cnt = 0, dead=0, final=0; if (argc != 3) return RESULT_SHOWUSAGE; for (cur = iaxq.head; cur ; cur = cur->next) { if (cur->retries < 0) dead++; if (cur->final) final++; cnt++; } ast_cli(fd, " IAX Statistics\n"); ast_cli(fd, "---------------------\n"); ast_cli(fd, "Outstanding frames: %d (%d ingress, %d outgress)\n", iax_get_frames(), iax_get_iframes(), iax_get_oframes()); ast_cli(fd, "Packets in transmit queue: %d dead, %d final, %d total\n", dead, final, cnt); return RESULT_SUCCESS; } static int iax2_show_cache(int fd, int argc, char *argv[]) { struct iax2_dpcache *dp; char tmp[1024] = "", *pc; int s; int x,y; struct timeval tv; gettimeofday(&tv, NULL); ast_mutex_lock(&dpcache_lock); dp = dpcache; ast_cli(fd, "%-20.20s %-12.12s %-9.9s %-8.8s %s\n", "Peer/Context", "Exten", "Exp.", "Wait.", "Flags"); while(dp) { s = dp->expirey.tv_sec - tv.tv_sec; tmp[0] = '\0'; if (dp->flags & CACHE_FLAG_EXISTS) strncat(tmp, "EXISTS|", sizeof(tmp) - strlen(tmp) - 1); if (dp->flags & CACHE_FLAG_NONEXISTANT) strncat(tmp, "NONEXISTANT|", sizeof(tmp) - strlen(tmp) - 1); if (dp->flags & CACHE_FLAG_CANEXIST) strncat(tmp, "CANEXIST|", sizeof(tmp) - strlen(tmp) - 1); if (dp->flags & CACHE_FLAG_PENDING) strncat(tmp, "PENDING|", sizeof(tmp) - strlen(tmp) - 1); if (dp->flags & CACHE_FLAG_TIMEOUT) strncat(tmp, "TIMEOUT|", sizeof(tmp) - strlen(tmp) - 1); if (dp->flags & CACHE_FLAG_TRANSMITTED) strncat(tmp, "TRANSMITTED|", sizeof(tmp) - strlen(tmp) - 1); if (dp->flags & CACHE_FLAG_MATCHMORE) strncat(tmp, "MATCHMORE|", sizeof(tmp) - strlen(tmp) - 1); if (dp->flags & CACHE_FLAG_UNKNOWN) strncat(tmp, "UNKNOWN|", sizeof(tmp) - strlen(tmp) - 1); /* Trim trailing pipe */ if (!ast_strlen_zero(tmp)) tmp[strlen(tmp) - 1] = '\0'; else strncpy(tmp, "(none)", sizeof(tmp) - 1); y=0; pc = strchr(dp->peercontext, '@'); if (!pc) pc = dp->peercontext; else pc++; for (x=0;xwaiters) / sizeof(dp->waiters[0]); x++) if (dp->waiters[x] > -1) y++; if (s > 0) ast_cli(fd, "%-20.20s %-12.12s %-9d %-8d %s\n", pc, dp->exten, s, y, tmp); else ast_cli(fd, "%-20.20s %-12.12s %-9.9s %-8d %s\n", pc, dp->exten, "(expired)", y, tmp); dp = dp->next; } ast_mutex_unlock(&dpcache_lock); return RESULT_SUCCESS; } static char show_stats_usage[] = "Usage: iax show stats\n" " Display statistics on IAX channel driver.\n"; static char show_cache_usage[] = "Usage: iax show cache\n" " Display currently cached IAX Dialplan results.\n"; static struct ast_cli_entry cli_set_jitter = { { "iax2", "set", "jitter", NULL }, iax2_set_jitter, "Sets IAX jitter buffer", jitter_usage }; static struct ast_cli_entry cli_show_stats = { { "iax2", "show", "stats", NULL }, iax2_show_stats, "Display IAX statistics", show_stats_usage }; static struct ast_cli_entry cli_show_cache = { { "iax2", "show", "cache", NULL }, iax2_show_cache, "Display IAX cached dialplan", show_cache_usage }; static unsigned int calc_rxstamp(struct chan_iax2_pvt *p); #ifdef BRIDGE_OPTIMIZATION static unsigned int calc_fakestamp(struct chan_iax2_pvt *from, struct chan_iax2_pvt *to, unsigned int ts); static int forward_delivery(struct iax_frame *fr) { struct chan_iax2_pvt *p1, *p2; char iabuf[INET_ADDRSTRLEN]; p1 = iaxs[fr->callno]; p2 = iaxs[p1->bridgecallno]; if (!p1) return -1; if (!p2) return -1; if (option_debug) ast_log(LOG_DEBUG, "forward_delivery: Forwarding ts=%d on %d/%d to %d/%d on %s:%d\n", fr->ts, p1->callno, p1->peercallno, p2->callno, p2->peercallno, ast_inet_ntoa(iabuf, sizeof(iabuf), p2->addr.sin_addr), ntohs(p2->addr.sin_port)); /* Undo wraparound - which can happen when full VOICE frame wasn't sent by our peer. This is necessary for when our peer is chan_iax2.c v1.175 or earlier which didn't send full frame on timestamp wrap when doing optimized bridging */ if (fr->ts + 32767 <= p1->last) { fr->ts = ( (p1->last & 0xFFFF0000) + 0x10000) | (fr->ts & 0xFFFF); p1->last = fr->ts; /* necessary? */ if (option_debug) ast_log(LOG_DEBUG, "forward_delivery: pushed forward timestamp to %u\n", fr->ts); } /* Fix relative timestamp */ fr->ts = calc_fakestamp(p1, p2, fr->ts); /* Now just send it send on the 2nd one with adjusted timestamp */ return iax2_send(p2, &fr->af, fr->ts, -1, 0, 0, 0); } #endif static int schedule_delivery(struct iax_frame *fr, int reallydeliver, int updatehistory) { int ms,x; int drops[MEMORY_SIZE]; int min, max=0, prevjitterbuffer, maxone=0,y,z, match; /* Remember current jitterbuffer so we can log any change */ prevjitterbuffer = iaxs[fr->callno]->jitterbuffer; /* ms is a measure of the "lateness" of the packet relative to the first packet we received. Understand that "ms" can easily be -ve if lag improves since call start. Called by IAX thread, with iaxsl lock held. */ ms = calc_rxstamp(iaxs[fr->callno]) - fr->ts; if (ms > 32767) { /* What likely happened here is that our counter has circled but we haven't gotten the update from the main packet. We'll just pretend that we did, and update the timestamp appropriately. */ /*ms -= 65536; fr->ts += 65536;*/ fr->ts = ( (iaxs[fr->callno]->last & 0xFFFF0000) + 0x10000) | (fr->ts & 0xFFFF); iaxs[fr->callno]->last = fr->ts; ms = calc_rxstamp(iaxs[fr->callno]) - fr->ts; if (option_debug) ast_log(LOG_DEBUG, "schedule_delivery: pushed forward timestamp\n"); } if (ms < -32768) { /* We got this packet out of order. Lets add 65536 to it to bring it into our new time frame */ /*ms += 65536; fr->ts -= 65536;*/ fr->ts = ( (iaxs[fr->callno]->last & 0xFFFF0000) - 0x10000) | (fr->ts & 0xFFFF); iaxs[fr->callno]->last = fr->ts; ms = calc_rxstamp(iaxs[fr->callno]) - fr->ts; if (option_debug) ast_log(LOG_DEBUG, "schedule_delivery: pushed back timestamp\n"); } /* delivery time is sender's sent timestamp converted back into absolute time according to our clock */ fr->af.delivery.tv_sec = iaxs[fr->callno]->rxcore.tv_sec; fr->af.delivery.tv_usec = iaxs[fr->callno]->rxcore.tv_usec; fr->af.delivery.tv_sec += fr->ts / 1000; fr->af.delivery.tv_usec += (fr->ts % 1000) * 1000; if (fr->af.delivery.tv_usec >= 1000000) { fr->af.delivery.tv_usec -= 1000000; fr->af.delivery.tv_sec += 1; } /* Rotate our history queue of "lateness". Don't worry about those initial zeros because the first entry will always be zero */ if (updatehistory) { for (x=0;xcallno]->history[x] = iaxs[fr->callno]->history[x+1]; /* Add a history entry for this one */ iaxs[fr->callno]->history[x] = ms; } /* Initialize the minimum to reasonable values. It's too much work to do the same for the maximum, repeatedly */ min=iaxs[fr->callno]->history[0]; for (z=0;z < iax2_dropcount + 1;z++) { /* Start very optimistic ;-) */ max=-999999999; for (x=0;xcallno]->history[x]) { /* We have a candidate new maximum value. Make sure it's not in our drop list */ match = 0; for (y=0;!match && (ycallno]->history[x]; maxone = x; } } if (!z) { /* On our first pass, find the minimum too */ if (min > iaxs[fr->callno]->history[x]) min = iaxs[fr->callno]->history[x]; } } #if 1 drops[z] = maxone; #endif } /* Just for reference, keep the "jitter" value, the difference between the earliest and the latest. */ iaxs[fr->callno]->jitter = max - min; /* IIR filter for keeping track of historic jitter, but always increase historic jitter immediately for increase */ if (iaxs[fr->callno]->jitter > iaxs[fr->callno]->historicjitter ) iaxs[fr->callno]->historicjitter = iaxs[fr->callno]->jitter; else iaxs[fr->callno]->historicjitter = GAMMA * (double)iaxs[fr->callno]->jitter + (1-GAMMA) * iaxs[fr->callno]->historicjitter; /* If our jitter buffer is too big (by a significant margin), then we slowly shrink it to avoid letting the change be perceived */ if (max < iaxs[fr->callno]->jitterbuffer - max_jitter_buffer) iaxs[fr->callno]->jitterbuffer -= jittershrinkrate; /* If our jitter buffer headroom is too small (by a significant margin), then we slowly enlarge it */ /* min_jitter_buffer should be SMALLER than max_jitter_buffer - leaving a "no mans land" in between - otherwise the jitterbuffer size will hunt up and down causing unnecessary disruption. Set maxexcessbuffer to say 150msec, minexcessbuffer to say 50 */ if (max > iaxs[fr->callno]->jitterbuffer - min_jitter_buffer) iaxs[fr->callno]->jitterbuffer += jittershrinkrate; #if 1 /* Constrain our maximum jitter buffer appropriately */ if (max > min + maxjitterbuffer) { if (option_debug) ast_log(LOG_DEBUG, "Constraining buffer from %d to %d + %d\n", max, min , maxjitterbuffer); max = min + maxjitterbuffer; } #endif /* If our jitter buffer is smaller than our maximum delay, grow the jitter buffer immediately to accomodate it (and a little more). */ if (max > iaxs[fr->callno]->jitterbuffer) iaxs[fr->callno]->jitterbuffer = max /* + ((float)iaxs[fr->callno]->jitter) * 0.1 */; /* If the caller just wanted us to update, return now */ if (!reallydeliver) return 0; if (option_debug) /* Log jitter stats for possible offline analysis */ ast_log(LOG_DEBUG, "Jitter: call=%d ts=%d %s: min=%d max=%d jb=%d %+d; lateness=%d; jitter=%d historic=%d\n", fr->callno, fr->ts, (fr->af.frametype == AST_FRAME_VOICE) ? "VOICE" : "CONTROL", min, max, iaxs[fr->callno]->jitterbuffer, iaxs[fr->callno]->jitterbuffer - prevjitterbuffer, ms, iaxs[fr->callno]->jitter, iaxs[fr->callno]->historicjitter); /* Subtract the lateness from our jitter buffer to know how long to wait before sending our packet. */ ms = iaxs[fr->callno]->jitterbuffer - ms; if (!use_jitterbuffer) ms = 0; if (ms < 1) { /* Don't deliver it more than 4 ms late */ if ((ms > -4) || (fr->af.frametype != AST_FRAME_VOICE)) { if (option_debug) ast_log(LOG_DEBUG, "schedule_delivery: Delivering immediately (Calculated ms is %d)\n", ms); __do_deliver(fr); } else { if (option_debug) ast_log(LOG_DEBUG, "schedule_delivery: Dropping voice packet since %d ms is too old\n", ms); /* Free our iax frame */ iax2_frame_free(fr); } } else { if (option_debug) ast_log(LOG_DEBUG, "schedule_delivery: Scheduling delivery in %d ms\n", ms); fr->retrans = ast_sched_add(sched, ms, do_deliver, fr); } return 0; } static int iax2_transmit(struct iax_frame *fr) { /* Lock the queue and place this packet at the end */ fr->next = NULL; fr->prev = NULL; /* By setting this to 0, the network thread will send it for us, and queue retransmission if necessary */ fr->sentyet = 0; ast_mutex_lock(&iaxq.lock); if (!iaxq.head) { /* Empty queue */ iaxq.head = fr; iaxq.tail = fr; } else { /* Double link */ iaxq.tail->next = fr; fr->prev = iaxq.tail; iaxq.tail = fr; } iaxq.count++; ast_mutex_unlock(&iaxq.lock); /* Wake up the network thread */ pthread_kill(netthreadid, SIGURG); return 0; } static int iax2_digit(struct ast_channel *c, char digit) { return send_command_locked(PTR_TO_CALLNO(c->pvt->pvt), AST_FRAME_DTMF, digit, 0, NULL, 0, -1); } static int iax2_sendtext(struct ast_channel *c, char *text) { return send_command_locked(PTR_TO_CALLNO(c->pvt->pvt), AST_FRAME_TEXT, 0, 0, text, strlen(text) + 1, -1); } static int iax2_sendimage(struct ast_channel *c, struct ast_frame *img) { return send_command_locked(PTR_TO_CALLNO(c->pvt->pvt), AST_FRAME_IMAGE, img->subclass, 0, img->data, img->datalen, -1); } static int iax2_sendhtml(struct ast_channel *c, int subclass, char *data, int datalen) { return send_command_locked(PTR_TO_CALLNO(c->pvt->pvt), AST_FRAME_HTML, subclass, 0, data, datalen, -1); } static int iax2_fixup(struct ast_channel *oldchannel, struct ast_channel *newchan) { unsigned short callno = PTR_TO_CALLNO(newchan->pvt->pvt); ast_mutex_lock(&iaxsl[callno]); if (iaxs[callno]) iaxs[callno]->owner = newchan; else ast_log(LOG_WARNING, "Uh, this isn't a good sign...\n"); ast_mutex_unlock(&iaxsl[callno]); return 0; } #ifdef MYSQL_FRIENDS static void mysql_update_peer(char *peer, struct sockaddr_in *sin) { if (mysql && (strlen(peer) < 128)) { char query[512]; char *name; char iabuf[INET_ADDRSTRLEN]; time_t nowtime; name = alloca(strlen(peer) * 2 + 1); time(&nowtime); mysql_real_escape_string(mysql, name, peer, strlen(peer)); snprintf(query, sizeof(query), "UPDATE iaxfriends SET ipaddr=\"%s\", port=\"%d\", regseconds=\"%ld\" WHERE name=\"%s\"", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), ntohs(sin->sin_port), nowtime, name); ast_mutex_lock(&mysqllock); if (mysql_real_query(mysql, query, strlen(query))) ast_log(LOG_WARNING, "Unable to update database\n"); ast_mutex_unlock(&mysqllock); } } static struct iax2_peer *mysql_peer(char *peer) { struct iax2_peer *p; int success = 0; p = malloc(sizeof(struct iax2_peer)); memset(p, 0, sizeof(struct iax2_peer)); if (mysql && (strlen(peer) < 128)) { char query[512]; char *name; int numfields, x; int port; time_t regseconds, nowtime; MYSQL_RES *result; MYSQL_FIELD *fields; MYSQL_ROW rowval; name = alloca(strlen(peer) * 2 + 1); mysql_real_escape_string(mysql, name, peer, strlen(peer)); snprintf(query, sizeof(query), "SELECT name, secret, context, ipaddr, port, regseconds FROM iaxfriends WHERE name=\"%s\"", name); ast_mutex_lock(&mysqllock); mysql_query(mysql, query); if ((result = mysql_store_result(mysql))) { if ((rowval = mysql_fetch_row(result))) { numfields = mysql_num_fields(result); fields = mysql_fetch_fields(result); success = 1; for (x=0;xsecret, rowval[x], sizeof(p->secret) - 1); } else if (!strcasecmp(fields[x].name, "context")) { strncpy(p->context, rowval[x], sizeof(p->context) - 1); } else if (!strcasecmp(fields[x].name, "ipaddr")) { inet_aton(rowval[x], &p->addr.sin_addr); } else if (!strcasecmp(fields[x].name, "port")) { if (sscanf(rowval[x], "%i", &port) != 1) port = 0; p->addr.sin_port = htons(port); } else if (!strcasecmp(fields[x].name, "regseconds")) { if (sscanf(rowval[x], "%li", ®seconds) != 1) regseconds = 0; } } } time(&nowtime); if ((nowtime - regseconds) > IAX_DEFAULT_REG_EXPIRE) memset(&p->addr, 0, sizeof(p->addr)); } mysql_free_result(result); result = NULL; } ast_mutex_unlock(&mysqllock); } if (!success) { free(p); p = NULL; } else { strncpy(p->name, peer, sizeof(p->name) - 1); p->dynamic = 1; p->temponly = 1; p->expire = -1; p->capability = iax2_capability; p->authmethods = IAX_AUTH_MD5 | IAX_AUTH_PLAINTEXT; } return p; } static struct iax2_user *mysql_user(char *user) { struct iax2_user *p; struct iax2_context *con; int success = 0; p = malloc(sizeof(struct iax2_user)); memset(p, 0, sizeof(struct iax2_user)); con = malloc(sizeof(struct iax2_context)); memset(con, 0, sizeof(struct iax2_context)); strncpy(con->context, "default", sizeof(con->context) - 1); p->contexts = con; if (mysql && (strlen(user) < 128)) { char query[512]; char *name; int numfields, x; MYSQL_RES *result; MYSQL_FIELD *fields; MYSQL_ROW rowval; name = alloca(strlen(user) * 2 + 1); mysql_real_escape_string(mysql, name, user, strlen(user)); snprintf(query, sizeof(query), "SELECT name, secret, context, ipaddr, port, regseconds, accountcode FROM iaxfriends WHERE name=\"%s\"", name); ast_mutex_lock(&mysqllock); mysql_query(mysql, query); if ((result = mysql_store_result(mysql))) { if ((rowval = mysql_fetch_row(result))) { numfields = mysql_num_fields(result); fields = mysql_fetch_fields(result); success = 1; for (x=0;xsecret, rowval[x], sizeof(p->secret) - 1); } else if (!strcasecmp(fields[x].name, "context")) { strncpy(p->contexts->context, rowval[x], sizeof(p->contexts->context) - 1); } else if (!strcasecmp(fields[x].name, "accountcode")) { strncpy(p->accountcode, rowval[x], sizeof(p->accountcode) - 1); } } } } mysql_free_result(result); result = NULL; } ast_mutex_unlock(&mysqllock); } if (!success) { if (p->contexts) free(p->contexts); free(p); p = NULL; } else { strncpy(p->name, user, sizeof(p->name) - 1); p->temponly = 1; p->capability = iax2_capability; p->authmethods = IAX_AUTH_MD5 | IAX_AUTH_PLAINTEXT; } return p; } #endif /* MYSQL_FRIENDS */ static int create_addr(struct sockaddr_in *sin, int *capability, int *sendani, int *maxtime, char *peer, char *context, int *trunk, int *notransfer, char *username, int usernlen, char *secret, int seclen, int *ofound, char *peercontext) { struct ast_hostent ahp; struct hostent *hp; struct iax2_peer *p; int found=0; if (sendani) *sendani = 0; if (maxtime) *maxtime = 0; if (trunk) *trunk = 0; sin->sin_family = AF_INET; ast_mutex_lock(&peerl.lock); p = peerl.peers; while(p) { if (!strcasecmp(p->name, peer)) { break; } p = p->next; } ast_mutex_unlock(&peerl.lock); #ifdef MYSQL_FRIENDS if (!p) p = mysql_peer(peer); #endif if (p) { found++; if ((p->addr.sin_addr.s_addr || p->defaddr.sin_addr.s_addr) && (!p->maxms || ((p->lastms > 0) && (p->lastms <= p->maxms)))) { if (sendani) *sendani = p->sendani; /* Whether we transmit ANI */ if (maxtime) *maxtime = p->maxms; /* Max time they should take */ if (context) strncpy(context, p->context, AST_MAX_EXTENSION - 1); if (peercontext) strncpy(peercontext, p->peercontext, AST_MAX_EXTENSION - 1); if (trunk) *trunk = p->trunk; if (capability) *capability = p->capability; if (username) strncpy(username, p->username, usernlen); if (secret) strncpy(secret, p->secret, seclen); /* safe */ if (p->addr.sin_addr.s_addr) { sin->sin_addr = p->addr.sin_addr; sin->sin_port = p->addr.sin_port; } else { sin->sin_addr = p->defaddr.sin_addr; sin->sin_port = p->defaddr.sin_port; } if (notransfer) *notransfer=p->notransfer; } else { if (p->temponly) free(p); p = NULL; } } if (ofound) *ofound = found; if (!p && !found) { hp = ast_gethostbyname(peer, &ahp); if (hp) { memcpy(&sin->sin_addr, hp->h_addr, sizeof(sin->sin_addr)); sin->sin_port = htons(IAX_DEFAULT_PORTNO); return 0; } else { ast_log(LOG_WARNING, "No such host: %s\n", peer); return -1; } } else if (!p) return -1; if (p->temponly) free(p); return 0; } static int auto_congest(void *nothing) { int callno = PTR_TO_CALLNO(nothing); struct ast_frame f = { AST_FRAME_CONTROL, AST_CONTROL_CONGESTION }; ast_mutex_lock(&iaxsl[callno]); if (iaxs[callno]) { iaxs[callno]->initid = -1; iax2_queue_frame(callno, &f); ast_log(LOG_NOTICE, "Auto-congesting call due to slow response\n"); } ast_mutex_unlock(&iaxsl[callno]); return 0; } static unsigned int iax2_datetime(void) { time_t t; struct tm tm; unsigned int tmp; time(&t); localtime_r(&t, &tm); tmp = (tm.tm_sec >> 1) & 0x1f; /* 5 bits of seconds */ tmp |= (tm.tm_min & 0x3f) << 5; /* 6 bits of minutes */ tmp |= (tm.tm_hour & 0x1f) << 11; /* 5 bits of hours */ tmp |= (tm.tm_mday & 0x1f) << 16; /* 5 bits of day of month */ tmp |= ((tm.tm_mon + 1) & 0xf) << 21; /* 4 bits of month */ tmp |= ((tm.tm_year - 100) & 0x7f) << 25; /* 7 bits of year */ return tmp; } static int iax2_call(struct ast_channel *c, char *dest, int timeout) { struct sockaddr_in sin; char host[256]; char *rdest; char *rcontext; char *username; char *secret = NULL; char *hname; char cid[256] = ""; char *l=NULL, *n=NULL; struct iax_ie_data ied; char myrdest [5] = "s"; char context[AST_MAX_EXTENSION] =""; char peercontext[AST_MAX_EXTENSION] =""; char *portno = NULL; char *opts = ""; unsigned short callno = PTR_TO_CALLNO(c->pvt->pvt); char *stringp=NULL; char storedusern[80], storedsecret[80]; if ((c->_state != AST_STATE_DOWN) && (c->_state != AST_STATE_RESERVED)) { ast_log(LOG_WARNING, "Line is already in use (%s)?\n", c->name); return -1; } strncpy(host, dest, sizeof(host)-1); stringp=host; strsep(&stringp, "/"); /* If no destination extension specified, use 's' */ rdest = strsep(&stringp, "/"); if (!rdest) rdest = myrdest; else { /* Check for trailing options */ opts = strsep(&stringp, "/"); if (!opts) opts = ""; } stringp=rdest; strsep(&stringp, "@"); rcontext = strsep(&stringp, "@"); stringp=host; strsep(&stringp, "@"); username = strsep(&stringp, "@"); if (username) { /* Really the second argument is the host, not the username */ hname = username; username = host; } else { hname = host; } if (username) { stringp=username; username = strsep(&stringp, ":"); secret = strsep(&stringp, ":"); } stringp=hname; if (strsep(&stringp, ":")) { stringp=hname; strsep(&stringp, ":"); portno = strsep(&stringp, ":"); } if (create_addr(&sin, NULL, NULL, NULL, hname, context, NULL, NULL, storedusern, sizeof(storedusern) - 1, storedsecret, sizeof(storedsecret) - 1, NULL, peercontext)) { ast_log(LOG_WARNING, "No address associated with '%s'\n", hname); return -1; } /* Keep track of the context for outgoing calls too */ strncpy(c->context, context, sizeof(c->context) - 1); if (portno) { sin.sin_port = htons(atoi(portno)); } if (c->callerid) { strncpy(cid, c->callerid, sizeof(cid) - 1); ast_callerid_parse(cid, &n, &l); if (l) ast_shrink_phone_number(l); } /* Now build request */ memset(&ied, 0, sizeof(ied)); /* On new call, first IE MUST be IAX version of caller */ iax_ie_append_short(&ied, IAX_IE_VERSION, IAX_PROTO_VERSION); iax_ie_append_str(&ied, IAX_IE_CALLED_NUMBER, rdest); if (strchr(opts, 'a')) { /* Request auto answer */ iax_ie_append(&ied, IAX_IE_AUTOANSWER); } if (l) iax_ie_append_str(&ied, IAX_IE_CALLING_NUMBER, l); if (n) iax_ie_append_str(&ied, IAX_IE_CALLING_NAME, n); if (iaxs[callno]->sendani && c->ani) { l = n = NULL; strncpy(cid, c->ani, sizeof(cid) - 1); ast_callerid_parse(cid, &n, &l); if (l) { ast_shrink_phone_number(l); iax_ie_append_str(&ied, IAX_IE_CALLING_ANI, l); } } if (c->language && !ast_strlen_zero(c->language)) iax_ie_append_str(&ied, IAX_IE_LANGUAGE, c->language); if (c->dnid && !ast_strlen_zero(c->dnid)) iax_ie_append_str(&ied, IAX_IE_DNID, c->dnid); if (rcontext) iax_ie_append_str(&ied, IAX_IE_CALLED_CONTEXT, rcontext); else if (strlen(peercontext)) iax_ie_append_str(&ied, IAX_IE_CALLED_CONTEXT, peercontext); if (!username && !ast_strlen_zero(storedusern)) username = storedusern; if (username) iax_ie_append_str(&ied, IAX_IE_USERNAME, username); if (!secret && !ast_strlen_zero(storedsecret)) secret = storedsecret; ast_mutex_lock(&iaxsl[callno]); if (!ast_strlen_zero(c->context)) strncpy(iaxs[callno]->context, c->context, sizeof(iaxs[callno]->context) - 1); if (secret) { if (secret[0] == '[') { /* This is an RSA key, not a normal secret */ strncpy(iaxs[callno]->outkey, secret + 1, sizeof(iaxs[callno]->secret)-1); if (!ast_strlen_zero(iaxs[callno]->outkey)) { iaxs[callno]->outkey[strlen(iaxs[callno]->outkey) - 1] = '\0'; } } else strncpy(iaxs[callno]->secret, secret, sizeof(iaxs[callno]->secret)-1); } iax_ie_append_int(&ied, IAX_IE_FORMAT, c->nativeformats); iax_ie_append_int(&ied, IAX_IE_CAPABILITY, iaxs[callno]->capability); iax_ie_append_short(&ied, IAX_IE_ADSICPE, c->adsicpe); iax_ie_append_int(&ied, IAX_IE_DATETIME, iax2_datetime()); /* Transmit the string in a "NEW" request */ #if 0 /* XXX We have no equivalent XXX */ if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Calling using options '%s'\n", requeststr); #endif if (iaxs[callno]->maxtime) { /* Initialize pingtime and auto-congest time */ iaxs[callno]->pingtime = iaxs[callno]->maxtime / 2; iaxs[callno]->initid = ast_sched_add(sched, iaxs[callno]->maxtime * 2, auto_congest, CALLNO_TO_PTR(callno)); } send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_NEW, 0, ied.buf, ied.pos, -1); ast_mutex_unlock(&iaxsl[callno]); ast_setstate(c, AST_STATE_RINGING); return 0; } static int iax2_hangup(struct ast_channel *c) { unsigned short callno = PTR_TO_CALLNO(c->pvt->pvt); int alreadygone; ast_mutex_lock(&iaxsl[callno]); if (callno && iaxs[callno]) { ast_log(LOG_DEBUG, "We're hanging up %s now...\n", c->name); alreadygone = iaxs[callno]->alreadygone; /* Send the hangup unless we have had a transmission error or are already gone */ if (!iaxs[callno]->error && !alreadygone) send_command_final(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_HANGUP, 0, NULL, 0, -1); /* Explicitly predestroy it */ iax2_predestroy_nolock(callno); /* If we were already gone to begin with, destroy us now */ if (alreadygone) { ast_log(LOG_DEBUG, "Really destroying %s now...\n", c->name); iax2_destroy_nolock(callno); } } ast_mutex_unlock(&iaxsl[callno]); if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Hungup '%s'\n", c->name); return 0; } static int iax2_setoption(struct ast_channel *c, int option, void *data, int datalen) { struct ast_option_header *h; int res; h = malloc(datalen + sizeof(struct ast_option_header)); if (h) { h->flag = AST_OPTION_FLAG_REQUEST; h->option = htons(option); memcpy(h->data, data, datalen); res = send_command_locked(PTR_TO_CALLNO(c->pvt->pvt), AST_FRAME_CONTROL, AST_CONTROL_OPTION, 0, (char *)h, datalen + sizeof(struct ast_option_header), -1); free(h); return res; } else ast_log(LOG_WARNING, "Out of memory\n"); return -1; } static struct ast_frame *iax2_read(struct ast_channel *c) { static struct ast_frame f = { AST_FRAME_NULL, }; ast_log(LOG_NOTICE, "I should never be called!\n"); return &f; } static int iax2_start_transfer(unsigned short callno0, unsigned short callno1) { int res; struct iax_ie_data ied0; struct iax_ie_data ied1; unsigned int transferid = rand(); memset(&ied0, 0, sizeof(ied0)); iax_ie_append_addr(&ied0, IAX_IE_APPARENT_ADDR, &iaxs[callno1]->addr); iax_ie_append_short(&ied0, IAX_IE_CALLNO, iaxs[callno1]->peercallno); iax_ie_append_int(&ied0, IAX_IE_TRANSFERID, transferid); memset(&ied1, 0, sizeof(ied1)); iax_ie_append_addr(&ied1, IAX_IE_APPARENT_ADDR, &iaxs[callno0]->addr); iax_ie_append_short(&ied1, IAX_IE_CALLNO, iaxs[callno0]->peercallno); iax_ie_append_int(&ied1, IAX_IE_TRANSFERID, transferid); res = send_command(iaxs[callno0], AST_FRAME_IAX, IAX_COMMAND_TXREQ, 0, ied0.buf, ied0.pos, -1); if (res) return -1; res = send_command(iaxs[callno1], AST_FRAME_IAX, IAX_COMMAND_TXREQ, 0, ied1.buf, ied1.pos, -1); if (res) return -1; iaxs[callno0]->transferring = TRANSFER_BEGIN; iaxs[callno1]->transferring = TRANSFER_BEGIN; return 0; } static void lock_both(unsigned short callno0, unsigned short callno1) { ast_mutex_lock(&iaxsl[callno0]); while (ast_mutex_trylock(&iaxsl[callno1])) { ast_mutex_unlock(&iaxsl[callno0]); usleep(10); ast_mutex_lock(&iaxsl[callno0]); } } static void unlock_both(unsigned short callno0, unsigned short callno1) { ast_mutex_unlock(&iaxsl[callno1]); ast_mutex_unlock(&iaxsl[callno0]); } static int iax2_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, struct ast_frame **fo, struct ast_channel **rc) { struct ast_channel *cs[3]; struct ast_channel *who; int to = -1; int res = -1; int transferstarted=0; struct ast_frame *f; unsigned short callno0 = PTR_TO_CALLNO(c0->pvt->pvt); unsigned short callno1 = PTR_TO_CALLNO(c1->pvt->pvt); struct timeval waittimer = {0, 0}, tv; lock_both(callno0, callno1); /* Put them in native bridge mode */ iaxs[callno0]->bridgecallno = callno1; iaxs[callno1]->bridgecallno = callno0; unlock_both(callno0, callno1); /* If not, try to bridge until we can execute a transfer, if we can */ cs[0] = c0; cs[1] = c1; for (/* ever */;;) { /* Check in case we got masqueraded into */ if ((c0->type != type) || (c1->type != type)) { if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Can't masquerade, we're different...\n"); /* Remove from native mode */ if (c0->type == type) { ast_mutex_lock(&iaxsl[callno0]); iaxs[callno0]->bridgecallno = 0; ast_mutex_unlock(&iaxsl[callno0]); } if (c1->type == type) { ast_mutex_lock(&iaxsl[callno1]); iaxs[callno1]->bridgecallno = 0; ast_mutex_unlock(&iaxsl[callno1]); } return -2; } if (c0->nativeformats != c1->nativeformats) { ast_verbose(VERBOSE_PREFIX_3 "Operating with different codecs, can't native bridge...\n"); /* Remove from native mode */ lock_both(callno0, callno1); iaxs[callno0]->bridgecallno = 0; iaxs[callno1]->bridgecallno = 0; unlock_both(callno0, callno1); return -2; } /* check if transfered and if we really want native bridging */ if (!transferstarted && !iaxs[callno0]->notransfer && !iaxs[callno1]->notransfer) { /* Try the transfer */ if (iax2_start_transfer(callno0, callno1)) ast_log(LOG_WARNING, "Unable to start the transfer\n"); transferstarted = 1; } if ((iaxs[callno0]->transferring == TRANSFER_RELEASED) && (iaxs[callno1]->transferring == TRANSFER_RELEASED)) { /* Call has been transferred. We're no longer involved */ gettimeofday(&tv, NULL); if (!waittimer.tv_sec && !waittimer.tv_usec) { waittimer.tv_sec = tv.tv_sec; waittimer.tv_usec = tv.tv_usec; } else if (tv.tv_sec - waittimer.tv_sec > IAX_LINGER_TIMEOUT) { c0->_softhangup |= AST_SOFTHANGUP_DEV; c1->_softhangup |= AST_SOFTHANGUP_DEV; *fo = NULL; *rc = c0; res = 0; break; } } to = 1000; who = ast_waitfor_n(cs, 2, &to); if (!who) { if (ast_check_hangup(c0) || ast_check_hangup(c1)) { res = -1; break; } continue; } f = ast_read(who); if (!f) { *fo = NULL; *rc = who; res = 0; break; } if ((f->frametype == AST_FRAME_CONTROL) && !(flags & AST_BRIDGE_IGNORE_SIGS)) { *fo = f; *rc = who; res = 0; break; } if ((f->frametype == AST_FRAME_VOICE) || (f->frametype == AST_FRAME_TEXT) || (f->frametype == AST_FRAME_VIDEO) || (f->frametype == AST_FRAME_IMAGE) || (f->frametype == AST_FRAME_DTMF)) { if ((f->frametype == AST_FRAME_DTMF) && (flags & (AST_BRIDGE_DTMF_CHANNEL_0 | AST_BRIDGE_DTMF_CHANNEL_1))) { if ((who == c0)) { if ((flags & AST_BRIDGE_DTMF_CHANNEL_0)) { *rc = c0; *fo = f; /* Take out of conference mode */ res = 0; /* Remove from native mode */ break; } else goto tackygoto; } else if ((who == c1)) { if (flags & AST_BRIDGE_DTMF_CHANNEL_1) { *rc = c1; *fo = f; res = 0; /* Remove from native mode */ break; } else goto tackygoto; } } else { #if 0 ast_log(LOG_DEBUG, "Read from %s\n", who->name); if (who == last) ast_log(LOG_DEBUG, "Servicing channel %s twice in a row?\n", last->name); last = who; #endif tackygoto: if (who == c0) ast_write(c1, f); else ast_write(c0, f); } ast_frfree(f); } else ast_frfree(f); /* Swap who gets priority */ cs[2] = cs[0]; cs[0] = cs[1]; cs[1] = cs[2]; } lock_both(callno0, callno1); iaxs[callno0]->bridgecallno = 0; iaxs[callno1]->bridgecallno = 0; unlock_both(callno0, callno1); return res; } static int iax2_answer(struct ast_channel *c) { unsigned short callno = PTR_TO_CALLNO(c->pvt->pvt); if (option_debug) ast_log(LOG_DEBUG, "Answering\n"); return send_command_locked(callno, AST_FRAME_CONTROL, AST_CONTROL_ANSWER, 0, NULL, 0, -1); } static int iax2_indicate(struct ast_channel *c, int condition) { unsigned short callno = PTR_TO_CALLNO(c->pvt->pvt); if (option_debug) ast_log(LOG_DEBUG, "Indicating condition %d\n", condition); return send_command_locked(callno, AST_FRAME_CONTROL, condition, 0, NULL, 0, -1); } static int iax2_transfer(struct ast_channel *c, char *dest) { unsigned short callno = PTR_TO_CALLNO(c->pvt->pvt); struct iax_ie_data ied; char tmp[256] = "", *context; strncpy(tmp, dest, sizeof(tmp) - 1); context = strchr(tmp, '@'); if (context) { *context = '\0'; context++; } memset(&ied, 0, sizeof(ied)); iax_ie_append_str(&ied, IAX_IE_CALLED_NUMBER, tmp); if (context) iax_ie_append_str(&ied, IAX_IE_CALLED_CONTEXT, context); if (option_debug) ast_log(LOG_DEBUG, "Transferring '%s' to '%s'\n", c->name, dest); return send_command_locked(callno, AST_FRAME_IAX, IAX_COMMAND_TRANSFER, 0, ied.buf, ied.pos, -1); } static int iax2_write(struct ast_channel *c, struct ast_frame *f); static int iax2_getpeertrunk(struct sockaddr_in sin) { struct iax2_peer *peer; int res = 0; ast_mutex_lock(&peerl.lock); peer = peerl.peers; while(peer) { if ((peer->addr.sin_addr.s_addr == sin.sin_addr.s_addr) && (peer->addr.sin_port == sin.sin_port)) { res = peer->trunk; break; } peer = peer->next; } ast_mutex_unlock(&peerl.lock); return res; } static struct ast_channel *ast_iax2_new(int callno, int state, int capability) { struct ast_channel *tmp; struct chan_iax2_pvt *i; /* Don't hold call lock */ ast_mutex_unlock(&iaxsl[callno]); tmp = ast_channel_alloc(1); ast_mutex_lock(&iaxsl[callno]); i = iaxs[callno]; if (i && tmp) { if (!ast_strlen_zero(i->username)) snprintf(tmp->name, sizeof(tmp->name), "IAX2/%s@%s/%d", i->username, i->host, i->callno); else snprintf(tmp->name, sizeof(tmp->name), "IAX2/%s/%d", i->host, i->callno); tmp->type = type; /* We can support any format by default, until we get restricted */ tmp->nativeformats = capability; tmp->readformat = 0; tmp->writeformat = 0; tmp->pvt->pvt = CALLNO_TO_PTR(i->callno); tmp->pvt->send_digit = iax2_digit; tmp->pvt->send_text = iax2_sendtext; tmp->pvt->send_image = iax2_sendimage; tmp->pvt->send_html = iax2_sendhtml; tmp->pvt->call = iax2_call; tmp->pvt->hangup = iax2_hangup; tmp->pvt->answer = iax2_answer; tmp->pvt->read = iax2_read; tmp->pvt->write = iax2_write; tmp->pvt->write_video = iax2_write; tmp->pvt->indicate = iax2_indicate; tmp->pvt->setoption = iax2_setoption; tmp->pvt->bridge = iax2_bridge; tmp->pvt->transfer = iax2_transfer; if (!ast_strlen_zero(i->callerid)) tmp->callerid = strdup(i->callerid); if (!ast_strlen_zero(i->ani)) tmp->ani = strdup(i->ani); if (!ast_strlen_zero(i->language)) strncpy(tmp->language, i->language, sizeof(tmp->language)-1); if (!ast_strlen_zero(i->dnid)) tmp->dnid = strdup(i->dnid); if (!ast_strlen_zero(i->accountcode)) strncpy(tmp->accountcode, i->accountcode, sizeof(tmp->accountcode)-1); if (i->amaflags) tmp->amaflags = i->amaflags; strncpy(tmp->context, i->context, sizeof(tmp->context)-1); strncpy(tmp->exten, i->exten, sizeof(tmp->exten)-1); tmp->adsicpe = i->peeradsicpe; tmp->pvt->fixup = iax2_fixup; i->owner = tmp; i->capability = capability; ast_setstate(tmp, state); ast_mutex_lock(&usecnt_lock); usecnt++; ast_mutex_unlock(&usecnt_lock); ast_update_use_count(); if (state != AST_STATE_DOWN) { if (ast_pbx_start(tmp)) { ast_log(LOG_WARNING, "Unable to start PBX on %s\n", tmp->name); ast_hangup(tmp); tmp = NULL; } } } return tmp; } static unsigned int calc_txpeerstamp(struct iax2_trunk_peer *tpeer, int sampms, struct timeval *tv) { unsigned long int mssincetx; /* unsigned to handle overflows */ long int ms, pred; tpeer->trunkact = *tv; mssincetx = (tv->tv_sec - tpeer->lasttxtime.tv_sec) * 1000 + (1000000 + tv->tv_usec - tpeer->lasttxtime.tv_usec) / 1000 - 1000; if (mssincetx > 5000 || (!tpeer->txtrunktime.tv_sec && !tpeer->txtrunktime.tv_usec)) { /* If it's been at least 5 seconds since the last time we transmitted on this trunk, reset our timers */ tpeer->txtrunktime.tv_sec = tv->tv_sec; tpeer->txtrunktime.tv_usec = tv->tv_usec; tpeer->lastsent = 999999; } /* Update last transmit time now */ tpeer->lasttxtime.tv_sec = tv->tv_sec; tpeer->lasttxtime.tv_usec = tv->tv_usec; /* Calculate ms offset */ ms = (tv->tv_sec - tpeer->txtrunktime.tv_sec) * 1000 + (1000000 + tv->tv_usec - tpeer->txtrunktime.tv_usec) / 1000 - 1000; /* Predict from last value */ pred = tpeer->lastsent + sampms; if (abs(ms - pred) < MAX_TIMESTAMP_SKEW) ms = pred; /* We never send the same timestamp twice, so fudge a little if we must */ if (ms == tpeer->lastsent) ms = tpeer->lastsent + 1; tpeer->lastsent = ms; return ms; } static unsigned int fix_peerts(struct timeval *tv, int callno, unsigned int ts) { long ms; /* NOT unsigned */ if (!iaxs[callno]->rxcore.tv_sec && !iaxs[callno]->rxcore.tv_usec) { /* Initialize rxcore time if appropriate */ gettimeofday(&iaxs[callno]->rxcore, NULL); /* Round to nearest 20ms so traces look pretty */ iaxs[callno]->rxcore.tv_usec -= iaxs[callno]->rxcore.tv_usec % 20000; } /* Calculate difference between trunk and channel */ ms = (tv->tv_sec - iaxs[callno]->rxcore.tv_sec) * 1000 + (1000000 + tv->tv_usec - iaxs[callno]->rxcore.tv_usec) / 1000 - 1000; /* Return as the sum of trunk time and the difference between trunk and real time */ return ms + ts; } static unsigned int calc_timestamp(struct chan_iax2_pvt *p, unsigned int ts, struct ast_frame *f) { struct timeval tv; int ms; int voice = 0; int genuine = 0; struct timeval *delivery = NULL; /* What sort of frame do we have?: voice is self-explanatory "genuine" means an IAX frame - things like LAGRQ/RP, PING/PONG, ACK non-genuine frames are CONTROL frames [ringing etc], DTMF The "genuine" distinction is needed because genuine frames must get a clock-based timestamp, the others need a timestamp slaved to the voice frames so that they go in sequence */ if (f) { if (f->frametype == AST_FRAME_VOICE) { voice = 1; delivery = &f->delivery; } else if (f->frametype == AST_FRAME_IAX) { genuine = 1; } } if (!p->offset.tv_sec && !p->offset.tv_usec) { gettimeofday(&p->offset, NULL); /* Round to nearest 20ms for nice looking traces */ p->offset.tv_usec -= p->offset.tv_usec % 20000; } /* If the timestamp is specified, just send it as is */ if (ts) return ts; /* If we have a time that the frame arrived, always use it to make our timestamp */ if (delivery && (delivery->tv_sec || delivery->tv_usec)) { ms = (delivery->tv_sec - p->offset.tv_sec) * 1000 + (1000000 + delivery->tv_usec - p->offset.tv_usec) / 1000 - 1000; } else { gettimeofday(&tv, NULL); ms = (tv.tv_sec - p->offset.tv_sec) * 1000 + (1000000 + tv.tv_usec - p->offset.tv_usec) / 1000 - 1000; if (ms < 0) ms = 0; if (voice) { /* On a voice frame, use predicted values if appropriate */ if (abs(ms - p->nextpred) <= MAX_TIMESTAMP_SKEW) { if (!p->nextpred) { p->nextpred = ms; /*f->samples / 8;*/ if (p->nextpred <= p->lastsent) p->nextpred = p->lastsent + 3; } ms = p->nextpred; } else p->nextpred = ms; } else { /* On a dataframe, use last value + 3 (to accomodate jitter buffer shrinking) if appropriate unless it's a genuine frame */ if (genuine) { /* genuine (IAX LAGRQ etc) must keep their clock-based stamps */ if (ms <= p->lastsent) ms = p->lastsent + 3; } else if (abs(ms - p->lastsent) <= MAX_TIMESTAMP_SKEW) { /* non-genuine frames (!?) (DTMF, CONTROL) should be pulled into the predicted stream stamps */ ms = p->lastsent + 3; } } } p->lastsent = ms; if (voice) p->nextpred = p->nextpred + f->samples / 8; #if 0 printf("TS: %s - %dms\n", voice ? "Audio" : "Control", ms); #endif return ms; } #ifdef BRIDGE_OPTIMIZATION static unsigned int calc_fakestamp(struct chan_iax2_pvt *p1, struct chan_iax2_pvt *p2, unsigned int fakets) { int ms; /* Receive from p1, send to p2 */ /* Setup rxcore if necessary on outgoing channel */ if (!p1->rxcore.tv_sec && !p1->rxcore.tv_usec) gettimeofday(&p1->rxcore, NULL); /* Setup txcore if necessary on outgoing channel */ if (!p2->offset.tv_sec && !p2->offset.tv_usec) gettimeofday(&p2->offset, NULL); /* Now, ts is the timestamp of the original packet in the orignal context. Adding rxcore to it gives us when we would want the packet to be delivered normally. Subtracting txcore of the outgoing channel gives us what we'd expect */ ms = (p1->rxcore.tv_sec - p2->offset.tv_sec) * 1000 + (1000000 + p1->rxcore.tv_usec - p2->offset.tv_usec) / 1000 - 1000; fakets += ms; /* FIXME? SLD would rather remove this and leave it to the end system to deal with */ if (fakets <= p2->lastsent) fakets = p2->lastsent + 1; p2->lastsent = fakets; return fakets; } #endif static unsigned int calc_rxstamp(struct chan_iax2_pvt *p) { /* Returns where in "receive time" we are */ struct timeval tv; int ms; /* Setup rxcore if necessary */ if (!p->rxcore.tv_sec && !p->rxcore.tv_usec) gettimeofday(&p->rxcore, NULL); gettimeofday(&tv, NULL); ms = (tv.tv_sec - p->rxcore.tv_sec) * 1000 + (1000000 + tv.tv_usec - p->rxcore.tv_usec) / 1000 - 1000; return ms; } static struct iax2_trunk_peer *find_tpeer(struct sockaddr_in *sin) { struct iax2_trunk_peer *tpeer; char iabuf[INET_ADDRSTRLEN]; /* Finds and locks trunk peer */ ast_mutex_lock(&tpeerlock); tpeer = tpeers; while(tpeer) { /* We don't lock here because tpeer->addr *never* changes */ if (!inaddrcmp(&tpeer->addr, sin)) { ast_mutex_lock(&tpeer->lock); break; } tpeer = tpeer->next; } if (!tpeer) { tpeer = malloc(sizeof(struct iax2_trunk_peer)); if (tpeer) { memset(tpeer, 0, sizeof(struct iax2_trunk_peer)); ast_mutex_init(&tpeer->lock); tpeer->lastsent = 9999; memcpy(&tpeer->addr, sin, sizeof(tpeer->addr)); gettimeofday(&tpeer->trunkact, NULL); ast_mutex_lock(&tpeer->lock); tpeer->next = tpeers; tpeers = tpeer; ast_log(LOG_DEBUG, "Created trunk peer for '%s:%d'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), tpeer->addr.sin_addr), ntohs(tpeer->addr.sin_port)); } } ast_mutex_unlock(&tpeerlock); return tpeer; } static int iax2_trunk_queue(struct chan_iax2_pvt *pvt, struct ast_frame *f) { struct iax2_trunk_peer *tpeer; void *tmp, *ptr; struct ast_iax2_meta_trunk_entry *met; char iabuf[INET_ADDRSTRLEN]; tpeer = find_tpeer(&pvt->addr); if (tpeer) { if (tpeer->trunkdatalen + f->datalen + 4 >= tpeer->trunkdataalloc) { /* Need to reallocate space */ if (tpeer->trunkdataalloc < MAX_TRUNKDATA) { tmp = realloc(tpeer->trunkdata, tpeer->trunkdataalloc + DEFAULT_TRUNKDATA + IAX2_TRUNK_PREFACE); if (tmp) { tpeer->trunkdataalloc += DEFAULT_TRUNKDATA; tpeer->trunkdata = tmp; ast_log(LOG_DEBUG, "Expanded trunk '%s:%d' to %d bytes\n", ast_inet_ntoa(iabuf, sizeof(iabuf), tpeer->addr.sin_addr), ntohs(tpeer->addr.sin_port), tpeer->trunkdataalloc); } else { ast_log(LOG_WARNING, "Insufficient memory to expand trunk data to %s:%d\n", ast_inet_ntoa(iabuf, sizeof(iabuf), tpeer->addr.sin_addr), ntohs(tpeer->addr.sin_port)); ast_mutex_unlock(&tpeer->lock); return -1; } } else { ast_log(LOG_WARNING, "Maximum trunk data space exceeded to %s:%d\n", ast_inet_ntoa(iabuf, sizeof(iabuf), tpeer->addr.sin_addr), ntohs(tpeer->addr.sin_port)); ast_mutex_unlock(&tpeer->lock); return -1; } } /* Append to meta frame */ ptr = tpeer->trunkdata + IAX2_TRUNK_PREFACE + tpeer->trunkdatalen; met = (struct ast_iax2_meta_trunk_entry *)ptr; /* Store call number and length in meta header */ met->callno = htons(pvt->callno); met->len = htons(f->datalen); /* Advance pointers/decrease length past trunk entry header */ ptr += sizeof(struct ast_iax2_meta_trunk_entry); tpeer->trunkdatalen += sizeof(struct ast_iax2_meta_trunk_entry); /* Copy actual trunk data */ memcpy(ptr, f->data, f->datalen); tpeer->trunkdatalen += f->datalen; tpeer->calls++; ast_mutex_unlock(&tpeer->lock); } return 0; } static int iax2_send(struct chan_iax2_pvt *pvt, struct ast_frame *f, unsigned int ts, int seqno, int now, int transfer, int final) { /* Queue a packet for delivery on a given private structure. Use "ts" for timestamp, or calculate if ts is 0. Send immediately without retransmission or delayed, with retransmission */ struct ast_iax2_full_hdr *fh; struct ast_iax2_mini_hdr *mh; struct ast_iax2_video_hdr *vh; struct { struct iax_frame fr2; unsigned char buffer[4096]; } frb; struct iax_frame *fr; int res; int sendmini=0; unsigned int lastsent; unsigned int fts; if (!pvt) { ast_log(LOG_WARNING, "No private structure for packet?\n"); return -1; } lastsent = pvt->lastsent; /* Calculate actual timestamp */ fts = calc_timestamp(pvt, ts, f); if ((pvt->trunk || ((fts & 0xFFFF0000L) == (lastsent & 0xFFFF0000L))) /* High two bytes are the same on timestamp, or sending on a trunk */ && (f->frametype == AST_FRAME_VOICE) /* is a voice frame */ && (f->subclass == pvt->svoiceformat) /* is the same type */ ) { /* Force immediate rather than delayed transmission */ now = 1; /* Mark that mini-style frame is appropriate */ sendmini = 1; } if (((fts & 0xFFFF8000L) == (lastsent & 0xFFFF8000L)) && (f->frametype == AST_FRAME_VIDEO) && ((f->subclass & ~0x1) == pvt->svideoformat)) { now = 1; sendmini = 1; } /* Allocate an iax_frame */ if (now) { fr = &frb.fr2; } else fr = iax_frame_new(DIRECTION_OUTGRESS, f->datalen); if (!fr) { ast_log(LOG_WARNING, "Out of memory\n"); return -1; } /* Copy our prospective frame into our immediate or retransmitted wrapper */ iax_frame_wrap(fr, f); fr->ts = fts; fr->callno = pvt->callno; fr->transfer = transfer; fr->final = final; if (!sendmini) { /* We need a full frame */ if (seqno > -1) fr->oseqno = seqno; else fr->oseqno = pvt->oseqno++; fr->iseqno = pvt->iseqno; fh = (struct ast_iax2_full_hdr *)(fr->af.data - sizeof(struct ast_iax2_full_hdr)); fh->scallno = htons(fr->callno | IAX_FLAG_FULL); fh->ts = htonl(fr->ts); fh->oseqno = fr->oseqno; if (transfer) { fh->iseqno = 0; } else fh->iseqno = fr->iseqno; /* Keep track of the last thing we've acknowledged */ if (!transfer) pvt->aseqno = fr->iseqno; fh->type = fr->af.frametype & 0xFF; if (fr->af.frametype == AST_FRAME_VIDEO) fh->csub = compress_subclass(fr->af.subclass & ~0x1) | ((fr->af.subclass & 0x1) << 6); else fh->csub = compress_subclass(fr->af.subclass); if (transfer) { fr->dcallno = pvt->transfercallno; } else fr->dcallno = pvt->peercallno; fh->dcallno = htons(fr->dcallno); fr->datalen = fr->af.datalen + sizeof(struct ast_iax2_full_hdr); fr->data = fh; fr->retries = 0; /* Retry after 2x the ping time has passed */ fr->retrytime = pvt->pingtime * 2; if (fr->retrytime < MIN_RETRY_TIME) fr->retrytime = MIN_RETRY_TIME; if (fr->retrytime > MAX_RETRY_TIME) fr->retrytime = MAX_RETRY_TIME; /* Acks' don't get retried */ if ((f->frametype == AST_FRAME_IAX) && (f->subclass == IAX_COMMAND_ACK)) fr->retries = -1; else if (f->frametype == AST_FRAME_VOICE) pvt->svoiceformat = f->subclass; else if (f->frametype == AST_FRAME_VIDEO) pvt->svideoformat = f->subclass & ~0x1; if (now) { res = send_packet(fr); } else res = iax2_transmit(fr); } else { if (pvt->trunk) { iax2_trunk_queue(pvt, &fr->af); res = 0; } else if (fr->af.frametype == AST_FRAME_VIDEO) { /* Video frame have no sequence number */ fr->oseqno = -1; fr->iseqno = -1; vh = (struct ast_iax2_video_hdr *)(fr->af.data - sizeof(struct ast_iax2_video_hdr)); vh->zeros = 0; vh->callno = htons(0x8000 | fr->callno); vh->ts = htons((fr->ts & 0x7FFF) | (fr->af.subclass & 0x1 ? 0x8000 : 0)); fr->datalen = fr->af.datalen + sizeof(struct ast_iax2_video_hdr); fr->data = vh; fr->retries = -1; res = send_packet(fr); } else { /* Mini-frames have no sequence number */ fr->oseqno = -1; fr->iseqno = -1; /* Mini frame will do */ mh = (struct ast_iax2_mini_hdr *)(fr->af.data - sizeof(struct ast_iax2_mini_hdr)); mh->callno = htons(fr->callno); mh->ts = htons(fr->ts & 0xFFFF); fr->datalen = fr->af.datalen + sizeof(struct ast_iax2_mini_hdr); fr->data = mh; fr->retries = -1; res = send_packet(fr); } } return res; } static int iax2_show_users(int fd, int argc, char *argv[]) { #define FORMAT "%-15.15s %-20.20s %-15.15s %-15.15s %-5.5s\n" #define FORMAT2 "%-15.15s %-20.20s %-15.15d %-15.15s %-5.5s\n" struct iax2_user *user; char auth[90] = ""; if (argc != 3) return RESULT_SHOWUSAGE; ast_mutex_lock(&userl.lock); ast_cli(fd, FORMAT, "Username", "Secret", "Authen", "Def.Context", "A/C"); for(user=userl.users;user;user=user->next) { if (!ast_strlen_zero(user->secret)) { strncpy(auth,user->secret,sizeof(auth)-1); } else if (!ast_strlen_zero(user->inkeys)) { snprintf(auth, sizeof(auth), "Key: %-15.15s ", user->inkeys); } else strncpy(auth, "-no secret-", sizeof(auth) - 1); ast_cli(fd, FORMAT2, user->name, auth, user->authmethods, user->contexts ? user->contexts->context : context, user->ha ? "Yes" : "No"); } ast_mutex_unlock(&userl.lock); return RESULT_SUCCESS; #undef FORMAT #undef FORMAT2 } static int iax2_show_peers(int fd, int argc, char *argv[]) { #define FORMAT2 "%-15.15s %-15.15s %s %-15.15s %-8s %-10s\n" #define FORMAT "%-15.15s %-15.15s %s %-15.15s %-5d%s %-10s\n" struct iax2_peer *peer; char name[256] = ""; char iabuf[INET_ADDRSTRLEN]; int registeredonly=0; if ((argc != 3) && (argc != 4) && (argc != 5)) return RESULT_SHOWUSAGE; if ((argc == 4)) { if (!strcasecmp(argv[3], "registered")) { registeredonly = 1; } else return RESULT_SHOWUSAGE; } ast_mutex_lock(&peerl.lock); ast_cli(fd, FORMAT2, "Name/Username", "Host", " ", "Mask", "Port", "Status"); for (peer = peerl.peers;peer;peer = peer->next) { char nm[20]; char status[20] = ""; int print_line = -1; char srch[2000] = ""; if (registeredonly && !peer->addr.sin_addr.s_addr) continue; if (!ast_strlen_zero(peer->username)) snprintf(name, sizeof(name), "%s/%s", peer->name, peer->username); else strncpy(name, peer->name, sizeof(name) - 1); if (peer->maxms) { if (peer->lastms < 0) strncpy(status, "UNREACHABLE", sizeof(status) - 1); else if (peer->lastms > peer->maxms) snprintf(status, sizeof(status), "LAGGED (%d ms)", peer->lastms); else if (peer->lastms) snprintf(status, sizeof(status), "OK (%d ms)", peer->lastms); else strncpy(status, "UNKNOWN", sizeof(status) - 1); } else strncpy(status, "Unmonitored", sizeof(status) - 1); strncpy(nm, ast_inet_ntoa(iabuf, sizeof(iabuf), peer->mask), sizeof(nm)-1); snprintf(srch, sizeof(srch), FORMAT, name, peer->addr.sin_addr.s_addr ? ast_inet_ntoa(iabuf, sizeof(iabuf), peer->addr.sin_addr) : "(Unspecified)", peer->dynamic ? "(D)" : "(S)", nm, ntohs(peer->addr.sin_port), peer->trunk ? "(T)" : " ", status); if (argc == 5) { if (!strcasecmp(argv[3],"include") && strstr(srch,argv[4])) { print_line = -1; } else if (!strcasecmp(argv[3],"exclude") && !strstr(srch,argv[4])) { print_line = 1; } else if (!strcasecmp(argv[3],"begin") && !strncasecmp(srch,argv[4],strlen(argv[4]))) { print_line = -1; } else { print_line = 0; } } if (print_line) { ast_cli(fd, FORMAT, name, peer->addr.sin_addr.s_addr ? ast_inet_ntoa(iabuf, sizeof(iabuf), peer->addr.sin_addr) : "(Unspecified)", peer->dynamic ? "(D)" : "(S)", nm, ntohs(peer->addr.sin_port), peer->trunk ? "(T)" : " ", status); } } ast_mutex_unlock(&peerl.lock); return RESULT_SUCCESS; #undef FORMAT #undef FORMAT2 } static int iax2_show_firmware(int fd, int argc, char *argv[]) { #define FORMAT2 "%-15.15s %-15.15s %-15.15s\n" #define FORMAT "%-15.15s %-15d %-15d\n" struct iax_firmware *cur; if ((argc != 3) && (argc != 4)) return RESULT_SHOWUSAGE; ast_mutex_lock(&waresl.lock); ast_cli(fd, FORMAT2, "Device", "Version", "Size"); for (cur = waresl.wares;cur;cur = cur->next) { if ((argc == 3) || (!strcasecmp(argv[3], cur->fwh->devname))) ast_cli(fd, FORMAT, cur->fwh->devname, ntohs(cur->fwh->version), ntohl(cur->fwh->datalen)); } ast_mutex_unlock(&waresl.lock); return RESULT_SUCCESS; #undef FORMAT #undef FORMAT2 } /* JDG: callback to display iax peers in manager */ static int manager_iax2_show_peers( struct mansession *s, struct message *m ) { char *a[] = { "iax2", "show", "users" }; int ret; ret = iax2_show_peers( s->fd, 3, a ); ast_cli( s->fd, "\r\n" ); return ret; } /* /JDG */ static char *regstate2str(int regstate) { switch(regstate) { case REG_STATE_UNREGISTERED: return "Unregistered"; case REG_STATE_REGSENT: return "Request Sent"; case REG_STATE_AUTHSENT: return "Auth. Sent"; case REG_STATE_REGISTERED: return "Registered"; case REG_STATE_REJECTED: return "Rejected"; case REG_STATE_TIMEOUT: return "Timeout"; case REG_STATE_NOAUTH: return "No Authentication"; default: return "Unknown"; } } static int iax2_show_registry(int fd, int argc, char *argv[]) { #define FORMAT2 "%-20.20s %-10.10s %-20.20s %8.8s %s\n" #define FORMAT "%-20.20s %-10.10s %-20.20s %8d %s\n" struct iax2_registry *reg; char host[80]; char perceived[80] = ""; char iabuf[INET_ADDRSTRLEN]; if (argc != 3) return RESULT_SHOWUSAGE; ast_mutex_lock(&peerl.lock); ast_cli(fd, FORMAT2, "Host", "Username", "Perceived", "Refresh", "State"); for (reg = registrations;reg;reg = reg->next) { snprintf(host, sizeof(host), "%s:%d", ast_inet_ntoa(iabuf, sizeof(iabuf), reg->addr.sin_addr), ntohs(reg->addr.sin_port)); if (reg->us.sin_addr.s_addr) snprintf(perceived, sizeof(perceived), "%s:%d", ast_inet_ntoa(iabuf, sizeof(iabuf), reg->us.sin_addr), ntohs(reg->us.sin_port)); else strncpy(perceived, "", sizeof(perceived) - 1); ast_cli(fd, FORMAT, host, reg->username, perceived, reg->refresh, regstate2str(reg->regstate)); } ast_mutex_unlock(&peerl.lock); return RESULT_SUCCESS; #undef FORMAT #undef FORMAT2 } static int jitterbufsize(struct chan_iax2_pvt *pvt) { int min, i; min = 99999999; for (i=0; ihistory[i] < min) min = pvt->history[i]; } return pvt->jitterbuffer - min; } static int iax2_show_channels(int fd, int argc, char *argv[]) { #define FORMAT2 "%-15.15s %-10.10s %-11.11s %-11.11s %-7.7s %-6.6s %-6.6s %s\n" #define FORMAT "%-15.15s %-10.10s %5.5d/%5.5d %5.5d/%5.5d %-5.5dms %-4.4dms %-4.4dms %-6.6s\n" int x; int numchans = 0; char iabuf[INET_ADDRSTRLEN]; if (argc != 3) return RESULT_SHOWUSAGE; ast_cli(fd, FORMAT2, "Peer", "Username", "ID (Lo/Rem)", "Seq (Tx/Rx)", "Lag", "Jitter", "JitBuf", "Format"); for (x=0;xaddr.sin_addr), !ast_strlen_zero(iaxs[x]->username) ? iaxs[x]->username : "(None)", iaxs[x]->callno, iaxs[x]->peercallno, iaxs[x]->oseqno, iaxs[x]->iseqno, iaxs[x]->lag, iaxs[x]->jitter, use_jitterbuffer ? jitterbufsize(iaxs[x]) : 0, ast_getformatname(iaxs[x]->voiceformat) ); numchans++; } ast_mutex_unlock(&iaxsl[x]); } ast_cli(fd, "%d active IAX channel(s)\n", numchans); return RESULT_SUCCESS; #undef FORMAT #undef FORMAT2 } static int iax2_do_trunk_debug(int fd, int argc, char *argv[]) { if (argc != 3) return RESULT_SHOWUSAGE; iaxtrunkdebug = 1; ast_cli(fd, "IAX2 Trunk Debug Requested\n"); return RESULT_SUCCESS; } static int iax2_do_debug(int fd, int argc, char *argv[]) { if (argc != 2) return RESULT_SHOWUSAGE; iaxdebug = 1; ast_cli(fd, "IAX2 Debugging Enabled\n"); return RESULT_SUCCESS; } static int iax2_no_debug(int fd, int argc, char *argv[]) { if (argc != 3) return RESULT_SHOWUSAGE; iaxdebug = 0; ast_cli(fd, "IAX2 Debugging Disabled\n"); return RESULT_SUCCESS; } static char show_users_usage[] = "Usage: iax2 show users\n" " Lists all users known to the IAX (Inter-Asterisk eXchange rev 2) subsystem.\n"; static char show_channels_usage[] = "Usage: iax2 show channels\n" " Lists all currently active IAX channels.\n"; static char show_peers_usage[] = "Usage: iax2 show peers\n" " Lists all known IAX peers.\n"; static char show_firmware_usage[] = "Usage: iax2 show firmware\n" " Lists all known IAX firmware images.\n"; static char show_reg_usage[] = "Usage: iax2 show registry\n" " Lists all registration requests and status.\n"; static char debug_usage[] = "Usage: iax2 debug\n" " Enables dumping of IAX packets for debugging purposes\n"; static char no_debug_usage[] = "Usage: iax2 no debug\n" " Disables dumping of IAX packets for debugging purposes\n"; static char debug_trunk_usage[] = "Usage: iax2 trunk debug\n" " Requests current status of IAX trunking\n"; static struct ast_cli_entry cli_show_users = { { "iax2", "show", "users", NULL }, iax2_show_users, "Show defined IAX users", show_users_usage }; static struct ast_cli_entry cli_show_firmware = { { "iax2", "show", "firmware", NULL }, iax2_show_firmware, "Show available IAX firmwares", show_firmware_usage }; static struct ast_cli_entry cli_show_channels = { { "iax2", "show", "channels", NULL }, iax2_show_channels, "Show active IAX channels", show_channels_usage }; static struct ast_cli_entry cli_show_peers = { { "iax2", "show", "peers", NULL }, iax2_show_peers, "Show defined IAX peers", show_peers_usage }; static struct ast_cli_entry cli_show_peers_include = { { "iax2", "show", "peers", "include", NULL }, iax2_show_peers, "Show defined IAX peers", show_peers_usage }; static struct ast_cli_entry cli_show_peers_exclude = { { "iax2", "show", "peers", "exclude", NULL }, iax2_show_peers, "Show defined IAX peers", show_peers_usage }; static struct ast_cli_entry cli_show_peers_begin = { { "iax2", "show", "peers", "begin", NULL }, iax2_show_peers, "Show defined IAX peers", show_peers_usage }; static struct ast_cli_entry cli_show_registry = { { "iax2", "show", "registry", NULL }, iax2_show_registry, "Show IAX registration status", show_reg_usage }; static struct ast_cli_entry cli_debug = { { "iax2", "debug", NULL }, iax2_do_debug, "Enable IAX debugging", debug_usage }; static struct ast_cli_entry cli_trunk_debug = { { "iax2", "trunk", "debug", NULL }, iax2_do_trunk_debug, "Request IAX trunk debug", debug_trunk_usage }; static struct ast_cli_entry cli_no_debug = { { "iax2", "no", "debug", NULL }, iax2_no_debug, "Disable IAX debugging", no_debug_usage }; static int iax2_write(struct ast_channel *c, struct ast_frame *f) { unsigned short callno = PTR_TO_CALLNO(c->pvt->pvt); int res = -1; ast_mutex_lock(&iaxsl[callno]); if (iaxs[callno]) { /* If there's an outstanding error, return failure now */ if (!iaxs[callno]->error) { if (iaxs[callno]->alreadygone) res = 0; /* Don't waste bandwidth sending null frames */ else if (f->frametype == AST_FRAME_NULL) res = 0; else if ((f->frametype == AST_FRAME_VOICE) && iaxs[callno]->quelch) res = 0; else if (!(iaxs[callno]->state & IAX_STATE_STARTED)) res = 0; else /* Simple, just queue for transmission */ res = iax2_send(iaxs[callno], f, 0, -1, 0, 0, 0); } else { ast_log(LOG_DEBUG, "Write error: %s\n", strerror(errno)); } } /* If it's already gone, just return */ ast_mutex_unlock(&iaxsl[callno]); return res; } static int __send_command(struct chan_iax2_pvt *i, char type, int command, unsigned int ts, char *data, int datalen, int seqno, int now, int transfer, int final) { struct ast_frame f; f.frametype = type; f.subclass = command; f.datalen = datalen; f.samples = 0; f.mallocd = 0; f.offset = 0; f.src = __FUNCTION__; f.data = data; return iax2_send(i, &f, ts, seqno, now, transfer, final); } static int send_command(struct chan_iax2_pvt *i, char type, int command, unsigned int ts, char *data, int datalen, int seqno) { return __send_command(i, type, command, ts, data, datalen, seqno, 0, 0, 0); } static int send_command_locked(unsigned short callno, char type, int command, unsigned int ts, char *data, int datalen, int seqno) { int res; ast_mutex_lock(&iaxsl[callno]); res = send_command(iaxs[callno], type, command, ts, data, datalen, seqno); ast_mutex_unlock(&iaxsl[callno]); return res; } #ifdef BRIDGE_OPTIMIZATION static int forward_command(struct chan_iax2_pvt *i, char type, int command, unsigned int ts, char *data, int datalen, int seqno) { return __send_command(iaxs[i->bridgecallno], type, command, ts, data, datalen, seqno, 0, 0, 0); } #endif static int send_command_final(struct chan_iax2_pvt *i, char type, int command, unsigned int ts, char *data, int datalen, int seqno) { /* It is assumed that the callno has already been locked */ iax2_predestroy_nolock(i->callno); return __send_command(i, type, command, ts, data, datalen, seqno, 0, 0, 1); } static int send_command_immediate(struct chan_iax2_pvt *i, char type, int command, unsigned int ts, char *data, int datalen, int seqno) { return __send_command(i, type, command, ts, data, datalen, seqno, 1, 0, 0); } static int send_command_transfer(struct chan_iax2_pvt *i, char type, int command, unsigned int ts, char *data, int datalen) { return __send_command(i, type, command, ts, data, datalen, 0, 0, 1, 0); } static int apply_context(struct iax2_context *con, char *context) { while(con) { if (!strcmp(con->context, context) || !strcmp(con->context, "*")) return -1; con = con->next; } return 0; } static int check_access(int callno, struct sockaddr_in *sin, struct iax_ies *ies) { /* Start pessimistic */ int res = -1; int version = 2; struct iax2_user *user, *best = NULL; int bestscore = 0; int gotcapability=0; char iabuf[INET_ADDRSTRLEN]; if (!iaxs[callno]) return res; if (ies->called_number) strncpy(iaxs[callno]->exten, ies->called_number, sizeof(iaxs[callno]->exten) - 1); if (ies->calling_number) { if (ies->calling_name) snprintf(iaxs[callno]->callerid, sizeof(iaxs[callno]->callerid), "\"%s\" <%s>", ies->calling_name, ies->calling_number); else strncpy(iaxs[callno]->callerid, ies->calling_number, sizeof(iaxs[callno]->callerid) - 1); } else if (ies->calling_name) strncpy(iaxs[callno]->callerid, ies->calling_name, sizeof(iaxs[callno]->callerid) - 1); if (ies->calling_ani) strncpy(iaxs[callno]->ani, ies->calling_ani, sizeof(iaxs[callno]->ani) - 1); if (ies->dnid) strncpy(iaxs[callno]->dnid, ies->dnid, sizeof(iaxs[callno]->dnid)-1); if (ies->called_context) strncpy(iaxs[callno]->context, ies->called_context, sizeof(iaxs[callno]->context)-1); if (ies->language) strncpy(iaxs[callno]->language, ies->language, sizeof(iaxs[callno]->language)-1); if (ies->username) strncpy(iaxs[callno]->username, ies->username, sizeof(iaxs[callno]->username)-1); if (ies->format) iaxs[callno]->peerformat = ies->format; if (ies->adsicpe) iaxs[callno]->peeradsicpe = ies->adsicpe; if (ies->capability) { gotcapability = 1; iaxs[callno]->peercapability = ies->capability; } if (ies->version) version = ies->version; if (!gotcapability) iaxs[callno]->peercapability = iaxs[callno]->peerformat; if (version > IAX_PROTO_VERSION) { ast_log(LOG_WARNING, "Peer '%s' has too new a protocol version (%d) for me\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), version); return res; } ast_mutex_lock(&userl.lock); /* Search the userlist for a compatible entry, and fill in the rest */ user = userl.users; while(user) { if ((ast_strlen_zero(iaxs[callno]->username) || /* No username specified */ !strcmp(iaxs[callno]->username, user->name)) /* Or this username specified */ && ast_apply_ha(user->ha, sin) /* Access is permitted from this IP */ && (ast_strlen_zero(iaxs[callno]->context) || /* No context specified */ apply_context(user->contexts, iaxs[callno]->context))) { /* Context is permitted */ if (!ast_strlen_zero(iaxs[callno]->username)) { /* Exact match, stop right now. */ best = user; break; } else if (ast_strlen_zero(user->secret) && ast_strlen_zero(user->inkeys)) { /* No required authentication */ if (user->ha) { /* There was host authentication and we passed, bonus! */ if (bestscore < 4) { bestscore = 4; best = user; } } else { /* No host access, but no secret, either, not bad */ if (bestscore < 3) { bestscore = 3; best = user; } } } else { if (user->ha) { /* Authentication, but host access too, eh, it's something.. */ if (bestscore < 2) { bestscore = 2; best = user; } } else { /* Authentication and no host access... This is our baseline */ if (bestscore < 1) { bestscore = 1; best = user; } } } } user = user->next; } ast_mutex_unlock(&userl.lock); user = best; #ifdef MYSQL_FRIENDS if (!user && mysql && !ast_strlen_zero(iaxs[callno]->username) && (strlen(iaxs[callno]->username) < 128)) { user = mysql_user(iaxs[callno]->username); if (user && !ast_strlen_zero(iaxs[callno]->context) && /* No context specified */ !apply_context(user->contexts, iaxs[callno]->context)) { /* Context is permitted */ if (user->contexts) free(user->contexts); free(user); user = NULL; } } #endif if (user) { /* We found our match (use the first) */ /* Store the requested username if not specified */ if (ast_strlen_zero(iaxs[callno]->username)) strncpy(iaxs[callno]->username, user->name, sizeof(iaxs[callno]->username)-1); /* Store whether this is a trunked call, too, of course, and move if appropriate */ iaxs[callno]->trunk = user->trunk; iaxs[callno]->capability = user->capability; /* And use the default context */ if (ast_strlen_zero(iaxs[callno]->context)) { if (user->contexts) strncpy(iaxs[callno]->context, user->contexts->context, sizeof(iaxs[callno]->context)-1); else strncpy(iaxs[callno]->context, context, sizeof(iaxs[callno]->context)-1); } /* Copy the secret */ strncpy(iaxs[callno]->secret, user->secret, sizeof(iaxs[callno]->secret)-1); /* And any input keys */ strncpy(iaxs[callno]->inkeys, user->inkeys, sizeof(iaxs[callno]->inkeys) - 1); /* And the permitted authentication methods */ iaxs[callno]->authmethods = user->authmethods; /* If they have callerid, override the given caller id. Always store the ANI */ if (!ast_strlen_zero(iaxs[callno]->callerid)) { if (user->hascallerid) strncpy(iaxs[callno]->callerid, user->callerid, sizeof(iaxs[callno]->callerid)-1); strncpy(iaxs[callno]->ani, user->callerid, sizeof(iaxs[callno]->ani)-1); } if (!ast_strlen_zero(user->accountcode)) strncpy(iaxs[callno]->accountcode, user->accountcode, sizeof(iaxs[callno]->accountcode)-1); if (user->amaflags) iaxs[callno]->amaflags = user->amaflags; if (!ast_strlen_zero(user->language)) strncpy(iaxs[callno]->language, user->language, sizeof(iaxs[callno]->language)-1); iaxs[callno]->notransfer = user->notransfer; res = 0; } iaxs[callno]->trunk = iax2_getpeertrunk(*sin); return res; } static int raw_hangup(struct sockaddr_in *sin, unsigned short src, unsigned short dst) { struct ast_iax2_full_hdr fh; char iabuf[INET_ADDRSTRLEN]; fh.scallno = htons(src | IAX_FLAG_FULL); fh.dcallno = htons(dst); fh.ts = 0; fh.oseqno = 0; fh.iseqno = 0; fh.type = AST_FRAME_IAX; fh.csub = compress_subclass(IAX_COMMAND_INVAL); #if 0 if (option_debug) #endif ast_log(LOG_DEBUG, "Raw Hangup %s:%d, src=%d, dst=%d\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), ntohs(sin->sin_port), src, dst); return sendto(netsocket, &fh, sizeof(fh), 0, (struct sockaddr *)sin, sizeof(*sin)); } static int authenticate_request(struct chan_iax2_pvt *p) { struct iax_ie_data ied; memset(&ied, 0, sizeof(ied)); iax_ie_append_short(&ied, IAX_IE_AUTHMETHODS, p->authmethods); if (p->authmethods & (IAX_AUTH_MD5 | IAX_AUTH_RSA)) { snprintf(p->challenge, sizeof(p->challenge), "%d", rand()); iax_ie_append_str(&ied, IAX_IE_CHALLENGE, p->challenge); } iax_ie_append_str(&ied,IAX_IE_USERNAME, p->username); return send_command(p, AST_FRAME_IAX, IAX_COMMAND_AUTHREQ, 0, ied.buf, ied.pos, -1); } static int authenticate_verify(struct chan_iax2_pvt *p, struct iax_ies *ies) { char requeststr[256] = ""; char md5secret[256] = ""; char secret[256] = ""; char rsasecret[256] = ""; int res = -1; int x; if (!(p->state & IAX_STATE_AUTHENTICATED)) return res; if (ies->password) strncpy(secret, ies->password, sizeof(secret) - 1); if (ies->md5_result) strncpy(md5secret, ies->md5_result, sizeof(md5secret)-1); if (ies->rsa_result) strncpy(rsasecret, ies->rsa_result, sizeof(rsasecret)-1); if ((p->authmethods & IAX_AUTH_RSA) && !ast_strlen_zero(rsasecret) && !ast_strlen_zero(p->inkeys)) { struct ast_key *key; char *keyn; char tmpkey[256] = ""; char *stringp=NULL; strncpy(tmpkey, p->inkeys, sizeof(tmpkey) - 1); stringp=tmpkey; keyn = strsep(&stringp, ":"); while(keyn) { key = ast_key_get(keyn, AST_KEY_PUBLIC); if (key && !ast_check_signature(key, p->challenge, rsasecret)) { res = 0; break; } else if (!key) ast_log(LOG_WARNING, "requested inkey '%s' for RSA authentication does not exist\n", keyn); keyn = strsep(&stringp, ":"); } } else if (p->authmethods & IAX_AUTH_MD5) { struct MD5Context md5; unsigned char digest[16]; MD5Init(&md5); MD5Update(&md5, p->challenge, strlen(p->challenge)); MD5Update(&md5, p->secret, strlen(p->secret)); MD5Final(digest, &md5); /* If they support md5, authenticate with it. */ for (x=0;x<16;x++) sprintf(requeststr + (x << 1), "%2.2x", digest[x]); /* safe */ if (!strcasecmp(requeststr, md5secret)) res = 0; } else if (p->authmethods & IAX_AUTH_PLAINTEXT) { if (!strcmp(secret, p->secret)) res = 0; } return res; } static int register_verify(int callno, struct sockaddr_in *sin, struct iax_ies *ies) { char requeststr[256] = ""; char peer[256] = ""; char md5secret[256] = ""; char rsasecret[256] = ""; char secret[256] = ""; char iabuf[INET_ADDRSTRLEN]; struct iax2_peer *p; struct ast_key *key; char *keyn; int x; int expire = 0; iaxs[callno]->state &= ~IAX_STATE_AUTHENTICATED; iaxs[callno]->peer[0] = '\0'; if (ies->username) strncpy(peer, ies->username, sizeof(peer) - 1); if (ies->password) strncpy(secret, ies->password, sizeof(secret) - 1); if (ies->md5_result) strncpy(md5secret, ies->md5_result, sizeof(md5secret)-1); if (ies->rsa_result) strncpy(rsasecret, ies->rsa_result, sizeof(rsasecret)-1); if (ies->refresh) expire = ies->refresh; if (ast_strlen_zero(peer)) { ast_log(LOG_NOTICE, "Empty registration from %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr)); return -1; } ast_mutex_lock(&peerl.lock); for (p = peerl.peers; p ; p = p->next) if (!strcasecmp(p->name, peer)) break; ast_mutex_unlock(&peerl.lock); #ifdef MYSQL_FRIENDS if (!p) p = mysql_peer(peer); #endif if (!p) { if (authdebug) ast_log(LOG_NOTICE, "No registration for peer '%s' (from %s)\n", peer, ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr)); return -1; } if (!p->dynamic) { if (authdebug) ast_log(LOG_NOTICE, "Peer '%s' is not dynamic (from %s)\n", peer, ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr)); if (p->temponly) free(p); return -1; } if (!ast_apply_ha(p->ha, sin)) { if (authdebug) ast_log(LOG_NOTICE, "Host %s denied access to register peer '%s'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), p->name); if (p->temponly) free(p); return -1; } strncpy(iaxs[callno]->secret, p->secret, sizeof(iaxs[callno]->secret)-1); strncpy(iaxs[callno]->inkeys, p->inkeys, sizeof(iaxs[callno]->inkeys)-1); /* Check secret against what we have on file */ if (!ast_strlen_zero(rsasecret) && (p->authmethods & IAX_AUTH_RSA) && !ast_strlen_zero(iaxs[callno]->challenge)) { if (!ast_strlen_zero(p->inkeys)) { char tmpkeys[256] = ""; char *stringp=NULL; strncpy(tmpkeys, p->inkeys, sizeof(tmpkeys) - 1); stringp=tmpkeys; keyn = strsep(&stringp, ":"); while(keyn) { key = ast_key_get(keyn, AST_KEY_PUBLIC); if (key && !ast_check_signature(key, iaxs[callno]->challenge, rsasecret)) { iaxs[callno]->state |= IAX_STATE_AUTHENTICATED; break; } else if (!key) ast_log(LOG_WARNING, "requested inkey '%s' does not exist\n", keyn); keyn = strsep(&stringp, ":"); } if (!keyn) { if (authdebug) ast_log(LOG_NOTICE, "Host %s failed RSA authentication with inkeys '%s'\n", peer, p->inkeys); if (p->temponly) free(p); return -1; } } else { if (authdebug) ast_log(LOG_NOTICE, "Host '%s' trying to do RSA authentication, but we have no inkeys\n", peer); if (p->temponly) free(p); return -1; } } else if (!ast_strlen_zero(secret) && (p->authmethods & IAX_AUTH_PLAINTEXT)) { /* They've provided a plain text password and we support that */ if (strcmp(secret, p->secret)) { if (authdebug) ast_log(LOG_NOTICE, "Host %s did not provide proper plaintext password for '%s'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), p->name); if (p->temponly) free(p); return -1; } else iaxs[callno]->state |= IAX_STATE_AUTHENTICATED; } else if (!ast_strlen_zero(md5secret) && (p->authmethods & IAX_AUTH_MD5) && !ast_strlen_zero(iaxs[callno]->challenge)) { struct MD5Context md5; unsigned char digest[16]; MD5Init(&md5); MD5Update(&md5, iaxs[callno]->challenge, strlen(iaxs[callno]->challenge)); MD5Update(&md5, p->secret, strlen(p->secret)); MD5Final(digest, &md5); for (x=0;x<16;x++) sprintf(requeststr + (x << 1), "%2.2x", digest[x]); /* safe */ if (strcasecmp(requeststr, md5secret)) { if (authdebug) ast_log(LOG_NOTICE, "Host %s failed MD5 authentication for '%s' (%s != %s)\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), p->name, requeststr, md5secret); if (p->temponly) free(p); return -1; } else iaxs[callno]->state |= IAX_STATE_AUTHENTICATED; } else if (!ast_strlen_zero(md5secret) || !ast_strlen_zero(secret)) { if (authdebug) ast_log(LOG_NOTICE, "Inappropriate authentication received\n"); if (p->temponly) free(p); return -1; } strncpy(iaxs[callno]->peer, peer, sizeof(iaxs[callno]->peer)-1); /* Choose lowest expirey number */ if (expire && (expire < iaxs[callno]->expirey)) iaxs[callno]->expirey = expire; if (p->temponly) free(p); return 0; } static int authenticate(char *challenge, char *secret, char *keyn, int authmethods, struct iax_ie_data *ied, struct sockaddr_in *sin) { int res = -1; int x; char iabuf[INET_ADDRSTRLEN]; if (keyn && !ast_strlen_zero(keyn)) { if (!(authmethods & IAX_AUTH_RSA)) { if (!secret || ast_strlen_zero(secret)) ast_log(LOG_NOTICE, "Asked to authenticate to %s with an RSA key, but they don't allow RSA authentication\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr)); } else if (ast_strlen_zero(challenge)) { ast_log(LOG_NOTICE, "No challenge provided for RSA authentication to %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr)); } else { char sig[256]; struct ast_key *key; key = ast_key_get(keyn, AST_KEY_PRIVATE); if (!key) { ast_log(LOG_NOTICE, "Unable to find private key '%s'\n", keyn); } else { if (ast_sign(key, challenge, sig)) { ast_log(LOG_NOTICE, "Unable to sign challenge withy key\n"); res = -1; } else { iax_ie_append_str(ied, IAX_IE_RSA_RESULT, sig); res = 0; } } } } /* Fall back */ if (res && secret && !ast_strlen_zero(secret)) { if ((authmethods & IAX_AUTH_MD5) && !ast_strlen_zero(challenge)) { struct MD5Context md5; unsigned char digest[16]; char digres[128] = ""; MD5Init(&md5); MD5Update(&md5, challenge, strlen(challenge)); MD5Update(&md5, secret, strlen(secret)); MD5Final(digest, &md5); /* If they support md5, authenticate with it. */ for (x=0;x<16;x++) sprintf(digres + (x << 1), "%2.2x", digest[x]); /* safe */ iax_ie_append_str(ied, IAX_IE_MD5_RESULT, digres); res = 0; } else if (authmethods & IAX_AUTH_PLAINTEXT) { iax_ie_append_str(ied, IAX_IE_PASSWORD, secret); res = 0; } else ast_log(LOG_NOTICE, "No way to send secret to peer '%s' (their methods: %d)\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), authmethods); } return res; } static int authenticate_reply(struct chan_iax2_pvt *p, struct sockaddr_in *sin, struct iax_ies *ies, char *override, char *okey) { struct iax2_peer *peer; /* Start pessimistic */ int res = -1; int authmethods = 0; struct iax_ie_data ied; memset(&ied, 0, sizeof(ied)); if (ies->username) strncpy(p->username, ies->username, sizeof(p->username) - 1); if (ies->challenge) strncpy(p->challenge, ies->challenge, sizeof(p->challenge)-1); if (ies->authmethods) authmethods = ies->authmethods; /* Check for override RSA authentication first */ if ((override && !ast_strlen_zero(override)) || (okey && !ast_strlen_zero(okey))) { /* Normal password authentication */ res = authenticate(p->challenge, override, okey, authmethods, &ied, sin); } else { ast_mutex_lock(&peerl.lock); peer = peerl.peers; while(peer) { if ((ast_strlen_zero(p->peer) || !strcmp(p->peer, peer->name)) /* No peer specified at our end, or this is the peer */ && (ast_strlen_zero(peer->username) || (!strcmp(peer->username, p->username))) /* No username specified in peer rule, or this is the right username */ && (!peer->addr.sin_addr.s_addr || ((sin->sin_addr.s_addr & peer->mask.s_addr) == (peer->addr.sin_addr.s_addr & peer->mask.s_addr))) /* No specified host, or this is our host */ ) { res = authenticate(p->challenge, peer->secret, peer->outkey, authmethods, &ied, sin); if (!res) break; } peer = peer->next; } ast_mutex_unlock(&peerl.lock); } if (!res) res = send_command(p, AST_FRAME_IAX, IAX_COMMAND_AUTHREP, 0, ied.buf, ied.pos, -1); return res; } static int iax2_do_register(struct iax2_registry *reg); static int iax2_do_register_s(void *data) { struct iax2_registry *reg = data; reg->expire = -1; iax2_do_register(reg); return 0; } static int try_transfer(struct chan_iax2_pvt *pvt, struct iax_ies *ies) { int newcall = 0; char newip[256] = ""; struct iax_ie_data ied; struct sockaddr_in new; memset(&ied, 0, sizeof(ied)); if (ies->apparent_addr) memcpy(&new, ies->apparent_addr, sizeof(new)); if (ies->callno) newcall = ies->callno; if (!newcall || !new.sin_addr.s_addr || !new.sin_port) { ast_log(LOG_WARNING, "Invalid transfer request\n"); return -1; } pvt->transfercallno = newcall; memcpy(&pvt->transfer, &new, sizeof(pvt->transfer)); inet_aton(newip, &pvt->transfer.sin_addr); pvt->transfer.sin_family = AF_INET; pvt->transferring = TRANSFER_BEGIN; pvt->transferid = ies->transferid; if (ies->transferid) iax_ie_append_int(&ied, IAX_IE_TRANSFERID, ies->transferid); send_command_transfer(pvt, AST_FRAME_IAX, IAX_COMMAND_TXCNT, 0, ied.buf, ied.pos); return 0; } static int complete_dpreply(struct chan_iax2_pvt *pvt, struct iax_ies *ies) { char exten[256] = ""; int status = CACHE_FLAG_UNKNOWN; int expirey = iaxdefaultdpcache; int x; int matchmore = 0; struct iax2_dpcache *dp, *prev; if (ies->called_number) strncpy(exten, ies->called_number, sizeof(exten)-1); if (ies->dpstatus & IAX_DPSTATUS_EXISTS) status = CACHE_FLAG_EXISTS; else if (ies->dpstatus & IAX_DPSTATUS_CANEXIST) status = CACHE_FLAG_CANEXIST; else if (ies->dpstatus & IAX_DPSTATUS_NONEXISTANT) status = CACHE_FLAG_NONEXISTANT; if (ies->dpstatus & IAX_DPSTATUS_IGNOREPAT) { /* Don't really do anything with this */ } if (ies->refresh) expirey = ies->refresh; if (ies->dpstatus & IAX_DPSTATUS_MATCHMORE) matchmore = CACHE_FLAG_MATCHMORE; ast_mutex_lock(&dpcache_lock); prev = NULL; dp = pvt->dpentries; while(dp) { if (!strcmp(dp->exten, exten)) { /* Let them go */ if (prev) prev->peer = dp->peer; else pvt->dpentries = dp->peer; dp->peer = NULL; dp->callno = 0; dp->expirey.tv_sec = dp->orig.tv_sec + expirey; if (dp->flags & CACHE_FLAG_PENDING) { dp->flags &= ~CACHE_FLAG_PENDING; dp->flags |= status; dp->flags |= matchmore; } /* Wake up waiters */ for (x=0;xwaiters) / sizeof(dp->waiters[0]); x++) if (dp->waiters[x] > -1) write(dp->waiters[x], "asdf", 4); } prev = dp; dp = dp->peer; } ast_mutex_unlock(&dpcache_lock); return 0; } static int complete_transfer(int callno, struct iax_ies *ies) { int peercallno = 0; struct chan_iax2_pvt *pvt = iaxs[callno]; struct iax_frame *cur; if (ies->callno) peercallno = ies->callno; if (peercallno < 1) { ast_log(LOG_WARNING, "Invalid transfer request\n"); return -1; } memcpy(&pvt->addr, &pvt->transfer, sizeof(pvt->addr)); memset(&pvt->transfer, 0, sizeof(pvt->transfer)); /* Reset sequence numbers */ pvt->oseqno = 0; pvt->iseqno = 0; pvt->aseqno = 0; pvt->peercallno = peercallno; pvt->transferring = TRANSFER_NONE; pvt->svoiceformat = -1; pvt->voiceformat = 0; pvt->svideoformat = -1; pvt->videoformat = 0; pvt->transfercallno = -1; memset(&pvt->rxcore, 0, sizeof(pvt->rxcore)); memset(&pvt->offset, 0, sizeof(pvt->offset)); memset(&pvt->history, 0, sizeof(pvt->history)); pvt->jitterbuffer = 0; pvt->jitter = 0; pvt->historicjitter = 0; pvt->lag = 0; pvt->last = 0; pvt->lastsent = 0; pvt->nextpred = 0; pvt->pingtime = DEFAULT_RETRY_TIME; ast_mutex_lock(&iaxq.lock); for (cur = iaxq.head; cur ; cur = cur->next) { /* We must cancel any packets that would have been transmitted because now we're talking to someone new. It's okay, they were transmitted to someone that didn't care anyway. */ if (callno == cur->callno) cur->retries = -1; } ast_mutex_unlock(&iaxq.lock); return 0; } static int iax2_ack_registry(struct iax_ies *ies, struct sockaddr_in *sin, int callno) { struct iax2_registry *reg; /* Start pessimistic */ char peer[256] = ""; char msgstatus[40] = ""; int refresh = 0; char ourip[256] = ""; struct sockaddr_in oldus; struct sockaddr_in us; char iabuf[INET_ADDRSTRLEN]; int oldmsgs; memset(&us, 0, sizeof(us)); if (ies->apparent_addr) memcpy(&us, ies->apparent_addr, sizeof(us)); if (ies->username) strncpy(peer, ies->username, sizeof(peer) - 1); if (ies->refresh) refresh = ies->refresh; if (ies->calling_number) { /* We don't do anything with it really, but maybe we should */ } reg = iaxs[callno]->reg; if (!reg) { ast_log(LOG_WARNING, "Registry acknowledge on unknown registery '%s'\n", peer); return -1; } memcpy(&oldus, ®->us, sizeof(oldus)); oldmsgs = reg->messages; if (inaddrcmp(®->addr, sin)) { ast_log(LOG_WARNING, "Received unsolicited registry ack from '%s'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr)); return -1; } memcpy(®->us, &us, sizeof(reg->us)); reg->messages = ies->msgcount; if (refresh && (reg->refresh > refresh)) { /* Refresh faster if necessary */ reg->refresh = refresh; if (reg->expire > -1) ast_sched_del(sched, reg->expire); reg->expire = ast_sched_add(sched, (5 * reg->refresh / 6) * 1000, iax2_do_register_s, reg); } if ((inaddrcmp(&oldus, ®->us) || (reg->messages != oldmsgs)) && (option_verbose > 2)) { if (reg->messages > 65534) snprintf(msgstatus, sizeof(msgstatus), " with message(s) waiting\n"); else if (reg->messages > 1) snprintf(msgstatus, sizeof(msgstatus), " with %d messages waiting\n", reg->messages); else if (reg->messages > 0) snprintf(msgstatus, sizeof(msgstatus), " with 1 message waiting\n"); else if (reg->messages > -1) snprintf(msgstatus, sizeof(msgstatus), " with no messages waiting\n"); snprintf(ourip, sizeof(ourip), "%s:%d", ast_inet_ntoa(iabuf, sizeof(iabuf), reg->us.sin_addr), ntohs(reg->us.sin_port)); ast_verbose(VERBOSE_PREFIX_3 "Registered to '%s', who sees us as %s%s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), ourip, msgstatus); } reg->regstate = REG_STATE_REGISTERED; return 0; } static int iax2_register(char *value, int lineno) { struct iax2_registry *reg; char copy[256]; char *username, *hostname, *secret; char *porta; char *stringp=NULL; struct ast_hostent ahp; struct hostent *hp; if (!value) return -1; strncpy(copy, value, sizeof(copy)-1); stringp=copy; username = strsep(&stringp, "@"); hostname = strsep(&stringp, "@"); if (!hostname) { ast_log(LOG_WARNING, "Format for registration is user[:secret]@host[:port] at line %d", lineno); return -1; } stringp=username; username = strsep(&stringp, ":"); secret = strsep(&stringp, ":"); stringp=hostname; hostname = strsep(&stringp, ":"); porta = strsep(&stringp, ":"); if (porta && !atoi(porta)) { ast_log(LOG_WARNING, "%s is not a valid port number at line %d\n", porta, lineno); return -1; } hp = ast_gethostbyname(hostname, &ahp); if (!hp) { ast_log(LOG_WARNING, "Host '%s' not found at line %d\n", hostname, lineno); return -1; } reg = malloc(sizeof(struct iax2_registry)); if (reg) { memset(reg, 0, sizeof(struct iax2_registry)); strncpy(reg->username, username, sizeof(reg->username)-1); if (secret) strncpy(reg->secret, secret, sizeof(reg->secret)-1); reg->expire = -1; reg->refresh = IAX_DEFAULT_REG_EXPIRE; reg->addr.sin_family = AF_INET; memcpy(®->addr.sin_addr, hp->h_addr, sizeof(®->addr.sin_addr)); reg->addr.sin_port = porta ? htons(atoi(porta)) : htons(IAX_DEFAULT_PORTNO); reg->next = registrations; reg->callno = 0; registrations = reg; } else { ast_log(LOG_ERROR, "Out of memory\n"); return -1; } return 0; } static void register_peer_exten(struct iax2_peer *peer, int onoff) { unsigned char multi[256]=""; char *stringp, *ext; if (!ast_strlen_zero(regcontext)) { strncpy(multi, ast_strlen_zero(peer->regexten) ? peer->name : peer->regexten, sizeof(multi) - 1); stringp = multi; while((ext = strsep(&stringp, "&"))) { if (onoff) ast_add_extension(regcontext, 1, ext, 1, NULL, "Noop", strdup(peer->name), free, type); else ast_context_remove_extension(regcontext, ext, 1, NULL); } } } static int expire_registry(void *data) { struct iax2_peer *p = data; /* Reset the address */ memset(&p->addr, 0, sizeof(p->addr)); /* Reset expire notice */ p->expire = -1; /* Reset expirey value */ p->expirey = expirey; ast_db_del("IAX/Registry", p->name); register_peer_exten(p, 0); if (iax2_regfunk) iax2_regfunk(p->name, 0); return 0; } static int iax2_poke_peer(struct iax2_peer *peer, int heldcall); static void reg_source_db(struct iax2_peer *p) { char data[80]; struct in_addr in; char iabuf[INET_ADDRSTRLEN]; char *c, *d; if (!ast_db_get("IAX/Registry", p->name, data, sizeof(data))) { c = strchr(data, ':'); if (c) { *c = '\0'; c++; if (inet_aton(data, &in)) { d = strchr(c, ':'); if (d) { *d = '\0'; d++; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Seeding '%s' at %s:%d for %d\n", p->name, ast_inet_ntoa(iabuf, sizeof(iabuf), in), atoi(c), atoi(d)); iax2_poke_peer(p, 0); p->expirey = atoi(d); memset(&p->addr, 0, sizeof(p->addr)); p->addr.sin_family = AF_INET; p->addr.sin_addr = in; p->addr.sin_port = htons(atoi(c)); if (p->expire > -1) ast_sched_del(sched, p->expire); p->expire = ast_sched_add(sched, p->expirey * 1000, expire_registry, (void *)p); if (iax2_regfunk) iax2_regfunk(p->name, 1); register_peer_exten(p, 1); } } } } } static int update_registry(char *name, struct sockaddr_in *sin, int callno, char *devtype) { /* Called from IAX thread only, with proper iaxsl lock */ struct iax_ie_data ied; struct iax2_peer *p; int msgcount; char data[80]; char iabuf[INET_ADDRSTRLEN]; int version; memset(&ied, 0, sizeof(ied)); for (p = peerl.peers;p;p = p->next) { if (!strcasecmp(name, p->name)) { break; } } #ifdef MYSQL_FRIENDS if (!p) p = mysql_peer(name); #endif if (p) { #ifdef MYSQL_FRIENDS if (p->temponly) mysql_update_peer(name, sin); #endif if (inaddrcmp(&p->addr, sin)) { if (iax2_regfunk) iax2_regfunk(p->name, 1); snprintf(data, sizeof(data), "%s:%d:%d", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), ntohs(sin->sin_port), p->expirey); if (sin->sin_addr.s_addr) { ast_db_put("IAX/Registry", p->name, data); if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Registered '%s' (%s) at %s:%d\n", p->name, iaxs[callno]->state & IAX_STATE_AUTHENTICATED ? "AUTHENTICATED" : "UNAUTHENTICATED", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr), ntohs(sin->sin_port)); register_peer_exten(p, 1); } else { if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Unregistered '%s' (%s)\n", p->name, iaxs[callno]->state & IAX_STATE_AUTHENTICATED ? "AUTHENTICATED" : "UNAUTHENTICATED"); register_peer_exten(p, 0); ast_db_del("IAX/Registry", p->name); } /* Update the host */ memcpy(&p->addr, sin, sizeof(p->addr)); /* Verify that the host is really there */ iax2_poke_peer(p, callno); } /* Setup the expirey */ if (p->expire > -1) ast_sched_del(sched, p->expire); if (p->expirey && sin->sin_addr.s_addr) p->expire = ast_sched_add(sched, p->expirey * 1000, expire_registry, (void *)p); iax_ie_append_str(&ied, IAX_IE_USERNAME, p->name); iax_ie_append_int(&ied, IAX_IE_DATETIME, iax2_datetime()); if (sin->sin_addr.s_addr) { iax_ie_append_short(&ied, IAX_IE_REFRESH, p->expirey); iax_ie_append_addr(&ied, IAX_IE_APPARENT_ADDR, &p->addr); if (!ast_strlen_zero(p->mailbox)) { if (p->messagedetail) { int new, old; ast_app_messagecount(p->mailbox, &new, &old); if (new > 255) new = 255; if (old > 255) old = 255; msgcount = (old << 8) | new; } else { msgcount = ast_app_has_voicemail(p->mailbox); if (msgcount) msgcount = 65535; } iax_ie_append_short(&ied, IAX_IE_MSGCOUNT, msgcount); } if (p->hascallerid) iax_ie_append_str(&ied, IAX_IE_CALLING_NAME, p->callerid); } version = iax_check_version(devtype); if (version) iax_ie_append_short(&ied, IAX_IE_FIRMWAREVER, version); if (p->temponly) free(p); return send_command_final(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_REGACK, 0, ied.buf, ied.pos, -1); } ast_log(LOG_WARNING, "No such peer '%s'\n", name); return -1; } static int registry_authrequest(char *name, int callno) { struct iax_ie_data ied; struct iax2_peer *p; ast_mutex_lock(&peerl.lock); for (p = peerl.peers;p;p = p->next) { if (!strcasecmp(name, p->name)) { break; } } ast_mutex_unlock(&peerl.lock); #ifdef MYSQL_FRIENDS if (!p) p = mysql_peer(name); #endif if (p) { memset(&ied, 0, sizeof(ied)); iax_ie_append_short(&ied, IAX_IE_AUTHMETHODS, p->authmethods); if (p->authmethods & (IAX_AUTH_RSA | IAX_AUTH_MD5)) { /* Build the challenge */ snprintf(iaxs[callno]->challenge, sizeof(iaxs[callno]->challenge), "%d", rand()); iax_ie_append_str(&ied, IAX_IE_CHALLENGE, iaxs[callno]->challenge); } iax_ie_append_str(&ied, IAX_IE_USERNAME, name); if (p->temponly) free(p); return send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_REGAUTH, 0, ied.buf, ied.pos, -1);; } ast_log(LOG_WARNING, "No such peer '%s'\n", name); return 0; } static int registry_rerequest(struct iax_ies *ies, int callno, struct sockaddr_in *sin) { struct iax2_registry *reg; /* Start pessimistic */ struct iax_ie_data ied; char peer[256] = ""; char iabuf[INET_ADDRSTRLEN]; char challenge[256] = ""; int res; int authmethods = 0; if (ies->authmethods) authmethods = ies->authmethods; if (ies->username) strncpy(peer, ies->username, sizeof(peer) - 1); if (ies->challenge) strncpy(challenge, ies->challenge, sizeof(challenge) - 1); memset(&ied, 0, sizeof(ied)); reg = iaxs[callno]->reg; if (inaddrcmp(®->addr, sin)) { ast_log(LOG_WARNING, "Received unsolicited registry authenticate request from '%s'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin->sin_addr)); return -1; } if (ast_strlen_zero(reg->secret)) { ast_log(LOG_NOTICE, "No secret associated with peer '%s'\n", reg->username); reg->regstate = REG_STATE_NOAUTH; return -1; } iax_ie_append_str(&ied, IAX_IE_USERNAME, reg->username); iax_ie_append_short(&ied, IAX_IE_REFRESH, reg->refresh); if (reg->secret[0] == '[') { char tmpkey[256]; strncpy(tmpkey, reg->secret + 1, sizeof(tmpkey) - 1); tmpkey[strlen(tmpkey) - 1] = '\0'; res = authenticate(challenge, NULL, tmpkey, authmethods, &ied, sin); } else res = authenticate(challenge, reg->secret, NULL, authmethods, &ied, sin); if (!res) { reg->regstate = REG_STATE_AUTHSENT; return send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_REGREQ, 0, ied.buf, ied.pos, -1); } else return -1; ast_log(LOG_WARNING, "Registry acknowledge on unknown registery '%s'\n", peer); return -1; } static int stop_stuff(int callno) { if (iaxs[callno]->lagid > -1) ast_sched_del(sched, iaxs[callno]->lagid); iaxs[callno]->lagid = -1; if (iaxs[callno]->pingid > -1) ast_sched_del(sched, iaxs[callno]->pingid); iaxs[callno]->pingid = -1; if (iaxs[callno]->autoid > -1) ast_sched_del(sched, iaxs[callno]->autoid); iaxs[callno]->autoid = -1; if (iaxs[callno]->initid > -1) ast_sched_del(sched, iaxs[callno]->initid); iaxs[callno]->initid = -1; if (iaxs[callno]->authid > -1) ast_sched_del(sched, iaxs[callno]->authid); iaxs[callno]->authid = -1; return 0; } static int auth_reject(void *nothing) { /* Called from IAX thread only, without iaxs lock */ int callno = (int)(long)(nothing); struct iax_ie_data ied; ast_mutex_lock(&iaxsl[callno]); if (iaxs[callno]) { iaxs[callno]->authid = -1; memset(&ied, 0, sizeof(ied)); if (iaxs[callno]->authfail == IAX_COMMAND_REGREJ) { iax_ie_append_str(&ied, IAX_IE_CAUSE, "Registration Refused"); } else if (iaxs[callno]->authfail == IAX_COMMAND_REJECT) { iax_ie_append_str(&ied, IAX_IE_CAUSE, "No authority found"); } send_command_final(iaxs[callno], AST_FRAME_IAX, iaxs[callno]->authfail, 0, ied.buf, ied.pos, -1); } ast_mutex_unlock(&iaxsl[callno]); return 0; } static int auth_fail(int callno, int failcode) { /* Schedule sending the authentication failure in one second, to prevent guessing */ ast_mutex_lock(&iaxsl[callno]); iaxs[callno]->authfail = failcode; if (delayreject) { ast_mutex_lock(&iaxsl[callno]); if (iaxs[callno]->authid > -1) ast_sched_del(sched, iaxs[callno]->authid); iaxs[callno]->authid = ast_sched_add(sched, 1000, auth_reject, (void *)(long)callno); ast_mutex_unlock(&iaxsl[callno]); } else auth_reject((void *)(long)callno); ast_mutex_unlock(&iaxsl[callno]); return 0; } static int auto_hangup(void *nothing) { /* Called from IAX thread only, without iaxs lock */ int callno = (int)(long)(nothing); struct iax_ie_data ied; ast_mutex_lock(&iaxsl[callno]); if (iaxs[callno]) { iaxs[callno]->autoid = -1; memset(&ied, 0, sizeof(ied)); iax_ie_append_str(&ied, IAX_IE_CAUSE, "Timeout"); send_command_final(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_HANGUP, 0, ied.buf, ied.pos, -1); } ast_mutex_unlock(&iaxsl[callno]); return 0; } static void iax2_dprequest(struct iax2_dpcache *dp, int callno) { struct iax_ie_data ied; /* Auto-hangup with 30 seconds of inactivity */ if (iaxs[callno]->autoid > -1) ast_sched_del(sched, iaxs[callno]->autoid); iaxs[callno]->autoid = ast_sched_add(sched, 30000, auto_hangup, (void *)(long)callno); memset(&ied, 0, sizeof(ied)); iax_ie_append_str(&ied, IAX_IE_CALLED_NUMBER, dp->exten); send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_DPREQ, 0, ied.buf, ied.pos, -1); dp->flags |= CACHE_FLAG_TRANSMITTED; } static int iax2_vnak(int callno) { return send_command_immediate(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_VNAK, 0, NULL, 0, iaxs[callno]->iseqno); } static void vnak_retransmit(int callno, int last) { struct iax_frame *f; ast_mutex_lock(&iaxq.lock); f = iaxq.head; while(f) { /* Send a copy immediately */ if ((f->callno == callno) && iaxs[f->callno] && (f->oseqno >= last)) { send_packet(f); } f = f->next; } ast_mutex_unlock(&iaxq.lock); } static int iax2_poke_peer_s(void *data) { struct iax2_peer *peer = data; peer->pokeexpire = -1; iax2_poke_peer(peer, 0); return 0; } static int send_trunk(struct iax2_trunk_peer *tpeer, struct timeval *now) { int res = 0; struct iax_frame *fr; struct ast_iax2_meta_hdr *meta; struct ast_iax2_meta_trunk_hdr *mth; int calls = 0; /* Point to frame */ fr = (struct iax_frame *)tpeer->trunkdata; /* Point to meta data */ meta = (struct ast_iax2_meta_hdr *)fr->afdata; mth = (struct ast_iax2_meta_trunk_hdr *)meta->data; if (tpeer->trunkdatalen) { /* We're actually sending a frame, so fill the meta trunk header and meta header */ meta->zeros = 0; meta->metacmd = IAX_META_TRUNK; meta->cmddata = 0; mth->ts = htonl(calc_txpeerstamp(tpeer, trunkfreq, now)); /* And the rest of the ast_iax2 header */ fr->direction = DIRECTION_OUTGRESS; fr->retrans = -1; fr->transfer = 0; /* Any appropriate call will do */ fr->data = fr->afdata; fr->datalen = tpeer->trunkdatalen + sizeof(struct ast_iax2_meta_hdr) + sizeof(struct ast_iax2_meta_trunk_hdr); #if 0 ast_log(LOG_DEBUG, "Trunking %d calls in %d bytes, ts=%d\n", calls, fr->datalen, ntohl(mth->ts)); #endif res = transmit_trunk(fr, &tpeer->addr); calls = tpeer->calls; /* Reset transmit trunk side data */ tpeer->trunkdatalen = 0; tpeer->calls = 0; } if (res < 0) return res; return calls; } static inline int iax2_trunk_expired(struct iax2_trunk_peer *tpeer, struct timeval *now) { /* Drop when trunk is about 5 seconds idle */ if (now->tv_sec > tpeer->trunkact.tv_sec + 5) return 1; return 0; } static int timing_read(int *id, int fd, short events, void *cbdata) { char buf[1024]; int res; char iabuf[INET_ADDRSTRLEN]; struct iax2_trunk_peer *tpeer, *prev = NULL, *drop=NULL; int processed = 0; int totalcalls = 0; #ifdef ZT_TIMERACK int x = 1; #endif struct timeval now; if (iaxtrunkdebug) ast_verbose("Beginning trunk processing\n"); gettimeofday(&now, NULL); if (events & AST_IO_PRI) { #ifdef ZT_TIMERACK /* Great, this is a timing interface, just call the ioctl */ if (ioctl(fd, ZT_TIMERACK, &x)) ast_log(LOG_WARNING, "Unable to acknowledge zap timer\n"); res = 0; #endif } else { /* Read and ignore from the pseudo channel for timing */ res = read(fd, buf, sizeof(buf)); if (res < 1) { ast_log(LOG_WARNING, "Unable to read from timing fd\n"); ast_mutex_unlock(&peerl.lock); return 1; } } /* For each peer that supports trunking... */ ast_mutex_lock(&tpeerlock); tpeer = tpeers; while(tpeer) { processed++; res = 0; ast_mutex_lock(&tpeer->lock); /* We can drop a single tpeer per pass. That makes all this logic substantially easier */ if (!drop && iax2_trunk_expired(tpeer, &now)) { /* Take it out of the list, but don't free it yet, because it could be in use */ if (prev) prev->next = tpeer->next; else tpeers = tpeer->next; drop = tpeer; } else { res = send_trunk(tpeer, &now); if (iaxtrunkdebug) ast_verbose("Processed trunk peer (%s:%d) with %d call(s)\n", ast_inet_ntoa(iabuf, sizeof(iabuf), tpeer->addr.sin_addr), ntohs(tpeer->addr.sin_port), res); } totalcalls += res; res = 0; ast_mutex_unlock(&tpeer->lock); prev = tpeer; tpeer = tpeer->next; } ast_mutex_unlock(&tpeerlock); if (drop) { ast_mutex_lock(&drop->lock); /* Once we have this lock, we're sure nobody else is using it or could use it once we release it, because by the time they could get tpeerlock, we've already grabbed it */ ast_log(LOG_DEBUG, "Dropping unused iax2 trunk peer '%s:%d'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), drop->addr.sin_addr), ntohs(drop->addr.sin_port)); free(drop->trunkdata); ast_mutex_unlock(&drop->lock); ast_mutex_destroy(&drop->lock); free(drop); } if (iaxtrunkdebug) ast_verbose("Ending trunk processing with %d peers and %d calls processed\n", processed, totalcalls); iaxtrunkdebug =0; return 1; } struct dpreq_data { int callno; char context[AST_MAX_EXTENSION]; char callednum[AST_MAX_EXTENSION]; char *callerid; }; static void dp_lookup(int callno, char *context, char *callednum, char *callerid, int skiplock) { unsigned short dpstatus = 0; struct iax_ie_data ied1; int mm; memset(&ied1, 0, sizeof(ied1)); mm = ast_matchmore_extension(NULL, context, callednum, 1, callerid); /* Must be started */ if (!strcmp(callednum, ast_parking_ext()) || ast_exists_extension(NULL, context, callednum, 1, callerid)) { dpstatus = IAX_DPSTATUS_EXISTS; } else if (ast_canmatch_extension(NULL, context, callednum, 1, callerid)) { dpstatus = IAX_DPSTATUS_CANEXIST; } else { dpstatus = IAX_DPSTATUS_NONEXISTANT; } if (ast_ignore_pattern(context, callednum)) dpstatus |= IAX_DPSTATUS_IGNOREPAT; if (mm) dpstatus |= IAX_DPSTATUS_MATCHMORE; if (!skiplock) ast_mutex_lock(&iaxsl[callno]); if (iaxs[callno]) { iax_ie_append_str(&ied1, IAX_IE_CALLED_NUMBER, callednum); iax_ie_append_short(&ied1, IAX_IE_DPSTATUS, dpstatus); iax_ie_append_short(&ied1, IAX_IE_REFRESH, iaxdefaultdpcache); send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_DPREP, 0, ied1.buf, ied1.pos, -1); } if (!skiplock) ast_mutex_unlock(&iaxsl[callno]); } static void *dp_lookup_thread(void *data) { /* Look up for dpreq */ struct dpreq_data *dpr = data; dp_lookup(dpr->callno, dpr->context, dpr->callednum, dpr->callerid, 0); if (dpr->callerid) free(dpr->callerid); free(dpr); return NULL; } static void spawn_dp_lookup(int callno, char *context, char *callednum, char *callerid) { pthread_t newthread; struct dpreq_data *dpr; dpr = malloc(sizeof(struct dpreq_data)); if (dpr) { memset(dpr, 0, sizeof(struct dpreq_data)); dpr->callno = callno; strncpy(dpr->context, context, sizeof(dpr->context) - 1); strncpy(dpr->callednum, callednum, sizeof(dpr->callednum) - 1); if (callerid) dpr->callerid = strdup(callerid); if (ast_pthread_create(&newthread, NULL, dp_lookup_thread, dpr)) { ast_log(LOG_WARNING, "Unable to start lookup thread!\n"); } } else ast_log(LOG_WARNING, "Out of memory!\n"); } struct iax_dual { struct ast_channel *chan1; struct ast_channel *chan2; }; static void *iax_park_thread(void *stuff) { struct ast_channel *chan1, *chan2; struct iax_dual *d; struct ast_frame *f; int ext; int res; d = stuff; chan1 = d->chan1; chan2 = d->chan2; free(d); f = ast_read(chan1); if (f) ast_frfree(f); res = ast_park_call(chan1, chan2, 0, &ext); ast_hangup(chan2); ast_log(LOG_DEBUG, "Parked on extension '%d'\n", ext); return NULL; } static int iax_park(struct ast_channel *chan1, struct ast_channel *chan2) { struct iax_dual *d; struct ast_channel *chan1m, *chan2m; pthread_t th; chan1m = ast_channel_alloc(0); chan2m = ast_channel_alloc(0); if (chan2m && chan1m) { snprintf(chan1m->name, sizeof(chan1m->name), "Parking/%s", chan1->name); /* Make formats okay */ chan1m->readformat = chan1->readformat; chan1m->writeformat = chan1->writeformat; ast_channel_masquerade(chan1m, chan1); /* Setup the extensions and such */ strncpy(chan1m->context, chan1->context, sizeof(chan1m->context) - 1); strncpy(chan1m->exten, chan1->exten, sizeof(chan1m->exten) - 1); chan1m->priority = chan1->priority; /* We make a clone of the peer channel too, so we can play back the announcement */ snprintf(chan2m->name, sizeof (chan2m->name), "IAXPeer/%s",chan2->name); /* Make formats okay */ chan2m->readformat = chan2->readformat; chan2m->writeformat = chan2->writeformat; ast_channel_masquerade(chan2m, chan2); /* Setup the extensions and such */ strncpy(chan2m->context, chan2->context, sizeof(chan2m->context) - 1); strncpy(chan2m->exten, chan2->exten, sizeof(chan2m->exten) - 1); chan2m->priority = chan2->priority; if (ast_do_masquerade(chan2m)) { ast_log(LOG_WARNING, "Masquerade failed :(\n"); ast_hangup(chan2m); return -1; } } else { if (chan1m) ast_hangup(chan1m); if (chan2m) ast_hangup(chan2m); return -1; } d = malloc(sizeof(struct iax_dual)); if (d) { memset(d, 0, sizeof(*d)); d->chan1 = chan1m; d->chan2 = chan2m; if (!ast_pthread_create(&th, NULL, iax_park_thread, d)) return 0; free(d); } return -1; } static int iax2_provision(struct sockaddr_in *end, char *dest, const char *template, int force); static int check_provisioning(struct sockaddr_in *sin, char *si, unsigned int ver) { unsigned int ourver; unsigned char rsi[80]; snprintf(rsi, sizeof(rsi), "si-%s", si); if (iax_provision_version(&ourver, rsi, 1)) return 0; if (option_debug) ast_log(LOG_DEBUG, "Service identifier '%s', we think '%08x', they think '%08x'\n", si, ourver, ver); if (ourver != ver) iax2_provision(sin, NULL, rsi, 1); return 0; } static int socket_read(int *id, int fd, short events, void *cbdata) { struct sockaddr_in sin; int res; int updatehistory=1; int new = NEW_PREVENT; char buf[4096], *ptr; int len = sizeof(sin); int dcallno = 0; struct ast_iax2_full_hdr *fh = (struct ast_iax2_full_hdr *)buf; struct ast_iax2_mini_hdr *mh = (struct ast_iax2_mini_hdr *)buf; struct ast_iax2_meta_hdr *meta = (struct ast_iax2_meta_hdr *)buf; struct ast_iax2_video_hdr *vh = (struct ast_iax2_video_hdr *)buf; struct ast_iax2_meta_trunk_hdr *mth; struct ast_iax2_meta_trunk_entry *mte; char dblbuf[4096]; /* Declaration of dblbuf must immediately *preceed* fr on the stack */ struct iax_frame fr; struct iax_frame *cur; char iabuf[INET_ADDRSTRLEN]; struct ast_frame f; struct ast_channel *c; struct iax2_dpcache *dp; struct iax2_peer *peer; struct iax2_trunk_peer *tpeer; struct timeval rxtrunktime; struct iax_ies ies; struct iax_ie_data ied0, ied1; int format; int exists; int minivid = 0; unsigned int ts; char empty[32]=""; /* Safety measure */ dblbuf[0] = 0; /* Keep GCC from whining */ fr.callno = 0; res = recvfrom(netsocket, buf, sizeof(buf), 0,(struct sockaddr *) &sin, &len); if (res < 0) { if (errno != ECONNREFUSED) ast_log(LOG_WARNING, "Error: %s\n", strerror(errno)); handle_error(); return 1; } if (res < sizeof(struct ast_iax2_mini_hdr)) { ast_log(LOG_WARNING, "midget packet received (%d of %d min)\n", res, (int)sizeof(struct ast_iax2_mini_hdr)); return 1; } if ((vh->zeros == 0) && (ntohs(vh->callno) & 0x8000)) { /* This is a video frame, get call number */ fr.callno = find_callno(ntohs(vh->callno) & ~0x8000, dcallno, &sin, new, 1); minivid = 1; } else if (meta->zeros == 0) { /* This is a meta header */ switch(meta->metacmd) { case IAX_META_TRUNK: if (res < sizeof(struct ast_iax2_meta_hdr) + sizeof(struct ast_iax2_meta_trunk_hdr)) { ast_log(LOG_WARNING, "midget meta trunk packet received (%d of %d min)\n", res, (int)sizeof(struct ast_iax2_mini_hdr)); return 1; } mth = (struct ast_iax2_meta_trunk_hdr *)(meta->data); ts = ntohl(mth->ts); res -= (sizeof(struct ast_iax2_meta_hdr) + sizeof(struct ast_iax2_meta_trunk_hdr)); ptr = mth->data; tpeer = find_tpeer(&sin); if (!tpeer) { ast_log(LOG_WARNING, "Unable to accept trunked packet from '%s:%d': No matching peer\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), ntohs(sin.sin_port)); return 1; } if (!ts || (!tpeer->rxtrunktime.tv_sec && !tpeer->rxtrunktime.tv_usec)) { gettimeofday(&tpeer->rxtrunktime, NULL); tpeer->trunkact = tpeer->rxtrunktime; } else gettimeofday(&tpeer->trunkact, NULL); rxtrunktime = tpeer->rxtrunktime; ast_mutex_unlock(&tpeer->lock); while(res >= sizeof(struct ast_iax2_meta_trunk_entry)) { /* Process channels */ mte = (struct ast_iax2_meta_trunk_entry *)ptr; ptr += sizeof(struct ast_iax2_meta_trunk_entry); res -= sizeof(struct ast_iax2_meta_trunk_entry); len = ntohs(mte->len); /* Stop if we don't have enough data */ if (len > res) break; fr.callno = find_callno(ntohs(mte->callno) & ~IAX_FLAG_FULL, 0, &sin, NEW_PREVENT, 1); if (fr.callno) { ast_mutex_lock(&iaxsl[fr.callno]); /* If it's a valid call, deliver the contents. If not, we drop it, since we don't have a scallno to use for an INVAL */ /* Process as a mini frame */ f.frametype = AST_FRAME_VOICE; if (iaxs[fr.callno]) { if (iaxs[fr.callno]->voiceformat > 0) { f.subclass = iaxs[fr.callno]->voiceformat; f.datalen = len; if (f.datalen >= 0) { if (f.datalen) f.data = ptr; else f.data = NULL; fr.ts = fix_peerts(&rxtrunktime, fr.callno, ts); /* Don't pass any packets until we're started */ if ((iaxs[fr.callno]->state & IAX_STATE_STARTED)) { /* Common things */ f.src = "IAX2"; f.mallocd = 0; f.offset = 0; if (f.datalen && (f.frametype == AST_FRAME_VOICE)) f.samples = get_samples(&f); else f.samples = 0; fr.outoforder = 0; iax_frame_wrap(&fr, &f); #ifdef BRIDGE_OPTIMIZATION if (iaxs[fr.callno]->bridgecallno) { forward_delivery(&fr); } else { schedule_delivery(iaxfrdup2(&fr), 1, updatehistory); } #else schedule_delivery(iaxfrdup2(&fr), 1, updatehistory); #endif } } else { ast_log(LOG_WARNING, "Datalen < 0?\n"); } } else { ast_log(LOG_WARNING, "Received trunked frame before first full voice frame\n "); iax2_vnak(fr.callno); } } ast_mutex_unlock(&iaxsl[fr.callno]); } ptr += len; res -= len; } } return 1; } #ifdef DEBUG_SUPPORT if (iaxdebug) iax_showframe(NULL, fh, 1, &sin, res - sizeof(struct ast_iax2_full_hdr)); #endif if (ntohs(mh->callno) & IAX_FLAG_FULL) { /* Get the destination call number */ dcallno = ntohs(fh->dcallno) & ~IAX_FLAG_RETRANS; /* Retrieve the type and subclass */ f.frametype = fh->type; if (f.frametype == AST_FRAME_VIDEO) { f.subclass = uncompress_subclass(fh->csub & ~0x40) | ((fh->csub >> 6) & 0x1); } else { f.subclass = uncompress_subclass(fh->csub); } if ((f.frametype == AST_FRAME_IAX) && ((f.subclass == IAX_COMMAND_NEW) || (f.subclass == IAX_COMMAND_REGREQ) || (f.subclass == IAX_COMMAND_POKE) || (f.subclass == IAX_COMMAND_FWDOWNL))) new = NEW_ALLOW; } else { /* Don't know anything about it yet */ f.frametype = AST_FRAME_NULL; f.subclass = 0; } if (!fr.callno) fr.callno = find_callno(ntohs(mh->callno) & ~IAX_FLAG_FULL, dcallno, &sin, new, 1); if (fr.callno > 0) ast_mutex_lock(&iaxsl[fr.callno]); if (!fr.callno || !iaxs[fr.callno]) { /* A call arrived for a non-existant destination. Unless it's an "inval" frame, reply with an inval */ if (ntohs(mh->callno) & IAX_FLAG_FULL) { /* We can only raw hangup control frames */ if (((f.subclass != IAX_COMMAND_INVAL) && (f.subclass != IAX_COMMAND_TXCNT) && (f.subclass != IAX_COMMAND_TXACC) && (f.subclass != IAX_COMMAND_FWDOWNL))|| (f.frametype != AST_FRAME_IAX)) raw_hangup(&sin, ntohs(fh->dcallno) & ~IAX_FLAG_RETRANS, ntohs(mh->callno) & ~IAX_FLAG_FULL ); } if (fr.callno > 0) ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } if (!inaddrcmp(&sin, &iaxs[fr.callno]->addr) && !minivid) iaxs[fr.callno]->peercallno = (unsigned short)(ntohs(mh->callno) & ~IAX_FLAG_FULL); if (ntohs(mh->callno) & IAX_FLAG_FULL) { if (option_debug) ast_log(LOG_DEBUG, "Received packet %d, (%d, %d)\n", fh->oseqno, f.frametype, f.subclass); /* Check if it's out of order (and not an ACK or INVAL) */ fr.oseqno = fh->oseqno; fr.iseqno = fh->iseqno; fr.ts = ntohl(fh->ts); if ((ntohs(fh->dcallno) & IAX_FLAG_RETRANS) || (f.frametype != AST_FRAME_VOICE)) updatehistory = 0; if ((iaxs[fr.callno]->iseqno != fr.oseqno) && (iaxs[fr.callno]->iseqno || ((f.subclass != IAX_COMMAND_TXCNT) && (f.subclass != IAX_COMMAND_TXACC)) || (f.subclass != AST_FRAME_IAX))) { if ( ((f.subclass != IAX_COMMAND_ACK) && (f.subclass != IAX_COMMAND_INVAL) && (f.subclass != IAX_COMMAND_TXCNT) && (f.subclass != IAX_COMMAND_TXACC) && (f.subclass != IAX_COMMAND_VNAK)) || (f.frametype != AST_FRAME_IAX)) { /* If it's not an ACK packet, it's out of order. */ if (option_debug) ast_log(LOG_DEBUG, "Packet arrived out of order (expecting %d, got %d) (frametype = %d, subclass = %d)\n", iaxs[fr.callno]->iseqno, fr.oseqno, f.frametype, f.subclass); if (iaxs[fr.callno]->iseqno > fr.oseqno) { /* If we've already seen it, ack it XXX There's a border condition here XXX */ if ((f.frametype != AST_FRAME_IAX) || ((f.subclass != IAX_COMMAND_ACK) && (f.subclass != IAX_COMMAND_INVAL))) { if (option_debug) ast_log(LOG_DEBUG, "Acking anyway\n"); /* XXX Maybe we should handle its ack to us, but then again, it's probably outdated anyway, and if we have anything to send, we'll retransmit and get an ACK back anyway XXX */ send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); } } else { /* Send a VNAK requesting retransmission */ iax2_vnak(fr.callno); } ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } } else { /* Increment unless it's an ACK or VNAK */ if (((f.subclass != IAX_COMMAND_ACK) && (f.subclass != IAX_COMMAND_INVAL) && (f.subclass != IAX_COMMAND_TXCNT) && (f.subclass != IAX_COMMAND_TXACC) && (f.subclass != IAX_COMMAND_VNAK)) || (f.frametype != AST_FRAME_IAX)) iaxs[fr.callno]->iseqno++; } /* A full frame */ if (res < sizeof(struct ast_iax2_full_hdr)) { ast_log(LOG_WARNING, "midget packet received (%d of %d min)\n", res, (int)sizeof(struct ast_iax2_full_hdr)); ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } f.datalen = res - sizeof(struct ast_iax2_full_hdr); /* Handle implicit ACKing unless this is an INVAL, and only if this is from the real peer, not the transfer peer */ if (!inaddrcmp(&sin, &iaxs[fr.callno]->addr) && (((f.subclass != IAX_COMMAND_INVAL)) || (f.frametype != AST_FRAME_IAX))) { unsigned char x; /* XXX This code is not very efficient. Surely there is a better way which still properly handles boundary conditions? XXX */ /* First we have to qualify that the ACKed value is within our window */ for (x=iaxs[fr.callno]->rseqno; x != iaxs[fr.callno]->oseqno; x++) if (fr.iseqno == x) break; if ((x != iaxs[fr.callno]->oseqno) || (iaxs[fr.callno]->oseqno == fr.iseqno)) { /* The acknowledgement is within our window. Time to acknowledge everything that it says to */ for (x=iaxs[fr.callno]->rseqno; x != fr.iseqno; x++) { /* Ack the packet with the given timestamp */ if (option_debug) ast_log(LOG_DEBUG, "Cancelling transmission of packet %d\n", x); ast_mutex_lock(&iaxq.lock); for (cur = iaxq.head; cur ; cur = cur->next) { /* If it's our call, and our timestamp, mark -1 retries */ if ((fr.callno == cur->callno) && (x == cur->oseqno)) { cur->retries = -1; /* Destroy call if this is the end */ if (cur->final) { if (option_debug) ast_log(LOG_DEBUG, "Really destroying %d, having been acked on final message\n", fr.callno); iax2_destroy_nolock(fr.callno); } } } ast_mutex_unlock(&iaxq.lock); } /* Note how much we've received acknowledgement for */ if (iaxs[fr.callno]) iaxs[fr.callno]->rseqno = fr.iseqno; else { /* Stop processing now */ ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } } else ast_log(LOG_DEBUG, "Received iseqno %d not within window %d->%d\n", fr.iseqno, iaxs[fr.callno]->rseqno, iaxs[fr.callno]->oseqno); } if (inaddrcmp(&sin, &iaxs[fr.callno]->addr) && ((f.frametype != AST_FRAME_IAX) || ((f.subclass != IAX_COMMAND_TXACC) && (f.subclass != IAX_COMMAND_TXCNT)))) { /* Only messages we accept from a transfer host are TXACC and TXCNT */ ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } if (f.datalen) { if (f.frametype == AST_FRAME_IAX) { if (iax_parse_ies(&ies, buf + sizeof(struct ast_iax2_full_hdr), f.datalen)) { ast_log(LOG_WARNING, "Undecodable frame received from '%s'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr)); ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } f.data = NULL; } else f.data = buf + sizeof(struct ast_iax2_full_hdr); } else { if (f.frametype == AST_FRAME_IAX) f.data = NULL; else f.data = empty; memset(&ies, 0, sizeof(ies)); } if (f.frametype == AST_FRAME_VOICE) { if (f.subclass != iaxs[fr.callno]->voiceformat) { iaxs[fr.callno]->voiceformat = f.subclass; ast_log(LOG_DEBUG, "Ooh, voice format changed to %d\n", f.subclass); if (iaxs[fr.callno]->owner) { int orignative; retryowner: if (ast_mutex_trylock(&iaxs[fr.callno]->owner->lock)) { ast_mutex_unlock(&iaxsl[fr.callno]); usleep(1); ast_mutex_lock(&iaxsl[fr.callno]); if (iaxs[fr.callno] && iaxs[fr.callno]->owner) goto retryowner; } if (iaxs[fr.callno]) { if (iaxs[fr.callno]->owner) { orignative = iaxs[fr.callno]->owner->nativeformats; iaxs[fr.callno]->owner->nativeformats = f.subclass; if (iaxs[fr.callno]->owner->readformat) ast_set_read_format(iaxs[fr.callno]->owner, iaxs[fr.callno]->owner->readformat); iaxs[fr.callno]->owner->nativeformats = orignative; ast_mutex_unlock(&iaxs[fr.callno]->owner->lock); } } else { ast_log(LOG_DEBUG, "Neat, somebody took away the channel at a magical time but i found it!\n"); ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } } } } if (f.frametype == AST_FRAME_VIDEO) { if (f.subclass != iaxs[fr.callno]->videoformat) { ast_log(LOG_DEBUG, "Ooh, video format changed to %d\n", f.subclass & ~0x1); iaxs[fr.callno]->videoformat = f.subclass & ~0x1; } } if (f.frametype == AST_FRAME_IAX) { if (iaxs[fr.callno]->initid > -1) { /* Don't auto congest anymore since we've gotten something usefulb ack */ ast_sched_del(sched, iaxs[fr.callno]->initid); iaxs[fr.callno]->initid = -1; } /* Handle the IAX pseudo frame itself */ if (option_debug) ast_log(LOG_DEBUG, "IAX subclass %d received\n", f.subclass); /* Go through the motions of delivering the packet without actually doing so */ schedule_delivery(&fr, 0, updatehistory); switch(f.subclass) { case IAX_COMMAND_ACK: /* Do nothing */ break; case IAX_COMMAND_QUELCH: if (iaxs[fr.callno]->state & IAX_STATE_STARTED) { iaxs[fr.callno]->quelch = 1; if (ies.musiconhold) { if (iaxs[fr.callno]->owner && iaxs[fr.callno]->owner->bridge) ast_moh_start(iaxs[fr.callno]->owner->bridge, NULL); } } break; case IAX_COMMAND_UNQUELCH: if (iaxs[fr.callno]->state & IAX_STATE_STARTED) { iaxs[fr.callno]->quelch = 0; if (iaxs[fr.callno]->owner && iaxs[fr.callno]->owner->bridge) ast_moh_stop(iaxs[fr.callno]->owner->bridge); } break; case IAX_COMMAND_TXACC: if (iaxs[fr.callno]->transferring == TRANSFER_BEGIN) { /* Ack the packet with the given timestamp */ ast_mutex_lock(&iaxq.lock); for (cur = iaxq.head; cur ; cur = cur->next) { /* Cancel any outstanding txcnt's */ if ((fr.callno == cur->callno) && (cur->transfer)) cur->retries = -1; } ast_mutex_unlock(&iaxq.lock); memset(&ied1, 0, sizeof(ied1)); iax_ie_append_short(&ied1, IAX_IE_CALLNO, iaxs[fr.callno]->callno); send_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_TXREADY, 0, ied1.buf, ied1.pos, -1); iaxs[fr.callno]->transferring = TRANSFER_READY; } break; case IAX_COMMAND_NEW: /* Ignore if it's already up */ if (iaxs[fr.callno]->state & (IAX_STATE_STARTED | IAX_STATE_TBD)) break; if (ies.provverpres && ies.serviceident && sin.sin_addr.s_addr) check_provisioning(&sin, ies.serviceident, ies.provver); /* For security, always ack immediately */ if (delayreject) send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); if (check_access(fr.callno, &sin, &ies)) { /* They're not allowed on */ auth_fail(fr.callno, IAX_COMMAND_REJECT); if (authdebug) ast_log(LOG_NOTICE, "Rejected connect attempt from %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr)); break; } /* If we're in trunk mode, do it now, and update the trunk number in our frame before continuing */ if (iaxs[fr.callno]->trunk) { fr.callno = make_trunk(fr.callno, 1); } /* This might re-enter the IAX code and need the lock */ if (strcasecmp(iaxs[fr.callno]->exten, "TBD")) { ast_mutex_unlock(&iaxsl[fr.callno]); exists = ast_exists_extension(NULL, iaxs[fr.callno]->context, iaxs[fr.callno]->exten, 1, iaxs[fr.callno]->callerid); ast_mutex_lock(&iaxsl[fr.callno]); } else exists = 0; if (ast_strlen_zero(iaxs[fr.callno]->secret) && ast_strlen_zero(iaxs[fr.callno]->inkeys)) { if (strcmp(iaxs[fr.callno]->exten, "TBD") && !exists) { memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "No such context/extension"); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); if (authdebug) ast_log(LOG_NOTICE, "Rejected connect attempt from %s, request '%s@%s' does not exist\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->exten, iaxs[fr.callno]->context); } else { /* Select an appropriate format */ format = iaxs[fr.callno]->peerformat & iaxs[fr.callno]->capability; if (!format) { format = iaxs[fr.callno]->peercapability & iaxs[fr.callno]->capability; if (!format) { memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "Unable to negotiate codec"); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); if (authdebug) ast_log(LOG_NOTICE, "Rejected connect attempt from %s, requested/capability 0x%x/0x%x incompatible with our capability 0x%x.\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->peerformat, iaxs[fr.callno]->peercapability, iaxs[fr.callno]->capability); } else { /* Pick one... */ format = ast_best_codec(iaxs[fr.callno]->peercapability & iaxs[fr.callno]->capability); if (!format) { memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "Unable to negotiate codec"); ast_log(LOG_ERROR, "No best format in 0x%x???\n", iaxs[fr.callno]->peercapability & iaxs[fr.callno]->capability); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); if (authdebug) ast_log(LOG_NOTICE, "Rejected connect attempt from %s, requested/capability 0x%x/0x%x incompatible with our capability 0x%x.\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->peerformat, iaxs[fr.callno]->peercapability, iaxs[fr.callno]->capability); iaxs[fr.callno]->alreadygone = 1; break; } } } if (format) { /* No authentication required, let them in */ memset(&ied1, 0, sizeof(ied1)); iax_ie_append_int(&ied1, IAX_IE_FORMAT, format); send_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACCEPT, 0, ied1.buf, ied1.pos, -1); if (strcmp(iaxs[fr.callno]->exten, "TBD")) { iaxs[fr.callno]->state |= IAX_STATE_STARTED; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Accepting unauthenticated call from %s, requested format = %d, actual format = %d\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->peerformat,format); if(!(c = ast_iax2_new(fr.callno, AST_STATE_RING, format))) iax2_destroy_nolock(fr.callno); } else { iaxs[fr.callno]->state |= IAX_STATE_TBD; /* If this is a TBD call, we're ready but now what... */ if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Accepted unauthenticated TBD call from %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr)); } } } break; } authenticate_request(iaxs[fr.callno]); iaxs[fr.callno]->state |= IAX_STATE_AUTHENTICATED; break; case IAX_COMMAND_DPREQ: /* Request status in the dialplan */ if ((iaxs[fr.callno]->state & IAX_STATE_TBD) && !(iaxs[fr.callno]->state & IAX_STATE_STARTED) && ies.called_number) { if (iaxcompat) { /* Spawn a thread for the lookup */ spawn_dp_lookup(fr.callno, iaxs[fr.callno]->context, ies.called_number, iaxs[fr.callno]->callerid); } else { /* Just look it up */ dp_lookup(fr.callno, iaxs[fr.callno]->context, ies.called_number, iaxs[fr.callno]->callerid, 1); } } break; case IAX_COMMAND_HANGUP: iaxs[fr.callno]->alreadygone = 1; ast_log(LOG_DEBUG, "Immediately destroying %d, having received hangup\n", fr.callno); /* Send ack immediately, before we destroy */ send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); iax2_destroy_nolock(fr.callno); break; case IAX_COMMAND_REJECT: memset(&f, 0, sizeof(f)); f.frametype = AST_FRAME_CONTROL; f.subclass = AST_CONTROL_CONGESTION; iax2_queue_frame(fr.callno, &f); if (iaxs[fr.callno]->provision) { /* Send ack immediately, before we destroy */ send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); iax2_destroy_nolock(fr.callno); break; } if (iaxs[fr.callno]->owner) { if (authdebug) ast_log(LOG_WARNING, "Call rejected by %s: %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), iaxs[fr.callno]->addr.sin_addr), ies.cause ? ies.cause : ""); } ast_log(LOG_DEBUG, "Immediately destroying %d, having received reject\n", fr.callno); /* Send ack immediately, before we destroy */ send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); iaxs[fr.callno]->error = EPERM; iax2_destroy_nolock(fr.callno); break; case IAX_COMMAND_TRANSFER: if (iaxs[fr.callno]->owner && iaxs[fr.callno]->owner->bridge && ies.called_number) { if (!strcmp(ies.called_number, ast_parking_ext())) { if (iax_park(iaxs[fr.callno]->owner->bridge, iaxs[fr.callno]->owner)) { ast_log(LOG_WARNING, "Failed to park call on '%s'\n", iaxs[fr.callno]->owner->bridge->name); } else ast_log(LOG_DEBUG, "Parked call on '%s'\n", iaxs[fr.callno]->owner->bridge->name); } else { if (ast_async_goto(iaxs[fr.callno]->owner->bridge, iaxs[fr.callno]->context, ies.called_number, 1)) ast_log(LOG_WARNING, "Async goto of '%s' to '%s@%s' failed\n", iaxs[fr.callno]->owner->bridge->name, ies.called_number, iaxs[fr.callno]->context); else ast_log(LOG_DEBUG, "Async goto of '%s' to '%s@%s' started\n", iaxs[fr.callno]->owner->bridge->name, ies.called_number, iaxs[fr.callno]->context); } } else ast_log(LOG_DEBUG, "Async goto not applicable on call %d\n", fr.callno); break; case IAX_COMMAND_ACCEPT: /* Ignore if call is already up or needs authentication or is a TBD */ if (iaxs[fr.callno]->state & (IAX_STATE_STARTED | IAX_STATE_TBD | IAX_STATE_AUTHENTICATED)) break; if (iaxs[fr.callno]->provision) { /* Send ack immediately, before we destroy */ send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); iax2_destroy_nolock(fr.callno); break; } if (ies.format) { iaxs[fr.callno]->peerformat = ies.format; } else { if (iaxs[fr.callno]->owner) iaxs[fr.callno]->peerformat = iaxs[fr.callno]->owner->nativeformats; else iaxs[fr.callno]->peerformat = iaxs[fr.callno]->capability; } if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Call accepted by %s (format %s)\n", ast_inet_ntoa(iabuf, sizeof(iabuf), iaxs[fr.callno]->addr.sin_addr), ast_getformatname(iaxs[fr.callno]->peerformat)); if (!(iaxs[fr.callno]->peerformat & iaxs[fr.callno]->capability)) { memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "Unable to negotiate codec"); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); if (authdebug) ast_log(LOG_NOTICE, "Rejected call to %s, format 0x%x incompatible with our capability 0x%x.\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->peerformat, iaxs[fr.callno]->capability); } else { iaxs[fr.callno]->state |= IAX_STATE_STARTED; if (iaxs[fr.callno]->owner) { /* Switch us to use a compatible format */ iaxs[fr.callno]->owner->nativeformats = iaxs[fr.callno]->peerformat; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Format for call is %s\n", ast_getformatname(iaxs[fr.callno]->owner->nativeformats)); retryowner2: if (ast_mutex_trylock(&iaxs[fr.callno]->owner->lock)) { ast_mutex_unlock(&iaxsl[fr.callno]); usleep(1); ast_mutex_lock(&iaxsl[fr.callno]); if (iaxs[fr.callno] && iaxs[fr.callno]->owner) goto retryowner2; } if (iaxs[fr.callno] && iaxs[fr.callno]->owner) { /* Setup read/write formats properly. */ if (iaxs[fr.callno]->owner->writeformat) ast_set_write_format(iaxs[fr.callno]->owner, iaxs[fr.callno]->owner->writeformat); if (iaxs[fr.callno]->owner->readformat) ast_set_read_format(iaxs[fr.callno]->owner, iaxs[fr.callno]->owner->readformat); ast_mutex_unlock(&iaxs[fr.callno]->owner->lock); } } } ast_mutex_lock(&dpcache_lock); dp = iaxs[fr.callno]->dpentries; while(dp) { if (!(dp->flags & CACHE_FLAG_TRANSMITTED)) { iax2_dprequest(dp, fr.callno); } dp = dp->peer; } ast_mutex_unlock(&dpcache_lock); break; case IAX_COMMAND_POKE: /* Send back a pong packet with the original timestamp */ send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_PONG, fr.ts, NULL, 0, -1); break; case IAX_COMMAND_PING: #ifdef BRIDGE_OPTIMIZATION if (iaxs[fr.callno]->bridgecallno) { /* If we're in a bridged call, just forward this */ forward_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_PING, fr.ts, NULL, 0, -1); } else { /* Send back a pong packet with the original timestamp */ send_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_PONG, fr.ts, NULL, 0, -1); } #else /* Send back a pong packet with the original timestamp */ send_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_PONG, fr.ts, NULL, 0, -1); #endif break; case IAX_COMMAND_PONG: #ifdef BRIDGE_OPTIMIZATION if (iaxs[fr.callno]->bridgecallno) { /* Forward to the other side of the bridge */ forward_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_PONG, fr.ts, NULL, 0, -1); } else { /* Calculate ping time */ iaxs[fr.callno]->pingtime = calc_timestamp(iaxs[fr.callno], 0, &f) - fr.ts; } #else /* Calculate ping time */ iaxs[fr.callno]->pingtime = calc_timestamp(iaxs[fr.callno], 0, &f) - fr.ts; #endif if (iaxs[fr.callno]->peerpoke) { peer = iaxs[fr.callno]->peerpoke; if ((peer->lastms < 0) || (peer->lastms > peer->maxms)) { if (iaxs[fr.callno]->pingtime <= peer->maxms) ast_log(LOG_NOTICE, "Peer '%s' is now REACHABLE!\n", peer->name); } else if ((peer->lastms > 0) && (peer->lastms <= peer->maxms)) { if (iaxs[fr.callno]->pingtime > peer->maxms) ast_log(LOG_NOTICE, "Peer '%s' is now TOO LAGGED (%d ms)!\n", peer->name, iaxs[fr.callno]->pingtime); } peer->lastms = iaxs[fr.callno]->pingtime; if (peer->pokeexpire > -1) ast_sched_del(sched, peer->pokeexpire); send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); iax2_destroy_nolock(fr.callno); peer->callno = 0; /* Try again eventually */ if ((peer->lastms < 0) || (peer->lastms > peer->maxms)) peer->pokeexpire = ast_sched_add(sched, DEFAULT_FREQ_NOTOK, iax2_poke_peer_s, peer); else peer->pokeexpire = ast_sched_add(sched, DEFAULT_FREQ_OK, iax2_poke_peer_s, peer); } break; case IAX_COMMAND_LAGRQ: case IAX_COMMAND_LAGRP: #ifdef BRIDGE_OPTIMIZATION if (iaxs[fr.callno]->bridgecallno) { forward_command(iaxs[fr.callno], AST_FRAME_IAX, f.subclass, fr.ts, NULL, 0, -1); } else { #endif f.src = "LAGRQ"; f.mallocd = 0; f.offset = 0; f.samples = 0; iax_frame_wrap(&fr, &f); if(f.subclass == IAX_COMMAND_LAGRQ) { /* Received a LAGRQ - echo back a LAGRP */ fr.af.subclass = IAX_COMMAND_LAGRP; iax2_send(iaxs[fr.callno], &fr.af, fr.ts, -1, 0, 0, 0); } else { /* Received LAGRP in response to our LAGRQ */ unsigned int ts; /* This is a reply we've been given, actually measure the difference */ ts = calc_timestamp(iaxs[fr.callno], 0, &fr.af); iaxs[fr.callno]->lag = ts - fr.ts; if (option_debug) ast_log(LOG_DEBUG, "Peer %s lag measured as %dms\n", ast_inet_ntoa(iabuf, sizeof(iabuf), iaxs[fr.callno]->addr.sin_addr), iaxs[fr.callno]->lag); } #ifdef BRIDGE_OPTIMIZATION } #endif break; case IAX_COMMAND_AUTHREQ: if (iaxs[fr.callno]->state & (IAX_STATE_STARTED | IAX_STATE_TBD)) { ast_log(LOG_WARNING, "Call on %s is already up, can't start on it\n", iaxs[fr.callno]->owner ? iaxs[fr.callno]->owner->name : ""); break; } if (authenticate_reply(iaxs[fr.callno], &iaxs[fr.callno]->addr, &ies, iaxs[fr.callno]->secret, iaxs[fr.callno]->outkey)) { ast_log(LOG_WARNING, "I don't know how to authenticate %s to %s\n", ies.username ? ies.username : "", ast_inet_ntoa(iabuf, sizeof(iabuf), iaxs[fr.callno]->addr.sin_addr)); } break; case IAX_COMMAND_AUTHREP: /* For security, always ack immediately */ if (delayreject) send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); /* Ignore once we've started */ if (iaxs[fr.callno]->state & (IAX_STATE_STARTED | IAX_STATE_TBD)) { ast_log(LOG_WARNING, "Call on %s is already up, can't start on it\n", iaxs[fr.callno]->owner ? iaxs[fr.callno]->owner->name : ""); break; } if (authenticate_verify(iaxs[fr.callno], &ies)) { if (authdebug) ast_log(LOG_NOTICE, "Host %s failed to authenticate as %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), iaxs[fr.callno]->addr.sin_addr), iaxs[fr.callno]->username); memset(&ied0, 0, sizeof(ied0)); auth_fail(fr.callno, IAX_COMMAND_REJECT); break; } if (strcasecmp(iaxs[fr.callno]->exten, "TBD")) { /* This might re-enter the IAX code and need the lock */ exists = ast_exists_extension(NULL, iaxs[fr.callno]->context, iaxs[fr.callno]->exten, 1, iaxs[fr.callno]->callerid); } else exists = 0; if (strcmp(iaxs[fr.callno]->exten, "TBD") && !exists) { if (authdebug) ast_log(LOG_NOTICE, "Rejected connect attempt from %s, request '%s@%s' does not exist\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->exten, iaxs[fr.callno]->context); memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "No such context/extension"); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); } else { /* Select an appropriate format */ format = iaxs[fr.callno]->peerformat & iaxs[fr.callno]->capability; if (!format) { ast_log(LOG_DEBUG, "We don't do requested format %s, falling back to peer capability %d\n", ast_getformatname(iaxs[fr.callno]->peerformat), iaxs[fr.callno]->peercapability); format = iaxs[fr.callno]->peercapability & iaxs[fr.callno]->capability; if (!format) { if (authdebug) ast_log(LOG_NOTICE, "Rejected connect attempt from %s, requested/capability 0x%x/0x%x incompatible with our capability 0x%x.\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->peerformat, iaxs[fr.callno]->peercapability, iaxs[fr.callno]->capability); memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "Unable to negotiate codec"); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); } else { /* Pick one... */ format = ast_best_codec(iaxs[fr.callno]->peercapability & iaxs[fr.callno]->capability); if (!format) { ast_log(LOG_ERROR, "No best format in 0x%x???\n", iaxs[fr.callno]->peercapability & iaxs[fr.callno]->capability); if (authdebug) ast_log(LOG_NOTICE, "Rejected connect attempt from %s, requested/capability 0x%x/0x%x incompatible with our capability 0x%x.\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->peerformat, iaxs[fr.callno]->peercapability, iaxs[fr.callno]->capability); memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "Unable to negotiate codec"); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); } } } if (format) { /* Authentication received */ memset(&ied1, 0, sizeof(ied1)); iax_ie_append_int(&ied1, IAX_IE_FORMAT, format); send_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACCEPT, 0, ied1.buf, ied1.pos, -1); if (strcmp(iaxs[fr.callno]->exten, "TBD")) { iaxs[fr.callno]->state |= IAX_STATE_STARTED; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Accepting AUTHENTICATED call from %s, requested format = %d, actual format = %d\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->peerformat,format); iaxs[fr.callno]->state |= IAX_STATE_STARTED; if(!(c = ast_iax2_new(fr.callno, AST_STATE_RING, format))) iax2_destroy_nolock(fr.callno); } else { iaxs[fr.callno]->state |= IAX_STATE_TBD; /* If this is a TBD call, we're ready but now what... */ if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Accepted AUTHENTICATED TBD call from %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr)); } } } break; case IAX_COMMAND_DIAL: if (iaxs[fr.callno]->state & IAX_STATE_TBD) { iaxs[fr.callno]->state &= ~IAX_STATE_TBD; strncpy(iaxs[fr.callno]->exten, ies.called_number ? ies.called_number : "s", sizeof(iaxs[fr.callno]->exten)-1); if (!ast_exists_extension(NULL, iaxs[fr.callno]->context, iaxs[fr.callno]->exten, 1, iaxs[fr.callno]->callerid)) { if (authdebug) ast_log(LOG_NOTICE, "Rejected dial attempt from %s, request '%s@%s' does not exist\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->exten, iaxs[fr.callno]->context); memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "No such context/extension"); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); } else { iaxs[fr.callno]->state |= IAX_STATE_STARTED; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Accepting DIAL from %s, formats = 0x%x\n", ast_inet_ntoa(iabuf, sizeof(iabuf), sin.sin_addr), iaxs[fr.callno]->peerformat); iaxs[fr.callno]->state |= IAX_STATE_STARTED; send_command(iaxs[fr.callno], AST_FRAME_CONTROL, AST_CONTROL_PROGRESS, 0, NULL, 0, -1); if(!(c = ast_iax2_new(fr.callno, AST_STATE_RING, iaxs[fr.callno]->peerformat))) iax2_destroy_nolock(fr.callno); } } break; case IAX_COMMAND_INVAL: iaxs[fr.callno]->error = ENOTCONN; ast_log(LOG_DEBUG, "Immediately destroying %d, having received INVAL\n", fr.callno); iax2_destroy_nolock(fr.callno); if (option_debug) ast_log(LOG_DEBUG, "Destroying call %d\n", fr.callno); break; case IAX_COMMAND_VNAK: ast_log(LOG_DEBUG, "Sending VNAK\n"); /* Force retransmission */ vnak_retransmit(fr.callno, fr.iseqno); break; case IAX_COMMAND_REGREQ: case IAX_COMMAND_REGREL: /* For security, always ack immediately */ if (delayreject) send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); if (register_verify(fr.callno, &sin, &ies)) { /* Send delayed failure */ auth_fail(fr.callno, IAX_COMMAND_REGREJ); break; } if ((ast_strlen_zero(iaxs[fr.callno]->secret) && ast_strlen_zero(iaxs[fr.callno]->inkeys)) || (iaxs[fr.callno]->state & IAX_STATE_AUTHENTICATED)) { if (f.subclass == IAX_COMMAND_REGREL) memset(&sin, 0, sizeof(sin)); if (update_registry(iaxs[fr.callno]->peer, &sin, fr.callno, ies.devicetype)) ast_log(LOG_WARNING, "Registry error\n"); if (ies.provverpres && ies.serviceident && sin.sin_addr.s_addr) check_provisioning(&sin, ies.serviceident, ies.provver); break; } registry_authrequest(iaxs[fr.callno]->peer, fr.callno); break; case IAX_COMMAND_REGACK: if (iax2_ack_registry(&ies, &sin, fr.callno)) ast_log(LOG_WARNING, "Registration failure\n"); /* Send ack immediately, before we destroy */ send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); iax2_destroy_nolock(fr.callno); break; case IAX_COMMAND_REGREJ: if (iaxs[fr.callno]->reg) { if (authdebug) ast_log(LOG_NOTICE, "Registration of '%s' rejected: %s\n", iaxs[fr.callno]->reg->username, ies.cause ? ies.cause : ""); iaxs[fr.callno]->reg->regstate = REG_STATE_REJECTED; } /* Send ack immediately, before we destroy */ send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); iax2_destroy_nolock(fr.callno); break; case IAX_COMMAND_REGAUTH: /* Authentication request */ if (registry_rerequest(&ies, fr.callno, &sin)) { memset(&ied0, 0, sizeof(ied0)); iax_ie_append_str(&ied0, IAX_IE_CAUSE, "No authority found"); send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); } break; case IAX_COMMAND_TXREJ: iaxs[fr.callno]->transferring = 0; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Channel '%s' unable to transfer\n", iaxs[fr.callno]->owner ? iaxs[fr.callno]->owner->name : ""); memset(&iaxs[fr.callno]->transfer, 0, sizeof(iaxs[fr.callno]->transfer)); if (iaxs[fr.callno]->bridgecallno) { if (iaxs[iaxs[fr.callno]->bridgecallno]->transferring) { iaxs[iaxs[fr.callno]->bridgecallno]->transferring = 0; send_command(iaxs[iaxs[fr.callno]->bridgecallno], AST_FRAME_IAX, IAX_COMMAND_TXREJ, 0, NULL, 0, -1); } } break; case IAX_COMMAND_TXREADY: if (iaxs[fr.callno]->transferring == TRANSFER_BEGIN) { iaxs[fr.callno]->transferring = TRANSFER_READY; if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Channel '%s' ready to transfer\n", iaxs[fr.callno]->owner ? iaxs[fr.callno]->owner->name : ""); if (iaxs[fr.callno]->bridgecallno) { if (iaxs[iaxs[fr.callno]->bridgecallno]->transferring == TRANSFER_READY) { if (option_verbose > 2) ast_verbose(VERBOSE_PREFIX_3 "Releasing %s and %s\n", iaxs[fr.callno]->owner ? iaxs[fr.callno]->owner->name : "", iaxs[iaxs[fr.callno]->bridgecallno]->owner ? iaxs[iaxs[fr.callno]->bridgecallno]->owner->name : ""); /* They're both ready, now release them. */ iaxs[iaxs[fr.callno]->bridgecallno]->transferring = TRANSFER_RELEASED; iaxs[fr.callno]->transferring = TRANSFER_RELEASED; iaxs[iaxs[fr.callno]->bridgecallno]->alreadygone = 1; iaxs[fr.callno]->alreadygone = 1; /* Stop doing lag & ping requests */ stop_stuff(fr.callno); stop_stuff(iaxs[fr.callno]->bridgecallno); memset(&ied0, 0, sizeof(ied0)); memset(&ied1, 0, sizeof(ied1)); iax_ie_append_short(&ied0, IAX_IE_CALLNO, iaxs[iaxs[fr.callno]->bridgecallno]->peercallno); iax_ie_append_short(&ied1, IAX_IE_CALLNO, iaxs[fr.callno]->peercallno); send_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_TXREL, 0, ied0.buf, ied0.pos, -1); send_command(iaxs[iaxs[fr.callno]->bridgecallno], AST_FRAME_IAX, IAX_COMMAND_TXREL, 0, ied1.buf, ied1.pos, -1); } } } break; case IAX_COMMAND_TXREQ: try_transfer(iaxs[fr.callno], &ies); break; case IAX_COMMAND_TXCNT: if (iaxs[fr.callno]->transferring) send_command_transfer(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_TXACC, 0, NULL, 0); break; case IAX_COMMAND_TXREL: /* Send ack immediately, rather than waiting until we've changed addresses */ send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); complete_transfer(fr.callno, &ies); break; case IAX_COMMAND_DPREP: complete_dpreply(iaxs[fr.callno], &ies); break; case IAX_COMMAND_UNSUPPORT: ast_log(LOG_NOTICE, "Peer did not understand our iax command '%d'\n", ies.iax_unknown); break; case IAX_COMMAND_FWDOWNL: /* Firmware download */ memset(&ied0, 0, sizeof(ied0)); res = iax_firmware_append(&ied0, ies.devicetype, ies.fwdesc); if (res < 0) send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_REJECT, 0, ied0.buf, ied0.pos, -1); else if (res > 0) send_command_final(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_FWDATA, 0, ied0.buf, ied0.pos, -1); else send_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_FWDATA, 0, ied0.buf, ied0.pos, -1); break; default: ast_log(LOG_DEBUG, "Unknown IAX command %d on %d/%d\n", f.subclass, fr.callno, iaxs[fr.callno]->peercallno); memset(&ied0, 0, sizeof(ied0)); iax_ie_append_byte(&ied0, IAX_IE_IAX_UNKNOWN, f.subclass); send_command(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_UNSUPPORT, 0, ied0.buf, ied0.pos, -1); } /* Don't actually pass these frames along */ if ((f.subclass != IAX_COMMAND_ACK) && (f.subclass != IAX_COMMAND_TXCNT) && (f.subclass != IAX_COMMAND_TXACC) && (f.subclass != IAX_COMMAND_INVAL) && (f.subclass != IAX_COMMAND_VNAK)) { if (iaxs[fr.callno] && iaxs[fr.callno]->aseqno != iaxs[fr.callno]->iseqno) send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); } ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } /* Unless this is an ACK or INVAL frame, ack it */ if (iaxs[fr.callno]->aseqno != iaxs[fr.callno]->iseqno) send_command_immediate(iaxs[fr.callno], AST_FRAME_IAX, IAX_COMMAND_ACK, fr.ts, NULL, 0,fr.iseqno); } else if (minivid) { f.frametype = AST_FRAME_VIDEO; if (iaxs[fr.callno]->videoformat > 0) f.subclass = iaxs[fr.callno]->videoformat | (ntohs(vh->ts) & 0x8000 ? 1 : 0); else { ast_log(LOG_WARNING, "Received mini frame before first full voice frame\n "); iax2_vnak(fr.callno); ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } f.datalen = res - sizeof(struct ast_iax2_video_hdr); if (f.datalen) f.data = buf + sizeof(struct ast_iax2_video_hdr); else f.data = NULL; fr.ts = (iaxs[fr.callno]->last & 0xFFFF8000L) | (ntohs(mh->ts) & 0x7fff); } else { /* A mini frame */ f.frametype = AST_FRAME_VOICE; if (iaxs[fr.callno]->voiceformat > 0) f.subclass = iaxs[fr.callno]->voiceformat; else { ast_log(LOG_WARNING, "Received mini frame before first full voice frame\n "); iax2_vnak(fr.callno); ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } f.datalen = res - sizeof(struct ast_iax2_mini_hdr); if (f.datalen < 0) { ast_log(LOG_WARNING, "Datalen < 0?\n"); ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } if (f.datalen) f.data = buf + sizeof(struct ast_iax2_mini_hdr); else f.data = NULL; fr.ts = (iaxs[fr.callno]->last & 0xFFFF0000L) | ntohs(mh->ts); } /* Don't pass any packets until we're started */ if (!(iaxs[fr.callno]->state & IAX_STATE_STARTED)) { ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } /* Common things */ f.src = "IAX2"; f.mallocd = 0; f.offset = 0; if (f.datalen && (f.frametype == AST_FRAME_VOICE)) f.samples = get_samples(&f); else f.samples = 0; iax_frame_wrap(&fr, &f); /* If this is our most recent packet, use it as our basis for timestamping */ if (iaxs[fr.callno]->last < fr.ts) { iaxs[fr.callno]->last = fr.ts; fr.outoforder = 0; } else { if (option_debug) ast_log(LOG_DEBUG, "Received out of order packet... (type=%d, subclass %d, ts = %d, last = %d)\n", f.frametype, f.subclass, fr.ts, iaxs[fr.callno]->last); fr.outoforder = -1; } #ifdef BRIDGE_OPTIMIZATION if (iaxs[fr.callno]->bridgecallno) { forward_delivery(&fr); } else { schedule_delivery(iaxfrdup2(&fr), 1, updatehistory); } #else schedule_delivery(iaxfrdup2(&fr), 1, updatehistory); #endif /* Always run again */ ast_mutex_unlock(&iaxsl[fr.callno]); return 1; } static int iax2_do_register(struct iax2_registry *reg) { struct iax_ie_data ied; if (option_debug) ast_log(LOG_DEBUG, "Sending registration request for '%s'\n", reg->username); if (!reg->callno) { if (option_debug) ast_log(LOG_DEBUG, "Allocate call number\n"); reg->callno = find_callno(0, 0, ®->addr, NEW_FORCE, 1); if (reg->callno < 1) { ast_log(LOG_WARNING, "Unable to create call for registration\n"); return -1; } else if (option_debug) ast_log(LOG_DEBUG, "Registration created on call %d\n", reg->callno); iaxs[reg->callno]->reg = reg; } /* Schedule the next registration attempt */ if (reg->expire > -1) ast_sched_del(sched, reg->expire); /* Setup the registration a little early */ reg->expire = ast_sched_add(sched, (5 * reg->refresh / 6) * 1000, iax2_do_register_s, reg); /* Send the request */ memset(&ied, 0, sizeof(ied)); iax_ie_append_str(&ied, IAX_IE_USERNAME, reg->username); iax_ie_append_short(&ied, IAX_IE_REFRESH, reg->refresh); send_command(iaxs[reg->callno],AST_FRAME_IAX, IAX_COMMAND_REGREQ, 0, ied.buf, ied.pos, -1); reg->regstate = REG_STATE_REGSENT; return 0; } static char *iax2_prov_complete_template_3rd(char *line, char *word, int pos, int state) { if (pos != 3) return NULL; return iax_prov_complete_template(line, word, pos, state); } static int iax2_provision(struct sockaddr_in *end, char *dest, const char *template, int force) { /* Returns 1 if provisioned, -1 if not able to find destination, or 0 if no provisioning is found for template */ struct iax_ie_data provdata; struct iax_ie_data ied; unsigned int sig; struct sockaddr_in sin; int callno; if (option_debug) ast_log(LOG_DEBUG, "Provisioning '%s' from template '%s'\n", dest, template); if (iax_provision_build(&provdata, &sig, template, force)) { ast_log(LOG_DEBUG, "No provisioning found for template '%s'\n", template); return 0; } if (end) memcpy(&sin, end, sizeof(sin)); else { if (create_addr(&sin, NULL, NULL, NULL, dest, NULL, NULL, NULL, NULL, 0, NULL, 0, NULL, NULL)) return -1; } /* Build the rest of the message */ memset(&ied, 0, sizeof(ied)); iax_ie_append_raw(&ied, IAX_IE_PROVISIONING, provdata.buf, provdata.pos); callno = find_callno(0, 0, &sin, NEW_FORCE, 1); if (!callno) return -1; ast_mutex_lock(&iaxsl[callno]); if (iaxs[callno]) { /* Schedule autodestruct in case they don't ever give us anything back */ if (iaxs[callno]->autoid > -1) ast_sched_del(sched, iaxs[callno]->autoid); iaxs[callno]->autoid = ast_sched_add(sched, 15000, auto_hangup, (void *)(long)callno); iaxs[callno]->provision = 1; /* Got a call number now, so go ahead and send the provisioning information */ send_command(iaxs[callno], AST_FRAME_IAX, IAX_COMMAND_PROVISION, 0, ied.buf, ied.pos, -1); } ast_mutex_unlock(&iaxsl[callno]); return 1; } static int iax2_prov_cmd(int fd, int argc, char *argv[]) { int force = 0; int res; if (argc < 4) return RESULT_SHOWUSAGE; if ((argc > 4)) { if (!strcasecmp(argv[4], "forced")) force = 1; else return RESULT_SHOWUSAGE; } res = iax2_provision(NULL, argv[2], argv[3], force); if (res < 0) ast_cli(fd, "Unable to find peer/address '%s'\n", argv[2]); else if (res < 1) ast_cli(fd, "No template (including wildcard) matching '%s'\n", argv[3]); else ast_cli(fd, "Provisioning '%s' with template '%s'%s\n", argv[2], argv[3], force ? ", forced" : ""); return RESULT_SUCCESS; } static char show_prov_usage[] = "Usage: iax2 provision