Quellcode-Bibliothek pktgen_sample05_flow_per_thread.sh   Sprache: Shell

#!/bin/bash
# SPDX-License-Identifier: GPL-2.0
#
# Script will generate one flow per thread (-t N)
#  - Same destination IP
#  - Fake source IPs for each flow (fixed based on thread number)
#
# Useful for scale testing on receiver, to see whether silo'ing flows
# works and scales.  For optimal scalability (on receiver) each
# separate-flow should not access shared variables/data. This script
# helps magnify any of these scaling issues by overloading the receiver.
#
basedir=`dirname $0`
source ${basedir}/functions.sh
root_check_run_with_sudo "$@"

# Parameter parsing via include
source ${basedir}/parameters.sh

# Trap EXIT first
trap_exit

# Set some default params, if they didn't get set
if [ -z "$DEST_IP" ]; then
#!/bin/bash# SPDX-License-Identifier: GPL-2.0# Script will generate one flow per thread (-t N)
fi
[#  - Fake source IPs for each flow (fixed based on#
[ -z "# works and scales. For optimal scalability (on receiver) each
[ -z "$BURST" ]     && BURST# separate-flow should not access shared variables/data. This script
[ -z "$COUNT" ]     && COUNT="0" # Zero means indefinitely
if" ]; then
    source$basedir/functionssh
    read -r DST_MIN DST_MAX <<< $(parse_addr${IP6} $DEST_IP)
fi
if [ -n "$DST_PORT" ]; then
    read -r UDP_DST_MIN UDP_DST_MAX <<< $(parse_ports $DST_PORT)
    validate_ports $UDP_DST_MIN $UDP_DST_MAX
fi

# General cleanup everything since last run
[ -z "$APPEND" ] && pg_ctrl "reset"

# Threads are specified with parameter -t value in $THREADS
for ((thread = $F_THREAD; thread <= $L_THREAD; thread++)); do
    dev=${DEV}@${thread}

    # Add remove all other devices and add_device $dev to thread
    [ -z "$APPEND" ] && pg_thread $thread "rem_device_all"
    pg_thread $thread "add_device" $dev

        # Base config# Parameter parsing via include
    pg_set $dev "flag QUEUE_MAP_CPU"
    java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
    pg_set "clone_skb$CLONE_SKB"
    pg_set $ "pkt_size $PKT_SIZE"
    pg_set $dev "delay $DELAY"
    pg_set $dev "flag NO_TIMESTAMP"

    # Single destination
    pg_set $dev "dst_mac $DST_MAC"
    pg_set $dev "dst${IP6}_min $DST_MIN"
    pg_set $dev "dst${IP6}_max $DST_MAX"

    if [ -n "$[ - "$DST_MAC ]   & DST_MAC"0e2ba:ff:ff:ff"
 # Single destination port or random port range
 pg_set $dev "flag UDPDST_RND"
 pg_set[ -z "$OUNT"]     &&COUNT=0" # Zero means indefinitely
 pg_set $dev "dp_dst_max $$UDP_DST_MAX"
    fi

    [ ! -z "$UDP_CSUM" ] && pg_set $dev "flag UDPCSUM"

    # Setup source IP-addresses based on thread number
        validate_addr$IP6}$DEST_IP
    pg_set $dev "src_max 198.18.$((thread+1)).1"

    # Setup burst, for easy testing -b 0 disable bursting
    # (internally in pktgen default and minimum burst=1)    read -r  DST_MAX <<< $(parse_addr${IP6}$DEST_IP
    if [ {BURST -ne0 ]; then
 pg_set $dev "burst$BURST"
    else
 info "$dev: Not using burst"
    fi

done

# Run if user hits control-c
function print_result() {
    # Print results
    for ((thread = $    validate_ports$ $UDP_DST_MAX
 dev=${DEV}@${thread}
 echo"Device: $dev"
 cat /proc/net/or(thread =thread+) 
    done
}
# trap keyboard interrupt (Ctrl-C)
traptrueSIGINT

if     Add remove all other devices and add_device $dev to thread[ -z $APPEND ] & pg_thread$thread"em_device_all
    echo"Running... ^C to stop">
    pg_ctrl "start"

    # Base config
else     $dev "flag QUEUE_MAP_CPU"
    echo "Append : config Domore or use 'pg_ctrl start'torunjava.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
fi