- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 2,831 for watt (0.04 sec)
-
src/crypto/internal/boring/bcache/cache_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 18 00:30:19 UTC 2022 - 2.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/xdsfake/updater.go
if len(events) == 0 { return } select { case e := <-fx.Events: found := false for i, want := range events { if e.Type == want.Type && (want.ID == "" || e.ID == want.ID) && (want.Namespace == "" || want.Namespace == e.Namespace) && (want.EndpointCount == 0 || want.EndpointCount == len(e.Endpoints)) { // Matched - delete event from desired events = slices.Delete(events, i)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/cache_test.go
} transformer := &envelopeTransformer{} want := sets.NewInt() startCh := make(chan struct{}) wg := sync.WaitGroup{} for i := 0; i < 100; i++ { want.Insert(i + 1) k := fmt.Sprintf("key-%d", i) wg.Add(1) go func(key string) { defer wg.Done() <-startCh cache.set([]byte(key), transformer) }(k) } close(startCh) wg.Wait() got := sets.NewInt()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 31 20:26:58 UTC 2023 - 4.9K bytes - Viewed (0) -
src/strings/reader_test.go
continue } if tt.wantpos != 0 && tt.wantpos != pos { t.Errorf("%d. pos = %d, want %d", i, pos, tt.wantpos) } buf := make([]byte, tt.n) n, err := r.Read(buf) if err != tt.readerr { t.Errorf("%d. read = %v; want %v", i, err, tt.readerr) continue } got := string(buf[:n]) if got != tt.want { t.Errorf("%d. got %q; want %q", i, got, tt.want) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/authenticator/audiences_test.go
auds: Audiences{"foo", "bar"}, tauds: Audiences{"foo", "wat"}, expected: Audiences{"foo"}, }, { auds: Audiences{"foo", "bar"}, tauds: Audiences{"pls", "wat"}, expected: Audiences{}, }, } for _, c := range cs { t.Run("auds", func(t *testing.T) { if got, want := c.auds.Intersect(c.tauds), c.expected; !reflect.DeepEqual(got, want) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 31 21:50:11 UTC 2018 - 1.7K bytes - Viewed (0) -
src/sync/atomic/value_test.go
atomic.AddUint64(&count, c) g.Done() }() } g.Wait() if want, got := (m*n-1)*(m*n)/2, count+v.Load().(uint64); got != want { t.Errorf("sum from 0 to %d was %d, want %v", m*n-1, got, want) } } var heapA, heapB = struct{ uint }{0}, struct{ uint }{0} var Value_CompareAndSwapTests = []struct { init any new any old any want bool err any }{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/error_test.go
tests := []struct { name string err error want bool }{ { err: ErrWaitTimeout, want: true, }, { err: context.Canceled, want: true, }, { err: context.DeadlineExceeded, want: true, }, { err: errWrapper{ErrWaitTimeout}, want: true, }, { err: errWrapper{context.Canceled}, want: true, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 2.8K bytes - Viewed (0) -
src/runtime/profbuf_test.go
write(t, b, unsafe.Pointer(&myTags[2]), 99, []uint64{101, 102}, []uintptr{201, 202, 203, 204}) wait() wait = readBlock(t, b, nil, nil) b.Close() wait() wait = readBlock(t, b, nil, nil) wait() readEOF(t, b) }) t.Run("DataWraparound", func(t *testing.T) { b := NewProfBuf(2, 16, 1024) for i := 0; i < 10; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 15 20:04:56 UTC 2023 - 8.5K bytes - Viewed (0) -
src/cmd/go/testdata/script/mod_concurrent.txt
env GO111MODULE=on # Concurrent builds should succeed, even if they need to download modules. go get ./x ./y go build ./x & go build ./y wait # Concurrent builds should update go.sum to the union of the hashes for the # modules they read. cmp go.sum go.sum.want -- go.mod -- module golang.org/issue/26794 require ( golang.org/x/text v0.3.0 rsc.io/sampler v1.0.0 ) -- x/x.go -- package x
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 28 17:19:14 UTC 2021 - 800 bytes - Viewed (0) -
cluster/gce/gci/health-monitor.sh
systemctl kill --kill-who=main "${container_runtime_name}" # Wait for a while, as we don't want to kill it again before it is really up. sleep 120 else sleep "${SLEEP_SECONDS}" fi done } function kubelet_monitoring { echo "Wait for 2 minutes for kubelet to be functional" # TODO(andyzheng0831): replace it with a more reliable method if possible.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 20 09:19:08 UTC 2022 - 3.3K bytes - Viewed (0)