public class SslConnection.DecryptedEndPoint extends AbstractEndPoint
Constructor and Description |
---|
DecryptedEndPoint() |
Modifier and Type | Method and Description |
---|---|
void |
doClose() |
void |
doShutdownOutput() |
int |
fill(ByteBuffer buffer)
Fill the passed buffer with data from this endpoint.
|
boolean |
flush(ByteBuffer... appOuts)
Flush data from the passed header/buffer to this endpoint.
|
long |
getIdleTimeout()
Get the max idle time in ms.
|
InetSocketAddress |
getLocalAddress() |
InetSocketAddress |
getRemoteAddress() |
SslConnection |
getSslConnection() |
Object |
getTransport() |
protected WriteFlusher |
getWriteFlusher() |
boolean |
isInputShutdown()
Test if the input is shutdown.
|
boolean |
isOpen()
This abstract method should be called to check if idle timeouts
should still be checked.
|
boolean |
isOutputShutdown()
Test if output is shutdown.
|
protected void |
needsFillInterest() |
protected void |
onIncompleteFlush() |
void |
setConnection(Connection connection) |
void |
setIdleTimeout(long idleTimeout)
Set the idle timeout.
|
String |
toString() |
checkFill, checkFlush, close, close, doShutdownInput, fillInterested, getConnection, getCreatedTimeStamp, getFillInterest, isFillInterested, isOptimizedForDirectBuffers, onClose, onClose, onIdleExpired, onOpen, reset, shutdownInput, shutdownOutput, toConnectionString, toEndPointString, tryFillInterested, upgrade, write
checkIdleTimeout, getIdleFor, getIdleTimestamp, getScheduler, notIdle
public long getIdleTimeout()
EndPoint
The max idle time is the time the endpoint can be idle before extraordinary handling takes place.
getIdleTimeout
in interface EndPoint
getIdleTimeout
in class IdleTimeout
public void setIdleTimeout(long idleTimeout)
EndPoint
setIdleTimeout
in interface EndPoint
setIdleTimeout
in class IdleTimeout
idleTimeout
- the idle timeout in MS. Timeout <= 0 implies an infinite timeoutpublic boolean isOpen()
IdleTimeout
isOpen
in interface EndPoint
isOpen
in class AbstractEndPoint
public InetSocketAddress getLocalAddress()
EndPoint
is bound, or null
if this EndPoint
does not represent a network connection.public InetSocketAddress getRemoteAddress()
EndPoint
is bound, or null
if this EndPoint
does not represent a network connection.protected WriteFlusher getWriteFlusher()
getWriteFlusher
in class AbstractEndPoint
protected void onIncompleteFlush()
onIncompleteFlush
in class AbstractEndPoint
protected void needsFillInterest() throws IOException
needsFillInterest
in class AbstractEndPoint
IOException
public void setConnection(Connection connection)
setConnection
in interface EndPoint
setConnection
in class AbstractEndPoint
connection
- the Connection
associated with this EndPoint
EndPoint.getConnection()
,
EndPoint.upgrade(Connection)
public SslConnection getSslConnection()
public int fill(ByteBuffer buffer) throws IOException
EndPoint
buffer
- The buffer to fill. The position and limit are modified during the fill. After the
operation, the position is unchanged and the limit is increased to reflect the new data filled.int
value indicating the number of bytes
filled or -1 if EOF is read or the input is shutdown.IOException
- if the endpoint is closed.public boolean flush(ByteBuffer... appOuts) throws IOException
EndPoint
appOuts
- the buffers to flushIOException
- If the endpoint is closed or output is shutdown.public void doShutdownOutput()
doShutdownOutput
in class AbstractEndPoint
public boolean isOutputShutdown()
EndPoint
EndPoint.shutdownOutput()
or EndPoint.close()
.isOutputShutdown
in interface EndPoint
isOutputShutdown
in class AbstractEndPoint
public void doClose()
doClose
in class AbstractEndPoint
public Object getTransport()
public boolean isInputShutdown()
EndPoint
EndPoint.fill(ByteBuffer)
. Once the input is shutdown, all calls to
EndPoint.fill(ByteBuffer)
will return -1, until such time as the
end point is close, when they will return EofException
.isInputShutdown
in interface EndPoint
isInputShutdown
in class AbstractEndPoint
public String toString()
toString
in class AbstractEndPoint
Copyright © 1995–2017 Webtide. All rights reserved.