|
|
@@ -39,7 +39,7 @@ func NewSaveLog(name, saveColl string, mgoSaveCacheSize, sPSize, bulkSize, timeA
|
|
|
|
|
|
// SendLogs 往通道发送数据
|
|
|
func (s *SaveLogs) SendLogs(data map[string]interface{}) {
|
|
|
- timer := time.NewTimer(time.Duration(s.Timeout) * time.Millisecond)
|
|
|
+ timer := time.NewTicker(time.Duration(s.Timeout) * time.Millisecond)
|
|
|
defer timer.Stop()
|
|
|
select {
|
|
|
case s.MgoSaveCache <- data:
|
|
|
@@ -54,10 +54,9 @@ func (s *SaveLogs) SaveMgo() {
|
|
|
log.Println(fmt.Sprintf("%s Save...", s.Name))
|
|
|
arr := make([]map[string]interface{}, s.BulkSize)
|
|
|
index := 0
|
|
|
- timer := time.NewTimer(time.Duration(s.TimeAfter) * time.Millisecond)
|
|
|
+ timer := time.NewTicker(time.Duration(s.TimeAfter) * time.Millisecond)
|
|
|
defer timer.Stop()
|
|
|
for {
|
|
|
- timer.Reset(time.Duration(s.TimeAfter) * time.Millisecond)
|
|
|
select {
|
|
|
case v := <-s.MgoSaveCache:
|
|
|
arr[index] = v
|
