Whamcloud - gitweb
9354b38913bb6aba63bcf82cff13c07d3d34d2d0
[fs/lustre-release.git] / lustre / tests / test-framework.sh
1 #!/bin/bash
2
3 trap 'print_summary && print_stack_trace | tee $TF_FAIL && \
4     echo "$TESTSUITE: FAIL: test-framework exiting on error"' ERR
5 set -e
6
7 export LANG=en_US
8 export REFORMAT=${REFORMAT:-""}
9 export WRITECONF=${WRITECONF:-""}
10 export VERBOSE=${VERBOSE:-false}
11 export GSS=${GSS:-false}
12 export GSS_SK=${GSS_SK:-false}
13 export GSS_KRB5=false
14 export GSS_PIPEFS=false
15 export SHARED_KEY=${SHARED_KEY:-false}
16 export SK_PATH=${SK_PATH:-/tmp/test-framework-keys}
17 export SK_OM_PATH=$SK_PATH'/tmp-request-mount'
18 export SK_MOUNTED=${SK_MOUNTED:-false}
19 export SK_FLAVOR=${SK_FLAVOR:-ski}
20 export SK_NO_KEY=${SK_NO_KEY:-true}
21 export SK_UNIQUE_NM=${SK_UNIQUE_NM:-false}
22 export SK_S2S=${SK_S2S:-false}
23 export SK_S2SNM=${SK_S2SNM:-TestFrameNM}
24 export SK_S2SNMCLI=${SK_S2SNMCLI:-TestFrameNMCli}
25 export SK_SKIPFIRST=${SK_SKIPFIRST:-true}
26 export IDENTITY_UPCALL=default
27 export QUOTA_AUTO=1
28 export FLAKEY=${FLAKEY:-true}
29 # specify environment variable containing batch job name for server statistics
30 export JOBID_VAR=${JOBID_VAR:-"procname_uid"}  # or "existing" or "disable"
31
32 #export PDSH="pdsh -S -Rssh -w"
33 export MOUNT_CMD=${MOUNT_CMD:-"mount -t lustre"}
34 export UMOUNT=${UMOUNT:-"umount -d"}
35
36 export LSNAPSHOT_CONF="/etc/ldev.conf"
37 export LSNAPSHOT_LOG="/var/log/lsnapshot.log"
38
39 # sles12 umount has a issue with -d option
40 [ -e /etc/SuSE-release ] && grep -w VERSION /etc/SuSE-release | grep -wq 12 && {
41         export UMOUNT="umount"
42 }
43
44 # function used by scripts run on remote nodes
45 LUSTRE=${LUSTRE:-$(cd $(dirname $0)/..; echo $PWD)}
46 . $LUSTRE/tests/functions.sh
47 . $LUSTRE/tests/yaml.sh
48
49 export LD_LIBRARY_PATH=${LUSTRE}/utils/.libs:${LUSTRE}/utils:${LD_LIBRARY_PATH}
50
51 LUSTRE_TESTS_CFG_DIR=${LUSTRE_TESTS_CFG_DIR:-${LUSTRE}/tests/cfg}
52
53 EXCEPT_LIST_FILE=${EXCEPT_LIST_FILE:-${LUSTRE_TESTS_CFG_DIR}/tests-to-skip.sh}
54
55 if [ -f "$EXCEPT_LIST_FILE" ]; then
56     echo "Reading test skip list from $EXCEPT_LIST_FILE"
57     cat $EXCEPT_LIST_FILE
58     . $EXCEPT_LIST_FILE
59 fi
60
61 # check config files for options in decreasing order of preference
62 [ -z "$MODPROBECONF" -a -f /etc/modprobe.d/lustre.conf ] &&
63     MODPROBECONF=/etc/modprobe.d/lustre.conf
64 [ -z "$MODPROBECONF" -a -f /etc/modprobe.d/Lustre ] &&
65     MODPROBECONF=/etc/modprobe.d/Lustre
66 [ -z "$MODPROBECONF" -a -f /etc/modprobe.conf ] &&
67     MODPROBECONF=/etc/modprobe.conf
68
69 sanitize_parameters() {
70         for i in DIR DIR1 DIR2 MOUNT MOUNT1 MOUNT2
71         do
72                 local path=${!i}
73                 if [ -d "$path" ]; then
74                         eval export $i=$(echo $path | sed -r 's/\/+$//g')
75                 fi
76         done
77 }
78 assert_DIR () {
79         local failed=""
80         [[ $DIR/ = $MOUNT/* ]] ||
81                 { failed=1 && echo "DIR=$DIR not in $MOUNT. Aborting."; }
82         [[ $DIR1/ = $MOUNT1/* ]] ||
83                 { failed=1 && echo "DIR1=$DIR1 not in $MOUNT1. Aborting."; }
84         [[ $DIR2/ = $MOUNT2/* ]] ||
85                 { failed=1 && echo "DIR2=$DIR2 not in $MOUNT2. Aborting"; }
86
87         [ -n "$failed" ] && exit 99 || true
88 }
89
90 usage() {
91     echo "usage: $0 [-r] [-f cfgfile]"
92     echo "       -r: reformat"
93
94     exit
95 }
96
97 print_summary () {
98         trap 0
99         [ -z "$DEFAULT_SUITES" ] && return 0
100         [ -n "$ONLY" ] && echo "WARNING: ONLY is set to $(echo $ONLY)"
101         local details
102         local form="%-13s %-17s %-9s %s %s\n"
103
104         printf "$form" "status" "script" "Total(sec)" "E(xcluded) S(low)"
105         echo "---------------------------------------------------------------"
106     for O in $DEFAULT_SUITES; do
107         O=$(echo $O  | tr "-" "_" | tr "[:lower:]" "[:upper:]")
108         [ "${!O}" = "no" ] && continue || true
109         local o=$(echo $O  | tr "[:upper:]_" "[:lower:]-")
110         local log=${TMP}/${o}.log
111         if is_sanity_benchmark $o; then
112             log=${TMP}/sanity-benchmark.log
113         fi
114         local slow=
115         local skipped=
116         local total=
117         local status=Unfinished
118         if [ -f $log ]; then
119                 skipped=$(grep excluded $log | awk '{ printf " %s", $3 }' |
120                         sed 's/test_//g')
121                 slow=$(egrep "^PASS|^FAIL" $log | tr -d "("| sed s/s\)$//g |
122                         sort -nr -k 3  | head -n5 |  awk '{ print $2":"$3"s" }')
123                 total=$(grep duration $log | awk '{ print $2 }')
124                 if [ "${!O}" = "done" ]; then
125                         status=Done
126                 fi
127                 if $DDETAILS; then
128                         local durations=$(egrep "^PASS|^FAIL" $log |
129                                 tr -d "("| sed s/s\)$//g |
130                                 awk '{ print $2":"$3"|" }')
131                         details=$(printf "%s\n%s %s %s\n" "$details" \
132                                 "DDETAILS" "$O" "$(echo $durations)")
133                 fi
134         fi
135         printf "$form" $status "$O" "${total}" "E=$skipped"
136         printf "$form" "-" "-" "-" "S=$(echo $slow)"
137     done
138
139     for O in $DEFAULT_SUITES; do
140         O=$(echo $O  | tr "-" "_" | tr "[:lower:]" "[:upper:]")
141         if [ "${!O}" = "no" ]; then
142             printf "$form" "Skipped" "$O" ""
143         fi
144     done
145
146     # print the detailed tests durations if DDETAILS=true
147     if $DDETAILS; then
148         echo "$details"
149     fi
150 }
151
152 # Get information about the Lustre environment. The information collected
153 # will be used in Lustre tests.
154 # usage: get_lustre_env
155 # input: No required or optional arguments
156 # output: No return values, environment variables are exported
157
158 get_lustre_env() {
159
160         export mds1_FSTYPE=${mds1_FSTYPE:-$(facet_fstype mds1)}
161         export ost1_FSTYPE=${ost1_FSTYPE:-$(facet_fstype ost1)}
162
163         export MGS_VERSION=$(lustre_version_code mgs)
164         export MDS1_VERSION=$(lustre_version_code mds1)
165         export OST1_VERSION=$(lustre_version_code ost1)
166         export CLIENT_VERSION=$(lustre_version_code client)
167
168         # Prefer using "mds1" directly instead of SINGLEMDS.
169         # Keep this for compat until it is removed from scripts.
170         export SINGLEMDS=${SINGLEMDS:-mds1}
171 }
172
173 init_test_env() {
174         export LUSTRE=$(absolute_path $LUSTRE)
175         export TESTSUITE=$(basename $0 .sh)
176         export TEST_FAILED=false
177         export FAIL_ON_SKIP_ENV=${FAIL_ON_SKIP_ENV:-false}
178         export RPC_MODE=${RPC_MODE:-false}
179         export DO_CLEANUP=${DO_CLEANUP:-true}
180         export KEEP_ZPOOL=${KEEP_ZPOOL:-false}
181         export CLEANUP_DM_DEV=false
182         export PAGE_SIZE=$(get_page_size client)
183
184         export MKE2FS=$MKE2FS
185         if [ -z "$MKE2FS" ]; then
186                 if which mkfs.ldiskfs >/dev/null 2>&1; then
187                         export MKE2FS=mkfs.ldiskfs
188                 else
189                         export MKE2FS=mke2fs
190                 fi
191         fi
192
193         export DEBUGFS=$DEBUGFS
194         if [ -z "$DEBUGFS" ]; then
195                 if which debugfs.ldiskfs >/dev/null 2>&1; then
196                         export DEBUGFS=debugfs.ldiskfs
197                 else
198                         export DEBUGFS=debugfs
199                 fi
200         fi
201
202         export TUNE2FS=$TUNE2FS
203         if [ -z "$TUNE2FS" ]; then
204                 if which tunefs.ldiskfs >/dev/null 2>&1; then
205                         export TUNE2FS=tunefs.ldiskfs
206                 else
207                         export TUNE2FS=tune2fs
208                 fi
209         fi
210
211         export E2LABEL=$E2LABEL
212         if [ -z "$E2LABEL" ]; then
213                 if which label.ldiskfs >/dev/null 2>&1; then
214                         export E2LABEL=label.ldiskfs
215                 else
216                         export E2LABEL=e2label
217                 fi
218         fi
219
220         export DUMPE2FS=$DUMPE2FS
221         if [ -z "$DUMPE2FS" ]; then
222                 if which dumpfs.ldiskfs >/dev/null 2>&1; then
223                         export DUMPE2FS=dumpfs.ldiskfs
224                 else
225                         export DUMPE2FS=dumpe2fs
226                 fi
227         fi
228
229         export E2FSCK=$E2FSCK
230         if [ -z "$E2FSCK" ]; then
231                 if which fsck.ldiskfs >/dev/null 2>&1; then
232                         export E2FSCK=fsck.ldiskfs
233                 else
234                          export E2FSCK=e2fsck
235                 fi
236         fi
237
238         export RESIZE2FS=$RESIZE2FS
239         if [ -z "$RESIZE2FS" ]; then
240                 if which resizefs.ldiskfs >/dev/null 2>&1; then
241                         export RESIZE2FS=resizefs.ldiskfs
242                 else
243                         export RESIZE2FS=resize2fs
244                 fi
245         fi
246
247         export LFSCK_ALWAYS=${LFSCK_ALWAYS:-"no"} # check fs after test suite
248         export FSCK_MAX_ERR=4   # File system errors left uncorrected
249
250         export ZFS=${ZFS:-zfs}
251         export ZPOOL=${ZPOOL:-zpool}
252         export ZDB=${ZDB:-zdb}
253         export PARTPROBE=${PARTPROBE:-partprobe}
254
255         #[ -d /r ] && export ROOT=${ROOT:-/r}
256         export TMP=${TMP:-$ROOT/tmp}
257         export TESTSUITELOG=${TMP}/${TESTSUITE}.log
258         export LOGDIR=${LOGDIR:-${TMP}/test_logs/$(date +%s)}
259         export TESTLOG_PREFIX=$LOGDIR/$TESTSUITE
260
261         export HOSTNAME=${HOSTNAME:-$(hostname -s)}
262         if ! echo $PATH | grep -q $LUSTRE/utils; then
263                 export PATH=$LUSTRE/utils:$PATH
264         fi
265         if ! echo $PATH | grep -q $LUSTRE/utils/gss; then
266                 export PATH=$LUSTRE/utils/gss:$PATH
267         fi
268         if ! echo $PATH | grep -q $LUSTRE/tests; then
269                 export PATH=$LUSTRE/tests:$PATH
270         fi
271         if ! echo $PATH | grep -q $LUSTRE/../lustre-iokit/sgpdd-survey; then
272                 export PATH=$LUSTRE/../lustre-iokit/sgpdd-survey:$PATH
273         fi
274         export LST=${LST:-"$LUSTRE/../lnet/utils/lst"}
275         [ ! -f "$LST" ] && export LST=$(which lst)
276         export SGPDDSURVEY=${SGPDDSURVEY:-"$LUSTRE/../lustre-iokit/sgpdd-survey/sgpdd-survey")}
277         [ ! -f "$SGPDDSURVEY" ] && export SGPDDSURVEY=$(which sgpdd-survey)
278         export MCREATE=${MCREATE:-mcreate}
279         export MULTIOP=${MULTIOP:-multiop}
280         export MMAP_CAT=${MMAP_CAT:-mmap_cat}
281         export STATX=${STATX:-statx}
282         # Ubuntu, at least, has a truncate command in /usr/bin
283         # so fully path our truncate command.
284         export TRUNCATE=${TRUNCATE:-$LUSTRE/tests/truncate}
285         export FSX=${FSX:-$LUSTRE/tests/fsx}
286         export MDSRATE=${MDSRATE:-"$LUSTRE/tests/mpi/mdsrate"}
287         [ ! -f "$MDSRATE" ] && export MDSRATE=$(which mdsrate 2> /dev/null)
288         if ! echo $PATH | grep -q $LUSTRE/tests/racer; then
289                 export PATH=$LUSTRE/tests/racer:$PATH:
290         fi
291         if ! echo $PATH | grep -q $LUSTRE/tests/mpi; then
292                 export PATH=$LUSTRE/tests/mpi:$PATH
293         fi
294         export RSYNC_RSH=${RSYNC_RSH:-rsh}
295
296         export LCTL=${LCTL:-"$LUSTRE/utils/lctl"}
297         [ ! -f "$LCTL" ] && export LCTL=$(which lctl)
298         export LFS=${LFS:-"$LUSTRE/utils/lfs"}
299         [ ! -f "$LFS" ] && export LFS=$(which lfs)
300
301         export PERM_CMD=${PERM_CMD:-"$LCTL conf_param"}
302
303         export L_GETIDENTITY=${L_GETIDENTITY:-"$LUSTRE/utils/l_getidentity"}
304         if [ ! -f "$L_GETIDENTITY" ]; then
305                 if `which l_getidentity > /dev/null 2>&1`; then
306                         export L_GETIDENTITY=$(which l_getidentity)
307                 else
308                         export L_GETIDENTITY=NONE
309                 fi
310         fi
311         export LL_DECODE_FILTER_FID=${LL_DECODE_FILTER_FID:-"$LUSTRE/utils/ll_decode_filter_fid"}
312         [ ! -f "$LL_DECODE_FILTER_FID" ] && export LL_DECODE_FILTER_FID="ll_decode_filter_fid"
313         export LL_DECODE_LINKEA=${LL_DECODE_LINKEA:-"$LUSTRE/utils/ll_decode_linkea"}
314         [ ! -f "$LL_DECODE_LINKEA" ] && export LL_DECODE_LINKEA="ll_decode_linkea"
315         export MKFS=${MKFS:-"$LUSTRE/utils/mkfs.lustre"}
316         [ ! -f "$MKFS" ] && export MKFS="mkfs.lustre"
317         export TUNEFS=${TUNEFS:-"$LUSTRE/utils/tunefs.lustre"}
318         [ ! -f "$TUNEFS" ] && export TUNEFS="tunefs.lustre"
319         export CHECKSTAT="${CHECKSTAT:-"checkstat -v"} "
320         export LUSTRE_RMMOD=${LUSTRE_RMMOD:-$LUSTRE/scripts/lustre_rmmod}
321         [ ! -f "$LUSTRE_RMMOD" ] &&
322                 export LUSTRE_RMMOD=$(which lustre_rmmod 2> /dev/null)
323         export LUSTRE_ROUTES_CONVERSION=${LUSTRE_ROUTES_CONVERSION:-$LUSTRE/scripts/lustre_routes_conversion}
324         [ ! -f "$LUSTRE_ROUTES_CONVERSION" ] &&
325                 export LUSTRE_ROUTES_CONVERSION=$(which lustre_routes_conversion 2> /dev/null)
326         export LFS_MIGRATE=${LFS_MIGRATE:-$LUSTRE/scripts/lfs_migrate}
327         [ ! -f "$LFS_MIGRATE" ] &&
328                 export LFS_MIGRATE=$(which lfs_migrate 2> /dev/null)
329         export LR_READER=${LR_READER:-"$LUSTRE/utils/lr_reader"}
330         [ ! -f "$LR_READER" ] &&
331                 export LR_READER=$(which lr_reader 2> /dev/null)
332         [ -z "$LR_READER" ] && export LR_READER="/usr/sbin/lr_reader"
333         export LSOM_SYNC=${LSOM_SYNC:-"$LUSTRE/utils/llsom_sync"}
334         [ ! -f "$LSOM_SYNC" ] &&
335                 export LSOM_SYNC=$(which llsom_sync 2> /dev/null)
336         [ -z "$LSOM_SYNC" ] && export LSOM_SYNC="/usr/sbin/llsom_sync"
337         export NAME=${NAME:-local}
338         export LGSSD=${LGSSD:-"$LUSTRE/utils/gss/lgssd"}
339         [ "$GSS_PIPEFS" = "true" ] && [ ! -f "$LGSSD" ] &&
340                 export LGSSD=$(which lgssd)
341         export LSVCGSSD=${LSVCGSSD:-"$LUSTRE/utils/gss/lsvcgssd"}
342         [ ! -f "$LSVCGSSD" ] && export LSVCGSSD=$(which lsvcgssd 2> /dev/null)
343         export KRB5DIR=${KRB5DIR:-"/usr/kerberos"}
344         export DIR2
345         export SAVE_PWD=${SAVE_PWD:-$LUSTRE/tests}
346         export AT_MAX_PATH
347         export LDEV=${LDEV:-"$LUSTRE/scripts/ldev"}
348         [ ! -f "$LDEV" ] && export LDEV=$(which ldev 2> /dev/null)
349
350         export DMSETUP=${DMSETUP:-dmsetup}
351         export DM_DEV_PATH=${DM_DEV_PATH:-/dev/mapper}
352         export LOSETUP=${LOSETUP:-losetup}
353
354         if [ "$ACCEPTOR_PORT" ]; then
355                 export PORT_OPT="--port $ACCEPTOR_PORT"
356         fi
357
358         if $SHARED_KEY; then
359                 $RPC_MODE || echo "Using GSS shared-key feature"
360                 which lgss_sk > /dev/null 2>&1 ||
361                         error_exit "built with lgss_sk disabled! SEC=$SEC"
362                 GSS=true
363                 GSS_SK=true
364                 SEC=$SK_FLAVOR
365         fi
366
367         case "x$SEC" in
368                 xkrb5*)
369                 $RPC_MODE || echo "Using GSS/krb5 ptlrpc security flavor"
370                 which lgss_keyring > /dev/null 2>&1 ||
371                         error_exit "built with gss disabled! SEC=$SEC"
372                 GSS=true
373                 GSS_KRB5=true
374                 ;;
375         esac
376
377         case "x$IDUP" in
378                 xtrue)
379                         IDENTITY_UPCALL=true
380                         ;;
381                 xfalse)
382                         IDENTITY_UPCALL=false
383                         ;;
384         esac
385
386         export LOAD_MODULES_REMOTE=${LOAD_MODULES_REMOTE:-false}
387
388         # Paths on remote nodes, if different
389         export RLUSTRE=${RLUSTRE:-$LUSTRE}
390         export RPWD=${RPWD:-$PWD}
391         export I_MOUNTED=${I_MOUNTED:-"no"}
392         export AUSTER_CLEANUP=${AUSTER_CLEANUP:-false}
393         if [ ! -f /lib/modules/$(uname -r)/kernel/fs/lustre/mdt.ko -a \
394              ! -f /lib/modules/$(uname -r)/updates/kernel/fs/lustre/mdt.ko -a \
395              ! -f /lib/modules/$(uname -r)/extra/kernel/fs/lustre/mdt.ko -a \
396              ! -f $LUSTRE/mdt/mdt.ko ]; then
397             export CLIENTMODSONLY=yes
398         fi
399
400         export SHUTDOWN_ATTEMPTS=${SHUTDOWN_ATTEMPTS:-3}
401         export OSD_TRACK_DECLARES_LBUG=${OSD_TRACK_DECLARES_LBUG:-"yes"}
402
403         # command line
404
405         while getopts "rvwf:" opt $*; do
406                 case $opt in
407                         f) CONFIG=$OPTARG;;
408                         r) REFORMAT=yes;;
409                         v) VERBOSE=true;;
410                         w) WRITECONF=writeconf;;
411                         \?) usage;;
412                 esac
413         done
414
415         shift $((OPTIND - 1))
416         ONLY=${ONLY:-$*}
417
418         # print the durations of each test if "true"
419         DDETAILS=${DDETAILS:-false}
420         [ "$TESTSUITELOG" ] && rm -f $TESTSUITELOG || true
421         if ! $RPC_MODE; then
422                 rm -f $TMP/*active
423         fi
424
425         export TF_FAIL=${TF_FAIL:-$TMP/tf.fail}
426
427         # Constants used in more than one test script
428         export LOV_MAX_STRIPE_COUNT=2000
429
430         export MACHINEFILE=${MACHINEFILE:-$TMP/$(basename $0 .sh).machines}
431         . ${CONFIG:=$LUSTRE/tests/cfg/$NAME.sh}
432         get_lustre_env
433
434         # use localrecov to enable recovery for local clients, LU-12722
435         [[ $MDS1_VERSION -lt $(version_code 2.13.52) ]] ||
436                 export MDS_MOUNT_OPTS=${MDS_MOUNT_OPTS:-"-o localrecov"}
437         [[ $OST1_VERSION -lt $(version_code 2.13.52) ]] ||
438                 export OST_MOUNT_OPTS=${OST_MOUNT_OPTS:-"-o localrecov"}
439 }
440
441 check_cpt_number() {
442         local facet=$1
443         local ncpts
444
445         ncpts=$(do_facet $facet "lctl get_param -n " \
446                 "cpu_partition_table 2>/dev/null| wc -l" || echo 1)
447
448         if [ $ncpts -eq 0 ]; then
449                 echo "1"
450         else
451                 echo $ncpts
452         fi
453 }
454
455 # Return a numeric version code based on a version string.  The version
456 # code is useful for comparison two version strings to see which is newer.
457 version_code() {
458         # split arguments like "1.8.6-wc3" into "1", "8", "6", "wc3"
459         eval set -- $(tr "[:punct:]" " " <<< $*)
460
461         echo -n $(((${1:-0} << 16) | (${2:-0} << 8) | ${3:-0}))
462 }
463
464 export LINUX_VERSION=$(uname -r | sed -e "s/\([0-9]*\.[0-9]*\.[0-9]*\).*/\1/")
465 export LINUX_VERSION_CODE=$(version_code ${LINUX_VERSION//\./ })
466
467 # Report the Lustre build version string (e.g. 1.8.7.3 or 2.4.1).
468 #
469 # usage: lustre_build_version
470 #
471 # All Lustre versions support "lctl get_param" to report the version of the
472 # code running in the kernel (what our tests are interested in), but it
473 # doesn't work without modules loaded.  After 2.9.53 and in upstream kernels
474 # the "version" parameter doesn't include "lustre: " at the beginning.
475 # If that fails, call "lctl lustre_build_version" which prints either (or both)
476 # the userspace and kernel build versions, but until 2.8.55 required root
477 # access to get the Lustre kernel version.  If that also fails, fall back to
478 # using "lctl --version", which is easy to parse and works without the kernel
479 # modules, but was only added in 2.6.50 and only prints the lctl tool version,
480 # not the module version, though they are usually the same.
481 #
482 # Various commands and their output format for different Lustre versions:
483 # lctl get_param version:       2.9.55
484 # lctl get_param version:       lustre: 2.8.53
485 # lctl get_param version:       lustre: 2.6.52
486 #                               kernel: patchless_client
487 #                               build: v2_6_92_0-2.6.32-431.el6_lustre.x86_64
488 # lctl lustre_build_version:    Lustre version: 2.8.53_27_gae67fc01
489 # lctl lustre_build_version:    error: lustre_build_version: Permission denied
490 #       (as non-root user)      lctl   version: v2_6_92_0-2.6.32-431.el6.x86_64
491 # lctl lustre_build_version:    Lustre version: 2.5.3-2.6.32.26-175.fc12.x86_64
492 #                               lctl   version: 2.5.3-2.6.32..26-175fc12.x86_64
493 # lctl --version:               lctl 2.6.50
494 #
495 # output: prints version string to stdout in (up to 4) dotted-decimal values
496 lustre_build_version() {
497         local facet=${1:-client}
498         local facet_version=${facet}_VERSION
499
500         # if the global variable is already set, then use that
501         [ -n "${!facet_version}" ] && echo ${!facet_version} && return
502
503         # this is the currently-running version of the kernel modules
504         local ver=$(do_facet $facet "$LCTL get_param -n version 2>/dev/null")
505         # we mostly test 2.10+ systems, only try others if the above fails
506         if [ -z "$ver" ]; then
507                 ver=$(do_facet $facet "$LCTL lustre_build_version 2>/dev/null")
508         fi
509         if [ -z "$ver" ]; then
510                 ver=$(do_facet $facet "$LCTL --version 2>/dev/null" |
511                       cut -d' ' -f2)
512         fi
513         local lver=$(egrep -i "lustre: |version: " <<<"$ver" | head -n 1)
514         [ -n "$lver" ] && ver="$lver"
515
516         lver=$(sed -e 's/[^:]*: //' -e 's/^v//' -e 's/[ -].*//' <<<$ver |
517                tr _ . | cut -d. -f1-4)
518
519         # save in global variable for the future
520         export $facet_version=$lver
521
522         echo $lver
523 }
524
525 # Report the Lustre numeric build version code for the supplied facet.
526 lustre_version_code() {
527         version_code $(lustre_build_version $1)
528 }
529
530 module_loaded () {
531         /sbin/lsmod | grep -q "^\<$1\>"
532 }
533
534 PRLFS=false
535 lustre_insmod() {
536         local module=$1
537         shift
538         local args="$@"
539         local msg
540         local rc=0
541
542         if ! $PRLFS; then
543                 msg="$(insmod $module $args 2>&1)" && return 0 || rc=$?
544         fi
545
546         # parallels can't load modules directly from prlfs, use /tmp instead
547         if $PRLFS || [[ "$(stat -f -c%t $module)" == "7c7c6673" ]]; then
548                 local target="$(mktemp)"
549
550                 cp "$module" "$target"
551                 insmod $target $args
552                 rc=$?
553                 [[ $rc == 0 ]] && PRLFS=true
554                 rm -f $target
555         else
556                 echo "$msg"
557         fi
558         return $rc
559 }
560
561 # Load a module on the system where this is running.
562 #
563 # usage: load_module module_name [module arguments for insmod/modprobe]
564 #
565 # If module arguments are not given but MODOPTS_<MODULE> is set, then its value
566 # will be used as the arguments.  Otherwise arguments will be obtained from
567 # /etc/modprobe.conf, from /etc/modprobe.d/Lustre, or else none will be used.
568 #
569 load_module() {
570         local module=$1 # '../libcfs/libcfs/libcfs', 'obdclass/obdclass', ...
571         shift
572         local ext=".ko"
573         local base=$(basename $module $ext)
574         local path
575         local -A module_is_loaded_aa
576         local optvar
577         local mod
578
579         for mod in $(lsmod | awk '{ print $1; }'); do
580                 module_is_loaded_aa[${mod//-/_}]=true
581         done
582
583         module_is_loaded() {
584                 ${module_is_loaded_aa[${1//-/_}]:-false}
585         }
586
587         if module_is_loaded $base; then
588                 return
589         fi
590
591         if [[ -f $LUSTRE/$module$ext ]]; then
592                 path=$LUSTRE/$module$ext
593         elif [[ "$base" == lnet_selftest ]] &&
594              [[ -f $LUSTRE/../lnet/selftest/$base$ext ]]; then
595                 path=$LUSTRE/../lnet/selftest/$base$ext
596         else
597                 path=''
598         fi
599
600         if [[ -n "$path" ]]; then
601                 # Try to load any non-Lustre modules that $module depends on.
602                 for mod in $(modinfo --field=depends $path | tr ',' ' '); do
603                         if ! module_is_loaded $mod; then
604                                 modprobe $mod
605                         fi
606                 done
607         fi
608
609         # If no module arguments were passed then get them from
610         # $MODOPTS_<MODULE>, otherwise from modprobe.conf.
611         if [ $# -eq 0 ]; then
612                 # $MODOPTS_<MODULE>; we could use associative arrays, but that's
613                 # not in Bash until 4.x, so we resort to eval.
614                 optvar="MODOPTS_$(basename $module | tr a-z A-Z)"
615                 eval set -- \$$optvar
616                 if [ $# -eq 0 -a -n "$MODPROBECONF" ]; then
617                         # Nothing in $MODOPTS_<MODULE>; try modprobe.conf
618                         local opt
619                         opt=$(awk -v var="^options $base" '$0 ~ var \
620                               {gsub("'"options $base"'",""); print}' \
621                                 $MODPROBECONF)
622                         set -- $(echo -n $opt)
623
624                         # Ensure we have accept=all for lnet
625                         if [[ "$base" == lnet ]]; then
626                                 # OK, this is a bit wordy...
627                                 local arg accept_all_present=false
628
629                                 for arg in "$@"; do
630                                         [[ "$arg" == accept=all ]] &&
631                                                 accept_all_present=true
632                                 done
633
634                                 $accept_all_present || set -- "$@" accept=all
635                         fi
636
637                         export $optvar="$*"
638                 fi
639         fi
640
641         [ $# -gt 0 ] && echo "${module} options: '$*'"
642
643         # Note that insmod will ignore anything in modprobe.conf, which is why
644         # we're passing options on the command-line. If $path does not exist
645         # then we must be testing a "make install" or"rpm" installation. Also
646         # note that failing to load ptlrpc_gss is not considered fatal.
647         if [[ -n "$path" ]]; then
648                 lustre_insmod $path "$@"
649         elif [[ "$base" == ptlrpc_gss ]]; then
650                 if ! modprobe $base "$@" 2>/dev/null; then
651                         echo "gss/krb5 is not supported"
652                 fi
653         else
654                 modprobe $base "$@"
655         fi
656 }
657
658 load_modules_local() {
659         if [ -n "$MODPROBE" ]; then
660                 # use modprobe
661                 echo "Using modprobe to load modules"
662                 return 0
663         fi
664
665         # Create special udev test rules on every node
666         if [ -f $LUSTRE/lustre/conf/99-lustre.rules ]; then {
667                 sed -e 's|/usr/sbin/lctl|$LCTL|g' $LUSTRE/lustre/conf/99-lustre.rules > /etc/udev/rules.d/99-lustre-test.rules
668         } else {
669                 echo "SUBSYSTEM==\"lustre\", ACTION==\"change\", ENV{PARAM}==\"?*\", RUN+=\"$LCTL set_param '\$env{PARAM}=\$env{SETTING}'\"" > /etc/udev/rules.d/99-lustre-test.rules
670         } fi
671         udevadm control --reload-rules
672         udevadm trigger
673
674         # For kmemleak-enabled kernels we need clear all past state
675         # that obviously has nothing to do with this Lustre run
676         # Disable automatic memory scanning to avoid perf hit.
677         if [ -f /sys/kernel/debug/kmemleak ] ; then
678                 echo scan=off > /sys/kernel/debug/kmemleak
679                 echo scan > /sys/kernel/debug/kmemleak
680                 echo clear > /sys/kernel/debug/kmemleak
681         fi
682
683         echo Loading modules from $LUSTRE
684
685         local ncpus
686
687         if [ -f /sys/devices/system/cpu/online ]; then
688                 ncpus=$(($(cut -d "-" -f 2 /sys/devices/system/cpu/online) + 1))
689                 echo "detected $ncpus online CPUs by sysfs"
690         else
691                 ncpus=$(getconf _NPROCESSORS_CONF 2>/dev/null)
692                 local rc=$?
693                 if [ $rc -eq 0 ]; then
694                         echo "detected $ncpus online CPUs by getconf"
695                 else
696                         echo "Can't detect number of CPUs"
697                         ncpus=1
698                 fi
699         fi
700
701         # if there is only one CPU core, libcfs can only create one partition
702         # if there is more than 4 CPU cores, libcfs should create multiple CPU
703         # partitions. So we just force libcfs to create 2 partitions for
704         # system with 2 or 4 cores
705         local saved_opts="$MODOPTS_LIBCFS"
706         if [ $ncpus -le 4 ] && [ $ncpus -gt 1 ]; then
707                 # force to enable multiple CPU partitions
708                 echo "Force libcfs to create 2 CPU partitions"
709                 MODOPTS_LIBCFS="cpu_npartitions=2 $MODOPTS_LIBCFS"
710         else
711                 echo "libcfs will create CPU partition based on online CPUs"
712         fi
713
714         load_module ../libcfs/libcfs/libcfs
715         # Prevent local MODOPTS_LIBCFS being passed as part of environment
716         # variable to remote nodes
717         MODOPTS_LIBCFS=$saved_opts
718
719         set_default_debug
720         load_module ../lnet/lnet/lnet
721
722         LNDPATH=${LNDPATH:-"../lnet/klnds"}
723         if [ -z "$LNETLND" ]; then
724                 case $NETTYPE in
725                 o2ib*)  LNETLND="o2iblnd/ko2iblnd" ;;
726                 tcp*)   LNETLND="socklnd/ksocklnd" ;;
727                 *)      local lnd="${NETTYPE%%[0-9]}lnd"
728                         [ -f "$LNDPATH/$lnd/k$lnd.ko" ] &&
729                                 LNETLND="$lnd/k$lnd" ||
730                                 LNETLND="socklnd/ksocklnd"
731                 esac
732         fi
733         load_module ../lnet/klnds/$LNETLND
734         load_module obdclass/obdclass
735         load_module ptlrpc/ptlrpc
736         load_module ptlrpc/gss/ptlrpc_gss
737         load_module fld/fld
738         load_module fid/fid
739         load_module lmv/lmv
740         load_module osc/osc
741         load_module lov/lov
742         load_module mdc/mdc
743         load_module mgc/mgc
744         load_module obdecho/obdecho
745         if ! client_only; then
746                 load_module lfsck/lfsck
747                 [ "$LQUOTA" != "no" ] &&
748                         load_module quota/lquota $LQUOTAOPTS
749                 if [[ $(node_fstypes $HOSTNAME) == *zfs* ]]; then
750                         load_module osd-zfs/osd_zfs
751                 elif [[ $(node_fstypes $HOSTNAME) == *ldiskfs* ]]; then
752                         load_module ../ldiskfs/ldiskfs
753                         load_module osd-ldiskfs/osd_ldiskfs
754                 fi
755                 load_module mgs/mgs
756                 load_module mdd/mdd
757                 load_module mdt/mdt
758                 load_module ost/ost
759                 load_module lod/lod
760                 load_module osp/osp
761                 load_module ofd/ofd
762                 load_module osp/osp
763         fi
764
765         load_module llite/lustre
766         [ -d /r ] && OGDB=${OGDB:-"/r/tmp"}
767         OGDB=${OGDB:-$TMP}
768         rm -f $OGDB/ogdb-$HOSTNAME
769         $LCTL modules > $OGDB/ogdb-$HOSTNAME
770
771         # 'mount' doesn't look in $PATH, just sbin
772         local mount_lustre=$LUSTRE/utils/mount.lustre
773         if [ -f $mount_lustre ]; then
774                 local sbin_mount=$(readlink -f /sbin)/mount.lustre
775                 if grep -qw "$sbin_mount" /proc/mounts; then
776                         cmp -s $mount_lustre $sbin_mount || umount $sbin_mount
777                 fi
778                 if ! grep -qw "$sbin_mount" /proc/mounts; then
779                         [ ! -f "$sbin_mount" ] && touch "$sbin_mount"
780                         if [ ! -s "$sbin_mount" -a -w "$sbin_mount" ]; then
781                                 cat <<- EOF > "$sbin_mount"
782                                 #!/bin/sh
783                                 #STUB MARK
784                                 echo "This $sbin_mount just a mountpoint." 1>&2
785                                 echo "It is never supposed to be run." 1>&2
786                                 logger -p emerg -- "using stub $sbin_mount $@"
787                                 exit 1
788                                 EOF
789                                 chmod a+x $sbin_mount
790                         fi
791                         mount --bind $mount_lustre $sbin_mount ||
792                                 error "can't bind $mount_lustre to $sbin_mount"
793                 fi
794         fi
795 }
796
797 load_modules () {
798         load_modules_local
799         # bug 19124
800         # load modules on remote nodes optionally
801         # lustre-tests have to be installed on these nodes
802         if $LOAD_MODULES_REMOTE; then
803                 local list=$(comma_list $(remote_nodes_list))
804                 if [ -n "$list" ]; then
805                         echo "loading modules on: '$list'"
806                         do_rpc_nodes "$list" load_modules_local
807                 fi
808         fi
809 }
810
811 check_mem_leak () {
812     LEAK_LUSTRE=$(dmesg | tail -n 30 | grep "obd_memory.*leaked" || true)
813     LEAK_PORTALS=$(dmesg | tail -n 20 | grep "Portals memory leaked" || true)
814     if [ "$LEAK_LUSTRE" -o "$LEAK_PORTALS" ]; then
815         echo "$LEAK_LUSTRE" 1>&2
816         echo "$LEAK_PORTALS" 1>&2
817         mv $TMP/debug $TMP/debug-leak.`date +%s` || true
818         echo "Memory leaks detected"
819         [ -n "$IGNORE_LEAK" ] && { echo "ignoring leaks" && return 0; } || true
820         return 1
821     fi
822 }
823
824 unload_modules() {
825         wait_exit_ST client # bug 12845
826
827         $LUSTRE_RMMOD ldiskfs || return 2
828
829         [ -f /etc/udev/rules.d/99-lustre-test.rules ] &&
830                 rm /etc/udev/rules.d/99-lustre-test.rules
831         udevadm control --reload-rules
832         udevadm trigger
833
834         if $LOAD_MODULES_REMOTE; then
835                 local list=$(comma_list $(remote_nodes_list))
836                 if [ -n "$list" ]; then
837                         echo "unloading modules on: '$list'"
838                         do_rpc_nodes "$list" $LUSTRE_RMMOD ldiskfs
839                         do_rpc_nodes "$list" check_mem_leak
840                         do_rpc_nodes "$list" "rm -f /etc/udev/rules.d/99-lustre-test.rules"
841                         do_rpc_nodes "$list" "udevadm control --reload-rules"
842                         do_rpc_nodes "$list" "udevadm trigger"
843                 fi
844         fi
845
846         local sbin_mount=$(readlink -f /sbin)/mount.lustre
847         if grep -qe "$sbin_mount " /proc/mounts; then
848                 umount $sbin_mount || true
849                 [ -s $sbin_mount ] && ! grep -q "STUB MARK" $sbin_mount ||
850                         rm -f $sbin_mount
851         fi
852
853         check_mem_leak || return 254
854
855         echo "modules unloaded."
856         return 0
857 }
858
859 fs_log_size() {
860         local facet=${1:-$SINGLEMDS}
861         local size=0
862
863         case $(facet_fstype $facet) in
864                 ldiskfs) size=50;; # largest seen is 44, leave some headroom
865                 # grant_block_size is in bytes, allow at least 2x max blocksize
866                 zfs)     size=$(lctl get_param osc.$FSNAME*.import |
867                                 awk '/grant_block_size:/ {print $2/512; exit;}')
868                           ;;
869         esac
870
871         echo -n $((size * MDSCOUNT))
872 }
873
874 fs_inode_ksize() {
875         local facet=${1:-$SINGLEMDS}
876         local fstype=$(facet_fstype $facet)
877         local size=0
878         case $fstype in
879                 ldiskfs) size=4;;  # ~4KB per inode
880                 zfs)     size=11;; # 10 to 11KB per inode
881         esac
882
883         echo -n $size
884 }
885
886 check_gss_daemon_nodes() {
887     local list=$1
888     dname=$2
889
890     do_nodesv $list "num=\\\$(ps -o cmd -C $dname | grep $dname | wc -l);
891 if [ \\\"\\\$num\\\" -ne 1 ]; then
892     echo \\\$num instance of $dname;
893     exit 1;
894 fi; "
895 }
896
897 check_gss_daemon_facet() {
898     facet=$1
899     dname=$2
900
901     num=`do_facet $facet ps -o cmd -C $dname | grep $dname | wc -l`
902     if [ $num -ne 1 ]; then
903         echo "$num instance of $dname on $facet"
904         return 1
905     fi
906     return 0
907 }
908
909 send_sigint() {
910     local list=$1
911     shift
912     echo Stopping $@ on $list
913     do_nodes $list "killall -2 $@ 2>/dev/null || true"
914 }
915
916 # start gss daemons on all nodes, or "daemon" on "nodes" if set
917 start_gss_daemons() {
918         local nodes=$1
919         local daemon=$2
920
921         if [ "$nodes" ] && [ "$daemon" ] ; then
922                 echo "Starting gss daemon on nodes: $nodes"
923                 do_nodes $nodes "$daemon" || return 8
924                 return 0
925         fi
926
927         nodes=$(comma_list $(mdts_nodes))
928         echo "Starting gss daemon on mds: $nodes"
929         if $GSS_SK; then
930                 # Start all versions, in case of switching
931                 do_nodes $nodes "$LSVCGSSD -vvv -s -m -o -z" || return 1
932         else
933                 do_nodes $nodes "$LSVCGSSD -v" || return 1
934         fi
935         if $GSS_PIPEFS; then
936                 do_nodes $nodes "$LGSSD -v" || return 2
937         fi
938
939         nodes=$(comma_list $(osts_nodes))
940         echo "Starting gss daemon on ost: $nodes"
941         if $GSS_SK; then
942                 # Start all versions, in case of switching
943                 do_nodes $nodes "$LSVCGSSD -vvv -s -m -o -z" || return 3
944         else
945                 do_nodes $nodes "$LSVCGSSD -v" || return 3
946         fi
947         # starting on clients
948
949         local clients=${CLIENTS:-$HOSTNAME}
950         if $GSS_PIPEFS; then
951                 echo "Starting $LGSSD on clients $clients "
952                 do_nodes $clients  "$LGSSD -v" || return 4
953         fi
954
955         # wait daemons entering "stable" status
956         sleep 5
957
958         #
959         # check daemons are running
960         #
961         nodes=$(comma_list $(mdts_nodes) $(osts_nodes))
962         check_gss_daemon_nodes $nodes lsvcgssd || return 5
963         if $GSS_PIPEFS; then
964                 nodes=$(comma_list $(mdts_nodes))
965                 check_gss_daemon_nodes $nodes lgssd || return 6
966         fi
967         if $GSS_PIPEFS; then
968                 check_gss_daemon_nodes $clients lgssd || return 7
969         fi
970 }
971
972 stop_gss_daemons() {
973         local nodes=$(comma_list $(mdts_nodes))
974
975         send_sigint $nodes lsvcgssd lgssd
976
977         nodes=$(comma_list $(osts_nodes))
978         send_sigint $nodes lsvcgssd
979
980         nodes=${CLIENTS:-$HOSTNAME}
981         send_sigint $nodes lgssd
982 }
983
984 add_sk_mntflag() {
985         # Add mount flags for shared key
986         local mt_opts=$@
987         if grep -q skpath <<< "$mt_opts" ; then
988                 mt_opts=$(echo $mt_opts |
989                         sed -e "s#skpath=[^ ,]*#skpath=$SK_PATH#")
990         else
991                 if [ -z "$mt_opts" ]; then
992                         mt_opts="-o skpath=$SK_PATH"
993                 else
994                         mt_opts="$mt_opts,skpath=$SK_PATH"
995                 fi
996         fi
997         echo -n $mt_opts
998 }
999
1000 from_build_tree() {
1001         local from_tree
1002
1003         case $LUSTRE in
1004         /usr/lib/lustre/* | /usr/lib64/lustre/* | /usr/lib/lustre | \
1005         /usr/lib64/lustre )
1006                 from_tree=false
1007                 ;;
1008         *)
1009                 from_tree=true
1010                 ;;
1011         esac
1012
1013         [ $from_tree = true ]
1014 }
1015
1016 init_gss() {
1017         if $SHARED_KEY; then
1018                 GSS=true
1019                 GSS_SK=true
1020         fi
1021
1022         if ! $GSS; then
1023                 return
1024         fi
1025
1026         if ! module_loaded ptlrpc_gss; then
1027                 load_module ptlrpc/gss/ptlrpc_gss
1028                 module_loaded ptlrpc_gss ||
1029                         error_exit "init_gss: GSS=$GSS, but gss/krb5 missing"
1030         fi
1031
1032         if $GSS_KRB5 || $GSS_SK; then
1033                 start_gss_daemons || error_exit "start gss daemon failed! rc=$?"
1034         fi
1035
1036         if $GSS_SK && $SK_NO_KEY; then
1037                 local numclients=${1:-$CLIENTCOUNT}
1038                 local clients=${CLIENTS:-$HOSTNAME}
1039
1040                 # security ctx config for keyring
1041                 SK_NO_KEY=false
1042                 local lgssc_conf_file="/etc/request-key.d/lgssc.conf"
1043
1044                 if from_build_tree; then
1045                         mkdir -p $SK_OM_PATH
1046                         if grep -q request-key /proc/mounts > /dev/null; then
1047                                 echo "SSK: Request key already mounted."
1048                         else
1049                                 mount -o bind $SK_OM_PATH /etc/request-key.d/
1050                         fi
1051                         local lgssc_conf_line='create lgssc * * '
1052                         lgssc_conf_line+=$(which lgss_keyring)
1053                         lgssc_conf_line+=' %o %k %t %d %c %u %g %T %P %S'
1054                         echo "$lgssc_conf_line" > $lgssc_conf_file
1055                 fi
1056
1057                 [ -e $lgssc_conf_file ] ||
1058                         error_exit "Could not find key options in $lgssc_conf_file"
1059                 echo "$lgssc_conf_file content is:"
1060                 cat $lgssc_conf_file
1061
1062                 if ! local_mode; then
1063                         if from_build_tree; then
1064                                 do_nodes $(comma_list $(all_nodes)) "mkdir -p \
1065                                         $SK_OM_PATH"
1066                                 do_nodes $(comma_list $(all_nodes)) "mount \
1067                                         -o bind $SK_OM_PATH \
1068                                         /etc/request-key.d/"
1069                                 do_nodes $(comma_list $(all_nodes)) "rsync \
1070                                         -aqv $HOSTNAME:$lgssc_conf_file \
1071                                         $lgssc_conf_file >/dev/null 2>&1"
1072                         else
1073                                 do_nodes $(comma_list $(all_nodes)) \
1074                                         "echo $lgssc_conf_file: ; \
1075                                         cat $lgssc_conf_file"
1076                         fi
1077                 fi
1078
1079                 # create shared key on all nodes
1080                 mkdir -p $SK_PATH/nodemap
1081                 rm -f $SK_PATH/$FSNAME.key $SK_PATH/nodemap/c*.key \
1082                         $SK_PATH/$FSNAME-*.key
1083                 # for nodemap testing each client may need own key,
1084                 # and S2S now requires keys as well, both for "client"
1085                 # and for "server"
1086                 if $SK_S2S; then
1087                         lgss_sk -t server -f$FSNAME -n $SK_S2SNMCLI \
1088                                 -w $SK_PATH/$FSNAME-nmclient.key \
1089                                 -d /dev/urandom >/dev/null 2>&1
1090                         lgss_sk -t mgs,server -f$FSNAME -n $SK_S2SNM \
1091                                 -w $SK_PATH/$FSNAME-s2s-server.key \
1092                                 -d /dev/urandom >/dev/null 2>&1
1093                 fi
1094                 # basic key create
1095                 lgss_sk -t server -f$FSNAME -w $SK_PATH/$FSNAME.key \
1096                         -d /dev/urandom >/dev/null 2>&1
1097                 # per-nodemap keys
1098                 for i in $(seq 0 $((numclients - 1))); do
1099                         lgss_sk -t server -f$FSNAME -n c$i \
1100                                 -w $SK_PATH/nodemap/c$i.key -d /dev/urandom \
1101                                 >/dev/null 2>&1
1102                 done
1103                 # Distribute keys
1104                 if ! local_mode; then
1105                         for lnode in $(all_nodes); do
1106                                 scp -r $SK_PATH ${lnode}:$(dirname $SK_PATH)/
1107                         done
1108                 fi
1109                 # Set client keys to client type to generate prime P
1110                 if local_mode; then
1111                         do_nodes $(all_nodes) "lgss_sk -t client,server -m \
1112                                 $SK_PATH/$FSNAME.key >/dev/null 2>&1"
1113                 else
1114                         do_nodes $clients "lgss_sk -t client -m \
1115                                 $SK_PATH/$FSNAME.key >/dev/null 2>&1"
1116                         do_nodes $clients "find $SK_PATH/nodemap -name \*.key | \
1117                                 xargs -IX lgss_sk -t client -m X >/dev/null 2>&1"
1118                 fi
1119                 # This is required for servers as well, if S2S in use
1120                 if $SK_S2S; then
1121                         do_nodes $(comma_list $(mdts_nodes)) \
1122                                 "cp $SK_PATH/$FSNAME-s2s-server.key \
1123                                 $SK_PATH/$FSNAME-s2s-client.key; lgss_sk \
1124                                 -t client -m $SK_PATH/$FSNAME-s2s-client.key \
1125                                 >/dev/null 2>&1"
1126                         do_nodes $(comma_list $(osts_nodes)) \
1127                                 "cp $SK_PATH/$FSNAME-s2s-server.key \
1128                                 $SK_PATH/$FSNAME-s2s-client.key; lgss_sk \
1129                                 -t client -m $SK_PATH/$FSNAME-s2s-client.key \
1130                                 >/dev/null 2>&1"
1131                         do_nodes $clients "lgss_sk -t client \
1132                                 -m $SK_PATH/$FSNAME-nmclient.key \
1133                                  >/dev/null 2>&1"
1134                 fi
1135         fi
1136         if $GSS_SK; then
1137                 # mount options for servers and clients
1138                 MGS_MOUNT_OPTS=$(add_sk_mntflag $MGS_MOUNT_OPTS)
1139                 MDS_MOUNT_OPTS=$(add_sk_mntflag $MDS_MOUNT_OPTS)
1140                 OST_MOUNT_OPTS=$(add_sk_mntflag $OST_MOUNT_OPTS)
1141                 MOUNT_OPTS=$(add_sk_mntflag $MOUNT_OPTS)
1142                 SEC=$SK_FLAVOR
1143                 if [ -z "$LGSS_KEYRING_DEBUG" ]; then
1144                         LGSS_KEYRING_DEBUG=4
1145                 fi
1146         fi
1147
1148         if [ -n "$LGSS_KEYRING_DEBUG" ] && \
1149                ( local_mode || from_build_tree ); then
1150                 lctl set_param -n \
1151                      sptlrpc.gss.lgss_keyring.debug_level=$LGSS_KEYRING_DEBUG
1152         elif [ -n "$LGSS_KEYRING_DEBUG" ]; then
1153                 do_nodes $(comma_list $(all_nodes)) "modprobe ptlrpc_gss && \
1154                 lctl set_param -n \
1155                    sptlrpc.gss.lgss_keyring.debug_level=$LGSS_KEYRING_DEBUG"
1156         fi
1157 }
1158
1159 cleanup_gss() {
1160         if $GSS; then
1161                 stop_gss_daemons
1162                 # maybe cleanup credential cache?
1163         fi
1164 }
1165
1166 cleanup_sk() {
1167         if $GSS_SK; then
1168                 if $SK_S2S; then
1169                         do_node $(mgs_node) "$LCTL nodemap_del $SK_S2SNM"
1170                         do_node $(mgs_node) "$LCTL nodemap_del $SK_S2SNMCLI"
1171                         $RPC_MODE || echo "Sleeping for 10 sec for Nodemap.."
1172                         sleep 10
1173                 fi
1174                 stop_gss_daemons
1175                 $RPC_MODE || echo "Cleaning up Shared Key.."
1176                 do_nodes $(comma_list $(all_nodes)) "rm -f \
1177                         $SK_PATH/$FSNAME*.key $SK_PATH/nodemap/$FSNAME*.key"
1178                 do_nodes $(comma_list $(all_nodes)) "keyctl show | \
1179                   awk '/lustre/ { print \\\$1 }' | xargs -IX keyctl unlink X"
1180                 if from_build_tree; then
1181                         # Remove the mount and clean up the files we added to
1182                         # SK_PATH
1183                         do_nodes $(comma_list $(all_nodes)) "while grep -q \
1184                                 request-key.d /proc/mounts; do umount \
1185                                 /etc/request-key.d/; done"
1186                         do_nodes $(comma_list $(all_nodes)) "rm -f \
1187                                 $SK_OM_PATH/lgssc.conf"
1188                         do_nodes $(comma_list $(all_nodes)) "rmdir $SK_OM_PATH"
1189                 fi
1190                 SK_NO_KEY=true
1191         fi
1192 }
1193
1194 facet_svc() {
1195         local facet=$1
1196         local var=${facet}_svc
1197
1198         echo -n ${!var}
1199 }
1200
1201 facet_type() {
1202         local facet=$1
1203
1204         echo -n $facet | sed -e 's/^fs[0-9]\+//' -e 's/[0-9_]\+//' |
1205                 tr '[:lower:]' '[:upper:]'
1206 }
1207
1208 facet_number() {
1209         local facet=$1
1210
1211         if [ $facet == mgs ] || [ $facet == client ]; then
1212                 return 1
1213         fi
1214
1215         echo -n $facet | sed -e 's/^fs[0-9]\+//' | sed -e 's/^[a-z]\+//'
1216 }
1217
1218 facet_fstype() {
1219         local facet=$1
1220         local var
1221
1222         var=${facet}_FSTYPE
1223         if [ -n "${!var}" ]; then
1224                 echo -n ${!var}
1225                 return
1226         fi
1227
1228         var=$(facet_type $facet)FSTYPE
1229         if [ -n "${!var}" ]; then
1230                 echo -n ${!var}
1231                 return
1232         fi
1233
1234         if [ -n "$FSTYPE" ]; then
1235                 echo -n $FSTYPE
1236                 return
1237         fi
1238
1239         if [[ $facet == mgs ]] && combined_mgs_mds; then
1240                 facet_fstype mds1
1241                 return
1242         fi
1243
1244         return 1
1245 }
1246
1247 node_fstypes() {
1248         local node=$1
1249         local fstypes
1250         local fstype
1251         local facets=$(get_facets)
1252         local facet
1253
1254         for facet in ${facets//,/ }; do
1255                 if [ $node == $(facet_host $facet) ] ||
1256                    [ $node == "$(facet_failover_host $facet)" ]; then
1257                         fstype=$(facet_fstype $facet)
1258                         if [[ $fstypes != *$fstype* ]]; then
1259                                 fstypes+="${fstypes:+,}$fstype"
1260                         fi
1261                 fi
1262         done
1263         echo -n $fstypes
1264 }
1265
1266 facet_index() {
1267         local facet=$1
1268         local num=$(facet_number $facet)
1269         local index
1270
1271         if [[ $(facet_type $facet) = OST ]]; then
1272                 index=OSTINDEX${num}
1273                 if [[ -n "${!index}" ]]; then
1274                         echo -n ${!index}
1275                         return
1276                 fi
1277
1278                 index=${OST_INDICES[num - 1]}
1279         fi
1280
1281         [[ -n "$index" ]] || index=$((num - 1))
1282         echo -n $index
1283 }
1284
1285 devicelabel() {
1286         local facet=$1
1287         local dev=$2
1288         local label
1289         local fstype=$(facet_fstype $facet)
1290
1291         case $fstype in
1292         ldiskfs)
1293                 label=$(do_facet ${facet} "$E2LABEL ${dev} 2>/dev/null");;
1294         zfs)
1295                 label=$(do_facet ${facet} "$ZFS get -H -o value lustre:svname \
1296                                            ${dev} 2>/dev/null");;
1297         *)
1298                 error "unknown fstype!";;
1299         esac
1300
1301         echo -n $label
1302 }
1303
1304 mdsdevlabel() {
1305         local num=$1
1306         local device=$(mdsdevname $num)
1307         local label=$(devicelabel mds$num ${device} | grep -v "CMD: ")
1308         echo -n $label
1309 }
1310
1311 ostdevlabel() {
1312         local num=$1
1313         local device=$(ostdevname $num)
1314         local label=$(devicelabel ost$num ${device} | grep -v "CMD: ")
1315         echo -n $label
1316 }
1317
1318 #
1319 # Get the device of a facet.
1320 #
1321 facet_device() {
1322         local facet=$1
1323         local device
1324
1325         case $facet in
1326                 mgs) device=$(mgsdevname) ;;
1327                 mds*) device=$(mdsdevname $(facet_number $facet)) ;;
1328                 ost*) device=$(ostdevname $(facet_number $facet)) ;;
1329                 fs2mds) device=$(mdsdevname 1_2) ;;
1330                 fs2ost) device=$(ostdevname 1_2) ;;
1331                 fs3ost) device=$(ostdevname 2_2) ;;
1332                 *) ;;
1333         esac
1334
1335         echo -n $device
1336 }
1337
1338 #
1339 # Get the virtual device of a facet.
1340 #
1341 facet_vdevice() {
1342         local facet=$1
1343         local device
1344
1345         case $facet in
1346                 mgs) device=$(mgsvdevname) ;;
1347                 mds*) device=$(mdsvdevname $(facet_number $facet)) ;;
1348                 ost*) device=$(ostvdevname $(facet_number $facet)) ;;
1349                 fs2mds) device=$(mdsvdevname 1_2) ;;
1350                 fs2ost) device=$(ostvdevname 1_2) ;;
1351                 fs3ost) device=$(ostvdevname 2_2) ;;
1352                 *) ;;
1353         esac
1354
1355         echo -n $device
1356 }
1357
1358 running_in_vm() {
1359         local virt=$(virt-what 2> /dev/null)
1360
1361         [ $? -eq 0 ] && [ -n "$virt" ] && { echo $virt; return; }
1362
1363         virt=$(dmidecode -s system-product-name | awk '{print $1}')
1364
1365         case $virt in
1366                 VMware|KVM|VirtualBox|Parallels|Bochs)
1367                         echo $virt | tr '[A-Z]' '[a-z]' ;;
1368                 *) ;;
1369         esac
1370 }
1371
1372 #
1373 # Re-read the partition table on failover partner host.
1374 # After a ZFS storage pool is created on a shared device, the partition table
1375 # on the device may change. However, the operating system on the failover
1376 # host may not notice the change automatically. Without the up-to-date partition
1377 # block devices, 'zpool import ..' cannot find the labels, whose positions are
1378 # relative to partition rather than disk beginnings.
1379 #
1380 # This function performs partprobe on the failover host to make it re-read the
1381 # partition table.
1382 #
1383 refresh_partition_table() {
1384         local facet=$1
1385         local device=$2
1386         local host
1387
1388         host=$(facet_passive_host $facet)
1389         if [[ -n "$host" ]]; then
1390                 do_node $host "$PARTPROBE $device"
1391         fi
1392 }
1393
1394 #
1395 # Get ZFS storage pool name.
1396 #
1397 zpool_name() {
1398         local facet=$1
1399         local device
1400         local poolname
1401
1402         device=$(facet_device $facet)
1403         # poolname is string before "/"
1404         poolname="${device%%/*}"
1405
1406         echo -n $poolname
1407 }
1408
1409 #
1410 #
1411 # Get ZFS local fsname.
1412 #
1413 zfs_local_fsname() {
1414         local facet=$1
1415         local lfsname=$(basename $(facet_device $facet))
1416
1417         echo -n $lfsname
1418 }
1419
1420 #
1421 # Create ZFS storage pool.
1422 #
1423 create_zpool() {
1424         local facet=$1
1425         local poolname=$2
1426         local vdev=$3
1427         shift 3
1428         local opts=${@:-"-o cachefile=none"}
1429
1430         do_facet $facet "lsmod | grep zfs >&/dev/null || modprobe zfs;
1431                 $ZPOOL list -H $poolname >/dev/null 2>&1 ||
1432                 $ZPOOL create -f $opts $poolname $vdev"
1433 }
1434
1435 #
1436 # Create ZFS file system.
1437 #
1438 create_zfs() {
1439         local facet=$1
1440         local dataset=$2
1441         shift 2
1442         local opts=${@:-"-o mountpoint=legacy"}
1443
1444         do_facet $facet "$ZFS list -H $dataset >/dev/null 2>&1 ||
1445                 $ZFS create $opts $dataset"
1446 }
1447
1448 #
1449 # Export ZFS storage pool.
1450 # Before exporting the pool, all datasets within the pool should be unmounted.
1451 #
1452 export_zpool() {
1453         local facet=$1
1454         shift
1455         local opts="$@"
1456         local poolname
1457
1458         poolname=$(zpool_name $facet)
1459
1460         if [[ -n "$poolname" ]]; then
1461                 do_facet $facet "! $ZPOOL list -H $poolname >/dev/null 2>&1 ||
1462                         grep -q ^$poolname/ /proc/mounts ||
1463                         $ZPOOL export $opts $poolname"
1464         fi
1465 }
1466
1467 #
1468 # Destroy ZFS storage pool.
1469 # Destroy the given pool and free up any devices for other use. This command
1470 # tries to unmount any active datasets before destroying the pool.
1471 # -f    Force any active datasets contained within the pool to be unmounted.
1472 #
1473 destroy_zpool() {
1474         local facet=$1
1475         local poolname=${2:-$(zpool_name $facet)}
1476
1477         if [[ -n "$poolname" ]]; then
1478                 do_facet $facet "! $ZPOOL list -H $poolname >/dev/null 2>&1 ||
1479                         $ZPOOL destroy -f $poolname"
1480         fi
1481 }
1482
1483 #
1484 # Import ZFS storage pool.
1485 # Force importing, even if the pool appears to be potentially active.
1486 #
1487 import_zpool() {
1488         local facet=$1
1489         shift
1490         local opts=${@:-"-o cachefile=none -o failmode=panic"}
1491         local poolname
1492
1493         poolname=$(zpool_name $facet)
1494
1495         if [[ -n "$poolname" ]]; then
1496                 opts+=" -d $(dirname $(facet_vdevice $facet))"
1497                 do_facet $facet "lsmod | grep zfs >&/dev/null || modprobe zfs;
1498                         $ZPOOL list -H $poolname >/dev/null 2>&1 ||
1499                         $ZPOOL import -f $opts $poolname"
1500         fi
1501 }
1502
1503 #
1504 # Reimport ZFS storage pool with new name
1505 #
1506 reimport_zpool() {
1507         local facet=$1
1508         local newpool=$2
1509         local opts="-o cachefile=none"
1510         local poolname=$(zpool_name $facet)
1511
1512         opts+=" -d $(dirname $(facet_vdevice $facet))"
1513         do_facet $facet "$ZPOOL export $poolname;
1514                          $ZPOOL import $opts $poolname $newpool"
1515 }
1516
1517 #
1518 # Set the "cachefile=none" property on ZFS storage pool so that the pool
1519 # is not automatically imported on system startup.
1520 #
1521 # In a failover environment, this will provide resource level fencing which
1522 # will ensure that the same ZFS storage pool will not be imported concurrently
1523 # on different nodes.
1524 #
1525 disable_zpool_cache() {
1526         local facet=$1
1527         local poolname
1528
1529         poolname=$(zpool_name $facet)
1530
1531         if [[ -n "$poolname" ]]; then
1532                 do_facet $facet "$ZPOOL set cachefile=none $poolname"
1533         fi
1534 }
1535
1536 #
1537 # This and set_osd_param() shall be used to access OSD parameters
1538 # once existed under "obdfilter":
1539 #
1540 #   mntdev
1541 #   stats
1542 #   read_cache_enable
1543 #   writethrough_cache_enable
1544 #
1545 get_osd_param() {
1546         local nodes=$1
1547         local device=${2:-$FSNAME-OST*}
1548         local name=$3
1549
1550         do_nodes $nodes "$LCTL get_param -n obdfilter.$device.$name \
1551                 osd-*.$device.$name 2>&1" | grep -v 'error:'
1552 }
1553
1554 set_osd_param() {
1555         local nodes=$1
1556         local device=${2:-$FSNAME-OST*}
1557         local name=$3
1558         local value=$4
1559
1560         do_nodes $nodes "$LCTL set_param -n obdfilter.$device.$name=$value \
1561                 osd-*.$device.$name=$value 2>&1" | grep -v 'error:'
1562 }
1563
1564 set_debug_size () {
1565     local dz=${1:-$DEBUG_SIZE}
1566
1567     if [ -f /sys/devices/system/cpu/possible ]; then
1568         local cpus=$(($(cut -d "-" -f 2 /sys/devices/system/cpu/possible)+1))
1569     else
1570         local cpus=$(getconf _NPROCESSORS_CONF 2>/dev/null)
1571     fi
1572
1573     # bug 19944, adjust size to be -gt num_possible_cpus()
1574     # promise 2MB for every cpu at least
1575     if [ -n "$cpus" ] && [ $((cpus * 2)) -gt $dz ]; then
1576         dz=$((cpus * 2))
1577     fi
1578     lctl set_param debug_mb=$dz
1579 }
1580
1581 set_default_debug () {
1582         local debug=${1:-"$PTLDEBUG"}
1583         local subsys=${2:-"$SUBSYSTEM"}
1584         local debug_size=${3:-$DEBUG_SIZE}
1585
1586         [ -n "$debug" ] && lctl set_param debug="$debug" >/dev/null
1587         [ -n "$subsys" ] && lctl set_param subsystem_debug="${subsys# }" >/dev/null
1588
1589         [ -n "$debug_size" ] && set_debug_size $debug_size > /dev/null
1590 }
1591
1592 set_default_debug_nodes () {
1593         local nodes="$1"
1594         local debug="${2:-"$PTLDEBUG"}"
1595         local subsys="${3:-"$SUBSYSTEM"}"
1596         local debug_size="${4:-$DEBUG_SIZE}"
1597
1598         if [[ ,$nodes, = *,$HOSTNAME,* ]]; then
1599                 nodes=$(exclude_items_from_list "$nodes" "$HOSTNAME")
1600                 set_default_debug
1601         fi
1602
1603         [[ -z "$nodes" ]] ||
1604                 do_rpc_nodes "$nodes" set_default_debug \
1605                         \\\"$debug\\\" \\\"$subsys\\\" $debug_size || true
1606 }
1607
1608 set_default_debug_facet () {
1609         local facet=$1
1610         local debug="${2:-"$PTLDEBUG"}"
1611         local subsys="${3:-"$SUBSYSTEM"}"
1612         local debug_size="${4:-$DEBUG_SIZE}"
1613         local node=$(facet_active_host $facet)
1614
1615         [ -n "$node" ] || error "No host defined for facet $facet"
1616
1617         set_default_debug_nodes $node "$debug" "$subsys" $debug_size
1618 }
1619
1620 set_hostid () {
1621     local hostid=${1:-$(hostid)}
1622
1623     if [ ! -s /etc/hostid ]; then
1624         printf $(echo -n $hostid |
1625             sed 's/\(..\)\(..\)\(..\)\(..\)/\\x\4\\x\3\\x\2\\x\1/') >/etc/hostid
1626     fi
1627 }
1628
1629 # Facet functions
1630 mount_facets () {
1631         local facets=${1:-$(get_facets)}
1632         local facet
1633
1634         for facet in ${facets//,/ }; do
1635                 mount_facet $facet
1636                 local RC=$?
1637                 [ $RC -eq 0 ] && continue
1638
1639                 if [ "$TESTSUITE.$TESTNAME" = "replay-dual.test_0a" ]; then
1640                         skip_noexit "Restart of $facet failed!." &&
1641                                 touch $LU482_FAILED
1642                 else
1643                         error "Restart of $facet failed!"
1644                 fi
1645                 return $RC
1646         done
1647 }
1648
1649 #
1650 # Add argument "arg" (e.g., "loop") to the comma-separated list
1651 # of arguments for option "opt" (e.g., "-o") on command
1652 # line "opts" (e.g., "-o flock").
1653 #
1654 csa_add() {
1655         local opts=$1
1656         local opt=$2
1657         local arg=$3
1658         local opt_pattern="\([[:space:]]\+\|^\)$opt"
1659
1660         if echo "$opts" | grep -q $opt_pattern; then
1661                 opts=$(echo "$opts" | sed -e \
1662                         "s/$opt_pattern[[:space:]]*[^[:space:]]\+/&,$arg/")
1663         else
1664                 opts+="${opts:+ }$opt $arg"
1665         fi
1666         echo -n "$opts"
1667 }
1668
1669 #
1670 # Associate loop device with a given regular file.
1671 # Return the loop device.
1672 #
1673 setup_loop_device() {
1674         local facet=$1
1675         local file=$2
1676
1677         do_facet $facet "loop_dev=\\\$($LOSETUP -j $file | cut -d : -f 1);
1678                          if [[ -z \\\$loop_dev ]]; then
1679                                 loop_dev=\\\$($LOSETUP -f);
1680                                 $LOSETUP \\\$loop_dev $file || loop_dev=;
1681                          fi;
1682                          echo -n \\\$loop_dev"
1683 }
1684
1685 #
1686 # Detach a loop device.
1687 #
1688 cleanup_loop_device() {
1689         local facet=$1
1690         local loop_dev=$2
1691
1692         do_facet $facet "! $LOSETUP $loop_dev >/dev/null 2>&1 ||
1693                          $LOSETUP -d $loop_dev"
1694 }
1695
1696 #
1697 # Check if a given device is a block device.
1698 #
1699 is_blkdev() {
1700         local facet=$1
1701         local dev=$2
1702         local size=${3:-""}
1703
1704         [[ -n "$dev" ]] || return 1
1705         do_facet $facet "test -b $dev" || return 1
1706         if [[ -n "$size" ]]; then
1707                 local in=$(do_facet $facet "dd if=$dev of=/dev/null bs=1k \
1708                                             count=1 skip=$size 2>&1" |
1709                                             awk '($3 == "in") { print $1 }')
1710                 [[ "$in" = "1+0" ]] || return 1
1711         fi
1712 }
1713
1714 #
1715 # Check if a given device is a device-mapper device.
1716 #
1717 is_dm_dev() {
1718         local facet=$1
1719         local dev=$2
1720
1721         [[ -n "$dev" ]] || return 1
1722         do_facet $facet "$DMSETUP status $dev >/dev/null 2>&1"
1723 }
1724
1725 #
1726 # Check if a given device is a device-mapper flakey device.
1727 #
1728 is_dm_flakey_dev() {
1729         local facet=$1
1730         local dev=$2
1731         local type
1732
1733         [[ -n "$dev" ]] || return 1
1734
1735         type=$(do_facet $facet "$DMSETUP status $dev 2>&1" |
1736                awk '{print $3}')
1737         [[ $type = flakey ]] && return 0 || return 1
1738 }
1739
1740 #
1741 # Check if device-mapper flakey device is supported by the kernel
1742 # of $facet node or not.
1743 #
1744 dm_flakey_supported() {
1745         local facet=$1
1746
1747         $FLAKEY || return 1
1748         do_facet $facet "modprobe dm-flakey;
1749                          $DMSETUP targets | grep -q flakey" &> /dev/null
1750 }
1751
1752 #
1753 # Get the device-mapper flakey device name of a given facet.
1754 #
1755 dm_facet_devname() {
1756         local facet=$1
1757         [[ $facet = mgs ]] && combined_mgs_mds && facet=mds1
1758
1759         echo -n ${facet}_flakey
1760 }
1761
1762 #
1763 # Get the device-mapper flakey device of a given facet.
1764 # A device created by dmsetup will appear as /dev/mapper/<device-name>.
1765 #
1766 dm_facet_devpath() {
1767         local facet=$1
1768
1769         echo -n $DM_DEV_PATH/$(dm_facet_devname $facet)
1770 }
1771
1772 #
1773 # Set a device-mapper device with a new table.
1774 #
1775 # The table has the following format:
1776 # <logical_start_sector> <num_sectors> <target_type> <target_args>
1777 #
1778 # flakey <target_args> includes:
1779 # <destination_device> <offset> <up_interval> <down_interval> \
1780 # [<num_features> [<feature_arguments>]]
1781 #
1782 # linear <target_args> includes:
1783 # <destination_device> <start_sector>
1784 #
1785 dm_set_dev_table() {
1786         local facet=$1
1787         local dm_dev=$2
1788         local target_type=$3
1789         local num_sectors
1790         local real_dev
1791         local tmp
1792         local table
1793
1794         read tmp num_sectors tmp real_dev tmp \
1795                 <<< $(do_facet $facet "$DMSETUP table $dm_dev")
1796
1797         case $target_type in
1798         flakey)
1799                 table="0 $num_sectors flakey $real_dev 0 0 1800 1 drop_writes"
1800                 ;;
1801         linear)
1802                 table="0 $num_sectors linear $real_dev 0"
1803                 ;;
1804         *) error "invalid target type $target_type" ;;
1805         esac
1806
1807         do_facet $facet "$DMSETUP suspend --nolockfs --noflush $dm_dev" ||
1808                 error "failed to suspend $dm_dev"
1809         do_facet $facet "$DMSETUP load $dm_dev --table \\\"$table\\\"" ||
1810                 error "failed to load $target_type table into $dm_dev"
1811         do_facet $facet "$DMSETUP resume $dm_dev" ||
1812                 error "failed to resume $dm_dev"
1813 }
1814
1815 #
1816 # Set a device-mapper flakey device as "read-only" by using the "drop_writes"
1817 # feature parameter.
1818 #
1819 # drop_writes:
1820 #       All write I/O is silently ignored.
1821 #       Read I/O is handled correctly.
1822 #
1823 dm_set_dev_readonly() {
1824         local facet=$1
1825         local dm_dev=${2:-$(dm_facet_devpath $facet)}
1826
1827         dm_set_dev_table $facet $dm_dev flakey
1828 }
1829
1830 #
1831 # Set a device-mapper device to traditional linear mapping mode.
1832 #
1833 dm_clear_dev_readonly() {
1834         local facet=$1
1835         local dm_dev=${2:-$(dm_facet_devpath $facet)}
1836
1837         dm_set_dev_table $facet $dm_dev linear
1838 }
1839
1840 #
1841 # Set the device of a given facet as "read-only".
1842 #
1843 set_dev_readonly() {
1844         local facet=$1
1845         local svc=${facet}_svc
1846
1847         if [[ $(facet_fstype $facet) = zfs ]] ||
1848            ! dm_flakey_supported $facet; then
1849                 do_facet $facet $LCTL --device ${!svc} readonly
1850         else
1851                 dm_set_dev_readonly $facet
1852         fi
1853 }
1854
1855 #
1856 # Get size in 512-byte sectors (BLKGETSIZE64 / 512) of a given device.
1857 #
1858 get_num_sectors() {
1859         local facet=$1
1860         local dev=$2
1861         local num_sectors
1862
1863         num_sectors=$(do_facet $facet "blockdev --getsz $dev 2>/dev/null")
1864         [[ ${PIPESTATUS[0]} = 0 && -n "$num_sectors" ]] || num_sectors=0
1865         echo -n $num_sectors
1866 }
1867
1868 #
1869 # Create a device-mapper device with a given block device or regular file (will
1870 # be associated with loop device).
1871 # Return the full path of the device-mapper device.
1872 #
1873 dm_create_dev() {
1874         local facet=$1
1875         local real_dev=$2                                  # destination device
1876         local dm_dev_name=${3:-$(dm_facet_devname $facet)} # device name
1877         local dm_dev=$DM_DEV_PATH/$dm_dev_name            # device-mapper device
1878
1879         # check if the device-mapper device to be created already exists
1880         if is_dm_dev $facet $dm_dev; then
1881                 # if the existing device was set to "read-only", then clear it
1882                 ! is_dm_flakey_dev $facet $dm_dev ||
1883                         dm_clear_dev_readonly $facet $dm_dev
1884
1885                 echo -n $dm_dev
1886                 return 0
1887         fi
1888
1889         # check if the destination device is a block device, and if not,
1890         # associate it with a loop device
1891         is_blkdev $facet $real_dev ||
1892                 real_dev=$(setup_loop_device $facet $real_dev)
1893         [[ -n "$real_dev" ]] || { echo -n $real_dev; return 2; }
1894
1895         # now create the device-mapper device
1896         local num_sectors=$(get_num_sectors $facet $real_dev)
1897         local table="0 $num_sectors linear $real_dev 0"
1898         local rc=0
1899
1900         do_facet $facet "$DMSETUP create $dm_dev_name --table \\\"$table\\\"" ||
1901                 { rc=${PIPESTATUS[0]}; dm_dev=; }
1902         do_facet $facet "$DMSETUP mknodes >/dev/null 2>&1"
1903
1904         echo -n $dm_dev
1905         return $rc
1906 }
1907
1908 #
1909 # Map the facet name to its device variable name.
1910 #
1911 facet_device_alias() {
1912         local facet=$1
1913         local dev_alias=$facet
1914
1915         case $facet in
1916                 fs2mds) dev_alias=mds1_2 ;;
1917                 fs2ost) dev_alias=ost1_2 ;;
1918                 fs3ost) dev_alias=ost2_2 ;;
1919                 *) ;;
1920         esac
1921
1922         echo -n $dev_alias
1923 }
1924
1925 #
1926 # Save the original value of the facet device and export the new value.
1927 #
1928 export_dm_dev() {
1929         local facet=$1
1930         local dm_dev=$2
1931
1932         local active_facet=$(facet_active $facet)
1933         local dev_alias=$(facet_device_alias $active_facet)
1934         local dev_name=${dev_alias}_dev
1935         local dev=${!dev_name}
1936
1937         if [[ $active_facet = $facet ]]; then
1938                 local failover_dev=${dev_alias}failover_dev
1939                 if [[ ${!failover_dev} = $dev ]]; then
1940                         eval export ${failover_dev}_saved=$dev
1941                         eval export ${failover_dev}=$dm_dev
1942                 fi
1943         else
1944                 dev_alias=$(facet_device_alias $facet)
1945                 local facet_dev=${dev_alias}_dev
1946                 if [[ ${!facet_dev} = $dev ]]; then
1947                         eval export ${facet_dev}_saved=$dev
1948                         eval export ${facet_dev}=$dm_dev
1949                 fi
1950         fi
1951
1952         eval export ${dev_name}_saved=$dev
1953         eval export ${dev_name}=$dm_dev
1954 }
1955
1956 #
1957 # Restore the saved value of the facet device.
1958 #
1959 unexport_dm_dev() {
1960         local facet=$1
1961
1962         [[ $facet = mgs ]] && combined_mgs_mds && facet=mds1
1963         local dev_alias=$(facet_device_alias $facet)
1964
1965         local saved_dev=${dev_alias}_dev_saved
1966         [[ -z ${!saved_dev} ]] ||
1967                 eval export ${dev_alias}_dev=${!saved_dev}
1968
1969         saved_dev=${dev_alias}failover_dev_saved
1970         [[ -z ${!saved_dev} ]] ||
1971                 eval export ${dev_alias}failover_dev=${!saved_dev}
1972 }
1973
1974 #
1975 # Remove a device-mapper device.
1976 # If the destination device is a loop device, then also detach it.
1977 #
1978 dm_cleanup_dev() {
1979         local facet=$1
1980         local dm_dev=${2:-$(dm_facet_devpath $facet)}
1981         local major
1982         local minor
1983
1984         is_dm_dev $facet $dm_dev || return 0
1985
1986         read major minor <<< $(do_facet $facet "$DMSETUP table $dm_dev" |
1987                 awk '{ print $4 }' | awk -F: '{ print $1" "$2 }')
1988
1989         do_facet $facet "$DMSETUP remove $dm_dev"
1990         do_facet $facet "$DMSETUP mknodes >/dev/null 2>&1"
1991
1992         unexport_dm_dev $facet
1993
1994         # detach a loop device
1995         [[ $major -ne 7 ]] || cleanup_loop_device $facet /dev/loop$minor
1996
1997         # unload dm-flakey module
1998         do_facet $facet "modprobe -r dm-flakey" || true
1999 }
2000
2001 mount_facet() {
2002         local facet=$1
2003         shift
2004         local active_facet=$(facet_active $facet)
2005         local dev_alias=$(facet_device_alias $active_facet)
2006         local dev=${dev_alias}_dev
2007         local opt=${facet}_opt
2008         local mntpt=$(facet_mntpt $facet)
2009         local opts="${!opt} $@"
2010         local fstype=$(facet_fstype $facet)
2011         local devicelabel
2012         local dm_dev=${!dev}
2013
2014         module_loaded lustre || load_modules
2015
2016         case $fstype in
2017         ldiskfs)
2018                 if dm_flakey_supported $facet; then
2019                         dm_dev=$(dm_create_dev $facet ${!dev})
2020                         [[ -n "$dm_dev" ]] || dm_dev=${!dev}
2021                 fi
2022
2023                 is_blkdev $facet $dm_dev || opts=$(csa_add "$opts" -o loop)
2024
2025                 devicelabel=$(do_facet ${facet} "$E2LABEL $dm_dev");;
2026         zfs)
2027                 # import ZFS storage pool
2028                 import_zpool $facet || return ${PIPESTATUS[0]}
2029
2030                 devicelabel=$(do_facet ${facet} "$ZFS get -H -o value \
2031                                                 lustre:svname $dm_dev");;
2032         *)
2033                 error "unknown fstype!";;
2034         esac
2035
2036         echo "Starting ${facet}: $opts $dm_dev $mntpt"
2037         # for testing LU-482 error handling in mount_facets() and test_0a()
2038         if [ -f $TMP/test-lu482-trigger ]; then
2039                 RC=2
2040         else
2041                 do_facet ${facet} \
2042                         "mkdir -p $mntpt; $MOUNT_CMD $opts $dm_dev $mntpt"
2043                 RC=${PIPESTATUS[0]}
2044         fi
2045
2046         if [ $RC -ne 0 ]; then
2047                 echo "Start of $dm_dev on ${facet} failed ${RC}"
2048                 return $RC
2049         fi
2050
2051         health=$(do_facet ${facet} "$LCTL get_param -n health_check")
2052         if [[ "$health" != "healthy" ]]; then
2053                 error "$facet is in a unhealthy state"
2054         fi
2055
2056         set_default_debug_facet $facet
2057
2058         if [[ $opts =~ .*nosvc.* ]]; then
2059                 echo "Start $dm_dev without service"
2060         else
2061
2062                 case $fstype in
2063                 ldiskfs)
2064                         wait_update_facet ${facet} "$E2LABEL $dm_dev \
2065                                 2>/dev/null | grep -E ':[a-zA-Z]{3}[0-9]{4}'" \
2066                                 "" || error "$dm_dev failed to initialize!";;
2067                 zfs)
2068                         wait_update_facet ${facet} "$ZFS get -H -o value \
2069                                 lustre:svname $dm_dev 2>/dev/null | \
2070                                 grep -E ':[a-zA-Z]{3}[0-9]{4}'" "" ||
2071                                 error "$dm_dev failed to initialize!";;
2072
2073                 *)
2074                         error "unknown fstype!";;
2075                 esac
2076         fi
2077
2078         # commit the device label change to disk
2079         if [[ $devicelabel =~ (:[a-zA-Z]{3}[0-9]{4}) ]]; then
2080                 echo "Commit the device label on ${!dev}"
2081                 do_facet $facet "sync; sleep 1; sync"
2082         fi
2083
2084
2085         label=$(devicelabel ${facet} $dm_dev)
2086         [ -z "$label" ] && echo no label for $dm_dev && exit 1
2087         eval export ${facet}_svc=${label}
2088         echo Started ${label}
2089
2090         export_dm_dev $facet $dm_dev
2091
2092         return $RC
2093 }
2094
2095 # start facet device options
2096 start() {
2097         local facet=$1
2098         shift
2099         local device=$1
2100         shift
2101         local dev_alias=$(facet_device_alias $facet)
2102
2103         eval export ${dev_alias}_dev=${device}
2104         eval export ${facet}_opt=\"$@\"
2105
2106         local varname=${dev_alias}failover_dev
2107         if [ -n "${!varname}" ] ; then
2108                 eval export ${dev_alias}failover_dev=${!varname}
2109         else
2110                 eval export ${dev_alias}failover_dev=$device
2111         fi
2112
2113         local mntpt=$(facet_mntpt $facet)
2114         do_facet ${facet} mkdir -p $mntpt
2115         eval export ${facet}_MOUNT=$mntpt
2116         mount_facet ${facet}
2117         RC=$?
2118
2119         return $RC
2120 }
2121
2122 stop() {
2123         local running
2124         local facet=$1
2125         shift
2126         local HOST=$(facet_active_host $facet)
2127         [[ -z $HOST ]] && echo stop: no host for $facet && return 0
2128
2129         local mntpt=$(facet_mntpt $facet)
2130         running=$(do_facet ${facet} "grep -c $mntpt' ' /proc/mounts || true")
2131         if [ ${running} -ne 0 ]; then
2132                 echo "Stopping $mntpt (opts:$@) on $HOST"
2133                 do_facet ${facet} $UMOUNT $@ $mntpt
2134         fi
2135
2136         # umount should block, but we should wait for unrelated obd's
2137         # like the MGS or MGC to also stop.
2138         wait_exit_ST ${facet} || return ${PIPESTATUS[0]}
2139
2140         if [[ $(facet_fstype $facet) == zfs ]]; then
2141                 # export ZFS storage pool
2142                 [ "$KEEP_ZPOOL" = "true" ] || export_zpool $facet
2143         elif dm_flakey_supported $facet; then
2144                 local host=${facet}_HOST
2145                 local failover_host=${facet}failover_HOST
2146                 if [[ -n ${!failover_host} && ${!failover_host} != ${!host} ]]||
2147                         $CLEANUP_DM_DEV || [[ $facet = fs* ]]; then
2148                         dm_cleanup_dev $facet
2149                 fi
2150         fi
2151 }
2152
2153 # get mdt quota type
2154 mdt_quota_type() {
2155         local varsvc=${SINGLEMDS}_svc
2156         do_facet $SINGLEMDS $LCTL get_param -n \
2157                 osd-$(facet_fstype $SINGLEMDS).${!varsvc}.quota_slave.enabled
2158 }
2159
2160 # get ost quota type
2161 ost_quota_type() {
2162         # All OSTs should have same quota type
2163         local varsvc=ost1_svc
2164         do_facet ost1 $LCTL get_param -n \
2165                 osd-$(facet_fstype ost1).${!varsvc}.quota_slave.enabled
2166 }
2167
2168 # restore old quota type settings
2169 restore_quota() {
2170         if [ "$old_MDT_QUOTA_TYPE" ]; then
2171                 if [[ $PERM_CMD == *"set_param -P"* ]]; then
2172                         do_facet mgs $PERM_CMD \
2173                                 osd-*.$FSNAME-MDT*.quota_slave.enable = \
2174                                 $old_MDT_QUOTA_TYPE
2175                 else
2176                         do_facet mgs $PERM_CMD \
2177                                 $FSNAME.quota.mdt=$old_MDT_QUOTA_TYPE
2178                 fi
2179         fi
2180         if [ "$old_OST_QUOTA_TYPE" ]; then
2181                 if [[ $PERM_CMD == *"set_param -P"* ]]; then
2182                         do_facet mgs $PERM_CMD \
2183                                 osd-*.$FSNAME-OST*.quota_slave.enable = \
2184                                 $old_OST_QUOTA_TYPE
2185                 else
2186                         do_facet mgs $LCTL conf_param \
2187                                 $FSNAME.quota.ost=$old_OST_QUOTA_TYPE
2188                 fi
2189         fi
2190 }
2191
2192 # Handle the case when there is a space in the lfs df
2193 # "filesystem summary" line the same as when there is no space.
2194 # This will allow fixing the "lfs df" summary line in the future.
2195 lfs_df() {
2196         $LFS df $* | sed -e 's/filesystem /filesystem_/'
2197 }
2198
2199 # Get free inodes on the MDT specified by mdt index, free indoes on
2200 # the whole filesystem will be returned when index == -1.
2201 mdt_free_inodes() {
2202         local index=$1
2203         local free_inodes
2204         local mdt_uuid
2205
2206         if [ $index -eq -1 ]; then
2207                 mdt_uuid="summary"
2208         else
2209                 mdt_uuid=$(mdtuuid_from_index $index)
2210         fi
2211
2212         free_inodes=$(lfs_df -i $MOUNT | grep $mdt_uuid | awk '{print $4}')
2213         echo $free_inodes
2214 }
2215
2216 #
2217 # Get the OST device status from 'lfs df' with a given OST index.
2218 #
2219 ost_dev_status() {
2220         local ost_idx=$1
2221         local mnt_pnt=${2:-$MOUNT}
2222         local opts=$3
2223         local ost_uuid
2224
2225         ost_uuid=$(ostuuid_from_index $ost_idx $mnt_pnt)
2226         lfs_df $opts $mnt_pnt | awk '/'$ost_uuid'/ { print $7 }'
2227 }
2228
2229 setup_quota(){
2230         local mntpt=$1
2231
2232         # save old quota type & set new quota type
2233         local mdt_qtype=$(mdt_quota_type)
2234         local ost_qtype=$(ost_quota_type)
2235
2236         echo "[HOST:$HOSTNAME] [old_mdt_qtype:$mdt_qtype]" \
2237                 "[old_ost_qtype:$ost_qtype] [new_qtype:$QUOTA_TYPE]"
2238
2239         export old_MDT_QUOTA_TYPE=$mdt_qtype
2240         export old_OST_QUOTA_TYPE=$ost_qtype
2241
2242         if [[ $PERM_CMD == *"set_param -P"* ]]; then
2243                 do_facet mgs $PERM_CMD \
2244                         osd-*.$FSNAME-MDT*.quota_slave.enable=$QUOTA_TYPE
2245                 do_facet mgs $PERM_CMD \
2246                         osd-*.$FSNAME-OST*.quota_slave.enable=$QUOTA_TYPE
2247         else
2248                 do_facet mgs $PERM_CMD $FSNAME.quota.mdt=$QUOTA_TYPE ||
2249                         error "set mdt quota type failed"
2250                 do_facet mgs $PERM_CMD $FSNAME.quota.ost=$QUOTA_TYPE ||
2251                         error "set ost quota type failed"
2252         fi
2253
2254         local quota_usrs=$QUOTA_USERS
2255
2256         # get_filesystem_size
2257         local disksz=$(lfs_df $mntpt | grep "summary" | awk '{print $2}')
2258         local blk_soft=$((disksz + 1024))
2259         local blk_hard=$((blk_soft + blk_soft / 20)) # Go 5% over
2260
2261         local inodes=$(lfs_df -i $mntpt | grep "summary" | awk '{print $2}')
2262         local i_soft=$inodes
2263         local i_hard=$((i_soft + i_soft / 20))
2264
2265         echo "Total disk size: $disksz  block-softlimit: $blk_soft" \
2266                 "block-hardlimit: $blk_hard inode-softlimit: $i_soft" \
2267                 "inode-hardlimit: $i_hard"
2268
2269         local cmd
2270         for usr in $quota_usrs; do
2271                 echo "Setting up quota on $HOSTNAME:$mntpt for $usr..."
2272                 for type in u g; do
2273                         cmd="$LFS setquota -$type $usr -b $blk_soft"
2274                         cmd="$cmd -B $blk_hard -i $i_soft -I $i_hard $mntpt"
2275                         echo "+ $cmd"
2276                         eval $cmd || error "$cmd FAILED!"
2277                 done
2278                 # display the quota status
2279                 echo "Quota settings for $usr : "
2280                 $LFS quota -v -u $usr $mntpt || true
2281         done
2282 }
2283
2284 zconf_mount() {
2285         local client=$1
2286         local mnt=$2
2287         local opts=${3:-$MOUNT_OPTS}
2288         opts=${opts:+-o $opts}
2289         local flags=${4:-$MOUNT_FLAGS}
2290
2291         local device=$MGSNID:/$FSNAME$FILESET
2292         if [ -z "$mnt" -o -z "$FSNAME" ]; then
2293                 echo "Bad mount command: opt=$flags $opts dev=$device " \
2294                      "mnt=$mnt"
2295                 exit 1
2296         fi
2297
2298         if $GSS_SK; then
2299                 # update mount option with skpath
2300                 opts=$(add_sk_mntflag $opts)
2301         fi
2302
2303         echo "Starting client: $client: $flags $opts $device $mnt"
2304         do_node $client mkdir -p $mnt
2305         if [ -n "$FILESET" -a -z "$SKIP_FILESET" ];then
2306                 do_node $client $MOUNT_CMD $flags $opts $MGSNID:/$FSNAME \
2307                         $mnt || return 1
2308                 #disable FILESET if not supported
2309                 do_nodes $client lctl get_param -n \
2310                         mdc.$FSNAME-MDT0000*.import | grep -q subtree ||
2311                                 device=$MGSNID:/$FSNAME
2312                 do_node $client mkdir -p $mnt/$FILESET
2313                 do_node $client "! grep -q $mnt' ' /proc/mounts ||
2314                         umount $mnt"
2315         fi
2316         if $GSS_SK && ($SK_UNIQUE_NM || $SK_S2S); then
2317                 # Mount using nodemap key
2318                 local mountkey=$SK_PATH/$FSNAME-nmclient.key
2319                 if $SK_UNIQUE_NM; then
2320                         mountkey=$SK_PATH/nodemap/c0.key
2321                 fi
2322                 local prunedopts=$(echo $opts |
2323                                 sed -e "s#skpath=[^,^ ]*#skpath=$mountkey#g")
2324                 do_node $client $MOUNT_CMD $flags $prunedopts $device $mnt ||
2325                                 return 1
2326         else
2327                 do_node $client $MOUNT_CMD $flags $opts $device $mnt ||
2328                                 return 1
2329         fi
2330
2331         set_default_debug_nodes $client
2332
2333         return 0
2334 }
2335
2336 zconf_umount() {
2337         local client=$1
2338         local mnt=$2
2339         local force
2340         local busy
2341         local need_kill
2342         local running=$(do_node $client "grep -c $mnt' ' /proc/mounts") || true
2343
2344         [ "$3" ] && force=-f
2345         [ $running -eq 0 ] && return 0
2346
2347         echo "Stopping client $client $mnt (opts:$force)"
2348         do_node $client lsof -t $mnt || need_kill=no
2349         if [ "x$force" != "x" ] && [ "x$need_kill" != "xno" ]; then
2350                 pids=$(do_node $client lsof -t $mnt | sort -u);
2351                 if [ -n "$pids" ]; then
2352                         do_node $client kill -9 $pids || true
2353                 fi
2354         fi
2355
2356         busy=$(do_node $client "umount $force $mnt 2>&1" | grep -c "busy") ||
2357                 true
2358         if [ $busy -ne 0 ] ; then
2359                 echo "$mnt is still busy, wait one second" && sleep 1
2360                 do_node $client umount $force $mnt
2361         fi
2362 }
2363
2364 # Mount the file system on the MDS
2365 mount_mds_client() {
2366         local mds_HOST=${SINGLEMDS}_HOST
2367         echo $mds_HOST
2368         zconf_mount $mds1_HOST $MOUNT2 $MOUNT_OPTS ||
2369                 error "unable to mount $MOUNT2 on MDS"
2370 }
2371
2372 # Unmount the file system on the MDS
2373 umount_mds_client() {
2374         local mds_HOST=${SINGLEMDS}_HOST
2375         zconf_umount $mds1_HOST $MOUNT2
2376         do_facet $SINGLEMDS "rmdir $MOUNT2"
2377 }
2378
2379 # nodes is comma list
2380 sanity_mount_check_nodes () {
2381     local nodes=$1
2382     shift
2383     local mnts="$@"
2384     local mnt
2385
2386     # FIXME: assume that all cluster nodes run the same os
2387     [ "$(uname)" = Linux ] || return 0
2388
2389     local rc=0
2390     for mnt in $mnts ; do
2391         do_nodes $nodes "running=\\\$(grep -c $mnt' ' /proc/mounts);
2392 mpts=\\\$(mount | grep -c $mnt' ');
2393 if [ \\\$running -ne \\\$mpts ]; then
2394     echo \\\$(hostname) env are INSANE!;
2395     exit 1;
2396 fi"
2397     [ $? -eq 0 ] || rc=1
2398     done
2399     return $rc
2400 }
2401
2402 sanity_mount_check_servers () {
2403     [ -n "$CLIENTONLY" ] &&
2404         { echo "CLIENTONLY mode, skip mount_check_servers"; return 0; } || true
2405     echo Checking servers environments
2406
2407     # FIXME: modify get_facets to display all facets wo params
2408     local facets="$(get_facets OST),$(get_facets MDS),mgs"
2409     local node
2410     local mntpt
2411     local facet
2412     for facet in ${facets//,/ }; do
2413         node=$(facet_host ${facet})
2414         mntpt=$(facet_mntpt $facet)
2415         sanity_mount_check_nodes $node $mntpt ||
2416             { error "server $node environments are insane!"; return 1; }
2417     done
2418 }
2419
2420 sanity_mount_check_clients () {
2421     local clients=${1:-$CLIENTS}
2422     local mntpt=${2:-$MOUNT}
2423     local mntpt2=${3:-$MOUNT2}
2424
2425     [ -z $clients ] && clients=$(hostname)
2426     echo Checking clients $clients environments
2427
2428     sanity_mount_check_nodes $clients $mntpt $mntpt2 ||
2429        error "clients environments are insane!"
2430 }
2431
2432 sanity_mount_check () {
2433     sanity_mount_check_servers || return 1
2434     sanity_mount_check_clients || return 2
2435 }
2436
2437 # mount clients if not mouted
2438 zconf_mount_clients() {
2439         local clients=$1
2440         local mnt=$2
2441         local opts=${3:-$MOUNT_OPTS}
2442         opts=${opts:+-o $opts}
2443         local flags=${4:-$MOUNT_FLAGS}
2444         local device=$MGSNID:/$FSNAME$FILESET
2445         if [ -z "$mnt" -o -z "$FSNAME" ]; then
2446                 echo "Bad conf mount command: opt=$flags $opts dev=$device " \
2447                      "mnt=$mnt"
2448                 exit 1
2449         fi
2450
2451         echo "Starting client $clients: $flags $opts $device $mnt"
2452         do_nodes $clients mkdir -p $mnt
2453         if [ -n "$FILESET" -a -z "$SKIP_FILESET" ]; then
2454                 if $GSS_SK && ($SK_UNIQUE_NM || $SK_S2S); then
2455                         # Mount with own nodemap key
2456                         local i=0
2457                         # Mount all server nodes first with per-NM keys
2458                         for nmclient in ${clients//,/ }; do
2459 #                               do_nodes $(comma_list $(all_server_nodes)) "lgss_sk -t server -l $SK_PATH/nodemap/c$i.key -n c$i"
2460                                 do_nodes $(comma_list $(all_server_nodes)) "lgss_sk -t server -l $SK_PATH/nodemap/c$i.key"
2461                                 i=$((i + 1))
2462                         done
2463                         # set perms for per-nodemap keys else permission denied
2464                         do_nodes $(comma_list $(all_nodes)) \
2465                                 "keyctl show | grep lustre | cut -c1-11 |
2466                                 sed -e 's/ //g;' |
2467                                 xargs -IX keyctl setperm X 0x3f3f3f3f"
2468                         local mountkey=$SK_PATH/$FSNAME-nmclient.key
2469                         i=0
2470                         for nmclient in ${clients//,/ }; do
2471                                 if $SK_UNIQUE_NM; then
2472                                         mountkey=$SK_PATH/nodemap/c$i.key
2473                                 fi
2474                                 do_node $nmclient "! grep -q $mnt' ' \
2475                                         /proc/mounts || umount $mnt"
2476                                 local prunedopts=$(add_sk_mntflag $prunedopts);
2477                                 prunedopts=$(echo $prunedopts | sed -e \
2478                                         "s#skpath=[^ ^,]*#skpath=$mountkey#g")
2479                                 set -x
2480                                 do_nodes $(comma_list $(all_server_nodes)) \
2481                                         "keyctl show"
2482                                 set +x
2483                                 do_node $nmclient $MOUNT_CMD $flags \
2484                                         $prunedopts $MGSNID:/$FSNAME $mnt ||
2485                                         return 1
2486                                 i=$((i + 1))
2487                         done
2488                 else
2489                         do_nodes $clients "! grep -q $mnt' ' /proc/mounts ||
2490                                         umount $mnt"
2491                         do_nodes $clients $MOUNT_CMD $flags $opts \
2492                                         $MGSNID:/$FSNAME $mnt || return 1
2493                 fi
2494                 #disable FILESET if not supported
2495                 do_nodes $clients lctl get_param -n \
2496                         mdc.$FSNAME-MDT0000*.import | grep -q subtree ||
2497                                 device=$MGSNID:/$FSNAME
2498                 do_nodes $clients mkdir -p $mnt/$FILESET
2499                 do_nodes $clients "! grep -q $mnt' ' /proc/mounts ||
2500                         umount $mnt"
2501         fi
2502
2503         if $GSS_SK && ($SK_UNIQUE_NM || $SK_S2S); then
2504                 # Mount with nodemap key
2505                 local i=0
2506                 local mountkey=$SK_PATH/$FSNAME-nmclient.key
2507                 for nmclient in ${clients//,/ }; do
2508                         if $SK_UNIQUE_NM; then
2509                                 mountkey=$SK_PATH/nodemap/c$i.key
2510                         fi
2511                         local prunedopts=$(echo $opts | sed -e \
2512                                 "s#skpath=[^ ^,]*#skpath=$mountkey#g");
2513                         do_node $nmclient "! grep -q $mnt' ' /proc/mounts ||
2514                                 umount $mnt"
2515                         do_node $nmclient "
2516                 running=\\\$(mount | grep -c $mnt' ');
2517                 rc=0;
2518                 if [ \\\$running -eq 0 ] ; then
2519                         mkdir -p $mnt;
2520                         $MOUNT_CMD $flags $prunedopts $device $mnt;
2521                         rc=\\\$?;
2522                 else
2523                         lustre_mnt_count=\\\$(mount | grep $mnt' ' | \
2524                                 grep 'type lustre' | wc -l);
2525                         if [ \\\$running -ne \\\$lustre_mnt_count ] ; then
2526                                 echo zconf_mount_clients FAILED: \
2527                                         mount count \\\$running, not matching \
2528                                         with mount count of 'type lustre' \
2529                                         \\\$lustre_mnt_count;
2530                                 rc=1;
2531                         fi;
2532                 fi;
2533         exit \\\$rc" || return ${PIPESTATUS[0]}
2534
2535                         i=$((i + 1))
2536                 done
2537         else
2538
2539                 local tmpopts=$opts
2540                 if $SHARED_KEY; then
2541                         tmpopts=$(add_sk_mntflag $opts)
2542                 fi
2543                 do_nodes $clients "
2544 running=\\\$(mount | grep -c $mnt' ');
2545 rc=0;
2546 if [ \\\$running -eq 0 ] ; then
2547         mkdir -p $mnt;
2548         $MOUNT_CMD $flags $tmpopts $device $mnt;
2549         rc=\\\$?;
2550 fi;
2551 exit \\\$rc" || return ${PIPESTATUS[0]}
2552         fi
2553
2554         echo "Started clients $clients: "
2555         do_nodes $clients "mount | grep $mnt' '"
2556
2557         set_default_debug_nodes $clients
2558
2559         return 0
2560 }
2561
2562 zconf_umount_clients() {
2563     local clients=$1
2564     local mnt=$2
2565     local force
2566
2567     [ "$3" ] && force=-f
2568
2569     echo "Stopping clients: $clients $mnt (opts:$force)"
2570     do_nodes $clients "running=\\\$(grep -c $mnt' ' /proc/mounts);
2571 if [ \\\$running -ne 0 ] ; then
2572 echo Stopping client \\\$(hostname) $mnt opts:$force;
2573 lsof $mnt || need_kill=no;
2574 if [ "x$force" != "x" -a "x\\\$need_kill" != "xno" ]; then
2575     pids=\\\$(lsof -t $mnt | sort -u);
2576     if [ -n \\\"\\\$pids\\\" ]; then
2577              kill -9 \\\$pids;
2578     fi
2579 fi;
2580 while umount $force $mnt 2>&1 | grep -q "busy"; do
2581     echo "$mnt is still busy, wait one second" && sleep 1;
2582 done;
2583 fi"
2584 }
2585
2586 shutdown_node () {
2587     local node=$1
2588     echo + $POWER_DOWN $node
2589     $POWER_DOWN $node
2590 }
2591
2592 shutdown_node_hard () {
2593     local host=$1
2594     local attempts=$SHUTDOWN_ATTEMPTS
2595
2596     for i in $(seq $attempts) ; do
2597         shutdown_node $host
2598         sleep 1
2599         wait_for_function --quiet "! ping -w 3 -c 1 $host" 5 1 && return 0
2600         echo "waiting for $host to fail attempts=$attempts"
2601         [ $i -lt $attempts ] || \
2602             { echo "$host still pingable after power down! attempts=$attempts" && return 1; }
2603     done
2604 }
2605
2606 shutdown_client() {
2607     local client=$1
2608     local mnt=${2:-$MOUNT}
2609     local attempts=3
2610
2611     if [ "$FAILURE_MODE" = HARD ]; then
2612         shutdown_node_hard $client
2613     else
2614        zconf_umount_clients $client $mnt -f
2615     fi
2616 }
2617
2618 facets_on_host () {
2619     local host=$1
2620     local facets="$(get_facets OST),$(get_facets MDS)"
2621     local affected
2622
2623     combined_mgs_mds || facets="$facets,mgs"
2624
2625     for facet in ${facets//,/ }; do
2626         if [ $(facet_active_host $facet) == $host ]; then
2627            affected="$affected $facet"
2628         fi
2629     done
2630
2631     echo $(comma_list $affected)
2632 }
2633
2634 facet_up() {
2635         local facet=$1
2636         local host=${2:-$(facet_host $facet)}
2637
2638         local label=$(convert_facet2label $facet)
2639         do_node $host $LCTL dl | awk '{ print $4 }' | grep -q "^$label\$"
2640 }
2641
2642 facets_up_on_host () {
2643     local host=$1
2644     local facets=$(facets_on_host $host)
2645     local affected_up
2646
2647     for facet in ${facets//,/ }; do
2648         if $(facet_up $facet $host); then
2649             affected_up="$affected_up $facet"
2650         fi
2651     done
2652
2653     echo $(comma_list $affected_up)
2654 }
2655
2656 shutdown_facet() {
2657         local facet=$1
2658         local affected_facet
2659         local affected_facets
2660
2661         if [[ "$FAILURE_MODE" = HARD ]]; then
2662                 if [[ $(facet_fstype $facet) = ldiskfs ]] &&
2663                         dm_flakey_supported $facet; then
2664                         affected_facets=$(affected_facets $facet)
2665                         for affected_facet in ${affected_facets//,/ }; do
2666                                 unexport_dm_dev $affected_facet
2667                         done
2668                 fi
2669
2670                 shutdown_node_hard $(facet_active_host $facet)
2671         else
2672                 stop $facet
2673         fi
2674 }
2675
2676 reboot_node() {
2677     local node=$1
2678     echo + $POWER_UP $node
2679     $POWER_UP $node
2680 }
2681
2682 remount_facet() {
2683     local facet=$1
2684
2685     stop $facet
2686     mount_facet $facet
2687 }
2688
2689 reboot_facet() {
2690         local facet=$1
2691         if [ "$FAILURE_MODE" = HARD ]; then
2692                 reboot_node $(facet_active_host $facet)
2693         else
2694                 sleep 10
2695         fi
2696 }
2697
2698 boot_node() {
2699     local node=$1
2700     if [ "$FAILURE_MODE" = HARD ]; then
2701        reboot_node $node
2702        wait_for_host $node
2703     fi
2704 }
2705
2706 facets_hosts () {
2707     local facets=$1
2708     local hosts
2709
2710     for facet in ${facets//,/ }; do
2711         hosts=$(expand_list $hosts $(facet_host $facet) )
2712     done
2713
2714     echo $hosts
2715 }
2716
2717 _check_progs_installed () {
2718     local progs=$@
2719     local rc=0
2720
2721     for prog in $progs; do
2722         if ! [ "$(which $prog)"  -o  "${!prog}" ]; then
2723            echo $prog missing on $(hostname)
2724            rc=1
2725         fi
2726     done
2727     return $rc
2728 }
2729
2730 check_progs_installed () {
2731         local nodes=$1
2732         shift
2733
2734         do_rpc_nodes "$nodes" _check_progs_installed $@
2735 }
2736
2737 # recovery-scale functions
2738 node_var_name() {
2739     echo __$(echo $1 | tr '-' '_' | tr '.' '_')
2740 }
2741
2742 start_client_load() {
2743         local client=$1
2744         local load=$2
2745         local var=$(node_var_name $client)_load
2746         eval export ${var}=$load
2747
2748         do_node $client "PATH=$PATH MOUNT=$MOUNT ERRORS_OK=$ERRORS_OK \
2749                         BREAK_ON_ERROR=$BREAK_ON_ERROR \
2750                         END_RUN_FILE=$END_RUN_FILE \
2751                         LOAD_PID_FILE=$LOAD_PID_FILE \
2752                         TESTLOG_PREFIX=$TESTLOG_PREFIX \
2753                         TESTNAME=$TESTNAME \
2754                         DBENCH_LIB=$DBENCH_LIB \
2755                         DBENCH_SRC=$DBENCH_SRC \
2756                         CLIENT_COUNT=$((CLIENTCOUNT - 1)) \
2757                         LFS=$LFS \
2758                         LCTL=$LCTL \
2759                         FSNAME=$FSNAME \
2760                         MPIRUN=$MPIRUN \
2761                         MPIRUN_OPTIONS=\\\"$MPIRUN_OPTIONS\\\" \
2762                         MACHINEFILE_OPTION=\\\"$MACHINEFILE_OPTION\\\" \
2763                         num_clients=$(get_node_count ${CLIENTS//,/ }) \
2764                         ior_THREADS=$ior_THREADS ior_iteration=$ior_iteration \
2765                         ior_blockSize=$ior_blockSize \
2766                         ior_blockUnit=$ior_blockUnit \
2767                         ior_xferSize=$ior_xferSize ior_type=$ior_type \
2768                         ior_DURATION=$ior_DURATION \
2769                         ior_stripe_params=\\\"$ior_stripe_params\\\" \
2770                         ior_custom_params=\\\"$ior_custom_param\\\" \
2771                         mpi_ior_custom_threads=$mpi_ior_custom_threads \
2772                         run_${load}.sh" &
2773         local ppid=$!
2774         log "Started client load: ${load} on $client"
2775
2776         # get the children process IDs
2777         local pids=$(ps --ppid $ppid -o pid= | xargs)
2778         CLIENT_LOAD_PIDS="$CLIENT_LOAD_PIDS $ppid $pids"
2779         return 0
2780 }
2781
2782 start_client_loads () {
2783         local -a clients=(${1//,/ })
2784         local numloads=${#CLIENT_LOADS[@]}
2785
2786         for ((nodenum=0; nodenum < ${#clients[@]}; nodenum++ )); do
2787                 local load=$((nodenum % numloads))
2788                 start_client_load ${clients[nodenum]} ${CLIENT_LOADS[load]}
2789         done
2790         # bug 22169: wait the background threads to start
2791         sleep 2
2792 }
2793
2794 # only for remote client
2795 check_client_load () {
2796         local client=$1
2797         local var=$(node_var_name $client)_load
2798         local testload=run_${!var}.sh
2799
2800         ps auxww | grep -v grep | grep $client | grep -q $testload || return 1
2801
2802         # bug 18914: try to connect several times not only when
2803         # check ps, but  while check_node_health also
2804
2805         local tries=3
2806         local RC=254
2807         while [ $RC = 254 -a $tries -gt 0 ]; do
2808                 let tries=$tries-1
2809                 # assume success
2810                 RC=0
2811                 if ! check_node_health $client; then
2812                         RC=${PIPESTATUS[0]}
2813                         if [ $RC -eq 254 ]; then
2814                                 # FIXME: not sure how long we shuold sleep here
2815                                 sleep 10
2816                                 continue
2817                         fi
2818                         echo "check node health failed: RC=$RC "
2819                         return $RC
2820                 fi
2821         done
2822         # We can continue try to connect if RC=254
2823         # Just print the warning about this
2824         if [ $RC = 254 ]; then
2825                 echo "got a return status of $RC from do_node while checking " \
2826                 "node health on $client"
2827         fi
2828
2829         # see if the load is still on the client
2830         tries=3
2831         RC=254
2832         while [ $RC = 254 -a $tries -gt 0 ]; do
2833                 let tries=$tries-1
2834                 # assume success
2835                 RC=0
2836                 if ! do_node $client \
2837                         "ps auxwww | grep -v grep | grep -q $testload"; then
2838                         RC=${PIPESTATUS[0]}
2839                         sleep 30
2840                 fi
2841         done
2842         if [ $RC = 254 ]; then
2843                 echo "got a return status of $RC from do_node while checking " \
2844                 "(node health and 'ps') the client load on $client"
2845                 # see if we can diagnose a bit why this is
2846         fi
2847
2848         return $RC
2849 }
2850 check_client_loads () {
2851    local clients=${1//,/ }
2852    local client=
2853    local rc=0
2854
2855    for client in $clients; do
2856       check_client_load $client
2857       rc=${PIPESTATUS[0]}
2858       if [ "$rc" != 0 ]; then
2859         log "Client load failed on node $client, rc=$rc"
2860         return $rc
2861       fi
2862    done
2863 }
2864
2865 restart_client_loads () {
2866     local clients=${1//,/ }
2867     local expectedfail=${2:-""}
2868     local client=
2869     local rc=0
2870
2871     for client in $clients; do
2872         check_client_load $client
2873         rc=${PIPESTATUS[0]}
2874         if [ "$rc" != 0 -a "$expectedfail" ]; then
2875             local var=$(node_var_name $client)_load
2876             start_client_load $client ${!var}
2877             echo "Restarted client load ${!var}: on $client. Checking ..."
2878             check_client_load $client
2879             rc=${PIPESTATUS[0]}
2880             if [ "$rc" != 0 ]; then
2881                 log "Client load failed to restart on node $client, rc=$rc"
2882                 # failure one client load means test fail
2883                 # we do not need to check other
2884                 return $rc
2885             fi
2886         else
2887             return $rc
2888         fi
2889     done
2890 }
2891
2892 # Start vmstat and save its process ID in a file.
2893 start_vmstat() {
2894     local nodes=$1
2895     local pid_file=$2
2896
2897     [ -z "$nodes" -o -z "$pid_file" ] && return 0
2898
2899     do_nodes $nodes \
2900         "vmstat 1 > $TESTLOG_PREFIX.$TESTNAME.vmstat.\\\$(hostname -s).log \
2901         2>/dev/null </dev/null & echo \\\$! > $pid_file"
2902 }
2903
2904 # Display the nodes on which client loads failed.
2905 print_end_run_file() {
2906     local file=$1
2907     local node
2908
2909     [ -s $file ] || return 0
2910
2911     echo "Found the END_RUN_FILE file: $file"
2912     cat $file
2913
2914     # A client load will stop if it finds the END_RUN_FILE file.
2915     # That does not mean the client load actually failed though.
2916     # The first node in END_RUN_FILE is the one we are interested in.
2917     read node < $file
2918
2919     if [ -n "$node" ]; then
2920         local var=$(node_var_name $node)_load
2921
2922         local prefix=$TESTLOG_PREFIX
2923         [ -n "$TESTNAME" ] && prefix=$prefix.$TESTNAME
2924         local stdout_log=$prefix.run_${!var}_stdout.$node.log
2925         local debug_log=$(echo $stdout_log | sed 's/\(.*\)stdout/\1debug/')
2926
2927         echo "Client load ${!var} failed on node $node:"
2928         echo "$stdout_log"
2929         echo "$debug_log"
2930     fi
2931 }
2932
2933 # Stop the process which had its PID saved in a file.
2934 stop_process() {
2935     local nodes=$1
2936     local pid_file=$2
2937
2938     [ -z "$nodes" -o -z "$pid_file" ] && return 0
2939
2940     do_nodes $nodes "test -f $pid_file &&
2941         { kill -s TERM \\\$(cat $pid_file); rm -f $pid_file; }" || true
2942 }
2943
2944 # Stop all client loads.
2945 stop_client_loads() {
2946     local nodes=${1:-$CLIENTS}
2947     local pid_file=$2
2948
2949     # stop the client loads
2950     stop_process $nodes $pid_file
2951
2952     # clean up the processes that started them
2953     [ -n "$CLIENT_LOAD_PIDS" ] && kill -9 $CLIENT_LOAD_PIDS 2>/dev/null || true
2954 }
2955 # End recovery-scale functions
2956
2957 # verify that lustre actually cleaned up properly
2958 cleanup_check() {
2959         VAR=$(lctl get_param -n catastrophe 2>&1)
2960         if [ $? = 0 ] ; then
2961                 if [ $VAR != 0 ]; then
2962                         error "LBUG/LASSERT detected"
2963                 fi
2964         fi
2965         BUSY=$(dmesg | grep -i destruct || true)
2966         if [ -n "$BUSY" ]; then
2967                 echo "$BUSY" 1>&2
2968                 [ -e $TMP/debug ] && mv $TMP/debug $TMP/debug-busy.$(date +%s)
2969                 exit 205
2970         fi
2971
2972         check_mem_leak || exit 204
2973
2974         [[ $($LCTL dl 2>/dev/null | wc -l) -gt 0 ]] && $LCTL dl &&
2975                 echo "$TESTSUITE: lustre didn't clean up..." 1>&2 &&
2976                 return 202 || true
2977
2978         if module_loaded lnet || module_loaded libcfs; then
2979                 echo "$TESTSUITE: modules still loaded..." 1>&2
2980                 /sbin/lsmod 1>&2
2981                 return 203
2982         fi
2983         return 0
2984 }
2985
2986 ##
2987 # wait for a command to return the expected result
2988 #
2989 # This will run @check on @node repeatedly until the output matches @expect
2990 # based on the supplied condition, or until @max_wait seconds have elapsed,
2991 # whichever comes first.  @cond may be one of the normal bash operators,
2992 # "-gt", "-ge", "-eq", "-le", "-lt", "==", "!=", or "=~", and must be quoted
2993 # in the caller to avoid unintentional evaluation by the shell in the caller.
2994 #
2995 # If @max_wait is not specified, the condition will be checked for up to 90s.
2996 #
2997 # If --verbose is passed as the first argument, the result is printed on each
2998 # value change, otherwise it is only printed after every 10s interval.
2999 #
3000 # Using wait_update_cond() or related helper function is preferable to adding
3001 # a "long enough" wait for some state to change in the background, since
3002 # "long enough" may be too short due to tunables, system config, or running in
3003 # a VM, and must by necessity wait too long for most cases or risk failure.
3004 #
3005 # usage: wait_update_cond [--verbose] node check cond expect [max_wait]
3006 wait_update_cond() {
3007         local verbose=false
3008         [[ "$1" == "--verbose" ]] && verbose=true && shift
3009
3010         local node=$1
3011         local check="$2"
3012         local cond="$3"
3013         local expect="$4"
3014         local max_wait=${5:-90}
3015         local result
3016         local prev_result
3017         local waited=0
3018         local begin=$SECONDS
3019         local sleep=1
3020         local print=10
3021
3022         while (( $waited <= $max_wait )); do
3023                 result=$(do_node $node "$check")
3024
3025                 eval [[ "'$result'" $cond "'$expect'" ]]
3026                 if [[ $? == 0 ]]; then
3027                         [[ -z "$result" || $waited -le $sleep ]] ||
3028                                 echo "Updated after ${waited}s: want '$expect' got '$result'"
3029                         return 0
3030                 fi
3031                 if $verbose && [[ "$result" != "$prev_result" ]]; then
3032                         [[ -n "$prev_result" ]] &&
3033                                 echo "Changed after ${waited}s: from '$prev_result' to '$result'"
3034                         prev_result="$result"
3035                 fi
3036                 (( $waited % $print == 0 )) &&
3037                         echo "Waiting $((max_wait - waited))s for '$expect'"
3038                 sleep $sleep
3039                 waited=$((SECONDS - begin))
3040         done
3041         echo "Update not seen after ${max_wait}s: want '$expect' got '$result'"
3042         return 3
3043 }
3044
3045 # usage: wait_update [--verbose] node check expect [max_wait]
3046 wait_update() {
3047         local verbose=
3048         [ "$1" = "--verbose" ] && verbose="$1" && shift
3049
3050         local node="$1"
3051         local check="$2"
3052         local expect="$3"
3053         local max_wait=$4
3054
3055         wait_update_cond $verbose $node "$check" "==" "$expect" $max_wait
3056 }
3057
3058 # usage: wait_update_facet_cond [--verbose] facet check cond expect [max_wait]
3059 wait_update_facet_cond() {
3060         local verbose=
3061         [ "$1" = "--verbose" ] && verbose="$1" && shift
3062
3063         local node=$(facet_active_host $1)
3064         local check="$2"
3065         local cond="$3"
3066         local expect="$4"
3067         local max_wait=$5
3068
3069         wait_update_cond $verbose $node "$check" "$cond" "$expect" $max_wait
3070 }
3071
3072 # usage: wait_update_facet [--verbose] facet check expect [max_wait]
3073 wait_update_facet() {
3074         local verbose=
3075         [ "$1" = "--verbose" ] && verbose="$1" && shift
3076
3077         local node=$(facet_active_host $1)
3078         local check="$2"
3079         local expect="$3"
3080         local max_wait=$4
3081
3082         wait_update_cond $verbose $node "$check" "==" "$expect" $max_wait
3083 }
3084
3085 sync_all_data() {
3086         do_nodes $(comma_list $(mdts_nodes)) \
3087             "lctl set_param -n os[cd]*.*MDT*.force_sync=1"
3088         do_nodes $(comma_list $(osts_nodes)) \
3089             "lctl set_param -n osd*.*OS*.force_sync=1" 2>&1 |
3090                 grep -v 'Found no match'
3091 }
3092
3093 wait_zfs_commit() {
3094         local zfs_wait=${2:-5}
3095
3096         # the occupied disk space will be released
3097         # only after TXGs are committed
3098         if [[ $(facet_fstype $1) == zfs ]]; then
3099                 echo "sleep $zfs_wait for ZFS $(facet_fstype $1)"
3100                 sleep $zfs_wait
3101         fi
3102 }
3103
3104 fill_ost() {
3105         local filename=$1
3106         local ost_idx=$2
3107         local lwm=$3  #low watermark
3108         local size_mb #how many MB should we write to pass watermark
3109         local ost_name=$(ostname_from_index $ost_idx)
3110
3111         free_kb=$($LFS df $MOUNT | awk "/$ost_name/ { print \$4 }")
3112         size_mb=0
3113         if (( $free_kb / 1024 > lwm )); then
3114                 size_mb=$((free_kb / 1024 - lwm))
3115         fi
3116         #If 10% of free space cross low watermark use it
3117         if (( $free_kb / 10240 > size_mb )); then
3118                 size_mb=$((free_kb / 10240))
3119         else
3120                 #At least we need to store 1.1 of difference between
3121                 #free space and low watermark
3122                 size_mb=$((size_mb + size_mb / 10))
3123         fi
3124         if (( lwm <= $free_kb / 1024 )) ||
3125            [ ! -f $DIR/${filename}.fill_ost$ost_idx ]; then
3126                 $LFS setstripe -i $ost_idx -c1 $DIR/${filename}.fill_ost$ost_idx
3127                 dd if=/dev/zero of=$DIR/${filename}.fill_ost$ost_idx bs=1M \
3128                         count=$size_mb oflag=append conv=notrunc
3129         fi
3130
3131         sleep_maxage
3132
3133         free_kb=$($LFS df $MOUNT | awk "/$ost_name/ { print \$4 }")
3134         echo "OST still has $((free_kb / 1024)) MB free"
3135 }
3136
3137 # This checks only the primary MDS
3138 ost_watermarks_get() {
3139         local ost_idx=$1
3140         local ost_name=$(ostname_from_index $ost_idx)
3141         local mdtosc_proc=$(get_mdtosc_proc_path $SINGLEMDS $ost_name)
3142
3143         local hwm=$(do_facet $SINGLEMDS $LCTL get_param -n \
3144                         osp.$mdtosc_proc.reserved_mb_high)
3145         local lwm=$(do_facet $SINGLEMDS $LCTL get_param -n \
3146                         osp.$mdtosc_proc.reserved_mb_low)
3147
3148         echo "$lwm $hwm"
3149 }
3150
3151 # Note that we set watermarks on all MDSes (necessary for striped dirs)
3152 ost_watermarks_set() {
3153         local ost_idx=$1
3154         local lwm=$2
3155         local hwm=$3
3156         local ost_name=$(ostname_from_index $ost_idx)
3157         local facets=$(get_facets MDS)
3158
3159         do_nodes $(comma_list $(mdts_nodes)) $LCTL set_param -n \
3160                 osp.*$ost_name*.reserved_mb_low=$lwm \
3161                 osp.*$ost_name*.reserved_mb_high=$hwm > /dev/null
3162
3163         # sleep to ensure we see the change
3164         sleep_maxage
3165 }
3166
3167 ost_watermarks_set_low_space() {
3168         local ost_idx=$1
3169         local wms=$(ost_watermarks_get $ost_idx)
3170         local ost_name=$(ostname_from_index $ost_idx)
3171
3172         local old_lwm=$(echo $wms | awk '{ print $1 }')
3173         local old_hwm=$(echo $wms | awk '{ print $2 }')
3174
3175         local blocks=$($LFS df $MOUNT | awk "/$ost_name/ { print \$4 }")
3176         # minimal extension size is 64M
3177         local new_lwm=50
3178         if (( $blocks / 1024 > 50 )); then
3179                 new_lwm=$((blocks / 1024 - 50))
3180         fi
3181         local new_hwm=$((new_lwm + 5))
3182
3183         ost_watermarks_set $ost_idx $new_lwm $new_hwm
3184         echo "watermarks: $old_lwm $old_hwm $new_lwm $new_hwm"
3185 }
3186
3187 # Set watermarks to ~current available space & then write data to fill it
3188 # Note OST is not *actually* full after this, it just reports ENOSPC in the
3189 # internal statfs used by the stripe allocator
3190 #
3191 # first parameter is the filename-prefix, which must get under t-f cleanup
3192 # requirements (rm -rf $DIR/[Rdfs][0-9]*), i.e. $tfile work fine
3193 ost_watermarks_set_enospc() {
3194         local filename=$1
3195         local ost_idx=$2
3196         # on the mdt's osc
3197         local ost_name=$(ostname_from_index $ost_idx)
3198         local facets=$(get_facets MDS)
3199         local wms
3200         local MDS
3201
3202         for MDS in ${facets//,/ }; do
3203                 local mdtosc_proc=$(get_mdtosc_proc_path $MDS $ost_name)
3204
3205                 do_facet $MDS $LCTL get_param -n \
3206                         osp.$mdtosc_proc.reserved_mb_high ||
3207                         skip  "remote MDS does not support reserved_mb_high"
3208         done
3209
3210         wms=$(ost_watermarks_set_low_space $ost_idx)
3211         local new_lwm=$(echo $wms | awk '{ print $4 }')
3212         fill_ost $filename $ost_idx $new_lwm
3213         #First enospc could execute orphan deletion so repeat
3214         fill_ost $filename $ost_idx $new_lwm
3215         echo $wms
3216 }
3217
3218 ost_watermarks_enospc_delete_files() {
3219         local filename=$1
3220         local ost_idx=$2
3221
3222         rm -f $DIR/${filename}.fill_ost$ost_idx
3223
3224         wait_delete_completed
3225         wait_mds_ost_sync
3226 }
3227
3228 # clean up from "ost_watermarks_set_enospc"
3229 ost_watermarks_clear_enospc() {
3230         local filename=$1
3231         local ost_idx=$2
3232         local old_lwm=$4
3233         local old_hwm=$5
3234
3235         ost_watermarks_enospc_delete_files $filename $ost_idx
3236         ost_watermarks_set $ost_idx $old_lwm $old_hwm
3237         echo "set OST$ost_idx lwm back to $old_lwm, hwm back to $old_hwm"
3238 }
3239
3240 wait_delete_completed_mds() {
3241         local max_wait=${1:-20}
3242         local mds2sync=""
3243         local stime=$(date +%s)
3244         local etime
3245         local node
3246         local changes
3247
3248         # find MDS with pending deletions
3249         for node in $(mdts_nodes); do
3250                 changes=$(do_node $node "$LCTL get_param -n osc.*MDT*.sync_*" \
3251                         2>/dev/null | calc_sum)
3252                 if [[ $changes -eq 0 ]]; then
3253                         continue
3254                 fi
3255                 mds2sync="$mds2sync $node"
3256         done
3257         if [ -z "$mds2sync" ]; then
3258                 wait_zfs_commit $SINGLEMDS
3259                 return 0
3260         fi
3261         mds2sync=$(comma_list $mds2sync)
3262
3263         # sync MDS transactions
3264         do_nodes $mds2sync "$LCTL set_param -n os[cd]*.*MD*.force_sync 1"
3265
3266         # wait till all changes are sent and commmitted by OSTs
3267         # for ldiskfs space is released upon execution, but DMU
3268         # do this upon commit
3269
3270         local WAIT=0
3271         while [[ $WAIT -ne $max_wait ]]; do
3272                 changes=$(do_nodes $mds2sync \
3273                         "$LCTL get_param -n osc.*MDT*.sync_*" | calc_sum)
3274                 #echo "$node: $changes changes on all"
3275                 if [[ $changes -eq 0 ]]; then
3276                         wait_zfs_commit $SINGLEMDS
3277
3278                         # the occupied disk space will be released
3279                         # only after TXGs are committed
3280              &