From: Christian Heller Date: Sun, 20 Aug 2017 19:41:08 +0000 (+0200) Subject: Simulate world processing during INC calls. X-Git-Url: https://plomlompom.com/repos/template?a=commitdiff_plain;h=867b39dd4cf6bb0ce4bead991f93a3900fdf6fcc;p=plomrogue2-experiments Simulate world processing during INC calls. --- diff --git a/server.py b/server.py index ed60b6a..f4e2901 100755 --- a/server.py +++ b/server.py @@ -98,6 +98,7 @@ class CommandHandler: self.queues_out = queues_out self.pool = Pool() self.world = World() + self.pool_result = None def send_to(self, connection_id, msg): """Send msg to client of connection_id.""" @@ -131,10 +132,21 @@ class CommandHandler: self.send_to(connection_id, reply) def cmd_inc(self, connection_id): - """Increment world.turn, send TURN_FINISHED, NEW_TURN to everyone.""" + """Increment world.turn, send TURN_FINISHED, NEW_TURN to everyone. + + To simulate game processing waiting times, a one second delay between + TURN_FINISHED and NEW_TURN occurs; after NEW_TURN, some expensive + calculations are started as pool processes that need to be finished + until a further INC finishes the turn. + """ + from time import sleep + if self.pool_result is not None: + self.pool_result.wait() self.send_all('TURN_FINISHED ' + str(self.world.turn)) + sleep(1) self.world.turn += 1 self.send_all('NEW_TURN ' + str(self.world.turn)) + self.pool_result = self.pool.map_async(fib, (35,35)) def cmd_get_turn(self, connection_id): """Send world.turn to caller."""