| # | 
 | # Common functions used by pktgen scripts | 
 | #  - Depending on bash 3 (or higher) syntax | 
 | # | 
 | # Author: Jesper Dangaaard Brouer | 
 | # License: GPL | 
 |  | 
 | set -o errexit | 
 |  | 
 | ## -- General shell logging cmds -- | 
 | function err() { | 
 |     local exitcode=$1 | 
 |     shift | 
 |     echo "ERROR: $@" >&2 | 
 |     exit $exitcode | 
 | } | 
 |  | 
 | function warn() { | 
 |     echo "WARN : $@" >&2 | 
 | } | 
 |  | 
 | function info() { | 
 |     if [[ -n "$VERBOSE" ]]; then | 
 | 	echo "INFO : $@" >&2 | 
 |     fi | 
 | } | 
 |  | 
 | ## -- Pktgen proc config commands -- ## | 
 | export PROC_DIR=/proc/net/pktgen | 
 | # | 
 | # Three different shell functions for configuring the different | 
 | # components of pktgen: | 
 | #   pg_ctrl(), pg_thread() and pg_set(). | 
 | # | 
 | # These functions correspond to pktgens different components. | 
 | # * pg_ctrl()   control "pgctrl" (/proc/net/pktgen/pgctrl) | 
 | # * pg_thread() control the kernel threads and binding to devices | 
 | # * pg_set()    control setup of individual devices | 
 | function pg_ctrl() { | 
 |     local proc_file="pgctrl" | 
 |     proc_cmd ${proc_file} "$@" | 
 | } | 
 |  | 
 | function pg_thread() { | 
 |     local thread=$1 | 
 |     local proc_file="kpktgend_${thread}" | 
 |     shift | 
 |     proc_cmd ${proc_file} "$@" | 
 | } | 
 |  | 
 | function pg_set() { | 
 |     local dev=$1 | 
 |     local proc_file="$dev" | 
 |     shift | 
 |     proc_cmd ${proc_file} "$@" | 
 | } | 
 |  | 
 | # More generic replacement for pgset(), that does not depend on global | 
 | # variable for proc file. | 
 | function proc_cmd() { | 
 |     local result | 
 |     local proc_file=$1 | 
 |     local status=0 | 
 |     # after shift, the remaining args are contained in $@ | 
 |     shift | 
 |     local proc_ctrl=${PROC_DIR}/$proc_file | 
 |     if [[ ! -e "$proc_ctrl" ]]; then | 
 | 	err 3 "proc file:$proc_ctrl does not exists (dev added to thread?)" | 
 |     else | 
 | 	if [[ ! -w "$proc_ctrl" ]]; then | 
 | 	    err 4 "proc file:$proc_ctrl not writable, not root?!" | 
 | 	fi | 
 |     fi | 
 |  | 
 |     if [[ "$DEBUG" == "yes" ]]; then | 
 | 	echo "cmd: $@ > $proc_ctrl" | 
 |     fi | 
 |     # Quoting of "$@" is important for space expansion | 
 |     echo "$@" > "$proc_ctrl" || status=$? | 
 |  | 
 |     if [[ "$proc_file" != "pgctrl" ]]; then | 
 |         result=$(grep "Result: OK:" $proc_ctrl) || true | 
 |         if [[ "$result" == "" ]]; then | 
 |             grep "Result:" $proc_ctrl >&2 | 
 |         fi | 
 |     fi | 
 |     if (( $status != 0 )); then | 
 | 	err 5 "Write error($status) occurred cmd: \"$@ > $proc_ctrl\"" | 
 |     fi | 
 | } | 
 |  | 
 | # Old obsolete "pgset" function, with slightly improved err handling | 
 | function pgset() { | 
 |     local result | 
 |  | 
 |     if [[ "$DEBUG" == "yes" ]]; then | 
 | 	echo "cmd: $1 > $PGDEV" | 
 |     fi | 
 |     echo $1 > $PGDEV | 
 |     local status=$? | 
 |  | 
 |     result=`cat $PGDEV | fgrep "Result: OK:"` | 
 |     if [[ "$result" == "" ]]; then | 
 |          cat $PGDEV | fgrep Result: | 
 |     fi | 
 |     if (( $status != 0 )); then | 
 | 	err 5 "Write error($status) occurred cmd: \"$1 > $PGDEV\"" | 
 |     fi | 
 | } | 
 |  | 
 | [[ $EUID -eq 0 ]] && trap 'pg_ctrl "reset"' EXIT | 
 |  | 
 | ## -- General shell tricks -- | 
 |  | 
 | function root_check_run_with_sudo() { | 
 |     # Trick so, program can be run as normal user, will just use "sudo" | 
 |     #  call as root_check_run_as_sudo "$@" | 
 |     if [ "$EUID" -ne 0 ]; then | 
 | 	if [ -x $0 ]; then # Directly executable use sudo | 
 | 	    info "Not root, running with sudo" | 
 |             sudo "$0" "$@" | 
 |             exit $? | 
 | 	fi | 
 | 	err 4 "cannot perform sudo run of $0" | 
 |     fi | 
 | } | 
 |  | 
 | # Exact input device's NUMA node info | 
 | function get_iface_node() | 
 | { | 
 |     local node=$(</sys/class/net/$1/device/numa_node) | 
 |     if [[ $node == -1 ]]; then | 
 |         echo 0 | 
 |     else | 
 |         echo $node | 
 |     fi | 
 | } | 
 |  | 
 | # Given an Dev/iface, get its queues' irq numbers | 
 | function get_iface_irqs() | 
 | { | 
 | 	local IFACE=$1 | 
 | 	local queues="${IFACE}-.*TxRx" | 
 |  | 
 | 	irqs=$(grep "$queues" /proc/interrupts | cut -f1 -d:) | 
 | 	[ -z "$irqs" ] && irqs=$(grep $IFACE /proc/interrupts | cut -f1 -d:) | 
 | 	[ -z "$irqs" ] && irqs=$(for i in `ls -Ux /sys/class/net/$IFACE/device/msi_irqs` ;\ | 
 | 	    do grep "$i:.*TxRx" /proc/interrupts | grep -v fdir | cut -f 1 -d : ;\ | 
 | 	    done) | 
 | 	[ -z "$irqs" ] && err 3 "Could not find interrupts for $IFACE" | 
 |  | 
 | 	echo $irqs | 
 | } | 
 |  | 
 | # Given a NUMA node, return cpu ids belonging to it. | 
 | function get_node_cpus() | 
 | { | 
 | 	local node=$1 | 
 | 	local node_cpu_list | 
 | 	local node_cpu_range_list=`cut -f1- -d, --output-delimiter=" " \ | 
 | 	                  /sys/devices/system/node/node$node/cpulist` | 
 |  | 
 | 	for cpu_range in $node_cpu_range_list | 
 | 	do | 
 | 	    node_cpu_list="$node_cpu_list "`seq -s " " ${cpu_range//-/ }` | 
 | 	done | 
 |  | 
 | 	echo $node_cpu_list | 
 | } |