diff options
| author | Ryan Russell <ryanrussell@users.noreply.github.com> | 2022-09-14 08:30:32 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-14 06:30:32 -0700 |
| commit | 2c92a9ff7477705066d1f66cf9d8ab057e164f50 (patch) | |
| tree | 9c2d07648202713e0891e9462f72b81862622ecf | |
| parent | 60fa26ef45c9871d748065e09548401050d1a524 (diff) | |
| download | seaweedfs-2c92a9ff7477705066d1f66cf9d8ab057e164f50.tar.xz seaweedfs-2c92a9ff7477705066d1f66cf9d8ab057e164f50.zip | |
refactor: `DefaultConcurrencyLimit` var rename (#3658)
| -rw-r--r-- | weed/command/filer_sync.go | 8 |
1 files 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) |