Package org.jgroups.protocols.pbcast

Class DeltaView

java.lang.Object

org.jgroups.View

org.jgroups.protocols.pbcast.DeltaView

All Implemented Interfaces:

Comparable<View>, Iterable<Address>, Constructable<View>, SizeStreamable, Streamable

public class DeltaView
extends View

Subclass of View with a null members field. Adds an array for left members and one for joined members compared to the previous view. A recipient receiving a DeltaView can construct a new view by grabbing the view corresponding to View.view_id, removing the left members and adding the new members.

This class is only used with VIEW messages in GMS to install new views (not merge views). When a VIEW message is received, the DeltaView is read from the GMS.GmsHeader, a View is constructured and the header discarded. Therefore, the lifetime of a DeltaView is short: it is created and set in a GmsHeader, the header is then marshalled. On the receiving side, the DeltaView is created from the stream, a View is created and the DeltaView discarded again.

Instances of this class are created by CoordGmsImpl.handleMembershipChange(java.util.Collection).

JIRA issue: https://issues.redhat.com/browse/JGRP-1354

Since:

3.4

Field Summary

Fields

Modifier and Type	Field	Description
protected Address[]	left_members	Members which left the view corresponding to ref_view_id
protected Address[]	new_members	Members which joined the view corresponding to ref_view_id
protected ViewId	ref_view_id	The fields left_members and new_members refer to the view corresponding to ref_view_id

Fields inherited from class org.jgroups.View

members, suppress_view_size, view_id

Constructor Summary

Constructors

Constructor	Description
DeltaView()
DeltaView(ViewId view_id, ViewId ref_view_id, Address[] left_members, Address[] new_members)

Method Summary

Modifier and Type	Method	Description
Address[]	getLeftMembers()
Address[]	getNewMembers()
ViewId	getRefViewId()
Iterator<Address>	iterator()
void	readFrom(DataInput in)	Read the state of the current object (including superclasses) from instream Note that the input stream must not be closed
int	serializedSize()	Returns the size (in bytes) of the marshalled object
String	toString()
void	writeTo(DataOutput out)	Write the entire state of the current object (including superclasses) to outstream.

Methods inherited from class org.jgroups.View

compareTo, containsMember, containsMembers, create, create, create, deepEquals, diff, equals, getCoord, getCreator, getMembers, getMembersRaw, getViewId, hashCode, leftMembers, newMembers, printDiff, sameMembers, sameMembersOrdered, sameViews, sameViews, size

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

ref_view_id

protected ViewId ref_view_id

The fields left_members and new_members refer to the view corresponding to ref_view_id

left_members

protected Address[] left_members

Members which left the view corresponding to ref_view_id

new_members

protected Address[] new_members

Members which joined the view corresponding to ref_view_id

Constructor Details

DeltaView

public DeltaView()

DeltaView

public DeltaView(ViewId view_id,
 ViewId ref_view_id,
 Address[] left_members,
 Address[] new_members)

Method Details

getRefViewId

public ViewId getRefViewId()

getLeftMembers

public Address[] getLeftMembers()

getNewMembers

public Address[] getNewMembers()

serializedSize

public int serializedSize()

Description copied from interface: SizeStreamable

Returns the size (in bytes) of the marshalled object

Specified by:

serializedSize in interface SizeStreamable

Overrides:

serializedSize in class View

writeTo

public void writeTo(DataOutput out)
             throws IOException

Description copied from interface: Streamable

Write the entire state of the current object (including superclasses) to outstream. Note that the output stream must not be closed

Specified by:

writeTo in interface Streamable

Overrides:

writeTo in class View

Throws:

IOException

readFrom

public void readFrom(DataInput in)
              throws IOException,
ClassNotFoundException

Description copied from interface: Streamable

Read the state of the current object (including superclasses) from instream Note that the input stream must not be closed

Specified by:

readFrom in interface Streamable

Overrides:

readFrom in class View

Throws:

IOException

ClassNotFoundException

iterator

public Iterator<Address> iterator()

Specified by:

iterator in interface Iterable<Address>

Overrides:

iterator in class View

toString

public String toString()

Overrides:

toString in class View