}
}
- // Methods called by action()
- protected abstract void actionInternal(ActionCode actionCode, Object param);
- protected abstract void flush(boolean tbd) throws IOException;
- protected abstract void finish() throws IOException;
-
@Override
public SocketState asyncDispatch(SocketStatus status) {
@Override
- protected final boolean isComet() {
- // AJP does not support Comet
- return false;
- }
-
- @Override
public SocketState event(SocketStatus status) throws IOException {
// Should never reach this code but in case we do...
throw new IOException(
byteCount = 0;
}
+
// ------------------------------------------------------ Protected Methods
+ // Methods called by action()
+ protected abstract void actionInternal(ActionCode actionCode, Object param);
+ protected abstract void flush(boolean tbd) throws IOException;
+ protected abstract void finish() throws IOException;
+
+ // Methods called by prepareResponse()
+ protected abstract void output(byte[] src, int offset, int length)
+ throws IOException;
+
+
+ @Override
+ protected final boolean isComet() {
+ // AJP does not support Comet
+ return false;
+ }
+
/**
* After reading the request headers, we have to setup the request filters.
* When committing the response, we have to validate the set of headers, as
* well as setup the response filters.
*/
- protected void prepareResponse()
- throws IOException {
+ protected void prepareResponse() throws IOException {
response.setCommitted(true);
responseHeaderMessage.getLen());
}
- // Methods called by prepareResponse()
- protected abstract void output(byte[] src, int offset, int length)
- throws IOException;
-
// ------------------------------------- InputStreamInputBuffer Inner Class
* This class is an input buffer which will read its data from an input
* stream.
*/
- protected class SocketInputBuffer
- implements InputBuffer {
+ protected class SocketInputBuffer implements InputBuffer {
/**