- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for WriteHeader (0.23 sec)
-
src/archive/tar/writer_test.go
} }) t.Run("Persistence", func(t *testing.T) { tw := NewWriter(new(failOnceWriter)) if err := tw.WriteHeader(&Header{}); err != io.ErrShortWrite { t.Fatalf("WriteHeader() = %v, want %v", err, io.ErrShortWrite) } if err := tw.WriteHeader(&Header{Name: "small.txt"}); err == nil { t.Errorf("WriteHeader() = got %v, want non-nil error", err) } if _, err := tw.Write(nil); err == nil {
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Feb 27 16:39:23 GMT 2024 - 38.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) }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 1.8K bytes - Viewed (0) -
internal/http/response-recorder.go
// ... otherwise we return the <BLOB> place holder return blobBody } // WriteHeader - writes http status code func (lrw *ResponseRecorder) WriteHeader(code int) { if !lrw.headersLogged { lrw.StatusCode = code lrw.writeHeaders(&lrw.headers, code, lrw.ResponseWriter.Header()) lrw.headersLogged = true lrw.ResponseWriter.WriteHeader(code) } } // Flush - Calls the underlying Flush.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 02 00:13:19 GMT 2023 - 4.9K 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("Listing on :8081")
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri May 27 00:58:09 GMT 2022 - 2.1K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
// Fake out a test HTTP server and use that instead of a real HTTP server over gRPC to validate req/resp flows testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { res.WriteHeader(http.StatusOK) res.Write([]byte("server happy")) })) defer func() { testServer.Close() }() cniC := fakeCNIEventClient(testServer.URL)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 4.2K bytes - Viewed (0) -
src/archive/tar/writer.go
return tw.err } tw.pad = 0 return nil } // WriteHeader writes hdr and prepares to accept the file's contents. // The Header.Size determines how many bytes can be written for the next file. // If the current file is not fully written, then this returns an error. // This implicitly flushes any padding necessary before writing the header. func (tw *Writer) WriteHeader(hdr *Header) error { if err := tw.Flush(); err != nil { return err
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 19.6K bytes - Viewed (0) -
src/archive/tar/fuzz_test.go
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu Jan 13 18:06:33 GMT 2022 - 2.2K bytes - Viewed (0) -
internal/grid/manager.go
w.WriteHeader(http.StatusInternalServerError) } }() if debugPrint { fmt.Printf("grid: Got a %s request for: %v\n", req.Method, req.URL) } ctx := req.Context() if err := m.authRequest(req); err != nil { gridLogOnceIf(ctx, fmt.Errorf("auth %s: %w", req.RemoteAddr, err), req.RemoteAddr+err.Error()) w.WriteHeader(http.StatusForbidden) return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
src/archive/tar/tar_test.go
ModTime: time.Now().Round(time.Second), PAXRecords: map[string]string{"uid": "2097152"}, Format: FormatPAX, Typeflag: TypeReg, } if err := tw.WriteHeader(hdr); err != nil { t.Fatalf("tw.WriteHeader: %v", err) } if _, err := tw.Write(data); err != nil { t.Fatalf("tw.Write: %v", err) } if err := tw.Close(); err != nil { t.Fatalf("tw.Close: %v", err) }
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24K bytes - Viewed (0) -
src/archive/zip/writer.go
} fw.rawCount = &countWriter{w: fw.comp} fw.header = h ow = fw } w.dir = append(w.dir, h) if err := writeHeader(w.cw, h); err != nil { return nil, err } // If we're creating a directory, fw is nil. w.last = fw return ow, nil } func writeHeader(w io.Writer, h *header) error { const maxUint16 = 1<<16 - 1 if len(h.Name) > maxUint16 { return errLongName }
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0)