diff options
Diffstat (limited to 'src/spdk/test/pmem')
| -rw-r--r-- | src/spdk/test/pmem/common.sh | 91 | ||||
| -rwxr-xr-x | src/spdk/test/pmem/pmem.sh | 683 |
2 files changed, 774 insertions, 0 deletions
diff --git a/src/spdk/test/pmem/common.sh b/src/spdk/test/pmem/common.sh new file mode 100644 index 000000000..844930df2 --- /dev/null +++ b/src/spdk/test/pmem/common.sh @@ -0,0 +1,91 @@ +# Prints error message and return error code, closes vhost app and remove +# pmem pool file +# input: error message, error code +function error() { + local error_code=${2:-1} + echo "===========" + echo -e "ERROR: $1" + echo "error code: $error_code" + echo "===========" + vhost_kill 0 + pmem_clean_pool_file + return $error_code +} + +# check if there is pool file & remove it +# input: path to pool file +# default: $default_pool_file +function pmem_clean_pool_file() { + local pool_file=${1:-$default_pool_file} + + if [ -f $pool_file ]; then + echo "Deleting old pool_file" + rm $pool_file + fi +} + +# create new pmem file +# input: path to pool file, size in MB, block_size +# default: $default_pool_file 32 512 +function pmem_create_pool_file() { + local pool_file=${1:-$default_pool_file} + local size=${2:-32} + local block_size=${3:-512} + + pmem_clean_pool_file $pool_file + echo "Creating new pool file" + if ! $rpc_py bdev_pmem_create_pool $pool_file $size $block_size; then + error "Creating pool_file failed!" + fi + + if [ ! -f $pool_file ]; then + error "Creating pool_file failed!" + fi +} + +function pmem_unmount_ramspace() { + if [ -d "$testdir/ramspace" ]; then + if mount | grep -q "$testdir/ramspace"; then + umount $testdir/ramspace + fi + + rm -rf $testdir/ramspace + fi +} + +function pmem_print_tc_name() { + echo "" + echo "===============================================================" + echo "Now running: $1" + echo "===============================================================" +} + +function vhost_start() { + local vhost_pid + + $SPDK_BIN_DIR/vhost & + + vhost_pid=$! + echo $vhost_pid > $testdir/vhost.pid + waitforlisten $vhost_pid +} + +function vhost_kill() { + local vhost_pid_file="$testdir/vhost.pid" + local vhost_pid + vhost_pid="$(cat $vhost_pid_file)" + + if [[ ! -f $vhost_pid_file ]]; then + echo -e "ERROR: No vhost pid file found!" + return 1 + fi + + if ! kill -s INT $vhost_pid; then + echo -e "ERROR: Failed to exit vhost / invalid pid!" + rm $vhost_pid_file + return 1 + fi + + sleep 1 + rm $vhost_pid_file +} diff --git a/src/spdk/test/pmem/pmem.sh b/src/spdk/test/pmem/pmem.sh new file mode 100755 index 000000000..bca8b4db7 --- /dev/null +++ b/src/spdk/test/pmem/pmem.sh @@ -0,0 +1,683 @@ +#!/usr/bin/env bash + +testdir=$(readlink -f $(dirname $0)) +rootdir=$(readlink -f $testdir/../..) +source $rootdir/test/common/autotest_common.sh +source $rootdir/test/pmem/common.sh + +rpc_py="$rootdir/scripts/rpc.py " + +enable_script_debug=false +test_info=false +test_create=false +test_delete=false +test_construct_bdev=false +test_delete_bdev=false +test_all=true +test_all_get=false +default_pool_file="$testdir/pool_file" +obj_pool_file="$testdir/obj_pool_file" +bdev_name=pmem0 + +function usage() { + [[ -n $2 ]] && ( + echo "$2" + echo "" + ) + echo "Shortcut script for automated RPC tests for PMEM" + echo + echo "Usage: $(basename $1) [OPTIONS]" + echo + echo "-h, --help Print help and exit" + echo "-x set -x for script debug" + echo " --info Run test cases for bdev_pmem_get_pool_info" + echo " --create Run test cases for bdev_pmem_create_pool" + echo " --delete Run test cases for bdev_pmem_delete_pool" + echo " --construct_bdev Run test cases for constructing pmem bdevs" + echo " --delete_bdev Run test cases for deleting pmem bdevs" + echo " --all Run all test cases (default)" + exit 0 +} + +while getopts 'xh-:' optchar; do + case "$optchar" in + -) + case "$OPTARG" in + help) usage $0 ;; + info) + test_info=true + test_all=false + ;; + create) + test_create=true + test_all=false + ;; + delete) + test_delete=true + test_all=false + ;; + construct_bdev) + test_construct_bdev=true + test_all=false + ;; + delete_bdev) + test_delete_bdev=true + test_all=false + ;; + all) test_all_get=true ;; + *) usage $0 "Invalid argument '$OPTARG'" ;; + esac + ;; + h) usage $0 ;; + x) enable_script_debug=true ;; + *) usage $0 "Invalid argument '$OPTARG'" ;; + esac +done + +if $test_all_get; then + test_all=true +fi + +if [[ $EUID -ne 0 ]]; then + echo "Go away user come back as root" + exit 1 +fi + +#================================================ +# bdev_pmem_get_pool_info tests +#================================================ +function bdev_pmem_get_pool_info_tc1() { + pmem_print_tc_name ${FUNCNAME[0]} + + if $rpc_py bdev_pmem_get_pool_info; then + error "bdev_pmem_get_pool_info passed with missing argument!" + fi + + return 0 +} + +function bdev_pmem_get_pool_info_tc2() { + pmem_print_tc_name ${FUNCNAME[0]} + + if $rpc_py bdev_pmem_get_pool_info $rootdir/non/existing/path/non_existent_file; then + error "bdev_pmem_get_pool_info passed with invalid path!" + fi + + return 0 +} + +function bdev_pmem_get_pool_info_tc3() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file $obj_pool_file + + echo "Creating new type OBJ pool file" + if hash pmempool; then + pmempool create -s 32000000 obj $obj_pool_file + else + echo "Warning: pmempool package not found! Creating stub file." + truncate -s "32M" $obj_pool_file + fi + + if $rpc_py bdev_pmem_get_pool_info $obj_pool_file; then + pmem_clean_pool_file $obj_pool_file + error "Pmem_pool_info passed with invalid pool_file type!" + fi + + pmem_clean_pool_file $obj_pool_file + return 0 +} + +function bdev_pmem_get_pool_info_tc4() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + pmem_create_pool_file + if ! $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Failed to get bdev_pmem_get_pool_info!" + fi + + pmem_clean_pool_file + return 0 +} + +#================================================ +# bdev_pmem_create_pool tests +#================================================ +function bdev_pmem_create_pool_tc1() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + if $rpc_py bdev_pmem_create_pool 32 512; then + error "Mem pool file created w/out given path!" + fi + + if $rpc_py bdev_pmem_create_pool $default_pool_file; then + error "Mem pool file created w/out size & block size arguments!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "bdev_pmem_create_pool created invalid pool file!" + fi + + if $rpc_py bdev_pmem_create_pool $default_pool_file 32; then + error "Mem pool file created w/out block size argument!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "bdev_pmem_create_pool created invalid pool file!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_pool_tc2() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + if $rpc_py bdev_pmem_create_pool $rootdir/non/existing/path/non_existent_file 32 512; then + error "Mem pool file created with incorrect path!" + fi + + if $rpc_py bdev_pmem_get_pool_info $rootdir/non/existing/path/non_existent_file; then + error "bdev_pmem_create_pool created invalid pool file!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_pool_tc3() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + if ! $rpc_py bdev_pmem_create_pool $default_pool_file 256 512; then + error "Failed to create pmem pool!" + fi + + if ! $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Failed to get pmem info" + fi + + if ! $rpc_py bdev_pmem_delete_pool $default_pool_file; then + error "Failed to delete pool file!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Got pmem file info but file should be deleted" + fi + + if [ -f $default_pool_file ]; then + error "Failed to delete pmem file!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_pool_tc4() { + pmem_print_tc_name ${FUNCNAME[0]} + + pmem_unmount_ramspace + mkdir $rootdir/test/pmem/ramspace + mount -t tmpfs -o size=300m tmpfs $rootdir/test/pmem/ramspace + if ! $rpc_py bdev_pmem_create_pool $rootdir/test/pmem/ramspace/pool_file 256 512; then + pmem_unmount_ramspace + error "Failed to create pmem pool!" + fi + + if ! $rpc_py bdev_pmem_get_pool_info $rootdir/test/pmem/ramspace/pool_file; then + pmem_unmount_ramspace + error "Failed to get pmem info" + fi + + if ! $rpc_py bdev_pmem_delete_pool $rootdir/test/pmem/ramspace/pool_file; then + pmem_unmount_ramspace + error "Failed to delete pool file!" + fi + + if [ -f $rootdir/test/pmem/ramspace/pool_file ]; then + pmem_unmount_ramspace + error "Failed to delete pmem file / file still exists!" + fi + + pmem_unmount_ramspace + return 0 +} + +function bdev_pmem_create_pool_tc5() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + local pmem_block_size + local pmem_num_block + + if ! $rpc_py bdev_pmem_create_pool $default_pool_file 256 512; then + error "Failed to create pmem pool!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + pmem_block_size=$($rpc_py bdev_pmem_get_pool_info $default_pool_file | jq -r '.[] .block_size') + pmem_num_block=$($rpc_py bdev_pmem_get_pool_info $default_pool_file | jq -r '.[] .num_blocks') + else + error "Failed to get pmem info!" + fi + + if $rpc_py bdev_pmem_create_pool $default_pool_file 512 4096; then + error "Pmem pool with already occupied path has been created!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + if [ $pmem_block_size != $($rpc_py bdev_pmem_get_pool_info $default_pool_file | jq -r '.[] .block_size') ]; then + error "Invalid block size of pmem pool!" + fi + + if [ $pmem_num_block != $($rpc_py bdev_pmem_get_pool_info $default_pool_file | jq -r '.[] .num_blocks') ]; then + error "Invalid number of blocks of pmem pool!" + fi + else + error "Failed to get pmem info!" + fi + + if ! $rpc_py bdev_pmem_delete_pool $default_pool_file; then + error "Failed to delete pmem file!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_pool_tc6() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + local created_pmem_block_size + + for i in 511 512 1024 2048 4096 131072 262144; do + if ! $rpc_py bdev_pmem_create_pool $default_pool_file 256 $i; then + error "Failed to create pmem pool!" + fi + + if ! created_pmem_block_size=$($rpc_py bdev_pmem_get_pool_info $default_pool_file | jq -r '.[] .block_size'); then + error "Failed to get pmem info!" + fi + + if [ $i != $created_pmem_block_size ]; then + error "Invalid block size of pmem pool!" + fi + + if ! $rpc_py bdev_pmem_delete_pool $default_pool_file; then + error "Failed to delete pmem file!" + fi + done + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_pool_tc7() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + if $rpc_py bdev_pmem_create_pool $default_pool_file 15 512; then + error "Created pmem pool with invalid size!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Pmem file shouldn' exist!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_pool_tc8() { + pmem_print_tc_name "bdev_pmem_create_pool_tc8" + pmem_clean_pool_file + + if $rpc_py bdev_pmem_create_pool $default_pool_file 32 65536; then + error "Created pmem pool with invalid block number!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Pmem file shouldn' exist!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_pool_tc9() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + if $rpc_py bdev_pmem_create_pool $default_pool_file 256 -1; then + error "Created pmem pool with negative block size number!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "bdev_pmem_create_pool create invalid pool file!" + fi + + if $rpc_py bdev_pmem_create_pool $default_pool_file -1 512; then + error "Created pmem pool with negative size number!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "bdev_pmem_create_pool create invalid pool file!" + fi + + pmem_clean_pool_file + return 0 +} + +#================================================ +# bdev_pmem_delete_pool tests +#================================================ +function bdev_pmem_delete_pool_tc1() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + if $rpc_py bdev_pmem_delete_pool $default_pool_file; then + error "bdev_pmem_delete_pool deleted inexistant pool file!" + fi + + return 0 +} + +function bdev_pmem_delete_pool_tc2() { + pmem_print_tc_name "bdev_pmem_delete_pool_tc2" + pmem_clean_pool_file $obj_pool_file + + echo "Creating new type OBJ pool file" + if hash pmempool; then + pmempool create -s 32000000 obj $obj_pool_file + else + echo "Warning: pmempool package not found! Creating stub file." + truncate -s "32M" $obj_pool_file + fi + + if $rpc_py bdev_pmem_delete_pool $obj_pool_file; then + pmem_clean_pool_file $obj_pool_file + error "bdev_pmem_delete_pool deleted invalid pmem pool type!" + fi + + pmem_clean_pool_file $obj_pool_file + return 0 +} + +function bdev_pmem_delete_pool_tc3() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + pmem_create_pool_file + if ! $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Failed to get info on pmem pool file!" + fi + + if ! $rpc_py bdev_pmem_delete_pool $default_pool_file; then + error "Failed to delete pmem pool file!" + fi + + if $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Pmem pool file exists after using bdev_pmem_get_pool_info!" + fi + + return 0 +} + +function bdev_pmem_delete_pool_tc4() { + pmem_print_tc_name ${FUNCNAME[0]} + + bdev_pmem_delete_pool_tc3 + if $rpc_py bdev_pmem_delete_pool $default_pool_file; then + error "Deleted pmem pool file that shouldn't exist!" + fi + + return 0 +} + +#================================================ +# bdev_pmem_create tests +#================================================ +function bdev_pmem_create_tc1() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + pmem_create_pool_file + if $rpc_py bdev_pmem_create; then + error "bdev_pmem_create passed with missing argument!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_tc2() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + + pmem_create_pool_file + if $rpc_py bdev_pmem_create -n $bdev_name $rootdir/non/existing/path/non_existent_file; then + error "Created pmem bdev w/out valid pool file!" + fi + + if $rpc_py bdev_get_bdevs | jq -r '.[] .name' | grep -qi pmem; then + error "bdev_pmem_create passed with invalid argument!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_tc3() { + pmem_print_tc_name ${FUNCNAME[0]} + + truncate -s 32M $rootdir/test/pmem/random_file + if $rpc_py bdev_pmem_create -n $bdev_name $rootdir/test/pmem/random_file; then + error "Created pmem bdev from random file!" + fi + + if [ -f $rootdir/test/pmem/random_file ]; then + echo "Deleting previously created random file" + rm $rootdir/test/pmem/random_file + fi + + return 0 +} + +function bdev_pmem_create_tc4() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file $obj_pool_file + + echo "Creating new type OBJ pool file" + if hash pmempool; then + pmempool create -s 32000000 obj $obj_pool_file + else + echo "Warning: pmempool package not found! Creating stub file." + truncate -s "32M" $obj_pool_file + fi + + if $rpc_py bdev_pmem_create -n $bdev_name $obj_pool_file; then + pmem_clean_pool_file $obj_pool_file + error "Created pmem bdev from obj type pmem file!" + fi + + pmem_clean_pool_file $obj_pool_file + return 0 +} + +function bdev_pmem_create_tc5() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + pmem_create_pool_file + local pmem_bdev_name + + if ! $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Failed to get pmem info!" + fi + + if ! pmem_bdev_name=$($rpc_py bdev_pmem_create -n $bdev_name $default_pool_file); then + error "Failed to create pmem bdev" + fi + + if ! $rpc_py bdev_get_bdevs | jq -r '.[] .name' | grep -qi $pmem_bdev_name; then + error "Pmem bdev not found!" + fi + + if ! $rpc_py bdev_pmem_delete $pmem_bdev_name; then + error "Failed to delete pmem bdev!" + fi + + if ! $rpc_py bdev_pmem_delete_pool $default_pool_file; then + error "Failed to delete pmem pool file!" + fi + + pmem_clean_pool_file + return 0 +} + +function bdev_pmem_create_tc6() { + pmem_print_tc_name ${FUNCNAME[0]} + local pmem_bdev_name + pmem_clean_pool_file + + pmem_create_pool_file + if ! $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Failed to get info on pmem pool file!" + fi + + if ! pmem_bdev_name=$($rpc_py bdev_pmem_create -n $bdev_name $default_pool_file); then + error "Failed to create pmem bdev!" + fi + + if ! $rpc_py bdev_get_bdevs | jq -r '.[] .name' | grep -qi $pmem_bdev_name; then + error "Pmem bdev not found!" + fi + + if $rpc_py bdev_pmem_create -n $bdev_name $default_pool_file; then + error "Constructed pmem bdev with occupied path!" + fi + + if ! $rpc_py bdev_pmem_delete $pmem_bdev_name; then + error "Failed to delete pmem bdev!" + fi + + if ! $rpc_py bdev_pmem_delete_pool $default_pool_file; then + error "Failed to delete pmem pool file!" + fi + + pmem_clean_pool_file + return 0 +} + +#================================================ +# bdev_pmem_delete tests +#================================================ +function delete_bdev_tc1() { + pmem_print_tc_name ${FUNCNAME[0]} + local pmem_bdev_name + local bdevs_names + pmem_clean_pool_file + + pmem_create_pool_file $default_pool_file 256 512 + if ! $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Failed to get pmem info!" + fi + + if ! pmem_bdev_name=$($rpc_py bdev_pmem_create -n $bdev_name $default_pool_file); then + error "Failed to create pmem bdev!" + fi + + if ! $rpc_py bdev_get_bdevs | jq -r '.[] .name' | grep -qi $pmem_bdev_name; then + error "$pmem_bdev_name bdev not found!" + fi + + if ! $rpc_py bdev_pmem_delete $pmem_bdev_name; then + error "Failed to delete $pmem_bdev_name bdev!" + fi + + bdevs_names=$($rpc_py bdev_get_bdevs | jq -r '.[] .name') + if echo $bdevs_names | grep -qi $pmem_bdev_name; then + error "$pmem_bdev_name bdev is not deleted!" + fi + + pmem_clean_pool_file + return 0 +} + +function delete_bdev_tc2() { + pmem_print_tc_name ${FUNCNAME[0]} + pmem_clean_pool_file + pmem_create_pool_file $default_pool_file 256 512 + local pmem_bdev_name + + if ! $rpc_py bdev_pmem_get_pool_info $default_pool_file; then + error "Failed to get pmem info!" + fi + + if ! pmem_bdev_name=$($rpc_py bdev_pmem_create -n $bdev_name $default_pool_file); then + error "Failed to create pmem bdev" + fi + + if ! $rpc_py bdev_get_bdevs | jq -r '.[] .name' | grep -qi $pmem_bdev_name; then + error "Pmem bdev not found!" + fi + + if ! $rpc_py bdev_pmem_delete $pmem_bdev_name; then + error "Failed to delete pmem bdev!" + fi + + if $rpc_py bdev_pmem_delete $pmem_bdev_name; then + error "bdev_pmem_delete deleted pmem bdev for second time!" + fi + + pmem_clean_pool_file + return 0 +} + +vhost_start +if ! $enable_script_debug; then + set +x +fi + +if $test_info || $test_all; then + bdev_pmem_get_pool_info_tc1 + bdev_pmem_get_pool_info_tc2 + bdev_pmem_get_pool_info_tc3 + bdev_pmem_get_pool_info_tc4 +fi + +if $test_create || $test_all; then + bdev_pmem_create_pool_tc1 + bdev_pmem_create_pool_tc2 + bdev_pmem_create_pool_tc3 + bdev_pmem_create_pool_tc4 + bdev_pmem_create_pool_tc5 + bdev_pmem_create_pool_tc6 + bdev_pmem_create_pool_tc7 + bdev_pmem_create_pool_tc8 + bdev_pmem_create_pool_tc9 +fi + +if $test_delete || $test_all; then + bdev_pmem_delete_pool_tc1 + bdev_pmem_delete_pool_tc2 + bdev_pmem_delete_pool_tc3 + bdev_pmem_delete_pool_tc4 +fi + +if $test_construct_bdev || $test_all; then + bdev_pmem_create_tc1 + bdev_pmem_create_tc2 + bdev_pmem_create_tc3 + bdev_pmem_create_tc4 + bdev_pmem_create_tc5 + bdev_pmem_create_tc6 +fi + +if $test_delete_bdev || $test_all; then + delete_bdev_tc1 + delete_bdev_tc2 +fi + +pmem_clean_pool_file +vhost_kill 0 |