# HG changeset patch # User Matt Johnston # Date 1349959312 -28800 # Node ID 649648020123f5c24fdb6d465c05fcb9fd86b6ca # Parent 1603d0310dd0ff02bee507b3b7435d57ba2f0de9 log errors too diff -r 1603d0310dd0 -r 649648020123 server/dump.py --- a/server/dump.py Sat Oct 06 23:58:37 2012 +0800 +++ b/server/dump.py Thu Oct 11 20:41:52 2012 +0800 @@ -145,7 +145,11 @@ while True: l = readline(sock) - print l + if not l: + print '.', + sys.stdout.flush() + else: + print l testcount = 0 diff -r 1603d0310dd0 -r 649648020123 server/ts.py --- a/server/ts.py Sat Oct 06 23:58:37 2012 +0800 +++ b/server/ts.py Thu Oct 11 20:41:52 2012 +0800 @@ -43,21 +43,34 @@ def flush(sock): - while readline(sock): - pass + ret = [] + while True: + l = readline(sock) + if l: + ret.append(l) + else: + break + return ret + +def encode_extra(extra_lines): + return ['extra%d=%s' % (n, l.strip()) for (n,l) in enumerate(extra_lines)] @retry() def fetch(sock): - flush(sock) + extra_lines = flush(sock) sock.send("fetch\n") crc = 0 lines = [] l = readline(sock) + if not l: + return None + if l != 'START\n': - W("Bad expected START line '%s'\n" % str(l).rstrip('\n')) - return None + W("Bad expected START line '%s'\n" % l.rstrip('\n')) + extra_lines.append(l) + return encode_extra(extra_lines) crc = crc16(l, crc) while True: @@ -70,6 +83,8 @@ lines.append(l.rstrip('\n')) + lines += encode_extra(extra_lines) + for d in lines: L("Received: %s" % d)