Lines Matching refs:drones
9 from autotest_lib.scheduler import drones
21 # results on drones will be placed under the drone_installation_directory in a
136 """Wrapper to compare drones based on used_capacity().
138 These objects can be used to keep a heap of drones by capacity.
151 This class acts as an interface from the scheduler to drones, whether it be
152 only a single "drone" for localhost or multiple remote drones.
173 # holds the list of all processes running on all drones
190 # A threaded task queue used to refresh drones asynchronously.
206 # all drones failed to initialize
207 raise DroneManagerError('No valid drones found')
213 self._results_drone = drones.get_drone(results_repository_hostname)
252 drone = drones.get_drone(hostname)
264 Reread global config options for all drones.
454 drones = list(self.get_drones())
455 for drone in drones:
466 self._refresh_task_queue.execute(drones, wait=False)
490 logging.info("Drones refreshed.")
530 """Refresh all drones."""
542 on drones.
544 # Invoke calls queued on all drones since the last call to execute
591 execution) given the current load on drones.
593 @param drone_hostnames_allowed: list of drones that can be used. May be
602 # all drones disabled or inaccessible
610 def _least_loaded_drone(self, drones):
611 drone_to_use = drones[0]
612 for drone in drones[1:]:
631 # cycle through drones is order of increasing used capacity until
635 # Drones do not support server-side packaging, used as backup if no
667 # Drones are all over loaded, pick the one with least load.
713 @param drone_hostnames_allowed (optional): hostnames of the drones that
738 raise DroneManagerError('command failed; no drones available: %s'
819 Get a new temporary path guaranteed to be unique across all drones
831 base_dir = os.path.join(drones.AUTOTEST_INSTALL_DIR,
