*/
+
+/* Choose if you want to have chan_lcr for Asterisk 1.4.x or CallWeaver 1.2.x */
+#define LCR_FOR_ASTERISK
+/* #define LCR_FOR_CALLWEAVER */
+
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#define HAVE_ATTRIBUTE_always_inline 1
#define HAVE_ARPA_INET_H 1
#define HAVE_TIMERSUB 1
+#define HAVE_STRTOQ 1
+#define HAVE_INET_ATON 1
#include <asterisk/compiler.h>
+#ifdef LCR_FOR_ASTERISK
#include <asterisk/buildopts.h>
+#endif
#include <asterisk/module.h>
#include <asterisk/channel.h>
#include <asterisk/config.h>
#include <asterisk/dsp.h>
#include <asterisk/translate.h>
#include <asterisk/file.h>
+#ifdef LCR_FOR_ASTERISK
#include <asterisk/callerid.h>
+#endif
+#ifdef LCR_FOR_CALLWEAVER
+#include <asterisk/phone_no_utils.h>
+#endif
+
#include <asterisk/indications.h>
#include <asterisk/app.h>
#include <asterisk/features.h>
CHAN_LCR_STATE // state description structure
MESSAGES // message text
+#ifdef LCR_FOR_CALLWEAVER
+AST_MUTEX_DEFINE_STATIC(rand_lock);
+#endif
+
unsigned char flip_bits[256];
+#ifdef LCR_FOR_CALLWEAVER
+static struct ast_frame nullframe = { AST_FRAME_NULL, };
+#endif
+
int lcr_debug=1;
int mISDN_created=1;
char lcr_type[]="lcr";
+#ifdef LCR_FOR_CALLWEAVER
+static ast_mutex_t usecnt_lock;
+static int usecnt=0;
+static char *desc = "Channel driver for mISDN/LCR Support (Bri/Pri)";
+#endif
+
pthread_t chan_tid;
ast_mutex_t chan_lock; /* global lock */
ast_mutex_t log_lock; /* logging log */
struct chan_call *call = call_first;
int assigned = (ref > 0);
- while(call)
- {
+ while(call) {
if (call->ref == ref && call->ref_was_assigned == assigned)
break;
call = call->next;
{
struct chan_call **temp = &call_first;
- while(*temp)
- {
- if (*temp == call)
- {
+ while(*temp) {
+ if (*temp == call) {
*temp = (*temp)->next;
if (call->pipe[0] > -1)
close(call->pipe[0]);
if (call->pipe[1] > -1)
close(call->pipe[1]);
- if (call->bchannel)
- {
+ if (call->bchannel) {
if (call->bchannel->call != call)
CERROR(call, NULL, "Linked bchannel structure has no link to us.\n");
call->bchannel->call = NULL;
}
- if (call->bridge_call)
- {
+ if (call->bridge_call) {
if (call->bridge_call->bridge_call != call)
CERROR(call, NULL, "Linked call structure has no link to us.\n");
call->bridge_call->bridge_call = NULL;
unsigned short id = 1;
/* search for lowest bridge id that is not in use and not 0 */
- while(id)
- {
+ while(id) {
call = call_first;
- while(call)
- {
+ while(call) {
if (call->bridge_id == id)
break;
call = call->next;
string[sizeof(string)-1] = '\0';
/* parse options */
- while((opt = strsep(&p, ":")))
- {
+ while((opt = strsep(&p, ":"))) {
switch(opt[0]) {
case 'd':
if (opt[1] == '\0') {
break;
}
CDEBUG(call, call->ast, "Option 'n' (no DTMF).\n");
- call->no_dtmf = 1;
+ if (call->dsp_dtmf) {
+ call->dsp_dtmf = 0;
+ if (call->bchannel)
+ bchannel_dtmf(call->bchannel, 0);
+ }
break;
case 'c':
if (opt[1] == '\0') {
break;
}
i = 0;
- while(*key)
- {
+ while(*key) {
if (*key>='0' && *key<='9')
call->bf_key[i] = (*key-'0') << 8;
else if (*key>='a' && *key<='f')
if (!call->dsp)
call->dsp=ast_dsp_new();
if (call->dsp) {
+ #ifdef LCR_FOR_CALLWEAVER
+ ast_dsp_set_features(call->dsp, DSP_FEATURE_DTMF_DETECT| DSP_FEATURE_FAX_CNG_DETECT);
+ #endif
+ #ifdef LCR_FOR_ASTERISK
+ #ifdef DSP_FEATURE_DTMF_DETECT
ast_dsp_set_features(call->dsp, DSP_FEATURE_DTMF_DETECT| DSP_FEATURE_FAX_DETECT);
+ #else
+ ast_dsp_set_features(call->dsp, DSP_FEATURE_DIGIT_DETECT| DSP_FEATURE_FAX_DETECT);
+ #endif
+
+ #endif
if (!call->trans)
+ #ifdef LCR_FOR_CALLWEAVER
+ call->trans=ast_translator_build_path(AST_FORMAT_SLINEAR, 8000, (options.law=='a')?AST_FORMAT_ALAW:AST_FORMAT_ULAW, 8000);
+ #endif
+ #ifdef LCR_FOR_ASTERISK
call->trans=ast_translator_build_path(AST_FORMAT_SLINEAR, (options.law=='a')?AST_FORMAT_ALAW:AST_FORMAT_ULAW);
+ #endif
}
CDEBUG(call, call->ast, "Option 'f' (faxdetect) with config '%s'.\n", call->faxdetect);
break;
strncpy(newparam.setup.callerinfo.id, call->cid_num, sizeof(newparam.setup.callerinfo.id)-1);
if (call->cid_name[0])
strncpy(newparam.setup.callerinfo.name, call->cid_name, sizeof(newparam.setup.callerinfo.name)-1);
- if (call->cid_rdnis[0])
- {
+ if (call->cid_rdnis[0]) {
strncpy(newparam.setup.redirinfo.id, call->cid_rdnis, sizeof(newparam.setup.redirinfo.id)-1);
newparam.setup.redirinfo.itype = INFO_ITYPE_CHAN;
newparam.setup.redirinfo.ntype = INFO_NTYPE_UNKNOWN;
}
- switch(ast->cid.cid_pres & AST_PRES_RESTRICTION)
- {
+ switch(ast->cid.cid_pres & AST_PRES_RESTRICTION) {
case AST_PRES_RESTRICTED:
newparam.setup.callerinfo.present = INFO_PRESENT_RESTRICTED;
break;
default:
newparam.setup.callerinfo.present = INFO_PRESENT_ALLOWED;
}
- switch(ast->cid.cid_ton)
- {
+ switch(ast->cid.cid_ton) {
case 4:
newparam.setup.callerinfo.ntype = INFO_NTYPE_SUBSCRIBER;
break;
CDEBUG(call, ast, "Try to start pbx. (exten=%s context=%s complete=%s)\n", exten, ast->context, complete?"yes":"no");
- if (complete)
- {
+ if (complete) {
/* if not match */
- if (!ast_canmatch_extension(ast, ast->context, exten, 1, call->oad))
- {
+ if (!ast_canmatch_extension(ast, ast->context, exten, 1, call->oad)) {
CDEBUG(call, ast, "Got 'sending complete', but extension '%s' will not match at context '%s' - releasing.\n", exten, ast->context);
cause = 1;
goto release;
}
- if (!ast_exists_extension(ast, ast->context, exten, 1, call->oad))
- {
+ if (!ast_exists_extension(ast, ast->context, exten, 1, call->oad)) {
CDEBUG(call, ast, "Got 'sending complete', but extension '%s' would match at context '%s', if more digits would be dialed - releasing.\n", exten, ast->context);
cause = 28;
goto release;
goto start;
}
- if (ast_canmatch_extension(ast, ast->context, exten, 1, call->oad))
- {
+ if (ast_canmatch_extension(ast, ast->context, exten, 1, call->oad)) {
/* send setup acknowledge to lcr */
if (call->state != CHAN_LCR_STATE_IN_DIALING) {
memset(&newparam, 0, sizeof(union parameter));
start:
/* send setup to asterisk */
CDEBUG(call, ast, "Starting call to Asterisk due to matching extension.\n");
+
+ #ifdef LCR_FOR_CALLWEAVER
+ ast->type = "LCR";
+ snprintf(ast->name, sizeof(ast->name), "LCR/%s-%04x",ast->cid.cid_num, ast_random() & 0xffff);
+ #endif
+
ret = ast_pbx_start(ast);
- if (ret < 0)
- {
+ if (ret < 0) {
cause = (ret==-2)?34:27;
goto release;
}
CDEBUG(call, NULL, "Incomming setup from LCR. (callerid %s, dialing %s)\n", param->setup.callerinfo.id, param->setup.dialinginfo.id);
/* create asterisk channel instrance */
+
+ #ifdef LCR_FOR_CALLWEAVER
+ ast = ast_channel_alloc(1);
+ #endif
+
+ #ifdef LCR_FOR_ASTERISK
ast = ast_channel_alloc(1, AST_STATE_RESERVED, NULL, NULL, "", NULL, "", 0, "%s/%d", lcr_type, ++glob_channel);
- if (!ast)
- {
+ #endif
+
+ if (!ast) {
/* release */
CERROR(call, NULL, "Failed to create Asterisk channel - releasing.\n");
send_release_and_import(call, CAUSE_RESSOURCEUNAVAIL, LOCATION_PRIVATE_LOCAL);
ast->cid.cid_name = strdup(param->setup.callerinfo.name);
if (param->setup.redirinfo.id[0])
ast->cid.cid_name = strdup(numberrize_callerinfo(param->setup.callerinfo.id, param->setup.callerinfo.ntype, options.national, options.international));
- switch (param->setup.callerinfo.present)
- {
+ switch (param->setup.callerinfo.present) {
case INFO_PRESENT_ALLOWED:
ast->cid.cid_pres = AST_PRES_ALLOWED;
break;
default:
ast->cid.cid_pres = AST_PRES_UNAVAILABLE;
}
- switch (param->setup.callerinfo.ntype)
- {
+ switch (param->setup.callerinfo.ntype) {
case INFO_NTYPE_SUBSCRIBER:
ast->cid.cid_ton = 4;
break;
memcpy(&call->connectinfo, ¶m->connectinfo, sizeof(struct connect_info));
/* queue event to asterisk */
if (call->ast && call->pbx_started)
- strncat(call->queue_string, "A", sizeof(call->queue_string)-1);
+ strncat(call->queue_string, "N", sizeof(call->queue_string)-1);
}
/*
/* if bridge, forward disconnect and return */
#ifdef TODO
feature flag
- if (call->bridge_call)
- {
+ if (call->bridge_call) {
CDEBUG(call, call->ast, "Only signal disconnect via bridge.\n");
bridge_message_if_bridged(call, message_type, param);
return;
/* change to release state */
call->state = CHAN_LCR_STATE_RELEASE;
/* queue release asterisk */
- if (ast)
- {
+ if (ast) {
ast->hangupcause = call->cause;
if (call->pbx_started)
strcpy(call->queue_string, "H"); // overwrite other indications
/* change to release state */
call->state = CHAN_LCR_STATE_RELEASE;
/* copy release info */
- if (!call->cause)
- {
+ if (!call->cause) {
call->cause = param->disconnectinfo.cause;
call->location = param->disconnectinfo.location;
}
/* if we have an asterisk instance, queue hangup, else we are done */
- if (ast)
- {
+ if (ast) {
ast->hangupcause = call->cause;
if (call->pbx_started)
strcpy(call->queue_string, "H");
else {
ast_hangup(ast); // call will be destroyed here
}
- } else
- {
+ } else {
free_call(call);
}
if (!ast) return;
/* pbx not started */
- if (!call->pbx_started)
- {
+ if (!call->pbx_started) {
CDEBUG(call, call->ast, "Asterisk not started, adding digits to number.\n");
strncat(ast->exten, param->information.id, AST_MAX_EXTENSION-1);
lcr_start_pbx(call, ast, param->information.sending_complete);
}
/*
+ * incoming pattern from LCR
+ */
+static void lcr_in_pattern(struct chan_call *call, int message_type, union parameter *param)
+{
+ union parameter newparam;
+
+ CDEBUG(call, call->ast, "Incomming pattern indication from LCR.\n");
+
+ if (!call->ast) return;
+
+ /* pattern are indicated only once */
+ if (call->has_pattern)
+ return;
+ call->has_pattern = 1;
+
+ /* request bchannel */
+ if (!call->bchannel) {
+ CDEBUG(call, call->ast, "Requesting B-channel.\n");
+ memset(&newparam, 0, sizeof(union parameter));
+ newparam.bchannel.type = BCHANNEL_REQUEST;
+ send_message(MESSAGE_BCHANNEL, call->ref, &newparam);
+ }
+ /* queue PROGRESS, because tones are available */
+ if (call->ast && call->pbx_started)
+ strncat(call->queue_string, "T", sizeof(call->queue_string)-1);
+}
+
+/*
* got dtmf from bchannel (locked state)
*/
void lcr_in_dtmf(struct chan_call *call, int val)
if (!call->pbx_started)
return;
+ if (!call->dsp_dtmf) {
+ CDEBUG(call, call->ast, "Recognised DTMF digit '%c', but ignoring. This is fixed in later mISDN driver.\n", val);
+ return;
+ }
+
CDEBUG(call, call->ast, "Recognised DTMF digit '%c'.\n", val);
digit[0] = val;
digit[1] = '\0';
memset(&newparam, 0, sizeof(union parameter));
/* handle bchannel message*/
- if (message_type == MESSAGE_BCHANNEL)
- {
- switch(param->bchannel.type)
- {
+ if (message_type == MESSAGE_BCHANNEL) {
+ switch(param->bchannel.type) {
case BCHANNEL_ASSIGN:
CDEBUG(NULL, NULL, "Received BCHANNEL_ASSIGN message. (handle=%08lx) for ref %d\n", param->bchannel.handle, ref);
- if ((bchannel = find_bchannel_handle(param->bchannel.handle)))
- {
+ if ((bchannel = find_bchannel_handle(param->bchannel.handle))) {
CERROR(NULL, NULL, "bchannel handle %x already assigned.\n", (int)param->bchannel.handle);
return(-1);
}
/* create bchannel */
bchannel = alloc_bchannel(param->bchannel.handle);
- if (!bchannel)
- {
+ if (!bchannel) {
CERROR(NULL, NULL, "alloc bchannel handle %x failed.\n", (int)param->bchannel.handle);
return(-1);
}
bchannel->b_tx_gain = param->bchannel.tx_gain;
bchannel->b_rx_gain = param->bchannel.rx_gain;
strncpy(bchannel->b_pipeline, param->bchannel.pipeline, sizeof(bchannel->b_pipeline)-1);
- if (param->bchannel.crypt_len && param->bchannel.crypt_len <= sizeof(bchannel->b_bf_key))
- {
+ if (param->bchannel.crypt_len && param->bchannel.crypt_len <= sizeof(bchannel->b_bf_key)) {
bchannel->b_bf_len = param->bchannel.crypt_len;
memcpy(bchannel->b_bf_key, param->bchannel.crypt, param->bchannel.crypt_len);
}
bchannel->b_txdata = 0;
- bchannel->b_dtmf = 1;
bchannel->b_tx_dejitter = 1;
/* in case, ref is not set, this bchannel instance must
* be created until it is removed again by LCR */
/* link to call */
call = find_call_ref(ref);
- if (call)
- {
+ if (call) {
bchannel->call = call;
call->bchannel = bchannel;
- if (call->dtmf)
+ if (call->dsp_dtmf)
bchannel_dtmf(bchannel, 1);
if (call->bf_len)
bchannel_blowfish(bchannel, call->bf_key, call->bf_len);
case BCHANNEL_REMOVE:
CDEBUG(NULL, NULL, "Received BCHANNEL_REMOVE message. (handle=%08lx)\n", param->bchannel.handle);
- if (!(bchannel = find_bchannel_handle(param->bchannel.handle)))
- {
+ if (!(bchannel = find_bchannel_handle(param->bchannel.handle))) {
CERROR(NULL, NULL, "Bchannel handle %x not assigned.\n", (int)param->bchannel.handle);
return(-1);
}
}
/* handle new ref */
- if (message_type == MESSAGE_NEWREF)
- {
- if (param->direction)
- {
+ if (message_type == MESSAGE_NEWREF) {
+ if (param->direction) {
/* new ref from lcr */
CDEBUG(NULL, NULL, "Received new ref by LCR, due to incomming call. (ref=%ld)\n", ref);
- if (!ref || find_call_ref(ref))
- {
+ if (!ref || find_call_ref(ref)) {
CERROR(NULL, NULL, "Illegal new ref %ld received.\n", ref);
return(-1);
}
/* set ref */
call->ref = ref;
call->ref_was_assigned = 1;
+ /* set dtmf (default, use option 'n' to disable */
+ call->dsp_dtmf = 1;
/* wait for setup (or release from asterisk) */
- } else
- {
+ } else {
/* new ref, as requested from this remote application */
CDEBUG(NULL, NULL, "Received new ref by LCR, as requested from chan_lcr. (ref=%ld)\n", ref);
call = find_call_ref(0);
- if (!call)
- {
+ if (!call) {
/* send release, if ref does not exist */
CDEBUG(NULL, NULL, "No call found, that requests a ref.\n");
send_release_and_import(call, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL);
if (call->state == CHAN_LCR_STATE_OUT_PREPARE)
send_setup_to_lcr(call);
/* release if asterisk has signed off */
- else if (call->state == CHAN_LCR_STATE_RELEASE)
- {
+ else if (call->state == CHAN_LCR_STATE_RELEASE) {
/* send release */
if (call->cause)
send_release_and_import(call, call->cause, call->location);
}
/* check ref */
- if (!ref)
- {
+ if (!ref) {
CERROR(NULL, NULL, "Received message %d without ref.\n", message_type);
return(-1);
}
call = find_call_ref(ref);
- if (!call)
- {
+ if (!call) {
/* ignore ref that is not used (anymore) */
CDEBUG(NULL, NULL, "Message %d from LCR ignored, because no call instance found.\n", message_type);
return(0);
}
/* handle messages */
- switch(message_type)
- {
+ switch(message_type) {
case MESSAGE_SETUP:
lcr_in_setup(call, message_type, param);
break;
break;
case MESSAGE_PATTERN: // audio available from LCR
+ if (!call->has_pattern)
+ lcr_in_pattern(call, message_type, param);
break;
case MESSAGE_NOPATTERN: // audio not available from LCR
/* read from socket */
len = read(lcr_sock, &msg, sizeof(msg));
- if (len == 0)
- {
+ if (len == 0) {
CERROR(NULL, NULL, "Socket closed.\n");
return(-1); // socket closed
}
- if (len > 0)
- {
- if (len != sizeof(msg))
- {
+ if (len > 0) {
+ if (len != sizeof(msg)) {
CERROR(NULL, NULL, "Socket short read. (len %d)\n", len);
return(-1); // socket error
}
- if (msg.message != ADMIN_MESSAGE)
- {
+ if (msg.message != ADMIN_MESSAGE) {
CERROR(NULL, NULL, "Socket received illegal message %d.\n", msg.message);
return(-1);
}
receive_message(msg.u.msg.type, msg.u.msg.ref, &msg.u.msg.param);
work = 1;
- } else
- {
- if (errno != EWOULDBLOCK)
- {
+ } else {
+ if (errno != EWOULDBLOCK) {
CERROR(NULL, NULL, "Socket failed (errno %d).\n", errno);
return(-1);
}
return(work);
admin = admin_first;
len = write(lcr_sock, &admin->msg, sizeof(msg));
- if (len == 0)
- {
+ if (len == 0) {
CERROR(NULL, NULL, "Socket closed.\n");
return(-1); // socket closed
}
- if (len > 0)
- {
- if (len != sizeof(msg))
- {
+ if (len > 0) {
+ if (len != sizeof(msg)) {
CERROR(NULL, NULL, "Socket short write. (len %d)\n", len);
return(-1); // socket error
}
free(admin);
work = 1;
- } else
- {
- if (errno != EWOULDBLOCK)
- {
+ } else {
+ if (errno != EWOULDBLOCK) {
CERROR(NULL, NULL, "Socket failed (errno %d).\n", errno);
return(-1);
}
union parameter param;
/* open socket */
- if ((lcr_sock = socket(PF_UNIX, SOCK_STREAM, 0)) < 0)
- {
+ if ((lcr_sock = socket(PF_UNIX, SOCK_STREAM, 0)) < 0) {
CERROR(NULL, NULL, "Failed to create socket.\n");
return(lcr_sock);
}
sprintf(sock_address.sun_path, SOCKET_NAME, options.lock);
/* connect socket */
- if ((conn = connect(lcr_sock, (struct sockaddr *)&sock_address, SUN_LEN(&sock_address))) < 0)
- {
+ if ((conn = connect(lcr_sock, (struct sockaddr *)&sock_address, SUN_LEN(&sock_address))) < 0) {
close(lcr_sock);
lcr_sock = -1;
CDEBUG(NULL, NULL, "Failed to connect to socket '%s'. Is LCR running?\n", sock_address.sun_path);
}
/* set non-blocking io */
- if ((ret = ioctl(lcr_sock, FIONBIO, (unsigned char *)(&on))) < 0)
- {
+ if ((ret = ioctl(lcr_sock, FIONBIO, (unsigned char *)(&on))) < 0) {
close(lcr_sock);
lcr_sock = -1;
CERROR(NULL, NULL, "Failed to set socket into non-blocking IO.\n");
if (!ast_channel_trylock(ast)) { /* succeed */
while(*p) {
switch (*p) {
+ case 'T':
+ CDEBUG(call, ast, "Sending queued PROGRESS to Asterisk.\n");
+ ast_queue_control(ast, AST_CONTROL_PROGRESS);
+ break;
case 'P':
CDEBUG(call, ast, "Sending queued PROCEEDING to Asterisk.\n");
ast_queue_control(ast, AST_CONTROL_PROCEEDING);
ast_queue_control(ast, AST_CONTROL_RINGING);
ast_setstate(ast, AST_STATE_RINGING);
break;
- case 'A':
+ case 'N':
CDEBUG(call, ast, "Sending queued ANSWER to Asterisk.\n");
ast_queue_control(ast, AST_CONTROL_ANSWER);
break;
CDEBUG(call, ast, "Sending queued HANGUP to Asterisk.\n");
ast_queue_hangup(ast);
break;
- case '1': case '2': case '3': case 'a':
- case '4': case '5': case '6': case 'b':
- case '7': case '8': case '9': case 'c':
- case '*': case '0': case '#': case 'd':
+ case '1': case '2': case '3': case 'A':
+ case '4': case '5': case '6': case 'B':
+ case '7': case '8': case '9': case 'C':
+ case '*': case '0': case '#': case 'D':
CDEBUG(call, ast, "Sending queued digit '%c' to Asterisk.\n", *p);
/* send digit to asterisk */
memset(&fr, 0, sizeof(fr));
+
+ #ifdef LCR_FOR_ASTERISK
fr.frametype = AST_FRAME_DTMF_BEGIN;
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ fr.frametype = AST_FRAME_DTMF;
+ #endif
+
fr.subclass = *p;
fr.delivery = ast_tv(0, 0);
ast_queue_frame(ast, &fr);
+
+ #ifdef LCR_FOR_ASTERISK
fr.frametype = AST_FRAME_DTMF_END;
ast_queue_frame(ast, &fr);
+ #endif
+
break;
default:
- CDEBUG(call, ast, "Ignoring queued digit 0x%02d.\n", *p);
+ CDEBUG(call, ast, "Ignoring queued digit 0x%02x.\n", *p);
}
p++;
}
/* delay if no work done */
if (!work) {
ast_mutex_unlock(&chan_lock);
+
+ #ifdef LCR_FOR_ASTERISK
usleep(30000);
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ usleep(20000);
+ #endif
+
ast_mutex_lock(&chan_lock);
}
}
CDEBUG(NULL, NULL, "Received request from Asterisk. (data=%s)\n", (char *)data);
/* if socket is closed */
- if (lcr_sock < 0)
- {
+ if (lcr_sock < 0) {
CERROR(NULL, NULL, "Rejecting call from Asterisk, because LCR not running.\n");
ast_mutex_unlock(&chan_lock);
return NULL;
/* create call instance */
call = alloc_call();
- if (!call)
- {
+ if (!call) {
/* failed to create instance */
ast_mutex_unlock(&chan_lock);
return NULL;
}
/* create asterisk channel instrance */
+
+ #ifdef LCR_FOR_ASTERISK
ast = ast_channel_alloc(1, AST_STATE_RESERVED, NULL, NULL, "", NULL, "", 0, "%s/%d", lcr_type, ++glob_channel);
- if (!ast)
- {
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ ast = ast_channel_alloc(1);
+ #endif
+
+ if (!ast) {
CERROR(NULL, NULL, "Failed to create Asterisk channel.\n");
free_call(call);
/* failed to create instance */
ast_mutex_lock(&chan_lock);
call = ast->tech_pvt;
+
+ #ifdef LCR_FOR_CALLWEAVER
+ ast->type = "LCR";
+ snprintf(ast->name, sizeof(ast->name), "LCR/%s-%04x",call->dialstring, ast_random() & 0xffff);
+ #endif
+
if (!call) {
CERROR(NULL, ast, "Received call from Asterisk, but call instance does not exist.\n");
ast_mutex_unlock(&chan_lock);
}
}
-
+#ifdef LCR_FOR_ASTERISK
static int lcr_digit_begin(struct ast_channel *ast, char digit)
+#endif
+#ifdef LCR_FOR_CALLWEAVER
+static int lcr_digit(struct ast_channel *ast, char digit)
+#endif
{
struct chan_call *call;
union parameter newparam;
char buf[]="x";
+#ifdef LCR_FOR_CALLWEAVER
+ int inband_dtmf = 0;
+#endif
+
/* only pass IA5 number space */
if (digit > 126 || digit < 32)
return 0;
CDEBUG(call, ast, "Received digit '%c' from Asterisk.\n", digit);
/* send information or queue them */
- if (call->ref && call->state == CHAN_LCR_STATE_OUT_DIALING)
- {
+ if (call->ref && call->state == CHAN_LCR_STATE_OUT_DIALING) {
CDEBUG(call, ast, "Sending digit to LCR, because we are in dialing state.\n");
memset(&newparam, 0, sizeof(union parameter));
newparam.information.id[0] = digit;
send_message(MESSAGE_INFORMATION, call->ref, &newparam);
} else
if (!call->ref
- && (call->state == CHAN_LCR_STATE_OUT_PREPARE || call->state == CHAN_LCR_STATE_OUT_SETUP))
- {
+ && (call->state == CHAN_LCR_STATE_OUT_PREPARE || call->state == CHAN_LCR_STATE_OUT_SETUP)) {
CDEBUG(call, ast, "Queue digits, because we are in setup/dialing state and have no ref yet.\n");
*buf = digit;
strncat(call->dialque, buf, strlen(call->dialque)-1);
}
ast_mutex_unlock(&chan_lock);
+
+#ifdef LCR_FOR_ASTERISK
return(0);
}
{
int inband_dtmf = 0;
struct chan_call *call;
+#endif
ast_mutex_lock(&chan_lock);
/* enable keypad */
// memset(&newparam, 0, sizeof(union parameter));
// send_message(MESSAGE_ENABLEKEYPAD, call->ref, &newparam);
- /* enable dtmf */
- if (call->no_dtmf)
- CDEBUG(call, ast, "DTMF is disabled by option.\n");
- else
- call->dtmf = 1;
ast_mutex_unlock(&chan_lock);
return 0;
/* disconnect asterisk, maybe not required */
ast->tech_pvt = NULL;
ast->fds[0] = -1;
- if (call->ref)
- {
+ if (call->ref) {
/* release */
CDEBUG(call, ast, "Releasing ref and freeing call instance.\n");
if (ast->hangupcause > 0)
if (!pthread_equal(tid, chan_tid))
ast_mutex_unlock(&chan_lock);
return 0;
- } else
- {
+ } else {
/* ref is not set, due to prepare setup or release */
- if (call->state == CHAN_LCR_STATE_RELEASE)
- {
+ if (call->state == CHAN_LCR_STATE_RELEASE) {
/* we get the response to our release */
CDEBUG(call, ast, "Freeing call instance, because we have no ref AND we are requesting no ref.\n");
free_call(call);
- } else
- {
+ } else {
/* during prepare, we change to release state */
CDEBUG(call, ast, "We must wait until we received our ref, until we can free call instance.\n");
call->state = CHAN_LCR_STATE_RELEASE;
return -1;
}
if (call->bchannel && f->samples)
- bchannel_transmit(call->bchannel, (unsigned char *)f->data, f->samples);
+ bchannel_transmit(call->bchannel, *((unsigned char **)&(f->data)), f->samples);
ast_mutex_unlock(&chan_lock);
return 0;
}
}
if (len < 0 && errno == EAGAIN) {
ast_mutex_unlock(&chan_lock);
+
+ #ifdef LCR_FOR_ASTERISK
return &ast_null_frame;
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ return &nullframe;
+ #endif
+
}
if (len <= 0) {
close(call->pipe[0]);
call->state = CHAN_LCR_STATE_IN_ALERTING;
}
break;
+ case AST_CONTROL_PROGRESS:
+ CDEBUG(call, ast, "Received indicate AST_CONTROL_PROGRESS from Asterisk.\n");
+ /* request bchannel */
+ if (!call->bchannel) {
+ CDEBUG(call, ast, "Requesting B-channel.\n");
+ memset(&newparam, 0, sizeof(union parameter));
+ newparam.bchannel.type = BCHANNEL_REQUEST;
+ send_message(MESSAGE_BCHANNEL, call->ref, &newparam);
+ }
+ break;
case -1:
CDEBUG(call, ast, "Received indicate -1.\n");
res = -1;
send_message(MESSAGE_NOTIFY, call->ref, &newparam);
/*start music onhold*/
+ #ifdef LCR_FOR_ASTERISK
ast_moh_start(ast,data,ast->musicclass);
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ ast_moh_start(ast, NULL);
+ #endif
+
call->on_hold = 1;
break;
case AST_CONTROL_UNHOLD:
ast_mutex_lock(&chan_lock);
call1 = ast1->tech_pvt;
call2 = ast2->tech_pvt;
- if (call1 && call1->bridge_id)
- {
+ if (call1 && call1->bridge_id) {
call1->bridge_id = 0;
if (call1->bchannel)
bchannel_join(call1->bchannel, 0);
if (call1->bridge_call)
call1->bridge_call->bridge_call = NULL;
}
- if (call2 && call1->bridge_id)
- {
+ if (call2 && call1->bridge_id) {
call2->bridge_id = 0;
if (call2->bchannel)
bchannel_join(call2->bchannel, 0);
.description = "Channel driver for connecting to Linux-Call-Router",
.capabilities = AST_FORMAT_ALAW,
.requester = lcr_request,
+
+ #ifdef LCR_FOR_ASTERISK
.send_digit_begin = lcr_digit_begin,
.send_digit_end = lcr_digit_end,
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ .send_digit = lcr_digit,
+ #endif
+
.call = lcr_call,
.bridge = lcr_bridge,
.hangup = lcr_hangup,
#endif
-
+#ifdef LCR_FOR_ASTERISK
static int lcr_config_exec(struct ast_channel *ast, void *data)
+#endif
+
+#ifdef LCR_FOR_CALLWEAVER
+static int lcr_config_exec(struct ast_channel *ast, void *data, char **argv)
+#endif
{
struct chan_call *call;
ast_mutex_lock(&chan_lock);
+
+ #ifdef LCR_FOR_ASTERISK
CDEBUG(NULL, ast, "Received lcr_config (data=%s)\n", (char *)data);
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ CDEBUG(NULL, ast, "Received lcr_config (data=%s)\n", argv[0]);
+ #endif
+
/* find channel */
call = call_first;
while(call) {
call = call->next;
}
if (call)
+
+ #ifdef LCR_FOR_ASTERISK
apply_opt(call, (char *)data);
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ apply_opt(call, (char *)argv[0]);
+ #endif
+
else
CERROR(NULL, ast, "lcr_config app not called by chan_lcr channel.\n");
if (read_options() == 0) {
CERROR(NULL, NULL, "%s", options_error);
+
+ #ifdef LCR_FOR_ASTERISK
return AST_MODULE_LOAD_DECLINE;
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ return 0;
+ #endif
+
}
ast_mutex_init(&chan_lock);
if (bchannel_initialize()) {
CERROR(NULL, NULL, "Unable to open mISDN device\n");
close_socket();
+
+ #ifdef LCR_FOR_ASTERISK
return AST_MODULE_LOAD_DECLINE;
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ return 0;
+ #endif
}
mISDN_created = 1;
CERROR(NULL, NULL, "Unable to register channel class\n");
bchannel_deinitialize();
close_socket();
+
+ #ifdef LCR_FOR_ASTERISK
return AST_MODULE_LOAD_DECLINE;
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ return 0;
+ #endif
}
ast_register_application("lcr_config", lcr_config_exec, "lcr_config",
+
+ #ifdef LCR_FOR_ASTERISK
"lcr_config(<opt><optarg>:<opt>:...)\n"
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ "lcr_config(<opt><optarg>:<opt>:...)\n",
+ #endif
+
"Sets LCR opts. and optargs\n"
"\n"
"The available options are:\n"
#endif
quit = 0;
- if ((pthread_create(&chan_tid, NULL, chan_thread, NULL)<0))
- {
+ if ((pthread_create(&chan_tid, NULL, chan_thread, NULL)<0)) {
/* failed to create thread */
bchannel_deinitialize();
close_socket();
ast_channel_unregister(&lcr_tech);
+
+ #ifdef LCR_FOR_ASTERISK
return AST_MODULE_LOAD_DECLINE;
+ #endif
+
+ #ifdef LCR_FOR_CALLWEAVER
+ return 0;
+ #endif
+
}
return 0;
}
return 0;
}
-
+#ifdef LCR_FOR_ASTERISK
#define AST_MODULE "chan_lcr"
+#endif
+#ifdef LCR_FOR_CALLWEAVER
+int usecount(void)
+{
+ int res;
+ ast_mutex_lock(&usecnt_lock);
+ res = usecnt;
+ ast_mutex_unlock(&usecnt_lock);
+ return res;
+}
+#endif
+
+#ifdef LCR_FOR_ASTERISK
AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_DEFAULT, "Channel driver for Linux-Call-Router Support (ISDN BRI/PRI)",
.load = load_module,
.unload = unload_module,
.reload = reload_module,
);
+#endif
+#ifdef LCR_FOR_CALLWEAVER
+char *description(void)
+{
+ return desc;
+}
+#endif