Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 158 for _Gwaiting (0.13 sec)

  1. src/runtime/coro.go

    		// If we can CAS ourselves directly from running to waiting, so do,
    		// keeping the control transfer as lightweight as possible.
    		gp.waitreason = waitReasonCoroutine
    		if !gp.atomicstatus.CompareAndSwap(_Grunning, _Gwaiting) {
    			// The CAS failed: use casgstatus, which will take care of
    			// coordinating with the garbage collector about the state change.
    			casgstatus(gp, _Grunning, _Gwaiting)
    		}
    
    		// Clear gp.m.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:18 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  2. src/runtime/tracestatus.go

    	case _Grunnable:
    		tgs = traceGoRunnable
    	case _Grunning, _Gcopystack:
    		tgs = traceGoRunning
    	case _Gsyscall:
    		tgs = traceGoSyscall
    	case _Gwaiting, _Gpreempted:
    		// There are a number of cases where a G might end up in
    		// _Gwaiting but it's actually running in a non-preemptive
    		// state but needs to present itself as preempted to the
    		// garbage collector. In these cases, we're not going to
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  3. src/runtime/debugcall.go

    		if trace.ok() {
    			traceRelease(trace)
    		}
    		dropg()
    		lock(&sched.lock)
    		globrunqput(gp)
    		unlock(&sched.lock)
    
    		trace = traceAcquire()
    		casgstatus(callingG, _Gwaiting, _Grunnable)
    		if trace.ok() {
    			trace.GoUnpark(callingG, 0)
    			traceRelease(trace)
    		}
    		execute(callingG, true)
    	})
    }
    
    func debugCallWrap2(dispatch uintptr) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 05 20:50:21 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  4. src/cmd/trace/viewer.go

    		return traceviewer.GDead
    	case trace.GoRunnable:
    		return traceviewer.GRunnable
    	case trace.GoRunning:
    		return traceviewer.GRunning
    	case trace.GoWaiting:
    		if inMarkAssist {
    			return traceviewer.GWaitingGC
    		}
    		return traceviewer.GWaiting
    	case trace.GoSyscall:
    		// N.B. A goroutine in a syscall is considered "executing" (state.Executing() == true).
    		return traceviewer.GRunning
    	default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  5. src/internal/trace/resources.go

    	GoNotExist                    // Goroutine does not exist.
    	GoRunnable                    // Goroutine is runnable but not running.
    	GoRunning                     // Goroutine is running.
    	GoWaiting                     // Goroutine is waiting on something to happen.
    	GoSyscall                     // Goroutine is in a system call.
    )
    
    // Executing returns true if the state indicates that the goroutine is executing
    // and bound to its thread.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go

    }
    
    // conditionalProgressRequester will request progress notification if there
    // is a request waiting for watch cache to be fresh.
    type conditionalProgressRequester struct {
    	clock                TickerFactory
    	requestWatchProgress WatchProgressRequester
    	contextMetadata      metadata.MD
    
    	mux     sync.Mutex
    	cond    *sync.Cond
    	waiting int
    	stopped bool
    }
    
    func (pr *conditionalProgressRequester) Run(stopCh <-chan struct{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 24 09:56:38 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. subprojects/core/src/integTest/groovy/org/gradle/api/CrossProcessFileLockIntegrationTest.groovy

                  def sanityWaitUntil = System.currentTimeMillis() + 120000
                  println 'waiting for file...'
                  while(!file('stop.txt').exists()) {
                    Thread.sleep(300)
                    assert System.currentTimeMillis() < sanityWaitUntil : "Timeout waiting for file"
                  }
                  println 'no more waiting!'
                }
                def stopNow() {
                  assert file('stop.txt').createNewFile()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 03 15:21:23 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/testdata/HEAD/core.v1.PodStatusResult.yaml

            exitCode: 1
            finishedAt: "2006-01-01T01:01:01Z"
            message: messageValue
            reason: reasonValue
            signal: 2
            startedAt: "2005-01-01T01:01:01Z"
          waiting:
            message: messageValue
            reason: reasonValue
        name: nameValue
        ready: true
        resources:
          claims:
          - name: nameValue
          limits:
            limitsKey: "0"
          requests:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  9. src/internal/trace/internal/oldtrace/order.go

    		EvGoSysBlock, EvGoBlockGC:
    		g = ev.G
    		init = gState{noseq, gRunning}
    		next = gState{noseq, gWaiting}
    		return
    	case EvGoSched, EvGoPreempt:
    		g = ev.G
    		init = gState{noseq, gRunning}
    		next = gState{noseq, gRunnable}
    		return
    	case EvGoUnblock, EvGoSysExit:
    		g = ev.Args[0]
    		init = gState{ev.Args[1], gWaiting}
    		next = gState{ev.Args[1] + 1, gRunnable}
    		return
    	case EvGoUnblockLocal, EvGoSysExitLocal:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. subprojects/core/src/main/java/org/gradle/internal/work/AsyncWorkTracker.java

         * @throws IllegalStateException when new work is submitted for an operation while another thread is waiting in {@link #waitForCompletion(BuildOperationRef, ProjectLockRetention)} for the same operation.
         */
        void registerWork(BuildOperationRef operation, AsyncWorkCompletion completion);
    
        /**
         * Blocks waiting for the completion of all items of asynchronous work associated with the provided build operation.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 26 11:22:05 UTC 2024
    - 3K bytes
    - Viewed (0)
Back to top