def addressFactory = new InetAddressFactory()
    def communicator = new FileLockCommunicator(new InetAddressProvider() {
        @Override
        InetAddress getWildcardBindingAddress() {
            return addressFactory.wildcardBindingAddress
        }

        @Override
        Iterable<InetAddress> getCommunicationAddresses() {
            return addressFactory.communicationAddresses

            executorFactory,
            new InetAddressProvider() {
                @Override
                public InetAddress getWildcardBindingAddress() {
                    return inetAddressFactory.getWildcardBindingAddress();
                }

                @Override
                public Iterable<InetAddress> getCommunicationAddresses() {

 * limitations under the License.
 */

package org.gradle.cache.internal.locklistener;

import java.net.InetAddress;

public interface InetAddressProvider {
    InetAddress getWildcardBindingAddress();
    Iterable<InetAddress> getCommunicationAddresses();

    def addressFactory = new InetAddressFactory()
    def addressProvider = new InetAddressProvider() {
        @Override
        InetAddress getWildcardBindingAddress() {
            return addressFactory.wildcardBindingAddress
        }

        @Override
        Iterable<InetAddress> getCommunicationAddresses() {
            return addressFactory.communicationAddresses

class DefaultFileLockContentionHandlerTest extends ConcurrentSpecification {
    def addressFactory = new InetAddressFactory()
    def addressProvider = new InetAddressProvider() {
        @Override
        InetAddress getWildcardBindingAddress() {
            return addressFactory.wildcardBindingAddress
        }

        @Override
        Iterable<InetAddress> getCommunicationAddresses() {
            return addressFactory.communicationAddresses

            }
        } catch (Exception e) {
            throw new RuntimeException("Could not determine a usable local IP for this machine.", e);
        }
    }

    public InetAddress getWildcardBindingAddress() {
        try {
            synchronized (lock) {
                init();
                return wildcardBindingAddress;
            }
        } catch (Exception e) {

    public FileLockCommunicator(InetAddressProvider inetAddressProvider) {
        this.inetAddressProvider = inetAddressProvider;
        try {
            socket = new DatagramSocket(0, inetAddressProvider.getWildcardBindingAddress());
        } catch (SocketException e) {
            throw throwAsUncheckedException(e);
        }
    }

    public boolean pingOwner(int ownerPort, long lockId, String displayName) {

        return new DefaultFileLockContentionHandler(executorFactory, new InetAddressProvider() {
            @Override
            public InetAddress getWildcardBindingAddress() {
                return new InetSocketAddress(0).getAddress();
            }

            @Override
            public Iterable<InetAddress> getCommunicationAddresses() {
                try {

        receivingFileLockContentionHandler = new DefaultFileLockContentionHandler(new DefaultExecutorFactory(), new InetAddressProvider() {
            @Override
            InetAddress getWildcardBindingAddress() {
                return addressFactory.wildcardBindingAddress
            }

            @Override
            Iterable<InetAddress> getCommunicationAddresses() {