org.jgroups.protocols

Class TP.SimplifiedTransferQueueBundler

java.lang.Object

org.jgroups.protocols.TP.BaseBundler

org.jgroups.protocols.TP.TransferQueueBundler

org.jgroups.protocols.TP.SimplifiedTransferQueueBundler

All Implemented Interfaces:

java.lang.Runnable, TP.Bundler

Enclosing class:

TP

protected class TP.SimplifiedTransferQueueBundler
extends TP.TransferQueueBundler

This bundler uses the same logic as TP.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 and Description
protected int	curr
protected static int	MSG_BUF_SIZE
protected Message[]	msg_queue

Fields inherited from class org.jgroups.protocols.TP.TransferQueueBundler

bundler_thread, queue, THREAD_NAME

Fields inherited from class org.jgroups.protocols.TP.BaseBundler

output

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	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)

Methods inherited from class org.jgroups.protocols.TP.TransferQueueBundler

getBufferSize, getThread, run, send, start, stop

Methods inherited from class org.jgroups.protocols.TP.BaseBundler

numMessages, sendMessageList, sendSingleMessage

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

protected SimplifiedTransferQueueBundler(int capacity)

Method Detail

addMessage

protected void addMessage(Message msg,
                          long size)

Overrides:

addMessage in class TP.BaseBundler

sendBundledMessages

protected void sendBundledMessages()

Description copied from class: TP.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 TP.BaseBundler

sendSingleMessage

protected void sendSingleMessage(Message msg,
                                 ByteArrayDataOutputStream output)