public class UDPNIOServerConnection extends UDPNIOConnection
Connection
implementation
for the UDPNIOTransport
Connection.CloseListener, Connection.CloseType
asyncReadQueue, asyncWriteQueue, attributes, channel, closeTypeFlag, 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 |
---|---|
void |
close(CompletionHandler<Closeable> completionHandler)
Close the
Connection |
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() |
void |
unbind(CompletionHandler<Closeable> completionHandler) |
block, canWrite, canWrite, drop, drop, dropAll, getLocalAddress, getPeerAddress, getReadBufferSize, getWriteBufferSize, isConnected, join, join, notifyCanWrite, notifyCanWrite, notifyReady, onConnect, onRead, onWrite, resetProperties, setReadBufferSize, setSelectionKey, setSelectorRunner, setWriteBufferSize, toString, unblock
addCloseListener, addCloseListener, attachToSelectorRunner, checkEmptyRead, close, close0, closeSilently, configureBlocking, configureStandalone, detachSelectorRunner, disableIOEvent, enableIOEvent, getAsyncReadQueue, getAsyncWriteQueue, getAttributes, getChannel, getMaxAsyncWriteQueueSize, getMonitoringConfig, getReadTimeout, getSelectionKey, getSelectorRunner, getTransport, getWriteTimeout, isBlocking, 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, 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
public void close(CompletionHandler<Closeable> completionHandler)
Connection
Connection
close
in interface Closeable
close
in interface Connection<SocketAddress>
close
in class NIOConnection
completionHandler
- CompletionHandler
to be called, when
the connection is closed.public void unbind(CompletionHandler<Closeable> completionHandler)
protected void preClose()
preClose
in class NIOConnection
Copyright © 2014 Oracle Corporation. All rights reserved.