| java.lang.Object
 org.apache.coyote.ajp.AjpAprProcessor
| AjpAprProcessor | | public class AjpAprProcessor implements ActionHook(Code) | | Processes HTTP requests.
author:
Remy Maucherat
author:
Henri Gomez
author:
Dan Milstein
author:
Keith Wannamaker
author:
Kevin Seguin
author:
Costin Manolache
author:
Bill Barker |
| Inner Class :protected class SocketInputBuffer implements InputBuffer | |
| Inner Class :protected class SocketOutputBuffer implements OutputBuffer | |
| Method Summary | |
| public void | action(ActionCode actionCode, Object param)
Send an action to the connector. | | protected void | finish()
Finish AJP response. | | protected void | flush()
Callback to write data from the buffer. | | public Adapter | getAdapter()
Get the associated adapter. | | public Request | getRequest()
Get the request associated with this processor. | | public boolean | getTomcatAuthentication()
| | public void | parseHost(MessageBytes valueMB)
Parse host. | | protected void | prepareRequest()
After reading the request headers, we have to setup the request filters. | | protected void | prepareResponse()
When committing the response, we have to validate the set of headers, as
well as setup the response filters. | | public boolean | process(long socket)
Process pipelined HTTP requests using the specified input and output
streams. | | protected boolean | read(int n)
Read at least the specified amount of bytes, and place them
in the input buffer. | | protected boolean | readMessage(AjpMessage message, boolean first, boolean useAvailableData)
Read an AJP message. | | protected boolean | readt(int n, boolean useAvailableData)
Read at least the specified amount of bytes, and place them
in the input buffer. | | public boolean | receive()
Receive a chunk of data. | | public void | recycle()
Recycle the processor. | | public void | setAdapter(Adapter adapter)
Set the associated adapter. | | public void | setRequiredSecret(String requiredSecret)
| | public void | setTomcatAuthentication(boolean tomcatAuthentication)
|
| empty | | protected boolean empty(Code) | | Body empty flag.
|
| endMessageArray | | final protected static byte[] endMessageArray(Code) | | End message array.
|
| endOfStream | | protected boolean endOfStream(Code) | | End of stream flag.
|
| error | | protected boolean error(Code) | | Error flag.
|
| finished | | protected boolean finished(Code) | | Finished response.
|
| first | | protected boolean first(Code) | | First read.
|
| flushMessageBuffer | | final protected static ByteBuffer flushMessageBuffer(Code) | | Direct buffer used for sending explicit flush message.
|
| getBodyMessageBuffer | | final protected static ByteBuffer getBodyMessageBuffer(Code) | | Direct buffer used for sending right away a get body message.
|
| hostNameC | | protected char[] hostNameC(Code) | | Host name (used to avoid useless B2C conversion on the host name).
|
| inputBuffer | | protected ByteBuffer inputBuffer(Code) | | Direct buffer used for input.
|
| outputBuffer | | protected ByteBuffer outputBuffer(Code) | | Direct buffer used for output.
|
| pongMessageBuffer | | final protected static ByteBuffer pongMessageBuffer(Code) | | Direct buffer used for sending right away a pong message.
|
| replay | | protected boolean replay(Code) | | Replay read.
|
| requestHeaderMessage | | protected AjpMessage requestHeaderMessage(Code) | | Header message. Note that this header is merely the one used during the
processing of the first message of a "request", so it might not be a request
header. It will stay unchanged during the processing of the whole request.
|
| requiredSecret | | protected String requiredSecret(Code) | | Required secret.
|
| responseHeaderMessage | | protected AjpMessage responseHeaderMessage(Code) | | Message used for response header composition.
|
| socket | | protected long socket(Code) | | Socket associated with the current connection.
|
| started | | protected boolean started(Code) | | State flag.
|
| tomcatAuthentication | | protected boolean tomcatAuthentication(Code) | | Use Tomcat authentication ?
|
| action | | public void action(ActionCode actionCode, Object param)(Code) | | Send an action to the connector.
Parameters:
actionCode - Type of the action
Parameters:
param - Action parameter |
| flush | | protected void flush() throws IOException(Code) | | Callback to write data from the buffer.
|
| getAdapter | | public Adapter getAdapter()(Code) | | Get the associated adapter.
the associated adapter |
| getRequest | | public Request getRequest()(Code) | | Get the request associated with this processor.
The request |
| getTomcatAuthentication | | public boolean getTomcatAuthentication()(Code) | | |
| prepareRequest | | protected void prepareRequest()(Code) | | After reading the request headers, we have to setup the request filters.
|
| prepareResponse | | protected void prepareResponse() throws IOException(Code) | | When committing the response, we have to validate the set of headers, as
well as setup the response filters.
|
| process | | public boolean process(long socket) throws IOException(Code) | | Process pipelined HTTP requests using the specified input and output
streams.
throws:
IOException - error during an I/O operation |
| read | | protected boolean read(int n) throws IOException(Code) | | Read at least the specified amount of bytes, and place them
in the input buffer.
|
| readMessage | | protected boolean readMessage(AjpMessage message, boolean first, boolean useAvailableData) throws IOException(Code) | | Read an AJP message.
Parameters:
first - is true if the message is the first in the request, whichwill cause a short duration blocking read true if the message has been read, false if the short readdidn't return anything
throws:
IOException - any other failure, including incomplete reads |
| readt | | protected boolean readt(int n, boolean useAvailableData) throws IOException(Code) | | Read at least the specified amount of bytes, and place them
in the input buffer.
|
| receive | | public boolean receive() throws IOException(Code) | | Receive a chunk of data. Called to implement the
'special' packet in ajp13 and to receive the data
after we send a GET_BODY packet
|
| recycle | | public void recycle()(Code) | | Recycle the processor.
|
| setAdapter | | public void setAdapter(Adapter adapter)(Code) | | Set the associated adapter.
Parameters:
adapter - the new adapter |
| setRequiredSecret | | public void setRequiredSecret(String requiredSecret)(Code) | | |
| setTomcatAuthentication | | public void setTomcatAuthentication(boolean tomcatAuthentication)(Code) | | |
|
|