summaryrefslogtreecommitdiffstats
path: root/tester
diff options
context:
space:
mode:
authorChris Johns <chrisj@rtems.org>2021-09-07 14:25:18 +1000
committerChris Johns <chrisj@rtems.org>2021-09-09 18:33:54 +1000
commite730a2d781fde8ff695cc57ed9bd950d8551c30d (patch)
treebbcf5c10f4115eb11d062713524892a505c1e275 /tester
parenttester: Count tester header errors (diff)
downloadrtems-tools-e730a2d781fde8ff695cc57ed9bd950d8551c30d.tar.bz2
tester/tftp: Fix prptocol timeout handling
- Change some of the notification messages
Diffstat (limited to 'tester')
-rw-r--r--tester/rt/tftp.py2
-rw-r--r--tester/rt/tftpserver.py28
2 files changed, 15 insertions, 15 deletions
diff --git a/tester/rt/tftp.py b/tester/rt/tftp.py
index af5029a..49bdb29 100644
--- a/tester/rt/tftp.py
+++ b/tester/rt/tftp.py
@@ -140,7 +140,7 @@ class tftp(object):
self._unlock('_listener')
self.server = tester.rt.tftpserver.tftp_server(host = 'all',
port = self.port,
- timeout = 1,
+ timeout = 10,
forced_file = exe,
sessions = 1)
try:
diff --git a/tester/rt/tftpserver.py b/tester/rt/tftpserver.py
index 46b594f..8a63546 100644
--- a/tester/rt/tftpserver.py
+++ b/tester/rt/tftpserver.py
@@ -309,12 +309,12 @@ class tftp_session(object):
block = (data[2] << 8) | data[3]
out += ' ' + self.opcodes[opcode] + ', '
out += '#' + str(block) + ', '
- if dlen > 4:
+ if dlen > 8:
out += '%02x%02x..%02x%02x' % (data[4], data[5],
data[-2], data[-1])
else:
- out += '%02x%02x%02x%02x' % (data[4], data[5], data[6],
- data[6])
+ for i in range(4, dlen):
+ out += '%02x' % (data[i])
out += ',' + str(dlen - 4)
elif opcode == self.OP_ACK:
block = (data[2] << 8) | data[3]
@@ -370,7 +370,7 @@ class tftp_session(object):
def get_timeout(self, default_timeout, timeout_guard):
'''Get the timeout. The timeout can be an option.'''
- if self.timeout == 0:
+ if self.timeout != 0:
return self.timeout + timeout_guard
return default_timeout
@@ -384,8 +384,7 @@ class udp_handler(socketserver.BaseRequestHandler):
def _notice(self, text):
if self.server.tftp.notices:
log.notice(text)
- else:
- log.trace(text)
+ log.output(text)
def handle_session(self, index):
'''Handle the TFTP session data.'''
@@ -408,7 +407,7 @@ class udp_handler(socketserver.BaseRequestHandler):
if log.tracing and self.server.tftp.packet_trace:
log.trace(' > ' +
session.decode(client_ip, client_port, data))
- timeout = session.get_timeout(self.server.tftp.timeout, 1)
+ timeout = session.get_timeout(self.server.tftp.timeout, 5)
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sock.bind(('', 0))
sock.settimeout(timeout)
@@ -426,21 +425,22 @@ class udp_handler(socketserver.BaseRequestHandler):
log.trace(
' > ' +
session.decode(address[0], address[1], data))
+ except socket.timout as sto:
+ self._notice('] tftp: %d: timeout: %s' % (index, client))
+ continue
except socket.error as serr:
- if log.tracing:
- log.trace('] tftp: %d: receive: %s: error: %s' \
- % (index, client, serr))
+ log._notice('] tftp: %d: sock receive: %s: error: %s' \
+ % (index, client, serr))
return
except socket.gaierror as serr:
- if log.tracing:
- log.trace('] tftp: %d: receive: %s: error: %s' \
- % (index, client, serr))
+ log._notice('] tftp: %d: sock receive: %s: error: %s' \
+ % (index, client, serr))
return
if session.finished:
break
response = session.process(address[0], address[1], data)
except error.general as gerr:
- self._notice('] tftp: %dd: error: %s' % (index, gerr))
+ self._notice('] tftp: %d: error: %s' % (index, gerr))
except error.internal as ierr:
self._notice('] tftp: %d: error: %s' % (index, ierr))
except error.exit: