X-Git-Url: https://plomlompom.com/repos/foo.html?a=blobdiff_plain;ds=sidebyside;f=plomrogue%2Fio.py;h=68f580ba3fa689b78075a175ed4a2e880128235f;hb=baab532ba5125527bdc7061864f7cc7db8d7abc3;hp=8e0f9bf530548572eb7c07d389d7188e19af47d1;hpb=540aec0e9bf55d0452cffda4b34e1995d3724abf;p=plomrogue2
diff --git a/plomrogue/io.py b/plomrogue/io.py
index 8e0f9bf..68f580b 100644
--- a/plomrogue/io.py
+++ b/plomrogue/io.py
@@ -14,10 +14,21 @@ class GameIO():
self.servers = []
def loop(self, q):
- """Handle commands coming through queue q, run game, send results back."""
+ """Handle commands coming through queue q, run game, send results back.
+
+ As basic flood protection, Only accepts one command per connection per
+ 1/100 of a second.
+
+ """
+ import time
+ potential_flooders = {}
while True:
try:
command, connection_id = q.get(timeout=0.001)
+ if connection_id in potential_flooders:
+ if int(time.time() * 100) == potential_flooders[connection_id]:
+ continue
+ potential_flooders[connection_id] = int(time.time() * 100)
self.handle_input(connection_id, command)
except queue.Empty:
self.game.run_tick()