|
|
@ -62,6 +62,104 @@ func (exe IcsExec) Execute() *icserror.IcsError {
|
|
|
|
sm := icssessionmanager.NewSessionManager()
|
|
|
|
sm := icssessionmanager.NewSessionManager()
|
|
|
|
sm.Load()
|
|
|
|
sm.Load()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/////////////////////////////////////////////////////////////////////
|
|
|
|
|
|
|
|
//start Heart beat TCP server
|
|
|
|
|
|
|
|
// hbDone := make(chan *icserror.IcsError)
|
|
|
|
|
|
|
|
// if exe.config.HeartBeat.Value {
|
|
|
|
|
|
|
|
// go func() {
|
|
|
|
|
|
|
|
// saddr := fmt.Sprintf(":%d", exe.config.HeartBeat.Port)
|
|
|
|
|
|
|
|
// hbladdr := icsnet.NewNetAddrWithIPAddr(saddr)
|
|
|
|
|
|
|
|
// var hbErr *icserror.IcsError
|
|
|
|
|
|
|
|
// //set handler
|
|
|
|
|
|
|
|
// exe.hbNet, hbErr = icsnet.ListenAndServeTCP(&hbladdr, nil, LINEEND1, TCPConnHandlerHeartBeat)
|
|
|
|
|
|
|
|
// if hbErr != nil {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_ERROR, -1, "Heart beat Listen - %s", hbErr.GetError())
|
|
|
|
|
|
|
|
// hbDone <- hbErr
|
|
|
|
|
|
|
|
// } else {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_INFO, -1, "Liesting Heart beat - %s", saddr)
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
// }()
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// /////////////////////////////////////////////////////////////////////
|
|
|
|
|
|
|
|
// //start Call signal TCP server
|
|
|
|
|
|
|
|
// csDone := make(chan *icserror.IcsError)
|
|
|
|
|
|
|
|
// p1 := &exe.config.ServerConfig.CSConfig.Port
|
|
|
|
|
|
|
|
// go func() {
|
|
|
|
|
|
|
|
// //saddr := fmt.Sprintf("%s:%d", exe.config.STTConfig.SrcIP, exe.config.STTConfig.Port)
|
|
|
|
|
|
|
|
// cslAddr := icsnet.NewNetAddrWithIPPort("0.0.0.0", *p1)
|
|
|
|
|
|
|
|
// //cslAddr := icsnet.NewNetAddrWithIPPort("0.0.0.0", exe.config.AgentConfig[idx].CSConfig.Port)
|
|
|
|
|
|
|
|
// //cslAddr := icsnet.NewNetAddrWithIPPort("0.0.0.0", exe.config.AgentConfig[iter].CSConfig.Port)
|
|
|
|
|
|
|
|
// var csErr *icserror.IcsError
|
|
|
|
|
|
|
|
// //set handler
|
|
|
|
|
|
|
|
// exe.csNet, csErr = icsnet.ListenAndServeTCP(&cslAddr, nil, LINEEND2, TCPConnHandlerCS)
|
|
|
|
|
|
|
|
// if csErr != nil {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_ERROR, -1, "Call Signal Listen failure - %s", csErr.GetMessage())
|
|
|
|
|
|
|
|
// csDone <- csErr
|
|
|
|
|
|
|
|
// } else {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_INFO, -1, "Listening Call Signal - %s", cslAddr)
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
// }()
|
|
|
|
|
|
|
|
// /////////////////////////////////////////////////////////////////////
|
|
|
|
|
|
|
|
// //start STT TCP server
|
|
|
|
|
|
|
|
// sttDone := make(chan *icserror.IcsError)
|
|
|
|
|
|
|
|
// if exe.config.STTConfig.Value {
|
|
|
|
|
|
|
|
// go func() {
|
|
|
|
|
|
|
|
// saddr := fmt.Sprintf("%s:%d", exe.config.STTConfig.SrcIP, exe.config.STTConfig.Port)
|
|
|
|
|
|
|
|
// STTladdr := icsnet.NewNetAddrWithIPAddr(saddr)
|
|
|
|
|
|
|
|
// var sttErr *icserror.IcsError
|
|
|
|
|
|
|
|
// //set handler
|
|
|
|
|
|
|
|
// exe.sttNet, sttErr = icsnet.ListenAndServeTCP(&STTladdr, nil, LINEEND1, TCPConnHandlerSTT)
|
|
|
|
|
|
|
|
// if sttErr != nil {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_ERROR, -1, "STT Listen failure - %s", sttErr.GetMessage())
|
|
|
|
|
|
|
|
// sttDone <- sttErr
|
|
|
|
|
|
|
|
// } else {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_INFO, -1, "Listening STT - %s", saddr)
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
// //sttDone <- nil
|
|
|
|
|
|
|
|
// }()
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// /////////////////////////////////////////////////////////////////////
|
|
|
|
|
|
|
|
// //start TTS TCP server
|
|
|
|
|
|
|
|
// ttsDone := make(chan *icserror.IcsError)
|
|
|
|
|
|
|
|
// if exe.config.TTSConfig.Value {
|
|
|
|
|
|
|
|
// go func() {
|
|
|
|
|
|
|
|
// saddr := fmt.Sprintf("%s:%d", exe.config.TTSConfig.SrcIP, exe.config.TTSConfig.Port)
|
|
|
|
|
|
|
|
// TTSladdr := icsnet.NewNetAddrWithIPAddr(saddr)
|
|
|
|
|
|
|
|
// var ttsErr *icserror.IcsError
|
|
|
|
|
|
|
|
// //set handler
|
|
|
|
|
|
|
|
// exe.ttsNet, ttsErr = icsnet.ListenAndServeTCP(&TTSladdr, nil, LINEEND2, TCPConnHandlerTTS)
|
|
|
|
|
|
|
|
// if ttsErr != nil {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_ERROR, -1, "TTS Listen - %s", ttsErr.GetMessage())
|
|
|
|
|
|
|
|
// ttsDone <- ttsErr
|
|
|
|
|
|
|
|
// } else {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_INFO, -1, "Listening TTS - %s", saddr)
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
// //ttsDone <- nil
|
|
|
|
|
|
|
|
// }()
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// /////////////////////////////////////////////////////////////////////
|
|
|
|
|
|
|
|
// //start command TCP server
|
|
|
|
|
|
|
|
// cmdDone := make(chan *icserror.IcsError)
|
|
|
|
|
|
|
|
// if exe.config.CommandConfig.Value {
|
|
|
|
|
|
|
|
// go func() {
|
|
|
|
|
|
|
|
// saddr := fmt.Sprintf("%s:%d", exe.config.CommandConfig.SrcIP, exe.config.CommandConfig.Port)
|
|
|
|
|
|
|
|
// CMDladdr := icsnet.NewNetAddrWithIPAddr(saddr)
|
|
|
|
|
|
|
|
// var cmdErr *icserror.IcsError
|
|
|
|
|
|
|
|
// //set handler
|
|
|
|
|
|
|
|
// exe.cmdNet, cmdErr = icsnet.ListenAndServeTCP(&CMDladdr, nil, LINEEND2, TCPConnHandlerCommand)
|
|
|
|
|
|
|
|
// if cmdErr != nil {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_ERROR, -1, "Bot Command Listen - %s", cmdErr.GetMessage())
|
|
|
|
|
|
|
|
// cmdDone <- cmdErr
|
|
|
|
|
|
|
|
// } else {
|
|
|
|
|
|
|
|
// l.Printf(icslog.LOG_LEVEL_INFO, -1, "Listeing Bot Command Listen - %s", saddr)
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
// //ttsDone <- nil
|
|
|
|
|
|
|
|
// }()
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
/////////////////////////////////////////////////////////////////////
|
|
|
|
/////////////////////////////////////////////////////////////////////
|
|
|
|
//make http handler
|
|
|
|
//make http handler
|
|
|
|
httpDone := make(chan error)
|
|
|
|
httpDone := make(chan error)
|
|
|
|