Modifier and Type | Field and Description |
---|---|
protected Map<Long,Datagram> |
BaseIntraband.responseWaitingMap |
Modifier and Type | Method and Description |
---|---|
protected static Datagram |
Datagram.createACKResponseDatagram(long sequenceId) |
protected static Datagram |
Datagram.createReceiveDatagram() |
static Datagram |
Datagram.createRequestDatagram(byte type,
byte[] data) |
static Datagram |
Datagram.createRequestDatagram(byte type,
ByteBuffer dataByteBuffer) |
static Datagram |
Datagram.createResponseDatagram(Datagram requestDatagram,
byte[] data) |
static Datagram |
Datagram.createResponseDatagram(Datagram requestDatagram,
ByteBuffer byteBuffer) |
protected Datagram |
BaseIntraband.doSendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram,
long timeout) |
Datagram |
ChannelContext.getReadingDatagram() |
Datagram |
ChannelContext.getWritingDatagram() |
protected Datagram |
BaseIntraband.removeResponseWaitingDatagram(Datagram responseDatagram) |
Datagram |
Intraband.sendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram) |
Datagram |
BaseIntraband.sendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram) |
Datagram |
Intraband.sendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram,
long timeout,
TimeUnit timeUnit) |
Datagram |
BaseIntraband.sendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram,
long timeout,
TimeUnit timeUnit) |
Datagram |
BaseIntraband.SendSyncDatagramCompletionHandler.waitResult(long timeout) |
Modifier and Type | Method and Description |
---|---|
Queue<Datagram> |
ChannelContext.getSendingQueue() |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseIntraband.addResponseWaitingDatagram(Datagram requestDatagram) |
static Datagram |
Datagram.createResponseDatagram(Datagram requestDatagram,
byte[] data) |
static Datagram |
Datagram.createResponseDatagram(Datagram requestDatagram,
ByteBuffer byteBuffer) |
protected abstract void |
BaseAsyncDatagramReceiveHandler.doReceive(RegistrationReference registrationReference,
Datagram datagram) |
protected abstract void |
BaseIntraband.doSendDatagram(RegistrationReference registrationReference,
Datagram datagram) |
protected Datagram |
BaseIntraband.doSendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram,
long timeout) |
void |
DatagramReceiveHandler.receive(RegistrationReference registrationReference,
Datagram datagram) |
void |
BaseAsyncDatagramReceiveHandler.receive(RegistrationReference registrationReference,
Datagram datagram) |
protected Datagram |
BaseIntraband.removeResponseWaitingDatagram(Datagram responseDatagram) |
void |
CompletionHandler.replied(A attachment,
Datagram datagram) |
void |
BaseIntraband.SendSyncDatagramCompletionHandler.replied(Object attachment,
Datagram datagram) |
void |
Intraband.sendDatagram(RegistrationReference registrationReference,
Datagram datagram) |
void |
BaseIntraband.sendDatagram(RegistrationReference registrationReference,
Datagram datagram) |
<A> void |
Intraband.sendDatagram(RegistrationReference registrationReference,
Datagram datagram,
A attachment,
EnumSet<CompletionHandler.CompletionType> completionTypes,
CompletionHandler<A> completionHandler) |
<A> void |
BaseIntraband.sendDatagram(RegistrationReference registrationReference,
Datagram datagram,
A attachment,
EnumSet<CompletionHandler.CompletionType> completionTypes,
CompletionHandler<A> completionHandler) |
<A> void |
Intraband.sendDatagram(RegistrationReference registrationReference,
Datagram datagram,
A attachment,
EnumSet<CompletionHandler.CompletionType> completionTypes,
CompletionHandler<A> completionHandler,
long timeout,
TimeUnit timeUnit) |
<A> void |
BaseIntraband.sendDatagram(RegistrationReference registrationReference,
Datagram datagram,
A attachment,
EnumSet<CompletionHandler.CompletionType> completionTypes,
CompletionHandler<A> completionHandler,
long timeout,
TimeUnit timeUnit) |
Datagram |
Intraband.sendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram) |
Datagram |
BaseIntraband.sendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram) |
Datagram |
Intraband.sendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram,
long timeout,
TimeUnit timeUnit) |
Datagram |
BaseIntraband.sendSyncDatagram(RegistrationReference registrationReference,
Datagram datagram,
long timeout,
TimeUnit timeUnit) |
void |
ChannelContext.setReadingDatagram(Datagram readingDatagram) |
void |
ChannelContext.setWritingDatagram(Datagram writingDatagram) |
Constructor and Description |
---|
ChannelContext(Queue<Datagram> sendingQueue) |
Modifier and Type | Method and Description |
---|---|
protected void |
ExecutorIntraband.doSendDatagram(RegistrationReference registrationReference,
Datagram datagram) |
Modifier and Type | Method and Description |
---|---|
protected void |
MailboxDatagramReceiveHandler.doReceive(RegistrationReference registrationReference,
Datagram datagram) |
Modifier and Type | Method and Description |
---|---|
protected void |
MessageDatagramReceiveHandler.doReceive(RegistrationReference registrationReference,
Datagram datagram) |
Modifier and Type | Method and Description |
---|---|
protected void |
SelectorIntraband.doSendDatagram(RegistrationReference registrationReference,
Datagram datagram) |
Modifier and Type | Method and Description |
---|---|
void |
IntrabandProxySkeleton.dispatch(RegistrationReference registrationReference,
Datagram datagram,
Deserializer deserializer) |
void |
AsyncIntrabandProxySkeleton.dispatch(RegistrationReference registrationReference,
Datagram datagram,
Deserializer deserializer) |
protected void |
IntrabandProxyDatagramReceiveHandler.doReceive(RegistrationReference registrationReference,
Datagram datagram) |
Modifier and Type | Method and Description |
---|---|
protected void |
RPCDatagramReceiveHandler.doReceive(RegistrationReference registrationReference,
Datagram datagram) |
void |
BootstrapRPCDatagramReceiveHandler.receive(RegistrationReference registrationReference,
Datagram datagram) |
void |
IntrabandRPCUtil.FutureCompletionHandler.replied(Object attachment,
Datagram datagram) |