- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ErrHijacked (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
} func (tw *baseTimeoutWriter) Write(p []byte) (int, error) { tw.mu.Lock() defer tw.mu.Unlock() if tw.timedOut { return 0, http.ErrHandlerTimeout } if tw.hijacked { return 0, http.ErrHijacked } if !tw.wroteHeader { copyHeaders(tw.w.Header(), tw.handlerHeaders) tw.wroteHeader = true } return tw.w.Write(p) } func (tw *baseTimeoutWriter) Flush() { tw.mu.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
func (w *tunnelingResponseWriter) Write(p []byte) (int, error) { w.mu.Lock() defer w.mu.Unlock() if w.hijacked { klog.Errorf("Write called after hijack") return 0, http.ErrHijacked } w.written = true return w.w.Write(p) } // WriteHeader is delegated to the stored "http.ResponseWriter". func (w *tunnelingResponseWriter) WriteHeader(statusCode int) { w.mu.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
src/net/http/server.go
// ErrHijacked is returned by ResponseWriter.Write calls when // the underlying connection has been hijacked using the // Hijacker interface. A zero-byte write on a hijacked // connection will return ErrHijacked without any other side // effects. ErrHijacked = errors.New("http: connection has been hijacked")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
trw.hijacked = true _, err = trw.Write(expectedWrite) assert.Error(t, err, "Writing to ResponseWriter after Hijack() is an error") assert.True(t, errors.Is(err, http.ErrHijacked), "Hijacked error returned if writing after hijacked") // Validate WriteHeader(). trw = &tunnelingResponseWriter{w: &mockResponseWriter{}} expectedStatusCode := 201
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
src/net/http/serve_test.go
conn, _, err := w.(Hijacker).Hijack() if err != nil { t.Errorf("Hijack: %v", err) return } defer conn.Close() _, err = w.Write(nil) if err != ErrHijacked { t.Errorf("Write error = %v; want ErrHijacked", err) } }), func(ts *httptest.Server) { ts.Config.ErrorLog = log.New(terrorWriter{t}, "Unexpected write: ", 0) }).ts c := ts.Client() res, err := c.Get(ts.URL)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go
{"ErrAbortHandler", Var, 8}, {"ErrBodyNotAllowed", Var, 0}, {"ErrBodyReadAfterClose", Var, 0}, {"ErrContentLength", Var, 0}, {"ErrHandlerTimeout", Var, 0}, {"ErrHeaderTooLong", Var, 0}, {"ErrHijacked", Var, 0}, {"ErrLineTooLong", Var, 0}, {"ErrMissingBoundary", Var, 0}, {"ErrMissingContentLength", Var, 0}, {"ErrMissingFile", Var, 0}, {"ErrNoCookie", Var, 0}, {"ErrNoLocation", Var, 0},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0)