- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 514 for stopped_ (0.46 sec)
-
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) -
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) -
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) -
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) -
staging/src/k8s.io/apimachinery/pkg/watch/mux_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:25 UTC 2022 - 8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/DefaultGradleConnector.java
private final DistributionFactory distributionFactory; private Distribution distribution; private final List<DefaultProjectConnection> connections = new ArrayList<DefaultProjectConnection>(4); private boolean stopped = false; private final DefaultConnectionParameters.Builder connectionParamsBuilder = DefaultConnectionParameters.builder();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6.8K bytes - Viewed (0)