Uses of Interface
org.jgroups.Address
Packages that use Address
Package
Description
Provides top-level public JGroups classes such as Channel, Message, etc.
Provides building blocks that are layered on top of channels.
Provides debug support, including testing, profiling, and a graphical view of a protocol stack.
Provides demonstrations of JGroups functionality.
A distributed whiteboard applet implemented using JGroups.
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
Supports probabilistic broadcasts.
Support for managing protocol stacks.
Provides useful functionality which cannot be assigned to any particular other package.
-
Uses of Address in org.jgroups
Fields in org.jgroups declared as AddressModifier and TypeFieldDescriptionprotected Address
Message.dest_addr
protected Address
Message.src_addr
Fields in org.jgroups with type parameters of type AddressModifier and TypeFieldDescriptionView.members
A list containing all the members of the view This list is always ordered, with the coordinator being the first member.Methods in org.jgroups that return AddressModifier and TypeMethodDescriptionMembership.elementAt
(int index) Returns the component at the specified indexViewId.getCoordAddress()
returns the address of the member that issued this viewView.getCreator()
returns the creator of this view if this view was created with the empty constructur, null will be returnedMessage.getDest()
abstract Address
Channel.getLocalAddress()
Returns the channel's own address.JChannel.getLocalAddress()
returns the local address of the channel returns null if the channel is closedMessage.getSrc()
Methods in org.jgroups that return types with arguments of type AddressModifier and TypeMethodDescriptionMembership.getMembers()
returns a copy (clone) of the members in this membership.View.getMembers()
Returns a reference to the List of members (ordered) Do NOT change this list, hence your will invalidate the view Make a copy if you have to modify it.Methods in org.jgroups with parameters of type AddressModifier and TypeMethodDescriptionvoid
Adds a new member to this membership.void
ChannelListener.channelReconnected
(Address addr) void
ChannelListenerAdapter.channelReconnected
(Address addr) abstract void
Connects the channel to a group and fetches the statevoid
Connects this channel to a group and gets a state from a specified state provider.boolean
Returns true if the provided member belongs to this membershipboolean
View.containsMember
(Address mbr) returns true, if this view contains a certain memberabstract boolean
Retrieve the state of the group.abstract boolean
Fetches a partial state identified by state_id.boolean
Retrieves a full state from the target member.boolean
Retrieves a substate (or partial state) indicated by state_id from the target member.boolean
Retrieves a substate (or partial state) indicated by state_id from the target member.protected boolean
Retrieves a substate (or partial state) indicated by state_id from the target member.protected void
Channel.notifyChannelReconnected
(Address addr) void
removes an member from the membership.abstract void
Channel.send
(Address dst, Address src, Serializable obj) Helper method.void
JChannel.send
(Address dst, Address src, Serializable obj) creates a new message with the destination address, and the source address and the object as the message valuevoid
void
void
void
Called whenever a member is suspected of having crashed, but has not yet been excluded.void
Method parameters in org.jgroups with type arguments of type AddressModifier and TypeMethodDescriptionfinal void
Membership.add
(Collection<Address> v) Adds a list of members to this membershipvoid
Membership.merge
(Collection<Address> new_mems, Collection<Address> suspects) merges membership with the new members and removes suspects The Merge method will remove all the suspects and add in the new members.void
Membership.remove
(Collection<Address> v) removes all the members contained in v from this membershipvoid
Membership.set
(Collection<Address> v) Clear the membership and adds all members of v This method will clear out all the old members of this membership by invoking theClear
method.abstract boolean
Channel.startFlush
(List<Address> flushParticipants, boolean automatic_resume) boolean
JChannel.startFlush
(List<Address> flushParticipants, boolean automatic_resume) Performs a partial flush in a cluster for flush participants.abstract void
void
Constructors in org.jgroups with parameters of type AddressModifierConstructorDescriptionCreates a new viewPublic constructorPublic constructorConstructs a message.Message
(Address dest, Address src, Serializable obj) Public constructorCreates a new viewCreates a ViewID with the coordinator address and a Lamport timestamp of 0.Creates a ViewID with the coordinator address and the given Lamport timestamp.Constructor parameters in org.jgroups with type arguments of type AddressModifierConstructorDescriptionMembership
(Collection<Address> initial_members) Creates a member ship object with the initial members.Creates a new viewCreates a new viewCreates a new viewCreates a new view -
Uses of Address in org.jgroups.blocks
Fields in org.jgroups.blocks declared as AddressModifier and TypeFieldDescriptionprotected Address
MessageDispatcher.local_addr
protected Address
RequestCorrelator.local_addr
The address of this group memberFields in org.jgroups.blocks with type parameters of type AddressModifier and TypeFieldDescriptionRequestCorrelator.call_stack
This field is used only if deadlock detection is enabled.RequestCorrelator.Header.callStack
Stack<Address>.RequestCorrelator.Header.dest_mbrs
Contains a list of members who should receive the request (others will drop).Methods in org.jgroups.blocks that return AddressModifier and TypeMethodDescriptionGroupRequest.getCaller()
BasicConnectionTable.getLocalAddress()
DistributedHashtable.getLocalAddress()
Deprecated.DistributedQueue.getLocalAddress()
NotificationBus.getLocalAddress()
ReplicatedHashMap.getLocalAddress()
ReplicatedHashtable.getLocalAddress()
Deprecated.ReplicatedTree.getLocalAddress()
RequestCorrelator.getLocalAddress()
Methods in org.jgroups.blocks that return types with arguments of type AddressModifier and TypeMethodDescriptionGroupRequest.getSuspects()
Returns the list of suspected members.Methods in org.jgroups.blocks with parameters of type AddressModifier and TypeMethodDescriptionRpcDispatcher.callRemoteMethod
(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout) RpcDispatcher.callRemoteMethod
(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout) RpcDispatcher.callRemoteMethod
(Address dest, MethodCall method_call, int mode, long timeout) RpcDispatcher.callRemoteMethod
(Address dest, MethodCall method_call, int mode, long timeout, boolean oob) void
PullPushAdapter.channelReconnected
(Address addr) Deprecated.void
RpcDispatcher.channelReconnected
(Address new_addr) void
BasicConnectionTable.ConnectionListener.connectionClosed
(Address peer_addr) void
BasicConnectionTable.ConnectionListener.connectionOpened
(Address peer_addr) NotificationBus.getCacheFromMember
(Address mbr, long timeout, int max_tries) Determines the coordinator and asks it for its cache.boolean
RspFilter.isAcceptable
(Object response, Address sender) Determines whether a response from a given sender should be added to the response list of the requestvoid
NotificationBus.Consumer.memberJoined
(Address mbr) void
NotificationBus.Consumer.memberLeft
(Address mbr) protected void
PullPushAdapter.notifySuspect
(Address suspected_mbr) Deprecated.void
Calls the receiver callback.void
void
GroupRequest.receiveResponse
(Object response_value, Address sender) Callback (called by RequestCorrelator or Transport).void
RspCollector.receiveResponse
(Object response_value, Address sender) void
RequestCorrelator.receiveSuspect
(Address mbr) Event.SUSPECT event received from a layer below.void
BasicConnectionTable.removeConnection
(Address addr) Removeaddr
from connection table.protected void
ConnectionTableNIO.runRequest
(Address addr, ByteBuffer buf) void
void
NotificationBus.sendNotification
(Address dest, Serializable n) Pack the argument in a Info, serialize that one into the message buffer and send the messagevoid
void
RequestCorrelator.setLocalAddress
(Address local_addr) void
Deprecated.Called when a member is suspectedvoid
void
Called when a member is suspectedvoid
Called when a member is suspectedvoid
Callback (called by RequestCorrelator or Transport).void
Notify membership listener that some node was suspected.void
void
Called when a member is suspectedvoid
Deprecated.Called when a member is suspectedvoid
Called when a member is suspectedvoid
void
Callback for notification that one node is suspectedMethod parameters in org.jgroups.blocks with type arguments of type AddressModifier and TypeMethodDescriptionfinal void
This method sets themembership
variable to the value ofmembers
.void
BasicConnectionTable.retainAll
(Collection<Address> current_mbrs) Removes all connections from ConnectionTable which are not in current_mbrsvoid
RequestCorrelator.sendRequest
(long id, List<Address> dest_mbrs, Message msg, RspCollector coll) void
RequestCorrelator.sendRequest
(long id, List<Address> dest_mbrs, Message msg, RspCollector coll, boolean use_anycasting) Send a request to a group.void
ReplicatedHashMap.Notification.viewChange
(View view, Vector<Address> new_mbrs, Vector<Address> old_mbrs) Constructors in org.jgroups.blocks with parameters of type AddressModifierConstructorDescriptionRequestCorrelator
(String name, Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr) RequestCorrelator
(String name, Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing) RequestCorrelator
(String name, Object transport, RequestHandler handler, Address local_addr) Constructor parameters in org.jgroups.blocks with type arguments of type AddressModifierConstructorDescriptionGroupRequest
(Message m, RequestCorrelator corr, Vector<Address> members, int rsp_mode) GroupRequest
(Message m, RequestCorrelator corr, Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs) GroupRequest
(Message m, Transport transport, Vector<Address> members, int rsp_mode) GroupRequest
(Message m, Transport transport, Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs) -
Uses of Address in org.jgroups.debug
Methods in org.jgroups.debug with parameters of type Address -
Uses of Address in org.jgroups.demos
Methods in org.jgroups.demos with parameters of type AddressModifier and TypeMethodDescriptionvoid
Draw.channelReconnected
(Address addr) void
Gossip.channelReconnected
(Address new_addr) void
NotificationBusDemo.memberJoined
(Address mbr) void
NotificationBusDemo.memberLeft
(Address mbr) void
void
void
void
void
Called when a member is suspected -
Uses of Address in org.jgroups.demos.wb
Fields in org.jgroups.demos.wb declared as AddressMethods in org.jgroups.demos.wb with parameters of type Address -
Uses of Address in org.jgroups.jmx
Methods in org.jgroups.jmx that return AddressMethods in org.jgroups.jmx with parameters of type Address -
Uses of Address in org.jgroups.jmx.protocols
Methods in org.jgroups.jmx.protocols that return Address -
Uses of Address in org.jgroups.mux
Methods in org.jgroups.mux that return AddressMethods in org.jgroups.mux with parameters of type AddressModifier and TypeMethodDescriptionvoid
boolean
void
MuxChannel.send
(Address dst, Address src, Serializable obj) Constructors in org.jgroups.mux with parameters of type Address -
Uses of Address in org.jgroups.protocols
Classes in org.jgroups.protocols that implement AddressModifier and TypeClassDescriptionstatic class
SimpleAddress
representing the JMS node ID or JMS topic group.Fields in org.jgroups.protocols declared as AddressModifier and TypeFieldDescriptionPingRsp.coord_addr
protected Address
TP.local_addr
The address (host and port) of this memberprotected Address
PARTITION.local_address
PingRsp.own_addr
Fields in org.jgroups.protocols with type parameters of type AddressModifier and TypeFieldDescriptionTP.members
The members of this group (updated when a member joins or leaves)Methods in org.jgroups.protocols that return AddressModifier and TypeMethodDescriptionprotected Address
UDP.createLocalAddress()
PingRsp.getAddress()
PingRsp.getCoordAddress()
SEQUENCER.getCoordinator()
protected Address
ENCRYPT.getKeyServerAddr()
protected Address
ENCRYPT.getLocal_addr()
SEQUENCER.getLocalAddress()
TP.getLocalAddress()
SEQUENCER.SequencerHeader.getOriginalSender()
Methods in org.jgroups.protocols that return types with arguments of type AddressModifier and TypeMethodDescriptionTCPPING.getInitialHosts()
Returns the list of initial hosts as configured by the user via XML.TP.ProtocolAdapter.getMembers()
Methods in org.jgroups.protocols with parameters of type AddressModifier and TypeMethodDescriptionvoid
DISCARD.addIgnoreMember
(Address sender) Messages from this sender will get droppedprotected void
FD.Broadcaster.addSuspectedMember
(Address mbr) Adds a suspected member.void
FD.BroadcastTask.addSuspectedMember
(Address suspect) void
Called by AgeOutCache, to removed expired connectionsvoid
Discovery.localAddressSet
(Address addr) Called after local_addr was setvoid
PING.localAddressSet
(Address addr) void
TCPPING.localAddressSet
(Address addr) void
BasicTCP.postUnmarshalling
(Message msg, Address dest, Address src, boolean multicast) void
LOOPBACK.postUnmarshalling
(Message msg, Address dest, Address src, boolean multicast) void
SHARED_LOOPBACK.postUnmarshalling
(Message msg, Address dest, Address src, boolean multicast) abstract void
TP.postUnmarshalling
(Message msg, Address dest, Address src, boolean multicast) void
TUNNEL.postUnmarshalling
(Message msg, Address dest, Address src, boolean multicast) void
UDP.postUnmarshalling
(Message msg, Address dest, Address src, boolean multicast) void
BasicTCP.postUnmarshallingList
(Message msg, Address dest, boolean multicast) void
LOOPBACK.postUnmarshallingList
(Message msg, Address dest, boolean multicast) void
SHARED_LOOPBACK.postUnmarshallingList
(Message msg, Address dest, boolean multicast) abstract void
TP.postUnmarshallingList
(Message msg, Address dest, boolean multicast) void
TUNNEL.postUnmarshallingList
(Message msg, Address dest, boolean multicast) void
UDP.postUnmarshallingList
(Message msg, Address dest, boolean multicast) void
ConnectionTable.Receiver interfaceprotected final void
Subclasses must call this method when a unicast or multicast message has been received.boolean
UNICAST.removeConnection
(Address mbr) Removes and resets from connection table (which is already locked).void
DISCARD.removeIgnoredMember
(Address member) void
SMACK.retransmit
(long seqno, Message msg, Address dest) abstract void
void
void
void
BasicTCP.sendToSingleMember
(Address dest, byte[] data, int offset, int length) void
LOOPBACK.sendToSingleMember
(Address dest, byte[] data, int offset, int length) void
SHARED_LOOPBACK.sendToSingleMember
(Address dest, byte[] data, int offset, int length) abstract void
TP.sendToSingleMember
(Address dest, byte[] data, int offset, int length) Send to all members in the group.void
TUNNEL.sendToSingleMember
(Address dest, byte[] data, int offset, int length) void
UDP.sendToSingleMember
(Address dest, byte[] data, int offset, int length) protected void
ENCRYPT.setKeyServerAddr
(Address keyServerAddr) protected void
ENCRYPT.setLocal_addr
(Address local_addr) void
DISCARD.setLocalAddress
(Address localAddress) Method parameters in org.jgroups.protocols with type arguments of type AddressModifier and TypeMethodDescriptionabstract void
BasicTCP.retainAll
(Collection<Address> members) void
TCP_NIO.retainAll
(Collection<Address> members) void
TCP.retainAll
(Collection<Address> members) Constructors in org.jgroups.protocols with parameters of type AddressModifierConstructorDescriptionCoordAnnouncement
(Address coord) HTotalHeader
(Address dest, Address src) MergefastHeader
(Address coord) ProtocolAdapter
(String cluster_name, String transport_name, Protocol up, Protocol down, String pattern, Address addr) SequencerHeader
(byte type, Address original_sender, long seqno) Constructor parameters in org.jgroups.protocols with type arguments of type Address -
Uses of Address in org.jgroups.protocols.pbcast
Methods in org.jgroups.protocols.pbcast that return AddressModifier and TypeMethodDescriptionprotected Address
GMS.determineCoordinator()
GMS.GmsHeader.getMember()
MergeData.getSender()
Methods in org.jgroups.protocols.pbcast with parameters of type AddressModifier and TypeMethodDescriptionvoid
Gossip.addToSeenList
(Address mbr) double
NAKACK.getSmoothedAverageRetransmissionTime
(Address sender) Returns the smoothed average retransmission time for a given sendervoid
CoordGmsImpl.handleDigestResponse
(Address sender, Digest digest) void
GmsImpl.handleDigestResponse
(Address sender, Digest digest) void
CoordGmsImpl.handleMergeRequest
(Address sender, ViewId merge_id) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.void
GmsImpl.handleMergeRequest
(Address sender, ViewId merge_id) void
ParticipantGmsImpl.handleMergeRequest
(Address sender, ViewId merge_id) void
void
abstract void
void
void
ClientGmsImpl.joinWithStateTransfer
(Address address) void
CoordGmsImpl.joinWithStateTransfer
(Address mbr) abstract void
GmsImpl.joinWithStateTransfer
(Address local_addr) void
ParticipantGmsImpl.joinWithStateTransfer
(Address mbr) void
void
The coordinator itself wants to leave the groupabstract void
void
Loop: determine coord.void
NAKACK.messageGapDetected
(long from, long to, Address src) Called when a message gap is detectedvoid
NAKACK.missingMessageReceived
(long seqno, Address original_sender) void
Gossip.removeFromNotSeenList
(Address mbr) Removes obj from not_seen listvoid
NAKACK.retransmit
(long first_seqno, long last_seqno, Address sender) Implementation of Retransmitter.RetransmitCommand.protected void
NAKACK.retransmit
(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request) void
GMS.sendJoinResponse
(JoinRsp rsp, Address dest) protected void
GmsImpl.sendMergeRejectedResponse
(Address sender, ViewId merge_id) void
void
abstract void
void
void
void
abstract void
void
Removes previously suspected member from list of currently suspected membersprotected boolean
GMS.wouldBeNewCoordinator
(Address potential_new_coord) Checks whether the potential_new_coord would be the new coordinator (2nd in line)Method parameters in org.jgroups.protocols.pbcast with type arguments of type AddressModifier and TypeMethodDescriptionvoid
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 boolean
GMS.checkSelfInclusion
(Vector<Address> mbrs) Returns true if local_addr is member of mbrs, else falseGMS.getNextView
(Collection<Address> new_mbrs, Collection<Address> old_mbrs, Collection<Address> suspected_mbrs) Computes the next view.static View
void
Invoked upon receiving a MERGE event from the MERGE layer.void
Constructors in org.jgroups.protocols.pbcast with parameters of type AddressModifierConstructorDescriptionUsed for JOIN_REQ or LEAVE_REQ headerNakAckHeader
(byte type, long low, long high, Address sender) StateHeader
(byte type, Address sender, long id, Digest digest) StateHeader
(byte type, Address sender, long id, Digest digest, String state_id) StateHeader
(byte type, Address sender, long id, Digest digest) StateHeader
(byte type, Address sender, String state_id) StateHeader
(byte type, Address sender, IpAddress bind_addr, Digest digest, String state_id) Constructor parameters in org.jgroups.protocols.pbcast with type arguments of type Address -
Uses of Address in org.jgroups.stack
Classes in org.jgroups.stack that implement AddressFields in org.jgroups.stack declared as AddressMethods in org.jgroups.stack that return AddressMethods in org.jgroups.stack that return types with arguments of type AddressModifier and TypeMethodDescriptionGossipClient.getMembers
(String group) Returns all members of a given groupMethods in org.jgroups.stack with parameters of type AddressModifier and TypeMethodDescriptionvoid
An ACK has been received fromsender
.void
NakReceiverWindow.Listener.messageGapDetected
(long from, long to, Address src) void
NakReceiverWindow.Listener.missingMessageReceived
(long seqno, Address original_sender) void
Adds the member to the given group.void
Removeobj
from all receiver sets and wake up retransmission thread.void
AckMcastSenderWindow.RetransmitCommand.retransmit
(long seqno, Message msg, Address dest) Retranmit the given msgvoid
AckSenderWindow.retransmit
(long first_seqno, long last_seqno, Address sender) void
Retransmitter.RetransmitCommand.retransmit
(long first_seqno, long last_seqno, Address sender) Get the missing messages between sequence numbersfirst_seqno
andlast_seqno
.void
RouterStub.sendToSingleMember
(Address dest, byte[] data, int offset, int length) void
Process with addresssuspected
is suspected: remove it from all receiver sets.void
GossipClient.unregister
(String group, Address mbr) Constructors in org.jgroups.stack with parameters of type AddressModifierConstructorDescriptionAckSenderWindow
(AckSenderWindow.RetransmitCommand com, Interval interval, TimeScheduler sched, Address sender) GossipData
(byte type, String group, Address addr, List mbrs) NakReceiverWindow
(Address local_addr, Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched) NakReceiverWindow
(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno) Creates a new instance with the given retransmit commandNakReceiverWindow
(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched) Creates a new instance with the given retransmit commandNakReceiverWindow
(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, TimeScheduler sched) Creates a new instance with the given retransmit commandRetransmitter
(Address sender, Retransmitter.RetransmitCommand cmd) Create a new Retransmitter associated with the given sender addressRetransmitter
(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched) Create a new Retransmitter associated with the given sender addressStateTransferInfo
(Address target) StateTransferInfo
(Address target, long timeout) StateTransferInfo
(Address target, InputStream is, String state_id) StateTransferInfo
(Address target, OutputStream os, String state_id) StateTransferInfo
(Address target, String state_id, long timeout) StateTransferInfo
(Address target, String state_id, long timeout, byte[] state) -
Uses of Address in org.jgroups.util
Fields in org.jgroups.util with type parameters of type AddressModifier and TypeFieldDescriptionprotected final Map
<Address, Digest.Entry> Digest.senders
Map<Address, Entry>Methods in org.jgroups.util that return AddressModifier and TypeMethodDescriptionRsp.getSender()
static Address
Util.readAddress
(DataInputStream in) Methods in org.jgroups.util that return types with arguments of type AddressModifier and TypeMethodDescriptionUtil.determineLeftMembers
(Vector<Address> old_mbrs, Vector<Address> new_mbrs) Returns all members that left between 2 views.RspList.entrySet()
ResponseCollector.getResults()
Digest.getSenders()
Returns an unmodifiable map, so modifications will result in exceptionsMutableDigest.getSenders()
RspList.getSuspectedMembers()
RspList.keySet()
static Collection
<Address> Util.readAddresses
(DataInputStream in, Class cl) Methods in org.jgroups.util with parameters of type AddressModifier and TypeMethodDescriptionvoid
void
MutableDigest.add
(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno) void
boolean
void
RspList.addNotReceived
(Address sender) void
void
RspList.addSuspect
(Address sender) boolean
static View
Util.createView
(Address coord, long id, Address... members) void
Returns the Entry for the given sender.long
SeqnoTable.getHighestReceived
(Address member) long
SeqnoTable.getNextToReceive
(Address member) long
Digest.highestDeliveredSeqnoAt
(Address sender) long
Digest.highestReceivedSeqnoAt
(Address sender) void
MutableDigest.incrementHighestDeliveredSeqno
(Address sender) Increments the sender's high_seqno by 1.boolean
RspList.isReceived
(Address sender) boolean
RspList.isSuspected
(Address sender) long
Digest.lowSeqnoAt
(Address sender) void
MutableDigest.merge
(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno) Similar to add(), but if the sender already exists, its seqnos will be modified (no new entry) as follows: this.low_seqno=min(this.low_seqno, low_seqno) this.highest_delivered_seqno=max(this.highest_delivered_seqno, highest_delivered_seqno) this.highest_received_seqno=max(this.highest_received_seqno, highest_received_seqno) If the sender doesn not exist, a new entry will be added (provided there is enough space)void
void
void
void
Resets the seqnos for the sender at 'index' to 0.static boolean
Checks whether 2 Addresses are on the same hostboolean
MutableDigest.set
(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno) void
MutableDigest.setHighestDeliveredAndSeenSeqnos
(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno) static int
void
void
void
static void
Util.writeAddress
(Address addr, DataOutputStream out) Method parameters in org.jgroups.util with type arguments of type AddressModifier and TypeMethodDescriptionUtil.determineLeftMembers
(Vector<Address> old_mbrs, Vector<Address> new_mbrs) Returns all members that left between 2 views.void
void
void
ResponseCollector.reset
(Collection<Address> members) boolean
SeqnoTable.retainAll
(Collection<Address> members) static boolean
Util.startFlush
(Channel c, List<Address> flushParticipants) static boolean
Util.startFlush
(Channel c, List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling) Constructors in org.jgroups.util with parameters of type AddressModifierConstructorDescriptionConstructor parameters in org.jgroups.util with type arguments of type AddressModifierConstructorDescriptionDigest
(Map<Address, Digest.Entry> map) Creates a new digest from an existing map by copying the keys and values from mapMutableDigest
(Map<Address, Digest.Entry> map) ResponseCollector
(Collection<Address> members)