Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.fork | |
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.relay | |
org.jgroups.protocols.rules | |
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.tests.rt.transports | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method and Description |
---|---|
void |
ReceiverAdapter.receive(MessageBatch batch) |
default void |
MessageListener.receive(MessageBatch batch)
Called when a batch of messages is received
|
JChannel |
JChannel.up(MessageBatch batch)
Callback invoked by the protocol stack to deliver a message batch
|
default void |
UpHandler.up(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
RequestCorrelator.receiveMessageBatch(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
ForkProtocolStack.up(MessageBatch batch) |
Modifier and Type | Field and Description |
---|---|
protected static BiConsumer<MessageBatch,Message> |
UNICAST3.BATCH_ACCUMULATOR |
protected static BiConsumer<MessageBatch,Message> |
SEQUENCER2.BATCH_ACCUMULATOR |
Modifier and Type | Method and Description |
---|---|
void |
Encrypt.Decrypter.accept(Message msg,
MessageBatch batch) |
protected SHUFFLE |
SHUFFLE.add(List<Message> queue,
MessageBatch batch,
Lock lock,
Consumer<Message> send_function) |
protected void |
UNICAST3.deliverBatch(MessageBatch batch) |
protected void |
SEQUENCER2.deliverBatch(MessageBatch batch) |
protected void |
UNICAST3.handleBatchFromSelf(MessageBatch batch,
UNICAST3.Entry entry) |
protected static int |
SIZE.numHeaders(MessageBatch batch) |
void |
TP.passBatchUp(MessageBatch batch,
boolean perform_cluster_name_matching,
boolean discard_own_mcast) |
protected void |
TP.processBatch(MessageBatch batch,
boolean oob,
boolean internal) |
protected static void |
SHUFFLE.shuffle(MessageBatch batch) |
void |
FORK.up(MessageBatch batch) |
void |
FRAG3.up(MessageBatch batch) |
void |
STOMP.up(MessageBatch batch) |
void |
UNICAST3.up(MessageBatch batch) |
void |
DUPL.up(MessageBatch batch) |
void |
BARRIER.up(MessageBatch batch) |
void |
TRACE.up(MessageBatch batch) |
void |
AUTH.up(MessageBatch batch) |
void |
ASYM_ENCRYPT.up(MessageBatch batch) |
void |
SIZE.up(MessageBatch batch) |
void |
FD.up(MessageBatch batch) |
void |
FlowControl.up(MessageBatch batch) |
void |
PERF.up(MessageBatch batch) |
void |
Encrypt.up(MessageBatch batch) |
void |
NAMING.up(MessageBatch batch) |
void |
RELAY.up(MessageBatch batch) |
void |
SNIFF.up(MessageBatch batch) |
void |
DELIVERY_TIME.up(MessageBatch batch) |
void |
SASL.up(MessageBatch batch) |
void |
DELAY.up(MessageBatch batch) |
void |
HDRS.up(MessageBatch batch) |
void |
COMPRESS.up(MessageBatch batch) |
void |
FD_ALL2.up(MessageBatch batch) |
void |
DISCARD.up(MessageBatch batch) |
void |
STATS.up(MessageBatch batch) |
void |
DROP.up(MessageBatch batch) |
void |
DAISYCHAIN.up(MessageBatch batch) |
void |
FRAG2.up(MessageBatch batch) |
void |
SEQUENCER2.up(MessageBatch batch) |
void |
SHUFFLE.up(MessageBatch batch) |
void |
EXAMPLE.up(MessageBatch batch) |
void |
SEQUENCER.up(MessageBatch batch) |
void |
FD_ALL.up(MessageBatch batch) |
void |
DH_KEY_EXCHANGE.up(MessageBatch batch) |
void |
FRAG.up(MessageBatch batch) |
void |
RSVP.up(MessageBatch batch) |
Modifier and Type | Field and Description |
---|---|
protected static BiConsumer<MessageBatch,Message> |
NAKACK2.BATCH_ACCUMULATOR |
Modifier and Type | Method and Description |
---|---|
protected void |
NAKACK2.deliverBatch(MessageBatch batch) |
void |
STABLE.up(MessageBatch batch) |
void |
NAKACK2.up(MessageBatch batch) |
void |
FLUSH.up(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
RELAY2.up(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
SUPERVISOR.up(MessageBatch batch) |
Modifier and Type | Method and Description |
---|---|
void |
MessageProcessingPolicy.process(MessageBatch batch,
boolean oob,
boolean internal)
Process a batch received from the transport
|
void |
ProtocolStack.up(MessageBatch batch) |
void |
Protocol.up(MessageBatch batch)
Sends up a multiple messages in a
MessageBatch . |
Modifier and Type | Method and Description |
---|---|
void |
JGroupsTransport.receive(MessageBatch batch) |
Modifier and Type | Field and Description |
---|---|
protected MessageBatch |
MaxOneThreadPerSender.Entry.batch |
protected MessageBatch |
SubmitToThreadPool.BatchHandler.batch |
Modifier and Type | Field and Description |
---|---|
protected IntFunction<MessageBatch> |
MaxOneThreadPerSender.Entry.batch_creator |
protected static ToIntBiFunction<Message,MessageBatch> |
MessageBatch.length_visitor |
protected static ToLongBiFunction<Message,MessageBatch> |
MessageBatch.total_size_visitor |
Modifier and Type | Method and Description |
---|---|
MessageBatch |
MessageBatch.add(Message msg) |
MessageBatch |
MessageBatch.add(MessageBatch batch) |
MessageBatch |
MessageBatch.clear() |
MessageBatch |
MessageBatch.clusterName(AsciiString name) |
MessageBatch |
MessageBatch.dest(Address dest) |
MessageBatch |
MessageBatch.mode(MessageBatch.Mode mode) |
MessageBatch |
MessageBatch.multicast(boolean flag) |
static MessageBatch[] |
Util.readMessageBatch(DataInput in,
boolean multicast)
Reads a list of messages into 4 MessageBatches:
regular
OOB
INTERNAL-OOB (INTERNAL and OOB)
INTERNAL (INTERNAL)
|
MessageBatch |
MessageBatch.remove(Message msg)
Removes the current message (found by indentity (==)) by nulling it in the message array
|
MessageBatch |
MessageBatch.remove(Predicate<Message> filter)
Removes all messages which match filter
|
MessageBatch |
MessageBatch.replace(Message existing_msg,
Message new_msg)
Replaces a message in the batch with another one
|
MessageBatch |
MessageBatch.replace(Predicate<Message> filter,
Message replacement,
boolean match_all)
Replaces all messages which match a given filter with a replacement message
|
MessageBatch |
MessageBatch.reset() |
MessageBatch |
MessageBatch.sender(Address sender) |
MessageBatch |
MessageBatch.setClusterName(AsciiString name) |
MessageBatch |
MessageBatch.setDest(Address dest) |
MessageBatch |
MessageBatch.setMode(MessageBatch.Mode mode) |
MessageBatch |
MessageBatch.setSender(Address sender) |
Modifier and Type | Method and Description |
---|---|
MessageBatch |
MessageBatch.add(MessageBatch batch) |
int |
MessageBatch.add(MessageBatch batch,
boolean resize)
Adds another batch to this one
|
protected boolean |
MaxOneThreadPerSender.Entry.allowedToSubmitToThreadPool(MessageBatch msg_batch) |
protected void |
MaxOneThreadPerSender.MessageTable.process(MessageBatch batch) |
protected void |
MaxOneThreadPerSender.Entry.process(MessageBatch batch) |
void |
MaxOneThreadPerSender.process(MessageBatch batch,
boolean oob,
boolean internal) |
void |
SubmitToThreadPool.process(MessageBatch batch,
boolean oob,
boolean internal) |
protected void |
SubmitToThreadPool.removeAndDispatchNonBundledMessages(MessageBatch oob_batch)
Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool.
|
protected void |
MaxOneThreadPerSender.Entry.submit(MessageBatch mb) |
int |
MessageBatch.transferFrom(MessageBatch other,
boolean clear)
Transfers messages from other to this batch.
|
protected boolean |
MaxOneThreadPerSender.Entry.workAvailable(MessageBatch msg_batch)
Called by
MaxOneThreadPerSender.BatchHandlerLoop . |
Modifier and Type | Method and Description |
---|---|
void |
MessageBatch.forEach(BiConsumer<Message,MessageBatch> consumer) |
<T> Collection<T> |
MessageBatch.map(BiFunction<Message,MessageBatch,T> visitor)
Applies a function to all messages and returns a list of the function results
|
Constructor and Description |
---|
BatchHandler(MessageBatch batch) |
BatchHandlerLoop(MessageBatch batch,
MaxOneThreadPerSender.Entry entry,
boolean loopback) |
Constructor and Description |
---|
Entry(IntFunction<MessageBatch> creator) |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.