Grizzly NIO 5.0.2 · org.glassfish.grizzly.nio.NIOConnection

Modifier and Type	Class and Description
private static class	NIOConnection.ProcessorStatesMap Map, which contains `Processor`s and their states related to this `Connection`.

Modifier and Type	Field and Description
private volatile TaskQueue<AsyncReadQueueRecord>	asyncReadQueue
private final TaskQueue<AsyncWriteQueueRecord>	asyncWriteQueue
protected final AttributeHolder	attributes
protected volatile SelectableChannel	channel
private volatile GrizzlyFuture<CloseReason>	closeFuture
private final List<CloseListener<T extends Closeable, C extends ICloseType>>	closeListeners
private volatile CloseReason	closeReason
private static final AtomicReferenceFieldUpdater<NIOConnection, CloseReason>	closeReasonUpdater
private volatile Object	connectCloseSemaphore
protected static final AtomicReferenceFieldUpdater<NIOConnection, Object>	connectCloseSemaphoreUpdater Semaphore responsible for connect/close notification
private static final AtomicLong	CONNECTION_ID_GENERATOR
private final long	id
protected volatile boolean	isBlocking
private final AtomicBoolean	isCloseScheduled closeTypeFlag, "null" value means the connection is open.
private boolean	isInitialReadRequired Is initial OP_READ enabling required for the connection
protected volatile boolean	isStandalone
private static final Logger	LOGGER
private static final short	MAX_ZERO_READ_COUNT
protected volatile int	maxAsyncWriteQueueSize
protected final DefaultMonitoringConfig<ConnectionProbe>	monitoringConfig Connection probes
protected static final Object	NOTIFICATION_CLOSED_COMPLETE
protected static final Object	NOTIFICATION_INITIALIZED
protected volatile Processor<E extends Context>	processor
protected volatile ProcessorSelector	processorSelector
private final NIOConnection.ProcessorStatesMap	processorStateStorage Storage contains states of different Processors this Connection is associated with.
private final SelectorHandler.Task	readSimulatorRunnable
protected volatile long	readTimeoutMillis
protected volatile SelectionKey	selectionKey
protected volatile SelectorRunner	selectorRunner
protected final NIOTransport	transport
private static final boolean	WIN32
private final SelectorHandler.Task	writeSimulatorRunnable
protected volatile long	writeTimeoutMillis
protected short	zeroByteReadCount

Access	Constructor and Description
public	NIOConnection(final NIOTransport transport)

Method Summary

Modifier and Type	Method and Description
public void	addCloseListener(final CloseListener<T extends Closeable, C extends ICloseType> closeListener) Implements org.glassfish.grizzly.Connection.addCloseListener. Add the `CloseListener`, which will be notified once `Connection` will be closed.
public void	addCloseListener(Connection.CloseListener closeListener) Implements org.glassfish.grizzly.Connection.addCloseListener. References Deprecated `Connection.CloseListener` is deprecated or references (maybe indirectly) at least one deprecated element. Add the `CloseListener`, which will be notified once `Connection` will be closed.
public void	assertOpen() Implements org.glassfish.grizzly.Connection.assertOpen. Checks if this `Connection` is open and ready to be used.
public void	attachToSelectorRunner(final SelectorRunner selectorRunner)
protected final void	checkEmptyRead(final int size)
public GrizzlyFuture<Closeable>	close() Implements org.glassfish.grizzly.Connection.close. Gracefully close the `Connection`
public void	close(final CompletionHandler<Closeable> completionHandler) Implements org.glassfish.grizzly.Connection.close. Deprecated please use `close()` with the following `GrizzlyFuture#addCompletionHandler(org.glassfish.grizzly.CompletionHandler)` call Gracefully close the `Connection`
public GrizzlyFuture<CloseReason>	closeFuture() Implements org.glassfish.grizzly.Closeable.closeFuture.
protected void	closeGracefully0(final CompletionHandler<Closeable> completionHandler, CloseReason closeReason)
public final void	closeSilently() Implements org.glassfish.grizzly.Connection.closeSilently. Gracefully close the `Connection` silently, no notification required on completion or failure.
public void	closeWithReason(final IOException reason) Implements org.glassfish.grizzly.Connection.closeWithReason. Gracefully closes the `Connection` and provides the reason description.
public void	configureBlocking(boolean isBlocking) Implements org.glassfish.grizzly.Connection.configureBlocking. Sets the `Connection` mode.
public synchronized void	configureStandalone(boolean isStandalone) Implements org.glassfish.grizzly.Connection.configureStandalone.
public void	detachSelectorRunner()
public final void	disableIOEvent(final IOEvent ioEvent) Implements org.glassfish.grizzly.Connection.disableIOEvent.
protected void	doClose() Do the actual connection close.
protected void	enableInitialOpRead() Enables OP_READ if it has never been enabled before.
public final void	enableIOEvent(final IOEvent ioEvent) Implements org.glassfish.grizzly.Connection.enableIOEvent.
public void	executeInEventThread(final IOEvent event, final Runnable runnable) Implements org.glassfish.grizzly.Connection.executeInEventThread. Executes the `Runnable` in the thread, responsible for running the given type of event on this `Connection`.
public TaskQueue<AsyncReadQueueRecord>	getAsyncReadQueue()
public TaskQueue<AsyncWriteQueueRecord>	getAsyncWriteQueue()
public AttributeHolder	getAttributes() Implements org.glassfish.grizzly.attributes.AttributeStorage.getAttributes. Get associated `AttributeHolder`.
public SelectableChannel	getChannel()
public CloseReason	getCloseReason() Implements org.glassfish.grizzly.Connection.getCloseReason. Returns `CloseReason` if this `Connection` has been closed, or `null` otherwise.
public long	getId() Implements org.glassfish.grizzly.Connection.getId. Returns id of this instance, unique in the context of the JVM and the implementation class.
public int	getMaxAsyncWriteQueueSize() Implements org.glassfish.grizzly.Connection.getMaxAsyncWriteQueueSize. Get the max size (in bytes) of asynchronous write queue associated with connection.
public MemoryManager<?>	getMemoryManager() Implements org.glassfish.grizzly.Connection.getMemoryManager.
public final MonitoringConfig<ConnectionProbe>	getMonitoringConfig() Implements org.glassfish.grizzly.Connection.getMonitoringConfig. Return the object associated `MonitoringConfig`.
public Processor<E extends Context>	getProcessor() Implements org.glassfish.grizzly.Connection.getProcessor. Gets the default `Processor`, which will process `Connection` I/O events.
public ProcessorSelector	getProcessorSelector() Implements org.glassfish.grizzly.Connection.getProcessorSelector. Gets the default `ProcessorSelector`, which will be used to get `Processor` to process `Connection` I/O events, in case if this `Connection`'s `Processor` is `null`.
public long	getReadTimeout(TimeUnit timeUnit) Implements org.glassfish.grizzly.Connection.getReadTimeout. Returns the current value for the blocking read timeout converted to the provided `TimeUnit` specification.
public SelectionKey	getSelectionKey()
public SelectorRunner	getSelectorRunner()
public Transport	getTransport() Implements org.glassfish.grizzly.Connection.getTransport. Get the `Transport`, to which this `Connection` belongs to.
public long	getWriteTimeout(TimeUnit timeUnit) Implements org.glassfish.grizzly.Connection.getWriteTimeout. Returns the current value for the blocking write timeout converted to the provided `TimeUnit` specification.
private void	invokeCloseListener(final CloseListener<T extends Closeable, C extends ICloseType> closeListener, final CloseType closeType) References Deprecated `CloseType` is deprecated or references (maybe indirectly) at least one deprecated element.
public boolean	isBlocking() Implements org.glassfish.grizzly.Connection.isBlocking.
public boolean	isClosed()
public boolean	isOpen() Implements org.glassfish.grizzly.Connection.isOpen. Is `Connection` open and ready.
public boolean	isStandalone() Implements org.glassfish.grizzly.Connection.isStandalone.
private void	notifyCloseListeners(final CloseReason closeReason) Notify all close listeners
public void	notifyConnectionError(Throwable error) Implements org.glassfish.grizzly.Connection.notifyConnectionError. Method gets invoked, when error occur during the `Connection` lifecycle.
protected static void	notifyIOEventDisabled(NIOConnection the `Connection` event occurred on. connection, IOEvent the `IOEvent`. ioEvent) Notify registered `ConnectionProbe`s about the IO Event disabled event.
protected static void	notifyIOEventEnabled(NIOConnection the `Connection` event occurred on. connection, IOEvent the `IOEvent`. ioEvent) Notify registered `ConnectionProbe`s about the IO Event enabled event.
protected static void	notifyIOEventReady(NIOConnection the `Connection` event occurred on. connection, IOEvent the `IOEvent`. ioEvent) Notify registered `ConnectionProbe`s about the IO Event ready event.
protected static void	notifyProbesAccept(final NIOConnection the server `Connection`, which accepted the client connection. serverConnection, final NIOConnection the client `Connection`. clientConnection) Notify registered `ConnectionProbe`s about the accept event.
protected static void	notifyProbesBind(NIOConnection the `Connection` event occurred on. connection) Notify registered `ConnectionProbe`s about the bind event.
protected static void	notifyProbesClose(NIOConnection the `Connection` event occurred on. connection) Notify registered `ConnectionProbe`s about the close event.
protected static void	notifyProbesConnect(NIOConnection the `Connection` event occurred on. connection) Notify registered `ConnectionProbe`s about the connect event.
protected static void	notifyProbesError(NIOConnection the `Connection` event occurred on. connection, Throwable error) Notify registered `ConnectionProbe`s about the error.
protected static void	notifyProbesRead(NIOConnection connection, Buffer data, int size) Notify registered `ConnectionProbe`s about the read event.
protected static void	notifyProbesWrite(NIOConnection connection, Buffer data, long size) Notify registered `ConnectionProbe`s about the write event.
public Processor<E extends Context>	obtainProcessor(IOEvent ioEvent) Implements org.glassfish.grizzly.Connection.obtainProcessor. Gets the `Processor`, which will process `Connection` I/O event.
public <E> E	obtainProcessorState(final Processor<E extends Context> processor, final Supplier<E> factory) Implements org.glassfish.grizzly.Connection.obtainProcessorState. Returns the `Processor` state associated with this `Connection`.
pack-priv final void	onSelectionKeyUpdated(final SelectionKey newSelectionKey)
protected void	preClose()
public <M> GrizzlyFuture<ReadResult<M, SocketAddress>>	read() Implements org.glassfish.grizzly.Readable.read. Method reads data.
public <M> void	read(final CompletionHandler<ReadResult<M, SocketAddress>> completionHandler) Implements org.glassfish.grizzly.Readable.read.
public boolean	removeCloseListener(final CloseListener<T extends Closeable, C extends ICloseType> closeListener) Implements org.glassfish.grizzly.Connection.removeCloseListener. Remove the `CloseListener`.
public boolean	removeCloseListener(Connection.CloseListener closeListener) Implements org.glassfish.grizzly.Connection.removeCloseListener. References Deprecated `Connection.CloseListener` is deprecated or references (maybe indirectly) at least one deprecated element. Remove the `CloseListener`.
protected void	setChannel(SelectableChannel channel)
public void	setMaxAsyncWriteQueueSize(int maxAsyncWriteQueueSize) Implements org.glassfish.grizzly.Connection.setMaxAsyncWriteQueueSize. Set the max size (in bytes) of asynchronous write queue associated with connection.
pack-priv void	setMonitoringProbes(final ConnectionProbe[] monitoringProbes) Set the monitoringProbes array directly.
public void	setProcessor(Processor<E extends Context> preferableProcessor) Implements org.glassfish.grizzly.Connection.setProcessor. Sets the default `Processor`, which will process `Connection` I/O events.
public void	setProcessorSelector(final ProcessorSelector preferableProcessorSelector) Implements org.glassfish.grizzly.Connection.setProcessorSelector. Sets the default `ProcessorSelector`, which will be used to get `Processor` to process `Connection` I/O events, in case if this `Connection`'s `Processor` is `null`.
public void	setReadTimeout(long timeout, TimeUnit timeUnit) Implements org.glassfish.grizzly.Connection.setReadTimeout. Specifies the timeout for the blocking reads.
protected void	setSelectionKey(SelectionKey selectionKey)
protected void	setSelectorRunner(SelectorRunner selectorRunner)
public void	setWriteTimeout(long timeout, TimeUnit timeUnit) Implements org.glassfish.grizzly.Connection.setWriteTimeout. Specifies the timeout for the blocking writes.
public void	simulateIOEvent(final IOEvent ioEvent) Implements org.glassfish.grizzly.Connection.simulateIOEvent.
public GrizzlyFuture<Closeable>	terminate() Implements org.glassfish.grizzly.Connection.terminate. Close the `Connection`
protected void	terminate0(final CompletionHandler<Closeable> completionHandler, final CloseReason reason)
public void	terminateSilently() Implements org.glassfish.grizzly.Connection.terminateSilently. Close the `Connection` silently, no notification required on completion or failure.
public void	terminateWithReason(final IOException reason) Implements org.glassfish.grizzly.Connection.terminateWithReason. Closes the `Connection` and provides the reason description.
public <M> GrizzlyFuture<WriteResult<M, SocketAddress>>	write(final M message) Implements org.glassfish.grizzly.Writeable.write. Method writes the `buffer`.
public <M> void	write(final M message, final CompletionHandler<WriteResult<M, SocketAddress>> completionHandler) Implements org.glassfish.grizzly.Writeable.write. Method writes the `buffer`.
public <M> void	write(final M message, CompletionHandler<WriteResult<M, SocketAddress>> completionHandler, PushBackHandler pushbackHandler) Implements org.glassfish.grizzly.Writeable.write. Deprecated Method writes the `buffer`.
public <M> void	write(final SocketAddress dstAddress, final M message, final CompletionHandler<WriteResult<M, SocketAddress>> completionHandler) Implements org.glassfish.grizzly.Writeable.write. Method writes the `buffer` to the specific address.
public <M> void	write(final SocketAddress dstAddress, final M message, final CompletionHandler<WriteResult<M, SocketAddress>> completionHandler, final PushBackHandler pushbackHandler) Implements org.glassfish.grizzly.Writeable.write. Deprecated Method writes the `buffer` to the specific address.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

public abstract Class NIOConnection

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary