AbstractHttpData Class — netty Architecture

Source Code

codec-http/src/main/java/io/netty/handler/codec/http/multipart/AbstractHttpData.java lines 32–183

public abstract class AbstractHttpData extends AbstractReferenceCounted implements HttpData {

    private final String name;
    protected long definedSize;
    protected long size;
    private Charset charset = HttpConstants.DEFAULT_CHARSET;
    private boolean completed;
    private long maxSize = DefaultHttpDataFactory.MAXSIZE;

    protected AbstractHttpData(String name, Charset charset, long size) {
        ObjectUtil.checkNotNull(name, "name");

        this.name = checkNonEmpty(cleanName(name), "name");
        if (charset != null) {
            setCharset(charset);
        }
        definedSize = size;
    }

    //Replaces \r and \t with a space
    //Removes leading and trailing whitespace and newlines
    private static String cleanName(String name) {
        int len = name.length();
        StringBuilder sb = null;

        int start = 0;
        int end = len;

        // Trim leading whitespace
        while (start < end && Character.isWhitespace(name.charAt(start))) {
            start++;
        }

        // Trim trailing whitespace
        while (end > start && Character.isWhitespace(name.charAt(end - 1))) {
            end--;
        }

        for (int i = start; i < end; i++) {
            char c = name.charAt(i);

            if (c == '\n') {
                // Skip newline entirely
                if (sb == null) {
                    sb = new StringBuilder(len);
                    sb.append(name, start, i);
                }
                continue;
            }

            if (c == '\r' || c == '\t') {
                if (sb == null) {
                    sb = new StringBuilder(len);
                    sb.append(name, start, i);
                }
                sb.append(' ');
            } else if (sb != null) {
                sb.append(c);
            }
        }

        // If no replacements were needed, return the trimmed slice
        return sb == null ? name.substring(start, end) : sb.toString();
    }

    @Override
    public long getMaxSize() {
        return maxSize;
    }

    @Override
    public void setMaxSize(long maxSize) {
        this.maxSize = maxSize;
    }

    @Override
    public void checkSize(long newSize) throws IOException {
        if (maxSize >= 0 && newSize > maxSize) {
            throw new IOException("Size exceed allowed maximum capacity");
        }
    }