Lines Matching refs:queue_entries

134         queue_entries = self._dispatcher._refresh_pending_queue_entries()
135         hosts = list(rdb_lib.acquire_hosts(queue_entries))
165         queue_entries = self._dispatcher._refresh_pending_queue_entries()
166         hosts = list(rdb_lib.acquire_hosts(queue_entries))
226         queue_entries = self._dispatcher._refresh_pending_queue_entries()
227         matching_host  = rdb_lib.acquire_hosts(queue_entries).next()
262         queue_entries = self._dispatcher._refresh_pending_queue_entries()
263         matching_hosts  = list(rdb_lib.acquire_hosts(queue_entries))
266         for job, host in zip(queue_entries, matching_hosts):
284         queue_entries = self._dispatcher._refresh_pending_queue_entries()
285         matching_host  = rdb_lib.acquire_hosts(queue_entries).next()
304         queue_entries = self._dispatcher._refresh_pending_queue_entries()
305         matching_host  = rdb_lib.acquire_hosts(queue_entries).next()
326         queue_entries = self._dispatcher._refresh_pending_queue_entries()
330         self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
355         queue_entries = self._dispatcher._refresh_pending_queue_entries()
359         self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
364         queue_entries = self._dispatcher._refresh_pending_queue_entries()
366         self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
371         queue_entries = self._dispatcher._refresh_pending_queue_entries()
373         self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
396         queue_entries = self._dispatcher._refresh_pending_queue_entries()
397         hosts = list(rdb_lib.acquire_hosts(queue_entries))
415         queue_entries = self._dispatcher._refresh_pending_queue_entries()
437         self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
469         queue_entries = self._dispatcher._refresh_pending_queue_entries()
515         list(rdb_lib.acquire_hosts(queue_entries))
530         queue_entries = self._dispatcher._refresh_pending_queue_entries()
531         matching_host = rdb_lib.acquire_hosts(queue_entries).next()
568         queue_entries = self._dispatcher._refresh_pending_queue_entries()
569         matching_hosts = rdb_lib.acquire_hosts(queue_entries, suite_min_duts)
570         for host, queue_entry in zip(matching_hosts, queue_entries):