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();
    }

        void testConstructorWithVariousSourceKeys() {
            // Given
            byte[] zeroKey = new byte[SOURCE_KEY_SIZE];
            byte[] maxKey = new byte[SOURCE_KEY_SIZE];
            Arrays.fill(maxKey, (byte) 0xFF);
            byte[] patternKey = new byte[SOURCE_KEY_SIZE];
            for (int i = 0; i < SOURCE_KEY_SIZE; i++) {
                patternKey[i] = (byte) i;
            }

            // When & Then

            }
            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) {

        tmp = new byte[TMP_BUFFER_SIZE];
    }

    @Override
    public synchronized int read() throws IOException {
        if (read(tmp, 0, 1) < 0) {
            return -1;
        }
        return tmp[0] & 0xFF;
    }

    @Override
    public synchronized int read(final byte[] b) throws IOException {
        return read(b, 0, b.length);
    }

    /* This method will not return until len bytes have been read

    @Test
    @DisplayName("Test readDataWireFormat with unsupported information level")
    void testReadDataWireFormatWithUnsupportedLevel() throws SMBProtocolDecodingException {
        byte unsupportedLevel = (byte) 0xFF;
        response = new Trans2QueryPathInformationResponse(mockConfig, unsupportedLevel);

        byte[] buffer = new byte[100];
        response.setDataCount(buffer.length);

    byte[] col2 = new byte[] {0x00, 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, (byte) 0x81};
    byte[] col3 = new byte[] {0x00, 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, (byte) 0xff};

    ImmutableSet<HashCode> hashCodes =
        ImmutableSet.of(
            SIP_WITH_KEY.hashBytes(col1),
            SIP_WITH_KEY.hashBytes(col2),
            SIP_WITH_KEY.hashBytes(col3));

            // Given
            byte[] buffer = new byte[10];
            // Write -1 which will be read as 65535 unsigned
            buffer[0] = (byte) 0xFF;
            buffer[1] = (byte) 0xFF;

            // When & Then
            SMBProtocolDecodingException exception =
                    assertThrows(SMBProtocolDecodingException.class, () -> response.readBytesWireFormat(buffer, 0));

        assertEquals("Pattern_V1", CompressionNegotiateContext.getAlgorithmName(CompressionNegotiateContext.COMPRESSION_PATTERN_V1));
        assertTrue(CompressionNegotiateContext.getAlgorithmName(0xFF).startsWith("Unknown"));
    }

    @Test
    @DisplayName("Test empty algorithms context")
    public void testEmptyAlgorithms() {

        ASN1ObjectIdentifier[] mechs = new ASN1ObjectIdentifier[] { OID_KRB_LEGACY };
        int flags = NegTokenInit.REPLAY_DETECTION | NegTokenInit.SEQUENCE_CHECKING;
        byte[] mic = new byte[] { 0x00, 0x0A, (byte) 0xFF };

        NegTokenInit init = new NegTokenInit(mechs, flags, null, mic);
        String s = init.toString();

        assertTrue(s.contains("flags=" + flags), "toString should include flags");