Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 35 of 35 for readWrite (0.14 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper.go

    	outerWithCloseNotifyAndFlush
    
    	// http.Hijacker for the inner object
    	InnerHijacker http.Hijacker
    }
    
    func (wr outerWithCloseNotifyFlushAndHijack) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	if hijacker, ok := wr.UserProvidedDecorator.(http.Hijacker); ok {
    		return hijacker.Hijack()
    	}
    
    	return wr.InnerHijacker.Hijack()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go

    	// http.CloseNotifier if the inner object (tw.w) implements http.CloseNotifier.
    	return tw.w.(http.CloseNotifier).CloseNotify()
    }
    
    func (tw *baseTimeoutWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	tw.mu.Lock()
    	defer tw.mu.Unlock()
    
    	if tw.timedOut {
    		return nil, nil, http.ErrHandlerTimeout
    	}
    
    	// the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/httplog/httplog.go

    }
    
    // WriteHeader implements http.ResponseWriter.
    func (rl *respLogger) WriteHeader(status int) {
    	rl.recordStatus(status)
    	rl.w.WriteHeader(status)
    }
    
    func (rl *respLogger) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	rl.hijacked = true
    
    	// the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
    	// http.Hijacker if the inner object (rl.w) implements http.Hijacker.
    	return rl.w.(http.Hijacker).Hijack()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 07 10:10:35 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper_test.go

    func (fw *fakeResponseWriterDecorator) Flush() {
    	if fw.counter != nil {
    		fw.counter.FlushInvoked++
    	}
    	fw.ResponseWriter.(http.Flusher).Flush()
    }
    func (fw *fakeResponseWriterDecorator) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	if fw.counter != nil {
    		fw.counter.HijackInvoked++
    	}
    	return fw.ResponseWriter.(http.Hijacker).Hijack()
    }
    func (fw *fakeResponseWriterDecorator) CloseNotify() <-chan bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 17 12:58:53 UTC 2021
    - 8.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit.go

    }
    
    func (a *auditResponseWriter) WriteHeader(code int) {
    	a.processCode(code)
    	a.ResponseWriter.WriteHeader(code)
    }
    
    func (a *auditResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	// fake a response status before protocol switch happens
    	a.processCode(http.StatusSwitchingProtocols)
    
    	// the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 8.6K bytes
    - Viewed (0)
Back to top