Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.demos.wb |
A distributed whiteboard applet implemented using JGroups.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.relay | |
org.jgroups.protocols.rules | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Class and Description |
---|---|
class |
MergeView
A view that is sent as a result of a cluster merge.
|
Modifier and Type | Field and Description |
---|---|
protected View |
JChannel.my_view |
protected View[] |
MergeView.subgroups |
Modifier and Type | Method and Description |
---|---|
View |
View.copy()
Deprecated.
View is immutable, so copy() is unnecessary
|
static View |
View.create(Address coord,
long id,
Address... members) |
static View |
View.create(Address coord,
long id,
java.util.Collection<Address> members) |
View |
JChannel.getView() |
abstract View |
Channel.getView()
Gets the current view.
|
protected static View[] |
MergeView.listToArray(java.util.List<View> list) |
Modifier and Type | Method and Description |
---|---|
java.util.List<View> |
MergeView.getSubgroups() |
Modifier and Type | Method and Description |
---|---|
int |
View.compareTo(View o) |
boolean |
MergeView.deepEquals(View other) |
boolean |
View.deepEquals(View other) |
static Address[][] |
View.diff(View from,
View to)
Returns the difference between 2 views from and to.
|
static java.util.List<Address> |
View.leftMembers(View one,
View two)
Returns a list of members which left from view one to two
|
void |
ReceiverAdapter.viewAccepted(View view)
Called when a change in membership has occurred.
|
void |
MembershipListener.viewAccepted(View new_view)
Called when a change in membership has occurred.
|
Modifier and Type | Method and Description |
---|---|
protected static View[] |
MergeView.listToArray(java.util.List<View> list) |
Constructor and Description |
---|
MergeView(Address creator,
long id,
java.util.List<Address> members,
java.util.List<View> subgroups)
Creates a new view
|
MergeView(ViewId view_id,
Address[] members,
java.util.List<View> subgroups) |
MergeView(ViewId view_id,
java.util.List<Address> members,
java.util.List<View> subgroups)
Creates a new merge view
|
Modifier and Type | Field and Description |
---|---|
protected View |
RequestCorrelator.view |
Modifier and Type | Method and Description |
---|---|
void |
RequestCorrelator.receiveView(View new_view)
Event.VIEW_CHANGE event received from a layer below.
|
void |
ReplCache.viewAccepted(View new_view) |
void |
ReplicatedHashMap.viewAccepted(View new_view) |
void |
PartitionedHashMap.viewAccepted(View new_view) |
void |
PartitionedHashMap.ConsistentHashFunction.viewAccepted(View new_view) |
void |
ReplicatedTree.viewAccepted(View new_view) |
abstract void |
Request.viewChange(View new_view) |
void |
UnicastRequest.viewChange(View view)
If the target address is not a member of the new view, we'll mark the response as not received and unblock
the caller of execute()
|
void |
GroupRequest.viewChange(View view)
Any member of 'membership' that is not in the new view is flagged as
SUSPECTED.
|
void |
ReplicatedTree.ReplicatedTreeListener.viewChange(View new_view) |
void |
ReplicatedHashMap.Notification.viewChange(View view,
java.util.List<Address> mbrs_joined,
java.util.List<Address> mbrs_left) |
Modifier and Type | Field and Description |
---|---|
protected View |
RelayDemoRpc.view |
Modifier and Type | Method and Description |
---|---|
void |
ViewDemo.viewAccepted(View new_view) |
void |
Draw.viewAccepted(View v) |
void |
QuoteClient.viewAccepted(View new_view) |
void |
RelayDemoRpc.viewAccepted(View new_view) |
void |
QuoteServer.viewAccepted(View new_view) |
void |
Chat.viewAccepted(View new_view) |
void |
ReplicatedHashMapDemo.viewChange(View view,
java.util.List<Address> new_mbrs,
java.util.List<Address> old_mbrs) |
Modifier and Type | Method and Description |
---|---|
void |
Whiteboard.viewAccepted(View v) |
Modifier and Type | Field and Description |
---|---|
protected View |
RELAY.bridge_view
The view of the bridge cluster, usually consists of max 2 nodes
|
protected View |
RELAY.global_view
The combined view of local and remote cluster
|
protected View |
RELAY.ViewData.global_view |
protected View |
RELAY.local_view
The view of the local cluster
|
protected View |
RELAY.remote_view
The view of the remote cluster
|
protected View |
RELAY.ViewData.remote_view |
protected View |
Locking.view |
protected View |
SHARED_LOOPBACK.view |
protected View |
MERGE3.view |
protected View |
COUNTER.view |
protected View |
MERGE2.view
Deprecated.
|
protected View |
MERGE2.MergeHeader.view |
protected View |
SEQUENCER2.view |
protected View |
Discovery.view |
protected View |
STOMP.view |
protected View |
SEQUENCER.view |
protected View |
TP.view |
protected View |
SSL_KEY_EXCHANGE.view |
protected View |
EncryptBase.view |
protected View |
Executing.view |
Modifier and Type | Field and Description |
---|---|
protected ResponseCollector<View> |
MERGE3.view_rsps |
protected java.util.Map<Address,View> |
MERGE2.views
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected View |
RELAY.generateGlobalView(View local_view,
View remote_view) |
protected View |
RELAY.generateGlobalView(View local_view,
View remote_view,
boolean merge) |
View |
SHARED_LOOPBACK.getView() |
protected View |
MERGE3.readView(byte[] buffer,
int offset,
int length) |
View |
TP.view() |
Modifier and Type | Method and Description |
---|---|
static java.util.List<View> |
MERGE3.detectDifferentViews(java.util.Map<Address,View> map) |
Modifier and Type | Method and Description |
---|---|
static RELAY.ViewData |
RELAY.ViewData.create(View remote_view,
View global_view) |
protected View |
RELAY.generateGlobalView(View local_view,
View remote_view) |
protected View |
RELAY.generateGlobalView(View local_view,
View remote_view,
boolean merge) |
void |
CENTRAL_EXECUTOR.handleView(View view) |
protected void |
RELAY.handleView(View view) |
protected void |
Locking.handleView(View view) |
protected void |
RSVP.handleView(View view) |
protected void |
COUNTER.handleView(View view) |
protected void |
ASYM_ENCRYPT.handleView(View v) |
void |
PEER_LOCK.handleView(View view)
Deprecated.
|
protected void |
STOMP.handleView(View view) |
void |
CENTRAL_LOCK.handleView(View view) |
protected void |
SSL_KEY_EXCHANGE.handleView(View view) |
protected void |
EncryptBase.handleView(View view) |
protected void |
Executing.handleView(View view) |
protected void |
KeyExchange.handleView(View view) |
protected void |
FD_HOST.handleView(View view) |
protected void |
DAISYCHAIN.handleView(View view) |
protected void |
JDBC_PING.handleView(View new_view,
View old_view,
boolean coord_changed) |
protected void |
FILE_PING.handleView(View new_view,
View old_view,
boolean coord_changed) |
protected void |
FORWARD_TO_COORD.handleViewChange(View view) |
protected void |
SEQUENCER2.handleViewChange(View v) |
protected void |
SEQUENCER.handleViewChange(View v) |
protected void |
FD_ALL.handleViewChange(View v) |
protected void |
FD_ALL2.handleViewChange(View v) |
protected void |
FRAG2.handleViewChange(View view) |
static Buffer |
MERGE3.marshal(View view) |
protected void |
RELAY.sendViewOnLocalCluster(View remote_view,
View global_view,
boolean use_seperate_thread,
java.util.List<Address> new_mbrs) |
void |
RELAY.Receiver.viewAccepted(View view) |
void |
Bundler.viewChange(View view) |
void |
BaseBundler.viewChange(View view) |
void |
NoBundler.viewChange(View view) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<View> |
MERGE3.detectDifferentViews(java.util.Map<Address,View> map) |
Constructor and Description |
---|
MergeHeader(byte type,
View view) |
PingData(Address sender,
View view,
boolean is_server,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
Deprecated.
Use the constructor wityh a single PhysicalAddress instead
|
PingData(Address sender,
View view,
ViewId view_id,
boolean is_server,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
Deprecated.
Use the constructor with a single PhysicalAddress instead
|
Modifier and Type | Class and Description |
---|---|
class |
DeltaView
Subclass of
View with a null members field. |
Modifier and Type | Field and Description |
---|---|
protected View |
GMS.view |
protected View |
STABLE.view |
protected View |
JoinRsp.view |
protected View |
MergeData.view |
protected View |
NAKACK2.view |
protected View |
STATE_TRANSFER.view |
Modifier and Type | Field and Description |
---|---|
protected java.util.Set<View> |
Merger.MergeTask.subviews |
Modifier and Type | Method and Description |
---|---|
protected static View |
GMS.createDeltaView(View current_view,
View next_view) |
protected View |
GMS.createViewFromDeltaView(View current_view,
DeltaView delta_view) |
View |
GMS.getNextView(java.util.Collection<Address> joiners,
java.util.Collection<Address> leavers,
java.util.Collection<Address> suspected_mbrs)
Computes the next view.
|
View |
JoinRsp.getView() |
View |
MergeData.getView() |
View |
GMS.view() |
Modifier and Type | Method and Description |
---|---|
static Tuple<View,Digest> |
GMS._readViewAndDigest(byte[] buffer,
int offset,
int length) |
Tuple<View,Digest> |
GMS.getViewAndDigest()
Returns the current view and digest.
|
protected Tuple<View,Digest> |
GMS.readViewAndDigest(byte[] buffer,
int offset,
int length) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
GMS._startFlush(View new_view,
int maxAttempts,
boolean resumeIfFailed,
long randomFloor,
long randomCeiling) |
void |
GMS.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 MutableDigest |
Merger.MergeTask.consolidateDigests(View new_view,
java.util.List<MergeData> merge_rsps)
Merge all digests into one.
|
protected static View |
GMS.createDeltaView(View current_view,
View next_view) |
protected View |
GMS.createViewFromDeltaView(View current_view,
DeltaView delta_view) |
protected static short |
GMS.determineFlags(View view,
Digest digest) |
protected Digest |
Merger.fetchDigestsFromAllMembersInSubPartition(View view,
MergeId merge_id)
Multicasts a GET_DIGEST_REQ to all members of this sub partition and waits for all responses
(GET_DIGEST_RSP) or N ms.
|
protected static int |
STABLE.getRank(Address member,
View v) |
protected void |
STATE_SOCK.handleViewChange(View v) |
protected void |
STABLE.handleViewChange(View v) |
protected void |
STATE.handleViewChange(View v) |
protected void |
StreamingStateTransfer.handleViewChange(View v) |
protected void |
STATE_TRANSFER.handleViewChange(View v) |
void |
ParticipantGmsImpl.handleViewChange(View new_view,
Digest digest)
If we are leaving, we have to wait for the view change (last msg in the current view) that
excludes us before we can leave.
|
void |
CoordGmsImpl.handleViewChange(View new_view,
Digest digest)
Called by the GMS when a VIEW is received.
|
void |
GmsImpl.handleViewChange(View new_view,
Digest digest) |
void |
GMS.installView(View new_view) |
void |
GMS.installView(View new_view,
Digest digest)
Sets the new view and sends a VIEW_CHANGE event up and down the stack.
|
protected static Buffer |
GMS.marshal(View view,
Digest digest) |
protected static Digest |
FLUSH.maxSeqnos(View view,
java.util.List<Digest> digests)
Returns a digest which contains, for all members of view, the highest delivered and received
seqno of all digests
|
protected void |
Merger.sendMergeResponse(Address sender,
View view,
Digest digest,
MergeId merge_id)
Send back a response containing view and digest to sender
|
protected static boolean |
GMS.writeAddresses(View view,
Digest digest) |
Modifier and Type | Method and Description |
---|---|
protected MergeData |
Merger.MergeTask.consolidateMergeData(java.util.List<MergeData> merge_rsps,
java.util.List<View> subviews)
Merge all MergeData.
|
protected static java.util.Map<Address,java.util.Collection<Address>> |
Merger.determineMergeCoords(java.util.Map<Address,View> views)
Needs to return a map of all subview coordinators and their views (as a collection of members).
|
protected Address |
Merger.determineMergeLeader(java.util.Map<Address,View> views)
Returns the address of the merge leader
|
void |
ServerGmsImpl.merge(java.util.Map<Address,View> views)
Invoked upon receiving a MERGE event from the MERGE layer.
|
void |
Merger.merge(java.util.Map<Address,View> views)
Invoked upon receiving a MERGE event from the MERGE layer.
|
void |
GmsImpl.merge(java.util.Map<Address,View> views) |
static void |
Merger.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).
|
void |
Merger.MergeTask.start(java.util.Map<Address,View> views) |
Constructor and Description |
---|
JoinRsp(View v,
Digest d) |
MergeData(Address sender,
View view,
Digest digest) |
MergeData(Address sender,
View view,
Digest digest,
boolean merge_rejected) |
Modifier and Type | Field and Description |
---|---|
protected View |
Relayer.Bridge.view |
Modifier and Type | Method and Description |
---|---|
View |
RELAY2.getBridgeView(java.lang.String cluster_name) |
protected View |
Relayer.getBridgeView(java.lang.String cluster_name) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Address> |
RELAY2.determineSiteMasters(View view)
Iterates over the list of members and adds every member if the member's rank is below max_site_masters.
|
protected java.util.Map<java.lang.String,java.util.List<Address>> |
Relayer.Bridge.extract(View view)
Returns a map containing the site keys and addresses as values
|
void |
RELAY2.handleView(View view) |
void |
Relayer.Bridge.viewAccepted(View new_view)
The view contains a list of SiteUUIDs.
|
Modifier and Type | Field and Description |
---|---|
protected View |
SUPERVISOR.view |
Modifier and Type | Method and Description |
---|---|
View |
SUPERVISOR.getView() |
Modifier and Type | Method and Description |
---|---|
protected void |
SUPERVISOR.handleView(View view) |
Modifier and Type | Method and Description |
---|---|
static View |
Util.readView(java.io.DataInput in) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<View> |
Util.detectDifferentViews(java.util.Map<Address,View> map) |
Modifier and Type | Method and Description |
---|---|
static Address |
Util.getCoordinator(View view) |
static int |
Util.getRank(View view,
Address addr)
Returns the rank of a member in a given view
|
static boolean |
Util.isCoordinator(View view,
Address local_addr) |
static int |
Util.size(View view) |
static void |
Util.writeView(View view,
java.io.DataOutput out) |
Modifier and Type | Method and Description |
---|---|
static boolean |
Util.containsViewId(java.util.Collection<View> views,
ViewId vid) |
static java.util.List<View> |
Util.detectDifferentViews(java.util.Map<Address,View> map) |
static java.util.Collection<Address> |
Util.determineActualMergeCoords(java.util.Map<Address,View> map)
Similar to
Util.determineMergeCoords(java.util.Map) but only actual coordinators are counted: an actual
coord is when the sender of a view is the first member of that view |
static java.util.Collection<Address> |
Util.determineMergeCoords(java.util.Map<Address,View> map)
This is the same or a subset of
Util.determineMergeParticipants(java.util.Map) and contains only members
which are currently sub-partition coordinators. |
static java.util.Collection<Address> |
Util.determineMergeParticipants(java.util.Map<Address,View> map)
Determines the members which take part in a merge.
|
static java.lang.String |
Util.printViews(java.util.Collection<View> views) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.