|
@@ -39,10 +39,9 @@ func NewSaveLog(name, saveColl string, mgoSaveCacheSize, sPSize, bulkSize, timeA
|
|
|
|
|
|
// SendLogs 往通道发送数据
|
|
// SendLogs 往通道发送数据
|
|
func (s *SaveLogs) SendLogs(data map[string]interface{}) {
|
|
func (s *SaveLogs) SendLogs(data map[string]interface{}) {
|
|
- timer := time.NewTicker(time.Duration(s.Timeout) * time.Millisecond)
|
|
|
|
select {
|
|
select {
|
|
case s.MgoSaveCache <- data:
|
|
case s.MgoSaveCache <- data:
|
|
- case <-timer.C:
|
|
|
|
|
|
+ case <-time.After(time.Duration(s.Timeout)*time.Millisecond):
|
|
log.Println("缓存通道已满,丢弃:", data)
|
|
log.Println("缓存通道已满,丢弃:", data)
|
|
return
|
|
return
|
|
}
|
|
}
|