import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;

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;

    def "encodes lock id and type"() {
        when:
        def bytes = FileLockPacketPayload.encode(42, LOCK_RELEASE_CONFIRMATION)

        then:
        bytes.length == FileLockPacketPayload.MAX_BYTES
        bytes == [1, 0, 0, 0, 0, 0, 0, 0, 42, 3] as byte[]
    }

    def "decodes payloads without type"() {
        when:
        def payload = FileLockPacketPayload.decode([1, 0, 0, 0, 0, 0, 0, 0, 42, 1] as byte[], 9)

        then:

            }
            throw new GracefullyStoppedException();
        }
    }

    public FileLockPacketPayload decode(DatagramPacket receivedPacket) {
        try {
            return FileLockPacketPayload.decode(receivedPacket.getData(), receivedPacket.getLength());
        } catch (IOException e) {
            if (!stopped) {
                throw new RuntimeException(e);
            }

    def "does not know port after stopping"() {
        when:
        communicator.stop()

        then:
        communicator.getPort() == -1
    }

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

        start {
            def packet = communicator.receive()
            receivedPayload = communicator.decode(packet)
        }

        poll {

                }
            }

            private void doRun() {
                while (true) {
                    DatagramPacket packet;
                    FileLockPacketPayload payload;
                    try {
                        packet = communicator.receive();
                        payload = communicator.decode(packet);
                    } catch (GracefullyStoppedException e) {

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