| /external/autotest/scheduler/ |
| D | drone_manager.py | 145 def __init__(self, drone): argument
146 self.drone = drone
151 return cmp(self.drone.used_capacity(), other.drone.used_capacity())
228 for drone in self.get_drones():
232 fields={'drone': drone.hostname}):
233 drone.call('initialize', self._results_dir)
237 for drone in self.get_drones():
238 drone.shutdown()
263 drone = drones.get_drone(hostname)
264 if drone:
[all …]
|
| D | thread_lib.py | 58 def worker(drone, results_queue): argument
68 logging.info('(Worker.%s) starting.', drone.hostname)
70 drone, drone.execute_queued_calls()))
71 logging.info('(Worker.%s) finished.', drone.hostname)
89 for drone, thread in self.drone_threads.iteritems():
94 drone_exceptions.append((drone, thread.err))
100 for drone, err in drone_exceptions:
102 (drone.hostname, err))
119 if drone_results.drone in results:
122 (drone_results.drone, results))
[all …]
|
| D | drone_task_queue.py | 55 for drone in drones:
56 if not drone.get_calls():
58 , drone)
61 'drone_hostname': drone.hostname,
62 'call_count': len(drone.get_calls())
66 drone_results = drone.execute_queued_calls()
67 logging.debug("Drone %s scheduled. crbug.com/853861", drone)
71 "Drone %s is not reachable by the scheduler.", drone)
76 if drone in self.results:
79 (drone, self.results))
[all …]
|
| D | luciferlib.py | 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
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)
[all …]
|
| D | drone_manager_unittest.py | 42 def send_file_to(self, drone, source_path, destination_path, argument
45 (drone, source_path, destination_path))
63 def was_file_sent(self, drone, source_path, destination_path): argument
65 (drone, source_path,
119 drone = self._test_choose_drone_for_execution_helper([(1, 2), (0, 2)],
121 self.assertEquals(drone.name, 1)
125 drone = self._test_choose_drone_for_execution_helper([(0, 1), (1, 3)],
127 self.assertEquals(drone.name, 1)
131 drone = self._test_choose_drone_for_execution_helper([(2, 1), (3, 2)],
133 self.assertEquals(drone.name, 1)
[all …]
|
| 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 | 51 drone = drones._RemoteDrone('fakehost', timestamp_remote_calls=False)
52 self.assertEqual('mock return', drone._execute_calls_impl(mock_calls))
62 drone = drones._RemoteDrone('fakehost', timestamp_remote_calls=False)
66 drone.queue_call('foo')
70 stdin=cPickle.dumps(drone.get_calls()), stdout_tee=None,
73 self.assertEqual(mock_return['results'], drone.execute_queued_calls())
|
| D | drones.py | 178 def send_file_to(self, drone, source_path, destination_path, argument
180 if drone.hostname == self.hostname:
184 self.queue_call('send_file_to', drone.hostname, source_path,
208 def send_file_to(self, drone, source_path, destination_path, argument
210 if drone.hostname == self.hostname:
213 elif isinstance(drone, _LocalDrone):
214 drone.queue_call('get_file_from', self.hostname, source_path,
217 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():
|
| D | monitor_db.py | 988 drone = luciferlib.spawn_starting_job_handler(
997 job=job, drone=drone.hostname())
1022 drone = luciferlib.spawn_parsing_job_handler(
1028 drone=drone.hostname())
|
| /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/venv/lucifer/ |
| D | handoffs.py | 40 .filter(Q(drone=socket.gethostname()) | Q(drone=None)))
|
| /external/autotest/frontend/afe/ |
| D | admin.py | 306 self.fields['drones'].widget.choices = [(drone.id, drone.hostname)
307 for drone in available_drones]
|
| D | models.py | 1800 drone = dbmodels.CharField( variable in JobHandoff
|
| /external/autotest/site_utils/sponge_lib/ |
| D | autotest_job_info.py | 72 def drone(self): member in AutotestJobInfo
|
| /external/autotest/site_utils/admin/scripts/ |
| D | check_db.out | 50 drone 11
|
| /external/autotest/ |
| D | global_config.ini | 222 # default_drone_set_name: This is required if drone sets are enabled.
236 # If True, the drone manager creates a thread for each drone.
377 # Flags to enable/disable drone election in resctricted subnet.
|
| /external/autotest/site_utils/ |
| D | server_manager_unittest.py | 120 drone = server_manager.create(hostname=self.PRIMARY_DRONE.hostname,
|
| /external/autotest/database/ |
| D | schema_129.sql | 359 `drone` varchar(128) DEFAULT NULL,
|
| /external/javaparser/ |
| D | changelog.md | 526 * Switched from drone.io to [Travis](https://travis-ci.org/javaparser/javaparser)
|
| /external/jline/src/src/test/resources/jline/example/ |
| D | english.gz | |
| /external/icu/icu4j/main/shared/data/ |
| D | Transliterator_Han_Latin_Definition.txt | 10439 靶機 < target\-drone;
28950 靶機 > target\-drone;
|
| /external/brotli/tests/testdata/ |
| D | plrabn12.txt | 6027 The female bee, that feeds her husband drone
|
| /external/cldr/tools/java/org/unicode/cldr/util/data/transforms/ |
| D | internal_raw_IPA-old.txt | 58193 drone %23138 dron
|
| D | internal_raw_IPA.txt | 49173 drone %32348 dron
|