类 com.fr.third.jgroups.View
的使用

使用View的程序包

程序包	说明
com.fr.cluster.engine.base
com.fr.ehcache.cluster
com.fr.third.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
com.fr.third.jgroups.blocks	Provides building blocks that are layered on top of channels.
com.fr.third.jgroups.demos	Provides demonstrations of JGroups functionality.
com.fr.third.jgroups.demos.wb	A distributed whiteboard applet implemented using JGroups.
com.fr.third.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
com.fr.third.jgroups.protocols.pbcast	Supports probabilistic broadcasts.
com.fr.third.jgroups.protocols.relay
com.fr.third.jgroups.protocols.rules
com.fr.third.jgroups.tests
com.fr.third.jgroups.tests.perf
com.fr.third.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

com.fr.cluster.engine.base中View的使用

类型参数类型为View的com.fr.cluster.engine.base中的字段

限定符和类型	字段和说明
static Event<View>	ClusterCommand.REFRESH 刷新视图

类型变量类型为View的com.fr.cluster.engine.base中的方法参数

限定符和类型	方法和说明
static java.util.List<ClusterMergeSubView>	ClusterEngineUtils.translateMergeSubView(java.util.List<View> subGroups) jgroup 的view 转换成子view

com.fr.ehcache.cluster中View的使用

参数类型为View的com.fr.ehcache.cluster中的方法

限定符和类型	方法和说明
void	JGroupsCacheReceiver.viewAccepted(View newView) Called when a change in membership has occurred.

com.fr.third.jgroups中View的使用

com.fr.third.jgroups中View的子类

限定符和类型	类和说明
class	MergeView A view that is sent as a result of a cluster merge.

声明为View的com.fr.third.jgroups中的字段

限定符和类型	字段和说明
protected View	JChannel.my_view
protected View[]	MergeView.subgroups

返回View的com.fr.third.jgroups中的方法

限定符和类型	方法和说明
View	View.copy() 已过时。 View is immutable, so copy() is unnecessary
static View	View.create(Address coord, long id, Address... members)
View	JChannel.getView()
abstract View	Channel.getView() Gets the current view.
protected static View[]	MergeView.listToArray(java.util.List<View> list)

返回变量类型为View的类型的com.fr.third.jgroups中的方法

限定符和类型	方法和说明
java.util.List<View>	MergeView.getSubgroups()

参数类型为View的com.fr.third.jgroups中的方法

限定符和类型	方法和说明
int	View.compareTo(View o)
boolean	View.deepEquals(View other)
boolean	MergeView.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.

类型变量类型为View的com.fr.third.jgroups中的方法参数

限定符和类型	方法和说明
protected static View[]	MergeView.listToArray(java.util.List<View> list)

类型变量类型为View的com.fr.third.jgroups中的构造器参数

构造器和说明
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

com.fr.third.jgroups.blocks中View的使用

声明为View的com.fr.third.jgroups.blocks中的字段

限定符和类型	字段和说明
protected View	RequestCorrelator.view

参数类型为View的com.fr.third.jgroups.blocks中的方法

限定符和类型	方法和说明
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, java.util.List<Address> mbrs_joined, java.util.List<Address> mbrs_left)

com.fr.third.jgroups.demos中View的使用

声明为View的com.fr.third.jgroups.demos中的字段

限定符和类型	字段和说明
protected View	RelayDemoRpc.view

参数类型为View的com.fr.third.jgroups.demos中的方法

限定符和类型	方法和说明
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, java.util.List<Address> new_mbrs, java.util.List<Address> old_mbrs)

com.fr.third.jgroups.demos.wb中View的使用

参数类型为View的com.fr.third.jgroups.demos.wb中的方法

限定符和类型	方法和说明
void	Whiteboard.viewAccepted(View v)

com.fr.third.jgroups.protocols中View的使用

声明为View的com.fr.third.jgroups.protocols中的字段

限定符和类型	字段和说明
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	FILE_PING.prev_view
protected View	RELAY.remote_view The view of the remote cluster
protected View	RELAY.ViewData.remote_view
protected View	STOMP.view
protected View	SHARED_LOOPBACK.view
protected View	SEQUENCER2.view
protected View	SEQUENCER.view
protected View	MERGE3.view
protected View	MERGE2.view 已过时。
protected View	MERGE2.MergeHeader.view
protected View	Locking.view
protected View	Executing.view
protected View	Discovery.view
protected View	COUNTER.view

类型参数类型为View的com.fr.third.jgroups.protocols中的字段

限定符和类型	字段和说明
protected ResponseCollector<View>	MERGE3.view_rsps
protected java.util.Map<Address,View>	MERGE2.views 已过时。

返回View的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
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的类型的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
static java.util.List<View>	MERGE3.detectDifferentViews(java.util.Map<Address,View> map)

参数类型为View的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
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	RSVP.handleView(View view)
protected void	RELAY.handleView(View view)
void	PEER_LOCK.handleView(View view)
protected void	Locking.handleView(View view)
protected void	FD_HOST.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	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	SEQUENCER2.handleViewChange(View v)
protected void	SEQUENCER.handleViewChange(View v)
protected void	FRAG2.handleViewChange(View view)
protected void	FORWARD_TO_COORD.handleViewChange(View view)
protected void	FD_ALL2.handleViewChange(View v)
protected void	FD_ALL.handleViewChange(View v)
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)

