diff options
| author | chrislu <chris.lu@gmail.com> | 2022-08-22 11:25:40 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-08-22 11:25:40 -0700 |
| commit | 7ea2c24c5d0b6ea49093e9aa081aa704f78216fe (patch) | |
| tree | ae32253e7ad409b54f4d52c0e4e6a47f1639a5a3 | |
| parent | 741a0136896395a6c79b414ed55eec248cab0b4a (diff) | |
| download | seaweedfs-7ea2c24c5d0b6ea49093e9aa081aa704f78216fe.tar.xz seaweedfs-7ea2c24c5d0b6ea49093e9aa081aa704f78216fe.zip | |
metadata processing use retry instead of retryForEver
| -rw-r--r-- | weed/command/filer_sync_jobs.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/weed/command/filer_sync_jobs.go b/weed/command/filer_sync_jobs.go index 3e9bb9f37..50428a3ad 100644 --- a/weed/command/filer_sync_jobs.go +++ b/weed/command/filer_sync_jobs.go @@ -41,12 +41,11 @@ func (t *MetadataProcessor) AddSyncJob(resp *filer_pb.SubscribeMetadataResponse) t.activeJobs[resp.TsNs] = resp go func() { - util.RetryForever("metadata processor", func() error { + if err := util.Retry("metadata processor", func() error { return t.fn(resp) - }, func(err error) bool { + }); err != nil { glog.Errorf("process %v: %v", resp, err) - return true - }) + } t.activeJobsLock.Lock() defer t.activeJobsLock.Unlock() |