* See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.cache.internal.locklistener;

import java.net.InetAddress;

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

    private final DatagramSocket socket;
    private final InetAddressProvider inetAddressProvider;
    private volatile boolean stopped;

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

    private final InetAddressProvider inetAddressProvider;

    private FileLockCommunicator communicator;
    private ManagedExecutor fileLockRequestListener;
    private ManagedExecutor unlockActionExecutor;
    private boolean stopped;

    public DefaultFileLockContentionHandler(ExecutorFactory executorFactory, InetAddressProvider inetAddressProvider) {
        this.executorFactory = executorFactory;

import org.gradle.cache.internal.locklistener.DefaultFileLockContentionHandler;
import org.gradle.cache.internal.locklistener.FileLockContentionHandler;
import org.gradle.cache.internal.locklistener.InetAddressProvider;
import org.gradle.internal.Factory;
import org.gradle.internal.concurrent.DefaultExecutorFactory;
import org.gradle.internal.concurrent.ExecutorFactory;
import org.gradle.internal.event.DefaultListenerManager;

import org.gradle.cache.internal.locklistener.DefaultFileLockContentionHandler
import org.gradle.cache.internal.locklistener.FileLockContentionHandler
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

class FileLockCommunicatorTest extends ConcurrentSpecification {

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

        @Override

import org.gradle.cache.internal.locklistener.DefaultFileLockContentionHandler
import org.gradle.cache.internal.locklistener.FileLockContentionHandler
import org.gradle.cache.internal.locklistener.InetAddressProvider
import org.gradle.integtests.fixtures.AbstractIntegrationSpec
import org.gradle.integtests.fixtures.executer.GradleHandle
import org.gradle.internal.concurrent.DefaultExecutorFactory

import org.gradle.cache.internal.locklistener.DefaultFileLockContentionHandler;
import org.gradle.cache.internal.locklistener.FileLockContentionHandler;
import org.gradle.cache.internal.locklistener.InetAddressProvider;
import org.gradle.caching.internal.controller.BuildCacheController;
import org.gradle.caching.internal.controller.DefaultBuildCacheController;

import static org.gradle.test.fixtures.ConcurrentTestUtil.poll

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

        @Override

Class <org.gradle.cache.internal.locklistener.InetAddressProvider> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (InetAddressProvider.java:0)