public class UDPNIOServerConnection extends UDPNIOConnection
Connection
implementation
for the UDPNIOTransport
Connection.CloseListener, Connection.CloseType
asyncReadQueue, asyncWriteQueue, attributes, channel, connectCloseSemaphor, isBlocking, isStandalone, maxAsyncWriteQueueSize, monitoringConfig, NOTIFICATION_CLOSED_COMPLETE, NOTIFICATION_INITIALIZED, processor, processorSelector, readTimeoutMillis, selectionKey, selectorRunner, transport, writeTimeoutMillis, zeroByteReadCount
Constructor and Description |
---|
UDPNIOServerConnection(UDPNIOTransport transport,
DatagramChannel channel) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeGracefully0(CompletionHandler<Closeable> completionHandler,
CloseReason closeReason) |
Processor |
getProcessor()
Gets the default
Processor , which will process Connection
I/O events. |
ProcessorSelector |
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. |
protected void |
preClose() |
void |
register() |
protected void |
terminate0(CompletionHandler<Closeable> completionHandler,
CloseReason closeReason) |
void |
unbind(CompletionHandler<Closeable> completionHandler) |
block, canWrite, canWrite, drop, drop, dropAll, enableInitialOpRead, getLocalAddress, getPeerAddress, getReadBufferSize, getWriteBufferSize, isConnected, join, join, notifyCanWrite, notifyCanWrite, notifyReady, onConnect, onRead, onWrite, resetProperties, setReadBufferSize, setSelectionKey, setSelectorRunner, setWriteBufferSize, toString, unblock
addCloseListener, addCloseListener, assertOpen, attachToSelectorRunner, checkEmptyRead, close, close, closeSilently, closeWithReason, configureBlocking, configureStandalone, detachSelectorRunner, disableIOEvent, doClose, enableIOEvent, executeInEventThread, getAsyncReadQueue, getAsyncWriteQueue, getAttributes, getChannel, getCloseReason, getMaxAsyncWriteQueueSize, getMemoryManager, getMonitoringConfig, getReadTimeout, getSelectionKey, getSelectorRunner, getTransport, getWriteTimeout, isBlocking, isClosed, isOpen, isStandalone, notifyConnectionError, notifyIOEventDisabled, notifyIOEventEnabled, notifyIOEventReady, notifyProbesAccept, notifyProbesBind, notifyProbesClose, notifyProbesConnect, notifyProbesError, notifyProbesRead, notifyProbesWrite, obtainProcessor, obtainProcessorState, read, read, removeCloseListener, removeCloseListener, setChannel, setMaxAsyncWriteQueueSize, setProcessor, setProcessorSelector, setReadTimeout, setWriteTimeout, simulateIOEvent, terminate, terminateSilently, terminateWithReason, write, write, write, write, write
public UDPNIOServerConnection(UDPNIOTransport transport, DatagramChannel channel)
public Processor getProcessor()
Connection
Processor
, which will process Connection
I/O events.
If Processor
is null, - then Transport
will try
to get Processor
using Connection
's
ProcessorSelector.select(IOEvent, Connection)
. If
ProcessorSelector
, associated withthe Connection
is also
null - Transport
will try to get Processor
using own settings.getProcessor
in interface Connection<SocketAddress>
getProcessor
in class NIOConnection
Processor
, which will process
Connection
I/O events.public ProcessorSelector getProcessorSelector()
Connection
ProcessorSelector
, which will be used to get
Processor
to process Connection
I/O events, in case if
this Connection
's Processor
is null.getProcessorSelector
in interface Connection<SocketAddress>
getProcessorSelector
in class NIOConnection
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 register() throws IOException
IOException
protected void closeGracefully0(CompletionHandler<Closeable> completionHandler, CloseReason closeReason)
closeGracefully0
in class NIOConnection
protected void terminate0(CompletionHandler<Closeable> completionHandler, CloseReason closeReason)
terminate0
in class NIOConnection
public void unbind(CompletionHandler<Closeable> completionHandler)
protected void preClose()
preClose
in class NIOConnection
Copyright © 2015 Oracle Corporation. All rights reserved.