X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;ds=sidebyside;f=qchess%2Fsrc%2Ftimeout_player.py;h=1bd53c9ac0657b6b148097dfa38bd1e7d279b8c4;hb=52068b63d49f02f4455a4415356ecfe38db72f59;hp=36f9e204a90587cbdb4e20c71ae65da30e7e20a6;hpb=444244d5c7698bb7861cdb7c0ec6bfb0e8cebfb7;p=progcomp2013.git

diff --git a/qchess/src/timeout_player.py b/qchess/src/timeout_player.py
index 36f9e20..1bd53c9 100644
--- a/qchess/src/timeout_player.py
+++ b/qchess/src/timeout_player.py
@@ -3,6 +3,7 @@ import multiprocessing
 # Hacky alternative to using select for timing out players
 
 # WARNING: Do not wrap around HumanPlayer or things breakify
+# WARNING: Do not use in general or things breakify
 
 class Sleeper(multiprocessing.Process):
 	def __init__(self, timeout):
@@ -21,8 +22,11 @@ class Worker(multiprocessing.Process):
 		self.q = q
 
 	def run(self):
-		#print str(self) + " runs " + str(self.function) + " with args " + str(self.args) 
+		#print str(self) + " runs " + str(self.function) + " with args " + str(self.args)
+		#try:
 		self.q.put(self.function(*self.args))
+		#except IOError:
+		#	pass
 		
 		
 
@@ -42,8 +46,8 @@ def TimeoutFunction(function, args, timeout):
 		elif not s.is_alive():
 			w.terminate()
 			s.join()
-			raise Exception("UNRESPONSIVE")
-
+			raise Exception("TIMEOUT")
+		time.sleep(0.1)