|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sun.grizzly.http.DefaultProtocolFilter
com.sun.grizzly.arp.AsyncProtocolFilter
public class AsyncProtocolFilter
A ProtocolFilter that allow asynchronous http request processing.
Field Summary | |
---|---|
protected int |
bbSize
Default size for ByteBuffer. |
protected Interceptor<ByteBuffer,SocketChannel> |
interceptor
Interceptor used when determining if a request must be handled
directly inside this ProtocolFilter . |
Fields inherited from class com.sun.grizzly.http.DefaultProtocolFilter |
---|
address, algorithmClass, logger, port |
Fields inherited from interface com.sun.grizzly.ProtocolFilter |
---|
SUCCESSFUL_READ |
Constructor Summary | |
---|---|
AsyncProtocolFilter(Class algorithmClass,
InetAddress address,
int port)
Constructs a new AsyncProtocolFilter
. |
|
AsyncProtocolFilter(Class algorithmClass,
int port)
Deprecated. use AsyncProtocolFilter(Class, java.net.InetAddress, int) |
Method Summary | |
---|---|
protected void |
configureInputBuffer(InputReader inputStream,
Context context,
HttpWorkerThread workerThread)
Configure InputReader . |
protected void |
configureProcessorTask(ProcessorTask processorTask,
Context context,
StreamAlgorithm streamAlgorithm,
InputStream inputStream)
Configure SSLProcessorTask . |
protected InputReader |
createInputReader()
Creates InputReader |
boolean |
execute(Context ctx)
Execute a unit of processing work to be performed. |
Interceptor<ByteBuffer,SocketChannel> |
getInterceptor()
Return the current Interceptor |
void |
setInterceptor(Interceptor<ByteBuffer,SocketChannel> interceptor)
Set the Interceptor used to decide if the request must be handled
by this ProtocolFilter directly. |
void |
taskEvent(TaskEvent event)
Called when the Asynchronous Request Processing is resuming. |
Methods inherited from class com.sun.grizzly.http.DefaultProtocolFilter |
---|
configureProcessorTask, isSecure, postExecute |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected int bbSize
protected Interceptor<ByteBuffer,SocketChannel> interceptor
Interceptor
used when determining if a request must be handled
directly inside this ProtocolFilter
.
Constructor Detail |
---|
@Deprecated public AsyncProtocolFilter(Class algorithmClass, int port)
AsyncProtocolFilter(Class, java.net.InetAddress, int)
Invokes AsyncProtocolFilter(Class, java.net.InetAddress, int)
with a null
InetAddress
.
algorithmClass
- the StreamAlgorithm
port
- the network port to associate with this filterpublic AsyncProtocolFilter(Class algorithmClass, InetAddress address, int port)
AsyncProtocolFilter
.
algorithmClass
- the StreamAlgorithm
address
- the network address to associate with this filterport
- the network port to associate with this filterMethod Detail |
---|
public boolean execute(Context ctx) throws IOException
execute
in interface ProtocolFilter
execute
in class DefaultProtocolFilter
ctx
- Context
IOException
public void taskEvent(TaskEvent event)
taskEvent
in interface TaskListener
protected void configureProcessorTask(ProcessorTask processorTask, Context context, StreamAlgorithm streamAlgorithm, InputStream inputStream)
SSLProcessorTask
.
protected void configureInputBuffer(InputReader inputStream, Context context, HttpWorkerThread workerThread)
InputReader
.
configureInputBuffer
in class DefaultProtocolFilter
protected InputReader createInputReader()
InputReader
public Interceptor<ByteBuffer,SocketChannel> getInterceptor()
Interceptor
Interceptor
public void setInterceptor(Interceptor<ByteBuffer,SocketChannel> interceptor)
Interceptor
used to decide if the request must be handled
by this ProtocolFilter
directly.
interceptor
- the Interceptor
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |