aa
This commit is contained in:
@@ -150,7 +150,6 @@ func HandleTcpMessages() {
|
|||||||
c net.Conn
|
c net.Conn
|
||||||
data []byte
|
data []byte
|
||||||
)
|
)
|
||||||
globals.SugarLogger.Debugf("HandleTcpMessages, start.....")
|
|
||||||
for {
|
for {
|
||||||
//一直读?
|
//一直读?
|
||||||
var err error
|
var err error
|
||||||
@@ -178,8 +177,8 @@ func HandleTcpMessages() {
|
|||||||
if c != nil {
|
if c != nil {
|
||||||
if _, err = c.Write(data); err != nil {
|
if _, err = c.Write(data); err != nil {
|
||||||
globals.SugarLogger.Debugf("handleTcpMessages err [%v]", err)
|
globals.SugarLogger.Debugf("handleTcpMessages err [%v]", err)
|
||||||
c.Close()
|
|
||||||
delete(tcpClient.Clients, printMsg.PrintNo)
|
delete(tcpClient.Clients, printMsg.PrintNo)
|
||||||
|
c.Close()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user