Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 189 for _Gwaiting (0.51 sec)

  1. src/runtime/preempt.go

    			// ownership of it by transitioning it to
    			// _Gwaiting.
    			if !casGFromPreempted(gp, _Gpreempted, _Gwaiting) {
    				break
    			}
    
    			// We stopped the G, so we have to ready it later.
    			stopped = true
    
    			s = _Gwaiting
    			fallthrough
    
    		case _Grunnable, _Gsyscall, _Gwaiting:
    			// Claim goroutine by setting scan bit.
    			// This may race with execution or readying of gp.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  2. src/runtime/runtime2.go

    	sudogcache *sudog
    
    	// Central pool of available defer structs.
    	deferlock mutex
    	deferpool *_defer
    
    	// freem is the list of m's waiting to be freed when their
    	// m.exited is set. Linked through m.freelink.
    	freem *m
    
    	gcwaiting  atomic.Bool // gc is waiting to run
    	stopwait   int32
    	stopnote   note
    	sysmonwait atomic.Bool
    	sysmonnote note
    
    	// safePointFn should be called on each P at the next GC
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  3. src/runtime/tracestack.go

    		// If the scan bit is set, assume we're the ones that acquired it.
    		if status&_Gscan == 0 {
    			// Use the trace status to check this. There are a number of cases
    			// where a running goroutine might be in _Gwaiting, and these cases
    			// are totally fine for taking a stack trace. They're captured
    			// correctly in goStatusToTraceGoStatus.
    			switch goStatusToTraceGoStatus(status, gp.waitreason) {
    			case traceGoRunning, traceGoSyscall:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 14:38:56 UTC 2024
    - 11K bytes
    - Viewed (0)
  4. src/runtime/trace.go

    	//  // <----> problem window
    	//	casgstatus(gp, _Gwaiting, _Grunnable)
    	//	if trace.ok() {
    	//		trace.GoUnpark(gp, 2)
    	//		traceRelease(trace)
    	//	}
    	//
    	// More precisely, if we readgstatus for a gp while another goroutine is in the problem
    	// window and that goroutine didn't observe that tracing had begun, then we might write
    	// a GoStatus(GoWaiting) event for that goroutine, but it won't trace an event marking
    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/mfinal.go

    		lock(&finlock)
    		// We know the queue has been drained when both finq is nil
    		// and the finalizer g has stopped executing.
    		empty := finq == nil
    		empty = empty && readgstatus(fing) == _Gwaiting && fing.waitreason == waitReasonFinalizerWait
    		unlock(&finlock)
    		if empty {
    			return true
    		}
    		Gosched()
    	}
    	return false
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 01:56:56 UTC 2024
    - 19K bytes
    - Viewed (0)
  6. src/runtime/stack.go

    	// preempt.
    	// This check is very early in newstack so that even the status change
    	// from Grunning to Gwaiting and back doesn't happen in this case.
    	// That status change by itself can be viewed as a small preemption,
    	// because the GC might change Gwaiting to Gscanwaiting, and then
    	// this goroutine has to wait for the GC to finish before continuing.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 41.1K bytes
    - Viewed (0)
  7. src/runtime/traceruntime.go

    }
    
    // emitUnblockStatus emits a GoStatus GoWaiting event for a goroutine about to be
    // unblocked to the trace writer.
    func emitUnblockStatus(w traceWriter, gp *g, gen uintptr) traceWriter {
    	if !gp.trace.statusWasTraced(gen) && gp.trace.acquireStatus(gen) {
    		// TODO(go.dev/issue/65634): Although it would be nice to add a stack trace here of gp,
    		// we cannot safely do so. gp is in _Gwaiting and so we don't have ownership of its stack.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 25.7K bytes
    - Viewed (0)
  8. src/runtime/export_test.go

    type G = g
    
    type Sudog = sudog
    
    func Getg() *G {
    	return getg()
    }
    
    func Goid() uint64 {
    	return getg().goid
    }
    
    func GIsWaitingOnMutex(gp *G) bool {
    	return readgstatus(gp) == _Gwaiting && gp.waitreason.isMutexWait()
    }
    
    var CasGStatusAlwaysTrack = &casgstatusAlwaysTrack
    
    //go:noinline
    func PanicForTesting(b []byte, i int) byte {
    	return unexportedPanicForTesting(b, i)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:50:53 UTC 2024
    - 46.1K bytes
    - Viewed (0)
  9. src/internal/trace/trace_test.go

    				{"sync.(*Mutex).Lock", 0},
    				{"main.main.func7", 0},
    			}},
    			{trace.EventStateTransition, "Goroutine Waiting->Runnable", []frame{
    				{"sync.(*Mutex).Unlock", 0},
    				{"main.main", 0},
    			}},
    			{trace.EventStateTransition, "Goroutine Running->Waiting", []frame{
    				{"sync.(*WaitGroup).Wait", 0},
    				{"main.main.func8", 0},
    			}},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  10. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultFileLockManager.java

                lock.lock();
                try {
                    if (waiting > 0) {
                        condition.signalAll();
                    }
                } finally {
                    lock.unlock();
                }
            }
    
            @VisibleForTesting
            boolean isWaiting() {
                lock.lock();
                try {
                    return waiting > 0;
                } finally {
                    lock.unlock();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 26 16:02:32 UTC 2024
    - 22.3K bytes
    - Viewed (0)
Back to top