Convert sig_analog to use a global callback table.

git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@370926 65c4cc65-6c06-0410-ace0-fbb531ad65f3
certified/11.2
Richard Mudgett 13 years ago
parent e571897441
commit 062becab80

@ -3768,7 +3768,7 @@ static int my_have_progressdetect(void *pvt)
} }
} }
static struct analog_callback dahdi_analog_callbacks = struct analog_callback analog_callbacks =
{ {
.play_tone = my_play_tone, .play_tone = my_play_tone,
.get_event = my_get_event, .get_event = my_get_event,
@ -12630,7 +12630,7 @@ static struct dahdi_pvt *mkintf(int channel, const struct dahdi_chan_conf *conf,
tmp->outsigmod = conf->chan.outsigmod; tmp->outsigmod = conf->chan.outsigmod;
if (analog_lib_handles(chan_sig, tmp->radio, tmp->oprmode)) { if (analog_lib_handles(chan_sig, tmp->radio, tmp->oprmode)) {
analog_p = analog_new(dahdisig_to_analogsig(chan_sig), &dahdi_analog_callbacks, tmp); analog_p = analog_new(dahdisig_to_analogsig(chan_sig), tmp);
if (!analog_p) { if (!analog_p) {
destroy_dahdi_pvt(tmp); destroy_dahdi_pvt(tmp);
return NULL; return NULL;

@ -161,56 +161,56 @@ const char *analog_cidtype_to_str(unsigned int cid_type)
static int analog_start_cid_detect(struct analog_pvt *p, int cid_signalling) static int analog_start_cid_detect(struct analog_pvt *p, int cid_signalling)
{ {
if (p->calls->start_cid_detect) { if (analog_callbacks.start_cid_detect) {
return p->calls->start_cid_detect(p->chan_pvt, cid_signalling); return analog_callbacks.start_cid_detect(p->chan_pvt, cid_signalling);
} }
return -1; return -1;
} }
static int analog_stop_cid_detect(struct analog_pvt *p) static int analog_stop_cid_detect(struct analog_pvt *p)
{ {
if (p->calls->stop_cid_detect) { if (analog_callbacks.stop_cid_detect) {
return p->calls->stop_cid_detect(p->chan_pvt); return analog_callbacks.stop_cid_detect(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_get_callerid(struct analog_pvt *p, char *name, char *number, enum analog_event *ev, size_t timeout) static int analog_get_callerid(struct analog_pvt *p, char *name, char *number, enum analog_event *ev, size_t timeout)
{ {
if (p->calls->get_callerid) { if (analog_callbacks.get_callerid) {
return p->calls->get_callerid(p->chan_pvt, name, number, ev, timeout); return analog_callbacks.get_callerid(p->chan_pvt, name, number, ev, timeout);
} }
return -1; return -1;
} }
static const char *analog_get_orig_dialstring(struct analog_pvt *p) static const char *analog_get_orig_dialstring(struct analog_pvt *p)
{ {
if (p->calls->get_orig_dialstring) { if (analog_callbacks.get_orig_dialstring) {
return p->calls->get_orig_dialstring(p->chan_pvt); return analog_callbacks.get_orig_dialstring(p->chan_pvt);
} }
return ""; return "";
} }
static int analog_get_event(struct analog_pvt *p) static int analog_get_event(struct analog_pvt *p)
{ {
if (p->calls->get_event) { if (analog_callbacks.get_event) {
return p->calls->get_event(p->chan_pvt); return analog_callbacks.get_event(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_wait_event(struct analog_pvt *p) static int analog_wait_event(struct analog_pvt *p)
{ {
if (p->calls->wait_event) { if (analog_callbacks.wait_event) {
return p->calls->wait_event(p->chan_pvt); return analog_callbacks.wait_event(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_have_progressdetect(struct analog_pvt *p) static int analog_have_progressdetect(struct analog_pvt *p)
{ {
if (p->calls->have_progressdetect) { if (analog_callbacks.have_progressdetect) {
return p->calls->have_progressdetect(p->chan_pvt); return analog_callbacks.have_progressdetect(p->chan_pvt);
} }
/* Don't have progress detection. */ /* Don't have progress detection. */
return 0; return 0;
@ -345,16 +345,16 @@ static void analog_swap_subs(struct analog_pvt *p, enum analog_sub a, enum analo
p->subs[a].inthreeway = p->subs[b].inthreeway; p->subs[a].inthreeway = p->subs[b].inthreeway;
p->subs[b].inthreeway = tinthreeway; p->subs[b].inthreeway = tinthreeway;
if (p->calls->swap_subs) { if (analog_callbacks.swap_subs) {
p->calls->swap_subs(p->chan_pvt, a, p->subs[a].owner, b, p->subs[b].owner); analog_callbacks.swap_subs(p->chan_pvt, a, p->subs[a].owner, b, p->subs[b].owner);
} }
} }
static int analog_alloc_sub(struct analog_pvt *p, enum analog_sub x) static int analog_alloc_sub(struct analog_pvt *p, enum analog_sub x)
{ {
if (p->calls->allocate_sub) { if (analog_callbacks.allocate_sub) {
int res; int res;
res = p->calls->allocate_sub(p->chan_pvt, x); res = analog_callbacks.allocate_sub(p->chan_pvt, x);
if (!res) { if (!res) {
p->subs[x].allocd = 1; p->subs[x].allocd = 1;
} }
@ -367,8 +367,8 @@ static int analog_unalloc_sub(struct analog_pvt *p, enum analog_sub x)
{ {
p->subs[x].allocd = 0; p->subs[x].allocd = 0;
p->subs[x].owner = NULL; p->subs[x].owner = NULL;
if (p->calls->unallocate_sub) { if (analog_callbacks.unallocate_sub) {
return p->calls->unallocate_sub(p->chan_pvt, x); return analog_callbacks.unallocate_sub(p->chan_pvt, x);
} }
return 0; return 0;
} }
@ -383,8 +383,8 @@ static int analog_send_callerid(struct analog_pvt *p, int cwcid, struct ast_part
p->callwaitcas = 0; p->callwaitcas = 0;
} }
if (p->calls->send_callerid) { if (analog_callbacks.send_callerid) {
return p->calls->send_callerid(p->chan_pvt, cwcid, caller); return analog_callbacks.send_callerid(p->chan_pvt, cwcid, caller);
} }
return 0; return 0;
} }
@ -412,8 +412,8 @@ static int _analog_get_index(struct ast_channel *ast, struct analog_pvt *p, int
static int analog_dsp_reset_and_flush_digits(struct analog_pvt *p) static int analog_dsp_reset_and_flush_digits(struct analog_pvt *p)
{ {
if (p->calls->dsp_reset_and_flush_digits) { if (analog_callbacks.dsp_reset_and_flush_digits) {
return p->calls->dsp_reset_and_flush_digits(p->chan_pvt); return analog_callbacks.dsp_reset_and_flush_digits(p->chan_pvt);
} }
/* Return 0 since I think this is unnecessary to do in most cases it is used. Mostly only for ast_dsp */ /* Return 0 since I think this is unnecessary to do in most cases it is used. Mostly only for ast_dsp */
@ -422,8 +422,8 @@ static int analog_dsp_reset_and_flush_digits(struct analog_pvt *p)
static int analog_play_tone(struct analog_pvt *p, enum analog_sub sub, enum analog_tone tone) static int analog_play_tone(struct analog_pvt *p, enum analog_sub sub, enum analog_tone tone)
{ {
if (p->calls->play_tone) { if (analog_callbacks.play_tone) {
return p->calls->play_tone(p->chan_pvt, sub, tone); return analog_callbacks.play_tone(p->chan_pvt, sub, tone);
} }
return -1; return -1;
} }
@ -431,8 +431,8 @@ static int analog_play_tone(struct analog_pvt *p, enum analog_sub sub, enum anal
static void analog_set_new_owner(struct analog_pvt *p, struct ast_channel *new_owner) static void analog_set_new_owner(struct analog_pvt *p, struct ast_channel *new_owner)
{ {
p->owner = new_owner; p->owner = new_owner;
if (p->calls->set_new_owner) { if (analog_callbacks.set_new_owner) {
p->calls->set_new_owner(p->chan_pvt, new_owner); analog_callbacks.set_new_owner(p->chan_pvt, new_owner);
} }
} }
@ -440,11 +440,11 @@ static struct ast_channel * analog_new_ast_channel(struct analog_pvt *p, int sta
{ {
struct ast_channel *c; struct ast_channel *c;
if (!p->calls->new_ast_channel) { if (!analog_callbacks.new_ast_channel) {
return NULL; return NULL;
} }
c = p->calls->new_ast_channel(p->chan_pvt, state, startpbx, sub, requestor); c = analog_callbacks.new_ast_channel(p->chan_pvt, state, startpbx, sub, requestor);
if (c) { if (c) {
ast_channel_call_forward_set(c, p->call_forward); ast_channel_call_forward_set(c, p->call_forward);
} }
@ -457,64 +457,64 @@ static struct ast_channel * analog_new_ast_channel(struct analog_pvt *p, int sta
static int analog_set_echocanceller(struct analog_pvt *p, int enable) static int analog_set_echocanceller(struct analog_pvt *p, int enable)
{ {
if (p->calls->set_echocanceller) { if (analog_callbacks.set_echocanceller) {
return p->calls->set_echocanceller(p->chan_pvt, enable); return analog_callbacks.set_echocanceller(p->chan_pvt, enable);
} }
return -1; return -1;
} }
static int analog_train_echocanceller(struct analog_pvt *p) static int analog_train_echocanceller(struct analog_pvt *p)
{ {
if (p->calls->train_echocanceller) { if (analog_callbacks.train_echocanceller) {
return p->calls->train_echocanceller(p->chan_pvt); return analog_callbacks.train_echocanceller(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_is_off_hook(struct analog_pvt *p) static int analog_is_off_hook(struct analog_pvt *p)
{ {
if (p->calls->is_off_hook) { if (analog_callbacks.is_off_hook) {
return p->calls->is_off_hook(p->chan_pvt); return analog_callbacks.is_off_hook(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_ring(struct analog_pvt *p) static int analog_ring(struct analog_pvt *p)
{ {
if (p->calls->ring) { if (analog_callbacks.ring) {
return p->calls->ring(p->chan_pvt); return analog_callbacks.ring(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_flash(struct analog_pvt *p) static int analog_flash(struct analog_pvt *p)
{ {
if (p->calls->flash) { if (analog_callbacks.flash) {
return p->calls->flash(p->chan_pvt); return analog_callbacks.flash(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_start(struct analog_pvt *p) static int analog_start(struct analog_pvt *p)
{ {
if (p->calls->start) { if (analog_callbacks.start) {
return p->calls->start(p->chan_pvt); return analog_callbacks.start(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_dial_digits(struct analog_pvt *p, enum analog_sub sub, struct analog_dialoperation *dop) static int analog_dial_digits(struct analog_pvt *p, enum analog_sub sub, struct analog_dialoperation *dop)
{ {
if (p->calls->dial_digits) { if (analog_callbacks.dial_digits) {
return p->calls->dial_digits(p->chan_pvt, sub, dop); return analog_callbacks.dial_digits(p->chan_pvt, sub, dop);
} }
return -1; return -1;
} }
static int analog_on_hook(struct analog_pvt *p) static int analog_on_hook(struct analog_pvt *p)
{ {
if (p->calls->on_hook) { if (analog_callbacks.on_hook) {
return p->calls->on_hook(p->chan_pvt); return analog_callbacks.on_hook(p->chan_pvt);
} }
return -1; return -1;
} }
@ -522,44 +522,44 @@ static int analog_on_hook(struct analog_pvt *p)
static void analog_set_outgoing(struct analog_pvt *p, int is_outgoing) static void analog_set_outgoing(struct analog_pvt *p, int is_outgoing)
{ {
p->outgoing = is_outgoing; p->outgoing = is_outgoing;
if (p->calls->set_outgoing) { if (analog_callbacks.set_outgoing) {
p->calls->set_outgoing(p->chan_pvt, is_outgoing); analog_callbacks.set_outgoing(p->chan_pvt, is_outgoing);
} }
} }
static int analog_check_for_conference(struct analog_pvt *p) static int analog_check_for_conference(struct analog_pvt *p)
{ {
if (p->calls->check_for_conference) { if (analog_callbacks.check_for_conference) {
return p->calls->check_for_conference(p->chan_pvt); return analog_callbacks.check_for_conference(p->chan_pvt);
} }
return -1; return -1;
} }
static void analog_all_subchannels_hungup(struct analog_pvt *p) static void analog_all_subchannels_hungup(struct analog_pvt *p)
{ {
if (p->calls->all_subchannels_hungup) { if (analog_callbacks.all_subchannels_hungup) {
p->calls->all_subchannels_hungup(p->chan_pvt); analog_callbacks.all_subchannels_hungup(p->chan_pvt);
} }
} }
static void analog_unlock_private(struct analog_pvt *p) static void analog_unlock_private(struct analog_pvt *p)
{ {
if (p->calls->unlock_private) { if (analog_callbacks.unlock_private) {
p->calls->unlock_private(p->chan_pvt); analog_callbacks.unlock_private(p->chan_pvt);
} }
} }
static void analog_lock_private(struct analog_pvt *p) static void analog_lock_private(struct analog_pvt *p)
{ {
if (p->calls->lock_private) { if (analog_callbacks.lock_private) {
p->calls->lock_private(p->chan_pvt); analog_callbacks.lock_private(p->chan_pvt);
} }
} }
static void analog_deadlock_avoidance_private(struct analog_pvt *p) static void analog_deadlock_avoidance_private(struct analog_pvt *p)
{ {
if (p->calls->deadlock_avoidance_private) { if (analog_callbacks.deadlock_avoidance_private) {
p->calls->deadlock_avoidance_private(p->chan_pvt); analog_callbacks.deadlock_avoidance_private(p->chan_pvt);
} else { } else {
/* Fallback to manual avoidance if callback not present. */ /* Fallback to manual avoidance if callback not present. */
analog_unlock_private(p); analog_unlock_private(p);
@ -601,83 +601,83 @@ static void analog_lock_sub_owner(struct analog_pvt *pvt, enum analog_sub sub_id
static int analog_off_hook(struct analog_pvt *p) static int analog_off_hook(struct analog_pvt *p)
{ {
if (p->calls->off_hook) { if (analog_callbacks.off_hook) {
return p->calls->off_hook(p->chan_pvt); return analog_callbacks.off_hook(p->chan_pvt);
} }
return -1; return -1;
} }
static void analog_set_needringing(struct analog_pvt *p, int value) static void analog_set_needringing(struct analog_pvt *p, int value)
{ {
if (p->calls->set_needringing) { if (analog_callbacks.set_needringing) {
return p->calls->set_needringing(p->chan_pvt, value); analog_callbacks.set_needringing(p->chan_pvt, value);
} }
} }
#if 0 #if 0
static void analog_set_polarity(struct analog_pvt *p, int value) static void analog_set_polarity(struct analog_pvt *p, int value)
{ {
if (p->calls->set_polarity) { if (analog_callbacks.set_polarity) {
return p->calls->set_polarity(p->chan_pvt, value); analog_callbacks.set_polarity(p->chan_pvt, value);
} }
} }
#endif #endif
static void analog_start_polarityswitch(struct analog_pvt *p) static void analog_start_polarityswitch(struct analog_pvt *p)
{ {
if (p->calls->start_polarityswitch) { if (analog_callbacks.start_polarityswitch) {
return p->calls->start_polarityswitch(p->chan_pvt); analog_callbacks.start_polarityswitch(p->chan_pvt);
} }
} }
static void analog_answer_polarityswitch(struct analog_pvt *p) static void analog_answer_polarityswitch(struct analog_pvt *p)
{ {
if (p->calls->answer_polarityswitch) { if (analog_callbacks.answer_polarityswitch) {
return p->calls->answer_polarityswitch(p->chan_pvt); analog_callbacks.answer_polarityswitch(p->chan_pvt);
} }
} }
static void analog_hangup_polarityswitch(struct analog_pvt *p) static void analog_hangup_polarityswitch(struct analog_pvt *p)
{ {
if (p->calls->hangup_polarityswitch) { if (analog_callbacks.hangup_polarityswitch) {
return p->calls->hangup_polarityswitch(p->chan_pvt); analog_callbacks.hangup_polarityswitch(p->chan_pvt);
} }
} }
static int analog_dsp_set_digitmode(struct analog_pvt *p, enum analog_dsp_digitmode mode) static int analog_dsp_set_digitmode(struct analog_pvt *p, enum analog_dsp_digitmode mode)
{ {
if (p->calls->dsp_set_digitmode) { if (analog_callbacks.dsp_set_digitmode) {
return p->calls->dsp_set_digitmode(p->chan_pvt, mode); return analog_callbacks.dsp_set_digitmode(p->chan_pvt, mode);
} }
return -1; return -1;
} }
static void analog_cb_handle_dtmf(struct analog_pvt *p, struct ast_channel *ast, enum analog_sub analog_index, struct ast_frame **dest) static void analog_cb_handle_dtmf(struct analog_pvt *p, struct ast_channel *ast, enum analog_sub analog_index, struct ast_frame **dest)
{ {
if (p->calls->handle_dtmf) { if (analog_callbacks.handle_dtmf) {
p->calls->handle_dtmf(p->chan_pvt, ast, analog_index, dest); analog_callbacks.handle_dtmf(p->chan_pvt, ast, analog_index, dest);
} }
} }
static int analog_wink(struct analog_pvt *p, enum analog_sub index) static int analog_wink(struct analog_pvt *p, enum analog_sub index)
{ {
if (p->calls->wink) { if (analog_callbacks.wink) {
return p->calls->wink(p->chan_pvt, index); return analog_callbacks.wink(p->chan_pvt, index);
} }
return -1; return -1;
} }
static int analog_has_voicemail(struct analog_pvt *p) static int analog_has_voicemail(struct analog_pvt *p)
{ {
if (p->calls->has_voicemail) { if (analog_callbacks.has_voicemail) {
return p->calls->has_voicemail(p->chan_pvt); return analog_callbacks.has_voicemail(p->chan_pvt);
} }
return -1; return -1;
} }
static int analog_is_dialing(struct analog_pvt *p, enum analog_sub index) static int analog_is_dialing(struct analog_pvt *p, enum analog_sub index)
{ {
if (p->calls->is_dialing) { if (analog_callbacks.is_dialing) {
return p->calls->is_dialing(p->chan_pvt, index); return analog_callbacks.is_dialing(p->chan_pvt, index);
} }
return -1; return -1;
} }
@ -779,20 +779,20 @@ static int analog_update_conf(struct analog_pvt *p)
for (x = 0; x < 3; x++) { for (x = 0; x < 3; x++) {
/* Look for three way calls */ /* Look for three way calls */
if ((p->subs[x].allocd) && p->subs[x].inthreeway) { if ((p->subs[x].allocd) && p->subs[x].inthreeway) {
if (p->calls->conf_add) { if (analog_callbacks.conf_add) {
p->calls->conf_add(p->chan_pvt, x); analog_callbacks.conf_add(p->chan_pvt, x);
} }
needconf++; needconf++;
} else { } else {
if (p->calls->conf_del) { if (analog_callbacks.conf_del) {
p->calls->conf_del(p->chan_pvt, x); analog_callbacks.conf_del(p->chan_pvt, x);
} }
} }
} }
ast_debug(1, "Updated conferencing on %d, with %d conference users\n", p->channel, needconf); ast_debug(1, "Updated conferencing on %d, with %d conference users\n", p->channel, needconf);
if (p->calls->complete_conference_update) { if (analog_callbacks.complete_conference_update) {
p->calls->complete_conference_update(p->chan_pvt, needconf); analog_callbacks.complete_conference_update(p->chan_pvt, needconf);
} }
return 0; return 0;
} }
@ -887,8 +887,8 @@ int analog_available(struct analog_pvt *p)
static int analog_stop_callwait(struct analog_pvt *p) static int analog_stop_callwait(struct analog_pvt *p)
{ {
p->callwaitcas = 0; p->callwaitcas = 0;
if (p->calls->stop_callwait) { if (analog_callbacks.stop_callwait) {
return p->calls->stop_callwait(p->chan_pvt); return analog_callbacks.stop_callwait(p->chan_pvt);
} }
return 0; return 0;
} }
@ -896,8 +896,8 @@ static int analog_stop_callwait(struct analog_pvt *p)
static int analog_callwait(struct analog_pvt *p) static int analog_callwait(struct analog_pvt *p)
{ {
p->callwaitcas = p->callwaitingcallerid; p->callwaitcas = p->callwaitingcallerid;
if (p->calls->callwait) { if (analog_callbacks.callwait) {
return p->calls->callwait(p->chan_pvt); return analog_callbacks.callwait(p->chan_pvt);
} }
return 0; return 0;
} }
@ -905,54 +905,53 @@ static int analog_callwait(struct analog_pvt *p)
static void analog_set_callwaiting(struct analog_pvt *p, int callwaiting_enable) static void analog_set_callwaiting(struct analog_pvt *p, int callwaiting_enable)
{ {
p->callwaiting = callwaiting_enable; p->callwaiting = callwaiting_enable;
if (p->calls->set_callwaiting) { if (analog_callbacks.set_callwaiting) {
p->calls->set_callwaiting(p->chan_pvt, callwaiting_enable); analog_callbacks.set_callwaiting(p->chan_pvt, callwaiting_enable);
} }
} }
static void analog_set_cadence(struct analog_pvt *p, struct ast_channel *chan) static void analog_set_cadence(struct analog_pvt *p, struct ast_channel *chan)
{ {
if (p->calls->set_cadence) { if (analog_callbacks.set_cadence) {
return p->calls->set_cadence(p->chan_pvt, &p->cidrings, chan); analog_callbacks.set_cadence(p->chan_pvt, &p->cidrings, chan);
} }
} }
static void analog_set_dialing(struct analog_pvt *p, int is_dialing) static void analog_set_dialing(struct analog_pvt *p, int is_dialing)
{ {
p->dialing = is_dialing; p->dialing = is_dialing;
if (p->calls->set_dialing) { if (analog_callbacks.set_dialing) {
return p->calls->set_dialing(p->chan_pvt, is_dialing); analog_callbacks.set_dialing(p->chan_pvt, is_dialing);
} }
} }
static void analog_set_alarm(struct analog_pvt *p, int in_alarm) static void analog_set_alarm(struct analog_pvt *p, int in_alarm)
{ {
p->inalarm = in_alarm; p->inalarm = in_alarm;
if (p->calls->set_alarm) { if (analog_callbacks.set_alarm) {
return p->calls->set_alarm(p->chan_pvt, in_alarm); analog_callbacks.set_alarm(p->chan_pvt, in_alarm);
} }
} }
static void analog_set_ringtimeout(struct analog_pvt *p, int ringt) static void analog_set_ringtimeout(struct analog_pvt *p, int ringt)
{ {
p->ringt = ringt; p->ringt = ringt;
if (!p->calls->set_ringtimeout) { if (analog_callbacks.set_ringtimeout) {
return; analog_callbacks.set_ringtimeout(p->chan_pvt, ringt);
} }
p->calls->set_ringtimeout(p->chan_pvt, ringt);
} }
static void analog_set_waitingfordt(struct analog_pvt *p, struct ast_channel *ast) static void analog_set_waitingfordt(struct analog_pvt *p, struct ast_channel *ast)
{ {
if (p->calls->set_waitingfordt) { if (analog_callbacks.set_waitingfordt) {
return p->calls->set_waitingfordt(p->chan_pvt, ast); analog_callbacks.set_waitingfordt(p->chan_pvt, ast);
} }
} }
static int analog_check_waitingfordt(struct analog_pvt *p) static int analog_check_waitingfordt(struct analog_pvt *p)
{ {
if (p->calls->check_waitingfordt) { if (analog_callbacks.check_waitingfordt) {
return p->calls->check_waitingfordt(p->chan_pvt); return analog_callbacks.check_waitingfordt(p->chan_pvt);
} }
return 0; return 0;
@ -960,16 +959,15 @@ static int analog_check_waitingfordt(struct analog_pvt *p)
static void analog_set_confirmanswer(struct analog_pvt *p, int flag) static void analog_set_confirmanswer(struct analog_pvt *p, int flag)
{ {
if (!p->calls->set_confirmanswer) { if (analog_callbacks.set_confirmanswer) {
return; analog_callbacks.set_confirmanswer(p->chan_pvt, flag);
} }
p->calls->set_confirmanswer(p->chan_pvt, flag);
} }
static int analog_check_confirmanswer(struct analog_pvt *p) static int analog_check_confirmanswer(struct analog_pvt *p)
{ {
if (p->calls->check_confirmanswer) { if (analog_callbacks.check_confirmanswer) {
return p->calls->check_confirmanswer(p->chan_pvt); return analog_callbacks.check_confirmanswer(p->chan_pvt);
} }
return 0; return 0;
@ -977,34 +975,31 @@ static int analog_check_confirmanswer(struct analog_pvt *p)
static void analog_cancel_cidspill(struct analog_pvt *p) static void analog_cancel_cidspill(struct analog_pvt *p)
{ {
if (!p->calls->cancel_cidspill) { if (analog_callbacks.cancel_cidspill) {
return; analog_callbacks.cancel_cidspill(p->chan_pvt);
} }
p->calls->cancel_cidspill(p->chan_pvt);
} }
static int analog_confmute(struct analog_pvt *p, int mute) static int analog_confmute(struct analog_pvt *p, int mute)
{ {
if (p->calls->confmute) { if (analog_callbacks.confmute) {
return p->calls->confmute(p->chan_pvt, mute); return analog_callbacks.confmute(p->chan_pvt, mute);
} }
return 0; return 0;
} }
static void analog_set_pulsedial(struct analog_pvt *p, int flag) static void analog_set_pulsedial(struct analog_pvt *p, int flag)
{ {
if (!p->calls->set_pulsedial) { if (analog_callbacks.set_pulsedial) {
return; analog_callbacks.set_pulsedial(p->chan_pvt, flag);
} }
p->calls->set_pulsedial(p->chan_pvt, flag);
} }
static int analog_set_linear_mode(struct analog_pvt *p, enum analog_sub sub, int linear_mode) static int analog_set_linear_mode(struct analog_pvt *p, enum analog_sub sub, int linear_mode)
{ {
if (p->calls->set_linear_mode) { if (analog_callbacks.set_linear_mode) {
/* Return provides old linear_mode setting or error indication */ /* Return provides old linear_mode setting or error indication */
return p->calls->set_linear_mode(p->chan_pvt, sub, linear_mode); return analog_callbacks.set_linear_mode(p->chan_pvt, sub, linear_mode);
} }
return -1; return -1;
} }
@ -1012,8 +1007,8 @@ static int analog_set_linear_mode(struct analog_pvt *p, enum analog_sub sub, int
static void analog_set_inthreeway(struct analog_pvt *p, enum analog_sub sub, int inthreeway) static void analog_set_inthreeway(struct analog_pvt *p, enum analog_sub sub, int inthreeway)
{ {
p->subs[sub].inthreeway = inthreeway; p->subs[sub].inthreeway = inthreeway;
if (p->calls->set_inthreeway) { if (analog_callbacks.set_inthreeway) {
p->calls->set_inthreeway(p->chan_pvt, sub, inthreeway); analog_callbacks.set_inthreeway(p->chan_pvt, sub, inthreeway);
} }
} }
@ -1667,35 +1662,31 @@ static int analog_my_getsigstr(struct ast_channel *chan, char *str, const char *
static int analog_handle_notify_message(struct ast_channel *chan, struct analog_pvt *p, int cid_flags, int neon_mwievent) static int analog_handle_notify_message(struct ast_channel *chan, struct analog_pvt *p, int cid_flags, int neon_mwievent)
{ {
if (p->calls->handle_notify_message) { if (analog_callbacks.handle_notify_message) {
p->calls->handle_notify_message(chan, p->chan_pvt, cid_flags, neon_mwievent); analog_callbacks.handle_notify_message(chan, p->chan_pvt, cid_flags, neon_mwievent);
return 0; return 0;
} }
return -1; return -1;
} }
static int analog_increase_ss_count(struct analog_pvt *p) static void analog_increase_ss_count(void)
{ {
if (p->calls->increase_ss_count) { if (analog_callbacks.increase_ss_count) {
p->calls->increase_ss_count(); analog_callbacks.increase_ss_count();
return 0;
} }
return -1;
} }
static int analog_decrease_ss_count(struct analog_pvt *p) static void analog_decrease_ss_count(void)
{ {
if (p->calls->decrease_ss_count) { if (analog_callbacks.decrease_ss_count) {
p->calls->decrease_ss_count(); analog_callbacks.decrease_ss_count();
return 0;
} }
return -1;
} }
static int analog_distinctive_ring(struct ast_channel *chan, struct analog_pvt *p, int idx, int *ringdata) static int analog_distinctive_ring(struct ast_channel *chan, struct analog_pvt *p, int idx, int *ringdata)
{ {
if (p->calls->distinctive_ring) { if (analog_callbacks.distinctive_ring) {
return p->calls->distinctive_ring(chan, p->chan_pvt, idx, ringdata); return analog_callbacks.distinctive_ring(chan, p->chan_pvt, idx, ringdata);
} }
return -1; return -1;
@ -1703,23 +1694,23 @@ static int analog_distinctive_ring(struct ast_channel *chan, struct analog_pvt *
static void analog_get_and_handle_alarms(struct analog_pvt *p) static void analog_get_and_handle_alarms(struct analog_pvt *p)
{ {
if (p->calls->get_and_handle_alarms) { if (analog_callbacks.get_and_handle_alarms) {
return p->calls->get_and_handle_alarms(p->chan_pvt); analog_callbacks.get_and_handle_alarms(p->chan_pvt);
} }
} }
static void *analog_get_bridged_channel(struct analog_pvt *p, struct ast_channel *chan) static void *analog_get_bridged_channel(struct ast_channel *chan)
{ {
if (p->calls->get_sigpvt_bridged_channel) { if (analog_callbacks.get_sigpvt_bridged_channel) {
return p->calls->get_sigpvt_bridged_channel(chan); return analog_callbacks.get_sigpvt_bridged_channel(chan);
} }
return NULL; return NULL;
} }
static int analog_get_sub_fd(struct analog_pvt *p, enum analog_sub sub) static int analog_get_sub_fd(struct analog_pvt *p, enum analog_sub sub)
{ {
if (p->calls->get_sub_fd) { if (analog_callbacks.get_sub_fd) {
return p->calls->get_sub_fd(p->chan_pvt, sub); return analog_callbacks.get_sub_fd(p->chan_pvt, sub);
} }
return -1; return -1;
} }
@ -1775,7 +1766,7 @@ static void *__analog_ss_thread(void *data)
int idx; int idx;
struct ast_callid *callid; struct ast_callid *callid;
analog_increase_ss_count(p); analog_increase_ss_count();
ast_debug(1, "%s %d\n", __FUNCTION__, p->channel); ast_debug(1, "%s %d\n", __FUNCTION__, p->channel);
@ -2323,7 +2314,7 @@ static void *__analog_ss_thread(void *data)
struct analog_pvt *pbridge = NULL; struct analog_pvt *pbridge = NULL;
/* set up the private struct of the bridged one, if any */ /* set up the private struct of the bridged one, if any */
if (nbridge) { if (nbridge) {
pbridge = analog_get_bridged_channel(p, nbridge); pbridge = analog_get_bridged_channel(nbridge);
} }
if (pbridge && ISTRUNK(pbridge)) { if (pbridge && ISTRUNK(pbridge)) {
/* Clear out the dial buffer */ /* Clear out the dial buffer */
@ -2651,7 +2642,7 @@ quit:
if (smdi_msg) { if (smdi_msg) {
ASTOBJ_UNREF(smdi_msg, ast_smdi_md_message_destroy); ASTOBJ_UNREF(smdi_msg, ast_smdi_md_message_destroy);
} }
analog_decrease_ss_count(p); analog_decrease_ss_count();
return NULL; return NULL;
} }
@ -3940,7 +3931,7 @@ void *analog_handle_init_event(struct analog_pvt *i, int event)
} }
struct analog_pvt *analog_new(enum analog_sigtype signallingtype, struct analog_callback *c, void *private_data) struct analog_pvt *analog_new(enum analog_sigtype signallingtype, void *private_data)
{ {
struct analog_pvt *p; struct analog_pvt *p;
@ -3949,7 +3940,6 @@ struct analog_pvt *analog_new(enum analog_sigtype signallingtype, struct analog_
return p; return p;
} }
p->calls = c;
p->outsigmod = ANALOG_SIG_NONE; p->outsigmod = ANALOG_SIG_NONE;
p->sig = signallingtype; p->sig = signallingtype;
p->chan_pvt = private_data; p->chan_pvt = private_data;

@ -239,6 +239,8 @@ struct analog_callback {
int (* const have_progressdetect)(void *pvt); int (* const have_progressdetect)(void *pvt);
}; };
/*! Global analog callbacks to the upper layer. */
extern struct analog_callback analog_callbacks;
struct analog_subchannel { struct analog_subchannel {
@ -254,8 +256,6 @@ struct analog_pvt {
enum analog_sigtype sig; enum analog_sigtype sig;
/* To contain the private structure passed into the channel callbacks */ /* To contain the private structure passed into the channel callbacks */
void *chan_pvt; void *chan_pvt;
/* Callbacks for various functions needed by the analog API */
struct analog_callback *calls;
/* All members after this are giong to be transient, and most will probably change */ /* All members after this are giong to be transient, and most will probably change */
struct ast_channel *owner; /*!< Our current active owner (if applicable) */ struct ast_channel *owner; /*!< Our current active owner (if applicable) */
@ -346,7 +346,7 @@ struct analog_pvt {
int ringt_base; int ringt_base;
}; };
struct analog_pvt *analog_new(enum analog_sigtype signallingtype, struct analog_callback *c, void *private_data); struct analog_pvt *analog_new(enum analog_sigtype signallingtype, void *private_data);
void analog_delete(struct analog_pvt *doomed); void analog_delete(struct analog_pvt *doomed);
void analog_free(struct analog_pvt *p); void analog_free(struct analog_pvt *p);

Loading…
Cancel
Save