Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 167 for wroteHeader (0.16 sec)

  1. src/compress/zlib/writer.go

    	if z.compressor != nil {
    		z.compressor.Reset(w)
    	}
    	if z.digest != nil {
    		z.digest.Reset()
    	}
    	z.err = nil
    	z.scratch = [4]byte{}
    	z.wroteHeader = false
    }
    
    // writeHeader writes the ZLIB header.
    func (z *Writer) writeHeader() (err error) {
    	z.wroteHeader = true
    	// ZLIB has a two-byte header (as documented in RFC 1950).
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 27 18:51:27 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  2. src/net/http/filetransport.go

    	return pr.res.Header
    }
    
    func (pr *populateResponse) WriteHeader(code int) {
    	if pr.wroteHeader {
    		return
    	}
    	pr.wroteHeader = true
    
    	pr.res.StatusCode = code
    	pr.res.Status = fmt.Sprintf("%d %s", code, StatusText(code))
    }
    
    func (pr *populateResponse) Write(p []byte) (n int, err error) {
    	if !pr.wroteHeader {
    		pr.WriteHeader(StatusOK)
    	}
    	pr.hasContent = true
    	if !pr.sentResponse {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go

    	tw.w.(http.Flusher).Flush()
    }
    
    func (tw *baseTimeoutWriter) WriteHeader(code int) {
    	tw.mu.Lock()
    	defer tw.mu.Unlock()
    
    	if tw.timedOut || tw.wroteHeader || tw.hijacked {
    		return
    	}
    
    	copyHeaders(tw.w.Header(), tw.handlerHeaders)
    	tw.wroteHeader = true
    	tw.w.WriteHeader(code)
    }
    
    func copyHeaders(dst, src http.Header) {
    	for k, v := range src {
    		dst[k] = v
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. src/net/http/cgi/child.go

    	header         http.Header
    	code           int
    	wroteHeader    bool
    	wroteCGIHeader bool
    	bufw           *bufio.Writer
    }
    
    func (r *response) Flush() {
    	r.bufw.Flush()
    }
    
    func (r *response) Header() http.Header {
    	return r.header
    }
    
    func (r *response) Write(p []byte) (n int, err error) {
    	if !r.wroteHeader {
    		r.WriteHeader(http.StatusOK)
    	}
    	if !r.wroteCGIHeader {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. src/net/http/httptest/recorder.go

    	// early. (We can't return an error from WriteHeader even if we wanted to.)
    	if code < 100 || code > 999 {
    		panic(fmt.Sprintf("invalid WriteHeader code %v", code))
    	}
    }
    
    // WriteHeader implements [http.ResponseWriter].
    func (rw *ResponseRecorder) WriteHeader(code int) {
    	if rw.wroteHeader {
    		return
    	}
    
    	checkWriteHeaderCode(code)
    	rw.Code = code
    	rw.wroteHeader = true
    	if rw.HeaderMap == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. src/net/http/fcgi/child.go

    	return r.header
    }
    
    func (r *response) Write(p []byte) (n int, err error) {
    	if !r.wroteHeader {
    		r.WriteHeader(http.StatusOK)
    	}
    	if !r.wroteCGIHeader {
    		r.writeCGIHeader(p)
    	}
    	return r.w.Write(p)
    }
    
    func (r *response) WriteHeader(code int) {
    	if r.wroteHeader {
    		return
    	}
    	r.wroteHeader = true
    	r.code = code
    	if code == http.StatusNotModified {
    		// Must not have body.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. pilot/pkg/xds/debuggen.go

    	body        *bytes.Buffer
    	header      map[string]string
    	wroteHeader bool
    }
    
    func (r ResponseCapture) Header() http.Header {
    	header := make(http.Header)
    	for k, v := range r.header {
    		header.Set(k, v)
    	}
    	return header
    }
    
    func (r ResponseCapture) Write(i []byte) (int, error) {
    	return r.body.Write(i)
    }
    
    func (r ResponseCapture) WriteHeader(statusCode int) {
    	r.header["statusCode"] = strconv.Itoa(statusCode)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Dec 04 18:51:52 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  8. src/compress/gzip/gzip.go

    func (z *Writer) Write(p []byte) (int, error) {
    	if z.err != nil {
    		return 0, z.err
    	}
    	var n int
    	// Write the GZIP header lazily.
    	if !z.wroteHeader {
    		z.wroteHeader = true
    		z.buf = [10]byte{0: gzipID1, 1: gzipID2, 2: gzipDeflate}
    		if z.Extra != nil {
    			z.buf[3] |= 0x04
    		}
    		if z.Name != "" {
    			z.buf[3] |= 0x08
    		}
    		if z.Comment != "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 13:32:40 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. src/net/http/server.go

    	// at the time of res.writeHeader, if res.writeHeader is
    	// called and extra buffering is being done to calculate
    	// Content-Type and/or Content-Length.
    	header Header
    
    	// wroteHeader tells whether the header's been written to "the
    	// wire" (or rather: w.conn.buf). this is unlike
    	// (*response).wroteHeader, which tells only whether it was
    	// logically written.
    	wroteHeader bool
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go

    	http.ResponseWriter
    
    	status      int
    	written     int64
    	wroteHeader bool
    }
    
    func (r *ResponseWriterDelegator) Unwrap() http.ResponseWriter {
    	return r.ResponseWriter
    }
    
    func (r *ResponseWriterDelegator) WriteHeader(code int) {
    	r.status = code
    	r.wroteHeader = true
    	r.ResponseWriter.WriteHeader(code)
    }
    
    func (r *ResponseWriterDelegator) Write(b []byte) (int, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 35K bytes
    - Viewed (0)
Back to top