- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for Procs (0.04 sec)
-
src/internal/trace/testdata/testprog/gc-stress.go
for i := range ballast { ballast[i] = new([1024]*node) for j := range ballast[i] { ballast[i][j] = &node{ data: [128]byte{1, 2, 3, 4}, } } } procs := runtime.GOMAXPROCS(-1) sink = make([][]byte, procs) for i := 0; i < procs; i++ { i := i go func() { for { sink[i] = make([]byte, 4<<10) } }() } // Increase the chance that we end up starting and stopping
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.5K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/futile-wakeup.go
} defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(8)) c0 := make(chan int, 1) c1 := make(chan int, 1) c2 := make(chan int, 1) const procs = 2 var done sync.WaitGroup done.Add(4 * procs) for p := 0; p < procs; p++ { const iters = 1e3 go func() { trace.WithRegion(context.Background(), "special", func() { for i := 0; i < iters; i++ { runtime.Gosched() c0 <- 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.8K bytes - Viewed (0) -
src/internal/trace/gc.go
series = len(out) out = append(out, []MutatorUtil{{int64(ev.Time()), 1}}) } ps = append(ps, perP{series: series}) } if len(procs) == 0 || gomaxprocs != procs[len(procs)-1].n { procs = append(procs, procsCount{time: int64(ev.Time()), n: gomaxprocs}) } } if len(ps) == 0 { // We can't start doing any analysis until we see what GOMAXPROCS is.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 26K bytes - Viewed (0) -
src/testing/benchmark_test.go
} testing.Benchmark(func(b *testing.B) { procs := uint32(0) iters := uint64(0) b.SetParallelism(3) b.RunParallel(func(pb *testing.PB) { atomic.AddUint32(&procs, 1) for pb.Next() { atomic.AddUint64(&iters, 1) } }) if want := uint32(3 * runtime.GOMAXPROCS(0)); procs != want { t.Errorf("got %v procs, want %v", procs, want) } if iters != uint64(b.N) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 5.6K bytes - Viewed (0) -
cni/pkg/repair/netns.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 04:07:10 UTC 2024 - 4.3K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress.go
}() time.Sleep(time.Millisecond) // give the goroutine above time to block if err := trace.Start(os.Stdout); err != nil { log.Fatalf("failed to start tracing: %v", err) } defer trace.Stop() procs := runtime.GOMAXPROCS(10) time.Sleep(50 * time.Millisecond) // test proc stop/start events go func() { runtime.LockOSThread() for { select { case <-done: return default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.5K bytes - Viewed (0) -
src/testing/benchmark.go
if len(*matchBenchmarks) == 0 { return true } // Collect matching benchmarks and determine longest name. maxprocs := 1 for _, procs := range cpuList { if procs > maxprocs { maxprocs = procs } } ctx := &benchContext{ match: newMatcher(matchString, *matchBenchmarks, "-test.bench", *skip), extLen: len(benchmarkName("", maxprocs)), }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23.9K bytes - Viewed (0) -
src/cmd/trace/procgen.go
} } // TODO(mknyszek): Consider modeling procs differently and have them be // transition to and from NotExist when GOMAXPROCS changes. We can emit // events for this to clearly delineate GOMAXPROCS changes. if viewerEv.Name != "" { ctx.Instant(viewerEv) } } func (g *procGenerator) Finish(ctx *traceContext) { ctx.SetResourceType("PROCS")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.1K bytes - Viewed (0) -
src/cmd/trace/jsontrace_test.go
checkExecutionTimes(t, data) checkPlausibleHeapMetrics(t, data) // TODO(mknyszek): Check for plausible thread and goroutine metrics. checkMetaNamesEmitted(t, data, "process_name", []string{"STATS", "PROCS"}) checkMetaNamesEmitted(t, data, "thread_name", []string{"GC", "Network", "Timers", "Syscalls", "Proc 0"}) checkProcStartStop(t, data) checkSyscalls(t, data) checkNetworkUnblock(t, data)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 7.8K bytes - Viewed (0) -
src/runtime/lock_futex.go
// Atomically, // if *addr == val { sleep } // Might be woken up spuriously; that's allowed. // Don't sleep longer than ns; ns < 0 means forever. // // futexwakeup(addr *uint32, cnt uint32) // If any procs are sleeping on addr, wake up at most cnt. const ( mutex_unlocked = 0 mutex_locked = 1 mutex_sleeping = 2 active_spin = 4 active_spin_cnt = 30 passive_spin = 1 )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0)