[asterisk-commits] trunk r9451 - in /trunk: apps/ channels/ doc/
include/asterisk/ res/
asterisk-commits at lists.digium.com
asterisk-commits at lists.digium.com
Fri Feb 10 16:55:48 MST 2006
Author: kpfleming
Date: Fri Feb 10 17:55:47 2006
New Revision: 9451
URL: http://svn.digium.com/view/asterisk?rev=9451&view=rev
Log:
clean up SMDI support commit:
copyright header format and dates
code formatting and guidelines conformance
use of timeval wrapper functions
use of memory allocation wrappers
propery unref created interface objects during config load
document new variable set by chan_zap in doc/channelvariables.txt
remove useless 'extern' on function prototypes and definitions
Modified:
trunk/apps/app_voicemail.c
trunk/channels/chan_zap.c
trunk/doc/channelvariables.txt
trunk/include/asterisk/smdi.h
trunk/res/res_smdi.c
Modified: trunk/apps/app_voicemail.c
URL: http://svn.digium.com/view/asterisk/trunk/apps/app_voicemail.c?rev=9451&r1=9450&r2=9451&view=diff
==============================================================================
--- trunk/apps/app_voicemail.c (original)
+++ trunk/apps/app_voicemail.c Fri Feb 10 17:55:47 2006
@@ -1,7 +1,7 @@
/*
* Asterisk -- An open source telephony toolkit.
*
- * Copyright (C) 1999 - 2005, Digium, Inc.
+ * Copyright (C) 1999 - 2006, Digium, Inc.
*
* Mark Spencer <markster at digium.com>
*
@@ -2335,14 +2335,12 @@
#ifdef WITH_SMDI
if (!strcasecmp(externnotify, "smdi")) {
-
if (ast_app_has_voicemail(ext_context, NULL))
ast_smdi_mwi_set(smdi_iface, extension);
else
ast_smdi_mwi_unset(smdi_iface, extension);
- mwi_msg = ast_smdi_mwi_message_wait(smdi_iface, SMDI_MWI_WAIT_TIMEOUT);
- if (mwi_msg) {
+ if ((mwi_msg = ast_smdi_mwi_message_wait(smdi_iface, SMDI_MWI_WAIT_TIMEOUT))) {
ast_log(LOG_ERROR, "Error executing SMDI MWI change for %s on %s\n", extension, smdi_iface->name);
if (!strncmp(mwi_msg->cause, "INV", 3))
ast_log(LOG_ERROR, "Invalid MWI extension: %s\n", mwi_msg->fwd_st);
@@ -5987,9 +5985,8 @@
ast_copy_string(externnotify, notifystr, sizeof(externnotify));
ast_log(LOG_DEBUG, "found externnotify: %s\n", externnotify);
#ifdef WITH_SMDI
- if(!strcasecmp(externnotify, "smdi")) {
+ if (!strcasecmp(externnotify, "smdi")) {
ast_log(LOG_DEBUG, "Using SMDI for external voicemail notification\n");
-
if ((smdistr = ast_variable_retrieve(cfg, "general", "smdiport"))) {
smdi_iface = ast_smdi_interface_find(smdistr);
} else {
@@ -5997,7 +5994,7 @@
smdi_iface = ast_smdi_interface_find("/dev/ttyS0");
}
- if(!smdi_iface) {
+ if (!smdi_iface) {
ast_log(LOG_ERROR, "No valid SMDI interface specfied, disabling external voicemail notification\n");
externnotify[0] = '\0';
} else {
Modified: trunk/channels/chan_zap.c
URL: http://svn.digium.com/view/asterisk/trunk/channels/chan_zap.c?rev=9451&r1=9450&r2=9451&view=diff
==============================================================================
--- trunk/channels/chan_zap.c (original)
+++ trunk/channels/chan_zap.c Fri Feb 10 17:55:47 2006
@@ -1,7 +1,7 @@
/*
* Asterisk -- An open source telephony toolkit.
*
- * Copyright (C) 1999 - 2005, Digium, Inc.
+ * Copyright (C) 1999 - 2006, Digium, Inc.
*
* Mark Spencer <markster at digium.com>
*
@@ -5948,10 +5948,10 @@
#endif
#ifdef WITH_SMDI
/* check for SMDI messages */
- if(p->use_smdi && p->smdi_iface) {
+ if (p->use_smdi && p->smdi_iface) {
smdi_msg = ast_smdi_md_message_wait(p->smdi_iface, SMDI_MD_WAIT_TIMEOUT);
- if(smdi_msg != NULL) {
+ if (smdi_msg != NULL) {
ast_copy_string(chan->exten, smdi_msg->fwd_st, sizeof(chan->exten));
if (smdi_msg->type == 'B')
Modified: trunk/doc/channelvariables.txt
URL: http://svn.digium.com/view/asterisk/trunk/doc/channelvariables.txt?rev=9451&r1=9450&r2=9451&view=diff
==============================================================================
--- trunk/doc/channelvariables.txt (original)
+++ trunk/doc/channelvariables.txt Fri Feb 10 17:55:47 2006
@@ -696,6 +696,8 @@
${CALLINGSUBADDR} * Called PRI Subaddress
${FAXEXTEN} * The extension called before being redirected to "fax"
${PRIREDIRECTREASON} * Reason for redirect, if a call was directed
+${SMDI_VM_TYPE} * When an call is received with an SMDI message, the 'type'
+ of message 'b' or 'u'
The SIP channel uses the following variables:
---------------------------------------------------------
Modified: trunk/include/asterisk/smdi.h
URL: http://svn.digium.com/view/asterisk/trunk/include/asterisk/smdi.h?rev=9451&r1=9450&r2=9451&view=diff
==============================================================================
--- trunk/include/asterisk/smdi.h (original)
+++ trunk/include/asterisk/smdi.h Fri Feb 10 17:55:47 2006
@@ -1,14 +1,19 @@
/*
* Asterisk -- A telephony toolkit for Linux.
*
- * SMDI support for Asterisk.
- *
- * Copyright (C) 2005, Digium, Inc.
+ * Copyright (C) 2005-2006, Digium, Inc.
*
* Matthew A. Nicholson <mnicholson at digium.com>
*
+ * See http://www.asterisk.org for more information about
+ * the Asterisk project. Please do not directly contact
+ * any of the maintainers of this project for assistance;
+ * the project provides a web site, mailing lists and IRC
+ * channels for your use.
+ *
* This program is free software, distributed under the terms of
- * the GNU General Public License.
+ * the GNU General Public License Version 2. See the LICENSE file
+ * at the top of the source tree.
*/
/*!
@@ -21,14 +26,15 @@
/* C is simply a ego booster for those who want to do objects the hard way. */
-#ifndef AST_SMDI_H
-#define AST_SMDI_H
+#ifndef ASTERISK_SMDI_H
+#define ASTERISK_SMDI_H
+
+#include <termios.h>
+#include <time.h>
#include "asterisk/config.h"
#include "asterisk/module.h"
#include "asterisk/astobj.h"
-#include <termios.h>
-#include <time.h>
#define SMDI_MESG_DESK_NUM_LEN 3
#define SMDI_MESG_DESK_TERM_LEN 4
@@ -98,23 +104,24 @@
/* MD message queue functions */
-extern struct ast_smdi_md_message *ast_smdi_md_message_pop(struct ast_smdi_interface *iface);
-extern struct ast_smdi_md_message *ast_smdi_md_message_wait(struct ast_smdi_interface *iface, int timeout);
-extern void ast_smdi_md_message_putback(struct ast_smdi_interface *iface, struct ast_smdi_md_message *msg);
+struct ast_smdi_md_message *ast_smdi_md_message_pop(struct ast_smdi_interface *iface);
+struct ast_smdi_md_message *ast_smdi_md_message_wait(struct ast_smdi_interface *iface, int timeout);
+void ast_smdi_md_message_putback(struct ast_smdi_interface *iface, struct ast_smdi_md_message *msg);
/* MWI message queue functions */
-extern struct ast_smdi_mwi_message *ast_smdi_mwi_message_pop(struct ast_smdi_interface *iface);
-extern struct ast_smdi_mwi_message *ast_smdi_mwi_message_wait(struct ast_smdi_interface *iface, int timeout);
-extern void ast_smdi_mwi_message_putback(struct ast_smdi_interface *iface, struct ast_smdi_mwi_message *msg);
+struct ast_smdi_mwi_message *ast_smdi_mwi_message_pop(struct ast_smdi_interface *iface);
+struct ast_smdi_mwi_message *ast_smdi_mwi_message_wait(struct ast_smdi_interface *iface, int timeout);
+void ast_smdi_mwi_message_putback(struct ast_smdi_interface *iface, struct ast_smdi_mwi_message *msg);
-extern struct ast_smdi_interface *ast_smdi_interface_find(const char *iface_name);
+struct ast_smdi_interface *ast_smdi_interface_find(const char *iface_name);
/* MWI functions */
-extern int ast_smdi_mwi_set(struct ast_smdi_interface *iface, const char *mailbox);
-extern int ast_smdi_mwi_unset(struct ast_smdi_interface *iface, const char *mailbox);
+int ast_smdi_mwi_set(struct ast_smdi_interface *iface, const char *mailbox);
+int ast_smdi_mwi_unset(struct ast_smdi_interface *iface, const char *mailbox);
-extern void ast_smdi_md_message_destroy(struct ast_smdi_md_message *msg);
-extern void ast_smdi_mwi_message_destroy(struct ast_smdi_mwi_message *msg);
+void ast_smdi_md_message_destroy(struct ast_smdi_md_message *msg);
+void ast_smdi_mwi_message_destroy(struct ast_smdi_mwi_message *msg);
-extern void ast_smdi_interface_destroy(struct ast_smdi_interface *iface);
-#endif
+void ast_smdi_interface_destroy(struct ast_smdi_interface *iface);
+
+#endif /* !ASTERISK_SMDI_H */
Modified: trunk/res/res_smdi.c
URL: http://svn.digium.com/view/asterisk/trunk/res/res_smdi.c?rev=9451&r1=9450&r2=9451&view=diff
==============================================================================
--- trunk/res/res_smdi.c (original)
+++ trunk/res/res_smdi.c Fri Feb 10 17:55:47 2006
@@ -3,7 +3,7 @@
*
* SMDI support for Asterisk.
*
- * Copyright (C) 2005, Digium, Inc.
+ * Copyright (C) 2005-2006, Digium, Inc.
*
* Matthew A. Nicholson <mnicholson at digium.com>
*
@@ -84,7 +84,7 @@
* \param iface the interface to use.
* \param mailbox the mailbox to use.
*/
-extern int ast_smdi_mwi_set(struct ast_smdi_interface *iface, const char *mailbox)
+int ast_smdi_mwi_set(struct ast_smdi_interface *iface, const char *mailbox)
{
FILE *file;
int i;
@@ -115,7 +115,7 @@
* \param iface the interface to use.
* \param mailbox the mailbox to use.
*/
-extern int ast_smdi_mwi_unset(struct ast_smdi_interface *iface, const char *mailbox)
+int ast_smdi_mwi_unset(struct ast_smdi_interface *iface, const char *mailbox)
{
FILE *file;
int i;
@@ -150,7 +150,7 @@
* should be used if a message was popped but is not going to be processed for
* some reason, and the message needs to be returned to the queue.
*/
-extern void ast_smdi_md_message_putback(struct ast_smdi_interface *iface, struct ast_smdi_md_message *md_msg)
+void ast_smdi_md_message_putback(struct ast_smdi_interface *iface, struct ast_smdi_md_message *md_msg)
{
ASTOBJ_CONTAINER_LINK_START(&iface->md_q, md_msg);
}
@@ -164,7 +164,7 @@
* should be used if a message was popped but is not going to be processed for
* some reason, and the message needs to be returned to the queue.
*/
-extern void ast_smdi_mwi_message_putback(struct ast_smdi_interface *iface, struct ast_smdi_mwi_message *mwi_msg)
+void ast_smdi_mwi_message_putback(struct ast_smdi_interface *iface, struct ast_smdi_mwi_message *mwi_msg)
{
ASTOBJ_CONTAINER_LINK_START(&iface->mwi_q, mwi_msg);
}
@@ -179,28 +179,26 @@
*
* \return the next SMDI message, or NULL if there were no pending messages.
*/
-extern struct ast_smdi_md_message *ast_smdi_md_message_pop(struct ast_smdi_interface *iface)
+struct ast_smdi_md_message *ast_smdi_md_message_pop(struct ast_smdi_interface *iface)
{
struct ast_smdi_md_message *md_msg = ASTOBJ_CONTAINER_UNLINK_START(&iface->md_q);
struct timeval now;
long elapsed = 0;
/* purge old messages */
- gettimeofday(&now, NULL);
- while(md_msg)
- {
- /* calculate the elapsed time since this message was recieved ( in milliseconds) */
- elapsed = (now.tv_sec - md_msg->timestamp.tv_sec) * 1000;
- elapsed += (now.tv_usec - md_msg->timestamp.tv_usec) / 1000;
-
- if(elapsed > iface->msg_expiry)
- { /* found an expired message */
- ASTOBJ_UNREF(md_msg,ast_smdi_md_message_destroy);
- ast_log(LOG_NOTICE, "Purged expired message from %s SMDI MD message queue. Message was %ld milliseconds too old.", iface->name, elapsed - iface->msg_expiry);
+ now = ast_tvnow();
+ while (md_msg) {
+ elapsed = ast_tvdiff_ms(now, md_msg->timestamp);
+
+ if (elapsed > iface->msg_expiry) {
+ /* found an expired message */
+ ASTOBJ_UNREF(md_msg, ast_smdi_md_message_destroy);
+ ast_log(LOG_NOTICE, "Purged expired message from %s SMDI MD message queue. Message was %ld milliseconds too old.",
+ iface->name, elapsed - iface->msg_expiry);
md_msg = ASTOBJ_CONTAINER_UNLINK_START(&iface->md_q);
}
- else /* good message, return it */
- {
+ else {
+ /* good message, return it */
break;
}
}
@@ -222,21 +220,20 @@
*/
extern struct ast_smdi_md_message *ast_smdi_md_message_wait(struct ast_smdi_interface *iface, int timeout)
{
- struct timeval start, end;
+ struct timeval start;
long diff = 0;
struct ast_smdi_md_message *msg;
- gettimeofday(&start, NULL);
- while(diff < timeout) {
-
- if((msg = ast_smdi_md_message_pop(iface)))
+ start = ast_tvnow();
+ while (diff < timeout) {
+
+ if ((msg = ast_smdi_md_message_pop(iface)))
return msg;
/* check timeout */
- gettimeofday(&end, NULL);
- diff = (end.tv_sec - start.tv_sec) * 1000;
- diff += (end.tv_usec - start.tv_usec) / 1000;
+ diff = ast_tvdiff_ms(ast_tvnow(), start);
}
+
return (ast_smdi_md_message_pop(iface));
}
@@ -257,27 +254,24 @@
long elapsed = 0;
/* purge old messages */
- gettimeofday(&now, NULL);
- while(mwi_msg)
- {
- /* calculate the elapsed time since this message was recieved ( in milliseconds) */
- elapsed = (now.tv_sec - mwi_msg->timestamp.tv_sec) * 1000;
- elapsed += (now.tv_usec - mwi_msg->timestamp.tv_usec) / 1000;
-
- if(elapsed > iface->msg_expiry)
- { /* found an expired message */
- ASTOBJ_UNREF(mwi_msg,ast_smdi_mwi_message_destroy);
- ast_log(LOG_NOTICE, "Purged expired message from %s SMDI MWI message queue. Message was %ld milliseconds too old.", iface->name, elapsed - iface->msg_expiry);
+ now = ast_tvnow();
+ while (mwi_msg) {
+ elapsed = ast_tvdiff_ms(now, mwi_msg->timestamp);
+
+ if (elapsed > iface->msg_expiry) {
+ /* found an expired message */
+ ASTOBJ_UNREF(mwi_msg, ast_smdi_mwi_message_destroy);
+ ast_log(LOG_NOTICE, "Purged expired message from %s SMDI MWI message queue. Message was %ld milliseconds too old.",
+ iface->name, elapsed - iface->msg_expiry);
mwi_msg = ASTOBJ_CONTAINER_UNLINK_START(&iface->mwi_q);
}
- else /* good message, return it */
- {
+ else {
+ /* good message, return it */
break;
}
}
return mwi_msg;
- return (ASTOBJ_CONTAINER_UNLINK_START(&iface->mwi_q));
}
/*!
@@ -294,21 +288,20 @@
*/
extern struct ast_smdi_mwi_message *ast_smdi_mwi_message_wait(struct ast_smdi_interface *iface, int timeout)
{
- struct timeval start, end;
+ struct timeval start;
long diff = 0;
struct ast_smdi_mwi_message *msg;
- gettimeofday(&start, NULL);
- while(diff < timeout) {
-
- if((msg = ast_smdi_mwi_message_pop(iface)))
+ start = ast_tvnow();
+ while (diff < timeout) {
+
+ if ((msg = ast_smdi_mwi_message_pop(iface)))
return msg;
/* check timeout */
- gettimeofday(&end, NULL);
- diff = (end.tv_sec - start.tv_sec) * 1000;
- diff += (end.tv_usec - start.tv_usec) / 1000;
+ diff = ast_tvdiff_ms(ast_tvnow(), start);
}
+
return (ast_smdi_mwi_message_pop(iface));
}
@@ -322,7 +315,7 @@
*/
extern struct ast_smdi_interface *ast_smdi_interface_find(const char *iface_name)
{
- return (ASTOBJ_CONTAINER_FIND(&smdi_ifaces,iface_name));
+ return (ASTOBJ_CONTAINER_FIND(&smdi_ifaces, iface_name));
}
/*! \brief Read an SMDI message.
@@ -343,39 +336,34 @@
int start = 0;
/* read an smdi message */
- while((c = fgetc(iface->file))) {
+ while ((c = fgetc(iface->file))) {
/* check if this is the start of a message */
- if(!start)
- {
- if(c == 'M')
+ if (!start) {
+ if (c == 'M')
start = 1;
}
- else /* Determine if this is a MD or MWI message */
- {
+ else { /* Determine if this is a MD or MWI message */
if(c == 'D') { /* MD message */
start = 0;
- md_msg = malloc(sizeof(struct ast_smdi_md_message));
- if(!md_msg) {
- ast_log(LOG_ERROR, "Error allocating memory for ast_smdi_md_message. Stopping listner thread.\n");
+ if (!(md_msg = ast_calloc(1, sizeof(*md_msg)))) {
ASTOBJ_UNREF(iface,ast_smdi_interface_destroy);
return NULL;
}
- memset(md_msg, 0, sizeof(struct ast_smdi_md_message));
ASTOBJ_INIT(md_msg);
/* read the message desk number */
- for(i = 0; i < SMDI_MESG_DESK_NUM_LEN; i++) {
+ for(i = 0; i < SMDI_MESG_DESK_NUM_LEN; i++)
md_msg->mesg_desk_num[i] = fgetc(iface->file);
- }
+
md_msg->mesg_desk_num[SMDI_MESG_DESK_NUM_LEN] = '\0';
/* read the message desk terminal number */
- for(i = 0; i < SMDI_MESG_DESK_TERM_LEN; i++) {
+ for(i = 0; i < SMDI_MESG_DESK_TERM_LEN; i++)
md_msg->mesg_desk_term[i] = fgetc(iface->file);
- }
+
md_msg->mesg_desk_term[SMDI_MESG_DESK_TERM_LEN] = '\0';
/* read the message type */
@@ -383,42 +371,40 @@
/* read the forwarding station number (may be blank) */
cp = &md_msg->fwd_st[0];
- for(i = 0; i < SMDI_MAX_STATION_NUM_LEN + 1; i++) {
+ for (i = 0; i < SMDI_MAX_STATION_NUM_LEN + 1; i++) {
if((c = fgetc(iface->file)) == ' ') {
*cp = '\0';
break;
}
/* store c in md_msg->fwd_st */
- if( i >= iface->msdstrip) {
- *cp = c;
- cp++;
- }
+ if( i >= iface->msdstrip)
+ *cp++ = c;
}
+
/* make sure the value is null terminated, even if this truncates it */
md_msg->fwd_st[SMDI_MAX_STATION_NUM_LEN] = '\0';
cp = NULL;
/* read the calling station number (may be blank) */
cp = &md_msg->calling_st[0];
- for(i = 0; i < SMDI_MAX_STATION_NUM_LEN + 1; i++) {
- if(!isdigit( (c = fgetc(iface->file)) )) {
+ for (i = 0; i < SMDI_MAX_STATION_NUM_LEN + 1; i++) {
+ if (!isdigit((c = fgetc(iface->file)))) {
*cp = '\0';
break;
}
/* store c in md_msg->calling_st */
- if( i >= iface->msdstrip) {
- *cp = c;
- cp++;
- }
+ if (i >= iface->msdstrip)
+ *cp++ = c;
}
+
/* make sure the value is null terminated, even if this truncates it */
md_msg->calling_st[SMDI_MAX_STATION_NUM_LEN] = '\0';
cp = NULL;
/* add the message to the message queue */
- gettimeofday(&md_msg->timestamp, NULL);
+ md_msg->timestamp = ast_tvnow();
ast_smdi_md_message_push(iface, md_msg);
ast_log(LOG_DEBUG, "Recieved SMDI MD message on %s\n", iface->name);
@@ -427,14 +413,11 @@
} else if(c == 'W') { /* MWI message */
start = 0;
- mwi_msg = malloc(sizeof(struct ast_smdi_mwi_message));
- if(!mwi_msg) {
- ast_log(LOG_ERROR, "Error allocating memory for ast_smdi_mwi_message. Stopping listner thread.\n");
+ if (!(mwi_msg = ast_calloc(1, sizeof(*mwi_msg)))) {
ASTOBJ_UNREF(iface,ast_smdi_interface_destroy);
return NULL;
}
- memset(mwi_msg, 0, sizeof(struct ast_smdi_mwi_message));
-
+
ASTOBJ_INIT(mwi_msg);
/* discard the 'I' (from 'MWI') */
@@ -442,30 +425,29 @@
/* read the forwarding station number (may be blank) */
cp = &mwi_msg->fwd_st[0];
- for(i = 0; i < SMDI_MAX_STATION_NUM_LEN + 1; i++) {
- if((c = fgetc(iface->file)) == ' ') {
+ for (i = 0; i < SMDI_MAX_STATION_NUM_LEN + 1; i++) {
+ if ((c = fgetc(iface->file)) == ' ') {
*cp = '\0';
break;
}
/* store c in md_msg->fwd_st */
- if( i >= iface->msdstrip) {
- *cp = c;
- cp++;
- }
+ if (i >= iface->msdstrip)
+ *cp++ = c;
}
+
/* make sure the station number is null terminated, even if this will truncate it */
mwi_msg->fwd_st[SMDI_MAX_STATION_NUM_LEN] = '\0';
cp = NULL;
/* read the mwi failure cause */
- for(i = 0; i < SMDI_MWI_FAIL_CAUSE_LEN; i++) {
+ for (i = 0; i < SMDI_MWI_FAIL_CAUSE_LEN; i++)
mwi_msg->cause[i] = fgetc(iface->file);
- }
+
mwi_msg->cause[SMDI_MWI_FAIL_CAUSE_LEN] = '\0';
/* add the message to the message queue */
- gettimeofday(&mwi_msg->timestamp, NULL);
+ mwi_msg->timestamp = ast_tvnow();
ast_smdi_mwi_message_push(iface, mwi_msg);
ast_log(LOG_DEBUG, "Recieved SMDI MWI message on %s\n", iface->name);
@@ -497,7 +479,7 @@
/*! \brief ast_smdi_interface destructor. */
void ast_smdi_interface_destroy(struct ast_smdi_interface *iface)
{
- if(iface->thread != AST_PTHREADT_NULL && iface->thread != AST_PTHREADT_STOP) {
+ if (iface->thread != AST_PTHREADT_NULL && iface->thread != AST_PTHREADT_STOP) {
pthread_cancel(iface->thread);
pthread_join(iface->thread, NULL);
}
@@ -547,7 +529,7 @@
conf = ast_config_load(config_file);
- if(!conf) {
+ if (!conf) {
ast_log(LOG_ERROR, "Unable to load config %s\n", config_file);
return -1;
}
@@ -557,61 +539,60 @@
* still marked after we have finished parsing the config file should
* be stopped.
*/
- if(reload)
+ if (reload)
ASTOBJ_CONTAINER_MARKALL(&smdi_ifaces);
- v = ast_variable_browse(conf, "interfaces");
- while(v) {
- if(!strcasecmp(v->name, "baudrate")) {
- if(!strcasecmp(v->value, "9600")) {
+ for (v = ast_variable_browse(conf, "interfaces"); v; v = v->next) {
+ if (!strcasecmp(v->name, "baudrate")) {
+ if (!strcasecmp(v->value, "9600"))
baud_rate = B9600;
- } else if(!strcasecmp(v->value, "4800")) {
+ else if(!strcasecmp(v->value, "4800"))
baud_rate = B4800;
- } else if(!strcasecmp(v->value, "2400")) {
+ else if(!strcasecmp(v->value, "2400"))
baud_rate = B2400;
- } else if(!strcasecmp(v->value, "1200")) {
+ else if(!strcasecmp(v->value, "1200"))
baud_rate = B1200;
- } else {
+ else {
ast_log(LOG_NOTICE, "Invalid baud rate '%s' specified in %s (line %d), using default\n", v->value, config_file, v->lineno);
baud_rate = B9600;
}
- } else if(!strcasecmp(v->name, "msdstrip")) {
- if(!sscanf(v->value, "%d", &msdstrip)) {
+ } else if (!strcasecmp(v->name, "msdstrip")) {
+ if (!sscanf(v->value, "%d", &msdstrip)) {
ast_log(LOG_NOTICE, "Invalid msdstrip value in %s (line %d), using default\n", config_file, v->lineno);
msdstrip = 0;
- } else if(0 > msdstrip || msdstrip > 9) {
+ } else if (0 > msdstrip || msdstrip > 9) {
ast_log(LOG_NOTICE, "Invalid msdstrip value in %s (line %d), using default\n", config_file, v->lineno);
msdstrip = 0;
}
- } else if(!strcasecmp(v->name, "msgexpirytime")) {
- if(!sscanf(v->value, "%ld", &msg_expiry)) {
+ } else if (!strcasecmp(v->name, "msgexpirytime")) {
+ if (!sscanf(v->value, "%ld", &msg_expiry)) {
ast_log(LOG_NOTICE, "Invalid msgexpirytime value in %s (line %d), using default\n", config_file, v->lineno);
msg_expiry = SMDI_MSG_EXPIRY_TIME;
}
- } else if(!strcasecmp(v->name, "paritybit")) {
- if(!strcasecmp(v->value, "even")) {
+ } else if (!strcasecmp(v->name, "paritybit")) {
+ if (!strcasecmp(v->value, "even"))
paritybit = PARENB;
- } else if(!strcasecmp(v->value, "odd")) {
+ else if (!strcasecmp(v->value, "odd"))
paritybit = PARENB | PARODD;
- } else if(!strcasecmp(v->value, "none")) {
+ else if (!strcasecmp(v->value, "none"))
paritybit = ~PARENB;
- } else {
+ else {
ast_log(LOG_NOTICE, "Invalid parity bit setting in %s (line %d), using default\n", config_file, v->lineno);
paritybit = PARENB;
}
- } else if(!strcasecmp(v->name, "charsize")) {
- if(!strcasecmp(v->value, "7")) {
+ } else if (!strcasecmp(v->name, "charsize")) {
+ if (!strcasecmp(v->value, "7"))
charsize = CS7;
- } else if(!strcasecmp(v->value, "8")) {
+ else if (!strcasecmp(v->value, "8"))
charsize = CS8;
- } else {
+ else {
ast_log(LOG_NOTICE, "Invalid character size setting in %s (line %d), using default\n", config_file, v->lineno);
charsize = CS7;
}
- } else if(!strcasecmp(v->name, "twostopbits")) {
+ } else if (!strcasecmp(v->name, "twostopbits")) {
stopbits = ast_true(v->name);
- } else if(!strcasecmp(v->name, "smdiport")) {
- if(reload) {
+ } else if (!strcasecmp(v->name, "smdiport")) {
+ if (reload) {
/* we are reloading, check if we are already
* monitoring this interface, if we are we do
* not want to start it again. This also has
@@ -622,57 +603,48 @@
* restarting the interface. Or the interface
* could be restarted with out emptying the
* queue. */
- iface = ASTOBJ_CONTAINER_FIND(&smdi_ifaces, v->value);
- if(iface) {
+ if ((iface = ASTOBJ_CONTAINER_FIND(&smdi_ifaces, v->value))) {
ast_log(LOG_NOTICE, "SMDI interface %s already running, not restarting\n", iface->name);
ASTOBJ_UNMARK(iface);
ASTOBJ_UNREF(iface, ast_smdi_interface_destroy);
- v = v->next;
continue;
}
}
- iface = malloc(sizeof(struct ast_smdi_interface));
+ iface = ast_calloc(1, sizeof(*iface));
ASTOBJ_INIT(iface);
ASTOBJ_CONTAINER_INIT(&iface->md_q);
ASTOBJ_CONTAINER_INIT(&iface->mwi_q);
- iface->md_q.head = NULL;
- iface->mwi_q.head = NULL;
- iface->thread = AST_PTHREADT_NULL;
- memset(&iface->mode, 0, sizeof(iface->mode));
ast_copy_string(iface->name, v->value, sizeof(iface->name));
- iface->file = fopen(iface->name, "r");
- if(!(iface->file)) {
+ if (!(iface->file = fopen(iface->name, "r"))) {
ast_log(LOG_ERROR, "Error opening SMDI interface %s (%s)\n", iface->name, strerror(errno));
ASTOBJ_UNREF(iface, ast_smdi_interface_destroy);
- v = v->next;
continue;
}
+
iface->fd = fileno(iface->file);
/* Set the proper attributes for our serial port. */
/* get the current attributes from the port */
- if(tcgetattr(iface->fd, &iface->mode)) {
+ if (tcgetattr(iface->fd, &iface->mode)) {
ast_log(LOG_ERROR, "Error getting atributes of %s (%s)\n", iface->name, strerror(errno));
ASTOBJ_UNREF(iface, ast_smdi_interface_destroy);
- v = v->next;
continue;
}
/* set the desired speed */
- if(cfsetispeed(&iface->mode, baud_rate) || cfsetospeed(&iface->mode, baud_rate)) {
+ if (cfsetispeed(&iface->mode, baud_rate) || cfsetospeed(&iface->mode, baud_rate)) {
ast_log(LOG_ERROR, "Error setting baud rate on %s (%s)\n", iface->name, strerror(errno));
ASTOBJ_UNREF(iface, ast_smdi_interface_destroy);
- v = v->next;
continue;
}
/* set the stop bits */
- if(stopbits)
+ if (stopbits)
iface->mode.c_cflag = iface->mode.c_cflag | CSTOPB; /* set two stop bits */
else
iface->mode.c_cflag = iface->mode.c_cflag & ~CSTOPB; /* set one stop bit */
@@ -684,10 +656,9 @@
iface->mode.c_cflag = (iface->mode.c_cflag & ~CSIZE) | charsize;
/* commit the desired attributes */
- if(tcsetattr(iface->fd, TCSAFLUSH, &iface->mode)) {
+ if (tcsetattr(iface->fd, TCSAFLUSH, &iface->mode)) {
ast_log(LOG_ERROR, "Error setting attributes on %s (%s)\n", iface->name, strerror(errno));
ASTOBJ_UNREF(iface, ast_smdi_interface_destroy);
- v = v->next;
continue;
}
@@ -698,15 +669,16 @@
iface->msg_expiry = msg_expiry;
/* start the listner thread */
- if(option_verbose > 2)
+ if (option_verbose > 2)
ast_verbose(VERBOSE_PREFIX_3 "Starting SMDI monitor thread for %s\n", iface->name);
- if(ast_pthread_create(&iface->thread, NULL, smdi_read, iface)) {
+ if (ast_pthread_create(&iface->thread, NULL, smdi_read, iface)) {
ast_log(LOG_ERROR, "Error starting SMDI monitor thread for %s\n", iface->name);
ASTOBJ_UNREF(iface, ast_smdi_interface_destroy);
- v = v->next;
continue;
}
+
ASTOBJ_CONTAINER_LINK(&smdi_ifaces, iface);
+ ASTOBJ_UNREF(iface, ast_smdi_interface_destroy);
ast_mutex_lock(&localuser_lock);
localusecnt++;
ast_mutex_unlock(&localuser_lock);
@@ -719,11 +691,12 @@
ast_config_destroy(conf);
/* Prune any interfaces we should no longer monitor. */
- if(reload)
+ if (reload)
ASTOBJ_CONTAINER_PRUNE_MARKED(&smdi_ifaces, ast_smdi_interface_destroy);
ASTOBJ_CONTAINER_RDLOCK(&smdi_ifaces);
- if(!smdi_ifaces.head)
+ /* TODO: this is bad, we need an ASTOBJ method for this! */
+ if (!smdi_ifaces.head)
res = 1;
ASTOBJ_CONTAINER_UNLOCK(&smdi_ifaces);
@@ -733,58 +706,58 @@
char *description(void)
{
- return (char *)tdesc;
+ return (char *) tdesc;
}
int load_module(void)
{
int res;
- /* initilize our containers */
+ /* initialize our containers */
+ memset(&smdi_ifaces, 0, sizeof(smdi_ifaces));
ASTOBJ_CONTAINER_INIT(&smdi_ifaces);
- smdi_ifaces.head = NULL;
/* load the config and start the listener threads*/
res = smdi_load(0);
- if(res < 0) {
+ if (res < 0) {
return res;
- } else if(res == 1) {
+ } else if (res == 1) {
ast_log(LOG_WARNING, "No SMDI interfaces are available to listen on, not starting SDMI listener.\n");
return 0;
- }
+ } else
+ return 0;
+}
+
+int unload_module(void)
+{
+ /* this destructor stops any running smdi_read threads */
+ ASTOBJ_CONTAINER_DESTROYALL(&smdi_ifaces, ast_smdi_interface_destroy);
+ ASTOBJ_CONTAINER_DESTROY(&smdi_ifaces);
return 0;
}
-int unload_module(void)
-{
- /* this destructor stops any running smdi_read threads */
- ASTOBJ_CONTAINER_DESTROYALL(&smdi_ifaces,ast_smdi_interface_destroy);
- ASTOBJ_CONTAINER_DESTROY(&smdi_ifaces);
-
- return 0;
-}
-
int reload(void)
{
int res;
+
res = smdi_load(1);
- if(res < 0) {
+ if (res < 0) {
return res;
- } else if(res == 1) {
+ } else if (res == 1) {
ast_log(LOG_WARNING, "No SMDI interfaces were specified to listen on, not starting SDMI listener.\n");
return 0;
- }
-
- /* notify the listner thread? */
- return 0;
+ } else
+ return 0;
}
int usecount(void)
{
int res;
+
STANDARD_USECOUNT(res);
+
return res;
}
More information about the asterisk-commits
mailing list