Searched refs:batch_locker (Results 1 – 4 of 4) sorted by relevance
| /external/autotest/server/cros/chaos_lib/ |
| D | static_runner.py | 108 batch_locker = ap_batch_locker.ApBatchLocker(
112 while batch_locker.has_more_aps():
131 aps = batch_locker.get_ap_batch(batch_size=batch_size)
139 batch_locker, job)
151 batch_locker.unlock_and_reclaim_aps()
161 batch_locker.unlock_and_reclaim_ap(ap.host_name)
171 utils.release_ap(ap, batch_locker)
179 ap, batch_locker)
215 utils.release_ap(ap, batch_locker)
223 batch_locker.unlock_aps()
|
| D | chaos_runner.py | 148 batch_locker = ap_batch_locker.ApBatchLocker(
152 while batch_locker.has_more_aps():
171 aps = batch_locker.get_ap_batch(batch_size=batch_size)
184 batch_locker, job, self._broken_pdus)
196 batch_locker.unlock_and_reclaim_aps()
206 batch_locker.unlock_and_reclaim_ap(ap.host_name)
216 utils.release_ap(ap, batch_locker, self._broken_pdus)
224 ap, batch_locker, self._broken_pdus)
260 utils.release_ap(ap, batch_locker, self._broken_pdus)
268 batch_locker.unlock_aps()
|
| /external/autotest/server/cros/network/ |
| D | chaos_clique_utils.py | 192 def release_ap(ap, batch_locker, broken_pdus=[]): argument
205 batch_locker.unlock_one_ap(ap.host_name)
208 def filter_quarantined_and_config_failed_aps(aps, batch_locker, job, argument
240 release_ap(ap, batch_locker, broken_pdus)
243 batch_locker.unlock_one_ap(ap.host_name)
|
| /external/autotest/server/cros/ap_configurators/ |
| D | ap_configurator_test.py | 51 self.batch_locker = ap_batch_locker.ApBatchLocker(lock_manager,
53 ap_batch = self.batch_locker.get_ap_batch(batch_size=1)
69 if self.batch_locker:
70 self.batch_locker.unlock_aps()
|