- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 79 for Procs (0.04 sec)
-
src/go/doc/testdata/benchmark.go
os.Exit(1) } if !matched { continue } for _, procs := range cpuList { runtime.GOMAXPROCS(procs) b := &B{ common: common{ signal: make(chan any), }, benchmark: Benchmark, } benchName := Benchmark.Name if procs != 1 { benchName = fmt.Sprintf("%s-%d", Benchmark.Name, procs) } fmt.Printf("%s\t", benchName) r := b.run() if b.failed {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 7.4K 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/runtime/symtab_test.go
// license that can be found in the LICENSE file. package runtime_test import ( "runtime" "strings" "testing" "unsafe" ) func TestCaller(t *testing.T) { procs := runtime.GOMAXPROCS(-1) c := make(chan bool, procs) for p := 0; p < procs; p++ { go func() { for i := 0; i < 1000; i++ { testCallerFoo(t) } c <- true }() defer func() { <-c }() } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 17 21:46:33 UTC 2022 - 7.5K bytes - Viewed (0) -
pkg/kubelet/cm/helpers_linux.go
} // getCgroupProcs takes a cgroup directory name as an argument // reads through the cgroup's procs file and returns a list of tgid's. // It returns an empty list if a procs file doesn't exists func getCgroupProcs(dir string) ([]int, error) { procsFile := filepath.Join(dir, "cgroup.procs") f, err := os.Open(procsFile) if err != nil { if os.IsNotExist(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 11:52:28 UTC 2023 - 9.8K bytes - Viewed (0) -
src/runtime/signal_plan9.go
{_SigNotify, "sys: write on closed pipe"}, // Other system notes are more serious and cannot be recovered. {_SigThrow, "sys:"}, // Issued to all other procs when calling runtime·exit. {_SigGoExit, "go: exit "}, // Kill is sent by external programs to cause an exit. {_SigKill, "kill"}, // Interrupts can be handled if desired, otherwise they cause an exit.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 07 16:25:17 UTC 2016 - 1.9K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue9400_linux.go
import "C" import ( "runtime" "runtime/debug" "sync/atomic" "testing" "cmd/cgo/internal/test/issue9400" ) func test9400(t *testing.T) { // We synchronize through a shared variable, so we need two procs defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(2)) // Start signaller atomic.StoreInt32(&issue9400.Baton, 0) go func() { // Wait for RewindAndSetgid for atomic.LoadInt32(&issue9400.Baton) == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 1.7K bytes - Viewed (0) -
src/go/doc/testdata/testing.go
ok = true if len(tests) == 0 { fmt.Fprintln(os.Stderr, "testing: warning: no tests to run") return } for _, procs := range cpuList { runtime.GOMAXPROCS(procs) // We build a new channel tree for each run of the loop. // collector merges in one channel all the upstream signals from parallel tests.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 11.8K bytes - Viewed (0)