类型变量类型为View的com.fr.third.jgroups.protocols中的方法参数

限定符和类型	方法和说明
static java.util.List<View>	MERGE3.detectDifferentViews(java.util.Map<Address,View> map)

参数类型为View的com.fr.third.jgroups.protocols中的构造器

构造器和说明
MERGE2.MergeHeader(byte type, View view)
PingData(Address sender, View view, boolean is_server, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs) 已过时。 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) 已过时。 Use the constructor with a single PhysicalAddress instead

com.fr.third.jgroups.protocols.pbcast中View的使用

com.fr.third.jgroups.protocols.pbcast中View的子类

限定符和类型	类和说明
class	DeltaView Subclass of View with a null members field.

声明为View的com.fr.third.jgroups.protocols.pbcast中的字段

限定符和类型	字段和说明
protected View	STATE_TRANSFER.view
protected View	STABLE.view
protected View	NAKACK2.view
protected View	MergeData.view
protected View	JoinRsp.view
protected View	GMS.view

类型参数类型为View的com.fr.third.jgroups.protocols.pbcast中的字段

限定符和类型	字段和说明
protected java.util.Set<View>	Merger.MergeTask.subviews

返回View的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
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	MergeData.getView()
View	JoinRsp.getView()

返回变量类型为View的类型的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
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)

参数类型为View的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
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 static int	STABLE.getRank(Address member, View v)
protected void	StreamingStateTransfer.handleViewChange(View v)
protected void	STATE_TRANSFER.handleViewChange(View v)
protected void	STATE_SOCK.handleViewChange(View v)
protected void	STATE.handleViewChange(View v)
protected void	STABLE.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.
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 static boolean	GMS.writeAddresses(View view, Digest digest)

类型变量类型为View的com.fr.third.jgroups.protocols.pbcast中的方法参数

限定符和类型	方法和说明
protected MergeData	Merger.MergeTask.consolidateMergeData(java.util.List<MergeData> merge_rsps, java.util.List<View> subviews) Merge all MergeData.
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).
void	Merger.MergeTask.start(java.util.Map<Address,View> views)

参数类型为View的com.fr.third.jgroups.protocols.pbcast中的构造器

构造器和说明
JoinRsp(View v, Digest d)
MergeData(Address sender, View view, Digest digest)
MergeData(Address sender, View view, Digest digest, boolean merge_rejected)

com.fr.third.jgroups.protocols.relay中View的使用

声明为View的com.fr.third.jgroups.protocols.relay中的字段

限定符和类型	字段和说明
protected View	Relayer.Bridge.view

返回View的com.fr.third.jgroups.protocols.relay中的方法

限定符和类型	方法和说明
protected View	Relayer.getBridgeView(java.lang.String cluster_name)
View	RELAY2.getBridgeView(java.lang.String cluster_name)

参数类型为View的com.fr.third.jgroups.protocols.relay中的方法

限定符和类型	方法和说明
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.

com.fr.third.jgroups.protocols.rules中View的使用

声明为View的com.fr.third.jgroups.protocols.rules中的字段

限定符和类型	字段和说明
protected View	SUPERVISOR.view

返回View的com.fr.third.jgroups.protocols.rules中的方法

限定符和类型	方法和说明
View	SUPERVISOR.getView()

参数类型为View的com.fr.third.jgroups.protocols.rules中的方法

限定符和类型	方法和说明
protected void	SUPERVISOR.handleView(View view)

com.fr.third.jgroups.tests中View的使用

参数类型为View的com.fr.third.jgroups.tests中的方法

限定符和类型	方法和说明
void	UnicastTestRpc.viewAccepted(View new_view)
void	UnicastTest.MyReceiver.viewAccepted(View new_view)
void	RpcDispatcherSpeedTest.viewAccepted(View new_view)
void	RpcDispatcherBlocking.viewAccepted(View new_view)
void	PingPong.viewAccepted(View new_view)
void	MessageDispatcherSpeedTest.viewAccepted(View new_view)
void	LargeState.viewAccepted(View new_view)
void	FlowControlTest.viewAccepted(View view)

com.fr.third.jgroups.tests.perf中View的使用

声明为View的com.fr.third.jgroups.tests.perf中的字段

限定符和类型	字段和说明
protected View	UPerf.view

参数类型为View的com.fr.third.jgroups.tests.perf中的方法

限定符和类型	方法和说明
void	UUPerf.viewAccepted(View new_view)
void	UPerf.viewAccepted(View new_view)
void	MPerfRpc.viewAccepted(View view)
void	MPerf.viewAccepted(View view)

com.fr.third.jgroups.util中View的使用

返回View的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
static View	Util.readView(java.io.DataInput in)

返回变量类型为View的类型的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
static java.util.List<View>	Util.detectDifferentViews(java.util.Map<Address,View> map)

参数类型为View的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
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)

类型变量类型为View的com.fr.third.jgroups.util中的方法参数

限定符和类型	方法和说明
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)