- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 5,360 for watt (0.27 sec)
-
pkg/scheduler/scheduler_test.go
wantfns, ok := tt.want[e] if !ok { t.Errorf("got unexpected event %v", e) continue } if len(fns) != len(wantfns) { t.Errorf("got %v queueing hint functions, want %v", len(fns), len(wantfns)) continue } for i, fn := range fns { if fn.PluginName != wantfns[i].PluginName { t.Errorf("got plugin name %v, want %v", fn.PluginName, wantfns[i].PluginName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
src/internal/trace/summary_test.go
} } // Check logs. if len(want.logs) != len(summary.Logs) { t.Errorf("wanted %d logs for task %d, got %d logs instead", len(want.logs), id, len(summary.Logs)) } else { for i := range want.logs { if want.logs[i] != summary.Logs[i].Log() { t.Errorf("log mismatch: want %#v, got %#v", want.logs[i], summary.Logs[i].Log()) } } } // Check goroutines.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/istio-agent/health/health_check_test.go
cont := make(chan struct{}, len(expectedTCPEvents)) // wait for go-ahead for state change go func() { prev := false for _, want := range tcpHealthStatuses { if !prev && want { assert.NoError(t, listener.Listen()) } if prev && !want { assert.NoError(t, listener.Close()) } <-cont prev = want } }() eventNum := atomic.NewInt32(0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 16:50:11 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/test/framework/components/istioctl/kube.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet_test.go
if !reflect.DeepEqual(gotDNSNames, tt.wantDNSNames) { t.Errorf("addressesToHostnamesAndIPs() gotDNSNames = %v, want %v", gotDNSNames, tt.wantDNSNames) } if !reflect.DeepEqual(gotIPs, tt.wantIPs) { t.Errorf("addressesToHostnamesAndIPs() gotIPs = %v, want %v", gotIPs, tt.wantIPs) } }) } } func removeThenCreate(name string, data []byte, perm os.FileMode) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:40 UTC 2024 - 7.4K bytes - Viewed (0) -
internal/grid/muxserver.go
// Handler goroutine. var handlerErr atomic.Pointer[RemoteErr] go func() { wg.Wait() defer xioutil.SafeClose(send) err := m.handleRequests(ctx, msg, send, handler, handlerIn) if err != nil { handlerErr.Store(err) } }() // Response sender goroutine... go func(outBlock <-chan struct{}) { wg.Wait() defer m.parent.deleteMux(true, m.ID) m.sendResponses(ctx, send, c, &handlerErr, outBlock)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go
t.Errorf("migrateConfig() = %v, want %v", got, tt.want) } }) } } func Test_groupByPriority(t *testing.T) { type args struct { shutdownGracePeriodByPodPriority []kubeletconfig.ShutdownGracePeriodByPodPriority pods []*v1.Pod } tests := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 29.8K bytes - Viewed (0) -
src/cmd/go/internal/modload/search.go
if strings.HasPrefix(elem, ".") || strings.HasPrefix(elem, "_") || elem == "testdata" { want = false } } name := path.Join(importPathRoot, filepath.ToSlash(pkgDir[len(root):])) if !treeCanMatch(name) { want = false } if !fi.IsDir() { if fi.Mode()&fs.ModeSymlink != 0 && want && strings.Contains(m.Pattern(), "...") {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:15 UTC 2023 - 7.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultConditionalExecutionQueue.java
* the thread pool is full of work items that are waiting on other queued work items. The queued work items cannot execute * because the thread pool is already full with their parent work items. We use expand() to allow the thread pool to temporarily
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.2K bytes - Viewed (0) -
src/net/tcpsock_test.go
t.Errorf("ResolveTCPAddr(%q, %q) = %#v, %v, want %#v, %v", tt.network, tt.litAddrOrName, addr, err, tt.addr, tt.err) continue } if err == nil { addr2, err := ResolveTCPAddr(addr.Network(), addr.String()) if !reflect.DeepEqual(addr2, tt.addr) || err != tt.err {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0)