GMS

java.lang.Object
- org.jgroups.stack.Protocol
- - org.jgroups.protocols.pbcast.GMS

All Implemented Interfaces:

DiagnosticsHandler.ProbeHandler
```
public class GMS
extends Protocol
implements DiagnosticsHandler.ProbeHandler
```
Group membership protocol. Handles joins/leaves/crashes (suspicions) and emits new views accordingly. Use VIEW_ENFORCER on top of this layer to make sure new members don't receive any messages until they are members

Author:

Bela Ban

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class GMS.DefaultMembershipPolicy

static class GMS.GmsHeader

Nested Classes
Modifier and Type	Class and Description
`static class`	`GMS.DefaultMembershipPolicy`
`static class`	`GMS.GmsHeader`

Field Summary

Fields
Modifier and Type	Field and Description
`protected AckCollector`	`ack_collector` To collect VIEW_ACKs from all members
`protected static java.lang.String`	`CLIENT`
`protected static java.lang.String`	`COORD`
`static short`	`DELTA_VIEW`
`static short`	`DIGEST_PRESENT`
`protected boolean`	`first_view_sent`
`protected java.lang.Class<java.util.concurrent.Callable<java.lang.Boolean>>`	`flushInvokerClass`
`protected boolean`	`flushProtocolInStack`
`protected boolean`	`handle_concurrent_startup` Deprecated.
`protected GmsImpl`	`impl`
`protected java.lang.Object`	`impl_mutex`
`protected java.util.Map<java.lang.String,GmsImpl>`	`impls`
`protected boolean`	`install_view_locally_first`
`protected long`	`join_timeout`
`protected java.util.List<Address>`	`joining` Members joined but for which no view has been received yet
`protected long`	`leave_timeout`
`protected java.util.List<Address>`	`leaving` Members excluded from group, but for which no view has been received yet
`protected Address`	`local_addr`
`protected boolean`	`log_collect_msgs`
`protected boolean`	`log_view_warnings`
`protected long`	`ltime`
`protected long`	`max_bundling_time`
`protected long`	`max_join_attempts`
`protected Membership`	`members`
`protected MembershipChangePolicy`	`membership_change_policy`
`protected AckCollector`	`merge_ack_collector`
`protected long`	`merge_timeout`
`static short`	`MERGE_VIEW`
`protected Merger`	`merger`
`protected int`	`num_prev_mbrs`
`protected int`	`num_prev_views`
`protected int`	`num_views`
`protected static java.lang.String`	`PART`
`protected BoundedList<Address>`	`prev_members` Keeps track of old members (up to num_prev_mbrs)
`protected BoundedList<java.lang.String>`	`prev_views` Stores the last 20 views
`protected boolean`	`print_local_addr`
`protected boolean`	`print_physical_addrs`
`static short`	`READ_ADDRS`
`protected long`	`resume_task_timeout`
`protected TimeScheduler`	`timer`
`protected Membership`	`tmp_members`
`protected boolean`	`use_delta_views`
`protected boolean`	`use_flush_if_present`
`protected View`	`view`
`protected long`	`view_ack_collection_timeout`
`protected boolean`	`view_bundling` Whether view bundling (http://jira.jboss.com/jira/browse/JGRP-144) should be enabled or not.
`protected org.jgroups.protocols.pbcast.GMS.ViewHandler`	`view_handler` Class to process JOIN, LEAVE and MERGE requests
`static short`	`VIEW_PRESENT`

Fields inherited from class org.jgroups.stack.Protocol
after_creation_hook, down_prot, ergonomics, id, log, name, stack, stats, up_prot

Constructor Summary

Constructors
Constructor and Description

GMS()

Constructors
Constructor and Description
`GMS()`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`MergeId`	`_getMergeId()`
`static Tuple<View,Digest>`	`_readViewAndDigest(byte[] buffer, int offset, int length)`
`protected boolean`	`_startFlush(View new_view, int maxAttempts, boolean resumeIfFailed, long randomFloor, long randomCeiling)`
`void`	`becomeClient()`
`void`	`becomeCoordinator()`
`void`	`becomeParticipant()`
`void`	`cancelMerge()`
`void`	`castViewChange(View new_view, Digest digest, java.util.Collection<Address> newMembers)` Broadcasts the new view and digest as a VIEW message and waits for acks from existing members
`protected java.util.List<Address>`	`computeNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)` Computes a merge membership
`protected java.util.List<Address>`	`computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects)` Computes the regular membership
`protected static View`	`createDeltaView(View current_view, View next_view)`
`protected View`	`createViewFromDeltaView(View current_view, DeltaView delta_view)`
`protected Address`	`determineCoordinator()`
`protected static short`	`determineFlags(View view, Digest digest)`
`java.lang.Object`	`down(Event evt)` An event is to be sent down the stack.
`java.lang.String`	`dumpViewHandlerHistory()`
`java.lang.String`	`dumpViewHandlerQueue()`
`void`	`fixDigests()`
`Digest`	`getDigest()` Grabs the current digest from NAKACK{2}
`GmsImpl`	`getImpl()`
`java.lang.String`	`getImplementation()`
`long`	`getJoinTimeout()`
`java.lang.String`	`getLocalAddress()`
`boolean`	`getLogCollectMessages()`
`long`	`getMaxBundlingTime()`
`long`	`getMaxJoinAttempts()`
`java.lang.String`	`getMembers()`
`MembershipChangePolicy`	`getMembershipChangePolicy()`
`java.lang.String`	`getMergeId()`
`Merger`	`getMerger()` Only used for internal testing, don't use this method !
`long`	`getMergeTimeout()`
`View`	`getNextView(java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspected_mbrs)` Computes the next view.
`int`	`getNumberOfViews()`
`int`	`getNumMembers()`
`java.lang.String`	`getView()`
`long`	`getViewAckCollectionTimeout()`
`Tuple<View,Digest>`	`getViewAndDigest()` Returns the current view and digest.
`int`	`getViewHandlerSize()`
`ViewId`	`getViewId()`
`java.util.Map<java.lang.String,java.lang.String>`	`handleProbe(java.lang.String... keys)` Handles a probe.
`void`	`init()` Called after instance has been created (null constructor) and before protocol is started.
`void`	`installView(View new_view)`
`void`	`installView(View new_view, Digest digest)` Sets the new view and sends a VIEW_CHANGE event up and down the stack.
`boolean`	`isCoord()`
`boolean`	`isCoordinator()`
`boolean`	`isMergeInProgress()`
`boolean`	`isMergeKillerRunning()`
`boolean`	`isMergeTaskRunning()`
`boolean`	`isViewBundling()`
`boolean`	`isViewHandlerSuspended()`
`GMS`	`joinTimeout(long timeout)`
`protected static Buffer`	`marshal(java.util.Collection<? extends Address> mbrs)`
`static Buffer`	`marshal(JoinRsp join_rsp)`
`protected static Buffer`	`marshal(View view, Digest digest)`
`protected static Buffer`	`marshal(ViewId view_id)`
`void`	`mergeDigest(Digest d)` Send down a MERGE_DIGEST event
`java.lang.String`	`printMergeIdHistory()`
`java.lang.String`	`printPreviousMembers()`
`java.lang.String`	`printPreviousViews()`
`java.util.List<java.lang.Integer>`	`providedDownServices()` List of events that are provided to layers below (they will be handled when sent down below)
`protected JoinRsp`	`readJoinRsp(byte[] buffer, int offset, int length)`
`protected java.util.Collection<? extends Address>`	`readMembers(byte[] buffer, int offset, int length)`
`protected Tuple<View,Digest>`	`readViewAndDigest(byte[] buffer, int offset, int length)`
`protected ViewId`	`readViewId(byte[] buffer, int offset, int length)`
`java.util.List<java.lang.Integer>`	`requiredDownServices()` List of events that are required to be answered by some layer below
`void`	`resetStats()`
`void`	`resumeViewHandler()`
`void`	`sendJoinResponse(JoinRsp rsp, Address dest)`
`void`	`sendJoinResponses(JoinRsp jr, java.util.Collection<Address> newMembers)`
`void`	`setDigest(Digest d)` Send down a SET_DIGEST event
`void`	`setImpl(GmsImpl new_impl)`
`void`	`setJoinTimeout(long t)`
`void`	`setLogCollectMessages(boolean flag)`
`void`	`setMaxBundlingTime(long max_bundling_time)`
`void`	`setMaxJoinAttempts(long t)`
`void`	`setMembershipChangePolicy(MembershipChangePolicy membership_change_policy)`
`void`	`setMembershipChangePolicy(java.lang.String classname)`
`void`	`setMergeTimeout(long timeout)`
`void`	`setPrintLocalAddr(boolean flag)`
`void`	`setPrintLocalAddress(boolean flag)`
`void`	`setViewAckCollectionTimeout(long view_ack_collection_timeout)`
`void`	`setViewBundling(boolean view_bundling)`
`void`	`start()` This method is called on a `Channel.connect(String)`.
`void`	`stop()` This method is called on a `Channel.disconnect()`.
`java.lang.String[]`	`supportedKeys()` Returns a list of supported keys
`void`	`suspect(java.lang.String suspected_member)`
`void`	`suspendViewHandler()`
`java.lang.Object`	`up(Event evt)` An event was received from the layer below.
`View`	`view()`
`protected boolean`	`wouldBeNewCoordinator(Address potential_new_coord)` Checks whether the potential_new_coord would be the new coordinator (2nd in line)
`protected static boolean`	`writeAddresses(View view, Digest digest)`

Methods inherited from class org.jgroups.stack.Protocol
accept, afterCreationHook, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedUpServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled, up

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLIENT

protected static final java.lang.String CLIENT

See Also:: Constant Field Values

COORD

protected static final java.lang.String COORD

See Also:: Constant Field Values

PART

protected static final java.lang.String PART

See Also:: Constant Field Values

VIEW_PRESENT
```
public static final short VIEW_PRESENT
```
See Also:

Constant Field Values

DIGEST_PRESENT
```
public static final short DIGEST_PRESENT
```
See Also:

Constant Field Values

MERGE_VIEW
```
public static final short MERGE_VIEW
```
See Also:

Constant Field Values

DELTA_VIEW
```
public static final short DELTA_VIEW
```
See Also:

Constant Field Values

READ_ADDRS
```
public static final short READ_ADDRS
```
See Also:

Constant Field Values

join_timeout
```
protected long join_timeout
```

leave_timeout
```
protected long leave_timeout
```

merge_timeout
```
protected long merge_timeout
```

max_join_attempts
```
protected long max_join_attempts
```

print_local_addr
```
protected boolean print_local_addr
```

print_physical_addrs
```
protected boolean print_physical_addrs
```

handle_concurrent_startup
```
@Deprecated
protected boolean handle_concurrent_startup
```
Deprecated.

Setting this to false disables concurrent startups. This is only used by unit testing code for testing merging. To everybody else: don't change it to false !

view_bundling
```
protected boolean view_bundling
```
Whether view bundling (http://jira.jboss.com/jira/browse/JGRP-144) should be enabled or not. Setting this to false forces each JOIN/LEAVE/SUPSECT request to be handled separately. By default these requests are processed together if they are queued at approximately the same time

use_delta_views
```
protected boolean use_delta_views
```

max_bundling_time
```
protected long max_bundling_time
```

num_prev_mbrs
```
protected int num_prev_mbrs
```

num_prev_views
```
protected int num_prev_views
```

view_ack_collection_timeout

protected long view_ack_collection_timeout

resume_task_timeout
```
protected long resume_task_timeout
```

use_flush_if_present
```
protected boolean use_flush_if_present
```

log_collect_msgs
```
protected boolean log_collect_msgs
```

log_view_warnings
```
protected boolean log_view_warnings
```

install_view_locally_first

protected boolean install_view_locally_first

num_views
```
protected int num_views
```

prev_views

protected BoundedList<java.lang.String> prev_views

Stores the last 20 views

flushInvokerClass

protected java.lang.Class<java.util.concurrent.Callable<java.lang.Boolean>> flushInvokerClass

impl
```
protected GmsImpl impl
```

impl_mutex

protected final java.lang.Object impl_mutex

impls

protected final java.util.Map<java.lang.String,GmsImpl> impls

merger
```
protected Merger merger
```

local_addr
```
protected Address local_addr
```

members
```
protected final Membership members
```

tmp_members
```
protected final Membership tmp_members
```

membership_change_policy

protected MembershipChangePolicy membership_change_policy

joining
```
protected final java.util.List<Address> joining
```
Members joined but for which no view has been received yet

leaving
```
protected final java.util.List<Address> leaving
```
Members excluded from group, but for which no view has been received yet

prev_members
```
protected BoundedList<Address> prev_members
```
Keeps track of old members (up to num_prev_mbrs)

view
```
protected volatile View view
```

ltime
```
protected long ltime
```

timer
```
protected TimeScheduler timer
```

view_handler

protected final org.jgroups.protocols.pbcast.GMS.ViewHandler view_handler

Class to process JOIN, LEAVE and MERGE requests

ack_collector
```
protected final AckCollector ack_collector
```
To collect VIEW_ACKs from all members

merge_ack_collector

protected final AckCollector merge_ack_collector

flushProtocolInStack
```
protected boolean flushProtocolInStack
```

first_view_sent
```
protected boolean first_view_sent
```

Constructor Detail
- GMS
```
public GMS()
```

Method Detail

getViewId
```
public ViewId getViewId()
```

view
```
public View view()
```

getViewAndDigest
```
public Tuple<View,Digest> getViewAndDigest()
```
Returns the current view and digest. Try to find a matching digest twice (if not found on the first try)

getView
```
public java.lang.String getView()
```

getNumberOfViews
```
public int getNumberOfViews()
```

getLocalAddress

public java.lang.String getLocalAddress()

getMembers
```
public java.lang.String getMembers()
```

getNumMembers
```
public int getNumMembers()
```

getJoinTimeout
```
public long getJoinTimeout()
```

setJoinTimeout
```
public void setJoinTimeout(long t)
```

joinTimeout
```
public GMS joinTimeout(long timeout)
```

getMergeTimeout
```
public long getMergeTimeout()
```

setMergeTimeout

public void setMergeTimeout(long timeout)

getMaxJoinAttempts
```
public long getMaxJoinAttempts()
```

setMaxJoinAttempts

public void setMaxJoinAttempts(long t)

getImplementation

public java.lang.String getImplementation()

isCoord
```
public boolean isCoord()
```

getMembershipChangePolicy

public MembershipChangePolicy getMembershipChangePolicy()

setMembershipChangePolicy

public void setMembershipChangePolicy(MembershipChangePolicy membership_change_policy)

getMergeId
```
public java.lang.String getMergeId()
```

isMergeInProgress
```
public boolean isMergeInProgress()
```

getMerger
```
public Merger getMerger()
```
Only used for internal testing, don't use this method !

setMembershipChangePolicy

public void setMembershipChangePolicy(java.lang.String classname)

printMergeIdHistory

public java.lang.String printMergeIdHistory()

printPreviousMembers

public java.lang.String printPreviousMembers()

setPrintLocalAddress

public void setPrintLocalAddress(boolean flag)

setPrintLocalAddr

public void setPrintLocalAddr(boolean flag)

getViewAckCollectionTimeout

public long getViewAckCollectionTimeout()

setViewAckCollectionTimeout

public void setViewAckCollectionTimeout(long view_ack_collection_timeout)

isViewBundling
```
public boolean isViewBundling()
```

setViewBundling

public void setViewBundling(boolean view_bundling)

getMaxBundlingTime
```
public long getMaxBundlingTime()
```

setMaxBundlingTime

public void setMaxBundlingTime(long max_bundling_time)

getViewHandlerSize
```
public int getViewHandlerSize()
```

isViewHandlerSuspended

public boolean isViewHandlerSuspended()

dumpViewHandlerQueue

public java.lang.String dumpViewHandlerQueue()

dumpViewHandlerHistory

public java.lang.String dumpViewHandlerHistory()

suspendViewHandler
```
public void suspendViewHandler()
```

resumeViewHandler
```
public void resumeViewHandler()
```

printPreviousViews

public java.lang.String printPreviousViews()

suspect

public void suspect(java.lang.String suspected_member)

isCoordinator
```
public boolean isCoordinator()
```

_getMergeId
```
public MergeId _getMergeId()
```

setLogCollectMessages

public void setLogCollectMessages(boolean flag)

getLogCollectMessages

public boolean getLogCollectMessages()

resetStats
```
public void resetStats()
```
Overrides:

resetStats in class Protocol

requiredDownServices
```
public java.util.List<java.lang.Integer> requiredDownServices()
```
Description copied from class: Protocol

List of events that are required to be answered by some layer below

Overrides:

requiredDownServices in class Protocol

providedDownServices
```
public java.util.List<java.lang.Integer> providedDownServices()
```
Description copied from class: Protocol

List of events that are provided to layers below (they will be handled when sent down below)

Overrides:

providedDownServices in class Protocol

setImpl

public void setImpl(GmsImpl new_impl)

getImpl
```
public GmsImpl getImpl()
```

init
```
public void init()
          throws java.lang.Exception
```
Description copied from class: Protocol

Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.

Overrides:

init in class Protocol

Throws:

java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

start
```
public void start()
           throws java.lang.Exception
```
Description copied from class: Protocol

This method is called on a Channel.connect(String). Starts work. Protocols are connected and queues are ready to receive events. Will be called from bottom to top. This call will replace the START and START_OK events.

Overrides:

start in class Protocol

Throws:

java.lang.Exception - Thrown if protocol cannot be started successfully. This will cause the ProtocolStack to fail, so Channel.connect(String) will throw an exception

stop
```
public void stop()
```
Description copied from class: Protocol

This method is called on a Channel.disconnect(). Stops work (e.g. by closing multicast socket). Will be called from top to bottom. This means that at the time of the method invocation the neighbor protocol below is still working. This method will replace the STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that when this method is called all messages in the down queue will have been flushed

Overrides:

stop in class Protocol

becomeCoordinator
```
public void becomeCoordinator()
```

becomeParticipant
```
public void becomeParticipant()
```

becomeClient
```
public void becomeClient()
```

fixDigests
```
public void fixDigests()
```

cancelMerge
```
public void cancelMerge()
```

isMergeTaskRunning
```
public boolean isMergeTaskRunning()
```

isMergeKillerRunning
```
public boolean isMergeKillerRunning()
```

getNextView

public View getNextView(java.util.Collection<Address> joiners,
                        java.util.Collection<Address> leavers,
                        java.util.Collection<Address> suspected_mbrs)

Computes the next view. Returns a copy that has leavers and suspected_mbrs removed and joiners added.

computeNewMembership

protected java.util.List<Address> computeNewMembership(java.util.List<Address> current_members,
                                                       java.util.Collection<Address> joiners,
                                                       java.util.Collection<Address> leavers,
                                                       java.util.Collection<Address> suspects)

Computes the regular membership

computeNewMembership

protected java.util.List<Address> computeNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)

Computes a merge membership

castViewChange

public void castViewChange(View new_view,
                           Digest digest,
                           java.util.Collection<Address> newMembers)

Broadcasts the new view and digest as a VIEW message and waits for acks from existing members

sendJoinResponses

public void sendJoinResponses(JoinRsp jr,
                              java.util.Collection<Address> newMembers)

sendJoinResponse

public void sendJoinResponse(JoinRsp rsp,
                             Address dest)

installView

public void installView(View new_view)

installView
```
public void installView(View new_view,
                        Digest digest)
```
Sets the new view and sends a VIEW_CHANGE event up and down the stack. If the view is a MergeView (subclass of View), then digest will be non-null and has to be set before installing the view.

determineCoordinator

protected Address determineCoordinator()

createDeltaView

protected static View createDeltaView(View current_view,
                                      View next_view)

wouldBeNewCoordinator
```
protected boolean wouldBeNewCoordinator(Address potential_new_coord)
```
Checks whether the potential_new_coord would be the new coordinator (2nd in line)

setDigest
```
public void setDigest(Digest d)
```
Send down a SET_DIGEST event

mergeDigest
```
public void mergeDigest(Digest d)
```
Send down a MERGE_DIGEST event

getDigest
```
public Digest getDigest()
```
Grabs the current digest from NAKACK{2}

_startFlush

protected boolean _startFlush(View new_view,
                              int maxAttempts,
                              boolean resumeIfFailed,
                              long randomFloor,
                              long randomCeiling)

up
```
public java.lang.Object up(Event evt)
```
Description copied from class: Protocol

An event was received from the layer below. Usually the current layer will want to examine the event type and - depending on its type - perform some computation (e.g. removing headers from a MSG event type, or updating the internal membership list when receiving a VIEW_CHANGE event). Finally the event is either a) discarded, or b) an event is sent down the stack using down_prot.down() or c) the event (or another event) is sent up the stack using up_prot.up().

