0ct0pu5/moby
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Merge pull request #5806 from icecrime/5766-events_endless_newlines

Browse source 
Issue #5766 - Check channel closed state in /events loop
This commit is contained in:
Victor Vieux 2014-05-14 14:09:26 -07:00
commit 49deffe6fe
2 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
AUTHORS
View file

@ -28,6 +28,7 @@ Anthony Bishopric <git@anthonybishopric.com>
Anton Nikitin <anton.k.nikitin@gmail.com>
Antony Messerli <amesserl@rackspace.com>
apocas <petermdias@gmail.com>
Arnaud Porterie <arnaud.porterie@gmail.com>
Asbjørn Enge <asbjorn@hanafjedle.net>
Barry Allard <barry.allard@gmail.com>
Bartłomiej Piotrowski <b@bpiotrowski.pl>

5
server/server.go
View file

@ -259,7 +259,10 @@ func (srv *Server) Events(job *engine.Job) engine.Status {
}
for {
select {
case event := <-listener:
case event, ok := <-listener:
if !ok { // Channel is closed: listener was evicted
return engine.StatusOK
}
err := sendEvent(&event)
if err != nil && err.Error() == "JSON error" {
continue