X-Git-Url: https://git.ucc.asn.au/?p=progcomp2013.git;a=blobdiff_plain;f=qchess%2Fsrc%2Fnetwork.py;h=32a7b503a9720632f2ceee4c836ccec53293ffd5;hp=20f632bdd09bf93634c035ec14a63911caf24b8d;hb=64978647120812a13948e2146de81281b38a54d5;hpb=8a1471b7bee654a02fc205dd4de7bebd12084435 diff --git a/qchess/src/network.py b/qchess/src/network.py index 20f632b..32a7b50 100644 --- a/qchess/src/network.py +++ b/qchess/src/network.py @@ -4,38 +4,129 @@ import select 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 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)+">" + + 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: + 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) + + + + 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, colour, address = None): + def __init__(self, address = (None,4562)): self.socket = socket.socket() + self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) #self.socket.setblocking(0) - - if colour == "white": - self.port = 4562 - else: - self.port = 4563 - - self.src = None - - # print str(self) + " listens on port " + str(self.port) - - if address == None: - self.host = socket.gethostname() - self.socket.bind((self.host, self.port)) + self.address = address + self.server = (address[0] == 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])) self.socket.listen(5) - self.src, self.address = self.socket.accept() + self.src, self.actual_address = self.socket.accept() + self.src.send("ok\n") - if self.get_response() == "QUIT": + s = self.get_response() + if s == "QUIT": self.src.close() + return + elif s != "ok": + self.src.close() + self.__init__(colour, (self.address[0], int(s)), baseplayer) + return + else: - self.host = address - self.socket.connect((address, self.port)) + time.sleep(0.3) + self.socket.connect(self.address) self.src = self.socket self.src.send("ok\n") - if self.get_response() == "QUIT": + s = self.get_response() + if s == "QUIT": + self.src.close() + return + elif s != "ok": self.src.close() + self.__init__(colour, (self.address[0], int(s)), baseplayer) + return + + + + def __str__(self): + return "@network:"+str(self.address) def get_response(self): + # Timeout the start of the message (first character) if network_timeout_start > 0.0: ready = select.select([self.src], [], [], network_timeout_start)[0] @@ -58,6 +149,7 @@ class Network(): else: raise Exception("UNRESPONSIVE") + return s.strip(" \r\n") def send_message(self,s): @@ -70,122 +162,9 @@ class Network(): self.src.send(s + "\n") else: raise Exception("UNRESPONSIVE") - - 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 - - -class NetworkSender(Player,Network): - def __init__(self, base_player, address = None): - self.base_player = base_player - Player.__init__(self, base_player.name, base_player.colour) - - self.address = address - - def connect(self): - Network.__init__(self, self.base_player.colour, self.address) - - - - def select(self): - [x,y] = self.base_player.select() - choice = self.board.grid[x][y] - s = str(x) + " " + str(y) - #print str(self) + ".select sends " + s - self.send_message(s) - return [x,y] - - def get_move(self): - [x,y] = self.base_player.get_move() - s = str(x) + " " + str(y) - #print str(self) + ".get_move sends " + s - self.send_message(s) - return [x,y] - - def update(self, s): - self.base_player.update(s) - s = s.split(" ") - [x,y] = map(int, s[0:2]) - selected = self.board.grid[x][y] - if selected != None and selected.colour == self.colour and len(s) > 2 and not "->" in s: - s = " ".join(s[0:3]) - for i in range(2): - if selected.types_revealed[i] == True: - s += " " + str(selected.types[i]) - else: - s += " unknown" - #print str(self) + ".update sends " + s - self.send_message(s) - - - def quit(self, final_result): - self.base_player.quit(final_result) - #self.src.send("QUIT " + str(final_result) + "\n") - self.src.close() - -class NetworkReceiver(Player,Network): - def __init__(self, colour, address=None): - - Player.__init__(self, "NetworkReceiver", colour) - - self.address = address - - self.board = None - - def connect(self): - Network.__init__(self, self.colour, self.address) - - - def select(self): - s = self.get_response() - #print str(self) + ".select gets " + s - [x,y] = map(int,s.split(" ")) - if x == -1 and y == -1: - #print str(self) + ".select quits the game" - with game.lock: - game.final_state = "network terminated " + self.colour - game.stop() - return [x,y] - def get_move(self): - s = self.get_response() - #print str(self) + ".get_move gets " + s - [x,y] = map(int,s.split(" ")) - if x == -1 and y == -1: - #print str(self) + ".get_move quits the game" - with game.lock: - game.final_state = "network terminated " + self.colour - game.stop() - return [x,y] - def update(self, result): - - result = result.split(" ") - [x,y] = map(int, result[0:2]) - selected = self.board.grid[x][y] - if selected != None and selected.colour == self.colour and len(result) > 2 and not "->" in result: - s = self.get_response() - #print str(self) + ".update - receives " + str(s) - s = s.split(" ") - selected.choice = int(s[2]) - for i in range(2): - selected.types[i] = str(s[3+i]) - if s[3+i] == "unknown": - selected.types_revealed[i] = False - else: - selected.types_revealed[i] = True - selected.current_type = selected.types[selected.choice] - else: - pass - #print str(self) + ".update - ignore result " + str(result) - - - def quit(self, final_result): + def close(self): + self.src.shutdown() self.src.close() -