Class PartitionHandler

java.lang.Object

org.jgroups.admin.AdminHandler

org.jgroups.admin.PartitionHandler

public class PartitionHandler
extends AdminHandler

Injects partitions into a cluster (via injectView()). The syntax is string based, and partitions are separated by '||'. Example: if we have member A,B,C,D,E, we can inject a partition with injectView("A,B,C || D,E"). To heal this, injectView("A,B,C,D") can be used. Note that view IDs will be incremented by 1, but no MergeViews will be installed.

Since:

5.6.0

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	PartitionHandler.ViewInfo

Field Summary

Fields

Modifier and Type	Field	Description
static final String	GET_VIEW
static final String	GET_VIEW_RSP
static final String	INJECT_MERGE_EVENT
static final String	INJECT_MERGE_VIEW
static final String	INJECT_VIEW
static final String	KEY
protected final ResponseCollector<View>	rsp_coll
protected long	timeout

Fields inherited from class AdminHandler

ch, FAIL, OK

Constructor Summary

Constructors

Constructor	Description
PartitionHandler(JChannel ch)

Method Summary

Modifier and Type	Method	Description
protected View	createView(String mbrs)
String	executeRequest(String req)
protected static Address	getByValue(Map<Address,String> cache, String name)
protected List<Address>	getMembers(String view)
void	handleRequest(Message msg, AdminHeader hdr)
void	handleResponse(Message msg, AdminHeader hdr)
void	injectMergeView(String view)	Fetches the views from all members (GET_VIEW), collects all responses (GET_VIEW_RSP), creates a map of addresses and views and sends that map to all members, which inject that as a MERGE event into GMS
void	injectView(String views)	Injects non-overlapping views into members.
long	timeout()
PartitionHandler	timeout(long t)

Methods inherited from class AdminHandler

channel, handleMessage, sendRequest, sendRequest, sendResponse, sendResponse

Methods inherited from class Object

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

Field Details

KEY

public static final String KEY

See Also:

• Constant Field Values

INJECT_VIEW

public static final String INJECT_VIEW

See Also:

• Constant Field Values

INJECT_MERGE_VIEW

public static final String INJECT_MERGE_VIEW

See Also:

• Constant Field Values

INJECT_MERGE_EVENT

public static final String INJECT_MERGE_EVENT

See Also:

• Constant Field Values

GET_VIEW

public static final String GET_VIEW

See Also:

• Constant Field Values

GET_VIEW_RSP

public static final String GET_VIEW_RSP

See Also:

• Constant Field Values

rsp_coll

protected final ResponseCollector<View> rsp_coll

timeout

protected long timeout

Constructor Details

PartitionHandler

public PartitionHandler(JChannel ch)

Method Details

timeout

public long timeout()

timeout

public PartitionHandler timeout(long t)

executeRequest

public String executeRequest(String req)

Overrides:

executeRequest in class AdminHandler

injectView

public void injectView(String views)

Injects non-overlapping views into members. Example: "A,B,C || D,E" injects view {A,B,C} into A, B and C, and {D,E} into D and E. "A,B,C,D,E" injects view {A,B,C,D,E} into all members, healing the partition.

Parameters:

views - The partition to be injected

injectMergeView

public void injectMergeView(String view)

Fetches the views from all members (GET_VIEW), collects all responses (GET_VIEW_RSP), creates a map of addresses and views and sends that map to all members, which inject that as a MERGE event into GMS

handleRequest

public void handleRequest(Message msg,
 AdminHeader hdr)

Specified by:

handleRequest in class AdminHandler

handleResponse

public void handleResponse(Message msg,
 AdminHeader hdr)

Specified by:

handleResponse in class AdminHandler

getMembers

protected List<Address> getMembers(String view)

createView

protected View createView(String mbrs)

getByValue

protected static Address getByValue(Map<Address,String> cache,
 String name)