|
|
@ -45,9 +45,7 @@ func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry, deleteChunks bool) |
|
|
|
notification.Queue.SendMessage(fullpath, eventNotification) |
|
|
|
} |
|
|
|
|
|
|
|
if false { |
|
|
|
f.logMetaEvent(time.Now(), fullpath, eventNotification) |
|
|
|
} |
|
|
|
f.logMetaEvent(time.Now(), fullpath, eventNotification) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
@ -70,6 +68,9 @@ func (f *Filer) logMetaEvent(ts time.Time, fullpath string, eventNotification *f |
|
|
|
} |
|
|
|
|
|
|
|
func (f *Filer) logFlushFunc(startTime, stopTime time.Time, buf []byte) { |
|
|
|
|
|
|
|
return |
|
|
|
|
|
|
|
targetFile := fmt.Sprintf("/.meta/log/%04d/%02d/%02d/%02d/%02d/%02d.%09d.log", |
|
|
|
startTime.Year(), startTime.Month(), startTime.Day(), startTime.Hour(), startTime.Minute(), |
|
|
|
startTime.Second(), startTime.Nanosecond()) |
|
|
|