internal/runtime/atomic.Uint32.Load (method)

120 uses

	internal/runtime/atomic (current package)
		types.go#L193: func (u *Uint32) Load() uint32 {

	runtime
		cgocall.go#L397: 	if gp.m.needextram || extraMWaiters.Load() > 0 {
		debuglog.go#L88: 			if l1.owned.Load() == 0 && l1.owned.CompareAndSwap(0, 1) {
		mcache.go#L359: 	flushGen := c.flushGen.Load()
		mcleanup.go#L589: 	return q.workUnits.Load() > 0 && (q.asleep.Load() > 0 || q.ng.Load() < maxCleanupGs())
		mcleanup.go#L602: 	asleep := uint64(q.asleep.Load())
		mcleanup.go#L618: 		newg := min(extra, maxCleanupGs()-q.ng.Load())
		mcleanup.go#L647: 	have := q.ng.Load()
		mcleanup.go#L655: 	return q.needg.Load() > 0
		mcleanup.go#L660: 	have := q.ng.Load()
		mcleanup.go#L770: 		if q.flushed.Load() && q.full.empty() && uint32(q.sleeping.size) == q.ng.Load() {
		metrics.go#L345: 				out.scalar = uint64(gcCPULimiter.lastEnabledCycle.Load())
		metrics.go#L810: 	a.threads = uint64(mcount()) - uint64(extraMInUse.Load()) - uint64(extraMLength.Load())
		mfinal.go#L171: 	if fingStatus.Load() == fingUninitialized && fingStatus.CompareAndSwap(fingUninitialized, fingCreated) {
		mgc.go#L549: 	n := work.cycles.Load()
		mgc.go#L564: 	for work.cycles.Load() == n+1 && sweepone() != ^uintptr(0) {
		mgc.go#L579: 	for work.cycles.Load() == n+1 && !isSweepDone() {
		mgc.go#L587: 	cycle := work.cycles.Load()
		mgc.go#L649: 		nMarks := work.cycles.Load()
		mgc.go#L707: 	if !memstats.enablegc || panicking.Load() != 0 || gcphase != _GCoff {
		mgc.go#L722: 		return int32(t.n-work.cycles.Load()) > 0
		mgc.go#L807: 		if fg := p.mcache.flushGen.Load(); fg != mheap_.sweepgen {
		mgc.go#L1223: 	oldRootJobs := work.markrootJobs.Load()
		mgc.go#L1963: 	if next, jobs := work.markrootNext.Load(), work.markrootJobs.Load(); work.full != 0 || next < jobs {
		mgcmark.go#L180: 	if next, jobs := work.markrootNext.Load(), work.markrootJobs.Load(); next < jobs {
		mgcmark.go#L1195: 		return job, job < work.markrootJobs.Load()
		mgcmark.go#L1199: 	for next, jobs := work.markrootNext.Load(), work.markrootJobs.Load(); next < jobs; next = work.markrootNext.Load() {
		mgcmark.go#L1267: 	if work.markrootNext.Load() < work.markrootJobs.Load() {
		mgcmark.go#L1424: 								if work.markrootNext.Load() < work.markrootJobs.Load() {
		mgcmark_greenteagc.go#L515: 	h := r.head.Load() // synchronize with consumers
		mgcmark_greenteagc.go#L516: 	t := r.tail.Load()
		mgcmark_greenteagc.go#L594: 		h := r.head.Load() // load-acquire, synchronize with other consumers
		mgcmark_greenteagc.go#L595: 		t := r.tail.Load() // load-acquire, synchronize with the producer
		mgcmark_greenteagc.go#L733: 	h := r.head.Load()
		mgcmark_greenteagc.go#L734: 	t := r.tail.Load()
		mgcmark_greenteagc.go#L1169: 	if work.markrootNext.Load() < work.markrootJobs.Load() {
		mgcpacer.go#L1364: 		gcWaitOnMark(work.cycles.Load())
		mgcsweep.go#L150: 		state := a.state.Load()
		mgcsweep.go#L167: 		state := a.state.Load()
		mgcsweep.go#L195: 		state := a.state.Load()
		mgcsweep.go#L207: 	return a.state.Load() &^ sweepDrainedMask
		mgcsweep.go#L214: 	return a.state.Load() == sweepDrainedMask
		mprof.go#L191: 	v := c.value.Load()
		mprof.go#L200: 		prev := c.value.Load()
		mprof.go#L217: 		prev := c.value.Load()
		mprof.go#L1308: 	return goroutineProfileState((*atomic.Uint32)(p).Load())
		mprof.go#L1379: 	if fingStatus.Load()&fingRunningFinalizer != 0 {
		mprof.go#L1382: 	n += int(gcCleanups.running.Load())
		mspanset.go#L269: 			if block.popped.Load() == 0 {
		mspanset.go#L275: 			if block.popped.Load() == spanSetBlockEntries {
		mstats.go#L787: 	gen := m.gen.Load() % 3
		mstats.go#L856: 	currGen := m.gen.Load()
		mstats.go#L879: 		for p.statsSeq.Load()%2 != 0 {
		netpoll.go#L143: 	return pollInfo(pd.atomicInfo.Load())
		netpoll.go#L167: 	x := pd.atomicInfo.Load()
		netpoll.go#L169: 		x = pd.atomicInfo.Load()
		netpoll.go#L178: 	x := pd.atomicInfo.Load()
		netpoll.go#L184: 		x = pd.atomicInfo.Load()
		netpoll.go#L219: 	if netpollInited.Load() == 0 {
		netpoll.go#L223: 		if netpollInited.Load() == 0 {
		netpoll.go#L232: 	return netpollInited.Load() != 0
		netpoll.go#L678: 	return netpollWaiters.Load() > 0
		preempt.go#L196: 			if gp.preemptStop && gp.preempt && gp.stackguard0 == stackPreempt && asyncM == gp.m && asyncM.preemptGen.Load() == asyncGen {
		preempt.go#L212: 			asyncGen2 := asyncM2.preemptGen.Load()
		print.go#L46: 	if panicking.Load() == 0 {
		proc.go#L310: 	if runningPanicDefers.Load() != 0 {
		proc.go#L313: 			if runningPanicDefers.Load() == 0 {
		proc.go#L319: 	if panicking.Load() != 0 {
		proc.go#L974: 	count := mcount() - int32(extraMInUse.Load()) - int32(extraMLength.Load())
		proc.go#L1208: 	return gp.atomicstatus.Load()
		proc.go#L1296: 		if oldval == _Gwaiting && gp.atomicstatus.Load() == _Grunnable {
		proc.go#L1307: 			for x := 0; x < 10 && gp.atomicstatus.Load() != oldval; x++ {
		proc.go#L2076: 		if mp.signalPending.Load() != 0 {
		proc.go#L2289: 			wait := freem.freeWait.Load()
		proc.go#L2498: 	} else if extraMLength.Load() == 0 {
		proc.go#L3453: 	if fingStatus.Load()&(fingWait|fingWake) == fingWait|fingWake {
		proc.go#L3610: 	if !mp.spinning && sched.needspinning.Load() == 1 {
		proc.go#L5800: 		if mp.cgoCallersUse.Load() == 0 && mp.cgoCallers != nil && mp.cgoCallers[0] != 0 {
		proc.go#L6383: 	if panicking.Load() > 0 {
		proc.go#L6392: 	if !iscgo && cgoHasExtraM && extraMLength.Load() > 0 {
		proc.go#L6591: 		if scavenger.sysmonWake.Load() != 0 {
		proc.go#L6906: 	print("SCHED ", (now-starttime)/1e6, "ms: gomaxprocs=", gomaxprocs, " idleprocs=", sched.npidle.Load(), " threads=", mcount(), " spinningthreads=", sched.nmspinning.Load(), " needspinning=", sched.needspinning.Load(), " idlethreads=", sched.nmidle, " runqueue=", sched.runq.size)
		proc.go#L7382: 	if pp.timers.len.Load() == 0 {
		profbuf.go#L416: 	if b.eof.Load() > 0 {
		profbuf.go#L500: 		if b.eof.Load() > 0 {
		runtime.go#L238: 		gp == nil && panicking.Load() > 0 {
		runtime.go#L260: 	if panicking.Load() > 0 {
		runtime.go#L287: 	if panicking.Load() > 0 {
		sema.go#L214: 	if root.nwait.Load() == 0 {
		sema.go#L220: 	if root.nwait.Load() == 0 {
		sema.go#L634: 	if l.wait.Load() == atomic.Load(&l.notify) {
		sema.go#L649: 	atomic.Store(&l.notify, l.wait.Load())
		sema.go#L671: 	if l.wait.Load() == atomic.Load(&l.notify) {
		sema.go#L679: 	if t == l.wait.Load() {
		signal_unix.go#L795: 		if crashing.Load() < mcount()-int32(extraMLength.Load()) {
		signal_unix.go#L817: 			for timeout > 0 && (crashing.Load() < mcount()-int32(extraMLength.Load())) {
		sigqueue.go#L100: 		switch sig.state.Load() {
		sigqueue.go#L143: 			switch sig.state.Load() {
		sigqueue.go#L185: 	for sig.delivering.Load() != 0 {
		sigqueue.go#L192: 	for sig.state.Load() != sigReceiving {
		symtab.go#L1069: 		if strict && panicking.Load() == 0 {
		symtab.go#L1124: 	if panicking.Load() != 0 || !strict {
		time.go#L454: 	if netpollInited.Load() == 0 {
		time.go#L1030: 	force := ts == &getg().m.p.ptr().timers && int(zombies) > int(ts.len.Load())/4
		time.go#L1056: 		force = ts == &getg().m.p.ptr().timers && int(ts.zombies.Load()) > int(ts.len.Load())/4
		time.go#L1288: 	if n := int(ts.len.Load()); len(ts.heap) != n {
		traceback.go#L1425: 		return fingStatus.Load()&fingRunningFinalizer == 0
		traceback.go#L1734: 	if panicking.Load() > 0 || getg().m.curg != getg() {
		traceback.go#L1753: 	if panicking.Load() > 0 || getg().m.curg != getg() {
		tracestatus.go#L188: 	return r.statusTraced[gen%3].Load() != 0