diff --git a/qchess/qchess.py b/qchess/qchess.py
index 1a9f398596fbc458e4e3d115e8fe27e85dabe368..32e2c60df459f6f702996f1633c71fb7a720360e 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 9938e0ddb6efb3a90cd61d60c28a21202f80bd69..b3c7dd3ecdf86b50e6ab7647da807a828ad270b5 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 0712910e76ae616df0edd7f77171080984b0514c..981e936b5d9e27a9a4e37f1dffbb7ede50e56375 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: