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 TP.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

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.TransferQueueBundler

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

Methods inherited from class org.jgroups.protocols.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 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)