mirror of
https://github.com/Telecominfraproject/wlan-lanforge-scripts.git
synced 2025-10-31 02:38:03 +00:00
299 lines
7.9 KiB
Perl
Executable File
299 lines
7.9 KiB
Perl
Executable File
#!/usr/bin/perl -w
|
|
use strict;
|
|
use warnings;
|
|
use diagnostics;
|
|
use Carp;
|
|
$SIG{ __DIE__ } = sub { Carp::confess( @_ ) };
|
|
$SIG{ __WARN__ } = sub { Carp::confess( @_ ) };
|
|
|
|
# Un-buffer output
|
|
$| = 1;
|
|
use Getopt::Long;
|
|
use JSON::XS;
|
|
use HTTP::Request;
|
|
use LWP;
|
|
use LWP::UserAgent;
|
|
use Data::Dumper;
|
|
use Time::HiRes qw(usleep);
|
|
use JSON;
|
|
use lib '/home/lanforge/scripts';
|
|
use LANforge::JsonUtils qw(logg err json_request get_links_from get_thru json_post get_port_names flatten_list);
|
|
|
|
package main;
|
|
# Default values for ye ole cmd-line args.
|
|
our $Resource = 1;
|
|
our $quiet = "yes";
|
|
our $Host = "localhost";
|
|
our $Port = 8080;
|
|
our $HostUri = "http://$Host:$Port";
|
|
our $Web = LWP::UserAgent->new;
|
|
our $Decoder = JSON->new->utf8;
|
|
our $ssid;
|
|
our $security;
|
|
our $passphrase;
|
|
|
|
my $usage = qq("$0 --host {ip or hostname} # connect to this
|
|
--port {port number} # defaults to 8080
|
|
);
|
|
|
|
|
|
##
|
|
## M A I N
|
|
##
|
|
|
|
my $des_resource = 6;
|
|
|
|
GetOptions
|
|
(
|
|
'host=s' => \$::Host,
|
|
'port=i' => \$::Port,
|
|
'resource=i' => \$des_resource
|
|
) || (print($usage) && exit(1));
|
|
|
|
$::HostUri = "http://$Host:$Port";
|
|
|
|
my $uri = "/shelf/1";
|
|
my $rh = json_request($uri);
|
|
my $ra_links = get_links_from($rh, 'resources');
|
|
my @ports_up= ();
|
|
|
|
# TODO: make this a JsonUtils::list_ports()
|
|
$uri = "/port/1/${des_resource}/list?fields=alias,device,down,phantom,port";
|
|
logg("requesting $uri");
|
|
$rh = json_request($uri);
|
|
#print Dumper($rh);
|
|
flatten_list($rh, 'interfaces');
|
|
#print Dumper($rh->{'flat_list'});
|
|
for my $rh_p (keys %{$rh->{'flat_list'}}) {
|
|
print " $rh_p ".$rh->{'flat_list'}->{$rh_p}->{'down'};
|
|
if ("false" eq $rh->{'flat_list'}->{$rh_p}->{'down'}) {
|
|
push(@ports_up, $rh_p);
|
|
}
|
|
}
|
|
# find first station
|
|
my $rh_sta;
|
|
print Dumper(\@ports_up);
|
|
for my $rh_up (@ports_up) {
|
|
my $eid = $rh->{'flat_list'}->{$rh_up}->{'port'};
|
|
my @hunks = split(/[.]/, $eid);
|
|
if ($hunks[1]) {
|
|
$rh_sta = $rh_up;
|
|
}
|
|
}
|
|
if (!defined $rh_sta) {
|
|
die("Unable to find a virtual station. Is one up?");
|
|
}
|
|
|
|
# delete old CXes and old endpoints
|
|
# TODO: collect_cx_names
|
|
my $rh_cxlist = json_request("/cx/list");
|
|
|
|
my @cx_names = ();
|
|
for my $cx_name (sort keys %$rh_cxlist) {
|
|
#print " cx_name[$cx_name]";
|
|
next if (ref $rh_cxlist->{$cx_name} ne "HASH");
|
|
next if (!defined $rh_cxlist->{$cx_name}->{"name"});
|
|
next if ($rh_cxlist->{$cx_name}->{"name"} eq "uri");
|
|
push(@cx_names, $rh_cxlist->{$cx_name}->{"name"});
|
|
}
|
|
|
|
print "\nRemoving cx: ";
|
|
$uri = "/cli-json/rm_cx";
|
|
for my $cx_name (sort @cx_names) {
|
|
print "$cx_name ";
|
|
$rh = {
|
|
"test_mgr" => "all",
|
|
"cx_name" => $cx_name
|
|
};
|
|
json_post($uri, $rh);
|
|
}
|
|
sleep 1;
|
|
|
|
|
|
my $rh_endplist = json_request("/endp/list");
|
|
print "\nRemoving endpoints: ";
|
|
flatten_list($rh_endplist, 'endpoint');
|
|
#print Dumper($rh_endplist->{'flat_list'});
|
|
#sleep 10;
|
|
my @endp_names = ();
|
|
for my $ep_name (keys %{$rh_endplist->{'flat_list'}}) {
|
|
next if (!defined $ep_name);
|
|
next if ($ep_name eq "");
|
|
next if ((ref $ep_name) eq "ARRAY");
|
|
next if (!defined $rh_endplist->{'flat_list'}->{$ep_name}->{"name"});
|
|
next if ($rh_endplist->{'flat_list'}->{$ep_name}->{"name"} eq "");
|
|
#print "epn:".Dumper($rh_endplist->{'flat_list'}->{$ep_name}->{"name"});
|
|
push(@endp_names, $ep_name);
|
|
}
|
|
|
|
$uri = "/cli-json/rm_endp";
|
|
for my $ep_name (@endp_names) {
|
|
if (!defined $ep_name || $ep_name =~/^\s*$/ || (ref $ep_name) eq "ARRAY") {
|
|
print " skipping ep_name[$ep_name]";
|
|
print Dumper(\$ep_name);
|
|
next;
|
|
}
|
|
print "[$ep_name] ";
|
|
#usleep(500000);
|
|
$rh = { "endp_name" => $ep_name };
|
|
json_post($uri, $rh);
|
|
|
|
}
|
|
|
|
print "\nRefreshing...";
|
|
my $h = {"endpoint"=>"all"};
|
|
json_request("/cli-json/nc_show_endpoints", $h);
|
|
sleep 1;
|
|
$h = {"test_mgr"=>"all", "cross_connect"=>"all"};
|
|
json_request("/cli-json/show_cxe", $h);
|
|
|
|
# assume resource 1, eth1 is present, and create an endpoint to it
|
|
# -A and -B are expected convention for endpoint names
|
|
|
|
# create 10 endpoints
|
|
my $rh_ports = json_request("/port/1/$des_resource/list");
|
|
flatten_list($rh_ports, 'interfaces');
|
|
|
|
my $rh_endp_A = {
|
|
'alias' => 'udp_json',
|
|
'shelf' => 1,
|
|
'resource' => 1,
|
|
'port' => 'b1000', # or eth1
|
|
'type' => 'lf_udp',
|
|
'ip_port' => -1,
|
|
'is_rate_bursty' => 'NO',
|
|
'min_rate' => 100000,
|
|
'min_pkt' => -1,
|
|
'max_pkt' => -1,
|
|
'payload_pattern' => 'increasing',
|
|
'multi_conn' => 0
|
|
};
|
|
|
|
my $rh_endp_B = {
|
|
'alias' => 'udp_json',
|
|
'shelf' => 1,
|
|
'resource' => $des_resource,
|
|
'port' => 'unset',
|
|
'type' => 'lf_udp',
|
|
'ip_port' => -1,
|
|
'is_rate_bursty' => 'NO',
|
|
'min_rate' => 12800,
|
|
'min_pkt' => -1,
|
|
'max_pkt' => -1,
|
|
'payload_pattern' => 'increasing',
|
|
'multi_conn' => 0
|
|
};
|
|
my $rh_cx = {
|
|
"alias" => 'udp_json',
|
|
"test_mgr" => 'default_tm',
|
|
'tx_endp' => '',
|
|
'rx_endp' => ''
|
|
};
|
|
|
|
$h = {"endpoint"=>"all"};
|
|
json_request("/cli-json/nc_show_endpoints", $h);
|
|
$h = {"test_mgr"=>"all", "cross_connect"=>"all"};
|
|
json_request("/cli-json/show_cxe", $h);
|
|
sleep 1;
|
|
print "\nConstructing new Endpoints: ";
|
|
my $num_ports = scalar keys(%{$rh_ports->{'flat_list'}});
|
|
my $num_cx = 0;
|
|
for my $rh_p (values %{$rh_ports->{'flat_list'}}) {
|
|
|
|
last if ($num_cx >= ($num_ports-1));
|
|
next if ($rh_p->{'alias'} !~ /^v*sta/);
|
|
|
|
my $end_a_alias = "udp_json_$num_cx-A";
|
|
my $end_b_alias = "udp_json_$num_cx-B";
|
|
my $port_b = $rh_p->{'alias'};
|
|
print "$port_b ";
|
|
$rh_endp_B->{'port'} = $port_b;
|
|
$rh_endp_B->{'alias'} = $end_b_alias;
|
|
$rh_endp_A->{'alias'} = $end_a_alias;
|
|
$num_cx++;
|
|
|
|
json_post("/cli-json/add_endp", $rh_endp_A);
|
|
json_post("/cli-json/add_endp", $rh_endp_B);
|
|
}
|
|
print "\nRefreshing...";
|
|
$h = {"endpoint"=>"all"};
|
|
json_request("/cli-json/nc_show_endpoints", $h);
|
|
sleep 1;
|
|
print "\nConstructing new CX: ";
|
|
$num_cx = 0;
|
|
for my $rh_p (values %{$rh_ports->{'flat_list'}}) {
|
|
last if ($num_cx >= ($num_ports-1));
|
|
next if ($rh_p->{'alias'} !~ /^v*sta/);
|
|
|
|
my $end_a_alias = "udp_json_${num_cx}-A";
|
|
my $end_b_alias = "udp_json_${num_cx}-B";
|
|
my $port_b = $rh_p->{'alias'};
|
|
my $cx_alias = "udp_json_".$num_cx;
|
|
$rh_cx->{'alias'} = $cx_alias;
|
|
$rh_cx->{'tx_endp'} = $end_a_alias;
|
|
$rh_cx->{'rx_endp'} = $end_b_alias;
|
|
json_post("/cli-json/add_cx", $rh_cx);
|
|
print " $cx_alias";
|
|
$num_cx++;
|
|
}
|
|
print "\nRefreshing...";
|
|
$h = {"endpoint"=>"all"};
|
|
json_request("/cli-json/nc_show_endpoints", $h);
|
|
|
|
$rh_cxlist = json_request("/cx/list");
|
|
@cx_names = ();
|
|
for my $cx_name (sort keys %$rh_cxlist) {
|
|
next if (ref $rh_cxlist->{$cx_name} ne "HASH");
|
|
next if (!defined $rh_cxlist->{$cx_name}->{"name"});
|
|
push(@cx_names, $rh_cxlist->{$cx_name}->{"name"});
|
|
}
|
|
for my $cx_alias (sort @cx_names) {
|
|
my $rh_cx_t = {
|
|
'test_mgr' => 'default_tm',
|
|
'cx_name' => $cx_alias,
|
|
'milliseconds'=> 1000,
|
|
};
|
|
json_post("/cli-json/set_cx_report_timer", $rh_cx_t);
|
|
}
|
|
print "\nRefreshing...";
|
|
$h = {"endpoint"=>"all"};
|
|
json_request("/cli-json/nc_show_endpoints", $h);
|
|
sleep 1;
|
|
$h = {"test_mgr"=>"all", "cross_connect"=>"all"};
|
|
json_request("/cli-json/show_cxe", $h);
|
|
|
|
my $set_state = {
|
|
'test_mgr' => 'default_tm',
|
|
'cx_name' => 'udp_ex',
|
|
'cx_state' => 'RUNNING'
|
|
};
|
|
@cx_names = ();
|
|
$rh_cxlist = json_request("/cx/list");
|
|
for my $cx_name (sort keys %$rh_cxlist) {
|
|
next if (ref $rh_cxlist->{$cx_name} ne "HASH");
|
|
next if (!defined $rh_cxlist->{$cx_name}->{"name"});
|
|
push(@cx_names, $rh_cxlist->{$cx_name}->{"name"});
|
|
}
|
|
print "\nStarting: ";
|
|
for my $cxname (@cx_names) {
|
|
print " $cxname";
|
|
$set_state->{'cx_name'} = $cxname;
|
|
json_post("/cli-json/set_cx_state", $set_state);
|
|
}
|
|
sleep 1;
|
|
|
|
$set_state = {
|
|
'test_mgr' => 'default_tm',
|
|
'cx_name' => 'udp_ex',
|
|
'cx_state' => 'STOPPED'
|
|
};
|
|
print "\nStopping: ";
|
|
for my $cxname (@cx_names) {
|
|
$set_state->{'cx_name'} = $cxname;
|
|
print " $cxname";
|
|
json_post("/cli-json/set_cx_state", $set_state);
|
|
}
|
|
print "...done\n";
|
|
|
|
#
|