*/

package org.gradle.cache.internal.locklistener;

/**
 * Packet type for communication about file locks.
 *
 * <p>For backward compatibility, enum constants must not be removed.
 */
public enum FileLockPacketType {
    UNKNOWN,
    UNLOCK_REQUEST,
    UNLOCK_REQUEST_CONFIRMATION,
    LOCK_RELEASE_CONFIRMATION

import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNKNOWN;

public class FileLockPacketPayload {

    public static final int MAX_BYTES = 1 + 8 + 1; // protocolVersion + lockId + type
    private static final byte PROTOCOL_VERSION = 1;
    private static final ImmutableList<FileLockPacketType> TYPES = ImmutableList.copyOf(FileLockPacketType.values());

    private final long lockId;

 */

package org.gradle.cache.internal.locklistener

import spock.lang.Specification

import static org.gradle.cache.internal.locklistener.FileLockPacketType.LOCK_RELEASE_CONFIRMATION
import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNKNOWN

class FileLockPacketPayloadTest extends Specification {

    def "encodes lock id and type"() {
        when:

import java.net.SocketException;
import java.util.Set;

import static org.gradle.cache.internal.locklistener.FileLockPacketType.LOCK_RELEASE_CONFIRMATION;
import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNLOCK_REQUEST;
import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNLOCK_REQUEST_CONFIRMATION;
import static org.gradle.internal.UncheckedException.throwAsUncheckedException;

        when:
        communicator.pingOwner(communicator.getPort(), 155, "lock")

        then:
        poll {
            assert receivedPayload.lockId == 155
            assert receivedPayload.type == FileLockPacketType.UNLOCK_REQUEST
        }
    }

    def "can receive lock id despite missing type"() {
        FileLockPacketPayload receivedPayload

        start {
            def packet = communicator.receive()

import java.util.Map;
import java.util.Set;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.function.Consumer;

import static org.gradle.cache.internal.locklistener.FileLockPacketType.LOCK_RELEASE_CONFIRMATION;

/**
 * The contention handler is responsible for negotiating the transfer of a lock from one process to another.

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