Package org.jgroups.protocols

Class FRAG2.FragEntry

java.lang.Object

org.jgroups.protocols.FRAG2.FragEntry

Enclosing class:

FRAG2

protected static class FRAG2.FragEntry
extends Object

Class 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 final Message[]	fragments
protected final Lock	lock
protected final MessageFactory	msg_factory
protected final boolean	needs_deserialization
protected int	number_of_frags_recvd

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FragEntry(int tot_frags, boolean needs_deserialization, MessageFactory mf)	Creates a new entry

Method Summary

Modifier and Type	Method	Description
boolean	isComplete()	returns true if this fragmentation is complete ie, all fragmentations have been received for this buffer
void	set(int frag_id, Message frag)	adds on fragmentation buffer to the message
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

fragments

protected final Message[] fragments

number_of_frags_recvd

protected int number_of_frags_recvd

needs_deserialization

protected final boolean needs_deserialization

msg_factory

protected final MessageFactory msg_factory

lock

protected final Lock lock

Constructor Details

FragEntry

protected FragEntry(int tot_frags,
 boolean needs_deserialization,
 MessageFactory mf)

Creates a new entry

Parameters:

tot_frags - the number of fragments to expect for this message

Method Details

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

toString

public String toString()

Overrides:

toString in class Object