mirror of
https://github.com/docker/docs.git
synced 2026-04-03 09:49:05 +07:00
Merge pull request #4832 from LK4D4/fix_events_hanging_#4804
Workaround for hanging events. Fixes #4804
This commit is contained in:
@@ -222,6 +222,10 @@ func (srv *Server) Events(job *engine.Job) engine.Status {
|
||||
|
||||
listener := make(chan utils.JSONMessage)
|
||||
srv.Lock()
|
||||
if old, ok := srv.listeners[from]; ok {
|
||||
delete(srv.listeners, from)
|
||||
close(old)
|
||||
}
|
||||
srv.listeners[from] = listener
|
||||
srv.Unlock()
|
||||
job.Stdout.Write(nil) // flush
|
||||
|
||||
Reference in New Issue
Block a user