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
)
13 s
.bind(('', JTORXPORT
))
15 print 'Listening on port {} for JTorx'.format(JTORXPORT
)
16 conn
, addr
= s
.accept()
17 print 'Connected by JTorx at {}'.format(addr
)
22 data
= conn
.recv(1024)
27 sender
= Sender(serverIP
="127.0.0.1", networkInterface
="lo", isLocal
=True, serverPort
=serverPort
, waitTime
=1, isVerbose
=0)
31 print 'S: {}'.format(seqnr
)
32 response
= sender
.sendInput('S', seqnr
, seqnr
)
35 print 'A: {}'.format(seqnr
)
36 response
= sender
.sendInput('A', seqnr
, sender
.lastSeqReceived
+ 1)
39 print 'FA: {}'.format(seqnr
)
40 response
= sender
.sendInput("FA", seqnr
, sender
.lastSeqReceived
+ 1)
43 print 'F: {}'.format(seqnr
)
44 response
= sender
.sendInput("F", seqnr
, sender
.lastSeqReceived
+ 1)
47 print 'RP: {}'.format(seqnr
)
48 response
= sender
.sendInput("RP", seqnr
, 0)
51 print 'DAT: {} sending: a'.format(seqnr
)
52 response
= sender
.sendInput('A', seqnr
, sender
.lastSeqReceived
+ 1)
53 response
= sender
.sendInput('PA', seqnr
, sender
.lastSeqReceived
+ 1, data
='a\n')
56 print 'response: {}'.format(response
)
57 if response
== 'Timeout':
58 print 'data: {} - TIMEOUT!'.format(data
)
59 conn
.send('TIMEOUT!\n')
60 elif response
[0] == 'A' or response
[0] == 'PA':
61 print 'data: {} - ACK!'.format(data
)
63 elif response
[0] == 'R':
64 print 'data: {} - RST!'.format(data
)
66 elif response
[0] == 'SA':
67 print 'data: {} - SYNACK!'.format(data
)
68 conn
.send('SYNACK!\n')
70 print 'data: {}'.format(data
)