- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for wroteHeader (0.19 sec)
-
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/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/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) -
docs/iam/identity-manager-plugin.go
if token == "" { writeErrorResponse(w, errors.New("token parameter not given")) return } rsp, ok := tokens[token] if !ok { w.WriteHeader(http.StatusForbidden) return } fmt.Printf("Allowed for token: %s user: %s\n", token, rsp.User) w.WriteHeader(http.StatusOK) json.NewEncoder(w).Encode(rsp) return } func main() { http.HandleFunc("/", mainHandler) log.Print("Listening on :8081")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 2.1K bytes - Viewed (0) -
src/cmd/dist/buildruntime.go
) /* * Helpers for building runtime. */ // mkzversion writes zversion.go: // // package sys // // (Nothing right now!) func mkzversion(dir, file string) { var buf strings.Builder writeHeader(&buf) fmt.Fprintf(&buf, "package sys\n") writefile(buf.String(), file, writeSkipSame) } // mkbuildcfg writes internal/buildcfg/zbootstrap.go: // // package buildcfg // // const defaultGOROOT = <goroot>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 06 01:33:19 UTC 2024 - 2.5K bytes - Viewed (0) -
src/internal/trace/version/version.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.7K bytes - Viewed (0) -
cni/pkg/nodeagent/healthServer.go
func healthz(w http.ResponseWriter, _ *http.Request) { w.WriteHeader(http.StatusOK) } func readyz(installReady, watchReady *atomic.Value) http.HandlerFunc { return func(w http.ResponseWriter, _ *http.Request) { if !installReady.Load().(bool) || !watchReady.Load().(bool) { http.Error(w, http.StatusText(http.StatusServiceUnavailable), http.StatusServiceUnavailable) return } w.WriteHeader(http.StatusOK) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 01:29:35 UTC 2024 - 1.8K bytes - Viewed (0) -
docs/auditlog/auditlog-echo.go
defer r.Body.Close() if err != nil { log.Printf("Error reading request body: %v", err) w.WriteHeader(http.StatusBadRequest) return } log.Printf(">>> %s %s\n", r.Method, r.URL.Path) var out bytes.Buffer json.Indent(&out, body, "", " ") log.Printf("%s\n", out.String()) w.WriteHeader(http.StatusOK) } func main() { flag.Parse() http.HandleFunc("/", mainHandler)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 1.5K bytes - Viewed (0) -
samples/jwt-server/src/main.go
if err != nil { // Handle invalid delay parameter response.WriteHeader(http.StatusBadRequest) response.Write([]byte("Invalid delay parameter")) return } // If delay parameter is provided and valid, add delay if delayDuration > 0 { time.Sleep(delayDuration) } } response.WriteHeader(http.StatusOK) response.Write([]byte(string(jwtKey))) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 16 23:56:50 UTC 2024 - 4.4K bytes - Viewed (0) -
src/encoding/pem/pem.go
// See RFC 1421, section 4.6.1.1 if hasProcType { if err := writeHeader(out, procType, b.Headers[procType]); err != nil { return err } } // For consistency of output, write other headers sorted by key. slices.Sort(h) for _, k := range h { if err := writeHeader(out, k, b.Headers[k]); err != nil { return err } } if _, err := out.Write(nl); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 7.6K bytes - Viewed (0)