txlyre 2 年之前
父節點
當前提交
dd0e7df7b2
共有 1 個文件被更改,包括 1 次插入6 次删除
  1. 1 6
      byafn.py

+ 1 - 6
byafn.py

@@ -190,7 +190,6 @@ class Peer:
     self.receive_lock = asyncio.Lock()
     self.ticks = 0
     self.last_message_in_ts = -1
-    self.last_message_out_ts = -1
 
 async def write(peer, data):
   peer.writer.write(data)
@@ -206,11 +205,7 @@ async def read(peer, size):
 
 async def cooldown(peer, out=True):
   if out:
-    diff = time.time() - peer.last_message_out_ts
-    if diff < RATELIMIT:
-      await asyncio.sleep(RATELIMIT - diff)
-
-    peer.last_message_out_ts = time.time()
+    await asyncio.sleep(RATELIMIT)
   else:
     if time.time() - peer.last_message_in_ts < RATELIMIT:
       raise Error(f'rate limit (={RATELIMIT}s.) exceeded for incoming messages')