From 4df6871c2642dded074db47a39c75722896f8f1e Mon Sep 17 00:00:00 2001 From: n-peugnet Date: Sat, 21 Aug 2021 12:49:07 +0200 Subject: dont use channels for listfiles --- repo_test.go | 18 +++++++----------- 1 file changed, 7 insertions(+), 11 deletions(-) (limited to 'repo_test.go') diff --git a/repo_test.go b/repo_test.go index 956bd84..7c6316e 100644 --- a/repo_test.go +++ b/repo_test.go @@ -15,9 +15,8 @@ func prepareResult() { func chunkCompare(t *testing.T, dataDir string, testFiles []string, chunkCount int) { - files := make(chan File) chunks := make(chan []byte) - go ListFiles(dataDir, files) + files := ListFiles(dataDir) go ReadFiles(files, chunks) offset := 0 @@ -81,15 +80,12 @@ func TestLoadChunks(t *testing.T) { prepareResult() dataDir := path.Join("test", "data") resultDir := path.Join("test", "result") - files1 := make(chan File) - files2 := make(chan File) - chunks1 := make(chan []byte) - chunks2 := make(chan []byte) - chunks3 := make(chan []byte) - go ListFiles(dataDir, files1) - go ListFiles(dataDir, files2) - go ReadFiles(files1, chunks1) - go ReadFiles(files2, chunks2) + chunks1 := make(chan []byte, 16) + chunks2 := make(chan []byte, 16) + chunks3 := make(chan []byte, 16) + files := ListFiles(dataDir) + go ReadFiles(files, chunks1) + go ReadFiles(files, chunks2) StoreChunks(resultDir, chunks1) go LoadChunks(resultDir, chunks3) -- cgit v1.2.3