Show More
@@ -23,10 +23,13 b' along with git_http_backend.py Project.' | |||
|
23 | 23 | If not, see <http://www.gnu.org/licenses/>. |
|
24 | 24 | """ |
|
25 | 25 | import os |
|
26 | import logging | |
|
26 | 27 | import subprocess32 as subprocess |
|
27 | 28 | from collections import deque |
|
28 | 29 | from threading import Event, Thread |
|
29 | 30 | |
|
31 | log = logging.getLogger(__name__) | |
|
32 | ||
|
30 | 33 | |
|
31 | 34 | class StreamFeeder(Thread): |
|
32 | 35 | """ |
@@ -133,8 +136,9 b' class InputStreamChunker(Thread):' | |||
|
133 | 136 | keep_reading.clear() |
|
134 | 137 | keep_reading.wait(timeout_input) |
|
135 | 138 | if len(t) > chunk_count_max + timeout_input: |
|
136 | raise IOError( | |
|
137 | "Timed out while waiting for input from subprocess.") | |
|
139 | log.error("Timed out while waiting for input from subprocess.") | |
|
140 | os._exit(-1) # this will cause the worker to recycle itself | |
|
141 | ||
|
138 | 142 | t.append(b) |
|
139 | 143 | da.set() |
|
140 | 144 | b = s.read(cs) |
General Comments 0
You need to be logged in to leave comments.
Login now