public class SpdyProcessor<S> extends AbstractProcessor<S> implements Runnable
adapter, asyncStateMachine, endpoint, request, response, sm, socketWrapper
Constructor and Description |
---|
SpdyProcessor(SpdyConnection spdy,
AbstractEndpoint<S> endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
action(ActionCode actionCode,
Object param)
Send an action to the connector.
|
AbstractEndpoint.Handler.SocketState |
asyncDispatch(SocketStatus status)
Process in-progress Servlet 3.0 Async requests.
|
AbstractEndpoint.Handler.SocketState |
event(SocketStatus status)
Process in-progress Comet requests.
|
HttpUpgradeHandler |
getHttpUpgradeHandler() |
protected Log |
getLog() |
boolean |
isComet() |
boolean |
isUpgrade() |
void |
onSynStream(SpdyStream str) |
AbstractEndpoint.Handler.SocketState |
process(SocketWrapper<S> socket)
Process HTTP requests.
|
void |
recycle(boolean socketClosing) |
protected void |
registerForEvent(boolean read,
boolean write)
Register the socket for the specified events.
|
void |
run()
Execute the request.
|
protected void |
sendSynReply()
When committing the response, we have to validate the set of headers, as
well as setup the response filters.
|
void |
setSslSupport(SSLSupport sslSupport) |
AbstractEndpoint.Handler.SocketState |
upgradeDispatch(SocketStatus status)
Processes data received on a connection that has been through an HTTP
upgrade.
|
asyncPostProcess, errorDispatch, getAdapter, getEndpoint, getErrorState, getExecutor, getRequest, getSocketWrapper, isAsync, resetErrorState, setAdapter, setErrorState, setSocketWrapper
public SpdyProcessor(SpdyConnection spdy, AbstractEndpoint<S> endpoint)
public void action(ActionCode actionCode, Object param)
ActionHook
action
in interface ActionHook
actionCode
- Type of the actionparam
- Action parameterprotected void sendSynReply()
public boolean isComet()
public AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socket) throws IOException
AbstractProcessor
process
in interface Processor<S>
process
in class AbstractProcessor<S>
IOException
public AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws IOException
AbstractProcessor
event
in interface Processor<S>
event
in class AbstractProcessor<S>
IOException
public AbstractEndpoint.Handler.SocketState asyncDispatch(SocketStatus status)
AbstractProcessor
asyncDispatch
in interface Processor<S>
asyncDispatch
in class AbstractProcessor<S>
public boolean isUpgrade()
public AbstractEndpoint.Handler.SocketState upgradeDispatch(SocketStatus status) throws IOException
AbstractProcessor
upgradeDispatch
in interface Processor<S>
upgradeDispatch
in class AbstractProcessor<S>
IOException
protected void registerForEvent(boolean read, boolean write)
AbstractProcessor
registerForEvent
in class AbstractProcessor<S>
read
- Register the socket for read eventswrite
- Register the socket for write eventspublic void onSynStream(SpdyStream str) throws IOException
IOException
public void setSslSupport(SSLSupport sslSupport)
setSslSupport
in interface Processor<S>
public HttpUpgradeHandler getHttpUpgradeHandler()
getHttpUpgradeHandler
in interface Processor<S>
getHttpUpgradeHandler
in class AbstractProcessor<S>
protected Log getLog()
getLog
in class AbstractProcessor<S>
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.