}
            } else if (c == delimiter && !inQuotes) {
                // Field separator
                fields.add(unquoteField(currentField.toString().trim()));
                currentField.setLength(0);
            } else {
                currentField.append(c);
            }
        }

        // Add last field
        fields.add(unquoteField(currentField.toString().trim()));

                if (pathStartsWithSlash) {
                    if (initialUrlEndsWithSlash) {
                        // 1 extra '/' to remove
                        url.setLength(url.length() - 1);
                    }
                } else if (!initialUrlEndsWithSlash) {
                    // add missing '/' between url and path
                    url.append('/');
                }

        final String target = rightString(buf, size);
        if (!termCache.contains(target)) {
            termCache.add(target);
            return isSpace;
        }
        buf.setLength(buf.length() - size);
        if (!isSpace && !isLastSpaceChar(buf)) {
            buf.appendCodePoint(' ');
            return true;
        }
        return isSpace;
    }

                }
                buffer.append(buildTimeDuration);
                buffer.append(']');
            }

            logger.info(buffer.toString());
            buffer.setLength(0);
        }
    }

    private void logResult(MavenSession session) {
        infoLine('-');
        MessageBuilder buffer = builder();

        if (session.getResult().hasExceptions()) {

            this.responseTable.clear();
        }
    }

    @Override
    public void run() {
        try {
            while (this.thread == Thread.currentThread()) {
                this.in.setLength(this.transportContext.getConfig().getNetbiosRcvBufSize());

                this.socket.setSoTimeout(this.closeTimeout);
                this.socket.receive(this.in);

     * @param fbuf
     * @throws DcerpcException
     */
    private void setupReceivedFragment(final NdrBuffer fbuf) throws DcerpcException {
        fbuf.reset();
        fbuf.setIndex(8);
        fbuf.setLength(fbuf.dec_ndr_short());

        if (this.securityProvider != null) {
            this.securityProvider.unwrap(fbuf);
        }
    }

    /**
     * Encode a DCE/RPC message for transmission
     *

     *
     * @param newLength the new file length in bytes
     * @throws SmbException if an I/O error occurs
     */
    public void setLength(final long newLength) throws SmbException {
        // ensure file is open
        if (!file.isOpen()) {
            file.open(openFlags, 0, SmbFile.ATTR_NORMAL, options);
        }

            try {
                Smb2ReadRequest request = new Smb2ReadRequest();
                request.setFileId(this.fileId);
                request.setOffset(offset + chunkOffset);
                request.setLength(chunkLength);
                
                Smb2ReadResponse response = (Smb2ReadResponse) 
                    channel.getTransport().send(request);
                

    public int getLength() {
        return this.deferred.length;
    }

    /**
     * Sets the length of data in the buffer.
     *
     * @param length the new data length
     */
    public void setLength(final int length) {
        this.deferred.length = length;
    }

    /**
     * Advances the buffer index by the specified number of bytes.
     *
     * @param n the number of bytes to advance
     */

    Integer[] codePoints = utf8Lengths.keySet().toArray(new Integer[] {});
    StringBuilder sb = new StringBuilder();
    Random rnd = new Random();
    for (int trial = 0; trial < 100; trial++) {
      sb.setLength(0);
      int utf8Length = 0;
      for (int i = 0; i < 6; i++) {
        Integer randomCodePoint = codePoints[rnd.nextInt(codePoints.length)];
        sb.appendCodePoint(randomCodePoint);