zuul
/
zuul
Code Issues Proposed changes

Merge "Close fingergw connection handler on input termination"

This commit is contained in:
Zuul 2021-08-01 09:19:39 +00:00 committed by Gerrit Code Review
parent 32235f980d 4109322f1c
commit 785c51ee0c
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
zuul/lib/streamer_utils.py
View File

@ -50,7 +50,11 @@ class BaseFingerRequestHandler(socketserver.BaseRequestHandler):
raise Exception("Timeout while waiting for input")
for fd, event in poll.poll(timeout):
if event & select.POLLIN:
buffer += self.request.recv(self.MAX_REQUEST_LEN)
x = self.request.recv(self.MAX_REQUEST_LEN)
if not x:
# This will cause the caller to quietly shut down
raise BrokenPipeError
buffer += x
else:
raise Exception("Received error event")
if len(buffer) >= self.MAX_REQUEST_LEN: