Skip to content

F
freeswitch-contrib
提交 b23ec880 authored 作者: João Mesquita's avatar João Mesquita
浏览文件
操作

* Added the KChannel -> session relationship so I always know what is what 

* Added handlers for almost all events sent by the board
* Cleaned up the code a little bit more


git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk/scripts/contrib@13778 d0543943-73ff-0310-b7d9-9358b9ac24b2
上级 07073e9c
隐藏空白字符变更
内嵌 并排
正在显示 包含 289 行增加 和 123 行删除
jmesquita/mod_khomp/Makefile
浏览文件 @ b23ec880
MODNAME=mod_khomp
LOCAL_CFLAGS=-I./include -I./commons/include -lk3l -D_REENTRANT -D_GNU_SOURCE -D_FILE_OFFSET_BITS=64 -D_LARGEFILE_SOURCE -DK3L_HOSTSYSTEM -DKHOMP_COMMONS_WITH_CHANNEL
LOCAL_CFLAGS=-I./include -I./commons/include -lk3l -D_REENTRANT -D_GNU_SOURCE -D_FILE_OFFSET_BITS=64 -D_LARGEFILE_SOURCE -DK3L_HOSTSYSTEM
LOCAL_OBJS= ./commons/k3lapi.o
......
jmesquita/mod_khomp/commons/include/k3lapi.hpp
浏览文件 @ b23ec880
#include <string>
#include <k3l.h>
#ifndef KHOMP_COMMONS_WITH_CHANNEL
# include <k3lVersion.h>
#endif
#include <k3lVersion.h>
#ifdef __GNUC_PREREQ
#if __GNUC_PREREQ(4,3)
......@@ -15,6 +12,12 @@
#ifndef INCLUDED_K3LAPI_HPP
#define INCLUDED_K3LAPI_HPP
/* FreeSWITCH include */
extern "C" {
#include "switch.h"
}
struct K3LAPI
{
/* exceptions */
......@@ -78,12 +81,29 @@ struct K3LAPI
std::string name;
KLibraryStatus rc;
};
struct KChannel {
public:
KChannel() : _session(NULL){};
void setSession(switch_core_session_t * session)
{
_session = session;
}
switch_core_session_t * getSession()
{
return _session;
}
protected:
switch_core_session_t * _session;
};
typedef K3L_DEVICE_CONFIG device_conf_type;
typedef K3L_CHANNEL_CONFIG channel_conf_type;
typedef K3L_CHANNEL_CONFIG * channel_ptr_conf_type;
typedef K3L_LINK_CONFIG link_conf_type;
typedef K3L_LINK_CONFIG * link_ptr_conf_type;
typedef KChannel KChannel_t;
typedef KChannel_t * KChannel_ptr_t;
/* constructors/destructors */
......@@ -186,12 +206,27 @@ struct K3LAPI
void init(void);
void setSession(unsigned int boardId, unsigned int chanId, switch_core_session_t * session)
{
if (!valid_channel(boardId, chanId))
throw invalid_channel(boardId, chanId);
_KChannel[boardId][chanId].setSession(session);
}
switch_core_session_t * getSession(unsigned int boardId, unsigned int chanId)
{
if (!valid_channel(boardId, chanId))
throw invalid_channel(boardId, chanId);
return _KChannel[boardId][chanId].getSession();
}
protected:
unsigned int _device_count;
unsigned int * _channel_count;
unsigned int * _link_count;
unsigned int _device_count;
unsigned int * _channel_count;
unsigned int * _link_count;
KChannel_ptr_t * _KChannel;
device_conf_type * _device_config;
channel_ptr_conf_type * _channel_config;
link_ptr_conf_type * _link_config;
......
jmesquita/mod_khomp/commons/k3lapi.cpp
浏览文件 @ b23ec880
......@@ -22,7 +22,7 @@ K3LAPI::~K3LAPI()
void K3LAPI::start(void)
{
/* tie the used k3l to the compiled k3l version */
char *ret = k3lStart(k3lApiMajorVersion, k3lApiMinorVersion, 0); //k3lApiBuildVersion);
char *ret = k3lStart(2, 0, 0); //k3lApiMajorVersion, k3lApiMinorVersion, 0); //k3lApiBuildVersion);
if (ret && *ret)
throw start_failed(ret);
......@@ -129,6 +129,7 @@ void K3LAPI::init(void)
_device_type = new KDeviceType[_device_count];
_device_config = new device_conf_type[_device_count];
_channel_config = new channel_ptr_conf_type[_device_count];
_KChannel = new KChannel_ptr_t[_device_count];
_link_config = new link_ptr_conf_type[_device_count];
_channel_count = new unsigned int[_device_count];
_link_count = new unsigned int[_device_count];
......@@ -147,12 +148,15 @@ void K3LAPI::init(void)
/* caches each channel config */
_channel_config[dev] = new channel_conf_type[_channel_count[dev]];
_KChannel[dev] = new KChannel_t[_channel_count[dev]];
for (unsigned int obj = 0; obj < _channel_count[dev]; obj++)
{
if (k3lGetDeviceConfig(dev, ksoChannel + obj, &(_channel_config[dev][obj]),
sizeof(_channel_config[dev][obj])) != ksSuccess)
{
throw start_failed("k3lGetDeviceConfig(channel)");
}
}
/* adjust link count for device */
......
jmesquita/mod_khomp/include/k3lVersion.h 0 → 100644
浏览文件 @ b23ec880
#ifndef k3lVersion_h
#define k3lVersion_h
#define k3lApiMajorVersion 2
#define k3lApiMinorVersion 0
#define k3lApiBuildVersion 0
#endif
jmesquita/mod_khomp/mod_khomp.cpp
浏览文件 @ b23ec880
......@@ -98,9 +98,8 @@ struct private_object {
switch_mutex_t *mutex;
switch_mutex_t *flag_mutex;
//switch_thread_cond_t *cond;
unsigned int Kdevice; // Represent de board we are making the call from
unsigned int Klink; // Represent the link we are making the call from
unsigned int Kchannel; // Represent the channel we are making the call from
unsigned int KDeviceId; // Represent de board we are making the call from
unsigned int KChannel; // Represent the channel we are making the call from
};
typedef struct private_object private_t;
......@@ -128,8 +127,8 @@ static switch_status_t channel_write_frame(switch_core_session_t *session, switc
static switch_status_t channel_kill_channel(switch_core_session_t *session, int sig);
/* Helper function prototypes */
static void printSystemSummary(switch_stream_handle_t*);
static const char* linkStatus(unsigned int device, unsigned int link);
static void printSystemSummary(switch_stream_handle_t* stream);
static void printLinks(switch_stream_handle_t* stream, unsigned int device, unsigned int link);
static void printChannels(switch_stream_handle_t* stream, unsigned int device, unsigned int link);
/* Handles callbacks and events from the boards */
static int32 Kstdcall EventCallBack(int32 obj, K3L_EVENT * e);
......@@ -268,7 +267,7 @@ static switch_status_t channel_on_hangup(switch_core_session_t *session)
}
try {
k3l->command(tech_pvt->Kdevice, tech_pvt->Kchannel, CM_DISCONNECT, NULL);
k3l->command(tech_pvt->KDeviceId, tech_pvt->KChannel, CM_DISCONNECT, NULL);
}
catch(K3LAPI::failed_command & e)
{
......@@ -352,8 +351,6 @@ static switch_status_t channel_read_frame(switch_core_session_t *session, switch
tech_pvt->read_frame.flags = SFF_NONE;
*frame = NULL;
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Are we being called?");
while (switch_test_flag(tech_pvt, TFLAG_IO)) {
......@@ -403,8 +400,6 @@ static switch_status_t channel_write_frame(switch_core_session_t *session, switc
private_t *tech_pvt = NULL;
//switch_frame_t *pframe;
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Are we being called?");
channel = switch_core_session_get_channel(session);
assert(channel != NULL);
......@@ -436,8 +431,6 @@ static switch_status_t channel_answer_channel(switch_core_session_t *session)
tech_pvt = static_cast<private_t*>(switch_core_session_get_private(session));
assert(tech_pvt != NULL);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "When the fuck is this called?.\n");
return SWITCH_STATUS_SUCCESS;
}
......@@ -476,7 +469,7 @@ static switch_call_cause_t channel_outgoing_channel(switch_core_session_t *sessi
switch_core_session_t **new_session, switch_memory_pool_t **pool, switch_originate_flag_t flags)
{
char *argv[4] = { 0 };
char *argv[3] = { 0 };
int argc = 0;
if ((*new_session = switch_core_session_request(khomp_endpoint_interface, SWITCH_CALL_DIRECTION_OUTBOUND, pool)) != 0) {
......@@ -501,20 +494,19 @@ static switch_call_cause_t channel_outgoing_channel(switch_core_session_t *sessi
switch_channel_set_name(channel, name);
/* Let's setup our own vars on tech_pvt */
if ((argc = switch_separate_string(outbound_profile->destination_number, '/', argv, (sizeof(argv) / sizeof(argv[0])))) < 4)
if ((argc = switch_separate_string(outbound_profile->destination_number, '/', argv, (sizeof(argv) / sizeof(argv[0])))) < 3)
{
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Invalid dial string. Should be on the format:[Khomp/BOARD/LINK/CHANNEL]\n");
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Invalid dial string. Should be on the format:[Khomp/BOARD/CHANNEL]\n");
return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER;
}
else
{
tech_pvt->Kdevice = atoi(argv[0]);
tech_pvt->Klink = atoi(argv[1]);
tech_pvt->Kchannel = atoi(argv[2]);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Dialing out from Board:%d, Link:%d, Channel:%d.\n",
tech_pvt->Kdevice,
tech_pvt->Klink,
tech_pvt->Kchannel);
tech_pvt->KDeviceId = atoi(argv[0]);
tech_pvt->KChannel = atoi(argv[1]);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Dialing to %s out from Board:%u, Channel:%u.\n",
argv[2],
tech_pvt->KDeviceId,
tech_pvt->KChannel);
}
......@@ -524,6 +516,8 @@ static switch_call_cause_t channel_outgoing_channel(switch_core_session_t *sessi
} else {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Doh! no caller profile\n");
switch_core_session_destroy(new_session);
/* Destroy the channel session */
k3l->setSession(tech_pvt->KDeviceId, tech_pvt->KChannel, NULL);
return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER;
}
......@@ -536,9 +530,9 @@ static switch_call_cause_t channel_outgoing_channel(switch_core_session_t *sessi
try {
/* Lets make the call! */
char params[ 255 ];
sprintf(params, "dest_addr=\"%s\"", argv[3]);
sprintf(params, "dest_addr=\"%s\"", argv[2]);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "We are calling with params: %s.\n", params);
k3l->command(tech_pvt->Kdevice,tech_pvt->Kchannel, CM_MAKE_CALL, params);
k3l->command(tech_pvt->KDeviceId,tech_pvt->KChannel, CM_MAKE_CALL, params);
}
catch(K3LAPI::failed_command & e)
{
......@@ -546,6 +540,9 @@ static switch_call_cause_t channel_outgoing_channel(switch_core_session_t *sessi
return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER;
}
/* Add the new session the the channel's info */
k3l->setSession(tech_pvt->KDeviceId, tech_pvt->KChannel, *new_session);
return SWITCH_CAUSE_SUCCESS;
}
......@@ -718,6 +715,7 @@ SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_khomp_shutdown)
/*
khomp API definition
TODO: Add as xml modifier
*/
SWITCH_STANDARD_API(khomp)
{
......@@ -748,23 +746,12 @@ SWITCH_STANDARD_API(khomp)
}
/* Show all the links and their status */
if (argv[1] && !strncasecmp(argv[1], "links", 5)) {
for(int device=0 ; device < k3l->device_count() ; device++)
{
stream->write_function(stream, "___________________________________________\n");
stream->write_function(stream, "|--------------Khomp Links----------------|\n");
stream->write_function(stream, "|----Board----|----Link----|----Status----|\n");
for(int link=0 ; link < k3l->link_count(device) ; link++)
{
stream->write_function(stream, "|%13d|%12d|%s|\n"
, device
, link
, linkStatus(device, link));
}
}
stream->write_function(stream, "-------------------------------------------\n");
/* TODO: Let show specific boards/links */
printLinks(stream, NULL, NULL);
}
// Show all channels from all boards and all links
if (argv[1] && !strncasecmp(argv[1], "channels", 8)) {
/* TODO: Let show specific channels */
printChannels(stream, NULL, NULL);
}
......@@ -799,34 +786,16 @@ static void printChannels(switch_stream_handle_t* stream, unsigned int device, u
stream->write_function(stream, "Damn, again something bad happened.\n");
return;
}
switch(status.AddInfo) {
case kecsFree:
switch(status.CallStatus) {
case kcsFree:
stream->write_function(stream, "| %6u| %8u| Free |\n", board, channel);
break;
case kecsBusy:
stream->write_function(stream, "| %6u| %8u| Busy |\n", board, channel);
break;
case kecsOutgoing:
case kcsOutgoing:
stream->write_function(stream, "| %6u| %8u| Outgoing |\n", board, channel);
break;
case kecsIncoming:
case kcsIncoming:
stream->write_function(stream, "| %6u| %8u| Incoming |\n", board, channel);
break;
case kecsLocked:
stream->write_function(stream, "| %6u| %8u| Locked |\n", board, channel);
break;
case kecsOutgoingLock:
stream->write_function(stream, "| %6u| %8u| OutgoingLock |\n", board, channel);
break;
case kecsLocalFail:
stream->write_function(stream, "| %6u| %8u| LocalFail |\n", board, channel);
break;
case kecsIncomingLock:
stream->write_function(stream, "| %6u| %8u| IncomingLock |\n", board, channel);
break;
case kecsRemoteLock:
stream->write_function(stream, "| %6u| %8u| RemoteLock |\n", board, channel);
break;
default:
stream->write_function(stream, "| %6u| %8u| UNKNOWN : %x |\n", board, channel, status.AddInfo);
}
......@@ -837,60 +806,98 @@ static void printChannels(switch_stream_handle_t* stream, unsigned int device, u
}
}
static const char * linkStatus(unsigned int device, unsigned int link)
static void printLinks(switch_stream_handle_t* stream, unsigned int device, unsigned int link)
{
K3L_LINK_CONFIG & config = k3l->link_config(device, link);
K3L_LINK_STATUS status;
KLibraryStatus ret = (KLibraryStatus) k3lGetDeviceStatus (device, link + ksoLink, &status, sizeof(status));
stream->write_function(stream, "___________________________________________\n");
stream->write_function(stream, "|--------------Khomp Links----------------|\n");
stream->write_function(stream, "|----Board----|----Link----|----Status----|\n");
if (ret == ksSuccess)
{
switch (config.Signaling)
// We want to see all links from all devices
if (!device) {
for(int device=0 ; device < k3l->device_count() ; device++)
{
case ksigInactive:
return "[ksigInactive]";
case ksigAnalog:
return "[ksigAnalog]";
case ksigSIP:
return "[ksigSIP]";
case ksigOpenCAS:
case ksigOpenR2:
case ksigR2Digital:
case ksigUserR2Digital:
case ksigOpenCCS:
case ksigPRI_EndPoint:
case ksigPRI_Network:
case ksigPRI_Passive:
case ksigLineSide:
case ksigCAS_EL7:
case ksigAnalogTerminal:
if (kesOk == status.E1)
{
return "kesOk";
}
else
{
if (kesSignalLost & status.E1) return "SignalLost";
if (kesNetworkAlarm & status.E1) return "NetworkAlarm";
if (kesFrameSyncLost & status.E1) return "FrameSyncLost";
if (kesMultiframeSyncLost & status.E1) return "MultiframeSyncLost";
if (kesRemoteAlarm & status.E1) return "RemoteAlarm";
if (kesHighErrorRate & status.E1) return "HighErrorRate";
if (kesUnknownAlarm & status.E1) return "UnknownAlarm";
if (kesE1Error & status.E1) return "E1Error";
K3L_LINK_CONFIG & config = k3l->link_config(device, link);
K3L_LINK_STATUS status;
for(int link=0 ; link < k3l->link_count(device) ; link++)
{
const char * E1Status = "";
if (k3lGetDeviceStatus (device, link + ksoLink, &status, sizeof(status)) == ksSuccess)
{
switch (config.Signaling)
{
case ksigInactive:
E1Status = "[ksigInactive]";
break;
case ksigAnalog:
E1Status = "[ksigAnalog]";
break;
case ksigSIP:
E1Status = "[ksigSIP]";
break;
case ksigOpenCAS:
case ksigOpenR2:
case ksigR2Digital:
case ksigUserR2Digital:
case ksigOpenCCS:
case ksigPRI_EndPoint:
case ksigPRI_Network:
case ksigPRI_Passive:
case ksigLineSide:
case ksigCAS_EL7:
case ksigAnalogTerminal:
switch (status.E1) {
case (kesOk):
E1Status = "kesOk";
break;
case (kesSignalLost):
E1Status = "kesSignalLost";
break;
case (kesNetworkAlarm):
E1Status = "kesNetworkAlarm";
break;
case (kesFrameSyncLost):
E1Status = "kesFrameSyncLost";
break;
case (kesMultiframeSyncLost):
E1Status = "kesMultiframeSyncLost";
break;
case (kesRemoteAlarm):
E1Status = "kesRemoteAlarm";
break;
case (kesHighErrorRate):
E1Status = "kesHighErrorRate";
break;
case (kesUnknownAlarm):
E1Status = "kesUnknownAlarm";
break;
case (kesE1Error):
E1Status = "kesE1Error";
break;
case (kesNotInitialized):
E1Status = "kesNotInitialized";
break;
default:
E1Status = "UnknownE1Status";
}
break;
default:
E1Status = "NotImplementedBoard";
}
}
default:
return "NotImplementedBoard";
stream->write_function(stream, "|%13d|%12d|%s|\n"
, device
, link
, E1Status);
}
}
}
return "<unknown>";
stream->write_function(stream, "-------------------------------------------\n");
}
......@@ -1000,28 +1007,139 @@ static void printSystemSummary(switch_stream_handle_t* stream) {
static int32 Kstdcall EventCallBack(int32 obj, K3L_EVENT * e)
{
/* TODO: We should hash things to make it stateful */
/* TODO: How do we make sure channels inside FreeSWITCH only change to valid states on K3L? */
switch(e->Code)
{
case EV_NEW_CALL:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "New call on %u to %s.\n", obj, k3l->get_param(e, "dest_addr").c_str());
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "New call on %u to %s. [EV_NEW_CALL]\n", obj, k3l->get_param(e, "dest_addr").c_str());
try {
k3l->command(e->DeviceId, obj, CM_RINGBACK, NULL);
k3l->command(e->DeviceId, obj, CM_CONNECT, NULL);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Accepeted the call.\n");
}
catch (K3LAPI::failed_command & err)
{
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Something went wrong here!\n");
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Could not set board channel status! [EV_NEW_CALL]\n");
}
break;
case EV_DISCONNECT:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Called party dropped the call on: %u. Releasing channel.\n", obj);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Called party dropped the call on: %u. Releasing channel. [EV_DISCONNECT]\n", obj);
/* Do we need to release on the board? */
k3l->command(e->DeviceId, obj, CM_DISCONNECT, NULL);
try {
k3l->setSession(e->DeviceId, obj, NULL);
}
catch(K3LAPI::invalid_channel & err)
{
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Called party dropped the call on: %u. Releasing channel. [EV_DISCONNECT]\n", obj);
}
break;
default:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "New Event has just arrived on %u with untreated code: %x\n", obj, e->Code);
case EV_CONNECT:
switch_channel_t *channel;
/* TODO: We should check if the session is there before getting the channel. */
channel = switch_core_session_get_channel(k3l->getSession(e->DeviceId ,obj));
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Call will be answered on board %u, channel %u. [EV_CONNECT]\n", e->DeviceId, obj);
switch_channel_mark_answered(channel);
break;
case EV_CALL_SUCCESS:
/* TODO: Should we bridge here? Maybe check a certain variable if we should generate ringback? */
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Call on board %u, channel %u is ringing. [EV_CALL_SUCESS]\n", e->DeviceId, obj);
break;
case EV_CHANNEL_FREE:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Channel %u on board %u is now free. [EV_CHANNEL_FREE]\n", obj, e->DeviceId);
break;
case EV_NO_ANSWER:
/* TODO: Destroy sessions and channels */
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "No one answered the call on board %u channel %u. [EV_NO_ANSWER]\n", e->DeviceId, obj);
break;
case EV_CALL_ANSWER_INFO:
{
/* TODO: Set channel variable if we get this event */
/* TODO: Fire an event so ESL can get it? */
/* Call Analyser has to be enabled on k3lconfig */
const char * startInfo = "";
switch (e->AddInfo)
{
case (kcsiHumanAnswer):
startInfo = "kcsiHumanAnswer";
break;
case (kcsiAnsweringMachine):
startInfo = "kcsiAnsweringMachine";
break;
case (kcsiCellPhoneMessageBox):
startInfo = "kcsiCellPhoneMessageBox";
break;
case (kcsiUnknown):
startInfo = "kcsiUnknown";
break;
case (kcsiCarrierMessage):
startInfo = "kcsiCarrierMessage";
break;
default:
startInfo = "Error or unknown code!";
}
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Channel %u, board %u detected: \"%s\". [EV_CALL_ANSWER_INFO]\n", e->DeviceId, obj, startInfo);
break;
}
case EV_DTMF_DETECTED:
/* TODO: What to do with DTMF? */
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Board %u detected DTMF (%d) on channel %u. [EV_DTMF_DETECTED]\n", e->DeviceId, e->AddInfo, obj);
break;
case EV_DTMF_SEND_FINISH:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Channel %u on board %u has sucessfully generated DTMF. [EV_DTMF_SEND_FINNISH]\n", obj, e->DeviceId);
break;
case EV_CALL_FAIL:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Channel %u on board %u reported call fail. [EV_CALL_FAIL]\n", obj, e->DeviceId);
break;
case EV_CHANNEL_FAIL:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Channel %u on board %u reported failure. [EV_CHANNEL_FAIL]\n", obj, e->DeviceId);
break;
case EV_LINK_STATUS:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Link %u on board %u changed. [EV_LINK_STATUS]\n", e->DeviceId, obj);
break;
case EV_PHYSICAL_LINK_DOWN:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Link %u on board %u is DOWN. [EV_PHYSICAL_LINK_DOWN]\n", e->DeviceId, obj);
break;
case EV_PHYSICAL_LINK_UP:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Link %u on board %u is UP. [EV_PHYSICAL_LINK_UP]\n", e->DeviceId, obj);
break;
case EV_INTERNAL_FAIL:
{
const char * msg = "";
switch(e->AddInfo)
{
case kifInterruptCtrl:
msg = "kifInterruptCtrl";
break;
case kifCommunicationFail:
msg = "kifCommunicationFail";
break;
case kifProtocolFail:
msg = "kifProtocolFail";
break;
case kifInternalBuffer:
msg = "kifInternalBuffer";
break;
case kifMonitorBuffer:
msg = "kifMonitorBuffer";
break;
case kifInitialization:
msg = "kifInitialization";
break;
case kifInterfaceFail:
msg = "kifInterfaceFail";
break;
case kifClientCommFail:
msg = "kifClientCommFail";
break;
default:
msg = "UnknownError";
}
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "This is a fatal error and we will not recover. Reason: %s. [EV_INTERNAL_FAIL]\n", msg);
break;
}
default:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "New Event has just arrived on %u with untreated code: %x\n", obj, e->Code);
}
return ksSuccess;
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论