- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 186 for stopped_ (0.18 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/internal/DefaultActorFactory.java
synchronized (lock) { stopped = true; } stopped(this); } @Override public void dispatch(MethodInvocation message) { synchronized (lock) { if (stopped) { throw new IllegalStateException("This actor has been stopped."); } dispatch.dispatch(message);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/ServiceLifecycleTest.groovy
then: noExceptionThrown() } def "throws exception when attempting to use service after it has stopped"() { when: lifecycle.stop() lifecycle.use { } then: IllegalStateException e = thrown() e.message == 'Cannot use [service] as it has been stopped.' } def "throws exception when attempting to use service after stop has been requested"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 6.2K 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) -
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/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-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/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-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)