Overrides:

up in class Protocol

down
```
public java.lang.Object down(Event evt)
```
Description copied from class: Protocol

An event is to be sent down the stack. The layer may want to examine its type and perform some action on it, depending on the event's type. If the event is a message MSG, then the layer may need to add a header to it (or do nothing at all) before sending it down the stack using down_prot.down(). In case of a GET_ADDRESS event (which tries to retrieve the stack's address from one of the bottom layers), the layer may need to send a new response event back up the stack using up_prot.up().

Overrides:

down in class Protocol

handleProbe
```
public java.util.Map<java.lang.String,java.lang.String> handleProbe(java.lang.String... keys)
```
Description copied from interface: DiagnosticsHandler.ProbeHandler

Handles a probe. For each key that is handled, the key and its result should be in the returned map.

Specified by:

handleProbe in interface DiagnosticsHandler.ProbeHandler

Returns:

Map. A map of keys and values. A null return value is permissible.

supportedKeys
```
public java.lang.String[] supportedKeys()
```
Description copied from interface: DiagnosticsHandler.ProbeHandler

Returns a list of supported keys

Specified by:

supportedKeys in interface DiagnosticsHandler.ProbeHandler

createViewFromDeltaView

protected View createViewFromDeltaView(View current_view,
                                       DeltaView delta_view)

