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 +}