- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for STOPPED (0.09 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
// to be retried. if !i.stopped && i.store.hasSynced() && now.After(i.lastAccessTime.Add(maxIdleTime)) { return i.stopThreadUnsafe() } return false } func (i *objectCacheItem) restartReflectorIfNeeded() { i.lock.Lock() defer i.lock.Unlock() if i.immutable || !i.stopped { return } i.stopCh = make(chan struct{}) i.stopped = false go i.startReflector() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
src/runtime/preempt.go
// state was observed, so the caller must not assume that it // remains dead. dead bool // stopped indicates that this suspendG transitioned the G to // _Gwaiting via g.preemptStop and thus is responsible for // readying it when done. stopped bool } // suspendG suspends goroutine gp at a safe-point and returns the // state of the suspended goroutine. The caller gets read access to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/worker/TestWorker.java
state = State.STOPPED; // Clean the interrupted status // because some test class processors do work here, e.g. JUnitPlatform Thread.interrupted(); } } }); } private synchronized void submitToRun(Runnable command) { if (state != State.STOPPED) { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 10K bytes - Viewed (0) -
src/time/tick_test.go
// to have the same signatures as Timer. type tickerTimer struct { *Ticker stopped bool } func (t *tickerTimer) Stop() bool { pending := !t.stopped t.stopped = true t.Ticker.Stop() return pending } func (t *tickerTimer) Reset(d Duration) bool { pending := !t.stopped t.stopped = false t.Ticker.Reset(d) return pending }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonClientsManager.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:54:37 UTC 2024 - 10K bytes - Viewed (0) -
src/cmd/trace/gstate.go
} } // block indicates that the goroutine has stopped executing on a proc -- specifically, // it blocked for some reason. func (gs *gState[R]) block(ts trace.Time, stack trace.Stack, reason string, ctx *traceContext) { gs.startBlockReason = reason gs.stop(ts, stack, ctx) } // stop indicates that the goroutine has stopped executing on a proc.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
return count == 2, nil }); err != nil { t.Fatalf("expected forget() to be called twice, first call from w.add() and then from w.Stop() called from w.processInterval(): %v", err) } if !w.stopped { t.Fatal("expected the watcher to be stopped but it wasn't") } } // TestCacheWatcherDrainingNoBookmarkAfterResourceVersionSent checks if the watcher's input
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java
} /** * Starts the daemon, receiving connections asynchronously (i.e. returns immediately). * * @throws IllegalStateException if this daemon is already running, or has already been stopped. */ public void start() { LOGGER.info("start() called on daemon - {}", daemonContext); lifecycleLock.lock(); try { if (stateCoordinator != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 12.9K bytes - Viewed (0) -
platforms/core-runtime/daemon-server/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonMain.java
import java.util.List; /** * The entry point for a daemon process. * * If the daemon hits the specified idle timeout the process will exit with 0. If the daemon encounters an internal error or is explicitly stopped (which can be via receiving a stop command, or * unexpected client disconnection) the process will exit with 1. */ public class DaemonMain extends EntryPoint {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.8K bytes - Viewed (0)