Package org.apache.hc.core5.reactor

Class InternalDataChannel

java.lang.Object

org.apache.hc.core5.reactor.InternalChannel

org.apache.hc.core5.reactor.InternalDataChannel

All Implemented Interfaces:

Closeable, AutoCloseable, ByteChannel, Channel, ReadableByteChannel, WritableByteChannel, SocketModalCloseable, ModalCloseable, IOSession, ProtocolIOSession, TransportSecurityLayer, Identifiable

final class InternalDataChannel
extends InternalChannel
implements ProtocolIOSession

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hc.core5.reactor.IOSession

IOSession.Status

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	closed
private final Queue<InternalDataChannel>	closedSessions
private final AtomicReference<IOSession>	currentSessionRef
private final AtomicReference<IOEventHandler>	eventHandlerRef
private final NamedEndpoint	initialEndpoint
private final IOSession	ioSession
private final Decorator<IOSession>	ioSessionDecorator
private final ConcurrentMap<String,ProtocolUpgradeHandler>	protocolUpgradeHandlerMap
private final IOSessionListener	sessionListener
private final AtomicReference<SSLIOSession>	tlsSessionRef

Constructor Summary

Constructors

Constructor	Description
InternalDataChannel(IOSession ioSession, NamedEndpoint initialEndpoint, Decorator<IOSession> ioSessionDecorator, IOSessionListener sessionListener, Queue<InternalDataChannel> closedSessions)

Method Summary

Modifier and Type	Method	Description
ByteChannel	channel()	Returns the underlying I/O channel associated with this session.
void	clearEvent(int op)	Clears interest in a particular I/O event type by updating the event mask associated with the session.
void	close()	Terminates the session gracefully and closes the underlying I/O channel.
void	close(CloseMode closeMode)	Closes this process or endpoint and releases any system resources associated with it.
(package private) void	disconnected()
void	enqueue(Command command, Command.Priority priority)	Inserts Command at the end of the command queue.
private IOEventHandler	ensureHandler(IOSession session)
int	getEventMask()	Returns mask of I/O evens this session declared interest in.
IOEventHandler	getHandler()	Returns event handler associated with the session.
String	getId()
NamedEndpoint	getInitialEndpoint()
long	getLastEventTime()	Returns timestamp of the last I/O event including socket timeout reset.
long	getLastReadTime()	Returns timestamp of the last read event.
long	getLastWriteTime()	Returns timestamp of the last write event.
SocketAddress	getLocalAddress()	Returns local address.
Lock	getLock()	Returns session lock that should be used by I/O event handlers to synchronize access to the session.
SocketAddress	getRemoteAddress()	Returns address of the remote peer.
Timeout	getSocketTimeout()	Returns value of the socket timeout in milliseconds.
IOSession.Status	getStatus()	Returns status of the session:
(package private) Timeout	getTimeout()
TlsDetails	getTlsDetails()	Returns details of a fully established TLS session.
boolean	hasCommands()	Tests if there enqueued commands pending execution.
boolean	isOpen()
(package private) void	onException(Exception cause)
(package private) void	onIOEvent(int readyOps)
(package private) void	onTimeout(Timeout timeout)
(package private) void	onTLSSessionEnd(SSLIOSession sslSession)
(package private) void	onTLSSessionStart(SSLIOSession sslSession)
Command	poll()	Removes first Command from the command queue if available.
int	read(ByteBuffer dst)
void	registerProtocol(String protocolId, ProtocolUpgradeHandler upgradeHandler)	Registers protocol upgrade handler with the given application protocol ID.
void	setEvent(int op)	Declares interest in a particular I/O event type by updating the event mask associated with the session.
void	setEventMask(int ops)	Declares interest in I/O event notifications by setting the event mask associated with the session
void	setSocketTimeout(Timeout timeout)	Sets value of the socket timeout in milliseconds.
void	startTls(SSLContext sslContext, NamedEndpoint endpoint, SSLBufferMode sslBufferMode, SSLSessionInitializer initializer, SSLSessionVerifier verifier, Timeout handshakeTimeout)	Starts TLS session over an existing network connection with the given SSL context.
void	startTls(SSLContext sslContext, NamedEndpoint endpoint, SSLBufferMode sslBufferMode, SSLSessionInitializer initializer, SSLSessionVerifier verifier, Timeout handshakeTimeout, FutureCallback<TransportSecurityLayer> callback)	Starts TLS session over an existing network connection with the given SSL context.
void	switchProtocol(String protocolId, FutureCallback<ProtocolIOSession> callback)	Switches this I/O session to the application protocol with the given ID.
String	toString()
void	updateReadTime()	Updates the timestamp of the last read event
void	updateWriteTime()	Updates the timestamp of the last write event
void	upgrade(IOEventHandler handler)	Upgrades event handler associated with the session.
int	write(ByteBuffer src)

Methods inherited from class org.apache.hc.core5.reactor.InternalChannel

checkTimeout, handleIOEvent

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

ioSession

private final IOSession ioSession

initialEndpoint

private final NamedEndpoint initialEndpoint

ioSessionDecorator

private final Decorator<IOSession> ioSessionDecorator

sessionListener

private final IOSessionListener sessionListener

closedSessions

private final Queue<InternalDataChannel> closedSessions

tlsSessionRef

private final AtomicReference<SSLIOSession> tlsSessionRef

currentSessionRef

private final AtomicReference<IOSession> currentSessionRef

eventHandlerRef

private final AtomicReference<IOEventHandler> eventHandlerRef

protocolUpgradeHandlerMap

private final ConcurrentMap<String,ProtocolUpgradeHandler> protocolUpgradeHandlerMap

closed

private final AtomicBoolean closed

Constructor Details

InternalDataChannel

InternalDataChannel(IOSession ioSession,
 NamedEndpoint initialEndpoint,
 Decorator<IOSession> ioSessionDecorator,
 IOSessionListener sessionListener,
 Queue<InternalDataChannel> closedSessions)

Method Details

getId

public String getId()

Specified by:

getId in interface Identifiable

getInitialEndpoint

public NamedEndpoint getInitialEndpoint()

Specified by:

getInitialEndpoint in interface ProtocolIOSession

getHandler

public IOEventHandler getHandler()

Description copied from interface: IOSession

Returns event handler associated with the session.

Specified by:

getHandler in interface IOSession

upgrade

public void upgrade(IOEventHandler handler)

Description copied from interface: IOSession

Upgrades event handler associated with the session.

Specified by:

upgrade in interface IOSession

ensureHandler

private IOEventHandler ensureHandler(IOSession session)

onIOEvent

void onIOEvent(int readyOps)
        throws IOException

Specified by:

onIOEvent in class InternalChannel

Throws:

IOException

getTimeout

Timeout getTimeout()

Specified by:

getTimeout in class InternalChannel

onTimeout

void onTimeout(Timeout timeout)
        throws IOException

Specified by:

onTimeout in class InternalChannel

Throws:

IOException

onException

void onException(Exception cause)

Specified by:

onException in class InternalChannel

onTLSSessionStart

void onTLSSessionStart(SSLIOSession sslSession)

onTLSSessionEnd

void onTLSSessionEnd(SSLIOSession sslSession)

disconnected

void disconnected()

startTls

public void startTls(SSLContext sslContext,
 NamedEndpoint endpoint,
 SSLBufferMode sslBufferMode,
 SSLSessionInitializer initializer,
 SSLSessionVerifier verifier,
 Timeout handshakeTimeout)

Description copied from interface: TransportSecurityLayer

Starts TLS session over an existing network connection with the given SSL context. NamedEndpoint details are applicable for client side connections and are used for host name verification, when supported by the SSL engine.

Specified by:

startTls in interface TransportSecurityLayer

Parameters:

sslContext - SSL context to be used for this session.

endpoint - optional endpoint details for outgoing client side connections.

sslBufferMode - SSL buffer management mode.

initializer - SSL session initialization callback.

verifier - SSL session verification callback.

handshakeTimeout - the timeout to use while performing the TLS handshake; may be null.

startTls

public void startTls(SSLContext sslContext,
 NamedEndpoint endpoint,
 SSLBufferMode sslBufferMode,
 SSLSessionInitializer initializer,
 SSLSessionVerifier verifier,
 Timeout handshakeTimeout,
 FutureCallback<TransportSecurityLayer> callback)

Description copied from interface: TransportSecurityLayer

Starts TLS session over an existing network connection with the given SSL context. NamedEndpoint details are applicable for client side connections and are used for host name verification, when supported by the SSL engine.

Specified by:

startTls in interface TransportSecurityLayer

Parameters:

sslContext - SSL context to be used for this session.

endpoint - optional endpoint details for outgoing client side connections.

sslBufferMode - SSL buffer management mode.

initializer - SSL session initialization callback.

verifier - SSL session verification callback.

handshakeTimeout - the timeout to use while performing the TLS handshake; may be null.

getTlsDetails

public TlsDetails getTlsDetails()

Description copied from interface: TransportSecurityLayer

Returns details of a fully established TLS session.

Specified by:

getTlsDetails in interface TransportSecurityLayer

Returns:

TLS session details.

getLock

public Lock getLock()

Description copied from interface: IOSession

Returns session lock that should be used by I/O event handlers to synchronize access to the session.

Specified by:

getLock in interface IOSession

close

public void close()

Description copied from interface: IOSession

Terminates the session gracefully and closes the underlying I/O channel. This method ensures that session termination handshake, such as the one used by the SSL/TLS protocol, is correctly carried out.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Specified by:

close in interface IOSession

close

public void close(CloseMode closeMode)

Description copied from interface: ModalCloseable

Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.

Specified by:

close in interface ModalCloseable

Parameters:

closeMode - How to close the receiver.

getStatus

public IOSession.Status getStatus()

