diff options
author | Android Build Coastguard Worker <android-build-coastguard-worker@google.com> | 2022-11-13 02:20:05 +0000 |
---|---|---|
committer | Android Build Coastguard Worker <android-build-coastguard-worker@google.com> | 2022-11-13 02:20:05 +0000 |
commit | cec5bc676dfc0ade1b32f3873e93a3bd2c30e390 (patch) | |
tree | 77dc031614745bb406dbd90cea9a082a1b5cdd54 /cros_utils/locks.py | |
parent | 773bb66b7b5fab0b5f14d66455274040063e14bf (diff) | |
parent | 517424dcc11380511bc34f4a081f119104ff9e80 (diff) | |
download | toolchain-utils-android14-d1-s5-release.tar.gz |
Snap for 9286410 from 517424dcc11380511bc34f4a081f119104ff9e80 to udc-d1-releaseandroid-14.0.0_r9android-14.0.0_r8android-14.0.0_r7android-14.0.0_r6android-14.0.0_r5android-14.0.0_r4android-14.0.0_r3android-14.0.0_r12android-14.0.0_r11android-14.0.0_r10android14-d1-s7-releaseandroid14-d1-s6-releaseandroid14-d1-s5-releaseandroid14-d1-s4-releaseandroid14-d1-s3-releaseandroid14-d1-s2-releaseandroid14-d1-s1-releaseandroid14-d1-release
Change-Id: I0dfd9fe9a88cd3daf076b0fb77b69e3138c08e6c
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 |