From: Sam Moore Date: Wed, 30 Jan 2013 09:20:45 +0000 (+0800) Subject: Make sure the board reflects the state BEFORE the move is made X-Git-Url: https://git.ucc.asn.au/?a=commitdiff_plain;h=6857a85bd7dc426f0b864780596435555bef3f11;p=progcomp2013.git Make sure the board reflects the state BEFORE the move is made Whoops Probably going to get a lot of really small commits for a while... --- diff --git a/qchess/qchess.py b/qchess/qchess.py index 1a9f398..32e2c60 100755 --- a/qchess/qchess.py +++ b/qchess/qchess.py @@ -1251,9 +1251,9 @@ class HttpReplay(): def readline(self): line = self.log.readline() - sys.stderr.write(sys.argv[0] + " : " + str(self) + " read \""+str(line) + "\" from address " + str(self.address) + "\n") + sys.stderr.write(sys.argv[0] + " : " + str(self.__class__.__name__) + " read \""+str(line.strip("\r\n")) + "\" from address " + str(self.address) + "\n") if line == "": - sys.stderr.write(sys.argv[0] + " : " + str(self) + " retrieving from address " + str(self.address) + "\n") + sys.stderr.write(sys.argv[0] + " : " + str(self.__class__.__name__) + " retrieving from address " + str(self.address) + "\n") date_mod = datetime.datetime.strptime(self.log.headers['last-modified'], "%a, %d %b %Y %H:%M:%S GMT") self.log.close() @@ -1263,13 +1263,15 @@ class HttpReplay(): next_log = urllib2.urlopen(HeadRequest(self.address)) date_new = datetime.datetime.strptime(next_log.headers['last-modified'], "%a, %d %b %Y %H:%M:%S GMT") - self.log = urllib2.urlopen(address) + self.log = urllib2.urlopen(self.address) game.setup() line = self.log.readline() return line + def close(self): + self.log.close() def log(s): if log_file != None: @@ -1421,6 +1423,7 @@ class ReplayThread(GameThread): self.setup() def setup(self): + sys.stderr.write("setup called for ReplayThread\n") if True: while self.src.readline().strip(" \r\n") != "# Initial board": self.line_number += 1 @@ -1455,6 +1458,7 @@ class ReplayThread(GameThread): count = 0 line = self.src.readline().strip(" \r\n") while line != "# EOF": + sys.stderr.write(sys.argv[0] + " : " + str(self.__class__.__name__) + " read: " + str(line) + "\n") count += 1 if self.max_lines != None and count > self.max_lines: self.stop() @@ -1467,15 +1471,18 @@ class ReplayThread(GameThread): line = line.split(":") result = line[len(line)-1].strip(" \r\n") - log(result) + try: self.board.update(result) - except: + except Exception, e: + sys.stderr.write("Exception! " + str(e.message) + "\n") self.final_result = result self.stop() break + log(result) + [x,y] = map(int, result.split(" ")[0:2]) target = self.board.grid[x][y] @@ -1511,9 +1518,11 @@ class ReplayThread(GameThread): phase = (phase + 1) % 2 if phase == 0: i = (i + 1) % 2 - + line = self.src.readline().strip(" \r\n") + sys.stderr.write(sys.argv[0] + " : " + str(self.__class__.__name__) + " finished...\n") + if self.max_lines != None and self.max_lines > count: sys.stderr.write(sys.argv[0] + " : Replaying from file; stopping at last line (" + str(count) + ")\n") sys.stderr.write(sys.argv[0] + " : (You requested line " + str(self.max_lines) + ")\n") @@ -2321,4 +2330,4 @@ if __name__ == "__main__": sys.exit(102) # --- main.py --- # -# EOF - created from make on Wed Jan 30 17:03:00 WST 2013 +# EOF - created from make on Wed Jan 30 17:20:26 WST 2013 diff --git a/qchess/src/game.py b/qchess/src/game.py index 9938e0d..b3c7dd3 100644 --- a/qchess/src/game.py +++ b/qchess/src/game.py @@ -138,6 +138,7 @@ class ReplayThread(GameThread): self.setup() def setup(self): + sys.stderr.write("setup called for ReplayThread\n") if True: while self.src.readline().strip(" \r\n") != "# Initial board": self.line_number += 1 @@ -172,6 +173,7 @@ class ReplayThread(GameThread): count = 0 line = self.src.readline().strip(" \r\n") while line != "# EOF": + sys.stderr.write(sys.argv[0] + " : " + str(self.__class__.__name__) + " read: " + str(line) + "\n") count += 1 if self.max_lines != None and count > self.max_lines: self.stop() @@ -184,15 +186,18 @@ class ReplayThread(GameThread): line = line.split(":") result = line[len(line)-1].strip(" \r\n") - log(result) + try: self.board.update(result) - except: + except Exception, e: + sys.stderr.write("Exception! " + str(e.message) + "\n") self.final_result = result self.stop() break + log(result) + [x,y] = map(int, result.split(" ")[0:2]) target = self.board.grid[x][y] @@ -228,9 +233,11 @@ class ReplayThread(GameThread): phase = (phase + 1) % 2 if phase == 0: i = (i + 1) % 2 - + line = self.src.readline().strip(" \r\n") + sys.stderr.write(sys.argv[0] + " : " + str(self.__class__.__name__) + " finished...\n") + if self.max_lines != None and self.max_lines > count: sys.stderr.write(sys.argv[0] + " : Replaying from file; stopping at last line (" + str(count) + ")\n") sys.stderr.write(sys.argv[0] + " : (You requested line " + str(self.max_lines) + ")\n") diff --git a/qchess/src/log.py b/qchess/src/log.py index 0712910..981e936 100644 --- a/qchess/src/log.py +++ b/qchess/src/log.py @@ -50,9 +50,9 @@ class HttpReplay(): def readline(self): line = self.log.readline() - sys.stderr.write(sys.argv[0] + " : " + str(self) + " read \""+str(line) + "\" from address " + str(self.address) + "\n") + sys.stderr.write(sys.argv[0] + " : " + str(self.__class__.__name__) + " read \""+str(line.strip("\r\n")) + "\" from address " + str(self.address) + "\n") if line == "": - sys.stderr.write(sys.argv[0] + " : " + str(self) + " retrieving from address " + str(self.address) + "\n") + sys.stderr.write(sys.argv[0] + " : " + str(self.__class__.__name__) + " retrieving from address " + str(self.address) + "\n") date_mod = datetime.datetime.strptime(self.log.headers['last-modified'], "%a, %d %b %Y %H:%M:%S GMT") self.log.close() @@ -62,13 +62,15 @@ class HttpReplay(): next_log = urllib2.urlopen(HeadRequest(self.address)) date_new = datetime.datetime.strptime(next_log.headers['last-modified'], "%a, %d %b %Y %H:%M:%S GMT") - self.log = urllib2.urlopen(address) + self.log = urllib2.urlopen(self.address) game.setup() line = self.log.readline() return line + def close(self): + self.log.close() def log(s): if log_file != None: