- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for getDaemonRegistry (0.35 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/NotMostRecentlyUsedDaemonExpirationStrategy.java
NotMostRecentlyUsedDaemonExpirationStrategy(Daemon daemon) { this.daemon = daemon; } @Override public DaemonExpirationResult checkExpiration() { if (!isMostRecentlyUsed(daemon.getDaemonRegistry().getIdle(), daemon.getDaemonContext())) { return new DaemonExpirationResult(DaemonExpirationStatus.GRACEFUL_EXPIRE, EXPIRATION_REASON); } return DaemonExpirationResult.NOT_TRIGGERED; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/NotMostRecentlyUsedDaemonExpirationStrategyTest.groovy
expect: wouldExpire(d1) !wouldExpire(d2) } boolean wouldExpire(DaemonInfo info) { Daemon daemon = Mock(Daemon) { 1 * getDaemonRegistry() >> { registry } _ * getDaemonContext() >> { info.getContext() } } return new NotMostRecentlyUsedDaemonExpirationStrategy(daemon).checkExpiration().status == DaemonExpirationStatus.GRACEFUL_EXPIRE
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/CompatibleDaemonExpirationStrategy.java
return compatibilitySpec.isSatisfiedBy(daemonInfo.getContext()); } }; Collection<DaemonInfo> compatibleIdleDaemons = CollectionUtils.filter(daemon.getDaemonRegistry().getIdle(), spec); if (compatibleIdleDaemons.size() > 1) { return new DaemonExpirationResult(DaemonExpirationStatus.GRACEFUL_EXPIRE, EXPIRATION_REASON); } else {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 18:27:45 UTC 2024 - 2.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/CompatibleDaemonExpirationStrategyTest.groovy
compatible = [ d1 ] then: !wouldExpire(d1) } boolean wouldExpire(DaemonInfo info, Boolean timeoutReached = true) { Daemon daemon = Mock(Daemon) { 1 * getDaemonRegistry() >> { registry } _ * getDaemonContext() >> { info.getContext() } _ * getStateCoordinator() >> Stub(DaemonStateCoordinator) { getState() >> info.state
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/main/java/org/gradle/launcher/daemon/server/DaemonRegistryUnavailableExpirationStrategy.java
} else { // Check that given daemon still exists in registry - a daemon registry could be removed and recreated between checks List<Long> allDaemonPids = Lists.transform(daemon.getDaemonRegistry().getAll(), new Function<DaemonInfo, Long>() { @Override public Long apply(DaemonInfo info) { return info.getPid(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonRegistryUnavailableExpirationStrategyTest.groovy
registry.store(new DaemonInfo(address, daemonContext, "password".bytes, Idle)) when: 1 * daemon.getDaemonContext() >> { daemonContext } 1 * daemon.getDaemonRegistry() >> { registry } then: DaemonExpirationResult expirationCheck = expirationStrategy.checkExpiration() expirationCheck.status == DO_NOT_EXPIRE expirationCheck.reason == null }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 00:09:57 UTC 2024 - 3.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DefaultDaemonConnector.java
this.connectTimeout = connectTimeout; } public long getConnectTimeout() { return connectTimeout; } public DaemonRegistry getDaemonRegistry() { return daemonRegistry; } @Override public DaemonClientConnection maybeConnect(ExplainingSpec<DaemonContext> constraint) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 14.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java
} public Address getAddress() { return connectorAddress; } public DaemonContext getDaemonContext() { return daemonContext; } public DaemonRegistry getDaemonRegistry() { return this.daemonRegistry; } /** * Starts the daemon, receiving connections asynchronously (i.e. returns immediately). *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 12.9K bytes - Viewed (0)