#define REM_SCANTIME 100
-enum {REM_OFF,REM_MONITOR,REM_TX};
+enum {REM_OFF, REM_MONITOR, REM_TX};
-enum{ID,PROC,TERM,COMPLETE,UNKEY,REMDISC,REMALREADY,REMNOTFOUND,REMGO,
- CONNECTED,CONNFAIL,STATUS,TIMEOUT,ID1, STATS_TIME,
+enum {ID, PROC, TERM, COMPLETE, UNKEY, REMDISC, REMALREADY, REMNOTFOUND, REMGO,
+ CONNECTED, CONNFAIL, STATUS, TIMEOUT, ID1, STATS_TIME,
STATS_VERSION, IDTALKOVER, ARB_ALPHA, TEST_TONE, REV_PATCH,
TAILMSG, MACRO_NOTFOUND, MACRO_BUSY, LASTNODEKEY};
-enum {REM_SIMPLEX,REM_MINUS,REM_PLUS};
+enum {REM_SIMPLEX, REM_MINUS, REM_PLUS};
-enum {REM_LOWPWR,REM_MEDPWR,REM_HIPWR};
+enum {REM_LOWPWR, REM_MEDPWR, REM_HIPWR};
enum {DC_INDETERMINATE, DC_REQ_FLUSH, DC_ERROR, DC_COMPLETE, DC_DOKEY};
enum {DLY_TELEM, DLY_ID, DLY_UNKEY, DLY_CALLTERM};
-enum {REM_MODE_FM,REM_MODE_USB,REM_MODE_LSB,REM_MODE_AM};
+enum {REM_MODE_FM, REM_MODE_USB, REM_MODE_LSB, REM_MODE_AM};
-enum {HF_SCAN_OFF,HF_SCAN_DOWN_SLOW,HF_SCAN_DOWN_QUICK,
- HF_SCAN_DOWN_FAST,HF_SCAN_UP_SLOW,HF_SCAN_UP_QUICK,HF_SCAN_UP_FAST};
+enum {HF_SCAN_OFF, HF_SCAN_DOWN_SLOW, HF_SCAN_DOWN_QUICK,
+ HF_SCAN_DOWN_FAST, HF_SCAN_UP_SLOW, HF_SCAN_UP_QUICK, HF_SCAN_UP_FAST};
#include "asterisk.h"
#include "asterisk/config.h"
#include "asterisk/say.h"
#include "asterisk/localtime.h"
+#include "asterisk/app.h"
static char *app = "Rpt";
static int nrpts = 0;
char *discstr = "!!DISCONNECT!!";
-static char *remote_rig_ft897="ft897";
-static char *remote_rig_rbi="rbi";
+static char *remote_rig_ft897 = "ft897";
+static char *remote_rig_rbi = "rbi";
#ifdef OLD_ASTERISK
STANDARD_LOCAL_USER;
char *remote;
struct {
-
- const char *ourcontext;
- const char *ourcallerid;
- const char *acctcode;
- const char *ident;
- char *tonezone;
+ char ourcontext[80];
+ char ourcallerid[80];
+ char acctcode[21];
+ char ident[80];
+ char tonezone[80];
char simple;
- const char *functions;
- const char *link_functions;
- const char *phone_functions;
- const char *dphone_functions;
- const char *nodes;
+ char functions[80];
+ char link_functions[80];
+ char phone_functions[80];
+ char dphone_functions[80];
+ char nodes[80];
int hangtime;
int totime;
int idtime;
int tailsquashedtime;
int duplex;
int politeid;
- char *tailmessages[500];
- int tailmessagemax;
- const char *memory;
- const char *macro;
- const char *startupmacro;
+ char *tailmsgbuf;
+ AST_DECLARE_APP_ARGS(tailmsg,
+ AST_APP_ARG(msgs)[100];
+ );
+ char memory[80];
+ char macro[80];
+ char startupmacro[80];
int iobase;
char funcchar;
char endchar;
- char nobusyout;
+ char nobusyout;
} p;
struct rpt_link links;
int unkeytocttimer;
char rem_dtmfbuf[MAXDTMF];
char lastdtmfcommand[MAXDTMF];
char cmdnode[50];
- struct ast_channel *rxchannel,*txchannel;
- struct ast_channel *pchannel,*txpchannel, *remchannel;
+ struct ast_channel *rxchannel, *txchannel;
+ struct ast_channel *pchannel, *txpchannel, *remchannel;
struct rpt_tele tele;
- struct timeval lasttv,curtv;
- pthread_t rpt_call_thread,rpt_thread;
- time_t dtmf_time,rem_dtmf_time,dtmf_time_rem;
- int tailtimer,totimer,idtimer,txconf,conf,callmode,cidx,scantimer,tmsgtimer,skedtimer;
- int mustid,tailid;
+ struct timeval lasttv, curtv;
+ pthread_t rpt_call_thread, rpt_thread;
+ time_t dtmf_time, rem_dtmf_time, dtmf_time_rem;
+ int tailtimer, totimer, idtimer, txconf, conf, callmode, cidx, scantimer, tmsgtimer, skedtimer;
+ int mustid, tailid;
int tailevent;
int telemrefcount;
- int dtmfidx,rem_dtmfidx;
- int dailytxtime,dailykerchunks,totalkerchunks,dailykeyups,totalkeyups,timeouts;
+ int dtmfidx, rem_dtmfidx;
+ int dailytxtime, dailykerchunks, totalkerchunks, dailykeyups, totalkeyups, timeouts;
int totalexecdcommands, dailyexecdcommands;
- long retxtimer;
+ long retxtimer;
long long totaltxtime;
char mydtmf;
char exten[AST_MAX_EXTENSION];
- char freq[MAXREMSTR],rxpl[MAXREMSTR],txpl[MAXREMSTR];
+ char freq[MAXREMSTR], rxpl[MAXREMSTR], txpl[MAXREMSTR];
char offset;
char powerlevel;
char txplon;
int tailmessagen;
time_t disgorgetime;
time_t lastthreadrestarttime;
- long macrotimer;
- char lastnodewhichkeyedusup[MAXNODESTR];
+ long macrotimer;
+ char lastnodewhichkeyedusup[MAXNODESTR];
#ifdef __RPT_NOTCH
struct rptfilter
{
- char desc[100];
- float x0;
- float x1;
- float x2;
- float y0;
- float y1;
- float y2;
- float gain;
- float const0;
- float const1;
- float const2;
+ char desc[100];
+ float x0;
+ float x1;
+ float x2;
+ float y0;
+ float y1;
+ float y2;
+ float gain;
+ float const0;
+ float const1;
+ float const2;
} filters[MAXFILTERS];
#endif
#ifdef _MDC_DECODE_H_
#define MAXLOCKTHREAD 100
-#define rpt_mutex_lock(x) _rpt_mutex_lock(x,myrpt,__LINE__)
-#define rpt_mutex_unlock(x) _rpt_mutex_unlock(x,myrpt,__LINE__)
+#define rpt_mutex_lock(x) _rpt_mutex_lock(x, myrpt, __LINE__)
+#define rpt_mutex_unlock(x) _rpt_mutex_unlock(x, myrpt, __LINE__)
struct lockthread
{
static struct lockthread *get_lockthread(pthread_t id)
{
-int i;
+ int i;
- for(i = 0; i < MAXLOCKTHREAD; i++)
- {
- if (lockthreads[i].id == id) return(&lockthreads[i]);
+ for (i = 0; i < MAXLOCKTHREAD; i++) {
+ if (lockthreads[i].id == id)
+ return(&lockthreads[i]);
}
- return(NULL);
+ return NULL;
}
static struct lockthread *put_lockthread(pthread_t id)
{
-int i;
+ int i;
- for(i = 0; i < MAXLOCKTHREAD; i++)
- {
+ for (i = 0; i < MAXLOCKTHREAD; i++) {
if (lockthreads[i].id == id)
return(&lockthreads[i]);
}
- for(i = 0; i < MAXLOCKTHREAD; i++)
- {
- if (!lockthreads[i].id)
- {
+ for (i = 0; i < MAXLOCKTHREAD; i++) {
+ if (!lockthreads[i].id) {
lockthreads[i].lockcount = 0;
lockthreads[i].lastlock = 0;
lockthreads[i].lastunlock = 0;
lockthreads[i].id = id;
- return(&lockthreads[i]);
+ return &lockthreads[i];
}
}
- return(NULL);
+ return NULL;
}
{
struct by_lightning lock_ring_copy[32];
int lock_ring_index_copy;
- int i,j;
+ int i, j;
long long diff;
- char a[100];
+ char a[100] = "";
struct timeval lasttv;
ast_mutex_lock(&locklock);
ast_mutex_unlock(&locklock);
lasttv.tv_sec = lasttv.tv_usec = 0;
- for(i = 0 ; i < 32 ; i++)
- {
+ for (i = 0; i < 32; i++) {
j = (i + lock_ring_index_copy) % 32;
- strftime(a,sizeof(a) - 1,"%m/%d/%Y %H:%M:%S",
+ strftime(a, sizeof(a) - 1, "%m/%d/%Y %H:%M:%S",
localtime(&lock_ring_copy[j].tv.tv_sec));
diff = 0;
- if(lasttv.tv_sec)
- {
- diff = (lock_ring_copy[j].tv.tv_sec - lasttv.tv_sec)
- * 1000000;
+ if (lasttv.tv_sec) {
+ diff = (lock_ring_copy[j].tv.tv_sec - lasttv.tv_sec) * 1000000;
diff += (lock_ring_copy[j].tv.tv_usec - lasttv.tv_usec);
}
lasttv.tv_sec = lock_ring_copy[j].tv.tv_sec;
lasttv.tv_usec = lock_ring_copy[j].tv.tv_usec;
- if (!lock_ring_copy[j].tv.tv_sec) continue;
- if (lock_ring_copy[j].line < 0)
- {
- ast_log(LOG_NOTICE,"LOCKDEBUG [#%d] UNLOCK app_rpt.c:%d node %s pid %x diff %lld us at %s.%06d\n",
- i - 31,-lock_ring_copy[j].line,lock_ring_copy[j].rpt->name,(int) lock_ring_copy[j].lockthread.id,diff,a,(int)lock_ring_copy[j].tv.tv_usec);
- }
- else
- {
- ast_log(LOG_NOTICE,"LOCKDEBUG [#%d] LOCK app_rpt.c:%d node %s pid %x diff %lld us at %s.%06d\n",
- i - 31,lock_ring_copy[j].line,lock_ring_copy[j].rpt->name,(int) lock_ring_copy[j].lockthread.id,diff,a,(int)lock_ring_copy[j].tv.tv_usec);
+ if (!lock_ring_copy[j].tv.tv_sec)
+ continue;
+ if (lock_ring_copy[j].line < 0) {
+ ast_log(LOG_NOTICE, "LOCKDEBUG [#%d] UNLOCK app_rpt.c:%d node %s pid %x diff %lld us at %s.%06d\n",
+ i - 31, -lock_ring_copy[j].line, lock_ring_copy[j].rpt->name,
+ (int) lock_ring_copy[j].lockthread.id, diff, a, (int)lock_ring_copy[j].tv.tv_usec);
+ } else {
+ ast_log(LOG_NOTICE, "LOCKDEBUG [#%d] LOCK app_rpt.c:%d node %s pid %x diff %lld us at %s.%06d\n",
+ i - 31, lock_ring_copy[j].line, lock_ring_copy[j].rpt->name,
+ (int) lock_ring_copy[j].lockthread.id, diff, a, (int)lock_ring_copy[j].tv.tv_usec);
}
}
}
static void _rpt_mutex_lock(ast_mutex_t *lockp, struct rpt *myrpt, int line)
{
-struct lockthread *t;
-pthread_t id;
+ struct lockthread *t;
+ pthread_t id;
id = pthread_self();
ast_mutex_lock(&locklock);
t = put_lockthread(id);
- if (!t)
- {
+ if (!t) {
ast_mutex_unlock(&locklock);
return;
}
- if (t->lockcount)
- {
+ if (t->lockcount) {
int lastline = t->lastlock;
ast_mutex_unlock(&locklock);
- ast_log(LOG_NOTICE,"rpt_mutex_lock: Double lock request line %d node %s pid %x, last lock was line %d\n",line,myrpt->name,(int) t->id,lastline);
+ ast_log(LOG_NOTICE, "rpt_mutex_lock: Double lock request line %d node %s pid %x, last lock was line %d\n",
+ line, myrpt->name, (int) t->id, lastline);
rpt_mutex_spew();
return;
}
t->lockcount = 1;
gettimeofday(&lock_ring[lock_ring_index].tv, NULL);
lock_ring[lock_ring_index].rpt = myrpt;
- memcpy(&lock_ring[lock_ring_index].lockthread,t,sizeof(struct lockthread));
+ memcpy(&lock_ring[lock_ring_index].lockthread, t, sizeof(struct lockthread));
lock_ring[lock_ring_index++].line = line;
- if(lock_ring_index == 32)
+ if (lock_ring_index == 32)
lock_ring_index = 0;
ast_mutex_unlock(&locklock);
ast_mutex_lock(lockp);
static void _rpt_mutex_unlock(ast_mutex_t *lockp, struct rpt *myrpt, int line)
{
-struct lockthread *t;
-pthread_t id;
+ struct lockthread *t;
+ pthread_t id;
id = pthread_self();
ast_mutex_lock(&locklock);
t = put_lockthread(id);
- if (!t)
- {
+ if (!t) {
ast_mutex_unlock(&locklock);
return;
}
- if (!t->lockcount)
- {
+ if (!t->lockcount) {
int lastline = t->lastunlock;
ast_mutex_unlock(&locklock);
- ast_log(LOG_NOTICE,"rpt_mutex_lock: Double un-lock request line %d node %s pid %x, last un-lock was line %d\n",line,myrpt->name,(int) t->id,lastline);
+ ast_log(LOG_NOTICE, "rpt_mutex_lock: Double un-lock request line %d node %s pid %x, last un-lock was line %d\n",
+ line, myrpt->name, (int) t->id, lastline);
rpt_mutex_spew();
return;
}
t->lockcount = 0;
gettimeofday(&lock_ring[lock_ring_index].tv, NULL);
lock_ring[lock_ring_index].rpt = myrpt;
- memcpy(&lock_ring[lock_ring_index].lockthread,t,sizeof(struct lockthread));
+ memcpy(&lock_ring[lock_ring_index].lockthread, t, sizeof(struct lockthread));
lock_ring[lock_ring_index++].line = -line;
- if(lock_ring_index == 32)
+ if (lock_ring_index == 32)
lock_ring_index = 0;
ast_mutex_unlock(&locklock);
ast_mutex_unlock(lockp);
static struct ast_cli_entry cli_rpt[] = {
{ { "rpt", "debug", "level" },
- rpt_do_debug, "Enable app_rpt debugging",
- debug_usage },
-
- { { "rpt", "dump" },
- rpt_do_dump, "Dump app_rpt structs for debugging",
- dump_usage },
-
- { { "rpt", "stats" },
- rpt_do_stats, "Dump node statistics",
- dump_stats },
- { { "rpt", "lstats" },
- rpt_do_lstats, "Dump link statistics",
- dump_lstats },
-
- { { "rpt", "reload" },
- rpt_do_reload, "Reload app_rpt config",
- reload_usage },
-
- { { "rpt", "restart" },
- rpt_do_restart, "Restart app_rpt",
- restart_usage },
+ rpt_do_debug, "Enable app_rpt debugging",
+ debug_usage },
+
+ { { "rpt", "dump" },
+ rpt_do_dump, "Dump app_rpt structs for debugging",
+ dump_usage },
+
+ { { "rpt", "stats" },
+ rpt_do_stats, "Dump node statistics",
+ dump_stats },
+ { { "rpt", "lstats" },
+ rpt_do_lstats, "Dump link statistics",
+ dump_lstats },
+
+ { { "rpt", "reload" },
+ rpt_do_reload, "Reload app_rpt config",
+ reload_usage },
+
+ { { "rpt", "restart" },
+ rpt_do_restart, "Restart app_rpt",
+ restart_usage },
};
/*
static struct telem_defaults tele_defs[] = {
- {"ct1","|t(350,0,100,3072)(500,0,100,3072)(660,0,100,3072)"},
- {"ct2","|t(660,880,150,3072)"},
- {"ct3","|t(440,0,150,3072)"},
- {"ct4","|t(550,0,150,3072)"},
- {"ct5","|t(660,0,150,3072)"},
- {"ct6","|t(880,0,150,3072)"},
- {"ct7","|t(660,440,150,3072)"},
- {"ct8","|t(700,1100,150,3072)"},
- {"remotemon","|t(1600,0,75,2048)"},
- {"remotetx","|t(2000,0,75,2048)(0,0,75,0)(1600,0,75,2048)"},
- {"cmdmode","|t(900,904,200,2048)"},
- {"functcomplete","|t(1000,0,100,2048)(0,0,100,0)(1000,0,100,2048)"}
+ {"ct1", "|t(350,0,100,3072)(500,0,100,3072)(660,0,100,3072)"},
+ {"ct2", "|t(660,880,150,3072)"},
+ {"ct3", "|t(440,0,150,3072)"},
+ {"ct4", "|t(550,0,150,3072)"},
+ {"ct5", "|t(660,0,150,3072)"},
+ {"ct6", "|t(880,0,150,3072)"},
+ {"ct7", "|t(660,440,150,3072)"},
+ {"ct8", "|t(700,1100,150,3072)"},
+ {"remotemon", "|t(1600,0,75,2048)"},
+ {"remotetx", "|t(2000,0,75,2048)(0,0,75,0)(1600,0,75,2048)"},
+ {"cmdmode", "|t(900,904,200,2048)"},
+ {"functcomplete", "|t(1000,0,100,2048)(0,0,100,0)(1000,0,100,2048)"}
} ;
/*
} ;
/*
-* Break up a delimited string into a table of substrings
-*
-* str - delimited string ( will be modified )
-* strp- list of pointers to substrings (this is built by this function), NULL will be placed at end of list
-* limit- maximum number of substrings to process
-*/
-
-
-
-static int finddelim(char *str, char *strp[], int limit)
-{
-int i,l,inquo;
-
- inquo = 0;
- i = 0;
- strp[i++] = str;
- if (!*str)
- {
- strp[0] = 0;
- return(0);
- }
- for(l = 0; *str && (l < limit) ; str++)
- {
- if (*str == QUOTECHR)
- {
- if (inquo)
- {
- *str = 0;
- inquo = 0;
- }
- else
- {
- strp[i - 1] = str + 1;
- inquo = 1;
- }
- }
- if ((*str == DELIMCHR) && (!inquo))
- {
- *str = 0;
- l++;
- strp[i++] = str + 1;
- }
- }
- strp[i] = 0;
- return(i);
-
-}
-
-/*
* Match a keyword in a list, and return index of string plus 1 if there was a match,
* else return 0. If param is passed in non-null, then it will be set to the first character past the match
*/
static int matchkeyword(char *string, char **param, char *keywords[])
{
-int i,ls;
- for( i = 0 ; keywords[i] ; i++){
+ int i, ls;
+ for (i = 0; keywords[i]; i++) {
ls = strlen(keywords[i]);
- if(!ls){
+ if (!ls) {
*param = NULL;
return 0;
}
- if(!strncmp(string, keywords[i], ls)){
- if(param)
+ if (!strncmp(string, keywords[i], ls)) {
+ if (param)
*param = string + ls;
return i + 1;
}
static char *skipchars(char *string, char *charlist)
{
-int i;
- while(*string){
- for(i = 0; charlist[i] ; i++){
- if(*string == charlist[i]){
+ int i;
+ while (*string) {
+ for (i = 0; charlist[i] ; i++) {
+ if (*string == charlist[i]) {
string++;
break;
}
}
- if(!charlist[i])
+ if (!charlist[i])
return string;
}
return string;
static int myatoi(const char *str)
{
-int ret;
+ int ret;
- if (str == NULL) return -1;
+ if (str == NULL)
+ return -1;
/* leave this %i alone, non-base-10 input is useful here */
- if (sscanf(str,"%i",&ret) != 1) return -1;
+ if (sscanf(str, "%i", &ret) != 1)
+ return -1;
return ret;
}
/* rpt filter routine */
static void rpt_filter(struct rpt *myrpt, volatile short *buf, int len)
{
-int i,j;
-struct rptfilter *f;
+ int i, j;
+ struct rptfilter *f;
- for(i = 0; i < len; i++)
- {
- for(j = 0; j < MAXFILTERS; j++)
- {
+ for (i = 0; i < len; i++) {
+ for (j = 0; j < MAXFILTERS; j++) {
f = &myrpt->filters[j];
- if (!*f->desc) continue;
+ if (!*f->desc)
+ continue;
f->x0 = f->x1; f->x1 = f->x2;
- f->x2 = ((float)buf[i]) / f->gain;
- f->y0 = f->y1; f->y1 = f->y2;
- f->y2 = (f->x0 + f->x2) + f->const0 * f->x1
- + (f->const1 * f->y0) + (f->const2 * f->y1);
+ f->x2 = ((float)buf[i]) / f->gain;
+ f->y0 = f->y1; f->y1 = f->y2;
+ f->y2 = (f->x0 + f->x2) + f->const0 * f->x1
+ + (f->const1 * f->y0) + (f->const2 * f->y1);
buf[i] = (short)f->y2;
}
}
#endif
/* Retrieve an int from a config file */
-
-static int retrieve_astcfgint(struct rpt *myrpt,char *category, char *name, int min, int max, int defl)
+static int retrieve_astcfgint(struct rpt *myrpt, const char *category, const char *name, int min, int max, int defl)
{
- const char *var;
- int ret;
-
- var = ast_variable_retrieve(myrpt->cfg, category, name);
- if(var){
- ret = myatoi(var);
- if(ret < min)
- ret = min;
- if(ret > max)
- ret = max;
- }
- else
- ret = defl;
- return ret;
+ const char *var = ast_variable_retrieve(myrpt->cfg, category, name);
+ int ret;
+
+ if (var) {
+ ret = myatoi(var);
+ if (ret < min)
+ ret = min;
+ else if (ret > max)
+ ret = max;
+ } else
+ ret = defl;
+ return ret;
}
-static void load_rpt_vars(int n,int init)
+static void load_rpt_vars(int n, int init)
{
-char *this;
- const char *val;
-int j,longestnode;
-struct ast_variable *vp;
-struct ast_config *cfg;
+ int j;
+ struct ast_variable *vp, *var;
+ struct ast_config *cfg;
#ifdef __RPT_NOTCH
-int i;
-char *strs[100];
+ AST_DECLARE_APP_ARGS(strs,
+ AST_APP_ARG(str)[100];
+ );
#endif
if (option_verbose > 2)
ast_verbose(VERBOSE_PREFIX_3 "%s config for repeater %s\n",
- (init) ? "Loading initial" : "Re-Loading",rpt_vars[n].name);
+ (init) ? "Loading initial" : "Re-Loading", rpt_vars[n].name);
ast_mutex_lock(&rpt_vars[n].lock);
- if (rpt_vars[n].cfg) ast_config_destroy(rpt_vars[n].cfg);
+ if (rpt_vars[n].cfg)
+ ast_config_destroy(rpt_vars[n].cfg);
cfg = ast_config_load("rpt.conf");
if (!cfg) {
ast_mutex_unlock(&rpt_vars[n].lock);
- ast_log(LOG_NOTICE, "Unable to open radio repeater configuration rpt.conf. Radio Repeater disabled.\n");
+ ast_log(LOG_NOTICE, "Unable to open radio repeater configuration rpt.conf. Radio Repeater disabled.\n");
pthread_exit(NULL);
}
- rpt_vars[n].cfg = cfg;
- this = rpt_vars[n].name;
- memset(&rpt_vars[n].p,0,sizeof(rpt_vars[n].p));
- if (init)
- {
+ rpt_vars[n].cfg = cfg;
+ /* Free previously malloc'ed buffer */
+ if (!init && rpt_vars[n].p.tailmsgbuf)
+ ast_free(rpt_vars[n].p.tailmsgbuf);
+ memset(&rpt_vars[n].p, 0, sizeof(rpt_vars[n].p));
+ if (init) {
char *cp;
int savearea = (char *)&rpt_vars[n].p - (char *)&rpt_vars[n];
}
#ifdef __RPT_NOTCH
/* zot out filters stuff */
- memset(&rpt_vars[n].filters,0,sizeof(rpt_vars[n].filters));
+ memset(&rpt_vars[n].filters, 0, sizeof(rpt_vars[n].filters));
#endif
- val = ast_variable_retrieve(cfg,this,"context");
- if (val) rpt_vars[n].p.ourcontext = val;
- else rpt_vars[n].p.ourcontext = this;
- val = ast_variable_retrieve(cfg,this,"callerid");
- if (val) rpt_vars[n].p.ourcallerid = val;
- val = ast_variable_retrieve(cfg,this,"accountcode");
- if (val) rpt_vars[n].p.acctcode = val;
- val = ast_variable_retrieve(cfg,this,"idrecording");
- if (val) rpt_vars[n].p.ident = val;
- val = ast_variable_retrieve(cfg,this,"hangtime");
- if (val) rpt_vars[n].p.hangtime = atoi(val);
- else rpt_vars[n].p.hangtime = HANGTIME;
- val = ast_variable_retrieve(cfg,this,"totime");
- if (val) rpt_vars[n].p.totime = atoi(val);
- else rpt_vars[n].p.totime = TOTIME;
- rpt_vars[n].p.tailmessagetime = retrieve_astcfgint(&rpt_vars[n],this, "tailmessagetime", 0, 2400000, 0);
- rpt_vars[n].p.tailsquashedtime = retrieve_astcfgint(&rpt_vars[n],this, "tailsquashedtime", 0, 2400000, 0);
- rpt_vars[n].p.duplex = retrieve_astcfgint(&rpt_vars[n],this,"duplex",0,4,2);
- rpt_vars[n].p.idtime = retrieve_astcfgint(&rpt_vars[n],this, "idtime", 60000, 2400000, IDTIME); /* Enforce a min max */
- rpt_vars[n].p.politeid = retrieve_astcfgint(&rpt_vars[n],this, "politeid", 30000, 300000, POLITEID); /* Enforce a min max */
- val = ast_variable_retrieve(cfg,this,"tonezone");
- if (val) rpt_vars[n].p.tonezone = ast_strdupa(val);
- rpt_vars[n].p.tailmessages[0] = 0;
- rpt_vars[n].p.tailmessagemax = 0;
- val = ast_variable_retrieve(cfg,this,"tailmessagelist");
- if (val) rpt_vars[n].p.tailmessagemax = finddelim(ast_strdupa(val), rpt_vars[n].p.tailmessages, 500);
- val = ast_variable_retrieve(cfg,this,"memory");
- if (!val) val = MEMORY;
- rpt_vars[n].p.memory = val;
- val = ast_variable_retrieve(cfg,this,"macro");
- if (!val) val = MACRO;
- rpt_vars[n].p.macro = val;
- val = ast_variable_retrieve(cfg,this,"startup_macro");
- if (val) rpt_vars[n].p.startupmacro = val;
- val = ast_variable_retrieve(cfg,this,"iobase");
- /* do not use atoi() here, we need to be able to have
- the input specified in hex or decimal so we use
- sscanf with a %i */
- if ((!val) || (sscanf(val,"%i",&rpt_vars[n].p.iobase) != 1))
+
+ /* Defaults */
+ ast_copy_string(rpt_vars[n].p.ourcontext, rpt_vars[n].name, sizeof(rpt_vars[n].p.ourcontext));
+ rpt_vars[n].p.hangtime = HANGTIME;
+ rpt_vars[n].p.totime = TOTIME;
+ rpt_vars[n].p.duplex = 2;
+ rpt_vars[n].p.idtime = IDTIME;
+ rpt_vars[n].p.politeid = POLITEID;
+ ast_copy_string(rpt_vars[n].p.memory, MEMORY, sizeof(rpt_vars[n].p.memory));
+ ast_copy_string(rpt_vars[n].p.macro, MACRO, sizeof(rpt_vars[n].p.macro));
rpt_vars[n].p.iobase = DEFAULT_IOBASE;
- val = ast_variable_retrieve(cfg,this,"functions");
- if (!val)
- {
- val = FUNCTIONS;
- rpt_vars[n].p.simple = 1;
- }
- rpt_vars[n].p.functions = val;
- val = ast_variable_retrieve(cfg,this,"link_functions");
- if (val) rpt_vars[n].p.link_functions = val;
- else
- rpt_vars[n].p.link_functions = rpt_vars[n].p.functions;
- val = ast_variable_retrieve(cfg,this,"phone_functions");
- if (val) rpt_vars[n].p.phone_functions = val;
- val = ast_variable_retrieve(cfg,this,"dphone_functions");
- if (val) rpt_vars[n].p.dphone_functions = val;
- val = ast_variable_retrieve(cfg,this,"funcchar");
- if (!val) rpt_vars[n].p.funcchar = FUNCCHAR; else
- rpt_vars[n].p.funcchar = *val;
- val = ast_variable_retrieve(cfg,this,"endchar");
- if (!val) rpt_vars[n].p.endchar = ENDCHAR; else
- rpt_vars[n].p.endchar = *val;
- val = ast_variable_retrieve(cfg,this,"nobusyout");
- if (val) rpt_vars[n].p.nobusyout = ast_true(val);
- val = ast_variable_retrieve(cfg,this,"nodes");
- if (!val) val = NODES;
- rpt_vars[n].p.nodes = val;
+ ast_copy_string(rpt_vars[n].p.functions, FUNCTIONS, sizeof(rpt_vars[n].p.functions));
+ rpt_vars[n].p.simple = 1;
+ rpt_vars[n].p.funcchar = FUNCCHAR;
+ rpt_vars[n].p.endchar = ENDCHAR;
+ ast_copy_string(rpt_vars[n].p.nodes, NODES, sizeof(rpt_vars[n].p.nodes));
+
+ for (var = ast_variable_browse(cfg, rpt_vars[n].name); var; var = var->next) {
+ if (!strcmp(var->name, "context")) {
+ ast_copy_string(rpt_vars[n].p.ourcontext, var->value, sizeof(rpt_vars[n].p.ourcontext));
+ } else if (!strcmp(var->name, "callerid")) {
+ ast_copy_string(rpt_vars[n].p.ourcallerid, var->value, sizeof(rpt_vars[n].p.ourcallerid));
+ } else if (!strcmp(var->name, "accountcode")) {
+ ast_copy_string(rpt_vars[n].p.acctcode, var->value, sizeof(rpt_vars[n].p.acctcode));
+ } else if (!strcmp(var->name, "idrecording")) {
+ ast_copy_string(rpt_vars[n].p.ident, var->value, sizeof(rpt_vars[n].p.ident));
+ } else if (!strcmp(var->name, "hangtime")) {
+ rpt_vars[n].p.hangtime = atoi(var->value);
+ } else if (!strcmp(var->name, "totime")) {
+ rpt_vars[n].p.totime = atoi(var->value);
+ } else if (!strcmp(var->name, "tailmessagetime")) {
+ rpt_vars[n].p.tailmessagetime = atoi(var->value);
+ if (rpt_vars[n].p.tailmessagetime < 0)
+ rpt_vars[n].p.tailmessagetime = 0;
+ else if (rpt_vars[n].p.tailmessagetime > 2400000)
+ rpt_vars[n].p.tailmessagetime = 2400000;
+ } else if (!strcmp(var->name, "tailsquashedtime")) {
+ rpt_vars[n].p.tailsquashedtime = atoi(var->value);
+ if (rpt_vars[n].p.tailsquashedtime < 0)
+ rpt_vars[n].p.tailsquashedtime = 0;
+ else if (rpt_vars[n].p.tailsquashedtime > 2400000)
+ rpt_vars[n].p.tailsquashedtime = 2400000;
+ } else if (!strcmp(var->name, "duplex")) {
+ rpt_vars[n].p.duplex = atoi(var->value);
+ if (rpt_vars[n].p.duplex < 0)
+ rpt_vars[n].p.duplex = 0;
+ else if (rpt_vars[n].p.duplex > 4)
+ rpt_vars[n].p.duplex = 4;
+ } else if (!strcmp(var->name, "idtime")) {
+ rpt_vars[n].p.idtime = atoi(var->value);
+ if (rpt_vars[n].p.idtime < 60000)
+ rpt_vars[n].p.idtime = 60000;
+ else if (rpt_vars[n].p.idtime > 2400000)
+ rpt_vars[n].p.idtime = 2400000;
+ } else if (!strcmp(var->name, "politeid")) {
+ rpt_vars[n].p.politeid = atoi(var->value);
+ if (rpt_vars[n].p.politeid < 30000)
+ rpt_vars[n].p.politeid = 30000;
+ else if (rpt_vars[n].p.politeid > 300000)
+ rpt_vars[n].p.politeid = 300000;
+ } else if (!strcmp(var->name, "tonezone")) {
+ ast_copy_string(rpt_vars[n].p.tonezone, var->value, sizeof(rpt_vars[n].p.tonezone));
+ } else if (!strcmp(var->name, "tailmessagelist")) {
+ rpt_vars[n].p.tailmsgbuf = ast_strdup(var->value);
+ AST_NONSTANDARD_APP_ARGS(rpt_vars[n].p.tailmsg, rpt_vars[n].p.tailmsgbuf, ',');
+ } else if (!strcmp(var->name, "memory")) {
+ ast_copy_string(rpt_vars[n].p.memory, var->value, sizeof(rpt_vars[n].p.memory));
+ } else if (!strcmp(var->name, "macro")) {
+ ast_copy_string(rpt_vars[n].p.macro, var->value, sizeof(rpt_vars[n].p.macro));
+ } else if (!strcmp(var->name, "startup_macro")) {
+ ast_copy_string(rpt_vars[n].p.startupmacro, var->value, sizeof(rpt_vars[n].p.startupmacro));
+ } else if (!strcmp(var->name, "iobase")) {
+ /* do not use atoi() here, we need to be able to have
+ the input specified in hex or decimal so we use
+ sscanf with a %i */
+ if (sscanf(var->value, "%i", &rpt_vars[n].p.iobase) != 1)
+ rpt_vars[n].p.iobase = DEFAULT_IOBASE;
+ } else if (!strcmp(var->name, "functions")) {
+ rpt_vars[n].p.simple = 0;
+ ast_copy_string(rpt_vars[n].p.functions, var->value, sizeof(rpt_vars[n].p.functions));
+ } else if (!strcmp(var->name, "link_functions")) {
+ ast_copy_string(rpt_vars[n].p.link_functions, var->value, sizeof(rpt_vars[n].p.link_functions));
+ } else if (!strcmp(var->name, "phone_functions")) {
+ ast_copy_string(rpt_vars[n].p.phone_functions, var->value, sizeof(rpt_vars[n].p.phone_functions));
+ } else if (!strcmp(var->name, "dphone_functions")) {
+ ast_copy_string(rpt_vars[n].p.dphone_functions, var->value, sizeof(rpt_vars[n].p.dphone_functions));
+ } else if (!strcmp(var->name, "funcchar")) {
+ rpt_vars[n].p.funcchar = *var->value;
+ } else if (!strcmp(var->name, "endchar")) {
+ rpt_vars[n].p.endchar = *var->value;
+ } else if (!strcmp(var->name, "nobusyout")) {
+ rpt_vars[n].p.nobusyout = ast_true(var->value);
+ } else if (!strcmp(var->name, "nodes")) {
+ ast_copy_string(rpt_vars[n].p.nodes, var->value, sizeof(rpt_vars[n].p.nodes));
#ifdef __RPT_NOTCH
- val = ast_variable_retrieve(cfg,this,"rxnotch");
- if (val) {
- i = finddelim(ast_strdupa(val),strs,MAXFILTERS * 2);
- i &= ~1; /* force an even number, rounded down */
- if (i >= 2) for(j = 0; j < i; j += 2)
- {
- rpt_mknotch(atof(strs[j]),atof(strs[j + 1]),
- &rpt_vars[n].filters[j >> 1].gain,
- &rpt_vars[n].filters[j >> 1].const0,
- &rpt_vars[n].filters[j >> 1].const1,
- &rpt_vars[n].filters[j >> 1].const2);
- sprintf(rpt_vars[n].filters[j >> 1].desc,"%s Hz, BW = %s",
- strs[j],strs[j + 1]);
+ } else if (!strcmp(var->name, "rxnotch")) {
+ char *tmp = ast_strdupa(val);
+ AST_NONSTANDARD_APP_ARGS(strs, tmp, ',');
+ strs.argc &= ~1; /* force an even number, rounded down */
+ if (strs.argc >= 2) {
+ for (j = 0; j < strs.argc; j += 2) {
+ rpt_mknotch(atof(strs.str[j]),atof(strs.str[j + 1]),
+ &rpt_vars[n].filters[j >> 1].gain,
+ &rpt_vars[n].filters[j >> 1].const0,
+ &rpt_vars[n].filters[j >> 1].const1,
+ &rpt_vars[n].filters[j >> 1].const2);
+ sprintf(rpt_vars[n].filters[j >> 1].desc, "%s Hz, BW = %s",
+ strs.str[j], strs.str[j + 1]);
+ }
+ }
+#endif
}
-
}
-#endif
- longestnode = 0;
- vp = ast_variable_browse(cfg, rpt_vars[n].p.nodes);
-
- while(vp){
- j = strlen(vp->name);
- if (j > longestnode)
- longestnode = j;
- vp = vp->next;
+ /* If these aren't specified, copy them from the functions property. */
+ if (ast_strlen_zero(rpt_vars[n].p.link_functions))
+ ast_copy_string(rpt_vars[n].p.link_functions, rpt_vars[n].p.functions, sizeof(rpt_vars[n].p.link_functions));
+
+ rpt_vars[n].longestnode = 0;
+ for (vp = ast_variable_browse(cfg, rpt_vars[n].p.nodes); vp; vp = vp->next) {
+ if ((j = strlen(vp->name)) > rpt_vars[n].longestnode)
+ rpt_vars[n].longestnode = j;
}
- rpt_vars[n].longestnode = longestnode;
-
/*
* For this repeater, Determine the length of the longest function
*/
rpt_vars[n].longestfunc = 0;
- vp = ast_variable_browse(cfg, rpt_vars[n].p.functions);
- while(vp){
- j = strlen(vp->name);
- if (j > rpt_vars[n].longestfunc)
+ for (vp = ast_variable_browse(cfg, rpt_vars[n].p.functions); vp; vp = vp->next) {
+ if ((j = strlen(vp->name)) > rpt_vars[n].longestfunc)
rpt_vars[n].longestfunc = j;
- vp = vp->next;
}
- /*
- * For this repeater, Determine the length of the longest function
- */
+
rpt_vars[n].link_longestfunc = 0;
- vp = ast_variable_browse(cfg, rpt_vars[n].p.link_functions);
- while(vp){
- j = strlen(vp->name);
- if (j > rpt_vars[n].link_longestfunc)
+ for (vp = ast_variable_browse(cfg, rpt_vars[n].p.link_functions); vp; vp = vp->next) {
+ if ((j = strlen(vp->name)) > rpt_vars[n].link_longestfunc)
rpt_vars[n].link_longestfunc = j;
- vp = vp->next;
}
+
rpt_vars[n].phone_longestfunc = 0;
- if (rpt_vars[n].p.phone_functions)
- {
- vp = ast_variable_browse(cfg, rpt_vars[n].p.phone_functions);
- while(vp){
- j = strlen(vp->name);
- if (j > rpt_vars[n].phone_longestfunc)
- rpt_vars[n].phone_longestfunc = j;
- vp = vp->next;
- }
+ for (vp = ast_variable_browse(cfg, rpt_vars[n].p.phone_functions); vp; vp = vp->next) {
+ if ((j = strlen(vp->name)) > rpt_vars[n].phone_longestfunc)
+ rpt_vars[n].phone_longestfunc = j;
}
+
rpt_vars[n].dphone_longestfunc = 0;
- if (rpt_vars[n].p.dphone_functions)
- {
- vp = ast_variable_browse(cfg, rpt_vars[n].p.dphone_functions);
- while(vp){
- j = strlen(vp->name);
- if (j > rpt_vars[n].dphone_longestfunc)
- rpt_vars[n].dphone_longestfunc = j;
- vp = vp->next;
- }
+ for (vp = ast_variable_browse(cfg, rpt_vars[n].p.dphone_functions); vp; vp = vp->next) {
+ if ((j = strlen(vp->name)) > rpt_vars[n].dphone_longestfunc)
+ rpt_vars[n].dphone_longestfunc = j;
}
+
rpt_vars[n].macro_longest = 1;
- vp = ast_variable_browse(cfg, rpt_vars[n].p.macro);
- while(vp){
- j = strlen(vp->name);
- if (j > rpt_vars[n].macro_longest)
+ for (vp = ast_variable_browse(cfg, rpt_vars[n].p.macro); vp; vp = vp->next) {
+ if ((j = strlen(vp->name)) > rpt_vars[n].macro_longest)
rpt_vars[n].macro_longest = j;
- vp = vp->next;
}
ast_mutex_unlock(&rpt_vars[n].lock);
}
/*
* Enable or disable debug output at a given level at the console
*/
-
static int rpt_do_debug(int fd, int argc, char *argv[])
{
int newlevel;
- if (argc != 4)
- return RESULT_SHOWUSAGE;
- newlevel = myatoi(argv[3]);
- if((newlevel < 0) || (newlevel > 7))
- return RESULT_SHOWUSAGE;
- if(newlevel)
- ast_cli(fd, "app_rpt Debugging enabled, previous level: %d, new level: %d\n", debug, newlevel);
- else
- ast_cli(fd, "app_rpt Debugging disabled\n");
-
- debug = newlevel;
- return RESULT_SUCCESS;
+ if (argc != 4)
+ return RESULT_SHOWUSAGE;
+ newlevel = myatoi(argv[3]);
+ if ((newlevel < 0) || (newlevel > 7))
+ return RESULT_SHOWUSAGE;
+ if (newlevel)
+ ast_cli(fd, "app_rpt Debugging enabled, previous level: %d, new level: %d\n", debug, newlevel);
+ else
+ ast_cli(fd, "app_rpt Debugging disabled\n");
+
+ debug = newlevel;
+ return RESULT_SUCCESS;
}
/*
* Dump rpt struct debugging onto console
*/
-
static int rpt_do_dump(int fd, int argc, char *argv[])
{
int i;
- if (argc != 3)
- return RESULT_SHOWUSAGE;
+ if (argc != 3)
+ return RESULT_SHOWUSAGE;
- for(i = 0; i < nrpts; i++)
- {
- if (!strcmp(argv[2],rpt_vars[i].name))
- {
+ for (i = 0; i < nrpts; i++) {
+ if (!strcmp(argv[2], rpt_vars[i].name)) {
rpt_vars[i].disgorgetime = time(NULL) + 10; /* Do it 10 seconds later */
- ast_cli(fd, "app_rpt struct dump requested for node %s\n",argv[2]);
- return RESULT_SUCCESS;
+ ast_cli(fd, "app_rpt struct dump requested for node %s\n",argv[2]);
+ return RESULT_SUCCESS;
}
}
return RESULT_FAILURE;
/*
* Dump statistics onto console
*/
-
static int rpt_do_stats(int fd, int argc, char *argv[])
{
- int i,j;
+ int i, j;
int dailytxtime, dailykerchunks;
int totalkerchunks, dailykeyups, totalkeyups, timeouts;
int totalexecdcommands, dailyexecdcommands, hours, minutes, seconds;
long long totaltxtime;
- struct rpt_link *l;
+ struct rpt_link *l;
char *listoflinks[MAX_STAT_LINKS];
char *lastnodewhichkeyedusup, *lastdtmfcommand;
char *tot_state, *ider_state, *patch_state;
static char *not_applicable = "N/A";
- if(argc != 3)
+ if (argc != 3)
return RESULT_SHOWUSAGE;
- for(i = 0 ; i <= MAX_STAT_LINKS; i++)
+ for (i = 0 ; i <= MAX_STAT_LINKS; i++)
listoflinks[i] = NULL;
tot_state = ider_state =
input_signal = called_number =
lastdtmfcommand = not_applicable;
- for(i = 0; i < nrpts; i++)
- {
- if (!strcmp(argv[2],rpt_vars[i].name)){
+ for (i = 0; i < nrpts; i++) {
+ if (!strcmp(argv[2], rpt_vars[i].name)) {
/* Make a copy of all stat variables while locked */
myrpt = &rpt_vars[i];
rpt_mutex_lock(&myrpt->lock); /* LOCK */
reverse_patch_state = "DOWN";
j = 0;
l = myrpt->links.next;
- while(l != &myrpt->links){
- if (l->name[0] == '0'){ /* Skip '0' nodes */
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') { /* Skip '0' nodes */
reverse_patch_state = "UP";
l = l->next;
continue;
}
listoflinks[j] = ast_strdupa(l->name);
- if(listoflinks[j])
+ if (listoflinks[j])
j++;
l = l->next;
}
lastnodewhichkeyedusup = ast_strdupa(myrpt->lastnodewhichkeyedusup);
- if((!lastnodewhichkeyedusup) || (!strlen(lastnodewhichkeyedusup)))
+ if ((!lastnodewhichkeyedusup) || (ast_strlen_zero(lastnodewhichkeyedusup)))
lastnodewhichkeyedusup = not_applicable;
- if(myrpt->keyed)
+ if (myrpt->keyed)
input_signal = "YES";
else
input_signal = "NO";
- if(myrpt->enable)
+ if (myrpt->enable)
enable_state = "YES";
else
enable_state = "NO";
- if(!myrpt->totimer)
+ if (!myrpt->totimer)
tot_state = "TIMED OUT!";
- else if(myrpt->totimer != myrpt->p.totime)
+ else if (myrpt->totimer != myrpt->p.totime)
tot_state = "ARMED";
else
tot_state = "RESET";
- if(myrpt->tailid)
+ if (myrpt->tailid)
ider_state = "QUEUED IN TAIL";
- else if(myrpt->mustid)
+ else if (myrpt->mustid)
ider_state = "QUEUED FOR CLEANUP";
else
ider_state = "CLEAN";
- switch(myrpt->callmode){
- case 1:
- patch_state = "DIALING";
- break;
- case 2:
- patch_state = "CONNECTING";
- break;
- case 3:
- patch_state = "UP";
- break;
-
- case 4:
- patch_state = "CALL FAILED";
- break;
-
- default:
- patch_state = "DOWN";
+ switch (myrpt->callmode) {
+ case 1:
+ patch_state = "DIALING";
+ break;
+ case 2:
+ patch_state = "CONNECTING";
+ break;
+ case 3:
+ patch_state = "UP";
+ break;
+ case 4:
+ patch_state = "CALL FAILED";
+ break;
+ default:
+ patch_state = "DOWN";
}
- if(strlen(myrpt->exten)){
+ if (!ast_strlen_zero(myrpt->exten))
called_number = ast_strdupa(myrpt->exten);
- if(!called_number)
- called_number = not_applicable;
- }
- if(strlen(myrpt->lastdtmfcommand)){
+ if (!ast_strlen_zero(myrpt->lastdtmfcommand))
lastdtmfcommand = ast_strdupa(myrpt->lastdtmfcommand);
- if(!lastdtmfcommand)
- lastdtmfcommand = not_applicable;
- }
rpt_mutex_unlock(&myrpt->lock); /* UNLOCK */
ast_cli(fd, "DTMF commands since system initialization........: %d\n", totalexecdcommands);
ast_cli(fd, "Last DTMF command executed.......................: %s\n", lastdtmfcommand);
- hours = dailytxtime/3600000;
+ hours = dailytxtime / 3600000;
dailytxtime %= 3600000;
- minutes = dailytxtime/60000;
+ minutes = dailytxtime / 60000;
dailytxtime %= 60000;
- seconds = dailytxtime/1000;
+ seconds = dailytxtime / 1000;
dailytxtime %= 1000;
ast_cli(fd, "TX time today ...................................: %02d:%02d:%02d.%d\n",
hours, minutes, seconds, dailytxtime);
- hours = (int) totaltxtime/3600000;
+ hours = (int) totaltxtime / 3600000;
totaltxtime %= 3600000;
- minutes = (int) totaltxtime/60000;
+ minutes = (int) totaltxtime / 60000;
totaltxtime %= 60000;
- seconds = (int) totaltxtime/1000;
+ seconds = (int) totaltxtime / 1000;
totaltxtime %= 1000;
ast_cli(fd, "TX time since system initialization..............: %02d:%02d:%02d.%d\n",
hours, minutes, seconds, (int) totaltxtime);
ast_cli(fd, "Nodes currently connected to us..................: ");
- for(j = 0 ;; j++){
- if(!listoflinks[j]){
- if(!j){
- ast_cli(fd,"<NONE>");
+ for (j = 0;; j++) {
+ if (!listoflinks[j]) {
+ if (!j) {
+ ast_cli(fd, "<NONE>");
}
break;
}
ast_cli(fd, "%s", listoflinks[j]);
- if(j % 4 == 3){
+ if (j % 4 == 3) {
ast_cli(fd, "\n");
ast_cli(fd, " : ");
- }
- else{
- if(listoflinks[j + 1])
+ } else {
+ if (listoflinks[j + 1])
ast_cli(fd, ", ");
}
}
- ast_cli(fd,"\n");
+ ast_cli(fd, "\n");
ast_cli(fd, "Last node which transmitted to us................: %s\n", lastnodewhichkeyedusup);
ast_cli(fd, "Autopatch state..................................: %s\n", patch_state);
ast_cli(fd, "Autopatch called number..........................: %s\n", called_number);
ast_cli(fd, "Reverse patch/IAXRPT connected...................: %s\n\n", reverse_patch_state);
- return RESULT_SUCCESS;
+ return RESULT_SUCCESS;
}
}
return RESULT_FAILURE;
/*
* Link stats function
*/
-
static int rpt_do_lstats(int fd, int argc, char *argv[])
{
- int i,j;
+ int i, j;
struct rpt *myrpt;
struct rpt_link *l;
struct rpt_lstat *s,*t;
struct rpt_lstat s_head;
- if(argc != 3)
+ if (argc != 3)
return RESULT_SHOWUSAGE;
s = NULL;
s_head.next = &s_head;
s_head.prev = &s_head;
- for(i = 0; i < nrpts; i++)
- {
- if (!strcmp(argv[2],rpt_vars[i].name)){
+ for (i = 0; i < nrpts; i++) {
+ if (!strcmp(argv[2], rpt_vars[i].name)) {
/* Make a copy of all stat variables while locked */
myrpt = &rpt_vars[i];
rpt_mutex_lock(&myrpt->lock); /* LOCK */
/* Traverse the list of connected nodes */
j = 0;
l = myrpt->links.next;
- while(l != &myrpt->links){
- if (l->name[0] == '0'){ /* Skip '0' nodes */
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') { /* Skip '0' nodes */
l = l->next;
continue;
}
- if((s = (struct rpt_lstat *) malloc(sizeof(struct rpt_lstat))) == NULL){
+ if ((s = (struct rpt_lstat *) ast_calloc(1, sizeof(struct rpt_lstat))) == NULL) {
ast_log(LOG_ERROR, "Malloc failed in rpt_do_lstats\n");
rpt_mutex_unlock(&myrpt->lock); /* UNLOCK */
return RESULT_FAILURE;
}
- memset(s, 0, sizeof(struct rpt_lstat));
- strncpy(s->name, l->name, MAXREMSTR - 1);
+ ast_copy_string(s->name, l->name, MAXREMSTR);
pbx_substitute_variables_helper(l->chan, "${IAXPEER(CURRENTCHANNEL)}", s->peer, MAXPEERSTR - 1);
s->mode = l->mode;
s->outbound = l->outbound;
ast_cli(fd, "NODE PEER RECONNECTS DIRECTION CONNECT TIME\n");
ast_cli(fd, "---- ---- ---------- --------- ------------\n");
- for(s = s_head.next; s != &s_head; s = s->next){
+ for (s = s_head.next; s != &s_head; s = s->next) {
int hours, minutes, seconds;
long long connecttime = s->connecttime;
char conntime[31];
connecttime %= 60000;
seconds = (int) connecttime/1000;
connecttime %= 1000;
- snprintf(conntime, 30, "%02d:%02d:%02d.%d",
+ snprintf(conntime, sizeof(conntime), "%02d:%02d:%02d.%d",
hours, minutes, seconds, (int) connecttime);
- conntime[30] = 0;
ast_cli(fd, "%-10s%-20s%-12d%-11s%-30s\n",
s->name, s->peer, s->reconnects, (s->outbound)? "OUT":"IN", conntime);
}
/* destroy our local link queue */
s = s_head.next;
- while(s != &s_head){
+ while (s != &s_head) {
t = s;
s = s->next;
remque((struct qelem *)t);
- free(t);
+ ast_free(t);
}
return RESULT_SUCCESS;
}
/*
* reload vars
*/
-
static int rpt_do_reload(int fd, int argc, char *argv[])
{
-int n;
+ int n;
- if (argc > 2) return RESULT_SHOWUSAGE;
+ if (argc > 2)
+ return RESULT_SHOWUSAGE;
- for(n = 0; n < nrpts; n++) rpt_vars[n].reload = 1;
+ for (n = 0; n < nrpts; n++)
+ rpt_vars[n].reload = 1;
return RESULT_FAILURE;
}
/*
* restart app_rpt
*/
-
static int rpt_do_restart(int fd, int argc, char *argv[])
{
-int i;
+ int i;
- if (argc > 2) return RESULT_SHOWUSAGE;
- for(i = 0; i < nrpts; i++)
- {
- if (rpt_vars[i].rxchannel) ast_softhangup(rpt_vars[i].rxchannel,AST_SOFTHANGUP_DEV);
+ if (argc > 2)
+ return RESULT_SHOWUSAGE;
+ for (i = 0; i < nrpts; i++) {
+ if (rpt_vars[i].rxchannel)
+ ast_softhangup(rpt_vars[i].rxchannel, AST_SOFTHANGUP_DEV);
}
return RESULT_FAILURE;
}
{
int res;
- if ((res = ast_tonepair_start(chan, f1, f2, duration, amplitude)))
- return res;
-
- while(chan->generatordata) {
- if (ast_safe_sleep(chan,1)) return -1;
+ if ((res = ast_tonepair_start(chan, f1, f2, duration, amplitude)))
+ return res;
+
+ while (chan->generatordata) {
+ if (ast_safe_sleep(chan, 1))
+ return -1;
}
- return 0;
+ return 0;
}
static int play_tone(struct ast_channel *chan, int freq, int duration, int amplitude)
static int send_morse(struct ast_channel *chan, const char *string, int speed, int freq, int amplitude)
{
-static struct morse_bits mbits[] = {
+ static struct morse_bits mbits[] = {
{0, 0}, /* SPACE */
{0, 0},
{6, 18},/* " */
{0, 0},
{6, 12},/* ? */
{0, 0},
- {2, 2}, /* A */
- {4, 1}, /* B */
+ {2, 2}, /* A */
+ {4, 1}, /* B */
{4, 5}, /* C */
{3, 1}, /* D */
{1, 0}, /* E */
{4, 3} /* Z */
};
-
int dottime;
int dashtime;
int intralettertime;
/* Approximate the dot time from the speed arg. */
- dottime = 900/speed;
+ dottime = 900 / speed;
/* Establish timing releationships */
interlettertime = dottime * 4 ;
interwordtime = dottime * 7;
- for(;(*string) && (!res); string++){
+ for (; (*string) && (!res); string++) {
c = *string;
/* Convert lower case to upper case */
- if((c >= 'a') && (c <= 'z'))
+ if ((c >= 'a') && (c <= 'z'))
c -= 0x20;
/* Can't deal with any char code greater than Z, skip it */
- if(c > 'Z')
+ if (c > 'Z')
continue;
/* If space char, wait the inter word time */
- if(c == ' '){
- if(!res)
+ if (c == ' ') {
+ if (!res)
res = play_silence(chan, interwordtime);
continue;
}
/* Send the character */
- for(; len ; len--){
- if(!res)
+ for (; len ; len--) {
+ if (!res)
res = play_tone(chan, freq, (ddcomb & 1) ? dashtime : dottime, amplitude);
- if(!res)
+ if (!res)
res = play_silence(chan, intralettertime);
ddcomb >>= 1;
}
/* Wait the interletter time */
- if(!res)
+ if (!res)
res = play_silence(chan, interlettertime - intralettertime);
}
* Wait for the zaptel driver to physically write the tone blocks to the hardware
*/
- for(i = 0; i < 20 ; i++){
+ for (i = 0; i < 20 ; i++) {
flags = ZT_IOMUX_WRITEEMPTY | ZT_IOMUX_NOWAIT;
res = ioctl(chan->fds[0], ZT_IOMUX, &flags);
- if(flags & ZT_IOMUX_WRITEEMPTY)
+ if (flags & ZT_IOMUX_WRITEEMPTY)
break;
- if( ast_safe_sleep(chan, 50)){
+ if ( ast_safe_sleep(chan, 50)) {
res = -1;
break;
}
{
char *stringp;
char *tonesubset;
- int f1,f2;
+ int f1, f2;
int duration;
int amplitude;
int res;
stringp = ast_strdupa(tonestring);
- for(;tonestring;){
- tonesubset = strsep(&stringp,")");
- if(!tonesubset)
+ for (;tonestring;) {
+ tonesubset = strsep(&stringp, ")");
+ if (!tonesubset)
break;
- if(sscanf(tonesubset,"(%d,%d,%d,%d", &f1, &f2, &duration, &litude) != 4)
+ if (sscanf(tonesubset, "(%d,%d,%d,%d", &f1, &f2, &duration, &litude) != 4)
break;
res = play_tone_pair(chan, f1, f2, duration, amplitude);
- if(res)
+ if (res)
break;
}
- if(!res)
+ if (!res)
res = play_tone_pair(chan, 0, 0, 100, 0); /* This is needed to ensure the last tone segment is timed correctly */
if (!res)
* Wait for the zaptel driver to physically write the tone blocks to the hardware
*/
- for(i = 0; i < 20 ; i++){
+ for (i = 0; i < 20 ; i++) {
flags = ZT_IOMUX_WRITEEMPTY | ZT_IOMUX_NOWAIT;
res = ioctl(chan->fds[0], ZT_IOMUX, &flags);
- if(flags & ZT_IOMUX_WRITEEMPTY)
+ if (flags & ZT_IOMUX_WRITEEMPTY)
break;
- if( ast_safe_sleep(chan, 50)){
+ if (ast_safe_sleep(chan, 50)) {
res = -1;
break;
}
}
return res;
-
}
static int sayfile(struct ast_channel *mychannel, const char *fname)
{
-int res;
+ int res;
res = ast_streamfile(mychannel, fname, mychannel->language);
if (!res)
static int saycharstr(struct ast_channel *mychannel,char *str)
{
-int res;
+ int res;
- res = ast_say_character_str(mychannel,str,NULL,mychannel->language);
+ res = ast_say_character_str(mychannel, str, NULL, mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else
{
int res;
res = ast_say_number(mychannel, num, NULL, mychannel->language, NULL);
- if(!res)
+ if (!res)
+ res = ast_waitstream(mychannel, "");
+ else
+ ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
+ ast_stopstream(mychannel);
+ return res;
+}
+
+static int saydigits(struct ast_channel *mychannel, int num)
+{
+ int res;
+ res = ast_say_digits(mychannel, num, NULL, mychannel->language);
+ if (!res)
res = ast_waitstream(mychannel, "");
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
}
-static int telem_any(struct rpt *myrpt,struct ast_channel *chan, const char *entry)
+static int telem_any(struct rpt *myrpt, struct ast_channel *chan, const char *entry)
{
int res;
char c;
res = 0;
- if(!morseidfreq){ /* Get the morse parameters if not already loaded */
+ if (!morseidfreq) { /* Get the morse parameters if not already loaded */
morsespeed = retrieve_astcfgint(myrpt, mcat, "speed", 5, 20, 20);
- morsefreq = retrieve_astcfgint(myrpt, mcat, "frequency", 300, 3000, 800);
- morseampl = retrieve_astcfgint(myrpt, mcat, "amplitude", 200, 8192, 4096);
+ morsefreq = retrieve_astcfgint(myrpt, mcat, "frequency", 300, 3000, 800);
+ morseampl = retrieve_astcfgint(myrpt, mcat, "amplitude", 200, 8192, 4096);
morseidampl = retrieve_astcfgint(myrpt, mcat, "idamplitude", 200, 8192, 2048);
morseidfreq = retrieve_astcfgint(myrpt, mcat, "idfrequency", 300, 3000, 330);
}
/* Is it a file, or a tone sequence? */
- if(entry[0] == '|'){
+ if (entry[0] == '|') {
c = entry[1];
- if((c >= 'a')&&(c <= 'z'))
+ if ((c >= 'a') && (c <= 'z'))
c -= 0x20;
- switch(c){
- case 'I': /* Morse ID */
- res = send_morse(chan, entry + 2, morsespeed, morseidfreq, morseidampl);
- break;
-
- case 'M': /* Morse Message */
- res = send_morse(chan, entry + 2, morsespeed, morsefreq, morseampl);
- break;
-
- case 'T': /* Tone sequence */
- res = send_tone_telemetry(chan, entry + 2);
- break;
- default:
- res = -1;
+ switch (c) {
+ case 'I': /* Morse ID */
+ res = send_morse(chan, entry + 2, morsespeed, morseidfreq, morseidampl);
+ break;
+ case 'M': /* Morse Message */
+ res = send_morse(chan, entry + 2, morsespeed, morsefreq, morseampl);
+ break;
+ case 'T': /* Tone sequence */
+ res = send_tone_telemetry(chan, entry + 2);
+ break;
+ default:
+ res = -1;
}
- }
- else
+ } else
res = sayfile(chan, entry); /* File */
return res;
}
* 4 types of telemtry are handled: Morse ID, Morse Message, Tone Sequence, and a File containing a recording.
*/
-static int telem_lookup(struct rpt *myrpt,struct ast_channel *chan, char *node, char *name)
+static int telem_lookup(struct rpt *myrpt, struct ast_channel *chan, const char *node, const char *name)
{
-
- int res;
+ int res = 0;
int i;
- const char *entry;
+ const char *entry = NULL;
const char *telemetry;
- char *telemetry_save;
- res = 0;
- telemetry_save = NULL;
- entry = NULL;
-
/* Retrieve the section name for telemetry from the node section */
- telemetry = ast_variable_retrieve(myrpt->cfg, node, TELEMETRY);
- if(telemetry ){
- telemetry_save = ast_strdupa(telemetry);
- if(!telemetry_save){
- ast_log(LOG_WARNING,"ast_strdupa() failed in telem_lookup()\n");
- return res;
- }
- entry = ast_variable_retrieve(myrpt->cfg, telemetry_save, name);
- }
-
+ if ((telemetry = ast_variable_retrieve(myrpt->cfg, node, TELEMETRY)))
+ entry = ast_variable_retrieve(myrpt->cfg, telemetry, name);
+
/* Try to look up the telemetry name */
- if(!entry){
+ if (!entry) {
/* Telemetry name wasn't found in the config file, use the default */
- for(i = 0; i < sizeof(tele_defs)/sizeof(struct telem_defaults) ; i++){
- if(!strcasecmp(tele_defs[i].name, name))
+ for (i = 0; i < sizeof(tele_defs) / sizeof(struct telem_defaults); i++) {
+ if (!strcasecmp(tele_defs[i].name, name))
entry = tele_defs[i].value;
}
}
- if(entry){
- if(strlen(entry))
- telem_any(myrpt,chan, entry);
- }
- else{
+ if (entry) {
+ if (!ast_strlen_zero(entry))
+ telem_any(myrpt, chan, entry);
+ } else {
res = -1;
}
return res;
static int get_wait_interval(struct rpt *myrpt, int type)
{
- int interval;
- const char *wait_times;
- char *wait_times_save = NULL;
-
- wait_times = ast_variable_retrieve(myrpt->cfg, myrpt->name, "wait_times");
-
- if (wait_times) {
- wait_times_save = ast_strdupa(wait_times);
- if (!wait_times_save) {
- ast_log(LOG_WARNING, "Out of memory in wait_interval()\n");
- wait_times = NULL;
- }
- }
+ int interval = 1000;
+ const char *wait_times = ast_variable_retrieve(myrpt->cfg, myrpt->name, "wait_times");
switch (type) {
case DLY_TELEM:
if (wait_times)
- interval = retrieve_astcfgint(myrpt, wait_times_save, "telemwait", 500, 5000, 1000);
- else
- interval = 1000;
+ interval = retrieve_astcfgint(myrpt, wait_times, "telemwait", 500, 5000, 1000);
break;
-
case DLY_ID:
if (wait_times)
- interval = retrieve_astcfgint(myrpt, wait_times_save, "idwait", 250, 5000, 500);
+ interval = retrieve_astcfgint(myrpt, wait_times, "idwait", 250, 5000, 500);
else
interval = 500;
break;
-
case DLY_UNKEY:
if (wait_times)
- interval = retrieve_astcfgint(myrpt, wait_times_save, "unkeywait", 500, 5000, 1000);
- else
- interval = 1000;
+ interval = retrieve_astcfgint(myrpt, wait_times, "unkeywait", 500, 5000, 1000);
break;
-
case DLY_CALLTERM:
if (wait_times)
- interval = retrieve_astcfgint(myrpt, wait_times_save, "calltermwait", 500, 5000, 1500);
- else
- interval = 1500;
+ interval = retrieve_astcfgint(myrpt, wait_times, "calltermwait", 500, 5000, 1500);
break;
-
default:
return 0;
}
{
int interval;
interval = get_wait_interval(myrpt, type);
- if(debug)
- ast_log(LOG_NOTICE," Delay interval = %d\n", interval);
- if(interval)
+ if (debug)
+ ast_log(LOG_NOTICE, " Delay interval = %d\n", interval);
+ if (interval)
ast_safe_sleep(chan,interval);
- if(debug)
- ast_log(LOG_NOTICE,"Delay complete\n");
+ if (debug)
+ ast_log(LOG_NOTICE, "Delay complete\n");
return;
}
static void *rpt_tele_thread(void *this)
{
-ZT_CONFINFO ci; /* conference info */
-int res = 0,haslink,hastx,hasremote,imdone = 0, unkeys_queued, x;
-struct rpt_tele *mytele = (struct rpt_tele *)this;
-struct rpt_tele *tlist;
-struct rpt *myrpt;
-struct rpt_link *l,*m,linkbase;
-struct ast_channel *mychannel;
+ ZT_CONFINFO ci; /* conference info */
+ int res = 0, haslink, hastx, hasremote, imdone = 0, unkeys_queued, x;
+ struct rpt_tele *mytele = (struct rpt_tele *)this;
+ struct rpt_tele *tlist;
+ struct rpt *myrpt;
+ struct rpt_link *l, *m, linkbase;
+ struct ast_channel *mychannel;
const char *p, *ct;
- char *ct_copy, *ident, *nodename;
-time_t t;
-struct tm localtm;
+ time_t t;
+ struct tm localtm;
+#ifdef APP_RPT_LOCK_DEBUG
+ struct lockthread *t;
+#endif
/* get a pointer to myrpt */
myrpt = mytele->rpt;
/* Snag copies of a few key myrpt variables */
rpt_mutex_lock(&myrpt->lock);
- nodename = ast_strdupa(myrpt->name);
- ident = ast_strdupa(myrpt->p.ident);
rpt_mutex_unlock(&myrpt->lock);
/* allocate a pseudo-channel thru asterisk */
- mychannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo",NULL);
- if (!mychannel)
- {
- fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
+ mychannel = ast_request("zap", AST_FORMAT_SLINEAR, "pseudo", NULL);
+ if (!mychannel) {
+ ast_log(LOG_WARNING, "rpt: unable to obtain pseudo channel\n");
rpt_mutex_lock(&myrpt->lock);
remque((struct qelem *)mytele);
- ast_log(LOG_NOTICE,"Telemetry thread aborted at line %d, mode: %d\n",__LINE__, mytele->mode); /*@@@@@@@@@@@*/
+ ast_log(LOG_NOTICE, "Telemetry thread aborted at line %d, mode: %d\n", __LINE__, mytele->mode); /*@@@@@@@@@@@*/
rpt_mutex_unlock(&myrpt->lock);
- free(mytele);
+ ast_free(mytele);
pthread_exit(NULL);
}
rpt_mutex_lock(&myrpt->lock);
myrpt->txconf : myrpt->conf);
ci.confmode = ZT_CONF_CONFANN;
/* first put the channel on the conference in announce mode */
- if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
- {
+ if (ioctl(mychannel->fds[0], ZT_SETCONF, &ci) == -1) {
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
rpt_mutex_lock(&myrpt->lock);
remque((struct qelem *)mytele);
rpt_mutex_unlock(&myrpt->lock);
- ast_log(LOG_NOTICE,"Telemetry thread aborted at line %d, mode: %d\n",__LINE__, mytele->mode); /*@@@@@@@@@@@*/
- free(mytele);
+ ast_log(LOG_NOTICE, "Telemetry thread aborted at line %d, mode: %d\n", __LINE__, mytele->mode); /*@@@@@@@@@@@*/
+ ast_free(mytele);
ast_hangup(mychannel);
pthread_exit(NULL);
}
ast_stopstream(mychannel);
- switch(mytele->mode)
- {
-
- case ID:
- case ID1:
+ switch (mytele->mode) {
+ case ID:
+ case ID1:
/* wait a bit */
wait_interval(myrpt, (mytele->mode == ID) ? DLY_ID : DLY_TELEM,mychannel);
- res = telem_any(myrpt,mychannel, ident);
+ res = telem_any(myrpt, mychannel, myrpt->p.ident);
imdone=1;
break;
- case TAILMSG:
- res = ast_streamfile(mychannel, myrpt->p.tailmessages[myrpt->tailmessagen], mychannel->language);
+ case TAILMSG:
+ res = ast_streamfile(mychannel, myrpt->p.tailmsg.msgs[myrpt->tailmessagen], mychannel->language);
break;
- case IDTALKOVER:
- p = ast_variable_retrieve(myrpt->cfg, nodename, "idtalkover");
- if(p)
- res = telem_any(myrpt,mychannel, p);
- imdone=1;
- break;
-
- case PROC:
+ case IDTALKOVER:
+ p = ast_variable_retrieve(myrpt->cfg, myrpt->name, "idtalkover");
+ if (p)
+ res = telem_any(myrpt, mychannel, p);
+ imdone = 1;
+ break;
+ case PROC:
/* wait a little bit longer */
wait_interval(myrpt, DLY_TELEM, mychannel);
res = telem_lookup(myrpt, mychannel, myrpt->name, "patchup");
- if(res < 0){ /* Then default message */
+ if (res < 0) { /* Then default message */
res = ast_streamfile(mychannel, "rpt/callproceeding", mychannel->language);
}
break;
- case TERM:
+ case TERM:
/* wait a little bit longer */
wait_interval(myrpt, DLY_CALLTERM, mychannel);
res = telem_lookup(myrpt, mychannel, myrpt->name, "patchdown");
- if(res < 0){ /* Then default message */
+ if (res < 0) { /* Then default message */
res = ast_streamfile(mychannel, "rpt/callterminated", mychannel->language);
}
break;
- case COMPLETE:
+ case COMPLETE:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
- res = telem_lookup(myrpt,mychannel, myrpt->name, "functcomplete");
+ res = telem_lookup(myrpt, mychannel, myrpt->name, "functcomplete");
break;
- case MACRO_NOTFOUND:
+ case MACRO_NOTFOUND:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
res = ast_streamfile(mychannel, "rpt/macro_notfound", mychannel->language);
break;
- case MACRO_BUSY:
+ case MACRO_BUSY:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
res = ast_streamfile(mychannel, "rpt/macro_busy", mychannel->language);
break;
- case UNKEY:
- if(myrpt->patchnoct && myrpt->callmode){ /* If no CT during patch configured, then don't send one */
+ case UNKEY:
+ if (myrpt->patchnoct && myrpt->callmode) { /* If no CT during patch configured, then don't send one */
imdone = 1;
break;
}
tlist = myrpt->tele.next;
unkeys_queued = 0;
- if (tlist != &myrpt->tele)
- {
- rpt_mutex_lock(&myrpt->lock);
- while(tlist != &myrpt->tele){
- if (tlist->mode == UNKEY) unkeys_queued++;
- tlist = tlist->next;
- }
- rpt_mutex_unlock(&myrpt->lock);
- }
- if( unkeys_queued > 1){
+ if (tlist != &myrpt->tele) {
+ rpt_mutex_lock(&myrpt->lock);
+ while (tlist != &myrpt->tele) {
+ if (tlist->mode == UNKEY)
+ unkeys_queued++;
+ tlist = tlist->next;
+ }
+ rpt_mutex_unlock(&myrpt->lock);
+ }
+ if (unkeys_queued > 1) {
imdone = 1;
break;
}
/* Wait for the telemetry timer to expire */
/* Periodically check the timer since it can be re-initialized above */
- while(myrpt->unkeytocttimer)
- {
+ while (myrpt->unkeytocttimer) {
int ctint;
- if(myrpt->unkeytocttimer > 100)
+ if (myrpt->unkeytocttimer > 100)
ctint = 100;
else
ctint = myrpt->unkeytocttimer;
ast_safe_sleep(mychannel, ctint);
rpt_mutex_lock(&myrpt->lock);
- if(myrpt->unkeytocttimer < ctint)
+ if (myrpt->unkeytocttimer < ctint)
myrpt->unkeytocttimer = 0;
else
myrpt->unkeytocttimer -= ctint;
* Now, the carrier on the rptr rx should be gone.
* If it re-appeared, then forget about sending the CT
*/
- if(myrpt->keyed){
+ if (myrpt->keyed) {
imdone = 1;
break;
}
hastx = 0;
hasremote = 0;
l = myrpt->links.next;
- if (l != &myrpt->links)
- {
+ if (l != &myrpt->links) {
rpt_mutex_lock(&myrpt->lock);
- while(l != &myrpt->links)
- {
- if (l->name[0] == '0')
- {
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') {
l = l->next;
continue;
}
haslink = 1;
if (l->mode) {
hastx++;
- if (l->isremote) hasremote++;
+ if (l->isremote)
+ hasremote++;
}
l = l->next;
}
rpt_mutex_unlock(&myrpt->lock);
}
- if (haslink)
- {
-
+ if (haslink) {
res = telem_lookup(myrpt,mychannel, myrpt->name, (!hastx) ? "remotemon" : "remotetx");
- if(res)
+ if (res)
ast_log(LOG_WARNING, "telem_lookup:remotexx failed on %s\n", mychannel->name);
-
-
+
/* if in remote cmd mode, indicate it */
- if (myrpt->cmdnode[0])
- {
- ast_safe_sleep(mychannel,200);
- res = telem_lookup(myrpt,mychannel, myrpt->name, "cmdmode");
- if(res)
+ if (myrpt->cmdnode[0]) {
+ ast_safe_sleep(mychannel, 200);
+ res = telem_lookup(myrpt, mychannel, myrpt->name, "cmdmode");
+ if (res)
ast_log(LOG_WARNING, "telem_lookup:cmdmode failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
}
- }
- else if((ct = ast_variable_retrieve(myrpt->cfg, nodename, "unlinkedct"))){ /* Unlinked Courtesy Tone */
- ct_copy = ast_strdupa(ct);
- res = telem_lookup(myrpt,mychannel, myrpt->name, ct_copy);
- if(res)
+ } else if ((ct = ast_variable_retrieve(myrpt->cfg, myrpt->name, "unlinkedct"))) { /* Unlinked Courtesy Tone */
+ res = telem_lookup(myrpt, mychannel, myrpt->name, ct);
+ if (res)
ast_log(LOG_WARNING, "telem_lookup:ctx failed on %s\n", mychannel->name);
}
- if (hasremote && (!myrpt->cmdnode[0]))
- {
+ if (hasremote && (!myrpt->cmdnode[0])) {
/* set for all to hear */
ci.chan = 0;
ci.confno = myrpt->conf;
ci.confmode = ZT_CONF_CONFANN;
/* first put the channel on the conference in announce mode */
- if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
- {
+ if (ioctl(mychannel->fds[0], ZT_SETCONF, &ci) == -1) {
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
rpt_mutex_lock(&myrpt->lock);
remque((struct qelem *)mytele);
rpt_mutex_unlock(&myrpt->lock);
- ast_log(LOG_NOTICE,"Telemetry thread aborted at line %d, mode: %d\n",__LINE__, mytele->mode); /*@@@@@@@@@@@*/
- free(mytele);
+ ast_log(LOG_NOTICE, "Telemetry thread aborted at line %d, mode: %d\n", __LINE__, mytele->mode); /*@@@@@@@@@@@*/
+ ast_free(mytele);
ast_hangup(mychannel);
pthread_exit(NULL);
}
- if((ct = ast_variable_retrieve(myrpt->cfg, nodename, "remotect"))){ /* Unlinked Courtesy Tone */
- ast_safe_sleep(mychannel,200);
- ct_copy = ast_strdupa(ct);
- res = telem_lookup(myrpt,mychannel, myrpt->name, ct_copy);
- if(res)
+ if ((ct = ast_variable_retrieve(myrpt->cfg, myrpt->name, "remotect"))) { /* Unlinked Courtesy Tone */
+ ast_safe_sleep(mychannel, 200);
+ res = telem_lookup(myrpt, mychannel, myrpt->name, ct);
+ if (res)
ast_log(LOG_WARNING, "telem_lookup:ctx failed on %s\n", mychannel->name);
}
}
#ifdef _MDC_DECODE_H_
- if (myrpt->lastunit)
- {
+ if (myrpt->lastunit) {
char mystr[10];
- ast_safe_sleep(mychannel,200);
+ ast_safe_sleep(mychannel, 200);
/* set for all to hear */
ci.chan = 0;
ci.confno = myrpt->txconf;
ci.confmode = ZT_CONF_CONFANN;
/* first put the channel on the conference in announce mode */
- if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1)
- {
+ if (ioctl(mychannel->fds[0],ZT_SETCONF,&ci) == -1) {
ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
rpt_mutex_lock(&myrpt->lock);
remque((struct qelem *)mytele);
rpt_mutex_unlock(&myrpt->lock);
- ast_log(LOG_NOTICE,"Telemetry thread aborted at line %d, mode: %d\n",__LINE__, mytele->mode); /*@@@@@@@@@@@*/
- free(mytele);
+ ast_log(LOG_NOTICE, "Telemetry thread aborted at line %d, mode: %d\n", __LINE__, mytele->mode); /*@@@@@@@@@@@*/
+ ast_free(mytele);
ast_hangup(mychannel);
pthread_exit(NULL);
}
- sprintf(mystr,"%04x",myrpt->lastunit);
+ snprintf(mystr, sizeof(mystr), "%04x", myrpt->lastunit);
myrpt->lastunit = 0;
- ast_say_character_str(mychannel,mystr,NULL,mychannel->language);
+ ast_say_character_str(mychannel, mystr, NULL, mychannel->language);
break;
}
#endif
imdone = 1;
break;
- case REMDISC:
+ case REMDISC:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
res = ast_streamfile(mychannel, "rpt/node", mychannel->language);
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
- ast_say_character_str(mychannel,mytele->mylink.name,NULL,mychannel->language);
+ ast_say_character_str(mychannel, mytele->mylink.name, NULL, mychannel->language);
res = ast_streamfile(mychannel, ((mytele->mylink.connected) ?
"rpt/remote_disc" : "rpt/remote_busy"), mychannel->language);
break;
- case REMALREADY:
+ case REMALREADY:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
res = ast_streamfile(mychannel, "rpt/remote_already", mychannel->language);
break;
- case REMNOTFOUND:
+ case REMNOTFOUND:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
res = ast_streamfile(mychannel, "rpt/remote_notfound", mychannel->language);
break;
- case REMGO:
+ case REMGO:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
res = ast_streamfile(mychannel, "rpt/remote_go", mychannel->language);
break;
- case CONNECTED:
+ case CONNECTED:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
res = ast_streamfile(mychannel, "rpt/node", mychannel->language);
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
- ast_say_character_str(mychannel,mytele->mylink.name,NULL,mychannel->language);
+ ast_say_character_str(mychannel, mytele->mylink.name, NULL, mychannel->language);
res = ast_streamfile(mychannel, "rpt/connected", mychannel->language);
break;
- case CONNFAIL:
+ case CONNFAIL:
res = ast_streamfile(mychannel, "rpt/node", mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
- ast_say_character_str(mychannel,mytele->mylink.name,NULL,mychannel->language);
+ ast_say_character_str(mychannel, mytele->mylink.name, NULL, mychannel->language);
res = ast_streamfile(mychannel, "rpt/connection_failed", mychannel->language);
break;
- case STATUS:
+ case STATUS:
/* wait a little bit */
wait_interval(myrpt, DLY_TELEM, mychannel);
hastx = 0;
rpt_mutex_lock(&myrpt->lock);
/* make our own list of links */
l = myrpt->links.next;
- while(l != &myrpt->links)
- {
- if (l->name[0] == '0')
- {
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') {
l = l->next;
continue;
}
- m = malloc(sizeof(struct rpt_link));
- if (!m)
- {
+ m = ast_malloc(sizeof(struct rpt_link));
+ if (!m) {
ast_log(LOG_WARNING, "Cannot alloc memory on %s\n", mychannel->name);
remque((struct qelem *)mytele);
rpt_mutex_unlock(&myrpt->lock);
- ast_log(LOG_NOTICE,"Telemetry thread aborted at line %d, mode: %d\n",__LINE__, mytele->mode); /*@@@@@@@@@@@*/
- free(mytele);
+ ast_log(LOG_NOTICE, "Telemetry thread aborted at line %d, mode: %d\n", __LINE__, mytele->mode); /*@@@@@@@@@@@*/
+ ast_free(mytele);
ast_hangup(mychannel);
pthread_exit(NULL);
}
- memcpy(m,l,sizeof(struct rpt_link));
+ memcpy(m, l, sizeof(struct rpt_link));
m->next = m->prev = NULL;
- insque((struct qelem *)m,(struct qelem *)linkbase.next);
+ insque((struct qelem *)m, (struct qelem *)linkbase.next);
l = l->next;
}
rpt_mutex_unlock(&myrpt->lock);
res = ast_streamfile(mychannel, "rpt/node", mychannel->language);
- if (!res)
+ if (!res)
res = ast_waitstream(mychannel, "");
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
- ast_say_character_str(mychannel,myrpt->name,NULL,mychannel->language);
+ ast_say_character_str(mychannel, myrpt->name, NULL, mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
- if (myrpt->callmode)
- {
+ if (myrpt->callmode) {
hastx = 1;
res = ast_streamfile(mychannel, "rpt/autopatch_on", mychannel->language);
- if (!res)
+ if (!res)
res = ast_waitstream(mychannel, "");
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
}
l = linkbase.next;
- while(l != &linkbase)
- {
+ while (l != &linkbase) {
hastx = 1;
res = ast_streamfile(mychannel, "rpt/node", mychannel->language);
if (!res)
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
- ast_say_character_str(mychannel,l->name,NULL,mychannel->language);
+ ast_say_character_str(mychannel, l->name, NULL, mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else
ast_stopstream(mychannel);
l = l->next;
}
- if (!hastx)
- {
+ if (!hastx) {
res = ast_streamfile(mychannel, "rpt/repeat_only", mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
}
/* destroy our local link queue */
l = linkbase.next;
- while(l != &linkbase)
- {
+ while (l != &linkbase) {
m = l;
l = l->next;
remque((struct qelem *)m);
- free(m);
+ ast_free(m);
}
imdone = 1;
break;
- case LASTNODEKEY: /* Identify last node which keyed us up */
+ case LASTNODEKEY: /* Identify last node which keyed us up */
rpt_mutex_lock(&myrpt->lock);
- if(myrpt->lastnodewhichkeyedusup)
+ if (myrpt->lastnodewhichkeyedusup)
p = ast_strdupa(myrpt->lastnodewhichkeyedusup); /* Make a local copy of the node name */
else
p = NULL;
rpt_mutex_unlock(&myrpt->lock);
- if(!p){
+ if (!p) {
imdone = 1; /* no node previously keyed us up, or the node which did has been disconnected */
break;
}
imdone = 1;
break;
- case TIMEOUT:
+ case TIMEOUT:
res = ast_streamfile(mychannel, "rpt/node", mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
ast_stopstream(mychannel);
- ast_say_character_str(mychannel,myrpt->name,NULL,mychannel->language);
+ ast_say_character_str(mychannel, myrpt->name, NULL, mychannel->language);
res = ast_streamfile(mychannel, "rpt/timeout", mychannel->language);
break;
- case STATS_TIME:
- wait_interval(myrpt, DLY_TELEM, mychannel); /* Wait a little bit */
+ case STATS_TIME:
+ wait_interval(myrpt, DLY_TELEM, mychannel); /* Wait a little bit */
t = time(NULL);
localtime_r(&t, &localtm);
/* Say the phase of the day is before the time */
- if((localtm.tm_hour >= 0) && (localtm.tm_hour < 12))
+ if ((localtm.tm_hour >= 0) && (localtm.tm_hour < 12))
p = "rpt/goodmorning";
- else if((localtm.tm_hour >= 12) && (localtm.tm_hour < 18))
+ else if ((localtm.tm_hour >= 12) && (localtm.tm_hour < 18))
p = "rpt/goodafternoon";
else
p = "rpt/goodevening";
- if (sayfile(mychannel,p) == -1)
- {
+ if (sayfile(mychannel, p) == -1) {
imdone = 1;
break;
}
/* Say the time is ... */
- if (sayfile(mychannel,"rpt/thetimeis") == -1)
- {
+ if (sayfile(mychannel, "rpt/thetimeis") == -1) {
imdone = 1;
break;
}
/* Say the time */
- res = ast_say_time(mychannel, t, "", mychannel->language);
+ res = ast_say_time(mychannel, t, "", mychannel->language);
if (!res)
res = ast_waitstream(mychannel, "");
ast_stopstream(mychannel);
imdone = 1;
break;
- case STATS_VERSION:
- wait_interval(myrpt, DLY_TELEM, mychannel); /* Wait a little bit */
+ case STATS_VERSION:
+ wait_interval(myrpt, DLY_TELEM, mychannel); /* Wait a little bit */
/* Say "version" */
- if (sayfile(mychannel,"rpt/version") == -1)
- {
+ if (sayfile(mychannel, "rpt/version") == -1) {
imdone = 1;
break;
}
- if(!res) /* Say "X" */
+ if (!res) /* Say "X" */
ast_say_number(mychannel, vmajor, "", mychannel->language, (char *) NULL);
if (!res)
res = ast_waitstream(mychannel, "");
ast_stopstream(mychannel);
- if (saycharstr(mychannel,".") == -1)
- {
+ if (saycharstr(mychannel, ".") == -1) {
imdone = 1;
break;
}
- if(!res) /* Say "Y" */
+ if (!res) /* Say "Y" */
ast_say_number(mychannel, vminor, "", mychannel->language, (char *) NULL);
- if (!res){
+ if (!res) {
res = ast_waitstream(mychannel, "");
ast_stopstream(mychannel);
- }
- else
+ } else
ast_log(LOG_WARNING, "ast_streamfile failed on %s\n", mychannel->name);
imdone = 1;
- break;
- case ARB_ALPHA:
- wait_interval(myrpt, DLY_TELEM, mychannel); /* Wait a little bit */
- if(mytele->param)
- saycharstr(mychannel, mytele->param);
- imdone = 1;
break;
- case REV_PATCH:
- wait_interval(myrpt, DLY_TELEM, mychannel); /* Wait a little bit */
- if(mytele->param) {
-
+ case ARB_ALPHA:
+ wait_interval(myrpt, DLY_TELEM, mychannel); /* Wait a little bit */
+ if (mytele->param)
+ saycharstr(mychannel, mytele->param);
+ imdone = 1;
+ break;
+ case REV_PATCH:
+ wait_interval(myrpt, DLY_TELEM, mychannel); /* Wait a little bit */
+ if (mytele->param) {
/* Parts of this section taken from app_parkandannounce */
char *tpl_working, *tpl_current;
char *tmp[100], *myparm;
- int looptemp=0,i=0, dres = 0;
-
+ int looptemp=0, i = 0, dres = 0;
- tpl_working = strdupa(mytele->param);
- myparm = strsep(&tpl_working,",");
- tpl_current=strsep(&tpl_working, ":");
+ tpl_working = ast_strdupa(mytele->param);
+ myparm = strsep(&tpl_working, ",");
+ tpl_current = strsep(&tpl_working, ":");
- while(tpl_current && looptemp < sizeof(tmp)) {
- tmp[looptemp]=tpl_current;
+ while (tpl_current && looptemp < sizeof(tmp)) {
+ tmp[looptemp] = tpl_current;
looptemp++;
- tpl_current=strsep(&tpl_working,":");
+ tpl_current = strsep(&tpl_working, ":");
}
- for(i=0; i<looptemp; i++) {
- if(!strcmp(tmp[i], "PARKED")) {
+ for (i = 0; i < looptemp; i++) {
+ if (!strcmp(tmp[i], "PARKED")) {
ast_say_digits(mychannel, atoi(myparm), "", mychannel->language);
- } else if(!strcmp(tmp[i], "NODE")) {
+ } else if (!strcmp(tmp[i], "NODE")) {
ast_say_digits(mychannel, atoi(myrpt->name), "", mychannel->language);
} else {
dres = ast_streamfile(mychannel, tmp[i], mychannel->language);
- if(!dres) {
+ if (!dres) {
dres = ast_waitstream(mychannel, "");
} else {
ast_log(LOG_WARNING, "ast_streamfile of %s failed on %s\n", tmp[i], mychannel->name);
}
}
}
- imdone = 1;
+ imdone = 1;
break;
- case TEST_TONE:
+ case TEST_TONE:
imdone = 1;
myrpt->stopgen = 0;
- if ((res = ast_tonepair_start(mychannel, 1004.0, 0, 99999999, 7200.0)))
+ if ((res = ast_tonepair_start(mychannel, 1004.0, 0, 99999999, 7200.0)))
break;
- while(mychannel->generatordata && (!myrpt->stopgen)) {
+ while (mychannel->generatordata && (!myrpt->stopgen)) {
if (ast_safe_sleep(mychannel,1)) break;
- imdone = 1;
- }
+ imdone = 1;
+ }
+ break;
+ default:
break;
- default:
- break;
}
+
myrpt->stopgen = 0;
- if (!imdone)
- {
+ if (!imdone) {
if (!res)
res = ast_waitstream(mychannel, "");
else {
}
ast_stopstream(mychannel);
rpt_mutex_lock(&myrpt->lock);
- if (mytele->mode == TAILMSG)
- {
- if (!res)
- {
+ if (mytele->mode == TAILMSG) {
+ if (!res) {
myrpt->tailmessagen++;
- if(myrpt->tailmessagen >= myrpt->p.tailmessagemax) myrpt->tailmessagen = 0;
- }
- else
- {
+ if (myrpt->tailmessagen >= myrpt->p.tailmsg.argc)
+ myrpt->tailmessagen = 0;
+ } else {
myrpt->tmsgtimer = myrpt->p.tailsquashedtime;
}
}
remque((struct qelem *)mytele);
rpt_mutex_unlock(&myrpt->lock);
- free(mytele);
+ ast_free(mytele);
ast_hangup(mychannel);
#ifdef APP_RPT_LOCK_DEBUG
- {
- struct lockthread *t;
-
- sleep(5);
- ast_mutex_lock(&locklock);
- t = get_lockthread(pthread_self());
- if (t) memset(t,0,sizeof(struct lockthread));
- ast_mutex_unlock(&locklock);
- }
+ sleep(5);
+ ast_mutex_lock(&locklock);
+ t = get_lockthread(pthread_self());
+ if (t)
+ memset(t, 0, sizeof(struct lockthread));
+ ast_mutex_unlock(&locklock);
#endif
pthread_exit(NULL);
}
static void rpt_telemetry(struct rpt *myrpt,int mode, void *data)
{
-struct rpt_tele *tele;
-struct rpt_link *mylink = (struct rpt_link *) data;
-int res;
-pthread_attr_t attr;
+ struct rpt_tele *tele;
+ struct rpt_link *mylink = (struct rpt_link *) data;
+ int res;
+ pthread_attr_t attr;
- tele = malloc(sizeof(struct rpt_tele));
- if (!tele)
- {
+ tele = ast_calloc(1, sizeof(struct rpt_tele));
+ if (!tele) {
ast_log(LOG_WARNING, "Unable to allocate memory\n");
pthread_exit(NULL);
- return;
}
- /* zero it out */
- memset((char *)tele,0,sizeof(struct rpt_tele));
tele->rpt = myrpt;
tele->mode = mode;
rpt_mutex_lock(&myrpt->lock);
- if((mode == CONNFAIL) || (mode == REMDISC) || (mode == CONNECTED)){
- memset(&tele->mylink,0,sizeof(struct rpt_link));
- if (mylink){
- memcpy(&tele->mylink,mylink,sizeof(struct rpt_link));
+ if ((mode == CONNFAIL) || (mode == REMDISC) || (mode == CONNECTED)) {
+ if (mylink) {
+ memcpy(&tele->mylink, mylink, sizeof(struct rpt_link));
}
- }
- else if ((mode == ARB_ALPHA) || (mode == REV_PATCH)) {
- strncpy(tele->param, (char *) data, TELEPARAMSIZE - 1);
- tele->param[TELEPARAMSIZE - 1] = 0;
+ } else if ((mode == ARB_ALPHA) || (mode == REV_PATCH)) {
+ ast_copy_string(tele->param, (char *) data, sizeof(tele->param));
}
insque((struct qelem *)tele, (struct qelem *)myrpt->tele.next);
rpt_mutex_unlock(&myrpt->lock);
- pthread_attr_init(&attr);
- pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
- res = ast_pthread_create(&tele->threadid,&attr,rpt_tele_thread,(void *) tele);
- if(res < 0){
+ pthread_attr_init(&attr);
+ pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
+ res = ast_pthread_create(&tele->threadid, &attr, rpt_tele_thread, (void *) tele);
+ pthread_attr_destroy(&attr);
+ if (res != 0) {
rpt_mutex_lock(&myrpt->lock);
remque((struct qlem *) tele); /* We don't like stuck transmitters, remove it from the queue */
rpt_mutex_unlock(&myrpt->lock);
- ast_log(LOG_WARNING, "Could not create telemetry thread: %s\n",strerror(res));
+ ast_log(LOG_WARNING, "Could not create telemetry thread: %s\n", strerror(res));
}
return;
}
static void *rpt_call(void *this)
{
-ZT_CONFINFO ci; /* conference info */
-struct rpt *myrpt = (struct rpt *)this;
-int res;
-struct ast_frame wf;
-int stopped,congstarted,dialtimer,lastcidx,aborted;
-struct ast_channel *mychannel,*genchannel;
-
+ ZT_CONFINFO ci; /* conference info */
+ struct rpt *myrpt = (struct rpt *)this;
+ int res;
+ struct ast_frame wf;
+ int stopped, congstarted, dialtimer, lastcidx, aborted;
+ struct ast_channel *mychannel, *genchannel;
myrpt->mydtmf = 0;
/* allocate a pseudo-channel thru asterisk */
- mychannel = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo",NULL);
- if (!mychannel)
- {
- fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
+ mychannel = ast_request("zap", AST_FORMAT_SLINEAR, "pseudo", NULL);
+ if (!mychannel) {
+ ast_log(LOG_ERROR, "rpt: unable to obtain pseudo channel\n");
pthread_exit(NULL);
}
ci.chan = 0;
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)
- {
+ 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",NULL);
- if (!genchannel)
- {
- fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
+ genchannel = ast_request("zap", AST_FORMAT_SLINEAR, "pseudo", NULL);
+ if (!genchannel) {
+ ast_log(LOG_ERROR, "rpt: unable to obtain pseudo channel\n");
ast_hangup(mychannel);
pthread_exit(NULL);
}
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)
- {
+ 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->p.tonezone && (tone_zone_set_zone(mychannel->fds[0],myrpt->p.tonezone) == -1))
- {
- ast_log(LOG_WARNING, "Unable to set tone zone %s\n",myrpt->p.tonezone);
+ if (myrpt->p.tonezone && (tone_zone_set_zone(mychannel->fds[0], myrpt->p.tonezone) == -1)) {
+ ast_log(LOG_WARNING, "Unable to set tone zone %s\n", myrpt->p.tonezone);
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
- if (myrpt->p.tonezone && (tone_zone_set_zone(genchannel->fds[0],myrpt->p.tonezone) == -1))
- {
- ast_log(LOG_WARNING, "Unable to set tone zone %s\n",myrpt->p.tonezone);
+ if (myrpt->p.tonezone && (tone_zone_set_zone(genchannel->fds[0], myrpt->p.tonezone) == -1)) {
+ ast_log(LOG_WARNING, "Unable to set tone zone %s\n", myrpt->p.tonezone);
ast_hangup(mychannel);
ast_hangup(genchannel);
myrpt->callmode = 0;
pthread_exit(NULL);
}
/* start dialtone if patchquiet is 0. Special patch modes don't send dial tone */
- if ((!myrpt->patchquiet) && (tone_zone_play_tone(mychannel->fds[0],ZT_TONE_DIALTONE) < 0))
- {
+ if ((!myrpt->patchquiet) && (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);
lastcidx = 0;
aborted = 0;
-
- while ((myrpt->callmode == 1) || (myrpt->callmode == 4))
- {
-
- if((myrpt->patchdialtime)&&(myrpt->callmode == 1)&&(myrpt->cidx != lastcidx)){
+ while ((myrpt->callmode == 1) || (myrpt->callmode == 4)) {
+ if ((myrpt->patchdialtime) && (myrpt->callmode == 1) && (myrpt->cidx != lastcidx)) {
dialtimer = 0;
lastcidx = myrpt->cidx;
}
- if((myrpt->patchdialtime)&&(dialtimer >= myrpt->patchdialtime)){
+ if ((myrpt->patchdialtime) && (dialtimer >= myrpt->patchdialtime)) {
rpt_mutex_lock(&myrpt->lock);
aborted = 1;
myrpt->callmode = 0;
break;
}
- if ((!myrpt->patchquiet) && (!stopped) && (myrpt->callmode == 1) && (myrpt->cidx > 0))
- {
+ if ((!myrpt->patchquiet) && (!stopped) && (myrpt->callmode == 1) && (myrpt->cidx > 0)) {
stopped = 1;
/* stop dial tone */
- tone_zone_play_tone(mychannel->fds[0],-1);
+ tone_zone_play_tone(mychannel->fds[0], -1);
}
- if (myrpt->callmode == 4)
- {
- if(!congstarted){
+ if (myrpt->callmode == 4) {
+ if (!congstarted) {
congstarted = 1;
/* start congestion tone */
- tone_zone_play_tone(mychannel->fds[0],ZT_TONE_CONGESTION);
+ tone_zone_play_tone(mychannel->fds[0], ZT_TONE_CONGESTION);
}
}
res = ast_safe_sleep(mychannel, MSWAIT);
- if (res < 0)
- {
+ if (res < 0) {
ast_hangup(mychannel);
ast_hangup(genchannel);
rpt_mutex_lock(&myrpt->lock);
dialtimer += MSWAIT;
}
/* stop any tone generation */
- tone_zone_play_tone(mychannel->fds[0],-1);
+ tone_zone_play_tone(mychannel->fds[0], -1);
/* end if done */
- if (!myrpt->callmode)
- {
+ if (!myrpt->callmode) {
ast_hangup(mychannel);
ast_hangup(genchannel);
rpt_mutex_lock(&myrpt->lock);
myrpt->callmode = 0;
rpt_mutex_unlock(&myrpt->lock);
- if((!myrpt->patchquiet) && aborted)
+ if ((!myrpt->patchquiet) && aborted)
rpt_telemetry(myrpt, TERM, NULL);
pthread_exit(NULL);
}
- if (myrpt->p.ourcallerid && *myrpt->p.ourcallerid){
+ if (myrpt->p.ourcallerid && *myrpt->p.ourcallerid) {
char *name, *loc, *instr;
- instr = strdup(myrpt->p.ourcallerid);
- if(instr){
+ instr = ast_strdup(myrpt->p.ourcallerid);
+ if (instr) {
ast_callerid_parse(instr, &name, &loc);
- if(loc){
- if(mychannel->cid.cid_num)
- free(mychannel->cid.cid_num);
- mychannel->cid.cid_num = strdup(loc);
+ if (loc) {
+ if (mychannel->cid.cid_num)
+ ast_free(mychannel->cid.cid_num);
+ mychannel->cid.cid_num = ast_strdup(loc);
}
- if(name){
- if(mychannel->cid.cid_name)
- free(mychannel->cid.cid_name);
- mychannel->cid.cid_name = strdup(name);
+ if (name) {
+ if (mychannel->cid.cid_name)
+ ast_free(mychannel->cid.cid_name);
+ mychannel->cid.cid_name = ast_strdup(name);
}
- free(instr);
+ ast_free(instr);
}
}
- strncpy(mychannel->exten, myrpt->exten, sizeof(mychannel->exten) - 1);
- strncpy(mychannel->context, myrpt->patchcontext, sizeof(mychannel->context) - 1);
+ ast_copy_string(mychannel->exten, myrpt->exten, sizeof(mychannel->exten));
+ ast_copy_string(mychannel->context, myrpt->patchcontext, sizeof(mychannel->context));
if (myrpt->p.acctcode)
- strncpy((char *)mychannel->accountcode, myrpt->p.acctcode, sizeof(mychannel->accountcode) - 1);
+ ast_copy_string((char *)mychannel->accountcode, myrpt->p.acctcode, sizeof(mychannel->accountcode));
mychannel->priority = 1;
ast_channel_undefer_dtmf(mychannel);
- if (ast_pbx_start(mychannel) < 0)
- {
+ if (ast_pbx_start(mychannel) < 0) {
ast_log(LOG_WARNING, "Unable to start PBX!!\n");
ast_hangup(mychannel);
ast_hangup(genchannel);
ci.confmode = (myrpt->p.duplex == 2) ? ZT_CONF_CONFANNMON :
(ZT_CONF_CONF | ZT_CONF_LISTENER | ZT_CONF_TALKER);
/* first put the channel on the conference in announce mode */
- if (ioctl(myrpt->pchannel->fds[0],ZT_SETCONF,&ci) == -1)
- {
+ if (ioctl(myrpt->pchannel->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);
}
- while(myrpt->callmode)
- {
- if ((!mychannel->pbx) && (myrpt->callmode != 4))
- {
- if(myrpt->patchfarenddisconnect){ /* If patch is setup for far end disconnect */
+ while (myrpt->callmode) {
+ if ((!mychannel->pbx) && (myrpt->callmode != 4)) {
+ if (myrpt->patchfarenddisconnect) { /* If patch is setup for far end disconnect */
myrpt->callmode = 0;
- if(!myrpt->patchquiet){
+ if (!myrpt->patchquiet) {
rpt_mutex_unlock(&myrpt->lock);
rpt_telemetry(myrpt, TERM, NULL);
rpt_mutex_lock(&myrpt->lock);
}
- }
- else{ /* Send congestion until patch is downed by command */
+ } else { /* Send congestion until patch is downed by command */
myrpt->callmode = 4;
rpt_mutex_unlock(&myrpt->lock);
/* start congestion tone */
- tone_zone_play_tone(genchannel->fds[0],ZT_TONE_CONGESTION);
+ tone_zone_play_tone(genchannel->fds[0], ZT_TONE_CONGESTION);
rpt_mutex_lock(&myrpt->lock);
}
}
- if (myrpt->mydtmf)
- {
+ if (myrpt->mydtmf) {
wf.frametype = AST_FRAME_DTMF;
wf.subclass = myrpt->mydtmf;
wf.offset = 0;
wf.datalen = 0;
wf.samples = 0;
rpt_mutex_unlock(&myrpt->lock);
- ast_write(genchannel,&wf);
+ ast_write(genchannel, &wf);
rpt_mutex_lock(&myrpt->lock);
myrpt->mydtmf = 0;
}
rpt_mutex_lock(&myrpt->lock);
}
rpt_mutex_unlock(&myrpt->lock);
- tone_zone_play_tone(genchannel->fds[0],-1);
- if (mychannel->pbx) ast_softhangup(mychannel,AST_SOFTHANGUP_DEV);
+ tone_zone_play_tone(genchannel->fds[0], -1);
+ if (mychannel->pbx)
+ ast_softhangup(mychannel, AST_SOFTHANGUP_DEV);
ast_hangup(genchannel);
rpt_mutex_lock(&myrpt->lock);
myrpt->callmode = 0;
ci.confmode = ((myrpt->p.duplex == 2) || (myrpt->p.duplex == 4)) ? ZT_CONF_CONFANNMON :
(ZT_CONF_CONF | ZT_CONF_LISTENER | ZT_CONF_TALKER);
/* first put the channel on the conference in announce mode */
- if (ioctl(myrpt->pchannel->fds[0],ZT_SETCONF,&ci) == -1)
- {
+ 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);
static void send_link_dtmf(struct rpt *myrpt,char c)
{
-char str[300];
-struct ast_frame wf;
-struct rpt_link *l;
+ char str[300];
+ struct ast_frame wf;
+ struct rpt_link *l;
snprintf(str, sizeof(str), "D %s %s %d %c", myrpt->cmdnode, myrpt->name, ++(myrpt->dtmfidx), c);
wf.frametype = AST_FRAME_TEXT;
wf.samples = 0;
l = myrpt->links.next;
/* first, see if our dude is there */
- while(l != &myrpt->links)
- {
- if (l->name[0] == '0')
- {
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') {
l = l->next;
continue;
}
/* if we found it, write it and were done */
- if (!strcmp(l->name,myrpt->cmdnode))
- {
- wf.data = strdup(str);
- if (l->chan) ast_write(l->chan,&wf);
+ if (!strcmp(l->name,myrpt->cmdnode)) {
+ wf.data = ast_strdup(str);
+ if (l->chan)
+ ast_write(l->chan,&wf);
return;
}
l = l->next;
}
l = myrpt->links.next;
/* if not, give it to everyone */
- while(l != &myrpt->links)
- {
- wf.data = strdup(str);
- if (l->chan) ast_write(l->chan,&wf);
+ while (l != &myrpt->links) {
+ wf.data = ast_strdup(str);
+ if (l->chan)
+ ast_write(l->chan, &wf);
l = l->next;
}
return;
static int function_ilink(struct rpt *myrpt, char *param, char *digits, int command_source, struct rpt_link *mylink)
{
-
const char *val;
- char *s, *s1, *s2, *tele;
- char tmp[300], deststr[300] = "",modechange = 0;
+ char *s, *tele;
+ char deststr[300] = "", modechange = 0;
char digitbuf[MAXNODESTR];
struct rpt_link *l;
int reconnects = 0;
ZT_CONFINFO ci; /* conference info */
+ AST_DECLARE_APP_ARGS(args,
+ AST_APP_ARG(s1);
+ AST_APP_ARG(s2); /* XXX Never used. Scratch? XXX */
+ );
- if(!param)
+ if (!param)
return DC_ERROR;
-
-
+
if (!myrpt->enable)
return DC_ERROR;
- strncpy(digitbuf,digits,MAXNODESTR - 1);
+ ast_copy_string(digitbuf, digits, sizeof(digitbuf));
- if(debug)
- printf("@@@@ ilink param = %s, digitbuf = %s\n", (param)? param : "(null)", digitbuf);
-
- switch(myatoi(param)){
- case 1: /* Link off */
- if ((digitbuf[0] == '0') && (myrpt->lastlinknode[0]))
- strcpy(digitbuf,myrpt->lastlinknode);
- val = ast_variable_retrieve(myrpt->cfg, myrpt->p.nodes, digitbuf);
- if (!val){
- if(strlen(digitbuf) >= myrpt->longestnode)
- return DC_ERROR;
- break;
- }
- strncpy(tmp,val,sizeof(tmp) - 1);
- s = tmp;
- s1 = strsep(&s,",");
- s2 = strsep(&s,",");
- rpt_mutex_lock(&myrpt->lock);
- l = myrpt->links.next;
- /* try to find this one in queue */
- while(l != &myrpt->links){
- if (l->name[0] == '0')
- {
- l = l->next;
- continue;
- }
- /* if found matching string */
- if (!strcmp(l->name, digitbuf))
- break;
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ ilink param = %s, digitbuf = %s\n", S_OR(param, "(null)"), digitbuf);
+
+ switch (myatoi(param)) {
+ case 1: /* Link off */
+ if ((digitbuf[0] == '0') && (myrpt->lastlinknode[0]))
+ strcpy(digitbuf, myrpt->lastlinknode);
+ val = ast_variable_retrieve(myrpt->cfg, myrpt->p.nodes, digitbuf);
+ if (!val) {
+ if (strlen(digitbuf) >= myrpt->longestnode)
+ return DC_ERROR;
+ break;
+ }
+ rpt_mutex_lock(&myrpt->lock);
+ l = myrpt->links.next;
+ /* try to find this one in queue */
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') {
l = l->next;
+ continue;
}
- if (l != &myrpt->links){ /* if found */
- struct ast_frame wf;
- strncpy(myrpt->lastlinknode,digitbuf,MAXNODESTR - 1);
- l->retries = MAX_RETRIES + 1;
- l->disced = 1;
- rpt_mutex_unlock(&myrpt->lock);
- wf.frametype = AST_FRAME_TEXT;
- wf.subclass = 0;
- wf.offset = 0;
- wf.mallocd = 1;
- wf.datalen = strlen(discstr) + 1;
- wf.samples = 0;
- wf.data = strdup(discstr);
- if (l->chan)
- {
- ast_write(l->chan,&wf);
- if (ast_safe_sleep(l->chan,250) == -1) return DC_ERROR;
- ast_softhangup(l->chan,AST_SOFTHANGUP_DEV);
- }
- rpt_telemetry(myrpt, COMPLETE, NULL);
- return DC_COMPLETE;
- }
- rpt_mutex_unlock(&myrpt->lock);
- return DC_COMPLETE;
- case 2: /* Link Monitor */
- if ((digitbuf[0] == '0') && (myrpt->lastlinknode[0]))
- strcpy(digitbuf,myrpt->lastlinknode);
- val = ast_variable_retrieve(myrpt->cfg, myrpt->p.nodes, digitbuf);
- if (!val){
- if(strlen(digitbuf) >= myrpt->longestnode)
- return DC_ERROR;
+ /* if found matching string */
+ if (!strcmp(l->name, digitbuf))
break;
- }
- strncpy(tmp,val,sizeof(tmp) - 1);
- s = tmp;
- s1 = strsep(&s,",");
- s2 = strsep(&s,",");
- rpt_mutex_lock(&myrpt->lock);
- l = myrpt->links.next;
- /* try to find this one in queue */
- while(l != &myrpt->links){
- if (l->name[0] == '0')
- {
- l = l->next;
- continue;
- }
- /* if found matching string */
- if (!strcmp(l->name, digitbuf))
- break;
- l = l->next;
- }
- /* if found */
- if (l != &myrpt->links)
- {
- /* if already in this mode, just ignore */
- if ((!l->mode) || (!l->chan)) {
- rpt_mutex_unlock(&myrpt->lock);
- rpt_telemetry(myrpt,REMALREADY,NULL);
- return DC_COMPLETE;
-
- }
- reconnects = l->reconnects;
- rpt_mutex_unlock(&myrpt->lock);
- if (l->chan) ast_softhangup(l->chan,AST_SOFTHANGUP_DEV);
- l->retries = MAX_RETRIES + 1;
- l->disced = 2;
- modechange = 1;
- } else
- rpt_mutex_unlock(&myrpt->lock);
- strncpy(myrpt->lastlinknode,digitbuf,MAXNODESTR - 1);
- /* establish call in monitor mode */
- l = malloc(sizeof(struct rpt_link));
- if (!l){
- ast_log(LOG_WARNING, "Unable to malloc\n");
- return DC_ERROR;
- }
- /* zero the silly thing */
- memset((char *)l,0,sizeof(struct rpt_link));
- snprintf(deststr, sizeof(deststr), "IAX2/%s", s1);
- tele = strchr(deststr,'/');
- if (!tele){
- fprintf(stderr,"link2:Dial number (%s) must be in format tech/number\n",deststr);
- return DC_ERROR;
- }
- *tele++ = 0;
- l->isremote = (s && ast_true(s));
- strncpy(l->name, digitbuf, MAXNODESTR - 1);
- l->chan = ast_request(deststr,AST_FORMAT_SLINEAR,tele,NULL);
- if (modechange) l->connected = 1;
- if (l->chan){
- ast_set_read_format(l->chan,AST_FORMAT_SLINEAR);
- ast_set_write_format(l->chan,AST_FORMAT_SLINEAR);
- l->chan->whentohangup = 0;
- l->chan->appl = "Apprpt";
- l->chan->data = "(Remote Rx)";
- if (option_verbose > 2)
- ast_verbose(VERBOSE_PREFIX_3 "rpt (remote) initiating call to %s/%s on %s\n",
- deststr,tele,l->chan->name);
- if(l->chan->cid.cid_num)
- free(l->chan->cid.cid_num);
- l->chan->cid.cid_num = strdup(myrpt->name);
- ast_call(l->chan,tele,0);
- }
- else
- {
- rpt_telemetry(myrpt,CONNFAIL,l);
- free(l);
- if (option_verbose > 2)
- ast_verbose(VERBOSE_PREFIX_3 "Unable to place call to %s/%s on %s\n",
- deststr,tele,l->chan->name);
- return DC_ERROR;
- }
- /* allocate a pseudo-channel thru asterisk */
- l->pchan = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo",NULL);
- if (!l->pchan){
- fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
- ast_hangup(l->chan);
- free(l);
- return DC_ERROR;
- }
- ast_set_read_format(l->pchan,AST_FORMAT_SLINEAR);
- ast_set_write_format(l->pchan,AST_FORMAT_SLINEAR);
- /* make a conference for the pseudo-one */
- ci.chan = 0;
- ci.confno = myrpt->conf;
- ci.confmode = ZT_CONF_CONF | ZT_CONF_LISTENER | ZT_CONF_TALKER;
- /* first put the channel on the conference in proper mode */
- if (ioctl(l->pchan->fds[0],ZT_SETCONF,&ci) == -1)
- {
- ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
- ast_hangup(l->chan);
- ast_hangup(l->pchan);
- free(l);
- return DC_ERROR;
- }
- rpt_mutex_lock(&myrpt->lock);
- l->reconnects = reconnects;
- /* insert at end of queue */
- insque((struct qelem *)l,(struct qelem *)myrpt->links.next);
+ l = l->next;
+ }
+ if (l != &myrpt->links) { /* if found */
+ struct ast_frame wf;
+ ast_copy_string(myrpt->lastlinknode, digitbuf, MAXNODESTR);
+ l->retries = MAX_RETRIES + 1;
+ l->disced = 1;
rpt_mutex_unlock(&myrpt->lock);
- rpt_telemetry(myrpt,COMPLETE,NULL);
- return DC_COMPLETE;
- case 3: /* Link transceive */
- if ((digitbuf[0] == '0') && (myrpt->lastlinknode[0]))
- strcpy(digitbuf,myrpt->lastlinknode);
- val = ast_variable_retrieve(myrpt->cfg, myrpt->p.nodes, digitbuf);
- if (!val){
- if(strlen(digitbuf) >= myrpt->longestnode)
+ wf.frametype = AST_FRAME_TEXT;
+ wf.subclass = 0;
+ wf.offset = 0;
+ wf.mallocd = 1;
+ wf.datalen = strlen(discstr) + 1;
+ wf.samples = 0;
+ wf.data = ast_strdup(discstr);
+ if (l->chan) {
+ ast_write(l->chan, &wf);
+ if (ast_safe_sleep(l->chan, 250) == -1)
return DC_ERROR;
- break;
+ ast_softhangup(l->chan, AST_SOFTHANGUP_DEV);
}
- strncpy(tmp,val,sizeof(tmp) - 1);
- s = tmp;
- s1 = strsep(&s,",");
- s2 = strsep(&s,",");
- rpt_mutex_lock(&myrpt->lock);
- l = myrpt->links.next;
- /* try to find this one in queue */
- while(l != &myrpt->links){
- if (l->name[0] == '0')
- {
- l = l->next;
- continue;
- }
- /* if found matching string */
- if (!strcmp(l->name, digitbuf))
- break;
+ rpt_telemetry(myrpt, COMPLETE, NULL);
+ return DC_COMPLETE;
+ }
+ rpt_mutex_unlock(&myrpt->lock);
+ return DC_COMPLETE;
+ case 2: /* Link Monitor */
+ if ((digitbuf[0] == '0') && (myrpt->lastlinknode[0]))
+ strcpy(digitbuf, myrpt->lastlinknode);
+ val = ast_variable_retrieve(myrpt->cfg, myrpt->p.nodes, digitbuf);
+ if (!val) {
+ if (strlen(digitbuf) >= myrpt->longestnode)
+ return DC_ERROR;
+ break;
+ }
+ s = ast_strdupa(val);
+ AST_NONSTANDARD_APP_ARGS(args, s, ',');
+ rpt_mutex_lock(&myrpt->lock);
+ l = myrpt->links.next;
+ /* try to find this one in queue */
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') {
l = l->next;
+ continue;
}
- /* if found */
- if (l != &myrpt->links){
- /* if already in this mode, just ignore */
- if ((l->mode) || (!l->chan)) {
- rpt_mutex_unlock(&myrpt->lock);
- rpt_telemetry(myrpt, REMALREADY, NULL);
- return DC_COMPLETE;
- }
- reconnects = l->reconnects;
- rpt_mutex_unlock(&myrpt->lock);
- if (l->chan) ast_softhangup(l->chan, AST_SOFTHANGUP_DEV);
- l->retries = MAX_RETRIES + 1;
- l->disced = 2;
- modechange = 1;
- } else
+ /* if found matching string */
+ if (!strcmp(l->name, digitbuf))
+ break;
+ l = l->next;
+ }
+ /* if found */
+ if (l != &myrpt->links) {
+ /* if already in this mode, just ignore */
+ if ((!l->mode) || (!l->chan)) {
rpt_mutex_unlock(&myrpt->lock);
- strncpy(myrpt->lastlinknode,digitbuf,MAXNODESTR - 1);
- /* establish call in tranceive mode */
- l = malloc(sizeof(struct rpt_link));
- if (!l){
- ast_log(LOG_WARNING, "Unable to malloc\n");
- return(DC_ERROR);
- }
- /* zero the silly thing */
- memset((char *)l,0,sizeof(struct rpt_link));
- l->mode = 1;
- l->outbound = 1;
- strncpy(l->name, digitbuf, MAXNODESTR - 1);
- l->isremote = (s && ast_true(s));
- if (modechange) l->connected = 1;
- snprintf(deststr, sizeof(deststr), "IAX2/%s", s1);
- tele = strchr(deststr, '/');
- if (!tele){
- fprintf(stderr,"link3:Dial number (%s) must be in format tech/number\n",deststr);
- free(l);
- return DC_ERROR;
- }
- *tele++ = 0;
- l->chan = ast_request(deststr, AST_FORMAT_SLINEAR, tele,NULL);
- if (l->chan){
- ast_set_read_format(l->chan, AST_FORMAT_SLINEAR);
- ast_set_write_format(l->chan, AST_FORMAT_SLINEAR);
- l->chan->whentohangup = 0;
- l->chan->appl = "Apprpt";
- l->chan->data = "(Remote Rx)";
- if (option_verbose > 2)
- ast_verbose(VERBOSE_PREFIX_3 "rpt (remote) initiating call to %s/%s on %s\n",
- deststr, tele, l->chan->name);
- if(l->chan->cid.cid_num)
- free(l->chan->cid.cid_num);
- l->chan->cid.cid_num = strdup(myrpt->name);
- ast_call(l->chan,tele,999);
- }
- else{
- rpt_telemetry(myrpt,CONNFAIL,l);
- free(l);
- if (option_verbose > 2)
- ast_verbose(VERBOSE_PREFIX_3 "Unable to place call to %s/%s on %s\n",
- deststr,tele,l->chan->name);
- return DC_ERROR;
- }
- /* allocate a pseudo-channel thru asterisk */
- l->pchan = ast_request("zap",AST_FORMAT_SLINEAR,"pseudo",NULL);
- if (!l->pchan){
- fprintf(stderr,"rpt:Sorry unable to obtain pseudo channel\n");
- ast_hangup(l->chan);
- free(l);
- return DC_ERROR;
+ rpt_telemetry(myrpt, REMALREADY, NULL);
+ return DC_COMPLETE;
}
- ast_set_read_format(l->pchan, AST_FORMAT_SLINEAR);
- ast_set_write_format(l->pchan, AST_FORMAT_SLINEAR);
- /* make a conference for the tx */
- ci.chan = 0;
- ci.confno = myrpt->conf;
- ci.confmode = ZT_CONF_CONF | ZT_CONF_LISTENER | ZT_CONF_TALKER;
- /* first put the channel on the conference in proper mode */
- if (ioctl(l->pchan->fds[0], ZT_SETCONF, &ci) == -1)
- {
- ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
- ast_hangup(l->chan);
- ast_hangup(l->pchan);
- free(l);
+ reconnects = l->reconnects;
+ rpt_mutex_unlock(&myrpt->lock);
+ if (l->chan)
+ ast_softhangup(l->chan, AST_SOFTHANGUP_DEV);
+ l->retries = MAX_RETRIES + 1;
+ l->disced = 2;
+ modechange = 1;
+ } else
+ rpt_mutex_unlock(&myrpt->lock);
+ ast_copy_string(myrpt->lastlinknode, digitbuf, MAXNODESTR);
+ /* establish call in monitor mode */
+ l = ast_calloc(1, sizeof(struct rpt_link));
+ if (!l) {
+ ast_log(LOG_WARNING, "Unable to malloc\n");
+ return DC_ERROR;
+ }
+ snprintf(deststr, sizeof(deststr), "IAX2/%s", args.s1);
+ tele = strchr(deststr, '/');
+ if (!tele) {
+ ast_log(LOG_ERROR, "link2:Dial number (%s) must be in format tech/number\n", deststr);
+ return DC_ERROR;
+ }
+ *tele++ = 0;
+ l->isremote = (s && ast_true(s));
+ ast_copy_string(l->name, digitbuf, MAXNODESTR);
+ l->chan = ast_request(deststr, AST_FORMAT_SLINEAR, tele, NULL);
+ if (modechange)
+ l->connected = 1;
+ if (l->chan) {
+ ast_set_read_format(l->chan, AST_FORMAT_SLINEAR);
+ ast_set_write_format(l->chan, AST_FORMAT_SLINEAR);
+ l->chan->whentohangup = 0;
+ l->chan->appl = "Apprpt";
+ l->chan->data = "(Remote Rx)";
+ if (option_verbose > 2)
+ ast_verbose(VERBOSE_PREFIX_3 "rpt (remote) initiating call to %s/%s on %s\n",
+ deststr, tele, l->chan->name);
+ if (l->chan->cid.cid_num)
+ ast_free(l->chan->cid.cid_num);
+ l->chan->cid.cid_num = ast_strdup(myrpt->name);
+ ast_call(l->chan, tele, 0);
+ } else {
+ rpt_telemetry(myrpt, CONNFAIL, l);
+ ast_free(l);
+ if (option_verbose > 2)
+ ast_verbose(VERBOSE_PREFIX_3 "Unable to place call to %s/%s on %s\n",
+ deststr, tele, l->chan->name);
+ return DC_ERROR;
+ }
+ /* allocate a pseudo-channel thru asterisk */
+ l->pchan = ast_request("zap", AST_FORMAT_SLINEAR, "pseudo", NULL);
+ if (!l->pchan) {
+ ast_log(LOG_ERROR, "rpt:Sorry unable to obtain pseudo channel\n");
+ ast_hangup(l->chan);
+ ast_free(l);
+ return DC_ERROR;
+ }
+ ast_set_read_format(l->pchan, AST_FORMAT_SLINEAR);
+ ast_set_write_format(l->pchan, AST_FORMAT_SLINEAR);
+ /* make a conference for the pseudo-one */
+ ci.chan = 0;
+ ci.confno = myrpt->conf;
+ ci.confmode = ZT_CONF_CONF | ZT_CONF_LISTENER | ZT_CONF_TALKER;
+ /* first put the channel on the conference in proper mode */
+ if (ioctl(l->pchan->fds[0], ZT_SETCONF, &ci) == -1) {
+ ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
+ ast_hangup(l->chan);
+ ast_hangup(l->pchan);
+ ast_free(l);
+ return DC_ERROR;
+ }
+ rpt_mutex_lock(&myrpt->lock);
+ l->reconnects = reconnects;
+ /* insert at end of queue */
+ insque((struct qelem *)l, (struct qelem *)myrpt->links.next);
+ rpt_mutex_unlock(&myrpt->lock);
+ rpt_telemetry(myrpt, COMPLETE, NULL);
+ return DC_COMPLETE;
+ case 3: /* Link transceive */
+ if ((digitbuf[0] == '0') && (myrpt->lastlinknode[0]))
+ strcpy(digitbuf,myrpt->lastlinknode);
+ val = ast_variable_retrieve(myrpt->cfg, myrpt->p.nodes, digitbuf);
+ if (!val) {
+ if (strlen(digitbuf) >= myrpt->longestnode)
return DC_ERROR;
+ break;
+ }
+ s = ast_strdupa(val);
+ AST_NONSTANDARD_APP_ARGS(args, s, ',');
+ rpt_mutex_lock(&myrpt->lock);
+ l = myrpt->links.next;
+ /* try to find this one in queue */
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') {
+ l = l->next;
+ continue;
}
- rpt_mutex_lock(&myrpt->lock);
- l->reconnects = reconnects;
- /* insert at end of queue */
- insque((struct qelem *)l,(struct qelem *)myrpt->links.next);
- rpt_mutex_unlock(&myrpt->lock);
- rpt_telemetry(myrpt,COMPLETE,NULL);
- return DC_COMPLETE;
- case 4: /* Enter Command Mode */
-
- /* if doesnt allow link cmd, or no links active, return */
- if (((command_source != SOURCE_RPT) && (command_source != SOURCE_PHONE) && (command_source != SOURCE_DPHONE)) || (myrpt->links.next == &myrpt->links))
- return DC_COMPLETE;
-
- /* if already in cmd mode, or selected self, fughetabahtit */
- if ((myrpt->cmdnode[0]) || (!strcmp(myrpt->name, digitbuf))){
-
+ /* if found matching string */
+ if (!strcmp(l->name, digitbuf))
+ break;
+ l = l->next;
+ }
+ /* if found */
+ if (l != &myrpt->links) {
+ /* if already in this mode, just ignore */
+ if ((l->mode) || (!l->chan)) {
+ rpt_mutex_unlock(&myrpt->lock);
rpt_telemetry(myrpt, REMALREADY, NULL);
return DC_COMPLETE;
}
- if ((digitbuf[0] == '0') && (myrpt->lastlinknode[0]))
- strcpy(digitbuf,myrpt->lastlinknode);
- /* node must at least exist in list */
- val = ast_variable_retrieve(myrpt->cfg, myrpt->p.nodes, digitbuf);
- if (!val){
- if(strlen(digitbuf) >= myrpt->longestnode)
- return DC_ERROR;
- break;
-
- }
- rpt_mutex_lock(&myrpt->lock);
- strcpy(myrpt->lastlinknode,digitbuf);
- strncpy(myrpt->cmdnode, digitbuf, sizeof(myrpt->cmdnode) - 1);
+ reconnects = l->reconnects;
+ rpt_mutex_unlock(&myrpt->lock);
+ if (l->chan)
+ ast_softhangup(l->chan, AST_SOFTHANGUP_DEV);
+ l->retries = MAX_RETRIES + 1;
+ l->disced = 2;
+ modechange = 1;
+ } else
rpt_mutex_unlock(&myrpt->lock);
- rpt_telemetry(myrpt, REMGO, NULL);
+ ast_copy_string(myrpt->lastlinknode, digitbuf, MAXNODESTR);
+ /* establish call in tranceive mode */
+ l = ast_calloc(1, sizeof(struct rpt_link));
+ if (!l) {
+ ast_log(LOG_WARNING, "Unable to malloc\n");
+ return DC_ERROR;
+ }
+ l->mode = 1;
+ l->outbound = 1;
+ ast_copy_string(l->name, digitbuf, MAXNODESTR);
+ l->isremote = (s && ast_true(s));
+ if (modechange)
+ l->connected = 1;
+ snprintf(deststr, sizeof(deststr), "IAX2/%s", args.s1);
+ tele = strchr(deststr, '/');
+ if (!tele) {
+ ast_log(LOG_ERROR, "link3:Dial number (%s) must be in format tech/number\n", deststr);
+ ast_free(l);
+ return DC_ERROR;
+ }
+ *tele++ = 0;
+ l->chan = ast_request(deststr, AST_FORMAT_SLINEAR, tele, NULL);
+ if (l->chan) {
+ ast_set_read_format(l->chan, AST_FORMAT_SLINEAR);
+ ast_set_write_format(l->chan, AST_FORMAT_SLINEAR);
+ l->chan->whentohangup = 0;
+ l->chan->appl = "Apprpt";
+ l->chan->data = "(Remote Rx)";
+ if (option_verbose > 2)
+ ast_verbose(VERBOSE_PREFIX_3 "rpt (remote) initiating call to %s/%s on %s\n",
+ deststr, tele, l->chan->name);
+ if (l->chan->cid.cid_num)
+ ast_free(l->chan->cid.cid_num);
+ l->chan->cid.cid_num = ast_strdup(myrpt->name);
+ ast_call(l->chan, tele, 999);
+ } else {
+ rpt_telemetry(myrpt, CONNFAIL, l);
+ ast_free(l);
+ if (option_verbose > 2)
+ ast_verbose(VERBOSE_PREFIX_3 "Unable to place call to %s/%s on %s\n",
+ deststr, tele, l->chan->name);
+ return DC_ERROR;
+ }
+ /* allocate a pseudo-channel thru asterisk */
+ l->pchan = ast_request("zap", AST_FORMAT_SLINEAR, "pseudo", NULL);
+ if (!l->pchan) {
+ ast_log(LOG_ERROR, "rpt:Sorry unable to obtain pseudo channel\n");
+ ast_hangup(l->chan);
+ ast_free(l);
+ return DC_ERROR;
+ }
+ ast_set_read_format(l->pchan, AST_FORMAT_SLINEAR);
+ ast_set_write_format(l->pchan, AST_FORMAT_SLINEAR);
+ /* make a conference for the tx */
+ ci.chan = 0;
+ ci.confno = myrpt->conf;
+ ci.confmode = ZT_CONF_CONF | ZT_CONF_LISTENER | ZT_CONF_TALKER;
+ /* first put the channel on the conference in proper mode */
+ if (ioctl(l->pchan->fds[0], ZT_SETCONF, &ci) == -1) {
+ ast_log(LOG_WARNING, "Unable to set conference mode to Announce\n");
+ ast_hangup(l->chan);
+ ast_hangup(l->pchan);
+ ast_free(l);
+ return DC_ERROR;
+ }
+ rpt_mutex_lock(&myrpt->lock);
+ l->reconnects = reconnects;
+ /* insert at end of queue */
+ insque((struct qelem *)l, (struct qelem *)myrpt->links.next);
+ rpt_mutex_unlock(&myrpt->lock);
+ rpt_telemetry(myrpt, COMPLETE, NULL);
+ return DC_COMPLETE;
+ case 4: /* Enter Command Mode */
+ /* if doesnt allow link cmd, or no links active, return */
+ if (((command_source != SOURCE_RPT) &&
+ (command_source != SOURCE_PHONE) &&
+ (command_source != SOURCE_DPHONE)) ||
+ (myrpt->links.next == &myrpt->links))
return DC_COMPLETE;
-
- case 5: /* Status */
- rpt_telemetry(myrpt, STATUS, NULL);
+ /* if already in cmd mode, or selected self, fughetabahtit */
+ if ((myrpt->cmdnode[0]) || (!strcmp(myrpt->name, digitbuf))) {
+ rpt_telemetry(myrpt, REMALREADY, NULL);
return DC_COMPLETE;
-
-
- case 6: /* All Links Off */
- l = myrpt->links.next;
-
- while(l != &myrpt->links){ /* This code is broke and needs to be changed to work with the reconnect kludge */
- if (l->chan) ast_softhangup(l->chan, AST_SOFTHANGUP_DEV); /* Hang 'em up */
- l = l->next;
- }
- rpt_telemetry(myrpt, COMPLETE, NULL);
- break;
-
- case 7: /* Identify last node which keyed us up */
- rpt_telemetry(myrpt, LASTNODEKEY, NULL);
+ }
+ if ((digitbuf[0] == '0') && (myrpt->lastlinknode[0]))
+ strcpy(digitbuf,myrpt->lastlinknode);
+ /* node must at least exist in list */
+ val = ast_variable_retrieve(myrpt->cfg, myrpt->p.nodes, digitbuf);
+ if (!val) {
+ if (strlen(digitbuf) >= myrpt->longestnode)
+ return DC_ERROR;
break;
-
- default:
- return DC_ERROR;
-
+ }
+ rpt_mutex_lock(&myrpt->lock);
+ strcpy(myrpt->lastlinknode, digitbuf);
+ ast_copy_string(myrpt->cmdnode, digitbuf, sizeof(myrpt->cmdnode));
+ rpt_mutex_unlock(&myrpt->lock);
+ rpt_telemetry(myrpt, REMGO, NULL);
+ return DC_COMPLETE;
+ case 5: /* Status */
+ rpt_telemetry(myrpt, STATUS, NULL);
+ return DC_COMPLETE;
+ case 6: /* All Links Off */
+ l = myrpt->links.next;
+ while (l != &myrpt->links) { /* This code is broke and needs to be changed to work with the reconnect kludge */
+ if (l->chan)
+ ast_softhangup(l->chan, AST_SOFTHANGUP_DEV); /* Hang 'em up */
+ l = l->next;
+ }
+ rpt_telemetry(myrpt, COMPLETE, NULL);
+ break;
+ case 7: /* Identify last node which keyed us up */
+ rpt_telemetry(myrpt, LASTNODEKEY, NULL);
+ break;
+ default:
+ return DC_ERROR;
}
-
+
return DC_INDETERMINATE;
-}
+}
/*
* Autopatch up
static int function_autopatchup(struct rpt *myrpt, char *param, char *digitbuf, int command_source, struct rpt_link *mylink)
{
pthread_attr_t attr;
- int i, index, paramlength;
- char *lparam;
+ int i, index;
char *value = NULL;
- char *paramlist[20];
+ AST_DECLARE_APP_ARGS(params,
+ AST_APP_ARG(list)[20];
+ );
static char *keywords[] = {
"context",
if (!myrpt->enable)
return DC_ERROR;
-
- if(debug)
- printf("@@@@ Autopatch up\n");
- if(!myrpt->callmode){
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ Autopatch up\n");
+
+ if (!myrpt->callmode) {
/* Set defaults */
myrpt->patchnoct = 0;
myrpt->patchdialtime = 0;
myrpt->patchfarenddisconnect = 0;
myrpt->patchquiet = 0;
- strncpy(myrpt->patchcontext, myrpt->p.ourcontext, MAXPATCHCONTEXT);
+ ast_copy_string(myrpt->patchcontext, myrpt->p.ourcontext, sizeof(myrpt->patchcontext));
- if(param){
+ if (param) {
/* Process parameter list */
- lparam = ast_strdupa(param);
- if(!lparam){
- ast_log(LOG_ERROR,"App_rpt out of memory on line %d\n",__LINE__);
- return DC_ERROR;
- }
- paramlength = finddelim(lparam, paramlist, 20);
- for(i = 0; i < paramlength; i++){
- index = matchkeyword(paramlist[i], &value, keywords);
- if(value)
+ char *tmp = ast_strdupa(param);
+ AST_NONSTANDARD_APP_ARGS(params, tmp, ',');
+ for (i = 0; i < params.argc; i++) {
+ index = matchkeyword(params.list[i], &value, keywords);
+ if (value)
value = skipchars(value, "= ");
- switch(index){
-
- case 1: /* context */
- strncpy(myrpt->patchcontext, value, MAXPATCHCONTEXT - 1) ;
- break;
-
- case 2: /* dialtime */
- myrpt->patchdialtime = atoi(value);
- break;
-
- case 3: /* farenddisconnect */
- myrpt->patchfarenddisconnect = atoi(value);
- break;
-
- case 4: /* noct */
- myrpt->patchnoct = atoi(value);
- break;
-
- case 5: /* quiet */
- myrpt->patchquiet = atoi(value);
- break;
-
- default:
- break;
+ switch (index) {
+ case 1: /* context */
+ ast_copy_string(myrpt->patchcontext, value, sizeof(myrpt->patchcontext)) ;
+ break;
+ case 2: /* dialtime */
+ myrpt->patchdialtime = atoi(value);
+ break;
+ case 3: /* farenddisconnect */
+ myrpt->patchfarenddisconnect = atoi(value);
+ break;
+ case 4: /* noct */
+ myrpt->patchnoct = atoi(value);
+ break;
+ case 5: /* quiet */
+ myrpt->patchquiet = atoi(value);
+ break;
+ default:
+ break;
}
}
}
/* if on call, force * into current audio stream */
- if ((myrpt->callmode == 2) || (myrpt->callmode == 3)){
+ if ((myrpt->callmode == 2) || (myrpt->callmode == 3)) {
myrpt->mydtmf = myrpt->p.funcchar;
}
- if (myrpt->callmode){
+ if (myrpt->callmode) {
rpt_mutex_unlock(&myrpt->lock);
return DC_COMPLETE;
}
rpt_mutex_unlock(&myrpt->lock);
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
- ast_pthread_create(&myrpt->rpt_call_thread,&attr,rpt_call,(void *) myrpt);
+ ast_pthread_create(&myrpt->rpt_call_thread, &attr, rpt_call, (void *) myrpt);
+ pthread_attr_destroy(&attr);
return DC_COMPLETE;
}
if (!myrpt->enable)
return DC_ERROR;
- if(debug)
- printf("@@@@ Autopatch down\n");
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ Autopatch down\n");
rpt_mutex_lock(&myrpt->lock);
- if (!myrpt->callmode){
+ if (!myrpt->callmode) {
rpt_mutex_unlock(&myrpt->lock);
return DC_COMPLETE;
}
if (!myrpt->enable)
return DC_ERROR;
- if(debug)
- printf("@@@@ status param = %s, digitbuf = %s\n", (param)? param : "(null)", digitbuf);
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ status param = %s, digitbuf = %s\n", (param)? param : "(null)", digitbuf);
- switch(myatoi(param)){
- case 1: /* System ID */
- rpt_telemetry(myrpt, ID1, NULL);
- return DC_COMPLETE;
- case 2: /* System Time */
- rpt_telemetry(myrpt, STATS_TIME, NULL);
- return DC_COMPLETE;
- case 3: /* app_rpt.c version */
- rpt_telemetry(myrpt, STATS_VERSION, NULL);
- default:
- return DC_ERROR;
+ switch (myatoi(param)) {
+ case 1: /* System ID */
+ rpt_telemetry(myrpt, ID1, NULL);
+ return DC_COMPLETE;
+ case 2: /* System Time */
+ rpt_telemetry(myrpt, STATS_TIME, NULL);
+ return DC_COMPLETE;
+ case 3: /* app_rpt.c version */
+ rpt_telemetry(myrpt, STATS_VERSION, NULL);
+ default:
+ return DC_ERROR;
}
+
+ /* Never reached */
return DC_INDETERMINATE;
}
static int function_macro(struct rpt *myrpt, char *param, char *digitbuf, int command_source, struct rpt_link *mylink)
{
- const char *val;
-int i;
-struct ast_channel *mychannel;
+ const char *val;
+ int i;
+ struct ast_channel *mychannel;
if ((!myrpt->remote) && (!myrpt->enable))
return DC_ERROR;
- if(debug)
- printf("@@@@ macro-oni param = %s, digitbuf = %s\n", (param)? param : "(null)", digitbuf);
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ macro-oni param = %s, digitbuf = %s\n", (param)? param : "(null)", digitbuf);
mychannel = myrpt->remchannel;
- if(strlen(digitbuf) < 1) /* needs 1 digit */
+ if (ast_strlen_zero(digitbuf)) /* needs 1 digit */
return DC_INDETERMINATE;
- for(i = 0 ; i < digitbuf[i] ; i++) {
- if((digitbuf[i] < '0') || (digitbuf[i] > '9'))
+ for (i = 0; i < digitbuf[i]; i++) {
+ if ((digitbuf[i] < '0') || (digitbuf[i] > '9'))
return DC_ERROR;
}
- if (*digitbuf == '0') val = myrpt->p.startupmacro;
- else val = ast_variable_retrieve(myrpt->cfg, myrpt->p.macro, digitbuf);
+ if (*digitbuf == '0')
+ val = myrpt->p.startupmacro;
+ else
+ val = ast_variable_retrieve(myrpt->cfg, myrpt->p.macro, digitbuf);
/* param was 1 for local buf */
- if (!val){
+ if (!val) {
rpt_telemetry(myrpt, MACRO_NOTFOUND, NULL);
return DC_COMPLETE;
}
rpt_mutex_lock(&myrpt->lock);
- if ((MAXMACRO - strlen(myrpt->macrobuf)) < strlen(val))
- {
+ if ((sizeof(myrpt->macrobuf) - strlen(myrpt->macrobuf)) < strlen(val)) {
rpt_mutex_unlock(&myrpt->lock);
rpt_telemetry(myrpt, MACRO_BUSY, NULL);
return DC_ERROR;
}
myrpt->macrotimer = MACROTIME;
- strncat(myrpt->macrobuf,val,MAXMACRO - 1);
+ strncat(myrpt->macrobuf, val, sizeof(myrpt->macrobuf) - 1);
rpt_mutex_unlock(&myrpt->lock);
return DC_COMPLETE;
}
static int function_cop(struct rpt *myrpt, char *param, char *digitbuf, int command_source, struct rpt_link *mylink)
{
- if(!param)
+ if (!param)
return DC_ERROR;
- switch(myatoi(param)){
- case 1: /* System reset */
- system("killall -9 asterisk"); /* FIXME to drastic? */
- return DC_COMPLETE;
-
- case 2:
- myrpt->enable = 1;
- rpt_telemetry(myrpt, ARB_ALPHA, (void *) "RPTENA");
- return DC_COMPLETE;
-
- case 3:
- myrpt->enable = 0;
- return DC_COMPLETE;
-
- case 4: /* test tone on */
- rpt_telemetry(myrpt, TEST_TONE, NULL);
- return DC_COMPLETE;
-
- case 5: /* Disgorge variables to log for debug purposes */
- myrpt->disgorgetime = time(NULL) + 10; /* Do it 10 seconds later */
- return DC_COMPLETE;
-
- case 6: /* Simulate COR being activated (phone only) */
- if (command_source != SOURCE_PHONE) return DC_INDETERMINATE;
- return DC_DOKEY;
-
- }
- return DC_INDETERMINATE;
-}
+ switch(myatoi(param)) {
+ case 1: /* System reset */
+ ast_cli_command(STDERR_FILENO, "restart now"); /* A little less drastic than what was previously here. */
+ return DC_COMPLETE;
+ case 2:
+ myrpt->enable = 1;
+ rpt_telemetry(myrpt, ARB_ALPHA, (void *) "RPTENA");
+ return DC_COMPLETE;
+ case 3:
+ myrpt->enable = 0;
+ return DC_COMPLETE;
+ case 4: /* test tone on */
+ rpt_telemetry(myrpt, TEST_TONE, NULL);
+ return DC_COMPLETE;
+ case 5: /* Disgorge variables to log for debug purposes */
+ myrpt->disgorgetime = time(NULL) + 10; /* Do it 10 seconds later */
+ return DC_COMPLETE;
+ case 6: /* Simulate COR being activated (phone only) */
+ if (command_source != SOURCE_PHONE)
+ return DC_INDETERMINATE;
+ return DC_DOKEY;
+ }
+ return DC_INDETERMINATE;
+}
/*
* Collect digits one by one until something matches
*/
-static int collect_function_digits(struct rpt *myrpt, char *digits,
- int command_source, struct rpt_link *mylink)
+static int collect_function_digits(struct rpt *myrpt, char *digits, int command_source, struct rpt_link *mylink)
{
int i;
- char *stringp,*action,*param,*functiondigits;
+ char *stringp, *functiondigits;
char function_table_name[30] = "";
- char workstring[200];
-
struct ast_variable *vp;
+ AST_DECLARE_APP_ARGS(args,
+ AST_APP_ARG(action);
+ AST_APP_ARG(param);
+ );
- if(debug)
- printf("@@@@ Digits collected: %s, source: %d\n", digits, command_source);
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ Digits collected: %s, source: %d\n", digits, command_source);
if (command_source == SOURCE_DPHONE) {
- if (!myrpt->p.dphone_functions) return DC_INDETERMINATE;
- strncpy(function_table_name, myrpt->p.dphone_functions, sizeof(function_table_name) - 1);
- }
- else if (command_source == SOURCE_PHONE) {
- if (!myrpt->p.phone_functions) return DC_INDETERMINATE;
- strncpy(function_table_name, myrpt->p.phone_functions, sizeof(function_table_name) - 1);
- }
- else if (command_source == SOURCE_LNK)
- strncpy(function_table_name, myrpt->p.link_functions, sizeof(function_table_name) - 1);
+ if (!myrpt->p.dphone_functions)
+ return DC_INDETERMINATE;
+ ast_copy_string(function_table_name, myrpt->p.dphone_functions, sizeof(function_table_name));
+ } else if (command_source == SOURCE_PHONE) {
+ if (!myrpt->p.phone_functions)
+ return DC_INDETERMINATE;
+ ast_copy_string(function_table_name, myrpt->p.phone_functions, sizeof(function_table_name));
+ } else if (command_source == SOURCE_LNK)
+ ast_copy_string(function_table_name, myrpt->p.link_functions, sizeof(function_table_name));
else
- strncpy(function_table_name, myrpt->p.functions, sizeof(function_table_name) - 1);
- vp = ast_variable_browse(myrpt->cfg, function_table_name);
- while(vp) {
- if(!strncasecmp(vp->name, digits, strlen(vp->name)))
+ ast_copy_string(function_table_name, myrpt->p.functions, sizeof(function_table_name));
+
+ for (vp = ast_variable_browse(myrpt->cfg, function_table_name); vp; vp = vp->next) {
+ if (!strncasecmp(vp->name, digits, strlen(vp->name)))
break;
- vp = vp->next;
}
- if(!vp) {
+ if (!vp) {
int n;
n = myrpt->longestfunc;
- if (command_source == SOURCE_LNK) n = myrpt->link_longestfunc;
- else
- if (command_source == SOURCE_PHONE) n = myrpt->phone_longestfunc;
- else
- if (command_source == SOURCE_DPHONE) n = myrpt->dphone_longestfunc;
-
- if(strlen(digits) >= n)
+ if (command_source == SOURCE_LNK)
+ n = myrpt->link_longestfunc;
+ else if (command_source == SOURCE_PHONE)
+ n = myrpt->phone_longestfunc;
+ else if (command_source == SOURCE_DPHONE)
+ n = myrpt->dphone_longestfunc;
+
+ if (strlen(digits) >= n)
return DC_ERROR;
else
return DC_INDETERMINATE;
- }
+ }
+
/* Found a match, retrieve value part and parse */
- strncpy(workstring, vp->value, sizeof(workstring) - 1 );
- stringp = workstring;
- action = strsep(&stringp, ",");
- param = stringp;
- if(debug)
- printf("@@@@ action: %s, param = %s\n",action, (param) ? param : "(null)");
+ stringp = ast_strdupa(vp->value);
+ AST_NONSTANDARD_APP_ARGS(args, stringp, ',');
+
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ action: %s, param = %s\n", args.action, S_OR(args.param, "(null)"));
/* Look up the action */
- for(i = 0 ; i < (sizeof(function_table)/sizeof(struct function_table_tag)); i++){
- if(!strncasecmp(action, function_table[i].action, strlen(action)))
+ for (i = 0; i < (sizeof(function_table) / sizeof(struct function_table_tag)); i++) {
+ if (!strncasecmp(args.action, function_table[i].action, strlen(args.action)))
break;
}
- if(debug)
- printf("@@@@ table index i = %d\n",i);
- if(i == (sizeof(function_table)/sizeof(struct function_table_tag))){
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ table index i = %d\n", i);
+ if (i == (sizeof(function_table) / sizeof(struct function_table_tag))) {
/* Error, action not in table */
return DC_ERROR;
}
- if(function_table[i].function == NULL){
+ if (function_table[i].function == NULL) {
/* Error, function undefined */
- if(debug)
- printf("@@@@ NULL for action: %s\n",action);
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ NULL for action: %s\n", args.action);
return DC_ERROR;
}
functiondigits = digits + strlen(vp->name);
- return (*function_table[i].function)(myrpt, param, functiondigits, command_source, mylink);
+ return (*function_table[i].function)(myrpt, args.param, functiondigits, command_source, mylink);
}
-static void handle_link_data(struct rpt *myrpt, struct rpt_link *mylink,
- char *str)
+static void handle_link_data(struct rpt *myrpt, struct rpt_link *mylink, char *str)
{
-char tmp[300],cmd[300] = "",dest[300],src[300],c;
-int seq, res;
-struct rpt_link *l;
-struct ast_frame wf;
+ char cmd[300] = "", dest[300], src[300], c;
+ int seq, res;
+ struct rpt_link *l;
+ struct ast_frame wf;
wf.frametype = AST_FRAME_TEXT;
wf.subclass = 0;
wf.mallocd = 1;
wf.datalen = strlen(str) + 1;
wf.samples = 0;
- /* put string in our buffer */
- strncpy(tmp,str,sizeof(tmp) - 1);
-
- if (!strcmp(tmp,discstr))
- {
- mylink->disced = 1;
+ if (!strcmp(str, discstr)) {
+ mylink->disced = 1;
mylink->retries = MAX_RETRIES + 1;
- ast_softhangup(mylink->chan,AST_SOFTHANGUP_DEV);
- return;
- }
- if (sscanf(tmp,"%s %s %s %d %c",cmd,dest,src,&seq,&c) != 5)
- {
- ast_log(LOG_WARNING, "Unable to parse link string %s\n",str);
+ ast_softhangup(mylink->chan, AST_SOFTHANGUP_DEV);
return;
}
- if (strcmp(cmd,"D"))
- {
- ast_log(LOG_WARNING, "Unable to parse link string %s\n",str);
+ if (sscanf(str, "%s %s %s %d %c", cmd, dest, src, &seq, &c) != 5) {
+ ast_log(LOG_WARNING, "Unable to parse link string %s\n", str);
+ return;
+ }
+ if (strcmp(cmd, "D")) {
+ ast_log(LOG_WARNING, "Unable to parse link string %s\n", str);
return;
}
- if (dest[0] == '0')
- {
- strcpy(dest,myrpt->name);
- }
+ if (dest[0] == '0') {
+ strcpy(dest, myrpt->name);
+ }
/* if not for me, redistribute to all links */
- if (strcmp(dest,myrpt->name))
- {
+ if (strcmp(dest, myrpt->name)) {
l = myrpt->links.next;
/* see if this is one in list */
- while(l != &myrpt->links)
- {
- if (l->name[0] == '0')
- {
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') {
l = l->next;
continue;
}
/* dont send back from where it came */
- if ((l == mylink) || (!strcmp(l->name,mylink->name)))
- {
+ if ((l == mylink) || (!strcmp(l->name, mylink->name))) {
l = l->next;
continue;
}
/* if it is, send it and we're done */
- if (!strcmp(l->name,dest))
- {
+ if (!strcmp(l->name, dest)) {
/* send, but not to src */
- if (strcmp(l->name,src)) {
- wf.data = strdup(str);
- if (l->chan) ast_write(l->chan,&wf);
+ if (strcmp(l->name, src)) {
+ wf.data = ast_strdup(str);
+ if (l->chan)
+ ast_write(l->chan,&wf);
}
return;
}
}
l = myrpt->links.next;
/* otherwise, send it to all of em */
- while(l != &myrpt->links)
- {
- if (l->name[0] == '0')
- {
+ while (l != &myrpt->links) {
+ if (l->name[0] == '0') {
l = l->next;
continue;
}
/* dont send back from where it came */
- if ((l == mylink) || (!strcmp(l->name,mylink->name)))
- {
+ if ((l == mylink) || (!strcmp(l->name, mylink->name))) {
l = l->next;
continue;
}
/* send, but not to src */
if (strcmp(l->name,src)) {
- wf.data = strdup(str);
- if (l->chan) ast_write(l->chan,&wf);
+ wf.data = ast_strdup(str);
+ if (l->chan)
+ ast_write(l->chan, &wf);
}
l = l->next;
}
return;
}
rpt_mutex_lock(&myrpt->lock);
- if (c == myrpt->p.endchar) myrpt->stopgen = 1;
- if (myrpt->callmode == 1)
- {
+ if (c == myrpt->p.endchar)
+ myrpt->stopgen = 1;
+ if (myrpt->callmode == 1) {
myrpt->exten[myrpt->cidx++] = c;
myrpt->exten[myrpt->cidx] = 0;
/* if this exists */
- if (ast_exists_extension(myrpt->pchannel,myrpt->patchcontext,myrpt->exten,1,NULL))
- {
+ if (ast_exists_extension(myrpt->pchannel, myrpt->patchcontext, myrpt->exten, 1, NULL)) {
myrpt->callmode = 2;
- if(!myrpt->patchquiet){
+ if (!myrpt->patchquiet) {
rpt_mutex_unlock(&myrpt->lock);
- rpt_telemetry(myrpt,PROC,NULL);
+ rpt_telemetry(myrpt, PROC, NULL);
rpt_mutex_lock(&myrpt->lock);
}
}
/* if can continue, do so */
- if (!ast_canmatch_extension(myrpt->pchannel,myrpt->patchcontext,myrpt->exten,1,NULL))
- {
+ if (!ast_canmatch_extension(myrpt->pchannel, myrpt->patchcontext, myrpt->exten, 1, NULL)) {
/* call has failed, inform user */
myrpt->callmode = 4;
}
}
- if ((myrpt->callmode == 2) || (myrpt->callmode == 3))
- {
+ if ((myrpt->callmode == 2) || (myrpt->callmode == 3)) {
myrpt->mydtmf = c;
}
- if (c == myrpt->p.funcchar)
- {
+ if (c == myrpt->p.funcchar) {
myrpt->rem_dtmfidx = 0;
myrpt->rem_dtmfbuf[myrpt->rem_dtmfidx] = 0;
time(&myrpt->rem_dtmf_time);
rpt_mutex_unlock(&myrpt->lock);
return;
- }
- else if ((c != myrpt->p.endchar) && (myrpt->rem_dtmfidx >= 0))
- {
+ } else if ((c != myrpt->p.endchar) && (myrpt->rem_dtmfidx >= 0)) {
time(&myrpt->rem_dtmf_time);
- if (myrpt->rem_dtmfidx < MAXDTMF)
- {
+ if (myrpt->rem_dtmfidx < MAXDTMF) {
myrpt->rem_dtmfbuf[myrpt->rem_dtmfidx++] = c;
myrpt->rem_dtmfbuf[myrpt->rem_dtmfidx] = 0;
rpt_mutex_unlock(&myrpt->lock);
- strncpy(cmd, myrpt->rem_dtmfbuf, sizeof(cmd) - 1);
+ ast_copy_string(cmd, myrpt->rem_dtmfbuf, sizeof(cmd));
res = collect_function_digits(myrpt, cmd, SOURCE_LNK, mylink);
rpt_mutex_lock(&myrpt->lock);
- switch(res){
-
- case DC_INDETERMINATE:
- break;
-
- case DC_REQ_FLUSH:
- myrpt->rem_dtmfidx = 0;
- myrpt->rem_dtmfbuf[0] = 0;
- break;
-
-
- case DC_COMPLETE:
- myrpt->totalexecdcommands++;
- myrpt->dailyexecdcommands++;
- strncpy(myrpt->lastdtmfcommand, cmd, MAXDTMF-1);
- myrpt->lastdtmfcommand[MAXDTMF-1] = '\0';
- myrpt->rem_dtmfbuf[0] = 0;
- myrpt->rem_dtmfidx = -1;
- myrpt->rem_dtmf_time = 0;
- break;
-
- case DC_ERROR:
- default:
- myrpt->rem_dtmfbuf[0] = 0;
- myrpt->rem_dtmfidx = -1;
- myrpt->rem_dtmf_time = 0;
- break;
+ switch (res) {
+ case DC_INDETERMINATE:
+ break;
+ case DC_REQ_FLUSH:
+ myrpt->rem_dtmfidx = 0;
+ myrpt->rem_dtmfbuf[0] = 0;
+ break;
+ case DC_COMPLETE:
+ myrpt->totalexecdcommands++;
+ myrpt->dailyexecdcommands++;
+ ast_copy_string(myrpt->lastdtmfcommand, cmd, MAXDTMF);
+ myrpt->lastdtmfcommand[MAXDTMF-1] = '\0';
+ myrpt->rem_dtmfbuf[0] = 0;
+ myrpt->rem_dtmfidx = -1;
+ myrpt->rem_dtmf_time = 0;
+ break;
+ case DC_ERROR:
+ default:
+ myrpt->rem_dtmfbuf[0] = 0;
+ myrpt->rem_dtmfidx = -1;
+ myrpt->rem_dtmf_time = 0;
+ break;
}
}
return;
}
-static void handle_link_phone_dtmf(struct rpt *myrpt, struct rpt_link *mylink,
- char c)
+static void handle_link_phone_dtmf(struct rpt *myrpt, struct rpt_link *mylink, char c)
{
-
-char cmd[300];
-int res;
+ char cmd[300];
+ int res;
rpt_mutex_lock(&myrpt->lock);
- if (c == myrpt->p.endchar)
- {
- if (mylink->lastrx)
- {
+ if (c == myrpt->p.endchar) {
+ if (mylink->lastrx) {
mylink->lastrx = 0;
rpt_mutex_unlock(&myrpt->lock);
return;
}
myrpt->stopgen = 1;
- if (myrpt->cmdnode[0])
- {
+ if (myrpt->cmdnode[0]) {
myrpt->cmdnode[0] = 0;
myrpt->dtmfidx = -1;
myrpt->dtmfbuf[0] = 0;
rpt_mutex_unlock(&myrpt->lock);
- rpt_telemetry(myrpt,COMPLETE,NULL);
+ rpt_telemetry(myrpt, COMPLETE, NULL);
return;
}
}
- if (myrpt->cmdnode[0])
- {
+ if (myrpt->cmdnode[0]) {
rpt_mutex_unlock(&myrpt->lock);
- send_link_dtmf(myrpt,c);
+ send_link_dtmf(myrpt, c);
return;
}
- if (myrpt->callmode == 1)
- {
+ if (myrpt->callmode == 1) {
myrpt->exten[myrpt->cidx++] = c;
myrpt->exten[myrpt->cidx] = 0;
/* if this exists */
- if (ast_exists_extension(myrpt->pchannel,myrpt->patchcontext,myrpt->exten,1,NULL))
- {
+ if (ast_exists_extension(myrpt->pchannel, myrpt->patchcontext, myrpt->exten, 1, NULL)) {
myrpt->callmode = 2;
- if(!myrpt->patchquiet){
+ if (!myrpt->patchquiet) {
rpt_mutex_unlock(&myrpt->lock);
- rpt_telemetry(myrpt,PROC,NULL);
+ rpt_telemetry(myrpt, PROC, NULL);
rpt_mutex_lock(&myrpt->lock);
}
}
/* if can continue, do so */
- if (!ast_canmatch_extension(myrpt->pchannel,myrpt->patchcontext,myrpt->exten,1,NULL))
- {
+ if (!ast_canmatch_extension(myrpt->pchannel, myrpt->patchcontext, myrpt->exten, 1, NULL)) {
/* call has failed, inform user */
myrpt->callmode = 4;
}
}
- if ((myrpt->callmode == 2) || (myrpt->callmode == 3))
- {
+ if ((myrpt->callmode == 2) || (myrpt->callmode == 3)) {
myrpt->mydtmf = c;
}
- if (c == myrpt->p.funcchar)
- {
+ if (c == myrpt->p.funcchar) {
myrpt->rem_dtmfidx = 0;
myrpt->rem_dtmfbuf[myrpt->rem_dtmfidx] = 0;
time(&myrpt->rem_dtmf_time);
rpt_mutex_unlock(&myrpt->lock);
return;
- }
- else if ((c != myrpt->p.endchar) && (myrpt->rem_dtmfidx >= 0))
- {
+ } else if ((c != myrpt->p.endchar) && (myrpt->rem_dtmfidx >= 0)) {
time(&myrpt->rem_dtmf_time);
- if (myrpt->rem_dtmfidx < MAXDTMF)
- {
+ if (myrpt->rem_dtmfidx < MAXDTMF) {
myrpt->rem_dtmfbuf[myrpt->rem_dtmfidx++] = c;
myrpt->rem_dtmfbuf[myrpt->rem_dtmfidx] = 0;
rpt_mutex_unlock(&myrpt->lock);
- strncpy(cmd, myrpt->rem_dtmfbuf, sizeof(cmd) - 1);
- switch(mylink->phonemode)
- {
- case 1:
+ ast_copy_string(cmd, myrpt->rem_dtmfbuf, sizeof(cmd));
+ switch(mylink->phonemode) {
+ case 1:
res = collect_function_digits(myrpt, cmd,
SOURCE_PHONE, mylink);
break;
- case 2:
+ case 2:
res = collect_function_digits(myrpt, cmd,
SOURCE_DPHONE,mylink);
break;
- default:
+ default:
res = collect_function_digits(myrpt, cmd,
SOURCE_LNK, mylink);
break;
}
rpt_mutex_lock(&myrpt->lock);
-
- switch(res){
- case DC_INDETERMINATE:
- break;
-
- case DC_DOKEY:
- mylink->lastrx = 1;
- break;
-
- case DC_REQ_FLUSH:
- myrpt->rem_dtmfidx = 0;
- myrpt->rem_dtmfbuf[0] = 0;
- break;
-
-
- case DC_COMPLETE:
- myrpt->totalexecdcommands++;
- myrpt->dailyexecdcommands++;
- strncpy(myrpt->lastdtmfcommand, cmd, MAXDTMF-1);
- myrpt->lastdtmfcommand[MAXDTMF-1] = '\0';
- myrpt->rem_dtmfbuf[0] = 0;
- myrpt->rem_dtmfidx = -1;
- myrpt->rem_dtmf_time = 0;
- break;
-
- case DC_ERROR:
- default:
- myrpt->rem_dtmfbuf[0] = 0;
- myrpt->rem_dtmfidx = -1;
- myrpt->rem_dtmf_time = 0;
- break;
+ switch(res) {
+ case DC_INDETERMINATE:
+ break;
+ case DC_DOKEY:
+ mylink->lastrx = 1;
+ break;
+ case DC_REQ_FLUSH:
+ myrpt->rem_dtmfidx = 0;
+ myrpt->rem_dtmfbuf[0] = 0;
+ break;
+ case DC_COMPLETE:
+ myrpt->totalexecdcommands++;
+ myrpt->dailyexecdcommands++;
+ ast_copy_string(myrpt->lastdtmfcommand, cmd, MAXDTMF);
+ myrpt->rem_dtmfbuf[0] = 0;
+ myrpt->rem_dtmfidx = -1;
+ myrpt->rem_dtmf_time = 0;
+ break;
+ case DC_ERROR:
+ default:
+ myrpt->rem_dtmfbuf[0] = 0;
+ myrpt->rem_dtmfidx = -1;
+ myrpt->rem_dtmf_time = 0;
+ break;
}
}
static int rbi_mhztoband(char *str)
{
-int i;
+ int i;
i = atoi(str) / 10; /* get the 10's of mhz */
- switch(i)
- {
- case 2:
+ switch (i) {
+ case 2:
return 10;
- case 5:
+ case 5:
return 11;
- case 14:
+ case 14:
return 2;
- case 22:
+ case 22:
return 3;
- case 44:
+ case 44:
return 4;
- case 124:
+ case 124:
return 0;
- case 125:
+ case 125:
return 1;
- case 126:
+ case 126:
return 8;
- case 127:
+ case 127:
return 5;
- case 128:
+ case 128:
return 6;
- case 129:
+ case 129:
return 7;
- default:
+ default:
break;
}
return -1;
/* take a PL frequency and turn it into a code */
static int rbi_pltocode(char *str)
{
-int i;
-char *s;
+ int i;
+ char *s;
- s = strchr(str,'.');
+ s = strchr(str, '.');
i = 0;
- if (s) i = atoi(s + 1);
+ if (s)
+ i = atoi(s + 1);
i += atoi(str) * 10;
- switch(i)
- {
- case 670:
+ switch(i) {
+ case 670:
return 0;
- case 719:
+ case 719:
return 1;
- case 744:
+ case 744:
return 2;
- case 770:
+ case 770:
return 3;
- case 797:
+ case 797:
return 4;
- case 825:
+ case 825:
return 5;
- case 854:
+ case 854:
return 6;
- case 885:
+ case 885:
return 7;
- case 915:
+ case 915:
return 8;
- case 948:
+ case 948:
return 9;
- case 974:
+ case 974:
return 10;
- case 1000:
+ case 1000:
return 11;
- case 1035:
+ case 1035:
return 12;
- case 1072:
+ case 1072:
return 13;
- case 1109:
+ case 1109:
return 14;
- case 1148:
+ case 1148:
return 15;
- case 1188:
+ case 1188:
return 16;
- case 1230:
+ case 1230:
return 17;
- case 1273:
+ case 1273:
return 18;
- case 1318:
+ case 1318:
return 19;
- case 1365:
+ case 1365:
return 20;
- case 1413:
+ case 1413:
return 21;
- case 1462:
+ case 1462:
return 22;
- case 1514:
+ case 1514:
return 23;
- case 1567:
+ case 1567:
return 24;
- case 1622:
+ case 1622:
return 25;
- case 1679:
+ case 1679:
return 26;
- case 1738:
+ case 1738:
return 27;
- case 1799:
+ case 1799:
return 28;
- case 1862:
+ case 1862:
return 29;
- case 1928:
+ case 1928:
return 30;
- case 2035:
+ case 2035:
return 31;
- case 2107:
+ case 2107:
return 32;
- case 2181:
+ case 2181:
return 33;
- case 2257:
+ case 2257:
return 34;
- case 2336:
+ case 2336:
return 35;
- case 2418:
+ case 2418:
return 36;
- case 2503:
+ case 2503:
return 37;
}
return -1;
* Shift out a formatted serial bit stream
*/
-static void rbi_out_parallel(struct rpt *myrpt,unsigned char *data)
- {
- int i,j;
- unsigned char od,d;
- static volatile long long delayvar;
-
- for(i = 0 ; i < 5 ; i++){
- od = *data++;
- for(j = 0 ; j < 8 ; j++){
- d = od & 1;
- outb(d,myrpt->p.iobase);
- /* >= 15 us */
- for(delayvar = 1; delayvar < 15000; delayvar++);
- od >>= 1;
- outb(d | 2,myrpt->p.iobase);
- /* >= 30 us */
- for(delayvar = 1; delayvar < 30000; delayvar++);
- outb(d,myrpt->p.iobase);
- /* >= 10 us */
- for(delayvar = 1; delayvar < 10000; delayvar++);
- }
- }
+static void rbi_out_parallel(struct rpt *myrpt, unsigned char *data)
+{
+ int i, j;
+ unsigned char od, d;
+
+ for (i = 0; i < 5; i++) {
+ od = *data++;
+ for (j = 0; j < 8; j++) {
+ d = od & 1;
+ outb(d, myrpt->p.iobase);
+ usleep(15);
+ od >>= 1;
+ outb(d | 2, myrpt->p.iobase);
+ usleep(30);
+ outb(d, myrpt->p.iobase);
+ usleep(10);
+ }
+ }
/* >= 50 us */
- for(delayvar = 1; delayvar < 50000; delayvar++);
- }
+ usleep(50);
+}
-static void rbi_out(struct rpt *myrpt,unsigned char *data)
+static void rbi_out(struct rpt *myrpt, unsigned char *data)
{
-struct zt_radio_param r;
+ struct zt_radio_param r = { 0, };
- memset(&r,0,sizeof(struct zt_radio_param));
r.radpar = ZT_RADPAR_REMMODE;
r.data = ZT_RADPAR_REM_RBI1;
/* if setparam ioctl fails, its probably not a pciradio card */
- if (ioctl(myrpt->rxchannel->fds[0],ZT_RADIO_SETPARAM,&r) == -1)
- {
+ if (ioctl(myrpt->rxchannel->fds[0], ZT_RADIO_SETPARAM, &r) == -1) {
rbi_out_parallel(myrpt,data);
return;
}
r.radpar = ZT_RADPAR_REMCOMMAND;
- memcpy(&r.data,data,5);
- if (ioctl(myrpt->rxchannel->fds[0],ZT_RADIO_SETPARAM,&r) == -1)
- {
- ast_log(LOG_WARNING,"Cannot send RBI command for channel %s\n",myrpt->rxchannel->name);
+ memcpy(&r.data, data, 5);
+ if (ioctl(myrpt->rxchannel->fds[0], ZT_RADIO_SETPARAM, &r) == -1) {
+ ast_log(LOG_WARNING, "Cannot send RBI command for channel %s\n", myrpt->rxchannel->name);
return;
}
}
-static int serial_remote_io(struct rpt *myrpt, unsigned char *txbuf, int txbytes, char *rxbuf,
- int rxmaxbytes, int asciiflag)
+static int serial_remote_io(struct rpt *myrpt, unsigned char *txbuf, int txbytes, char *rxbuf, int rxmaxbytes, int asciiflag)
{
int i;
struct zt_radio_param prm;
- if(debug){
- printf("String output was: ");
- for(i = 0; i < txbytes; i++)
- printf("%02X ", (unsigned char ) txbuf[i]);
- printf("\n");
- }
-
- prm.radpar = ZT_RADPAR_REMMODE;
- if (asciiflag) prm.data = ZT_RADPAR_REM_SERIAL_ASCII;
- else prm.data = ZT_RADPAR_REM_SERIAL;
- if (ioctl(myrpt->rxchannel->fds[0],ZT_RADIO_SETPARAM,&prm) == -1) return -1;
- prm.radpar = ZT_RADPAR_REMCOMMAND;
- prm.data = rxmaxbytes;
- memcpy(prm.buf,txbuf,txbytes);
- prm.index = txbytes;
- if (ioctl(myrpt->rxchannel->fds[0],ZT_RADIO_SETPARAM,&prm) == -1) return -1;
- if (rxbuf)
- {
- *rxbuf = 0;
- memcpy(rxbuf,prm.buf,prm.index);
- }
- return(prm.index);
+ if (debug) {
+ char *buf = alloca(30 + txbytes * 3);
+ int len;
+ ast_copy_string(buf, "String output was: ", 30 + txbytes * 3);
+ len = strlen(buf);
+ for (i = 0; i < txbytes; i++)
+ len += snprintf(buf + len, 30 + txbytes * 3 - len, "%02X ", (unsigned char) txbuf[i]);
+ strcat(buf + len, "\n");
+ ast_log(LOG_DEBUG, "%s", buf);
+ }
+
+ prm.radpar = ZT_RADPAR_REMMODE;
+ if (asciiflag)
+ prm.data = ZT_RADPAR_REM_SERIAL_ASCII;
+ else
+ prm.data = ZT_RADPAR_REM_SERIAL;
+ if (ioctl(myrpt->rxchannel->fds[0], ZT_RADIO_SETPARAM, &prm) == -1)
+ return -1;
+ prm.radpar = ZT_RADPAR_REMCOMMAND;
+ prm.data = rxmaxbytes;
+ memcpy(prm.buf, txbuf, txbytes);
+ prm.index = txbytes;
+ if (ioctl(myrpt->rxchannel->fds[0], ZT_RADIO_SETPARAM, &prm) == -1)
+ return -1;
+ if (rxbuf) {
+ *rxbuf = 0;
+ memcpy(rxbuf,prm.buf,prm.index);
+ }
+ return(prm.index);
}
static int setrbi(struct rpt *myrpt)
{
-char tmp[MAXREMSTR] = "",*s;
-unsigned char rbicmd[5];
-int band,txoffset = 0,txpower = 0,txpl;
+ char tmp[MAXREMSTR] = "", *s;
+ unsigned char rbicmd[5];
+ int band, txoffset = 0, txpower = 0, txpl;
/* must be a remote system */
- if (!myrpt->remote) return(0);
+ if (!myrpt->remote)
+ return(0);
/* must have rbi hardware */
- if (strncmp(myrpt->remote,remote_rig_rbi,3)) return(0);
- strncpy(tmp, myrpt->freq, sizeof(tmp) - 1);
- s = strchr(tmp,'.');
+ if (strncmp(myrpt->remote, remote_rig_rbi, 3))
+ return(0);
+ ast_copy_string(tmp, myrpt->freq, sizeof(tmp));
+ s = strchr(tmp, '.');
/* if no decimal, is invalid */
- if (s == NULL){
- if(debug)
- printf("@@@@ Frequency needs a decimal\n");
+ if (s == NULL) {
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ Frequency needs a decimal\n");
return -1;
}
*s++ = 0;
- if (strlen(tmp) < 2){
- if(debug)
- printf("@@@@ Bad MHz digits: %s\n", tmp);
+ if (strlen(tmp) < 2) {
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ Bad MHz digits: %s\n", tmp);
return -1;
}
- if (strlen(s) < 3){
- if(debug)
- printf("@@@@ Bad KHz digits: %s\n", s);
+ if (strlen(s) < 3) {
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ Bad KHz digits: %s\n", s);
return -1;
}
- if ((s[2] != '0') && (s[2] != '5')){
- if(debug)
- printf("@@@@ KHz must end in 0 or 5: %c\n", s[2]);
+ if ((s[2] != '0') && (s[2] != '5')) {
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ KHz must end in 0 or 5: %c\n", s[2]);
return -1;
}
band = rbi_mhztoband(tmp);
- if (band == -1){
- if(debug)
- printf("@@@@ Bad Band: %s\n", tmp);
+ if (band == -1) {
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ Bad Band: %s\n", tmp);
return -1;
}
txpl = rbi_pltocode(myrpt->txpl);
- if (txpl == -1){
- if(debug)
- printf("@@@@ Bad TX PL: %s\n", myrpt->txpl);
+ if (txpl == -1) {
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ Bad TX PL: %s\n", myrpt->txpl);
return -1;
}
- switch(myrpt->offset)
- {
- case REM_MINUS:
+ switch (myrpt->offset) {
+ case REM_MINUS:
txoffset = 0;
break;
- case REM_PLUS:
+ case REM_PLUS:
txoffset = 0x10;
break;
- case REM_SIMPLEX:
+ case REM_SIMPLEX:
txoffset = 0x20;
break;
}
- switch(myrpt->powerlevel)
- {
- case REM_LOWPWR:
+ switch(myrpt->powerlevel) {
+ case REM_LOWPWR:
txpower = 0;
break;
- case REM_MEDPWR:
+ case REM_MEDPWR:
txpower = 0x20;
break;
- case REM_HIPWR:
+ case REM_HIPWR:
txpower = 0x10;
break;
}
rbicmd[0] = 0;
rbicmd[1] = band | txpower | 0xc0;
rbicmd[2] = (*(s - 2) - '0') | txoffset | 0x80;
- if (s[2] == '5') rbicmd[2] |= 0x40;
+ if (s[2] == '5')
+ rbicmd[2] |= 0x40;
rbicmd[3] = ((*s - '0') << 4) + (s[1] - '0');
rbicmd[4] = txpl;
- if (myrpt->txplon) rbicmd[4] |= 0x40;
- if (myrpt->rxplon) rbicmd[4] |= 0x80;
- rbi_out(myrpt,rbicmd);
+ if (myrpt->txplon)
+ rbicmd[4] |= 0x40;
+ if (myrpt->rxplon)
+ rbicmd[4] |= 0x80;
+ rbi_out(myrpt, rbicmd);
return 0;
}
{
int dflmd = REM_MODE_FM;
- if(m == 50){ /* 6 meters */
- if(d < 10100)
+ if (m == 50) { /* 6 meters */
+ if (d < 10100)
return -1;
- }
- else if((m >= 51) && ( m < 54)){
- ;
- }
- else if(m == 144){ /* 2 meters */
- if(d < 10100)
+ } else if ((m >= 51) && ( m < 54)) {
+ /* nada */
+ } else if (m == 144) { /* 2 meters */
+ if (d < 10100)
return -1;
- }
- else if((m >= 145) && (m < 148)){
- ;
- }
- else if((m >= 222) && (m < 225)){ /* 1.25 meters */
- ;
- }
- else if((m >= 430) && (m < 450)){ /* 70 centimeters */
- ;
- }
- else if((m >= 1240) && (m < 1300)){ /* 23 centimeters */
- ;
- }
- else
+ } else if ((m >= 145) && (m < 148)) {
+ /* nada */
+ } else if ((m >= 222) && (m < 225)) { /* 1.25 meters */
+ /* nada */
+ } else if ((m >= 430) && (m < 450)) { /* 70 centimeters */
+ /* nada */
+ } else if ((m >= 1240) && (m < 1300)) { /* 23 centimeters */
+ /* nada */
+ } else
return -1;
- if(defmode)
+ if (defmode)
*defmode = dflmd;
-
return 0;
}
+static int split_decimal(char *input, int *ints, int *decs, int places)
+{
+ double input2 = 0.0;
+ long long modifier = (long long)pow(10.0, (double)places);
+ if (sscanf(input, "%lf", &input2) == 1) {
+ long long input3 = input2 * modifier;
+ *ints = input3 / modifier;
+ *decs = input3 % modifier;
+ return 0;
+ } else
+ return -1;
+}
+
/*
* Split frequency into mhz and decimals
*/
-static int split_freq(char *mhz, char *decimals, char *freq)
-{
- char freq_copy[MAXREMSTR];
- char *decp;
-
- decp = strchr(strncpy(freq_copy, freq, MAXREMSTR),'.');
- if(decp){
- *decp++ = 0;
- strncpy(mhz, freq_copy, MAXREMSTR);
- strcpy(decimals, "00000");
- strncpy(decimals, decp, strlen(decp));
- decimals[5] = 0;
- return 0;
- }
- else
- return -1;
+#define split_freq(mhz, decimal, freq) split_decimal(freq, mhz, decimal, 5)
-}
-
/*
* Split ctcss frequency into hertz and decimal
*/
-static int split_ctcss_freq(char *hertz, char *decimal, char *freq)
-{
- char freq_copy[MAXREMSTR];
- char *decp;
-
- decp = strchr(strncpy(freq_copy, freq, MAXREMSTR),'.');
- if(decp){
- *decp++ = 0;
- strncpy(hertz, freq_copy, MAXREMSTR);
- strncpy(decimal, decp, strlen(decp));
- decimal[strlen(decp)] = '\0';
- return 0;
- }
- else
- return -1;
-}
-
-
+#define split_ctcss_freq(hertz, decimal, freq) split_decimal(freq, hertz, decimal, 1)
/*
* FT-897 I/O handlers
/* Check to see that the frequency is valid */
/* Hard coded limits now, configurable later, maybe? */
-
static int check_freq_ft897(int m, int d, int *defmode)
{
int dflmd = REM_MODE_FM;
- if(m == 1){ /* 160 meters */
+ if (m == 1) { /* 160 meters */
dflmd = REM_MODE_LSB;
- if(d < 80001)
+ if (d < 80001)
return -1;
- }
- else if(m == 3){ /* 80 meters */
+ } else if (m == 3) { /* 80 meters */
dflmd = REM_MODE_LSB;
- if(d < 75001)
+ if (d < 75001)
return -1;
- }
- else if(m == 7){ /* 40 meters */
+ } else if (m == 7) { /* 40 meters */
dflmd = REM_MODE_LSB;
- if((d < 15001) || (d > 29999))
+ if ((d < 15001) || (d > 29999))
return -1;
- }
- else if(m == 14){ /* 20 meters */
+ } else if (m == 14) { /* 20 meters */
dflmd = REM_MODE_USB;
- if((d < 15001) || (d > 34999))
+ if ((d < 15001) || (d > 34999))
return -1;
- }
- else if(m == 18){ /* 17 meters */
+ } else if (m == 18) { /* 17 meters */
dflmd = REM_MODE_USB;
- if((d < 11001) || (d > 16797))
+ if ((d < 11001) || (d > 16797))
return -1;
- }
- else if(m == 21){ /* 15 meters */
+ } else if (m == 21) { /* 15 meters */
dflmd = REM_MODE_USB;
- if((d < 20001) || (d > 44999))
+ if ((d < 20001) || (d > 44999))
return -1;
- }
- else if(m == 24){ /* 12 meters */
+ } else if (m == 24) { /* 12 meters */
dflmd = REM_MODE_USB;
- if((d < 93001) || (d > 98999))
+ if ((d < 93001) || (d > 98999))
return -1;
- }
- else if(m == 28){ /* 10 meters */
+ } else if (m == 28) { /* 10 meters */
dflmd = REM_MODE_USB;
- if(d < 30001)
+ if (d < 30001)
return -1;
- }
- else if(m == 29){
- if(d >= 51000)
+ } else if (m == 29) {
+ if (d >= 51000)
dflmd = REM_MODE_FM;
else
dflmd = REM_MODE_USB;
- if(d > 69999)
+ if (d > 69999)
return -1;
- }
- else if(m == 50){ /* 6 meters */
- if(d < 10100)
+ } else if (m == 50) { /* 6 meters */
+ if (d < 10100)
return -1;
- if(d >= 30000)
+ if (d >= 30000)
dflmd = REM_MODE_FM;
else
dflmd = REM_MODE_USB;
-
- }
- else if((m >= 51) && ( m < 54)){
+ } else if ((m >= 51) && ( m < 54)) {
dflmd = REM_MODE_FM;
- }
- else if(m == 144){ /* 2 meters */
- if(d < 10100)
+ } else if (m == 144) { /* 2 meters */
+ if (d < 10100)
return -1;
- if(d >= 30000)
+ if (d >= 30000)
dflmd = REM_MODE_FM;
else
dflmd = REM_MODE_USB;
- }
- else if((m >= 145) && (m < 148)){
+ } else if ((m >= 145) && (m < 148)) {
dflmd = REM_MODE_FM;
- }
- else if((m >= 430) && (m < 450)){ /* 70 centimeters */
- if(m < 438)
+ } else if ((m >= 430) && (m < 450)) { /* 70 centimeters */
+ if (m < 438)
dflmd = REM_MODE_USB;
else
dflmd = REM_MODE_FM;
;
- }
- else
+ } else
return -1;
- if(defmode)
+ if (defmode)
*defmode = dflmd;
return 0;
static int set_freq_ft897(struct rpt *myrpt, char *newfreq)
{
- char mhz[MAXREMSTR];
- char decimals[MAXREMSTR];
unsigned char cmdstr[5];
- int fd,m,d;
+ int fd, m, d;
fd = 0;
- if(debug)
- printf("New frequency: %s\n",newfreq);
+ if (debug)
+ ast_log(LOG_DEBUG, "New frequency: %s\n", newfreq);
- if(split_freq(mhz, decimals, newfreq))
+ if (split_freq(&m, &d, newfreq))
return -1;
- m = atoi(mhz);
- d = atoi(decimals);
-
/* The FT-897 likes packed BCD frequencies */
- cmdstr[0] = ((m / 100) << 4) + ((m % 100)/10); /* 100MHz 10Mhz */
- cmdstr[1] = ((m % 10) << 4) + (d / 10000); /* 1MHz 100KHz */
- cmdstr[2] = (((d % 10000)/1000) << 4) + ((d % 1000)/ 100); /* 10KHz 1KHz */
- cmdstr[3] = (((d % 100)/10) << 4) + (d % 10); /* 100Hz 10Hz */
- cmdstr[4] = 0x01; /* command */
+ cmdstr[0] = ((m / 100) << 4) + ((m % 100) / 10); /* 100MHz 10Mhz */
+ cmdstr[1] = ((m % 10) << 4) + (d / 10000); /* 1MHz 100KHz */
+ cmdstr[2] = (((d % 10000) / 1000) << 4) + ((d % 1000) / 100); /* 10KHz 1KHz */
+ cmdstr[3] = (((d % 100) / 10) << 4) + (d % 10); /* 100Hz 10Hz */
+ cmdstr[4] = 0x01; /* command */
return serial_remote_io(myrpt, cmdstr, 5, NULL, 0, 0);
-
}
/* ft-897 simple commands */
static int simple_command_ft897(struct rpt *myrpt, char command)
{
- unsigned char cmdstr[5];
-
- memset(cmdstr, 0, 5);
-
- cmdstr[4] = command;
+ unsigned char cmdstr[5] = { 0, 0, 0, 0, command };
return serial_remote_io(myrpt, cmdstr, 5, NULL, 0, 0);
-
}
/* ft-897 offset */
static int set_offset_ft897(struct rpt *myrpt, char offset)
{
- unsigned char cmdstr[5];
-
- memset(cmdstr, 0, 5);
+ unsigned char cmdstr[5] = "";
- switch(offset){
- case REM_SIMPLEX:
- cmdstr[0] = 0x89;
- break;
-
- case REM_MINUS:
- cmdstr[0] = 0x09;
- break;
-
- case REM_PLUS:
- cmdstr[0] = 0x49;
- break;
-
- default:
- return -1;
+ switch (offset) {
+ case REM_SIMPLEX:
+ cmdstr[0] = 0x89;
+ break;
+ case REM_MINUS:
+ cmdstr[0] = 0x09;
+ break;
+ case REM_PLUS:
+ cmdstr[0] = 0x49;
+ break;
+ default:
+ return -1;
}
cmdstr[4] = 0x09;
static int set_mode_ft897(struct rpt *myrpt, char newmode)
{
- unsigned char cmdstr[5];
-
- memset(cmdstr, 0, 5);
-
- switch(newmode){
- case REM_MODE_FM:
- cmdstr[0] = 0x08;
- break;
+ unsigned char cmdstr[5] = { 0, 0, 0, 0, 0x07 };
- case REM_MODE_USB:
- cmdstr[0] = 0x01;
- break;
-
- case REM_MODE_LSB:
- cmdstr[0] = 0x00;
- break;
-
- case REM_MODE_AM:
- cmdstr[0] = 0x04;
- break;
-
- default:
- return -1;
+ switch (newmode) {
+ case REM_MODE_FM:
+ cmdstr[0] = 0x08;
+ break;
+ case REM_MODE_USB:
+ cmdstr[0] = 0x01;
+ break;
+ case REM_MODE_LSB:
+ cmdstr[0] = 0x00;
+ break;
+ case REM_MODE_AM:
+ cmdstr[0] = 0x04;
+ break;
+ default:
+ return -1;
}
- cmdstr[4] = 0x07;
return serial_remote_io(myrpt, cmdstr, 5, NULL, 0, 0);
}
static int set_ctcss_mode_ft897(struct rpt *myrpt, char txplon, char rxplon)
{
- unsigned char cmdstr[5];
-
- memset(cmdstr, 0, 5);
-
- if(rxplon && txplon)
+ unsigned char cmdstr[5] = { 0, 0, 0, 0, 0x0A };
+
+ if (rxplon && txplon)
cmdstr[0] = 0x2A; /* Encode and Decode */
else if (!rxplon && txplon)
cmdstr[0] = 0x4A; /* Encode only */
else
cmdstr[0] = 0x8A; /* OFF */
- cmdstr[4] = 0x0A;
-
return serial_remote_io(myrpt, cmdstr, 5, NULL, 0, 0);
}
static int set_ctcss_freq_ft897(struct rpt *myrpt, char *txtone, char *rxtone)
{
- unsigned char cmdstr[5];
- char hertz[MAXREMSTR],decimal[MAXREMSTR];
- int h,d;
+ unsigned char cmdstr[5] = { 0, 0, 0, 0, 0x0B };
+ int hertz, decimal;
- memset(cmdstr, 0, 5);
-
- if(split_ctcss_freq(hertz, decimal, txtone))
+ if (split_ctcss_freq(&hertz, &decimal, txtone))
return -1;
- h = atoi(hertz);
- d = atoi(decimal);
-
- cmdstr[0] = ((h / 100) << 4) + (h % 100)/ 10;
- cmdstr[1] = ((h % 10) << 4) + (d % 10);
+ cmdstr[0] = ((hertz / 100) << 4) + (hertz % 100) / 10;
+ cmdstr[1] = ((hertz % 10) << 4) + (decimal % 10);
- if(rxtone){
-
- if(split_ctcss_freq(hertz, decimal, rxtone))
+ if (rxtone) {
+ if (split_ctcss_freq(&hertz, &decimal, rxtone))
return -1;
- h = atoi(hertz);
- d = atoi(decimal);
-
- cmdstr[2] = ((h / 100) << 4) + (h % 100)/ 10;
- cmdstr[3] = ((h % 10) << 4) + (d % 10);
+ cmdstr[2] = ((hertz / 100) << 4) + (hertz % 100)/ 10;
+ cmdstr[3] = ((hertz % 10) << 4) + (decimal % 10);
}
- cmdstr[4] = 0x0B;
return serial_remote_io(myrpt, cmdstr, 5, NULL, 0, 0);
}
{
int res;
- if(debug)
- printf("@@@@ lock on\n");
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ lock on\n");
res = simple_command_ft897(myrpt, 0x00); /* LOCK on */
- if(debug)
- printf("@@@@ ptt off\n");
+ if (debug)
+ ast_log(LOG_DEBUG, "@@@@ ptt off\n");
- if(!res)
+ if (!res)
res = simple_command_ft897(myrpt, 0x88); /* PTT off */
- if(debug)
- printf("Modulation mode\n");
+ if (debug)
+ ast_log(LOG_DEBUG, "Modulation mode\n");
- if(!res)
+ if (!res)
res = set_mode_ft897(myrpt, myrpt->remmode); /* Modulation mode */
- if(debug)
- printf("Split off\n");
+ if (debug)
+ ast_log(LOG_DEBUG, "Split off\n");
- if(!res)
+ if (!res)
simple_command_ft897(myrpt, 0x82); /* Split off */
- if(debug)
- printf("Frequency\n");
+ if (debug)
+ ast_log(LOG_DEBUG, "Frequency\n");
- if(!res)
+ if (!res)
res = set_freq_ft897(myrpt, myrpt->freq); /* Frequency */
- if((myrpt->remmode == REM_MODE_FM)){
- if(debug)
- printf("Offset\n");
- if(!res)
+ if ((myrpt->remmode == REM_MODE_FM)) {
+ if (debug)
+ ast_log(LOG_DEBUG, "Offset\n");
+ if (!res)
res = set_offset_ft897(myrpt, myrpt->offset); /* Offset if FM */
- if((!res)&&(myrpt->rxplon || myrpt->txplon)){
- if(debug)
- printf("CTCSS tone freqs.\n");
+ if ((!res)&&(myrpt->rxplon || myrpt->txplon)) {
+ if (debug)
+ ast_log(LOG_DEBUG, "CTCSS tone freqs.\n");
res = set_ctcss_freq_ft897(myrpt, myrpt->txpl, myrpt->rxpl); /* CTCSS freqs if CTCSS is enabled */
}
- if(!res){
- if(debug)
- printf("CTCSS mode\n");
+ if (!res) {
+ if (debug)
+ ast_log(LOG_DEBUG, "CTCSS mode\n");
res = set_ctcss_mode_ft897(myrpt, myrpt->txplon, myrpt->rxplon); /* CTCSS mode */
}
}
- if((myrpt->remmode == REM_MODE_USB)||(myrpt->remmode == REM_MODE_LSB)){
- if(debug)
- printf("Clarifier off\n");
+ if ((myrpt->remmode == REM_MODE_USB)||(myrpt->remmode == REM_MODE_LSB)) {
+ if (debug)
+ ast_log(LOG_DEBUG, "Clarifier off\n");
simple_command_ft897(myrpt, 0x85); /* Clarifier off if LSB or USB */
}
return res;
static int multimode_bump_freq_ft897(struct rpt *myrpt, int interval)
{
- int m,d;
- char mhz[MAXREMSTR], decimals[MAXREMSTR];
+ int m, d;
- if(debug)
- printf("Before bump: %s\n", myrpt->freq);
+ if (debug)
+ ast_log(LOG_DEBUG, "Before bump: %s\n", myrpt->freq);
- if(split_freq(mhz, decimals, myrpt->freq))
+ if (split_freq(&m, &d, myrpt->freq))
return -1;
- m = atoi(mhz);
- d = atoi(decimals);
-
d += (interval / 10); /* 10Hz resolution */
- if(d < 0){
+ if (d < 0) {
m--;
d += 100000;
- }
- else if(d >= 100000){
+ } else if (d >= 100000) {
m++;
d -= 100000;
}
- if(check_freq_ft897(m, d, NULL)){
- if(debug)
- printf("Bump freq invalid\n");
+ if (check_freq_ft897(m, d, NULL)) {
+ if (debug)
+ ast_log(LOG_DEBUG, "Bump freq invalid\n");
return -1;
}
snprintf(myrpt->freq, MAXREMSTR, "%d.%05d", m, d);
- if(debug)
- printf("After bump: %s\n", myrpt->freq);
+ if (debug)
+ ast_log(LOG_DEBUG, "After bump: %s\n", myrpt->freq);
return set_freq_ft897(myrpt, myrpt->freq);
}
static int setrem(struct rpt *myrpt)
{
return 0; /* XXX BROKEN!! */
- if(!strcmp(myrpt->remote, remote_rig_ft897))
+ if (!strcmp(myrpt->remote, remote_rig_ft897))
return set_ft897(myrpt);
- else if(!strcmp(myrpt->remote, remote_rig_rbi))
+ else if (!strcmp(myrpt->remote, remote_rig_rbi))
return setrbi(myrpt);
else
return -1;
static int closerem(struct rpt *myrpt)
{
return 0; /* XXX BROKEN!! */
- if(!strcmp(myrpt->remote, remote_rig_ft897))
+ if (!strcmp(myrpt->remote, remote_rig_ft897))
return closerem_ft897(myrpt);
else
return 0;
static int check_freq(struct rpt *myrpt, int m, int d, int *defmode)
{
- if(!strcmp(myrpt->remote, remote_rig_ft897))
+ if (!strcmp(myrpt->remote, remote_rig_ft897))
return check_freq_ft897(m, d, defmode);
- else if(!strcmp(myrpt->remote, remote_rig_rbi))
+ else if (!strcmp(myrpt->remote, remote_rig_rbi))
return check_freq_rbi(m, d, defmode);
else
return -1;
static int multimode_capable(struct rpt *myrpt)
{
- if(!strcmp(myrpt->remote, remote_rig_ft897))
+ if (!strcmp(myrpt->remote, remote_rig_ft897))
return 1;
return 0;
}
static int multimode_bump_freq(struct rpt *myrpt, int interval)
{
- if(!strcmp(myrpt->remote, remote_rig_ft897))
+ if (!strcmp(myrpt->remote, remote_rig_ft897))
return multimode_bump_freq_ft897(myrpt, interval);
else
return -1;
* This is called periodically when in scan mode
*/
-
static int service_scan(struct rpt *myrpt)
{
- int res, interval;
- char mhz[MAXREMSTR], decimals[MAXREMSTR], k10=0i, k100=0;
+ int res, interval, mhz, decimals;
+ char k10=0, k100=0;
- switch(myrpt->hfscanmode){
+ switch (myrpt->hfscanmode) {
- case HF_SCAN_DOWN_SLOW:
- interval = -10; /* 100Hz /sec */
- break;
+ case HF_SCAN_DOWN_SLOW:
+ interval = -10; /* 100Hz /sec */
+ break;
- case HF_SCAN_DOWN_QUICK:
- interval = -50; /* 500Hz /sec */
- break;
+ case HF_SCAN_DOWN_QUICK:
+ interval = -50; /* 500Hz /sec */
+ break;
- case HF_SCAN_DOWN_FAST:
- interval = -200; /* 2KHz /sec */
- break;
+ case HF_SCAN_DOWN_FAST:
+ interval = -200; /* 2KHz /sec */
+ break;
- case HF_SCAN_UP_SLOW:
- interval = 10; /* 100Hz /sec */
- break;
+ case HF_SCAN_UP_SLOW:
+ interval = 10; /* 100Hz /sec */
+ break;
- case HF_SCAN_UP_QUICK:
- interval = 50; /* 500 Hz/sec */
- break;
+ case HF_SCAN_UP_QUICK:
+ interval = 50; /* 500 Hz/sec */
+ break;
- case HF_SCAN_UP_FAST:
- interval = 200; /* 2KHz /sec */
- break;
+ case HF_SCAN_UP_FAST:
+ interval = 200; /* 2KHz /sec */
+ break;
- default:
- myrpt->hfscanmode = 0; /* Huh? */
- return -1;
+ default:
+ myrpt->hfscanmode = 0; /* Huh? */
+ return -1;
}
- res = split_freq(mhz, decimals, myrpt->freq);
+ res = split_freq(&mhz, &decimals, myrpt->freq);
- if(!res){
- k100 =decimals[0];
- k10 = decimals[1];
+ if (!res) {
+ k100 = decimals / 10000;
+ k10 = (decimals / 1000) % 10;
res = multimode_bump_freq(myrpt, interval);
}
- if(!res)
- res = split_freq(mhz, decimals, myrpt->freq);
+ if (!res)
+ res = split_freq(&mhz, &decimals, myrpt->freq);
-
- if(res){
- stop_scan(myrpt,1);
+ if (res) {
+ stop_scan(myrpt, 1);
return -1;
}
/* Announce 10KHz boundaries */
- if(k10 != decimals[1]){
- int myhund = (interval < 0) ? k100 : decimals[0];
- int myten = (interval < 0) ? k10 : decimals[1];
- myrpt->hfscanstatus = (myten == '0') ? (myhund - '0') * 100 : (myten - '0') * 10;
+ if (k10 != (decimals / 1000) % 10) {
+ int myhund = (interval < 0) ? k100 : decimals / 10000;
+ int myten = (interval < 0) ? k10 : (decimals / 1000) % 10;
+ myrpt->hfscanstatus = (myten == 0) ? (myhund) * 100 : (myten) * 10;
}
return res;
static int rmt_telem_start(struct rpt *myrpt, struct ast_channel *chan, int delay)
{
- myrpt->remotetx = 0;
- ast_indicate(myrpt->txchannel,AST_CONTROL_RADIO_UNKEY);
- if (!myrpt->remoterx)
- ast_indicate(chan,AST_CONTROL_RADIO_KEY);
- if (ast_safe_sleep(chan, delay) == -1)
- return -1;
- return 0;
+ myrpt->remotetx = 0;
+ ast_indicate(myrpt->txchannel, AST_CONTROL_RADIO_UNKEY);
+ if (!myrpt->remoterx)
+ ast_indicate(chan, AST_CONTROL_RADIO_KEY);
+ if (ast_safe_sleep(chan, delay) == -1)
+ return -1;
+ return 0;
}
static int rmt_telem_finish(struct rpt *myrpt, struct ast_channel *chan)
{
+ struct zt_params par;
-struct zt_params par;
-
- if (ioctl(myrpt->txchannel->fds[0],ZT_GET_PARAMS,&par) == -1)
- {
+ if (ioctl(myrpt->txchannel->fds[0], ZT_GET_PARAMS, &par) == -1) {
return -1;
}
- if (!par.rxisoffhook)
- {
- ast_indicate(myrpt->remchannel,AST_CONTROL_RADIO_UNKEY);
+ if (!par.rxisoffhook) {
+ ast_indicate(myrpt->remchannel, AST_CONTROL_RADIO_UNKEY);
myrpt->remoterx = 0;
- }
- else
- {
+ } else {
myrpt->remoterx = 1;
}
return 0;
res = rmt_telem_start(myrpt, chan, delay);
- if(!res)
+ if (!res)
res = sayfile(chan, filename);
- if(!res)
+ if (!res)
res = rmt_telem_finish(myrpt, chan);
return res;
}
res = rmt_telem_start(myrpt, chan, delay);
- if(!res)
+ if (!res)
res = saycharstr(chan, charstr);
- if(!res)
+ if (!res)
res = rmt_telem_finish(myrpt, chan);
return res;
}
-
-
/*
* Remote base function
*/
static int function_remote(struct rpt *myrpt, char *param, char *digitbuf, int command_source, struct rpt_link *mylink)
{
- char *s,*s1,*s2;
+ char *s, *modestr;
const char *val;
- int i,j,ht,k,l,ls2,m,d,res,offset,offsave, modesave, defmode;
+ int i, j, ht, k, l, ls2, res, offset, offsave, modesave, defmode;
char multimode = 0;
char oc;
char tmp[20], freq[20] = "", savestr[20] = "";
- char mhz[MAXREMSTR], decimals[MAXREMSTR];
+ int mhz, decimals;
struct ast_channel *mychannel;
-
- if((!param) || (command_source == SOURCE_RPT) || (command_source == SOURCE_LNK))
+ AST_DECLARE_APP_ARGS(args1,
+ AST_APP_ARG(freq);
+ AST_APP_ARG(xpl);
+ AST_APP_ARG(mode);
+ );
+ AST_DECLARE_APP_ARGS(args,
+ AST_APP_ARG(s1);
+ AST_APP_ARG(s2);
+ );
+
+ if ((!param) || (command_source == SOURCE_RPT) || (command_source == SOURCE_LNK))
return DC_ERROR;
multimode = multimode_capable(myrpt);
-
mychannel = myrpt->remchannel;
-
-
- switch(myatoi(param)){
- case 1: /* retrieve memory */
- if(strlen(digitbuf) < 2) /* needs 2 digits */
- break;
+ switch (myatoi(param)) {
+ case 1: /* retrieve memory */
+ if (strlen(digitbuf) < 2) /* needs 2 digits */
+ break;
- for(i = 0 ; i < 2 ; i++){
- if((digitbuf[i] < '0') || (digitbuf[i] > '9'))
- return DC_ERROR;
- }
-
- val = ast_variable_retrieve(myrpt->cfg, myrpt->p.memory, digitbuf);
- if (!val){
- if (ast_safe_sleep(mychannel,1000) == -1)
- return DC_ERROR;
- sayfile(mychannel,"rpt/memory_notfound");
- return DC_COMPLETE;
- }
- ast_copy_string(tmp, val, sizeof(tmp));
- s = strchr(tmp,',');
- if (!s)
+ for (i = 0 ; i < 2 ; i++) {
+ if ((digitbuf[i] < '0') || (digitbuf[i] > '9'))
return DC_ERROR;
- *s++ = 0;
- s1 = strchr(s,',');
- if (!s1)
+ }
+
+ val = ast_variable_retrieve(myrpt->cfg, myrpt->p.memory, digitbuf);
+ if (!val) {
+ if (ast_safe_sleep(mychannel, 1000) == -1)
return DC_ERROR;
- *s1++ = 0;
- strncpy(myrpt->freq, tmp, sizeof(myrpt->freq) - 1);
- strncpy(myrpt->rxpl, s, sizeof(myrpt->rxpl) - 1);
- strncpy(myrpt->txpl, s, sizeof(myrpt->rxpl) - 1);
- myrpt->remmode = REM_MODE_FM;
- myrpt->offset = REM_SIMPLEX;
- myrpt->powerlevel = REM_MEDPWR;
- myrpt->txplon = myrpt->rxplon = 0;
- while(*s1)
- {
- switch(*s1++){
- case 'A':
- case 'a':
- strcpy(myrpt->rxpl, "100.0");
- strcpy(myrpt->txpl, "100.0");
- myrpt->remmode = REM_MODE_AM;
- break;
-
- case 'B':
- case 'b':
- strcpy(myrpt->rxpl, "100.0");
- strcpy(myrpt->txpl, "100.0");
- myrpt->remmode = REM_MODE_LSB;
- break;
-
- case 'F':
- myrpt->remmode = REM_MODE_FM;
- break;
+ sayfile(mychannel, "rpt/memory_notfound");
+ return DC_COMPLETE;
+ }
+ s = ast_strdupa(val);
+ AST_NONSTANDARD_APP_ARGS(args1, s, ',');
+ if (args1.argc < 3)
+ return DC_ERROR;
+ ast_copy_string(myrpt->freq, args1.freq, sizeof(myrpt->freq));
+ ast_copy_string(myrpt->rxpl, args1.xpl, sizeof(myrpt->rxpl));
+ ast_copy_string(myrpt->txpl, args1.xpl, sizeof(myrpt->rxpl));
+ myrpt->remmode = REM_MODE_FM;
+ myrpt->offset = REM_SIMPLEX;
+ myrpt->powerlevel = REM_MEDPWR;
+ myrpt->txplon = myrpt->rxplon = 0;
+ modestr = args1.mode;
+ while (*modestr) {
+ switch (*modestr++) {
+ case 'A':
+ case 'a':
+ strcpy(myrpt->rxpl, "100.0");
+ strcpy(myrpt->txpl, "100.0");
+ myrpt->remmode = REM_MODE_AM;
+ break;
- case 'L':
- case 'l':
- myrpt->powerlevel = REM_LOWPWR;
- break;
- case 'H':
- case 'h':
- myrpt->powerlevel = REM_HIPWR;
- break;
-
- case 'M':
- case 'm':
- myrpt->powerlevel = REM_MEDPWR;
- break;
-
- case '-':
- myrpt->offset = REM_MINUS;
- break;
-
- case '+':
- myrpt->offset = REM_PLUS;
- break;
-
- case 'S':
- case 's':
- myrpt->offset = REM_SIMPLEX;
- break;
-
- case 'T':
- case 't':
- myrpt->txplon = 1;
- break;
-
- case 'R':
- case 'r':
- myrpt->rxplon = 1;
- break;
+ case 'B':
+ case 'b':
+ strcpy(myrpt->rxpl, "100.0");
+ strcpy(myrpt->txpl, "100.0");
+ myrpt->remmode = REM_MODE_LSB;
+ break;
- case 'U':
- case 'u':
- strcpy(myrpt->rxpl, "100.0");
- strcpy(myrpt->txpl, "100.0");
- myrpt->remmode = REM_MODE_USB;
- break;
- }
+ case 'F':
+ myrpt->remmode = REM_MODE_FM;
+ break;
+
+ case 'L':
+ case 'l':
+ myrpt->powerlevel = REM_LOWPWR;
+ break;
+ case 'H':
+ case 'h':
+ myrpt->powerlevel = REM_HIPWR;
+ break;
+
+ case 'M':
+ case 'm':
+ myrpt->powerlevel = REM_MEDPWR;
+ break;
+
+ case '-':
+ myrpt->offset = REM_MINUS;
+ break;
+
+ case '+':
+ myrpt->offset = REM_PLUS;
+ break;
+
+ case 'S':
+ case 's':
+ myrpt->offset = REM_SIMPLEX;
+ break;
+
+ case 'T':
+ case 't':
+ myrpt->txplon = 1;
+ break;
+
+ case 'R':
+ case 'r':
+ myrpt->rxplon = 1;
+ break;
+
+ case 'U':
+ case 'u':
+ strcpy(myrpt->rxpl, "100.0");
+ strcpy(myrpt->txpl, "100.0");
+ myrpt->remmode = REM_MODE_USB;
+ break;
}
-
-
- if (setrem(myrpt) == -1)
- return DC_ERROR;
-
-
- return DC_COMPLETE;
-
- case 2: /* set freq and offset */
-
-
- for(i = 0, j = 0, k = 0, l = 0 ; digitbuf[i] ; i++){ /* look for M+*K+*O or M+*H+* depending on mode */
- if(digitbuf[i] == '*'){
- j++;
- continue;
- }
- if((digitbuf[i] < '0') || (digitbuf[i] > '9'))
- goto invalid_freq;
- else{
- if(j == 0)
- l++; /* # of digits before first * */
- if(j == 1)
- k++; /* # of digits after first * */
- }
+ }
+
+ if (setrem(myrpt) == -1)
+ return DC_ERROR;
+
+ return DC_COMPLETE;
+
+ case 2: /* set freq and offset */
+ for (i = 0, j = 0, k = 0, l = 0 ; digitbuf[i] ; i++) { /* look for M+*K+*O or M+*H+* depending on mode */
+ if (digitbuf[i] == '*') {
+ j++;
+ continue;
}
-
- i = strlen(digitbuf) - 1;
- if(multimode){
- if((j > 2) || (l > 3) || (k > 6))
- goto invalid_freq; /* &^@#! */
- }
- else{
- if((j > 2) || (l > 4) || (k > 3))
- goto invalid_freq; /* &^@#! */
+ if ((digitbuf[i] < '0') || (digitbuf[i] > '9'))
+ goto invalid_freq;
+ else {
+ if (j == 0)
+ l++; /* # of digits before first * */
+ if (j == 1)
+ k++; /* # of digits after first * */
}
+ }
- /* Wait for M+*K+* */
+ i = strlen(digitbuf) - 1;
+ if (multimode) {
+ if ((j > 2) || (l > 3) || (k > 6))
+ goto invalid_freq; /* &^@#! */
+ } else {
+ if ((j > 2) || (l > 4) || (k > 3))
+ goto invalid_freq; /* &^@#! */
+ }
- if(j < 2)
- break; /* Not yet */
+ /* Wait for M+*K+* */
- /* We have a frequency */
+ if (j < 2)
+ break; /* Not yet */
- strncpy(tmp, digitbuf ,sizeof(tmp) - 1);
-
- s = tmp;
- s1 = strsep(&s, "*"); /* Pick off MHz */
- s2 = strsep(&s,"*"); /* Pick off KHz and Hz */
- ls2 = strlen(s2);
-
- switch(ls2){ /* Allow partial entry of khz and hz digits for laziness support */
- case 1:
- ht = 0;
- k = 100 * atoi(s2);
- break;
-
- case 2:
- ht = 0;
- k = 10 * atoi(s2);
- break;
-
- case 3:
- if(!multimode){
- if((s2[2] != '0')&&(s2[2] != '5'))
- goto invalid_freq;
- }
- ht = 0;
- k = atoi(s2);
- break;
- case 4:
- k = atoi(s2)/10;
- ht = 10 * (atoi(s2+(ls2-1)));
- break;
+ /* We have a frequency */
- case 5:
- k = atoi(s2)/100;
- ht = (atoi(s2+(ls2-2)));
- break;
-
- default:
+ s = ast_strdupa(digitbuf);
+ AST_NONSTANDARD_APP_ARGS(args, s, '*');
+ ls2 = strlen(args.s2);
+
+ switch (ls2) { /* Allow partial entry of khz and hz digits for laziness support */
+ case 1:
+ ht = 0;
+ k = 100 * atoi(args.s2);
+ break;
+ case 2:
+ ht = 0;
+ k = 10 * atoi(args.s2);
+ break;
+ case 3:
+ if (!multimode) {
+ if ((args.s2[2] != '0') && (args.s2[2] != '5'))
goto invalid_freq;
}
+ ht = 0;
+ k = atoi(args.s2);
+ break;
+ case 4:
+ k = atoi(args.s2) / 10;
+ ht = 10 * (atoi(args.s2 + (ls2 - 1)));
+ break;
+ case 5:
+ k = atoi(args.s2) / 100;
+ ht = (atoi(args.s2 + (ls2 - 2)));
+ break;
+ default:
+ goto invalid_freq;
+ }
- /* Check frequency for validity and establish a default mode */
+ /* Check frequency for validity and establish a default mode */
- snprintf(freq, sizeof(freq), "%s.%03d%02d",s1, k, ht);
+ snprintf(freq, sizeof(freq), "%s.%03d%02d", args.s1, k, ht);
- if(debug)
- printf("New frequency: %s\n", freq);
+ if (debug)
+ ast_log(LOG_DEBUG, "New frequency: %s\n", freq);
- split_freq(mhz, decimals, freq);
- m = atoi(mhz);
- d = atoi(decimals);
-
- if(check_freq(myrpt, m, d, &defmode)) /* Check to see if frequency entered is legit */
- goto invalid_freq;
+ split_freq(&mhz, &decimals, freq);
+ if (check_freq(myrpt, mhz, decimals, &defmode)) /* Check to see if frequency entered is legit */
+ goto invalid_freq;
- if((defmode == REM_MODE_FM) && (digitbuf[i] == '*')) /* If FM, user must enter and additional offset digit */
- break; /* Not yet */
+ if ((defmode == REM_MODE_FM) && (digitbuf[i] == '*')) /* If FM, user must enter and additional offset digit */
+ break; /* Not yet */
+ offset = REM_SIMPLEX; /* Assume simplex */
- offset = REM_SIMPLEX; /* Assume simplex */
-
- if(defmode == REM_MODE_FM){
- oc = *s; /* Pick off offset */
-
- if (oc){
- switch(oc){
- case '1':
- offset = REM_MINUS;
- break;
-
- case '2':
- offset = REM_SIMPLEX;
- break;
-
- case '3':
- offset = REM_PLUS;
- break;
-
- default:
- goto invalid_freq;
- }
+ if (defmode == REM_MODE_FM) {
+ oc = *s; /* Pick off offset */
+ if (oc) {
+ switch (oc) {
+ case '1':
+ offset = REM_MINUS;
+ break;
+ case '2':
+ offset = REM_SIMPLEX;
+ break;
+ case '3':
+ offset = REM_PLUS;
+ break;
+ default:
+ goto invalid_freq;
}
- }
- offsave = myrpt->offset;
- modesave = myrpt->remmode;
- strncpy(savestr, myrpt->freq, sizeof(savestr) - 1);
- strncpy(myrpt->freq, freq, sizeof(myrpt->freq) - 1);
- myrpt->offset = offset;
- myrp
projects / asterisk/asterisk.git / commitdiff