summaryrefslogtreecommitdiff
path: root/oslo_concurrency/processutils.py
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@yahoo-inc.com>2015-06-19 16:57:41 -0700
committerJoshua Harlow <harlowja@yahoo-inc.com>2015-06-22 10:34:30 -0700
commita0fabfc6885c9bcbe4d1b2c0d2e611ff6ad8d3bd (patch)
treeaa725125addfe5af78fb1fbc3129ab08f8e94270 /oslo_concurrency/processutils.py
parent2fc22f9a30a3f2942356f5a7bec13c29aa2a75d7 (diff)
downloadoslo-concurrency-a0fabfc6885c9bcbe4d1b2c0d2e611ff6ad8d3bd.tar.gz
Use better timing mechanisms instead of time.time()
To ensure we show accurate timing information about lock acqusition and release times use a timing mechanism which can not/should not move backwards. Change-Id: I9559b20cf7de67fc474e6e17eda23791ecc4122e
Diffstat (limited to 'oslo_concurrency/processutils.py')
-rw-r--r--oslo_concurrency/processutils.py10
1 files changed, 6 insertions, 4 deletions
diff --git a/oslo_concurrency/processutils.py b/oslo_concurrency/processutils.py
index 13dc1f7..0fd7915 100644
--- a/oslo_concurrency/processutils.py
+++ b/oslo_concurrency/processutils.py
@@ -27,6 +27,7 @@ import time
from oslo_utils import importutils
from oslo_utils import strutils
+from oslo_utils import timeutils
import six
from oslo_concurrency._i18n import _
@@ -209,10 +210,12 @@ def execute(*cmd, **kwargs):
cmd = [str(c) for c in cmd]
sanitized_cmd = strutils.mask_password(' '.join(cmd))
+ watch = timeutils.StopWatch()
while attempts > 0:
attempts -= 1
+ watch.restart()
+
try:
- start_time = time.time()
LOG.log(loglevel, _('Running cmd (subprocess): %s'), sanitized_cmd)
_PIPE = subprocess.PIPE # pylint: disable=E1101
@@ -240,9 +243,8 @@ def execute(*cmd, **kwargs):
obj.stdin.close() # pylint: disable=E1101
_returncode = obj.returncode # pylint: disable=E1101
- end_time = time.time() - start_time
- LOG.log(loglevel, 'CMD "%s" returned: %s in %0.3fs' %
- (sanitized_cmd, _returncode, end_time))
+ LOG.log(loglevel, 'CMD "%s" returned: %s in %0.3fs',
+ sanitized_cmd, _returncode, watch.elapsed())
if on_completion:
on_completion(obj)