Package org.jgroups.protocols

Class PerDestinationBundler.SendBuffer

java.lang.Object

org.jgroups.protocols.PerDestinationBundler.SendBuffer

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

PerDestinationBundler

protected class PerDestinationBundler.SendBuffer
extends java.lang.Object
implements java.lang.Runnable

Constructor Summary

Constructors

Constructor	Description
SendBuffer(Address dest)

Method Summary

Modifier and Type	Method	Description
protected void	addAndSendIfSizeExceeded(Message msg)
protected void	addMessage(Message msg, int size)
java.lang.String	dump()
boolean	isThreadAlive()
protected int	removeAndSend(boolean execute_only_once)
void	run()
protected boolean	send(Message msg)
protected void	sendBundledMessages()
protected void	sendMessages(Address dest, Address src, java.util.List<Message> list)
protected int	size()
PerDestinationBundler.SendBuffer	start()
void	stop()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SendBuffer

public SendBuffer(Address dest)

Method Detail

dump

public java.lang.String dump()

isThreadAlive

public boolean isThreadAlive()

start

public PerDestinationBundler.SendBuffer start()

stop

public void stop()

run

public void run()

Specified by:

run in interface java.lang.Runnable

removeAndSend

protected int removeAndSend(boolean execute_only_once)

addAndSendIfSizeExceeded

protected void addAndSendIfSizeExceeded(Message msg)

addMessage

protected void addMessage(Message msg,
                          int size)

send

protected boolean send(Message msg)
                throws java.lang.Exception

Throws:

java.lang.Exception

sendBundledMessages

protected void sendBundledMessages()

sendMessages

protected void sendMessages(Address dest,
                            Address src,
                            java.util.List<Message> list)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

size

protected int size()