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]
else:
raise Exception("UNRESPONSIVE")
+
return s.strip(" \r\n")
def send_message(self,s):
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()
-
git.ucc.asn.au / progcomp2013.git / blobdiff
UCC git Repository :: git.ucc.asn.au