- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 98 for _Gwaiting (0.43 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)