- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,019 for watt (0.05 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/wait.go
// NeverStop may be passed to Until to make it never stop. var NeverStop <-chan struct{} = make(chan struct{}) // Group allows to start a group of goroutines and wait for their completion. type Group struct { wg sync.WaitGroup } func (g *Group) Wait() { g.wg.Wait() } // StartWithChannel starts f in a new goroutine in the group. // stopCh is passed to f as an argument. f should stop when stopCh is available.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 7.1K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/wait.go
waitCmd.PersistentFlags().IntVar(&timeoutSeconds, "timeoutSeconds", 60, "maximum number of seconds to wait for Envoy to be ready") waitCmd.PersistentFlags().IntVar(&requestTimeoutMillis, "requestTimeoutMillis", 500, "number of milliseconds to wait for response") waitCmd.PersistentFlags().IntVar(&periodMillis, "periodMillis", 500, "number of milliseconds to wait between attempts")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.5K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/wait-on-pipe.go
time.Sleep(100 * time.Millisecond) // Write to the pipe to unblock it. if _, err := syscall.Write(wfd, []byte{10}); err != nil { log.Fatalf("failed to write to pipe: %v", err) } // Wait for the goroutine to unblock and start running. // This is helpful to catch incorrect information written // down for the syscall-blocked goroutine, since it'll start // executing, and that execution information will be
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.6K bytes - Viewed (0) -
releasenotes/notes/wait-when-distribution-tracing-disabled.yaml
apiVersion: release-notes/v2 kind: bug-fix area: istioctl releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 17 03:43:40 UTC 2023 - 212 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go
}); err != nil { t.Fatalf("Failed to wait progress requests, err: %s, want: %d , got %d", err, wantRequestsSent, requestsSent) } pr.Add() clock.Step(progressRequestPeriod * 2) if err := pollConditionNoChange(pollPeriod, minimalNoChange, pollTimeout, func() bool { requestsSent = pr.progressRequestsSentCount.Load() return requestsSent == wantRequestsSent }); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0) -
src/os/pidfd_linux_test.go
} // Check that all Process' public methods work as expected with // "done" Process. if err := proc.Kill(); err != os.ErrProcessDone { t.Errorf("Kill: got %v, want %v", err, os.ErrProcessDone) } if err := proc.Signal(os.Kill); err != os.ErrProcessDone { t.Errorf("Signal: got %v, want %v", err, os.ErrProcessDone) } if _, err := proc.Wait(); !errors.Is(err, syscall.ECHILD) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 1.6K bytes - Viewed (0) -
src/os/exec_unix_test.go
// Solaris/Illumos have a lower limit, above which wait returns // EINVAL (see waitid in usr/src/uts/common/os/exit.c in // illumos). This is configurable via sysconf(_SC_MAXPID), but // we'll just take the default. pid = 30000-1 } p, err := FindProcess(pid) if err != nil { t.Fatalf("FindProcess(math.MaxInt32) got err %v, want nil", err) } if ps, err := p.Wait(); !errors.Is(err, syscall.ECHILD) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 2K bytes - Viewed (0) -
src/internal/singleflight/singleflight_test.go
"testing" "time" ) func TestDo(t *testing.T) { var g Group v, err, _ := g.Do("key", func() (any, error) { return "bar", nil }) if got, want := fmt.Sprintf("%v (%T)", v, v), "bar (string)"; got != want { t.Errorf("Do = %v; want %v", got, want) } if err != nil { t.Errorf("Do error = %v", err) } } func TestDoErr(t *testing.T) { var g Group someErr := errors.New("some error")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 29 22:21:50 UTC 2023 - 3.9K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
delete(parsedLog, "time") want := map[string]any{ "level": cases[i].level, "msg": cases[i].msg, } if k := cases[i].key; k != nil { want["key"] = *k } assert.Equal(t, want, parsedLog) i++ } } func TestParseCniLog(t *testing.T) { wantT := &time.Time{} assert.NoError(t, wantT.UnmarshalText([]byte("2020-01-01T00:00:00.356374Z")))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/scheduler/framework/interface_test.go
t.Errorf("unexpected diff (-want, +got):\n%s", diff) } }) } } func TestIsStatusEqual(t *testing.T) { tests := []struct { name string x, y *Status want bool }{ { name: "two nil should be equal", x: nil, y: nil, want: true, }, { name: "nil should be equal to success status", x: nil,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Oct 22 04:41:59 UTC 2023 - 7.3K bytes - Viewed (0)