Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom@curii.com>
)
func (cresp ConnectionResponse) ServeHTTP(w http.ResponseWriter, req *http.Request) {
+ defer cresp.Conn.Close()
hj, ok := w.(http.Hijacker)
if !ok {
http.Error(w, "ResponseWriter does not support connection upgrade", http.StatusInternalServerError)
if err != nil {
ctxlog.FromContext(ctx).WithError(err).Error("error copying downstream")
}
+ conn.Close()
}()
wg.Add(1)
go func() {
if err != nil {
ctxlog.FromContext(ctx).WithError(err).Error("error copying upstream")
}
+ cresp.Conn.Close()
}()
wg.Wait()
if cresp.Logger != nil {