Package org.glassfish.jersey.jdk.connector.internal

Class TransportFilter

java.lang.Object

org.glassfish.jersey.jdk.connector.internal.Filter<ByteBuffer,ByteBuffer,Void,ByteBuffer>

org.glassfish.jersey.jdk.connector.internal.TransportFilter

class TransportFilter
extends Filter<ByteBuffer,ByteBuffer,Void,ByteBuffer>

Writes and reads data to and from a socket. Only one write(ByteBuffer, org.glassfish.jersey.jdk.connector.internal.CompletionHandler) method call can be processed at a time. Only one _read(ByteBuffer) operation is supported at a time, another one is started only after the previous one has completed. Blocking in Filter.onRead(Object) or Filter.onConnect() method will result in data not being read from a socket until these methods have completed.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TransportFilter.QueuingExecutor	A thread pool executor that prefers creating new worker threads over queueing tasks until the maximum poll size has been reached, after which it will start queueing tasks.
private static class	TransportFilter.TransportThreadFactory	A default thread factory that gets used if ThreadPoolConfig.getThreadFactory() is not specified.

Field Summary

Fields

Modifier and Type	Field	Description
private static AsynchronousChannelGroup	channelGroup
private static ScheduledFuture<?>	closeWaitTask
private static final ScheduledExecutorService	connectionCloseScheduler
private final int	containerIdleTimeout
private static Integer	currentContainerIdleTimeout	Idle timeout that will be used when closing current channelGroup
private static ThreadPoolConfig	currentThreadPoolConfig	ThreadPoolConfig current channelGroup has been created with.
private final int	inputBufferSize
private static final Logger	LOGGER
private static final AtomicInteger	openedConnections
private AsynchronousSocketChannel	socketChannel
private final ThreadPoolConfig	threadPoolConfig

Fields inherited from class org.glassfish.jersey.jdk.connector.internal.Filter

downstreamFilter, upstreamFilter

Constructor Summary

Constructors

Constructor	Description
TransportFilter(int inputBufferSize, ThreadPoolConfig threadPoolConfig, int containerIdleTimeout)	Constructor.

Method Summary

Modifier and Type	Method	Description
private void	_read(ByteBuffer inputBuffer)
(package private) void	close()	Close the filter, invokes close operation on the next filter in the filter chain.
void	handleConnect(SocketAddress serverAddress, Filter upstreamFilter)	Handle Filter.connect(SocketAddress, Filter).
private void	initializeChannelGroup()
private void	scheduleClose()
(package private) void	startSsl()	Signal to turn on SSL, it is passed on in the filter chain until a filter responsible for SSL is reached.
private void	updateThreadPoolConfig()
(package private) void	write(ByteBuffer data, CompletionHandler<ByteBuffer> completionHandler)	Perform write operation for this filter and invokes write method on the next filter in the filter chain.

Methods inherited from class org.glassfish.jersey.jdk.connector.internal.Filter

connect, onConnect, onConnectionClosed, onError, onRead, onSslHandshakeCompleted, processConnect, processConnectionClosed, processError, processRead, processSslHandshakeCompleted

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final Logger LOGGER

openedConnections

private static final AtomicInteger openedConnections

connectionCloseScheduler

private static final ScheduledExecutorService connectionCloseScheduler

channelGroup

private static volatile AsynchronousChannelGroup channelGroup

closeWaitTask

private static volatile ScheduledFuture<?> closeWaitTask

currentThreadPoolConfig

private static volatile ThreadPoolConfig currentThreadPoolConfig

ThreadPoolConfig current channelGroup has been created with.

currentContainerIdleTimeout

private static volatile Integer currentContainerIdleTimeout

Idle timeout that will be used when closing current channelGroup

inputBufferSize

private final int inputBufferSize

threadPoolConfig

private final ThreadPoolConfig threadPoolConfig

containerIdleTimeout

private final int containerIdleTimeout

socketChannel

private volatile AsynchronousSocketChannel socketChannel

Constructor Details

TransportFilter

TransportFilter(int inputBufferSize,
 ThreadPoolConfig threadPoolConfig,
 int containerIdleTimeout)

Constructor.

If the channel group is not active (all connections have been closed and the shutdown timeout is running) and a new transport is created with tread pool configuration different from the one of the current thread pool, the current thread pool will be shut down and a new one created with the new configuration.

Parameters:

inputBufferSize - size of buffer to be allocated for reading data from a socket.

threadPoolConfig - thread pool configuration used for creating thread pool.

containerIdleTimeout - idle time after which the shared thread pool will be destroyed.

Method Details

write

void write(ByteBuffer data,
 CompletionHandler<ByteBuffer> completionHandler)

Description copied from class: Filter

Perform write operation for this filter and invokes write method on the next filter in the filter chain.

Overrides:

write in class Filter<ByteBuffer,ByteBuffer,Void,ByteBuffer>

Parameters:

data - on which write operation is performed.

completionHandler - will be invoked when the write operation is completed or has failed.

close

void close()

Description copied from class: Filter

Close the filter, invokes close operation on the next filter in the filter chain.

The filter is expected to clean up any allocated resources and pass the invocation to downstream filter.

Overrides:

close in class Filter<ByteBuffer,ByteBuffer,Void,ByteBuffer>

startSsl

void startSsl()

Description copied from class: Filter

Signal to turn on SSL, it is passed on in the filter chain until a filter responsible for SSL is reached.

Overrides:

startSsl in class Filter<ByteBuffer,ByteBuffer,Void,ByteBuffer>

handleConnect

public void handleConnect(SocketAddress serverAddress,
 Filter upstreamFilter)

Description copied from class: Filter

Handle Filter.connect(SocketAddress, Filter).

Overrides:

handleConnect in class Filter<ByteBuffer,ByteBuffer,Void,ByteBuffer>

Parameters:

serverAddress - an address where to connect (server or proxy).

upstreamFilter - a filter positioned upstream.

See Also:

• Filter.connect(SocketAddress, Filter)

updateThreadPoolConfig

private void updateThreadPoolConfig()

initializeChannelGroup

private void initializeChannelGroup()
                             throws IOException

Throws:

IOException

_read

private void _read(ByteBuffer inputBuffer)

scheduleClose

private void scheduleClose()