- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 237 for errchk (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
ctx, cancel := context.WithCancel(origCtx) w := store.watcher.createWatchChan(ctx, "/abc", 0, false, false, storage.Everything) // make resultChan and errChan blocking to ensure ordering. w.resultChan = make(chan watch.Event) w.errChan = make(chan error) // The event flow goes like: // - first we send an error, it should block on resultChan. // - Then we cancel ctx. The blocking on resultChan should be freed up
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (1) -
src/cmd/internal/browser/browser.go
// If the command runs within the timeout, it's deemed successful if it exited cleanly. func appearsSuccessful(cmd *exec.Cmd, timeout time.Duration) bool { errc := make(chan error, 1) go func() { errc <- cmd.Wait() }() select { case <-time.After(timeout): return true case err := <-errc: return err == nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 17:49:12 UTC 2022 - 1.7K bytes - Viewed (0) -
src/crypto/tls/handshake_test.go
const sentinel = "SENTINEL\n" c, s := localPipe(t) errChan := make(chan error, 1) go func() { cli := Client(c, clientConfig) err := cli.Handshake() if err != nil { errChan <- fmt.Errorf("client: %v", err) c.Close() return } defer func() { errChan <- nil }() clientState = cli.ConnectionState() buf, err := io.ReadAll(cli) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 24.5K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
errCh.SendErrorWithCancel(err, cancel) return } } } if err := util.DeletePod(ctx, cs, victim); err != nil { logger.Error(err, "Preempted pod", "pod", klog.KObj(victim), "preemptor", klog.KObj(pod)) errCh.SendErrorWithCancel(err, cancel) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
close(errCh) if len(errCh) > 0 { errs := make([]error, 0) for err := range errCh { errs = append(errs, err) } return successes, utilerrors.NewAggregate(errs) } remaining -= batchSize } return successes, nil } type replicaStatus struct { replicas int32 readyReplicas int32 availableReplicas int32 currentReplicas int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
src/net/file_unix_test.go
if !testableNetwork("unix") { t.Skipf("skipping: unix sockets not supported") } ls := newLocalServer(t, "unix") defer ls.teardown() errc := make(chan error, 1) done := make(chan bool) handler := func(ls *localServer, ln Listener) { server, err := ln.Accept() errc <- err if err != nil { return } defer server.Close() <-done } if err := ls.buildup(handler); err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 22 16:48:53 UTC 2023 - 2.1K bytes - Viewed (0) -
common/config/.golangci.yml
# "make update-common". run: # Timeout for analysis, e.g. 30s, 5m. # Default: 1m timeout: 20m build-tags: - integ - integfuzz linters: disable-all: true enable: - errcheck - exportloopref - depguard - gocritic - gofumpt - goimports - revive - gosimple - govet - ineffassign - lll - misspell - staticcheck
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 20:03:06 UTC 2024 - 11.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
fmt.Printf("[control-plane-check] %s is not healthy after %v\n", comp.name, time.Since(start)) errChan <- lastError return } fmt.Printf("[control-plane-check] %s is healthy after %v\n", comp.name, time.Since(start)) errChan <- nil }(comp) } for i := 0; i < len(components); i++ { if err := <-errChan; err != nil { errs = append(errs, err) } } return utilerrors.NewAggregate(errs) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/source.go
ch rune // most recently read character chw int // width of ch } const sentinel = utf8.RuneSelf func (s *source) init(in io.Reader, errh func(line, col uint, msg string)) { s.in = in s.errh = errh if s.buf == nil { s.buf = make([]byte, nextSize(0)) } s.buf[0] = sentinel s.ioerr = nil s.b, s.r, s.e = -1, 0, 0 s.line, s.col = 0, 0 s.ch = ' ' s.chw = 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 05 19:25:46 UTC 2020 - 5.7K bytes - Viewed (0) -
src/net/net_test.go
t.Helper() ln := newLocalListener(t, "tcp") defer ln.Close() errc := make(chan error, 2) go func() { c1, err := ln.Accept() if err != nil { errc <- err return } err = peer1(c1.(*TCPConn)) c1.Close() errc <- err }() go func() { c2, err := Dial("tcp", ln.Addr().String()) if err != nil { errc <- err return } err = peer2(c2.(*TCPConn)) c2.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 21:04:44 UTC 2024 - 13.3K bytes - Viewed (0)