org.jgroups.protocols

Class SimplifiedTransferQueueBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.TransferQueueBundler

org.jgroups.protocols.SimplifiedTransferQueueBundler

All Implemented Interfaces:

java.lang.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.

Author:

Radim Vansa

Field Summary

Fields

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

Fields inherited from class org.jgroups.protocols.TransferQueueBundler

bundler_thread, queue, remove_queue, running, THREAD_NAME

Fields inherited from class org.jgroups.protocols.BaseBundler

count, lock, log, msgs, output, transport

Constructor Summary

Constructors

Constructor and Description
SimplifiedTransferQueueBundler()
SimplifiedTransferQueueBundler(int capacity)

Method Summary

Modifier and Type	Method and Description
protected void	addMessage(Message msg, long size)
protected void	sendBundledMessages() Sends all messages in the map.
protected void	sendSingleMessage(Message msg, ByteArrayDataOutputStream output)
int	size() The number of unsent messages in the bundler

Methods inherited from class org.jgroups.protocols.TransferQueueBundler

assertPositive, getBufferSize, getThread, init, removeQueueSize, removeQueueSize, run, send, start, stop

Methods inherited from class org.jgroups.protocols.BaseBundler

checkForSharedTransport, clearMessages, sendMessageList, sendSingleMessage, viewChange

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

SimplifiedTransferQueueBundler

public SimplifiedTransferQueueBundler()

SimplifiedTransferQueueBundler

public SimplifiedTransferQueueBundler(int capacity)

Method Detail

size

public int size()

Description copied from interface: Bundler

The number of unsent messages in the bundler

Specified by:

size in interface Bundler

Overrides:

size in class TransferQueueBundler

addMessage

protected void addMessage(Message msg,
                          long 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

sendSingleMessage

protected void sendSingleMessage(Message msg,
                                 ByteArrayDataOutputStream output)