public class SelectorIntraband extends BaseIntraband
| Modifier and Type | Class and Description |
|---|---|
protected class |
SelectorIntraband.RegisterCallable |
BaseIntraband.SendSyncDatagramCompletionHandler| Modifier and Type | Field and Description |
|---|---|
protected Thread |
pollingThread |
protected Queue<FutureTask<RegistrationReference>> |
registerQueue |
protected Selector |
selector |
protected static ThreadFactory |
threadFactory |
datagramReceiveHandlersReference, defaultTimeout, open, REPLIED_ENUM_SET, responseWaitingMap, sequenceIdGenerator, timeoutMap| Constructor and Description |
|---|
SelectorIntraband(long defaultTimeout) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
protected void |
doSendDatagram(RegistrationReference registrationReference,
Datagram datagram) |
RegistrationReference |
registerChannel(Channel channel) |
RegistrationReference |
registerChannel(ScatteringByteChannel scatteringByteChannel,
GatheringByteChannel gatheringByteChannel) |
protected void |
registerChannels() |
addResponseWaitingDatagram, cleanUpTimeoutResponseWaitingDatagrams, doSendSyncDatagram, ensureOpen, generateSequenceId, getDatagramReceiveHandlers, handleReading, handleWriting, isOpen, registerDatagramReceiveHandler, removeResponseWaitingDatagram, sendDatagram, sendDatagram, sendDatagram, sendSyncDatagram, sendSyncDatagram, unregisterDatagramReceiveHandlerprotected static final ThreadFactory threadFactory
protected final Thread pollingThread
protected final Queue<FutureTask<RegistrationReference>> registerQueue
protected final Selector selector
public SelectorIntraband(long defaultTimeout)
throws IOException
IOExceptionpublic void close()
throws InterruptedException,
IOException
close in interface Intrabandclose in class BaseIntrabandInterruptedExceptionIOExceptionpublic RegistrationReference registerChannel(Channel channel) throws IOException
IOExceptionpublic RegistrationReference registerChannel(ScatteringByteChannel scatteringByteChannel, GatheringByteChannel gatheringByteChannel) throws IOException
IOExceptionprotected void doSendDatagram(RegistrationReference registrationReference, Datagram datagram)
doSendDatagram in class BaseIntrabandprotected void registerChannels()