- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 237 for errchk (0.11 sec)
-
pkg/scheduler/framework/parallelize/error_channel.go
// are ignored, unless the existing error is received and the channel becomes empty // again. type ErrorChannel struct { errCh chan error } // SendError sends an error without blocking the sender. func (e *ErrorChannel) SendError(err error) { select { case e.errCh <- err: default: } } // SendErrorWithCancel sends an error without blocking the sender and calls // cancel function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 17:39:23 UTC 2021 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/testing/testserver.go
if err != nil { return result, fmt.Errorf("failed to create server: %v", err) } errCh = make(chan error) go func() { defer close(errCh) if err := server.GenericAPIServer.PrepareRun().RunWithContext(ctx); err != nil { errCh <- err } }() t.Logf("Waiting for /healthz to be ok...")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 9K bytes - Viewed (1) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/stream_test.go
if err != nil { return data, err } return data, <-errCh } func expectWebSocketFrames(r *Reader, t *testing.T, fn func(*websocket.Conn), frames [][]byte, protocols ...string) error { errCh := make(chan error, 1) s, addr := newServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { errCh <- r.Copy(w, req) })) defer s.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 7.4K bytes - Viewed (0) -
src/net/http/roundtrip_js.go
case clHeader != "": cl, err := strconv.ParseInt(clHeader, 10, 64) if err != nil { errCh <- fmt.Errorf("net/http: ill-formed Content-Length header: %v", err) return nil } if cl < 0 { // Content-Length values less than 0 are invalid. // See: https://datatracker.ietf.org/doc/html/rfc2616/#section-14.13 errCh <- fmt.Errorf("net/http: invalid Content-Length header: %q", clHeader) return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.8K bytes - Viewed (0) -
src/net/smtp/smtp_test.go
} defer l.Close() errCh := make(chan error) go func() { defer close(errCh) conn, err := l.Accept() if err != nil { errCh <- fmt.Errorf("Accept: %v", err) return } defer conn.Close() tc := textproto.NewConn(conn) tc.PrintfLine("220 hello world") msg, err := tc.ReadLine() if err != nil { errCh <- fmt.Errorf("ReadLine error: %v", err) return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 28.5K bytes - Viewed (0) -
src/compress/gzip/example_test.go
// gzipWriter compresses data to httpWriter. gzipWriter := gzip.NewWriter(httpWriter) // errch collects any errors from the writing goroutine. errch := make(chan error, 1) go func() { defer close(errch) sentErr := false sendErr := func(err error) { if !sentErr { errch <- err sentErr = true } } // Copy our data to gzipWriter, which compresses it to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 22 16:24:14 UTC 2022 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
errCh <- apierrors.NewInternalError(err) return } if rejectionErr, ok := err.(*webhookutil.ErrWebhookRejection); ok { err = rejectionErr.Status } klog.Warningf("rejected by webhook %q: %#v", hook.Name, err) errCh <- err }(relevantHooks[i], i) } wg.Wait() close(errCh) var errs []error for e := range errCh {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
cmd/kubemark/app/hollow_node_test.go
s := &hollowNodeConfig{ KubeconfigPath: kubeconfigPath, Morph: morph, } errCh := make(chan error) go func() { data, err := os.ReadFile(kubeconfigPath) t.Logf("read %d, err=%v\n", len(data), err) ctx := ktesting.Init(t) errCh <- run(ctx, s) }() select { case err := <-errCh: t.Fatalf("Run finished unexpectedly with error: %v", err) case <-time.After(3 * time.Second):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 2.3K bytes - Viewed (0) -
cmd/kube-apiserver/app/testing/testserver.go
} errCh = make(chan error) go func() { defer close(errCh) prepared, err := server.PrepareRun() if err != nil { errCh <- err } else if err := prepared.Run(tCtx); err != nil { errCh <- err } }() client, err := kubernetes.NewForConfig(server.GenericAPIServer.LoopbackClientConfig)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0) -
src/runtime/signal_windows_test.go
} errCh := make(chan error, 1) go func() { if line, err := outReader.ReadString('\n'); err != nil { errCh <- fmt.Errorf("could not read stdout: %v", err) } else if strings.TrimSpace(line) != "ready" { errCh <- fmt.Errorf("unexpected message: %v", line) } else { errCh <- sendCtrlBreak(cmd.Process.Pid) } }() if err := <-errCh; err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 05 08:26:52 UTC 2023 - 9K bytes - Viewed (0)