From f6b92b856196dcf356d1f0e7d65afbfd7d16966b Mon Sep 17 00:00:00 2001 From: chrislu Date: Mon, 22 Aug 2022 00:00:51 -0700 Subject: [PATCH] refactor --- weed/command/filer_sync_jobs.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/weed/command/filer_sync_jobs.go b/weed/command/filer_sync_jobs.go index 0d4d83adb..3e9bb9f37 100644 --- a/weed/command/filer_sync_jobs.go +++ b/weed/command/filer_sync_jobs.go @@ -2,23 +2,22 @@ package command import ( "github.com/seaweedfs/seaweedfs/weed/glog" + "github.com/seaweedfs/seaweedfs/weed/pb" "github.com/seaweedfs/seaweedfs/weed/pb/filer_pb" "github.com/seaweedfs/seaweedfs/weed/util" "sync" ) -type MetadataProcessFunc func(resp *filer_pb.SubscribeMetadataResponse) error - type MetadataProcessor struct { activeJobs map[int64]*filer_pb.SubscribeMetadataResponse activeJobsLock sync.Mutex activeJobsCond *sync.Cond concurrencyLimit int - fn MetadataProcessFunc + fn pb.ProcessMetadataFunc processedTsWatermark int64 } -func NewMetadataProcessor(fn MetadataProcessFunc, concurrency int) *MetadataProcessor { +func NewMetadataProcessor(fn pb.ProcessMetadataFunc, concurrency int) *MetadataProcessor { t := &MetadataProcessor{ fn: fn, activeJobs: make(map[int64]*filer_pb.SubscribeMetadataResponse),