.BANCHO. Add max packets buffer size
This commit is contained in:
parent
4ed5e0d14a
commit
e7b7dc932a
|
@ -34,7 +34,7 @@ if userToken.matchID != -1 and userToken.actionID != actions.MULTIPLAYING and us
|
|||
userToken.partMatch()
|
||||
'''
|
||||
|
||||
# Update cached stats if our pp changedm if we've just submitted a score or we've changed gameMode
|
||||
# Update cached stats if our pp changed if we've just submitted a score or we've changed gameMode
|
||||
if (userToken.actionID == actions.PLAYING or userToken.actionID == actions.MULTIPLAYING) or (userToken.pp != userUtils.getPP(userID, userToken.gameMode)) or (userToken.gameMode != packetData["gameMode"]):
|
||||
# Always update game mode, or we'll cache stats from the wrong game mode if we've changed it
|
||||
userToken.gameMode = packetData["gameMode"]
|
||||
|
|
|
@ -96,7 +96,10 @@ class token:
|
|||
bytes -- (packet) bytes to enqueue
|
||||
"""
|
||||
if not self.irc:
|
||||
self.queue += bytes_
|
||||
if len(bytes_) < 10 * 10 ** 6:
|
||||
self.queue += bytes_
|
||||
else:
|
||||
log.warning("{}'s packets buffer is above 10M!! Lost some data!".format(self.username))
|
||||
|
||||
|
||||
def resetQueue(self):
|
||||
|
|
Loading…
Reference in New Issue
Block a user