diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-07-14 11:25:50 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-07-14 11:25:50 -0700 |
| commit | 17f2d05cded9dee2cece0a4e9c5e49d9ad02e845 (patch) | |
| tree | 33f800e86ca661ba952776e8123324aed9f8b453 | |
| parent | ddec7b2bb986a352cc999ac4e350c8f3be87eacd (diff) | |
| download | seaweedfs-17f2d05cded9dee2cece0a4e9c5e49d9ad02e845.tar.xz seaweedfs-17f2d05cded9dee2cece0a4e9c5e49d9ad02e845.zip | |
filer: ensure logs are persisted
| -rw-r--r-- | weed/filer2/filer_notify.go | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/weed/filer2/filer_notify.go b/weed/filer2/filer_notify.go index 340f19fb5..e5f9eba0a 100644 --- a/weed/filer2/filer_notify.go +++ b/weed/filer2/filer_notify.go @@ -78,8 +78,13 @@ func (f *Filer) logFlushFunc(startTime, stopTime time.Time, buf []byte) { // startTime.Second(), startTime.Nanosecond(), ) - if err := f.appendToFile(targetFile, buf); err != nil { - glog.V(0).Infof("log write failed %s: %v", targetFile, err) + for { + if err := f.appendToFile(targetFile, buf); err != nil { + glog.V(1).Infof("log write failed %s: %v", targetFile, err) + time.Sleep(737 * time.Millisecond) + } else { + break + } } } |