762
762
/*! \brief TRUE if dynamic faxbuffers are configured for use, default is OFF */
763
763
unsigned int usefaxbuffers:1;
764
764
/*! \brief TRUE while dynamic faxbuffers are in use */
765
unsigned int faxbuffersinuse:1;
765
unsigned int bufferoverrideinuse:1;
766
766
/*! \brief TRUE if over a radio and dahdi_read() has been called. */
767
767
unsigned int firstradio:1;
1396
1396
static int dahdi_fixup(struct ast_channel *oldchan, struct ast_channel *newchan);
1397
1397
static int dahdi_setoption(struct ast_channel *chan, int option, void *data, int datalen);
1398
1398
static int dahdi_func_read(struct ast_channel *chan, const char *function, char *data, char *buf, size_t len);
1399
static int dahdi_func_write(struct ast_channel *chan, const char *function, char *data, const char *value);
1399
1400
static struct dahdi_pvt *handle_init_event(struct dahdi_pvt *i, int event);
1401
1402
static const struct ast_channel_tech dahdi_tech = {
5036
5046
ast_mutex_unlock(&p->lock);
5038
5048
ast_copy_string(buf, "", len);
5056
static int parse_buffers_policy(const char *parse, int *num_buffers, int *policy)
5059
char policy_str[21] = "";
5061
if (((res = sscanf(parse, "%d,%20s", num_buffers, policy_str)) != 2) &&
5062
((res = sscanf(parse, "%d|%20s", num_buffers, policy_str)) != 2)) {
5063
ast_log(LOG_WARNING, "Parsing buffer string '%s' failed.\n", parse);
5066
if (*num_buffers < 0) {
5067
ast_log(LOG_WARNING, "Invalid buffer count given '%d'.\n", *num_buffers);
5070
if (!strcasecmp(policy_str, "full")) {
5071
*policy = DAHDI_POLICY_WHEN_FULL;
5072
} else if (!strcasecmp(policy_str, "immediate")) {
5073
*policy = DAHDI_POLICY_IMMEDIATE;
5074
#ifdef DAHDI_POLICY_HALF_FULL
5075
} else if (!strcasecmp(policy_str, "half")) {
5076
*policy = DAHDI_POLICY_HALF_FULL;
5079
ast_log(LOG_WARNING, "Invalid policy name given '%s'.\n", policy_str);
5086
static int dahdi_func_write(struct ast_channel *chan, const char *function, char *data, const char *value)
5088
struct dahdi_pvt *p = chan->tech_pvt;
5091
if (!strcasecmp(data, "buffers")) {
5092
int num_bufs, policy;
5094
if (!(parse_buffers_policy(value, &num_bufs, &policy))) {
5095
struct dahdi_bufferinfo bi = {
5096
.txbufpolicy = policy,
5097
.rxbufpolicy = policy,
5098
.bufsize = p->bufsize,
5099
.numbufs = num_bufs,
5103
if ((bpres = ioctl(p->subs[SUB_REAL].dfd, DAHDI_SET_BUFINFO, &bi)) < 0) {
5104
ast_log(LOG_WARNING, "Channel '%d' unable to override buffer policy: %s\n", p->channel, strerror(errno));
5106
p->bufferoverrideinuse = 1;
5044
5118
static void dahdi_unlink(struct dahdi_pvt *slave, struct dahdi_pvt *master, int needlock)
5389
5462
#ifdef PRI_2BCT
5392
if (p0->transfer && p1->transfer
5394
&& !triedtopribridge) {
5395
pri_channel_bridge(q931c0, q931c1);
5463
if (!triedtopribridge) {
5396
5464
triedtopribridge = 1;
5465
if (p0->pri && p0->pri == p1->pri && p0->transfer && p1->transfer) {
5466
ast_mutex_lock(&p0->pri->lock);
5467
if (p0->call && p1->call) {
5468
pri_channel_bridge(p0->call, p1->call);
5470
ast_mutex_unlock(&p0->pri->lock);
5635
5710
/* Fax tone -- Handle and return NULL */
5636
5711
if ((p->callprogress & CALLPROGRESS_FAX) && !p->faxhandled) {
5637
5712
/* If faxbuffers are configured, use them for the fax transmission */
5638
if (p->usefaxbuffers && !p->faxbuffersinuse) {
5713
if (p->usefaxbuffers && !p->bufferoverrideinuse) {
5639
5714
struct dahdi_bufferinfo bi = {
5640
5715
.txbufpolicy = p->faxbuf_policy,
5641
5716
.bufsize = p->bufsize,
8373
8449
if (p->cid_signalling == CID_SIG_DTMF) {
8376
ast_debug(1, "Receiving DTMF cid on "
8377
"channel %s\n", chan->name);
8452
ast_debug(1, "Receiving DTMF cid on channel %s\n", chan->name);
8378
8453
dahdi_setlinear(p->subs[idx].dfd, 0);
8455
* We are the only party interested in the Rx stream since
8456
* we have not answered yet. We don't need or even want DTMF
8457
* emulation. The DTMF digits can come so fast that emulation
8458
* can drop some of them.
8460
ast_set_flag(chan, AST_FLAG_END_DTMF_ONLY);
8461
res = 4000;/* This is a typical OFF time between rings. */
8381
8463
struct ast_frame *f;
8382
8464
res = ast_waitfor(chan, res);
8383
8465
if (res <= 0) {
8467
* We do not need to restore the dahdi_setlinear()
8468
* or AST_FLAG_END_DTMF_ONLY flag settings since we
8469
* are hanging up the channel.
8384
8471
ast_log(LOG_WARNING, "DTMFCID timed out waiting for ring. "
8385
8472
"Exiting simple switch\n");
8386
8473
ast_hangup(chan);
8392
8479
if (f->frametype == AST_FRAME_DTMF) {
8393
dtmfbuf[k++] = f->subclass;
8480
if (k < ARRAY_LEN(dtmfbuf) - 1) {
8481
dtmfbuf[k++] = f->subclass;
8394
8483
ast_debug(1, "CID got digit '%c'\n", f->subclass);
8484
res = 4000;/* This is a typical OFF time between rings. */
8398
8487
if (chan->_state == AST_STATE_RING ||
8399
8488
chan->_state == AST_STATE_RINGING)
8400
8489
break; /* Got ring */
8491
ast_clear_flag(chan, AST_FLAG_END_DTMF_ONLY);
8402
8492
dtmfbuf[k] = '\0';
8403
8493
dahdi_setlinear(p->subs[idx].dfd, p->subs[idx].linear);
8404
8494
/* Got cid and ring. */
8405
8495
ast_debug(1, "CID got string '%s'\n", dtmfbuf);
8406
8496
callerid_get_dtmf(dtmfbuf, dtmfcid, &flags);
8407
ast_debug(1, "CID is '%s', flags %d\n",
8497
ast_debug(1, "CID is '%s', flags %d\n", dtmfcid, flags);
8409
8498
/* If first byte is NULL, we have no cid */
8410
8499
if (!ast_strlen_zero(dtmfcid))
8411
8500
number = dtmfcid;
8466
8555
res = callerid_feed(cs, buf, res, AST_LAW(p));
8470
ast_log(LOG_WARNING, "CallerID feed failed on channel '%s'\n", chan->name);
8559
* The previous diagnostic message output likely
8560
* explains why it failed.
8562
ast_log(LOG_WARNING,
8563
"Failed to decode CallerID on channel '%s'\n",
8472
8566
} else if (res)
8483
8577
if (p->cid_signalling == CID_SIG_V23_JP) {
8484
8578
res = dahdi_set_hook(p->subs[SUB_REAL].dfd, DAHDI_ONHOOK);
8489
/* Finished with Caller*ID, now wait for a ring to make sure there really is a call coming */
8582
/* Finished with Caller*ID, now wait for a ring to make sure there really is a call coming */
8583
res = 4000;/* This is a typical OFF time between rings. */
8494
8585
struct ast_frame *f;
8495
8586
res = ast_waitfor(chan, res);
8732
8823
samples += res;
8733
8824
res = callerid_feed(cs, buf, res, AST_LAW(p));
8735
ast_log(LOG_WARNING, "CallerID feed failed: %s\n", strerror(errno));
8827
* The previous diagnostic message output likely
8828
* explains why it failed.
8830
ast_log(LOG_WARNING,
8831
"Failed to decode CallerID on channel '%s'\n",
8737
8834
} else if (res)
9009
9106
samples += res;
9010
9107
if (!spill_done) {
9011
9108
if ((spill_result = callerid_feed(cs, mtd->buf, res, AST_LAW(mtd->pvt))) < 0) {
9012
ast_log(LOG_WARNING, "CallerID feed failed: %s\n", strerror(errno));
9110
* The previous diagnostic message output likely
9111
* explains why it failed.
9113
ast_log(LOG_WARNING, "Failed to decode CallerID\n");
9014
9115
} else if (spill_result) {
9015
9116
spill_done = 1;
10502
10604
ast_copy_string(tmp->context, conf->chan.context, sizeof(tmp->context));
10503
10605
ast_copy_string(tmp->parkinglot, conf->chan.parkinglot, sizeof(tmp->parkinglot));
10504
10606
tmp->cid_ton = 0;
10505
if ((tmp->sig != SIG_PRI) || (tmp->sig != SIG_SS7) || (tmp->sig != SIG_BRI) || (tmp->sig != SIG_BRI_PTMP) || (tmp->sig != SIG_MFCR2)) {
10607
switch (tmp->sig) {
10613
tmp->cid_num[0] = '\0';
10614
tmp->cid_name[0] = '\0';
10506
10617
ast_copy_string(tmp->cid_num, conf->chan.cid_num, sizeof(tmp->cid_num));
10507
10618
ast_copy_string(tmp->cid_name, conf->chan.cid_name, sizeof(tmp->cid_name));
10509
tmp->cid_num[0] = '\0';
10510
tmp->cid_name[0] = '\0';
10512
10621
ast_copy_string(tmp->mailbox, conf->chan.mailbox, sizeof(tmp->mailbox));
10513
10622
if (channel != CHAN_PSEUDO && !ast_strlen_zero(tmp->mailbox)) {
16126
16235
ast_log(LOG_DEBUG, "Channel '%s' configured.\n", v->value);
16127
16236
} else if (!strcasecmp(v->name, "buffers")) {
16129
char policy[21] = "";
16131
res = sscanf(v->value, "%30d,%20s", &confp->chan.buf_no, policy);
16133
ast_log(LOG_WARNING, "Parsing buffers option data failed, using defaults.\n");
16134
confp->chan.buf_no = numbufs;
16137
if (confp->chan.buf_no < 0)
16138
confp->chan.buf_no = numbufs;
16139
if (!strcasecmp(policy, "full")) {
16140
confp->chan.buf_policy = DAHDI_POLICY_WHEN_FULL;
16141
} else if (!strcasecmp(policy, "immediate")) {
16237
if (parse_buffers_policy(v->value, &confp->chan.buf_no, &confp->chan.buf_policy)) {
16238
ast_log(LOG_WARNING, "Using default buffer policy.\n");
16239
confp->chan.buf_no = numbufs;
16142
16240
confp->chan.buf_policy = DAHDI_POLICY_IMMEDIATE;
16143
#ifdef HAVE_DAHDI_HALF_FULL
16144
} else if (!strcasecmp(policy, "half_full")) {
16145
confp->chan.buf_policy = DAHDI_POLICY_HALF_FULL;
16148
ast_log(LOG_WARNING, "Invalid policy name given (%s).\n", policy);
16150
16242
} else if (!strcasecmp(v->name, "faxbuffers")) {
16152
char policy[21] = "";
16154
res = sscanf(v->value, "%30d,%20s", &confp->chan.faxbuf_no, policy);
16156
ast_log(LOG_WARNING, "Parsing faxbuffers option data failed, using defaults.\n");
16157
confp->chan.faxbuf_no = numbufs;
16160
confp->chan.usefaxbuffers = 1;
16161
if (confp->chan.faxbuf_no < 0)
16162
confp->chan.faxbuf_no = numbufs;
16163
if (!strcasecmp(policy, "full")) {
16164
confp->chan.faxbuf_policy = DAHDI_POLICY_WHEN_FULL;
16165
} else if (!strcasecmp(policy, "immediate")) {
16166
confp->chan.faxbuf_policy = DAHDI_POLICY_IMMEDIATE;
16168
ast_log(LOG_WARNING, "Invalid policy name given (%s).\n", policy);
16169
confp->chan.usefaxbuffers = 0;
16171
} else if (!strcasecmp(v->name, "dahdichan")) {
16243
if (!parse_buffers_policy(v->value, &confp->chan.faxbuf_no, &confp->chan.faxbuf_policy)) {
16244
confp->chan.usefaxbuffers = 1;
16246
} else if (!strcasecmp(v->name, "dahdichan")) {
16172
16247
ast_copy_string(dahdichan, v->value, sizeof(dahdichan));
16173
16248
} else if (!strcasecmp(v->name, "usedistinctiveringdetection")) {
16174
16249
usedistinctiveringdetection = ast_true(v->value);
added
removed
.pc/dahdi-fxsks-hookstate/channels/chan_dahdi.c
