#
#  Copyright (c) 2014 Spectra Logic Corporation
#  All rights reserved.
#
#  Redistribution and use in source and binary forms, with or without
#  modification, are permitted provided that the following conditions
#  are met:
#  1. Redistributions of source code must retain the above copyright
#     notice, this list of conditions, and the following disclaimer,
#     without modification.
#  2. Redistributions in binary form must reproduce at minimum a disclaimer
#     substantially similar to the "NO WARRANTY" disclaimer below
#     ("Disclaimer") and any redistribution must be conditioned upon
#     including a substantially similar Disclaimer requirement for further
#     binary redistribution.
#
#  NO WARRANTY
#  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
#  "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
#  LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR
#  A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
#  HOLDERS OR CONTRIBUTORS BE LIABLE FOR SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
#  DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
#  OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
#  HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
#  STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
#  IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
#  POSSIBILITY OF SUCH DAMAGES.
#
#  Authors: Alan Somers         (Spectra Logic Corporation)
#

# Outline:
# For each cloned interface type, do three tests
# 1) Create and destroy it
# 2) Create, up, and destroy it
# 3) Create, disable IPv6 auto address assignment, up, and destroy it

TESTLEN=10	# seconds

atf_test_case epair_stress cleanup
epair_stress_head()
{
	atf_set "descr" "Simultaneously create and destroy an epair(4)"
	atf_set "require.user" "root"
}
epair_stress_body()
{
	do_stress "epair"
}
epair_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case epair_up_stress cleanup
epair_up_stress_head()
{
	atf_set "descr" "Simultaneously up and detroy an epair(4)"
	atf_set "require.user" "root"
}
epair_up_stress_body()
{
	do_up_stress "epair" "" ""
}
epair_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case epair_destroy_race cleanup
epair_destroy_race_head()
{
	atf_set "descr" "Race if_detach() and if_vmove()"
	atf_set "require.user" "root"
}
epair_destroy_race_body()
{
	for i in `seq 1 10`
	do
		epair_a=$(ifconfig epair create)
		echo $epair_a >> devices_to_cleanup
		epair_b=${epair_a%a}b

		jail -c vnet name="epair_destroy" nopersist path=/ \
		  host.hostname="epair_destroy" vnet.interface="$epair_b" \
		  command=sh -c "ifconfig $epair_b 192.0.2.1/24; sleep 0.1"&
		pid=$!
		ifconfig "$epair_a" destroy
		wait $pid
	done
	true
}
epair_destroy_race_cleanup()
{
	cleanup_ifaces
}

