dkforest

commit 6108c0a0a817bcdda05820352385867f407a7ddf
parent 7ba7b754f8da20b7af083fb44a18aeb3a658360d
Author: n0tr1v <n0tr1v@protonmail.com>
Date:   Mon, 30 Jan 2023 15:45:52 -0800

cleanup

Diffstat:
M
cmd/dkfupload/main.go
 | 
12
++++++------

1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/cmd/dkfupload/main.go b/cmd/dkfupload/main.go
@@ -37,19 +37,19 @@ func main() {
 		log.Println("dry run")
 	}
 
-	ch := make(chan int64)
+	chunksCh := make(chan int64)
 	go func() {
 		for chunkNum := int64(0); chunkNum < nbChunks; chunkNum++ {
-			ch <- chunkNum
+			chunksCh <- chunkNum
 		}
-		close(ch)
+		close(chunksCh)
 	}()
 
 	wg := &sync.WaitGroup{}
 	wg.Add(nbThreads)
 	for i := 0; i < nbThreads; i++ {
-		go func(i int, wg *sync.WaitGroup) {
-			for chunkNum := range ch {
+		go func(i int, wg *sync.WaitGroup, chunksCh chan int64) {
+			for chunkNum := range chunksCh {
 				offset := int64(chunkNum) * maxChunkSize
 				buf := make([]byte, maxChunkSize)
 				n, _ := f.ReadAt(buf, offset)
@@ -59,7 +59,7 @@ func main() {
 				}
 			}
 			wg.Done()
-		}(i, wg)
+		}(i, wg, chunksCh)
 	}
 
 	wg.Wait()