kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-10-15 08:44:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Formatting fixes for chan_oss (issue #7808 reported by Mithraen)

Browse Source 
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@42389 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
Joshua Colp
2006-09-08 03:51:26 +00:00
parent fd9f37a63f
commit ac9e94d0ee
1 changed files with 208 additions and 238 deletions
Download Patch File Download Diff File Expand all files Collapse all files

232
channels/chan_oss.c
View File

@@ -88,7 +88,7 @@ static struct ast_jb_conf default_jbconf =
.flags = 0, .flags = 0,
.max_size = -1, .max_size = -1,
.resync_threshold = -1, .resync_threshold = -1,
.impl = "" .impl = "",
}; };
static struct ast_jb_conf global_jbconf; static struct ast_jb_conf global_jbconf;
@@ -376,7 +376,7 @@ struct chan_oss_pvt {
char mohinterpret[MAX_MUSICCLASS]; char mohinterpret[MAX_MUSICCLASS];
/* buffers used in oss_write */ /* buffers used in oss_write */
char oss_write_buf[FRAME_SIZE*2]; char oss_write_buf[FRAME_SIZE * 2];
int oss_write_dst; int oss_write_dst;
/* buffers used in oss_read - AST_FRIENDLY_OFFSET space for headers /* buffers used in oss_read - AST_FRIENDLY_OFFSET space for headers
* plus enough room for a full frame * plus enough room for a full frame
@@ -441,14 +441,16 @@ static const struct ast_channel_tech oss_tech = {
*/ */
static struct chan_oss_pvt *find_desc(char *dev) static struct chan_oss_pvt *find_desc(char *dev)
{ {
struct chan_oss_pvt *o; struct chan_oss_pvt *o = NULL;
if (dev == NULL)
if (!dev)
ast_log(LOG_WARNING, "null dev\n"); ast_log(LOG_WARNING, "null dev\n");
for (o = oss_default.next; o && o->name && dev && strcmp(o->name, dev) != 0; o = o->next) for (o = oss_default.next; o && o->name && dev && strcmp(o->name, dev) != 0; o = o->next);
;
if (o == NULL) if (!o)
ast_log(LOG_WARNING, "could not find <%s>\n", dev ? dev : "--no-device--"); ast_log(LOG_WARNING, "could not find <%s>\n", dev ? dev : "--no-device--");
return o; return o;
} }
@@ -467,17 +469,22 @@ static char *ast_ext_ctx(const char *src, char **ext, char **ctx)
if (ext == NULL || ctx == NULL) if (ext == NULL || ctx == NULL)
return NULL; /* error */ return NULL; /* error */
*ext = *ctx = NULL; *ext = *ctx = NULL;
if (src && *src != '\0') if (src && *src != '\0')
*ext = ast_strdup(src); *ext = ast_strdup(src);
if (*ext == NULL) if (*ext == NULL)
return NULL; return NULL;
if (!o->overridecontext) { if (!o->overridecontext) {
/* parse from the right */ /* parse from the right */
*ctx = strrchr(*ext, '@'); *ctx = strrchr(*ext, '@');
if (*ctx) if (*ctx)
*(*ctx)++ = '\0'; *(*ctx)++ = '\0';
} }
return *ext; return *ext;
} }
@@ -489,20 +496,19 @@ static int used_blocks(struct chan_oss_pvt *o)
struct audio_buf_info info; struct audio_buf_info info;
if (ioctl(o->sounddev, SNDCTL_DSP_GETOSPACE, &info)) { if (ioctl(o->sounddev, SNDCTL_DSP_GETOSPACE, &info)) {
if (! (o->warned & WARN_used_blocks)) { if (!(o->warned & WARN_used_blocks)) {
ast_log(LOG_WARNING, "Error reading output space\n"); ast_log(LOG_WARNING, "Error reading output space\n");
o->warned |= WARN_used_blocks; o->warned |= WARN_used_blocks;
} }
return 1; return 1;
} }
if (o->total_blocks == 0) { if (o->total_blocks == 0) {
if (0) /* debugging */ if (0) /* debugging */
ast_log(LOG_WARNING, "fragtotal %d size %d avail %d\n", ast_log(LOG_WARNING, "fragtotal %d size %d avail %d\n", info.fragstotal, info.fragsize, info.fragments);
info.fragstotal,
info.fragsize,
info.fragments);
o->total_blocks = info.fragments; o->total_blocks = info.fragments;
} }
return o->total_blocks - info.fragments; return o->total_blocks - info.fragments;
} }
@@ -524,12 +530,11 @@ static int soundcard_writeframe(struct chan_oss_pvt *o, short *data)
res = used_blocks(o); res = used_blocks(o);
if (res > o->queuesize) { /* no room to write a block */ if (res > o->queuesize) { /* no room to write a block */
if (o->w_errors++ == 0 && (oss_debug & 0x4)) if (o->w_errors++ == 0 && (oss_debug & 0x4))
ast_log(LOG_WARNING, "write: used %d blocks (%d)\n", ast_log(LOG_WARNING, "write: used %d blocks (%d)\n", res, o->w_errors);
res, o->w_errors);
return 0; return 0;
} }
o->w_errors = 0; o->w_errors = 0;
return write(o->sounddev, ((void *)data), FRAME_SIZE * 2); return write(o->sounddev, ((void *) data), FRAME_SIZE * 2);
} }
/* /*
@@ -551,7 +556,9 @@ static void send_sound(struct chan_oss_pvt *o)
if (o->cursound < 0) /* no sound to send */ if (o->cursound < 0) /* no sound to send */
return; return;
s = &sounds[o->cursound]; s = &sounds[o->cursound];
for (ofs = 0; ofs < FRAME_SIZE; ofs += l) { for (ofs = 0; ofs < FRAME_SIZE; ofs += l) {
l = s->samplen - l_sampsent; /* # of available samples */ l = s->samplen - l_sampsent; /* # of available samples */
if (l > 0) { if (l > 0) {
@@ -560,26 +567,25 @@ static void send_sound(struct chan_oss_pvt *o)
l = FRAME_SIZE - ofs; l = FRAME_SIZE - ofs;
if (l > s->datalen - start) /* don't overflow the source */ if (l > s->datalen - start) /* don't overflow the source */
l = s->datalen - start; l = s->datalen - start;
bcopy(s->data + start, myframe + ofs, l*2); bcopy(s->data + start, myframe + ofs, l * 2);
if (0) if (0)
ast_log(LOG_WARNING, "send_sound sound %d/%d of %d into %d\n", ast_log(LOG_WARNING, "send_sound sound %d/%d of %d into %d\n", l_sampsent, l, s->samplen, ofs);
l_sampsent, l, s->samplen, ofs);
l_sampsent += l; l_sampsent += l;
} else { /* end of samples, maybe some silence */ } else { /* end of samples, maybe some silence */
static const short silence[FRAME_SIZE] = {0, }; static const short silence[FRAME_SIZE] = { 0, };
l += s->silencelen; l += s->silencelen;
if (l > 0) { if (l > 0) {
if (l > FRAME_SIZE - ofs) if (l > FRAME_SIZE - ofs)
l = FRAME_SIZE - ofs; l = FRAME_SIZE - ofs;
bcopy(silence, myframe + ofs, l*2); bcopy(silence, myframe + ofs, l * 2);
l_sampsent += l; l_sampsent += l;
} else { /* silence is over, restart sound if loop */ } else { /* silence is over, restart sound if loop */
if (s->repeat == 0) { /* last block */ if (s->repeat == 0) { /* last block */
o->cursound = -1; o->cursound = -1;
o->nosound = 0; /* allow audio data */ o->nosound = 0; /* allow audio data */
if (ofs < FRAME_SIZE) /* pad with silence */ if (ofs < FRAME_SIZE) /* pad with silence */
bcopy(silence, myframe + ofs, (FRAME_SIZE - ofs)*2); bcopy(silence, myframe + ofs, (FRAME_SIZE - ofs) * 2);
} }
l_sampsent = 0; l_sampsent = 0;
} }
@@ -593,7 +599,7 @@ static void send_sound(struct chan_oss_pvt *o)
static void *sound_thread(void *arg) static void *sound_thread(void *arg)
{ {
char ign[4096]; char ign[4096];
struct chan_oss_pvt *o = (struct chan_oss_pvt *)arg; struct chan_oss_pvt *o = (struct chan_oss_pvt *) arg;
/* /*
* Just in case, kick the driver by trying to read from it. * Just in case, kick the driver by trying to read from it.
@@ -675,10 +681,9 @@ static int setformat(struct chan_oss_pvt *o, int mode)
if (ast_tvdiff_ms(ast_tvnow(), o->lastopen) < 1000) if (ast_tvdiff_ms(ast_tvnow(), o->lastopen) < 1000)
return -1; /* don't open too often */ return -1; /* don't open too often */
o->lastopen = ast_tvnow(); o->lastopen = ast_tvnow();
fd = o->sounddev = open(o->device, mode |O_NONBLOCK); fd = o->sounddev = open(o->device, mode | O_NONBLOCK);
if (fd < 0) { if (fd < 0) {
ast_log(LOG_WARNING, "Unable to re-open DSP device %s: %s\n", ast_log(LOG_WARNING, "Unable to re-open DSP device %s: %s\n", o->device, strerror(errno));
o->device, strerror(errno));
return -1; return -1;
} }
if (o->owner) if (o->owner)
@@ -697,7 +702,7 @@ static int setformat(struct chan_oss_pvt *o, int mode)
switch (mode) { switch (mode) {
case O_RDWR: case O_RDWR:
res = ioctl(fd, SNDCTL_DSP_SETDUPLEX, 0); res = ioctl(fd, SNDCTL_DSP_SETDUPLEX, 0);
/* Check to see if duplex set (FreeBSD Bug)*/ /* Check to see if duplex set (FreeBSD Bug) */
res = ioctl(fd, SNDCTL_DSP_GETCAPS, &fmt); res = ioctl(fd, SNDCTL_DSP_GETCAPS, &fmt);
if (res == 0 && (fmt & DSP_CAP_DUPLEX)) { if (res == 0 && (fmt & DSP_CAP_DUPLEX)) {
if (option_verbose > 1) if (option_verbose > 1)
@@ -767,14 +772,14 @@ static int oss_digit_begin(struct ast_channel *c, char digit)
static int oss_digit_end(struct ast_channel *c, char digit) static int oss_digit_end(struct ast_channel *c, char digit)
{ {
/* no better use for received digits than print them */ /* no better use for received digits than print them */
ast_verbose( " << Console Received digit %c >> \n", digit); ast_verbose(" << Console Received digit %c >> \n", digit);
return 0; return 0;
} }
static int oss_text(struct ast_channel *c, const char *text) static int oss_text(struct ast_channel *c, const char *text)
{ {
/* print received messages */ /* print received messages */
ast_verbose( " << Console Received text %s >> \n", text); ast_verbose(" << Console Received text %s >> \n", text);
return 0; return 0;
} }
@@ -793,10 +798,9 @@ static int oss_call(struct ast_channel *c, char *dest, int timeout)
struct chan_oss_pvt *o = c->tech_pvt; struct chan_oss_pvt *o = c->tech_pvt;
struct ast_frame f = { 0, }; struct ast_frame f = { 0, };
ast_verbose(" << Call to device '%s' dnid '%s' rdnis '%s' on console from '%s' <%s> >>\n", ast_verbose(" << Call to device '%s' dnid '%s' rdnis '%s' on console from '%s' <%s> >>\n", dest, c->cid.cid_dnid, c->cid.cid_rdnis, c->cid.cid_name, c->cid.cid_num);
dest, c->cid.cid_dnid, c->cid.cid_rdnis, c->cid.cid_name, c->cid.cid_num);
if (o->autoanswer) { if (o->autoanswer) {
ast_verbose( " << Auto-answered >> \n" ); ast_verbose(" << Auto-answered >> \n");
f.frametype = AST_FRAME_CONTROL; f.frametype = AST_FRAME_CONTROL;
f.subclass = AST_CONTROL_ANSWER; f.subclass = AST_CONTROL_ANSWER;
ast_queue_frame(c, &f); ast_queue_frame(c, &f);
@@ -817,14 +821,14 @@ static int oss_answer(struct ast_channel *c)
{ {
struct chan_oss_pvt *o = c->tech_pvt; struct chan_oss_pvt *o = c->tech_pvt;
ast_verbose( " << Console call has been answered >> \n"); ast_verbose(" << Console call has been answered >> \n");
#if 0 #if 0
/* play an answer tone (XXX do we really need it ?) */ /* play an answer tone (XXX do we really need it ?) */
ring(o, AST_CONTROL_ANSWER); ring(o, AST_CONTROL_ANSWER);
#endif #endif
ast_setstate(c, AST_STATE_UP); ast_setstate(c, AST_STATE_UP);
o->cursound = -1; o->cursound = -1;
o->nosound=0; o->nosound = 0;
return 0; return 0;
} }
@@ -836,7 +840,7 @@ static int oss_hangup(struct ast_channel *c)
o->nosound = 0; o->nosound = 0;
c->tech_pvt = NULL; c->tech_pvt = NULL;
o->owner = NULL; o->owner = NULL;
ast_verbose( " << Hangup on console >> \n"); ast_verbose(" << Hangup on console >> \n");
ast_mutex_lock(&usecnt_lock); /* XXX not sure why */ ast_mutex_lock(&usecnt_lock); /* XXX not sure why */
usecnt--; usecnt--;
ast_mutex_unlock(&usecnt_lock); ast_mutex_unlock(&usecnt_lock);
@@ -871,20 +875,18 @@ static int oss_write(struct ast_channel *c, struct ast_frame *f)
* Keep the residue stored for future use. * Keep the residue stored for future use.
*/ */
src = 0; /* read position into f->data */ src = 0; /* read position into f->data */
while ( src < f->datalen ) { while (src < f->datalen) {
/* Compute spare room in the buffer */ /* Compute spare room in the buffer */
int l = sizeof(o->oss_write_buf) - o->oss_write_dst; int l = sizeof(o->oss_write_buf) - o->oss_write_dst;
if (f->datalen - src >= l) { /* enough to fill a frame */ if (f->datalen - src >= l) { /* enough to fill a frame */
memcpy(o->oss_write_buf + o->oss_write_dst, memcpy(o->oss_write_buf + o->oss_write_dst, f->data + src, l);
f->data + src, l); soundcard_writeframe(o, (short *) o->oss_write_buf);
soundcard_writeframe(o, (short *)o->oss_write_buf);
src += l; src += l;
o->oss_write_dst = 0; o->oss_write_dst = 0;
} else { /* copy residue */ } else { /* copy residue */
l = f->datalen - src; l = f->datalen - src;
memcpy(o->oss_write_buf + o->oss_write_dst, memcpy(o->oss_write_buf + o->oss_write_dst, f->data + src, l);
f->data + src, l);
src += l; /* but really, we are done */ src += l; /* but really, we are done */
o->oss_write_dst += l; o->oss_write_dst += l;
} }
@@ -904,8 +906,7 @@ static struct ast_frame *oss_read(struct ast_channel *c)
f->frametype = AST_FRAME_NULL; f->frametype = AST_FRAME_NULL;
f->src = oss_tech.type; f->src = oss_tech.type;
res = read(o->sounddev, o->oss_read_buf + o->readpos, res = read(o->sounddev, o->oss_read_buf + o->readpos, sizeof(o->oss_read_buf) - o->readpos);
sizeof(o->oss_read_buf) - o->readpos);
if (res < 0) /* audio data not ready, return a NULL frame */ if (res < 0) /* audio data not ready, return a NULL frame */
return f; return f;
@@ -927,7 +928,7 @@ static struct ast_frame *oss_read(struct ast_channel *c)
f->data = o->oss_read_buf + AST_FRIENDLY_OFFSET; f->data = o->oss_read_buf + AST_FRIENDLY_OFFSET;
if (o->boost != BOOST_SCALE) { /* scale and clip values */ if (o->boost != BOOST_SCALE) { /* scale and clip values */
int i, x; int i, x;
int16_t *p = (int16_t *)f->data; int16_t *p = (int16_t *) f->data;
for (i = 0; i < f->samples; i++) { for (i = 0; i < f->samples; i++) {
x = (p[i] * o->boost) / BOOST_SCALE; x = (p[i] * o->boost) / BOOST_SCALE;
if (x > 32767) if (x > 32767)
@@ -954,7 +955,7 @@ static int oss_indicate(struct ast_channel *c, int cond, const void *data, size_
struct chan_oss_pvt *o = c->tech_pvt; struct chan_oss_pvt *o = c->tech_pvt;
int res = -1; int res = -1;
switch(cond) { switch (cond) {
case AST_CONTROL_BUSY: case AST_CONTROL_BUSY:
case AST_CONTROL_CONGESTION: case AST_CONTROL_CONGESTION:
case AST_CONTROL_RINGING: case AST_CONTROL_RINGING:
@@ -970,18 +971,16 @@ static int oss_indicate(struct ast_channel *c, int cond, const void *data, size_
res = -1; res = -1;
break; break;
case AST_CONTROL_HOLD: case AST_CONTROL_HOLD:
ast_verbose( " << Console Has Been Placed on Hold >> \n"); ast_verbose(" << Console Has Been Placed on Hold >> \n");
ast_moh_start(c, data, o->mohinterpret); ast_moh_start(c, data, o->mohinterpret);
break; break;
case AST_CONTROL_UNHOLD: case AST_CONTROL_UNHOLD:
ast_verbose( " << Console Has Been Retrieved from Hold >> \n"); ast_verbose(" << Console Has Been Retrieved from Hold >> \n");
ast_moh_stop(c); ast_moh_stop(c);
break; break;
default: default:
ast_log(LOG_WARNING, ast_log(LOG_WARNING, "Don't know how to display condition %d on %s\n", cond, c->name);
"Don't know how to display condition %d on %s\n",
cond, c->name);
return -1; return -1;
} }
@@ -994,8 +993,7 @@ static int oss_indicate(struct ast_channel *c, int cond, const void *data, size_
/* /*
* allocate a new channel. * allocate a new channel.
*/ */
static struct ast_channel *oss_new(struct chan_oss_pvt *o, static struct ast_channel *oss_new(struct chan_oss_pvt *o, char *ext, char *ctx, int state)
char *ext, char *ctx, int state)
{ {
struct ast_channel *c; struct ast_channel *c;
@@ -1042,16 +1040,14 @@ static struct ast_channel *oss_new(struct chan_oss_pvt *o,
return c; return c;
} }
static struct ast_channel *oss_request(const char *type, static struct ast_channel *oss_request(const char *type, int format, void *data, int *cause)
int format, void *data, int *cause)
{ {
struct ast_channel *c; struct ast_channel *c;
struct chan_oss_pvt *o = find_desc(data); struct chan_oss_pvt *o = find_desc(data);
ast_log(LOG_WARNING, "oss_request ty <%s> data 0x%p <%s>\n", ast_log(LOG_WARNING, "oss_request ty <%s> data 0x%p <%s>\n", type, data, (char *) data);
type, data, (char *)data);
if (o == NULL) { if (o == NULL) {
ast_log(LOG_NOTICE, "Device %s not found\n", (char *)data); ast_log(LOG_NOTICE, "Device %s not found\n", (char *) data);
/* XXX we could default to 'dsp' perhaps ? */ /* XXX we could default to 'dsp' perhaps ? */
return NULL; return NULL;
} }
@@ -1064,7 +1060,7 @@ static struct ast_channel *oss_request(const char *type,
*cause = AST_CAUSE_BUSY; *cause = AST_CAUSE_BUSY;
return NULL; return NULL;
} }
c= oss_new(o, NULL, NULL, AST_STATE_DOWN); c = oss_new(o, NULL, NULL, AST_STATE_DOWN);
if (c == NULL) { if (c == NULL) {
ast_log(LOG_WARNING, "Unable to create new OSS channel\n"); ast_log(LOG_WARNING, "Unable to create new OSS channel\n");
return NULL; return NULL;
@@ -1083,8 +1079,7 @@ static int console_autoanswer(int fd, int argc, char *argv[])
if (argc != 2) if (argc != 2)
return RESULT_SHOWUSAGE; return RESULT_SHOWUSAGE;
if (o == NULL) { if (o == NULL) {
ast_log(LOG_WARNING, "Cannot find device %s (should not happen!)\n", ast_log(LOG_WARNING, "Cannot find device %s (should not happen!)\n", oss_active);
oss_active);
return RESULT_FAILURE; return RESULT_FAILURE;
} }
if (!strcasecmp(argv[1], "on")) if (!strcasecmp(argv[1], "on"))
@@ -1104,10 +1099,9 @@ static char *autoanswer_complete(const char *line, const char *word, int pos, in
} }
static char autoanswer_usage[] = static char autoanswer_usage[] =
"Usage: autoanswer [on|off]\n" "Usage: autoanswer [on|off]\n"
" Enables or disables autoanswer feature. If used without\n" " Enables or disables autoanswer feature. If used without\n"
" argument, displays the current on/off status of autoanswer.\n" " argument, displays the current on/off status of autoanswer.\n" " The default value of autoanswer is in 'oss.conf'.\n";
" The default value of autoanswer is in 'oss.conf'.\n";
/* /*
* answer command from the console * answer command from the console
@@ -1134,9 +1128,7 @@ static int console_answer(int fd, int argc, char *argv[])
return RESULT_SUCCESS; return RESULT_SUCCESS;
} }
static char sendtext_usage[] = static char sendtext_usage[] = "Usage: send text <message>\n" " Sends a text message for display on the remote terminal.\n";
"Usage: send text <message>\n"
" Sends a text message for display on the remote terminal.\n";
/* /*
* concatenate all arguments into a single string. argv is NULL-terminated * concatenate all arguments into a single string. argv is NULL-terminated
@@ -1153,7 +1145,7 @@ static int console_sendtext(int fd, int argc, char *argv[])
ast_cli(fd, "Not in a call\n"); ast_cli(fd, "Not in a call\n");
return RESULT_FAILURE; return RESULT_FAILURE;
} }
ast_join(buf, sizeof(buf) - 1, argv+2); ast_join(buf, sizeof(buf) - 1, argv + 2);
if (!ast_strlen_zero(buf)) { if (!ast_strlen_zero(buf)) {
struct ast_frame f = { 0, }; struct ast_frame f = { 0, };
int i = strlen(buf); int i = strlen(buf);
@@ -1167,9 +1159,7 @@ static int console_sendtext(int fd, int argc, char *argv[])
return RESULT_SUCCESS; return RESULT_SUCCESS;
} }
static char answer_usage[] = static char answer_usage[] = "Usage: answer\n" " Answers an incoming call on the console (OSS) channel.\n";
"Usage: answer\n"
" Answers an incoming call on the console (OSS) channel.\n";
static int console_hangup(int fd, int argc, char *argv[]) static int console_hangup(int fd, int argc, char *argv[])
{ {
@@ -1190,9 +1180,7 @@ static int console_hangup(int fd, int argc, char *argv[])
return RESULT_SUCCESS; return RESULT_SUCCESS;
} }
static char hangup_usage[] = static char hangup_usage[] = "Usage: hangup\n" " Hangs up any call currently placed on the console.\n";
"Usage: hangup\n"
" Hangs up any call currently placed on the console.\n";
static int console_flash(int fd, int argc, char *argv[]) static int console_flash(int fd, int argc, char *argv[])
@@ -1215,9 +1203,7 @@ static int console_flash(int fd, int argc, char *argv[])
} }
static char flash_usage[] = static char flash_usage[] = "Usage: flash\n" " Flashes the call currently placed on the console.\n";
"Usage: flash\n"
" Flashes the call currently placed on the console.\n";
@@ -1238,7 +1224,7 @@ static int console_dial(int fd, int argc, char *argv[])
} }
s = argv[1]; s = argv[1];
/* send the string one char at a time */ /* send the string one char at a time */
for (i=0; i<strlen(s); i++) { for (i = 0; i < strlen(s); i++) {
f.subclass = s[i]; f.subclass = s[i];
ast_queue_frame(o->owner, &f); ast_queue_frame(o->owner, &f);
} }
@@ -1262,15 +1248,11 @@ static int console_dial(int fd, int argc, char *argv[])
return RESULT_SUCCESS; return RESULT_SUCCESS;
} }
static char dial_usage[] = static char dial_usage[] = "Usage: dial [extension[@context]]\n" " Dials a given extension (and context if specified)\n";
"Usage: dial [extension[@context]]\n"
" Dials a given extension (and context if specified)\n";
static char mute_usage[] = static char mute_usage[] = "Usage: mute\nMutes the microphone\n";
"Usage: mute\nMutes the microphone\n";
static char unmute_usage[] = static char unmute_usage[] = "Usage: unmute\nUnmutes the microphone\n";
"Usage: unmute\nUnmutes the microphone\n";
static int console_mute(int fd, int argc, char *argv[]) static int console_mute(int fd, int argc, char *argv[])
{ {
@@ -1302,7 +1284,7 @@ static int console_transfer(int fd, int argc, char *argv[])
return RESULT_SHOWUSAGE; return RESULT_SHOWUSAGE;
if (o == NULL) if (o == NULL)
return RESULT_FAILURE; return RESULT_FAILURE;
if (o->owner ==NULL || (b = ast_bridged_channel(o->owner)) == NULL) { if (o->owner == NULL || (b = ast_bridged_channel(o->owner)) == NULL) {
ast_cli(fd, "There is no call to transfer\n"); ast_cli(fd, "There is no call to transfer\n");
return RESULT_SUCCESS; return RESULT_SUCCESS;
} }
@@ -1313,8 +1295,7 @@ static int console_transfer(int fd, int argc, char *argv[])
if (!ast_exists_extension(b, ctx, ext, 1, b->cid.cid_num)) if (!ast_exists_extension(b, ctx, ext, 1, b->cid.cid_num))
ast_cli(fd, "No such extension exists\n"); ast_cli(fd, "No such extension exists\n");
else { else {
ast_cli(fd, "Whee, transferring %s to %s@%s.\n", ast_cli(fd, "Whee, transferring %s to %s@%s.\n", b->name, ext, ctx);
b->name, ext, ctx);
if (ast_async_goto(b, ctx, ext, 1)) if (ast_async_goto(b, ctx, ext, 1))
ast_cli(fd, "Failed to transfer :(\n"); ast_cli(fd, "Failed to transfer :(\n");
} }
@@ -1323,16 +1304,11 @@ static int console_transfer(int fd, int argc, char *argv[])
return RESULT_SUCCESS; return RESULT_SUCCESS;
} }
static char transfer_usage[] = static char transfer_usage[] = "Usage: transfer <extension>[@context]\n" " Transfers the currently connected call to the given extension (and\n" "context if specified)\n";
"Usage: transfer <extension>[@context]\n"
" Transfers the currently connected call to the given extension (and\n"
"context if specified)\n";
static char console_usage[] = static char console_usage[] =
"Usage: console [device]\n" "Usage: console [device]\n"
" If used without a parameter, displays which device is the current\n" " If used without a parameter, displays which device is the current\n" "console. If a device is specified, the console sound device is changed to\n" "the device specified.\n";
"console. If a device is specified, the console sound device is changed to\n"
"the device specified.\n";
static int console_active(int fd, int argc, char *argv[]) static int console_active(int fd, int argc, char *argv[])
{ {
@@ -1343,7 +1319,7 @@ static int console_active(int fd, int argc, char *argv[])
else { else {
struct chan_oss_pvt *o; struct chan_oss_pvt *o;
if (strcmp(argv[1], "show") == 0) { if (strcmp(argv[1], "show") == 0) {
for (o = oss_default.next; o ; o = o->next) for (o = oss_default.next; o; o = o->next)
ast_cli(fd, "device [%s] exists\n", o->name); ast_cli(fd, "device [%s] exists\n", o->name);
return RESULT_SUCCESS; return RESULT_SUCCESS;
} }
@@ -1366,16 +1342,14 @@ static void store_boost(struct chan_oss_pvt *o, char *s)
ast_log(LOG_WARNING, "invalid boost <%s>\n", s); ast_log(LOG_WARNING, "invalid boost <%s>\n", s);
return; return;
} }
if (boost < - BOOST_MAX) { if (boost < -BOOST_MAX) {
ast_log(LOG_WARNING, "boost %s too small, using %d\n", ast_log(LOG_WARNING, "boost %s too small, using %d\n", s, -BOOST_MAX);
s, -BOOST_MAX);
boost = -BOOST_MAX; boost = -BOOST_MAX;
} else if (boost > BOOST_MAX) { } else if (boost > BOOST_MAX) {
ast_log(LOG_WARNING, "boost %s too large, using %d\n", ast_log(LOG_WARNING, "boost %s too large, using %d\n", s, BOOST_MAX);
s, BOOST_MAX);
boost = BOOST_MAX; boost = BOOST_MAX;
} }
boost = exp(log(10)*boost/20) * BOOST_SCALE; boost = exp(log(10) * boost / 20) * BOOST_SCALE;
o->boost = boost; o->boost = boost;
ast_log(LOG_WARNING, "setting boost %s to %d\n", s, o->boost); ast_log(LOG_WARNING, "setting boost %s to %d\n", s, o->boost);
} }
@@ -1385,25 +1359,24 @@ static int do_boost(int fd, int argc, char *argv[])
struct chan_oss_pvt *o = find_desc(oss_active); struct chan_oss_pvt *o = find_desc(oss_active);
if (argc == 2) if (argc == 2)
ast_cli(fd, "boost currently %5.1f\n", ast_cli(fd, "boost currently %5.1f\n", 20 * log10(((double) o->boost / (double) BOOST_SCALE)));
20 * log10(((double)o->boost/(double)BOOST_SCALE)) );
else if (argc == 3) else if (argc == 3)
store_boost(o, argv[2]); store_boost(o, argv[2]);
return RESULT_SUCCESS; return RESULT_SUCCESS;
} }
static struct ast_cli_entry myclis[] = { static struct ast_cli_entry myclis[] = {
{ { "answer", NULL }, console_answer, "Answer an incoming console call", answer_usage }, {{"answer", NULL}, console_answer, "Answer an incoming console call", answer_usage},
{ { "hangup", NULL }, console_hangup, "Hangup a call on the console", hangup_usage }, {{"hangup", NULL}, console_hangup, "Hangup a call on the console", hangup_usage},
{ { "flash", NULL }, console_flash, "Flash a call on the console", flash_usage }, {{"flash", NULL}, console_flash, "Flash a call on the console", flash_usage},
{ { "dial", NULL }, console_dial, "Dial an extension on the console", dial_usage }, {{"dial", NULL}, console_dial, "Dial an extension on the console", dial_usage},
{ { "mute", NULL }, console_mute, "Disable mic input", mute_usage }, {{"mute", NULL}, console_mute, "Disable mic input", mute_usage},
{ { "unmute", NULL }, console_unmute, "Enable mic input", unmute_usage }, {{"unmute", NULL}, console_unmute, "Enable mic input", unmute_usage},
{ { "transfer", NULL }, console_transfer, "Transfer a call to a different extension", transfer_usage }, {{"transfer", NULL}, console_transfer, "Transfer a call to a different extension", transfer_usage},
{ { "send", "text", NULL }, console_sendtext, "Send text to the remote device", sendtext_usage }, {{"send", "text", NULL}, console_sendtext, "Send text to the remote device", sendtext_usage},
{ { "autoanswer", NULL }, console_autoanswer, "Sets/displays autoanswer", autoanswer_usage, autoanswer_complete }, {{"autoanswer", NULL}, console_autoanswer, "Sets/displays autoanswer", autoanswer_usage, autoanswer_complete},
{ { "oss", "boost", NULL }, do_boost, "Sets/displays mic boost in dB"}, {{"oss", "boost", NULL}, do_boost, "Sets/displays mic boost in dB"},
{ { "console", NULL }, console_active, "Sets/displays active console", console_usage }, {{"console", NULL}, console_active, "Sets/displays active console", console_usage},
}; };
/* /*
@@ -1415,10 +1388,9 @@ static void store_mixer(struct chan_oss_pvt *o, char *s)
{ {
int i; int i;
for (i=0; i < strlen(s); i++) { for (i = 0; i < strlen(s); i++) {
if (!isalnum(s[i]) && index(" \t-/", s[i]) == NULL) { if (!isalnum(s[i]) && index(" \t-/", s[i]) == NULL) {
ast_log(LOG_WARNING, ast_log(LOG_WARNING, "Suspect char %c in mixer cmd, ignoring:\n\t%s\n", s[i], s);
"Suspect char %c in mixer cmd, ignoring:\n\t%s\n", s[i], s);
return; return;
} }
} }
@@ -1439,7 +1411,7 @@ static void store_callerid(struct chan_oss_pvt *o, char *s)
/* /*
* grab fields from the config file, init the descriptor and open the device. * grab fields from the config file, init the descriptor and open the device.
*/ */
static struct chan_oss_pvt * store_config(struct ast_config *cfg, char *ctg) static struct chan_oss_pvt *store_config(struct ast_config *cfg, char *ctg)
{ {
struct ast_variable *v; struct ast_variable *v;
struct chan_oss_pvt *o; struct chan_oss_pvt *o;
@@ -1464,7 +1436,7 @@ static struct chan_oss_pvt * store_config(struct ast_config *cfg, char *ctg)
o->lastopen = ast_tvnow(); /* don't leave it 0 or tvdiff may wrap */ o->lastopen = ast_tvnow(); /* don't leave it 0 or tvdiff may wrap */
/* fill other fields from configuration */ /* fill other fields from configuration */
for (v = ast_variable_browse(cfg, ctg);v; v=v->next) { for (v = ast_variable_browse(cfg, ctg); v; v = v->next) {
M_START(v->name, v->value); M_START(v->name, v->value);
/* handle jb conf */ /* handle jb conf */
@@ -1485,7 +1457,8 @@ static struct chan_oss_pvt * store_config(struct ast_config *cfg, char *ctg)
M_F("mixer", store_mixer(o, v->value)) M_F("mixer", store_mixer(o, v->value))
M_F("callerid", store_callerid(o, v->value)) M_F("callerid", store_callerid(o, v->value))
M_F("boost", store_boost(o, v->value)) M_F("boost", store_boost(o, v->value))
M_END(;); M_END(;
);
} }
if (ast_strlen_zero(o->device)) if (ast_strlen_zero(o->device))
ast_copy_string(o->device, DEV_DSP, sizeof(o->device)); ast_copy_string(o->device, DEV_DSP, sizeof(o->device));
@@ -1500,19 +1473,17 @@ static struct chan_oss_pvt * store_config(struct ast_config *cfg, char *ctg)
if (o == &oss_default) /* we are done with the default */ if (o == &oss_default) /* we are done with the default */
return NULL; return NULL;
openit: openit:
#if TRYOPEN #if TRYOPEN
if (setformat(o, O_RDWR) < 0) { /* open device */ if (setformat(o, O_RDWR) < 0) { /* open device */
if (option_verbose > 0) { if (option_verbose > 0) {
ast_verbose(VERBOSE_PREFIX_2 "Device %s not detected\n", ctg); ast_verbose(VERBOSE_PREFIX_2 "Device %s not detected\n", ctg);
ast_verbose(VERBOSE_PREFIX_2 "Turn off OSS support by adding " ast_verbose(VERBOSE_PREFIX_2 "Turn off OSS support by adding " "'noload=chan_oss.so' in /etc/asterisk/modules.conf\n");
"'noload=chan_oss.so' in /etc/asterisk/modules.conf\n");
} }
goto error; goto error;
} }
if (o->duplex != M_FULL) if (o->duplex != M_FULL)
ast_log(LOG_WARNING, "XXX I don't work right with non " ast_log(LOG_WARNING, "XXX I don't work right with non " "full-duplex sound cards XXX\n");
"full-duplex sound cards XXX\n");
#endif /* TRYOPEN */ #endif /* TRYOPEN */
if (pipe(o->sndcmd) != 0) { if (pipe(o->sndcmd) != 0) {
ast_log(LOG_ERROR, "Unable to create pipe\n"); ast_log(LOG_ERROR, "Unable to create pipe\n");
@@ -1526,7 +1497,7 @@ openit:
} }
return o; return o;
error: error:
if (o != &oss_default) if (o != &oss_default)
free(o); free(o);
return NULL; return NULL;
@@ -1565,7 +1536,7 @@ static int load_module(void)
/* XXX should cleanup allocated memory etc. */ /* XXX should cleanup allocated memory etc. */
return -1; return -1;
} }
ast_cli_register_multiple(myclis, sizeof(myclis)/sizeof(struct ast_cli_entry)); ast_cli_register_multiple(myclis, sizeof(myclis) / sizeof(struct ast_cli_entry));
return 0; return 0;
} }
@@ -1575,10 +1546,9 @@ static int unload_module(void)
struct chan_oss_pvt *o; struct chan_oss_pvt *o;
ast_channel_unregister(&oss_tech); ast_channel_unregister(&oss_tech);
ast_cli_unregister_multiple(myclis, ast_cli_unregister_multiple(myclis, sizeof(myclis) / sizeof(struct ast_cli_entry));
sizeof(myclis)/sizeof(struct ast_cli_entry));
for (o = oss_default.next; o ; o = o->next) { for (o = oss_default.next; o; o = o->next) {
close(o->sounddev); close(o->sounddev);
if (o->sndcmd[0] > 0) { if (o->sndcmd[0] > 0) {
close(o->sndcmd[0]); close(o->sndcmd[0]);