Lines Matching refs:drone

91     def worker(drone, results_queue):  argument
101         logging.info('(Worker.%s) starting.', drone.hostname)
103             drone, drone.execute_queued_calls()))
104         logging.info('(Worker.%s) finished.', drone.hostname)
122         for drone, thread in self.drone_threads.iteritems():
127                 drone_exceptions.append((drone, thread.err))
133         for drone, err in drone_exceptions:
135                               (drone.hostname, err))
153             if drone_results.drone in results:
156                         (drone_results.drone, results))
157             results[drone_results.drone] = drone_results.results
186         for drone in drones:
187             if not drone.get_calls():
191                     args=(drone, self.results_queue))
196             self.drone_threads[drone] = worker_thread
199                                   (self.name, drone.hostname.replace('.', '_')))