dect
/
asterisk
Archived
13
0
Fork 0
Code Releases Activity
This repository has been archived on 2022-02-17. You can view files and clone it, but cannot push or open issues or pull requests.
asterisk/apps/app_rpt.c

1243 lines
33 KiB
C
Executable File
Raw Blame History

/** @file app_rpt.c
*
* Asterisk -- A telephony toolkit for Linux.
*
* Radio Repeater / Remote Base program
* version 0.2 5/30/04
*
* Copyright (C) 2002-2004, Jim Dixon
*
* Jim Dixon <jim@lambdatel.com>
*
* This program is free software, distributed under the terms of
* the GNU General Public License
*
* Repeater / Remote Functions:
* "Simple" Mode: * - autopatch access, # - autopatch hangup
* Normal mode:
* *0 - autopatch access
* *1 - remote base off
* *2 - remote base monitor
* *3 - remote base tranceive
* *8 - force ID
* *9 - system reset
*
* To send an asterisk (*) while dialing or talking on phone,
* use the autopatch acess code.
*/
/* number of digits for function after *. Must be at least 1 */
#define FUNCTION_LEN 1
/* maximum digits in DTMF buffer, and seconds after * for DTMF command timeout */
#define MAXDTMF 10
#define DTMF_TIMEOUT 3
enum {REM_OFF,REM_MONITOR,REM_TX};
#include <asterisk/lock.h>
#include <asterisk/file.h>
#include <asterisk/logger.h>
#include <asterisk/channel.h>
#include <asterisk/pbx.h>
#include <asterisk/module.h>
#include <asterisk/translate.h>
#include <asterisk/options.h>
#include <asterisk/config.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <pthread.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <dirent.h>
#include <ctype.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <sys/file.h>
#include <sys/ioctl.h>
#include <math.h>
#include <tonezone.h>
#include <linux/zaptel.h>
static char *tdesc = "Radio Repeater / Remote Base version 0.2 05/30/2004";
static int debug = 0;
STANDARD_LOCAL_USER;
LOCAL_USER_DECL;
#define MSWAIT 200
#define HANGTIME 5000
#define TOTIME 180000
#define IDTIME 300000
#define MAXRPTS 20
static pthread_t rpt_master_thread;
static struct rpt
{
char *name;
char *rxchanname;
char *txchanname;
char *rem_rxchanname;
char *rem_txchanname;
char *ourcontext;
char *ourcallerid;
char *acctcode;
char *idrecording;
char *tonezone;
int hangtime;
int totime;
int idtime;
char remoterx;
char remotetx;
char remotemode;
char simple;
struct ast_channel *rxchannel,*txchannel,*rem_rxchannel;
struct ast_channel *rem_txchannel,*pchannel;
int tailtimer,totimer,idtimer,txconf,pconf,callmode,cidx;
pthread_t rpt_id_thread,rpt_term_thread,rpt_proc_thread,rpt_call_thread;
char mydtmf,iding,terming,teleing,comping,procing;
char exten[AST_MAX_EXTENSION];
} rpt_vars[MAXRPTS];
static void *rpt_id(void *this)
{
ZT_CONFINFO ci; /* conference info */
int res;
struct rpt *myrpt = (struct rpt *)this;
struct ast_channel *mychannel;
/* allocate a pseudo-channel thru asterisk */
mychannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo");
if (!mychannel)
{
fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
pthread_exit(NULL);
}
/* make a conference for the tx */
ci.chan = 0;
ci.confno = myrpt->txconf; /* use the tx conference */
ci.confmode = ZT_CONF_CONFANN;
/* first put the channel on the conference in announce mode */
if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
myrpt->iding = 1;
ast_stopstream(mychannel);
res = ast_streamfile(mychannel, myrpt->idrecording, mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else {
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
res = 0;
}
myrpt->iding = 0;
ast_stopstream(mychannel);
ast_hangup(mychannel);
pthread_exit(NULL);
}
static void *rpt_proc(void *this)
{
ZT_CONFINFO ci; /* conference info */
int res;
struct rpt *myrpt = (struct rpt *)this;
struct ast_channel *mychannel;
/* wait a little bit */
usleep(1500000);
/* allocate a pseudo-channel thru asterisk */
mychannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo");
if (!mychannel)
{
fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
pthread_exit(NULL);
}
/* make a conference for the tx */
ci.chan = 0;
ci.confno = myrpt->txconf; /* use the tx conference */
ci.confmode = ZT_CONF_CONFANN;
/* first put the channel on the conference in announce mode */
if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
myrpt->procing = 1;
ast_stopstream(mychannel);
res = ast_streamfile(mychannel, "callproceeding", mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else {
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
res = 0;
}
myrpt->procing = 0;
ast_stopstream(mychannel);
ast_hangup(mychannel);
pthread_exit(NULL);
}
static void *rpt_term(void *this)
{
ZT_CONFINFO ci; /* conference info */
int res;
struct rpt *myrpt = (struct rpt *)this;
struct ast_channel *mychannel;
/* wait a little bit */
usleep(1500000);
/* allocate a pseudo-channel thru asterisk */
mychannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo");
if (!mychannel)
{
fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
pthread_exit(NULL);
}
/* make a conference for the tx */
ci.chan = 0;
ci.confno = myrpt->txconf; /* use the tx conference */
ci.confmode = ZT_CONF_CONFANN;
/* first put the channel on the conference in announce mode */
if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
myrpt->terming = 1;
ast_stopstream(mychannel);
res = ast_streamfile(mychannel, "callterminated", mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else {
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
res = 0;
}
myrpt->terming = 0;
ast_stopstream(mychannel);
ast_hangup(mychannel);
pthread_exit(NULL);
}
static void *rpt_complete(void *this)
{
ZT_CONFINFO ci; /* conference info */
int res;
struct rpt *myrpt = (struct rpt *)this;
struct ast_channel *mychannel;
/* wait a little bit */
usleep(1000000);
/* allocate a pseudo-channel thru asterisk */
mychannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo");
if (!mychannel)
{
fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
pthread_exit(NULL);
}
/* make a conference for the tx */
ci.chan = 0;
ci.confno = myrpt->txconf; /* use the tx conference */
ci.confmode = ZT_CONF_CONFANN;
/* first put the channel on the conference in announce mode */
if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
myrpt->comping = 1;
ast_stopstream(mychannel);
res = ast_streamfile(mychannel, "functioncomplete", mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else {
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
res = 0;
}
myrpt->comping = 0;
ast_stopstream(mychannel);
ast_hangup(mychannel);
pthread_exit(NULL);
}
static void *rpt_remote_telemetry(void *this)
{
ZT_CONFINFO ci; /* conference info */
int res;
struct rpt *myrpt = (struct rpt *)this;
struct ast_channel *mychannel;
/* wait a little bit */
usleep(1000000);
/* allocate a pseudo-channel thru asterisk */
mychannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo");
if (!mychannel)
{
fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
pthread_exit(NULL);
}
/* make a conference for the tx */
ci.chan = 0;
ci.confno = myrpt->txconf; /* use the tx conference */
ci.confmode = ZT_CONF_CONFANN;
/* first put the channel on the conference in announce mode */
if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
myrpt->teleing = 1;
ast_stopstream(mychannel);
res = ast_streamfile(mychannel,
((myrpt->remotemode == REM_MONITOR) ? "remote_monitor" : "remote_tx"),
mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else {
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
res = 0;
}
myrpt->teleing = 0;
ast_hangup(mychannel);
pthread_exit(NULL);
}
static void *rpt_call(void *this)
{
ZT_CONFINFO ci; /* conference info */
struct rpt *myrpt = (struct rpt *)this;
int res;
struct ast_frame *f,wf;
int stopped,congstarted;
struct ast_channel *mychannel,*genchannel;
myrpt->mydtmf = 0;
/* allocate a pseudo-channel thru asterisk */
mychannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo");
if (!mychannel)
{
fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
pthread_exit(NULL);
}
ci.chan = 0;
ci.confno = myrpt->pconf; /* use the pseudo conference */
ci.confmode = ZT_CONF_REALANDPSEUDO | ZT_CONF_TALKER | ZT_CONF_LISTENER
| ZT_CONF_PSEUDO_TALKER | ZT_CONF_PSEUDO_LISTENER;
/* first put the channel on the conference */
if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
ast_hangup(mychannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
/* allocate a pseudo-channel thru asterisk */
genchannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo");
if (!genchannel)
{
fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
ast_hangup(mychannel);
pthread_exit(NULL);
}
ci.chan = 0;
ci.confno = myrpt->pconf;
ci.confmode = ZT_CONF_REALANDPSEUDO | ZT_CONF_TALKER | ZT_CONF_LISTENER
| ZT_CONF_PSEUDO_TALKER | ZT_CONF_PSEUDO_LISTENER;
/* first put the channel on the conference */
if (ioctl(genchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
if (myrpt->tonezone && (tone_zone_set_zone(mychannel->fds[0],myrpt->tonezone) == -1))
{
ast_log(LOG_WARNING, "Unable to set tone zone %s\n",myrpt->tonezone);
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
if (myrpt->tonezone && (tone_zone_set_zone(genchannel->fds[0],myrpt->tonezone) == -1))
{
ast_log(LOG_WARNING, "Unable to set tone zone %s\n",myrpt->tonezone);
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
/* start dialtone */
if (tone_zone_play_tone(mychannel->fds[0],ZT_TONE_DIALTONE) < 0)
{
ast_log(LOG_WARNING, "Cannot start dialtone\n");
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
stopped = 0;
congstarted = 0;
while ((myrpt->callmode == 1) || (myrpt->callmode == 4))
{
if ((myrpt->callmode == 1) && (myrpt->cidx > 0) && (!stopped))
{
stopped = 1;
/* stop dial tone */
tone_zone_play_tone(mychannel->fds[0],-1);
}
if ((myrpt->callmode == 4) && (!congstarted))
{
congstarted = 1;
/* start congestion tone */
tone_zone_play_tone(mychannel->fds[0],ZT_TONE_CONGESTION);
}
res = ast_waitfor(mychannel, MSWAIT);
if (res < 0)
{
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
if (res == 0) continue;
f = ast_read(mychannel);
if (f == NULL)
{
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
if ((f->frametype == AST_FRAME_CONTROL) &&
(f->subclass == AST_CONTROL_HANGUP))
{
ast_frfree(f);
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
ast_frfree(f);
}
/* stop any tone generation */
tone_zone_play_tone(mychannel->fds[0],-1);
/* end if done */
if (!myrpt->callmode)
{
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
if (myrpt->ourcallerid && *myrpt->ourcallerid)
{
if (mychannel->callerid) free(mychannel->callerid);
mychannel->callerid = strdup(myrpt->ourcallerid);
}
strcpy(mychannel->exten,myrpt->exten);
strcpy(mychannel->context,myrpt->ourcontext);
if (myrpt->acctcode)
strcpy(mychannel->accountcode,myrpt->acctcode);
mychannel->priority = 1;
ast_channel_undefer_dtmf(mychannel);
if (ast_pbx_start(mychannel) < 0)
{
ast_log(LOG_WARNING, "Unable to start PBX!!\n");
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
myrpt->callmode = 3;
while(myrpt->callmode)
{
if ((!mychannel->pvt) && (myrpt->callmode != 4))
{
myrpt->callmode = 4;
/* start congestion tone */
tone_zone_play_tone(genchannel->fds[0],ZT_TONE_CONGESTION);
}
if (myrpt->mydtmf)
{
wf.frametype = AST_FRAME_DTMF;
wf.subclass = myrpt->mydtmf;
wf.offset = 0;
wf.mallocd = 0;
wf.data = NULL;
wf.datalen = 0;
wf.samples = 0;
ast_write(genchannel,&wf);
myrpt->mydtmf = 0;
}
usleep(25000);
}
tone_zone_play_tone(genchannel->fds[0],-1);
if (mychannel->pvt) ast_softhangup(mychannel,AST_SOFTHANGUP_DEV);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
static void process_dtmf(char *cmd,struct rpt *myrpt)
{
pthread_attr_t attr;
ZT_CONFINFO ci; /* conference info */
switch(atoi(cmd))
{
case 0: /* autopatch on / send asterisk (*) */
/* if on call, force * into current audio stream */
if ((myrpt->callmode == 2) || (myrpt->callmode == 3))
{
myrpt->mydtmf = '*';
break;
}
if (myrpt->callmode) return;
myrpt->callmode = 1;
myrpt->cidx = 0;
myrpt->exten[myrpt->cidx] = 0;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&myrpt->rpt_call_thread,&attr,rpt_call,(void *)myrpt);
return;
case 9: /* master reset */
myrpt->callmode = 0;
/* fall thru intentionally */
case 1: /* remote base off */
if (myrpt->rem_rxchannel == NULL) return;
myrpt->remotemode = REM_OFF;
ci.chan = 0;
ci.confno = 0;
ci.confmode = 0;
/* Take off conf */
if (ioctl(myrpt->rem_rxchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
/* Take off conf */
if (ioctl(myrpt->rem_txchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
break;
case 2: /* remote base monitor */
if (myrpt->rem_rxchannel == NULL) return;
myrpt->remotemode = REM_MONITOR;
if (myrpt->remoterx && (!myrpt->remotetx))
{
ci.chan = 0;
ci.confno = myrpt->pconf;
ci.confmode = ZT_CONF_CONF | ZT_CONF_TALKER;
/* Put on conf */
if (ioctl(myrpt->rem_rxchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
}
break;
case 3: /* remote base tranceieve */
if (myrpt->rem_rxchannel == NULL) return;
myrpt->remotemode = REM_TX;
if (myrpt->remoterx && (!myrpt->remotetx))
{
ci.chan = 0;
ci.confno = myrpt->pconf;
ci.confmode = ZT_CONF_CONF | ZT_CONF_TALKER;
/* Put on conf */
if (ioctl(myrpt->rem_rxchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
}
break;
case 8: /* force ID */
myrpt->idtimer = 0;
return;
default:
return;
}
/* send function complete */
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&myrpt->rpt_call_thread,&attr,rpt_complete,(void *)myrpt);
}
/* single thread with one file (request) to dial */
static void *rpt(void *this)
{
struct rpt *myrpt = (struct rpt *)this;
char *tele;
int ms = MSWAIT,lasttx,keyed,val,dtmfidx;
char dtmfbuf[MAXDTMF];
struct ast_channel *who;
ZT_CONFINFO ci; /* conference info */
time_t dtmf_time,t;
pthread_attr_t attr;
tele = strchr(myrpt->rxchanname,'/');
if (!tele)
{
fprintf(stderr,"rpt:Dial number must be in format tech/number\n");
pthread_exit(NULL);
}
*tele++ = 0;
myrpt->rxchannel = ast_request(myrpt->rxchanname,AST_FORMAT_SLINEAR,tele);
if (myrpt->rxchannel)
{
ast_set_read_format(myrpt->rxchannel,AST_FORMAT_SLINEAR);
ast_set_write_format(myrpt->rxchannel,AST_FORMAT_SLINEAR);
myrpt->rxchannel->whentohangup = 0;
myrpt->rxchannel->appl = "Apprpt";
myrpt->rxchannel->data = "(Repeater Rx)";
if (option_verbose > 2)
ast_verbose(VERBOSE_PREFIX_3 "rpt (Rx) initiating call to %s/%s on %s\n",
myrpt->rxchanname,tele,myrpt->rxchannel->name);
ast_call(myrpt->rxchannel,tele,999);
}
else
{
fprintf(stderr,"rpt:Sorry unable to obtain Rx channel\n");
pthread_exit(NULL);
}
if (myrpt->txchanname)
{
tele = strchr(myrpt->txchanname,'/');
if (!tele)
{
fprintf(stderr,"rpt:Dial number must be in format tech/number\n");
pthread_exit(NULL);
}
*tele++ = 0;
myrpt->txchannel = ast_request(myrpt->txchanname,AST_FORMAT_SLINEAR,tele);
if (myrpt->txchannel)
{
ast_set_read_format(myrpt->txchannel,AST_FORMAT_SLINEAR);
ast_set_write_format(myrpt->txchannel,AST_FORMAT_SLINEAR);
myrpt->txchannel->whentohangup = 0;
myrpt->txchannel->appl = "Apprpt";
myrpt->txchannel->data = "(Repeater Rx)";
if (option_verbose > 2)
ast_verbose(VERBOSE_PREFIX_3 "rpt (Tx) initiating call to %s/%s on %s\n",
myrpt->txchanname,tele,myrpt->txchannel->name);
ast_call(myrpt->txchannel,tele,999);
}
else
{
fprintf(stderr,"rpt:Sorry unable to obtain Tx channel\n");
pthread_exit(NULL);
}
}
else
{
myrpt->txchannel = myrpt->rxchannel;
}
myrpt->rem_rxchannel = NULL;
myrpt->rem_txchannel = NULL;
myrpt->remoterx = 0;
myrpt->remotemode = REM_OFF;
if (myrpt->rem_rxchanname)
{
tele = strchr(myrpt->rem_rxchanname,'/');
if (!tele)
{
fprintf(stderr,"rpt:Dial number must be in format tech/number\n");
pthread_exit(NULL);
}
*tele++ = 0;
myrpt->rem_rxchannel = ast_request(myrpt->rem_rxchanname,AST_FORMAT_SLINEAR,tele);
if (myrpt->rem_rxchannel)
{
ast_set_read_format(myrpt->rem_rxchannel,AST_FORMAT_SLINEAR);
ast_set_write_format(myrpt->rem_rxchannel,AST_FORMAT_SLINEAR);
myrpt->rem_rxchannel->whentohangup = 0;
myrpt->rem_rxchannel->appl = "Apprpt";
myrpt->rem_rxchannel->data = "(Repeater/Remote Rx)";
if (option_verbose > 2)
ast_verbose(VERBOSE_PREFIX_3 "rpt (RemoteRx) initiating call to %s/%s on %s\n",
myrpt->rem_rxchanname,tele,myrpt->rem_rxchannel->name);
ast_call(myrpt->rem_rxchannel,tele,999);
}
else
{
fprintf(stderr,"rpt:Sorry unable to obtain RemoteRx channel\n");
pthread_exit(NULL);
}
if (myrpt->rem_txchanname) /* if in remote base mode */
{
tele = strchr(myrpt->rem_txchanname,'/');
if (!tele)
{
fprintf(stderr,"rpt:Dial number must be in format tech/number\n");
pthread_exit(NULL);
}
*tele++ = 0;
myrpt->rem_txchannel = ast_request(myrpt->rem_txchanname,AST_FORMAT_SLINEAR,tele);
if (myrpt->rem_txchannel)
{
ast_set_read_format(myrpt->rem_txchannel,AST_FORMAT_SLINEAR);
ast_set_write_format(myrpt->rem_txchannel,AST_FORMAT_SLINEAR);
myrpt->rem_txchannel->whentohangup = 0;
myrpt->rem_txchannel->appl = "Apprpt";
myrpt->rem_txchannel->data = "(Repeater/Remote Tx)";
if (option_verbose > 2)
ast_verbose(VERBOSE_PREFIX_3 "rpt (RemoteTx) initiating call to %s/%s on %s\n",
myrpt->rem_txchanname,tele,myrpt->rem_txchannel->name);
ast_call(myrpt->rem_txchannel,tele,999);
}
else
{
fprintf(stderr,"rpt:Sorry unable to obtain Tx channel\n");
pthread_exit(NULL);
}
}
else
{
myrpt->rem_txchannel = myrpt->rem_rxchannel;
}
}
/* allocate a pseudo-channel thru asterisk */
myrpt->pchannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo");
if (!myrpt->pchannel)
{
fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
pthread_exit(NULL);
}
/* make a conference for the tx */
ci.chan = 0;
ci.confno = -1; /* make a new conf */
ci.confmode = ZT_CONF_CONF | ZT_CONF_LISTENER;
/* first put the channel on the conference in announce mode */
if (ioctl(myrpt->txchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
/* save tx conference number */
myrpt->txconf = ci.confno;
/* make a conference for the pseudo */
ci.chan = 0;
ci.confno = -1; /* make a new conf */
ci.confmode = ZT_CONF_CONFANNMON;
/* first put the channel on the conference in announce mode */
if (ioctl(myrpt->pchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
/* save pseudo channel conference number */
myrpt->pconf = ci.confno;
/* Now, the idea here is to copy from the physical rx channel buffer
into the pseudo tx buffer, and from the pseudo rx buffer into the
tx channel buffer */
myrpt->tailtimer = 0;
myrpt->totimer = 0;
myrpt->idtimer = 0;
lasttx = 0;
myrpt->remotetx = 0;
keyed = 0;
myrpt->callmode = 0;
dtmfidx = -1;
dtmfbuf[0] = 0;
dtmf_time = 0;
val = 0;
ast_channel_setoption(myrpt->rxchannel,AST_OPTION_TONE_VERIFY,&val,sizeof(char),0);
val = 1;
ast_channel_setoption(myrpt->rxchannel,AST_OPTION_RELAXDTMF,&val,sizeof(char),0);
if (myrpt->rem_rxchannel)
{
val = 0;
ast_channel_setoption(myrpt->rem_rxchannel,AST_OPTION_TONE_VERIFY,&val,sizeof(char),0);
val = 1;
ast_channel_setoption(myrpt->rem_rxchannel,AST_OPTION_RELAXDTMF,&val,sizeof(char),0);
}
while (ms >= 0)
{
struct ast_frame *f;
struct ast_channel *cs[5];
int totx,rem_totx,elap,n;
if (ast_check_hangup(myrpt->rxchannel)) break;
if (ast_check_hangup(myrpt->txchannel)) break;
if (myrpt->rem_rxchannel)
{
if (ast_check_hangup(myrpt->rem_rxchannel)) break;
if (ast_check_hangup(myrpt->rem_txchannel)) break;
}
totx = (keyed || myrpt->callmode || myrpt->iding || myrpt->terming
|| ((myrpt->remotemode != REM_OFF) && myrpt->remoterx) ||
myrpt->teleing || myrpt->comping || myrpt->procing);
if (!totx) myrpt->totimer = myrpt->totime;
else myrpt->tailtimer = myrpt->hangtime;
totx = (totx || myrpt->tailtimer) && myrpt->totimer;
/* if wants to transmit and in phone call, but timed out,
reset time-out timer if keyed */
if ((!totx) && (!myrpt->totimer) && myrpt->callmode && keyed)
{
myrpt->totimer = myrpt->totime;
continue;
}
/* if timed-out and in circuit busy after call */
if ((!totx) && (!myrpt->totimer) && (myrpt->callmode == 4))
{
myrpt->callmode = 0;
}
if (totx && (!myrpt->idtimer))
{
myrpt->idtimer = myrpt->idtime;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&myrpt->rpt_id_thread,&attr,rpt_id,(void *) myrpt);
}
if (totx && (!lasttx))
{
lasttx = 1;
ast_indicate(myrpt->txchannel,AST_CONTROL_RADIO_KEY);
}
if ((!totx) && lasttx)
{
lasttx = 0;
ast_indicate(myrpt->txchannel,AST_CONTROL_RADIO_UNKEY);
}
rem_totx = ((keyed && (myrpt->remotemode == REM_TX)) && myrpt->totimer);
if (rem_totx && (!myrpt->remotetx))
{
myrpt->remotetx = 1;
ci.chan = 0;
ci.confno = 0;
ci.confmode = 0;
/* Take off conf */
if (ioctl(myrpt->rem_rxchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
ast_indicate(myrpt->rem_txchannel,AST_CONTROL_RADIO_KEY);
ci.chan = 0;
ci.confno = myrpt->txconf;
ci.confmode = ZT_CONF_CONF | ZT_CONF_LISTENER;
/* Put the channel on the conference in listener mode */
if (ioctl(myrpt->rem_txchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
}
if ((!rem_totx) && myrpt->remotetx)
{
myrpt->remotetx = 0;
ast_indicate(myrpt->rem_txchannel,AST_CONTROL_RADIO_UNKEY);
ci.chan = 0;
ci.confno = 0;
ci.confmode = 0;
/* Take off conf */
if (ioctl(myrpt->rem_txchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
if (myrpt->remotemode != REM_OFF)
{
ci.chan = 0;
ci.confno = myrpt->pconf;
ci.confmode = ZT_CONF_CONF | ZT_CONF_TALKER;
/* Put on conf */
if (ioctl(myrpt->rem_rxchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
}
}
time(&t);
/* if DTMF timeout */
if ((dtmfidx >= 0) && ((dtmf_time + DTMF_TIMEOUT) < t))
{
dtmfidx = -1;
dtmfbuf[0] = 0;
}
n = 0;
cs[n++] = myrpt->rxchannel;
cs[n++] = myrpt->pchannel;
if (myrpt->txchannel != myrpt->rxchannel) cs[n++] = myrpt->txchannel;
if (myrpt->rem_rxchannel)
{
cs[n++] = myrpt->rem_rxchannel;
if (myrpt->rem_txchannel != myrpt->rem_rxchannel)
cs[n++] = myrpt->rem_txchannel;
}
ms = MSWAIT;
who = ast_waitfor_n(cs,n,&ms);
if (who == NULL) ms = 0;
elap = MSWAIT - ms;
if (myrpt->tailtimer) myrpt->tailtimer -= elap;
if (myrpt->tailtimer < 0) myrpt->tailtimer = 0;
if (myrpt->totimer) myrpt->totimer -= elap;
if (myrpt->totimer < 0) myrpt->totimer = 0;
if (myrpt->idtimer) myrpt->idtimer -= elap;
if (myrpt->idtimer < 0) myrpt->idtimer = 0;
if (!ms) continue;
if (who == myrpt->rxchannel) /* if it was a read from rx */
{
f = ast_read(myrpt->rxchannel);
if (!f)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
break;
}
if (f->frametype == AST_FRAME_VOICE)
{
ast_write(myrpt->pchannel,f);
}
else if (f->frametype == AST_FRAME_DTMF)
{
char c;
c = (char) f->subclass; /* get DTMF char */
if (!myrpt->simple)
{
if (c == '*')
{
dtmfidx = 0;
dtmfbuf[dtmfidx] = 0;
time(&dtmf_time);
continue;
}
else if ((c != '#') && (dtmfidx >= 0))
{
time(&dtmf_time);
if (dtmfidx < MAXDTMF)
{
dtmfbuf[dtmfidx++] = c;
dtmfbuf[dtmfidx] = 0;
}
if (dtmfidx == FUNCTION_LEN)
{
process_dtmf(dtmfbuf,myrpt);
dtmfbuf[0] = 0;
dtmfidx = -1;
continue;
}
}
}
else
{
if ((!myrpt->callmode) && (c == '*'))
{
myrpt->callmode = 1;
myrpt->cidx = 0;
myrpt->exten[myrpt->cidx] = 0;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&myrpt->rpt_call_thread,&attr,rpt_call,(void *)myrpt);
continue;
}
}
if (myrpt->callmode && (c == '#'))
{
myrpt->callmode = 0;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&myrpt->rpt_term_thread,&attr,rpt_term,(void *) myrpt);
continue;
}
if (myrpt->callmode == 1)
{
myrpt->exten[myrpt->cidx++] = c;
myrpt->exten[myrpt->cidx] = 0;
/* if this exists */
if (ast_exists_extension(myrpt->pchannel,myrpt->ourcontext,myrpt->exten,1,NULL))
{
myrpt->callmode = 2;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&myrpt->rpt_proc_thread,&attr,rpt_proc,(void *) myrpt);
}
/* if can continue, do so */
if (ast_canmatch_extension(myrpt->pchannel,myrpt->ourcontext,myrpt->exten,1,NULL)) continue;
/* call has failed, inform user */
myrpt->callmode = 4;
continue;
}
if ((myrpt->callmode == 2) || (myrpt->callmode == 3))
{
myrpt->mydtmf = f->subclass;
}
}
else if (f->frametype == AST_FRAME_CONTROL)
{
if (f->subclass == AST_CONTROL_HANGUP)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
ast_frfree(f);
break;
}
/* if RX key */
if (f->subclass == AST_CONTROL_RADIO_KEY)
{
if (debug) printf("@@@@ rx key\n");
keyed = 1;
}
/* if RX un-key */
if (f->subclass == AST_CONTROL_RADIO_UNKEY)
{
if (debug) printf("@@@@ rx un-key\n");
keyed = 0;
if (myrpt->remotemode != REM_OFF)
{
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&myrpt->rpt_proc_thread,&attr,rpt_remote_telemetry,(void *) myrpt);
}
}
}
ast_frfree(f);
continue;
}
if (who == myrpt->pchannel) /* if it was a read from pseudo */
{
f = ast_read(myrpt->pchannel);
if (!f)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
break;
}
if (f->frametype == AST_FRAME_VOICE)
{
ast_write(myrpt->txchannel,f);
if (myrpt->remotemode == REM_TX)
ast_write(myrpt->rem_txchannel,f);
}
if (f->frametype == AST_FRAME_CONTROL)
{
if (f->subclass == AST_CONTROL_HANGUP)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
ast_frfree(f);
break;
}
}
ast_frfree(f);
continue;
}
if (who == myrpt->txchannel) /* if it was a read from tx */
{
f = ast_read(myrpt->txchannel);
if (!f)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
break;
}
if (f->frametype == AST_FRAME_CONTROL)
{
if (f->subclass == AST_CONTROL_HANGUP)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
ast_frfree(f);
break;
}
}
ast_frfree(f);
continue;
}
if (who == myrpt->rem_rxchannel) /* if it was a read from rx */
{
f = ast_read(myrpt->rem_rxchannel);
if (!f)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
break;
}
if (f->frametype == AST_FRAME_CONTROL)
{
if (f->subclass == AST_CONTROL_HANGUP)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
ast_frfree(f);
break;
}
/* if RX key */
if (f->subclass == AST_CONTROL_RADIO_KEY)
{
if (debug) printf("@@@@ remote rx key\n");
if (!myrpt->remotetx)
{
myrpt->remoterx = 1;
ci.chan = 0;
ci.confno = myrpt->pconf;
ci.confmode = ZT_CONF_CONF | ZT_CONF_TALKER;
/* Put on conf */
if (ioctl(myrpt->rem_rxchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
}
}
/* if RX un-key */
if (f->subclass == AST_CONTROL_RADIO_UNKEY)
{
if (debug) printf("@@@@ remote rx un-key\n");
if (!myrpt->remotetx)
{
myrpt->remoterx = 0;
ci.chan = 0;
ci.confno = 0;
ci.confmode = 0;
/* Take off conf */
if (ioctl(myrpt->rem_rxchannel->fds[0],ZT_SETCONF,&ci) == -1)
{
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
pthread_exit(NULL);
}
}
}
}
ast_frfree(f);
continue;
}
if (who == myrpt->rem_txchannel) /* if it was a read from remote tx */
{
f = ast_read(myrpt->rem_txchannel);
if (!f)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
break;
}
if (f->frametype == AST_FRAME_CONTROL)
{
if (f->subclass == AST_CONTROL_HANGUP)
{
if (debug) printf("@@@@ rpt:Hung Up\n");
ast_frfree(f);
break;
}
}
ast_frfree(f);
continue;
}
}
ast_hangup(myrpt->pchannel);
ast_hangup(myrpt->rxchannel);
if (myrpt->txchannel != myrpt->rxchannel) ast_hangup(myrpt->txchannel);
if (myrpt->rem_rxchannel)
{
ast_hangup(myrpt->rem_rxchannel);
if (myrpt->rem_txchannel != myrpt->rem_rxchannel)
ast_hangup(myrpt->rem_txchannel);
}
if (debug) printf("@@@@ rpt:Hung up channel\n");
pthread_exit(NULL);
return NULL;
}
static void *rpt_master(void *ignore)
{
struct ast_config *cfg;
char *this,*val;
int i,n;
/* start with blank config */
memset(&rpt_vars,0,sizeof(rpt_vars));
cfg = ast_load("rpt.conf");
if (!cfg) {
ast_log(LOG_NOTICE, "Unable to open radio repeater configuration rpt.conf. Radio Repeater disabled.\n");
pthread_exit(NULL);
}
/* go thru all the specified repeaters */
this = NULL;
n = 0;
while((this = ast_category_browse(cfg,this)) != NULL)
{
ast_log(LOG_DEBUG,"Loading config for repeater %s\n",this);
rpt_vars[n].name = this;
rpt_vars[n].rxchanname = ast_variable_retrieve(cfg,this,"rxchannel");
rpt_vars[n].txchanname = ast_variable_retrieve(cfg,this,"txchannel");
rpt_vars[n].rem_rxchanname = ast_variable_retrieve(cfg,this,"remote_rxchannel");
rpt_vars[n].rem_txchanname = ast_variable_retrieve(cfg,this,"remote_txchannel");
rpt_vars[n].ourcontext = ast_variable_retrieve(cfg,this,"context");
if (!rpt_vars[n].ourcontext) rpt_vars[n].ourcontext = this;
rpt_vars[n].ourcallerid = ast_variable_retrieve(cfg,this,"callerid");
rpt_vars[n].acctcode = ast_variable_retrieve(cfg,this,"accountcode");
rpt_vars[n].idrecording = ast_variable_retrieve(cfg,this,"idrecording");
val = ast_variable_retrieve(cfg,this,"hangtime");
if (val) rpt_vars[n].hangtime = atoi(val);
else rpt_vars[n].hangtime = HANGTIME;
val = ast_variable_retrieve(cfg,this,"totime");
if (val) rpt_vars[n].totime = atoi(val);
else rpt_vars[n].totime = TOTIME;
val = ast_variable_retrieve(cfg,this,"idtime");
if (val) rpt_vars[n].idtime = atoi(val);
else rpt_vars[n].idtime = IDTIME;
val = ast_variable_retrieve(cfg,this,"simple");
if (val) rpt_vars[n].simple = ast_true(val);
else rpt_vars[n].simple = 0;
rpt_vars[n].tonezone = ast_variable_retrieve(cfg,this,"tonezone");
n++;
}
ast_log(LOG_DEBUG, "Total of %d repeaters configured.\n",n);
/* start em all */
for(i = 0; i < n; i++)
{
if (!rpt_vars[i].rxchanname)
{
ast_log(LOG_WARNING,"Did not specify rxchanname for repeater %s\n",rpt_vars[i].name);
pthread_exit(NULL);
}
if (!rpt_vars[i].idrecording)
{
ast_log(LOG_WARNING,"Did not specify idrecording for repeater %s\n",rpt_vars[i].name);
pthread_exit(NULL);
}
pthread_create(&rpt_vars[i].rpt_id_thread,NULL,rpt,(void *) &rpt_vars[i]);
}
/* wait for first one to die (should be never) */
pthread_join(rpt_vars[0].rpt_id_thread,NULL);
pthread_exit(NULL);
}
int unload_module(void)
{
STANDARD_HANGUP_LOCALUSERS;
return 0;
}
int load_module(void)
{
pthread_create(&rpt_master_thread,NULL,rpt_master,NULL);
return 0;
}
char *description(void)
{
return tdesc;
}
int usecount(void)
{
int res;
STANDARD_USECOUNT(res);
return res;
}
char *key()
{
return ASTERISK_GPL_KEY;
}
View Git Blame Copy Permalink