change vendor for debug

pkg/autoscaler/statserver/server.go

@@ -169,7 +169,7 @@ func (s *Server) Handler(w http.ResponseWriter, r *http.Request) {
 		if err != nil {
 			// We close abnormally, because we're just closing the connection in the client,
 			// which is okay. There's no value delaying closure of the connection unnecessarily.
-			if errors.Is(err, io.ErrUnexpectedEOF) {
+			if errors.Is(err, io.EOF) {
 				s.logger.Debug("Handler disconnected")
 			} else {
 				s.logger.Errorf("Handler exiting on error: %#v", err)

test/e2e/websocket_test.go

@@ -118,6 +118,7 @@ func TestWebSocket(t *testing.T) {
 	if err := ValidateWebSocketConnection(t, clients, names, NoDelay); err != nil {
 		t.Error(err)
 	}
+	t.Fatal("debug")
 }
 
 // and with -1 as target burst capacity and then validates that we can still serve.

test/e2e/websocket_ws.go

@@ -22,10 +22,10 @@ import (
 	"fmt"
 	"io"
 	"net"
-	"net/http"
 	"net/url"
 	"strings"
 	"testing"
+	"time"
 
 	"github.com/gobwas/ws"
 	"github.com/gobwas/ws/wsutil"
@@ -62,12 +62,11 @@ func connectWS(t *testing.T, clients *test.Clients, domain, timeout string) (net
 	waitErr := wait.PollImmediate(connectRetryInterval, connectTimeout, func() (bool, error) {
 		t.Logf("Connecting using websocket: url=%s, host=%s", u.String(), domain)
 		dialer := &ws.Dialer{
-			//	Timeout: 45 * time.Second,
-			Header: ws.HandshakeHeaderHTTP(http.Header{"Host": {domain}}),
+			Timeout: 45 * time.Second,
 			OnStatusError: func(status int, reason []byte, resp io.Reader) {
 				var b bytes.Buffer
 				io.Copy(&b, resp)
-				t.Logf("HTTP connection failed: %v Response=%+v. ResponseBody=%q", reason, status, b.String())
+				t.Logf("HTTP connection failed: %v Response=%+v. ResponseBody=%q", string(reason), status, b.String())
 			},
 		}
 		if test.ServingFlags.HTTPS {
@@ -76,16 +75,16 @@ func connectWS(t *testing.T, clients *test.Clients, domain, timeout string) (net
 		}
 
 		c, _, _, err := dialer.Dial(context.TODO(), u.String())
-		if c != nil {
-			t.Log("WebSocket connection established.")
-			conn = c
-			return true, nil
-		}
 		if err != nil {
 			// We don't have an HTTP response, probably TCP errors.
 			t.Log("Connection failed:", err)
 			return false, nil
 		}
+		if c != nil {
+			t.Log("WebSocket connection established.")
+			conn = c
+			return true, nil
+		}
 		return false, nil
 	})
 	return conn, waitErr

test/test_images/wsserver/echo.go

@@ -19,6 +19,7 @@ package main
 import (
 	"errors"
 	"flag"
+	"fmt"
 	"io"
 	"log"
 	"net/http"
@@ -50,6 +51,7 @@ var upgrader = ws.HTTPUpgrader{}
 func handler(w http.ResponseWriter, r *http.Request) {
 	params := r.URL.Query()
 	d := params.Get("delay")
+	fmt.Println("debug: handler is called")
 	if d != "" {
 		log.Println("Found delay header")
 		parsed, _ := strconv.Atoi(d)
@@ -73,7 +75,7 @@ func handler(w http.ResponseWriter, r *http.Request) {
 		if err != nil {
 			// We close abnormally, because we're just closing the connection in the client,
 			// which is okay. There's no value delaying closure of the connection unnecessarily.
-			if errors.Is(err, io.ErrUnexpectedEOF) {
+			if errors.Is(err, io.EOF) {
 				log.Println("Client disconnected.")
 			} else {
 				log.Println("Handler exiting on error:", err)