- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 155 for STOPPED (0.15 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/DaemonConnectionBackedEventConsumer.java
} private boolean moreMessagesToSend() { return ableToSend && !(stopped && queue.isEmpty()); } private Object getNextEvent() { try { return queue.poll(10, TimeUnit.MILLISECONDS); } catch (InterruptedException e) { stopped = true; return null; } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/timeout/impl/DefaultTimeoutHandler.java
} } private void onAfterTimeoutCheck() { synchronized (lock) { if (!stopped) { slowStop = true; doAsPartOfBuildOperation(() -> { LOGGER.warn("Timed out {} has not yet stopped.", workUnitDescription.getDisplayName()); if (logStacktraceTimer.hasExpired()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 7.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonStartupMessageTest.groovy
0 | 1 | 0 | ["1 incompatible"] 1 | 0 | 0 | ["1 busy"] 0 | 0 | 1 | ["1 stopped"] 1 | 2 | 4 | ["1 busy", "2 incompatible", "4 stopped"] } def "starting message contains subsequent builds message given no unavailable daemons"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2K 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) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonStopClient.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0) -
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) -
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)