mirror of
https://git.proxmox.com/git/mirror_zfs.git
synced 2025-08-06 15:07:39 +03:00
fbe811b054
As found by git -C tests/ grep ^function | grep -vFe '.lua:' -e '.zcp:' | while IFS=":$IFS" read -r _ _ fn _; do [ $(git -C tests/ grep -wF $fn | head -2 | wc -l) -eq 1 ] && echo $fn; done after all rounds this comes out to, sorted: check_slog_state chgusr_exec cksum_files cleanup_pools compare_modes count_ACE dataset_set_defaultproperties ds_is_snapshot get_ACE get_group get_min get_mode get_owner get_rand_checksum get_rand_checksum_any get_rand_large_recsize get_rand_recsize get_user_group getitem indirect_vdev_mapping_size is_dilos log_noresult log_notinuse log_other log_timed_out log_uninitiated log_warning num_jobs_by_cpu plus_sign_check_l plus_sign_check_v record_cksum rwx_node seconds_mmp_waits_for_activity set_cur_usr setup_mirrors setup_raidzs showshares_smb zfs_zones_setup This, of course, doesn't catch recursive ones, or ones that log with their own function name as a prefix, but Reviewed-by: Brian Behlendorf <behlendorf1@llnl.gov> Reviewed-by: John Kennedy <john.kennedy@delphix.com> Reviewed-by: Ryan Moeller <ryan@iXsystems.com> Signed-off-by: Ahelenia Ziemiańska <nabijaczleweli@nabijaczleweli.xyz> Closes #13259
150 lines
3.3 KiB
Plaintext
150 lines
3.3 KiB
Plaintext
#
|
|
# CDDL HEADER START
|
|
#
|
|
# This file and its contents are supplied under the terms of the
|
|
# Common Development and Distribution License ("CDDL"), version 1.0.
|
|
# You may only use this file in accordance with the terms of version
|
|
# 1.0 of the CDDL.
|
|
#
|
|
# A full copy of the text of the CDDL should have accompanied this
|
|
# source. A copy of the CDDL is also available via the Internet at
|
|
# http://www.illumos.org/license/CDDL.
|
|
#
|
|
# CDDL HEADER END
|
|
#
|
|
|
|
#
|
|
# Copyright (c) 2014, 2017 by Delphix. All rights reserved.
|
|
#
|
|
|
|
export REMOVEDISK=${DISKS%% *}
|
|
export NOTREMOVEDISK=${DISKS##* }
|
|
|
|
#
|
|
# Waits for the pool to finish a removal.
|
|
#
|
|
function wait_for_removal # pool
|
|
{
|
|
typeset pool=$1
|
|
typeset callback=$2
|
|
|
|
log_must zpool wait -t remove $pool
|
|
|
|
#
|
|
# The pool state changes before the TXG finishes syncing; wait for
|
|
# the removal to be completed on disk.
|
|
#
|
|
sync_pool $pool
|
|
|
|
log_must is_pool_removed $pool
|
|
return 0
|
|
}
|
|
|
|
#
|
|
# Removes the specified disk from its respective pool and
|
|
# runs the callback while the removal is in progress.
|
|
#
|
|
# This function is mainly used to test how other operations
|
|
# interact with device removal. After the callback is done,
|
|
# the removal is unpaused and we wait for it to finish.
|
|
#
|
|
# Example usage:
|
|
#
|
|
# attempt_during_removal $TESTPOOL $DISK dd if=/dev/urandom \
|
|
# of=/$TESTPOOL/file count=1
|
|
#
|
|
function attempt_during_removal # pool disk callback [args]
|
|
{
|
|
typeset pool=$1
|
|
typeset disk=$2
|
|
typeset callback=$3
|
|
|
|
shift 3
|
|
log_onexit_push set_tunable32 REMOVAL_SUSPEND_PROGRESS 0
|
|
set_tunable32 REMOVAL_SUSPEND_PROGRESS 1
|
|
|
|
log_must zpool remove $pool $disk
|
|
|
|
#
|
|
# We want to make sure that the removal started
|
|
# before issuing the callback.
|
|
#
|
|
sync_pool $pool
|
|
log_must is_pool_removing $pool
|
|
|
|
log_must $callback "$@"
|
|
|
|
#
|
|
# Ensure that we still haven't finished the removal
|
|
# as expected.
|
|
#
|
|
log_must is_pool_removing $pool
|
|
|
|
set_tunable32 REMOVAL_SUSPEND_PROGRESS 0
|
|
log_onexit_pop
|
|
|
|
log_must wait_for_removal $pool
|
|
log_mustnot vdevs_in_pool $pool $disk
|
|
return 0
|
|
}
|
|
|
|
function random_write # file write_size
|
|
{
|
|
typeset file=$1
|
|
typeset block_size=$2
|
|
typeset file_size=$(stat_size $file 2>/dev/null)
|
|
typeset nblocks=$((file_size / block_size))
|
|
|
|
[[ -w $file ]] || return 1
|
|
|
|
dd if=/dev/urandom of=$file conv=notrunc \
|
|
bs=$block_size count=1 seek=$((RANDOM % nblocks)) >/dev/null 2>&1
|
|
}
|
|
|
|
function start_random_writer # file
|
|
{
|
|
typeset file=$1
|
|
(
|
|
log_note "Starting writer for $file"
|
|
# This will fail when we destroy the pool.
|
|
while random_write $file $((2**12)); do
|
|
:
|
|
done
|
|
log_note "Stopping writer for $file"
|
|
) &
|
|
}
|
|
|
|
function test_removal_with_operation # callback [args]
|
|
{
|
|
#
|
|
# To ensure that the removal takes a while, we fragment the pool
|
|
# by writing random blocks and continue to do during the removal.
|
|
#
|
|
log_must mkfile 1g $TESTDIR/$TESTFILE0
|
|
for i in $(seq $((2**10))); do
|
|
random_write $TESTDIR/$TESTFILE0 $((2**12)) || \
|
|
log_fail "Could not write to $TESTDIR/$TESTFILE0."
|
|
done
|
|
start_random_writer $TESTDIR/$TESTFILE0 1g
|
|
killpid=$!
|
|
|
|
log_must attempt_during_removal $TESTPOOL $REMOVEDISK "$@"
|
|
log_mustnot vdevs_in_pool $TESTPOOL $REMOVEDISK
|
|
log_must zdb -cd $TESTPOOL
|
|
|
|
kill $killpid
|
|
wait
|
|
|
|
verify_pool $TESTPOOL
|
|
}
|
|
|
|
#
|
|
# Kill the background job use by the test_removal_with_operation function.
|
|
#
|
|
function test_removal_with_operation_kill
|
|
{
|
|
kill $killpid
|
|
wait $killpid
|
|
return 0
|
|
}
|