Lines Matching refs:backfill_queue

168     def __init__(self, reader, writer, db, request_stats, backfill_queue, upstream, read_only):  argument
173         self.backfill_queue = backfill_queue
373                 await self.backfill_queue.put((method, taskhash))
497             'tasks': self.backfill_queue.qsize(),
499         await self.backfill_queue.join()
527 …return ServerClient(reader, writer, self.db, self.request_stats, self.backfill_queue, self.upstrea…
535                     item = await self.backfill_queue.get()
537                         self.backfill_queue.task_done()
541                     self.backfill_queue.task_done()
546             await self.backfill_queue.put(None)
559         self.backfill_queue = asyncio.Queue()