From a69115a4dc6ee25ba871cf2bd13e7bdb5c4f975d Mon Sep 17 00:00:00 2001
From: Ryo Nakamura <upa@haeena.net>
Date: Tue, 15 Nov 2022 19:57:53 +0900
Subject: add -m coremask option

---
 test/test_e2e.py | 12 ++++++++++++
 1 file changed, 12 insertions(+)

(limited to 'test/test_e2e.py')

diff --git a/test/test_e2e.py b/test/test_e2e.py
index 25a566d..5fa0ea7 100644
--- a/test/test_e2e.py
+++ b/test/test_e2e.py
@@ -150,6 +150,18 @@ def test_min_chunk(mscp, src_prefix, dst_prefix):
     src.cleanup()
     dst.cleanup()
 
+@pytest.mark.parametrize("src_prefix, dst_prefix", param_remote_prefix)
+def test_thread_affinity(mscp, src_prefix, dst_prefix):
+    src = File("src", size = 64 * 1024).make()
+    dst = File("dst")
+
+    run2ok([mscp, "-H", "-n", 4, "-m", "0x01", "-s", 8192, "-S", 65536,
+            src_prefix + src.path, dst_prefix + dst.path])
+    assert check_same_md5sum(src, dst)
+
+    src.cleanup()
+    dst.cleanup()
+
 @pytest.mark.parametrize("src_prefix, dst_prefix", param_remote_prefix)
 def test_cannot_override_file_with_dir(mscp, src_prefix, dst_prefix):
     src = File("src", size = 128).make()
-- 
cgit v1.2.3