diff options
author | Android Build Coastguard Worker <android-build-coastguard-worker@google.com> | 2023-07-03 15:57:36 +0000 |
---|---|---|
committer | Android Build Coastguard Worker <android-build-coastguard-worker@google.com> | 2023-07-03 15:57:36 +0000 |
commit | 9086b037eb418807f99d5ce5825f285d6b427cc6 (patch) | |
tree | 77dc031614745bb406dbd90cea9a082a1b5cdd54 /cros_utils/locks.py | |
parent | 732a4eb324abf0d0f0c2bf539634a5e45ef5f56f (diff) | |
parent | 40214b48188358a80b7478bfff21d4814dd9177c (diff) | |
download | toolchain-utils-android14-mainline-adbd-release.tar.gz |
Snap for 10428683 from 40214b48188358a80b7478bfff21d4814dd9177c to mainline-adbd-releaseaml_adb_341520010aml_adb_341517070aml_adb_340912530aml_adb_340912350aml_adb_340912200aml_adb_340912000android14-mainline-adbd-release
Change-Id: I578fe57f97e55cbf6f5fc268be1f15035a00433b
Diffstat (limited to 'cros_utils/locks.py')
-rw-r--r-- | cros_utils/locks.py | 67 |
1 files changed, 35 insertions, 32 deletions
diff --git a/cros_utils/locks.py b/cros_utils/locks.py index 848e23fc..db6f4343 100644 --- a/cros_utils/locks.py +++ b/cros_utils/locks.py @@ -1,49 +1,52 @@ # -*- coding: utf-8 -*- # -# Copyright 2019 The Chromium OS Authors. All rights reserved. +# Copyright 2019 The ChromiumOS Authors # Use of this source code is governed by a BSD-style license that can be # found in the LICENSE file. """Utilities for locking machines.""" -from __future__ import print_function import time -import lock_machine - from cros_utils import logger +import lock_machine def AcquireLock(machines, chromeos_root, timeout=1200): - """Acquire lock for machine(s) with timeout.""" - start_time = time.time() - locked = True - sleep_time = min(10, timeout / 10.0) - while True: - try: - lock_machine.LockManager(machines, False, - chromeos_root).UpdateMachines(True) - break - except Exception as e: - if time.time() - start_time > timeout: - locked = False - logger.GetLogger().LogWarning( - 'Could not acquire lock on {0} within {1} seconds: {2}'.format( - repr(machines), timeout, str(e))) - break - time.sleep(sleep_time) - return locked + """Acquire lock for machine(s) with timeout.""" + start_time = time.time() + locked = True + sleep_time = min(10, timeout / 10.0) + while True: + try: + lock_machine.LockManager( + machines, False, chromeos_root + ).UpdateMachines(True) + break + except Exception as e: + if time.time() - start_time > timeout: + locked = False + logger.GetLogger().LogWarning( + "Could not acquire lock on {0} within {1} seconds: {2}".format( + repr(machines), timeout, str(e) + ) + ) + break + time.sleep(sleep_time) + return locked def ReleaseLock(machines, chromeos_root): - """Release locked machine(s).""" - unlocked = True - try: - lock_machine.LockManager(machines, False, - chromeos_root).UpdateMachines(False) - except Exception as e: - unlocked = False - logger.GetLogger().LogWarning( - 'Could not unlock %s. %s' % (repr(machines), str(e))) - return unlocked + """Release locked machine(s).""" + unlocked = True + try: + lock_machine.LockManager(machines, False, chromeos_root).UpdateMachines( + False + ) + except Exception as e: + unlocked = False + logger.GetLogger().LogWarning( + "Could not unlock %s. %s" % (repr(machines), str(e)) + ) + return unlocked |