public class SelectorIntraband extends BaseIntraband
| Modifier and Type | Class and Description |
|---|---|
protected class |
SelectorIntraband.RegisterCallable |
BaseIntraband.SendSyncDatagramCompletionHandler| Modifier and Type | Field and Description |
|---|---|
protected java.lang.Thread |
pollingThread |
protected java.util.Queue<java.util.concurrent.FutureTask<RegistrationReference>> |
registerQueue |
protected java.nio.channels.Selector |
selector |
protected static java.util.concurrent.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(java.nio.channels.Channel channel) |
RegistrationReference |
registerChannel(java.nio.channels.ScatteringByteChannel scatteringByteChannel,
java.nio.channels.GatheringByteChannel gatheringByteChannel) |
protected void |
registerChannels() |
addResponseWaitingDatagram, cleanUpTimeoutResponseWaitingDatagrams, doSendSyncDatagram, ensureOpen, generateSequenceId, getDatagramReceiveHandlers, handleReading, handleWriting, isOpen, registerDatagramReceiveHandler, removeResponseWaitingDatagram, sendDatagram, sendDatagram, sendDatagram, sendSyncDatagram, sendSyncDatagram, unregisterDatagramReceiveHandlerprotected static final java.util.concurrent.ThreadFactory threadFactory
protected final java.lang.Thread pollingThread
protected final java.util.Queue<java.util.concurrent.FutureTask<RegistrationReference>> registerQueue
protected final java.nio.channels.Selector selector
public SelectorIntraband(long defaultTimeout)
throws java.io.IOException
java.io.IOExceptionpublic void close()
throws java.lang.InterruptedException,
java.io.IOException
close in interface Intrabandclose in class BaseIntrabandjava.lang.InterruptedExceptionjava.io.IOExceptionpublic RegistrationReference registerChannel(java.nio.channels.Channel channel) throws java.io.IOException
java.io.IOExceptionpublic RegistrationReference registerChannel(java.nio.channels.ScatteringByteChannel scatteringByteChannel, java.nio.channels.GatheringByteChannel gatheringByteChannel) throws java.io.IOException
java.io.IOExceptionprotected void doSendDatagram(RegistrationReference registrationReference, Datagram datagram)
doSendDatagram in class BaseIntrabandprotected void registerChannels()