Package | Description |
---|---|
org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
org.infinispan.util.logging |
Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
|
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.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method and Description |
---|---|
void |
JGroupsTransport.viewAccepted(View newView) |
Modifier and Type | Method and Description |
---|---|
void |
Log.receivedClusterView(View newView) |
void |
Log.receivedMergedView(View newView) |
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 List<View> |
MergeView.subgroups |
Modifier and Type | Method and Description |
---|---|
View |
View.copy() |
View |
MergeView.copy() |
View |
JChannel.getView() |
abstract View |
Channel.getView()
Gets the current view.
|
Modifier and Type | Method and Description |
---|---|
List<View> |
MergeView.getSubgroups() |
Modifier and Type | Method and Description |
---|---|
int |
View.compareTo(View o) |
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.
|
Constructor and Description |
---|
MergeView(Address creator,
long id,
List<Address> members,
List<View> subgroups)
Creates a new view
|
MergeView(ViewId vid,
List<Address> members,
List<View> subgroups)
Creates a new 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 |
ReplicatedTree.viewAccepted(View new_view) |
void |
ReplicatedHashMap.viewAccepted(View new_view) |
void |
ReplCache.viewAccepted(View new_view) |
void |
PartitionedHashMap.viewAccepted(View new_view) |
void |
PartitionedHashMap.ConsistentHashFunction.viewAccepted(View new_view) |
void |
UnicastRequest.viewChange(View new_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 |
RspCollector.viewChange(View new_view) |
abstract void |
Request.viewChange(View new_view) |
void |
ReplicatedTree.ReplicatedTreeListener.viewChange(View new_view) |
void |
GroupRequest.viewChange(View new_view)
Any member of 'membership' that is not in the new view is flagged as
SUSPECTED.
|
void |
ReplicatedHashMap.Notification.viewChange(View view,
List<Address> mbrs_joined,
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 |
RelayDemoRpc.viewAccepted(View new_view) |
void |
QuoteServer.viewAccepted(View new_view) |
void |
QuoteClient.viewAccepted(View new_view) |
void |
Draw.viewAccepted(View v) |
void |
Chat.viewAccepted(View new_view) |
void |
ReplicatedHashMapDemo.viewChange(View view,
List<Address> new_mbrs,
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 |
STOMP.view |
protected View |
PingData.view |
protected View |
MERGE2.view |
protected View |
Locking.view |
protected View |
Executing.view |
protected View |
Discovery.view |
protected View |
COUNTER.view |
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 |
PingData.getView() |
Modifier and Type | Method and Description |
---|---|
List<View> |
MERGE2.FindSubgroupsTask.detectDifferentViews(Map<Address,View> map) |
Map<Address,View> |
MERGE2.FindSubgroupsTask.getViews(List<PingData> initial_mbrs) |
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) |
protected void |
STOMP.handleView(View view) |
protected void |
RELAY.handleView(View view) |
void |
PEER_LOCK.handleView(View view) |
protected void |
Locking.handleView(View view) |
protected void |
FILE_PING.handleView(View view) |
protected void |
Executing.handleView(View view) |
protected void |
DAISYCHAIN.handleView(View view) |
protected void |
COUNTER.handleView(View view) |
void |
CENTRAL_LOCK.handleView(View view) |
void |
CENTRAL_EXECUTOR.handleView(View view) |
protected void |
RELAY.sendViewOnLocalCluster(View remote_view,
View global_view,
boolean use_seperate_thread,
List<Address> new_mbrs) |
void |
PingData.setView(View view) |
void |
RELAY.Receiver.viewAccepted(View view) |
Modifier and Type | Method and Description |
---|---|
List<View> |
MERGE2.FindSubgroupsTask.detectDifferentViews(Map<Address,View> map) |
Constructor and Description |
---|
PingData(Address own_addr,
View view,
boolean is_server) |
PingData(Address own_addr,
View view,
boolean is_server,
String logical_name,
Collection<PhysicalAddress> physical_addrs) |
PingData(Address own_addr,
View view,
ViewId view_id,
boolean is_server,
String logical_name,
Collection<PhysicalAddress> physical_addrs) |
Modifier and Type | Field and Description |
---|---|
protected View |
MergeData.view |
protected View |
GMS.view |
Modifier and Type | Method and Description |
---|---|
View |
GMS.getNextView(Collection<Address> new_mbrs,
Collection<Address> old_mbrs,
Collection<Address> suspected_mbrs)
Computes the next view.
|
View |
MergeData.getView() |
View |
JoinRsp.getView() |
Modifier and Type | Method and Description |
---|---|
Tuple<View,Digest> |
GMS.getViewAndDigest()
Returns the current view and digest
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
GMS._startFlush(View new_view,
int maxAttempts,
long randomFloor,
long randomCeiling) |
void |
GMS.castViewChangeWithDest(View new_view,
Digest digest,
JoinRsp jr,
Collection<Address> newMembers)
Broadcasts the new view and digest, and waits for acks from all members in the list given as argument.
|
protected void |
StreamingStateTransfer.handleViewChange(View v) |
protected void |
STATE_SOCK.handleViewChange(View v) |
protected void |
STATE.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 |
GmsImpl.handleViewChange(View new_view,
Digest digest) |
void |
CoordGmsImpl.handleViewChange(View new_view,
Digest digest)
Called by the GMS when a VIEW is received.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
Merger.merge(Map<Address,View> views)
Invoked upon receiving a MERGE event from the MERGE layer.
|
void |
GmsImpl.merge(Map<Address,View> views) |
void |
CoordGmsImpl.merge(Map<Address,View> views)
Invoked upon receiving a MERGE event from the MERGE layer.
|
static void |
Merger.sanitizeViews(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).
|
Constructor and Description |
---|
GMS.GmsHeader(byte type,
View view)
Used for VIEW header
|
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 | Method and Description |
---|---|
static View |
Util.createView(Address coord,
long id,
Address... members) |
static View |
Util.readView(DataInput in) |
Modifier and Type | Method and Description |
---|---|
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 List<Address> |
Util.leftMembers(View one,
View two)
Returns a list of members which left from view one to two
|
static int |
Util.size(View view) |
static void |
Util.writeView(View view,
DataOutput out) |
Modifier and Type | Method and Description |
---|---|
static boolean |
Util.containsViewId(Collection<View> views,
ViewId vid) |
static Collection<Address> |
Util.determineMergeCoords(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 Collection<Address> |
Util.determineMergeParticipants(Map<Address,View> map)
Determines the members which take part in a merge.
|
static String |
Util.printViews(Collection<View> views) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.