- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of about 10,000 for allm (0.06 sec)
-
src/runtime/debug.go
var n = int64(atomic.Load64(&ncgocall)) for mp := (*m)(atomic.Loadp(unsafe.Pointer(&allm))); mp != nil; mp = mp.alllink { n += int64(mp.ncgocall) } return n } func totalMutexWaitTimeNanos() int64 { total := sched.totalMutexWaitTime.Load() total += sched.totalRuntimeLockWaitTime.Load() for mp := (*m)(atomic.Loadp(unsafe.Pointer(&allm))); mp != nil; mp = mp.alllink { total += mp.mLockProfile.waitTime.Load() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 4.2K bytes - Viewed (0) -
operator/pkg/name/name.go
// Consolidated returns a representation of mm where all manifests in the slice under a key are combined into a single // manifest. func (mm ManifestMap) Consolidated() map[string]string { out := make(map[string]string) for cname, ms := range mm { allM := "" for _, m := range ms { allM += m + helm.YAMLSeparator } out[string(cname)] = allM } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 7.9K bytes - Viewed (0) -
src/runtime/os_linux.go
// This function depends on several properties: // // 1. All OS threads that already exist are associated with an M in // allm. i.e., we won't miss any pre-existing threads. // 2. All Ms listed in allm will eventually have an OS thread exist. // i.e., they will set procid and be able to receive signals. // 3. OS threads created after we read allm will clone from a thread
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 25.9K bytes - Viewed (0) -
src/runtime/trace.go
// // Preventing preemption is sufficient to access allp safely. allp is only // mutated by GOMAXPROCS calls, which require a STW. // // TODO(mknyszek): Consider explicitly emitting ProcCreate and ProcDestroy // events to indicate whether a P exists, rather than just making its // existence implicit. mp = acquirem() for _, pp := range allp[len(allp):cap(allp)] { pp.trace.readyNextGen(traceNextGen(gen)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
src/runtime/os_plan9.go
if !atomic.Cas(&exiting, 0, 1) { return } getg().m.locks++ n := copy(buf[:], goexits) n = copy(buf[n:], gostringnocopy(status)) pid := getpid() for mp := (*m)(atomic.Loadp(unsafe.Pointer(&allm))); mp != nil; mp = mp.alllink { if mp.procid != 0 && mp.procid != pid { postnote(mp.procid, buf[:]) } } getg().m.locks-- } var procdir = []byte("/proc/") var notefile = []byte("/note\x00")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 10.3K bytes - Viewed (0) -
src/runtime/runtime2.go
waitReasonFlushProcCaches: true, } var ( allm *m gomaxprocs int32 ncpu int32 forcegc forcegcstate sched schedt newprocs int32 ) var ( // allpLock protects P-less reads and size changes of allp, idlepMask, // and timerpMask, and all writes to allp. allpLock mutex // len(allp) == gomaxprocs; may change at safe points, otherwise // immutable.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
src/runtime/proc.go
mp.gsignal.stackguard1 = mp.gsignal.stack.lo + stackGuard } // Add to allm so garbage collector doesn't free g->m // when it is just in a register or thread-local storage. mp.alllink = allm // NumCgoCall() and others iterate over allm w/o schedlock, // so we need to publish it safely. atomicstorep(unsafe.Pointer(&allm), unsafe.Pointer(mp)) unlock(&sched.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
src/runtime/os_windows.go
// all Ps being idle. // // Some versions of Windows have high resolution timer. For those // versions osRelax is noop. // For Windows versions without high resolution timer, osRelax // adjusts the system-wide timer resolution. Go needs a // high resolution timer while running and there's little extra cost // if we're already using the CPU, but if all Ps are idle there's no
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 41.5K bytes - Viewed (0) -
src/runtime/heapdump.go
// Copyright 2014 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Implementation of runtime/debug.WriteHeapDump. Writes all // objects in the heap plus additional info (roots, threads, // finalizers, etc.) to a file. // The format of the dumped file is described at // https://golang.org/s/go15heapdump. package runtime import ( "internal/abi"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 09 04:07:57 UTC 2024 - 17.6K bytes - Viewed (0) -
src/runtime/traceruntime.go
// // sched.lock must be held to synchronize with traceAdvance. func traceThreadDestroy(mp *m) { assertLockHeld(&sched.lock) // Flush all outstanding buffers to maintain the invariant // that an M only has active buffers while on sched.freem // or allm. // // Perform a traceAcquire/traceRelease on behalf of mp to // synchronize with the tracer trying to flush our buffer // as well.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0)