export GSS_PIPEFS=false
export IDENTITY_UPCALL=default
export QUOTA_AUTO=1
+export JOBSTATS_AUTO=${JOBSTATS_AUTO:-1}
+export JOBID_VAR=${JOBID_VAR:-"procname_uid"}
# LOAD_LLOOP: LU-409: only load llite_lloop module if kernel < 2.6.32 or
# LOAD_LLOOP is true. LOAD_LLOOP is false by default.
. $LUSTRE/tests/functions.sh
. $LUSTRE/tests/yaml.sh
+export LD_LIBRARY_PATH=${LUSTRE}/utils:${LD_LIBRARY_PATH}
+
LUSTRE_TESTS_CFG_DIR=${LUSTRE_TESTS_CFG_DIR:-${LUSTRE}/tests/cfg}
EXCEPT_LIST_FILE=${EXCEPT_LIST_FILE:-${LUSTRE_TESTS_CFG_DIR}/tests-to-skip.sh}
export TEST_FAILED=false
export FAIL_ON_SKIP_ENV=${FAIL_ON_SKIP_ENV:-false}
- export MKE2FS=${MKE2FS:-mke2fs}
- export DEBUGFS=${DEBUGFS:-debugfs}
- export TUNE2FS=${TUNE2FS:-tune2fs}
- export E2LABEL=${E2LABEL:-e2label}
- export DUMPE2FS=${DUMPE2FS:-dumpe2fs}
- export E2FSCK=${E2FSCK:-e2fsck}
- export LFSCK_BIN=${LFSCK_BIN:-lfsck}
+ export MKE2FS=$MKE2FS
+ if [ -z "$MKE2FS" ]; then
+ if which mkfs.ldiskfs >/dev/null 2>&1; then
+ export MKE2FS=mkfs.ldiskfs
+ else
+ export MKE2FS=mke2fs
+ fi
+ fi
+
+ export DEBUGFS=$DEBUGFS
+ if [ -z "$DEBUGFS" ]; then
+ if which debugfs.ldiskfs >/dev/null 2>&1; then
+ export DEBUGFS=debugfs.ldiskfs
+ else
+ export DEBUGFS=debugfs
+ fi
+ fi
+
+ export TUNE2FS=$TUNE2FS
+ if [ -z "$TUNE2FS" ]; then
+ if which tunefs.ldiskfs >/dev/null 2>&1; then
+ export TUNE2FS=tunefs.ldiskfs
+ else
+ export TUNE2FS=tune2fs
+ fi
+ fi
+
+ export E2LABEL=$E2LABEL
+ if [ -z "$E2LABEL" ]; then
+ if which label.ldiskfs >/dev/null 2>&1; then
+ export E2LABEL=label.ldiskfs
+ else
+ export E2LABEL=e2label
+ fi
+ fi
+
+ export DUMPE2FS=$DUMPE2FS
+ if [ -z "$DUMPE2FS" ]; then
+ if which dumpfs.ldiskfs >/dev/null 2>&1; then
+ export DUMPE2FS=dumpfs.ldiskfs
+ else
+ export DUMPE2FS=dumpe2fs
+ fi
+ fi
+
+ export E2FSCK=$E2FSCK
+ if [ -z "$E2FSCK" ]; then
+ if which fsck.ldiskfs >/dev/null 2>&1; then
+ export E2FSCK=fsck.ldiskfs
+ else
+ export E2FSCK=e2fsck
+ fi
+ fi
+ export LFSCK_BIN=${LFSCK_BIN:-lfsck}
export LFSCK_ALWAYS=${LFSCK_ALWAYS:-"no"} # check fs after each test suite
export FSCK_MAX_ERR=4 # File system errors left uncorrected
fi
fi
export LL_DECODE_FILTER_FID=${LL_DECODE_FILTER_FID:-"$LUSTRE/utils/ll_decode_filter_fid"}
- [ ! -f "$LL_DECODE_FILTER_FID" ] && export LL_DECODE_FILTER_FID=$(which ll_decode_filter_fid)
+ [ ! -f "$LL_DECODE_FILTER_FID" ] && export LL_DECODE_FILTER_FID="ll_decode_filter_fid"
export MKFS=${MKFS:-"$LUSTRE/utils/mkfs.lustre"}
- [ ! -f "$MKFS" ] && export MKFS=$(which mkfs.lustre)
+ [ ! -f "$MKFS" ] && export MKFS="mkfs.lustre"
export TUNEFS=${TUNEFS:-"$LUSTRE/utils/tunefs.lustre"}
- [ ! -f "$TUNEFS" ] && export TUNEFS=$(which tunefs.lustre)
+ [ ! -f "$TUNEFS" ] && export TUNEFS="tunefs.lustre"
export CHECKSTAT="${CHECKSTAT:-"checkstat -v"} "
export LUSTRE_RMMOD=${LUSTRE_RMMOD:-$LUSTRE/scripts/lustre_rmmod}
[ ! -f "$LUSTRE_RMMOD" ] &&
IDENTITY_UPCALL=false
;;
esac
+ USE_OFD=${USE_OFD:-yes}
+ [ "$USE_OFD" = "yes" ] && LOAD_MODULES_REMOTE=true
+
export LOAD_MODULES_REMOTE=${LOAD_MODULES_REMOTE:-false}
# Paths on remote nodes, if different
}
load_modules_local() {
+ [ $(facet_fstype ost1) == "zfs" ] && export USE_OFD=yes
if [ "$USE_OFD" == yes ]; then
if module_loaded obdfilter; then
if ! $LUSTRE_RMMOD ldiskfs; then
fi
fi
- local ncpts=0
# if there is only one CPU core, libcfs can only create one partition
# if there is more than 4 CPU cores, libcfs should create multiple CPU
# partitions. So we just force libcfs to create 2 partitions for
if [ $ncpus -le 4 ] && [ $ncpus -gt 1 ]; then
# force to enable multiple CPU partitions
echo "Force libcfs to create 2 CPU partitions"
- ncpts=2
+ MODOPTS_LIBCFS="cpu_npartitions=2 $MODOPTS_LIBCFS"
else
echo "libcfs will create CPU partition based on online CPUs"
fi
- load_module ../libcfs/libcfs/libcfs cpu_npartitions=$ncpts
+ load_module ../libcfs/libcfs/libcfs
[ "$PTLDEBUG" ] && lctl set_param debug="$PTLDEBUG"
[ "$SUBSYSTEM" ] && lctl set_param subsystem_debug="${SUBSYSTEM# }"
grep -q -w jbd2 $SYMLIST || { modprobe jbd2 2>/dev/null || true; }
[ "$LQUOTA" != "no" ] && load_module quota/lquota $LQUOTAOPTS
if [[ $(node_fstypes $HOSTNAME) == *zfs* ]]; then
+ modprobe zfs
load_module osd-zfs/osd_zfs
fi
load_module mgs/mgs
load_module osd-ldiskfs/osd_ldiskfs
fi
load_module mdt/mdt
- load_module cmm/cmm
load_module ost/ost
+ load_module lod/lod
+ load_module osp/osp
if [ "$USE_OFD" == yes ]; then
load_module ofd/ofd
else
load_module obdfilter/obdfilter
fi
+ load_module osp/osp
fi
# bug 19124
# load modules on remote nodes optionally
# lustre-tests have to be installed on these nodes
- if $LOAD_MODULES_REMOTE ; then
+ if $LOAD_MODULES_REMOTE; then
local list=$(comma_list $(remote_nodes_list))
- echo loading modules on $list
- do_rpc_nodes $list load_modules_local
+ if [ -n "$list" ]; then
+ echo "loading modules on: '$list'"
+ do_rpc_nodes "$list" load_modules_local
+ fi
fi
}
$LUSTRE_RMMOD ldiskfs || return 2
- if $LOAD_MODULES_REMOTE ; then
+ if $LOAD_MODULES_REMOTE; then
local list=$(comma_list $(remote_nodes_list))
- if [ ! -z $list ]; then
- echo unloading modules on $list
- do_rpc_nodes $list $LUSTRE_RMMOD ldiskfs
- do_rpc_nodes $list check_mem_leak
+ if [ -n "$list" ]; then
+ echo "unloading modules on: '$list'"
+ do_rpc_nodes "$list" $LUSTRE_RMMOD ldiskfs
+ do_rpc_nodes "$list" check_mem_leak
fi
fi
}
set_default_debug_nodes () {
- local nodes=$1
+ local nodes="$1"
- if [[ ,$nodes, = *,$HOSTNAME,* ]]; then
- nodes=$(exclude_items_from_list "$nodes" "$HOSTNAME")
- set_default_debug
- fi
+ if [[ ,$nodes, = *,$HOSTNAME,* ]]; then
+ nodes=$(exclude_items_from_list "$nodes" "$HOSTNAME")
+ set_default_debug
+ fi
- [[ -n $nodes ]] && do_rpc_nodes $nodes set_default_debug \
- \\\"$PTLDEBUG\\\" \\\"$SUBSYSTEM\\\" $DEBUG_SIZE || true
+ do_rpc_nodes "$nodes" set_default_debug \
+ \\\"$PTLDEBUG\\\" \\\"$SUBSYSTEM\\\" $DEBUG_SIZE || true
}
set_default_debug_facet () {
# save quota version (both administrative and operational quotas)
# add an additional parameter if mountpoint is ever different from $MOUNT
+#
+# XXX This function is kept for interoperability with old server (< 2.3.50),
+# it should be removed whenever we drop the interoperability for such
+# server.
quota_save_version() {
local fsname=${2:-$FSNAME}
local spec=$1
done
}
-# client could mount several lustre
+# client could mount several lustre
+#
+# XXX This function is kept for interoperability with old server (< 2.3.50),
+# it should be removed whenever we drop the interoperability for such
+# server.
quota_type () {
local fsname=${1:-$FSNAME}
local rc=0
return $rc
}
-restore_quota_type () {
- local mntpt=${1:-$MOUNT}
- local quota_type=$(quota_type $FSNAME | grep MDT | cut -d "=" -f2)
- if [ ! "$old_QUOTA_TYPE" ] || [ "$quota_type" = "$old_QUOTA_TYPE" ]; then
- return
- fi
- quota_save_version $old_QUOTA_TYPE
+# XXX This function is kept for interoperability with old server (< 2.3.50),
+# it should be removed whenever we drop the interoperability for such
+# server.
+restore_quota_old() {
+ local mntpt=${1:-$MOUNT}
+ local quota_type=$(quota_type $FSNAME | grep MDT | cut -d "=" -f2)
+ if [ ! "$old_QUOTA_TYPE" ] ||
+ [ "$quota_type" = "$old_QUOTA_TYPE" ]; then
+ return
+ fi
+ quota_save_version $old_QUOTA_TYPE
}
-setup_quota(){
- local mntpt=$1
+# XXX This function is kept for interoperability with old server (< 2.3.50),
+# it should be removed whenever we drop the interoperability for such
+# server.
+setup_quota_old(){
+ local mntpt=$1
- if [ "$USE_OFD" = "yes" ]; then
- $LFS quotacheck $mntpt || error "quotacheck failed"
- return
- fi
+ # no quota enforcement for now and accounting works out of the box
+ return
# We need save the original quota_type params, and restore them after testing
done
}
+# get mdt quota type
+mdt_quota_type() {
+ local varsvc=${SINGLEMDS}_svc
+ do_facet $SINGLEMDS $LCTL get_param -n \
+ osd-$FSTYPE.${!varsvc}.quota_slave.enabled
+}
+
+# get ost quota type
+ost_quota_type() {
+ # All OSTs should have same quota type
+ local varsvc=ost1_svc
+ do_facet ost1 $LCTL get_param -n \
+ osd-$FSTYPE.${!varsvc}.quota_slave.enabled
+}
+
+# restore old quota type settings
+restore_quota() {
+ if [ $(lustre_version_code $SINGLEMDS) -lt $(version_code 2.3.50) ]; then
+ restore_quota_old
+ return
+ fi
+
+ if [ "$old_MDT_QUOTA_TYPE" ]; then
+ do_facet mgs $LCTL conf_param \
+ $FSNAME.quota.mdt=$old_MDT_QUOTA_TYPE
+ fi
+ if [ "$old_OST_QUOTA_TYPE" ]; then
+ do_facet mgs $LCTL conf_param \
+ $FSNAME.quota.ost=$old_OST_QUOTA_TYPE
+ fi
+}
+
+setup_quota(){
+ if [ $(lustre_version_code $SINGLEMDS) -lt $(version_code 2.3.50) ]; then
+ setup_quota_old $1
+ return
+ fi
+
+ # XXX remove it once all quota code landed
+ echo "skip quota setup"
+ return
+
+ local mntpt=$1
+
+ # save old quota type & set new quota type
+ local mdt_qtype=$(mdt_quota_type)
+ local ost_qtype=$(ost_quota_type)
+
+ echo "[HOST:$HOSTNAME] [old_mdt_qtype:$mdt_qtype]" \
+ "[old_ost_qtype:$ost_qtype] [new_qtype:$QUOTA_TYPE]"
+
+ export old_MDT_QUOTA_TYPE=$mdt_qtype
+ export old_OST_QUOTA_TYPE=$ost_qtype
+
+ do_facet mgs $LCTL conf_param $FSNAME.quota.mdt=$QUOTA_TYPE ||
+ error "set mdt quota type failed"
+ do_facet mgs $LCTL conf_param $FSNAME.quota.ost=$QUOTA_TYPE ||
+ error "set ost quota type failed"
+
+ local quota_usrs=$QUOTA_USERS
+
+ # get_filesystem_size
+ local disksz=$(lfs df $mntpt | grep "filesystem summary:" |
+ awk '{print $3}')
+ local blk_soft=$((disksz + 1024))
+ local blk_hard=$((blk_soft + blk_soft / 20)) # Go 5% over
+
+ local inodes=$(lfs df -i $mntpt | grep "filesystem summary:" |
+ awk '{print $3}')
+ local i_soft=$inodes
+ local i_hard=$((i_soft + i_soft / 20))
+
+ echo "Total disk size: $disksz block-softlimit: $blk_soft" \
+ "block-hardlimit: $blk_hard inode-softlimit: $i_soft" \
+ "inode-hardlimit: $i_hard"
+
+ local cmd
+ for usr in $quota_usrs; do
+ echo "Setting up quota on $HOSTNAME:$mntpt for $usr..."
+ for type in u g; do
+ cmd="$LFS setquota -$type $usr -b $blk_soft"
+ cmd="$cmd -B $blk_hard -i $i_soft -I $i_hard $mntpt"
+ echo "+ $cmd"
+ eval $cmd || error "$cmd FAILED!"
+ done
+ # display the quota status
+ echo "Quota settings for $usr : "
+ $LFS quota -v -u $usr $mntpt || true
+ done
+}
+
zconf_mount() {
local client=$1
local mnt=$2
echo $(comma_list $affected)
}
-facet_up () {
- local facet=$1
- local host=${2:-$(facet_host $facet)}
+facet_up() {
+ local facet=$1
+ local host=${2:-$(facet_host $facet)}
- local label=$(convert_facet2label $facet)
- do_node $host lctl dl | awk '{print $4}' | grep -q $label
+ local label=$(convert_facet2label $facet)
+ do_node $host $LCTL dl | awk '{print $4}' | grep -q -x $label
}
facets_up_on_host () {
}
check_progs_installed () {
- local nodes=$1
- shift
+ local nodes=$1
+ shift
- do_rpc_nodes $nodes _check_progs_installed $@
+ do_rpc_nodes "$nodes" _check_progs_installed $@
}
# recovery-scale functions
return 3
}
-wait_update_facet () {
- local facet=$1
- wait_update $(facet_active_host $facet) "$@"
+wait_update_facet() {
+ local facet=$1
+ shift
+ wait_update $(facet_active_host $facet) "$@"
}
sync_all_data() {
grep -v 'Found no match'
}
-wait_delete_completed () {
- local TOTALPREV=`lctl get_param -n osc.*.kbytesavail | \
- awk 'BEGIN{total=0}; {total+=$1}; END{print total}'`
+wait_delete_completed_mds() {
+ local MAX_WAIT=${1:-20}
+ local mds2sync=""
+ local stime=`date +%s`
+ local etime
+ local node
+ local changes
+
+ # find MDS with pending deletions
+ for node in $(mdts_nodes); do
+ changes=$(do_node $node "lctl get_param -n osc.*MDT*.sync_*" \
+ 2>/dev/null | calc_sum)
+ if [ -z "$changes" ] || [ $changes -eq 0 ]; then
+ continue
+ fi
+ mds2sync="$mds2sync $node"
+ done
+ if [ "$mds2sync" == "" ]; then
+ return
+ fi
+ mds2sync=$(comma_list $mds2sync)
+
+ # sync MDS transactions
+ do_nodes $mds2sync "lctl set_param -n osd*.*MD*.force_sync 1"
+
+ # wait till all changes are sent and commmitted by OSTs
+ # for ldiskfs space is released upon execution, but DMU
+ # do this upon commit
+
+ local WAIT=0
+ while [ "$WAIT" -ne "$MAX_WAIT" ]; do
+ changes=$(do_nodes $mds2sync "lctl get_param -n osc.*MDT*.sync_*" \
+ | calc_sum)
+ #echo "$node: $changes changes on all"
+ if [ "$changes" -eq "0" ]; then
+ etime=`date +%s`
+ #echo "delete took $((etime - stime)) seconds"
+ return
+ fi
+ sleep 1
+ WAIT=$(( WAIT + 1))
+ done
- local WAIT=0
- local MAX_WAIT=20
- while [ "$WAIT" -ne "$MAX_WAIT" ]; do
- sleep 1
- TOTAL=`lctl get_param -n osc.*.kbytesavail | \
- awk 'BEGIN{total=0}; {total+=$1}; END{print total}'`
- [ "$TOTAL" -eq "$TOTALPREV" ] && return 0
- echo "Waiting delete completed ... prev: $TOTALPREV current: $TOTAL "
- TOTALPREV=$TOTAL
- WAIT=$(( WAIT + 1))
- done
- echo "Delete is not completed in $MAX_WAIT sec"
- return 1
+ etime=`date +%s`
+ echo "Delete is not completed in $((etime - stime)) seconds"
+ do_nodes $mds2sync "lctl get_param osc.*MDT*.sync_*"
}
wait_for_host() {
fi
echo affected facets: $facets
- # we can use "for" here because we are waiting the slowest
- for facet in ${facets//,/ }; do
- local var_svc=${facet}_svc
- local param="*.${!var_svc}.recovery_status"
+ # we can use "for" here because we are waiting the slowest
+ for facet in ${facets//,/ }; do
+ local var_svc=${facet}_svc
+ local param="*.${!var_svc}.recovery_status"
- local host=$(facet_active_host $facet)
- do_rpc_nodes $host _wait_recovery_complete $param $MAX
- done
+ local host=$(facet_active_host $facet)
+ do_rpc_nodes "$host" _wait_recovery_complete $param $MAX
+ done
}
wait_mds_ost_sync () {
}
wait_destroy_complete () {
- echo "Waiting for destroy to be done..."
- # MAX value shouldn't be big as this mean server responsiveness
- # never increase this just to make test pass but investigate
- # why it takes so long time
- local MAX=5
- local WAIT=0
- while [ $WAIT -lt $MAX ]; do
- local -a RPCs=($($LCTL get_param -n osc.*.destroys_in_flight))
- local con=1
- for ((i=0; i<${#RPCs[@]}; i++)); do
- [ ${RPCs[$i]} -eq 0 ] && continue
- # there are still some destroy RPCs in flight
- con=0
- break;
- done
- sleep 1
- [ ${con} -eq 1 ] && return 0 # done waiting
- echo "Waiting $WAIT secs for destroys to be done."
- WAIT=$((WAIT + 1))
- done
- echo "Destroys weren't done in $MAX sec."
- return 1
+ echo "Waiting for local destroys to complete"
+ # MAX value shouldn't be big as this mean server responsiveness
+ # never increase this just to make test pass but investigate
+ # why it takes so long time
+ local MAX=5
+ local WAIT=0
+ while [ $WAIT -lt $MAX ]; do
+ local -a RPCs=($($LCTL get_param -n osc.*.destroys_in_flight))
+ local con=1
+ local i
+
+ for ((i=0; i<${#RPCs[@]}; i++)); do
+ [ ${RPCs[$i]} -eq 0 ] && continue
+ # there are still some destroy RPCs in flight
+ con=0
+ break;
+ done
+ sleep 1
+ [ ${con} -eq 1 ] && return 0 # done waiting
+ echo "Waiting ${WAIT}s for local destroys to complete"
+ WAIT=$((WAIT + 1))
+ done
+ echo "Local destroys weren't done in $MAX sec."
+ return 1
+}
+
+wait_delete_completed() {
+ wait_delete_completed_mds $1 || return $?
+ wait_destroy_complete
}
wait_exit_ST () {
# make sure there will be no seq change
local clients=${CLIENTS:-$HOSTNAME}
- do_nodes $clients "f=${MOUNT}/fsa-\\\$(hostname); mcreate \\\$f; rm \\\$f"
+ local f=fsa-\\\$\(hostname\)
+ do_nodes $clients "mcreate $MOUNT/$f; rm $MOUNT/$f"
+ do_nodes $clients "if [ -d $MOUNT2 ]; then mcreate $MOUNT2/$f; rm $MOUNT2/$f; fi"
local svc=${facet}_svc
do_facet $facet $LCTL --device %${!svc} notransno
[ $period -lt $timeout ] || log "$count OST are inactive after $timeout seconds, give up"
}
+set_conf_param_and_check() {
+ local myfacet=$1
+ local TEST=$2
+ local PARAM=$3
+ local ORIG=$(do_facet $myfacet "$TEST")
+ if [ $# -gt 3 ]; then
+ local FINAL=$4
+ else
+ local -i FINAL
+ FINAL=$((ORIG + 5))
+ fi
+ echo "Setting $PARAM from $ORIG to $FINAL"
+ do_facet mgs "$LCTL conf_param $PARAM='$FINAL'" ||
+ error "conf_param $PARAM failed"
+
+ wait_update $(facet_host $myfacet) "$TEST" "$FINAL" ||
+ error "check $PARAM failed!"
+}
+
init_param_vars () {
- remote_mds_nodsh ||
- TIMEOUT=$(do_facet $SINGLEMDS "lctl get_param -n timeout")
+ remote_mds_nodsh ||
+ TIMEOUT=$(do_facet $SINGLEMDS "lctl get_param -n timeout")
- log "Using TIMEOUT=$TIMEOUT"
+ log "Using TIMEOUT=$TIMEOUT"
- osc_ensure_active $SINGLEMDS $TIMEOUT
- osc_ensure_active client $TIMEOUT
+ osc_ensure_active $SINGLEMDS $TIMEOUT
+ osc_ensure_active client $TIMEOUT
- if [ $QUOTA_AUTO -ne 0 ]; then
- if [ "$ENABLE_QUOTA" ]; then
- echo "enable quota as required"
- setup_quota $MOUNT || return 2
- else
- echo "disable quota as required"
- $LFS quotaoff -ug $MOUNT > /dev/null 2>&1
- fi
- fi
+ local jobid_var
+ if [ -z "$(lctl get_param -n mdc.*.connect_flags | grep jobstats)" ]; then
+ jobid_var="none"
+ elif [ $JOBSTATS_AUTO -ne 0 ]; then
+ echo "enable jobstats, set job scheduler as $JOBID_VAR"
+ jobid_var=$JOBID_VAR
+ else
+ jobid_var=`$LCTL get_param -n jobid_var`
+ if [ $jobid_var != "disable" ]; then
+ echo "disable jobstats as required"
+ jobid_var="disable"
+ else
+ jobid_var="none"
+ fi
+ fi
- return 0
+ if [ $jobid_var == $JOBID_VAR -o $jobid_var == "disable" ]; then
+ do_facet mgs $LCTL conf_param $FSNAME.sys.jobid_var=$jobid_var
+ wait_update $HOSTNAME "$LCTL get_param -n jobid_var" \
+ $jobid_var || return 1
+ fi
+
+ if [ $QUOTA_AUTO -ne 0 ]; then
+ if [ "$ENABLE_QUOTA" ]; then
+ echo "enable quota as required"
+ setup_quota $MOUNT || return 2
+ else
+ echo "disable quota as required"
+ # $LFS quotaoff -ug $MOUNT > /dev/null 2>&1
+ fi
+ fi
+ return 0
}
nfs_client_mode () {
}
check_config_clients () {
- local clients=${CLIENTS:-$HOSTNAME}
- local mntpt=$1
+ local clients=${CLIENTS:-$HOSTNAME}
+ local mntpt=$1
- nfs_client_mode && return
+ nfs_client_mode && return
- do_rpc_nodes $clients check_config_client $mntpt
+ do_rpc_nodes "$clients" check_config_client $mntpt
- sanity_mount_check ||
- error "environments are insane!"
+ sanity_mount_check || error "environments are insane!"
}
check_timeout () {
# verify a directory is shared among nodes.
check_shared_dir() {
- local dir=$1
+ local dir=$1
- [ -z "$dir" ] && return 1
- do_rpc_nodes $(comma_list $(nodes_list)) check_logdir $dir
- check_write_access $dir || return 1
- return 0
+ [ -z "$dir" ] && return 1
+ do_rpc_nodes "$(comma_list $(nodes_list))" check_logdir $dir
+ check_write_access $dir || return 1
+ return 0
}
# Run e2fsck on MDT and OST(s) to generate databases used for lfsck.
local ostidx
local dev
+ [[ $(lustre_version_code $SINGLEMDS) -ne $(version_code 2.2.0) ]] ||
+ { skip "Lustre 2.2.0 lacks the patch for LU-1255"; exit 0; }
+
check_shared_dir $SHARED_DIRECTORY ||
error "$SHARED_DIRECTORY isn't a shared directory"
run_lfsck
fi
- if is_mounted $MOUNT; then
- [ -n "$DIR" ] && rm -rf $DIR/[Rdfs][0-9]* ||
- error "remove sub-test dirs failed"
- [ "$ENABLE_QUOTA" ] && restore_quota_type || true
- fi
+ if is_mounted $MOUNT; then
+ [ -n "$DIR" ] && rm -rf $DIR/[Rdfs][0-9]* ||
+ error "remove sub-test dirs failed"
+ [ "$ENABLE_QUOTA" ] && restore_quota || true
+ fi
if [ "$I_UMOUNTED2" = "yes" ]; then
restore_mount $MOUNT2 || error "restore $MOUNT2 failed"
eval $@
}
+# Convert a space-delimited list to a comma-delimited list. If the input is
+# only whitespace, ensure the output is empty (i.e. "") so [ -n $list ] works
comma_list() {
- # the sed converts spaces to commas, but leaves the last space
- # alone, so the line doesn't end with a comma.
- echo "$*" | tr -s " " "\n" | sort -b -u | tr "\n" " " | sed 's/ \([^$]\)/,\1/g'
+ # echo is used to convert newlines to spaces, since it doesn't
+ # introduce a trailing space as using "tr '\n' ' '" does
+ echo $(tr -s " " "\n" <<< $* | sort -b -u) | tr ' ' ','
}
list_member () {
error_noexit "$@"
}
+error_and_remount() {
+ error_noexit "$@"
+ remount_client $MOUNT
+ exit 1
+}
+
skip_env () {
$FAIL_ON_SKIP_ENV && error false $@ || skip $@
}
-skip () {
- echo
- log " SKIP: ${TESTSUITE} ${TESTNAME} $@"
- [ "$ALWAYS_SKIPPED" ] && \
- skip_logged ${TESTNAME} "$@" || true
- [ "$TESTSUITELOG" ] && \
- echo "${TESTSUITE}: SKIP: $TESTNAME $@" >> $TESTSUITELOG || true
+skip() {
+ echo
+ log " SKIP: $TESTSUITE $TESTNAME $@"
+
+ if [[ -n "$ALWAYS_SKIPPED" ]]; then
+ skip_logged $TESTNAME "$@"
+ else
+ mkdir -p $LOGDIR
+ echo "$@" > $LOGDIR/skip
+ fi
+
+ [[ -n "$TESTSUITELOG" ]] &&
+ echo "$TESTSUITE: SKIP: $TESTNAME $@" >> $TESTSUITELOG || true
}
build_test_filter() {
echo -n "."
return 0
fi
+
+ LAST_SKIPPED="y"
+ ALWAYS_SKIPPED="y"
testname=EXCEPT_$1
if [ ${!testname}x != x ]; then
- LAST_SKIPPED="y"
TESTNAME=test_$1 skip "skipping excluded test $1"
return 0
fi
testname=EXCEPT_$base
if [ ${!testname}x != x ]; then
- LAST_SKIPPED="y"
TESTNAME=test_$1 skip "skipping excluded test $1 (base $base)"
return 0
fi
testname=EXCEPT_ALWAYS_$1
if [ ${!testname}x != x ]; then
- LAST_SKIPPED="y"
- ALWAYS_SKIPPED="y"
TESTNAME=test_$1 skip "skipping ALWAYS excluded test $1"
return 0
fi
testname=EXCEPT_ALWAYS_$base
if [ ${!testname}x != x ]; then
- LAST_SKIPPED="y"
- ALWAYS_SKIPPED="y"
TESTNAME=test_$1 skip "skipping ALWAYS excluded test $1 (base $base)"
return 0
fi
testname=EXCEPT_SLOW_$1
if [ ${!testname}x != x ]; then
- LAST_SKIPPED="y"
TESTNAME=test_$1 skip "skipping SLOW test $1"
return 0
fi
testname=EXCEPT_SLOW_$base
if [ ${!testname}x != x ]; then
- LAST_SKIPPED="y"
TESTNAME=test_$1 skip "skipping SLOW test $1 (base $base)"
return 0
fi
}
pass() {
- # Set TEST_STATUS here; will be used for logging the result
- if [ -f $LOGDIR/err ]; then
- TEST_STATUS="FAIL"
- else
- TEST_STATUS="PASS"
- fi
- echo "$TEST_STATUS $@" 2>&1 | tee -a $TESTSUITELOG
+ # Set TEST_STATUS here. It will be used for logging the result.
+ TEST_STATUS="PASS"
+
+ if [[ -f $LOGDIR/err ]]; then
+ TEST_STATUS="FAIL"
+ elif [[ -f $LOGDIR/skip ]]; then
+ TEST_STATUS="SKIP"
+ fi
+ echo "$TEST_STATUS $@" 2>&1 | tee -a $TESTSUITELOG
}
check_mds() {
local name=${TESTSUITE}.test_${1}.test_log.$(hostname -s).log
local test_log=$LOGDIR/$name
rm -rf $LOGDIR/err
+ rm -rf $LOGDIR/skip
local SAVE_UMASK=`umask`
umask 0022
duration=$((`date +%s` - $BEFORE))
pass "$1" "(${duration}s)"
- [ -f $LOGDIR/err ] && TEST_ERROR=$(cat $LOGDIR/err)
+
+ if [[ -f $LOGDIR/err ]]; then
+ TEST_ERROR=$(cat $LOGDIR/err)
+ elif [[ -f $LOGDIR/skip ]]; then
+ TEST_ERROR=$(cat $LOGDIR/skip)
+ fi
log_sub_test_end $TEST_STATUS $duration "$RC" "$TEST_ERROR"
if [ -f $LOGDIR/err ]; then
# Print information of skipped tests to result.yml
#
skip_logged(){
- log_sub_test_begin $1
- log_sub_test_end "SKIP" "0" "0" "\"$2\""
+ log_sub_test_begin $1
+ shift
+ log_sub_test_end "SKIP" "0" "0" "$@"
}
canonical_path() {
}
remote_nodes_list () {
- local rnodes=$(nodes_list)
- rnodes=$(echo " $rnodes " | sed -re "s/\s+$HOSTNAME\s+/ /g")
- echo $rnodes
+ echo $(nodes_list) | sed -re "s/\<$HOSTNAME\>//g"
}
init_clients_lists () {
do_nodev $nfsserver lfs setstripe "$@"
}
+# Check and add a test group.
+add_group() {
+ local group_id=$1
+ local group_name=$2
+ local rc=0
+
+ local gid=$(getent group $group_name | cut -d: -f3)
+ if [[ -n "$gid" ]]; then
+ [[ "$gid" -eq "$group_id" ]] || {
+ error_noexit "inconsistent group ID:" \
+ "new: $group_id, old: $gid"
+ rc=1
+ }
+ else
+ groupadd -g $group_id $group_name
+ rc=${PIPESTATUS[0]}
+ fi
+
+ return $rc
+}
+
+# Check and add a test user.
+add_user() {
+ local user_id=$1
+ shift
+ local user_name=$1
+ shift
+ local group_name=$1
+ shift
+ local home=$1
+ shift
+ local opts="$@"
+ local rc=0
+
+ local uid=$(getent passwd $user_name | cut -d: -f3)
+ if [[ -n "$uid" ]]; then
+ if [[ "$uid" -eq "$user_id" ]]; then
+ local dir=$(getent passwd $user_name | cut -d: -f6)
+ if [[ "$dir" != "$home" ]]; then
+ mkdir -p $home
+ usermod -d $home $user_name
+ rc=${PIPESTATUS[0]}
+ fi
+ else
+ error_noexit "inconsistent user ID:" \
+ "new: $user_id, old: $uid"
+ rc=1
+ fi
+ else
+ mkdir -p $home
+ useradd -M -u $user_id -d $home -g $group_name $opts $user_name
+ rc=${PIPESTATUS[0]}
+ fi
+
+ return $rc
+}
+
check_runas_id_ret() {
local myRC=0
local myRUNAS_UID=$1
}
check_catastrophe() {
- local rnodes=${1:-$(comma_list $(remote_nodes_list))}
- local C=$CATASTROPHE
- [ -f $C ] && [ $(cat $C) -ne 0 ] && return 1
+ local rnodes=${1:-$(comma_list $(remote_nodes_list))}
+ local C=$CATASTROPHE
+ [ -f $C ] && [ $(cat $C) -ne 0 ] && return 1
- if [ $rnodes ]; then
- do_nodes $rnodes "rc=\\\$([ -f $C ] && echo \\\$(< $C) || echo 0);
-if [ \\\$rc -ne 0 ]; then echo \\\$(hostname): \\\$rc; fi
-exit \\\$rc;"
- fi
+ [ -z "$rnodes" ] && return 0
+
+ do_nodes "$rnodes" "rc=\\\$([ -f $C ] && echo \\\$(< $C) || echo 0);
+ if [ \\\$rc -ne 0 ]; then echo \\\$(hostname): \\\$rc; fi
+ exit \\\$rc;"
}
# CMD: determine mds index where directory inode presents
# 2. wait the deadline of client 2nd request
local maxtime=$(( 2 * $(request_timeout $facet)))
- if ! do_rpc_nodes $(facet_host $facet) \
- _wait_import_state $expected $param $maxtime; then
- error "import is not in ${expected} state"
- return 1
- fi
+ if ! do_rpc_nodes "$(facet_host $facet)" \
+ _wait_import_state $expected $param $maxtime; then
+ error "import is not in ${expected} state"
+ return 1
+ fi
- return 0
+ return 0
}
get_clientmdc_proc_path() {
}
do_rpc_nodes () {
- local list=$1
- shift
+ local list=$1
+ shift
+
+ [ -z "$list" ] && return 0
- # Add paths to lustre tests for 32 and 64 bit systems.
- local RPATH="PATH=$RLUSTRE/tests:/usr/lib/lustre/tests:/usr/lib64/lustre/tests:$PATH"
- do_nodesv $list "${RPATH} NAME=${NAME} sh rpc.sh $@ "
+ # Add paths to lustre tests for 32 and 64 bit systems.
+ local RPATH="PATH=$RLUSTRE/tests:/usr/lib/lustre/tests:/usr/lib64/lustre/tests:$PATH"
+ do_nodesv $list "${RPATH} NAME=${NAME} sh rpc.sh $@ "
}
wait_clients_import_state () {
local params=$(expand_list $params $proc_path)
done
- if ! do_rpc_nodes $list wait_import_state $expected $params; then
- error "import is not in ${expected} state"
- return 1
- fi
+ if ! do_rpc_nodes "$list" wait_import_state $expected $params; then
+ error "import is not in ${expected} state"
+ return 1
+ fi
}
oos_full() {