zuul
/
zuul
Code Issues Proposed changes

Merge "Read all Gerrit events from poll interruption" into feature/zuulv3

This commit is contained in:
Jenkins 2017-05-22 12:36:49 +00:00 committed by Gerrit Code Review
parent 05706f7aeb 537da25d89
commit cec997eb7c
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
zuul/driver/gerrit/gerritconnection.py
View File

@ -171,11 +171,15 @@ class GerritWatcher(threading.Thread):
self._stopped = False
def _read(self, fd):
l = fd.readline()
data = json.loads(l)
self.log.debug("Received data from Gerrit event stream: \n%s" %
pprint.pformat(data))
self.gerrit_connection.addEvent(data)
while True:
l = fd.readline()
data = json.loads(l)
self.log.debug("Received data from Gerrit event stream: \n%s" %
pprint.pformat(data))
self.gerrit_connection.addEvent(data)
# Continue until all the lines received are consumed
if fd._pos == fd._realpos:
break
def _listen(self, stdout, stderr):
poll = select.poll()