org.jgroups.protocols

Class MERGE2.FindSubgroupsTask

java.lang.Object

org.jgroups.protocols.MERGE2.FindSubgroupsTask

All Implemented Interfaces:

Condition

Enclosing class:

MERGE2

protected class MERGE2.FindSubgroupsTask
extends java.lang.Object
implements Condition

Task periodically executing (if role is coordinator). Gets the initial membership and determines whether there are subgroups (multiple coordinators for the same group). If yes, it sends a MERGE event with the list of the coordinators up the stack

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.Future<?>	future
protected java.util.concurrent.locks.Lock	lock

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FindSubgroupsTask()

Method Summary

Modifier and Type	Method and Description
protected void	_findAndNotify()
protected long	computeInterval() Returns a random value within [min_interval - max_interval]
protected void	fetchViews() Fetches views from members in the cluster.
void	findAndNotify()
boolean	isMet() Return true if the condition is met and false otherwise
boolean	isRunning()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

future

protected java.util.concurrent.Future<?> future

lock

protected final java.util.concurrent.locks.Lock lock

Constructor Detail

FindSubgroupsTask

protected FindSubgroupsTask()

Method Detail

start

public void start()

stop

public void stop()

isRunning

public boolean isRunning()

isMet

public boolean isMet()

Description copied from interface: Condition

Return true if the condition is met and false otherwise

Specified by:

isMet in interface Condition

findAndNotify

public void findAndNotify()

_findAndNotify

protected void _findAndNotify()
                       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

fetchViews

protected void fetchViews()
                   throws java.lang.InterruptedException

Fetches views from members in the cluster. Returns when either discovery_timeout ms have elapsed or more than 1 different view has been found

Throws:

java.lang.InterruptedException

computeInterval

protected long computeInterval()

Returns a random value within [min_interval - max_interval]