Apache Tomcat 7.0.39

org.apache.coyote.http11.upgrade
Class UpgradeProcessor<S>

java.lang.Object
  extended by org.apache.coyote.http11.upgrade.UpgradeProcessor<S>
All Implemented Interfaces:
Processor<S>
Direct Known Subclasses:
UpgradeAprProcessor, UpgradeBioProcessor, UpgradeNioProcessor

public abstract class UpgradeProcessor<S>
extends Object
implements Processor<S>


Field Summary
protected static StringManager sm
           
 
Constructor Summary
protected UpgradeProcessor(UpgradeInbound upgradeInbound)
           
 
Method Summary
 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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

sm

protected static final StringManager sm
Constructor Detail

UpgradeProcessor

protected UpgradeProcessor(UpgradeInbound upgradeInbound)
Method Detail

flush

public abstract void flush()
                    throws IOException
Throws:
IOException

write

public abstract void write(int b)
                    throws IOException
Throws:
IOException

write

public abstract void write(byte[] b,
                           int off,
                           int len)
                    throws IOException
Throws:
IOException

read

public abstract int read()
                  throws IOException
This is always a blocking read of a single byte.

Returns:
The next byte or -1 if the end of the input is reached.
Throws:
IOException - If a problem occurs trying to read from the input

read

public abstract int read(boolean block,
                         byte[] bytes,
                         int off,
                         int len)
                  throws IOException
Read up to len bytes from the input in either blocking or non-blocking mode (where non-blocking is supported). If the input does not support non-blocking reads, a blcoking read will be performed.

Parameters:
block -
bytes -
off -
len -
Returns:
The number of bytes read or -1 if the end of the input is reached. Non-blocking reads may return zero if no data is available. Blocking reads never return zero.
Throws:
IOException - If a problem occurs trying to read from the input

getUpgradeInbound

public final UpgradeInbound getUpgradeInbound()
Specified by:
getUpgradeInbound in interface Processor<S>

upgradeDispatch

public final AbstractEndpoint.Handler.SocketState upgradeDispatch()
                                                           throws IOException
Specified by:
upgradeDispatch in interface Processor<S>
Throws:
IOException

isUpgrade

public final boolean isUpgrade()
Specified by:
isUpgrade in interface Processor<S>

recycle

public final void recycle(boolean socketClosing)
Specified by:
recycle in interface Processor<S>

getExecutor

public final Executor getExecutor()
Specified by:
getExecutor in interface Processor<S>

process

public final AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socketWrapper)
                                                   throws IOException
Specified by:
process in interface Processor<S>
Throws:
IOException

event

public final AbstractEndpoint.Handler.SocketState event(SocketStatus status)
                                                 throws IOException
Specified by:
event in interface Processor<S>
Throws:
IOException

asyncDispatch

public final AbstractEndpoint.Handler.SocketState asyncDispatch(SocketStatus status)
Specified by:
asyncDispatch in interface Processor<S>

asyncPostProcess

public final AbstractEndpoint.Handler.SocketState asyncPostProcess()
Specified by:
asyncPostProcess in interface Processor<S>

isComet

public final boolean isComet()
Specified by:
isComet in interface Processor<S>

isAsync

public final boolean isAsync()
Specified by:
isAsync in interface Processor<S>

getRequest

public final Request getRequest()
Specified by:
getRequest in interface Processor<S>

setSslSupport

public final void setSslSupport(SSLSupport sslSupport)
Specified by:
setSslSupport in interface Processor<S>

Apache Tomcat 7.0.39

Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.