Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for getDaemonRegistry (0.35 sec)

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