return ((SrvPipePeekResponse)resp.getOutputData()).getReadDataAvailable();
            }
            TransPeekNamedPipe req = new TransPeekNamedPipe(th.getConfig(), this.handle.getUncPath(), fd.getFid());
            TransPeekNamedPipeResponse resp = new TransPeekNamedPipeResponse(th.getConfig());
            th.send(req, resp, RequestParam.NO_RETRY);
            if ( resp.getStatus() == TransPeekNamedPipeResponse.STATUS_DISCONNECTED

     *
     * @see java.lang.AutoCloseable#close()
     */
    @Override
    void close ();


    /**
     * @return the configuration used by this session
     */
    Configuration getConfig ();


    /**
     * 
     * @param type
     * @return session instance with the given type
     */
    <T extends SmbSession> T unwrap ( Class<T> type );


    /**
     * 

/**
 * Handle to a connected SMB tree
 * 
 * @author mbechler
 *
 */
public interface SmbTreeHandle extends AutoCloseable {

    /**
     * @return the active configuration
     */
    Configuration getConfig ();


    /**
     * {@inheritDoc}
     *
     * @see java.lang.AutoCloseable#close()
     */
    @Override
    void close () throws CIFSException;


    /**

    }


    @Override
    protected Smb2TreeDisconnectResponse createResponse ( CIFSContext tc, ServerMessageBlock2Request<Smb2TreeDisconnectResponse> req ) {
        return new Smb2TreeDisconnectResponse(tc.getConfig());
    }


    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.CommonServerMessageBlockRequest#size()
     */
    @Override
    public int size () {

        super(config, SMB2_LOGOFF);
    }


    @Override
    protected Smb2LogoffResponse createResponse ( CIFSContext tc, ServerMessageBlock2Request<Smb2LogoffResponse> req ) {
        return new Smb2LogoffResponse(tc.getConfig());
    }


    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.CommonServerMessageBlockRequest#size()
     */
    @Override
    public int size () {

        super(config, SMB2_ECHO);
    }


    @Override
    protected Smb2EchoResponse createResponse ( CIFSContext tc, ServerMessageBlock2Request<Smb2EchoResponse> req ) {
        return new Smb2EchoResponse(tc.getConfig());
    }


    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.CommonServerMessageBlockRequest#size()
     */
    @Override
    public int size () {

     * @param previousSessionid
     * @param token
     */
    public Smb2SessionSetupRequest ( CIFSContext context, int securityMode, int capabilities, long previousSessionid, byte[] token ) {
        super(context.getConfig(), SMB2_SESSION_SETUP);
        this.securityMode = securityMode;
        this.capabilities = capabilities;
        this.previousSessionId = previousSessionid;
        this.token = token;
    }


    @Override

        }
    }


    protected CIFSContext wrap ( CIFSContext newContext ) {
        return newContext;
    }


    @Override
    public Configuration getConfig () {
        return this.delegate.getConfig();
    }


    @Override
    public DfsResolver getDfs () {
        return this.delegate.getDfs();
    }


    @Override
    public Credentials getCredentials () {

public class FieldConfigs {

    private final Map<String, String> params;

    public FieldConfigs(final Map<String, String> params) {
        this.params = params;
    }

    public OptionalThing<Config> getConfig(final String fieldName) {
        final String value = params.get(fieldName);
        if (StringUtil.isNotBlank(value)) {
            return OptionalThing.of(new Config(value));
        }

        if ( th.hasCapability(SmbConstants.CAP_LARGE_READX) ) {
            this.largeReadX = true;
            this.readSizeFile = Math.min(th.getConfig().getReceiveBufferSize() - 70, th.areSignaturesActive() ? 0xFFFF - 70 : 0xFFFFFF - 70);
            log.debug("Enabling LARGE_READX with " + this.readSizeFile);
        }
        else {