From eff0a9ee9693181b1f844566274029a172f8e57b Mon Sep 17 00:00:00 2001 From: Mattias Andrée Date: Thu, 2 Apr 2015 15:51:16 +0200 Subject: add locks plugin MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Mattias Andrée --- examples/plugins/locks | 83 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 83 insertions(+) create mode 100644 examples/plugins/locks (limited to 'examples/plugins/locks') diff --git a/examples/plugins/locks b/examples/plugins/locks new file mode 100644 index 0000000..b24f870 --- /dev/null +++ b/examples/plugins/locks @@ -0,0 +1,83 @@ +# -*- python -*- + +# A xpybar configuration example testing the features of plugins.locks + +import time +import threading + +from plugins.locks import Locks + + +OUTPUT, HEIGHT, YPOS, TOP = 0, 12, 24, True + + +locks = Locks().locks +headers = ('Id', 'Syscall', 'Level', 'Shared', 'Pid', 'Device', 'Inode', 'Range', 'Mountpoint', 'Pathname') +def convert(lock): + rc = [] + rc.append(str(lock.lock_id)) + rc.append({'FLOCK' : 'flock', 'POSIX' : 'lockf'}[lock.lock_type]) + rc.append('mandatory' if lock.mandatory else 'advisory') + rc.append('yes' if lock.shared else 'no') + rc.append(str(lock.pid)) + rc.append('%i:%i' % (lock.major, lock.minor)) + rc.append(str(lock.inode)) + rc.append('%i..%s' % (lock.start, 'eof' if lock.end is None else str(lock.end))) + rc += ['...'] * 2 + return rc +text_locks = [convert(lock) for lock in locks] + +HEIGHT *= len(text_locks) + + +def locate_files(): + dev_cache = {} + for i, lock in enumerate(locks): + if (lock.major, lock.minor) in dev_cache: + mountpoint, device = dev_cache[(lock.major, lock.minor)] + text_locks[i][-2] = mountpoint + text_locks[i][5] = '%s(%s)' % (text_locks[i][5], device) + else: + device = lock.find_device() + mountpoint = device[1] if device is not None else '(not found)' + device = device[2] if device is not None else None + dev_cache[(lock.major, lock.minor)] = (mountpoint, device) + text_locks[i][-2] = mountpoint + if device is not None: + text_locks[i][5] = '%s(%s)' % (text_locks[i][5], device) + if not mountpoint.startswith('/'): + text_locks[i][-1] = '(not found)' + try: + with open('/proc/%i/comm' % lock.pid, 'rb') as file: + cmd = file.read() + cmd = cmd.decode('utf-8', 'replace')[:-1] + text_locks[i][4] = '%s(%s)' % (text_locks[i][4], cmd) + except: + pass + bar.invalidate() + for i, lock in enumerate(locks): + mountpoint = text_locks[i][-2] + if not mountpoint.startswith('/'): + continue + pathnames = lock.find_pathname(mountpoint) + if len(pathnames) == 0: + text_locks[i][-1] = '(not found)' + else: + text_locks[i][-1] = pathnames[0] + bar.invalidate() + + +start_ = start +def start(): + start_() + async(locate_files) + + +semaphore = threading.Semaphore() +def redraw(): + semaphore.acquire(blocking = True) + text = '\n'.join(' │ '.join('%s: %s' % (h, v) for (h, v) in zip(headers, lock)) for lock in text_locks) + bar.clear() + bar.draw_coloured_text(0, 10, 0, 2, text) + semaphore.release() + -- cgit v1.2.3-70-g09d2