aboutsummaryrefslogtreecommitdiff
path: root/weed/filer2/filer_notify.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-30 03:05:34 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-30 03:05:34 -0700
commitf9b6178b8f12bd1b34a3756b15d6cee69930b26c (patch)
tree2faaf74e906fc45766d4d6422a9cf583461cd664 /weed/filer2/filer_notify.go
parent8c73410a51441d7f9f1140a8996dd3eb1f191f2e (diff)
downloadseaweedfs-f9b6178b8f12bd1b34a3756b15d6cee69930b26c.tar.xz
seaweedfs-f9b6178b8f12bd1b34a3756b15d6cee69930b26c.zip
log messages
Diffstat (limited to 'weed/filer2/filer_notify.go')
-rw-r--r--weed/filer2/filer_notify.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/filer2/filer_notify.go b/weed/filer2/filer_notify.go
index 28ade51cc..ecb488373 100644
--- a/weed/filer2/filer_notify.go
+++ b/weed/filer2/filer_notify.go
@@ -133,6 +133,7 @@ func ReadEachLogEntry(r io.Reader, sizeBuf []byte, ns int64, eachLogEntryFn func
return fmt.Errorf("size %d bytes, expected 4 bytes", n)
}
size := util.BytesToUint32(sizeBuf)
+ // println("entry size", size)
entryData := make([]byte, size)
n, err = r.Read(entryData)
if err != nil {