writeAddresses

protected static boolean writeAddresses(View view,
                                        Digest digest)

determineFlags

protected static short determineFlags(View view,
                                      Digest digest)

marshal

protected static Buffer marshal(View view,
                                Digest digest)

marshal

public static Buffer marshal(JoinRsp join_rsp)

marshal

protected static Buffer marshal(java.util.Collection<? extends Address> mbrs)

marshal

protected static Buffer marshal(ViewId view_id)

readJoinRsp

protected JoinRsp readJoinRsp(byte[] buffer,
                              int offset,
                              int length)

readMembers

protected java.util.Collection<? extends Address> readMembers(byte[] buffer,
                                                              int offset,
                                                              int length)

readViewAndDigest

protected Tuple<View,Digest> readViewAndDigest(byte[] buffer,
                                               int offset,
                                               int length)

_readViewAndDigest

public static Tuple<View,Digest> _readViewAndDigest(byte[] buffer,
                                                    int offset,
                                                    int length)
                                             throws java.lang.Exception

Throws:: java.lang.Exception

readViewId

protected ViewId readViewId(byte[] buffer,
                            int offset,
                            int length)

Class GMS

Nested Class Summary

Field Summary

Fields inherited from class org.jgroups.stack.Protocol

Constructor Summary

Method Summary

