mirror of
https://github.com/Telecominfraproject/wlan-lanforge-scripts.git
synced 2025-10-28 17:32:35 +00:00
72712ff548
These scripts will now be publicly available in a git repo for easier shared development and change tracking.
1750 lines
53 KiB
Prolog
Executable File
1750 lines
53 KiB
Prolog
Executable File
#!/usr/bin/perl
|
|
|
|
# This program is used to test the max TCP connections allowed through a firewall,
|
|
# and may be used as an example for others who wish to automate LANforge tests.
|
|
|
|
# This script sets up 1 UDP connection and as many TCP connections as specified
|
|
# by $num_macvlans. Each connection is started and verified that it is passing
|
|
# traffic before starting the next connection. As each TCP connection is started
|
|
# the UDP connection is checked for any dropped packets. As soon as dropped packets
|
|
# are detected on the UDP connection, the number of TCP connections is recorded
|
|
# and the entire test is repeated for $loop_max times. An average number of TCP
|
|
# connections is calculated and reported at the conclusion of all the test runs.
|
|
|
|
|
|
# Un-buffer output
|
|
$| = 1;
|
|
|
|
use strict;
|
|
use Switch;
|
|
|
|
use Net::Telnet ();
|
|
use Time::HiRes qw (usleep);
|
|
use LANforge::Port;
|
|
use LANforge::Utils;
|
|
use LANforge::Endpoint;
|
|
|
|
my $init_stop_all = 1; # Stop all tests before running script test.
|
|
my $script_speed = 25; # Increase to issue commands faster.
|
|
my $quiet_cli_cmds = 1; # Quiesce CLI response output to commands sent.
|
|
my $quiet_cli_output = 1; # Quiesce unsolicited CLI output.
|
|
my $cli_cmd_delay = 0; # Increase to slow command rate sent to cli.
|
|
my $report_timer = 9000; # Set report timer for all tests created in ms, i.e. 8 seconds
|
|
|
|
my $INIT = 1; # If true, removes all previous tests and ports!!!
|
|
my $create_only = 0; # If true, only create tests, i.e. do not automatically run them.
|
|
|
|
my $mac_init = 0; # Set to 1 to start MAC address from zero when running looped test.
|
|
my $ip_init = 0; # Set to 1 to start IP addresses from zero when running looped test.
|
|
my $init_once = 1; # Set to 1 to only initialize test creation once.
|
|
my $init_net = 1; # Set to 0 to disable reconfiguring MAC and IP addresses.
|
|
my $init_tests = 1; # Set to 0 to disable reconfiguring tests.
|
|
my $first_run = 1; # Set to 0 to disable initial configurations.
|
|
my $name_id = 0; # First index of name of endpoints and CXs.
|
|
my $name_id_len = 0; # Override for length of $name_id.
|
|
my $loop_max = 3;
|
|
my $start_stop_loops = 2;
|
|
my $run_for_time = 120; # Run for XX seconds..then will be stopped again.
|
|
my $stop_for_time = 5; # Run for XX seconds..then will be stopped again.
|
|
my $keep_running = 1; # If ture, will keep last test loop running.
|
|
my $ignore_phys_ports = 1; # If true, just muck with MACVLANs.
|
|
|
|
my $one_cx_per_port = 0; # If zero, will have one of EACH of the cx types on each port.
|
|
|
|
my $cx_types_from_file = 0; # If true, will rotate through the @cx_types_files
|
|
# when creating tests instead of using @cx_types array.
|
|
|
|
my @cx_types = (
|
|
#"lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp",
|
|
"lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp",
|
|
"lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp",
|
|
"lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp","lf_tcp");
|
|
|
|
my $test_mgr = "max_cxs_tm";
|
|
|
|
my $lfmgr_host = "localhost";
|
|
my $lfmgr_port = 4001;
|
|
|
|
my $shelf = 1;
|
|
|
|
# This sets up connections.
|
|
my $lf1 = 1; # Minor Resource EID of first LANforge resource.
|
|
my $lf2 = ""; # Set to "" if we have no second machine. Or set to second Resource
|
|
# minor EID to create mac-vlans on it.
|
|
|
|
|
|
# Port pairs. These are the ports that should be talking to each other.
|
|
# i.e. the third column in lf1_ports talks to the third column in lf2_ports.
|
|
# EIDs or aliases can be used.
|
|
# Port pairs must match on each shelf - will enhance to allow any pair on each shelf.
|
|
#my @lf1_ports = (1); #, 2, 3);
|
|
#my @lf2_ports = (2); #, 2, 3);
|
|
my @lf1_ports = ( "eth0", "eth1");
|
|
my @lf2_ports = ("");
|
|
my @ip_base = ( "192.168", "172.1");
|
|
my @ip_c = ( 2 , 1 );
|
|
my @ip_lsb = ( 2 , 2 );
|
|
my @msk = ("255.255.255.0","255.255.255.0");
|
|
my @ip_gw = ( "192.168.2.1", "172.1.1.1");
|
|
|
|
my $mac1 = 0x00; # Starting MAC address 00:m5:m4:m3:m2:m1 where:
|
|
my $mac2 = 0x00; # m5 is shelf EID, m4 is card EID, m3 is $mac3,
|
|
my $mac3 = 0x00; # m2 is $mac2 and m1 is $mac1.
|
|
|
|
|
|
my $start_mvlan = 0;
|
|
my $num_mvlans = 30;
|
|
my $num_cxs = 0;
|
|
|
|
my @min_rate = (19200);# bps
|
|
my @max_rate = (19200);# bps
|
|
my @min_pkt_szs = (948); # bytes
|
|
my @max_pkt_szs = (948); # bytes
|
|
|
|
##########################
|
|
# lf_max_cxs.pl specific #
|
|
##########################
|
|
|
|
my $max_delay = 100; # Maximum endpoint delay threshold in milliseconds.
|
|
my $percent_ep_delay = 3.0;# Percentage of endpoints allowed to exceed the
|
|
# $max_delay. Exceeding percentage will cause curren
|
|
# test loop to exit.
|
|
|
|
my $settle_time = 1; # Number of seconds to allow an endpoint to receive data
|
|
my $ep_rx_strikes = 3; # Number of strikes before declaring it failed.
|
|
|
|
my $sample_time_dly = 500; # Milliseconds between endpoint delay samples.
|
|
my $samples = 3;
|
|
|
|
my $use_udp_probe = 1;
|
|
my $use_udp_loss = 1;
|
|
my $end_udp_drop = 0;
|
|
|
|
#my $percentile = 97;
|
|
#my $filename = "delay_data.txt";
|
|
|
|
|
|
################
|
|
# Layer-4 only #
|
|
################
|
|
|
|
my $url_dl = 1; # If true, test will download from URL. False will upload to URL.
|
|
#my $l4_dl_path = "/tmp"; # Path to save downloaded file.
|
|
#my $l4_dl_path = "NUL"; # Windows equivalent of *nix /dev/null.
|
|
my $l4_dl_path = "/dev/null"; # Improve performance by saving downloaded file to /dev/null.
|
|
|
|
my @l4_urls = (
|
|
"http://192.168.100.3/index.html", "ftp://192.168.100.3/file", "http://192.168.100.3/index.html", "ftp://192.168.100.3/file"
|
|
,"http://192.168.100.3/index.html", "ftp://192.168.100.3/file", "http://192.168.100.3/index.html", "ftp://192.168.100.3/file"
|
|
,"http://192.168.100.3/index.html", "ftp://192.168.100.3/file", "http://192.168.100.3/index.html", "ftp://192.168.100.3/file"
|
|
,"http://192.168.100.3/index.html", "ftp://192.168.100.3/file", "http://192.168.100.3/index.html", "ftp://192.168.100.3/file"
|
|
,"http://192.168.100.3/index.html", "ftp://192.168.100.3/file", "http://192.168.100.3/index.html", "ftp://192.168.100.3/file"
|
|
);
|
|
#my @l4_urls = ("ftp://192.168.100.3/file");
|
|
|
|
my $urls_10m = 100; # How many URLs to process every 10 minutes.
|
|
my $l4_timeout = 10000; # How long to wait for a connection, in milliseconds.
|
|
|
|
|
|
###########
|
|
# File-IO #
|
|
###########
|
|
|
|
my $fio_base = "/mnt/fio_base";
|
|
my $fio_targ_dir = "";
|
|
my $fsrw = "write";
|
|
|
|
|
|
#########
|
|
# Debug #
|
|
#########
|
|
|
|
my $DEBUG = 0;
|
|
my $D_PAUSE = 3;
|
|
########################################################################
|
|
# Nothing to configure below here, most likely.
|
|
########################################################################
|
|
my $script_name = $0;
|
|
$sample_time_dly = $sample_time_dly * 1000;
|
|
|
|
# Parse cmd-line args
|
|
my $i;
|
|
my $j;
|
|
for ($i = 0; $i<@ARGV; $i++) {
|
|
my $var = $ARGV[$i];
|
|
if ($var =~ m/(\S+)=(.*)/) {
|
|
my $arg = $1;
|
|
my $val = $2;
|
|
handleCmdLineArg($arg, $val);
|
|
}
|
|
else {
|
|
handleCmdLineArg($var);
|
|
}
|
|
}
|
|
|
|
my $ss_wait
|
|
= 0.003 * $report_timer; # Increase delay (seconds) if experiencing problems on slow systems.
|
|
|
|
|
|
if ($lfmgr_host eq undef) {
|
|
print "\nYou must define a LANforge Manager!!!\n\n"
|
|
. "For example:\n"
|
|
. "./$script_name mgr=localhost\n"
|
|
. "OR\n"
|
|
. "./$script_name mgr=192.168.1.101\n\n";
|
|
printHelp();
|
|
exit (1);
|
|
}
|
|
|
|
my $foundL4 = 0;
|
|
for ($i = 0; $i<@cx_types; $i++) {
|
|
if ($cx_types[$i] eq "l4") {
|
|
$foundL4 = 1;
|
|
last;
|
|
}
|
|
}
|
|
if ($lf2 == "" && @lf1_ports < 2 && !$foundL4) {
|
|
die ("Must have more than one port with only one resource.");
|
|
}
|
|
|
|
#if (!$numvlan && !$num_cxs) {
|
|
# die ("Must have either number of MACVLANs (num_mvl) or cross-connects (num_cxs) > 0.");
|
|
#}
|
|
|
|
print
|
|
"\nStarting script with the following arguments:"
|
|
. "\ninit: $INIT"
|
|
. "\nmanager: $lfmgr_host\n"
|
|
. "\nlf1: $lf1\nlf2: $lf2\n"
|
|
. "\nlf1_ports: " . join(" ", @lf1_ports)
|
|
. "\nlf2_ports: " . join(" ", @lf2_ports) . "\n"
|
|
. "\nstart_macvlans: $start_mvlan"
|
|
. "\nnum_mvlans: $num_mvlans\n"
|
|
. "\nmin_rates: " . join(" ", @min_rate)
|
|
. "\nmax_rates: " . join(" ", @max_rate)
|
|
. "\nmin_pkt_sizes: " . join(" ", @min_pkt_szs)
|
|
. "\nmax_pkt_sizes: " . join(" ", @max_pkt_szs) . "\n"
|
|
. "\ncx_types: " . join(" ", @cx_types)
|
|
. "\none_cx_per_port: $one_cx_per_port\n\n";
|
|
|
|
if ($DEBUG) { sleep ($D_PAUSE); }
|
|
|
|
|
|
# Determine total port and endpoint counts and make sorting by name easier in the GUI :P
|
|
|
|
my @num = (); # Formatted index number for name sorting in GUI.
|
|
my $t_num = 0;
|
|
my $t_ports = 0;
|
|
my $ni=0;
|
|
my $nj=0;
|
|
|
|
my $lf2orig = $lf2;
|
|
|
|
if ($lf2 == "") {
|
|
$lf2 = $lf1;
|
|
if ($foundL4) {
|
|
@lf2_ports = undef;
|
|
}
|
|
else {
|
|
# put every other port into @lf2_ports to fake out lf2 info which makes the
|
|
# script work later.
|
|
my @lf1_ports_tmp = @lf1_ports;
|
|
@lf1_ports = undef;
|
|
@lf2_ports = undef;
|
|
$i=0;
|
|
for ($ni=0; $ni<@lf1_ports_tmp; $ni++) {
|
|
$lf1_ports[$i] = $lf1_ports_tmp[$ni];
|
|
$lf2_ports[$i] = $lf1_ports_tmp[++$ni];
|
|
$i++;
|
|
}
|
|
}
|
|
}
|
|
|
|
# Check that ip_base address pairs aren't the same.
|
|
for ($ni = 0; $ni<@ip_base; $ni++) {
|
|
if ($ip_base[$ni] == $ip_base[$ni+1]) {
|
|
die ("ERROR: Base IP addresses cannot be the same.");
|
|
}
|
|
$ni++;
|
|
}
|
|
|
|
my @cxts = ("lf", "lf_udp", "lf_tcp", "custom_udp", "custom_tcp", "l4",
|
|
"fileIONFS", "fileIOCIFS");
|
|
my @t_cxts = ();
|
|
for ($ni=0; $ni<@cxts; $ni++) {
|
|
@t_cxts[$ni] = 0;
|
|
}
|
|
|
|
if ($lf2orig ne "") {
|
|
if ($ignore_phys_ports) {
|
|
$t_ports = $num_mvlans;
|
|
}
|
|
else {
|
|
$t_ports = @lf1_ports + @lf2_ports + ($num_mvlans);
|
|
}
|
|
}
|
|
elsif ($num_mvlans) {
|
|
if ($ignore_phys_ports) {
|
|
$t_ports = $num_mvlans;
|
|
}
|
|
else {
|
|
$t_ports = @lf1_ports + ($num_mvlans);
|
|
}
|
|
}
|
|
else {
|
|
$t_ports = @lf1_ports + @lf2_ports;
|
|
}
|
|
|
|
my $t_cxtypes = @cx_types;
|
|
my $t_urls = @l4_urls;
|
|
|
|
if (@min_rate != @max_rate ) {
|
|
die("Number of elements in min_rate does not match number of elements in max_rate.");
|
|
}
|
|
else {
|
|
my $t_rate = @min_rate + @max_rate;
|
|
}
|
|
if (@min_pkt_szs != @max_pkt_szs ) {
|
|
die("Number of elements in min_pkt_szs does not match number of elements in max_pkt_szs.");
|
|
}
|
|
else {
|
|
my $t_pkt_szs = @min_pkt_szs + @max_pkt_szs;
|
|
}
|
|
|
|
for ($ni=0; $ni<@cx_types; $ni++) {
|
|
for ($nj=0; $nj<@cxts; $nj++) {
|
|
if ( $cx_types[$ni] eq $cxts[$nj] ) {
|
|
$t_cxts[$nj]++;
|
|
}
|
|
}
|
|
}
|
|
|
|
for ($nj=0; $nj<@cxts; $nj++) {
|
|
if ( $cxts[$nj] eq "l4") {
|
|
$t_num += ($t_ports * (2 * ($t_cxts[$nj] * $t_urls)));
|
|
}
|
|
else {
|
|
$t_num += ($t_ports * (2 * $t_cxts[$nj]));
|
|
}
|
|
}
|
|
$t_num += $name_id;
|
|
|
|
my $num_len;
|
|
if ($name_id_len) {
|
|
if (length($name_id) > $name_id_len || length($t_num) > $name_id_len) {
|
|
print "\nWARNING: id_len specifies a string length less that first_name_id or less that total number of endpoints\n";
|
|
}
|
|
$num_len = $name_id_len;
|
|
}
|
|
else {
|
|
$num_len = length ($t_num);
|
|
}
|
|
$t_num -= $name_id;
|
|
$i = 0;
|
|
switch ($num_len) {
|
|
case 1 {
|
|
for ($i ; $i<$t_num; $i++) {
|
|
$num[$i] = sprintf("%01d", $name_id + $i);
|
|
}
|
|
}
|
|
case 2 {
|
|
for ($i ; $i<$t_num; $i++) {
|
|
$num[$i] = sprintf("%02d", $name_id + $i);
|
|
}
|
|
}
|
|
case 3 {
|
|
for ($i ; $i<$t_num; $i++) {
|
|
$num[$i] = sprintf("%03d", $name_id + $i);
|
|
}
|
|
}
|
|
case 4 {
|
|
for ($i ; $i<$t_num; $i++) {
|
|
$num[$i] = sprintf("%04d", $name_id + $i);
|
|
}
|
|
}
|
|
case 5 {
|
|
for ($i ; $i<$t_num; $i++) {
|
|
$num[$i] = sprintf("%05d", $name_id + $i);
|
|
}
|
|
}
|
|
case 6 {
|
|
for ($i ; $i<$t_num; $i++) {
|
|
$num[$i] = sprintf("%06d", $name_id + $i);
|
|
}
|
|
}
|
|
else {
|
|
for ($i ; $i<$t_num; $i++) {
|
|
$num[$i] = $name_id + $i;
|
|
}
|
|
}
|
|
}
|
|
if ($DEBUG > 99) {
|
|
$i = 0;
|
|
print "name_id: $name_id, t_num: $t_num, num_len: $num_len :-\n";
|
|
for ($i ; $i<$t_num; $i++) {
|
|
print $num[$i] . " ";
|
|
}
|
|
print "\n";
|
|
sleep ($D_PAUSE);
|
|
}
|
|
if ($DEBUG) { printArgs(); sleep ($D_PAUSE); }
|
|
|
|
# Open connection to the LANforge server.
|
|
my $t = new Net::Telnet(Timeout => 15,
|
|
Prompt => '/default\@btbits\>\>/');
|
|
|
|
$t->open(Host => $lfmgr_host,
|
|
Port => $lfmgr_port,
|
|
Timeout => 60);
|
|
|
|
$t->waitfor("/btbits\>\>/");
|
|
$t->max_buffer_length(1024 * 1024 * 10); # 10M buffer
|
|
|
|
# Configure our utils.
|
|
my $utils = new LANforge::Utils();
|
|
$utils->telnet($t); # Set our telnet object.
|
|
$utils->cli_send_silent($quiet_cli_cmds); # Do not show input to CLI
|
|
$utils->cli_rcv_silent($quiet_cli_output); # Repress output from CLI ??
|
|
|
|
my $dt = getDate();
|
|
my $dt_start = $dt;
|
|
my $cmd;
|
|
|
|
my @t_cx_run_loop = ();
|
|
my @endpoint_names = (); #will be added to as they are created
|
|
my @cx_names = ();
|
|
my @ep_delay = ();
|
|
my $cx_run = 0;
|
|
my $avg_cx_run = 0;
|
|
my $t_cx_run = 0;
|
|
my $t_prcnt_ep_dly = 0;
|
|
my $avg_prcnt_ep_dly = 0;
|
|
my $eia = 0;
|
|
my $eib = 0;
|
|
my $ci = 0;
|
|
my $ep_dly_cnt = 0;
|
|
my $t_ep_dly_cnt = 0;
|
|
my $avg_ep_dly_cnt = 0;
|
|
my $prcnt_ep_dly = 0;
|
|
my $epa_rx = 0;
|
|
my $epb_rx = 0;
|
|
my $ep_delay = 0.0;
|
|
#my $epa_delay = 0;
|
|
#my $epb_delay = 0;
|
|
my $epa_drop = 0;
|
|
my $epb_drop = 0;
|
|
my $t_ep_run = 0;
|
|
my $prcnt_ep_dlyd = 0;
|
|
|
|
|
|
if ($init_stop_all) { doCmd("set_cx_state ALL ALL STOPPED"); }
|
|
|
|
$SIG{'INT'} = 'CLEANUP';
|
|
|
|
my $loop = 0;
|
|
for ($loop = 0; $loop<$loop_max; $loop++) {
|
|
$dt = getDate();
|
|
print "\n\n***** Starting $script_name at: $dt. Test Loop: ". ($loop+1) . " *****\n\n";
|
|
|
|
if (!$init_once) {
|
|
if ($INIT) { initToDefaults(); }
|
|
|
|
if ($init_net) {
|
|
addMacVlans(); # Add MACVLANs.
|
|
initIpAddresses(); # Add some IP addresses to the ports.
|
|
}
|
|
if ($init_tests) {
|
|
doCmd("rm_cx $test_mgr all");
|
|
doCmd("rm_endp YES_ALL");
|
|
doCmd("rm_test_mgr $test_mgr");
|
|
doCmd("add_tm $test_mgr");
|
|
doCmd("tm_register $test_mgr default"); # Add default user
|
|
doCmd("tm_register $test_mgr default_gui"); # Add default GUI user
|
|
addCrossConnects(); # Add our endpoints.
|
|
print "Done adding CXs.\n";
|
|
}
|
|
}
|
|
elsif ($first_run) {
|
|
if ($INIT) { initToDefaults(); }
|
|
|
|
if ($init_net) {
|
|
addMacVlans();
|
|
initIpAddresses();
|
|
}
|
|
if ($first_run && $init_tests) {
|
|
doCmd("rm_cx $test_mgr all");
|
|
doCmd("rm_endp YES_ALL");
|
|
doCmd("rm_test_mgr $test_mgr");
|
|
doCmd("add_tm $test_mgr");
|
|
doCmd("tm_register $test_mgr default"); # Add default user
|
|
doCmd("tm_register $test_mgr default_gui"); # Add default GUI user
|
|
addCrossConnects(); # Add our endpoints.
|
|
print "Done adding CXs.\n";
|
|
}
|
|
$first_run = 0;
|
|
}
|
|
|
|
if ($DEBUG) { printArgs(); }
|
|
$dt = getDate();
|
|
print "\n\n*** Started $script_name script at : $dt_start ***\n"
|
|
. "*** Finished $script_name configuration at: $dt ***\n\n";
|
|
sleep($D_PAUSE);
|
|
|
|
if ($create_only == 1) { exit(0); }
|
|
|
|
print "Wait $ss_wait seconds for ports to update.\n";
|
|
sleep($ss_wait);
|
|
|
|
#######################
|
|
# START lf_max_cxs.pl #
|
|
#######################
|
|
# Start Cross-Connects
|
|
my $endp = new LANforge::Endpoint();
|
|
for ($ci=0; $ci<@cx_names; $ci++) {
|
|
$cmd = "set_cx_state $test_mgr " . $cx_names[$ci] . " RUNNING";
|
|
doCmd($cmd);
|
|
$eia = 2 * $ci;
|
|
$eib = $eia + 1;
|
|
|
|
$ep_delay[$eia] = $ep_delay[$eib] = 0.0;
|
|
|
|
# check that the CX is passing packets
|
|
$utils->updateEndpoint($endp, $endpoint_names[$eia]);
|
|
$epa_rx = $endp->rx_pkts();
|
|
|
|
$utils->updateEndpoint($endp, $endpoint_names[$eib]);
|
|
$epb_rx = $endp->rx_pkts();
|
|
|
|
my $slp = 0;
|
|
$ep_delay = 0.0;
|
|
# $epa_delay = $epb_delay = 0;
|
|
while ($epa_rx == 0 || $epb_rx == 0) {
|
|
sleep($settle_time); # sleep to allow CX to connect
|
|
$slp++;
|
|
|
|
$utils->updateEndpoint($endp, $endpoint_names[$eia]);
|
|
$epa_rx = $endp->rx_pkts();
|
|
|
|
$utils->updateEndpoint($endp, $endpoint_names[$eib]);
|
|
$epb_rx = $endp->rx_pkts();
|
|
|
|
if ($slp > $ep_rx_strikes) {
|
|
# too long
|
|
print "WARNING: Waited too long on endpoint $ci to receive packet\n";
|
|
if ($epa_rx == 0) {
|
|
$ep_delay[$eia] = 999999;
|
|
}
|
|
if ($epb_rx == 0) {
|
|
$ep_delay[$eib] = 999999;
|
|
}
|
|
last; # for $ci
|
|
}
|
|
} # while
|
|
|
|
$cx_run++;
|
|
if ($DEBUG > 99) {
|
|
print "\n[DEBUG] cx_run: $cx_run\n";
|
|
}
|
|
print "Test Loop: " . ($loop+1) . "\n Processing data for " . ($eib+1) . " endpoints";
|
|
$ep_dly_cnt = 0;
|
|
for ($i=0; $i<=$eib; $i++) {
|
|
print ".";
|
|
# MIGHT MOVE UDP CHECK into loop so that tcp delay and udp loss or delay can be used.
|
|
# if UDP check CX for dropped packets
|
|
if ($use_udp_probe) {
|
|
if ($use_udp_loss) {
|
|
$utils->updateEndpoint($endp, $endpoint_names[0]);
|
|
$epa_drop = $endp->rx_dropped_pkts();
|
|
|
|
$utils->updateEndpoint($endp, $endpoint_names[1]);
|
|
$epb_drop = $endp->rx_dropped_pkts();
|
|
|
|
if (($epa_drop || $epb_drop) && $i == 0) { # If there are ANY dropped packets on UDP CX.
|
|
print "DROP ON PROBE ENDPOINT DETECTED";
|
|
if ($end_udp_drop) {
|
|
print "\nSTOP FURTHER PROCESSING !!!\n";
|
|
# Probably should refine this to have a drop threshold.
|
|
# $t_cx_run += $cx_run; # Average calculated later.
|
|
# $t_ep_run = $t_cx_run * 2; # Probably need more or different results now.
|
|
# Might add processing for all UDP CXs....
|
|
#save ep delays
|
|
last; # not sure but NOT for $i - need the next one to break out of for $i
|
|
}
|
|
}
|
|
#elsif ($ci > 0) {
|
|
# # Successfully added TCP CX, count it
|
|
# $cx_run++;
|
|
#}
|
|
}
|
|
# if UDP delay? Nothing special about delay wrt UDP - just loss is special
|
|
}
|
|
if ($end_udp_drop && ($epa_drop || $epb_drop)) {
|
|
last; # for $i
|
|
}
|
|
if ($endpoint_names[$eia] eq $endpoint_names[$i] || $endpoint_names[$eib] eq $endpoint_names[$i] ) {
|
|
for ($j=0; $j<$samples; $j++) {
|
|
$utils->updateEndpoint($endp, $endpoint_names[$i]);
|
|
$ep_delay += $endp->avg_latency();
|
|
# $epa_delay += $endp->avg_latency();
|
|
# $utils->updateEndpoint($endp, $endpoint_names[($i+1)]);
|
|
# $epb_delay += $endp->avg_latency();
|
|
if ($DEBUG > 1) {
|
|
print "\n[DEBUG] Sample#" . ($j+1) . ": ". $endpoint_names[$i] . " - ep_delay +=: $ep_delay ms\n"
|
|
# print "\n[DEBUG] Sample#" . ($j+1) . ": ". $endpoint_names[$i] . " - epa_delay: $epa_delay\n"
|
|
# . "[DEBUG] Sample#" . ($j+1) . ": ". $endpoint_names[($i+1)] . " - epb_delay: $epb_delay\n";
|
|
}
|
|
usleep ($sample_time_dly);
|
|
}
|
|
$ep_delay[$i] = $ep_delay / $samples;
|
|
} else {
|
|
$utils->updateEndpoint($endp, $endpoint_names[$i]);
|
|
$ep_delay = $endp->avg_latency();
|
|
$ep_delay[$i] = $ep_delay;
|
|
if ($DEBUG > 1 ) {
|
|
print "\n[DEBUG] Single sample ". $endpoint_names[$i] . " - ep_delay: $ep_delay ms\n";
|
|
}
|
|
# $epa_delay = $endp->avg_latency();
|
|
# $utils->updateEndpoint($endp, $endpoint_names[($i+1)]);
|
|
# $epb_delay = $endp->avg_latency();
|
|
}
|
|
# $ep_delay[($i+1)] = $epb_delay / $samples;
|
|
# $epa_delay = $epb_delay = 0;
|
|
$ep_delay = 0.0;
|
|
# if ($ep_delay[$i] > $max_delay || $ep_delay[($i+1)] > $max_delay) {
|
|
if ($ep_delay[$i] > $max_delay) {
|
|
$ep_dly_cnt++;
|
|
} # if $ep_delay > $max_delay
|
|
} # for $i Processing endpoint delay data
|
|
|
|
if ($end_udp_drop && ($epa_drop || $epb_drop)) {
|
|
print "\nSTOP FURTHER PROCESSING !!!\n";
|
|
last; # for $ci
|
|
}
|
|
|
|
$prcnt_ep_dly = ($ep_dly_cnt / ($eib+1)) * 100.0;
|
|
if ($prcnt_ep_dly > $percent_ep_delay) {
|
|
$t_cx_run += $cx_run;
|
|
$t_ep_run = $t_cx_run * 2.0;
|
|
$t_ep_dly_cnt += $ep_dly_cnt;
|
|
$t_prcnt_ep_dly += $prcnt_ep_dly;
|
|
print "\n\n PERCENT DELAY EXCEEDED!!!\n";
|
|
#if ($DEBUG > 99) {
|
|
print "\n";
|
|
for ($i=0; $i<=$eib; $i++) {
|
|
print " Delay Exceeded, Endpoint: " . $endpoint_names[$i] . ", Delay: ". $ep_delay[$i] . " ms\n";
|
|
}
|
|
print "\n ep_dly_cnt: $ep_dly_cnt, prcnt_ep_dly: $prcnt_ep_dly%"
|
|
. "\n loop: $loop"
|
|
. "\n t_cx_run: $t_cx_run, t_ep_dly_cnt: $t_ep_dly_cnt, t_prcnt_ep_dly: $t_prcnt_ep_dly"
|
|
. "\n";
|
|
sleep ($D_PAUSE);
|
|
#}
|
|
#$avg_ep_dly_cnt
|
|
#do something like write out the ep delay data to file
|
|
#wonder if there is a way to use internal perl sort on the delay and still keep the endpoint
|
|
#name correctly indexed.
|
|
|
|
last; # for $ci
|
|
}
|
|
# $ep_dly_cnt = 0; might need to transfer to average ep_dly_cnt for loops.
|
|
#perhaps, do array sort on delays don't see why if were checking for a certain percentage of delayed CXs
|
|
#sort would be slooow and painful
|
|
} #for $ci
|
|
$t_cx_run_loop[$loop] = $cx_run;
|
|
$cx_run = 0;
|
|
if ($keep_running) {
|
|
if ($loop < ($loop_max - 1)) {
|
|
doCmd("set_cx_state $test_mgr ALL STOPPED");
|
|
} else {
|
|
last; # for $loop
|
|
}
|
|
} else {
|
|
doCmd("set_cx_state $test_mgr ALL STOPPED");
|
|
}
|
|
|
|
# SHOULD probably get throughput data for each pass
|
|
# need to save off each loops results.
|
|
$epa_drop = $epb_drop = 0;
|
|
doCmd("clear_cx_counters ALL");
|
|
} #for $loop_max
|
|
|
|
#save endpoints delays to file
|
|
print "\n\n*** RESULTS ****\n\n";
|
|
$loop++;
|
|
if ($t_cx_run == 0 && $use_udp_probe) {
|
|
print "$cx_run connections were made.\n";
|
|
print "No dropped packets were detected on the UDP connection.\n";
|
|
print "Try increasing the number of connections.\n";
|
|
}
|
|
#elsif ($use_udp_probe) {
|
|
# $avg_cx_run = int($t_cx_run / $loop);
|
|
# print "\n$loop test loops completed.\n"
|
|
# . "Average number of simultaneous connections: $avg_cx_run\n";
|
|
#}
|
|
elsif ($t_cx_run == 0) {
|
|
# if ($DEBUG) {
|
|
for ($i=0; $i<$loop_max; $i++) {
|
|
print "Loop " . ($i+1) . ": " . $t_cx_run_loop[$i] . " simultaneous connections.\n";
|
|
}
|
|
# }
|
|
print "$cx_run connections were made.\n"
|
|
. "Less than $percent_ep_delay% of endpoints exceeded $max_delay ms of delay.\n"
|
|
. "Actual percentage of endpoints that exceeded $max_delay ms of delay is $prcnt_ep_dly%.\n"
|
|
. "Try increasing the number of connections.\n";
|
|
}
|
|
else {
|
|
$prcnt_ep_dlyd = ($t_ep_dly_cnt / $t_ep_run) * 100.0;
|
|
$avg_cx_run = ($t_cx_run / $loop);
|
|
$avg_ep_dly_cnt = ($t_ep_dly_cnt / $loop);
|
|
$avg_prcnt_ep_dly = ($t_prcnt_ep_dly / $loop);
|
|
my $mean_ep_dly = 0;
|
|
#for ($i=0; $i<=$eib; $i++) {
|
|
#my $t_ep_dly += $_ foreach @ep_delay;
|
|
#my $avg_ep_dly = $t_ep_dly /
|
|
|
|
#}
|
|
if ($DEBUG > 1) {
|
|
print "\n";
|
|
for ($i=0; $i<=$eib; $i++) {
|
|
print "[DEBUG] Endpoint: " . $endpoint_names[$i] . " - Delay: ". $ep_delay[$i] . " ms\n";
|
|
}
|
|
}
|
|
for ($i=0; $i<$loop_max; $i++) {
|
|
print "Loop " . ($i+1) . ": " . $t_cx_run_loop[$i] . " simultaneous connections.\n";
|
|
}
|
|
|
|
print "\n"
|
|
. "$loop test loops completed.\n\n"
|
|
. "Over $percent_ep_delay% of endpoints exceeded $max_delay ms of delay.\n\n"
|
|
. "Total number of endpoints that exceeded $max_delay ms is $t_ep_dly_cnt\n"
|
|
. "Total number of endpoints run $t_ep_run\n"
|
|
. "Total percentage of delayed endpoints $prcnt_ep_dlyd%\n\n"
|
|
. "Average number of simultaneous connections per test loop is $avg_cx_run\n"
|
|
. "Average percentage of endpoints that exceeded $max_delay ms of delay per test loop is $avg_prcnt_ep_dly%\n"
|
|
. "Average number of endpoints exceeding $max_delay ms per test loop is $avg_ep_dly_cnt"
|
|
. "\n";
|
|
}
|
|
|
|
|
|
if ($DEBUG) { printArgs(); }
|
|
|
|
$dt = getDate();
|
|
print "\nStarted $script_name script at : $dt_start\n";
|
|
print "Completed $script_name script at: $dt\n\n";
|
|
exit(0);
|
|
#####################
|
|
# END lf_macvlan.pl #
|
|
#####################
|
|
sub CLEANUP {
|
|
print "\n\n*** RESULTS ****\n\n";
|
|
#save endpoints delays to file
|
|
$loop++;
|
|
if ($t_cx_run == 0 && $use_udp_probe) {
|
|
print "$cx_run connections were made.\n";
|
|
print "No dropped packets were detected on the UDP connection.\n";
|
|
print "Try increasing the number of connections.\n";
|
|
}
|
|
#elsif ($use_udp_probe) {
|
|
# $avg_cx_run = int($t_cx_run / $loop);
|
|
# print "\n$loop test loops completed.\n"
|
|
# . "Average number of simultaneous connections: $avg_cx_run\n";
|
|
#}
|
|
elsif ($t_cx_run == 0) {
|
|
# if ($DEBUG) {
|
|
for ($i=0; $i<$loop_max; $i++) {
|
|
print "Loop " . ($i+1) . ": " . $t_cx_run_loop[$i] . " simultaneous connections.\n";
|
|
}
|
|
# }
|
|
print "$cx_run connections were made.\n"
|
|
. "Less than $percent_ep_delay% of endpoints exceeded $max_delay ms of delay.\n"
|
|
. "Actual percentage of endpoints that exceeded $max_delay ms of delay is $prcnt_ep_dly%.\n"
|
|
. "Try increasing the number of connections.\n";
|
|
}
|
|
else {
|
|
$prcnt_ep_dlyd = ($t_ep_dly_cnt / $t_ep_run) * 100.0;
|
|
$avg_cx_run = ($t_cx_run / $loop);
|
|
$avg_ep_dly_cnt = ($t_ep_dly_cnt / $loop);
|
|
$avg_prcnt_ep_dly = ($t_prcnt_ep_dly / $loop);
|
|
my $mean_ep_dly = 0;
|
|
#for ($i=0; $i<=$eib; $i++) {
|
|
#my $t_ep_dly += $_ foreach @ep_delay;
|
|
#my $avg_ep_dly = $t_ep_dly /
|
|
|
|
#}
|
|
if ($DEBUG > 1) {
|
|
print "\n";
|
|
for ($i=0; $i<=$eib; $i++) {
|
|
print "[DEBUG] Endpoint: " . $endpoint_names[$i] . " - Delay: ". $ep_delay[$i] . " ms\n";
|
|
}
|
|
}
|
|
for ($i=0; $i<$loop_max; $i++) {
|
|
print "Loop " . ($i+1) . ": " . $t_cx_run_loop[$i] . " simultaneous connections.\n";
|
|
}
|
|
|
|
print "\n"
|
|
. "$loop test loops completed.\n\n"
|
|
. "Over $percent_ep_delay% of endpoints exceeded $max_delay ms of delay.\n\n"
|
|
. "Total number of endpoints that exceeded $max_delay ms is $t_ep_dly_cnt\n"
|
|
. "Total number of endpoints run $t_ep_run\n"
|
|
. "Total percentage of delayed endpoints $prcnt_ep_dlyd%\n\n"
|
|
. "Average number of simultaneous connections per test loop is $avg_cx_run\n"
|
|
. "Average percentage of endpoints that exceeded $max_delay ms of delay per test loop is $avg_prcnt_ep_dly%\n"
|
|
. "Average number of endpoints exceeding $max_delay ms per test loop is $avg_ep_dly_cnt"
|
|
. "\n";
|
|
}
|
|
|
|
|
|
if ($DEBUG) { printArgs(); }
|
|
|
|
$dt = getDate();
|
|
print "\nStarted $script_name script at : $dt_start\n";
|
|
print "Exited $script_name script at: $dt\n\n";
|
|
|
|
exit (0);
|
|
} # CLEANUP
|
|
|
|
|
|
sub addCrossConnects {
|
|
my $ep = 0;
|
|
my $cx = 0;
|
|
my $i = 0;
|
|
my $szs = 0;
|
|
my $r = 0;
|
|
my @all_ports1 = @lf1_ports;
|
|
my @all_ports2 = ("");
|
|
my $j;
|
|
my $pname;
|
|
|
|
if ($foundL4) {
|
|
my $p1 = new LANforge::Port();
|
|
my $q;
|
|
for ($q = $start_mvlan; $q<($num_mvlans + $start_mvlan); $q++) {
|
|
for ($j = 0; $j<@lf1_ports; $j++) {
|
|
$utils->updatePort($p1, $shelf, $lf1, $lf1_ports[$j]);
|
|
$pname = $p1->{dev};
|
|
@all_ports1 = (@all_ports1, "$pname\#$q");
|
|
}
|
|
}
|
|
if ($ignore_phys_ports) {
|
|
for ($j = 0; $j<@lf1_ports; $j++) {
|
|
shift(@all_ports1);
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
for ($j = 0; $j<@lf1_ports; $j++) {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf1, $lf1_ports[$j]);
|
|
$pname = $p1->{dev};
|
|
my $q;
|
|
for ($q = $start_mvlan; $q<($num_mvlans + $start_mvlan); $q++) {
|
|
@all_ports1 = (@all_ports1, "$pname\#$q");
|
|
}
|
|
}
|
|
|
|
@all_ports2 = @lf2_ports;
|
|
for ($j = 0; $j<@lf2_ports; $j++) {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf2, $lf2_ports[$j]);
|
|
$pname = $p1->{dev};
|
|
my $q;
|
|
for ($q = $start_mvlan; $q<($num_mvlans + $start_mvlan); $q++) {
|
|
@all_ports2 = (@all_ports2, "$pname\#$q");
|
|
}
|
|
}
|
|
if ($ignore_phys_ports) {
|
|
for ($j = 0; $j<@lf1_ports; $j++) {
|
|
shift(@all_ports1);
|
|
}
|
|
for ($j = 0; $j<@lf2_ports; $j++) {
|
|
shift(@all_ports2);
|
|
}
|
|
}
|
|
}
|
|
|
|
print "\nCreating endpoints on " . @all_ports1 . " ports:\nall_ports1: " . join(" ", @all_ports1);
|
|
|
|
# if ($lf2orig ne "") {
|
|
print "\nCreating endpoints on " . @all_ports2 . " ports:\nall_ports2: " . join(" ", @all_ports2) . "\n\n";
|
|
# }
|
|
|
|
if ($DEBUG) { sleep($D_PAUSE); }
|
|
|
|
if ($one_cx_per_port) {
|
|
my $j = 0;
|
|
my $cxcnt = 0;
|
|
my $fecnt = 0;
|
|
for ($j ; $j<@all_ports1; $j++) {
|
|
my $i = $cxcnt % @cx_types;
|
|
$cxcnt++;
|
|
|
|
my $cxt = $cx_types[$i];
|
|
if ($cxt eq "l4") {
|
|
# Create layer-4 endpoint
|
|
|
|
my $ep1 = "L4-${num[$ep]}";
|
|
# $ep++;
|
|
my $ep2 = "D_L4-${num[$ep]}";
|
|
$ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
# Add the dummy endpoint
|
|
my $cmd = "add_l4_endp $ep2 $shelf $lf1 " . $all_ports1[$j]
|
|
. " l4_generic 0 0 0 ' ' ' '";
|
|
doCmd($cmd);
|
|
$cmd = "set_endp_flag $ep2 unmanaged 1";
|
|
doCmd($cmd);
|
|
|
|
if ($l4_dl_path = "/dev/null") {
|
|
$cmd = "add_l4_endp $ep1 $shelf $lf1 " . $all_ports1[$j]
|
|
. " l4_generic 0 $l4_timeout $urls_10m 'dl ${l4_urls[0]} $l4_dl_path' ' '";
|
|
}
|
|
else {
|
|
$cmd = "add_l4_endp $ep1 $shelf $lf1 " . $all_ports1[$j]
|
|
. " l4_generic 0 $l4_timeout $urls_10m 'dl ${l4_urls[0]} $l4_dl_path/$ep1' ' '";
|
|
}
|
|
doCmd($cmd);
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "L4-${num[$cx]}";
|
|
$cmd = "add_cx $cx_name $test_mgr $ep1 $ep2";
|
|
doCmd($cmd);
|
|
doCmd("set_cx_report_timer $test_mgr $cx_name $report_timer");
|
|
|
|
$cx++;
|
|
|
|
@cx_names = (@cx_names, $cx_name);
|
|
}# if L4
|
|
elsif (($cxt eq "fileIONFS") || ($cxt eq "fileIOCIFS")) {
|
|
# Create File-IO endpoint
|
|
|
|
my $FST = "nfs";
|
|
if ($cxt eq "fileIOCIFS") {
|
|
$FST = "cifs";
|
|
}
|
|
|
|
my $ep1 = "fe-${num[$fecnt]}";
|
|
my $ep2 = "D_$ep1";
|
|
$fecnt++;
|
|
$ep++;
|
|
# $ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
# Add the dummy endpoint
|
|
my $cmd = "add_file_endp $ep2 $shelf $lf1 " . $all_ports1[$j]
|
|
. " fe_generic $min_rate[$r] $max_rate[$r] $min_rate[$r] $max_rate[$r]"
|
|
. " increasing $fio_base/$ep2 $ep2";
|
|
doCmd($cmd);
|
|
$cmd = "set_endp_flag $ep2 unmanaged 1";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "add_file_endp $ep1 $shelf $lf1 " . $all_ports1[$j]
|
|
. " fe_generic $min_rate[$r] $max_rate[$r] $min_rate[$r] $max_rate[$r]"
|
|
. " increasing \'$fio_base/$FST"
|
|
. "_$all_ports1[$j]" . $fio_targ_dir . "\' $ep1";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_fe_info $ep1 16384 16384 10 1000000 1000000 \'$fio_base/$FST" . "_$all_ports1[$j]"
|
|
. $fio_targ_dir . "\' $ep1 $fsrw";
|
|
doCmd($cmd);
|
|
|
|
if ($r < (@min_rate - 1)) {
|
|
$r++;
|
|
}
|
|
else {
|
|
$r = 0;
|
|
}
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "L4-${num[$cx]}";
|
|
$cmd = "add_cx $cx_name $test_mgr $ep1 $ep2";
|
|
doCmd($cmd);
|
|
doCmd("set_cx_report_timer $test_mgr $cx_name $report_timer");
|
|
|
|
$cx++;
|
|
|
|
@cx_names = (@cx_names, $cx_name);
|
|
}# elsif FIO
|
|
else {
|
|
# Create L3 endpoint
|
|
|
|
my $burst = "NO";
|
|
if ($min_rate[$r] != $max_rate[$r]) {
|
|
$burst = "YES";
|
|
}
|
|
my $szrnd = "NO";
|
|
if ($min_pkt_szs[$szs] != $max_pkt_szs[$szs]) {
|
|
$szrnd = "YES";
|
|
}
|
|
|
|
my $pattern = "increasing";
|
|
if ($cx_types[$i] =~ /custom/) {
|
|
$pattern = "custom";
|
|
}
|
|
|
|
my $ep1 = "L3e-${num[$ep]}tx";
|
|
$ep++;
|
|
my $ep2 = "L3e-${num[$ep]}rx";
|
|
$ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
$cmd = "add_endp $ep1 $shelf $lf1 " . $all_ports1[$j] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate[$r] $max_rate[$r] $szrnd " . $min_pkt_szs[$szs] . " " . $max_pkt_szs[$szs] .
|
|
" $pattern NO";
|
|
doCmd($cmd);
|
|
|
|
if ($lf2 ne "") {
|
|
# die("Must have lf2 defined if using non-l4 endpoints.");
|
|
$cmd = "add_endp $ep2 $shelf $lf2 " . $all_ports2[$j] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate[$r] $max_rate[$r] $szrnd " . $min_pkt_szs[$szs] . " " .
|
|
$max_pkt_szs[$szs] . " $pattern NO";
|
|
}
|
|
else {
|
|
$cmd = "add_endp $ep2 $shelf $lf1 " . $all_ports1[($j)] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate[$r] $max_rate[$r] $szrnd " . $min_pkt_szs[$szs] . " " . $max_pkt_szs[$szs] .
|
|
" $pattern NO";
|
|
}
|
|
doCmd($cmd);
|
|
|
|
if ($szs < (@min_pkt_szs - 1)) { $szs++; }
|
|
else { $szs = 0; }
|
|
if ($r < (@min_rate - 1)) { $r++; }
|
|
else { $r = 0; }
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "L3-${num[$cx]}";
|
|
$cmd = "add_cx $cx_name $test_mgr $ep1 $ep2";
|
|
doCmd($cmd);
|
|
doCmd("set_cx_report_timer $test_mgr $cx_name $report_timer");
|
|
|
|
$cx++;
|
|
|
|
@cx_names = (@cx_names, $cx_name);
|
|
|
|
if ($use_udp_probe && $first_run) {
|
|
$first_run = 0;
|
|
# Delete first CX and related Endpoints.
|
|
doCmd("rm_cx $test_mgr $cx_names[0]");
|
|
doCmd("rm_endp $endpoint_names[0]");
|
|
doCmd("rm_endp $endpoint_names[1]");
|
|
|
|
# Add UDP CX as first CX.
|
|
|
|
$cmd = "add_endp $endpoint_names[0] $shelf $lf1 " . $all_ports1[0] . " lf_udp "
|
|
. " -1 $burst $min_rate[0] $max_rate[0] $szrnd " . $min_pkt_szs[0] . " "
|
|
. $max_pkt_szs[0] . " $pattern NO";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "add_endp $endpoint_names[1] $shelf $lf2 " . $all_ports2[0] . " lf_udp "
|
|
. " -1 $burst $min_rate[0] $max_rate[0] $szrnd " . $min_pkt_szs[0] . " "
|
|
. $max_pkt_szs[0] . " $pattern NO";
|
|
doCmd($cmd);
|
|
doCmd("add_cx $cx_names[0] $test_mgr $endpoint_names[0] $endpoint_names[1]");
|
|
doCmd("set_cx_report_timer $test_mgr $cx_names[0] 1000");
|
|
|
|
if ($DEBUG > 99) { sleep ($D_PAUSE); }
|
|
}
|
|
}# else L3
|
|
}#for all ports
|
|
}#one_cx_per_port = 1
|
|
else {
|
|
my $j = 0;
|
|
my $n = 0;
|
|
my $fecnt = 0;
|
|
for ($j; $j<@all_ports1; $j++) {
|
|
for ($i = 0; $i<@cx_types; $i++) {
|
|
my $cxt = $cx_types[$i];
|
|
if ($cxt eq "l4") {
|
|
# Create layer-4 endpoint
|
|
for ($n = 0; $n<@l4_urls; $n++) {
|
|
my $ep1 = "L4-${num[$ep]}";
|
|
# $ep++;
|
|
my $ep2 = "D_L4-${num[$ep]}";
|
|
$ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
# Add the dummy endpoint
|
|
my $cmd = "add_l4_endp $ep2 $shelf $lf1 " . $all_ports1[$j] . " l4_generic 0 0 0 ' ' ' '";
|
|
doCmd($cmd);
|
|
$cmd = "set_endp_flag $ep2 unmanaged 1";
|
|
doCmd($cmd);
|
|
if ($l4_dl_path = "/dev/null") {
|
|
$cmd = "add_l4_endp $ep1 $shelf $lf1 " . $all_ports1[$j]
|
|
. " l4_generic 0 $l4_timeout $urls_10m 'dl ${l4_urls[$n]} $l4_dl_path' ' '";
|
|
}
|
|
else {
|
|
$cmd = "add_l4_endp $ep1 $shelf $lf1 " . $all_ports1[$j]
|
|
. " l4_generic 0 $l4_timeout $urls_10m 'dl ${l4_urls[$n]} $l4_dl_path/$ep1' ' '";
|
|
}
|
|
doCmd($cmd);
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "L4-${num[$cx]}";
|
|
$cmd = "add_cx $cx_name $test_mgr $ep1 $ep2";
|
|
doCmd($cmd);
|
|
doCmd("set_cx_report_timer $test_mgr $cx_name $report_timer");
|
|
|
|
$cx++;
|
|
|
|
@cx_names = (@cx_names, $cx_name);
|
|
} #for url_list
|
|
}
|
|
elsif (($cxt eq "fileIONFS") || ($cxt eq "fileIOCIFS")) {
|
|
# Create File-IO endpoint
|
|
my $FST = "nfs";
|
|
if ($cxt eq "fileIOCIFS") {
|
|
$FST = "cifs";
|
|
}
|
|
|
|
my $ep1 = "fe-${num[$fecnt]}";
|
|
my $ep2 = "D_$ep1";
|
|
$fecnt++;
|
|
$ep++;
|
|
# $ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
# Add the dummy endpoint
|
|
my $cmd = "add_file_endp $ep2 $shelf $lf1 " . $all_ports1[$j]
|
|
. " fe_generic $min_rate[$r] $max_rate[$r] $min_rate[$r] $max_rate[$r]"
|
|
. " increasing $fio_base/$ep2 $ep2";
|
|
doCmd($cmd);
|
|
$cmd = "set_endp_flag $ep2 unmanaged 1";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "add_file_endp $ep1 $shelf $lf1 " . $all_ports1[$j]
|
|
. " fe_generic $min_rate[$r] $max_rate[$r] $min_rate[$r] $max_rate[$r]"
|
|
. " increasing $fio_base/$FST" . "_$all_ports1[$j]" . $fio_targ_dir . " $ep1";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_fe_info $ep1 16384 16384 10 1000000 1000000 $fio_base/$FST"
|
|
. "_$all_ports1[$j]" . $fio_targ_dir . " $ep1 $fsrw";
|
|
doCmd($cmd);
|
|
|
|
if ($r < (@min_rate - 1)) { $r++; }
|
|
else { $r = 0; }
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "L4-${num[$cx]}";
|
|
$cmd = "add_cx $cx_name $test_mgr $ep1 $ep2";
|
|
doCmd($cmd);
|
|
doCmd("set_cx_report_timer $test_mgr $cx_name $report_timer");
|
|
|
|
$cx++;
|
|
|
|
@cx_names = (@cx_names, $cx_name);
|
|
}
|
|
else {
|
|
# Create L3 endpoint
|
|
|
|
my $burst = "NO";
|
|
if ($min_rate[$r] != $max_rate[$r]) {
|
|
$burst = "YES";
|
|
}
|
|
my $szrnd = "NO";
|
|
if ($min_pkt_szs[$szs] != $max_pkt_szs[$szs]) {
|
|
$szrnd = "YES";
|
|
}
|
|
|
|
my $pattern = "increasing";
|
|
if ($cx_types[$i] =~ /custom/) {
|
|
$pattern = "custom";
|
|
}
|
|
|
|
my $ep1 = "L3e-${num[$ep]}tx";
|
|
$ep++;
|
|
my $ep2 = "L3e-${num[$ep]}rx";
|
|
$ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
$cmd = "add_endp $ep1 $shelf $lf1 " . $all_ports1[$j] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate[$r] $max_rate[$r] $szrnd " . $min_pkt_szs[$szs] . " " . $max_pkt_szs[$szs] .
|
|
" $pattern NO";
|
|
doCmd($cmd);
|
|
|
|
|
|
if ($lf2 ne "") {
|
|
# die("Must have lf2 defined if using non-l4 endpoints.");
|
|
$cmd = "add_endp $ep2 $shelf $lf2 " . $all_ports2[$j] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate[$r] $max_rate[$r] $szrnd " . $min_pkt_szs[$szs] . " " .
|
|
$max_pkt_szs[$szs] . " $pattern NO";
|
|
}
|
|
else {
|
|
$cmd = "add_endp $ep2 $shelf $lf1 " . $all_ports1[$j+1] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate[$r] $max_rate[$r] $szrnd " . $min_pkt_szs[$szs] . " " . $max_pkt_szs[$szs] .
|
|
" $pattern NO";
|
|
}
|
|
doCmd($cmd);
|
|
|
|
if ($szs < (@min_pkt_szs - 1)) { $szs++; }
|
|
else { $szs = 0; }
|
|
if ($r < (@min_rate - 1)) { $r++; }
|
|
else { $r = 0; }
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "L3-${num[$cx]}";
|
|
$cmd = "add_cx $cx_name $test_mgr $ep1 $ep2";
|
|
doCmd($cmd);
|
|
doCmd("set_cx_report_timer $test_mgr $cx_name $report_timer");
|
|
|
|
$cx++;
|
|
|
|
@cx_names = (@cx_names, $cx_name);
|
|
|
|
if ($use_udp_probe && $first_run) {
|
|
$first_run = 0;
|
|
# Delete first CX and related Endpoints.
|
|
doCmd("rm_cx $test_mgr $cx_names[0]");
|
|
doCmd("rm_endp $endpoint_names[0]");
|
|
doCmd("rm_endp $endpoint_names[1]");
|
|
|
|
# Add UDP CX as first CX.
|
|
|
|
$cmd = "add_endp $endpoint_names[0] $shelf $lf1 " . $all_ports1[0] . " lf_udp "
|
|
. " -1 $burst $min_rate[0] $max_rate[0] $szrnd " . $min_pkt_szs[0] . " "
|
|
. $max_pkt_szs[0] . " $pattern NO";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "add_endp $endpoint_names[1] $shelf $lf2 " . $all_ports2[0] . " lf_udp "
|
|
. " -1 $burst $min_rate[0] $max_rate[0] $szrnd " . $min_pkt_szs[0] . " "
|
|
. $max_pkt_szs[0] . " $pattern NO";
|
|
doCmd($cmd);
|
|
doCmd("add_cx $cx_names[0] $test_mgr $endpoint_names[0] $endpoint_names[1]");
|
|
doCmd("set_cx_report_timer $test_mgr $cx_names[0] 1000");
|
|
|
|
if ($DEBUG > 99) { sleep ($D_PAUSE); }
|
|
}
|
|
}
|
|
}#for cx types
|
|
}#for each port
|
|
}#each cx per port
|
|
}#addCrossConnects
|
|
sub initToDefaults {
|
|
# Clean up database if stuff exists
|
|
if ($DEBUG) {
|
|
print "\nsub initToDefaults\n";
|
|
}
|
|
doCmd("rm_cx $test_mgr all");
|
|
doCmd("rm_endp YES_ALL");
|
|
doCmd("rm_test_mgr $test_mgr");
|
|
|
|
initPortsToDefault();
|
|
}#initToDefaults
|
|
|
|
my $lsb1 = sprintf("%d", $mac1);
|
|
my $lsb2 = sprintf("%d", $mac2);
|
|
my $lsb3 = sprintf("%d", $mac3);
|
|
|
|
# Return a unique MAC address using last 3 octets
|
|
sub getNextMac {
|
|
$lsb1++;
|
|
if ($lsb1 > 255) {
|
|
$lsb2++;
|
|
$lsb1 = 0;
|
|
if ($lsb2 > 255) {
|
|
$lsb3++;
|
|
$lsb2 = 0;
|
|
if ($lsb3 > 255) {
|
|
print "*** WARNING, MAC address rolling over XX:YY:ZZ:ff:ff:ff ***\n";
|
|
$lsb3 = 0;
|
|
}
|
|
}
|
|
}
|
|
$mac1 = sprintf("%02x", $lsb1);
|
|
$mac2 = sprintf("%02x", $lsb2);
|
|
$mac3 = sprintf("%02x", $lsb3);
|
|
return "$mac3:$mac2:$mac1";
|
|
} # getNextMac
|
|
|
|
sub addMacVlans {
|
|
if ($DEBUG) {
|
|
print "\nsub addMacVlans\n";
|
|
}
|
|
if ($mac_init == 1 ) {
|
|
$lsb1 = sprintf("%d", $mac1);
|
|
$lsb2 = sprintf("%d", $mac2);
|
|
$lsb3 = sprintf("%d", $mac3);
|
|
}
|
|
my $i;
|
|
my $q;
|
|
my $pnum1;
|
|
my $pnum2;
|
|
my $throttle = $script_speed;
|
|
my $since_throttle = 0;
|
|
for ($i = $start_mvlan; $i<($num_mvlans + $start_mvlan); $i++) {
|
|
for ($q = 0; $q<@lf1_ports; $q++) {
|
|
|
|
$pnum1 = $lf1_ports[$q];
|
|
my $shlf = sprintf("%02x", $shelf);
|
|
my $card = sprintf("%02x", $lf1);
|
|
my $mac_index = getNextMac();
|
|
my $mac_addr = "00:$shlf:$card:$mac_index";
|
|
doCmd("add_mvlan $shelf $lf1 $pnum1 $mac_addr $i");
|
|
|
|
$pnum2 = $lf2_ports[$q];
|
|
if ($pnum2 ne "") {
|
|
$card = sprintf("%02x", $lf2);
|
|
$mac_index = getNextMac();
|
|
$mac_addr = "00:$shlf:$card:$mac_index";
|
|
doCmd("add_mvlan $shelf $lf2 $pnum2 $mac_addr $i");
|
|
}
|
|
if ($DEBUG > 1) { sleep($D_PAUSE); }
|
|
|
|
# Throttle ourself so we don't over-run the poor LANforge system.
|
|
if ($since_throttle++ > $throttle) {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf1, $pnum1);
|
|
if ($pnum2 ne "") {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf2, $pnum2);
|
|
}
|
|
$since_throttle = 0;
|
|
}
|
|
}
|
|
}
|
|
|
|
doCmd("probe_ports");
|
|
|
|
# Wait until we discover all the ports...
|
|
|
|
for ($q = 0; $q<@lf1_ports; $q++) {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf1, $lf1_ports[$q]);
|
|
my $pname = $p1->{dev};
|
|
|
|
my $p2 = new LANforge::Port();
|
|
my $pname2;
|
|
if ($pnum2 ne "") {
|
|
$utils->updatePort($p2, $shelf, $lf2, $lf2_ports[$q]);
|
|
$pname2 = $p2->{dev};
|
|
}
|
|
|
|
for ($i = $start_mvlan; $i<($num_mvlans + $start_mvlan); $i++) {
|
|
while (1) {
|
|
$utils->updatePort($p1, $shelf, $lf1, "$pname\#$i");
|
|
if ($pnum2 ne "") {
|
|
$utils->updatePort($p2, $shelf, $lf2, "$pname2\#$i");
|
|
}
|
|
if ($p1->isPhantom() || (($pnum2 ne "") && $p2->isPhantom())) {
|
|
sleep(1);
|
|
}
|
|
else {
|
|
last;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}#addMacVlans
|
|
|
|
# Wait until the system can update a port..
|
|
sub throttleCard {
|
|
my $s = shift;
|
|
my $c = shift;
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $s, $c, 1);
|
|
}#throttle
|
|
|
|
sub initPortsToDefault {
|
|
clearMacVlanPorts($shelf, $lf1);
|
|
if ($lf2orig ne "") {
|
|
clearMacVlanPorts($shelf, $lf2);
|
|
}
|
|
|
|
throttleCard($shelf, $lf1);
|
|
if ($lf2orig ne "") {
|
|
throttleCard($shelf, $lf2);
|
|
}
|
|
|
|
# Set all ports we are messing with to known state.
|
|
my $i = 0;
|
|
for ($i = 0; $i<@lf1_ports; $i++) {
|
|
my $tmp = $lf1_ports[$i];
|
|
my $tmp2 = $lf2_ports[$i];
|
|
if ($tmp ne "0") {
|
|
doCmd("set_port $shelf $lf1 $tmp 0.0.0.0 0.0.0.0 0.0.0.0 NA NA NA");
|
|
}
|
|
if ($lf2orig ne "") {
|
|
if ($tmp2 ne "0") {
|
|
doCmd("set_port $shelf $lf2 $tmp2 0.0.0.0 0.0.0.0 0.0.0.0 NA NA NA");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
sub clearMacVlanPorts {
|
|
my $s = shift;
|
|
my $c = shift;
|
|
|
|
my $i;
|
|
my $found_one = 1;
|
|
my @ports = ();
|
|
while ($found_one) {
|
|
$found_one = 0;
|
|
doCmd("probe_ports");
|
|
# Clear out any existing MAC-VLAN ports.
|
|
$utils->error("");
|
|
@ports = $utils->getPortListing($s, $c);
|
|
my $mx = @ports;
|
|
print "Found $mx ports for resource: $shelf.$lf1\n";
|
|
|
|
if (($mx == 0) || ($utils->error() =~ /Timed out/g)) {
|
|
# System is too backlogged to answer, wait a bit
|
|
print " Will try listing ports again in a few seconds...system is backlogged now!\n";
|
|
sleep(5);
|
|
$found_one = 1;
|
|
next;
|
|
}
|
|
|
|
my $throttle = 0;
|
|
for ($i = 0; $i<$mx; $i++) {
|
|
if ($ports[$i]->isMacVlan()) {
|
|
doCmd($ports[$i]->getDeleteCmd());
|
|
$found_one = 1;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
sub initIpAddresses {
|
|
# Set all ports we are messing with to known state.
|
|
my $i;
|
|
for ($i = 0; $i<@lf1_ports; $i++) {
|
|
|
|
# if ($ip_lsb > 250) {
|
|
# $ip_c++;
|
|
# $ip_lsb = 2;
|
|
# }
|
|
|
|
my $ptmp = $lf1_ports[$i];
|
|
my $ptmp2 = $lf2_ports[$i];
|
|
# my $cmd = "";
|
|
if (!$ignore_phys_ports) {
|
|
# $cmd = "set_port $shelf $lf1 $ptmp $ip_base1.$ip_c1.$ip_lsb1 $msk1 " .
|
|
# "$ip_gw1 NA NA NA";
|
|
$cmd = "set_port $shelf $lf1 $ptmp 0.0.0.0 0.0.0.0 0.0.0.0 NA NA NA";
|
|
if ($ptmp ne "") {
|
|
doCmd($cmd);
|
|
}
|
|
# $ip_lsb++;
|
|
if ($ptmp2 ne "") {
|
|
# $cmd = "set_port $shelf $lf2 $tmp2 $ip_base1.$ip_c1.$ip_lsb1 $msk1 " .
|
|
# "$ip_gw1 NA NA NA";
|
|
$cmd = "set_port $shelf $lf2 $ptmp2 0.0.0.0 0.0.0.0 0.0.0.0 NA NA NA";
|
|
doCmd($cmd);
|
|
# $ip_lsb++;
|
|
}
|
|
}
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf1, $ptmp);
|
|
my $pname = $p1->{dev};
|
|
|
|
my $q;
|
|
my $throttle = $script_speed;
|
|
my $since_throttle = 0;
|
|
|
|
for ($q = $start_mvlan; $q<($num_mvlans + $start_mvlan); $q++) {
|
|
$cmd = "set_port $shelf $lf1 $pname\#$q " .
|
|
"$ip_base[$i].$ip_c[$i].$ip_lsb[$i] $msk[$i] " .
|
|
"$ip_gw[$i] NA NA NA";
|
|
doCmd($cmd);
|
|
$ip_lsb[$i]++;
|
|
|
|
if ($ip_lsb[$i] > 250) {
|
|
$ip_c[$i]++;
|
|
$ip_lsb[$i] = 2;
|
|
}
|
|
|
|
if ($since_throttle++ > $throttle) {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf1, "$pname\#$q");
|
|
$since_throttle = 0;
|
|
}
|
|
}
|
|
|
|
# $ip_lsb++;
|
|
|
|
if ($ptmp2 ne "") {
|
|
$p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf2, $ptmp2);
|
|
$pname = $p1->{dev};
|
|
|
|
for ($q = $start_mvlan; $q<($num_mvlans + $start_mvlan); $q++) {
|
|
if (@ip_base == 1) {
|
|
$cmd = "set_port $shelf $lf2 $pname\#$q " .
|
|
"$ip_base[$i].$ip_c[$i].$ip_lsb[$i] $msk[$i] " .
|
|
"$ip_gw[$i] NA NA NA";
|
|
doCmd($cmd);
|
|
$ip_lsb[$i]++;
|
|
|
|
if ($ip_lsb[$i] > 250) {
|
|
$ip_c[$i]++;
|
|
$ip_lsb[$i] = 2;
|
|
}
|
|
}
|
|
else {
|
|
$cmd = "set_port $shelf $lf2 $pname\#$q " .
|
|
"$ip_base[$i+1].$ip_c[$i+1].$ip_lsb[$i+1] $msk[$i+1] " .
|
|
"$ip_gw[$i+1] NA NA NA";
|
|
doCmd($cmd);
|
|
$ip_lsb[$i+1]++;
|
|
|
|
if ($ip_lsb[$i+1] > 250) {
|
|
$ip_c[$i+1]++;
|
|
$ip_lsb[$i+1] = 2;
|
|
}
|
|
}
|
|
if ($since_throttle++ > $throttle) {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf2, "$pname\#$q");
|
|
$since_throttle = 0;
|
|
}
|
|
} # for $q
|
|
} # if we have an lf2_ports defined
|
|
}
|
|
}
|
|
|
|
sub doCmd {
|
|
my $cmd = shift;
|
|
|
|
print ">>> $cmd\n";
|
|
|
|
$t->print($cmd);
|
|
my @rslt = $t->waitfor('/ \>\>RSLT:(.*)/');
|
|
print "**************\n @rslt ................\n\n";
|
|
sleep($cli_cmd_delay);
|
|
}
|
|
|
|
sub getDate {
|
|
my $date = `date`;
|
|
chomp($date);
|
|
return $date
|
|
}
|
|
|
|
sub printArgs {
|
|
print
|
|
"\n$script_name"
|
|
. "\nModified arguments:"
|
|
. "\ninit: $INIT"
|
|
. "\nmanager: $lfmgr_host\n"
|
|
. "\nlf1: $lf1\nlf2: $lf2\n"
|
|
. "\nlf1_ports: " . join(" ", @lf1_ports)
|
|
. "\nlf2_ports: " . join(" ", @lf2_ports) . "\n"
|
|
. "\nstart_macvlans: $start_mvlan"
|
|
. "\nnum_mvlans: $num_mvlans\n"
|
|
. "\nmin_rates: " . join(" ", @min_rate)
|
|
. "\nmax_rates: " . join(" ", @max_rate)
|
|
. "\nmin_pkt_sizes: " . join(" ", @min_pkt_szs)
|
|
. "\nmax_pkt_sizes: " . join(" ", @max_pkt_szs) . "\n"
|
|
. "\ncx_types: " . join(" ", @cx_types)
|
|
. "\none_cx_per_port: $one_cx_per_port\n\n"
|
|
. "\n"
|
|
. "Available CX types: " . join(", ", @cxts) . "\n"
|
|
. "Total of each CX type: " . join(", ", @t_cxts) . "\n"
|
|
. "Total number of ports: $t_ports\n"
|
|
. "Total number of urls: " . @l4_urls . "\n"
|
|
. "Total number of endpoints and CXs: $t_num\n"
|
|
. "\n\n";
|
|
}
|
|
|
|
sub printHelp {
|
|
print
|
|
"\n$script_name\n"
|
|
. "USAGE: mgr=[ip-of-mgr] speed=[25|n] slowsys_wait=[0|n] DEBUG=[0|1|2|...] D_PAUSE=[3|n]\n"
|
|
. " config_once=[0|1] init=[0|1] init_net=[1|0] init_tests=[1|0] exit_running=[0|1]\n"
|
|
. " test_loops=[3|n] cli_cmd_dly=[0|1] quiet_cli_cmds=[0|1] quiet_cli_output=[0|1]\n"
|
|
. " test_mgr=\"ben_tm\" first_run=[1|0] rpt_timer=[9000|n]\n"
|
|
. " first_name_id=[0|n] id_len=[0|n]\n"
|
|
. " create_only=[0|1] one_cx_per_port=[0|1] ignore_phys_ports=[1|0]\n"
|
|
. " lf1=X lf2=Y\n"
|
|
. " lf1_ports=[\"1 2 3\"|\"eth2 eth3\"] lf2_ports=[\"4 5 6\"|\"eth4 eth5\"]\n"
|
|
. " start_mvl=X num_mvl=X\n"
|
|
. " mac3=0xf0 mac2=0xbe mac1=0xef\n"
|
|
. " ip_base= \"192.168 172.16\"\n"
|
|
. " ip_c = \"2 1\"\n"
|
|
. " ip_lsb = \"2 2\"\n"
|
|
. " ip_msk =\"255.255.0.0 255.255.0.0\"\n"
|
|
. " ip_gw =\"192.168.2.1 172.16.1.1\"\n"
|
|
. " cx_types=\"lf lf_udp lf_tcp custom_udp custom_tcp l4 fileIONFS fileIOCIFS\"\n"
|
|
. " min_rates=\"9600 56000 128000\" max_rates=\"56000 128000 25600\"\n"
|
|
. " min_pkt_sizes=\"500 500 500\" max_pkt_sizes=\"1000 1000 1000\"\n"
|
|
. " url_rate=100 l4_wait=10000\n"
|
|
. " urls=\"http://www.candelatech.com/file ftp://www.candelatech.com/file https://www.candelatech.com/file\"\n"
|
|
. " fsrw=[read|write] fio_targ_dir=tmp/ fio_base=/mnt/fio_base\n"
|
|
. "\n";
|
|
|
|
}
|
|
|
|
sub handleCmdLineArg {
|
|
my $arg = $_[0];
|
|
my $val = $_[1];
|
|
|
|
if ($arg eq "help" || $arg eq "--help" || $arg eq "-h" || $arg eq "-help" || $arg eq "-h" ) {
|
|
printHelp();
|
|
exit(0);
|
|
}
|
|
elsif ($arg eq "debug" || $arg eq "DEBUG") {
|
|
$DEBUG = $val;
|
|
}
|
|
elsif ($arg eq "d_pause" || $arg eq "D_PAUSE") {
|
|
$D_PAUSE = $val;
|
|
}
|
|
elsif ($arg eq "mgr") {
|
|
$lfmgr_host = $val;
|
|
}
|
|
elsif ($arg eq "test_mgr") {
|
|
$test_mgr = $val;
|
|
}
|
|
elsif ($arg eq "init") {
|
|
$INIT = $val;
|
|
}
|
|
elsif ($arg eq "config_once") {
|
|
$init_once = $val;
|
|
}
|
|
elsif ($arg eq "init_net") {
|
|
$init_net = $val;
|
|
}
|
|
elsif ($arg eq "init_tests") {
|
|
$init_tests = $val;
|
|
}
|
|
elsif ($arg eq "exit_running") {
|
|
$keep_running = $val;
|
|
}
|
|
elsif ($arg eq "test_loops") {
|
|
$loop_max = $val;
|
|
}
|
|
elsif ($arg eq "cli_cmd_dly") {
|
|
$cli_cmd_delay = $val;
|
|
}
|
|
elsif ($arg eq "quiet_cli_cmds") {
|
|
$quiet_cli_cmds = $val;
|
|
}
|
|
elsif ($arg eq "quiet_cli_output") {
|
|
$quiet_cli_output = $val;
|
|
}
|
|
elsif ($arg eq "first_run") {
|
|
$first_run = $val;
|
|
}
|
|
elsif ($arg eq "rpt_timer") {
|
|
$report_timer = $val;
|
|
}
|
|
elsif ($arg eq "first_name_id") {
|
|
$name_id = $val;
|
|
}
|
|
elsif ($arg eq "id_len") {
|
|
$name_id_len = $val;
|
|
if (length($name_id) > $name_id_len) {
|
|
print "\nWARNING: id_len specifies a string length less that first_name_id.\n";
|
|
}
|
|
}
|
|
elsif ($arg eq "speed") {
|
|
$script_speed = $val;
|
|
}
|
|
elsif ($arg eq "slowsys_wait") {
|
|
$ss_wait = $val;
|
|
}
|
|
elsif ($arg eq "lf1") {
|
|
$lf1 = $val;
|
|
}
|
|
elsif ($arg eq "lf2") {
|
|
$lf2 = $val;
|
|
if ($lf1 == $lf2) {
|
|
die("\nINVALID: First and second resource are the same !!!\n\n");
|
|
}
|
|
}
|
|
elsif ($arg eq "mac3") {
|
|
$mac3 = $val;
|
|
}
|
|
elsif ($arg eq "mac2") {
|
|
$mac2 = $val;
|
|
}
|
|
elsif ($arg eq "mac1") {
|
|
$mac1 = $val;
|
|
}
|
|
elsif ($arg eq "ip_base") {
|
|
@ip_base = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "ip_c") {
|
|
@ip_c = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "ip_lsb") {
|
|
@ip_lsb = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "ip_msk") {
|
|
@msk = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "ip_gw") {
|
|
@ip_gw = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "lf1_ports") {
|
|
@lf1_ports = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "lf2_ports") {
|
|
if ($lf2 == "" || $lf1 == $lf2) {
|
|
die("\nINVALID: Either second resource is not defined\nor first and second resource are the same !!!\n\n");
|
|
}
|
|
else {
|
|
@lf2_ports = split(/ /, $val);
|
|
}
|
|
}
|
|
elsif ($arg eq "cx_types") {
|
|
@cx_types = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "min_pkt_sizes") {
|
|
@min_pkt_szs = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "max_pkt_sizes") {
|
|
@max_pkt_szs = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "start_mvl") {
|
|
$start_mvlan = $val;
|
|
}
|
|
elsif ($arg eq "num_mvl") {
|
|
$num_mvlans = $val;
|
|
}
|
|
elsif ($arg eq "min_rates") {
|
|
@min_rate = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "max_rates") {
|
|
@max_rate = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "fsrw") {
|
|
$fsrw = $val;
|
|
}
|
|
elsif ($arg eq "fio_base") {
|
|
$fio_base = $val;
|
|
}
|
|
elsif ($arg eq "fio_targ_dir") {
|
|
$fio_targ_dir = $val;
|
|
}
|
|
elsif ($arg eq "urls") {
|
|
@l4_urls = split(/ /, $val);
|
|
}
|
|
elsif ($arg eq "url_rate") {
|
|
$urls_10m = $val;
|
|
}
|
|
elsif ($arg eq "l4_wait") {
|
|
$l4_timeout = $val;
|
|
}
|
|
elsif ($arg eq "one_cx_per_port") {
|
|
$one_cx_per_port = $val;
|
|
}
|
|
elsif ($arg eq "ignore_phys_ports") {
|
|
$ignore_phys_ports = $val;
|
|
}
|
|
elsif ($arg eq "create_only") {
|
|
$create_only = $val;
|
|
}
|
|
else {
|
|
print "\n\nCould not parse one or more of the arguments !!!\n"
|
|
. "First rejected argument: $arg\n";
|
|
printHelp();
|
|
exit(1);
|
|
}
|
|
}
|