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 | 71 lock_manager = host_lock_manager.HostLockManager() 74 with host_lock_manager.HostsLockedBy(lock_manager): 76 lock_manager, hostname=capturer_hostname, 111 lock_manager, hostname=work_client_hostname) 115 webdriver_instance = utils.allocate_webdriver_instance(lock_manager) 149 lock_manager, self._ap_spec, 277 lock_manager.unlock(webdriver_instance.hostname)
|
D | static_runner.py | 65 lock_manager = host_lock_manager.HostLockManager() 68 with host_lock_manager.HostsLockedBy(lock_manager): 70 lock_manager, hostname=capturer_hostname, 105 lock_manager, hostname=work_client_hostname) 109 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 | 24 def allocate_packet_capturer(lock_manager, hostname, prefix): argument 46 if lock_manager.lock([pcap.hostname]): 54 def allocate_webdriver_instance(lock_manager): argument 67 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 | 349 def lock_host_with_labels(afe, lock_manager, labels): argument 375 if lock_manager.lock([host.hostname]):
|