Http2StreamChannelConfig Class — netty Architecture

Source Code

codec-http2/src/main/java/io/netty/handler/codec/http2/AbstractHttp2StreamChannel.java lines 1198–1267

    private static final class Http2StreamChannelConfig extends DefaultChannelConfig {

        volatile boolean autoStreamFlowControl = true;
        Http2StreamChannelConfig(Channel channel) {
            super(channel);
        }

        @Override
        public MessageSizeEstimator getMessageSizeEstimator() {
            return FlowControlledFrameSizeEstimator.INSTANCE;
        }

        @Override
        public ChannelConfig setMessageSizeEstimator(MessageSizeEstimator estimator) {
            throw new UnsupportedOperationException();
        }

        @Override
        public ChannelConfig setRecvByteBufAllocator(RecvByteBufAllocator allocator) {
            if (!(allocator.newHandle() instanceof RecvByteBufAllocator.ExtendedHandle)) {
                throw new IllegalArgumentException("allocator.newHandle() must return an object of type: " +
                        RecvByteBufAllocator.ExtendedHandle.class);
            }
            super.setRecvByteBufAllocator(allocator);
            return this;
        }

        @Override
        public Map<ChannelOption<?>, Object> getOptions() {
            return getOptions(
                    super.getOptions(),
                    Http2StreamChannelOption.AUTO_STREAM_FLOW_CONTROL);
        }

        @SuppressWarnings("unchecked")
        @Override
        public <T> T getOption(ChannelOption<T> option) {
            if (option == Http2StreamChannelOption.AUTO_STREAM_FLOW_CONTROL) {
                return (T) Boolean.valueOf(autoStreamFlowControl);
            }
            return super.getOption(option);
        }

        @Override
        public <T> boolean setOption(ChannelOption<T> option, T value) {
            validate(option, value);
            if (option == Http2StreamChannelOption.AUTO_STREAM_FLOW_CONTROL) {
                boolean newValue = (Boolean) value;
                boolean changed = newValue && !autoStreamFlowControl;
                autoStreamFlowControl = (Boolean) value;
                if (changed) {
                    if (channel.isRegistered()) {
                        final Http2ChannelUnsafe unsafe = (Http2ChannelUnsafe) channel.unsafe();
                        if (channel.eventLoop().inEventLoop()) {
                            unsafe.updateLocalWindowIfNeededAndFlush();
                        } else {
                            channel.eventLoop().execute(new Runnable() {
                                @Override
                                public void run() {
                                    unsafe.updateLocalWindowIfNeededAndFlush();
                                }
                            });
                        }
                    }
                }
                return true;
            }
            return super.setOption(option, value);
        }
    }