diff options
Diffstat (limited to 'platform_utils.py')
-rw-r--r-- | platform_utils.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/platform_utils.py b/platform_utils.py index 06ef9b18..490ba208 100644 --- a/platform_utils.py +++ b/platform_utils.py | |||
@@ -92,6 +92,7 @@ class _FileDescriptorStreamsNonBlocking(FileDescriptorStreams): | |||
92 | """ | 92 | """ |
93 | class Stream(object): | 93 | class Stream(object): |
94 | """ Encapsulates a file descriptor """ | 94 | """ Encapsulates a file descriptor """ |
95 | |||
95 | def __init__(self, fd, dest, std_name): | 96 | def __init__(self, fd, dest, std_name): |
96 | self.fd = fd | 97 | self.fd = fd |
97 | self.dest = dest | 98 | self.dest = dest |
@@ -125,6 +126,7 @@ class _FileDescriptorStreamsThreads(FileDescriptorStreams): | |||
125 | non blocking I/O. This implementation requires creating threads issuing | 126 | non blocking I/O. This implementation requires creating threads issuing |
126 | blocking read operations on file descriptors. | 127 | blocking read operations on file descriptors. |
127 | """ | 128 | """ |
129 | |||
128 | def __init__(self): | 130 | def __init__(self): |
129 | super(_FileDescriptorStreamsThreads, self).__init__() | 131 | super(_FileDescriptorStreamsThreads, self).__init__() |
130 | # The queue is shared accross all threads so we can simulate the | 132 | # The queue is shared accross all threads so we can simulate the |
@@ -144,12 +146,14 @@ class _FileDescriptorStreamsThreads(FileDescriptorStreams): | |||
144 | 146 | ||
145 | class QueueItem(object): | 147 | class QueueItem(object): |
146 | """ Item put in the shared queue """ | 148 | """ Item put in the shared queue """ |
149 | |||
147 | def __init__(self, stream, data): | 150 | def __init__(self, stream, data): |
148 | self.stream = stream | 151 | self.stream = stream |
149 | self.data = data | 152 | self.data = data |
150 | 153 | ||
151 | class Stream(object): | 154 | class Stream(object): |
152 | """ Encapsulates a file descriptor """ | 155 | """ Encapsulates a file descriptor """ |
156 | |||
153 | def __init__(self, fd, dest, std_name, queue): | 157 | def __init__(self, fd, dest, std_name, queue): |
154 | self.fd = fd | 158 | self.fd = fd |
155 | self.dest = dest | 159 | self.dest = dest |