Package org.jgroups.protocols

Class PerDestinationBundler.SendBuffer

java.lang.Object

org.jgroups.protocols.PerDestinationBundler.SendBuffer

All Implemented Interfaces:

Runnable

Enclosing class:

PerDestinationBundler

protected class PerDestinationBundler.SendBuffer
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private Thread	bundler_thread
private long	count
private final Address	dest
private final Lock	lock
protected final FastArray<Message>	msgs
private final ByteArrayDataOutputStream	output
private final BlockingQueue<Message>	queue
private final List<Message>	remove_queue
private boolean	running

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SendBuffer(Address dest)

Method Summary

Modifier and Type	Method	Description
protected void	addAndSendIfSizeExceeded(Message msg)
protected void	addMessage(Message msg, int size)
void	renameThread()
void	run()
protected void	send(Message msg)
protected void	sendBatch(Address destination, FastArray<Message> list)
protected void	sendBundledMessages()
protected void	sendMessageList(Address dest, Address src, FastArray<Message> list)
protected void	sendMessages(Address dest, Address src, FastArray<Message> list)
protected void	sendSingleMessage(Address dest, Message msg)
protected int	size()
PerDestinationBundler.SendBuffer	start()
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

dest

private final Address dest

msgs

protected final FastArray<Message> msgs

lock

private final Lock lock

queue

private final BlockingQueue<Message> queue

remove_queue

private final List<Message> remove_queue

output

private final ByteArrayDataOutputStream output

bundler_thread

private volatile Thread bundler_thread

running

private volatile boolean running

count

private long count

Constructor Details

SendBuffer

protected SendBuffer(Address dest)

Method Details

run

public void run()

Specified by:

run in interface Runnable

addAndSendIfSizeExceeded

protected void addAndSendIfSizeExceeded(Message msg)

addMessage

protected void addMessage(Message msg,
 int size)

sendBundledMessages

protected void sendBundledMessages()

start

public PerDestinationBundler.SendBuffer start()

stop

public void stop()

renameThread

public void renameThread()

send

protected void send(Message msg)
             throws Exception

Throws:

Exception

sendBatch

protected void sendBatch(Address destination,
 FastArray<Message> list)

sendSingleMessage

protected void sendSingleMessage(Address dest,
 Message msg)

sendMessageList

protected void sendMessageList(Address dest,
 Address src,
 FastArray<Message> list)

sendMessages

protected void sendMessages(Address dest,
 Address src,
 FastArray<Message> list)

toString

public String toString()

Overrides:

toString in class Object

size

protected int size()