| /external/autotest/scheduler/ |
| drones_unittest.py | 4 """Tests for autotest_lib.scheduler.drones."""
11 from autotest_lib.scheduler import drones namespace
21 self.god.stub_function(drones.drone_utility, 'create_host')
30 drones.drone_utility.create_host.expect_call('fakehost').and_return(
33 self.assertRaises(drones.DroneUnreachable,
34 drones._RemoteDrone, 'fakehost')
38 self.god.stub_with(drones._RemoteDrone, '_drone_utility_path',
40 drones.drone_utility.create_host.expect_call('fakehost').and_return(
50 drone = drones._RemoteDrone('fakehost', timestamp_remote_calls=False)
56 self.god.stub_with(drones._RemoteDrone, '_drone_utility_path'
[all...] |
| drone_task_queue_unittest.py | 18 from autotest_lib.scheduler import drones namespace
32 drones.drone_utility.create_host.expect_call(hostname).and_return(
35 return drones._RemoteDrone(hostname, timestamp_remote_calls=False)
42 self.god.stub_function(drones.drone_utility, 'create_host')
46 self.god.stub_with(drones._RemoteDrone, '_drone_utility_path',
71 drones = [drone1, drone2, drone3]
72 for drone in drones:
82 task_queue.execute(drones, wait=False)
83 self.assertTrue(set(task_queue.results.keys()) == set(drones))
97 self.assertTrue(task_queue.execute(drones, wait=True)[drone1] =
[all...] |
| drone_task_queue.py | 12 """A manager to run queued tasks in drones and gather results from them."""
19 """Get a results dictionary keyed on drones.
21 @return: A dictionary of return values from drones.
28 def execute(self, drones, wait=True):
31 @param drones: A list of drones with calls to execute.
32 @param wait: If True, this method will only return when all the drones
38 @return: A dictionary keyed on the drones, containing a list of return
48 for drone in drones:
|
| thread_lib_unittest.py | 18 from autotest_lib.scheduler import drones namespace
33 drones.drone_utility.create_host.expect_call(hostname).and_return(
36 return drones._RemoteDrone(hostname, timestamp_remote_calls=False)
43 self.god.stub_function(drones.drone_utility, 'create_host')
47 self.god.stub_with(drones._RemoteDrone, '_drone_utility_path',
58 # that the drones host.run method is invoked for the call, and the
100 # mock drones and confirm that:
160 # Insert results for different drones and check that they're returned
195 drones = [drone1, drone2, drone3]
196 for drone in drones
[all...] |
| site_drone_manager.py | 8 from autotest_lib.scheduler import drones, scheduler_config namespace
66 add it to the list of usable drones.
71 drone = drones.get_drone(hostname)
|
| drone_manager_unittest.py | 11 from autotest_lib.scheduler import drone_manager, drone_utility, drones namespace
18 class MockDrone(drones._AbstractDrone):
81 self.god.stub_with(drones, 'AUTOTEST_INSTALL_DIR',
87 self.god.stub_function(drones, 'get_drone')
93 # set up some dummy drones
256 (drones.get_drone.expect_call(self.mock_drone.name)
261 drones.get_drone.expect_call(results_hostname).and_return(results_drone)
366 _DRONE_CLASS = drones._RemoteDrone
377 self.god.stub_function(drones.drone_utility, 'create_host')
378 drones.drone_utility.create_host.expect_call(drone_hostname).and_return
[all...] |
| thread_lib.py | 9 and syncing threads across remote and localhost drones asynchronously. It also
14 2. execute: Takes a list of drones and invokes a worker thread per drone.
15 This method assumes that all drones have a queue of pending calls
20 on the drones.
86 # refreshing all drones across 'execute' and 'get_results'.
140 """Get a results dictionary keyed on the drones.
146 @return: A dictionary of return values from the drones.
161 def execute(self, drones, wait=True):
164 @param drones: A list of drones with calls to execute
[all...] |
| drone_manager.py | 13 from autotest_lib.scheduler import email_manager, drone_utility, drones namespace
19 # results on drones will be placed under the drone_installation_directory in a
134 """Wrapper to compare drones based on used_capacity().
136 These objects can be used to keep a heap of drones by capacity.
149 This class acts as an interface from the scheduler to drones, whether it be
150 only a single "drone" for localhost or multiple remote drones.
169 # holds the list of all processes running on all drones
189 # A threaded task queue used to refresh drones asynchronously.
205 # all drones failed to initialize
206 raise DroneManagerError('No valid drones found'
[all...] |
| postjob_task.py | 15 from autotest_lib.scheduler import agent_task, drones, drone_manager namespace
21 _parser_path = os.path.join(drones.AUTOTEST_INSTALL_DIR, 'tko', 'parse')
363 os.path.join(drones.AUTOTEST_INSTALL_DIR, 'scheduler',
|
| monitor_db_unittest.py | 421 'SCHEDULER', 'drones', 'localhost')
[all...] |
| /external/autotest/site_utils/deploy_autotest/ |
| lab_deploy_helper.py | 14 lab_deploy_helper.py (sync,restart,print) (devservers, drones, scheduler)+.
38 """Returns tuple containing the autotest scheduler and list of drones."""
41 autotest_drones = CONFIG.get_config_value('scheduler', 'drones',
87 master, drones = autotest_scheduler_drones()
94 if common_util.DRONES in requested_server_set:
95 for server in drones:
106 if common_util.DRONES in requested_server_set:
107 for server in drones:
118 if common_util.DRONES in requested_server_set:
119 for server in drones
[all...] |
| /external/autotest/server/ |
| system_utils.py | 21 """Get a list of drones from server database or global config.
26 drones = global_config.global_config.get_config_value(
27 scheduler_config.CONFIG_SECTION, 'drones', default='localhost')
28 return [hostname.strip() for hostname in drones.split(',')]
50 # A cache of unrestricted drones.
78 """Get a list of cached unrestricted drones.
|
| /external/autotest/tko/ |
| retrieve_logs.cgi | 109 # Drones do not run this script when receiving '/results/...' request.
110 # Only master should check drones and shards for the requested log.
111 # Also restricted users do not have access to drones or shards,
115 drones = system_utils.get_drones()
119 tpool_args = _get_tpool_args(drones, job_path, False, host_set)
|
| /external/autotest/site_utils/ |
| setup_dev_autotest.sh | 169 drones: localhost
|
| /external/autotest/frontend/afe/ |
| admin.py | 306 drone_ids_used.update(drone_set.drones.values_list('id', flat=True))
309 self.fields['drones'].widget.choices = [(drone.id, drone.hostname)
314 filter_horizontal = ('drones',)
|
| models.py | 204 raise Exception('Only superusers may edit drones')
210 raise Exception('Only superusers may delete drones')
224 A set of scheduler drones
226 These will be used by the scheduler to decide what drones a job is allowed
230 drones: the drones that are part of the set
238 drones = dbmodels.ManyToManyField(Drone, db_table='afe_drone_sets_drones') variable in class:DroneSet
307 Gets the hostnames of all drones in this drone set
309 return set(self.drones.all().values_list('hostname', flat=True))
[all...] |
