|
@@ -241,10 +241,11 @@ func (br *buildRouter) postBuild(ctx context.Context, w http.ResponseWriter, r *
|
|
if closeNotifier, ok := w.(http.CloseNotifier); ok {
|
|
if closeNotifier, ok := w.(http.CloseNotifier); ok {
|
|
finished := make(chan struct{})
|
|
finished := make(chan struct{})
|
|
defer close(finished)
|
|
defer close(finished)
|
|
|
|
+ clientGone := closeNotifier.CloseNotify()
|
|
go func() {
|
|
go func() {
|
|
select {
|
|
select {
|
|
case <-finished:
|
|
case <-finished:
|
|
- case <-closeNotifier.CloseNotify():
|
|
|
|
|
|
+ case <-clientGone:
|
|
logrus.Infof("Client disconnected, cancelling job: build")
|
|
logrus.Infof("Client disconnected, cancelling job: build")
|
|
b.Cancel()
|
|
b.Cancel()
|
|
}
|
|
}
|