Package org.jgroups.protocols
Class PerDestinationBundler.SendBuffer
java.lang.Object
org.jgroups.protocols.PerDestinationBundler.SendBuffer
- All Implemented Interfaces:
Runnable
- Enclosing class:
PerDestinationBundler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Threadprivate longprivate final Addressprivate final Lockprivate final ByteArrayDataOutputStreamprivate final BlockingQueue<Message> private boolean -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprotected voidaddMessage(Message msg, int size) voidvoidrun()protected voidprotected voidprotected voidprotected voidsendMessageList(Address dest, Address src, FastArray<Message> list) protected voidsendMessages(Address dest, Address src, FastArray<Message> list) protected voidsendSingleMessage(Address dest, Message msg) protected intsize()start()voidstop()toString()
-
Field Details
-
dest
-
msgs
-
lock
-
queue
-
remove_queue
-
output
-
bundler_thread
-
running
private volatile boolean running -
count
private long count
-
-
Constructor Details
-
SendBuffer
-
-
Method Details
-
run
public void run() -
addAndSendIfSizeExceeded
-
addMessage
-
sendBundledMessages
protected void sendBundledMessages() -
start
-
stop
public void stop() -
renameThread
public void renameThread() -
send
- Throws:
Exception
-
sendBatch
-
sendSingleMessage
-
sendMessageList
-
sendMessages
-
toString
-
size
protected int size()
-