📄 hmp_test_cpp-c++.cpp
字号:
Koders Code Search: hmp_test.cpp - C++
#include <stdio.h>
#include <conio.h>
#include <fcntl.h>
#include <srllib.h>
#include <dxxxlib.h>
#include <faxlib.h>
#include <dtilib.h>
#include <msilib.h>
#include <dcblib.h>
//#include <scxlib.h>
#include <gcip_defs.h>
#include <gcip.h>
#include <ipmlib.h>
#include <gcipmlib.h>
#define MAX_CHANNELS 2
#define HMP_SIP_PORT 5060
#define USING_V17_PCM_FAX FALSE
#define USING_MODIFY_MODE FALSE
#define USER_DISPLAY "foolbear"
#define USER_AGENT "HMP test"
#define CLI_BACK "back"
#define CLI_QUIT "quit"
#define CLI_QUIT_MSG "HMP test quitting...\n"
#define CLI_HELP "help"
#define CLI_HELP_MSG "%s by %s, please enter the command: \n\
'%s' for make call, '%s' for drop call, \n\
'%s' for blind transfer, '%s' for supervised transfer, \n\
'%s' for play wave file, '%s' for record wave file, '%s' for stop all, \n\
'%s' for send fax, '%s' for receive fax, '%s' for 491 REQUEST PENDING demo, \n\
'%s' for request modify call, \n\
'%s' for registration, '%s' for un-registration, \n\
'%s' for enum device information, '%s' for enum device capabilities', \n\
'%s' for print system status, \n\
'%s' for print this help message, '%s' for quit this test.\n\n"
#define PRINT_CLI_HELP_MSG printf(CLI_HELP_MSG, USER_AGENT, USER_DISPLAY, \
CLI_MAKECALL, CLI_DROPCALL, \
CLI_BLIND_XFER, CLI_SUPER_XFER, \
CLI_PLAYFILE, CLI_RECORDFILE, CLI_STOP, \
CLI_SENDFAX, CLI_RECEIVEFAX, CLI_GLAREFAX, \
CLI_MODIFYCALL, \
CLI_REGISTER, CLI_UNREGISTER, \
CLI_ENUM, CLI_CAPS, CLI_STAT, \
CLI_HELP, CLI_QUIT)
#define CLI_MAKECALL "mc"
#define CLI_DROPCALL "dc"
#define CLI_BLIND_XFER "bx"
#define CLI_SUPER_XFER "sx"
#define CLI_PLAYFILE "pw"
#define CLI_RECORDFILE "rw"
#define CLI_SENDFAX "sf"
#define CLI_RECEIVEFAX "rf"
#define CLI_GLAREFAX "gf"
#define CLI_GLAREFAX_MSG "Be sure Call Connected between channel '0' with '1'.\n"
#define CLI_MODIFYCALL "modify"
#define CLI_STOP "stop"
#define CLI_REGISTER "reg"
#define CLI_UNREGISTER "unreg"
#define CLI_ENUM "enum"
#define CLI_CAPS "caps"
#define CLI_STAT "stat"
#define CLI_REQ_INDEX " index(0-%u,%u): "
#define CLI_REQ_INDEX_DEFAULT 0
#define CLI_REQ_INDEX_2ND " index 2nd(0-%u,%u): "
#define CLI_REQ_INDEX_2ND_DEFAULT 1
#define CLI_REQ_ANI " ani(%s): "
#define CLI_REQ_ANI_DEFAULT "30@192.168.101.30"
#define CLI_REQ_DNIS " dnis(%s): "
#define CLI_REQ_DNIS_DEFAULT "31@192.168.101.30"
#define CLI_REQ_DNIS_ALIAS " dnis alias(%s): "
#define CLI_REQ_DNIS_ALIAS_DEFAULT "31"
#define CLI_REQ_WAVE_FILE " wave file(%s): "
#define CLI_REQ_WAVE_FILE_DEFAULT "play.wav"
#define CLI_REQ_FAX_FILE " fax file(%s): "
#define CLI_REQ_FAX_FILE_DEFAULT "fax.tif"
#define CLI_REQ_CONFIRM " confirm?(%s): "
#define CLI_REQ_CONFIRM_DEFAULT "Y"
#define CLI_REQ_PROXY_IP " proxy(%s): "
#define CLI_REQ_PROXY_IP_DEFAULT "192.168.101.58"
#define CLI_REQ_LOCAL_IP " local(%s): "
#define CLI_REQ_LOCAL_IP_DEFAULT "192.168.101.30"
#define CLI_REQ_ALIAS " alias(%s): "
#define CLI_REQ_ALIAS_DEFAULT "30"
#define CLI_REQ_PASSWORD " password(%s): "
#define CLI_REQ_PASSWORD_DEFAULT "30"
#define CLI_REQ_REALM " realm(%s): "
#define CLI_REQ_REALM_DEFAULT "ewings"
class CHANNEL;
long board_dev = 0;
BOOL registered = FALSE;
CHANNEL* channls[MAX_CHANNELS] = {0};
char proxy_ip[GC_ADDRSIZE] = "";
char local_ip[GC_ADDRSIZE] = "";
char alias[GC_ADDRSIZE] = "";
char password[GC_ADDRSIZE] = "";
char realm[GC_ADDRSIZE] = "";
ALARM_PARM_LIST alarm_parm_list;
IPM_QOS_THRESHOLD_INFO iqti;
void enum_support_capabilities();
int get_idle_channel_id();
void authentication(const char* proxy_ip, const char* alias, const char* password, const char* realm);
class CHANNEL{
public:
long gc_dev;
int vox_dev;
int fax_dev;
int ipm_dev;
long gc_xslot;
long ipm_xslot;
long vox_xslot;
long fax_xslot;
DV_TPT tpt;
DX_XPB xpb;
DX_IOTT vox_iott;
DF_IOTT fax_iott;
int fax_dir;
char fax_file[MAX_PATH];
CRN crn;
GCLIB_ADDRESS_BLK* rerouting_addrblkp;
int super_xfer_primary_ch_index;
int id;
BOOL fax_proceeding;
BOOL already_connect_fax;
CHANNEL(int index) {id = index; already_connect_fax = FALSE; fax_proceeding = FALSE;}
void open() {
print("open()...");
char dev_name[64] = "";
long request_id = 0;
GC_PARM_BLKP gc_parm_blkp = NULL;
sprintf(dev_name, "dxxxB1C%d", id+1);
vox_dev = dx_open(dev_name, NULL);
dx_setevtmsk(vox_dev, DM_RINGS|DM_DIGITS|DM_LCOF);
sprintf(dev_name, "dxxxB2C%d", id+1);
fax_dev = fx_open(dev_name, NULL);
sprintf(dev_name, ":N_iptB1T%d:P_SIP:M_ipmB1C%d", id+1, id+1);
gc_OpenEx(&gc_dev, dev_name, EV_ASYNC, (void*)this);
//Enabling GCEV_INVOKE_XFER_ACCEPTED Events
gc_util_insert_parm_val(&gc_parm_blkp, GCSET_CALLEVENT_MSK, GCACT_ADDMSK, sizeof(long), GCMSK_INVOKEXFER_ACCEPTED);
gc_SetConfigData(GCTGT_GCLIB_CHAN, gc_dev, gc_parm_blkp, 0, GCUPDATE_IMMEDIATE, &request_id, EV_SYNC);
gc_util_delete_parm_blk(gc_parm_blkp);
}
void connect_voice() {
print("connect_voice()...");
SC_TSINFO sc_tsinfo;
gc_GetResourceH(gc_dev, &ipm_dev, GC_MEDIADEVICE);
sc_tsinfo.sc_numts = 1;
sc_tsinfo.sc_tsarrayp = &gc_xslot;
gc_GetXmitSlot(gc_dev, &sc_tsinfo);
dx_listenEx(vox_dev, &sc_tsinfo, EV_SYNC);
sc_tsinfo.sc_numts = 1;
sc_tsinfo.sc_tsarrayp = &vox_xslot;
dx_getxmitslot(vox_dev, &sc_tsinfo);
gc_Listen(gc_dev, &sc_tsinfo, EV_SYNC);
sc_tsinfo.sc_numts = 1;
sc_tsinfo.sc_tsarrayp = &ipm_xslot;
ipm_GetXmitSlot(ipm_dev, &sc_tsinfo, EV_SYNC);
sc_tsinfo.sc_numts = 1;
sc_tsinfo.sc_tsarrayp = &fax_xslot;
fx_getxmitslot(fax_dev, &sc_tsinfo);
}
void connect_fax() {
SC_TSINFO sc_tsinfo;
print("connect_fax()...");
gc_UnListen(gc_dev, EV_SYNC);
if (TRUE == USING_V17_PCM_FAX) {
sc_tsinfo.sc_numts = 1;
sc_tsinfo.sc_tsarrayp = &gc_xslot;
fx_listen(fax_dev, &sc_tsinfo);
sc_tsinfo.sc_numts = 1;
sc_tsinfo.sc_tsarrayp = &fax_xslot;
gc_Listen(gc_dev, &sc_tsinfo, EV_SYNC);
} else {
GC_PARM_BLKP gc_parm_blkp = NULL;
IP_CONNECT ip_connect;
ip_connect.version = 0x100;
ip_connect.mediaHandle = ipm_dev;
ip_connect.faxHandle = fax_dev;
ip_connect.connectType = IP_FULLDUP;
gc_util_insert_parm_ref(&gc_parm_blkp, IPSET_FOIP, IPPARM_T38_CONNECT, sizeof(IP_CONNECT), (void*)(&ip_connect));
gc_SetUserInfo(GCTGT_GCLIB_CRN, crn, gc_parm_blkp, GC_SINGLECALL);
gc_util_delete_parm_blk(gc_parm_blkp);
}
}
void restore_voice() {
SC_TSINFO sc_tsinfo;
print("restore_voice()...");
if (TRUE == USING_V17_PCM_FAX) {
gc_UnListen(gc_dev, EV_SYNC);
}
sc_tsinfo.sc_numts = 1;
sc_tsinfo.sc_tsarrayp = &vox_xslot;
gc_Listen(gc_dev, &sc_tsinfo, EV_SYNC);
sc_tsinfo.sc_numts = 1;
sc_tsinfo.sc_tsarrayp = &gc_xslot;
dx_listenEx(vox_dev, &sc_tsinfo, EV_SYNC);
if (TRUE != USING_V17_PCM_FAX) {
IP_CONNECT ip_connect;
GC_PARM_BLKP gc_parm_blkp = NULL;
ip_connect.version = 0x100;
ip_connect.mediaHandle = ipm_dev;
gc_util_insert_parm_ref(&gc_parm_blkp, IPSET_FOIP, IPPARM_T38_DISCONNECT, sizeof(IP_CONNECT), (void*)(&ip_connect));
gc_SetUserInfo(GCTGT_GCLIB_CRN, crn, gc_parm_blkp, GC_SINGLECALL);
gc_util_delete_parm_blk(gc_parm_blkp);
}
}
void set_dtmf() {
print("set_dtmf()...");
GC_PARM_BLKP parmblkp = NULL;
gc_util_insert_parm_val(&parmblkp, IPSET_DTMF, IPPARM_SUPPORT_DTMF_BITMASK,
sizeof(char), IP_DTMF_TYPE_RFC_2833);
gc_util_insert_parm_val(&parmblkp, IPSET_DTMF, IPPARM_DTMF_RFC2833_PAYLOAD_TYPE,
sizeof(char), IP_USE_STANDARD_PAYLOADTYPE);
gc_SetUserInfo(GCTGT_GCLIB_CHAN, gc_dev, parmblkp, GC_ALLCALLS);
gc_util_delete_parm_blk(parmblkp);
}
void wait_call() {
print("wait_call()...");
print_gc_error_info("gc_WaitCall", gc_WaitCall(gc_dev, NULL, NULL, 0, EV_ASYNC));
}
void print_offer_info(METAEVENT meta_evt) {
char ani[255] = "";
char dnis[255] = "";
int protocol = CALLPROTOCOL_H323;
GC_PARM_BLKP gc_parm_blkp = (GC_PARM_BLKP)(meta_evt.extevtdatap);
GC_PARM_DATAP gc_parm_datap = NULL;
CRN secondary_crn = 0;
char transferring_addr[GC_ADDRSIZE] = "";
gc_GetCallInfo(crn, ORIGINATION_ADDRESS, ani);
gc_GetCallInfo(crn, DESTINATION_ADDRESS, dnis);
gc_GetCallInfo(crn, CALLPROTOCOL, (char*)&protocol);
print("%s got %s offer from %s",
dnis, protocol==CALLPROTOCOL_H323?"H323":"SIP", ani);
while (gc_parm_datap = gc_util_next_parm(gc_parm_blkp, gc_parm_datap)) {
if (GCSET_SUPP_XFER == gc_parm_datap->set_ID) {
switch (gc_parm_datap->parm_ID) {
case GCPARM_SECONDARYCALL_CRN:
memcpy(&secondary_crn, gc_parm_datap->value_buf, gc_parm_datap->value_size);
print(" GCPARM_SECONDARYCALL_CRN: 0x%x", secondary_crn);
break;
case GCPARM_TRANSFERRING_ADDR:
memcpy(transferring_addr, gc_parm_datap->value_buf, gc_parm_datap->value_size);
print(" GCPARM_TRANSFERRING_ADDR: %s", transferring_addr);
break;
default:
break;
}
}
}
}
void print_call_status(METAEVENT meta_evt) {
GC_INFO call_status_info = {0};
gc_ResultInfo(&meta_evt, &call_status_info);
print("CALLSTATUS Info: \n GC InfoValue:0x%hx-%s,\n CCLibID:%i-%s, CC InfoValue:0x%lx-%s,\n Additional Info:%s",
call_status_info.gcValue, call_status_info.gcMsg,
call_status_info.ccLibId, call_status_info.ccLibName,
call_status_info.ccValue, call_status_info.ccMsg,
call_status_info.additionalInfo);
}
void print_gc_error_info(const char* func_name, int func_return) {
GC_INFO gc_error_info;
if (GC_ERROR == func_return) {
gc_ErrorInfo(&gc_error_info);
print("%s return %d, GC ErrorValue:0x%hx-%s,\n CCLibID:%i-%s, CC ErrorValue:0x%lx-%s,\n Additional Info:%s",
func_name, func_return, gc_error_info.gcValue, gc_error_info.gcMsg,
gc_error_info.ccLibId, gc_error_info.ccLibName,
gc_error_info.ccValue, gc_error_info.ccMsg,
gc_error_info.additionalInfo);
}
}
void print_r4_error_info(const char* func_name, int dev, int func_return) {
long lasterr = 0;
if (-1 == func_return) {
lasterr = ATDV_LASTERR(dev);
if (EDX_SYSTEM == lasterr) {
print("%s return %d, dev=0x%lX, ATDV_LASTERR=%d[SYSTEM ERROR], errno=%d\n ATDV_ERRMSGP=%s",
func_name, func_return, dev, lasterr, errno, ATDV_ERRMSGP(dev));
} else if (EDX_BADPARM == lasterr) {
print("%s return %d, dev=0x%lX, ATDV_LASTERR=%d[BAD PARAMETER]\n ATDV_ERRMSGP=%s",
func_name, func_return, dev, lasterr, ATDV_ERRMSGP(dev));
} else {
print("%s return %d, dev=0x%lX, ATDV_LASTERR=%d\n ATDV_ERRMSGP=%s",
func_name, func_return, dev, lasterr, ATDV_ERRMSGP(dev));
}
}
}
void ack_call() {
GC_CALLACK_BLK gc_callack_blk;
memset(&gc_callack_blk, 0, sizeof(GC_CALLACK_BLK));
gc_callack_blk.type = GCACK_SERVICE_PROC;
print("ack_call()...");
print_gc_error_info("gc_CallAck", gc_CallAck(crn, &gc_callack_blk, EV_ASYNC));
}
void accept_call() {
print("accept_call()...");
print_gc_error_info("gc_AcceptCall", gc_AcceptCall(crn, 0, EV_ASYNC));
}
void answer_call() {
print("answer_call()...");
set_codec(GCTGT_GCLIB_CRN);
print_gc_error_info("gc_AnswerCall", gc_AnswerCall(crn, 0, EV_ASYNC));
}
void make_call(const char* ani, const char* dnis) {
GC_PARM_BLKP gc_parm_blkp = NULL;
GC_MAKECALL_BLK gc_mk_blk = {0};
GCLIB_MAKECALL_BLK gclib_mk_blk = {0};
char sip_header[1024] = "";
print("make_call(%s -> %s)...", ani, dnis);
gc_mk_blk.cclib = NULL;
gc_mk_blk.gclib = &gclib_mk_blk;
sprintf(sip_header, "User-Agent: %s", USER_AGENT); //proprietary header
gc_util_insert_parm_ref_ex(&gc_parm_blkp, IPSET_SIP_MSGINFO, IPPARM_SIP_HDR, (unsigned long)(strlen(sip_header)+1), sip_header);
sprintf(sip_header, "From: %s<sip:%s>", USER_DISPLAY, ani); //From header
gc_util_insert_parm_ref_ex(&gc_parm_blkp, IPSET_SIP_MSGINFO, IPPARM_SIP_HDR, (unsigned long)(strlen(sip_header)+1), sip_header);
sprintf(sip_header, "Contact: %s<sip:%s:%d>", USER_DISPLAY, ani, HMP_SIP_PORT); //Contact header
gc_util_insert_parm_ref_ex(&gc_parm_blkp, IPSET_SIP_MSGINFO, IPPARM_SIP_HDR, (unsigned long)(strlen(sip_header)+1), sip_header);
gc_SetUserInfo(GCTGT_GCLIB_CHAN, gc_dev, gc_parm_blkp, GC_SINGLECALL);
gc_util_delete_parm_blk(gc_parm_blkp);
gc_util_insert_parm_val(&gc_parm_blkp, IPSET_PROTOCOL, IPPARM_PROTOCOL_BITMASK, sizeof(int), IP_PROTOCOL_SIP);
gclib_mk_blk.ext_datap = gc_parm_blkp;
set_codec(GCTGT_GCLIB_CHAN);
print_gc_error_info("gc_MakeCall", gc_MakeCall(gc_dev, &crn, (char*)dnis, &gc_mk_blk, 30, EV_ASYNC));
gc_util_delete_parm_blk(gc_parm_blkp);
}
void make_call(const char* dnis_alias) {
GC_PARM_BLKP gc_parm_blkp = NULL;
GC_MAKECALL_BLK gc_mk_blk = {0};
GCLIB_MAKECALL_BLK gclib_mk_blk = {0};
char sip_header[1024] = "";
char ani[MAX_ADDRESS_LEN] = "";
char dnis[MAX_ADDRESS_LEN] = "";
char contact[MAX_ADDRESS_LEN] = "";
authentication(proxy_ip, alias, password, realm);
sprintf(ani, "%s@%s", alias, proxy_ip);
sprintf(dnis, "%s@%s", dnis_alias, proxy_ip);
sprintf(contact, "%s@%s", alias, local_ip);
print("make_call(%s -> %s -> %s)...", ani, proxy_ip, dnis);
gc_mk_blk.cclib = NULL;
gc_mk_blk.gclib = &gclib_mk_blk;
sprintf(sip_header, "User-Agent: %s", USER_AGENT); //proprietary header
gc_util_insert_parm_ref_ex(&gc_parm_blkp, IPSET_SIP_MSGINFO, IPPARM_SIP_HDR, (unsigned long)(strlen(sip_header)+1), sip_header);
sprintf(sip_header, "From: %s<sip:%s>", USER_DISPLAY, ani); //From header
gc_util_insert_parm_ref_ex(&gc_parm_blkp, IPSET_SIP_MSGINFO, IPPARM_SIP_HDR, (unsigned long)(strlen(sip_header)+1), sip_header);
sprintf(sip_header, "Contact: %s<sip:%s:%d>", USER_DISPLAY, contact, HMP_SIP_PORT); //Contact header
gc_util_insert_parm_ref_ex(&gc_parm_blkp, IPSET_SIP_MSGINFO, IPPARM_SIP_HDR, (unsigned long)(strlen(sip_header)+1), sip_header);
gc_SetUserInfo(GCTGT_GCLIB_CHAN, gc_dev, gc_parm_blkp, GC_SINGLECALL);
gc_util_delete_parm_blk(gc_parm_blkp);
gc_util_insert_parm_val(&gc_parm_blkp, IPSET_PROTOCOL, IPPARM_PROTOCOL_BITMASK, sizeof(int), IP_PROTOCOL_SIP);
gclib_mk_blk.ext_datap = gc_parm_blkp;
set_codec(GCTGT_GCLIB_CHAN);
print_gc_error_info("gc_MakeCall", gc_MakeCall(gc_dev, &crn, (char*)dnis, &gc_mk_blk, 30, EV_ASYNC));
gc_util_delete_parm_blk(gc_parm_blkp);
}
void drop_call() {
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -