private static final byte[] TEST_KEY = "testkey".getBytes();
    private static final byte[] LONG_TEST_KEY = new byte[80]; // Longer than 64 bytes
    private static final byte[] SHORT_TEST_KEY = "short".getBytes();
    private static final byte[] TEST_DATA = "testdata".getBytes();
    private static final byte[] EMPTY_DATA = new byte[0];

    static {
        // Initialize long key with predictable data

    void testRoundTripFull() throws IOException {
        // Arrange – create a fully populated token
        ASN1ObjectIdentifier mech = new ASN1ObjectIdentifier("1.2.840.113554.1.2.2");
        byte[] tokenArray = new byte[] { 1, 2, 3 };
        byte[] mic = new byte[] { 9, 9, 9 };
        NegTokenTarg original = new NegTokenTarg(NegTokenTarg.ACCEPT_COMPLETED, mech, tokenArray, mic);

        // Act – serialise and parse back

                                    inputStream.reset();
                                    br = new BufferedReader(new InputStreamReader(inputStream, enc));
                                } else {
                                    br = new BufferedReader(new InputStreamReader(new FileInputStream(tempFile), enc));
                                }
                                String line;

                    } else if (Method.HEAD.toString().equalsIgnoreCase(con.getRequestMethod())) {
                        return new ByteArrayInputStream(new byte[0]);
                    } else {
                        if (GZIP.equals(con.getContentEncoding())) {
                            return new GZIPInputStream(con.getErrorStream());
                        } else {
                            return con.getErrorStream();

        } catch (final UnknownHostException uhe) {}

        snd_buf = new byte[SND_BUF_SIZE];
        rcv_buf = new byte[RCV_BUF_SIZE];
        out = new DatagramPacket(snd_buf, SND_BUF_SIZE, baddr, NAME_SERVICE_UDP_PORT);
        in = new DatagramPacket(rcv_buf, RCV_BUF_SIZE);

        if (RO == null || RO.length() == 0) {

    void testMultipleInstances() {
        // Arrange
        TransPeekNamedPipeResponse response1 = new TransPeekNamedPipeResponse(mockConfig);
        TransPeekNamedPipeResponse response2 = new TransPeekNamedPipeResponse(mockConfig);

        // Act
        byte[] buffer = new byte[10];
        SMBUtil.writeInt2(100, buffer, 0);
        SMBUtil.writeInt2(0, buffer, 2);

        java.io.ByteArrayOutputStream baos = new java.io.ByteArrayOutputStream();
        java.io.ObjectOutputStream oos = new java.io.ObjectOutputStream(baos);
        oos.writeObject(exception);
        oos.close();

        // And deserialize
        java.io.ByteArrayInputStream bais = new java.io.ByteArrayInputStream(baos.toByteArray());
        java.io.ObjectInputStream ois = new java.io.ObjectInputStream(bais);

            // IbvSendWR sendWR = new IbvSendWR();
            // sendWR.setWr_id(System.nanoTime());
            // sendWR.setOpcode(IbvSendWR.IbvWrOpcode.IBV_WR_SEND.ordinal());
            // sendWR.setSend_flags(IbvSendWR.IBV_SEND_SIGNALED);
            //
            // LinkedList<IbvSge> sgeList = new LinkedList<>();
            // IbvSge sge = new IbvSge();
            // sge.setAddr(disniRegion.getAddress());

            int threadCount = 10;
            Thread[] threads = new Thread[threadCount];
            boolean[] success = new boolean[threadCount];

            for (int i = 0; i < threadCount; i++) {
                final int index = i;
                threads[i] = new Thread(() -> {
                    try {
                        Smb2EchoRequest req = new Smb2EchoRequest(mockConfig);

        byte[] buffer = new byte[4];
        pdis.readFully(buffer);
        assertArrayEquals(data, buffer);
    }

    @Test
    public void testReadFullyWithOffset() throws IOException {
        byte[] data = new byte[] { 0x01, 0x02, 0x03, 0x04 };
        PacDataInputStream pdis = createInputStream(data);
        byte[] buffer = new byte[6];
        pdis.readFully(buffer, 1, 4);