# OSCs keep a NOSPC flag that will be reset after ~5s (qos_maxage)
# if the OST isn't full anymore.
reset_enospc() {
- local OSTIDX=${1:-""}
+ local ostidx=${1:-""}
+ local delay
+ local ready
+ local get_prealloc
local list=$(comma_list $(osts_nodes))
- [ "$OSTIDX" ] && list=$(facet_host ost$((OSTIDX + 1)))
+ [ "$ostidx" ] && list=$(facet_host ost$((ostidx + 1)))
do_nodes $list lctl set_param fail_loc=0
- sync # initiate all OST_DESTROYs from MDS to OST
- sleep_maxage
+ wait_delete_completed # initiate all OST_DESTROYs from MDS to OST
+ delay=$(do_facet $SINGLEMDS lctl get_param -n lov.*.qos_maxage |
+ awk '{print $1 * 2;exit;}')
+ get_prealloc="$LCTL get_param -n osc.*MDT*.prealloc_status |
+ grep -v \"^0$\""
+ wait_update_facet $SINGLEMDS "$get_prealloc" "" $delay
}
-exhaust_precreations() {
+__exhaust_precreations() {
local OSTIDX=$1
local FAILLOC=$2
local FAILIDX=${3:-$OSTIDX}
createmany -o $DIR/$tdir/${OST}/f $next_id $((last_id - next_id + 2))
do_facet $mfacet lctl get_param osp.$mdtosc_proc2.prealloc*
do_facet $ofacet lctl set_param fail_loc=$FAILLOC
+}
+
+exhaust_precreations() {
+ __exhaust_precreations $1 $2 $3
sleep_maxage
}
exhaust_all_precreations() {
local i
for (( i=0; i < OSTCOUNT; i++ )) ; do
- exhaust_precreations $i $1 -1
+ __exhaust_precreations $i $1 -1
done
+ sleep_maxage
}
test_27n() {
}
run_test 56r "check lfs find -size works"
-test_56ra() {
- [[ $MDS1_VERSION -gt $(version_code 2.12.58) ]] ||
- skip "MDS < 2.12.58 doesn't return LSOM data"
- local dir=$DIR/$tdir
-
- [[ $OSC == "mdc" ]] && skip "DoM files" && return
-
- setup_56 $dir $NUMFILES $NUMDIRS "-c 1"
+test_56ra_sub() {
+ local expected=$1
+ local glimpses=$2
+ local cmd="$3"
cancel_lru_locks $OSC
local rpcs_before=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- local expected=12
- local cmd="$LFS find -size 0 -type f -lazy $dir"
local nums=$($cmd | wc -l)
[ $nums -eq $expected ] ||
error "'$cmd' wrong: found $nums, expected $expected"
local rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- [ $rpcs_before -eq $rpcs_after ] ||
- error "'$cmd' should not send glimpse RPCs to OST"
- cmd="$LFS find -size 0 -type f $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- echo "Before: $rpcs_before After: $rpcs_after $NUMFILES"
- $LCTL get_param osc.*.stats
- [ $rpcs_after -eq $((rpcs_before + 12)) ] ||
- error "'$cmd' should send 12 glimpse RPCs to OST"
- cancel_lru_locks $OSC
- rpcs_before=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- expected=0
- cmd="$LFS find ! -size 0 -type f -lazy $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- $LCTL get_param mdc.*.stats
- [ $rpcs_before -eq $rpcs_after ] ||
- error "'$cmd' should not send glimpse RPCs to OST"
- cmd="$LFS find ! -size 0 -type f $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- echo "Before: $rpcs_before After: $rpcs_after $NUMFILES"
- [ $rpcs_after -eq $((rpcs_before + 12)) ] ||
- error "'$cmd' should send 12 glimpse RPCs to OST"
+ if (( rpcs_before + glimpses != rpcs_after )); then
+ echo "Before: $rpcs_before After: $rpcs_after $NUMFILES"
+ $LCTL get_param osc.*.stats | grep ldlm_glimpse_enqueue
- echo "test" > $dir/$tfile
- echo "test2" > $dir/$tfile.2 && sync
- cancel_lru_locks $OSC
- rpcs_before=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- expected=1
- cmd="$LFS find -size 5 -type f -lazy $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- [ $rpcs_before -eq $rpcs_after ] ||
- error "'$cmd' should not send glimpse RPCs to OST"
- cmd="$LFS find -size 5 -type f $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- echo "Before: $rpcs_before After: $rpcs_after $NUMFILES"
- [ $rpcs_after -eq $((rpcs_before + 14)) ] ||
- error "'$cmd' should send 14 glimpse RPCs to OST"
+ if [[ $glimpses == 0 ]]; then
+ error "'$cmd' should not send glimpse RPCs to OST"
+ else
+ error "'$cmd' should send $glimpses glimpse RPCs to OST"
+ fi
+ fi
+}
- cancel_lru_locks $OSC
- rpcs_before=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- expected=1
- cmd="$LFS find -size +5 -type f -lazy $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- [ $rpcs_before -eq $rpcs_after ] ||
- error "'$cmd' should not send glimpse RPCs to OST"
- cmd="$LFS find -size +5 -type f $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- echo "Before: $rpcs_before After: $rpcs_after $NUMFILES"
- [ $rpcs_after -eq $((rpcs_before + 14)) ] ||
- error "'$cmd' should send 14 glimpse RPCs to OST"
+test_56ra() {
+ [[ $MDS1_VERSION -gt $(version_code 2.12.58) ]] ||
+ skip "MDS < 2.12.58 doesn't return LSOM data"
+ local dir=$DIR/$tdir
- cancel_lru_locks $OSC
- rpcs_before=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- expected=2
- cmd="$LFS find -size +0 -type f -lazy $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- [ $rpcs_before -eq $rpcs_after ] ||
- error "'$cmd' should not send glimpse RPCs to OST"
- cmd="$LFS find -size +0 -type f $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- echo "Before: $rpcs_before After: $rpcs_after $NUMFILES"
- [ $rpcs_after -eq $((rpcs_before + 14)) ] ||
- error "'$cmd' should send 14 glimpse RPCs to OST"
+ [[ $OSC == "mdc" ]] && skip "DoM files" && return
+ setup_56 $dir $NUMFILES $NUMDIRS "-c 1"
+ # open and close all files to ensure LSOM is updated
cancel_lru_locks $OSC
- rpcs_before=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- expected=2
- cmd="$LFS find ! -size -5 -type f -lazy $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- [ $rpcs_before -eq $rpcs_after ] ||
- error "'$cmd' should not send glimpse RPCs to OST"
- cmd="$LFS find ! -size -5 -type f $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- echo "Before: $rpcs_before After: $rpcs_after $NUMFILES"
- [ $rpcs_after -eq $((rpcs_before + 14)) ] ||
- error "'$cmd' should send 14 glimpse RPCs to OST"
+ find $dir -type f | xargs cat > /dev/null
+ # expect_found glimpse_rpcs command_to_run
+ test_56ra_sub 12 0 "$LFS find -size 0 -type f -lazy $dir"
+ test_56ra_sub 12 12 "$LFS find -size 0 -type f $dir"
+ test_56ra_sub 0 0 "$LFS find ! -size 0 -type f -lazy $dir"
+ test_56ra_sub 0 12 "$LFS find ! -size 0 -type f $dir"
+
+ echo "test" > $dir/$tfile
+ echo "test2" > $dir/$tfile.2 && sync
cancel_lru_locks $OSC
- rpcs_before=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- expected=12
- cmd="$LFS find -size -5 -type f -lazy $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- [ $rpcs_before -eq $rpcs_after ] ||
- error "'$cmd' should not send glimpse RPCs to OST"
- cmd="$LFS find -size -5 -type f $dir"
- nums=$($cmd | wc -l)
- [ $nums -eq $expected ] ||
- error "'$cmd' wrong: found $nums, expected $expected"
- rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
- echo "Before: $rpcs_before After: $rpcs_after $NUMFILES"
- [ $rpcs_after -eq $((rpcs_before + 14)) ] ||
- error "'$cmd' should send 14 glimpse RPCs to OST"
+ cat $dir/$tfile $dir/$tfile.2 > /dev/null
+
+ test_56ra_sub 1 0 "$LFS find -size 5 -type f -lazy $dir"
+ test_56ra_sub 1 14 "$LFS find -size 5 -type f $dir"
+ test_56ra_sub 1 0 "$LFS find -size +5 -type f -lazy $dir"
+ test_56ra_sub 1 14 "$LFS find -size +5 -type f $dir"
+
+ test_56ra_sub 2 0 "$LFS find -size +0 -type f -lazy $dir"
+ test_56ra_sub 2 14 "$LFS find -size +0 -type f $dir"
+ test_56ra_sub 2 0 "$LFS find ! -size -5 -type f -lazy $dir"
+ test_56ra_sub 2 14 "$LFS find ! -size -5 -type f $dir"
+ test_56ra_sub 12 0 "$LFS find -size -5 -type f -lazy $dir"
+ test_56ra_sub 12 14 "$LFS find -size -5 -type f $dir"
}
run_test 56ra "check lfs find -size -lazy works for data on OSTs"
}
run_test 56wd "check lfs_migrate --rsync and --no-rsync work"
+test_56we() {
+ local td=$DIR/$tdir
+ local tf=$td/$tfile
+
+ test_mkdir $td || error "cannot create $td"
+ touch $tf || error "cannot touch $tf"
+
+ echo -n "Make sure --non-direct|-D works..."
+ $LFS_MIGRATE -y --non-direct -v $tf 2>&1 |
+ grep -q "lfs migrate --non-direct" ||
+ error "--non-direct option cannot work correctly"
+ $LFS_MIGRATE -y -D -v $tf 2>&1 |
+ grep -q "lfs migrate -D" ||
+ error "-D option cannot work correctly"
+ echo "done."
+}
+run_test 56we "check lfs_migrate --non-direct|-D support"
+
test_56x() {
[[ $OSTCOUNT -lt 2 ]] && skip_env "needs >= 2 OSTs"
check_swap_layouts_support
}
run_test 121 "read cancel race ========="
-test_123a() { # was test 123, statahead(bug 11401)
- [ $PARALLEL == "yes" ] && skip "skip parallel run"
+test_123a_base() { # was test 123, statahead(bug 11401)
+ local lsx="$1"
SLOWOK=0
if ! grep -q "processor.*: 1" /proc/cpuinfo; then
test_mkdir $DIR/$tdir
NUMFREE=$(df -i -P $DIR | tail -n 1 | awk '{ print $4 }')
[[ $NUMFREE -gt 100000 ]] && NUMFREE=100000 || NUMFREE=$((NUMFREE-1000))
- MULT=10
- for ((i=100, j=0; i<=$NUMFREE; j=$i, i=$((i * MULT)) )); do
- createmany -o $DIR/$tdir/$tfile $j $((i - j))
-
- max=`lctl get_param -n llite.*.statahead_max | head -n 1`
- lctl set_param -n llite.*.statahead_max 0
- lctl get_param llite.*.statahead_max
- cancel_lru_locks mdc
- cancel_lru_locks osc
- stime=`date +%s`
- time ls -l $DIR/$tdir | wc -l
- etime=`date +%s`
- delta=$((etime - stime))
- log "ls $i files without statahead: $delta sec"
- lctl set_param llite.*.statahead_max=$max
-
- swrong=`lctl get_param -n llite.*.statahead_stats | grep "statahead wrong:" | awk '{print $3}'`
- lctl get_param -n llite.*.statahead_max | grep '[0-9]'
- cancel_lru_locks mdc
- cancel_lru_locks osc
- stime=`date +%s`
- time ls -l $DIR/$tdir | wc -l
- etime=`date +%s`
- delta_sa=$((etime - stime))
- log "ls $i files with statahead: $delta_sa sec"
- lctl get_param -n llite.*.statahead_stats
- ewrong=`lctl get_param -n llite.*.statahead_stats | grep "statahead wrong:" | awk '{print $3}'`
+ MULT=10
+ for ((i=100, j=0; i<=$NUMFREE; j=$i, i=$((i * MULT)) )); do
+ createmany -o $DIR/$tdir/$tfile $j $((i - j))
+
+ max=$(lctl get_param -n llite.*.statahead_max | head -n 1)
+ lctl set_param -n llite.*.statahead_max 0
+ lctl get_param llite.*.statahead_max
+ cancel_lru_locks mdc
+ cancel_lru_locks osc
+ stime=$(date +%s)
+ time $lsx $DIR/$tdir | wc -l
+ etime=$(date +%s)
+ delta=$((etime - stime))
+ log "$lsx $i files without statahead: $delta sec"
+ lctl set_param llite.*.statahead_max=$max
+
+ swrong=$(lctl get_param -n llite.*.statahead_stats |
+ grep "statahead wrong:" | awk '{print $3}')
+ lctl get_param -n llite.*.statahead_max | grep '[0-9]'
+ cancel_lru_locks mdc
+ cancel_lru_locks osc
+ stime=$(date +%s)
+ time $lsx $DIR/$tdir | wc -l
+ etime=$(date +%s)
+ delta_sa=$((etime - stime))
+ log "$lsx $i files with statahead: $delta_sa sec"
+ lctl get_param -n llite.*.statahead_stats
+ ewrong=$(lctl get_param -n llite.*.statahead_stats |
+ grep "statahead wrong:" | awk '{print $3}')
[[ $swrong -lt $ewrong ]] &&
log "statahead was stopped, maybe too many locks held!"
[[ $delta -eq 0 || $delta_sa -eq 0 ]] && continue
- if [ $((delta_sa * 100)) -gt $((delta * 105)) -a $delta_sa -gt $((delta + 2)) ]; then
- max=`lctl get_param -n llite.*.statahead_max | head -n 1`
- lctl set_param -n llite.*.statahead_max 0
- lctl get_param llite.*.statahead_max
- cancel_lru_locks mdc
- cancel_lru_locks osc
- stime=`date +%s`
- time ls -l $DIR/$tdir | wc -l
- etime=`date +%s`
- delta=$((etime - stime))
- log "ls $i files again without statahead: $delta sec"
- lctl set_param llite.*.statahead_max=$max
- if [ $((delta_sa * 100)) -gt $((delta * 105)) -a $delta_sa -gt $((delta + 2)) ]; then
- if [ $SLOWOK -eq 0 ]; then
- error "ls $i files is slower with statahead!"
- else
- log "ls $i files is slower with statahead!"
- fi
- break
- fi
- fi
+ if [ $((delta_sa * 100)) -gt $((delta * 105)) -a $delta_sa -gt $((delta + 2)) ]; then
+ max=$(lctl get_param -n llite.*.statahead_max |
+ head -n 1)
+ lctl set_param -n llite.*.statahead_max 0
+ lctl get_param llite.*.statahead_max
+ cancel_lru_locks mdc
+ cancel_lru_locks osc
+ stime=$(date +%s)
+ time $lsx $DIR/$tdir | wc -l
+ etime=$(date +%s)
+ delta=$((etime - stime))
+ log "$lsx $i files again without statahead: $delta sec"
+ lctl set_param llite.*.statahead_max=$max
+ if [ $((delta_sa * 100 > delta * 105 && delta_sa > delta + 2)) ]; then
+ if [ $SLOWOK -eq 0 ]; then
+ error "$lsx $i files is slower with statahead!"
+ else
+ log "$lsx $i files is slower with statahead!"
+ fi
+ break
+ fi
+ fi
- [ $delta -gt 20 ] && break
- [ $delta -gt 8 ] && MULT=$((50 / delta))
- [ "$SLOW" = "no" -a $delta -gt 5 ] && break
- done
- log "ls done"
+ [ $delta -gt 20 ] && break
+ [ $delta -gt 8 ] && MULT=$((50 / delta))
+ [ "$SLOW" = "no" -a $delta -gt 5 ] && break
+ done
+ log "$lsx done"
- stime=`date +%s`
- rm -r $DIR/$tdir
- sync
- etime=`date +%s`
- delta=$((etime - stime))
- log "rm -r $DIR/$tdir/: $delta seconds"
- log "rm done"
- lctl get_param -n llite.*.statahead_stats
+ stime=$(date +%s)
+ rm -r $DIR/$tdir
+ sync
+ etime=$(date +%s)
+ delta=$((etime - stime))
+ log "rm -r $DIR/$tdir/: $delta seconds"
+ log "rm done"
+ lctl get_param -n llite.*.statahead_stats
}
-run_test 123a "verify statahead work"
+
+test_123aa() {
+ [ $PARALLEL == "yes" ] && skip "skip parallel run"
+
+ test_123a_base "ls -l"
+}
+run_test 123aa "verify statahead work"
+
+test_123ab() {
+ [ $PARALLEL == "yes" ] && skip "skip parallel run"
+
+ statx_supported || skip_env "Test must be statx() syscall supported"
+
+ test_123a_base "$STATX -l"
+}
+run_test 123ab "verify statahead work by using statx"
+
+test_123ac() {
+ [ $PARALLEL == "yes" ] && skip "skip parallel run"
+
+ statx_supported || skip_env "Test must be statx() syscall supported"
+
+ local rpcs_before
+ local rpcs_after
+ local agl_before
+ local agl_after
+
+ cancel_lru_locks $OSC
+ rpcs_before=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
+ agl_before=$($LCTL get_param -n llite.*.statahead_stats |
+ awk '/agl.total:/ {print $3}')
+ test_123a_base "$STATX -c \"%n %i %A %h %u %g %W %X %Z\" -D"
+ test_123a_base "$STATX --cached=always -D"
+ agl_after=$($LCTL get_param -n llite.*.statahead_stats |
+ awk '/agl.total:/ {print $3}')
+ [ $agl_before -eq $agl_after ] ||
+ error "Should not trigger AGL thread - $agl_before:$agl_after"
+ rpcs_after=$(calc_stats $OSC.*$OSC*.stats ldlm_glimpse_enqueue)
+ [ $rpcs_after -eq $rpcs_before ] ||
+ error "$STATX should not send glimpse RPCs to $OSC"
+}
+run_test 123ac "verify statahead work by using statx without glimpse RPCs"
test_123b () { # statahead(bug 15027)
[ $PARALLEL == "yes" ] && skip "skip parallel run"
skip "Need MDS version at least 2.9.54"
local facet
-
for facet in client mds1 ost1; do
# Get the list of files that are missing the terminating newline
- #local missing=($(do_facet $facet \
local plist=$(do_facet $facet
$LCTL list_param -FR '*' | grep '=' | tr -d =)
local ent
awk -v FS='\v' -v RS='\v\v' \
"'END { if(NR>0 && \\\$NF !~ /.*\\\n\$/) \
print FILENAME}'" 2>/dev/null)
- [ -z $missing ] ||
- error "files do not end with newline: $missing"
+ [ -z $missing ] || {
+ do_facet $facet $LCTL get_param $ent | od -An -tx1
+ error "file does not end with newline: $facet-$ent"
+ }
done
done
}
}
run_test 205a "Verify job stats"
-# LU-13117
+# LU-13117, LU-13597
test_205b() {
+ job_stats="mdt.*.job_stats"
+ $LCTL set_param $job_stats=clear
$LCTL set_param jobid_var=USER jobid_name="%e.%u"
env -i USERTESTJOBSTATS=foolish touch $DIR/$tfile.1
- do_facet $SINGLEMDS $LCTL get_param mdt.*.job_stats |
- grep job_id: | grep foolish &&
+ do_facet $SINGLEMDS $LCTL get_param $job_stats |
+ grep "job_id:.*foolish" &&
error "Unexpected jobid found"
- true
+ do_facet $SINGLEMDS $LCTL get_param $job_stats |
+ grep "open:.*min.*max.*sum" ||
+ error "wrong job_stats format found"
}
-run_test 205b "Verify job stats jobid parsing"
+run_test 205b "Verify job stats jobid and output format"
# LU-1480, LU-1773 and LU-1657
test_206() {
}
run_test 209 "read-only open/close requests should be freed promptly"
+test_210() {
+ local pid
+
+ $MULTIOP $DIR/$tfile oO_CREAT:O_RDWR:eW_E+eUc &
+ pid=$!
+ sleep 1
+
+ $LFS getstripe $DIR/$tfile
+ kill -USR1 $pid
+ wait $pid || error "multiop failed"
+
+ $MULTIOP $DIR/$tfile oO_RDONLY:eR_E+eUc &
+ pid=$!
+ sleep 1
+
+ $LFS getstripe $DIR/$tfile
+ kill -USR1 $pid
+ wait $pid || error "multiop failed"
+}
+run_test 210 "lfs getstripe does not break leases"
+
test_212() {
size=`date +%s`
size=$((size % 8192 + 1))
test_230j() {
[ $MDSCOUNT -lt 2 ] && skip "needs >= 2 MDTs"
- [ $MDS1_VERSION -lt $(version_code 2.11.52) ] &&
+ [ $MDS1_VERSION -lt $(version_code 2.13.52) ] &&
skip "Need MDS version at least 2.11.52"
$LFS mkdir -m 0 -c 1 $DIR/$tdir || error "mkdir $tdir failed"
error "create $tfile failed"
cat /etc/passwd > $DIR/$tdir/$tfile
- $LFS migrate -m 1 $DIR/$tdir
+ $LFS migrate -m 1 $DIR/$tdir || error "migrate failed"
cmp /etc/passwd $DIR/$tdir/$tfile ||
error "DoM file mismatch after migration"
}
run_test 230n "Dir migration with mirrored file"
+test_230o() {
+ [ $MDSCOUNT -ge 2 ] || skip "needs >= 2 MDTs"
+ [ $MDS1_VERSION -ge $(version_code 2.13.52) ] ||
+ skip "Need MDS version at least 2.13.52"
+
+ local mdts=$(comma_list $(mdts_nodes))
+
+ local restripe_status
+ local delta
+ local i
+ local j
+
+ # in case "crush" hash type is not set
+ do_nodes $mdts "$LCTL set_param lod.*.mdt_hash=crush"
+
+ restripe_status=$(do_facet mds1 $LCTL get_param -n \
+ mdt.*MDT0000.enable_dir_restripe)
+ do_nodes $mdts "$LCTL set_param mdt.*.enable_dir_restripe=1"
+ stack_trap "do_nodes $mdts $LCTL set_param \
+ mdt.*.enable_dir_restripe=$restripe_status"
+
+ mkdir $DIR/$tdir
+ createmany -m $DIR/$tdir/f 100 ||
+ error "create files under remote dir failed $i"
+ createmany -d $DIR/$tdir/d 100 ||
+ error "create dirs under remote dir failed $i"
+
+ for i in $(seq 2 $MDSCOUNT); do
+ do_nodes $mdts "$LCTL set_param mdt.*.md_stats=clear > /dev/null"
+ $LFS setdirstripe -c $i $DIR/$tdir ||
+ error "split -c $i $tdir failed"
+ wait_update $HOSTNAME \
+ "$LFS getdirstripe -H $DIR/$tdir" "crush" 100 ||
+ error "dir split not finished"
+ delta=$(do_nodes $mdts "lctl get_param -n mdt.*MDT*.md_stats" |
+ awk '/migrate/ {sum += $2} END { print sum }')
+ echo "$delta files migrated when dir split from $((i - 1)) to $i stripes"
+ # delta is around total_files/stripe_count
+ [ $delta -lt $((200 /(i - 1))) ] ||
+ error "$delta files migrated"
+ done
+}
+run_test 230o "dir split"
+
+test_230p() {
+ [ $MDSCOUNT -ge 2 ] || skip "needs >= 2 MDTs"
+ [ $MDS1_VERSION -ge $(version_code 2.13.52) ] ||
+ skip "Need MDS version at least 2.13.52"
+
+ local mdts=$(comma_list $(mdts_nodes))
+
+ local restripe_status
+ local delta
+ local i
+ local j
+
+ do_nodes $mdts "$LCTL set_param lod.*.mdt_hash=crush"
+
+ restripe_status=$(do_facet mds1 $LCTL get_param -n \
+ mdt.*MDT0000.enable_dir_restripe)
+ do_nodes $mdts "$LCTL set_param mdt.*.enable_dir_restripe=1"
+ stack_trap "do_nodes $mdts $LCTL set_param \
+ mdt.*.enable_dir_restripe=$restripe_status"
+
+ test_mkdir -c $MDSCOUNT -H crush $DIR/$tdir
+ createmany -m $DIR/$tdir/f 100 ||
+ error "create files under remote dir failed $i"
+ createmany -d $DIR/$tdir/d 100 ||
+ error "create dirs under remote dir failed $i"
+
+ for i in $(seq $((MDSCOUNT - 1)) -1 1); do
+ local mdt_hash="crush"
+
+ do_nodes $mdts "$LCTL set_param mdt.*.md_stats=clear > /dev/null"
+ $LFS setdirstripe -c $i $DIR/$tdir ||
+ error "split -c $i $tdir failed"
+ [ $i -eq 1 ] && mdt_hash="none"
+ wait_update $HOSTNAME \
+ "$LFS getdirstripe -H $DIR/$tdir" $mdt_hash 100 ||
+ error "dir merge not finished"
+ delta=$(do_nodes $mdts "lctl get_param -n mdt.*MDT*.md_stats" |
+ awk '/migrate/ {sum += $2} END { print sum }')
+ echo "$delta files migrated when dir merge from $((i + 1)) to $i stripes"
+ # delta is around total_files/stripe_count
+ [ $delta -lt $((200 / i)) ] ||
+ error "$delta files migrated"
+ done
+}
+run_test 230p "dir merge"
+
+test_230q() {
+ [ $MDSCOUNT -ge 2 ] || skip "needs >= 2 MDTs"
+ [ $MDS1_VERSION -ge $(version_code 2.13.52) ] ||
+ skip "Need MDS version at least 2.13.52"
+
+ local mdts=$(comma_list $(mdts_nodes))
+ local saved_threshold=$(do_facet mds1 \
+ $LCTL get_param -n mdt.*-MDT0000.dir_split_count)
+ local saved_delta=$(do_facet mds1 \
+ $LCTL get_param -n mdt.*-MDT0000.dir_split_delta)
+ local threshold=100
+ local delta=2
+ local total=0
+ local stripe_count=0
+ local stripe_index
+ local nr_files
+
+ stack_trap "do_nodes $mdts $LCTL set_param \
+ mdt.*.dir_split_count=$saved_threshold"
+ stack_trap "do_nodes $mdts $LCTL set_param \
+ mdt.*.dir_split_delta=$saved_delta"
+ stack_trap "do_nodes $mdts $LCTL set_param mdt.*.dir_restripe_nsonly=1"
+ do_nodes $mdts "$LCTL set_param mdt.*.enable_dir_auto_split=1"
+ do_nodes $mdts "$LCTL set_param mdt.*.dir_split_count=$threshold"
+ do_nodes $mdts "$LCTL set_param mdt.*.dir_split_delta=$delta"
+ do_nodes $mdts "$LCTL set_param mdt.*.dir_restripe_nsonly=0"
+ do_nodes $mdts "$LCTL set_param lod.*.mdt_hash=crush"
+
+ $LFS mkdir -i -1 -c 1 $DIR/$tdir || error "mkdir $tdir failed"
+ stripe_index=$($LFS getdirstripe -i $DIR/$tdir)
+
+ while [ $stripe_count -lt $MDSCOUNT ]; do
+ createmany -m $DIR/$tdir/f $total $((threshold * 3 / 2)) ||
+ error "create sub files failed"
+ stat $DIR/$tdir > /dev/null
+ total=$((total + threshold * 3 / 2))
+ stripe_count=$((stripe_count + delta))
+ [ $stripe_count -gt $MDSCOUNT ] && stripe_count=$MDSCOUNT
+
+ wait_update $HOSTNAME \
+ "$LFS getdirstripe -c $DIR/$tdir" "$stripe_count" 40 ||
+ error "stripe count $($LFS getdirstripe -c $DIR/$tdir) != $stripe_count"
+
+ wait_update $HOSTNAME \
+ "$LFS getdirstripe -H $DIR/$tdir" "crush" 200 ||
+ error "stripe hash $($LFS getdirstripe -H $DIR/$tdir) != crush"
+
+ nr_files=$($LFS getstripe -m $DIR/$tdir/* |
+ grep -w $stripe_index | wc -l)
+ echo "$nr_files files on MDT$stripe_index after split"
+ [ $nr_files -lt $((total / (stripe_count - 1))) ] ||
+ error "$nr_files files on MDT$stripe_index after split"
+
+ nr_files=$(ls $DIR/$tdir | wc -w)
+ [ $nr_files -eq $total ] ||
+ error "total sub files $nr_files != $total"
+ done
+}
+run_test 230q "dir auto split"
+
test_231a()
{
# For simplicity this test assumes that max_pages_per_rpc
}
run_test 270g "DoM: default DoM stripe size depends on free space"
+test_270h() {
+ [[ $MDS1_VERSION -ge $(version_code 2.13.53) ]] ||
+ skip "Need MDS version at least 2.13.53"
+
+ local mdtname=${FSNAME}-MDT0000-mdtlov
+ local dom=$DIR/$tdir/$tfile
+ local save="$TMP/$TESTSUITE-$TESTNAME.parameters"
+
+ save_lustre_params mds1 "lod.*.dom_stripesize" > $save
+ stack_trap "restore_lustre_params < $save; rm -f $save" EXIT
+
+ $LFS mkdir -i 0 -c 1 $DIR/$tdir
+ $LFS setstripe -E 1M -c1 -E -1 -c2 ${dom}_1 ||
+ error "can't create OST file"
+ # mirrored file with DOM entry in the second mirror
+ $LFS mirror extend -N -E 1M -L mdt -E eof -c2 ${dom}_1 ||
+ error "can't create mirror with DoM component"
+
+ do_facet mds1 $LCTL set_param -n lod.$mdtname.dom_stripesize=0
+
+ # DOM component in the middle and has other enries in the same mirror,
+ # should succeed but lost DoM component
+ $LFS setstripe --copy=${dom}_1 $dom ||
+ error "Can't create file from OST|DOM mirror layout"
+ # check new file has no DoM layout after all
+ [[ $($LFS getstripe -L $dom) != "mdt" ]] ||
+ error "File has DoM component while DoM is disabled"
+}
+run_test 270h "DoM: DoM stripe removal when disabled on server"
+
test_271a() {
[ $MDS1_VERSION -lt $(version_code 2.10.55) ] &&
skip "Need MDS version at least 2.10.55"
}
run_test 423 "statfs should return a right data"
+test_424() {
+#define OBD_FAIL_PTLRPC_BULK_REPLY_ATTACH 0x522 | OBD_FAIL_ONCE
+ $LCTL set_param fail_loc=0x80000522
+ dd if=/dev/zero of=$DIR/$tfile bs=2M count=1 oflag=sync
+ rm -f $DIR/$tfile
+}
+run_test 424 "simulate ENOMEM in ptl_send_rpc bulk reply ME attach"
+
prep_801() {
[[ $MDS1_VERSION -lt $(version_code 2.9.55) ]] ||
[[ $OST1_VERSION -lt $(version_code 2.9.55) ]] &&
git://git.whamcloud.com / fs / lustre-release.git / blobdiff