- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 4,315 for watt (0.06 sec)
-
src/sync/cond_test.go
n := 2 running := make(chan bool, n) awake := make(chan bool, n) for i := 0; i < n; i++ { go func() { m.Lock() running <- true c.Wait() awake <- true m.Unlock() }() } for i := 0; i < n; i++ { <-running // Wait for everyone to run. } for n > 0 { select { case <-awake: t.Fatal("goroutine not asleep") default: } m.Lock() c.Signal() m.Unlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 18:52:42 UTC 2023 - 5K bytes - Viewed (0) -
src/sync/example_test.go
sum += i } fmt.Println("Computed once:", sum) return sum }) done := make(chan bool) for i := 0; i < 10; i++ { go func() { const want = 499500 got := once() if got != want { fmt.Println("want", want, "got", got) } done <- true }() } for i := 0; i < 10; i++ { <-done } // Output: // Computed once: 499500 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 23 17:45:47 UTC 2024 - 2.2K bytes - Viewed (0) -
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/vendor/golang.org/x/net/nettest/conntest.go
f(t, c1, c2) } // testBasicIO tests that the data sent on c1 is properly received on c2. func testBasicIO(t *testing.T, c1, c2 net.Conn) { want := make([]byte, 1<<20) rand.New(rand.NewSource(0)).Read(want) dataCh := make(chan []byte) go func() { rd := bytes.NewReader(want) if err := chunkedCopy(c1, rd); err != nil { t.Errorf("unexpected c1.Write error: %v", err) } if err := c1.Close(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0) -
src/cmd/go/internal/script/engine.go
// This error was surfaced from a background process by a call to Wait. // Add a call frame for Wait itself, but ignore its "want" field. // (Wait itself cannot fail to wait on commands or else it would leak // processes and/or goroutines — so a negative assertion for it would be at // best ambiguous.) return cmdError(cmd, err) } if cmd.want == success { return cmdError(cmd, err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 27 01:16:19 UTC 2023 - 22.2K bytes - Viewed (0) -
src/net/sendfile_test.go
c, err := Dial("tcp", ln.Addr().String()) if err != nil { t.Fatal(err) } defer c.Close() buf := new(bytes.Buffer) buf.ReadFrom(c) if want, have := "Produced ", buf.String(); have != want { t.Errorf("unexpected server reply %q, want %q", have, want) } for err := range errc { t.Error(err) } } func TestSendfileSeeked(t *testing.T) { ln := newLocalListener(t, "tcp")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0) -
src/os/signal/signal_test.go
c, stop := NotifyContext(parent, syscall.SIGINT) defer stop() if want, got := "signal.NotifyContext(context.Background.WithCancel, [interrupt])", fmt.Sprint(c); want != got { t.Errorf("c.String() = %q, want %q", got, want) } cancelParent() <-c.Done() if got := c.Err(); got != context.Canceled { t.Errorf("c.Err() = %q, want %q", got, context.Canceled) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K 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)