Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 98 for _Gwaiting (0.43 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.PodStatusResult.json

        "podIPs": [
          {
            "ip": "ipValue"
          }
        ],
        "startTime": "2007-01-01T01:01:01Z",
        "initContainerStatuses": [
          {
            "name": "nameValue",
            "state": {
              "waiting": {
                "reason": "reasonValue",
                "message": "messageValue"
              },
              "running": {
                "startedAt": "2001-01-01T01:01:01Z"
              },
              "terminated": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/testdata/v1.30.0/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: Thu Apr 18 08:52:25 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  10. src/cmd/go/internal/par/work.go

    // and all the runners are waiting for work.
    // (Then all the runners return.)
    func (w *Work[T]) runner() {
    	for {
    		// Wait for something to do.
    		w.mu.Lock()
    		for len(w.todo) == 0 {
    			w.waiting++
    			if w.waiting == w.running {
    				// All done.
    				w.wait.Broadcast()
    				w.mu.Unlock()
    				return
    			}
    			w.wait.Wait()
    			w.waiting--
    		}
    
    		// Pick something to do at random,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 15:54:54 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top