1
This commit is contained in:
@@ -172,7 +172,6 @@ func (t *TcpClient) changePrintMsg(data string, orderNo int64, printNo string) (
|
||||
}
|
||||
|
||||
func (t *TcpClient) HandleTcpMessages(printNo string) {
|
||||
fmt.Println("============:", t.getTimeOut(printNo))
|
||||
var (
|
||||
db = dao.GetDB()
|
||||
offset, pageSize = 0, 10
|
||||
@@ -318,10 +317,8 @@ func (t *TcpClient) doPrint(key string) (err error) {
|
||||
|
||||
//检测心跳
|
||||
func (t *TcpClient) HandleCheckTcpHeart(key string) {
|
||||
globals.SugarLogger.Debugf("HandleCheckTcpHeart begin key: %s", key)
|
||||
go func() {
|
||||
for {
|
||||
fmt.Println("============:", t.getTimeOut(key))
|
||||
select {
|
||||
case <-t.TimeoutMap[key]:
|
||||
t.getClients(key).C.Close()
|
||||
|
||||
Reference in New Issue
Block a user