- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 5,360 for watt (0.04 sec)
-
pkg/kubelet/util/manager/watch_based_manager.go
"k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apimachinery/pkg/watch" "k8s.io/utils/clock" ) type listObjectFunc func(string, metav1.ListOptions) (runtime.Object, error) type watchObjectFunc func(string, metav1.ListOptions) (watch.Interface, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
operator/pkg/util/progress/progress.go
comps := make([]string, 0, len(p.components)) wait := make([]string, 0, len(p.components)) for c, l := range p.components { comps = append(comps, name.UserFacingComponentName(name.ComponentName(c))) wait = append(wait, l.waitingResources()...) } sort.Strings(comps) sort.Strings(wait) msg := fmt.Sprintf(`Processing resources for %s.`, strings.Join(comps, ", ")) if len(wait) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 6.2K bytes - Viewed (0) -
src/os/readfrom_linux_test.go
} if dstoff != int64(len(data)) { t.Errorf("dstoff = %d, want %d", dstoff, len(data)) } if n != int64(len(data)) { t.Errorf("short ReadFrom: wrote %d bytes, want %d", n, len(data)) } mustSeekStart(t, dst) mustContainData(t, dst, data) // If we had a limit, check that it was updated. if lr != nil { if want := limit - n; lr.N != want {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 20.3K bytes - Viewed (0) -
src/runtime/sema_test.go
close(done) }() for SemNwait(&sema) == 0 { Gosched() // wait for goroutine to block in Semacquire } // The crux of the test: we release the semaphore with handoff // and immediately perform a CAS both here and in the waiter; we // want the CAS in the waiter to execute first. Semrelease1(&sema, true, 0) atomic.CompareAndSwapUint32(&res, 0, 2) wg.Wait() // wait for goroutines to finish to avoid data races
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 21 19:37:22 UTC 2022 - 4.2K bytes - Viewed (0) -
src/cmd/cgo/internal/testcarchive/carchive_test.go
for _, sec := range ef.Sections { want := elf.SHT_NULL switch sec.Name { case ".text", ".data": want = elf.SHT_PROGBITS case ".bss": want = elf.SHT_NOBITS case ".symtab": want = elf.SHT_SYMTAB case ".strtab": want = elf.SHT_STRTAB case ".init_array": want = elf.SHT_INIT_ARRAY case ".fini_array": want = elf.SHT_FINI_ARRAY case ".preinit_array":
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 00:43:51 UTC 2023 - 34.8K bytes - Viewed (0) -
src/runtime/netpoll_solaris.go
if portfd == -1 { return gList{}, 0 } var wait *timespec var ts timespec if delay < 0 { wait = nil } else if delay == 0 { wait = &ts } else { ts.setNsec(delay) if ts.tv_sec > 1e6 { // An arbitrary cap on how long to wait for a timer. // 1e6 s == ~11.5 days. ts.tv_sec = 1e6 } wait = &ts } var events [128]portevent retry:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0) -
cmd/metacache-stream_test.go
if entry.name != want[i] { t.Errorf("entry %d, want %q, got %q", i, want[i], entry.name) } } if entries.len() != len(want) { t.Fatal("unexpected length:", entries.len(), "want:", len(want)) } want = want[:0] entries, err = r.readN(0, false, true, false, "") if err != nil { t.Fatal(err, entries.len()) } if entries.len() != len(want) { t.Fatal("unexpected length:", entries.len(), "want:", len(want)) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 15K bytes - Viewed (0) -
src/go/token/position_test.go
) func checkPos(t *testing.T, msg string, got, want Position) { if got.Filename != want.Filename { t.Errorf("%s: got filename = %q; want %q", msg, got.Filename, want.Filename) } if got.Offset != want.Offset { t.Errorf("%s: got offset = %d; want %d", msg, got.Offset, want.Offset) } if got.Line != want.Line { t.Errorf("%s: got line = %d; want %d", msg, got.Line, want.Line) } if got.Column != want.Column {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 20:26:14 UTC 2024 - 14.3K bytes - Viewed (0) -
src/os/signal/signal_windows_test.go
"os" "os/signal" "time" ) func main() { c := make(chan os.Signal, 10) signal.Notify(c) select { case s := <-c: if s != os.Interrupt { log.Fatalf("Wrong signal received: got %q, want %q\n", s, os.Interrupt) } case <-time.After(3 * time.Second): log.Fatalf("Timeout waiting for Ctrl+Break\n") } } ` tmp := t.TempDir() // write ctrlbreak.go name := filepath.Join(tmp, "ctlbreak")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 21 23:07:55 UTC 2023 - 1.9K bytes - Viewed (0) -
src/time/internal_test.go
sources := []string{"../../lib/time/zoneinfo.zip"} z, err := loadLocation("America/Los_Angeles", sources) if err != nil { panic("cannot load America/Los_Angeles for testing: " + err.Error() + "; you may want to use -tags=timetzdata") } z.name = "Local" localLoc = *z } var origPlatformZoneSources []string = platformZoneSources func disablePlatformSources() (undo func()) { platformZoneSources = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:37 UTC 2024 - 2.2K bytes - Viewed (0)