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 |
