| /external/autotest/scheduler/ |
| D | drone_manager.py | 138 def __init__(self, drone): argument
139 self.drone = drone
144 return cmp(self.drone.used_capacity(), other.drone.used_capacity())
228 for drone in self.get_drones():
229 drone.shutdown()
246 drone = drones.get_drone(hostname)
247 if drone:
248 self._drones[drone.hostname] = drone
249 drone.call('initialize', self.absolute_path(''))
272 for hostname, drone in self._drones.iteritems():
[all …]
|
| D | thread_lib.py | 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))
[all …]
|
| D | drone_manager_unittest.py | 43 def send_file_to(self, drone, source_path, destination_path, argument
46 (drone, source_path, destination_path))
64 def was_file_sent(self, drone, source_path, destination_path): argument
66 (drone, source_path,
124 drone = self._test_choose_drone_for_execution_helper([(1, 2), (0, 2)],
126 self.assertEquals(drone.name, 1)
130 drone = self._test_choose_drone_for_execution_helper([(0, 1), (1, 3)],
132 self.assertEquals(drone.name, 1)
136 drone = self._test_choose_drone_for_execution_helper([(2, 1), (3, 2)],
138 self.assertEquals(drone.name, 1)
[all …]
|
| D | drone_task_queue.py | 48 for drone in drones:
49 if not drone.get_calls():
51 drone_results = drone.execute_queued_calls()
52 if drone in self.results:
55 (drone, self.results))
56 self.results[drone] = drone_results
|
| D | status_server.py | 52 def _write_drone(self, drone): argument
53 if drone.allowed_users:
54 allowed_users = ', '.join(drone.allowed_users)
58 % (drone.hostname, drone.active_processes, drone.max_processes,
60 if not drone.enabled:
67 for drone in self.server._drone_manager.get_drones():
68 self._write_drone(drone)
|
| D | site_drone_manager.py | 57 drone = self._get_drone_for_process(process)
58 drone.queue_kill_process(process)
71 drone = drones.get_drone(hostname)
72 if drone:
74 drone.call('initialize', self.absolute_path(''))
79 self._drones[drone.hostname] = drone
|
| D | thread_lib_unittest.py | 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
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():
[all …]
|
| D | drones_unittest.py | 50 drone = drones._RemoteDrone('fakehost', timestamp_remote_calls=False)
51 self.assertEqual('mock return', drone._execute_calls_impl(mock_calls))
61 drone = drones._RemoteDrone('fakehost', timestamp_remote_calls=False)
65 drone.queue_call('foo')
69 stdin=cPickle.dumps(drone.get_calls()), stdout_tee=None,
72 self.assertEqual(mock_return['results'], drone.execute_queued_calls())
|
| D | drones.py | 197 def send_file_to(self, drone, source_path, destination_path, argument
199 if drone.hostname == self.hostname:
203 self.queue_call('send_file_to', drone.hostname, source_path,
227 def send_file_to(self, drone, source_path, destination_path, argument
229 if drone.hostname == self.hostname:
232 elif isinstance(drone, _LocalDrone):
233 drone.queue_call('get_file_from', self.hostname, source_path,
236 self.queue_call('send_file_to', drone.hostname, source_path,
|
| D | drone_task_queue_unittest.py | 72 for drone in drones:
73 drone.queue_call('foo')
74 drone.queue_call('bar')
79 stdin=cPickle.dumps(drone.get_calls()), stdout_tee=None,
86 for drone, result in results.iteritems():
|
| /external/autotest/server/ |
| D | system_utils.py | 65 for drone in get_drones():
66 new_drone_ip_map[drone] = utils.get_ip_address(drone)
68 not utils.get_restricted_subnet(new_drone_ip_map[drone],
70 new_unrestricted_drones.append(drone)
|
| /external/autotest/site_utils/ |
| D | stats_poller.py | 27 for drone in infra.drone_servers():
29 threads.append(threading.Thread(target=f, args=(drone,)))
|
| D | server_manager_unittest.py | 120 drone = server_manager.create(hostname=self.BACKUP_DRONE.hostname,
|
| /external/autotest/frontend/afe/ |
| D | admin.py | 309 self.fields['drones'].widget.choices = [(drone.id, drone.hostname)
310 for drone in available_drones]
|
| /external/autotest/server/site_tests/moblab_RunSuite/ |
| D | control.dummyServer | 14 # moblab_RunSuite requires .boto file from drone. Disable SSP for this test as
|
| D | control.smoke | 14 # moblab_RunSuite requires .boto file from drone. Disable SSP for this test as
|
| /external/autotest/ |
| D | global_config.ini | 184 # default_drone_set_name: This is required if drone sets are enabled.
198 # If True, the drone manager creates a thread for each drone.
318 # Flags to enable/disable devserver and drone election in resctricted subnet.
|
| /external/autotest/site_utils/admin/scripts/ |
| D | check_db.out | 50 drone 11
|
| /external/icu/icu4j/main/shared/data/ |
| D | Transliterator_Han_Latin_Definition.txt | 10437 靶機 < target\-drone;
28948 靶機 > target\-drone;
|