- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for wroteHeader (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/cmd/dist/buildgo.go
// and will not clean up properly. const generatedHeader = "// Code generated by go tool dist; DO NOT EDIT.\n\n" // writeHeader emits the standard "generated by" header for all files generated // by dist. func writeHeader(w io.Writer) { fmt.Fprint(w, generatedHeader) } // mkzdefaultcc writes zdefaultcc.go: // // package main // const defaultCC = <defaultcc>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 13 20:44:00 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/ctrlz/fw/utils.go
RenderError(w, http.StatusInternalServerError, err) return } w.WriteHeader(http.StatusOK) w.Header().Set("Content-Type", "text/html; charset=utf-8") _, _ = b.WriteTo(w) } // RenderJSON outputs the given data as JSON func RenderJSON(w http.ResponseWriter, statusCode int, data any) { w.WriteHeader(statusCode) w.Header().Set("Content-Type", "application/json; charset=utf-8")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 14:06:41 UTC 2023 - 1.6K bytes - Viewed (0) -
src/runtime/write_err_android.go
msg := []byte("runtime: cannot open /dev/log/main\x00") write(2, unsafe.Pointer(&msg[0]), int32(len(msg))) exit(2) } // Prepopulate the invariant header part. copy(writeBuf[:len(writeHeader)], writeHeader) } // used in initLogdWrite but defined here to avoid heap allocation. var logdAddr sockaddr_un func initLogd() { // In logd mode, logs are sent to the logd via a unix domain socket.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 4.7K bytes - Viewed (0)