Methods inherited from class org.jgroups.stack.Protocol

Methods inherited from class java.lang.Object

Field Detail

CLIENT

COORD

PART

VIEW_PRESENT

DIGEST_PRESENT

MERGE_VIEW

DELTA_VIEW

READ_ADDRS

join_timeout

leave_timeout

merge_timeout

max_join_attempts

print_local_addr

print_physical_addrs

handle_concurrent_startup

view_bundling

use_delta_views

max_bundling_time

num_prev_mbrs

num_prev_views

view_ack_collection_timeout

resume_task_timeout

use_flush_if_present

log_collect_msgs

log_view_warnings

install_view_locally_first

num_views

prev_views

flushInvokerClass

impl

impl_mutex

impls

merger

local_addr

members

tmp_members

membership_change_policy

joining

leaving

prev_members

view

ltime

timer

view_handler

ack_collector

merge_ack_collector

flushProtocolInStack

first_view_sent

Constructor Detail

GMS

Method Detail

getViewId

view

getViewAndDigest

getView

getNumberOfViews

getLocalAddress

getMembers

getNumMembers

getJoinTimeout

setJoinTimeout

joinTimeout

getMergeTimeout

setMergeTimeout

getMaxJoinAttempts

setMaxJoinAttempts

getImplementation

isCoord

getMembershipChangePolicy

setMembershipChangePolicy

getMergeId