/usr/lib/python3/dist-packages/spur/io.py is in python3-spur 0.3.17-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 | from __future__ import unicode_literals
import threading
import os
import codecs
class IoHandler(object):
def __init__(self, channels, encoding):
self._handlers = [
_output_handler(channel, encoding)
for channel in channels
]
def wait(self):
return [handler.wait() for handler in self._handlers]
class Channel(object):
def __init__(self, file_in, file_out, is_pty=False):
self.file_in = file_in
self.file_out = file_out
self.is_pty = is_pty
def _output_handler(channel, encoding):
if encoding is None:
file_in = channel.file_in
empty = b""
else:
file_in = codecs.getreader(encoding)(channel.file_in)
empty = ""
if channel.file_out is None and not channel.is_pty:
return _ReadOutputAtEnd(file_in)
else:
return _ContinuousReader(
file_in=file_in,
file_out=channel.file_out,
is_pty=channel.is_pty,
empty=empty,
)
class _ReadOutputAtEnd(object):
def __init__(self, file_in):
self._file_in = file_in
def wait(self):
return self._file_in.read()
class _ContinuousReader(object):
def __init__(self, file_in, file_out, is_pty, empty):
self._file_in = file_in
self._file_out = file_out
self._is_pty = is_pty
self._empty = empty
self._output = empty
self._thread = threading.Thread(target=self._capture_output)
self._thread.daemon = True
self._thread.start()
def wait(self):
self._thread.join()
return self._output
def _capture_output(self):
output_buffer = []
while True:
try:
output = self._file_in.read(1)
except IOError:
if self._is_pty:
output = self._empty
else:
raise
if output:
if self._file_out is not None:
self._file_out.write(output)
output_buffer.append(output)
else:
self._output = self._empty.join(output_buffer)
return
|