Uses of Class
org.jgroups.util.MessageBatch

Packages that use MessageBatch

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
org.jgroups.protocols.relay
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of MessageBatch in org.jgroups

Methods in org.jgroups with parameters of type MessageBatch

Modifier and Type	Method	Description
default void	Receiver.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)

Uses of MessageBatch in org.jgroups.blocks

Methods in org.jgroups.blocks with parameters of type MessageBatch

Modifier and Type	Method	Description
protected void	RequestCorrelator.iterate(MessageBatch batch, boolean skip_excluded_msgs, boolean process_reqs, boolean process_rsps)
void	RequestCorrelator.receiveMessageBatch(MessageBatch batch)
void	MessageDispatcher.ProtocolAdapter.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.fork

Methods in org.jgroups.fork with parameters of type MessageBatch

Modifier and Type	Method	Description
void	ForkProtocolStack.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.protocols

Fields in org.jgroups.protocols with type parameters of type MessageBatch

Modifier and Type	Field	Description
protected static final BiConsumer<MessageBatch, Message>	ReliableMulticast.BATCH_ACCUMULATOR
protected static final BiConsumer<MessageBatch, Message>	ReliableUnicast.BATCH_ACCUMULATOR
protected static final BiConsumer<MessageBatch, Message>	SEQUENCER2.BATCH_ACCUMULATOR
protected static final BiConsumer<MessageBatch, Message>	UNICAST3.BATCH_ACCUMULATOR
protected final Map<Address, MessageBatch>	ReliableMulticast.cached_batches
protected final Map<Address, MessageBatch>	ReliableUnicast.cached_batches	To cache batches for sending messages up the stack (https://issues.redhat.com/browse/JGRP-2841).
protected final Map<Address, MessageBatch>	UNICAST3.cached_batches	To cache batches for sending messages up the stack (https://issues.redhat.com/browse/JGRP-2841)

Methods in org.jgroups.protocols with parameters of type MessageBatch

Modifier and Type	Method	Description
protected void	ReliableMulticast.deliverBatch(MessageBatch batch, ReliableMulticast.Entry entry)
protected void	ReliableUnicast.deliverBatch(MessageBatch batch, ReliableUnicast.Entry entry, Address original_dest)
protected void	SEQUENCER2.deliverBatch(MessageBatch batch)
protected void	UNICAST3.deliverBatch(MessageBatch batch)
protected void	ReliableUnicast.handleBatchFromSelf(MessageBatch batch, ReliableUnicast.Entry entry)
protected void	UNICAST3.handleBatchFromSelf(MessageBatch batch, UNICAST3.Entry entry)
protected void	ReliableMulticast.handleMessageBatch(MessageBatch mb)
void	TP.passBatchUp(MessageBatch batch, boolean perform_cluster_name_matching, boolean discard_own_mcast)
protected void	TP.processBatch(MessageBatch batch, boolean oob)
MsgStats	MsgStats.received(MessageBatch batch)
protected void	STATS.received(MessageBatch batch)
protected long	RATE.size(MessageBatch batch)
void	ASYM_ENCRYPT.up(MessageBatch batch)
void	AUTH.up(MessageBatch batch)
void	BARRIER.up(MessageBatch batch)
void	BATCH2.up(MessageBatch batch)
void	CLEAR_FLAGS.up(MessageBatch batch)
void	COMPRESS.up(MessageBatch batch)
void	DELAY.up(MessageBatch batch)
void	DH_KEY_EXCHANGE.up(MessageBatch batch)
void	DISCARD.up(MessageBatch batch)
void	Discovery.up(MessageBatch batch)
void	DROP.up(MessageBatch batch)
void	DUPL.up(MessageBatch batch)
void	Encrypt.up(MessageBatch batch)
void	EXAMPLE.up(MessageBatch batch)
void	FailureDetection.up(MessageBatch batch)
void	FD_SOCK2.up(MessageBatch batch)
void	FlowControl.up(MessageBatch batch)
void	FORK.up(MessageBatch batch)
void	FRAG.up(MessageBatch batch)
void	FRAG2.up(MessageBatch batch)
void	FRAG3.up(MessageBatch batch)
void	HDRS.up(MessageBatch batch)
void	MAKE_BATCH.up(MessageBatch batch)
void	MERGE3.up(MessageBatch batch)
void	NON_BLOCKING_SENDS.up(MessageBatch batch)
void	PERF.up(MessageBatch batch)
void	RATE.up(MessageBatch batch)
void	RED.up(MessageBatch batch)	Deprecated, for removal: This API element is subject to removal in a future version.
void	ReliableMulticast.up(MessageBatch mb)
void	ReliableUnicast.up(MessageBatch batch)
void	REVERSE.up(MessageBatch batch)
void	REVERSE2.up(MessageBatch batch)
void	RSVP.up(MessageBatch batch)
void	SEQUENCER.up(MessageBatch batch)
void	SEQUENCER2.up(MessageBatch batch)
void	SERIALIZE.up(MessageBatch batch)
void	SHUFFLE.up(MessageBatch batch)
void	SIZE.up(MessageBatch batch)
void	SIZE2.up(MessageBatch batch)
void	SNIFF.up(MessageBatch batch)
void	SOS.up(MessageBatch batch)
void	STATS.up(MessageBatch batch)
void	STOMP.up(MessageBatch batch)
void	THREAD_COUNT.up(MessageBatch batch)
void	TIME.up(MessageBatch batch)	Dividing the delivery time for a batch by the batch size is problematic, e.g.
void	TRACE.up(MessageBatch batch)
void	UNBATCH_OOB.up(MessageBatch batch)
void	UNBATCH.up(MessageBatch batch)
void	UNICAST3.up(MessageBatch batch)
void	VERIFY_SUSPECT.up(MessageBatch batch)
void	VERIFY_SUSPECT2.up(MessageBatch batch)
void	VERSION.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.protocols.pbcast

Fields in org.jgroups.protocols.pbcast with type parameters of type MessageBatch

Modifier and Type	Field	Description
protected static final BiConsumer<MessageBatch, Message>	NAKACK2.BATCH_ACCUMULATOR
protected final Map<Address, MessageBatch>	NAKACK2.cached_batches	To cache batches for sending messages up the stack (https://issues.redhat.com/browse/JGRP-2841)

Methods in org.jgroups.protocols.pbcast with parameters of type MessageBatch

Modifier and Type	Method	Description
protected void	NAKACK2.deliverBatch(MessageBatch batch)
protected void	NAKACK2.handleMessageBatch(MessageBatch mb)
void	GMS.up(MessageBatch batch)
void	NAKACK2.up(MessageBatch mb)
void	STABLE.up(MessageBatch batch)
void	StreamingStateTransfer.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.protocols.relay

Methods in org.jgroups.protocols.relay with parameters of type MessageBatch

Modifier and Type	Method	Description
void	RELAY2.up(MessageBatch batch)
void	RELAY3.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.stack

Methods in org.jgroups.stack with parameters of type MessageBatch

Modifier and Type	Method	Description
boolean	MessageProcessingPolicy.loopback(MessageBatch batch, boolean oob)
boolean	MessageProcessingPolicy.process(MessageBatch batch, boolean oob)	Process a batch received from the transport
void	Protocol.up(MessageBatch batch)	Sends up a multiple messages in a MessageBatch.
void	ProtocolStack.up(MessageBatch batch)

Uses of MessageBatch in org.jgroups.util

Fields in org.jgroups.util declared as MessageBatch

Modifier and Type	Field	Description
protected final MessageBatch	MaxOneThreadPerSender.Entry.batch
protected MessageBatch	SubmitToThreadPool.BatchHandler.batch

Methods in org.jgroups.util that return MessageBatch

Modifier and Type	Method	Description
MessageBatch	MessageBatch.add(Collection<Message> msgs)
MessageBatch	MessageBatch.add(Message msg)
MessageBatch	MessageBatch.add(Message[] msgs, int num_msgs)	Adds message to this batch from a message array
MessageBatch	MessageBatch.add(Message msg, boolean resize)	Adds a message to the table
MessageBatch	MessageBatch.add(Message msg, boolean resize, boolean determine_mode)	Adds a message to the table
MessageBatch	MessageBatch.add(MessageBatch batch)
MessageBatch	MessageBatch.add(MessageBatch batch, boolean resize)	Adds another batch to this one
MessageBatch	MessageBatch.clear()
MessageBatch	MessageBatch.cluster(AsciiString name)
MessageBatch	MessageBatch.clusterName(AsciiString name)
MessageBatch	MessageBatch.dest(Address dest)
MessageBatch	MessageBatch.determineMode()
MessageBatch	MessageBatch.incr(int i)
MessageBatch	MessageBatch.increment(int i)
MessageBatch	MessageBatch.mcast(boolean flag)
MessageBatch	MessageBatch.mode(MessageBatch.Mode m)
MessageBatch	MessageBatch.multicast(boolean flag)
static MessageBatch[]	Util.readMessageBatch(DataInput in, boolean multicast)	Reads a list of messages into 2 MessageBatches: regular OOB
MessageBatch	MessageBatch.removeIf(Predicate<Message> filter, boolean match_all)
MessageBatch	MessageBatch.reset()
MessageBatch	MessageBatch.resize(int new_capacity)
MessageBatch	MessageBatch.sender(Address sender)
MessageBatch	MessageBatch.set(Address dest, Address sender, Message[] msgs)
MessageBatch	MessageBatch.setClusterName(AsciiString name)
MessageBatch	MessageBatch.setDest(Address dest)
MessageBatch	MessageBatch.setMode(MessageBatch.Mode m)
MessageBatch	MessageBatch.setSender(Address sender)
MessageBatch	MessageBatch.timestamp(long ts)

Methods in org.jgroups.util with parameters of type MessageBatch

Modifier and Type	Method	Description
abstract boolean	Buffer.add(MessageBatch batch, Function<T,Long> seqno_getter, boolean remove_from_batch, T const_value)
boolean	DynamicBuffer.add(MessageBatch batch, Function<T,Long> seqno_getter, boolean remove_from_batch, T const_value)	Adds all messages from the given batch to the table
boolean	FixedBuffer.add(MessageBatch batch, Function<T,Long> seqno_getter, boolean remove_from_batch, T const_value)
MessageBatch	MessageBatch.add(MessageBatch batch)
MessageBatch	MessageBatch.add(MessageBatch batch, boolean resize)	Adds another batch to this one
boolean	Table.add(MessageBatch batch, Function<T,Long> seqno_getter)
boolean	Table.add(MessageBatch batch, Function<T,Long> seqno_getter, boolean remove_from_batch, T const_value)	Adds all messages from the given batch to the table
protected static <T> long	DynamicBuffer.findHighestSeqno(MessageBatch batch, Function<T,Long> seqno_getter)
protected static <T> long	Table.findHighestSeqno(MessageBatch batch, Function<T,Long> seqno_getter)
boolean	MaxOneThreadPerSender.loopback(MessageBatch batch, boolean oob)
boolean	PassAllMessagesUpDirectly.loopback(MessageBatch batch, boolean oob)
boolean	PassRegularMessagesUpDirectly.loopback(MessageBatch batch, boolean oob)
boolean	SubmitToThreadPool.loopback(MessageBatch batch, boolean oob)
static String	Util.print(MessageBatch batch, boolean print_headers)
protected boolean	MaxOneThreadPerSender.Entry.process(MessageBatch batch)
protected boolean	MaxOneThreadPerSender.MessageTable.process(MessageBatch batch)
boolean	MaxOneThreadPerSender.process(MessageBatch batch, boolean oob)
boolean	PassAllMessagesUpDirectly.process(MessageBatch batch, boolean oob)
boolean	PassRegularMessagesUpDirectly.process(MessageBatch batch, boolean oob)
boolean	SubmitToThreadPool.process(MessageBatch batch, boolean oob)
boolean	UnbatchOOBBatches.process(MessageBatch batch, boolean oob)
protected boolean	SubmitToThreadPool.removeAndDispatchNonBundledMessages(MessageBatch oob_batch, boolean loopback)	Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool.
void	ProtPerfHelper.setTime(MessageBatch batch)
int	MessageBatch.transferFrom(MessageBatch other, boolean clear)	Transfers messages from other to this batch.
void	ProtPerfHelper.upTime(MessageBatch batch, Protocol prot)

Constructors in org.jgroups.util with parameters of type MessageBatch

Modifier	Constructor	Description
	BatchHandler(MessageBatch batch, boolean loopback)