Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for writeErrors (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top