From eeffcd5df3850682dfd034ab10203929171f5638 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Sun, 17 Nov 2024 13:07:34 +0800 Subject: [PATCH] 1 --- server/wheelserver/service/log.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/server/wheelserver/service/log.go b/server/wheelserver/service/log.go index 57f1e9a2..1b3e5d2d 100644 --- a/server/wheelserver/service/log.go +++ b/server/wheelserver/service/log.go @@ -35,6 +35,9 @@ func (this *log) saveToDb() { this.loopCond.L.Lock() this.loopCond.Wait() this.loopCond.L.Unlock() + } else { + this.logQueue.WorkList.ForEach(this.saveNode) + this.logQueue.WorkList.Init(nil) } } } @@ -51,3 +54,7 @@ func (this *log) AddAsyncLog(accountId string, logType string, subLogType string this.logQueue.Push(&node.entry) this.loopCond.Broadcast() } + +func (this *log) saveNode(node interface{}) bool { + return true +}