- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for writeErrors (0.21 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/timeout_test.go
origReallyCrash := runtime.ReallyCrash runtime.ReallyCrash = false defer func() { runtime.ReallyCrash = origReallyCrash }() sendResponse := make(chan string, 1) doPanic := make(chan interface{}, 1) writeErrors := make(chan error, 1) gotPanic := make(chan interface{}, 1) timeout := make(chan time.Time, 1) resp := "test response" timeoutErr := apierrors.NewServerTimeout(schema.GroupResource{Group: "foo", Resource: "bar"}, "get", 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 18.4K bytes - Viewed (0) -
src/net/http/serve_test.go
func testTimeoutHandler(t *testing.T, mode testMode) { sendHi := make(chan bool, 1) writeErrors := make(chan error, 1) sayHi := HandlerFunc(func(w ResponseWriter, r *Request) { <-sendHi _, werr := w.Write([]byte("hi")) writeErrors <- werr }) ctx, cancel := context.WithCancel(context.Background()) h := NewTestTimeoutHandler(sayHi, cancelableTimeoutContext{ctx})
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
pkg/kubelet/server/server.go
if err != nil { utilruntime.HandleError(err) response.WriteError(http.StatusBadRequest, err) return } pod, ok := s.host.GetPodByName(params.podNamespace, params.podName) if !ok { response.WriteError(http.StatusNotFound, fmt.Errorf("pod does not exist")) return } if len(params.podUID) > 0 && pod.UID != params.podUID { response.WriteError(http.StatusNotFound, fmt.Errorf("pod not found")) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/JsonModelWriter.kt
property("documentationLink", documentationLinkFor(it)) } details.failure?.let { failure -> comma() writeError(failure) } } } private fun writeError(failure: DecoratedFailure) { val summary = failure.summary val parts = failure.parts property("error") { jsonObject {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 8.8K bytes - Viewed (0) -
src/text/template/exec.go
}) } // writeError is the wrapper type used internally when Execute has an // error writing to its output. We strip the wrapper in errRecover. // Note that this is not an implementation of error, so it cannot escape // from the package as an error value. type writeError struct { Err error // Original error. } func (s *state) writeError(err error) { panic(writeError{ Err: err, })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:22:24 UTC 2024 - 32K bytes - Viewed (0) -
pkg/kubelet/server/stats/handler.go
// request is provided for logging. func handleError(response *restful.Response, request string, err error) { switch err { case kubecontainer.ErrContainerNotFound: response.WriteError(http.StatusNotFound, err) default: msg := fmt.Sprintf("Internal Error: %v", err) klog.ErrorS(err, "HTTP InternalServerError serving", "request", request) response.WriteErrorString(http.StatusInternalServerError, msg)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 21:31:38 UTC 2023 - 6.8K bytes - Viewed (0) -
src/compress/flate/inflate.go
} // A WriteError reports an error encountered while writing output. // // Deprecated: No longer returned. type WriteError struct { Offset int64 // byte offset where error occurred Err error // error returned by underlying Write } func (e *WriteError) Error() string {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 23:20:03 UTC 2023 - 20.4K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/http.go
func processHTTPResponse(requestID int, httpResp *http.Response, outBuffer *bytes.Buffer) error { // Make sure we close the body before exiting. defer func() { if err := httpResp.Body.Close(); err != nil { echo.WriteError(outBuffer, requestID, err) } }() echo.StatusCodeField.WriteForRequest(outBuffer, requestID, strconv.Itoa(httpResp.StatusCode)) // Read the entire body. data, err := io.ReadAll(httpResp.Body)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 7.9K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/printer.go
p := printer{ output: w, form: form, linebreaks: form == 0, } defer func() { n = p.written if e := recover(); e != nil { err = e.(writeError).err // re-panics if it's not a writeError } }() p.print(x) p.flush(_EOF) return } // String is a convenience function that prints n in ShortForm // and returns the printed string.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 24 07:17:27 UTC 2023 - 21.5K bytes - Viewed (0) -
src/io/io_test.go
func TestCopyReadErrWriteErr(t *testing.T) { er, ew := errors.New("readError"), errors.New("writeError") r, w := zeroErrReader{err: er}, errWriter{err: ew} n, err := Copy(w, r) if n != 0 || err != ew { t.Errorf("Copy(zeroErrReader, errWriter) = %d, %v; want 0, writeError", n, err) } } func TestCopyN(t *testing.T) { rb := new(Buffer) wb := new(Buffer)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 09 22:04:41 UTC 2023 - 18.9K bytes - Viewed (0)