aboutsummaryrefslogtreecommitdiffstats
path: root/channels
diff options
context:
space:
mode:
authorjeremy <jeremy@f38db490-d61c-443f-a65b-d21fe96a405b>2003-12-24 22:38:24 +0000
committerjeremy <jeremy@f38db490-d61c-443f-a65b-d21fe96a405b>2003-12-24 22:38:24 +0000
commit73f7a57e9937a37f4357e6546ebbc870d25acf7b (patch)
tree12fff20e8cc06ef58f7d774b236ab51cc51dc9ef /channels
parent5c45c7bedd94300a8403ebcb091d4db972aaa20c (diff)
totally revert that highly broken patch. Please test your code before submitting diffs.
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@1881 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'channels')
-rwxr-xr-xchannels/chan_h323.c410
-rwxr-xr-xchannels/h323/ast_h323.cpp489
-rwxr-xr-xchannels/h323/ast_h323.h67
-rwxr-xr-xchannels/h323/chan_h323.h80
-rwxr-xr-xchannels/h323/h323.conf.sample7
5 files changed, 206 insertions, 847 deletions
diff --git a/channels/chan_h323.c b/channels/chan_h323.c
index eeeb001ea..15e4b5b22 100755
--- a/channels/chan_h323.c
+++ b/channels/chan_h323.c
@@ -46,7 +46,6 @@
#include <asterisk/callerid.h>
#include <asterisk/cli.h>
#include <asterisk/dsp.h>
-#include <asterisk/translate.h>
#include <sys/socket.h>
#include <net/if.h>
#include <errno.h>
@@ -60,19 +59,6 @@
#include "h323/chan_h323.h"
-#define TRUE 1
-#define FALSE 0
-
-/* from rtp.c to translate RTP's payload type to Asterisk's frame subcode */
-struct rtpPayloadType {
- int isAstFormat; // whether the following code is an AST_FORMAT
- int code;
-};
-
-call_options_t global_options;
-
-static struct sockaddr_in bindaddr;
-
/** String variables required by ASTERISK */
static char *type = "H323";
static char *desc = "The NuFone Network's Open H.323 Channel Driver";
@@ -120,8 +106,6 @@ struct oh323_pvt {
int bridge; /* Determine of we should native bridge or not*/
char exten[AST_MAX_EXTENSION]; /* Requested extension */
char context[AST_MAX_EXTENSION]; /* Context where to start */
- char dnid[AST_MAX_EXTENSION]; /* Called number */
- char rdnis[AST_MAX_EXTENSION]; /* Redirecting number */
char username[81]; /* H.323 alias using this channel */
char accountcode[256]; /* Account code */
int amaflags; /* AMA Flags */
@@ -261,37 +245,17 @@ static struct oh323_user *build_user(char *name, struct ast_variable *v)
} else if (!strcasecmp(v->name, "nat")) {
user->nat = ast_true(v->value);
} else if (!strcasecmp(v->name, "noFastStart")) {
- user->call_options.noFastStart = ast_true(v->value);
+ user->noFastStart = ast_true(v->value);
} else if (!strcasecmp(v->name, "noH245Tunneling")) {
- user->call_options.noH245Tunnelling = ast_true(v->value);
+ user->noH245Tunneling = ast_true(v->value);
} else if (!strcasecmp(v->name, "noSilenceSuppression")) {
- user->call_options.noSilenceSuppression = ast_true(v->value);
+ user->noSilenceSuppression = ast_true(v->value);
} else if (!strcasecmp(v->name, "secret")) {
strncpy(user->secret, v->value, sizeof(user->secret)-1);
} else if (!strcasecmp(v->name, "callerid")) {
strncpy(user->callerid, v->value, sizeof(user->callerid)-1);
} else if (!strcasecmp(v->name, "accountcode")) {
strncpy(user->accountcode, v->value, sizeof(user->accountcode)-1);
- } else if (!strcasecmp(v->name, "progress_setup")) {
- int progress_setup = atoi(v->value);
- if((progress_setup != 0) &&
- (progress_setup != 1) &&
- (progress_setup != 3) &&
- (progress_setup != 8)) {
- ast_log(LOG_WARNING, "Invalid value %d for progress_setup at line %d, assuming 0\n", progress_setup, v->lineno);
- progress_setup = 0;
- }
- user->call_options.progress_setup = progress_setup;
- } else if (!strcasecmp(v->name, "progress_alert")) {
- int progress_alert = atoi(v->value);
- if((progress_alert != 0) &&
- (progress_alert != 8)) {
- ast_log(LOG_WARNING, "Invalid value %d for progress_alert at line %d, assuming 0\n", progress_alert, v->lineno);
- progress_alert = 0;
- }
- user->call_options.progress_alert = progress_alert;
- } else if (!strcasecmp(v->name, "progress_audio")) {
- user->call_options.progress_audio = ast_true(v->value);
} else if (!strcasecmp(v->name, "incominglimit")) {
user->incominglimit = atoi(v->value);
if (user->incominglimit < 0)
@@ -368,31 +332,11 @@ static struct oh323_peer *build_peer(char *name, struct ast_variable *v)
} else if (!strcasecmp(v->name, "bridge")) {
peer->bridge = ast_true(v->value);
} else if (!strcasecmp(v->name, "noFastStart")) {
- peer->call_options.noFastStart = ast_true(v->value);
+ peer->noFastStart = ast_true(v->value);
} else if (!strcasecmp(v->name, "noH245Tunneling")) {
- peer->call_options.noH245Tunnelling = ast_true(v->value);
+ peer->noH245Tunneling = ast_true(v->value);
} else if (!strcasecmp(v->name, "noSilenceSuppression")) {
- peer->call_options.noSilenceSuppression = ast_true(v->value);
- } else if (!strcasecmp(v->name, "progress_setup")) {
- int progress_setup = atoi(v->value);
- if((progress_setup != 0) &&
- (progress_setup != 1) &&
- (progress_setup != 3) &&
- (progress_setup != 8)) {
- ast_log(LOG_WARNING, "Invalid value %d for progress_setup at line %d, assuming 0\n", progress_setup, v->lineno);
- progress_setup = 0;
- }
- peer->call_options.progress_setup = progress_setup;
- } else if (!strcasecmp(v->name, "progress_alert")) {
- int progress_alert = atoi(v->value);
- if((progress_alert != 0) &&
- (progress_alert != 8)) {
- ast_log(LOG_WARNING, "Invalid value %d for progress_alert at line %d, assuming 0\n", progress_alert, v->lineno);
- progress_alert = 0;
- }
- peer->call_options.progress_alert = progress_alert;
- } else if (!strcasecmp(v->name, "progress_audio")) {
- peer->call_options.progress_audio = ast_true(v->value);
+ peer->noSilenceSuppression = ast_true(v->value);
} else if (!strcasecmp(v->name, "outgoinglimit")) {
peer->outgoinglimit = atoi(v->value);
if (peer->outgoinglimit > 0)
@@ -483,16 +427,16 @@ static int oh323_call(struct ast_channel *c, char *dest, int timeout)
} else {
p->calloptions.callerid = strdup(c->callerid);
}
- }
+ }
- res = h323_make_call(called_addr, &(p->cd), &p->calloptions);
+ res = h323_make_call(called_addr, &(p->cd), p->calloptions);
if (res) {
ast_log(LOG_NOTICE, "h323_make_call failed(%s)\n", c->name);
return -1;
}
- ast_setstate(c, AST_STATE_RING);
+ ast_setstate(c, AST_STATE_RINGING);
return 0;
}
@@ -560,31 +504,20 @@ static int oh323_hangup(struct ast_channel *c)
return 0;
}
-/* Pass channel struct too to allow RTCP handling */
-static struct ast_frame *oh323_rtp_read(struct ast_channel *c, struct oh323_pvt *p)
+static struct ast_frame *oh323_rtp_read(struct oh323_pvt *p)
{
/* Retrieve audio/etc from channel. Assumes p->lock is already held. */
struct ast_frame *f;
static struct ast_frame null_frame = { AST_FRAME_NULL, };
- /* Only apply it for the first packet, we just need the correct ip/port */
- if(p->nat)
- {
- ast_rtp_setnat(p->rtp,p->nat);
- p->nat = 0;
- }
-
- switch(c->fdno) {
- case 0: /* RTP stream */
- f = ast_rtp_read(p->rtp);
- break;
- case 1: /* RTCP stream */
- f = ast_rtcp_read(p->rtp);
- break;
- default:
- f = &null_frame;
- }
+ /* Only apply it for the first packet, we just need the correct ip/port */
+ if(p->nat)
+ {
+ ast_rtp_setnat(p->rtp,p->nat);
+ p->nat = 0;
+ }
+ f = ast_rtp_read(p->rtp);
/* Don't send RFC2833 if we're not supposed to */
if (f && (f->frametype == AST_FRAME_DTMF) && !(p->dtmfmode & H323_DTMF_RFC2833))
return &null_frame;
@@ -592,12 +525,10 @@ static struct ast_frame *oh323_rtp_read(struct ast_channel *c, struct oh323_pvt
/* We already hold the channel lock */
if (f->frametype == AST_FRAME_VOICE) {
if (f->subclass != p->owner->nativeformats) {
- /* Must be handled on opening logical channel */
ast_log(LOG_DEBUG, "Oooh, format changed to %d\n", f->subclass);
p->owner->nativeformats = f->subclass;
ast_set_read_format(p->owner, p->owner->readformat);
- /* Don't set write format because it will be set up when channel started */
-// ast_set_write_format(p->owner, p->owner->writeformat);
+ ast_set_write_format(p->owner, p->owner->writeformat);
}
/* Do in-band DTMF detection */
@@ -619,8 +550,7 @@ static struct ast_frame *oh323_read(struct ast_channel *c)
struct ast_frame *fr;
struct oh323_pvt *p = c->pvt->pvt;
ast_mutex_lock(&p->lock);
- /* Pass channel structure to handle other streams than just RTP */
- fr = oh323_rtp_read(c, p);
+ fr = oh323_rtp_read(p);
ast_mutex_unlock(&p->lock);
return fr;
}
@@ -629,7 +559,6 @@ static int oh323_write(struct ast_channel *c, struct ast_frame *frame)
{
struct oh323_pvt *p = c->pvt->pvt;
int res = 0;
- int need_frfree = 0; /* Does ast_frfree() call required? */
if (frame->frametype != AST_FRAME_VOICE) {
if (frame->frametype == AST_FRAME_IMAGE)
return 0;
@@ -639,47 +568,9 @@ static int oh323_write(struct ast_channel *c, struct ast_frame *frame)
}
} else {
if (!(frame->subclass & c->nativeformats)) {
- if(!(frame->subclass & c->writeformat)) { /* Someone sent frame with old format */
- ast_log(LOG_WARNING, "Asked to transmit frame type %s from %s by '%s', while native formats is %s (read/write = %s/%s)\n",
- ast_getformatname(frame->subclass), frame->src, c->name, ast_getformatname(c->nativeformats), ast_getformatname(c->readformat), ast_getformatname(c->writeformat));
- return (c->nativeformats ? 0 : -1);
- } else {
- /* Frame goes from RTP is not in our native
- * format - try to translate it... Or we must
- * just drop it?
- */
-
- /* Sometimes translation table isn't set
- * correctly but writeformat is invalid,
- * so force required translation allocation
- */
- ast_set_write_format(c, c->nativeformats);
- ast_set_write_format(c, frame->subclass);
-
- /* Translate it on-the-fly */
- if (c->pvt->writetrans) {
- struct ast_frame *frame1;
- ast_log(LOG_WARNING, "Asked to transmit frame type %s from %s by '%s', while native formats is %s (read/write = %s/%s) - 2 TRANSLATE\n",
- ast_getformatname(frame->subclass), frame->src, c->name, ast_getformatname(c->nativeformats), ast_getformatname(c->readformat), ast_getformatname(c->writeformat));
- /* Allocate new frame with translated context.
- * Don't free frame because it will be freed on
- * upper layer (RTP).
- */
- frame1 = ast_translate(c->pvt->writetrans, frame, 0);
- if(frame1) {
- /* Substitute passed frame with translated and
- mark it for freeing before return */
- frame = frame1;
- need_frfree = 1;
- }
- else
- ast_log(LOG_WARNING, "Unable to translate frame type %s to %s\n", ast_getformatname(frame->subclass), ast_getformatname(c->nativeformats));
- } else {
- ast_log(LOG_WARNING, "Asked to transmit frame type %s from %s by '%s', while native formats is %s (read/write = %s/%s)\n",
- ast_getformatname(frame->subclass), frame->src, c->name, ast_getformatname(c->nativeformats), ast_getformatname(c->readformat), ast_getformatname(c->writeformat));
- return -1;
- }
- }
+ ast_log(LOG_WARNING, "Asked to transmit frame type %d, while native formats is %d (read/write = %d/%d)\n",
+ frame->subclass, c->nativeformats, c->readformat, c->writeformat);
+ return -1;
}
}
if (p) {
@@ -689,9 +580,6 @@ static int oh323_write(struct ast_channel *c, struct ast_frame *frame)
}
ast_mutex_unlock(&p->lock);
}
- /* Free translated frame */
- if(need_frfree)
- ast_frfree(frame);
return res;
}
@@ -725,7 +613,7 @@ static int oh323_indicate(struct ast_channel *c, int condition)
}
return 0;
case -1:
- return 0;
+ return -1;
default:
ast_log(LOG_WARNING, "Don't know how to indicate condition %d\n", condition);
return -1;
@@ -756,20 +644,13 @@ static struct ast_channel *oh323_new(struct oh323_pvt *i, int state, const char
if (ch) {
-// snprintf(ch->name, sizeof(ch->name)-1, "H323/%s-%04x", host, rand() & 0xffff);
snprintf(ch->name, sizeof(ch->name)-1, "H323/%s", host);
ch->nativeformats = i->capability;
if (!ch->nativeformats)
ch->nativeformats = capability;
fmt = ast_best_codec(ch->nativeformats);
ch->type = type;
-
- /* RTP stream */
ch->fds[0] = ast_rtp_fd(i->rtp);
-
- /* RTCP stream */
- ch->fds[1] = ast_rtcp_fd(i->rtp);
-
ast_setstate(ch, state);
if (state == AST_STATE_RING)
@@ -810,10 +691,6 @@ static struct ast_channel *oh323_new(struct oh323_pvt *i, int state, const char
ch->priority = 1;
if (strlen(i->callerid))
ch->callerid = strdup(i->callerid);
- if (strlen(i->dnid))
- ch->dnid = strdup(i->dnid);
- if (strlen(i->rdnis))
- ch->rdnis = strdup(i->rdnis);
if (strlen(i->accountcode))
strncpy(ch->accountcode, i->accountcode, sizeof(ch->accountcode)-1);
if (i->amaflags)
@@ -854,7 +731,6 @@ static struct oh323_pvt *oh323_alloc(int callid)
p->cd.call_reference = callid;
p->bridge = bridge_default;
- memcpy(&p->calloptions, &global_options, sizeof(global_options));
p->dtmfmode = dtmfmode;
if (p->dtmfmode & H323_DTMF_RFC2833)
@@ -872,24 +748,25 @@ static struct oh323_pvt *find_call(int call_reference)
{
struct oh323_pvt *p;
- ast_mutex_lock(&iflock);
+ ast_mutex_lock(&iflock);
p = iflist;
while(p) {
if (p->cd.call_reference == call_reference) {
/* Found the call */
- ast_mutex_unlock(&iflock);
- return p;
+ ast_mutex_unlock(&iflock);
+ return p;
}
p = p->next;
}
ast_mutex_unlock(&iflock);
-
- return NULL;
+ return NULL;
+
}
static struct ast_channel *oh323_request(char *type, int format, void *data)
{
+
int oldformat;
struct oh323_pvt *p;
struct ast_channel *tmpc = NULL;
@@ -958,45 +835,20 @@ static struct ast_channel *oh323_request(char *type, int format, void *data)
return tmpc;
}
-struct oh323_alias *find_alias(call_details_t cd)
+struct oh323_alias *find_alias(const char *source_aliases)
{
- struct oh323_alias *a, *a_e164 = NULL, *a_pfx = NULL;
- char *s, *p;
- int a_pfxlen, numlen;
+ struct oh323_alias *a;
a = aliasl.aliases;
- a_pfxlen = 0;
- numlen = strlen(cd.call_dest_e164);
while(a) {
- if (!strcasecmp(a->name, cd.call_dest_alias)) {
+ if (!strcasecmp(a->name, source_aliases)) {
break;
}
- /* Check for match of E164 number */
- if (!strcasecmp(a->e164, cd.call_dest_e164))
- a_e164 = a;
- else { /* Check for match called number with prefixes */
- for(s = a->prefix; *s; ) {
- for(; *s == ' '; ++s);
- if(!(p = strchr(s, ',')))
- p = s + strlen(s);
- if((p - s > a_pfxlen) && (numlen >= p - s) && (strncasecmp(s, cd.call_dest_e164, p - s) == 0)) {
- a_pfxlen = p - s;
- a_pfx = a;
- }
- s = p;
- if(*s == ',')
- ++s;
- }
- }
a = a->next;
}
- if(a)
- return a;
- if(a_e164)
- return a_e164;
- return a_pfx;
+ return a;
}
struct oh323_user *find_user(const call_details_t cd)
@@ -1042,27 +894,6 @@ struct oh323_peer *find_peer(char *dest_peer)
}
-static int progress(unsigned call_reference, int inband)
-{
- struct oh323_pvt *p;
-
- ast_log(LOG_DEBUG, "Received ALERT/PROGRESS message for %s tones\n", (inband ? "inband" : "self-generated"));
- p = find_call(call_reference);
-
- if (!p) {
- ast_log(LOG_ERROR, "Private structure not found in send_digit.\n");
- return -1;
- }
- if (!p->owner) {
- ast_log(LOG_ERROR, "No asterisk's channel associated with private structure.\n");
- return -1;
- }
-
- ast_queue_control(p->owner, (inband ? AST_CONTROL_PROGRESS : AST_CONTROL_RINGING), 0);
-
- return 0;
-}
-
/**
* Callback for sending digits from H.323 up to asterisk
*
@@ -1081,13 +912,13 @@ int send_digit(unsigned call_reference, char digit)
}
memset(&f, 0, sizeof(f));
f.frametype = AST_FRAME_DTMF;
- f.subclass = digit;
- f.datalen = 0;
- f.samples = 300;
+ f.subclass = digit;
+ f.datalen = 0;
+ f.samples = 300;
f.offset = 0;
f.data = NULL;
- f.mallocd = 0;
- f.src = "SEND_DIGIT";
+ f.mallocd = 0;
+ f.src = "SEND_DIGIT";
return ast_queue_frame(p->owner, &f, 1);
}
@@ -1131,21 +962,20 @@ struct rtp_info *create_connection(unsigned call_reference)
* Returns 1 on success
*/
-call_options_t *setup_incoming_call(call_details_t cd)
+int setup_incoming_call(call_details_t cd)
{
struct oh323_pvt *p = NULL;
struct ast_channel *c = NULL;
struct oh323_user *user = NULL;
struct oh323_alias *alias = NULL;
- call_options_t *call_options = NULL;
/* allocate the call*/
p = oh323_alloc(cd.call_reference);
if (!p) {
ast_log(LOG_ERROR, "Unable to allocate private structure, this is bad.\n");
- return NULL;
+ return 0;
}
/* Populate the call details in the private structure */
@@ -1156,28 +986,21 @@ call_options_t *setup_incoming_call(call_details_t cd)
p->cd.call_dest_e164 = cd.call_dest_e164;
if (h323debug) {
- ast_verbose(VERBOSE_PREFIX_2 "Setting up Call\n");
- ast_verbose(VERBOSE_PREFIX_3 "Calling party name: [%s]\n", p->cd.call_source_aliases);
- ast_verbose(VERBOSE_PREFIX_3 "Calling party number: [%s]\n", p->cd.call_source_e164);
- ast_verbose(VERBOSE_PREFIX_3 "Called party name: [%s]\n", p->cd.call_dest_alias);
- ast_verbose(VERBOSE_PREFIX_3 "Called party number: [%s]\n", p->cd.call_dest_e164);
- ast_verbose(VERBOSE_PREFIX_3 "Redirecting party number: [%s]\n", p->cd.call_redir_e164);
+ ast_verbose(VERBOSE_PREFIX_3 "Setting up Call\n");
+ ast_verbose(VERBOSE_PREFIX_3 " Calling party name: [%s]\n", p->cd.call_source_aliases);
+ ast_verbose(VERBOSE_PREFIX_3 " Calling party number: [%s]\n", p->cd.call_source_e164);
+ ast_verbose(VERBOSE_PREFIX_3 " Called party name: [%s]\n", p->cd.call_dest_alias);
+ ast_verbose(VERBOSE_PREFIX_3 " Called party number: [%s]\n", p->cd.call_dest_e164);
}
/* Decide if we are allowing Gatekeeper routed calls*/
if ((!strcasecmp(cd.sourceIp, gatekeeper)) && (gkroute == -1) && (usingGk == 1)) {
if (strlen(cd.call_dest_e164)) {
- char *ctx;
-
- alias = find_alias(cd);
- ctx = alias ? alias->context : default_context;
-
- strncpy(p->dnid, cd.call_dest_e164, sizeof(p->dnid)-1);
- strncpy(p->exten, cd.call_dest_e164, sizeof(p->exten)-1);
- strncpy(p->context, ctx, sizeof(p->context)-1);
+ strncpy(p->exten, cd.call_dest_e164, sizeof(p->exten)-1);
+ strncpy(p->context, default_context, sizeof(p->context)-1);
} else {
- alias = find_alias(cd);
+ alias = find_alias(cd.call_dest_alias);
if (!alias) {
ast_log(LOG_ERROR, "Call for %s rejected, alias not found\n", cd.call_dest_alias);
@@ -1187,8 +1010,8 @@ call_options_t *setup_incoming_call(call_details_t cd)
strncpy(p->context, alias->context, sizeof(p->context)-1);
}
- /* Asterisk prefers user name to be quoted */
- sprintf(p->callerid, "\"%s\" <%s>", p->cd.call_source_aliases, p->cd.call_source_e164);
+
+ sprintf(p->callerid, "%s <%s>", p->cd.call_source_aliases, p->cd.call_source_e164);
} else {
/* Either this call is not from the Gatekeeper
@@ -1199,13 +1022,11 @@ call_options_t *setup_incoming_call(call_details_t cd)
if (!user) {
- /* Asterisk prefers user name to be quoted */
- sprintf(p->callerid, "\"%s\" <%s>", p->cd.call_source_aliases, p->cd.call_source_e164);
+ sprintf(p->callerid, "%s <%s>", p->cd.call_source_aliases, p->cd.call_source_e164);
if (strlen(p->cd.call_dest_e164)) {
- strncpy(p->dnid, cd.call_dest_e164, sizeof(p->dnid)-1);
strncpy(p->exten, cd.call_dest_e164, sizeof(p->exten)-1);
} else {
- strncpy(p->exten, cd.call_dest_alias, sizeof(p->exten)-1);
+ strncpy(p->exten, cd.call_dest_alias, sizeof(p->exten)-1);
}
if (!strlen(default_context)) {
ast_log(LOG_ERROR, "Call from user '%s' rejected due to no default context\n", p->cd.call_source_aliases);
@@ -1213,14 +1034,13 @@ call_options_t *setup_incoming_call(call_details_t cd)
}
strncpy(p->context, default_context, sizeof(p->context)-1);
ast_log(LOG_DEBUG, "Sending %s to context [%s]\n", cd.call_source_aliases, p->context);
- } else {
- call_options = &user->call_options;
+ } else {
if (user->host) {
if (strcasecmp(cd.sourceIp, inet_ntoa(user->addr.sin_addr))){
if(!strlen(default_context)) {
ast_log(LOG_ERROR, "Call from user '%s' rejected due to non-matching IP address of '%s'\n", user->name, cd.sourceIp);
- return NULL;
+ return 0;
}
strncpy(p->context, default_context, sizeof(p->context)-1);
@@ -1232,12 +1052,12 @@ call_options_t *setup_incoming_call(call_details_t cd)
if (user->incominglimit > 0) {
if (user->inUse >= user->incominglimit) {
ast_log(LOG_ERROR, "Call from user '%s' rejected due to usage limit of %d\n", user->name, user->incominglimit);
- return NULL;
+ return 0;
}
}
strncpy(p->context, user->context, sizeof(p->context)-1);
p->bridge = user->bridge;
- p->nat = user->nat;
+ p->nat = user->nat;
if (strlen(user->callerid))
strncpy(p->callerid, user->callerid, sizeof(p->callerid) - 1);
@@ -1260,21 +1080,14 @@ call_options_t *setup_incoming_call(call_details_t cd)
/* I know this is horrid, don't kill me saddam */
exit:
-// if(strlen(p->cd.call_redir_e164))
-// strncpy(p->rdnis, cd.call_redir_e164, sizeof(p->rdnis)-1);
/* allocate a channel and tell asterisk about it */
c = oh323_new(p, AST_STATE_RINGING, cd.call_token);
if (!c) {
ast_log(LOG_ERROR, "Couldn't create channel. This is bad\n");
- return NULL;
+ return 0;
}
- ast_queue_control(c, AST_CONTROL_RINGING, 0);
-
- if(!call_options)
- return &global_options;
-
- return call_options;
+ return 1;
}
/**
@@ -1304,12 +1117,10 @@ if (!p) {
*
* Returns nothing
*/
-void setup_rtp_connection(unsigned call_reference, const char *remoteIp, int remotePort, int direction, int payloadType)
+void setup_rtp_connection(unsigned call_reference, const char *remoteIp, int remotePort)
{
struct oh323_pvt *p = NULL;
struct sockaddr_in them;
- struct rtpPayloadType payload;
- struct ast_channel *chan;
/* Find the call or allocate a private structure if call not found */
p = find_call(call_reference);
@@ -1322,56 +1133,11 @@ void setup_rtp_connection(unsigned call_reference, const char *remoteIp, int rem
them.sin_family = AF_INET;
them.sin_addr.s_addr = inet_addr(remoteIp); // only works for IPv4
them.sin_port = htons(remotePort);
-
- /* Find RTP payload <=> asterisk's subcode association */
- payload = ast_rtp_lookup_pt(p->rtp, payloadType);
-
- ast_log(LOG_DEBUG, "Setting up %sbound RTP connection for %s:%d with payload %s (RTP code %d)\n", (direction ? "out" : "in"), inet_ntoa(them.sin_addr), remotePort, ast_getformatname(payload.code), payloadType);
-
- /* Set channel's native codec and prepare translation table
- * for given direction and currently used format
- */
- if ((chan = p->owner)) {
- if (payload.isAstFormat) {
- /* Don't allow any transmission until codec is changed */
-// ast_mutex_lock(&chan->lock);
- chan->nativeformats = payload.code;
- if(direction)
- ast_set_write_format(chan, chan->writeformat);
- else
- ast_set_read_format(chan, chan->readformat);
-// ast_mutex_unlock(&chan->lock);
- }
- }
-
ast_rtp_set_peer(p->rtp, &them);
-
- if(p->calloptions.progress_audio)
- progress(call_reference, TRUE);
return;
}
-/* Not used for now - set RTP peer's address */
-void setup_rtp_peer(unsigned call_reference, const char *remoteIp, int remotePort)
-{
- struct oh323_pvt *p = NULL;
- struct sockaddr_in them;
-
- /* Find the call or allocate a private structure if call not found */
- p = find_call(call_reference);
-
- if (!p) {
- ast_log(LOG_ERROR, "Something is wrong: rtp\n");
- return;
- }
-
- them.sin_family = AF_INET;
- them.sin_addr.s_addr = inet_addr(remoteIp); // only works for IPv4
- them.sin_port = htons(remotePort);
- ast_rtp_set_peer(p->rtp, &them);
-}
-
/**
* Call-back function to signal asterisk that the channel has been answered
* Returns nothing
@@ -1470,15 +1236,13 @@ restartsearch:
}
ast_mutex_unlock(&iflock);
+ pthread_testcancel();
+
/* Wait for sched or io */
res = ast_sched_wait(sched);
if ((res < 0) || (res > 1000))
res = 1000;
res = ast_io_wait(io, res);
-
- /* Check for thread cancellation */
- pthread_testcancel();
-
ast_mutex_lock(&monlock);
if (res >= 0)
ast_sched_runq(sched);
@@ -1628,7 +1392,7 @@ int reload_config(void)
struct oh323_alias *alias = NULL;
struct hostent *hp;
char *cat;
- char *utype;
+ char *utype;
cfg = ast_load(config);
@@ -1644,8 +1408,6 @@ int reload_config(void)
}
h323debug=0;
dtmfmode = H323_DTMF_RFC2833;
- /* Fill global variables with pre-determined values */
- memset(&global_options, 0, sizeof(global_options));
memset(&bindaddr, 0, sizeof(bindaddr));
@@ -1716,33 +1478,6 @@ int reload_config(void)
ast_log(LOG_WARNING, "Unknown dtmf mode '%s', using rfc2833\n", v->value);
dtmfmode = H323_DTMF_RFC2833;
}
- /* Setup global parameters */
- } else if (!strcasecmp(v->name, "noFastStart")) {
- global_options.noFastStart = ast_true(v->value);
- } else if (!strcasecmp(v->name, "noH245Tunneling")) {
- global_options.noH245Tunnelling = ast_true(v->value);
- } else if (!strcasecmp(v->name, "noSilenceSuppression")) {
- global_options.noSilenceSuppression = ast_true(v->value);
- } else if (!strcasecmp(v->name, "progress_setup")) {
- int progress_setup = atoi(v->value);
- if((progress_setup != 0) &&
- (progress_setup != 1) &&
- (progress_setup != 3) &&
- (progress_setup != 8)) {
- ast_log(LOG_WARNING, "Invalid value %d for progress_setup at line %d, assuming 0\n", progress_setup, v->lineno);
- progress_setup = 0;
- }
- global_options.progress_setup = progress_setup;
- } else if (!strcasecmp(v->name, "progress_alert")) {
- int progress_alert = atoi(v->value);
- if((progress_alert != 0) &&
- (progress_alert != 8)) {
- ast_log(LOG_WARNING, "Invalid value %d for progress_alert at line %d, assuming 0\n", progress_alert, v->lineno);
- progress_alert = 0;
- }
- global_options.progress_alert = progress_alert;
- } else if (!strcasecmp(v->name, "progress_audio")) {
- global_options.progress_audio = ast_true(v->value);
} else if (!strcasecmp(v->name, "UserByAlias")) {
userbyalias = ast_true(v->value);
} else if (!strcasecmp(v->name, "bridge")) {
@@ -1873,20 +1608,15 @@ int reload(void)
delete_aliases();
prune_peers();
- reload_config();
-
-
-#if 0
-
-This code causes seg on -r
-
if (strlen(gatekeeper)) {
h323_gk_urq();
}
+ reload_config();
+#if 0
/* Possibly register with a GK */
- if (!gatekeeper_disable) {
+ if (gatekeeper_disable == 0) {
if (h323_set_gk(gatekeeper_discover, gatekeeper, secret)) {
ast_log(LOG_ERROR, "Gatekeeper registration failed.\n");
h323_end_process();
@@ -1894,7 +1624,6 @@ This code causes seg on -r
}
}
#endif
-
restart_monitor();
return 0;
}
@@ -2018,9 +1747,7 @@ int load_module()
create_connection,
setup_rtp_connection,
cleanup_connection,
- connection_made,
- send_digit,
- progress);
+ connection_made, send_digit);
/* start the h.323 listener */
@@ -2078,7 +1805,6 @@ int unload_module()
return -1;
}
h323_gk_urq();
- h323_debug(0,0);
h323_end_process();
/* unregister rtp */
@@ -2117,3 +1843,7 @@ char *key()
{
return ASTERISK_GPL_KEY;
}
+
+
+
+
diff --git a/channels/h323/ast_h323.cpp b/channels/h323/ast_h323.cpp
index dfdef12f9..3a822c806 100755
--- a/channels/h323/ast_h323.cpp
+++ b/channels/h323/ast_h323.cpp
@@ -41,11 +41,10 @@ int channelsOpen;
/* DTMF Mode */
int mode = H323_DTMF_RFC2833;
-/* Make those variables accessible from chan_h323.c */
-extern "C" {
/** Options for connections creation */
-call_options_t global_options;
-}
+BOOL noFastStart;
+BOOL noH245Tunnelling;
+BOOL noSilenceSuppression;
/**
* We assume that only one endPoint should exist.
@@ -60,27 +59,6 @@ MyProcess *localProcess = NULL;
/** H.323 listener */
H323ListenerTCP *tcpListener;
-/* Provide common methods to split out non-user parts of OpenH323 aliases */
-static void FormatAliases(PString & aliases)
-{
- /* Convert complex strings */
- // FIXME: deal more than one source alias
- char *s;
- const char *p = (const char *)aliases;
- if ((s = strchr(p, '(')) != NULL)
- *s = '\0';
- else if ((s = strchr(p, ',')) != NULL)
- *s = '\0';
- else if ((s = strchr(p, '[')) != NULL)
- *s = '\0';
- else if ((s = strchr(p, ' ')) != NULL)
- *s = '\0';
- else if ((s = strchr(p, '\t')) != NULL)
- *s = '\0';
- /* Strip trailing spaces */
- for(s = (char *)(p + strlen(p)); (s > p) && (*--s == ' '); *s = '\0');
-}
-
MyProcess::MyProcess(): PProcess("The NuFone Network's", "H.323 Channel Driver for Asterisk",
MAJOR_VERSION, MINOR_VERSION, BUILD_TYPE, BUILD_NUMBER)
{
@@ -98,7 +76,6 @@ void MyProcess::Main()
{
cout << " == Creating H.323 Endpoint" << endl;
endPoint = new MyH323EndPoint();
- endPoint->DisableDetectInBandDTMF(TRUE);
PTrace::Initialise(0, NULL, PTrace::Timestamp | PTrace::Thread | PTrace::FileAndLine);
}
@@ -134,7 +111,6 @@ H323_G7231Capability::H323_G7231Capability(BOOL annexA_)
: H323AudioCapability(7, 4)
{
annexA = annexA_;
- rtpPayloadType = RTP_DataFrame::G7231;
}
PObject::Comparison H323_G7231Capability::Compare(const PObject & obj) const
@@ -272,8 +248,7 @@ H323Codec * AST_G729ACapability::CreateCodec(H323Codec::Direction direction) con
* port = 1720.
*/
int MyH323EndPoint::MakeCall(const PString & dest, PString & token,
- unsigned int *callReference,
- call_options_t *call_options)
+ unsigned int *callReference, unsigned int port, char *callerid)
{
PString fullAddress;
MyH323Connection * connection;
@@ -289,7 +264,7 @@ int MyH323EndPoint::MakeCall(const PString & dest, PString & token,
cout << " -- Making call to " << fullAddress << "." << endl;
}
- if (!(connection = (MyH323Connection *)H323EndPoint::MakeCallLocked(fullAddress, token, call_options))) {
+ if (!(connection = (MyH323Connection *)H323EndPoint::MakeCallLocked(fullAddress, token))) {
if (h323debug)
cout << "Error making call to \"" << fullAddress << '"' << endl;
return 1;
@@ -297,8 +272,8 @@ int MyH323EndPoint::MakeCall(const PString & dest, PString & token,
*callReference = connection->GetCallReference();
- if (call_options->callerid)
- connection->SetCID(call_options->callerid); // Use our local function to setup H.323 caller ID correctly
+ if (callerid)
+ connection->SetLocalPartyName(PString(callerid));
connection->Unlock();
@@ -312,16 +287,7 @@ int MyH323EndPoint::MakeCall(const PString & dest, PString & token,
void MyH323EndPoint::SetEndpointTypeInfo( H225_EndpointType & info ) const
{
-// cout << " **** Terminal type: " << terminalType << endl;
H323EndPoint::SetEndpointTypeInfo(info);
-// cout << " **** INFO: " << info << endl;
- /* Because H323EndPoint::SetEndpointTypeInfo() don't set correctly
- endpoint type, force manual setting it */
- if(terminalType == e_GatewayOnly)
- {
- info.RemoveOptionalField(H225_EndpointType::e_terminal);
- info.IncludeOptionalField(H225_EndpointType::e_gateway);
- }
info.m_gateway.IncludeOptionalField(H225_GatewayInfo::e_protocol);
info.m_gateway.m_protocol.SetSize(1);
H225_SupportedProtocols &protocol=info.m_gateway.m_protocol[0];
@@ -370,17 +336,17 @@ void MyH323EndPoint::OnClosedLogicalChannel(H323Connection & connection, const H
}
BOOL MyH323EndPoint::OnConnectionForwarded(H323Connection & connection,
- const PString & forwardParty,
- const H323SignalPDU & pdu)
-{
+ const PString & forwardParty,
+ const H323SignalPDU & pdu)
+ {
if (h323debug)
cout << " -- Call Forwarded to " << forwardParty << endl;
return FALSE;
-}
-
+ }
+
BOOL MyH323EndPoint::ForwardConnection(H323Connection & connection,
- const PString & forwardParty,
- const H323SignalPDU & pdu)
+ const PString & forwardParty,
+ const H323SignalPDU & pdu)
{
if (h323debug)
cout << " -- Forwarding call to " << forwardParty << endl;
@@ -403,12 +369,14 @@ void MyH323EndPoint::OnConnectionCleared(H323Connection & connection, const PStr
call_details_t cd;
- /* Use common alias formatting routine */
- FormatAliases(remoteName);
-
cd.call_reference = connection.GetCallReference();
cd.call_token = (const char *)connection.GetCallToken();
- cd.call_source_aliases = (const char *)remoteName;
+ cd.call_source_aliases = (const char *)connection.GetRemotePartyName();
+
+ /* Convert complex strings */
+ char *s;
+ if ((s = strchr(cd.call_source_aliases, ' ')) != NULL)
+ *s = '\0';
/* Invoke the PBX application registered callback */
on_connection_cleared(cd);
@@ -484,7 +452,7 @@ void MyH323EndPoint::OnConnectionCleared(H323Connection & connection, const PStr
break;
default :
if (h323debug)
- cout << " -- Call with " << remoteName << " completed (" << connection.GetCallEndReason() << ")" << endl;
+ cout << " -- Call with " << remoteName << " completed" << endl;
}
if(connection.IsEstablished())
if (h323debug)
@@ -495,146 +463,26 @@ void MyH323EndPoint::OnConnectionCleared(H323Connection & connection, const PStr
H323Connection * MyH323EndPoint::CreateConnection(unsigned callReference, void *outbound)
{
unsigned options = 0;
- call_options_t *call_options = (call_options_t *)outbound;
-
- if (!call_options)
- call_options = &global_options;
- if (call_options->noFastStart)
+ if (noFastStart)
options |= H323Connection::FastStartOptionDisable;
- if (call_options->noH245Tunnelling)
+ if (noH245Tunnelling)
options |= H323Connection::H245TunnelingOptionDisable;
- /* Set silence detection mode - won't work for Asterisk's RTP but can be used in the negotiation process */
- SetSilenceDetectionMode(call_options->noSilenceSuppression ? H323AudioCodec::NoSilenceDetection : H323AudioCodec::AdaptiveSilenceDetection);
-
- return new MyH323Connection(*this, callReference, options, call_options);
-}
-
-/* MyH323_ExternalRTPChannel */
-MyH323_ExternalRTPChannel::MyH323_ExternalRTPChannel(
- H323Connection & connection, /// Connection to endpoint for channel
- const H323Capability & capability, /// Capability channel is using
- Directions direction, /// Direction of channel
- unsigned sessionID /// Session ID for channel
- ): H323_ExternalRTPChannel(connection,capability,direction,sessionID)
-{
-}
-
-MyH323_ExternalRTPChannel::MyH323_ExternalRTPChannel(
- H323Connection & connection, /// Connection to endpoint for channel
- const H323Capability & capability, /// Capability channel is using
- Directions direction, /// Direction of channel
- unsigned sessionID, /// Session ID for channel
- const H323TransportAddress & data, /// Data address
- const H323TransportAddress & control/// Control address
- ): H323_ExternalRTPChannel(connection, capability, direction, sessionID, data, control)
-{
-}
-
-MyH323_ExternalRTPChannel::MyH323_ExternalRTPChannel(
- H323Connection & connection, /// Connection to endpoint for channel
- const H323Capability & capability, /// Capability channel is using
- Directions direction, /// Direction of channel
- unsigned sessionID, /// Session ID for channel
- const PIPSocket::Address & ip, /// IP address of media server
- WORD dataPort /// Data port (control is dataPort+1)
- ): H323_ExternalRTPChannel(connection, capability, direction, sessionID, ip, dataPort)
-{
-}
-
-BOOL MyH323_ExternalRTPChannel::Start()
-{
- BOOL res;
- PIPSocket::Address remoteIpAddress; // IP Address of remote endpoint
- WORD remotePort; // remote endpoint Data port (control is dataPort+1)
- PIPSocket::Address externalIpAddress; // IP address of media server
- WORD externalPort; // local media server Data port (control is dataPort+1)
-
- res = H323_ExternalRTPChannel::Start();
- if (!res)
- return res;
-
- if (h323debug) {
- /* Show H.323 channel number to make debugging more comfortable */
- cout << " -- Started RTP media for channel " << GetNumber() << ": ";
- cout << ((GetDirection()==H323Channel::IsTransmitter)?"sending ":((GetDirection()==H323Channel::IsReceiver)?"receiving ":" "));
- cout << (const char *)(GetCapability()).GetFormatName() << endl;
- }
-
- if(!GetRemoteAddress(remoteIpAddress, remotePort) && h323debug)
- cout << " ** Unable to get remote IP address" << endl;
- externalMediaAddress.GetIpAndPort(externalIpAddress, externalPort);
-
- if (h323debug) {
- cout << " -- remoteIpAddress: " << remoteIpAddress << endl;
- cout << " -- remotePort: " << remotePort << endl;
- cout << " -- ExternalIpAddress: " << externalIpAddress << endl;
- cout << " -- ExternalPort: " << externalPort << endl;
- }
-
- const OpalMediaFormat & mediaFormat = codec->GetMediaFormat();
- if (rtpPayloadType == RTP_DataFrame::IllegalPayloadType) {
- rtpPayloadType = capability->GetPayloadType();
- if (rtpPayloadType == RTP_DataFrame::IllegalPayloadType)
- rtpPayloadType = mediaFormat.GetPayloadType();
- }
-
- /* Deduce direction of starting channel */
- int direction;
- if (GetDirection()==H323Channel::IsTransmitter)
- direction = 1;
- else if (GetDirection()==H323Channel::IsReceiver)
- direction = 0;
- else
- direction = -1;
-
- /* Notify Asterisk of remote RTP information */
- /* direction and payload arguments needs to
- * correctly setup RTP transport
- */
- on_start_logical_channel(connection.GetCallReference(), (const char *)remoteIpAddress.AsString(), remotePort, direction, (int)rtpPayloadType);
-
- return TRUE;
+ return new MyH323Connection(*this, callReference, options);
}
/* MyH323Connection */
MyH323Connection::MyH323Connection(MyH323EndPoint & ep,
- unsigned callReference,
- unsigned options)
- : H323Connection(ep,
- callReference,
- options)
+ unsigned callReference,
+ unsigned options)
+ : H323Connection(ep,
+ callReference,
+ options)
{
- remoteIpAddress = 0; // IP Address of remote endpoint
- remotePort = 0; // remote endpoint Data port (control is dataPort+1)
-
- progressSetup = global_options.progress_setup;
- progressAlert = global_options.progress_alert;
-
- if (h323debug)
- cout << " == New H.323 Connection created." << endl;
- return;
-}
-
-/* MyH323Connection */
-MyH323Connection::MyH323Connection(MyH323EndPoint & ep,
- unsigned callReference,
- unsigned options,
- call_options_t *call_options)
- : H323Connection(ep,
- callReference,
- options)
-{
- remoteIpAddress = 0; // IP Address of remote endpoint
- remotePort = 0; // remote endpoint Data port (control is dataPort+1)
-
- if (!call_options)
- call_options = &global_options;
-
- progressSetup = call_options->progress_setup;
- progressAlert = call_options->progress_alert;
+ remoteIpAddress = 0; // IP Address of remote endpoint
+ remotePort = 0; // remote endpoint Data port (control is dataPort+1)
if (h323debug)
cout << " == New H.323 Connection created." << endl;
@@ -648,118 +496,20 @@ MyH323Connection::~MyH323Connection()
return;
}
-/* Declare reference to standard Asterisk's callerid parser */
-extern "C" {
- void ast_callerid_parse(const char *, char **, char **);
-}
-
-/*
- * Setup H.323 caller ID to allow OpenH323 to set up Q.931's
- * IE:DisplayName and IE:DisplayNumber fields correctly
- */
-void MyH323Connection::SetCID(const char *callerid)
-{
- char *name;
- char *num;
-
- ast_callerid_parse(callerid, &name, &num);
-
- if (h323debug)
- cout << "name=" << name << ", num=" << num << endl;
-
- if ((name && *name) || (num && *num))
- {
- localAliasNames.RemoveAll();
- if(name && *name) {
- SetLocalPartyName(PString(name));
-// localAliasNames.AppendString(name);
- }
- if(num && *num)
- localAliasNames.AppendString(PString(num));
- }
-}
-
-BOOL MyH323Connection::OnReceivedProgress(const H323SignalPDU & pdu)
-{
- BOOL res;
-
- res = H323Connection::OnReceivedProgress(pdu);
-
- if(res && on_progress) {
- BOOL inband;
- unsigned ProgressPI;
-
- if(!pdu.GetQ931().GetProgressIndicator(ProgressPI))
- ProgressPI = 0;
- if(h323debug)
- cout << "Progress Indicator is " << ProgressPI << endl;
-
- /* XXX Is this correct? XXX */
- switch(ProgressPI) {
- case Q931::ProgressNotEndToEndISDN:
- case Q931::ProgressInbandInformationAvailable:
- inband = TRUE;
- break;
- default:
- inband = FALSE;
- }
- on_progress(GetCallReference(), inband);
- }
-
- return res;
-}
-
H323Connection::AnswerCallResponse MyH323Connection::OnAnswerCall(const PString & caller,
- const H323SignalPDU & setupPDU,
+ const H323SignalPDU & /*setupPDU*/,
H323SignalPDU & /*connectPDU*/)
{
- unsigned ProgressInd;
-
/* The call will be answered later with "AnsweringCall()" function.
*/
- if(!setupPDU.GetQ931().GetProgressIndicator(ProgressInd))
- ProgressInd = 0;
- if(h323debug)
- cout << "PI in SETUP was " << ProgressInd << endl;
-
- /* Progress indicator must be always set to 8 if Setup Have Progress indicator equal to 3 */
- if(progressAlert)
- ProgressInd = progressAlert;
- else if(ProgressInd == Q931::ProgressOriginNotISDN)
- ProgressInd = Q931::ProgressInbandInformationAvailable;
- if(ProgressInd)
- alertingPDU->GetQ931().SetProgressIndicator(ProgressInd);
- if(h323debug)
- cout << "Adding PI=" << ProgressInd << " to ALERT message" << endl;
-
return H323Connection::AnswerCallAlertWithMedia;
}
-BOOL MyH323Connection::OnAlerting(const H323SignalPDU & alertingPDU, const PString & username)
+BOOL MyH323Connection::OnAlerting(const H323SignalPDU & /*alertingPDU*/, const PString & username)
{
+
if (h323debug)
cout << " -- Ringing phone for \"" << username << "\"" << endl;
-
- if (on_progress) {
- BOOL inband;
- unsigned alertingPI;
-
- if(!alertingPDU.GetQ931().GetProgressIndicator(alertingPI))
- alertingPI = 0;
- if(h323debug)
- cout << "Progress Indicator is " << alertingPI << endl;
-
- /* XXX Is this correct? XXX */
- switch(alertingPI) {
- case Q931::ProgressNotEndToEndISDN:
- case Q931::ProgressInbandInformationAvailable:
- inband = TRUE;
- break;
- default:
- inband = FALSE;
- }
- on_progress(GetCallReference(), inband);
- }
return TRUE;
}
@@ -773,7 +523,6 @@ BOOL MyH323Connection::OnReceivedSignalSetup(const H323SignalPDU & setupPDU)
PString sourceE164;
PString destE164;
- PString redirE164;
PString sourceAliases;
PString destAliases;
PString sourceIp;
@@ -788,12 +537,19 @@ BOOL MyH323Connection::OnReceivedSignalSetup(const H323SignalPDU & setupPDU)
setupPDU.GetSourceE164(sourceE164);
destE164 = "";
setupPDU.GetDestinationE164(destE164);
- if(!setupPDU.GetQ931().GetRedirectingNumber(redirE164))
- redirE164 = "";
- /* Use common alias formatting routine */
- FormatAliases(sourceAliases);
- FormatAliases(destAliases);
+ /* Convert complex strings */
+ // FIXME: deal more than one source alias
+ char *s;
+ if ((s = strchr(sourceAliases, ' ')) != NULL)
+ *s = '\0';
+ if ((s = strchr(sourceAliases, '\t')) != NULL)
+ *s = '\0';
+ char *s1;
+ if ((s1 = strchr(destAliases, ' ')) != NULL)
+ *s1 = '\0';
+ if ((s1 = strchr(destAliases, '\t')) != NULL)
+ *s1 = '\0';
GetSignallingChannel()->GetRemoteAddress().GetIpAndPort(Ip, sourcePort);
@@ -801,24 +557,20 @@ BOOL MyH323Connection::OnReceivedSignalSetup(const H323SignalPDU & setupPDU)
cd.call_reference = GetCallReference();
cd.call_token = (const char *)GetCallToken();
- cd.call_source_aliases = (const char *)sourceAliases;
+ cd.call_source_aliases = (const char *)sourceAliases;
cd.call_dest_alias = (const char *)destAliases;
cd.call_source_e164 = (const char *)sourceE164;
cd.call_dest_e164 = (const char *)destE164;
- cd.call_redir_e164 = (const char *)redirE164;
- cd.sourceIp = (const char *)sourceIp;
+ cd.sourceIp = (const char *)sourceIp;
/* Notify Asterisk of the request */
- call_options_t *res = on_incoming_call(cd);
+ int res = on_incoming_call(cd);
if (!res) {
if (h323debug)
cout << " -- Call Failed" << endl;
return FALSE;
}
-
- progressSetup = res->progress_setup;
- progressAlert = res->progress_alert;
return H323Connection::OnReceivedSignalSetup(setupPDU);
}
@@ -838,13 +590,22 @@ BOOL MyH323Connection::OnSendSignalSetup(H323SignalPDU & setupPDU)
destE164 = "";
setupPDU.GetDestinationE164(destE164);
- /* Use common alias formatting routine */
- FormatAliases(sourceAliases);
- FormatAliases(destAliases);
+ /* Convert complex strings */
+ // FIXME: deal more than one source alias
+ char *s;
+ if ((s = strchr(sourceAliases, ' ')) != NULL)
+ *s = '\0';
+ if ((s = strchr(sourceAliases, '\t')) != NULL)
+ *s = '\0';
+ char *s1;
+ if ((s1 = strchr(destAliases, ' ')) != NULL)
+ *s1 = '\0';
+ if ((s1 = strchr(destAliases, '\t')) != NULL)
+ *s1 = '\0';
cd.call_reference = GetCallReference();
cd.call_token = (const char *)GetCallToken();
- cd.call_source_aliases = (const char *)sourceAliases;
+ cd.call_source_aliases = (const char *)sourceAliases;
cd.call_dest_alias = (const char *)destAliases;
cd.call_source_e164 = (const char *)sourceE164;
cd.call_dest_e164 = (const char *)destE164;
@@ -857,10 +618,6 @@ BOOL MyH323Connection::OnSendSignalSetup(H323SignalPDU & setupPDU)
return FALSE;
}
- if(progressSetup)
- setupPDU.GetQ931().SetProgressIndicator(progressSetup);
-// setupPDU.GetQ931().SetProgressIndicator(Q931::ProgressInbandInformationAvailable);
-// setupPDU.GetQ931().SetProgressIndicator(Q931::ProgressOriginNotISDN);
return H323Connection::OnSendSignalSetup(setupPDU);
}
@@ -951,7 +708,7 @@ H323Channel * MyH323Connection::CreateRealTimeLogicalChannel(const H323Capabilit
cout << " -- SessionID: " << sessionID << endl;
cout << " -- Direction: " << dir << endl;
}
- return new MyH323_ExternalRTPChannel(*this, capability, dir, sessionID, externalIpAddress, externalPort);
+ return new H323_ExternalRTPChannel(*this, capability, dir, sessionID, externalIpAddress, externalPort);
}
/** This callback function is invoked once upon creation of each
@@ -960,8 +717,7 @@ H323Channel * MyH323Connection::CreateRealTimeLogicalChannel(const H323Capabilit
BOOL MyH323Connection::OnStartLogicalChannel(H323Channel & channel)
{
if (h323debug) {
- /* Show H.323 channel number to make debugging more comfortable */
- cout << " -- Started logical channel " << channel.GetNumber() << ": ";
+ cout << " -- Started logical channel: ";
cout << ((channel.GetDirection()==H323Channel::IsTransmitter)?"sending ":((channel.GetDirection()==H323Channel::IsReceiver)?"receiving ":" "));
cout << (const char *)(channel.GetCapability()).GetFormatName() << endl;
}
@@ -970,10 +726,8 @@ BOOL MyH323Connection::OnStartLogicalChannel(H323Channel & channel)
if (h323debug)
cout << " -- channelsOpen = " << channelsOpen << endl;
-#if 0
H323_ExternalRTPChannel & external = (H323_ExternalRTPChannel &)channel;
- if(!external.GetRemoteAddress(remoteIpAddress, remotePort) && h323debug)
- cout << " ** Unable to get remote IP address" << endl;
+ external.GetRemoteAddress(remoteIpAddress, remotePort);
if (h323debug) {
cout << " -- remoteIpAddress: " << remoteIpAddress << endl;
@@ -981,49 +735,8 @@ BOOL MyH323Connection::OnStartLogicalChannel(H323Channel & channel)
cout << " -- ExternalIpAddress: " << externalIpAddress << endl;
cout << " -- ExternalPort: " << externalPort << endl;
}
-
- /* Try to determine negotiated RTP payload format to configure
- * RTP stack more quickly (not to wait at least one packet with
- * filled RTP payload
- */
- RTP_DataFrame::PayloadTypes payloadType = channel.GetCapability().GetPayloadType();
- cout << " *** channel's payload is " << payloadType << endl;
- if (payloadType == RTP_DataFrame::IllegalPayloadType) {
- payloadType = channel.GetCodec()->GetMediaFormat().GetPayloadType();
- cout << " *** channel's codec payload is " << payloadType << endl;
- }
- if ((payloadType == RTP_DataFrame::IllegalPayloadType) || (payloadType >= RTP_DataFrame::DynamicBase)) {
- OpalMediaFormat mediaFormat = channel.GetCodec()->GetMediaFormat();
-// if (mediaFormat.GetPayloadType() < RTP_DataFrame::DynamicBase)
- {
- payloadType = mediaFormat.GetPayloadType();
- cout << " *** channel's Opal media payload is " << payloadType << endl;
- }
- }
-// if ((payloadType == RTP_DataFrame::IllegalPayloadType)) {
-// OpalMediaFormat OMF((const char *)(channel.GetCapability()).GetFormatName(), 1);
-// if (OMF.IsValid())
-// {
-// payloadType = OMF.GetPayloadType();
-// cout << " *** channel's OMF payload is " << payloadType << endl;
-// }
-// }
-
- /* Deduce direction of starting channel */
- int direction;
- if (channel.GetDirection()==H323Channel::IsTransmitter)
- direction = 1;
- else if (channel.GetDirection()==H323Channel::IsReceiver)
- direction = 0;
- else
- direction = -1;
-
/* Notify Asterisk of remote RTP information */
- /* direction and payload arguments needs to
- * correctly setup RTP transport
- */
- on_start_logical_channel(GetCallReference(), (const char *)remoteIpAddress.AsString(), remotePort, direction, (int)payloadType);
-#endif
+ on_start_logical_channel(GetCallReference(), (const char *)remoteIpAddress.AsString(), remotePort);
return TRUE;
}
@@ -1086,6 +799,7 @@ void h323_gk_urq(void)
cout << " ERROR: [h323_gk_urq] No Endpoint, this is bad" << endl;
return;
}
+
endPoint->RemoveGatekeeper();
}
@@ -1109,8 +823,7 @@ void h323_callback_register(setup_incoming_cb ifunc,
start_logchan_cb lfunc,
clear_con_cb clfunc,
con_established_cb efunc,
- send_digit_cb dfunc,
- progress_cb pgfunc)
+ send_digit_cb dfunc)
{
on_incoming_call = ifunc;
on_outgoing_call = sfunc;
@@ -1119,7 +832,6 @@ void h323_callback_register(setup_incoming_cb ifunc,
on_connection_cleared = clfunc;
on_connection_established = efunc;
on_send_digit = dfunc;
- on_progress = pgfunc;
}
/**
@@ -1128,8 +840,7 @@ void h323_callback_register(setup_incoming_cb ifunc,
int h323_set_capability(int cap, int dtmfMode)
{
int g711Frames = 30;
- int gsmFrames = 4;
- PINDEX last_cap = -1; /* last common capability block index */
+ int gsmFrames = 4;
if (!h323_end_point_exist()) {
@@ -1137,74 +848,61 @@ int h323_set_capability(int cap, int dtmfMode)
return 1;
}
- /* User input mode moved to the end of procedure */
+ mode = dtmfMode;
+ if (dtmfMode == H323_DTMF_INBAND)
+ endPoint->SetSendUserInputMode(H323Connection::SendUserInputAsTone);
+ else
+ endPoint->SetSendUserInputMode(H323Connection::SendUserInputAsInlineRFC2833);
+
/* Hardcode this for now (Someone tell me if T.38 works now
or provide me with some debug so we can make this work */
-// last_cap = endPoint->SetCapability(0, 0, new H323_T38Capability(H323_T38Capability::e_UDP));
+// endPoint->SetCapability(0, 0, new H323_T38Capability(H323_T38Capability::e_UDP));
if (cap & AST_FORMAT_SPEEX) {
/* Not real sure if Asterisk acutally supports all
of the various different bit rates so add them
all and figure it out later*/
- last_cap = endPoint->SetCapability(0, 0, new SpeexNarrow2AudioCapability());
- last_cap = endPoint->SetCapability(0, 0, new SpeexNarrow3AudioCapability());
- last_cap = endPoint->SetCapability(0, 0, new SpeexNarrow4AudioCapability());
- last_cap = endPoint->SetCapability(0, 0, new SpeexNarrow5AudioCapability());
- last_cap = endPoint->SetCapability(0, 0, new SpeexNarrow6AudioCapability());
+ endPoint->SetCapability(0, 0, new SpeexNarrow2AudioCapability());
+ endPoint->SetCapability(0, 0, new SpeexNarrow3AudioCapability());
+ endPoint->SetCapability(0, 0, new SpeexNarrow4AudioCapability());
+ endPoint->SetCapability(0, 0, new SpeexNarrow5AudioCapability());
+ endPoint->SetCapability(0, 0, new SpeexNarrow6AudioCapability());
}
if (cap & AST_FORMAT_G729A) {
AST_G729ACapability *g729aCap;
AST_G729Capability *g729Cap;
- last_cap = endPoint->SetCapability(0, 0, g729aCap = new AST_G729ACapability);
- last_cap = endPoint->SetCapability(0, 0, g729Cap = new AST_G729Capability);
+ endPoint->SetCapability(0, 0, g729aCap = new AST_G729ACapability);
+ endPoint->SetCapability(0, 0, g729Cap = new AST_G729Capability);
}
if (cap & AST_FORMAT_G723_1) {
- H323_G7231Capability *g7231Cap, *g7231Cap1;
- last_cap = endPoint->SetCapability(0, 0, g7231Cap = new H323_G7231Capability);
- last_cap = endPoint->SetCapability(0, 0, g7231Cap1 = new H323_G7231Capability(FALSE));
+ H323_G7231Capability *g7231Cap;
+ endPoint->SetCapability(0, 0, g7231Cap = new H323_G7231Capability);
}
if (cap & AST_FORMAT_GSM) {
H323_GSM0610Capability *gsmCap;
- last_cap = endPoint->SetCapability(0, 0, gsmCap = new H323_GSM0610Capability);
- gsmCap->SetTxFramesInPacket(gsmFrames);
+ endPoint->SetCapability(0, 0, gsmCap = new H323_GSM0610Capability);
+ gsmCap->SetTxFramesInPacket(gsmFrames);
}
if (cap & AST_FORMAT_ULAW) {
+
H323_G711Capability *g711uCap;
- last_cap = endPoint->SetCapability(0, 0, g711uCap = new H323_G711Capability(H323_G711Capability::muLaw));
+ endPoint->SetCapability(0, 0, g711uCap = new H323_G711Capability(H323_G711Capability::muLaw));
g711uCap->SetTxFramesInPacket(g711Frames);
}
if (cap & AST_FORMAT_ALAW) {
H323_G711Capability *g711aCap;
- last_cap = endPoint->SetCapability(0, 0, g711aCap = new H323_G711Capability(H323_G711Capability::ALaw));
+ endPoint->SetCapability(0, 0, g711aCap = new H323_G711Capability(H323_G711Capability::ALaw));
g711aCap->SetTxFramesInPacket(g711Frames);
}
- /* Add HookFlash capability - not used yet now */
- last_cap++;
- last_cap = endPoint->SetCapability(0, last_cap, new H323_UserInputCapability(H323_UserInputCapability::HookFlashH245));
-
- /* Add correct UserInputMode capability
- * This allows remote party to send UserIput
- * correctly embedded into protocol
- */
- last_cap++;
- mode = dtmfMode;
- if (dtmfMode == H323_DTMF_INBAND) {
- endPoint->SetCapability(0, last_cap, new H323_UserInputCapability(H323_UserInputCapability::SignalToneH245));
- endPoint->SetSendUserInputMode(H323Connection::SendUserInputAsTone);
- } else {
- endPoint->SetCapability(0, last_cap, new H323_UserInputCapability(H323_UserInputCapability::SignalToneRFC2833));
- endPoint->SetSendUserInputMode(H323Connection::SendUserInputAsInlineRFC2833);
- }
-
return 0;
}
@@ -1356,7 +1054,7 @@ void h323_send_tone(const char *call_token, char tone)
/** Make a call to the remote endpoint.
*/
-int h323_make_call(char *host, call_details_t *cd, call_options_t *call_options)
+int h323_make_call(char *host, call_details_t *cd, call_options_t call_options)
{
int res;
PString token;
@@ -1367,7 +1065,7 @@ int h323_make_call(char *host, call_details_t *cd, call_options_t *call_options)
PString dest(host);
- res = endPoint->MakeCall(dest, token, &cd->call_reference, call_options);
+ res = endPoint->MakeCall(dest, token, &cd->call_reference, call_options.port, call_options.callerid);
memcpy((char *)(cd->call_token), (const unsigned char *)token, token.GetLength());
return res;
@@ -1444,3 +1142,6 @@ void h323_native_bridge(const char *token, char *them, char *capability)
}
} /* extern "C" */
+
+
+
diff --git a/channels/h323/ast_h323.h b/channels/h323/ast_h323.h
index 6b05a9fd8..5c0c2b4a9 100755
--- a/channels/h323/ast_h323.h
+++ b/channels/h323/ast_h323.h
@@ -88,7 +88,7 @@ class H323_G7231Capability : public H323AudioCapability
H245_AudioCapability & pdu, /// PDU to set information on
unsigned packetSize /// Packet size to use in capability
) const;
-
+
BOOL OnReceivedPDU(
const H245_AudioCapability & pdu, /// PDU to get information from
unsigned & packetSize /// Packet size to use in capability
@@ -198,7 +198,7 @@ class MyH323EndPoint : public H323EndPoint {
public:
- int MakeCall(const PString &, PString &, unsigned int *, call_options_t *);
+ int MakeCall(const PString &, PString &, unsigned int *, unsigned int, char *);
BOOL ClearCall(const PString &);
void OnClosedLogicalChannel(H323Connection &, const H323Channel &);
@@ -213,8 +213,9 @@ class MyH323EndPoint : public H323EndPoint {
PStringArray SupportedPrefixes;
- void SetEndpointTypeInfo( H225_EndpointType & info ) const;
- void SetGateway(void);
+ void SetEndpointTypeInfo( H225_EndpointType & info ) const;
+ void SetGateway(void);
+
};
@@ -224,7 +225,6 @@ class MyH323Connection : public H323Connection {
public:
MyH323Connection(MyH323EndPoint &, unsigned, unsigned);
- MyH323Connection(MyH323EndPoint &, unsigned, unsigned, call_options_t *);
~MyH323Connection();
H323Channel * CreateRealTimeLogicalChannel(const H323Capability &, H323Channel::Directions, unsigned,
@@ -241,9 +241,6 @@ class MyH323Connection : public H323Connection {
void SendUserInputTone(char, unsigned);
void OnUserInputTone(char, unsigned, unsigned, unsigned);
void OnUserInputString(const PString &value);
- BOOL OnReceivedProgress(const H323SignalPDU &);
- /* Set up H.323 caller id */
- void SetCID(const char *callerid);
PString sourceAliases;
PString destAliases;
@@ -251,53 +248,11 @@ class MyH323Connection : public H323Connection {
PString destE164;
PIPSocket::Address externalIpAddress; // IP address of media server
- PIPSocket::Address remoteIpAddress; // IP Address of remote endpoint
- WORD externalPort; // local media server Data port (control is dataPort+1)
- WORD remotePort; // remote endpoint Data port (control is dataPort+1)
- WORD sessionId;
- BOOL bridging; // Used to help determine which IP to use
- unsigned progressSetup; // ProgressIndicator IE value for SETUP message
- unsigned progressAlert; // ProgressIndicator IE value for ALERT message
-};
-
-class MyH323_ExternalRTPChannel : public H323_ExternalRTPChannel
-{
- PCLASSINFO(MyH323_ExternalRTPChannel, H323_ExternalRTPChannel);
-
-public:
- /**@name Construction */
- //@{
- /**Create a new channel.
- */
- MyH323_ExternalRTPChannel(
- H323Connection & connection, /// Connection to endpoint for channel
- const H323Capability & capability, /// Capability channel is using
- Directions direction, /// Direction of channel
- unsigned sessionID /// Session ID for channel
- );
- /**Create a new channel.
- */
- MyH323_ExternalRTPChannel(
- H323Connection & connection, /// Connection to endpoint for channel
- const H323Capability & capability, /// Capability channel is using
- Directions direction, /// Direction of channel
- unsigned sessionID, /// Session ID for channel
- const H323TransportAddress & data, /// Data address
- const H323TransportAddress & control/// Control address
- );
- /**Create a new channel.
- */
- MyH323_ExternalRTPChannel(
- H323Connection & connection, /// Connection to endpoint for channel
- const H323Capability & capability, /// Capability channel is using
- Directions direction, /// Direction of channel
- unsigned sessionID, /// Session ID for channel
- const PIPSocket::Address & ip, /// IP address of media server
- WORD dataPort /// Data port (control is dataPort+1)
- );
- //@}
-// BOOL OnReceivedAckPDU(const H245_H2250LogicalChannelAckParameters & param);
- BOOL Start(void);
+ PIPSocket::Address remoteIpAddress; // IP Address of remote endpoint
+ WORD externalPort; // local media server Data port (control is dataPort+1)
+ WORD remotePort; // remote endpoint Data port (control is dataPort+1)
+ WORD sessionId;
+ BOOL bridging; // Used to help determine which IP to use
};
@@ -393,3 +348,5 @@ class ClearCallThread : public PThread {
protected:
PString token;
};
+
+
diff --git a/channels/h323/chan_h323.h b/channels/h323/chan_h323.h
index 912b08152..c330dd883 100755
--- a/channels/h323/chan_h323.h
+++ b/channels/h323/chan_h323.h
@@ -28,23 +28,7 @@
#include <arpa/inet.h>
-//static struct sockaddr_in bindaddr;
-
-/** call_option struct is filled from the
- PBX application and passed through make_call
- function*/
-typedef struct call_options {
- char *callerid;
- int noFastStart;
- int noH245Tunnelling;
- int noSilenceSuppression;
- int progress_setup;
- int progress_alert;
- int progress_audio;
- unsigned int port;
-} call_options_t;
-
-extern call_options_t global_options;
+static struct sockaddr_in bindaddr;
/* structure to hold the valid asterisk users */
struct oh323_user {
@@ -54,13 +38,15 @@ struct oh323_user {
char callerid[80];
char accountcode[20];
int amaflags;
+ int noFastStart;
+ int noH245Tunneling;
+ int noSilenceSuppression;
int inUse;
int incominglimit;
int bridge;
int nat;
int dtmfmode;
int host;
- call_options_t call_options;
struct ast_ha *ha;
struct sockaddr_in addr;
struct oh323_user *next;
@@ -71,6 +57,9 @@ struct oh323_user {
struct oh323_peer {
char name[80];
char context[80];
+ int noFastStart;
+ int noH245Tunneling;
+ int noSilenceSuppression;
int inUse;
int outgoinglimit;
int bridge;
@@ -78,7 +67,6 @@ struct oh323_peer {
int dtmfmode;
struct sockaddr_in addr;
int delme;
- call_options_t call_options;
struct oh323_peer *next;
};
@@ -93,6 +81,17 @@ struct oh323_alias {
struct oh323_alias *next;
};
+/** call_option struct is filled from the
+ PBX application and passed through make_call
+ function*/
+typedef struct call_options {
+ char *callerid;
+ int noFastStart;
+ int noH245Tunnelling;
+ int noSilenceSuppression;
+ unsigned int port;
+} call_options_t;
+
/** call_details struct call detail records
to asterisk for processing and used for matching up
asterisk channels to acutal h.323 connections */
@@ -104,7 +103,6 @@ typedef struct call_details {
const char *call_dest_alias;
const char *call_source_e164;
const char *call_dest_e164;
- const char *call_redir_e164;
const char *sourceIp;
} call_details_t;
@@ -125,7 +123,7 @@ on_connection_cb on_create_connection;
/* This is a callback prototype function, called upon
an incoming call happens. */
-typedef call_options_t *(*setup_incoming_cb)(call_details_t);
+typedef int (*setup_incoming_cb)(call_details_t);
setup_incoming_cb on_incoming_call;
/* This is a callback prototype function, called upon
@@ -134,10 +132,8 @@ typedef int (*setup_outbound_cb)(call_details_t);
setup_outbound_cb on_outgoing_call;
/* This is a callback prototype function, called when the openh323
- OnStartLogicalChannel is invoked.
- 2 more arguments - direction and payload type.
- */
-typedef void (*start_logchan_cb)(unsigned int, const char *, int, int, int);
+ OnStartLogicalChannel is invoked. */
+typedef void (*start_logchan_cb)(unsigned int, const char *, int);
start_logchan_cb on_start_logical_channel;
/* This is a callback protoype function, called when the openh323
@@ -150,33 +146,15 @@ con_established_cb on_connection_established;
typedef void (*clear_con_cb)(call_details_t);
clear_con_cb on_connection_cleared;
-/* This is a callback prototype function, called when the openh323
- OnReceivedAckPDU is invoked. */
-typedef void (*setup_rtp_cb)(unsigned int, const char *, int);
-setup_rtp_cb on_setup_rtp_peer;
-
-typedef int (*progress_cb)(unsigned, int);
-progress_cb on_progress;
-
/* debug flag */
int h323debug;
#define H323_DTMF_RFC2833 (1 << 0)
#define H323_DTMF_INBAND (1 << 1)
-/* Required to declare global variables from chan_h323.c */
-#ifndef BOOL
-#define BOOL int
-#endif
-
#ifdef __cplusplus
extern "C" {
#endif
-
- /* chan_h323 global parameters */
- extern BOOL noFastStart;
- extern BOOL noH245Tunnelling;
- extern BOOL noSilenceSuppression;
void h323_gk_urq(void);
void h323_end_point_create(void);
@@ -187,13 +165,13 @@ extern "C" {
/* callback function handler*/
void h323_callback_register(setup_incoming_cb,
- setup_outbound_cb,
- on_connection_cb,
- start_logchan_cb,
- clear_con_cb,
- con_established_cb,
- send_digit_cb,
- progress_cb);
+ setup_outbound_cb,
+ on_connection_cb,
+ start_logchan_cb,
+ clear_con_cb,
+ con_established_cb,
+ send_digit_cb);
+
int h323_set_capability(int, int);
int h323_set_alias(struct oh323_alias *);
@@ -210,7 +188,7 @@ extern "C" {
void h323_send_tone(const char *call_token, char tone);
/* H323 create and destroy sessions */
- int h323_make_call(char *host, call_details_t *cd, call_options_t *call_options);
+ int h323_make_call(char *host, call_details_t *cd, call_options_t);
int h323_clear_call(const char *);
int h323_answering_call(const char *token, int);
diff --git a/channels/h323/h323.conf.sample b/channels/h323/h323.conf.sample
index 8ddf73dae..811647a08 100755
--- a/channels/h323/h323.conf.sample
+++ b/channels/h323/h323.conf.sample
@@ -52,13 +52,6 @@ allow=gsm ; Always allow GSM, it's cool :)
; use user authentication at all.
;
;context=default
-;noFastStart = no
-;noH245Tunneling = no
-;noSilenceSuppression = yes
-;progress_setup = 3
-;progress_alert = 8
-;progress_audio = yes
-
;
; H.323 Alias definitions
;