(int streamId)
| 662 | |
| 663 | |
| 664 | protected void onHeadersComplete(int streamId) throws Http2Exception { |
| 665 | // Any left over data is a compression error |
| 666 | if (headerReadBuffer.position() > 0) { |
| 667 | throw new ConnectionException(sm.getString("http2Parser.processFrameHeaders.decodingDataLeft"), |
| 668 | Http2Error.COMPRESSION_ERROR); |
| 669 | } |
| 670 | |
| 671 | synchronized (output) { |
| 672 | output.headersEnd(streamId, headersEndStream); |
| 673 | |
| 674 | if (headersEndStream) { |
| 675 | headersEndStream = false; |
| 676 | } |
| 677 | } |
| 678 | |
| 679 | // We know from test above that buffer is empty so no need to force it to be cleared |
| 680 | afterHeadersCompleteCleanUp(false); |
| 681 | } |
| 682 | |
| 683 | |
| 684 | protected void afterHeadersCompleteCleanUp(boolean forceClear) { |
no test coverage detected