- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for writeErrors (0.19 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/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/vendor/golang.org/x/tools/internal/stdlib/manifest.go
{"NoCompression", Const, 0}, {"ReadError", Type, 0}, {"ReadError.Err", Field, 0}, {"ReadError.Offset", Field, 0}, {"Reader", Type, 0}, {"Resetter", Type, 4}, {"WriteError", Type, 0}, {"WriteError.Err", Field, 0}, {"WriteError.Offset", Field, 0}, {"Writer", Type, 0}, }, "compress/gzip": { {"(*Reader).Close", Method, 0}, {"(*Reader).Multistream", Method, 4}, {"(*Reader).Read", Method, 0},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0)