From 2c92a9ff7477705066d1f66cf9d8ab057e164f50 Mon Sep 17 00:00:00 2001 From: Ryan Russell Date: Wed, 14 Sep 2022 08:30:32 -0500 Subject: [PATCH] refactor: `DefaultConcurrencyLimit` var rename (#3658) --- weed/command/filer_sync.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/weed/command/filer_sync.go b/weed/command/filer_sync.go index 7133b0aef..d361577e8 100644 --- a/weed/command/filer_sync.go +++ b/weed/command/filer_sync.go @@ -51,7 +51,7 @@ type SyncOptions struct { const ( SyncKeyPrefix = "sync." - DefaultConcurrcyLimit = 32 + DefaultConcurrencyLimit = 32 ) var ( @@ -83,7 +83,7 @@ func init() { syncOptions.bDebug = cmdFilerSynchronize.Flag.Bool("b.debug", false, "debug mode to print out filer B received files") syncOptions.aFromTsMs = cmdFilerSynchronize.Flag.Int64("a.fromTsMs", 0, "synchronization from timestamp on filer A. The unit is millisecond") syncOptions.bFromTsMs = cmdFilerSynchronize.Flag.Int64("b.fromTsMs", 0, "synchronization from timestamp on filer B. The unit is millisecond") - syncOptions.concurrency = cmdFilerSynchronize.Flag.Int("concurrency", DefaultConcurrcyLimit, "The maximum number of files that will be synced concurrently.") + syncOptions.concurrency = cmdFilerSynchronize.Flag.Int("concurrency", DefaultConcurrencyLimit, "The maximum number of files that will be synced concurrently.") syncCpuProfile = cmdFilerSynchronize.Flag.String("cpuprofile", "", "cpu profile output file") syncMemProfile = cmdFilerSynchronize.Flag.String("memprofile", "", "memory profile output file") syncOptions.metricsHttpPort = cmdFilerSynchronize.Flag.Int("metricsPort", 0, "metrics listen port") @@ -262,8 +262,8 @@ func doSubscribeFilerMetaChanges(clientId int32, clientEpoch int32, grpcDialOpti } if concurrency < 0 || concurrency > 1024 { - glog.Warningf("invalid concurrency value, using default: %d", DefaultConcurrcyLimit) - concurrency = DefaultConcurrcyLimit + glog.Warningf("invalid concurrency value, using default: %d", DefaultConcurrencyLimit) + concurrency = DefaultConcurrencyLimit } processor := NewMetadataProcessor(processEventFn, concurrency)