// This is not timing the actual read operation, but the time it takes to prepare the reader.
	stopFn := globalSftpMetrics.log(r, f.AccessKey())
	defer stopFn(0, err)

	flags := r.Pflags()
	if !flags.Read {
		// sanity check
		return nil, os.ErrInvalid
	}

	bucket, object := path2BucketObject(r.Filepath)
	if bucket == "" {
		return nil, errors.New("bucket name cannot be empty")
	}

        AvFlags flags1 = new AvFlags(0x11111111);
        AvFlags flags2 = new AvFlags(0x22222222);
        pairs.add(flags1);
        pairs.add(new AvTimestamp(new byte[8]));
        pairs.add(flags2);

        AvPair result = AvPairs.get(pairs, AvPair.MsvAvFlags);
        assertNotNull(result, "Should find the pair");
        assertEquals(flags1, result, "Should return first occurrence");
    }

            byte[] testBuffer = new byte[8];
            ByteBuffer bb = ByteBuffer.wrap(testBuffer).order(ByteOrder.LITTLE_ENDIAN);
            bb.putShort((short) 0); // pathConsumed (will be divided by 2)
            bb.putShort((short) 0); // numReferrals
            bb.putShort((short) 0); // tflags
            bb.putShort((short) 0); // tflags high bytes (skipped in decode)

        // Test with RECURSIVE_TREE scope (recursive flag set)
        DirectoryLeaseContext context2 = new DirectoryLeaseContext(key, 0, DirectoryCacheScope.RECURSIVE_TREE);
        context2.setNotificationEnabled(true);

        byte[] buffer2 = new byte[context2.size()];
        context2.encode(buffer2, 0);

        int flags2 = SMBUtil.readInt4(buffer2, 68);

    }

    /**
     * Gets the SMB message flags
     * @return the flags
     */
    public final byte getFlags() {
        return this.flags;
    }

    /**
     * Sets the SMB message flags
     * @param flags
     *            the flags to set
     */
    public final void setFlags(final byte flags) {
        this.flags = flags;
    }

    /**

        assertEquals(smb.flags, readSmb.flags);
        assertEquals(smb.flags2, readSmb.flags2);
        assertEquals(smb.tid, readSmb.tid);
        assertEquals(smb.pid, readSmb.pid);
        assertEquals(smb.uid, readSmb.uid);
        assertEquals(smb.mid, readSmb.mid);
    }

    @Test
    void testIsResponse() {
        smb.flags = (byte) ServerMessageBlock.FLAGS_RESPONSE;

        final String str = errorCode == 0 ? "0" : SmbException.getMessageByCode(errorCode);
        return "command=" + c + ",received=" + received + ",errorCode=" + str + ",flags=0x" + Hexdump.toHexString(flags & 0xFF, 4)
                + ",flags2=0x" + Hexdump.toHexString(flags2, 4) + ",signSeq=" + signSeq + ",tid=" + tid + ",pid=" + pid + ",uid=" + uid
                + ",mid=" + mid + ",wordCount=" + wordCount + ",byteCount=" + byteCount;
    }

        boolean end = false;
        int flags;
        String charset;
        if (lmResponseOffset < pos + 12 || ntResponseOffset < pos + 12 || domainOffset < pos + 12 || userOffset < pos + 12
                || workstationOffset < pos + 12) {
            // no room for SK/Flags
            flags = NTLMSSP_NEGOTIATE_NTLM | NTLMSSP_NEGOTIATE_OEM;
            setFlags(flags);
            charset = getOEMEncoding();

    int FLAGS_OPLOCK_REQUESTED_OR_GRANTED = 0x20;
    /** Notify of modify action flag */
    int FLAGS_NOTIFY_OF_MODIFY_ACTION = 0x40;
    /** Response flag */
    int FLAGS_RESPONSE = 0x80;

    /** No flags2 set */
    int FLAGS2_NONE = 0x0000;
    /** Long filenames supported flag */
    int FLAGS2_LONG_FILENAMES = 0x0001;
    /** Extended attributes supported flag */

    }

    @Override
    public String getPath() {
        return this.path;
    }

    /**
     * Get the referral flags
     *
     * @return the rflags
     */
    public int getFlags() {
        return this.rflags;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.dfs.DfsReferralDataInternal#setCacheMap(java.util.Map)
     */