|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use View | |
---|---|
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. |
Uses of View in org.jgroups |
---|
Subclasses of View in org.jgroups | |
---|---|
class |
MergeView
A view that is sent as a result of a cluster merge. |
Fields in org.jgroups declared as View | |
---|---|
protected View |
JChannel.my_view
|
Fields in org.jgroups with type parameters of type View | |
---|---|
protected java.util.List<View> |
MergeView.subgroups
|
Methods in org.jgroups that return View | |
---|---|
View |
MergeView.copy()
|
View |
View.copy()
|
View |
JChannel.getView()
|
abstract View |
Channel.getView()
Gets the current view. |
Methods in org.jgroups that return types with arguments of type View | |
---|---|
java.util.List<View> |
MergeView.getSubgroups()
|
Methods in org.jgroups with parameters of type View | |
---|---|
int |
View.compareTo(View o)
|
void |
MembershipListener.viewAccepted(View new_view)
Called when a change in membership has occurred. |
void |
ReceiverAdapter.viewAccepted(View view)
Called when a change in membership has occurred. |
Constructor parameters in org.jgroups with type arguments of type View | |
---|---|
MergeView(Address creator,
long id,
java.util.List<Address> members,
java.util.List<View> subgroups)
Creates a new view |
|
MergeView(ViewId vid,
java.util.List<Address> members,
java.util.List<View> subgroups)
Creates a new view |
Uses of View in org.jgroups.blocks |
---|
Fields in org.jgroups.blocks declared as View | |
---|---|
protected View |
RequestCorrelator.view
|
Methods in org.jgroups.blocks with parameters of type View | |
---|---|
void |
RequestCorrelator.receiveView(View new_view)
Event.VIEW_CHANGE event received from a layer below. |
void |
PartitionedHashMap.viewAccepted(View new_view)
|
void |
PartitionedHashMap.ConsistentHashFunction.viewAccepted(View new_view)
|
void |
ReplicatedTree.viewAccepted(View new_view)
|
void |
ReplCache.viewAccepted(View new_view)
|
void |
ReplicatedHashMap.viewAccepted(View new_view)
|
void |
ReplicatedTree.ReplicatedTreeListener.viewChange(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() |
abstract void |
Request.viewChange(View new_view)
|
void |
RspCollector.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,
java.util.List<Address> mbrs_joined,
java.util.List<Address> mbrs_left)
|
Uses of View in org.jgroups.demos |
---|
Fields in org.jgroups.demos declared as View | |
---|---|
protected View |
RelayDemoRpc.view
|
Methods in org.jgroups.demos with parameters of type View | |
---|---|
void |
ViewDemo.viewAccepted(View new_view)
|
void |
QuoteServer.viewAccepted(View new_view)
|
void |
QuoteClient.viewAccepted(View new_view)
|
void |
Chat.viewAccepted(View new_view)
|
void |
Draw.viewAccepted(View v)
|
void |
RelayDemoRpc.viewAccepted(View new_view)
|
void |
ReplicatedHashMapDemo.viewChange(View view,
java.util.List<Address> new_mbrs,
java.util.List<Address> old_mbrs)
|
Uses of View in org.jgroups.demos.wb |
---|
Methods in org.jgroups.demos.wb with parameters of type View | |
---|---|
void |
Whiteboard.viewAccepted(View v)
|
Uses of View in org.jgroups.protocols |
---|
Fields in org.jgroups.protocols declared as View | |
---|---|
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 |
PingData.view
|
protected View |
SEQUENCER.view
|
protected View |
MERGE3.view
|
protected View |
MERGE3.MergeHeader.view
|
protected View |
MERGE2.view
|
protected View |
Executing.view
|
protected View |
STOMP.view
|
protected View |
COUNTER.view
|
protected View |
Discovery.view
|
Fields in org.jgroups.protocols with type parameters of type View | |
---|---|
protected ResponseCollector<View> |
MERGE3.view_rsps
|
Methods in org.jgroups.protocols that return View | |
---|---|
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()
|
Methods in org.jgroups.protocols that return types with arguments of type View | |
---|---|
static java.util.List<View> |
MERGE3.detectDifferentViews(java.util.Map<Address,View> map)
|
java.util.Map<Address,View> |
MERGE2.FindSubgroupsTask.getViews(java.util.List<PingData> initial_mbrs)
|
Methods in org.jgroups.protocols with parameters of type View | |
---|---|
static RELAY.ViewData |
RELAY.ViewData.create(View remote_view,
View global_view)
|
static MERGE3.MergeHeader |
MERGE3.MergeHeader.createViewResponse(View 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 |
Locking.handleView(View view)
|
protected void |
RSVP.handleView(View view)
|
void |
PEER_LOCK.handleView(View view)
|
protected void |
DAISYCHAIN.handleView(View view)
|
protected void |
FILE_PING.handleView(View view)
|
void |
CENTRAL_EXECUTOR.handleView(View view)
|
protected void |
RELAY.handleView(View view)
|
void |
CENTRAL_LOCK.handleView(View view)
|
protected void |
Executing.handleView(View view)
|
protected void |
STOMP.handleView(View view)
|
protected void |
COUNTER.handleView(View view)
|
protected void |
FORWARD_TO_COORD.handleViewChange(View view)
|
protected void |
SEQUENCER.handleViewChange(View v)
|
protected void |
RELAY.sendViewOnLocalCluster(View remote_view,
View global_view,
boolean use_seperate_thread,
java.util.List<Address> new_mbrs)
|
void |
PingData.setView(View view)
|
void |
RELAY.Receiver.viewAccepted(View view)
|
Method parameters in org.jgroups.protocols with type arguments of type View | |
---|---|
static java.util.List<View> |
MERGE3.detectDifferentViews(java.util.Map<Address,View> map)
|
Constructors in org.jgroups.protocols with parameters of type View | |
---|---|
MERGE3.MergeHeader(MERGE3.MergeHeader.Type type,
ViewId view_id,
View view,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
|
|
PingData(Address sender,
View view,
boolean is_server)
|
|
PingData(Address sender,
View view,
boolean is_server,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
|
|
PingData(Address sender,
View view,
ViewId view_id,
boolean is_server,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
|
Uses of View in org.jgroups.protocols.pbcast |
---|
Fields in org.jgroups.protocols.pbcast declared as View | |
---|---|
protected View |
GMS.view
|
protected View |
MergeData.view
|
protected View |
NAKACK2.view
|
Methods in org.jgroups.protocols.pbcast that return View | |
---|---|
View |
GMS.getNextView(java.util.Collection<Address> new_mbrs,
java.util.Collection<Address> old_mbrs,
java.util.Collection<Address> suspected_mbrs)
Computes the next view. |
View |
MergeData.getView()
|
View |
JoinRsp.getView()
|
Methods in org.jgroups.protocols.pbcast that return types with arguments of type View | |
---|---|
Tuple<View,Digest> |
GMS.getViewAndDigest()
Returns the current view and digest |
Methods in org.jgroups.protocols.pbcast with parameters of type View | |
---|---|
protected boolean |
GMS._startFlush(View new_view,
int maxAttempts,
boolean resumeIfFailed,
long randomFloor,
long randomCeiling)
|
void |
GMS.castViewChange(View new_view,
Digest digest,
JoinRsp jr,
java.util.Collection<Address> newMembers)
Broadcasts the new view and digest, and waits for acks from all members in the list given as argument. |
protected void |
STATE_SOCK.handleViewChange(View v)
|
protected void |
STATE.handleViewChange(View v)
|
protected void |
StreamingStateTransfer.handleViewChange(View v)
|
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 |
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 |
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. |
Method parameters in org.jgroups.protocols.pbcast with type arguments of type View | |
---|---|
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)
|
void |
CoordGmsImpl.merge(java.util.Map<Address,View> views)
Invoked upon receiving a MERGE event from the MERGE layer. |
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). |
Constructors in org.jgroups.protocols.pbcast with parameters of type View | |
---|---|
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)
|
Uses of View in org.jgroups.protocols.relay |
---|
Fields in org.jgroups.protocols.relay declared as View | |
---|---|
protected View |
Relayer.Bridge.view
|
Methods in org.jgroups.protocols.relay that return View | |
---|---|
protected View |
Relayer.getBridgeView(java.lang.String cluster_name)
|
View |
RELAY2.getBridgeView(java.lang.String cluster_name)
|
Methods in org.jgroups.protocols.relay with parameters of type View | |
---|---|
protected static Address |
RELAY2.determineSiteMaster(View view)
Gets the site master from view. |
protected void |
RELAY2.handleView(View view)
|
void |
Relayer.Bridge.viewAccepted(View new_view)
|
Uses of View in org.jgroups.protocols.rules |
---|
Fields in org.jgroups.protocols.rules declared as View | |
---|---|
protected View |
SUPERVISOR.view
|
Methods in org.jgroups.protocols.rules that return View | |
---|---|
View |
SUPERVISOR.getView()
|
Methods in org.jgroups.protocols.rules with parameters of type View | |
---|---|
protected void |
SUPERVISOR.handleView(View view)
|
Uses of View in org.jgroups.util |
---|
Methods in org.jgroups.util that return View | |
---|---|
static View |
Util.createView(Address coord,
long id,
Address... members)
|
static View |
Util.readView(java.io.DataInput in)
|
Methods in org.jgroups.util that return types with arguments of type View | |
---|---|
static java.util.List<View> |
Util.detectDifferentViews(java.util.Map<Address,View> map)
|
Methods in org.jgroups.util with parameters of type View | |
---|---|
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 java.util.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,
java.io.DataOutput out)
|
Method parameters in org.jgroups.util with type arguments of type View | |
---|---|
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |