Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of about 10,000 for allm (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top