~ubuntu-branches/ubuntu/precise/libpgm/precise

« back to all changes in this revision

Viewing changes to openpgm/pgm/test/.svn/text-base/rdata_completion.pl.svn-base

• browse files at revision 1
• compare with another revision
• download diff
• download tarball
• view history from revision 1

Show diffs side-by-side

added

removed

openpgm/pgm/test/.svn/text-base/rdata_completion.pl.svn-base

 

1

#!/usr/bin/perl

 

2

# rdata_completion.pl

 

3

# 6.3. Data Recovery by Negative Acknowledgment

 

4

 

 

5

use strict;

 

6

use Time::HiRes qw( gettimeofday tv_interval );

 

7

use PGM::Test;

 

8

 

 

9

BEGIN { require "test.conf.pl"; }

 

10

 

 

11

$| = 1;

 

12

 

 

13

my $mon = PGM::Test->new(tag => 'mon', host => $config{mon}{host}, cmd => $config{mon}{cmd});

 

14

my $sim = PGM::Test->new(tag => 'sim', host => $config{sim}{host}, cmd => $config{sim}{cmd});

 

15

my $app = PGM::Test->new(tag => 'app', host => $config{app}{host}, cmd => $config{app}{cmd});

 

16

 

 

17

$mon->connect;

 

18

$sim->connect;

 

19

$app->connect;

 

20

 

 

21

sub close_ssh {

 

22

        $mon = $sim = $app = undef;

 

23

        print "finished.\n";

 

24

}

 

25

 

 

26

$SIG{'INT'} = sub { print "interrupt caught.\n"; close_ssh(); };

 

27

 

 

28

$mon->say ("filter $config{app}{ip}");

 

29

print "mon: ready.\n";

 

30

 

 

31

$app->say ("create ao");

 

32

$app->say ("bind ao");

 

33

$app->say ("connect ao");

 

34

$app->say ("listen ao");

 

35

 

 

36

## capture GSI of test spp

 

37

$app->say ("send ao nashi");

 

38

print "mon: wait for odata ...\n";

 

39

my $odata = $mon->wait_for_odata;

 

40

print "mon: odata received.\n";

 

41

 

 

42

$sim->say ("create fake ao");

 

43

$sim->say ("bind ao");

 

44

$sim->say ("connect ao");

 

45

 

 

46

print "sim: publish SPM txw_trail 90,001 txw_lead 90,000 at spm_sqn 3200.\n";

 

47

$sim->say ("net send spm ao 3200 90001 90000");

 

48

 

 

49

# no NAKs should be generated.

 

50

print "sim: waiting 2 seconds for erroneous NAKs ...\n";

 

51

$sim->die_on_nak ({ 'timeout' => 2 });

 

52

print "sim: no NAKs received.\n";

 

53

 

 

54

print "sim: publish ODATA sqn 90,001.\n";

 

55

$sim->say ("net send odata ao 90001 90001 ringo");

 

56

 

 

57

print "app: wait for data ...\n";

 

58

my $data = $app->wait_for_data;

 

59

print "app: data received [$data].\n";

 

60

 

 

61

# no NAKs should be generated.

 

62

print "sim: waiting 2 seconds for erroneous NAKs ...\n";

 

63

$sim->die_on_nak ({ 'timeout' => 2 });

 

64

print "sim: no NAKs received.\n";

 

65

 

 

66

print "sim: publish ODATA sqn 90,003.\n";

 

67

$sim->say ("net send odata ao 90003 90001 ichigo");

 

68

print "sim: waiting for valid NAK.\n";

 

69

$sim->wait_for_nak;

 

70

print "sim: NAK received.\n";

 

71

 

 

72

print "sim: publish RDATA sqn 90,002.\n";

 

73

$sim->say ("net send rdata ao 90002 90001 momo");

 

74

 

 

75

for (1..2)

 

76

{

 

77

        print "app: wait for data ...\n";

 

78

        my $data = $app->wait_for_data;

 

79

        print "app: data received [$data].\n";

 

80

}

 

81

 

 

82

print "test completed successfully.\n";

 

83

 

 

84

$mon->disconnect (1);

 

85

$sim->disconnect;

 

86

$app->disconnect;

 

87

close_ssh;

 

88

 

 

89

# eof

• Older »

Loggerhead is a web-based interface for Breezy
Version: 2.0.1