From c6f8c190862e9af516dda9338225de2c960c3b2f Mon Sep 17 00:00:00 2001 From: kercylan98 Date: Fri, 25 Aug 2023 15:23:53 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20survey=20=E5=8C=85=E4=BF=AE=E5=A4=8D=20A?= =?UTF-8?q?ll=20=E5=87=BD=E6=95=B0=E6=97=A0=E7=94=A8=E7=9A=84=E8=BF=94?= =?UTF-8?q?=E5=9B=9E=E5=8F=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- utils/log/survey/survey.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/utils/log/survey/survey.go b/utils/log/survey/survey.go index 72c20b0..a3264be 100644 --- a/utils/log/survey/survey.go +++ b/utils/log/survey/survey.go @@ -60,9 +60,7 @@ func Reg(name, filePath string, options ...Option) { survey[n].flush() } timerSurveyLock.Unlock() - if !t.Reset(interval) { - break - } + t.Reset(interval) } }(logger.interval) } @@ -129,7 +127,7 @@ func Close(names ...string) { // All 处理特定记录器特定日期的所有记录，当发生错误时，会发生 panic // - handle 为并行执行的，需要自行处理并发安全 -func All(name string, t time.Time, handle func(record R) bool) { +func All(name string, t time.Time, handle func(record R)) { timerSurveyLock.Lock() logger := survey[name] timerSurveyLock.Unlock() @@ -150,7 +148,7 @@ func All(name string, t time.Time, handle func(record R) bool) { // AllWithPath 处理特定记录器特定日期的所有记录，当发生错误时，会发生 panic // - handle 为并行执行的，需要自行处理并发安全 // - 适用于外部进程对于日志文件的读取，但是需要注意的是，此时日志文件可能正在被写入，所以可能会读取到错误的数据 -func AllWithPath(filePath string, handle func(record R) bool) { +func AllWithPath(filePath string, handle func(record R)) { err := file.ReadLineWithParallel(filePath, 1*1024*1024*1024, func(s string) { handle(R(s)) })