atf_test_case epair_ipv6_up_stress cleanup
epair_ipv6_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy an epair(4) with IPv6"
	atf_set "require.user" "root"
}
epair_ipv6_up_stress_body()
{
	do_up_stress "epair" "6" ""
}
epair_ipv6_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case faith_stress cleanup
faith_stress_head()
{
	atf_set "descr" "Simultaneously create and destroy a faith(4)"
	atf_set "require.user" "root"
}
faith_stress_body()
{
	do_stress "faith"
}
faith_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case faith_up_stress cleanup
faith_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a faith(4)"
	atf_set "require.user" "root"
}
faith_up_stress_body()
{
	do_up_stress "faith" "" ""
}
faith_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case faith_ipv6_up_stress cleanup
faith_ipv6_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a faith(4) with IPv6"
	atf_set "require.user" "root"
}
faith_ipv6_up_stress_body()
{
	do_up_stress "faith" "6" ""
}
faith_ipv6_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case gif_stress cleanup
gif_stress_head()
{
	atf_set "descr" "Simultaneously create and destroy a gif(4)"
	atf_set "require.user" "root"
}
gif_stress_body()
{
	do_stress "gif"
}
gif_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case gif_up_stress cleanup
gif_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a gif(4)"
	atf_set "require.user" "root"
}
gif_up_stress_body()
{
	do_up_stress "gif" "" "p2p"
}
gif_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case gif_ipv6_up_stress cleanup
gif_ipv6_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a gif(4) with IPv6"
	atf_set "require.user" "root"
}
gif_ipv6_up_stress_body()
{
	do_up_stress "gif" "6" "p2p"
}
gif_ipv6_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case lo_stress cleanup
lo_stress_head()
{
	atf_set "descr" "Simultaneously create and destroy an lo(4)"
	atf_set "require.user" "root"
}
lo_stress_body()
{
	do_stress "lo"
}
lo_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case lo_up_stress cleanup
lo_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy an lo(4)"
	atf_set "require.user" "root"
}
lo_up_stress_body()
{
	do_up_stress "lo" "" ""
}
lo_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case lo_ipv6_up_stress cleanup
lo_ipv6_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy an lo(4) with IPv6"
	atf_set "require.user" "root"
}
lo_ipv6_up_stress_body()
{
	do_up_stress "lo" "6" ""
}
lo_ipv6_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case tap_stress cleanup
tap_stress_head()
{
	atf_set "descr" "Simultaneously create and destroy a tap(4)"
	atf_set "require.user" "root"
}
tap_stress_body()
{
	do_stress "tap"
}
tap_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case tap_up_stress cleanup
tap_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a tap(4)"
	atf_set "require.user" "root"
}
tap_up_stress_body()
{
	do_up_stress "tap" "" ""
}
tap_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case tap_ipv6_up_stress cleanup
tap_ipv6_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a tap(4) with IPv6"
	atf_set "require.user" "root"
}
tap_ipv6_up_stress_body()
{
	do_up_stress "tap" "6" ""
}
tap_ipv6_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case tun_stress cleanup
tun_stress_head()
{
	atf_set "descr" "Simultaneously create and destroy a tun(4)"
	atf_set "require.user" "root"
}
tun_stress_body()
{
	do_stress "tun"
}
tun_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case tun_up_stress cleanup
tun_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a tun(4)"
	atf_set "require.user" "root"
}
tun_up_stress_body()
{
	do_up_stress "tun" "" "p2p"
}
tun_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case tun_ipv6_up_stress cleanup
tun_ipv6_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a tun(4) with IPv6"
	atf_set "require.user" "root"
}
tun_ipv6_up_stress_body()
{
	do_up_stress "tun" "6" "p2p"
}
tun_ipv6_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case vlan_stress cleanup
vlan_stress_head()
{
	atf_set "descr" "Simultaneously create and destroy a vlan(4)"
	atf_set "require.user" "root"
}
vlan_stress_body()
{
	do_stress "vlan"
}
vlan_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case vlan_up_stress cleanup
vlan_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a vlan(4)"
	atf_set "require.user" "root"
}
vlan_up_stress_body()
{
	do_up_stress "vlan" "" ""
}
vlan_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case vlan_ipv6_up_stress cleanup
vlan_ipv6_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a vlan(4) with IPv6"
	atf_set "require.user" "root"
}
vlan_ipv6_up_stress_body()
{
	do_up_stress "vlan" "6" ""
}
vlan_ipv6_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case vmnet_stress cleanup
vmnet_stress_head()
{
	atf_set "descr" "Simultaneously create and destroy a vmnet(4)"
	atf_set "require.user" "root"
}
vmnet_stress_body()
{
	do_stress "vmnet"
}
vmnet_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case vmnet_up_stress cleanup
vmnet_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a vmnet(4)"
	atf_set "require.user" "root"
}
vmnet_up_stress_body()
{
	do_up_stress "vmnet" "" ""
}
vmnet_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_test_case vmnet_ipv6_up_stress cleanup
vmnet_ipv6_up_stress_head()
{
	atf_set "descr" "Simultaneously up and destroy a vmnet(4) with IPv6"
	atf_set "require.user" "root"
}
vmnet_ipv6_up_stress_body()
{
	do_up_stress "vmnet" "6" ""
}
vmnet_ipv6_up_stress_cleanup()
{
	cleanup_ifaces
}

atf_init_test_cases()
{
	atf_add_test_case epair_ipv6_up_stress
	atf_add_test_case epair_stress
	atf_add_test_case epair_up_stress
	atf_add_test_case epair_destroy_race
	atf_add_test_case faith_ipv6_up_stress
	atf_add_test_case faith_stress
	atf_add_test_case faith_up_stress
	atf_add_test_case gif_ipv6_up_stress
	atf_add_test_case gif_stress
	atf_add_test_case gif_up_stress
	# Don't test lagg; it has its own test program
	atf_add_test_case lo_ipv6_up_stress
	atf_add_test_case lo_stress
	atf_add_test_case lo_up_stress
	atf_add_test_case tap_ipv6_up_stress
	atf_add_test_case tap_stress
	atf_add_test_case tap_up_stress
	atf_add_test_case tun_ipv6_up_stress
	atf_add_test_case tun_stress
	atf_add_test_case tun_up_stress
	atf_add_test_case vlan_ipv6_up_stress
	atf_add_test_case vlan_stress
	atf_add_test_case vlan_up_stress
	atf_add_test_case vmnet_ipv6_up_stress
	atf_add_test_case vmnet_stress
	atf_add_test_case vmnet_up_stress
}

