- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 297 for stopped_ (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
defer timer.Stop() for { stopped := func() bool { pr.mux.Lock() defer pr.mux.Unlock() for pr.waiting == 0 && !pr.stopped { pr.cond.Wait() } return pr.stopped }() if stopped { return } select { case <-timer.C(): shouldRequest := func() bool { pr.mux.Lock() defer pr.mux.Unlock() return pr.waiting > 0 && !pr.stopped }() if !shouldRequest {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStopState.java
package org.gradle.launcher.daemon.server; /** * Indicates the state of the daemon when it stops doing work. */ public enum DaemonStopState { /** * Daemon was stopped cleanly and all work stopped. */ Clean, /** * Daemon could not be stopped cleanly and some work may still be running. */ Forced
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:45:11 UTC 2024 - 953 bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockCommunicator.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 5.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/DefaultDeploymentRegistry.java
} finally { LOGGER.debug("Stopped deployment handles"); stopped = true; deployments.clear(); lock.unlock(); } pendingChangesManager.removeListener(this); } private void failIfStopped() { if (stopped) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 6.9K 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) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ExecutorFactory.java
* Creates an executor which can run multiple actions concurrently. It is the caller's responsibility to stop the executor. * * The executor will collect failures thrown by actions and rethrow when the executor is stopped. * * @param displayName The display name for the this executor. Used for thread names, logging and error message. * @return The executor. */ ManagedExecutor create(String displayName); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 3.4K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/deployment/internal/DefaultDeploymentRegistryTest.groovy
then: def e = thrown(IllegalStateException) e.message == "Cannot modify deployment handles once the registry has been stopped." } def "cannot register a handle once the registry is stopped" () { given: registry.stop() when: registry.start("id", DeploymentRegistry.ChangeBehavior.NONE, TestDeploymentHandle) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 4.6K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
return f.proxy } func (f *fakeConn) ConnectedAt() time.Time { return f.connTime } func (f *fakeConn) Stop() { f.Lock() defer f.Unlock() f.stopped = true } func (f *fakeConn) Stopped() bool { f.RLock() defer f.RUnlock() return f.stopped } var ( tmplA = &v1alpha3.WorkloadGroup{ Template: &v1alpha3.WorkloadEntry{ Ports: map[string]uint32{"http": 80},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K 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) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/AbstractDaemonFixture.groovy
this } DaemonFixture stops() { waitForState(Stopped) this } @Override void assertIdle() { assertHasState(Idle) } @Override void assertBusy() { assertHasState(Busy) } @Override void assertStopped() { assertHasState(Stopped) } @Override void assertCanceled() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 3.8K bytes - Viewed (0)