From: qydysky Date: Tue, 8 Oct 2024 08:15:12 +0000 (+0800) Subject: Update ws.go X-Git-Tag: v0.1.20241008081652 X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=d4b31e3aea87ec5fe188461dc74c8c95a19bb846;p=front%2F.git Update ws.go --- diff --git a/ws.go b/ws.go index de447dd..f54fe13 100644 --- a/ws.go +++ b/ws.go @@ -71,23 +71,15 @@ func (wsDealer) Deal(ctx context.Context, w http.ResponseWriter, r *http.Request if e != nil && !errors.Is(e, context.Canceled) { logger.Warn(`W:`, fmt.Sprintf(errFormat, r.RemoteAddr, chosenBack.route.config.Addr, routePath, chosenBack.Name, e, time.Since(opT))) chosenBack.Disable() - conn = nil - resp = nil + return ErrResFail } if chosenBack.getErrToSec() != 0 && time.Since(opT).Seconds() > chosenBack.getErrToSec() { logger.Warn(`W:`, fmt.Sprintf(errFormat, r.RemoteAddr, chosenBack.route.config.Addr, routePath, chosenBack.Name, ErrResTO, time.Since(opT))) chosenBack.Disable() - conn.Close() - conn = nil - resp = nil } // } - if resp == nil || conn == nil { - return ErrResFail - } - if pctx.Done(r.Context()) { return context.Canceled }