Lines Matching full:drone
7 """Tests for the drone managers thread queue."""
24 """Threaded task queue drone library tests."""
27 """Create and initialize a Remote Drone.
29 @param hostname: The name of the host for the remote drone.
31 @return: A remote drone instance.
44 self.drone_utility_path = 'mock-drone-utility-path'
57 # Invoke the worker method with a drone that has a queued call and check
60 drone = self.create_remote_drone('fakehostname')
63 drone.queue_call('foo')
67 stdin=cPickle.dumps(drone.get_calls()), stdout_tee=None,
70 task_queue.worker(drone, task_queue.results_queue)
74 result.drone == drone and
80 """Test waiting on drone threads."""
146 # Insert results for the same drone twice into the results queue
161 # in a drone results dict.
191 # Queue 2 calls against each drone, and confirm that the host's
196 for drone in drones:
197 drone.queue_call('foo')
198 drone.queue_call('bar')
203 stdin=cPickle.dumps(drone.get_calls()), stdout_tee=None,
208 for drone, thread in task_queue.drone_threads.iteritems():
209 self.assertTrue(drone.hostname in thread.getName())
213 for drone, result in results.iteritems():
