byte[] responseBuffer = negotiation.getResponseRaw();

        // Modify the buffers
        requestBuffer[0] = (byte) 0xFF;
        responseBuffer[0] = (byte) 0xEE;

        // Verify modifications are reflected
        assertEquals((byte) 0xFF, negotiation.getRequestRaw()[0]);
        assertEquals((byte) 0xEE, negotiation.getResponseRaw()[0]);
    }

    @Test

        assertEquals(60000L, context.getMaxCacheAge());

        context.setNotificationEnabled(false);
        assertFalse(context.isNotificationEnabled());

        context.setNotificationFilter(0xFF);
        assertEquals(0xFF, context.getNotificationFilter());
    }

    @Test
    public void testSize() {
        Smb2LeaseKey key = new Smb2LeaseKey();

        byte[] buffer = new byte[100];
        int bufferIndex = 50;

        // Set test values
        int testCapabilities = 0xABCDEF00;
        byte[] testGuid = new byte[16];
        Arrays.fill(testGuid, (byte) 0xFF);
        int testSecurityMode = 0x0001;
        int testDialect = 0x0202;

        // Write to buffer
        SMBUtil.writeInt4(testCapabilities, buffer, bufferIndex);

    byte[] quad = textToNumericFormatV4(dottedQuad);
    if (quad == null) {
      return null;
    }
    String penultimate = Integer.toHexString(((quad[0] & 0xff) << 8) | (quad[1] & 0xff));
    String ultimate = Integer.toHexString(((quad[2] & 0xff) << 8) | (quad[3] & 0xff));
    return initialPart + penultimate + ":" + ultimate;
  }

  private static byte parseOctet(String ipString, int start, int end) {

            }
            switch (sbuf[0] & 0xFF) {
            case SessionServicePacket.POSITIVE_SESSION_RESPONSE:
                if (LogStream.level >= 4) {
                    log.println("session established ok with " + address);
                }
                return;
            case SessionServicePacket.NEGATIVE_SESSION_RESPONSE:
                final int errorCode = in.read() & 0xFF;
                switch (errorCode) {

  private double[] dataset(int i) {
    // We must test on a fresh clone of the dataset each time. Doing sorts and quickselects on a
    // dataset which is already sorted or partially sorted is cheating.
    return datasets[i & 0xFF].clone();
  }

  @Benchmark
  double median(int reps) {
    double dummy = 0.0;
    for (int i = 0; i < reps; i++) {
      dummy += algorithm.singleQuantile(1, 2, dataset(i));
    }
    return dummy;
  }

  private double[] dataset(int i) {
    // We must test on a fresh clone of the dataset each time. Doing sorts and quickselects on a
    // dataset which is already sorted or partially sorted is cheating.
    return datasets[i & 0xFF].clone();
  }

  @Benchmark
  double median(int reps) {
    double dummy = 0.0;
    for (int i = 0; i < reps; i++) {
      dummy += algorithm.singleQuantile(1, 2, dataset(i));
    }
    return dummy;
  }

            if (TOK_ID[i] != buf[i]) {
                throw new IllegalArgumentException();
            }
        }
        // MECH_OID_LEN
        len = 0xff00 & buf[i] << 8;
        i++;
        len |= 0xff & buf[i++];

        // MECH_OID
        if (buf.length < i + len) {
            throw new IllegalArgumentException();
        }
        final byte[] bo = new byte[len];
        System.arraycopy(buf, i, bo, 0, len);

        for (int i = 0; i < key.length; i++) {
            if (i > 0) {
                sb.append(' ');
            }
            sb.append(String.format("%02X", key[i] & 0xFF));
        }
        sb.append(']');
        return sb.toString();
    }

        bufferIndex += 8;
        fileType = readInt2(buffer, bufferIndex);
        bufferIndex += 2;
        deviceState = readInt2(buffer, bufferIndex);
        bufferIndex += 2;
        directory = (buffer[bufferIndex++] & 0xFF) > 0;

        return bufferIndex - start;
    }

    @Override
    int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
        return 0;
    }

    @Override