- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for DaemonInfo (0.18 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/registry/DaemonInfo.java
*/ public class DaemonInfo implements Serializable, DaemonConnectDetails { private final Address address; private final DaemonContext context; private final byte[] token; private final Clock clock; private State state; private long lastBusy; public DaemonInfo(Address address, DaemonContext context, byte[] token, State state) {
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/NotMostRecentlyUsedDaemonExpirationStrategy.java
private boolean isMostRecentlyUsed(Collection<DaemonInfo> daemonInfos, DaemonContext thisDaemonContext) { String mruUid = null; Date mruTimestamp = new Date(Long.MIN_VALUE); for (DaemonInfo daemonInfo : daemonInfos) { Date daemonAccessTime = daemonInfo.getLastBusy(); if (daemonAccessTime.after(mruTimestamp)) { mruUid = daemonInfo.getUid(); mruTimestamp = daemonAccessTime;
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/main/java/org/gradle/launcher/daemon/client/DefaultDaemonConnector.java
} private Pair<Collection<DaemonInfo>, Collection<DaemonInfo>> partitionByState(final Collection<DaemonInfo> daemons, final DaemonStateControl.State state) { return CollectionUtils.partition(daemons, new Spec<DaemonInfo>() { @Override public boolean isSatisfiedBy(DaemonInfo daemonInfo) { return daemonInfo.getState() == state; } }); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 14.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/DaemonRegistryStateProbe.groovy
this.context = context this.registry = registry } void resetToken() { def daemonInfo = registry.all.find { it.context.pid == context.pid } registry.remove(daemonInfo.address) registry.store(new DaemonInfo(daemonInfo.address, daemonInfo.context, "password".bytes, daemonInfo.getState())) } void assertRegistryNotWorldReadable() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/ReportDaemonStatusClientTest.groovy
0 * _ } def "requests status report from all daemons"() { given: def daemon1 = Stub(DaemonInfo) def daemon2 = Stub(DaemonInfo) when: client.listAll() then: 1 * registry.getAll() >> { [daemon1, daemon2] as List<DaemonInfo> } 1 * connector.maybeConnect(daemon1) >>> connection _ * connection.daemon >> daemon1
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/NotMostRecentlyUsedDaemonExpirationStrategyTest.groovy
!wouldExpire(d1) } def "expires given more than 1 daemon"() { given: DaemonInfo d1 = registerDaemon(Idle) DaemonInfo d2 = registerDaemon(Idle) expect: wouldExpire(d1) !wouldExpire(d2) } boolean wouldExpire(DaemonInfo info) { Daemon daemon = Mock(Daemon) { 1 * getDaemonRegistry() >> { registry }
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/test/groovy/org/gradle/launcher/daemon/registry/EmbeddedDaemonRegistry.java
return daemonInfo.getState() == Idle; } }); @SuppressWarnings("unchecked") private final Spec<DaemonInfo> busySpec = Specs.<DaemonInfo>intersect(allSpec, new Spec<DaemonInfo>() { public boolean isSatisfiedBy(DaemonInfo daemonInfo) { return daemonInfo.getState() != Idle; } }); @SuppressWarnings("unchecked")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 4.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/CompatibleDaemonExpirationStrategyTest.groovy
given: DaemonInfo d1 = registerDaemon(Idle) DaemonInfo d2 = registerDaemon(Idle) when: compatible = [ d1, d2 ] then: wouldExpire(d1) wouldExpire(d2) } def "does not expire when there are no compatible daemons"() { given: DaemonInfo d1 = registerDaemon(Idle) DaemonInfo d2 = registerDaemon(Idle)
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/registry/PersistentDaemonRegistry.java
return daemonInfo.getState() != Idle; } }); } @Override public List<DaemonInfo> getCanceled() { return getDaemonsMatching(new Spec<DaemonInfo>() { @Override public boolean isSatisfiedBy(DaemonInfo daemonInfo) { return daemonInfo.getState() == Canceled; } });
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 8.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/registry/DaemonRegistryContent.java
} return out; } private Map<Address, DaemonInfo> readInfosMap(Decoder decoder, List<Address> addresses) throws Exception { Map<Address, DaemonInfo> infosMap = new LinkedHashMap<Address, DaemonInfo>(addresses.size()); DaemonInfo.Serializer daemonInfoSerializer = new DaemonInfo.Serializer(addresses); for (Address address : addresses) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 8.1K bytes - Viewed (0)