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)
protected void	loopback(Address dest, Address sender, FastArray<Message> list)
protected void	loopbackUnlessDontLoopbackIsSet(Message msg)
void	run()
protected void	send(Message msg)
protected void	sendBundledMessages()
protected void	sendMessageList(Address dest, Address src, FastArray<Message> list, ByteArrayDataOutputStream out)
protected void	sendMessages(Address dest, Address src, FastArray<Message> list)
protected void	sendMultiple(Address dst, Address sender, FastArray<Message> list, ByteArrayDataOutputStream out)
protected void	sendSingle(Address dst, Message msg, ByteArrayDataOutputStream out)
protected void	sendSingleMessage(Address dest, Message msg, ByteArrayDataOutputStream out)
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

start

public PerDestinationBundler.SendBuffer start()

stop

public void stop()

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)

send

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

Throws:

java.lang.Exception

sendBundledMessages

protected void sendBundledMessages()

sendMessages

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

sendSingle

protected void sendSingle(Address dst,
                          Message msg,
                          ByteArrayDataOutputStream out)

sendMultiple

protected void sendMultiple(Address dst,
                            Address sender,
                            FastArray<Message> list,
                            ByteArrayDataOutputStream out)

sendSingleMessage

protected void sendSingleMessage(Address dest,
                                 Message msg,
                                 ByteArrayDataOutputStream out)

sendMessageList

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

loopback

protected void loopback(Address dest,
                        Address sender,
                        FastArray<Message> list)

loopbackUnlessDontLoopbackIsSet

protected void loopbackUnlessDontLoopbackIsSet(Message msg)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

size

protected int size()