stray logging

downloader/downloader.go

@@ -152,7 +152,7 @@ func (c *Client) startWorkers(ctx context.Context, req <-chan FileRequest) *sync
 	for i := 0; i < c.workers; i++ {
 		wg.Add(1)
 		go func(workerNum int) {
-			c.worker(ctx, fltSeen(req))
+			c.worker(ctx, c.fltSeen(req))
 			wg.Done()
 			c.l().Debugf("download worker %d terminated", workerNum)
 		}(i)

downloader/filters.go

@@ -1,12 +1,8 @@
 package downloader
 
-import (
-	"log"
-)
-
 // fltSeen filters the files from filesC to ensure that no duplicates
 // are downloaded.
-func fltSeen(filesC <-chan FileRequest) <-chan FileRequest {
+func (c *Client) fltSeen(filesC <-chan FileRequest) <-chan FileRequest {
 	dlQ := make(chan FileRequest)
 	go func() {
 		// closing stop will lead to all worker goroutines to terminate.
@@ -19,7 +15,7 @@ func fltSeen(filesC <-chan FileRequest) <-chan FileRequest {
 		for f := range filesC {
 			id := f.File.ID + f.Directory
 			if _, ok := seen[id]; ok {
-				log.Printf("already seen %s, skipping", Filename(f.File))
+				c.l().Debugf("already seen %q, skipping", Filename(f.File))
 				continue
 			}
 			seen[id] = true

downloader/filters_test.go

@@ -38,7 +38,9 @@ func Test_fltSeen(t *testing.T) {
 				filesC <- f
 			}
 		}()
-		dlqC := fltSeen(filesC)
+
+		c := Client{}
+		dlqC := c.fltSeen(filesC)
 
 		var got []FileRequest
 		for f := range dlqC {
@@ -58,8 +60,8 @@ func BenchmarkFltSeen(b *testing.B) {
 			inputC <- req
 		}
 	}()
-
-	outputC := fltSeen(inputC)
+	c := Client{}
+	outputC := c.fltSeen(inputC)
 
 	for n := 0; n < b.N; n++ {
 		for out := range outputC {