# Update the board when a piece has been selected
# "type" is apparently reserved, so I'll use "state"
- def update_select(self, x, y, type_index, state, sanity=True):
+ def update_select(self, x, y, type_index, state, sanity=True, deselect=True):
+ debug(str(self) + " update_select called")
piece = self.grid[x][y]
if piece.types[type_index] == "unknown":
if not state in self.unrevealed_types[piece.colour].keys() and sanity == True:
piece.types[type_index] = state
piece.current_type = state
- if len(self.possible_moves(piece)) <= 0:
+ if deselect == True and len(self.possible_moves(piece)) <= 0:
piece.deselect() # Piece can't move; deselect it
# Piece needs to recalculate moves
# Update the board when a piece has been moved
def update_move(self, x, y, x2, y2, sanity=True):
-
+ debug(str(self) + " update_move called \""+str(x)+ " " + str(y) + " -> " + str(x2) + " " + str(y2) + "\"")
piece = self.grid[x][y]
#print "Moving " + str(x) + "," + str(y) + " to " + str(x2) + "," + str(y2) + "; possible_moves are " + str(self.possible_moves(piece))
# Update the board from a string
# Guesses what to do based on the format of the string
- def update(self, result, sanity=True):
- #print "Update called with \"" + str(result) + "\""
+ def update(self, result, sanity=True, deselect=True):
+ debug(str(self) + " update called \""+str(result)+"\"")
# String always starts with 'x y'
try:
s = result.split(" ")
piece = self.grid[x][y]
if piece == None and sanity == True:
- raise Exception("EMPTY")
+ raise Exception("EMPTY " + str(x) + " " + str(y))
# If a piece is being moved, the third token is '->'
# We could get away with just using four integers, but that wouldn't look as cool
# Select the piece
- self.update_select(x, y, type_index, state, sanity)
+ self.update_select(x, y, type_index, state, sanity=sanity, deselect=deselect)
return result
if p.current_type == "unknown":
- raise Exception("SANITY: Piece state unknown")
+ raise Exception("SANITY: Unknown state for piece: "+str(p))
# The below commented out code causes things to break badly
#for t in p.types:
# if t == "unknown":
def reset_board(self, s):
pass
+
+ def __str__(self):
+ return self.name + "<"+str(self.colour)+">"
+
+ def base_player(self):
+ return self
# Player that runs from another process
class ExternalAgent(Player):
network_timeout_start = -1.0 # Timeout in seconds to wait for the start of a message
network_timeout_delay = 1.0 # Maximum time between two characters being received
-class Network(Player):
- def __init__(self, colour, address = (None,4562), baseplayer = None):
+class NetworkPlayer(Player):
+ def __init__(self, colour, network, player):
+ Player.__init__(self, "@network:"+str(network.address), colour)
+ self.player = player
+ self.network = network
+
+ def __str__(self):
+ return "NetworkPlayer<"+str(self.colour)+","+str(self.player)+">"
- if baseplayer != None:
- name = baseplayer.name + " --> @network"
+ def select(self):
+ debug(str(self) + " select called")
+ if self.player != None:
+ s = self.player.select()
+ self.send_message(str(s[0]) + " " + str(s[1]))
else:
- name = "<-- @network"
+ s = map(int, self.get_response().split(" "))
+ for p in game.players:
+ if p != self and isinstance(p, NetworkPlayer) and p.player == None:
+ p.network.send_message(str(s[0]) + " " + str(s[1]))
+ return s
+
+ def send_message(self, message):
+ debug(str(self) + " send_message(\""+str(message)+"\") called")
+ self.network.send_message(message)
+ def get_response(self):
+ debug(str(self) + " get_response() called")
+ s = self.network.get_response()
+ debug(str(self) + " get_response() returns \""+str(s)+"\"")
+ return s
+
+
+ def get_move(self):
+ debug(str(self) + " get_move called")
+ if self.player != None:
+ s = self.player.get_move()
+ self.send_message(str(s[0]) + " " + str(s[1]))
+ else:
+ s = map(int, self.get_response().split(" "))
+ for p in game.players:
+ if p != self and isinstance(p, NetworkPlayer) and p.player == None:
+ p.network.send_message(str(s[0]) + " " + str(s[1]))
+ return s
+
+ def update(self, result):
+ debug(str(self) + " update(\""+str(result)+"\") called")
+ if self.network.server == True:
+ if self.player == None:
+ self.send_message(result)
+ elif self.player != None:
+ result = self.get_response()
+ self.board.update(result, deselect=False)
-
- Player.__init__(self, name, colour)
- debug("Colour is " + str(self.colour))
+
+ if self.player != None:
+ result = self.player.update(result)
+
+ return result
+
+
+
+ def base_player(self):
+ if self.player == None:
+ return self
+ else:
+ return self.player.base_player()
+
+ def quit(self, result):
+ pass
+
+class Network():
+ def __init__(self, address = (None,4562)):
self.socket = socket.socket()
self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
- self.baseplayer = baseplayer
#self.socket.setblocking(0)
-
self.address = address
self.server = (address[0] == None)
-
- if self.colour == "black":
- self.address = (self.address[0], self.address[1] + 1)
-
- debug(str(self) + ":"+str(self.address))
- self.board = None
-
+
+ self.connected = False
def connect(self):
+ debug(str(self) + "Tries to connect")
+ self.connected = True
if self.address[0] == None:
self.host = "0.0.0.0" #socket.gethostname() # Breaks things???
self.socket.bind((self.host, self.address[1]))
return
else:
+ time.sleep(0.3)
self.socket.connect(self.address)
self.src = self.socket
self.src.send("ok\n")
return
- def select(self):
- if self.baseplayer != None:
- s = self.baseplayer.select()
- self.send_message(str(s[0]) + " " + str(s[1]))
- return s
- return map(int,self.get_response().split(" "))
-
- def get_move(self):
- if self.baseplayer != None:
- s = self.baseplayer.get_move()
- self.send_message(str(s[0]) + " " + str(s[1]))
- return s
- return map(int,self.get_response().split(" "))
-
- def update(self, result):
- if self.baseplayer != None:
- result = self.baseplayer.update(result)
- self.send_message(result)
- return result
- if self.server:
- self.send_message(result)
- else:
- s = self.get_response()
- if self.board != None:
- self.board.update(s)
-
+
def __str__(self):
- return "Network<"+str(self.colour)+","+str(self.baseplayer)+">:"+str(self.address)
+ return "@network:"+str(self.address)
def get_response(self):
- debug(str(self) + " get_response called...")
+
# Timeout the start of the message (first character)
if network_timeout_start > 0.0:
ready = select.select([self.src], [], [], network_timeout_start)[0]
else:
raise Exception("UNRESPONSIVE")
- debug(str(self) + " get_response returns " + s.strip(" \r\n"))
+
return s.strip(" \r\n")
def send_message(self,s):
else:
raise Exception("UNRESPONSIVE")
- debug(str(self) + " send_message sent " + s)
-
- def check_quit(self, s):
- s = s.split(" ")
- if s[0] == "QUIT":
- with game.lock:
- game.final_result = " ".join(s[1:]) + " " + str(opponent(self.colour))
- game.stop()
- return True
-
- def quit(self, result):
- if self.baseplayer != None:
- self.send_message("QUIT")
-
- with game.lock:
- game.final_result = result
- game.stop()
-
-
-
-
+
+ def close(self):
+ self.src.shutdown()
+ self.src.close()
# --- network.py --- #
import threading
# A thread that runs the game
class GameThread(StoppableThread):
- def __init__(self, board, players):
+ def __init__(self, board, players, server = True):
StoppableThread.__init__(self)
self.board = board
self.players = players
self.lock = threading.RLock() #lock for access of self.state
self.cond = threading.Condition() # conditional for some reason, I forgot
self.final_result = ""
+ self.server = server
+
+
+
for p in self.players:
with self.lock:
- if isinstance(p, Network) and p.baseplayer != None:
- self.state["turn"] = p.baseplayer # "turn" contains the player who's turn it is
- else:
- self.state["turn"] = p
+ self.state["turn"] = p.base_player()
#try:
if True:
[x,y] = p.select() # Player selects a square
if self.stopped():
break
- if isinstance(p, Network) == False or p.server == True:
- result = self.board.select(x, y, colour = p.colour)
+ if isinstance(p, NetworkPlayer):
+ if p.network.server == True:
+ result = self.board.select(x, y, colour = p.colour)
+ else:
+ result = None
+
else:
- result = p.get_response()
- self.board.update(result)
-
+ result = self.board.select(x, y, colour = p.colour)
+
+ result = p.update(result)
for p2 in self.players:
- p2.update(result) # Inform players of what happened
+ if p2 != p:
+ p2.update(result) # Inform players of what happened
log(result)
if self.stopped():
break
-
- result = str(x) + " " + str(y) + " -> " + str(x2) + " " + str(y2)
- log(result)
-
- self.board.update_move(x, y, x2, y2)
+ if isinstance(p, NetworkPlayer):
+ if p.network.server == True:
+ result = str(x) + " " + str(y) + " -> " + str(x2) + " " + str(y2)
+ self.board.update_move(x, y, x2, y2)
+ else:
+ result = None
+
+ else:
+ result = str(x) + " " + str(y) + " -> " + str(x2) + " " + str(y2)
+ self.board.update_move(x, y, x2, y2)
+
+ result = p.update(result)
for p2 in self.players:
- p2.update(result) # Inform players of what happened
+ if p2 != p:
+ p2.update(result) # Inform players of what happened
+
+ log(result)
+
#print "Reject " + str(i) + str(event.pos) + " vs " + str(t)
+
# Function to pick players in a nice GUI way
def SelectPlayers(self, players = []):
time.sleep(1)
p = None
players.append(p)
- elif choice == 2:
+ elif choice == 1:
address = ""
while address == "":
self.board.display_grid(self.window, self.grid_sz)
# --- graphics.py --- #
+def dedicated_server():
+ max_games = 4
+ games = []
+ while True:
+ # Get players
+ s = socket.socket()
+ s.bind(("0.0.0.0", 4562))
+ s.listen(2)
+ ss = s.accept()
+
+ debug("Got white player")
+
+ g = subprocess.Popen(["python", "qchess.py", "@network::"+str(4700+len(games)), "@network::"+str(4700+len(games)), "--log="+"_".join(str(datetime.datetime.now()).split(" ")) + ".log"], stdout=subprocess.PIPE)
+ games.append(g)
+
+ ss[0].send("white " + str(4700 + len(games)-1))
+ ss[0].shutdown(socket.SHUT_RDWR)
+ ss[0].close()
+
+ time.sleep(0.5)
+ ss = s.accept()
+
+ debug("Got black player")
+
+ ss[0].send("black " + str(4700 + len(games)-1))
+ ss[0].shutdown(socket.SHUT_RDWR)
+ ss[0].close()
+
+ s.shutdown(socket.SHUT_RDWR)
+ s.close()
+
+ while len(games) > max_games:
+ ready = select.select(map(lambda e : e.stdout, games),[], [], None)
+ for r in ready:
+ s = r.readline().strip(" \r\n").split(" ")
+ if s[0] == "white" or s[0] == "black":
+ for g in games[:]:
+ if g.stdout == r:
+ games.remove(g)
+
+def client(addr):
+
+ s = socket.socket()
+ s.connect((addr, 4562))
+
+ [colour,port] = s.recv(1024).strip(" \r\n").split(" ")
+
+ debug("Colour: " + colour + ", port: " + port)
+
+ s.shutdown(socket.SHUT_RDWR)
+ s.close()
+
+ if colour == "white":
+ p = subprocess.Popen(["python", "qchess.py", "@human", "@network:"+addr+":"+port])
+ else:
+ p = subprocess.Popen(["python", "qchess.py", "@network:"+addr+":"+port, "@human"])
+ p.wait()
+ sys.exit(0)# --- server.py --- #
#!/usr/bin/python -u
# Do you know what the -u does? It unbuffers stdin and stdout
return HumanPlayer(name, colour)
s = name[1:].split(":")
if s[0] == "network":
- address = (None, 4562)
+ ip = None
+ port = 4562
+ #print str(s)
if len(s) > 1:
- address = (s[1], 4562)
- return Network(colour, address, baseplayer = None)
+ if s[1] != "":
+ ip = s[1]
+ if len(s) > 2:
+ port = int(s[2])
+
+ if ip == None:
+ if colour == "black":
+ port += 1
+ elif colour == "white":
+ port += 1
+
+ return NetworkPlayer(colour, Network((ip, port)), None)
if s[0] == "internal":
import inspect
if len(f.split(":")) == 2:
max_moves = int(f.split(":")[1])
-
+
+ elif (arg[1] == '-' and arg[2:] == "server"):
+ if len(arg[2:].split("=") <= 1):
+ dedicated_server()
+ else:
+ client(arg[2:].split("=")[1])
+ sys.exit(0)
elif (arg[1] == '-' and arg[2:].split("=")[0] == "log"):
# Log file
if len(arg[2:].split("=")) == 1:
sys.stderr.write(sys.argv[0] + " : Graphics window closed before players chosen\n")
return 45
-
- # Wrap Networks players around original players if necessary
- for i in range(len(players)):
- if isinstance(players[i], Network) and players[i].baseplayer == None:
- for j in range(len(players)):
- if i == j:
+ old = players[:]
+ for p in old:
+ if isinstance(p, NetworkPlayer):
+ for i in range(len(old)):
+ if old[i] == p or isinstance(old[i], NetworkPlayer):
continue
-
- port = players[i].address[1]
- if players[j].colour == "black" and players[i].colour == "white":
- pass
- elif players[j].colour == "white" and players[i].colour == "black":
- port -= 1
- players[j] = Network(players[j].colour, (players[i].address[0], port), baseplayer = players[j])
-
-
+ players[i] = NetworkPlayer(old[i].colour, p.network, old[i])
+
for p in players:
- if isinstance(p, Network):
- if p.address[0] != None:
- time.sleep(0.2)
- p.connect()
+ debug(str(p))
+ if isinstance(p, NetworkPlayer):
+ p.board = game.board
+ if not p.network.connected:
+ if not p.network.server:
+ time.sleep(0.2)
+ p.network.connect()
# If using windows, select won't work; use horrible TimeoutPlayer hack
sys.stdout.write(game.final_result + "\n")
return error
+
+
+
+
+
+
+
# This is how python does a main() function...
if __name__ == "__main__":
sys.exit(102)
# --- main.py --- #
-# EOF - created from make on Fri Apr 5 14:17:50 WST 2013
+# EOF - created from make on Sat Apr 20 10:20:13 WST 2013
git.ucc.asn.au / progcomp2013.git / blobdiff
UCC git Repository :: git.ucc.asn.au