1
This commit is contained in:
parent
b8ccbdd770
commit
eeffcd5df3
@ -35,6 +35,9 @@ func (this *log) saveToDb() {
|
|||||||
this.loopCond.L.Lock()
|
this.loopCond.L.Lock()
|
||||||
this.loopCond.Wait()
|
this.loopCond.Wait()
|
||||||
this.loopCond.L.Unlock()
|
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.logQueue.Push(&node.entry)
|
||||||
this.loopCond.Broadcast()
|
this.loopCond.Broadcast()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (this *log) saveNode(node interface{}) bool {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user