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.
883 lines
22 KiB
Perl
Executable File
883 lines
22 KiB
Perl
Executable File
#!/usr/bin/perl
|
|
|
|
# This program is used to stress test the LANforge system, and may be used as
|
|
# an example for others who wish to automate LANforge tests.
|
|
|
|
# This script sets up connections of types:
|
|
# lf, lf_udp, lf_tcp, custom_ether, custom_udp, and custom_tcp
|
|
# across 1 real port and manny macvlan ports on 2 machines.
|
|
# It then continously starts and stops the connections.
|
|
|
|
# Un-buffer output
|
|
$| = 1;
|
|
|
|
use strict;
|
|
|
|
use Net::Telnet ();
|
|
use LANforge::Port;
|
|
use LANforge::Utils;
|
|
|
|
#my $lfmgr_host = "localhost";
|
|
my $lfmgr_host = "localhost";
|
|
my $lfmgr_port = 4001;
|
|
|
|
my $shelf = 1;
|
|
|
|
# set $STARTSTOP_LOOP = 1; to start and stop ALL endpoints after script finishes
|
|
# populating the database.
|
|
my $STARTSTOP_LOOP = 0;
|
|
|
|
# This sets up connections between 2 LANforge machines
|
|
#my $lf1 = 4; my $lf2 = 15; my @lf1_ports = (0); my @lf2_ports = (0);
|
|
|
|
# This sets up connections between 2 ports of a single machine;
|
|
# $lf1 and $lf2 are the minor number of the EIDs of the resource/card.
|
|
#my $lf1 = 4; my $lf2 = 4; my @lf1_ports = ("eth1"); my @lf2_ports = ("eth2");
|
|
my $lf1 = 16; my $lf2 = 16; my @lf1_ports = ("eth2"); my @lf2_ports = ("eth3");
|
|
|
|
my @mac3 = (1, 2);
|
|
|
|
|
|
my $ignore_phys_ports = 1; # If 1, just muck with mac-vlans instead.
|
|
my $ip_base = "172.1";
|
|
my $ip_lsb = 2;
|
|
my $ip_c = 2;
|
|
my $msk = "255.255.0.0";
|
|
|
|
# The number of macvlans is dependant on the number for port used.
|
|
# e.g. if two ports used, eth2 and eth3 then the number of vlans
|
|
# for 120 virtual hosts would be 60 since they will be evenly distributed
|
|
# between eth2 and eth3.
|
|
my $num_macvlans = 60;
|
|
my $codec = "g729a"; # Other options: G711U, SPEEX, g726-16, g726-24, g726-32, g726-40
|
|
#my $codec = "G711U"; # Other options: G711U, SPEEX, g726-16, g726-24, g726-32, g726-40
|
|
|
|
my $mn_icg = 3; # minimum intercall gap
|
|
my $mx_icg = 3; # maximum intercall gap
|
|
my $min_call_duration = 0; # set to zero for 'file'
|
|
my $max_call_duration = 0; # Set to zero for 'file'
|
|
|
|
my $no_send_rtp = 0; # Set to zero to send RTP traffic, 1 to suppress RTP
|
|
my $use_VAD = 0; # Set to zero to not use VAD, 1 to use VAD
|
|
my $vad_timer = 500; # how much silence (ms) before we start VAD (Silence Suppression)
|
|
my $vad_fs = 3000; # how often (ms) to force an rtp pkt send even if we are in VAD
|
|
my $use_PESQ = 0; # Set to 1 for PESQ, zero for not PESQ
|
|
my $pesq_server = "127.0.0.1";
|
|
my $pesq_server_port = 3998;
|
|
my $vproto = "SIP";
|
|
#my $vproto = "H323";
|
|
|
|
# If zero, will have one of EACH of the cx types on each port.
|
|
#my $one_cx_per_port = 1;
|
|
my $one_cx_per_port = 0;
|
|
|
|
#my @cx_types = ("", "lf_udp", "lf_tcp", "custom_udp", "custom_tcp", "l4");
|
|
#my @min_pkt_szs = (64, 1, 1, 1, 1, 0);
|
|
#my @max_pkt_szs = (1514, 12000, 13000, 2048, 2048, 0);
|
|
|
|
# Layer-4 only
|
|
#my @cx_types = ("l4", "l4");
|
|
#my @min_pkt_szs = (0, 0);
|
|
#my @max_pkt_szs = (0, 0);
|
|
|
|
# VOIP only
|
|
#my @cx_types = ("voip", "voip", "voip", "voip");
|
|
#my @min_pkt_szs = (0, 0, 0, 0);
|
|
#my @max_pkt_szs = (0, 0, 0, 0);
|
|
my @cx_types = ("voip");
|
|
my @min_pkt_szs = (0);
|
|
my @max_pkt_szs = (0);
|
|
|
|
my $peer_to_peer_voip = 1; # Don't register with SIP proxy, but just call peer to peer.
|
|
|
|
my @src_sound_files = ("media/female_voice_8khz.wav");
|
|
|
|
# URL will be acted on from machine $lf1
|
|
#my $l4_url = "http://172.1.5.75";
|
|
my $l4_url = "http://172.1.2.3"; # not used in lf_voip.pl script but makes it work
|
|
|
|
my $min_rate = 64000; # not used in lf_voip.pl script but makes it work
|
|
my $max_rate = 512000; # not used in lf_voip.pl script but makes it work
|
|
|
|
my $test_mgr = "voip_tm";
|
|
|
|
my $loop_max = 100;
|
|
my $start_stop_iterations = 100;
|
|
my $run_for_time = 1200; # Run for XX seconds..then will be stopped again
|
|
my $stop_for_time = 5; # Run for XX seconds..then will be stopped again
|
|
my $report_timer = 5000; # 8 seconds
|
|
|
|
|
|
########################################################################
|
|
# Nothing to configure below here, most likely.
|
|
########################################################################
|
|
|
|
my @endpoint_names = (); #will be added to as they are created
|
|
my @cx_names = ();
|
|
|
|
# Open connection to the LANforge server.
|
|
|
|
my $t = new Net::Telnet(Prompt => '/default\@btbits\>\>/');
|
|
|
|
|
|
$t->open(Host => $lfmgr_host,
|
|
Port => $lfmgr_port,
|
|
Timeout => 45);
|
|
|
|
$t->waitfor("/btbits\>\>/");
|
|
|
|
# Configure our utils.
|
|
my $utils = new LANforge::Utils();
|
|
$utils->telnet($t); # Set our telnet object.
|
|
$utils->cli_send_silent(0); # Do show input to CLI
|
|
$utils->cli_rcv_silent(0); # Repress output from CLI ??
|
|
|
|
|
|
my $dt = "";
|
|
|
|
my $loop = 0;
|
|
for ($loop = 0; $loop<$loop_max; $loop++) {
|
|
$dt = `date`;
|
|
chomp($dt);
|
|
print "\n\n***** Starting loop: $loop at: $dt *****\n\n";
|
|
|
|
initToDefaults();
|
|
#exit(0);
|
|
|
|
# Now, add back the test manager we will be using
|
|
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
|
|
|
|
addMacVlans();
|
|
|
|
# Add some IP addresses to the ports
|
|
initIpAddresses();
|
|
|
|
# Add our endpoints
|
|
addCrossConnects();
|
|
|
|
if ($STARTSTOP_LOOP) {
|
|
my $rl = 0;
|
|
for ($rl = 0; $rl<$start_stop_iterations; $rl++) {
|
|
if (($rl % 2) == 0) {
|
|
doCmd("set_cx_state $test_mgr all RUNNING");
|
|
}
|
|
else {
|
|
# Do one at a time
|
|
my $q = 0;
|
|
for ($q = 0; $q<@cx_names; $q++) {
|
|
my $cmd = "set_cx_state $test_mgr " . $cx_names[$q] . " RUNNING";
|
|
doCmd($cmd);
|
|
}
|
|
}
|
|
|
|
print "Done starting endpoints...sleeping $run_for_time seconds.\n";
|
|
sleep($run_for_time);
|
|
|
|
# Now, stop them...
|
|
|
|
if (($rl % 2) == 0) {
|
|
doCmd("set_cx_state $test_mgr all STOPPED");
|
|
}
|
|
else {
|
|
# Do one at a time
|
|
my $q = 0;
|
|
for ($q = 0; $q<@cx_names; $q++) {
|
|
my $cmd = "set_cx_state $test_mgr " . $cx_names[$q] . " STOPPED";
|
|
doCmd($cmd);
|
|
}
|
|
}
|
|
sleep($stop_for_time);
|
|
}# For some amount of start_stop iterations...
|
|
}# STARTSTOP_LOOP
|
|
else {
|
|
$dt = `date`;
|
|
chomp($dt);
|
|
print "Done at: $dt\n\n";
|
|
exit(0);
|
|
}# STARTSTOP_LOOP
|
|
}# for some amount of loop iterations
|
|
|
|
$dt = `date`;
|
|
chomp($dt);
|
|
print "Done at: $dt\n\n";
|
|
exit(0);
|
|
|
|
|
|
sub initToDefaults {
|
|
# Clean up database if stuff exists
|
|
|
|
doCmd("rm_cx $test_mgr all");
|
|
doCmd("rm_endp YES_ALL");
|
|
doCmd("rm_test_mgr $test_mgr");
|
|
|
|
initPortsToDefault();
|
|
}#initToDefaults
|
|
|
|
|
|
sub addMacVlans {
|
|
my $i;
|
|
my $q;
|
|
|
|
my $v;
|
|
my $lsb = 10;
|
|
my $lsb2 = 10;
|
|
|
|
my $throttle = 25;
|
|
my $since_throttle = 0;
|
|
for ($q = 0; $q<@lf1_ports; $q++) {
|
|
my $pnum1 = $lf1_ports[$q];
|
|
my $pnum2 = $lf2_ports[$q];
|
|
for ($i = 0; $i<$num_macvlans; $i++) {
|
|
|
|
$lsb++;
|
|
if ($lsb > 99) {
|
|
$lsb2++;
|
|
$lsb = 2;
|
|
}
|
|
|
|
my $s2 = $shelf+10;
|
|
my $c2 = $lf1+10;
|
|
my $p2 = $mac3[0] + 10;
|
|
my $mc = "00:$s2:$c2:$p2:$lsb2:$lsb";
|
|
doCmd("add_mvlan $shelf $lf1 $pnum1 $mc");
|
|
|
|
if ($lf2 ne "") {
|
|
$c2 = $lf2+10;
|
|
$p2 = $mac3[1] + 10;
|
|
$mc = "00:$s2:$c2:$p2:$lsb2:$lsb";
|
|
doCmd("add_mvlan $shelf $lf2 $pnum2 $mc");
|
|
|
|
# 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);
|
|
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf2, $pnum2);
|
|
$since_throttle = 0;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
doCmd("probe_ports");
|
|
|
|
# Wait untill 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 ($lf2 ne "") {
|
|
$utils->updatePort($p2, $shelf, $lf2, $lf2_ports[$q]);
|
|
$pname2 = $p2->{dev};
|
|
}
|
|
|
|
for ($i = 0; $i<$num_macvlans; $i++) {
|
|
while (1) {
|
|
$utils->updatePort($p1, $shelf, $lf1, "$pname\#$i");
|
|
if ($lf2 ne "") {
|
|
$utils->updatePort($p2, $shelf, $lf2, "$pname2\#$i");
|
|
}
|
|
if ($p1->isPhantom() || (($lf2 ne "") && $p2->isPhantom())) {
|
|
sleep(1);
|
|
}
|
|
else {
|
|
last;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
}#addMacVlans
|
|
|
|
|
|
# Wait untill the system can update a port..
|
|
sub throttleCard {
|
|
my $s = shift;
|
|
my $c = shift;
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $s, $c, 0);
|
|
}#throttle
|
|
|
|
sub initPortsToDefault {
|
|
clearMacVlanPorts($shelf, $lf1);
|
|
if ($lf2 ne "") {
|
|
clearMacVlanPorts($shelf, $lf2);
|
|
}
|
|
|
|
throttleCard($shelf, $lf1);
|
|
|
|
if ($lf2 ne "") {
|
|
throttleCard($shelf, $lf2);
|
|
}
|
|
|
|
# Set all ports we are messing with to known state.
|
|
if (!$ignore_phys_ports) {
|
|
my $i = 0;
|
|
for ($i = 0; $i<@lf1_ports; $i++) {
|
|
my $tmp = $lf1_ports[$i];
|
|
my $tmp2 = $lf2_ports[$i];
|
|
doCmd("set_port $shelf $lf1 $tmp 0.0.0.0 0.0.0.0 0.0.0.0 NA NA NA");
|
|
if ($lf2 ne "") {
|
|
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;
|
|
my $wait_for_phantom = 0;
|
|
for ($i = 0; $i<$mx; $i++) {
|
|
if ($ports[$i]->isMacVlan()) {
|
|
if ($ports[$i]->isPhantom()) {
|
|
# Wait a bit..hopefully it will go away.
|
|
if ($wait_for_phantom++ < 20) {
|
|
print "Sleeping a bit, found a phantom port.";
|
|
sleep(5);
|
|
doCmd("probe_ports");
|
|
$found_one = 1;
|
|
}
|
|
}
|
|
else {
|
|
doCmd($ports[$i]->getDeleteCmd());
|
|
$found_one = 1;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
sub initIpAddresses {
|
|
# Set all ports we are messing with to known state.
|
|
my $i = 0;
|
|
for ($i = 0; $i<@lf1_ports; $i++) {
|
|
|
|
if ($ip_lsb > 250) {
|
|
$ip_c++;
|
|
$ip_lsb = 2;
|
|
}
|
|
|
|
my $tmp = $lf1_ports[$i];
|
|
my $tmp2 = $lf2_ports[$i];
|
|
my $cmd = "";
|
|
if (!$ignore_phys_ports) {
|
|
$cmd = "set_port $shelf $lf1 $tmp $ip_base.$ip_c.$ip_lsb $msk " .
|
|
"$ip_base.1.1 NA NA NA";
|
|
doCmd($cmd);
|
|
$ip_lsb++;
|
|
|
|
if ($lf2 ne "") {
|
|
$cmd = "set_port $shelf $lf2 $tmp2 $ip_base.$ip_c.$ip_lsb $msk " .
|
|
"$ip_base.1.1 NA NA NA";
|
|
doCmd($cmd);
|
|
$ip_lsb++;
|
|
}
|
|
}
|
|
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf1, $tmp);
|
|
my $pname = $p1->{dev};
|
|
|
|
my $q;
|
|
my $throttle = 25;
|
|
my $since_throttle = 0;
|
|
for ($q = 0; $q<$num_macvlans; $q++) {
|
|
$cmd = "set_port $shelf $lf1 $pname\#$q $ip_base.$ip_c.$ip_lsb $msk " .
|
|
"$ip_base.1.1 NA NA NA NA 400";
|
|
doCmd($cmd);
|
|
$ip_lsb++;
|
|
|
|
if ($ip_lsb > 250) {
|
|
$ip_c++;
|
|
$ip_lsb = 2;
|
|
}
|
|
|
|
if ($since_throttle++ > $throttle) {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf1, "$pname\#$q");
|
|
$since_throttle = 0;
|
|
}
|
|
|
|
}
|
|
|
|
$ip_lsb++;
|
|
|
|
if ($lf2 ne "") {
|
|
$p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf2, $tmp2);
|
|
$pname = $p1->{dev};
|
|
|
|
for ($q = 0; $q<$num_macvlans; $q++) {
|
|
$cmd = "set_port $shelf $lf2 $pname\#$q $ip_base.$ip_c.$ip_lsb $msk " .
|
|
"$ip_base.1.1 NA NA NA NA 400";
|
|
doCmd($cmd);
|
|
$ip_lsb++;
|
|
|
|
if ($ip_lsb > 250) {
|
|
$ip_c++;
|
|
$ip_lsb = 2;
|
|
}
|
|
|
|
if ($since_throttle++ > $throttle) {
|
|
my $p1 = new LANforge::Port();
|
|
$utils->updatePort($p1, $shelf, $lf2, "$pname\#$q");
|
|
$since_throttle = 0;
|
|
}
|
|
}
|
|
}# If we have an LF-2 defined.
|
|
}
|
|
}
|
|
|
|
sub addCrossConnects {
|
|
my $ep = 0;
|
|
my $cx = 0;
|
|
my $i = 0;
|
|
|
|
my $voip_phone = 3000; # Start here and count on up as needed.
|
|
my $rtp_port = 10000; # Starting RTP port.
|
|
my $sound_file_idx = 0;
|
|
|
|
my @all_ports1 = @lf1_ports;
|
|
my $j;
|
|
my $pname;
|
|
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 = 0; $q<$num_macvlans; $q++) {
|
|
@all_ports1 = (@all_ports1, "$pname\#$q");
|
|
}
|
|
}
|
|
|
|
my @all_ports2 = @lf2_ports;
|
|
if ($lf2 ne "") {
|
|
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 = 0; $q<$num_macvlans; $q++) {
|
|
@all_ports2 = (@all_ports2, "$pname\#$q");
|
|
}
|
|
}
|
|
}
|
|
|
|
print "About to start endpoints, all_ports1:\n" . join(" ", @all_ports1) .
|
|
"\nall_ports2: " . join(" ", @all_ports2) . "\n\n";
|
|
|
|
if ($one_cx_per_port) {
|
|
my $j = 0;
|
|
my $cxcnt = 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 = "l4e-${ep}-TX";
|
|
$ep++;
|
|
my $ep2 = "D_l4e-${ep}-TX";
|
|
$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);
|
|
|
|
$cmd = "add_l4_endp $ep1 $shelf $lf1 " . $all_ports1[$j] . " l4_generic 0 10000 100 '" .
|
|
"dl $l4_url /tmp/$ep1' ' '";
|
|
doCmd($cmd);
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "l4-cx-${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 ($cxt eq "voip") {
|
|
# Create VOIP endpoint
|
|
|
|
my $ep1 = "rtpe-${ep}-TX";
|
|
$ep++;
|
|
my $ep2 = "rtpe-${ep}-RX";
|
|
$ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
my $cmd = "add_voip_endp $ep2 $shelf $lf2 " . $all_ports2[$j] .
|
|
" $voip_phone $rtp_port AUTO " .
|
|
$src_sound_files[$sound_file_idx % @src_sound_files] .
|
|
" " . $src_sound_files[$sound_file_idx % @src_sound_files] .
|
|
".$ep2 $vad_timer $vad_fs";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_voip_info $ep2 NA $mn_icg $mx_icg NA $codec $vproto NA NA $min_call_duration $max_call_duration /dev/null 20000 NA $pesq_server $pesq_server_port NA";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_endp_flag $ep2 SavePCM 0";
|
|
doCmd($cmd);
|
|
if ($peer_to_peer_voip) {
|
|
$cmd = "set_endp_flag $ep2 DoNotRegister 1";
|
|
doCmd($cmd);
|
|
$cmd = "set_endp_flag $ep2 BindSIP 1";
|
|
doCmd($cmd);
|
|
}
|
|
if ($no_send_rtp) {
|
|
$cmd = "set_endp_flag $ep2 nosendrtp 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
if ($use_VAD) {
|
|
$cmd = "set_endp_flag $ep2 VAD 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
if ($use_PESQ) {
|
|
$cmd = "set_endp_flag $ep2 pesq 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
$voip_phone++;
|
|
$rtp_port += 2;
|
|
$sound_file_idx++;
|
|
|
|
doCmd($cmd);
|
|
|
|
$cmd = "add_voip_endp $ep1 $shelf $lf1 " . $all_ports1[$j] .
|
|
" $voip_phone $rtp_port AUTO " .
|
|
$src_sound_files[$sound_file_idx % @src_sound_files] .
|
|
" " . $src_sound_files[$sound_file_idx % @src_sound_files] .
|
|
".$ep1 $vad_timer $vad_fs";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_voip_info $ep1 NA $mn_icg $mx_icg NA $codec $vproto NA NA $min_call_duration $max_call_duration /dev/null 20000 NA $pesq_server $pesq_server_port NA";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_endp_flag $ep1 SavePCM 0";
|
|
doCmd($cmd);
|
|
|
|
if ($peer_to_peer_voip) {
|
|
$cmd = "set_endp_flag $ep1 DoNotRegister 1";
|
|
doCmd($cmd);
|
|
$cmd = "set_endp_flag $ep1 BindSIP 1";
|
|
doCmd($cmd);
|
|
}
|
|
if ($no_send_rtp) {
|
|
$cmd = "set_endp_flag $ep1 nosendrtp 1";
|
|
doCmd($cmd);
|
|
}
|
|
if ($use_VAD) {
|
|
$cmd = "set_endp_flag $ep1 VAD 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
if ($use_PESQ) {
|
|
$cmd = "set_endp_flag $ep1 pesq 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
$voip_phone++;
|
|
$rtp_port += 2;
|
|
$sound_file_idx++;
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "rtp-cx-${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 {
|
|
my $burst = "NO";
|
|
if ($min_rate != $max_rate) {
|
|
$burst = "YES";
|
|
}
|
|
my $szrnd = "NO";
|
|
if ($min_pkt_szs[$i] != $max_pkt_szs[$i]) {
|
|
$szrnd = "YES";
|
|
}
|
|
|
|
my $pattern = "increasing";
|
|
if ($cx_types[$i] =~ /custom/) {
|
|
$pattern = "custom";
|
|
}
|
|
|
|
my $ep1 = "l3e-${ep}-TX";
|
|
$ep++;
|
|
my $ep2 = "l3e-${ep}-RX";
|
|
$ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
my $cmd = "add_endp $ep1 $shelf $lf1 " . $all_ports1[$j] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate $max_rate $szrnd " . $min_pkt_szs[$i] . " " . $max_pkt_szs[$i] .
|
|
" $pattern NO";
|
|
doCmd($cmd);
|
|
|
|
|
|
if ($lf2 == "") {
|
|
die("Must lave lf2 defined if using non-l4 endpoints.");
|
|
}
|
|
|
|
$cmd = "add_endp $ep2 $shelf $lf2 " . $all_ports2[$j] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate $max_rate $szrnd " . $min_pkt_szs[$i] . " " .
|
|
$max_pkt_szs[$i] . " $pattern NO";
|
|
doCmd($cmd);
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "l3-cx-${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 all ports
|
|
}#one_cx_per_port
|
|
else {
|
|
my $j = 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
|
|
|
|
my $ep1 = "l4e-${ep}-TX";
|
|
$ep++;
|
|
my $ep2 = "D_l4e-${ep}-TX";
|
|
$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);
|
|
|
|
$cmd = "add_l4_endp $ep1 $shelf $lf1 " . $all_ports1[$j] . " l4_generic 0 10000 100 '" .
|
|
"dl $l4_url /tmp/$ep1' ' '";
|
|
doCmd($cmd);
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "l4-cx-${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 ($cxt eq "voip") {
|
|
# Create VOIP endpoint
|
|
|
|
my $ep1 = "RTPE-${ep}-TX";
|
|
$ep++;
|
|
my $ep2 = "RTPE-${ep}-RX";
|
|
$ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
my $cmd = "add_voip_endp $ep2 $shelf $lf2 " . $all_ports2[$j] .
|
|
" $voip_phone $rtp_port AUTO " .
|
|
$src_sound_files[$sound_file_idx % @src_sound_files] .
|
|
" " . $src_sound_files[$sound_file_idx % @src_sound_files] .
|
|
".$ep2 $vad_timer $vad_fs";
|
|
doCmd($cmd);
|
|
$voip_phone++;
|
|
$rtp_port += 2;
|
|
$sound_file_idx++;
|
|
|
|
$cmd = "set_voip_info $ep2 NA $mn_icg $mx_icg NA $codec $vproto NA NA $min_call_duration $max_call_duration /dev/null 20000 NA $pesq_server $pesq_server_port NA";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_endp_flag $ep2 SavePCM 0";
|
|
doCmd($cmd);
|
|
|
|
if ($peer_to_peer_voip) {
|
|
$cmd = "set_endp_flag $ep2 DoNotRegister 1";
|
|
doCmd($cmd);
|
|
$cmd = "set_endp_flag $ep2 BindSIP 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
if ($no_send_rtp) {
|
|
$cmd = "set_endp_flag $ep2 nosendrtp 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
if ($use_VAD) {
|
|
$cmd = "set_endp_flag $ep2 VAD 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
if ($use_PESQ) {
|
|
$cmd = "set_endp_flag $ep2 pesq 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
my $cmd = "add_voip_endp $ep1 $shelf $lf1 " . $all_ports1[$j] .
|
|
" $voip_phone $rtp_port AUTO " .
|
|
$src_sound_files[$sound_file_idx % @src_sound_files] .
|
|
" " . $src_sound_files[$sound_file_idx % @src_sound_files] .
|
|
".$ep1";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_voip_info $ep1 NA $mn_icg $mx_icg NA $codec $vproto NA NA $min_call_duration $max_call_duration /dev/null 20000 NA $pesq_server $pesq_server_port NA";
|
|
doCmd($cmd);
|
|
|
|
$cmd = "set_endp_flag $ep1 SavePCM 0";
|
|
doCmd($cmd);
|
|
|
|
if ($peer_to_peer_voip) {
|
|
$cmd = "set_endp_flag $ep1 DoNotRegister 1";
|
|
doCmd($cmd);
|
|
$cmd = "set_endp_flag $ep1 BindSIP 1";
|
|
doCmd($cmd);
|
|
}
|
|
if ($no_send_rtp) {
|
|
$cmd = "set_endp_flag $ep1 nosendrtp 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
if ($use_VAD) {
|
|
$cmd = "set_endp_flag $ep1 VAD 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
if ($use_PESQ) {
|
|
$cmd = "set_endp_flag $ep1 pesq 1";
|
|
doCmd($cmd);
|
|
}
|
|
|
|
$voip_phone++;
|
|
$rtp_port += 2;
|
|
$sound_file_idx++;
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "rtp-cx-${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 {
|
|
my $burst = "NO";
|
|
if ($min_rate != $max_rate) {
|
|
$burst = "YES";
|
|
}
|
|
my $szrnd = "NO";
|
|
if ($min_pkt_szs[$i] != $max_pkt_szs[$i]) {
|
|
$szrnd = "YES";
|
|
}
|
|
|
|
my $pattern = "increasing";
|
|
if ($cx_types[$i] =~ /custom/) {
|
|
$pattern = "custom";
|
|
}
|
|
|
|
my $ep1 = "l3e-${ep}-TX";
|
|
$ep++;
|
|
my $ep2 = "l3e-${ep}-RX";
|
|
$ep++;
|
|
|
|
@endpoint_names = (@endpoint_names, $ep1, $ep2);
|
|
|
|
my $cmd = "add_endp $ep1 $shelf $lf1 " . $all_ports1[$j] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate $max_rate $szrnd " . $min_pkt_szs[$i] . " " . $max_pkt_szs[$i] .
|
|
" $pattern NO";
|
|
doCmd($cmd);
|
|
|
|
if ($lf2 == "") {
|
|
die("Must lave lf2 defined if using non-l4 endpoints.");
|
|
}
|
|
|
|
$cmd = "add_endp $ep2 $shelf $lf2 " . $all_ports2[$j] . " " . @cx_types[$i] .
|
|
" -1 $burst $min_rate $max_rate $szrnd " . $min_pkt_szs[$i] . " " .
|
|
$max_pkt_szs[$i] . " $pattern NO";
|
|
doCmd($cmd);
|
|
|
|
# Now, add the cross-connects
|
|
my $cx_name = "l3-cx-${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 cx types
|
|
}#for each port
|
|
}# each cx per port
|
|
|
|
}#addCrossConnects
|
|
|
|
|
|
sub doCmd {
|
|
my $cmd = shift;
|
|
|
|
print ">>> $cmd\n";
|
|
|
|
$t->print($cmd);
|
|
|
|
my @rslt = $t->waitfor('/ \>\>RSLT:(.*)/');
|
|
print "**************\n @rslt ................\n\n";
|
|
#sleep(1);
|
|
}
|