- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for stw (0.05 sec)
-
src/runtime/debug.go
} lock(&sched.lock) ret := int(gomaxprocs) unlock(&sched.lock) if n <= 0 || n == ret { return ret } stw := stopTheWorldGC(stwGOMAXPROCS) // newprocs will be processed by startTheWorld newprocs = int32(n) startTheWorldGC(stw) return ret } // NumCPU returns the number of logical CPUs usable by the current process. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 4.2K bytes - Viewed (0) -
src/sync/pool_test.go
var total uint64 for _, ns := range pauses { total += ns } // ns/op for this benchmark is average STW time. b.ReportMetric(float64(total)/float64(b.N), "ns/op") b.ReportMetric(float64(pauses[len(pauses)*95/100]), "p95-ns/STW") b.ReportMetric(float64(pauses[len(pauses)*50/100]), "p50-ns/STW") } func BenchmarkPoolExpensiveNew(b *testing.B) { // Populate a pool with items that are expensive to construct
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8K bytes - Viewed (0) -
src/runtime/traceevent.go
traceEvGoStatus // goroutine status at the start of a generation [timestamp, goroutine ID, M ID, status] // STW. traceEvSTWBegin // STW start [timestamp, kind] traceEvSTWEnd // STW done [timestamp] // GC events. traceEvGCActive // GC active [timestamp, seq] traceEvGCBegin // GC start [timestamp, seq, stack ID]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.2K bytes - Viewed (0) -
src/sync/pool.go
var ( allPoolsMu Mutex // allPools is the set of pools that have non-empty primary // caches. Protected by either 1) allPoolsMu and pinning or 2) // STW. allPools []*Pool // oldPools is the set of pools that may have non-empty victim // caches. Protected by STW. oldPools []*Pool ) func init() { runtime_registerPoolCleanup(poolCleanup) } func indexLocal(l unsafe.Pointer, i int) *poolLocal {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 9.4K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser_test.go
for i := 0; i < res.Events.Len(); i++ { ev := res.Events.Ptr(i) if ver >= 21 { if ev.Type == EvSTWStart && res.Strings[ev.Args[0]] == "unknown" { t.Errorf("found unknown STW event; update stwReasonStrings?") } } } } func TestBuckets(t *testing.T) { var evs Events const N = eventsBucketSize*3 + 123 for i := 0; i < N; i++ { evs.append(Event{Ts: Timestamp(i)})
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 3.4K bytes - Viewed (0) -
src/runtime/os3_plan9.go
// license that can be found in the LICENSE file. package runtime import ( "internal/abi" "internal/goarch" "internal/stringslite" "unsafe" ) // May run during STW, so write barriers are not allowed. // //go:nowritebarrierrec func sighandler(_ureg *ureg, note *byte, gp *g) int { gsignal := getg() mp := gsignal.m var t sigTabT var docrash bool var sig int
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 4K bytes - Viewed (0) -
src/runtime/tracestatus.go
// writeProcStatusForP emits a ProcStatus event for the provided p based on its status. // // The caller must fully own pp and it must be prevented from transitioning (e.g. this can be // called by a forEachP callback or from a STW). func (w traceWriter) writeProcStatusForP(pp *p, inSTW bool) traceWriter { if !pp.trace.acquireStatus(w.gen) { return w } var status traceProcStatus switch pp.status { case _Pidle, _Pgcstop:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 7.2K bytes - Viewed (0)