1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
|
#!/usr/bin/perl
# nak_cancellation.pl
# 6.3. Data Recovery by Negative Acknowledgment
use strict;
use IO::Handle;
use JSON;
use Time::HiRes qw( gettimeofday tv_interval );
use PGM::Test;
BEGIN { require "test.conf.pl"; }
$| = 1;
my $mon = PGM::Test->new(tag => 'mon', host => $config{mon}{host}, cmd => $config{mon}{cmd});
my $sim = PGM::Test->new(tag => 'sim', host => $config{sim}{host}, cmd => $config{sim}{cmd});
my $app = PGM::Test->new(tag => 'app', host => $config{app}{host}, cmd => $config{app}{cmd});
pipe(FROM_PARENT, TO_CHILD) or die "pipe: $!";
FROM_PARENT->autoflush(1);
$mon->connect;
$sim->connect;
$app->connect;
sub close_ssh {
close FROM_PARENT; close TO_CHILD;
$mon = $sim = $app = undef;
print "finished.\n";
}
$SIG{'INT'} = sub { print "interrupt caught.\n"; close_ssh(); };
$mon->say ("filter $config{app}{ip}");
print "mon: ready.\n";
$app->say ("create ao");
$app->say ("set ao NAK_BO_IVL 5000"); # increase to count for test system latency
$app->say ("set ao NAK_RPT_IVL 10000");
$app->say ("set ao NAK_RDATA_IVL 10000");
$app->say ("set ao NAK_NCF_RETRIES 15");
$app->say ("set ao NAK_DATA_RETRIES 10");
$app->say ("bind ao");
$app->say ("listen ao");
## capture GSI of test spp
$app->say ("send ao nashi");
print "mon: wait for odata ...\n";
my $odata = $mon->wait_for_odata;
print "mon: odata received.\n";
$sim->say ("create fake ao");
$sim->say ("bind ao");
print "sim: publish SPM txw_trail 90,001 txw_lead 90,000 at spm_sqn 3200.\n";
$sim->say ("net send spm ao 3200 90001 90000");
# no NAKs should be generated.
print "sim: waiting 2 seconds for erroneous NAKs ...\n";
$sim->die_on_nak ({ 'timeout' => 2 });
print "sim: no NAKs received.\n";
print "sim: publish ODATA sqn 90,001.\n";
$sim->say ("net send odata ao 90001 90001 ringo");
print "app: wait for data ...\n";
my $data = $app->wait_for_data;
print "app: data received [$data].\n";
# no NAKs should be generated.
print "sim: waiting 2 seconds for erroneous NAKs ...\n";
$sim->die_on_nak ({ 'timeout' => 2 });
print "sim: no NAKs received.\n";
print "sim: publish ODATA sqn 90,003.\n";
$sim->say ("net send odata ao 90003 90001 ichigo");
my $t0 = [gettimeofday];
if (my $pid = fork) {
# parent
close FROM_PARENT;
sleep 10;
print "app: wait for data ...\n";
my $data = $app->wait_for_data({ 'timeout' => 0 });
print "app: data received [$data].\n";
print TO_CHILD "die\n";
close TO_CHILD;
waitpid($pid,0);
} else {
# child
die "cannot fork: $!" unless defined $pid;
close TO_CHILD;
print "sim: loop waiting for NAKs ...\n";
my $fh = $sim->{in};
vec(my $rin, fileno(FROM_PARENT), 1) = 1;
vec($rin, fileno($fh), 1) = 1;
my $rout = undef;
my $b = '';
my $state = 0;
my $json = new JSON;
my $io = IO::Handle->new_from_fd( fileno($fh), "r" );
my $cnt = 0;
while (select($rout = $rin, undef, undef, undef))
{
last if( vec($rout, fileno(FROM_PARENT), 1) );
while (defined($_ = $io->getline))
{
chomp;
my $l = $_;
if ($state == 0) {
if ($l =~ /{$/) {
$state = 1;
} else {
print "sim [$l]\n";
last;
}
}
if ($state == 1) {
$b .= $l;
if ($l =~ /^}$/) {
$state = 0;
my $obj = $json->jsonToObj($b);
if ($obj->{PGM}->{type} =~ /NAK/) {
$cnt++;
my $elapsed = tv_interval ( $t0, [gettimeofday] );
print "sim: $cnt x NAK received in $elapsed seconds.\n";
$sim->say ("net send ncf ao $odata->{PGM}->{gsi}.$odata->{PGM}->{sourcePort} 90002");
}
# reset
$b = '';
last;
}
}
}
last if ($io->eof);
}
print "sim: loop finished.\n";
close FROM_PARENT;
exit;
}
print "test completed successfully.\n";
$mon->disconnect (1);
$sim->disconnect;
$app->disconnect;
close_ssh;
# eof
|