Description copied from interface: IOSession

Returns status of the session:

IOSession.Status.ACTIVE: session is active.

IOSession.Status.CLOSING: session is being closed.

IOSession.Status.CLOSED: session has been terminated.

Specified by:

getStatus in interface IOSession

Returns:

session status.

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

enqueue

public void enqueue(Command command,
 Command.Priority priority)

Description copied from interface: IOSession

Inserts Command at the end of the command queue.

Specified by:

enqueue in interface IOSession

hasCommands

public boolean hasCommands()

Description copied from interface: IOSession

Tests if there enqueued commands pending execution.

Specified by:

hasCommands in interface IOSession

poll

public Command poll()

Description copied from interface: IOSession

Removes first Command from the command queue if available.

Specified by:

poll in interface IOSession

channel

public ByteChannel channel()

Description copied from interface: IOSession

Returns the underlying I/O channel associated with this session.

Specified by:

channel in interface IOSession

Returns:

the I/O channel.

getRemoteAddress

public SocketAddress getRemoteAddress()

Description copied from interface: IOSession

Returns address of the remote peer.

Specified by:

getRemoteAddress in interface IOSession

Returns:

socket address.

getLocalAddress

public SocketAddress getLocalAddress()

Description copied from interface: IOSession

Returns local address.

Specified by:

getLocalAddress in interface IOSession

Returns:

socket address.

getEventMask

public int getEventMask()

Description copied from interface: IOSession

Returns mask of I/O evens this session declared interest in.

Specified by:

getEventMask in interface IOSession

Returns:

I/O event mask.

setEventMask

public void setEventMask(int ops)

Description copied from interface: IOSession

Declares interest in I/O event notifications by setting the event mask associated with the session

Specified by:

setEventMask in interface IOSession

Parameters:

ops - new I/O event mask.

setEvent

public void setEvent(int op)

Description copied from interface: IOSession

Declares interest in a particular I/O event type by updating the event mask associated with the session.

Specified by:

setEvent in interface IOSession

Parameters:

op - I/O event type.

clearEvent

public void clearEvent(int op)

Description copied from interface: IOSession

Clears interest in a particular I/O event type by updating the event mask associated with the session.

Specified by:

clearEvent in interface IOSession

Parameters:

op - I/O event type.

getSocketTimeout

public Timeout getSocketTimeout()

Description copied from interface: IOSession

Returns value of the socket timeout in milliseconds. The value of 0 signifies the session cannot time out.

Specified by:

getSocketTimeout in interface IOSession

Specified by:

getSocketTimeout in interface SocketModalCloseable

Returns:

socket timeout.

setSocketTimeout

public void setSocketTimeout(Timeout timeout)

Description copied from interface: IOSession

Sets value of the socket timeout in milliseconds. The value of 0 signifies the session cannot time out.

Please note this operation may affect the last event time.

Specified by:

setSocketTimeout in interface IOSession

Specified by:

setSocketTimeout in interface SocketModalCloseable

Parameters:

timeout - socket timeout.

See Also:

• IOSession.getLastEventTime()

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface WritableByteChannel

Throws:

IOException

updateReadTime

public void updateReadTime()

Description copied from interface: IOSession

Updates the timestamp of the last read event

Specified by:

updateReadTime in interface IOSession

updateWriteTime

public void updateWriteTime()

Description copied from interface: IOSession

Updates the timestamp of the last write event

Specified by:

updateWriteTime in interface IOSession

getLastReadTime

public long getLastReadTime()

Description copied from interface: IOSession

Returns timestamp of the last read event.

Specified by:

getLastReadTime in interface IOSession

Returns:

timestamp.

getLastWriteTime

public long getLastWriteTime()

Description copied from interface: IOSession

Returns timestamp of the last write event.

Specified by:

getLastWriteTime in interface IOSession

Returns:

timestamp.

getLastEventTime

public long getLastEventTime()

Description copied from interface: IOSession

Returns timestamp of the last I/O event including socket timeout reset.

Specified by:

getLastEventTime in interface IOSession

Specified by:

getLastEventTime in class InternalChannel

Returns:

timestamp.

See Also:

• IOSession.getSocketTimeout()

switchProtocol

public void switchProtocol(String protocolId,
 FutureCallback<ProtocolIOSession> callback)

Description copied from interface: ProtocolIOSession

Switches this I/O session to the application protocol with the given ID.

Specified by:

switchProtocol in interface ProtocolIOSession

Parameters:

protocolId - the application protocol ID

callback - the result callback

registerProtocol

public void registerProtocol(String protocolId,
 ProtocolUpgradeHandler upgradeHandler)

Description copied from interface: ProtocolIOSession

Registers protocol upgrade handler with the given application protocol ID.

Specified by:

registerProtocol in interface ProtocolIOSession

Parameters:

protocolId - the application protocol ID

upgradeHandler - the upgrade handler.

toString

public String toString()

Overrides:

toString in class Object