network-test addedlinaro-rel-2021.08-dunfell.1-rc2linaro-rel-2021.08-dunfell.1-rc1linaro-rel-2021.08-dunfell.1linaro-rel-2021.08-dunfelllinaro-rel-2020.09-dunfell.3-rc2linaro-rel-2020.09-dunfell.3-rc1linaro-rel-2020.09-dunfell.3linaro-rel-2020.09-dunfell.2-rc2linaro-rel-2020.09-dunfell.2-rc1linaro-rel-2020.09-dunfell.2linaro-rel-2020.09-dunfell.1-rc2linaro-rel-2020.09-dunfell.1linaro

Signed-off-by: Ryan Harkin <ryan.harkin@linaro.org>

2 files changed, 1152 insertions, 0 deletions

diff --git a/automated/linux/network-test/network-test.sh b/automated/linux/network-test/network-test.sh
new file mode 100755
index 0000000..dd6ed6d
--- /dev/null
+++ b/automated/linux/network-test/network-test.sh
@@ -0,0 +1,1089 @@
+#!/bin/sh
+
+# shellcheck disable=SC1091
+. ../../lib/sh-test-lib
+OUTPUT="$(pwd)/output"
+RESULT_FILE="${OUTPUT}/result.txt"
+LOGFILE="${OUTPUT}/iperf3.txt"
+# Time in seconds to transmit for
+TIME="10"
+# Number of parallel client streams to run
+THREADS="1"
+# Specify iperf3 version for CentOS.
+VERSION="3.1.4"
+# By default, the client sends to the server,
+# Setting REVERSE="-R" means the server sends to the client
+REVERSE=""
+# CPU affinity is blank by default, meaning no affinity.
+ETH="eth0"
+EXPECTED_RESULT="pass"
+IPERF3_SERVER_RUNNING="no"
+CMD="usage"
+AUTONEG="auto"
+MTU="1500"
+NETD="" # network-manager or systemd-networkd, blank means auto-detect
+
+# TODO: IFLIST should be auto-generated or able to deal with other boards
+IFLIST=( eth0 eth1 lan0 lan1 lan2 )
+[ "${BOARD}" = "soca9" ] && IFLIST=(${IFLIST[@]} eth2)
+
+################################################################################
+#
+################################################################################
+usage() {
+    echo "Usage: $0 [-c command] [-e server ethernet device] [-t time] [-p number] [-v version] [-A cpu affinity] [-R] [-r expected ping result] [-s true|false] -w <switch-interface> -m <mtu> -n <netd>" 1>&2
+    exit 1
+}
+
+################################################################################
+#
+################################################################################
+command_exists(){
+	local cmd
+
+	cmd="$1"
+
+	if ! which "${cmd}"; then
+		echo "ERROR: ${cmd} not available"
+		exit 1
+	fi
+}
+
+################################################################################
+#
+################################################################################
+dump_msg_cache(){
+	# TODO -delete this debug
+	echo "################################################################################"
+	echo "/tmp/lava_multi_node_cache.txt"
+	echo "################################################################################"
+	cat /tmp/lava_multi_node_cache.txt || true
+	echo "################################################################################"
+}
+
+
+################################################################################
+#
+################################################################################
+wait_for_msg(){
+	local message="${1}"
+	local msgseq="${2}"
+	local ipaddress
+
+	while [ true ]; do
+		# Wait for the daemon to respond
+		lava-wait "${message}"
+
+		dump_msg_cache
+
+		# report pass/fail depending on whether we expected ping to succeed or not
+		rx_msgseq=$(grep "msgseq" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+
+		if [ "${rx_msgseq}" -lt "${msgseq}" ]; then
+			echo "Client: ignoring duplicate message (${rx_msgseq} < ${msgseq})"
+			rm -f /tmp/lava_multi_node_cache.txt
+			sleep 10
+
+			echo Free disk space
+			df -h || true
+			echo Free memory
+			free -h || true
+
+			# While we're waiting for a message, do a sanity check on our IP address
+			ipaddress=$(get_ipaddr ${ETH})
+			if [ "${ipaddress}" != "${IPADDR}" ]; then
+				echo "ERROR: our IP address changes from ${IPADDR} to ${ipaddress} while we were waiting"
+			fi
+			continue
+		elif [ "${rx_msgseq}" -gt "${msgseq}" ]; then
+			echo "ERROR: We missed the reply to our message (rx_msgseq=${rx_msgseq} > msgseq=${msgseq})"
+			# TODO - report lava test fail
+			exit 1
+		else
+			echo "ACK: we found the droids we were looking for..."
+			break
+		fi
+	done
+}
+
+################################################################################
+#
+################################################################################
+if_state() {
+	local interface
+	local if_info
+	local state
+
+	interface="${1}"
+	state=0 # zero is down, 1 is up
+
+	if_info=$(ip addr show "${interface}" | grep -a2 "state DOWN" | tail -1 )
+
+	if [ -z "${if_info}" ]; then
+		state=1
+	fi
+
+	echo "if_state: interface ${interface} is in state ${state}"
+	return "${state}"
+}
+
+################################################################################
+#
+################################################################################
+wait_for_if_up() {
+	local interface
+	local state
+
+	interface="${1}"
+
+	retries=0
+	max_retries=100
+	while if_state "${interface}" && [ "$((retries++))" -lt "${max_retries}" ]; do
+		sleep 0.1
+	done
+	if_state "${interface}" && return -1
+	return 0
+}
+
+################################################################################
+#
+################################################################################
+if_up() {
+	local interface
+	interface="${1}"
+
+	if if_state "${interface}" ; then
+		echo "Bringing interface ${interface} up"
+		ifconfig "${interface}" up
+		wait_for_if_up "${interface}" 2>&1 > /dev/null
+		check_return "ethernet-${interface}-state-up ${result}"
+	fi
+}
+
+
+################################################################################
+#
+################################################################################
+if_down() {
+	local interface
+	local result
+
+	interface="${1}"
+	result=fail
+
+	echo "Bringing interface ${interface} down"
+	ifconfig "${interface}" down
+	if_state "${interface}"
+	check_return "ethernet-${interface}-state-down"
+}
+
+################################################################################
+#
+################################################################################
+get_ipaddr() {
+	local ipaddress
+	local interface
+
+	interface="${1}"
+	ipaddress=$(ip addr show "${interface}" | grep -a2 "state " | grep "inet "| tail -1 | awk '{print $2}' | cut -f1 -d'/')
+	echo "${ipaddress}"
+}
+
+################################################################################
+#
+################################################################################
+get_netmask() {
+	local netmask
+	local interface
+
+	interface="${1}"
+	netmask=$(ip addr show "${interface}" | grep -a2 "state " | grep "inet " | tail -1 | awk '{print $2}' | cut -f2 -d'/')
+	echo "${netmask}"
+}
+
+################################################################################
+#
+################################################################################
+show_ip() {
+	local interface
+	local ipaddress
+	local netmask
+
+	interface="${1}"
+
+	ipaddress=$(get_ipaddr "${interface}")
+	netmask=$(get_netmask "${interface}")
+	echo "Current ipaddr=${ipaddress}/${netmask}"
+}
+
+################################################################################
+#
+################################################################################
+is_valid_ip() {
+    local  ip=$1
+    local  is_valid=1
+
+	if [ -n "${ip}" ]; then
+		if expr "$ip" : '[0-9][0-9]*\.[0-9][0-9]*\.[0-9][0-9]*\.[0-9][0-9]*$' >/dev/null; then
+		  for i in 1 2 3 4; do
+			if [ $(echo "$ip" | cut -d. -f$i) -gt 255 ]; then
+			  return 1
+			fi
+		  done
+		  is_valid=0
+		fi
+	fi
+    return $is_valid
+}
+
+################################################################################
+#
+################################################################################
+ping_test() {
+	local interface
+	local test_string
+	local ipaddress
+
+	interface="${1}"
+	test_string="${2}"
+
+	# Get IP address of a given interface
+	show_ip "${interface}"
+	ipaddress=$(get_ipaddr "${interface}")
+	[ -n "${ipaddress}" ]
+	check_return "ethernet-${interface}-ping-get-ipaddr"
+
+	# Get default Route IP address of a given interface
+	PING_ADDR=$(ip route list  | grep default | awk '{print $3}' | head -1)
+
+	if [ -z "${PING_ADDR}" ]; then
+		ip addr show "${interface}"
+		PING_ADDR=10.0.0.2
+		echo "WARNING: failed to get the default router, using ${PING_ADDR} instead."
+	fi
+
+	# Run the test
+	run_test_case "ping -I ${interface} -c 5 ${PING_ADDR}" "${test_string}"
+}
+
+
+
+################################################################################
+#
+################################################################################
+detect_netd(){
+	local mgr
+
+	if [ "${NETD}" = "" ]; then
+		NETD="unknown"
+		mgr=$(systemctl --no-pager -l status NetworkManager | grep "Active: " | awk '{print $2}')
+		if [ "${mgr}" = "active" ]; then
+			NETD="NetworkManager"
+		else
+			mgr=$(systemctl --no-pager -l status systemd-networkd | grep "Active: " | awk '{print $2}')
+			if [ "${mgr}" = "active" ]; then
+				NETD="systemd-networkd"
+			fi
+		fi
+	fi
+	echo "${NETD}"
+}
+
+################################################################################
+#
+################################################################################
+do_dhcp(){
+	local interface
+	local retries
+
+	interface="${1}"
+	IPADDR=""
+
+	case "$(detect_netd)" in
+		NetworkManager)
+			# Set the interface as managed by networkmanager
+			# autoconnect will use DHCP to assign an IP address
+			echo "nmcli: set interface ${interface} managed"
+			nmcli -c no device set "${interface}" managed yes autoconnect yes
+			nmcli -c no device
+			systemctl daemon-reload
+			;;
+
+		systemd-networkd)
+			# TODO - check udhcpc vs dhclient
+			echo "systemd-networkd: running udhcpc in ${interface}"
+			udhcpc -i "${interface}"
+			;;
+
+		*)
+			echo "ERROR: network daemon '${NETD}' not supported"
+			exit 1
+			;;
+	esac
+
+	# Wait for DHCP to complete
+	retries=1000
+	while [ "${IPADDR}" = "" ]; do
+		IPADDR=$(get_ipaddr "${interface}")
+		retries="$(expr ${retries} - 1)"
+		echo -n "$retries "
+		case "${retries}" in
+		"200"|"400"|"600"|"800")
+			echo "Taking ${interface} down..."
+			ifconfig "${interface}" down
+			sleep 5
+			echo "Bringing ${interface} up..."
+			ifconfig "${interface}" up
+			sleep 10
+			udhcpc -i "${interface}"
+			sleep 5
+			# Get default Route IP address of a given interface
+			ROUTE_ADDR=$(ip route list  | grep default | awk '{print $3}' | head -1)
+			if [ -z "${ROUTE_ADDR}" ]; then
+				IPADDR=$(get_ipaddr "${interface}")
+				netmask=$(get_netmask "${interface}")
+				if [ ! -z "${IPADDR}" ]; then
+					ip addr del "${IPADDR}"/"${netmask}" dev "${interface}"
+				fi
+				continue;
+			fi
+			;;
+		esac
+		if [ "${retries}" -lt "1" ]; then
+			echo "ERROR: dhcp failed to assign an IP address"
+			break
+		fi
+		sleep 0.1
+		echo -n "."
+	done
+}
+
+################################################################################
+#
+################################################################################
+assign_ipaddr(){
+	local interface
+	local netmask
+	local static_ipaddr
+
+	interface="${1}"
+	static_ipaddr="${2}"
+
+	if [ -z "${static_ipaddr}" ]; then
+		test_string="dhcp"
+	else
+		test_string="static-ip"
+	fi
+
+	show_ip "${interface}"
+	IPADDR=$(get_ipaddr "${interface}")
+	netmask=$(get_netmask "${interface}")
+	if is_valid_ip "${IPADDR}"; then
+		echo "ip address already set... removing"
+		ip addr del "${IPADDR}"/"${netmask}" dev "${interface}"
+
+		echo "Check IP address removed"
+		show_ip "${interface}"
+		IPADDR=$(get_ipaddr "${interface}")
+		echo "IPADDR=${IPADDR}"
+		! is_valid_ip "${IPADDR}"
+		check_return "ethernet-${interface}-${test_string}-remove-ipaddr"
+	fi
+
+	if [ -z "${static_ipaddr}" ]; then
+		echo "Running dhcpc on ${interface}..."
+		do_dhcp "${interface}"
+	else
+		echo "Setting a static IP address to ${static_ipaddr}..."
+		ifconfig "${interface}" "${static_ipaddr}"
+		echo "Setting default gateway to ${GATEWAY}"
+		route add default gw "${GATEWAY}"
+	fi
+
+	show_ip "${interface}"
+	IPADDR=$(get_ipaddr "${interface}")
+	if [ -z "${IPADDR}" ]; then
+		check_return "ethernet-${interface}-${test_string}-assign-ipaddr"
+	fi
+	ping_test "${interface}" "ethernet-${interface}-${test_string}-assign-ipaddr-ping"
+}
+
+################################################################################
+#
+################################################################################
+dump_link_settings(){
+	local interface
+	local speed
+	local duplex
+	local autoneg
+	local mtu
+
+	interface="${1}"
+	speed=$(get_link_speed "${interface}")
+	duplex=$(get_link_duplex "${interface}")
+	autoneg=$(get_link_autoneg "${interface}")
+	mtu=$(get_link_mtu "${interface}")
+
+	echo "Current settings for interface ${interface}"
+	echo "  Auto-neg: ${autoneg}"
+	echo "  Speed:    ${speed}"
+	echo "  Duplex:   ${duplex}"
+	echo "  MTU:      ${mtu}"
+}
+
+
+################################################################################
+#
+################################################################################
+get_link_speed(){
+	local interface
+	local speed
+
+	interface="${1}"
+	speed=$(ethtool "${interface}" \
+		| grep -e "Speed" \
+		| sed  -e "s/Speed: //g" \
+		| sed  -e 's/\t//g' -e 's/ //g' -e 's/Mb\/s//g')
+	echo "${speed}"
+}
+################################################################################
+#
+################################################################################
+get_link_duplex(){
+	local interface
+	local duplex
+
+	interface="${1}"
+	duplex=$(ethtool "${interface}" \
+		| grep -e "Duplex" \
+		| sed  -e "s/Duplex: //g" \
+		| sed  -e 's/\t//g' -e 's/ //g' \
+		| awk '{print tolower($0)}')
+	echo "${duplex}"
+}
+################################################################################
+#
+################################################################################
+get_link_autoneg(){
+	local interface
+	local autoneg
+
+	interface="${1}"
+	autoneg=$(ethtool "${interface}" \
+		| grep -e "Auto-negotiation" \
+		| sed  -e "s/Auto-negotiation://g" \
+		| sed  -e 's/\t//g' -e 's/ //g' \
+		| awk '{print tolower($0)}')
+
+	case "${autoneg}" in
+		no|off) autoneg=manual ;;
+		yes|on) autoneg=auto ;;
+	esac
+	echo "${autoneg}"
+}
+
+################################################################################
+#
+################################################################################
+get_link_mtu(){
+	local interface
+	local mtu
+
+	interface="${1}"
+	mtu=$(ip link show "${interface}" | awk '{print $5}')
+	echo "${mtu}"
+}
+
+################################################################################
+#
+################################################################################
+check_link_settings(){
+	local interface
+	local requested_speed
+	local requested_duplex
+	local requested_autoneg
+	local requested_mtu
+	local actual_speed
+	local actual_duplex
+	local actual_autoneg
+	local actual_mtu
+	local test_string
+
+	interface="${1}"
+	requested_speed="${2}"
+	requested_duplex="${3}"
+	requested_autoneg="${4}"
+	requested_mtu="${5}"
+	test_string="${6}"
+
+	dump_link_settings "${interface}"
+
+	actual_speed=$(get_link_speed "${interface}")
+	actual_duplex=$(get_link_duplex "${interface}")
+	actual_autoneg=$(get_link_autoneg "${interface}")
+	actual_mtu=$(get_link_mtu "${interface}")
+
+	[ "${actual_autoneg}" = "${requested_autoneg}" ]
+	check_return "ethernet-${interface}-${test_string}-check-link-autoneg"
+
+	if [ "${requested_autoneg}" = "manual" ] || [ "${requested_autoneg}" = "off" ]; then
+		[ "${actual_speed}" = "${requested_speed}" ]
+		check_return "ethernet-${interface}-${test_string}-check-link-speed"
+		[ "${actual_duplex}" = "${requested_duplex}" ]
+		check_return "ethernet-${interface}-${test_string}-check-link-duplex"
+	fi
+
+	[ "${actual_mtu}" = "${requested_mtu}" ]
+	check_return "ethernet-${interface}-${test_string}-check-link-mtu"
+}
+
+
+################################################################################
+#
+################################################################################
+test_link_settings(){
+	local interface
+	local speed
+	local duplex
+	local autoneg
+
+	interface="${1}"
+	speed="${2}"
+	duplex="${3}"
+	autoneg="${4}"
+	mtu="${5}"
+
+	dump_link_settings "${interface}"
+
+	echo "Requested Settings:"
+	echo "  Auto-neg: ${autoneg}"
+	echo "  Speed:    ${speed}"
+	echo "  Duplex:   ${duplex}"
+	echo "  MTU:      ${mtu}"
+
+	if [ "${autoneg}" = "auto" ] || [ "${autoneg}" = "on" ]; then
+		local actual_autoneg=$(get_link_autoneg "${interface}")
+		if [ "${actual_autoneg}" = "manual" ] || [ "${actual_autoneg}" = "off" ]; then
+			echo "Setting ${interface} to auto-negotiate"
+			ethtool -s "${interface}" autoneg on
+		else
+			echo "${interface} is already in auto-negotiate."
+		fi
+	else
+		echo "Setting ${interface} to manual negotiation for ${speed}Mbps at ${duplex} duplex"
+		ethtool -s "${interface}" speed "${speed}" duplex "${duplex}" autoneg off
+	fi
+	sleep 3
+	if_down "${interface}"
+	ifconfig "${interface}" mtu "${mtu}"
+	sleep 3
+	if_up "${interface}"
+	assign_ipaddr "${interface}"
+	echo ""
+	check_link_settings "${interface}" "${speed}" "${duplex}" "${autoneg}" "${mtu}" "link-settings"
+}
+
+################################################################################
+################################################################################
+################################################################################
+################################################################################
+################################################################################
+
+while getopts "a:c:d:e:l:m:t:p:v:s:r:w:Rh" o; do
+  case "$o" in
+    a) AUTONEG="${OPTARG}" ;;
+    c) CMD="${OPTARG}" ;;
+    d) DUPLEX="${OPTARG}" ;;
+    e) ETH="${OPTARG}" ;;
+    l) LINKSPEED="${OPTARG}" ;;
+    m) MTU="${OPTARG}" ;;
+    n) NETD="${OPTARG}" ;;
+    t) TIME="${OPTARG}" ;;
+    p) THREADS="${OPTARG}" ;;
+    r) EXPECTED_RESULT="${OPTARG}" ;;
+    R) REVERSE="-R" ;;
+    v) VERSION="${OPTARG}" ;;
+    w) SWITCH_IF="${OPTARG}" ;;
+    s) SKIP_INSTALL="${OPTARG}" ;;
+    h|*) usage ;;
+  esac
+done
+
+create_out_dir "${OUTPUT}"
+cd "${OUTPUT}"
+
+if [ "${SKIP_INSTALL}" = "true" ] || [ "${SKIP_INSTALL}" = "True" ]; then
+    info_msg "iperf3 installation skipped"
+else
+    dist_name
+    # shellcheck disable=SC2154
+    case "${dist}" in
+        debian|ubuntu|fedora)
+            install_deps "iperf3"
+            ;;
+        centos)
+            install_deps "wget gcc make"
+            wget https://github.com/esnet/iperf/archive/"${VERSION}".tar.gz
+            tar xf "${VERSION}".tar.gz
+            cd iperf-"${VERSION}"
+            ./configure
+            make
+            make install
+            ;;
+    esac
+fi
+
+command_exists "lava-send"
+command_exists "lava-wait"
+command_exists "ping"
+
+echo Free disk space
+df -h || true
+echo Free memory
+free -h || true
+
+# TODO - some commands *need* an IP address configured for the interface, eg. ping
+#        others don't, eg. configure-interface
+#        Exit early in these specific circumstances
+ipaddr_mandatory=true
+case "${CMD}" in
+	"configure-interface" | "finished")
+		ipaddr_mandatory=false ;;
+esac
+
+IPADDR=$(get_ipaddr $ETH)
+if [ "${ipaddr_mandatory}" = "true" ]; then
+	if ! is_valid_ip "${IPADDR}"; then
+		echo "WARNING: ipaddr '${IPADDR}' is invalid. Attempt to assign one..."
+		assign_ipaddr "${ETH}"
+		IPADDR=$(get_ipaddr $ETH)
+		if ! is_valid_ip "${IPADDR}"; then
+			echo "ERROR: ipaddr ${IPADDR} is invalid. Exiting."
+			# TODO - report lava test fail
+			exit 1
+		fi
+	fi
+fi
+
+case "$CMD" in
+	################################################################################
+	#
+	################################################################################
+	"configure-interface")
+
+		ip addr show # DEBUG
+
+		# Take all interfaces down
+		echo "################################################################################"
+		for intf in ${IFLIST[@]}; do
+			if_down "${intf}"
+			case "$(detect_netd)" in
+				NetworkManager)
+					nmcli -c no device set "${intf}" managed no autoconnect no
+					;;
+			esac
+		done
+		sleep 2
+		echo "################################################################################"
+
+		ip addr show # DEBUG
+
+		# Bring up the interface we want to test
+		echo "################################################################################"
+		echo "Bring ${ETH} up"
+		echo "################################################################################"
+		if [ -n "${SWITCH_IF}" ]; then
+			echo "${ETH} is a port on switch ${SWITCH_IF}"
+			ip addr show "${SWITCH_IF}"
+			if_up "${SWITCH_IF}"
+			ip addr show "${SWITCH_IF}"
+		fi
+		if_up "${ETH}"
+		assign_ipaddr "${ETH}"
+
+		# DEBUG
+		if [ -n "${SWITCH_IF}" ]; then
+			ip addr show "${SWITCH_IF}"
+		fi
+		ip addr show "${ETH}"
+		test_link_settings "${ETH}" "${LINKSPEED}" "${DUPLEX}" "${AUTONEG}" "${MTU}"
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"daemon")
+		previous_msgseq=""
+		while [ true ]; do
+			# Wait for the client to make a request
+			lava-wait client-request
+
+			# read the client request
+			request=$(grep "request" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+			msgseq=$(grep "msgseq" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+
+			if [ "${msgseq}" = "${previous_msgseq}" ]; then
+				echo "Daemon: ignoring duplicate message ${msgseq}"
+				sleep 10
+				continue
+			fi
+
+			# log this message so we don't handle it again
+			previous_msgseq="${msgseq}"
+
+			echo "client-request \"${request}\" with stamp ${msgseq} received"
+
+			# perform the client request
+			case "${request}" in
+				################################################################################
+				#
+				################################################################################
+				"finished")
+					echo "Client has signalled we are finished. Exiting."
+					exit 0
+					;;
+
+				################################################################################
+				#
+				################################################################################
+				"request-server-address")
+					dump_msg_cache
+					lava-send server-address ipaddr="${IPADDR}" msgseq="${msgseq}"
+					;;
+
+				################################################################################
+				#
+				################################################################################
+				"iperf3-server")
+					dump_msg_cache
+					if [ "${IPERF3_SERVER_RUNNING}" != "pass" ]; then
+						################################################################################
+						# Start the server
+						# report pass/fail as a test result
+						# send the server's IP address to the client(s)
+						################################################################################
+						echo "Client has asked us to start the iperf3 server"
+						cmd="iperf3 -s -D"
+						taskset 0x02 ${cmd}
+						if pgrep -f "${cmd}" > /dev/null; then
+							IPERF3_SERVER_RUNNING="pass"
+						else
+							IPERF3_SERVER_RUNNING="fail"
+						fi
+						echo "iperf3-server-running ${IPERF3_SERVER_RUNNING}" | tee -a "${RESULT_FILE}"
+					else
+						echo "iperf3 server is already running"
+					fi
+
+					if [ "${IPERF3_SERVER_RUNNING}" = "pass" ]; then
+						lava-send iperf3-server-ready ipaddr="${IPADDR}" msgseq="${msgseq}"
+					fi
+					;;
+
+				################################################################################
+				#
+				################################################################################
+				"ping-request")
+					dump_msg_cache
+
+					their_ipaddr=$(grep "ipaddr" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					msgseq=$(grep "msgseq" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					echo "Client has asked us to ping address ${their_ipaddr} with msgseq=${msgseq}"
+					pingresult=pass
+					ping -c 5 "${their_ipaddr}" || pingresult="fail"
+					lava-send client-ping-done pingresult="${pingresult}" msgseq="${msgseq}"
+					;;
+
+				################################################################################
+				#
+				################################################################################
+				"ssh-request")
+					dump_msg_cache
+					their_filename=$(grep "filename" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					their_ipaddr=$(grep "ipaddr" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					msgseq=$(grep "msgseq" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					# first check we can communicate with the client
+					if ping -c 3 ${their_ipaddr};
+					then
+						echo "Client has asked us to ssh in and md5sum ${their_filename}"
+						our_sum=$(ssh -v -o StrictHostKeyChecking=no -o ServerAliveInterval=60 -o BatchMode=yes root@"${their_ipaddr}" md5sum "${their_filename}" | tail -1 | cut -d " " -f 1 | tee -a "${their_filename}".md5)
+						retVal="$?"
+						if [ ${retVal} != 0 ]; then
+							echo "ERROR: ssh command failed with code ${retVal}"
+							our_sum=dead
+							echo Free disk space
+							df -h / || true
+							echo Free memory
+							free -h || true
+						fi
+					else
+						echo "ERROR: cannot communicate with ${their_ipaddr}"
+						our_sum=dead
+					fi
+					echo "Our md5sum is ${our_sum}"
+					lava-send ssh-result md5sum="${our_sum}" msgseq="${msgseq}"
+					;;
+
+				################################################################################
+				#
+				################################################################################
+				"md5sum-request")
+					dump_msg_cache
+					filename=$(grep "filename" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					msgseq=$(grep "msgseq" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					echo "Client has asked us to md5sum ${filename}"
+					our_sum=$(md5sum "${filename}" | tail -1 | cut -d " " -f 1 | tee -a "${filename}".md5)
+					echo "Our md5sum is ${our_sum}"
+					lava-send md5sum-result md5sum="${our_sum}" msgseq="${msgseq}"
+					;;
+
+				################################################################################
+				#
+				################################################################################
+				"scp-request")
+					dump_msg_cache
+					their_filename=$(grep "filename" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					their_ipaddr=$(grep "ipaddr" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					msgseq=$(grep "msgseq" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+					echo "Client has asked us to send them ${filename}"
+
+					# first check we can communicate with the client
+					if ping -c 3 ${their_ipaddr};
+					then
+						# create the file we want to send
+						our_filename=$(mktemp ~/largefile.XXXXX)
+						dd if=/dev/urandom of="${our_filename}" bs=1M count=1024
+						our_sum=$(md5sum "${our_filename}" | tail -1 | cut -d " " -f 1 | tee -a "${our_filename}".md5)
+						scp -v -o StrictHostKeyChecking=no -o ServerAliveInterval=60 -o BatchMode=yes "${our_filename}" root@"${their_ipaddr}":"${their_filename}"
+						retVal="$?"
+						if [ ${retVal} != 0 ]; then
+							echo "ERROR: scp command failed with code ${retVal}"
+							our_sum=dead
+							echo Free disk space
+							df -h || true
+							echo Free memory
+							free -h || true
+						fi
+					else
+						echo "ERROR: cannot communicate with ${their_ipaddr}"
+						our_sum=dead
+					fi
+
+					echo "Our md5sum is ${our_sum}"
+					lava-send scp-result md5sum="${our_sum}" msgseq="${msgseq}"
+					rm -f "${our_filename}"
+					;;
+
+				################################################################################
+				#
+				################################################################################
+				*) echo "Unknown client request: ${request}" ;;
+			esac
+			rm -f /tmp/lava_multi_node_cache.txt
+		done
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"ping-request")
+		tx_msgseq="$(date +%s)"
+		lava-send client-request request="ping-request" ipaddr="${IPADDR}" msgseq="${tx_msgseq}"
+		wait_for_msg client-ping-done "${tx_msgseq}"
+
+		pingresult=$(grep "pingresult" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+		echo "The daemon says that pinging the client returned ${pingresult}"
+		echo "We are expecting ping to ${EXPECTED_RESULT}"
+
+		if [ "${pingresult}" = "${EXPECTED_RESULT}" ]; then
+			result="pass"
+		else
+			result="fail"
+		fi
+		echo "client-ping-request ${result}" | tee -a "${RESULT_FILE}"
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"request-server-address"|"iperf3-server")
+		# The mechanism for requesting the servier address, or for requesting
+		# the the daemon starts the iperf3 daemon are the same:
+		# - we send the request
+		# - the server does what it needs to
+		# - the server replies with its IP address
+		tx_msgseq="$(date +%s)"
+		lava-send client-request request="${CMD}" msgseq="${tx_msgseq}"
+		case "${CMD}" in
+			"iperf3-server") wait_msg=iperf3-server-ready ;;
+			*) wait_msg=server-address ;;
+		esac
+		wait_for_msg "${wait_msg}" "${tx_msgseq}"
+
+		server=$(grep "ipaddr" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+
+		if [ -z "${server}" ]; then
+			echo "ERROR: no server specified"
+			result="fail"
+		else
+			SERVER="${server}"
+			echo "${CMD}: ${SERVER}"
+			echo "${SERVER}" > /tmp/server.ipaddr
+			result="pass"
+		fi
+		echo "${CMD}" | tee -a "${RESULT_FILE}"
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"iperf3-client")
+		SERVER="$(cat /tmp/server.ipaddr)"
+		if [ -z "${SERVER}" ]; then
+			echo "ERROR: no server specified"
+			exit 1
+		else
+			echo "Using SERVER=${SERVER}"
+		fi
+
+		# We are running in client mode
+		# Run iperf3 test with unbuffered output mode.
+		stdbuf -o0 taskset 0x02 iperf3 -c "${SERVER}" -t "${TIME}" -P "${THREADS}" "${REVERSE}" 2>&1 \
+			| tee "${LOGFILE}"
+
+		# Parse logfile.
+		if [ "${THREADS}" -eq 1 ]; then
+			grep -E "(sender|receiver)" "${LOGFILE}" \
+				| awk '{printf("iperf3_%s pass %s %s\n", $NF,$7,$8)}' \
+				| tee -a "${RESULT_FILE}"
+		elif [ "${THREADS}" -gt 1 ]; then
+			grep -E "[SUM].*(sender|receiver)" "${LOGFILE}" \
+				| awk '{printf("iperf3_%s pass %s %s\n", $NF,$6,$7)}' \
+				| tee -a "${RESULT_FILE}"
+		fi
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"ssh-host-to-target")
+		# SSH into the target and md5sum a file. Send the md5sum back to the target for verification
+		filename=$(mktemp /tmp/magic.XXXXX)
+		dd if=/dev/urandom of="${filename}" bs=1024 count=1
+		our_sum=$(md5sum "${filename}" | tail -1 | cut -d " " -f 1 | tee -a "${filename}".md5)
+		echo "Our   md5sum is ${our_sum}"
+
+		tx_msgseq="$(date +%s)"
+		lava-send client-request request="ssh-request" ipaddr="${IPADDR}" filename="${filename}" msgseq="${tx_msgseq}"
+		wait_for_msg ssh-result "${tx_msgseq}"
+		their_sum=$(grep "md5sum" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+		echo "Their md5sum is ${their_sum}"
+
+		if [ "${their_sum}" = "${our_sum}" ]; then
+			result=pass
+		else
+			result=fail
+		fi
+		echo "ssh-host-to-target ${result}" | tee -a "${RESULT_FILE}"
+		rm -f "${filename}"
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"scp-host-to-target")
+		# SCP a file from the host (server) to the target (client)
+		filename=$(mktemp ~/largefile.XXXXX)
+		tx_msgseq="$(date +%s)"
+
+		echo "scp-host-to-target: ETH=${ETH} ipaddr=${IPADDR}"
+		ip addr show "${ETH}"
+
+		lava-send client-request request="scp-request" ipaddr="${IPADDR}" filename="${filename}" msgseq="${tx_msgseq}"
+		show_ip "${ETH}"
+		wait_for_msg scp-result "${tx_msgseq}"
+		show_ip "${ETH}"
+		their_sum=$(grep "md5sum" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+		echo "Generating our md5sum..."
+		our_sum=$(md5sum "${filename}" | tail -1 | cut -d " " -f 1 | tee -a "${filename}".md5)
+		echo "Our   md5sum is ${our_sum}"
+		echo "Their md5sum is ${their_sum}"
+
+		if [ "${their_sum}" = "${our_sum}" ]; then
+			result=pass
+		else
+			result=fail
+		fi
+		echo "scp-host-to-target ${result}" | tee -a "${RESULT_FILE}"
+		rm -f "${filename}"
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"scp-target-to-host")
+		# SCP a file from the target (client, DUT) to the host (server)
+		# TODO - this relies on running iperf3 tests first
+		SERVER="$(cat /tmp/server.ipaddr)"
+		if [ -z "${SERVER}" ]; then
+			echo "ERROR: no server specified"
+			exit 1
+		else
+			echo "Using SERVER=${SERVER}"
+		fi
+
+		filename=$(mktemp ~/largefile.XXXXX)
+		echo "Creating 1G file..."
+		dd if=/dev/urandom of="${filename}" bs=1M count=1024
+		scp -v -o StrictHostKeyChecking=no -o ServerAliveInterval=60 -o BatchMode=yes "${filename}" root@"${SERVER}":"${filename}"
+		retVal="$?"
+		if [ ${retVal} != 0 ]; then
+			echo "ERROR: scp command failed with code ${retVal}"
+			result=fail
+			echo Free disk space
+			df -h || true
+			echo Free memory
+			free -h || true
+		else
+			tx_msgseq="$(date +%s)"
+			lava-send client-request request="md5sum-request" filename="${filename}" msgseq="${tx_msgseq}"
+			our_sum=$(md5sum "${filename}" | tail -1 | cut -d " " -f 1 | tee -a "${filename}".md5)
+			wait_for_msg md5sum-result "${tx_msgseq}"
+			their_sum=$(grep "md5sum" /tmp/lava_multi_node_cache.txt | tail -1 | awk -F"=" '{print $NF}')
+
+			if [ "${their_sum}" = "${our_sum}" ]; then
+				result=pass
+			else
+				result=fail
+			fi
+		fi
+		echo "scp-target-to-host ${result}" | tee -a "${RESULT_FILE}"
+
+		# Send an empty file back to the host to overwrite the large file, effectively deleting the file, so we don't eat their disk space
+		smallfilename=$(mktemp /tmp/smallfile.XXXXX)
+		scp -v -o StrictHostKeyChecking=no -o ServerAliveInterval=60 -o BatchMode=yes "${smallfilename}" root@"${SERVER}":"${filename}"
+		retVal="$?"
+		if [ ${retVal} != 0 ]; then
+			echo "ERROR: scp command failed with code ${retVal}"
+		fi
+		rm -f "${filename}" "${smallfilename}"
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"link-settings")
+		test_link_settings "${ETH}" "${LINKSPEED}" "${DUPLEX}" "${AUTONEG}" "${MTU}"
+		;;
+
+	################################################################################
+	#
+	################################################################################
+	"finished")
+		lava-send client-request request="finished"
+		;;
+
+	*)
+		usage
+		;;
+esac
diff --git a/automated/linux/network-test/network-test.yaml b/automated/linux/network-test/network-test.yaml
new file mode 100644
index 0000000..a60f1ab
--- /dev/null
+++ b/automated/linux/network-test/network-test.yaml
@@ -0,0 +1,63 @@
+metadata:
+    name: network-test
+    format: "Lava-Test Test Definition 1.0"
+    description: "Test networking features and performance, including
+                  running iperf, scp and ssh from daemon to DUT."
+    maintainer:
+        - milosz.wasilewski@linaro.org
+    os:
+        - debian
+        - ubuntu
+        - fedora
+        - centos
+        - openembedded
+    scope:
+        - performance
+    environment:
+        - lava-test-shell
+    devices:
+        - hi6220-hikey
+        - apq8016-sbc
+        - mustang
+        - moonshot
+        - thunderX
+        - d03
+        - d05
+        - soca9
+        - rzn1d
+
+params:
+    CMD: "daemon"
+    ETH: "eth0"
+
+    # Settings for CMD=ping-request
+    # Used for ping-request commands to indicate if we expect the ping to pass or fail
+    # This is used when we disable the ethernet port, then check that ping fails
+    EXPECTED_RESULT: "pass"
+    # Time in seconds to transmit for
+
+    # Setting for CMD=iperf3-client
+    TIME: "10"
+    # Number of parallel client streams to run
+    THREADS: "1"
+    # Set affinity of the client to cpu 0 using "-A 0"
+    AFFINITY: ""
+    # Set REVERSE="-R" to run tx from the server
+    REVERSE: ""
+
+    # Setting for CMD=link-settings
+    LINKSPEED: "1000"
+    DUPLEX: "full"
+    AUTONEG: "auto"
+    MTU: 1500
+
+    SWITCH_IF: ""
+    NETD: ""
+
+    SKIP_INSTALL: "false"
+
+run:
+    steps:
+        - cd ./automated/linux/network-test
+        - ./network-test.sh -c "${CMD}" -s "${SKIP_INSTALL}" -e "${ETH}"  -t "${TIME}" -p "${THREADS}" -r "${EXPECTED_RESULT}" -a "${AUTONEG}" -l "${LINKSPEED}" -d "${DUPLEX}" -m "${MTU}" -w "${SWITCH_IF}" "${AFFINITY}" "${REVERSE}"
+        - ../../utils/send-to-lava.sh ./output/result.txt