|
@@ -208,7 +208,7 @@ async def cooldown(peer, out=True):
|
|
|
if out:
|
|
if out:
|
|
|
diff = time.time() - peer.last_message_out_ts
|
|
diff = time.time() - peer.last_message_out_ts
|
|
|
if diff < RATELIMIT:
|
|
if diff < RATELIMIT:
|
|
|
- await asyncio.sleep(RATELIMIT - diff)
|
|
|
|
|
|
|
+ await asyncio.sleep(min(RATELIMIT - diff + 0.1, RATELIMIT + 0.01))
|
|
|
|
|
|
|
|
peer.last_message_out_ts = time.time()
|
|
peer.last_message_out_ts = time.time()
|
|
|
else:
|
|
else:
|
