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

Field Summary

Fields

Modifier and Type	Field	Description
protected FastArray<Message>	msgs

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	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()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

msgs

protected final FastArray<Message> msgs

Constructor Detail

SendBuffer

protected SendBuffer(Address dest)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.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()

send

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

Throws:

java.lang.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 java.lang.String toString()

Overrides:

toString in class java.lang.Object

size

protected int size()