Lines Matching refs:Drone
93 @returns: Drone instance
96 drone = manager.pick_drone_to_use()
118 drone.spawn(_ENV, args,
119 output_file=_prepare_output_file(drone, results_dir))
120 drone.add_active_processes(1)
124 return drone
138 @returns: Drone instance
142 drone = manager.pick_drone_to_use()
144 drone = manager.get_drone_for_pidfile(pidfile_id)
164 drone.spawn(_ENV, args,
165 output_file=_prepare_output_file(drone, results_dir))
166 drone.add_active_processes(1)
170 return drone
176 def _prepare_output_file(drone, results_dir):
178 drone.run('mkdir', ['-p', logdir])
204 """Simplified drone API."""
225 """Return a drone to use from a pidfile.
232 """Return a drone to use.
234 Various options can be passed to optimize drone selection.
236 @param num_processes: number of processes the drone is intended
245 """Return absolute path for drone results.
254 This should be done to allow the drone manager to check the
259 The exact semantics depends on the drone manager implementation;
271 """Reorder drone queue according to modified process counts.
273 Call this after Drone.add_active_processes().
279 """Wrap an old style drone."""
286 raise TypeError('Drone has an unknown host type')
318 class Drone(object):
319 """Simplified drone API."""
322 """Return the hostname of the drone."""
338 be used to perform setup local to the drone, when the drone may
367 The exact semantics depends on the drone manager implementation;
373 by the drone manager (so the count added by this function only
378 class LocalDrone(Drone):
379 """Local implementation of Drone."""
393 class RemoteDrone(Drone):
394 """Remote implementation of Drone through SSH."""
396 def __init__(self, drone):
397 host = drone._host
399 raise TypeError('RemoteDrone must be passed a drone with SSHHost')
400 self._drone = drone
401 self._host = drone._host
