()
| 49 | AbstractEndpoint endpoint1 = (AbstractEndpoint) endpoint.get(protocol); |
| 50 | Http11NioProtocol protocol1 = new Http11NioProtocol() { |
| 51 | @Override |
| 52 | protected Processor createProcessor() { |
| 53 | Http11Processor http11Processor = new Http11Processor(protocol.getMaxHttpHeaderSize(), |
| 54 | protocol.getAllowHostHeaderMismatch(), |
| 55 | protocol.getRejectIllegalHeaderName(), endpoint1, |
| 56 | protocol.getMaxTrailerSize(), |
| 57 | Collections.singleton(protocol.getAllowedTrailerHeaders()), |
| 58 | protocol.getMaxExtensionSize(), |
| 59 | protocol.getMaxSwallowSize(), |
| 60 | null, |
| 61 | protocol.getSendReasonPhrase(), |
| 62 | protocol.getRelaxedPathChars(), |
| 63 | protocol.getRelaxedQueryChars()) { |
| 64 | @Override |
| 65 | public AbstractEndpoint.Handler.SocketState process(SocketWrapperBase<?> socketWrapper, |
| 66 | SocketEvent status) throws IOException { |
| 67 | if (status == SocketEvent.OPEN_READ) { |
| 68 | ByteBuffer buffer = ByteBuffer.allocate(1); |
| 69 | socketWrapper.read(false, buffer); |
| 70 | } |
| 71 | socketWrapper.getSocketBufferHandler().getReadBuffer().position(0); |
| 72 | return super.process(socketWrapper, status); |
| 73 | } |
| 74 | }; |
| 75 | http11Processor.setAdapter(adapter); |
| 76 | return http11Processor; |
| 77 | } |
| 78 | }; |
| 79 | protocol1.setAdapter(adapter); |
| 80 | proto.set(hd, protocol1); |
nothing calls this directly
no outgoing calls
no test coverage detected