Searched refs:lock_manager (Results 1 – 11 of 11) sorted by relevance
| /external/toolchain-utils/ |
| D | afe_lock_machine.py | 631 lock_manager = AFELockManager(machine_list, options.force,
635 machine_states = lock_manager.GetMachineStates(cmd=options.cmd)
639 lock_manager.ListMachineStates(machine_states)
642 if not lock_manager.force:
643 lock_manager.CheckMachineLocks(machine_states, cmd)
644 lock_manager.UpdateMachines(True)
647 if not lock_manager.force:
648 lock_manager.CheckMachineLocks(machine_states, cmd)
649 lock_manager.UpdateMachines(False)
652 lock_manager.AddMachinesToLocalServer()
[all …]
|
| /external/autotest/server/site_tests/sonic_AppTest/ |
| D | control | 38 lock_manager = host_lock_manager.HostLockManager()
43 # manager handles unlocking hosts locked through the lock_manager.
44 with host_lock_manager.HostsLockedBy(lock_manager):
47 lock_manager.lock([sonic_hostname])
49 sonic_hostname = sonic_client_utils.acquire_sonic(lock_manager)
|
| /external/autotest/server/cros/chaos_lib/ |
| D | chaos_runner.py | 72 lock_manager = host_lock_manager.HostLockManager()
75 with host_lock_manager.HostsLockedBy(lock_manager):
77 lock_manager, hostname=capturer_hostname,
112 lock_manager, hostname=work_client_hostname)
116 webdriver_instance = utils.allocate_webdriver_instance(lock_manager)
150 lock_manager, self._ap_spec,
280 lock_manager.unlock(webdriver_instance.hostname)
|
| D | static_runner.py | 66 lock_manager = host_lock_manager.HostLockManager()
75 with host_lock_manager.HostsLockedBy(lock_manager):
77 lock_manager, hostname=capturer_hostname,
112 lock_manager, hostname=work_client_hostname)
116 lock_manager, self._ap_spec,
|
| /external/autotest/server/cros/clique_lib/ |
| D | clique_runner.py | 214 lock_manager = host_lock_manager.HostLockManager()
215 with host_lock_manager.HostsLockedBy(lock_manager):
217 lock_manager, self._dut_pool_spec)
226 lock_manager, hostname=capturer_hostname)
233 lock_manager, hostname=hostname)
245 lock_manager, ap_spec,
|
| D | clique_dut_locker.py | 112 def __init__(self, lock_manager, dut_pool_spec, retries=MAX_RETRIES): argument
121 self.lock_manager = lock_manager
157 if self.lock_manager.lock([host_name]):
170 afe, self.lock_manager, labels=labels) + '.cros'
|
| /external/autotest/server/cros/network/ |
| D | chaos_clique_utils.py | 23 def allocate_packet_capturer(lock_manager, hostname, prefix): argument
45 if lock_manager.lock([pcap.hostname]):
53 def allocate_webdriver_instance(lock_manager): argument
66 afe, lock_manager, labels=['webdriver'])
|
| /external/autotest/server/cros/ |
| D | sonic_client_utils.py | 139 def acquire_sonic(lock_manager, additional_labels=None): argument
157 lambda: site_utils.lock_host_with_labels(afe, lock_manager, labels),
|
| /external/autotest/server/cros/ap_configurators/ |
| D | ap_batch_locker.py | 101 def __init__(self, lock_manager, ap_spec, retries=MAX_RETRIES, argument
118 self.manager = lock_manager
|
| D | ap_configurator_test.py | 50 lock_manager = host_lock_manager.HostLockManager()
51 self.batch_locker = ap_batch_locker.ApBatchLocker(lock_manager,
|
| /external/autotest/server/ |
| D | site_utils.py | 343 def lock_host_with_labels(afe, lock_manager, labels): argument
369 if lock_manager.lock([host.hostname]):
|