org.jgroups.protocols

Class BaseBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

All Implemented Interfaces:

Bundler

Direct Known Subclasses:

RingBufferBundler, RingBufferBundlerLockless, RingBufferBundlerLockless2, SenderSendsBundler, SenderSendsWithTimerBundler, TransferQueueBundler

public class BaseBundler
extends java.lang.Object
implements Bundler

Implements storing of messages in a hashmap and sending of single messages and message batches. Most bundler implementations will want to extend this class

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field and Description
protected long	count
protected java.util.concurrent.locks.ReentrantLock	lock
protected Log	log
protected java.util.Map<SingletonAddress,java.util.List<Message>>	msgs Keys are destinations, values are lists of Messages
protected ByteArrayDataOutputStream	output
protected TP	transport

Constructor Summary

Constructors

Constructor and Description
BaseBundler()

Method Summary

Modifier and Type	Method and Description
protected void	addMessage(Message msg, long size)
protected void	checkForSharedTransport(TP tp)
protected void	clearMessages()
void	init(TP transport) Called after creation of the bundler
void	send(Message msg)
protected void	sendBundledMessages() Sends all messages in the map.
protected void	sendMessageList(Address dest, Address src, byte[] cluster_name, java.util.List<Message> list)
protected void	sendSingleMessage(Message msg)
int	size() The number of unsent messages in the bundler
void	start() Called after Bundler.init(TP)
void	stop()
void	viewChange(View view)

Methods inherited from class java.lang.Object

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

Field Detail

msgs

protected final java.util.Map<SingletonAddress,java.util.List<Message>> msgs

Keys are destinations, values are lists of Messages

transport

protected TP transport

count

protected long count

lock

protected final java.util.concurrent.locks.ReentrantLock lock

output

protected ByteArrayDataOutputStream output

log

protected Log log

Constructor Detail

BaseBundler

public BaseBundler()

Method Detail

init

public void init(TP transport)

Description copied from interface: Bundler

Called after creation of the bundler

Specified by:

init in interface Bundler

Parameters:

transport - the transport, for further reference

start

public void start()

Description copied from interface: Bundler

Called after Bundler.init(TP)

Specified by:

start in interface Bundler

stop

public void stop()

Specified by:

stop in interface Bundler

send

public void send(Message msg)
          throws java.lang.Exception

Specified by:

send in interface Bundler

Throws:

java.lang.Exception

viewChange

public void viewChange(View view)

Specified by:

viewChange in interface Bundler

size

public int size()

Description copied from interface: Bundler

The number of unsent messages in the bundler

Specified by:

size in interface Bundler

sendBundledMessages

protected void sendBundledMessages()

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

clearMessages

protected void clearMessages()

sendSingleMessage

protected void sendSingleMessage(Message msg)

sendMessageList

protected void sendMessageList(Address dest,
                               Address src,
                               byte[] cluster_name,
                               java.util.List<Message> list)

addMessage

protected void addMessage(Message msg,
                          long size)

checkForSharedTransport

protected void checkForSharedTransport(TP tp)