- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 451 for procMs (0.15 sec)
-
src/internal/trace/oldtrace.go
ctx: schedCtx{ G: GoID(ev.G), P: ProcID(ev.P), M: it.procMs[ProcID(ev.P)], }, table: it.evt, base: baseEvent{ typ: go122.EvGoLabel, time: Time(ev.Ts), args: timedEventArgs{ev.Args[2]}, }, }} return Event{ ctx: schedCtx{ G: GoID(ev.G), P: ProcID(ev.P), M: it.procMs[ProcID(ev.P)], }, table: it.evt, base: baseEvent{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
src/internal/trace/summary.go
case GoSyscall: s.syscallingP[ev.Proc()] = id s.syscallingG[id] = ev.Proc() g.lastSyscallTime = ev.Time() } // Handle procs to detect syscall blocking, which si identifiable as a // proc going idle while the goroutine it was attached to is in a syscall. case ResourceProc: id := st.Resource.Proc() old, new := st.Proc() if old != new && new == ProcIdle {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K 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/os/exec/exec_test.go
cancel() err := cmd.Wait() t.Logf("stderr:\n%s", cmd.Stderr) t.Logf("[%d] %v", cmd.Process.Pid, err) // This test should kill the child process after 10ms, // leaving a grandchild process writing probes in a loop. // The child process should be reported as failed, // and the grandchild will exit (or die by SIGPIPE) once the // stderr pipe is closed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 48.4K 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/testing/fuzz.go
m := newMatcher(deps.MatchString, *match, "-test.run", *skip) var mFuzz *matcher if *matchFuzz != "" { mFuzz = newMatcher(deps.MatchString, *matchFuzz, "-test.fuzz", *skip) } for _, procs := range cpuList { runtime.GOMAXPROCS(procs) for i := uint(0); i < *count; i++ { if shouldFailFast() { break } tctx := newTestContext(*parallel, m) tctx.deadline = deadline
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 22.9K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
log.Debug("pod netns was not found, trying to find it using procfs") // this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
src/internal/trace/testtrace/validation.go
} } case trace.ResourceProc: // Basic state transition validation. id := tr.Resource.Proc() old, new := tr.Proc() if new == trace.ProcUndetermined { e.Errorf("transition to undetermined state for proc %d", id) } if v.seenSync && old == trace.ProcUndetermined { e.Errorf("undetermined proc %d after first global sync", id) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.9K bytes - Viewed (0) -
src/os/exec.go
// On most operating systems, the Process must be a child // of the current process or an error will be returned. func (p *Process) Wait() (*ProcessState, error) { return p.wait() } // Signal sends a signal to the [Process]. // Sending [Interrupt] on Windows is not implemented. func (p *Process) Signal(sig Signal) error { return p.signal(sig) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
var kmsHealthChecks []healthz.HealthChecker transformers, probes, kmsUsed, err := getTransformerOverridesAndKMSPluginProbes(ctx, config, apiServerID) if err != nil { return nil, nil, nil, err } for i := range probes { probe := probes[i] kmsHealthChecks = append(kmsHealthChecks, probe.toHealthzCheck(i)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0)