public abstract class UpgradeProcessor<S> extends java.lang.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() |
java.util.concurrent.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 java.io.IOException
java.io.IOExceptionpublic abstract void write(int b)
throws java.io.IOException
java.io.IOExceptionpublic abstract void write(byte[] b,
int off,
int len)
throws java.io.IOException
java.io.IOExceptionpublic abstract int read()
throws java.io.IOException
java.io.IOException - If a problem occurs trying to read from the inputpublic abstract int read(boolean block,
byte[] bytes,
int off,
int len)
throws java.io.IOException
block - bytes - off - len - java.io.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 java.io.IOException
upgradeDispatch in interface Processor<S>java.io.IOExceptionpublic final void recycle(boolean socketClosing)
public final java.util.concurrent.Executor getExecutor()
getExecutor in interface Processor<S>public final AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socketWrapper) throws java.io.IOException
public final AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws java.io.IOException
public 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-2013 Apache Software Foundation. All Rights Reserved.