diff --git a/pri.c b/pri.c index dda65bf..a36be62 100644 --- a/pri.c +++ b/pri.c @@ -540,28 +540,44 @@ int pri_channel_bridge(q931_call *call1, q931_call *call2) if (!call1 || !call2) return -1; + /* Make sure we have compatible switchtypes */ + if (call1->pri->switchtype != call2->pri->switchtype) + return -1; + /* Check for bearer capability */ if (call1->transcapability != call2->transcapability) return -1; - /* Check to see if calls are on the same PRI dchannel - * Currently only support calls on the same dchannel - */ + + /* Check to see if we're on the same PRI */ if (call1->pri != call2->pri) return -1; - if (call1->pri->switchtype == PRI_SWITCH_LUCENT5E) - return eect_initiate_transfer(call1->pri, call1, call2); - - if (call1->pri->switchtype == PRI_SWITCH_DMS100) - return rlt_initiate_transfer(call1->pri, call1, call2); - - if (call1->pri->switchtype == PRI_SWITCH_QSIG) { - call1->bridged_call = call2; - call2->bridged_call = call1; - return anfpr_initiate_transfer(call1->pri, call1, call2); + switch (call1->pri->switchtype) { + case PRI_SWITCH_NI2: + case PRI_SWITCH_LUCENT5E: + case PRI_SWITCH_ATT4ESS: + if (eect_initiate_transfer(call1->pri, call1, call2)) + return -1; + else + return 0; + break; + case PRI_SWITCH_DMS100: + if (rlt_initiate_transfer(call1->pri, call1, call2)) + return -1; + else + return 0; + break; + case PRI_SWITCH_QSIG: + call1->bridged_call = call2; + call2->bridged_call = call1; + if (anfpr_initiate_transfer(call1->pri, call1, call2)) + return -1; + else + return 0; + break; + default: + return -1; } - - return -1; } int pri_hangup(struct pri *pri, q931_call *call, int cause) diff --git a/pri_facility.c b/pri_facility.c index 32442be..3e03d85 100644 --- a/pri_facility.c +++ b/pri_facility.c @@ -1128,13 +1128,10 @@ int mwi_message_send(struct pri* pri, q931_call *call, struct pri_sr *req, int a /* EECT functions */ int eect_initiate_transfer(struct pri *pri, q931_call *c1, q931_call *c2) { - /* Did all the tests to see if we're on the same PRI and - * are on a compatible switchtype */ - /* TODO */ int i = 0; int res = 0; unsigned char buffer[255] = ""; - unsigned short call_reference = c2->cr; + short call_reference = c2->cr ^ 0x8000; /* Let's do the trickery to make sure the flag is correct */ struct rose_component *comp = NULL, *compstk[10]; int compsp = 0; static unsigned char op_tag[] = { @@ -1147,16 +1144,7 @@ int eect_initiate_transfer(struct pri *pri, q931_call *c1, q931_call *c2) 0x08, }; - buffer[i++] = (ASN1_CONTEXT_SPECIFIC | Q932_PROTOCOL_EXTENSIONS); - /* Interpretation component */ - - ASN1_ADD_SIMPLE(comp, COMP_TYPE_NFE, buffer, i); - ASN1_PUSH(compstk, compsp, comp); - ASN1_ADD_BYTECOMP(comp, (ASN1_CONTEXT_SPECIFIC | ASN1_TAG_0), buffer, i, 0); - ASN1_ADD_BYTECOMP(comp, (ASN1_CONTEXT_SPECIFIC | ASN1_TAG_2), buffer, i, 0); - ASN1_FIXUP(compstk, compsp, buffer, i); - - ASN1_ADD_BYTECOMP(comp, COMP_TYPE_INTERPRETATION, buffer, i, 0); + buffer[i++] = (ASN1_CONTEXT_SPECIFIC | Q932_PROTOCOL_ROSE); ASN1_ADD_SIMPLE(comp, COMP_TYPE_INVOKE, buffer, i); ASN1_PUSH(compstk, compsp, comp);