| /external/autotest/frontend/migrations/ |
| 126_add_job_handoff_drone_column.py | 3 drone varchar(128) NULL
8 ALTER TABLE afe_job_handoffs DROP COLUMN drone;
|
| 062_drone_sets_unique.py | 44 raise Exception('Some drones are associated with more than one drone '
|
| /external/autotest/scheduler/ |
| thread_lib.py | 6 """Thread library for drone management.
14 2. execute: Takes a list of drones and invokes a worker thread per drone.
47 """Threaded implementation of a drone task queue."""
49 result = collections.namedtuple('task', ['drone', 'results'])
58 def worker(drone, results_queue):
61 Execute calls queued against the given drone and place the return value
64 @param drone: A drone with calls to execute.
66 ThreadedTaskQueue.result from the drone calls.
68 logging.info('(Worker.%s) starting.', drone.hostname
[all...] |
| drone_manager.py | 145 def __init__(self, drone):
146 self.drone = drone
151 return cmp(self.drone.used_capacity(), other.drone.used_capacity())
157 only a single "drone" for localhost or multiple remote drones.
165 # about a drone hitting process limit is sent.
186 # maps hostname to Drone object
223 # don't initialize() the results drone - we don't want to clear out any
228 for drone in self.get_drones()
[all...] |
| drone_task_queue.py | 29 """Invoke methods via SSH to a drone.
48 for drone in drones:
49 if not drone.get_calls():
51 drone_results = drone.execute_queued_calls()
52 if drone in self.results:
54 'Task queue has recorded results for drone %s: %s' %
55 (drone, self.results))
56 self.results[drone] = drone_results
|
| drones.py | 22 """The drone is non-sshable."""
29 * allowed_users: set of usernames allowed to use this drone. if None,
30 any user can use this drone.
33 """Instantiate an abstract drone.
48 # If drone supports server-side packaging. The property support_ssp will
65 """Gets the capacity used by this drone
68 direct comparisons, so that a 0/10 drone is considered less heavily
69 loaded than a 0/2 drone.
89 raise ValueError('Drone cannot execute calls without a host.')
108 subject = 'Warning from drone %s' % self.hostnam
[all...] |
| drone_manager_unittest.py | 43 def send_file_to(self, drone, source_path, destination_path,
46 (drone, source_path, destination_path))
64 def was_file_sent(self, drone, source_path, destination_path):
66 (drone, source_path,
71 _DRONE_INSTALL_DIR = '/drone/install/dir'
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)]
[all...] |
| drone_task_queue_unittest.py | 7 """Tests for the drone task queue."""
23 """Drone task queue tests."""
26 """Create and initialize a Remote Drone.
28 @param hostname: The name of the host for the remote drone.
30 @return: A remote drone instance.
43 self.drone_utility_path = 'mock-drone-utility-path'
68 # Queue 2 calls against each drone, and confirm that the host's
72 for drone in drones:
73 drone.queue_call('foo')
74 drone.queue_call('bar'
[all...] |
| thread_lib_unittest.py | 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
[all...] |
| drones_unittest.py | 23 self.drone_utility_path = 'mock-drone-utility-path'
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())
|
| luciferlib.py | 82 @returns: Drone instance
98 @returns: Drone instance
102 drone = manager.pick_drone_to_use()
104 drone = manager.get_drone_for_pidfile(pidfile_id)
129 drone.spawn(_ENV, args, output_file=output_file)
130 return drone
144 @returns: Drone instance
148 drone = manager.pick_drone_to_use()
150 drone = manager.get_drone_for_pidfile(pidfile_id)
172 drone.spawn(_ENV, args, output_file=output_file
[all...] |
| drone_logging_config.py | 13 """This class sets up logging for the Drone Machines.
41 timestamped log name with prefix 'drone'. Both the stdout and stderr
53 format of 'drone.log.YEAR-MONTH-DAY'
61 logfile_name = self.get_timestamped_log_name('drone')
|
| agent_task.py | 56 - pass the autoserv command, working directory etc to drone manager.
62 running on the drone through the PidfileRunMonitor created in prolog.
391 # restricted and unrestricted subnet. No drone can work in such
397 'no drone is available to run the test.')
409 logging.info('DUT %s is in restricted subnet, drone can only '
418 # If filtered_drones is an empty set, that means no drone is
423 'drone is available to run the test.')
461 Returns the user's default drone set, if present.
463 Otherwise, returns the global default drone set.
467 logging.warning('%s had no owner; using default drone set'
[all...] |
| /external/autotest/server/ |
| system_utils.py | 44 """A cache object to store drone list related data.
53 # A cache of a dict of (drone, ip).
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)
91 """Get a dict of (drone, ip).
|
| /external/autotest/site_utils/ |
| server_manager_unittest.py | 54 attrs={'role': server_models.ServerRole.ROLE.DRONE})
117 server=mox.IgnoreArg(), role=server_models.ServerRole.ROLE.DRONE
120 drone = server_manager.create(hostname=self.PRIMARY_DRONE.hostname,
121 role=server_models.ServerRole.ROLE.DRONE)
137 [server_models.ServerRole.ROLE.DRONE])
152 server_models.validate(role=server_models.ServerRole.ROLE.DRONE)
155 [server_models.ServerRole.ROLE.DRONE])
160 role=server_models.ServerRole.ROLE.DRONE,
171 server_models.validate(role=server_models.ServerRole.ROLE.DRONE)
176 [server_models.ServerRole.ROLE.DRONE])
[all...] |
| server_manager_actions.py | 9 be restarted. For example, scheduler needs to be restarted after a drone is
45 server_models.ServerRole.ROLE.DRONE: [RESTART_SCHEDULER],
64 server_models.ServerRole.ROLE.DRONE: [RESTART_SCHEDULER],
|
| server_manager_utils.py | 84 Roles : drone
88 Note : Drone in lab1
132 server2 | primary | drone | 2014-11-25 12:00:00 | | Drone
163 drone : server2(primary),
297 servers = get_servers(role=server_models.ServerRole.ROLE.DRONE,
|
| /external/autotest/client/common_lib/ |
| lsbrelease_utils.py | 25 If the caller is from drone, it can pass in the file content here.
46 If the caller is from drone, it can pass in the file content here.
58 If the caller is from drone, it can pass in the file content here.
71 If the caller is from drone, it can pass in the file content here.
83 lsb-release. If the caller is from drone, it can pass in the file
97 If the caller is from drone, it can pass in the file content here.
111 If the caller is from drone, it can pass in the file content here.
168 If the caller is from drone, it can pass in the file content here.
181 If the caller is from drone, it can pass in the file content here.
193 If the caller is from drone, it can pass in the file content here
[all...] |
| /external/autotest/site_utils/lxc/ |
| __init__.py | 8 3. Mount a directory in drone to the test container.
|
| /external/autotest/site_utils/sponge_lib/ |
| sponge_utils_functional_test.py | 101 job_keyvals = {'drone': 'localhost',
120 job.keyval_dict = {'drone': 'server1',
|
| autotest_job_info.py | 72 def drone(self): member in class:AutotestJobInfo
73 """The drone used to run the job."""
74 return self._job.keyval_dict.get('drone', socket.gethostname())
|
| /external/autotest/venv/lucifer/ |
| handoffs.py | 40 .filter(Q(drone=socket.gethostname()) | Q(drone=None)))
|
| /external/autotest/server/cros/audio/ |
| audio_test.py | 38 """Install sox command on autotest drone."""
|
| /external/autotest/frontend/server/ |
| models.py | 76 'roles': ['drone', 'scheduler'],
98 ROLE_LIST = ['afe', 'scheduler', 'host_scheduler', 'drone', 'devserver',
145 validate(role='drone', status='repair_required', hostname='server1')
|
| /external/autotest/frontend/afe/ |
| admin.py | 304 available_drones = models.Drone.objects.exclude(id__in=drone_ids_used)
306 self.fields['drones'].widget.choices = [(drone.id, drone.hostname)
307 for drone in available_drones]
316 admin.site.register(models.Drone)
|
