mirror of
https://github.com/upa/mscp.git
synced 2026-03-02 13:07:29 +08:00
Merge branch 'main' of github.com:upa/mscp
This commit is contained in:
@@ -11,6 +11,7 @@ set -x
|
|||||||
# Run sshd
|
# Run sshd
|
||||||
if [ ! -e /var/run/sshd.pid ]; then
|
if [ ! -e /var/run/sshd.pid ]; then
|
||||||
/usr/sbin/sshd
|
/usr/sbin/sshd
|
||||||
|
sleep 1
|
||||||
fi
|
fi
|
||||||
|
|
||||||
ssh-keyscan localhost >> ${HOME}/.ssh/known_hosts
|
ssh-keyscan localhost >> ${HOME}/.ssh/known_hosts
|
||||||
|
|||||||
@@ -101,7 +101,7 @@ sem_t *sem_create(int value)
|
|||||||
|
|
||||||
if (sem_init(sem, 0, value) < 0) {
|
if (sem_init(sem, 0, value) < 0) {
|
||||||
free(sem);
|
free(sem);
|
||||||
return sem;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
return sem;
|
return sem;
|
||||||
|
|||||||
@@ -144,7 +144,7 @@ def test_min_chunk(mscp, src_prefix, dst_prefix):
|
|||||||
src = File("src", size = 16 * 1024).make()
|
src = File("src", size = 16 * 1024).make()
|
||||||
dst = File("dst")
|
dst = File("dst")
|
||||||
|
|
||||||
run2ok([mscp, "-H", "-s", 8192, src_prefix + src.path, dst_prefix + dst.path])
|
run2ok([mscp, "-H", "-s", 32768, src_prefix + src.path, dst_prefix + dst.path])
|
||||||
assert check_same_md5sum(src, dst)
|
assert check_same_md5sum(src, dst)
|
||||||
|
|
||||||
src.cleanup()
|
src.cleanup()
|
||||||
@@ -155,7 +155,7 @@ def test_thread_affinity(mscp, src_prefix, dst_prefix):
|
|||||||
src = File("src", size = 64 * 1024).make()
|
src = File("src", size = 64 * 1024).make()
|
||||||
dst = File("dst")
|
dst = File("dst")
|
||||||
|
|
||||||
run2ok([mscp, "-H", "-n", 4, "-m", "0x01", "-s", 8192, "-S", 65536,
|
run2ok([mscp, "-H", "-n", 4, "-m", "0x01",
|
||||||
src_prefix + src.path, dst_prefix + dst.path])
|
src_prefix + src.path, dst_prefix + dst.path])
|
||||||
assert check_same_md5sum(src, dst)
|
assert check_same_md5sum(src, dst)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user