- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 472 for STOPPED (0.16 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonTcpServerConnector.java
lifecycleLock.lock(); try { if (stopped) { throw new IllegalStateException("server connector cannot be started as it is either stopping or has been stopped"); } if (started) { throw new IllegalStateException("server connector cannot be started as it has already been started");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonLifecycleSpec.groovy
when: startBuild() then: busy() when: completeBuild() then: idle() and: stopped() } //Java 9 and above needs --add-opens to make environment variable mutation work @Requires(UnitTestPreconditions.Jdk8OrEarlier) def "existing foreground idle daemons are used"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 6.8K bytes - Viewed (0) -
pkg/test/framework/components/echo/util/traffic/generator.go
fillInDefaults(&cfg) return &generator{ Config: cfg, t: t, stop: make(chan struct{}), stopped: make(chan struct{}), } } var _ Generator = &generator{} type generator struct { Config t test.Failer result Result stop chan struct{} stopped chan struct{} } func (g *generator) Start() Generator { go func() { t := time.NewTimer(g.Interval) for {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 12 22:50:35 UTC 2022 - 3.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) -
cluster/images/etcd/migrate/migrate_server.go
return } }() err = r.cmd.Wait() close(stopped) if exiterr, ok := err.(*exec.ExitError); ok { klog.Infof("etcd server stopped (signal: %s)", exiterr.Error()) // stopped } else if err != nil { return fmt.Errorf("error waiting for etcd to stop: %v", err) } klog.Infof("Stopped etcd server %s", r.cfg.name) return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 30 16:29:59 UTC 2022 - 3.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/LazyConsumerActionExecutor.java
} } @Override public void disconnect() { lock.lock(); try { if (stopped || connection == null) { return; } requestCancellation(); sendStopWhenIdleMessageToDaemons(); } finally { stopped = true; lock.unlock(); } } private void requestCancellation() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6.7K 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) -
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/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonStoppedException.java
* limitations under the License. */ package org.gradle.launcher.daemon.server.api; /** * Thrown when the daemon is stopped while running a command. */ public class DaemonStoppedException extends RuntimeException { public static final String MESSAGE = "Gradle build daemon has been stopped"; public DaemonStoppedException() { super(MESSAGE); } public DaemonStoppedException(String reason) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1K bytes - Viewed (0)