throw new IOException("DCERPC pipe is no longer open");
        }

        int have = this.handle.sendrecv(buf, off, length, inB, getMaxRecv());

        final int fraglen = Encdec.dec_uint16le(inB, 8);
        if (fraglen > getMaxRecv()) {
            throw new IOException("Unexpected fragment length: " + fraglen);
        }

        while (have < fraglen) {

    }

    private String getNtlmsspListItem(final byte[] type2token, final int id0) {
        int ri = 58;

        for (;;) {
            final int id = Encdec.dec_uint16le(type2token, ri);
            final int len = Encdec.dec_uint16le(type2token, ri + 2);
            ri += 4;
            if (id == 0 || ri + len > type2token.length) {
                break;
            }
            if (id == id0) {

     * @param si the starting index in the source array
     * @return the decoded long value
     */
    public static long dec_uint64le(final byte[] src, final int si) {
        long l = dec_uint32le(src, si + 4) & 0xFFFFFFFFL;
        l <<= 32L;
        l |= dec_uint32le(src, si) & 0xFFFFFFFFL;
        return l;
    }

    /* Encode floats
     */

    /**

     * @param si the starting index in the source array
     * @return the decoded long value
     */
    public static long dec_uint64le(final byte[] src, final int si) {
        long l = dec_uint32le(src, si + 4) & 0xFFFFFFFFL;
        l <<= 32L;
        l |= dec_uint32le(src, si) & 0xFFFFFFFFL;
        return l;
    }

    /*
     * Encode floats
     */

    /**

        }

        flags = buf[3] & 0xFF;
        // next read is start of new frag
        isStart = (flags & DCERPC_LAST_FRAG) == DCERPC_LAST_FRAG;

        length = Encdec.dec_uint16le(buf, 8);
        if (length > max_recv) {
            throw new IOException("Unexpected fragment length: " + length);
        }

        while (off < length) {

        align(2);
        Encdec.enc_uint16le((short) s, this.buf, this.index);
        advance(2);
    }

    /**
     * Decodes a short integer (2 bytes) from NDR format.
     *
     * @return the decoded short integer value
     */
    public int dec_ndr_short() {
        align(2);
        final int val = Encdec.dec_uint16le(this.buf, this.index);
        advance(2);
        return val;

        align(2);
        Encdec.enc_uint16le((short) s, buf, index);
        advance(2);
    }

    /**
     * Decodes a short integer (2 bytes) from NDR format.
     *
     * @return the decoded short integer value
     */
    public int dec_ndr_short() {
        align(2);
        final int val = Encdec.dec_uint16le(buf, index);
        advance(2);
        return val;
    }

            final int size = Encdec.dec_uint16be(buffer, 2) & 0xFFFF;
            if (size < SMB1_HEADER_LENGTH + 1 || 4 + size > Math.min(0xFFFF, getContext().getConfig().getMaximumBufferSize())) {
                throw new IOException("Invalid payload size: " + size);
            }
            final int errorCode = Encdec.dec_uint32le(buffer, 9) & 0xFFFFFFFF;

            System.arraycopy(sbuf, 0, BUF, 0, 4 + HEADER_LENGTH);
            final int size = Encdec.dec_uint16be(BUF, 2) & 0xFFFF;
            if (size < HEADER_LENGTH + 1 || 4 + size > rcv_buf_size) {
                throw new IOException("Invalid payload size: " + size);
            }
            final int errorCode = Encdec.dec_uint32le(BUF, 9) & 0xFFFFFFFF;

            byte[] buf = new byte[50];
            byte[] inB = new byte[100];

            // Setup fragment length in response buffer
            Encdec.enc_uint16le((short) 40, inB, 8);

            when(mockSmbPipeHandleInternal.isStale()).thenReturn(false);
            when(mockSmbPipeHandleInternal.sendrecv(buf, 0, 50, inB, 4280)).thenReturn(40);