diff options
Diffstat (limited to 'weed/command/filer_copy.go')
| -rw-r--r-- | weed/command/filer_copy.go | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/weed/command/filer_copy.go b/weed/command/filer_copy.go index db2d8c42c..667b089ed 100644 --- a/weed/command/filer_copy.go +++ b/weed/command/filer_copy.go @@ -31,21 +31,21 @@ var ( ) type CopyOptions struct { - include *string - replication *string - collection *string - ttl *string - diskType *string - maxMB *int - masterClient *wdclient.MasterClient - concurrenctFiles *int - concurrenctChunks *int - grpcDialOption grpc.DialOption - masters []string - cipher bool - ttlSec int32 - checkSize *bool - verbose *bool + include *string + replication *string + collection *string + ttl *string + diskType *string + maxMB *int + masterClient *wdclient.MasterClient + concurrentFiles *int + concurrentChunks *int + grpcDialOption grpc.DialOption + masters []string + cipher bool + ttlSec int32 + checkSize *bool + verbose *bool } func init() { @@ -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 |