mirror of
https://github.com/Jylpah/blitz-tools.git
synced 2026-10-24 03:29:54 +02:00
Set max size for replay queue
This commit is contained in:
1 parent
fca40d5030
commit
b4123c479d
1 file changed
+2
-10
+2
-10
@@ -422,9 +422,10 @@ async def main(argv):
|
|||||||
bu.debug('No DB in use')
|
bu.debug('No DB in use')
|
||||||
|
|
||||||
try:
|
try:
|
||||||
replayQ = asyncio.Queue()
|
replayQ = asyncio.Queue(maxsize=1000)
|
||||||
reader_tasks = []
|
reader_tasks = []
|
||||||
# Make replay Queue
|
# Make replay Queue
|
||||||
|
|
||||||
scanner_task = asyncio.create_task(mk_replayQ(replayQ, args.files))
|
scanner_task = asyncio.create_task(mk_replayQ(replayQ, args.files))
|
||||||
bu.debug('Replay scanner started')
|
bu.debug('Replay scanner started')
|
||||||
# Start tasks to process the Queue
|
# Start tasks to process the Queue
|
||||||
@@ -448,15 +449,6 @@ async def main(argv):
|
|||||||
results.extend(res[0])
|
results.extend(res[0])
|
||||||
players.update(res[1])
|
players.update(res[1])
|
||||||
|
|
||||||
# ## Remove battle_time from the player:tank data in case DB is not in use
|
|
||||||
# if db == None:
|
|
||||||
# players_tmp = set()
|
|
||||||
# for player in players:
|
|
||||||
# #bu.debug('playerID: ' + player + ' ==> ' + prune_stat_id(player))
|
|
||||||
# players_tmp.add(prune_stat_id(player))
|
|
||||||
# #bu.debug(str(len(players_tmp)))
|
|
||||||
# players = players_tmp
|
|
||||||
|
|
||||||
(player_stats, stat_id_map) = await process_player_stats(players, TASK_N, args, db)
|
(player_stats, stat_id_map) = await process_player_stats(players, TASK_N, args, db)
|
||||||
bu.verbose('')
|
bu.verbose('')
|
||||||
bu.debug('Number of player stats: ' + str(len(player_stats)))
|
bu.debug('Number of player stats: ' + str(len(player_stats)))
|
||||||
|
|||||||
Reference in new issue
Block a user