Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,219 for rerunning (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top