aa
This commit is contained in:
@@ -141,6 +141,10 @@ func ListenTcp() {
|
||||
return
|
||||
}
|
||||
globals.SugarLogger.Debugf("begin listenTcp port 8000......")
|
||||
go HandleTcpMessages()
|
||||
go HandleCheckTcpHeart()
|
||||
//go doPrint(printMsgChanFail)
|
||||
go doPrint2(printMsgChan)
|
||||
for {
|
||||
c, err := l.Accept()
|
||||
if err != nil {
|
||||
@@ -149,10 +153,6 @@ func ListenTcp() {
|
||||
}
|
||||
go handleConn(c)
|
||||
}
|
||||
go HandleTcpMessages()
|
||||
go HandleCheckTcpHeart()
|
||||
go doPrint(printMsgChanFail)
|
||||
go doPrint2(printMsgChan)
|
||||
}
|
||||
|
||||
func handleConn(c net.Conn) {
|
||||
|
||||
Reference in New Issue
Block a user