aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRyan Russell <ryanrussell@users.noreply.github.com>2022-09-14 06:53:04 -0500
committerGitHub <noreply@github.com>2022-09-14 04:53:04 -0700
commit60fa26ef45c9871d748065e09548401050d1a524 (patch)
treec19b61e6ea19062ea196be5581cf3819d01fdab5
parentba83dbda6fd85348f492910919e1ae19d8b43fc7 (diff)
downloadseaweedfs-60fa26ef45c9871d748065e09548401050d1a524.tar.xz
seaweedfs-60fa26ef45c9871d748065e09548401050d1a524.zip
refactor: `concurrentFiles` and `concurrentChunks` var name fix (#3655)
-rw-r--r--weed/command/filer_copy.go14
1 files changed, 7 insertions, 7 deletions
diff --git a/weed/command/filer_copy.go b/weed/command/filer_copy.go
index db2d8c42c..1294e0903 100644
--- a/weed/command/filer_copy.go
+++ b/weed/command/filer_copy.go
@@ -38,8 +38,8 @@ type CopyOptions struct {
diskType *string
maxMB *int
masterClient *wdclient.MasterClient
- concurrenctFiles *int
- concurrenctChunks *int
+ concurrentFiles *int
+ concurrentChunks *int
grpcDialOption grpc.DialOption
masters []string
cipher bool
@@ -57,8 +57,8 @@ func init() {
copy.ttl = cmdFilerCopy.Flag.String("ttl", "", "time to live, e.g.: 1m, 1h, 1d, 1M, 1y")
copy.diskType = cmdFilerCopy.Flag.String("disk", "", "[hdd|ssd|<tag>] hard drive or solid state drive or any tag")
copy.maxMB = cmdFilerCopy.Flag.Int("maxMB", 4, "split files larger than the limit")
- copy.concurrenctFiles = cmdFilerCopy.Flag.Int("c", 8, "concurrent file copy goroutines")
- copy.concurrenctChunks = cmdFilerCopy.Flag.Int("concurrentChunks", 8, "concurrent chunk copy goroutines for each file")
+ copy.concurrentFiles = cmdFilerCopy.Flag.Int("c", 8, "concurrent file copy goroutines")
+ copy.concurrentChunks = cmdFilerCopy.Flag.Int("concurrentChunks", 8, "concurrent chunk copy goroutines for each file")
copy.checkSize = cmdFilerCopy.Flag.Bool("check.size", false, "copy when the target file size is different from the source file")
copy.verbose = cmdFilerCopy.Flag.Bool("verbose", false, "print out details during copying")
}
@@ -141,7 +141,7 @@ func runCopy(cmd *Command, args []string) bool {
grace.SetupProfiling("filer.copy.cpu.pprof", "filer.copy.mem.pprof")
}
- fileCopyTaskChan := make(chan FileCopyTask, *copy.concurrenctFiles)
+ fileCopyTaskChan := make(chan FileCopyTask, *copy.concurrentFiles)
go func() {
defer close(fileCopyTaskChan)
@@ -152,7 +152,7 @@ func runCopy(cmd *Command, args []string) bool {
}
}
}()
- for i := 0; i < *copy.concurrenctFiles; i++ {
+ for i := 0; i < *copy.concurrentFiles; i++ {
waitGroup.Add(1)
go func() {
defer waitGroup.Done()
@@ -405,7 +405,7 @@ func (worker *FileCopyWorker) uploadFileInChunks(task FileCopyTask, f *os.File,
chunksChan := make(chan *filer_pb.FileChunk, chunkCount)
- concurrentChunks := make(chan struct{}, *worker.options.concurrenctChunks)
+ concurrentChunks := make(chan struct{}, *worker.options.concurrentChunks)
var wg sync.WaitGroup
var uploadError error