public abstract class UpgradeProcessor<S> extends Object implements Processor<S>
| Modifier and Type | Field and Description |
|---|---|
protected static StringManager |
sm |
| Modifier | Constructor and Description |
|---|---|
protected |
UpgradeProcessor(UpgradeInbound upgradeInbound) |
| Modifier and Type | Method and Description |
|---|---|
AbstractEndpoint.Handler.SocketState |
asyncDispatch(SocketStatus status) |
AbstractEndpoint.Handler.SocketState |
asyncPostProcess() |
AbstractEndpoint.Handler.SocketState |
event(SocketStatus status) |
abstract void |
flush() |
Executor |
getExecutor() |
Request |
getRequest() |
UpgradeInbound |
getUpgradeInbound() |
boolean |
isAsync() |
boolean |
isComet() |
boolean |
isUpgrade() |
AbstractEndpoint.Handler.SocketState |
process(SocketWrapper<S> socketWrapper) |
abstract int |
read()
This is always a blocking read of a single byte.
|
abstract int |
read(boolean block,
byte[] bytes,
int off,
int len)
Read up to len bytes from the input in either blocking or non-blocking
mode (where non-blocking is supported).
|
void |
recycle(boolean socketClosing) |
void |
setSslSupport(SSLSupport sslSupport) |
AbstractEndpoint.Handler.SocketState |
upgradeDispatch() |
abstract void |
write(byte[] b,
int off,
int len) |
abstract void |
write(int b) |
protected static final StringManager sm
protected UpgradeProcessor(UpgradeInbound upgradeInbound)
public abstract void flush()
throws IOException
IOExceptionpublic abstract void write(int b)
throws IOException
IOExceptionpublic abstract void write(byte[] b,
int off,
int len)
throws IOException
IOExceptionpublic abstract int read()
throws IOException
IOException - If a problem occurs trying to read from the inputpublic abstract int read(boolean block,
byte[] bytes,
int off,
int len)
throws IOException
block - bytes - off - len - IOException - If a problem occurs trying to read from the inputpublic final UpgradeInbound getUpgradeInbound()
getUpgradeInbound in interface Processor<S>public final AbstractEndpoint.Handler.SocketState upgradeDispatch() throws IOException
upgradeDispatch in interface Processor<S>IOExceptionpublic final void recycle(boolean socketClosing)
public final Executor getExecutor()
getExecutor in interface Processor<S>public final AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socketWrapper) throws IOException
process in interface Processor<S>IOExceptionpublic final AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws IOException
event in interface Processor<S>IOExceptionpublic final AbstractEndpoint.Handler.SocketState asyncDispatch(SocketStatus status)
asyncDispatch in interface Processor<S>public final AbstractEndpoint.Handler.SocketState asyncPostProcess()
asyncPostProcess in interface Processor<S>public final Request getRequest()
getRequest in interface Processor<S>public final void setSslSupport(SSLSupport sslSupport)
setSslSupport in interface Processor<S>Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.