From 06e3dd306f851d64ec8b84e74d115c5cd100a9cb Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Thu, 11 Jul 2024 00:19:39 -0700
Subject: [PATCH] clean up
---
weed/filer/filer_notify_read.go | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/weed/filer/filer_notify_read.go b/weed/filer/filer_notify_read.go
index 2e75677d7..1cdf12d63 100644
--- a/weed/filer/filer_notify_read.go
+++ b/weed/filer/filer_notify_read.go
@@ -140,7 +140,7 @@ func NewLogFileEntryCollector(f *Filer, startPosition log_buffer.MessagePosition
dayEntryQueue := util.NewQueue[*Entry]()
for _, dayEntry := range dayEntries {
dayEntryQueue.Enqueue(dayEntry)
- println("enqueue day entry", dayEntry.Name())
+ // println("enqueue day entry", dayEntry.Name())
}
startDate := fmt.Sprintf("%04d-%02d-%02d", startPosition.Year(), startPosition.Month(), startPosition.Day())
@@ -173,7 +173,7 @@ func (c *LogFileEntryCollector) collectMore(v *OrderedLogVisitor) (err error) {
if dayEntry == nil {
return io.EOF
}
- println("dequeue day entry", dayEntry.Name())
+ // println("dequeue day entry", dayEntry.Name())
if c.stopDate != "" {
if strings.Compare(dayEntry.Name(), c.stopDate) > 0 {
return io.EOF
@@ -200,7 +200,7 @@ func (c *LogFileEntryCollector) collectMore(v *OrderedLogVisitor) (err error) {
}
tsMinute := fmt.Sprintf("%s-%s", dayEntry.Name(), hourMinute)
- println(" enqueue", tsMinute)
+ // println(" enqueue", tsMinute)
t, parseErr := time.Parse("2006-01-02-15-04", tsMinute)
if parseErr != nil {
glog.Errorf("failed to parse %s: %v", tsMinute, parseErr)