com.fr.third.jgroups.protocols.pbcast

类 Merger

java.lang.Object

com.fr.third.jgroups.protocols.pbcast.Merger

public class Merger
extends java.lang.Object

Handles merging. Called by CoordGmsImpl and ParticipantGmsImpl

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	Merger.MergeTask Starts the merge protocol (only run by the merge leader).

字段概要

字段

限定符和类型	字段和说明
protected BoundedList<MergeId>	merge_id_history

构造器概要

构造器

构造器和说明
Merger(GMS gms)

方法概要

方法

限定符和类型	方法和说明
protected void	_handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
MergeId	getMergeId() Only used for testing, might get removed any time.
java.lang.String	getMergeIdAsString()
java.lang.String	getMergeIdHistory()
void	handleDigestResponse(Address sender, Digest digest)
void	handleMergeCancelled(MergeId merge_id)
void	handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	handleMergeResponse(MergeData data, MergeId merge_id)
void	handleMergeView(MergeData data, MergeId merge_id) If merge_id is not equal to this.merge_id then discard.
boolean	isMergeInProgress()
boolean	matchMergeId(MergeId id)
void	merge(java.util.Map<Address,View> views) Invoked upon receiving a MERGE event from the MERGE layer.
static void	sanitizeViews(java.util.Map<Address,View> map) Removes all members from a given view which don't have us in their view (https://jira.jboss.org/browse/JGRP-1061).
protected void	sendMergeRejectedResponse(Address sender, MergeId merge_id)
boolean	setMergeId(MergeId expected, MergeId new_value)

从类继承的方法 java.lang.Object

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

字段详细资料

merge_id_history

protected final BoundedList<MergeId> merge_id_history

构造器详细资料

Merger

public Merger(GMS gms)

方法详细资料

getMergeIdAsString

public java.lang.String getMergeIdAsString()

getMergeIdHistory

public java.lang.String getMergeIdHistory()

merge

public void merge(java.util.Map<Address,View> views)

Invoked upon receiving a MERGE event from the MERGE layer. Starts the merge protocol. See description of protocol in DESIGN.

参数:

views - A List of different views detected by the merge protocol

handleMergeRequest

public void handleMergeRequest(Address sender,
                      MergeId merge_id,
                      java.util.Collection<? extends Address> mbrs)

Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender. If a merge is already in progress, send back a MergeData with the merge_rejected field set to true.

参数:

sender - The address of the merge leader

merge_id - The merge ID

mbrs - The set of members from which we expect responses. Guaranteed to be non-null

_handleMergeRequest

protected void _handleMergeRequest(Address sender,
                       MergeId merge_id,
                       java.util.Collection<? extends Address> mbrs)
                            throws java.lang.Exception

抛出:

java.lang.Exception

handleMergeResponse

public void handleMergeResponse(MergeData data,
                       MergeId merge_id)

handleMergeView

public void handleMergeView(MergeData data,
                   MergeId merge_id)

If merge_id is not equal to this.merge_id then discard. Else cast the view/digest to all members of this group.

handleMergeCancelled

public void handleMergeCancelled(MergeId merge_id)

handleDigestResponse

public void handleDigestResponse(Address sender,
                        Digest digest)

sanitizeViews

public static void sanitizeViews(java.util.Map<Address,View> map)

Removes all members from a given view which don't have us in their view (https://jira.jboss.org/browse/JGRP-1061). Example:

 A: AB
 B: AB
 C: ABC
 

becomes

 A: AB
 B: AB
 C: C // A and B don't have C in their views
 

参数:

map - A map of members and their associated views

sendMergeRejectedResponse

protected void sendMergeRejectedResponse(Address sender,
                             MergeId merge_id)

setMergeId

public boolean setMergeId(MergeId expected,
                 MergeId new_value)

getMergeId

public MergeId getMergeId()

Only used for testing, might get removed any time. Do not use !

isMergeInProgress

public boolean isMergeInProgress()

matchMergeId

public boolean matchMergeId(MergeId id)