Add tests for concurrent dcopy

otiai10 · Sep 3, 2023 · 4c9bb1f · 4c9bb1f
1 parent 78d861c
commit 4c9bb1f
Show file tree

Hide file tree

Showing 6 changed files with 15 additions and 0 deletions.
diff --git a/all_test.go b/all_test.go
@@ -475,3 +475,17 @@ func (r *SleepyReader) Read(p []byte) (int, error) {
 	}
 	return n, e
 }
+
+func TestOptions_NumberOfWorkers(t *testing.T) {
+	opt := Options{NumberOfWorkers: 3}
+	err := Copy("test/data/case19", "test/data.copy/case19", opt)
+	Expect(t, err).ToBe(nil)
+}
+
+func TestOptions_PreferConcurrent(t *testing.T) {
+	opt := Options{NumberOfWorkers: 4, PreferConcurrent: func(sd, dd string) (bool, error) {
+		return strings.HasSuffix(sd, "concurrent"), nil
+	}}
+	err := Copy("test/data/case19", "test/data.copy/case19_preferconcurrent", opt)
+	Expect(t, err).ToBe(nil)
+}
diff --git a/test/data/case19/README.md b/test/data/case19/README.md
@@ -0,0 +1 @@
+# Concurrent case
diff --git a/test/data/case19/bar_sequential/aaa.txt b/test/data/case19/bar_sequential/aaa.txt
diff --git a/test/data/case19/bar_sequential/bbb.txt b/test/data/case19/bar_sequential/bbb.txt
diff --git a/test/data/case19/foo_concurrent/ccc.txt b/test/data/case19/foo_concurrent/ccc.txt
diff --git a/test/data/case19/foo_concurrent/ddd.txt b/test/data/case19/foo_concurrent/ddd.txt