Package org.jgroups.protocols
Class TransferQueueBundler2.Buffer
- java.lang.Object
-
- org.jgroups.protocols.TransferQueueBundler2.Buffer
-
- Enclosing class:
- TransferQueueBundler2
private static class TransferQueueBundler2.Buffer extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private intcountprivate intlength_indexprivate ByteArrayDataOutputStreamout
-
Constructor Summary
Constructors Modifier Constructor Description privateBuffer(int length)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private TransferQueueBundler2.BufferaddMessage(Message msg, TP transport)private TransferQueueBundler2.BuffercorrectLength()private booleanisEmpty()private TransferQueueBundler2.Bufferreset()private TransferQueueBundler2.Buffersend(Address dest, TP transport)private intsize()java.lang.StringtoString()
-
-
-
Field Detail
-
out
private final ByteArrayDataOutputStream out
-
length_index
private int length_index
-
count
private int count
-
-
Method Detail
-
reset
private TransferQueueBundler2.Buffer reset()
-
size
private int size()
-
isEmpty
private boolean isEmpty()
-
correctLength
private TransferQueueBundler2.Buffer correctLength()
-
addMessage
private TransferQueueBundler2.Buffer addMessage(Message msg, TP transport) throws java.io.IOException
- Throws:
java.io.IOException
-
send
private TransferQueueBundler2.Buffer send(Address dest, TP transport) throws java.lang.Exception
- Throws:
java.lang.Exception
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-