Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for InetAddressFactory (0.3 sec)

  1. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/InetAddressFactory.java

    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * Provides information on how two processes on this machine can communicate via IP addresses
     */
    @ServiceScope(Scope.Global.class)
    public class InetAddressFactory {
        private final Logger logger = LoggerFactory.getLogger(getClass());
        private final Object lock = new Object();
        private List<InetAddress> communicationAddresses;
        private InetAddress localBindingAddress;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 17 00:47:05 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. subprojects/core/src/main/java/org/gradle/internal/service/scopes/BasicGlobalScopeServices.java

            return new DefaultFileLockContentionHandler(
                executorFactory,
                new InetAddressProvider() {
                    @Override
                    public InetAddress getWildcardBindingAddress() {
                        return inetAddressFactory.getWildcardBindingAddress();
                    }
    
                    @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/services/MessagingServices.java

        @Provides
        protected InetAddressFactory createInetAddressFactory() {
            return new InetAddressFactory();
        }
    
        @Provides
        protected OutgoingConnector createOutgoingConnector() {
            return new TcpOutgoingConnector();
        }
    
        @Provides
        protected IncomingConnector createIncomingConnector(ExecutorFactory executorFactory, InetAddressFactory inetAddressFactory) {
            return new TcpIncomingConnector(
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  4. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonTcpServerConnector.java

        private ConnectionAcceptor acceptor;
    
        public DaemonTcpServerConnector(ExecutorFactory executorFactory, InetAddressFactory inetAddressFactory, Serializer<Message> serializer) {
            this.serializer = serializer;
            this.incomingConnector = new TcpIncomingConnector(
                    executorFactory,
                    inetAddressFactory,
                    new UUIDGenerator()
            );
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  5. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockCommunicatorTest.groovy

    
    package org.gradle.cache.internal.locklistener
    
    import org.gradle.internal.remote.internal.inet.InetAddressFactory
    import org.gradle.util.ConcurrentSpecification
    
    import static org.gradle.test.fixtures.ConcurrentTestUtil.poll
    
    class FileLockCommunicatorTest extends ConcurrentSpecification {
    
        def addressFactory = new InetAddressFactory()
        def communicator = new FileLockCommunicator(new InetAddressProvider() {
            @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:49 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonServices.java

            ExecutorFactory executorFactory,
            InetAddressFactory inetAddressFactory,
            DaemonRegistry daemonRegistry,
            DaemonContext daemonContext,
            ListenerManager listenerManager
        ) {
            return new Daemon(
                new DaemonTcpServerConnector(
                    executorFactory,
                    inetAddressFactory,
                    DaemonMessageSerializer.create(buildActionSerializer)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  7. platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/inet/InetAddressFactoryTest.groovy

     * limitations under the License.
     */
    
    package org.gradle.internal.remote.internal.inet
    
    import spock.lang.Specification
    
    class InetAddressFactoryTest extends Specification {
    
        def factory = new InetAddressFactory()
        InetAddresses addresses = Mock()
    
        def setup() {
            factory.inetAddresses = addresses
        }
    
        def "Loopback addresses are preferred"() {
            when:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:59:22 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  8. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/TcpIncomingConnector.java

        private final ExecutorFactory executorFactory;
        private final InetAddressFactory addressFactory;
        private final IdGenerator<UUID> idGenerator;
    
        public TcpIncomingConnector(ExecutorFactory executorFactory, InetAddressFactory addressFactory, IdGenerator<UUID> idGenerator) {
            this.executorFactory = executorFactory;
            this.addressFactory = addressFactory;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Oct 05 19:36:14 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  9. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionTest.groovy

    import org.gradle.cache.internal.locklistener.InetAddressProvider
    import org.gradle.internal.concurrent.CompositeStoppable
    import org.gradle.internal.remote.internal.inet.InetAddressFactory
    import org.gradle.test.fixtures.concurrent.ConcurrentSpec
    import org.gradle.test.fixtures.file.TestNameTestDirectoryProvider
    import org.junit.Rule
    
    import java.util.function.Consumer
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  10. platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonInitialCommunicationFailureIntegrationSpec.groovy

     * limitations under the License.
     */
    
    package org.gradle.launcher.daemon
    
    
    import org.gradle.integtests.fixtures.daemon.DaemonIntegrationSpec
    import org.gradle.internal.remote.internal.inet.InetAddressFactory
    import org.gradle.launcher.daemon.logging.DaemonMessages
    import org.gradle.test.fixtures.Flaky
    import org.gradle.test.precondition.Requires
    import org.gradle.test.preconditions.IntegTestPreconditions
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 16 07:46:29 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top