Package org.jgroups.protocols
Class FRAG2.FragEntry
- java.lang.Object
-
- org.jgroups.protocols.FRAG2.FragEntry
-
- Enclosing class:
- FRAG2
protected static class FRAG2.FragEntry extends java.lang.ObjectClass represents an entry for a message. Each entry holds an array of byte arrays sorted once all the byte buffer entries have been filled the fragmentation is considered complete.
All methods are unsynchronized, use getLock() to obtain a lock for concurrent access.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.concurrent.locks.Locklock
-
Constructor Summary
Constructors Modifier Constructor Description protectedFragEntry(int tot_frags)Creates a new entry
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected MessageassembleMessage()Assembles all the fragments into one buffer.booleanisComplete()returns true if this fragmentation is complete ie, all fragmentations have been received for this buffervoidlock()Use to synchronize on FragEntryvoidset(int frag_id, Message frag)adds on fragmentation buffer to the messagejava.lang.StringtoString()voidunlock()
-
-
-
Method Detail
-
lock
public void lock()
Use to synchronize on FragEntry
-
unlock
public void unlock()
-
set
public void set(int frag_id, Message frag)adds on fragmentation buffer to the message- Parameters:
frag_id- the number of the fragment being added 0..(tot_num_of_frags - 1)frag- the byte buffer containing the data for this fragmentation, should not be null
-
isComplete
public boolean isComplete()
returns true if this fragmentation is complete ie, all fragmentations have been received for this buffer
-
assembleMessage
protected Message assembleMessage()
Assembles all the fragments into one buffer. Takes all Messages, and combines their buffers into one buffer. This method does not check if the fragmentation is complete (useisComplete()to verify before calling this method)- Returns:
- the complete message in one buffer
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-