import java.util.concurrent.Executor;
import org.apache.tomcat.util.net.AbstractEndpoint;
+import org.apache.tomcat.util.net.AbstractEndpoint.Handler.SocketState;
/**
* Provides functionality and attributes common to all supported protocols
}
-
- /*
- * Expose selected endpoint attributes through the processor
- */
-
/**
* Obtain the Executor used by the underlying endpoint.
*/
public Executor getExecutor() {
return endpoint.getExecutor();
}
+
+
+ public boolean isAsync() {
+ return asyncStateMachine.isAsync();
+ }
+
+
+ public SocketState asyncPostProcess() {
+ return asyncStateMachine.asyncPostProcess();
+ }
}
throws IOException;
- protected boolean isAsync() {
- return asyncStateMachine.isAsync();
- }
-
- protected SocketState asyncPostProcess() {
- return asyncStateMachine.asyncPostProcess();
- }
-
// ------------------------------------- InputStreamInputBuffer Inner Class
import org.apache.tomcat.util.http.FastHttpDateFormat;
import org.apache.tomcat.util.http.MimeHeaders;
import org.apache.tomcat.util.net.AbstractEndpoint;
-import org.apache.tomcat.util.net.AbstractEndpoint.Handler.SocketState;
import org.apache.tomcat.util.res.StringManager;
public abstract class AbstractHttp11Processor extends AbstractProcessor {
}
protected abstract void recycleInternal();
-
- protected boolean isAsync() {
- return asyncStateMachine.isAsync();
- }
-
- protected SocketState asyncPostProcess() {
- return asyncStateMachine.asyncPostProcess();
- }
}