grep -q crc16 $SYMLIST || { modprobe crc16 2>/dev/null || true; }
grep -q -w jbd $SYMLIST || { modprobe jbd 2>/dev/null || true; }
grep -q -w jbd2 $SYMLIST || { modprobe jbd2 2>/dev/null || true; }
- if [[ $(node_fstypes $HOSTNAME) == *ldiskfs* ]]; then
- grep -q exportfs_decode_fh $SYMLIST ||
- { modprobe exportfs 2> /dev/null || true; }
- load_module ../ldiskfs/ldiskfs/ldiskfs
- fi
[ "$LQUOTA" != "no" ] && load_module quota/lquota $LQUOTAOPTS
+ if [[ $(node_fstypes $HOSTNAME) == *zfs* ]]; then
+ load_module osd-zfs/osd_zfs
+ fi
load_module mgs/mgs
load_module mds/mds
load_module mdd/mdd
+ if [[ $(node_fstypes $HOSTNAME) == *ldiskfs* ]]; then
+ #
+ # This block shall be moved up beside osd-zfs as soon
+ # as osd-ldiskfs stops using mdd symbols.
+ #
+ grep -q exportfs_decode_fh $SYMLIST ||
+ { modprobe exportfs 2> /dev/null || true; }
+ load_module ../ldiskfs/ldiskfs/ldiskfs
+ load_module lvfs/fsfilt_ldiskfs
+ load_module osd-ldiskfs/osd_ldiskfs
+ fi
load_module mdt/mdt
- load_module lvfs/fsfilt_ldiskfs
load_module cmm/cmm
- load_module osd-ldiskfs/osd_ldiskfs
load_module ost/ost
if [ "$USE_OFD" == yes ]; then
load_module ofd/ofd
local name=$3
do_nodes $nodes "$LCTL get_param -n obdfilter.$device.$name \
- osd-*.$device.$name" 2>&1 | grep -v 'Found no match'
+ osd-*.$device.$name 2>&1" | grep -v 'Found no match'
}
set_obdfilter_param() {
local value=$4
do_nodes $nodes "$LCTL set_param -n obdfilter.$device.$name=$value \
- osd-*.$device.$name=$value" 2>&1 | grep -v 'Found no match'
+ osd-*.$device.$name=$value 2>&1" | grep -v 'Found no match'
}
set_debug_size () {
return $RC
}
+#
+# When a ZFS OSD is made read-only by replay_barrier(), its pool is "freezed".
+# Because stopping corresponding target may not clear this in-memory state, we
+# need to zap the pool from memory by exporting and reimporting the pool.
+#
+# Although the uberblocks are not updated when a pool is freezed, transactions
+# are still written to the disks. Modified blocks may be cached in memory when
+# tests try reading them back. The export-and-reimport process also evicts any
+# cached pool data from memory to provide the correct "data loss" semantics.
+#
+refresh_disk() {
+ local facet=$1
+ local fstype=$(facet_fstype $facet)
+ local _dev
+ local dev
+ local poolname
+
+ if [ "${fstype}" == "zfs" ]; then
+ _dev=$(facet_active $facet)_dev
+ dev=${!_dev} # expand _dev to its value, e.g. ${mds1_dev}
+ poolname="${dev%%/*}" # poolname is string before "/"
+
+ if [ "${poolname}" == "" ]; then
+ echo "invalid dataset name: $dev"
+ return
+ fi
+ do_facet $facet "cp /etc/zfs/zpool.cache /tmp/zpool.cache.back"
+ do_facet $facet "$ZPOOL export ${poolname}"
+ do_facet $facet "$ZPOOL import -f -c /tmp/zpool.cache.back \
+ ${poolname}"
+ fi
+}
+
stop() {
local running
local facet=$1
}
reboot_facet() {
- local facet=$1
- if [ "$FAILURE_MODE" = HARD ]; then
- reboot_node $(facet_active_host $facet)
- else
- sleep 10
- fi
+ local facet=$1
+ if [ "$FAILURE_MODE" = HARD ]; then
+ reboot_node $(facet_active_host $facet)
+ else
+ refresh_disk ${facet}
+ sleep 10
+ fi
}
boot_node() {
echo "Failing $facet on node $host"
- # Make sure the client data is synced to disk. LU-924
- #
- # We don't write client data synchrnously (to avoid flooding sync writes
- # when there are many clients connecting), so if the server reboots before
- # the client data reachs disk, the client data will be lost and the client
- # will be evicted after recovery, which is not what we expected.
- do_facet $facet "sync; sync; sync"
-
local affected=$(affected_facets $facet)
shutdown_facet $facet
}
fail_abort() {
- local facet=$1
- stop $facet
- change_active $facet
- wait_for_facet $facet
- mount_facet $facet -o abort_recovery
- clients_up || echo "first df failed: $?"
- clients_up || error "post-failover df: $?"
+ local facet=$1
+ stop $facet
+ refresh_disk ${facet}
+ change_active $facet
+ wait_for_facet $facet
+ mount_facet $facet -o abort_recovery
+ clients_up || echo "first df failed: $?"
+ clients_up || error "post-failover df: $?"
}
do_lmc() {
get_env_vars() {
local var
local value
+ local facets=$(get_facets)
+ local facet
for var in ${!MODOPTS_*}; do
value=${!var}
done
echo -n " USE_OFD=$USE_OFD"
+
+ for facet in ${facets//,/ }; do
+ var=${facet}_FSTYPE
+ if [ -n "${!var}" ]; then
+ echo -n " $var=${!var}"
+ fi
+ done
+
+ for var in MGSFSTYPE MDSFSTYPE OSTFSTYPE; do
+ if [ -n "${!var}" ]; then
+ echo -n " $var=${!var}"
+ fi
+ done
+
+ if [ -n "$FSTYPE" ]; then
+ echo -n " FSTYPE=$FSTYPE"
+ fi
}
do_nodes() {
do_node $HOST "$@"
}
+# Function: do_facet_random_file $FACET $FILE $SIZE
+# Creates FILE with random content on the given FACET of given SIZE
+
+do_facet_random_file() {
+ local facet="$1"
+ local fpath="$2"
+ local fsize="$3"
+ local cmd="dd if=/dev/urandom of='$fpath' bs=$fsize count=1"
+ do_facet $facet "$cmd 2>/dev/null"
+}
+
+do_facet_create_file() {
+ local facet="$1"
+ local fpath="$2"
+ local fsize="$3"
+ local cmd="dd if=/dev/zero of='$fpath' bs=$fsize count=1"
+ do_facet $facet "$cmd 2>/dev/null"
+}
+
do_nodesv() {
do_nodes --verbose "$@"
}
debugrestore
}
+# prints bash call stack
+log_trace_dump() {
+ echo " Trace dump:"
+ for (( i=1; i < ${#BASH_LINENO[*]} ; i++ )) ; do
+ local s=${BASH_SOURCE[$i]}
+ local l=${BASH_LINENO[$i-1]}
+ local f=${FUNCNAME[$i]}
+ echo " = $s:$l:$f()"
+ done
+}
+
##################################
# Test interface
##################################
fi
log " ${TESTSUITE} ${TESTNAME}: @@@@@@ ${TYPE}: $@ "
+ log_trace_dump
mkdir -p $LOGDIR
# We need to dump the logs on all nodes
}
exit_status () {
- local status=0
- local log=$TESTSUITELOG
+ local status=0
+ local log=$TESTSUITELOG
- [ -f "$log" ] && grep -q FAIL: $log && status=1
- exit $status
+ [ -f "$log" ] && grep -q FAIL $log && status=1
+ exit $status
}
error() {
run_one() {
local testnum=$1
local message=$2
- tfile=f${testnum}
+ tfile=f.${TESTSUITE}.${testnum}
export tdir=d0.${TESTSUITE}/d${base}
export TESTNAME=test_$testnum
local SAVE_UMASK=`umask`
# - test result is saved to data file
#
run_one_logged() {
- local BEFORE=`date +%s`
- local TEST_ERROR
- local name=${TESTSUITE}.test_${1}.test_log.$(hostname -s).log
- local test_log=$LOGDIR/$name
- rm -rf $LOGDIR/err
- local SAVE_UMASK=`umask`
- umask 0022
-
- echo
- log_sub_test_begin test_${1}
- (run_one $1 "$2") 2>&1 | tee -i $test_log
- local RC=${PIPESTATUS[0]}
-
- [ $RC -ne 0 ] && [ ! -f $LOGDIR/err ] && \
- echo "test_$1 returned $RC" | tee $LOGDIR/err
-
- duration=$((`date +%s` - $BEFORE))
- pass "$1" "(${duration}s)"
- [ -f $LOGDIR/err ] && TEST_ERROR=$(cat $LOGDIR/err)
- log_sub_test_end $TEST_STATUS $duration "$RC" "$TEST_ERROR"
-
- if [ -f $LOGDIR/err ]; then
- $FAIL_ON_ERROR && exit $RC
- fi
+ local BEFORE=`date +%s`
+ local TEST_ERROR
+ local name=${TESTSUITE}.test_${1}.test_log.$(hostname -s).log
+ local test_log=$LOGDIR/$name
+ rm -rf $LOGDIR/err
+ local SAVE_UMASK=`umask`
+ umask 0022
+
+ echo
+ log_sub_test_begin test_${1}
+ (run_one $1 "$2") 2>&1 | tee -i $test_log
+ local RC=${PIPESTATUS[0]}
+
+ [ $RC -ne 0 ] && [ ! -f $LOGDIR/err ] && \
+ echo "test_$1 returned $RC" | tee $LOGDIR/err
+
+ duration=$((`date +%s` - $BEFORE))
+ pass "$1" "(${duration}s)"
+ [ -f $LOGDIR/err ] && TEST_ERROR=$(cat $LOGDIR/err)
+ log_sub_test_end $TEST_STATUS $duration "$RC" "$TEST_ERROR"
+
+ if [ -f $LOGDIR/err ]; then
+ $FAIL_ON_ERROR && exit $RC
+ fi
- umask $SAVE_UMASK
+ umask $SAVE_UMASK
- return $RC
+ return 0
}
#
git://git.whamcloud.com / fs / lustre-release.git / blobdiff