| /external/autotest/scheduler/ |
| 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
|
| drone_manager.py | 138 def __init__(self, drone):
139 self.drone = drone
144 return cmp(self.drone.used_capacity(), other.drone.used_capacity())
150 only a single "drone" for localhost or multiple remote drones.
158 # about a drone hitting process limit is sent.
179 # maps hostname to Drone object
186 # map drone hostname to time stamp of email that
187 # has been sent about the drone hitting process limit
[all...] |
| thread_lib.py | 6 """Thread library for drone management.
14 2. execute: Takes a list of drones and invokes a worker thread per drone.
77 """Threaded implementation of a drone task queue."""
79 result = collections.namedtuple('task', ['drone', 'results'])
91 def worker(drone, results_queue):
94 Execute calls queued against the given drone and place the return value
97 @param drone: A drone with calls to execute.
99 ThreadedTaskQueue.result from the drone calls.
101 logging.info('(Worker.%s) starting.', drone.hostname
[all...] |
| site_drone_manager.py | 57 drone = self._get_drone_for_process(process)
58 drone.queue_kill_process(process)
65 Catches AutoservRunError if the drone fails initialization and does not
68 @param hostname: Hostname of the drone we are trying to add.
70 logging.info('Adding drone %s' % hostname)
71 drone = drones.get_drone(hostname)
72 if drone:
74 drone.call('initialize', self.absolute_path(''))
76 logging.error('Failed to initialize drone %s with error: %s',
79 self._drones[drone.hostname] = dron
[all...] |
| status_server.py | 52 def _write_drone(self, drone):
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)
|
| drones_unittest.py | 22 self.drone_utility_path = 'mock-drone-utility-path'
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())
|
| 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...] |
| 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.py | 21 """The drone is non-sshable."""
28 * allowed_users: set of usernames allowed to use this drone. if None,
29 any user can use this drone.
32 """Instantiate an abstract drone.
47 # If drone supports server-side packaging. The property support_ssp will
63 """Gets the capacity used by this drone
66 direct comparisons, so that a 0/10 drone is considered less heavily
67 loaded than a 0/2 drone.
87 raise ValueError('Drone cannot execute calls without a host.')
108 subject = 'Warning from drone %s' % self.hostnam
[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...] |
| /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).
|
| autoserv | 229 metadata = {'drone': socket.gethostname(),
259 'drone': socket.gethostname()}
325 'However, no drone is found to support server-side '
326 'packaging. The test will be executed in a drone without '
363 metadata = {'drone': socket.gethostname(),
603 # running in a drone does not support SSP, thus no need to stage server-side
638 # running in a drone does not have SSP supported and a warning will be logs.
673 logging.debug('autoserv is running in drone %s.', socket.gethostname())
|
| /external/autotest/site_utils/ |
| stats_poller.py | 27 for drone in infra.drone_servers():
28 for f in pollers.get('drone', []):
29 threads.append(threading.Thread(target=f, args=(drone,)))
|
| server_manager_utils.py | 82 Roles : drone
86 Note : Drone in lab1
90 server2 | primary | drone | 2014-11-25 12:00:00 | | Drone
94 drone : server2(primary),
227 servers = get_servers(role=server_models.ServerRole.ROLE.DRONE,
|
| 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.BACKUP_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,
170 server_models.validate(role=server_models.ServerRole.ROLE.DRONE)
175 [server_models.ServerRole.ROLE.DRONE])
[all...] |
| /external/autotest/frontend/afe/ |
| admin.py | 307 available_drones = models.Drone.objects.exclude(id__in=drone_ids_used)
309 self.fields['drones'].widget.choices = [(drone.id, drone.hostname)
310 for drone in available_drones]
319 admin.site.register(models.Drone)
|
