AbstractMixedHttpData Class — netty Architecture

Source Code

codec-http/src/main/java/io/netty/handler/codec/http/multipart/AbstractMixedHttpData.java lines 26–279

abstract class AbstractMixedHttpData<D extends HttpData> extends AbstractReferenceCounted implements HttpData {
    final String baseDir;
    final boolean deleteOnExit;
    D wrapped;

    private final long limitSize;

    AbstractMixedHttpData(long limitSize, String baseDir, boolean deleteOnExit, D initial) {
        this.limitSize = limitSize;
        this.wrapped = initial;
        this.baseDir = baseDir;
        this.deleteOnExit = deleteOnExit;
    }

    abstract D makeDiskData();

    @Override
    public long getMaxSize() {
        return wrapped.getMaxSize();
    }

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

    @Override
    public ByteBuf content() {
        return wrapped.content();
    }

    @Override
    public void checkSize(long newSize) throws IOException {
        wrapped.checkSize(newSize);
    }

    @Override
    public long definedLength() {
        return wrapped.definedLength();
    }

    @Override
    public Charset getCharset() {
        return wrapped.getCharset();
    }

    @Override
    public String getName() {
        return wrapped.getName();
    }

    @Override
    public void addContent(ByteBuf buffer, boolean last) throws IOException {
        if (wrapped instanceof AbstractMemoryHttpData) {
            try {
                checkSize(wrapped.length() + buffer.readableBytes());
                if (wrapped.length() + buffer.readableBytes() > limitSize) {
                    D diskData = makeDiskData();
                    ByteBuf data = ((AbstractMemoryHttpData) wrapped).getByteBuf();
                    if (data != null && data.isReadable()) {
                        diskData.addContent(data.retain(), false);
                    }
                    wrapped.release();
                    wrapped = diskData;
                }
            } catch (IOException e) {
                buffer.release();
                throw e;
            }
        }
        wrapped.addContent(buffer, last);
    }

    @Override
    protected void deallocate() {
        delete();
    }

    @Override
    public void delete() {
        wrapped.delete();