liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2022-12-12 09:41:58 +08:00
parent be84e7c384
commit 9161338c9f
2 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/event/event_tcp.go
View File

@@ -22,7 +22,6 @@ func ListenTcp() {
fmt.Println("listen error:", err) fmt.Println("listen error:", err)
return return
} }
globals.SugarLogger.Debugf("begin listenTcp port 8000......")
for { for {
c, err := l.Accept() c, err := l.Accept()
if err != nil { if err != nil {
@@ -34,7 +33,6 @@ func ListenTcp() {
} }
func (t *TcpClient) handleConn(c net.Conn) { func (t *TcpClient) handleConn(c net.Conn) {
globals.SugarLogger.Debugf("conn time %v", time.Now())
if c == nil { if c == nil {
globals.SugarLogger.Debugf("conn is nil") globals.SugarLogger.Debugf("conn is nil")
return return
@@ -46,7 +44,6 @@ func (t *TcpClient) handleConn(c net.Conn) {
buffer = make([]byte, 1024) buffer = make([]byte, 1024)
) )
n, err := c.Read(buffer) n, err := c.Read(buffer)
fmt.Println("ReadString err", err)
if err != nil { if err != nil {
if err == io.EOF { if err == io.EOF {
fmt.Println("connection close") fmt.Println("connection close")

2
business/jxstore/event/event_tcp_utils.go
View File

@@ -261,7 +261,6 @@ func (t *TcpClient) setPrintStatus(key string, status int) {
} }
func (t *TcpClient) setPrintStatusTime(key string) { func (t *TcpClient) setPrintStatusTime(key string) {
globals.SugarLogger.Debugf("==========setPrintStatusTime:%s", key)
t.Lock() t.Lock()
defer t.Unlock() defer t.Unlock()
if t.Clients[key] != nil { if t.Clients[key] != nil {
@@ -282,7 +281,6 @@ func (t *TcpClient) addMsgChan(printMsg *model.PrintMsg) (err error) {
dataChan := make(chan *model.PrintMsg, 1024) dataChan := make(chan *model.PrintMsg, 1024)
t.MsgMap[printMsg.PrintNo] = dataChan t.MsgMap[printMsg.PrintNo] = dataChan
} }
globals.SugarLogger.Debugf("addMsgChan msgID: %s", printMsg.MsgID)
t.MsgMap[printMsg.PrintNo] <- printMsg t.MsgMap[printMsg.PrintNo] <- printMsg
return err return err
} }