- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 196 for STOPPED (0.11 sec)
-
platforms/core-runtime/concurrent/src/test/groovy/org/gradle/internal/concurrent/DefaultExecutorFactoryTest.groovy
executor.execute(action1) executor.execute(action2) executor.stop() instant.stopped } then: instant.stopped > instant.completed1 instant.stopped > instant.completed2 } def factoryStopBlocksUntilAllJobsAreComplete() { given: def action1 = { thread.block()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 11.2K bytes - Viewed (0) -
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) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonStateCoordinatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 16.3K bytes - Viewed (0) -
src/runtime/lockrank_on.go
// //go:nosplit func worldStarted() { if stopped := worldIsStopped.Add(-1); stopped != 0 { systemstack(func() { print("world stop count=", stopped, "\n") throw("released non-stopped world stop") }) } } // nosplit to ensure it can be called in as many contexts as possible. // //go:nosplit func checkWorldStopped() bool { stopped := worldIsStopped.Load() if stopped > 1 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 10.6K 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) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/TaskTimeoutIntegrationTest.groovy
outputLines[1] == "Timed out task ':block' has not yet stopped." outputLines[outputLines.size() - 1] == "Timed out task ':block' has stopped." and: def logging = taskLogging(":block") logging[0] == "Requesting stop of task ':block' as it has exceeded its configured timeout of 500ms." logging[1] == "Timed out task ':block' has not yet stopped."
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 12.6K 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/syscall/syscall_bsd.go
} func (w WaitStatus) Signaled() bool { return w&mask != stopped && w&mask != 0 } func (w WaitStatus) Signal() Signal { sig := Signal(w & mask) if sig == stopped || sig == 0 { return -1 } return sig } func (w WaitStatus) CoreDump() bool { return w.Signaled() && w&core != 0 } func (w WaitStatus) Stopped() bool { return w&mask == stopped && Signal(w>>shift) != SIGSTOP }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 07 10:34:48 UTC 2023 - 13.6K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
// Stop any running monitors. qm.monitorLock.Lock() defer qm.monitorLock.Unlock() monitors := qm.monitors stopped := 0 for _, monitor := range monitors { if monitor.stopCh != nil { stopped++ close(monitor.stopCh) } } logger.Info("QuotaMonitor stopped monitors", "stopped", stopped, "total", len(monitors)) } func (qm *QuotaMonitor) runProcessResourceChanges(ctx context.Context) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0)