do_stress()
{
	local IFACE CREATOR_PID DESTROYER_PID

	IFACE=`get_iface $1`

	# First thread: create the interface
	while true; do
		ifconfig ${IFACE%a} create 2>/dev/null && \
			echo -n . >> creator_count.txt
	done &
	CREATOR_PID=$!

	# Second thread: destroy the lagg
	while true; do
		ifconfig $IFACE destroy 2>/dev/null && \
			echo -n . >> destroyer_count.txt
	done &
	DESTROYER_PID=$!

	sleep ${TESTLEN}
	kill $CREATOR_PID
	kill $DESTROYER_PID
	echo "Created ${IFACE%a} `stat -f %z creator_count.txt` times."
	echo "Destroyed it `stat -f %z destroyer_count.txt` times."
}

# Implement the up stress tests
# Parameters
# $1	Interface class, etc "lo" or "tap"
# $2	"6" to enable IPv6 auto address assignment, anything else otherwise
# $3	p2p for point to point interfaces, anything else for normal interfaces
do_up_stress()
{
	local ADDR DSTADDR MASK MEAN_SLEEP_SECONDS MAX_SLEEP_USECS \
	    IFACE IPV6 P2P SRCDIR LOOP_PID ipv6_cmd up_cmd

	# Configure the interface to use an RFC5737 nonrouteable addresses
	ADDR="192.0.2.2"
	DSTADDR="192.0.2.3"
	MASK="24"
	# ifconfig takes about 10ms to run.  To increase race coverage,
	# randomly delay the two commands relative to each other by 5ms either
	# way.
	MEAN_SLEEP_SECONDS=.005
	MAX_SLEEP_USECS=10000

	IFACE=`get_iface $1`
	IPV6=$2
	P2P=$3

	SRCDIR=$( atf_get_srcdir )
	if [ "$IPV6" = 6 ]; then
		ipv6_cmd="true"
	else
		ipv6_cmd="ifconfig $IFACE inet6 ifdisabled"
	fi
	if [ "$P2P" = "p2p" ]; then
		up_cmd="ifconfig $IFACE up ${ADDR}/${MASK} ${DSTADDR}"
	else
		up_cmd="ifconfig $IFACE up ${ADDR}/${MASK}"
	fi
	while true; do
		eval "$ipv6_cmd"
		{ sleep ${MEAN_SLEEP_SECONDS} && \
			eval "$up_cmd" 2> /dev/null &&
			echo -n . >> up_count.txt ; } &
		{ ${SRCDIR}/randsleep ${MAX_SLEEP_USECS} && \
			ifconfig $IFACE destroy &&
			echo -n . >> destroy_count.txt ; } &
		wait
		ifconfig ${IFACE%a} create
	done &
	LOOP_PID=$!

	sleep ${TESTLEN}
	kill $LOOP_PID
	echo "Upped ${IFACE} `stat -f %z up_count.txt` times."
	echo "Destroyed it `stat -f %z destroy_count.txt` times."
}

# Creates a new cloned interface, registers it for cleanup, and echoes it
# params: $1	Interface class name (tap, gif, etc)
get_iface()
{
	local CLASS DEV N

	CLASS=$1
	N=0
	while ! ifconfig ${CLASS}${N} create > /dev/null 2>&1; do
		if [ "$N" -ge 8 ]; then
			atf_skip "Could not create a ${CLASS} interface"
		else
			N=$(($N + 1))
		fi
	done
	if [ ${CLASS} = "epair" ]; then
		DEV=${CLASS}${N}a
	else
		DEV=${CLASS}${N}
	fi
	# Record the device so we can clean it up later
	echo ${DEV} >> "devices_to_cleanup"
	echo ${DEV}
}


cleanup_ifaces()
{
	local DEV

	for DEV in `cat "devices_to_cleanup"`; do
		ifconfig ${DEV} destroy
	done
	true
}