Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 167 for wroteHeader (0.16 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/testing/webhook_server.go

    	// fmt.Printf("got req: %v\n", r.URL.Path)
    	switch r.URL.Path {
    	case "/internalErr":
    		http.Error(w, "webhook internal server error", http.StatusInternalServerError)
    		return
    	case "/invalidReq":
    		w.WriteHeader(http.StatusSwitchingProtocols)
    		w.Write([]byte("webhook invalid request"))
    		return
    	case "/invalidResp":
    		w.Header().Set("Content-Type", "application/json")
    		w.Write([]byte("webhook invalid response"))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 15 11:11:25 UTC 2021
    - 6.3K bytes
    - Viewed (0)
  2. src/net/http/fs.go

    	if ch == condNone {
    		ch = checkIfUnmodifiedSince(r, modtime)
    	}
    	if ch == condFalse {
    		w.WriteHeader(StatusPreconditionFailed)
    		return true, ""
    	}
    	switch checkIfNoneMatch(w, r) {
    	case condFalse:
    		if r.Method == "GET" || r.Method == "HEAD" {
    			writeNotModified(w)
    			return true, ""
    		} else {
    			w.WriteHeader(StatusPreconditionFailed)
    			return true, ""
    		}
    	case condNone:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 09 17:06:47 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  3. cmd/generic-handlers_test.go

    func TestSSETLSHandler(t *testing.T) {
    	defer func(isSSL bool) { globalIsTLS = isSSL }(globalIsTLS) // reset globalIsTLS after test
    
    	var okHandler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		w.WriteHeader(http.StatusOK)
    	}
    	for i, test := range sseTLSHandlerTests {
    		globalIsTLS = test.IsTLS
    
    		w := httptest.NewRecorder()
    		r := new(http.Request)
    		r.Header = test.Header
    		r.URL = test.URL
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/config_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	delegateServer.Handler.NonGoRestfulMux.HandleFunc("/foo", func(w http.ResponseWriter, _ *http.Request) {
    		w.WriteHeader(http.StatusForbidden)
    	})
    
    	delegatePostStartHookChan := make(chan struct{})
    	delegateServer.AddPostStartHookOrDie("delegate-post-start-hook", func(context PostStartHookContext) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  5. src/net/http/httputil/reverseproxy.go

    				// the ResponseWriter's header map.
    				return nil
    			}
    			h := rw.Header()
    			copyHeader(h, http.Header(header))
    			rw.WriteHeader(code)
    
    			// Clear headers, it's not automatically done by ResponseWriter.WriteHeader() for 1xx responses
    			clear(h)
    			return nil
    		},
    	}
    	outreq = outreq.WithContext(httptrace.WithClientTrace(outreq.Context(), trace))
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 23:37:42 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/server_test.go

    	stopCh := make(chan struct{})
    	defer close(stopCh)
    	server := &http.Server{
    		Handler: http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
    			w.WriteHeader(http.StatusOK)
    		}),
    		MaxHeaderBytes: 1 << 20,
    		TLSConfig:      tlsConfig,
    	}
    	listener, _, err := createListener("tcp", "127.0.0.1:0")
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 12 18:29:15 UTC 2021
    - 6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/graceful_shutdown_test.go

    	handlerLock.Lock()
    	b.counter++
    	if b.counter == 25 {
    		startServerShutdown <- struct{}{}
    	}
    	handlerLock.Unlock()
    
    	time.Sleep(60 * time.Second)
    
    	w.Write([]byte("hello from the backend"))
    	w.WriteHeader(http.StatusOK)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/httplog/httplog_test.go

    	if logger.status != http.StatusOK {
    		t.Errorf("expected status after write to be %v, got %v", http.StatusOK, logger.status)
    	}
    
    	tw = new(responsewriter.FakeResponseWriter)
    	logger = newLogged(req, tw)
    	logger.WriteHeader(http.StatusForbidden)
    	logger.Write(nil)
    
    	if logger.status != http.StatusForbidden {
    		t.Errorf("expected status after write to remain %v, got %v", http.StatusForbidden, logger.status)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 05 18:05:09 UTC 2021
    - 6.2K bytes
    - Viewed (0)
  9. internal/handlers/forwarder.go

    //	`http: proxy error: context canceled` printed by Golang
    func (f *Forwarder) customErrHandler(w http.ResponseWriter, r *http.Request, err error) {
    	if f.Logger != nil && err != context.Canceled {
    		f.Logger(err)
    	}
    	w.WriteHeader(http.StatusBadGateway)
    }
    
    func (f *Forwarder) getURLFromRequest(req *http.Request) *url.URL {
    	// If the Request was created by Go via a real HTTP request,  RequestURI will
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  10. pkg/test/echo/server/endpoint/http.go

    	}
    	if !h.IsServerReady() {
    		// Handle readiness probe failure.
    		epLog.Infof("HTTP service not ready, returning 503")
    		w.WriteHeader(http.StatusServiceUnavailable)
    		return
    	}
    
    	if common.IsWebSocketRequest(r) {
    		h.webSocketEcho(w, r)
    	} else {
    		h.echo(w, r, id)
    	}
    }
    
    // nolint: interfacer
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 16:20:31 UTC 2023
    - 12.8K bytes
    - Viewed (0)
Back to top