Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for DaemonInfo (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top