Mercurial > kallithea
diff rhodecode/lib/subprocessio.py @ 2730:7949bc80b3b1 beta
more py25 compat fixes
| author | Marcin Kuzminski <marcin@python-works.com> |
|---|---|
| date | Wed, 22 Aug 2012 13:30:52 +0200 |
| parents | e9e7c40b4f1a |
| children | fd5f2b217488 |
line wrap: on
line diff
--- a/rhodecode/lib/subprocessio.py Wed Aug 22 12:09:49 2012 +0200 +++ b/rhodecode/lib/subprocessio.py Wed Aug 22 13:30:52 2012 +0200 @@ -25,7 +25,7 @@ import os import subprocess import threading -from rhodecode.lib.compat import deque +from rhodecode.lib.compat import deque, Event class StreamFeeder(threading.Thread): @@ -89,16 +89,16 @@ self.chunk_count_max = int(buffer_size / chunk_size) + 1 self.chunk_size = chunk_size - self.data_added = threading.Event() + self.data_added = Event() self.data_added.clear() - self.keep_reading = threading.Event() + self.keep_reading = Event() self.keep_reading.set() - self.EOF = threading.Event() + self.EOF = Event() self.EOF.clear() - self.go = threading.Event() + self.go = Event() self.go.set() def stop(self):