- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,219 for rerunning (0.24 sec)
-
src/runtime/tracestatus.go
switch pp.status { case _Pidle, _Pgcstop: status = traceProcIdle if pp.status == _Pgcstop && inSTW { // N.B. a P that is running and currently has the world stopped will be // in _Pgcstop, but we model it as running in the tracer. status = traceProcRunning } case _Prunning: status = traceProcRunning // There's a short window wherein the goroutine may have entered _Gsyscall
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 7.2K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.h
/// IsRunning function. class RunnerInterface { public: virtual ~RunnerInterface() {} virtual Status Join() = 0; virtual Status ExportCostGraph(CostGraphDef* cost_graph) const { return Status(absl::StatusCode::kInvalidArgument, "No cost model to export."); } /// Returns true iff the runner is running, i.e. if it is trying to populate /// its queue.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 12 08:49:52 UTC 2023 - 4.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
val idleCallback: Runnable? this.withLock { if (!calls.remove(call)) throw AssertionError("Call wasn't in-flight!") idleCallback = this.idleCallback } val isRunning = promoteAndExecute() if (!isRunning && idleCallback != null) { idleCallback.run() } } /** Returns a snapshot of the calls currently awaiting execution. */ fun queuedCalls(): List<Call> =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 9K bytes - Viewed (0) -
src/cmd/trace/viewer.go
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: panic(fmt.Sprintf("unknown GoState: %s", state.String())) }
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
GoUndetermined GoState = iota // No information is known about the goroutine. 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. )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 8K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-task-across-generations.go
) func main() { testgen.Main(gen) } func gen(t *testgen.Trace) { g1 := t.Generation(1) // A running goroutine emits a task begin. b1 := g1.Batch(trace.ThreadID(0), 0) b1.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning) b1.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning) b1.Event("UserTaskBegin", trace.TaskID(2), trace.TaskID(0) /* 0 means no parent, not background */, "my task", testgen.NoStack)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.3K bytes - Viewed (0) -
pkg/proxy/util/nfacct/nfacct.go
// Interface is an injectable interface for running nfacct commands. type Interface interface { // Ensure checks the existence of a nfacct counter with the provided name and creates it if absent. Ensure(name string) error // Add creates a nfacct counter with the given name, returning an error if it already exists. Add(name string) error // Get retrieves the nfacct counter with the specified name, returning an error if it doesn't exist.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 06:47:50 UTC 2024 - 1.2K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-ambiguous.go
b0.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning) b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning) b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack) b0.Event("GoSyscallEnd") b0.Event("GoSyscallBegin", testgen.Seq(2), testgen.NoStack) b0.Event("GoSyscallEndBlocked") // A running goroutine steals proc 0. b1 := g.Batch(trace.ThreadID(1), 0) b1.Event("ProcStatus", trace.ProcID(2), go122.ProcRunning)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime.go
} runtime.imageService = imageService return nil } // IsRunning checks if runtime is running. func (runtime *CRIRuntime) IsRunning() error { ctx, cancel := defaultContext() defer cancel() res, err := runtime.impl.Status(ctx, runtime.runtimeService, false) if err != nil { return errors.Wrap(err, "container runtime is not running") } for _, condition := range res.GetStatus().GetConditions() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Stopwatch.java
*/ public boolean isRunning() { return isRunning; } /** * Starts the stopwatch. * * @return this {@code Stopwatch} instance * @throws IllegalStateException if the stopwatch is already running. */ @CanIgnoreReturnValue public Stopwatch start() { checkState(!isRunning, "This stopwatch is already running."); isRunning = true; startTick = ticker.read();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Nov 15 21:38:09 UTC 2022 - 8.5K bytes - Viewed (0)