aboutsummaryrefslogtreecommitdiffstats
path: root/src/plugins
diff options
context:
space:
mode:
authorMattias Andrée <maandree@operamail.com>2014-07-21 23:18:56 +0200
committerMattias Andrée <maandree@operamail.com>2014-07-21 23:18:56 +0200
commit611b0fbd9c0e55b0649340563a63434cf51c5adf (patch)
treeb0c9d297c75365e47b3c1ed2c2e34c952f48e890 /src/plugins
parentadd timezone support (diff)
downloadxpybar-611b0fbd9c0e55b0649340563a63434cf51c5adf.tar.gz
xpybar-611b0fbd9c0e55b0649340563a63434cf51c5adf.tar.bz2
xpybar-611b0fbd9c0e55b0649340563a63434cf51c5adf.tar.xz
ropty, does not work with the standard programs, but you can echo into it
Signed-off-by: Mattias Andrée <maandree@operamail.com>
Diffstat (limited to '')
-rw-r--r--src/plugins/ropty.py113
1 files changed, 113 insertions, 0 deletions
diff --git a/src/plugins/ropty.py b/src/plugins/ropty.py
new file mode 100644
index 0000000..09e4a23
--- /dev/null
+++ b/src/plugins/ropty.py
@@ -0,0 +1,113 @@
+# -*- python -*-
+'''
+xpybar – xmobar replacement written in python
+Copyright © 2014 Mattias Andrée (maandree@member.fsf.org)
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation, either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program. If not, see <http://www.gnu.org/licenses/>.
+'''
+import os
+import threading
+
+from plugins.linereader import LineReader
+
+
+class ROPTY(LineReader):
+ '''
+ Read-only PTY for viewing of wall, write and talk messages
+
+ @variable on_update:()→void Called when a new line is available
+ @variable master:int The file descriptor of the PTY master
+ @variable slave:int The file descriptor of the PTY slave
+ '''
+
+
+ def __init__(self, on_update = None):
+ '''
+ Constructor
+
+ @param on_update:()→void Called when a new line is available
+ '''
+ def noop():
+ pass
+ self.on_update = noop if on_update is None else on_update
+ (self.master, self.slave) = os.openpty()
+ self.__reader = LineReader(self.master)
+ self.__condition = threading.Condition()
+ self.__queue = []
+ def background():
+ try:
+ while True:
+ got = self.__reader.next()
+ if got is None:
+ return
+ self.__condition.acquire()
+ try:
+ self.__queue.append(got)
+ finally:
+ self.__condition.release()
+ self.on_update()
+ except:
+ return
+ self.__thread = threading.Thread(target = background)
+ self.__thread.setDaemon(True)
+ self.__thread.start()
+
+
+ def close(self):
+ '''
+ Close the PTY
+ '''
+ os.close(self.slave)
+ os.close(self.master)
+
+
+ def size(self):
+ '''
+ Return the number of available lines
+
+ @return :int The number of available lines
+ '''
+ self.__condition.acquire()
+ try:
+ return len(self.__queue)
+ finally:
+ self.__condition.release()
+
+
+ def __len__(self):
+ '''
+ Return the number of available lines
+
+ @return :int The number of available lines
+ '''
+ return self.size()
+
+
+ def next(self):
+ '''
+ Return and unqueue the next available line
+
+ @return :str The next available line, `None` if there
+ are no more lines currently available
+ '''
+ self.__condition.acquire()
+ try:
+ if len(self.__queue) == 0:
+ return None
+ rc = self.__queue[0]
+ self.__queue[:] = self.__queue[1:]
+ finally:
+ self.__condition.release()
+ return rc
+