| 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; |