Package org.jgroups.protocols

Class SimplifiedTransferQueueBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.TransferQueueBundler

org.jgroups.protocols.SimplifiedTransferQueueBundler

All Implemented Interfaces:

Runnable, Bundler

public class SimplifiedTransferQueueBundler
extends TransferQueueBundler

This bundler uses the same logic as TransferQueueBundler but does not allocate memory except for the buffer itself and does not use complex data structures.

Field Summary

Fields

Modifier and Type	Field	Description
protected int	curr
protected static final int	MSG_BUF_SIZE
protected final Message[]	msg_queue

Fields inherited from class org.jgroups.protocols.TransferQueueBundler

avg_fill_count, bundler_thread, drop_when_full, num_drops_on_full_queue, num_sends_because_full_queue, num_sends_because_no_msgs, queue, remove_queue, running, THREAD_NAME

Fields inherited from class org.jgroups.protocols.BaseBundler

avg_send_time, capacity, count, lock, log, max_size, msgs, output, transport

Constructor Summary

Constructors

Constructor	Description
SimplifiedTransferQueueBundler()

Method Summary

Modifier and Type	Method	Description
protected void	_sendBundledMessages()
protected void	addMessage(Message msg, int size)
protected void	sendBundledMessages()	Sends all messages in the map.
int	size()	Returns the total number of messages in the hashmap

Methods inherited from class org.jgroups.protocols.TransferQueueBundler

addAndSendIfSizeExceeded, drain, dropWhenFull, dropWhenFull, getQueueSize, init, removeQueueSize, renameThread, resetStats, run, send, start, stop

Methods inherited from class org.jgroups.protocols.BaseBundler

getCapacity, getMaxSize, sendMessageList, sendSingleMessage, setCapacity, setMaxSize, viewChange

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MSG_BUF_SIZE

protected static final int MSG_BUF_SIZE

See Also:

• Constant Field Values

msg_queue

protected final Message[] msg_queue

curr

protected int curr

Constructor Details

SimplifiedTransferQueueBundler

public SimplifiedTransferQueueBundler()

Method Details

size

public int size()

Description copied from class: BaseBundler

Returns the total number of messages in the hashmap

Specified by:

size in interface Bundler

Overrides:

size in class TransferQueueBundler

addMessage

protected void addMessage(Message msg,
 int size)

Overrides:

addMessage in class BaseBundler

sendBundledMessages

protected void sendBundledMessages()

Description copied from class: BaseBundler

Sends all messages in the map. Messages for the same destination are bundled into a message list. The map will be cleared when done.

Overrides:

sendBundledMessages in class BaseBundler

_sendBundledMessages

protected void _sendBundledMessages()