octoleo/s3fs-fuse
1
0
Fork 0
mirror of https://github.com/s3fs-fuse/s3fs-fuse.git synced 2024-12-23 01:08:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1400 from gaul/test/concurrent-read

Browse Source 
Add test for concurrent reads
This commit is contained in:
Takeshi Nakatani 2020-09-17 19:26:44 +09:00 committed by GitHub
commit 8c29b60129
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
test/integration-test-main.sh
View File

@ -667,7 +667,7 @@ function test_overwrite_existing_file_range {
rm_test_file rm_test_file
} }
function test_concurrency { function test_concurrent_directory_updates {
describe "Test concurrent updates to a directory ..." describe "Test concurrent updates to a directory ..."
for i in `seq 5`; do echo foo > $i; done for i in `seq 5`; do echo foo > $i; done
for process in `seq 10`; do for process in `seq 10`; do
@ -682,11 +682,21 @@ function test_concurrency {
rm -f `seq 5` rm -f `seq 5`
} }
function test_concurrent_writes { function test_concurrent_reads {
describe "Test concurrent updates to a file ..." describe "Test concurrent reads from a file ..."
dd if=/dev/urandom of=${TEST_TEXT_FILE} bs=$BIG_FILE_LENGTH count=1 dd if=/dev/urandom of=${TEST_TEXT_FILE} bs=$BIG_FILE_LENGTH count=1
for process in `seq 10`; do for process in `seq 10`; do
dd if=/dev/zero of=${TEST_TEXT_FILE} seek=$(($RANDOM % $BIG_FILE_LENGTH)) count=1 bs=1024 conv=notrunc & dd if=${TEST_TEXT_FILE} of=/dev/null seek=$(($RANDOM % $BIG_FILE_LENGTH)) count=16 bs=1024 &
done
wait
rm_test_file
}
function test_concurrent_writes {
describe "Test concurrent writes to a file ..."
dd if=/dev/urandom of=${TEST_TEXT_FILE} bs=$BIG_FILE_LENGTH count=1
for process in `seq 10`; do
dd if=/dev/zero of=${TEST_TEXT_FILE} seek=$(($RANDOM % $BIG_FILE_LENGTH)) count=16 bs=1024 conv=notrunc &
done done
wait wait
rm_test_file rm_test_file
@ -1060,7 +1070,8 @@ function add_all_tests {
add_tests test_copy_file add_tests test_copy_file
add_tests test_write_after_seek_ahead add_tests test_write_after_seek_ahead
add_tests test_overwrite_existing_file_range add_tests test_overwrite_existing_file_range
add_tests test_concurrency add_tests test_concurrent_directory_updates
add_tests test_concurrent_reads
add_tests test_concurrent_writes add_tests test_concurrent_writes
add_tests test_open_second_fd add_tests test_open_second_fd
add_tests test_write_multiple_offsets add_tests test_write_multiple_offsets