diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 80e7717dd..6d65a23fa 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -167,6 +167,7 @@ func (t *TcpClient) HandleTcpMessages(printNo string) { for { select { case <-timeoutChan: + globals.SugarLogger.Debugf("HandleTcpMessages timeout") return default: //一直读? @@ -195,6 +196,7 @@ func (t *TcpClient) doPrint(key string) (err error) { for { select { case <-timeoutChan: + globals.SugarLogger.Debugf("doPrint timeout") return default: printMsg, ok := <-t.MsgMap[key] @@ -269,6 +271,7 @@ func (t *TcpClient) HandleCheckTcpHeart(key string) { for { select { case <-timeoutChan: + globals.SugarLogger.Debugf("HandleCheckTcpHeart timeout") return default: if !utils.IsTimeZero(t.getPrintStatusTime(key)) {