2 from sender
import Sender
8 if __name__
== "__main__":
11 serverPort
= int(sys
.argv
[1])
12 s
= socket
.socket(socket
.AF_INET
, socket
.SOCK_STREAM
)
15 print 'Listening on port {}'.format(PORT
)
16 conn
, addr
= s
.accept()
17 print 'Connected by {}'.format(addr
)
18 print 'Initiating connection to EchoServer at port {}...'.format(serverPort
)
19 sender
= Sender(serverIP
="127.0.0.1", networkInterface
="lo", isLocal
=True, serverPort
=serverPort
, waitTime
=1, isVerbose
=0)
27 print 'waiting for data'
38 print 'invalid data received!'
40 print 'received: {}'.format(data
)
42 print 'resetting the SUT...'
44 sender
= Sender(serverIP
="127.0.0.1", networkInterface
="lo", isLocal
=True, serverPort
=serverPort
, waitTime
=1, isVerbose
=0)
54 elif data
== 'SYN' and not did_syn
:
56 print 'S: {}'.format(seqnr
)
57 response
= sender
.sendInput('S', seqnr
, seqnr
)
67 if sender
.lastSeqReceived
!= None:
69 print 'A: {}'.format(seqnr
)
70 response
= sender
.sendInput('A', seqnr
, sender
.lastSeqReceived
+ 1)
73 if sender
.lastSeqReceived
!= None:
75 print 'DAT: {} sending: a'.format(seqnr
)
76 response
= sender
.sendInput('PA', seqnr
, sender
.lastSeqReceived
+ 1, 'a')
79 if sender
.lastSeqReceived
!= None:
81 print 'RP: {}'.format(seqnr
)
82 response
= sender
.sendInput("RP", seqnr
, 0)
83 if response
[0] == 'T':
87 if sender
.lastSeqReceived
!= None:
89 print 'F: {}'.format(seqnr
)
90 response
= sender
.sendInput("FA", seqnr
, sender
.lastSeqReceived
+ 1)
91 if response
[0] == 'A':
96 print 'INVALID INPUT!: {}'.format(repr(data
))
99 if response
== 'Timeout':
102 elif response
== 'Reset':
105 elif response
== 'Closed':
107 elif response
[0] == 'A':
109 elif response
[0] == 'PA':
111 elif response
[0] == 'R':
113 elif response
[0] == 'SA':
119 print 'RESPONSE: '+data
120 conn
.send('{}\n'.format(data
))