From d524da9bd072ad1be4ac0d633e3e783094ddc2d7 Mon Sep 17 00:00:00 2001 From: Jonathan Herman Date: Wed, 19 Dec 2012 14:42:24 -0500 Subject: Added waiting tasks function. --- run/litmus_util.py | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/run/litmus_util.py b/run/litmus_util.py index fb2b341..340113d 100644 --- a/run/litmus_util.py +++ b/run/litmus_util.py @@ -67,6 +67,17 @@ def is_device(dev): mode = os.stat(dev)[stat.ST_MODE] return not (not mode & stat.S_IFCHR) +def waiting_tasks(): + reg = re.compile(r'^ready.*(?P\d+)$', re.M) + with open('/proc/litmus/stats', 'r') as f: + data = f.read() + + # Ignore if no tasks are waiting for release + match = re.search(reg, data) + ready = match.group("READY") + + return 0 if not ready else int(ready) + def release_tasks(): try: -- cgit v1.2.2