}
                th.send(req, resp, RequestParam.NO_RETRY);
                return resp.getResponseLength();
            }
            if (this.call) {
                th.send(new TransWaitNamedPipe(th.getConfig(), this.uncPath), new TransWaitNamedPipeResponse(th.getConfig()));
                final TransCallNamedPipeResponse resp = new TransCallNamedPipeResponse(th.getConfig(), inB);

            return rpc.getEntries();
        }
    }

    static FileEntry[] doNetShareEnum(final SmbTreeHandleImpl th) throws CIFSException {
        final SmbComTransaction req = new NetShareEnum(th.getConfig());
        final SmbComTransactionResponse resp = new NetShareEnumResponse(th.getConfig());
        th.send(req, resp);
        if (resp.getStatus() != WinError.ERROR_SUCCESS) {
            throw new SmbException(resp.getStatus(), true);

                    req.chain(new Smb2CloseRequest(th.getConfig(), Smb2Constants.UNSPECIFIED_FILEID));
                    th.send(req);
                } else {
                    th.send(new SmbComDeleteDirectory(th.getConfig(), fileName), new SmbComBlankResponse(th.getConfig()));
                }
            } else if (th.isSMB2()) {
                final Smb2CreateRequest req = new Smb2CreateRequest(th.getConfig(), fileName.substring(1));

            throw new SmbException("Not a directory: " + smbFile.getPath());
        }

        try (SmbTreeHandleImpl th = smbFile.ensureTreeConnected()) {
            // Check if we can use directory leasing
            DirectoryLeaseManager dirManager = getDirectoryLeaseManager(th);
            if (dirManager != null && smbFile.getContext().getConfig().isUseDirectoryLeasing()) {

                    count.getAndIncrement();
                }
            });
        }

        for (Thread th : threads) {
            th.start();
        }
        for (Thread th : threads) {
            th.join();
        }
        assertEquals(num, count.get());
        assertEquals(num, valueSet.size());

    protected void doCloseInternal() throws CIFSException {
        try {
            @SuppressWarnings("resource")
            final SmbTreeHandleImpl th = getTreeHandle();
            if (this.fileId != null && th.isConnected()) {
                th.send(new Smb2CloseRequest(th.getConfig(), this.fileId));
            }
        } finally {
            this.fileId = null;
        }
    }

        }

        final SmbTreeHandleImpl th = getTreeHandle();
        this.response = new Trans2FindFirst2Response(th.getConfig());

        try {
            th.send(new Trans2FindFirst2(th.getConfig(), unc, this.getWildcard(), this.getSearchAttributes(), th.getConfig().getListCount(),
                    th.getConfig().getListSize() - FIND_OVERHEAD), this.response);

        try (SmbFileHandleImpl fh = ensureOpen(); SmbTreeHandleImpl th = fh.getTree()) {
            if (th.isSMB2()) {
                final Smb2SetInfoRequest req = new Smb2SetInfoRequest(th.getConfig(), fh.getFileId());
                req.setFileInformation(new FileEndOfFileInformation(newLength));
                th.send(req, RequestParam.NO_RETRY);
            } else if (th.hasCapability(SmbConstants.CAP_NT_SMBS)) {

    /**
     * @param f
     * @param th
     * @throws SmbException
     */
    private void init(final SmbTreeHandleInternal th) throws CIFSException {
        if (this.smb2) {
            this.readSize = th.getReceiveBufferSize();
            this.readSizeFile = th.getReceiveBufferSize();
            return;
        }

        this.readSize = Math.min(th.getReceiveBufferSize() - 70, th.getMaximumBufferSize() - 70);

        this.access = access | SmbConstants.FILE_WRITE_DATA;

        try (SmbTreeHandleImpl th = file.ensureTreeConnected()) {
            this.smb2 = th.isSMB2();
            try (SmbFileHandleImpl fh = ensureOpen()) {
                if (append) {
                    this.fp = fh.getInitialSize();
                }
                init(th);
                if (!append && this.smb2) {