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, unregisterDatagramReceiveHandler
protected static final ThreadFactory threadFactory
protected final Thread pollingThread
protected final Queue<FutureTask<RegistrationReference>> registerQueue
protected final Selector selector
public SelectorIntraband(long defaultTimeout) throws IOException
IOException
public void close() throws InterruptedException, IOException
close
in interface Intraband
close
in class BaseIntraband
InterruptedException
IOException
public RegistrationReference registerChannel(Channel channel) throws IOException
IOException
public RegistrationReference registerChannel(ScatteringByteChannel scatteringByteChannel, GatheringByteChannel gatheringByteChannel) throws IOException
IOException
protected void doSendDatagram(RegistrationReference registrationReference, Datagram datagram)
doSendDatagram
in class BaseIntraband
protected void registerChannels()