}
- /* Copied from the AjpProcessor.java */
- public SocketState asyncDispatch(SocketWrapper<Long> socket,
- SocketStatus status) {
- // Setting up the socket
- this.socket = socket;
- long socketRef = socket.getSocket().longValue();
- inputBuffer.setSocket(socketRef);
- outputBuffer.setSocket(socketRef);
+ public SocketState asyncDispatch(SocketStatus status) {
RequestInfo rp = request.getRequestProcessor();
try {
SocketState state = SocketState.CLOSED;
do {
if (processor.isAsync() || state == SocketState.ASYNC_END) {
- state = processor.asyncDispatch(socket, status);
+ state = processor.asyncDispatch(status);
} else if (processor.comet) {
state = processor.event(status);
} else {