log优化
This commit is contained in:
parent
a387920c1f
commit
a7bbfc3d59
@ -197,6 +197,15 @@ func (L *LogMgr) InitManager() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (L *LogMgr) AddLog(logs *Log) {
|
func (L *LogMgr) AddLog(logs *Log) {
|
||||||
|
// 复制结构体和 Param map,避免并发修改导致 json.Marshal 时 panic
|
||||||
|
copyLog := *logs
|
||||||
|
if logs.Param != nil {
|
||||||
|
newParam := make(map[string]interface{}, len(logs.Param))
|
||||||
|
for k, v := range logs.Param {
|
||||||
|
newParam[k] = v
|
||||||
|
}
|
||||||
|
copyLog.Param = newParam
|
||||||
|
}
|
||||||
// 如果已经开始关闭,直接丢弃
|
// 如果已经开始关闭,直接丢弃
|
||||||
L.Lock.Lock()
|
L.Lock.Lock()
|
||||||
if L.closing {
|
if L.closing {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user