org.jgroups.blocks

Class DistributedTree

public class DistributedTree extends Object implements MessageListener, MembershipListener

A tree-like structure that is replicated across several members. Updates will be multicast to all group members reliably and in the same order.

Author: Bela Ban Alfonso Olias-Sanz

Nested Class Summary
interface	DistributedTree.DistributedTreeListener
interface	DistributedTree.ViewListener

Field Summary
protected Channel	channel
protected RpcDispatcher	disp
protected static Log	log

Constructor Summary
	DistributedTree()
	DistributedTree(String groupname, String channel_properties)
	DistributedTree(PullPushAdapter adapter, Serializable id, long state_timeout)

Method Summary
void	add(String fqn)
void	add(String fqn, Serializable element)
void	add(String fqn, Serializable element, int timeout)
void	addDistributedTreeListener(DistributedTree.DistributedTreeListener listener)
void	addViewListener(DistributedTree.ViewListener listener)
void	block() Block sending and receiving of messages until ViewAccepted is called
boolean	exists(String fqn)
Serializable	get(String fqn)
Channel	getChannel() Returns the Channel the DistributedTree is connected to
Vector	getChildrenNames(String fqn) Returns all children of a Node as strings
int	getGroupMembersNumber() Returns the number of current members joined to the group
String	getGroupName() Returns the name of the group that the DistributedTree is connected to
Object	getLocalAddress()
byte[]	getState() Return a copy of the tree
String	print()
void	receive(Message msg)
void	remove(String fqn)
void	remove(String fqn, int timeout)
void	removeDistributedTreeListener(DistributedTree.DistributedTreeListener listener)
void	removeViewListener(DistributedTree.ViewListener listener)
void	reset(String fqn, Serializable element) resets an existing node, useful after a merge when you want to tell other members of your state, but do not wish to remove and then add as two separate calls
void	reset(String fqn, Serializable element, int timeout) resets an existing node, useful after a merge when you want to tell other members of your state, but do not wish to remove and then add as two separate calls
void	set(String fqn, Serializable element)
void	set(String fqn, Serializable element, int timeout)
void	setDeadlockDetection(boolean flag)
void	setState(byte[] data)
void	start()
void	start(long timeout)
void	stop()
void	suspect(Address suspected_mbr) Called when a member is suspected
void	viewAccepted(View new_view)
void	_add(String fqn)
void	_add(String fqn, Serializable element)
void	_remove(String fqn)
void	_reset(String fqn, Serializable element) similar to set, but does not error if node does not exist, but rather does an add instead
void	_set(String fqn, Serializable element)

Field Detail

channel

protected Channel channel

disp

protected RpcDispatcher disp

log

protected static final Log log

Constructor Detail

DistributedTree

public DistributedTree()

DistributedTree

public DistributedTree(String groupname, String channel_properties)

DistributedTree

public DistributedTree(PullPushAdapter adapter, Serializable id, long state_timeout)

Method Detail

add

public void add(String fqn)

add

public void add(String fqn, Serializable element)

add

public void add(String fqn, Serializable element, int timeout)

addDistributedTreeListener

public void addDistributedTreeListener(DistributedTree.DistributedTreeListener listener)

addViewListener

public void addViewListener(DistributedTree.ViewListener listener)

block

public void block()

Block sending and receiving of messages until ViewAccepted is called

exists

public boolean exists(String fqn)

get

public Serializable get(String fqn)

getChannel

public Channel getChannel()

Returns the Channel the DistributedTree is connected to

Returns: Channel

getChildrenNames

public Vector getChildrenNames(String fqn)

Returns all children of a Node as strings

getGroupMembersNumber

public int getGroupMembersNumber()

Returns the number of current members joined to the group

Returns: int

getGroupName

public String getGroupName()

Returns the name of the group that the DistributedTree is connected to

Returns: String

getLocalAddress

public Object getLocalAddress()

getState

public byte[] getState()

Return a copy of the tree

print

public String print()

receive

public void receive(Message msg)

remove

public void remove(String fqn)

remove

public void remove(String fqn, int timeout)

removeDistributedTreeListener

public void removeDistributedTreeListener(DistributedTree.DistributedTreeListener listener)

removeViewListener

public void removeViewListener(DistributedTree.ViewListener listener)

reset

public void reset(String fqn, Serializable element)

resets an existing node, useful after a merge when you want to tell other members of your state, but do not wish to remove and then add as two separate calls

reset

public void reset(String fqn, Serializable element, int timeout)

resets an existing node, useful after a merge when you want to tell other members of your state, but do not wish to remove and then add as two separate calls