Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-04 06:54:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化日志

Browse Source
This commit is contained in:
duanhf2012
2024-11-29 15:55:35 +08:00
parent d29abc0813
commit da45f97fa8
2 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
sysservice/tcpservice/tcpservice.go
View File

@@ -9,7 +9,6 @@ import (
"github.com/duanhf2012/origin/v2/service" "github.com/duanhf2012/origin/v2/service"
"github.com/duanhf2012/origin/v2/util/bytespool" "github.com/duanhf2012/origin/v2/util/bytespool"
"github.com/google/uuid" "github.com/google/uuid"
"runtime"
"strings" "strings"
"sync" "sync"
"time" "time"
@@ -140,10 +139,7 @@ func (slf *Client) GetId() string {
func (slf *Client) Run() { func (slf *Client) Run() {
defer func() { defer func() {
if r := recover(); r != nil { if r := recover(); r != nil {
buf := make([]byte, 4096) log.StackError(fmt.Sprint(r))
l := runtime.Stack(buf, false)
errString := fmt.Sprint(r)
log.Dump(string(buf[:l]), log.String("error", errString))
} }
}() }()
@@ -156,7 +152,7 @@ func (slf *Client) Run() {
slf.tcpConn.SetReadDeadline(slf.tcpService.tcpServer.ReadDeadline) slf.tcpConn.SetReadDeadline(slf.tcpService.tcpServer.ReadDeadline)
bytes, err := slf.tcpConn.ReadMsg() bytes, err := slf.tcpConn.ReadMsg()
if err != nil { if err != nil {
log.Debug("read client failed", log.ErrorAttr("error", err), log.String("clientId", slf.id)) log.Debug("read client failed", log.ErrorField("error", err), log.String("clientId", slf.id))
break break
} }
data, err := slf.tcpService.process.Unmarshal(slf.id, bytes) data, err := slf.tcpService.process.Unmarshal(slf.id, bytes)

2
sysservice/wsservice/wsservice.go
View File

@@ -129,7 +129,7 @@ func (slf *WSClient) Run() {
for { for {
bytes, err := slf.wsConn.ReadMsg() bytes, err := slf.wsConn.ReadMsg()
if err != nil { if err != nil {
log.Debug("read client id %s is error:%+v", slf.id, err) log.Debugf("read client id %s is error:%+v", slf.id, err)
break break
} }
data, err := slf.wsService.process.Unmarshal(slf.id, bytes) data, err := slf.wsService.process.Unmarshal(slf.id, bytes)