Merge pull request #25 from symsimmy/feature/add-more-log

打印发送文件
symsimmy · May 9, 2024 · 0b76f65 · 0b76f65
2 parents 4e6d9cb + fc6262b
commit 0b76f65
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/network/gnet/server_conn.go b/network/gnet/server_conn.go
@@ -349,7 +349,9 @@ func (c *serverConn) write() {
 				if strings.Contains(err.Error(), "connection was aborted") {
 					break
 				}
-				//log.Errorf("connection:[%v] uid:[%v] write message error: %v", c.ID(), c.UID(), err)
+				log.Errorf("connection:[%v] uid:[%v] write message error: %v,data:%+v", c.ID(), c.UID(), err, buf)
+			} else {
+				log.Debugf("connection:[%v] uid:[%v] write message length:%+v,data:%+v", c.ID(), c.UID(), len(buf), buf)
 			}
 		case <-ticker.C:
 			deadline := xtime.Now().Add(-2 * c.connMgr.server.opts.heartbeatInterval).Unix()

diff --git a/network/gnet/server_conn_unix.go b/network/gnet/server_conn_unix.go
@@ -347,10 +347,12 @@ func (c *serverConn) write() {
 			}
 
 			if err = c.doWrite(buf); err != nil {
+				log.Errorf("connection:[%v] uid:[%v] write message error: %v", c.ID(), c.UID(), err)
 				if strings.Contains(err.Error(), "connection was aborted") {
 					break
 				}
-				//log.Errorf("connection:[%v] uid:[%v] write message error: %v", c.ID(), c.UID(), err)
+			} else {
+				log.Debugf("connection:[%v] uid:[%v] write message length:%+v", c.ID(), c.UID(), len(buf))
 			}
 		case <-ticker.C:
 			deadline := xtime.Now().Add(-2 * c.connMgr.server.opts.heartbeatInterval).Unix()