Class TestOutput

test/org/apache/coyote/http2/Http2TestBase.java:1113–1353

    public class TestOutput implements Output, HeaderEmitter {

        private final boolean autoAckSettings;

        private StringBuffer trace = new StringBuffer();
        private String lastStreamId = "0";
        private ConnectionSettingsRemote remoteSettings = new ConnectionSettingsRemote("-1");
        private boolean traceBody = false;
        private ByteBuffer bodyBuffer = null;
        private long bytesRead;
        private volatile HpackDecoder hpackDecoder = null;

        public TestOutput(boolean autoAckSettings) {
            this.autoAckSettings = autoAckSettings;
        }

        public void setTraceBody(boolean traceBody) {
            this.traceBody = traceBody;
        }


        @Override
        public HpackDecoder getHpackDecoder() {
            if (hpackDecoder == null) {
                synchronized (this) {
                    if (hpackDecoder == null) {
                        hpackDecoder = new HpackDecoder(remoteSettings.getHeaderTableSize());
                    }
                }
            }
            return hpackDecoder;
        }


        @Override
        public ByteBuffer startRequestBodyFrame(int streamId, int dataLength, boolean endOfStream) {
            lastStreamId = Integer.toString(streamId);
            bytesRead += dataLength;
            if (traceBody) {
                bodyBuffer = ByteBuffer.allocate(dataLength);
                return bodyBuffer;
            } else {
                trace.append(lastStreamId + "-Body-" + dataLength + "\n");
                return null;
            }
        }


        @Override
        public void endRequestBodyFrame(int streamId, int dataLength) throws Http2Exception {
            if (bodyBuffer != null) {
                if (bodyBuffer.limit() > 0) {
                    trace.append(lastStreamId + "-Body-");
                    bodyBuffer.flip();
                    while (bodyBuffer.hasRemaining()) {
                        trace.append((char) bodyBuffer.get());
                    }
                    trace.append("\n");