scottk/wlan-lanforge-scripts
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-lanforge-scripts.git synced 2025-10-31 10:48:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

port_test uses suppress_postexec to speed batch operations

Browse Source
This commit is contained in:
Jed Reynolds
2018-09-12 14:48:12 -07:00
parent 3cd278fd81
commit 222b094e25
1 changed files with 49 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
json/port_test.pl
View File

@@ -83,13 +83,23 @@ for my $rh_target (@destroy_me) {
my @hunks = split(/[\/]/, $rh_target->{'uri'}); my @hunks = split(/[\/]/, $rh_target->{'uri'});
# TODO: create JsonUtils::rm_vlan($eid, $alias) # TODO: create JsonUtils::rm_vlan($eid, $alias)
# suppress_postexec used to reduce the update traffic concurrent with large set of deletions
my $rh_data = { my $rh_data = {
'shelf'=>1, 'resource'=>$hunks[3], 'port'=>$alias 'shelf'=>1,
'resource'=>$hunks[3],
'port'=>$alias,
'suppress_postexec'=>'true'
}; };
logg(" $alias"); logg(" $alias");
json_post("/cli-json/rm_vlan", $rh_data); my $rh_response = json_post("/cli-json/rm_vlan", $rh_data);
usleep (15000); usleep (15000);
#sleep (5);
} }
my $rh_update = {
'shelf'=>1, 'resource'=>'all', 'port'=>'all', 'flags'=>'0x1'
};
logg(" updating ");
my $rh_response = json_post("/cli-json/nc_show_ports", $rh_update);
# this really should poll for ports to wait for them to disappear # this really should poll for ports to wait for them to disappear
sleep 2; sleep 2;
@@ -103,6 +113,7 @@ my $resource;
my $range; my $range;
my $num_sta = 129; my $num_sta = 129;
my $radio_num; my $radio_num;
my $radio_counter = 0;
for $rh_radio (@radios) { for $rh_radio (@radios) {
$radio_name = $rh_radio->{'alias'}; $radio_name = $rh_radio->{'alias'};
my @hunks = split(/[\/]/, $rh_radio->{'uri'}); my @hunks = split(/[\/]/, $rh_radio->{'uri'});
@@ -116,40 +127,52 @@ for $rh_radio (@radios) {
'shelf'=>1, 'shelf'=>1,
'resource'=>$resource, 'resource'=>$resource,
'radio'=>$radio_name, 'radio'=>$radio_name,
'sta_name'=>'sta'.$i, 'sta_name'=>'sta'.$radio_counter,
'alias'=>'vsta'.$i,
'flags'=>68862086144, # has port-down set 'flags'=>68862086144, # has port-down set
'ssid'=>'idtest-1200-wpa2', 'ssid'=>'idtest-1200-wpa2',
'key'=>'idtest-1200-wpa2', 'key'=>'idtest-1200-wpa2',
'mac'=>'xx:xx:xx:xx:*:xx', 'mac'=>'xx:xx:xx:xx:*:xx',
'mode'=>0, 'mode'=>0,
'rate'=>'DEFAULT' 'rate'=>'DEFAULT',
'suppress_postexec'=>'true'
}; };
#print Dumper($rh_data); #print Dumper($rh_data);
logg("1/$resource/$radio_name -> sta$i "); logg("1/$resource/$radio_name -> sta$radio_counter");
json_post("/cli-json/add_sta", $rh_data); my $rh_response = json_post("/cli-json/add_sta", $rh_data);
usleep(15000); print Dumper($rh_response);
usleep(10000);
$radio_counter +=1;
} }
} }
sleep 1; logg(" updating ");
$rh_response = json_post("/cli-json/nc_show_ports", $rh_update);
sleep 2;
for $rh_radio (@radios) { for $rh_radio (@radios) {
$radio_name = $rh_radio->{'alias'}; $radio_name = $rh_radio->{'alias'};
my @hunks = split(/[\/]/, $rh_radio->{'uri'}); my @hunks = split(/[\/]/, $rh_radio->{'uri'});
$resource = $hunks[3]; $resource = $hunks[3];
$range = ($resource * 1000) + ($radio_num * 100); $range = ($resource * 1000) + ($radio_num * 100);
$radio_counter = 0;
for (my $i = $range; $i < ($range+$num_sta); $i++) { for (my $i = $range; $i < ($range+$num_sta); $i++) {
my $rh_data = { my $rh_data = {
'shelf'=>1, 'shelf'=>1,
'resource'=>$resource, 'resource'=>$resource,
'port'=>'sta'.$i, 'port'=>'sta'.$radio_counter,
'cmd_flags'=>0, 'cmd_flags'=>0,
'current_flags'=>2147483648, 'current_flags'=>2147483648,
'suppress_postexec'=>'true',
'interest'=>16386 'interest'=>16386
}; };
# TODO: create JsonUtils::set_dhcp($eid, $alias, $on_off) # TODO: create JsonUtils::set_dhcp($eid, $alias, $on_off)
json_post("/cli-json/set_port", $rh_data); my $rh_response = json_post("/cli-json/set_port", $rh_data);
print Dumper($rh_response);
$radio_counter+=1;
usleep(21000); usleep(21000);
} }
} }
logg(" updating ");
$rh_response = json_post("/cli-json/nc_show_ports", $rh_update);
sleep 1; sleep 1;
for $uri (@$ra_links) { for $uri (@$ra_links) {
$uri =~ s{/resource}{/port}g; $uri =~ s{/resource}{/port}g;
@@ -172,11 +195,17 @@ for my $port_uri (@links2) {
my @hunks = split(/\./, $port); my @hunks = split(/\./, $port);
my $resource = $hunks[1]; my $resource = $hunks[1];
my %post = ( my %post = (
"shelf" => 1, "resource" => 0+$resource, "port" => $device, "shelf" => 1,
"current_flags" => 1, "interest" => 8388610 "resource" => 0+$resource,
"port" => $device,
'suppress_postexec'=>'true',
"current_flags" => 1,
"interest" => 8388610
); );
my $rh_response = json_post($set_port, \%post); my $rh_response = json_post($set_port, \%post);
} }
logg(" updating ");
$rh_response = json_post("/cli-json/nc_show_ports", $rh_update);
sleep 1; sleep 1;
logg("\nsetting ports up "); logg("\nsetting ports up ");
for my $port_uri (@links2) { for my $port_uri (@links2) {
@@ -189,10 +218,16 @@ for my $port_uri (@links2) {
my $resource = $hunks[1]; my $resource = $hunks[1];
# 'shelf=1&resource=2&port=vap2000&cmd_flags=0&current_flags=0&interest=8388610' # 'shelf=1&resource=2&port=vap2000&cmd_flags=0&current_flags=0&interest=8388610'
my %post = ( my %post = (
"shelf" => 1, "resource" => 0+$resource, "port" => $device, "shelf" => 1,
"current_flags" => 0, "interest" => 8388610 "resource" => 0+$resource,
"port" => $device,
'suppress_postexec'=>'true',
"current_flags" => 0,
"interest" => 8388610
); );
my $rh_response = json_post($set_port, \%post); my $rh_response = json_post($set_port, \%post);
} }
logg(" updating ");
$rh_response = json_post("/cli-json/nc_show_ports", $rh_update);
# #