- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 130 for errc2 (0.04 sec)
-
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) -
pkg/config/mesh/kubemesh/watcher_test.go
errCh := make(chan error, 2) for i := 0; i < 100; i++ { t.Log("iter", i) write := fmt.Sprint(i) wg := sync.WaitGroup{} wg.Add(2) go func() { defer wg.Done() if _, err := cms.Update(context.Background(), mkMap(extraCmName, write), metav1.UpdateOptions{}); err != nil { errCh <- err } }() go func() { defer wg.Done()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.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) -
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) -
src/internal/syscall/windows/registry/value.go
// type and ErrUnexpectedType. func (k Key) GetStringValue(name string) (val string, valtype uint32, err error) { data, typ, err2 := k.getValue(name, make([]byte, 64)) if err2 != nil { return "", typ, err2 } switch typ { case SZ, EXPAND_SZ: default: return "", typ, ErrUnexpectedType } if len(data) == 0 { return "", typ, nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 20:01:34 UTC 2023 - 11K bytes - Viewed (0) -
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) -
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/syscall/exec_linux.go
goto childerror } pid, _, err1 = RawSyscall(SYS_READ, uintptr(mapPipe[0]), uintptr(unsafe.Pointer(&err2)), unsafe.Sizeof(err2)) if err1 != 0 { goto childerror } if pid != unsafe.Sizeof(err2) { err1 = EINVAL goto childerror } if err2 != 0 { err1 = err2 goto childerror } } // Session ID if sys.Setsid {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 23K bytes - Viewed (0) -
src/runtime/time_test.go
t.Logf("raw stdout: %q", stdout.String()) t.Logf("raw stderr: %q", stderr.String()) f1, err1 := parseFakeTime(stdout.Bytes()) if err1 != nil { t.Fatal(err1) } f2, err2 := parseFakeTime(stderr.Bytes()) if err2 != nil { t.Fatal(err2) } const time0 = 1257894000000000000 got := [][]fakeTimeFrame{f1, f2} var want = [][]fakeTimeFrame{{ {time0 + 1, "line 2\n"}, {time0 + 1, "line 3\n"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Mar 09 03:40:04 UTC 2024 - 3.1K 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)