Uses of Interface
org.jgroups.Address
-
Packages that use Address Package Description 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.debug Provides debug support, including testing, profiling, and a graphical view of a protocol stack.org.jgroups.demos Provides demonstrations of JGroups functionality.org.jgroups.demos.wb A distributed whiteboard applet implemented using JGroups.org.jgroups.jmx org.jgroups.jmx.protocols org.jgroups.mux 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.stack Support for managing protocol stacks.org.jgroups.util Provides useful functionality which cannot be assigned to any particular other package. -
-
Uses of Address in org.jgroups
Fields in org.jgroups declared as Address Modifier and Type Field Description protected Address
Message. dest_addr
protected Address
Message. src_addr
Fields in org.jgroups with type parameters of type Address Modifier and Type Field Description protected java.util.Vector<Address>
View. 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 Address Modifier and Type Method Description Address
Membership. elementAt(int index)
Returns the component at the specified indexAddress
ViewId. getCoordAddress()
returns the address of the member that issued this viewAddress
View. getCreator()
returns the creator of this view if this view was created with the empty constructur, null will be returnedAddress
Message. getDest()
abstract Address
Channel. getLocalAddress()
Returns the channel's own address.Address
JChannel. getLocalAddress()
returns the local address of the channel returns null if the channel is closedAddress
Message. getSrc()
Methods in org.jgroups that return types with arguments of type Address Modifier and Type Method Description java.util.Vector<Address>
Membership. getMembers()
returns a copy (clone) of the members in this membership.java.util.Vector<Address>
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 Address Modifier and Type Method Description void
Membership. add(Address new_member)
Adds a new member to this membership.void
ChannelListener. channelReconnected(Address addr)
void
ChannelListenerAdapter. channelReconnected(Address addr)
abstract void
Channel. connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
Connects the channel to a group and fetches the statevoid
JChannel. connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
Connects this channel to a group and gets a state from a specified state provider.boolean
Membership. contains(Address member)
Returns true if the provided member belongs to this membershipboolean
View. containsMember(Address mbr)
returns true, if this view contains a certain memberabstract boolean
Channel. getState(Address target, long timeout)
Retrieve the state of the group.abstract boolean
Channel. getState(Address target, java.lang.String state_id, long timeout)
Fetches a partial state identified by state_id.boolean
JChannel. getState(Address target, long timeout)
Retrieves a full state from the target member.boolean
JChannel. getState(Address target, java.lang.String state_id, long timeout)
Retrieves a substate (or partial state) indicated by state_id from the target member.boolean
JChannel. getState(Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent)
Retrieves a substate (or partial state) indicated by state_id from the target member.protected boolean
JChannel. getState(Address target, java.lang.String state_id, long timeout, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)
Retrieves a substate (or partial state) indicated by state_id from the target member.protected void
Channel. notifyChannelReconnected(Address addr)
void
Membership. remove(Address old_member)
removes an member from the membership.abstract void
Channel. send(Address dst, Address src, java.io.Serializable obj)
Helper method.void
JChannel. send(Address dst, Address src, java.io.Serializable obj)
creates a new message with the destination address, and the source address and the object as the message valuevoid
Message. setDest(Address new_dest)
void
Message. setSrc(Address new_src)
void
ExtendedReceiverAdapter. suspect(Address suspected_mbr)
void
MembershipListener. suspect(Address suspected_mbr)
Called whenever a member is suspected of having crashed, but has not yet been excluded.void
ReceiverAdapter. suspect(Address suspected_mbr)
Method parameters in org.jgroups with type arguments of type Address Modifier and Type Method Description void
Membership. add(java.util.Collection<Address> v)
Adds a list of members to this membershipvoid
Membership. merge(java.util.Collection<Address> new_mems, java.util.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(java.util.Collection<Address> v)
removes all the members contained in v from this membershipvoid
Membership. set(java.util.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(java.util.List<Address> flushParticipants, boolean automatic_resume)
boolean
JChannel. startFlush(java.util.List<Address> flushParticipants, boolean automatic_resume)
Performs a partial flush in a cluster for flush participants.abstract void
Channel. stopFlush(java.util.List<Address> flushParticipants)
void
JChannel. stopFlush(java.util.List<Address> flushParticipants)
Constructors in org.jgroups with parameters of type Address Constructor Description MergeView(Address creator, long id, java.util.Vector<Address> members, java.util.Vector<View> subgroups)
Creates a new viewMessage(Address dest)
Public constructorMessage(Address dest, Address src, byte[] buf)
Public constructorMessage(Address dest, Address src, byte[] buf, int offset, int length)
Constructs a message.Message(Address dest, Address src, java.io.Serializable obj)
Public constructorView(Address creator, long id, java.util.Vector<Address> members)
Creates a new viewViewId(Address coord_addr)
Creates a ViewID with the coordinator address and a Lamport timestamp of 0.ViewId(Address coord_addr, long id)
Creates a ViewID with the coordinator address and the given Lamport timestamp.Constructor parameters in org.jgroups with type arguments of type Address Constructor Description Membership(java.util.Collection<Address> initial_members)
Creates a member ship object with the initial members.MergeView(Address creator, long id, java.util.Vector<Address> members, java.util.Vector<View> subgroups)
Creates a new viewMergeView(ViewId vid, java.util.Vector<Address> members, java.util.Vector<View> subgroups)
Creates a new viewView(Address creator, long id, java.util.Vector<Address> members)
Creates a new viewView(ViewId vid, java.util.Vector<Address> members)
Creates a new view -
Uses of Address in org.jgroups.blocks
Fields in org.jgroups.blocks declared as Address Modifier and Type Field Description protected Address
MessageDispatcher. local_addr
protected Address
RequestCorrelator. local_addr
The address of this group memberFields in org.jgroups.blocks with type parameters of type Address Modifier and Type Field Description protected java.util.Stack<Address>
RequestCorrelator. call_stack
This field is used only if deadlock detection is enabled.java.util.Stack<Address>
RequestCorrelator.Header. callStack
Stack<Address>.java.util.List<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 Address Modifier and Type Method Description Address
GroupRequest. getCaller()
Address
BasicConnectionTable. getLocalAddress()
Address
DistributedHashtable. getLocalAddress()
Deprecated.Address
DistributedQueue. getLocalAddress()
Address
NotificationBus. getLocalAddress()
Address
ReplicatedHashMap. getLocalAddress()
Address
ReplicatedHashtable. getLocalAddress()
Deprecated.Address
ReplicatedTree. getLocalAddress()
Address
RequestCorrelator. getLocalAddress()
Methods in org.jgroups.blocks that return types with arguments of type Address Modifier and Type Method Description java.util.Vector<Address>
GroupRequest. getSuspects()
Returns the list of suspected members.Methods in org.jgroups.blocks with parameters of type Address Modifier and Type Method Description java.lang.Object
RpcDispatcher. callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout)
java.lang.Object
RpcDispatcher. callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.String[] signature, int mode, long timeout)
java.lang.Object
RpcDispatcher. callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
java.lang.Object
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)
java.io.Serializable
NotificationBus. getCacheFromMember(Address mbr, long timeout, int max_tries)
Determines the coordinator and asks it for its cache.boolean
RspFilter. isAcceptable(java.lang.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
BasicConnectionTable. receive(Address sender, byte[] data, int offset, int length)
Calls the receiver callback.void
BasicConnectionTable.Receiver. receive(Address sender, byte[] data, int offset, int length)
void
GroupRequest. receiveResponse(java.lang.Object response_value, Address sender)
Callback (called by RequestCorrelator or Transport).void
RspCollector. receiveResponse(java.lang.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, java.nio.ByteBuffer buf)
void
BasicConnectionTable. send(Address dest, byte[] data, int offset, int length)
void
NotificationBus. sendNotification(Address dest, java.io.Serializable n)
Pack the argument in a Info, serialize that one into the message buffer and send the messagevoid
GroupRequest. setCaller(Address caller)
void
RequestCorrelator. setLocalAddress(Address local_addr)
void
DistributedHashtable. suspect(Address suspected_mbr)
Deprecated.Called when a member is suspectedvoid
DistributedLockManager. suspect(Address suspected_mbr)
void
DistributedQueue. suspect(Address suspected_mbr)
Called when a member is suspectedvoid
DistributedTree. suspect(Address suspected_mbr)
Called when a member is suspectedvoid
GroupRequest. suspect(Address suspected_member)
Callback (called by RequestCorrelator or Transport).void
MembershipListenerAdapter. suspect(Address suspected_mbr)
Notify membership listener that some node was suspected.void
NotificationBus. suspect(Address suspected_mbr)
void
ReplicatedHashMap. suspect(Address suspected_mbr)
Called when a member is suspectedvoid
ReplicatedHashtable. suspect(Address suspected_mbr)
Deprecated.Called when a member is suspectedvoid
ReplicatedTree. suspect(Address suspected_mbr)
Called when a member is suspectedvoid
RspCollector. suspect(Address mbr)
void
VotingAdapter. suspect(Address suspected)
Callback for notification that one node is suspectedMethod parameters in org.jgroups.blocks with type arguments of type Address Modifier and Type Method Description void
GroupRequest. reset(java.util.Vector<Address> mbrs)
This method sets themembership
variable to the value ofmembers
.void
BasicConnectionTable. retainAll(java.util.Collection<Address> current_mbrs)
Removes all connections from ConnectionTable which are not in current_mbrsvoid
RequestCorrelator. sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll)
void
RequestCorrelator. sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll, boolean use_anycasting)
Send a request to a group.void
ReplicatedHashMap.Notification. viewChange(View view, java.util.Vector<Address> new_mbrs, java.util.Vector<Address> old_mbrs)
Constructors in org.jgroups.blocks with parameters of type Address Constructor Description RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr)
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing)
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, Address local_addr)
Constructor parameters in org.jgroups.blocks with type arguments of type Address Constructor Description GroupRequest(Message m, RequestCorrelator corr, java.util.Vector<Address> members, int rsp_mode)
GroupRequest(Message m, RequestCorrelator corr, java.util.Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs)
GroupRequest(Message m, Transport transport, java.util.Vector<Address> members, int rsp_mode)
GroupRequest(Message m, Transport transport, java.util.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 Modifier and Type Method Description void
Simulator. addMember(Address addr)
void
Simulator. addMember(Address addr, Simulator s)
void
Simulator. setLocalAddress(Address addr)
-
Uses of Address in org.jgroups.demos
Methods in org.jgroups.demos with parameters of type Address Modifier and Type Method Description void
Draw. channelReconnected(Address addr)
void
Gossip. channelReconnected(Address new_addr)
void
NotificationBusDemo. memberJoined(Address mbr)
void
NotificationBusDemo. memberLeft(Address mbr)
void
ChatCore. suspect(Address suspected_mbr)
void
QuoteClient. suspect(Address suspected_mbr)
void
QuoteServer. suspect(Address suspected_mbr)
void
Topology. suspect(Address suspected_mbr)
void
ViewDemo. suspect(Address suspected_mbr)
Called when a member is suspected -
Uses of Address in org.jgroups.demos.wb
Fields in org.jgroups.demos.wb declared as Address Modifier and Type Field Description Address
Node. addr
Methods in org.jgroups.demos.wb with parameters of type Address Modifier and Type Method Description void
GraphPanel. addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void
Whiteboard. addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void
Whiteboard. suspect(Address obj)
-
Uses of Address in org.jgroups.jmx
Methods in org.jgroups.jmx that return Address Modifier and Type Method Description Address
JChannel. getLocalAddress()
Address
JChannelMBean. getLocalAddress()
Methods in org.jgroups.jmx with parameters of type Address Modifier and Type Method Description boolean
JChannel. getState(Address target, long timeout)
boolean
JChannelMBean. getState(Address target, long timeout)
void
JChannel. send(Address dst, Address src, java.io.Serializable obj)
void
JChannelMBean. send(Address dst, Address src, java.io.Serializable obj)
-
Uses of Address in org.jgroups.jmx.protocols
Methods in org.jgroups.jmx.protocols that return Address Modifier and Type Method Description Address
TP. getLocalAddress()
Address
TPMBean. getLocalAddress()
-
Uses of Address in org.jgroups.mux
Methods in org.jgroups.mux that return Address Modifier and Type Method Description Address
MuxChannel. getLocalAddress()
Methods in org.jgroups.mux with parameters of type Address Modifier and Type Method Description void
MuxChannel. connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
boolean
MuxChannel. getState(Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent)
void
MuxChannel. send(Address dst, Address src, java.io.Serializable obj)
Constructors in org.jgroups.mux with parameters of type Address Constructor Description ServiceInfo(byte type, java.lang.String service, Address host, byte[] state)
-
Uses of Address in org.jgroups.protocols
Classes in org.jgroups.protocols that implement Address Modifier and Type Class Description static class
JMS.JMSAddress
SimpleAddress
representing the JMS node ID or JMS topic group.Fields in org.jgroups.protocols declared as Address Modifier and Type Field Description Address
PingRsp. coord_addr
protected Address
TP. local_addr
The address (host and port) of this memberprotected Address
PARTITION. local_address
Address
PingRsp. own_addr
Fields in org.jgroups.protocols with type parameters of type Address Modifier and Type Field Description protected java.util.HashSet<Address>
TP. members
The members of this group (updated when a member joins or leaves)Methods in org.jgroups.protocols that return Address Modifier and Type Method Description protected Address
UDP. createLocalAddress()
Address
PingRsp. getAddress()
Address
PingRsp. getCoordAddress()
Address
SEQUENCER. getCoordinator()
protected Address
ENCRYPT. getKeyServerAddr()
protected Address
ENCRYPT. getLocal_addr()
Address
SEQUENCER. getLocalAddress()
Address
TP. getLocalAddress()
Address
SEQUENCER.SequencerHeader. getOriginalSender()
Methods in org.jgroups.protocols that return types with arguments of type Address Modifier and Type Method Description java.util.List<Address>
TCPPING. getInitialHosts()
Returns the list of initial hosts as configured by the user via XML.java.util.List<Address>
TP.ProtocolAdapter. getMembers()
Methods in org.jgroups.protocols with parameters of type Address Modifier and Type Method Description void
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
UNICAST. expired(Address key)
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
BasicTCP. receive(Address sender, byte[] data, int offset, int length)
ConnectionTable.Receiver interfaceprotected void
TP. receive(Address dest, Address sender, byte[] data, int offset, int length)
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
BasicTCP. send(Address dest, byte[] data, int offset, int length)
void
TCP_NIO. send(Address dest, byte[] data, int offset, int length)
void
TCP. send(Address dest, byte[] data, int offset, int length)
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 Address Modifier and Type Method Description abstract void
BasicTCP. retainAll(java.util.Collection<Address> members)
void
TCP_NIO. retainAll(java.util.Collection<Address> members)
void
TCP. retainAll(java.util.Collection<Address> members)
Constructors in org.jgroups.protocols with parameters of type Address Constructor Description CoordAnnouncement(Address coord)
FdHeader(byte type, Address mbr)
FdHeader(byte type, Address mbr, IpAddress sock_addr)
FdHeader(byte type, java.util.Vector<Address> mbrs, Address from)
Header(byte type, Address suspect)
HTotalHeader(Address dest, Address src)
MergefastHeader(Address coord)
PingRsp(Address own_addr, Address coord_addr, boolean is_server)
ProtocolAdapter(java.lang.String cluster_name, java.lang.String transport_name, Protocol up, Protocol down, java.lang.String pattern, Address addr)
SequencerHeader(byte type, Address original_sender, long seqno)
Constructor parameters in org.jgroups.protocols with type arguments of type Address Constructor Description DiscardHeader(java.util.Set<Address> ignoredAddresses)
FdHeader(byte type, java.util.Map<Address,IpAddress> cachedAddrs)
FdHeader(byte type, java.util.Set<Address> mbrs)
FdHeader(byte type, java.util.Vector<Address> mbrs, Address from)
-
Uses of Address in org.jgroups.protocols.pbcast
Methods in org.jgroups.protocols.pbcast that return Address Modifier and Type Method Description protected Address
GMS. determineCoordinator()
Address
GMS.GmsHeader. getMember()
Address
MergeData. getSender()
Methods in org.jgroups.protocols.pbcast with parameters of type Address Modifier and Type Method Description void
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
ClientGmsImpl. join(Address address)
void
CoordGmsImpl. join(Address mbr)
abstract void
GmsImpl. join(Address mbr)
void
ParticipantGmsImpl. join(Address mbr)
void
ClientGmsImpl. joinWithStateTransfer(Address address)
void
CoordGmsImpl. joinWithStateTransfer(Address mbr)
abstract void
GmsImpl. joinWithStateTransfer(Address local_addr)
void
ParticipantGmsImpl. joinWithStateTransfer(Address mbr)
void
ClientGmsImpl. leave(Address mbr)
void
CoordGmsImpl. leave(Address mbr)
The coordinator itself wants to leave the groupabstract void
GmsImpl. leave(Address mbr)
void
ParticipantGmsImpl. leave(Address mbr)
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
ClientGmsImpl. suspect(Address mbr)
void
CoordGmsImpl. suspect(Address mbr)
abstract void
GmsImpl. suspect(Address mbr)
void
ParticipantGmsImpl. suspect(Address mbr)
void
ClientGmsImpl. unsuspect(Address mbr)
void
CoordGmsImpl. unsuspect(Address mbr)
abstract void
GmsImpl. unsuspect(Address mbr)
void
ParticipantGmsImpl. unsuspect(Address mbr)
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 Address Modifier and Type Method Description void
GMS. castViewChangeWithDest(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 boolean
GMS. checkSelfInclusion(java.util.Vector<Address> mbrs)
Returns true if local_addr is member of mbrs, else falseView
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
GMS. makeView(java.util.Vector<Address> mbrs)
static View
GMS. makeView(java.util.Vector<Address> mbrs, ViewId vid)
void
CoordGmsImpl. merge(java.util.Vector<Address> other_coords)
Invoked upon receiving a MERGE event from the MERGE layer.void
GmsImpl. merge(java.util.Vector<Address> other_coords)
Constructors in org.jgroups.protocols.pbcast with parameters of type Address Constructor Description GmsHeader(byte type, Address mbr)
Used for JOIN_REQ or LEAVE_REQ headerGossip(Address obj, long id)
Gossip(Address obj, long id, Digest d, java.util.Vector not_seen)
MergeData(Address sender, View view, Digest digest)
NakAckHeader(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, java.lang.String state_id)
StateHeader(byte type, Address sender, long id, Digest digest)
StateHeader(byte type, Address sender, java.lang.String state_id)
StateHeader(byte type, Address sender, IpAddress bind_addr, Digest digest, java.lang.String state_id)
Constructor parameters in org.jgroups.protocols.pbcast with type arguments of type Address Constructor Description FlushHeader(byte type, long viewID, java.util.Collection<Address> flushView)
-
Uses of Address in org.jgroups.stack
Classes in org.jgroups.stack that implement Address Modifier and Type Class Description class
IpAddress
Network-dependent address (Internet).Fields in org.jgroups.stack declared as Address Modifier and Type Field Description Address
StateTransferInfo. target
Methods in org.jgroups.stack that return Address Modifier and Type Method Description Address
GossipData. getAddress()
Address
RouterStub. getLocalAddress()
Methods in org.jgroups.stack that return types with arguments of type Address Modifier and Type Method Description java.util.List<Address>
GossipClient. getMembers(java.lang.String group)
Returns all members of a given groupMethods in org.jgroups.stack with parameters of type Address Modifier and Type Method Description void
AckMcastSenderWindow. ack(long seqno, Address sender)
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
GossipClient. register(java.lang.String group, Address mbr)
Adds the member to the given group.void
AckMcastSenderWindow. remove(Address obj)
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
AckMcastSenderWindow. suspect(Address suspected)
Process with addresssuspected
is suspected: remove it from all receiver sets.void
GossipClient. unregister(java.lang.String group, Address mbr)
Constructors in org.jgroups.stack with parameters of type Address Constructor Description AckSenderWindow(AckSenderWindow.RetransmitCommand com, Interval interval, TimeScheduler sched, Address sender)
GossipData(byte type, java.lang.String group, Address addr, java.util.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, java.io.InputStream is, java.lang.String state_id)
StateTransferInfo(Address target, java.io.OutputStream os, java.lang.String state_id)
StateTransferInfo(Address target, java.lang.String state_id, long timeout)
StateTransferInfo(Address target, java.lang.String state_id, long timeout, byte[] state)
-
Uses of Address in org.jgroups.util
Fields in org.jgroups.util with type parameters of type Address Modifier and Type Field Description protected java.util.Map<Address,Digest.Entry>
Digest. senders
Map<Address, Entry>Methods in org.jgroups.util that return Address Modifier and Type Method Description Address
Rsp. getSender()
static Address
Util. readAddress(java.io.DataInputStream in)
Methods in org.jgroups.util that return types with arguments of type Address Modifier and Type Method Description static java.util.Vector<Address>
Util. determineLeftMembers(java.util.Vector<Address> old_mbrs, java.util.Vector<Address> new_mbrs)
Returns all members that left between 2 views.java.util.Set<java.util.Map.Entry<Address,Rsp>>
RspList. entrySet()
java.util.Map<Address,T>
ResponseCollector. getResults()
java.util.Map<Address,Digest.Entry>
Digest. getSenders()
Returns an unmodifiable map, so modifications will result in exceptionsjava.util.Map<Address,Digest.Entry>
MutableDigest. getSenders()
java.util.Vector<Address>
RspList. getSuspectedMembers()
java.util.Set<Address>
RspList. keySet()
static java.util.Collection<Address>
Util. readAddresses(java.io.DataInputStream in, java.lang.Class cl)
Methods in org.jgroups.util with parameters of type Address Modifier and Type Method Description void
MutableDigest. add(Address sender, long low_seqno, long highest_delivered_seqno)
void
MutableDigest. add(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno)
void
ResponseCollector. add(Address member, T data)
boolean
SeqnoTable. add(Address member, long seqno)
void
RspList. addNotReceived(Address sender)
void
RspList. addRsp(Address sender, java.lang.Object retval)
void
RspList. addSuspect(Address sender)
boolean
Digest. contains(Address sender)
static View
Util. createView(Address coord, long id, Address... members)
void
FIFOMessageQueue. done(Address sender, K dest)
Digest.Entry
Digest. get(Address sender)
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
FIFOMessageQueue. put(Address sender, K dest, V el)
Rsp
RspList. put(Address key, Rsp value)
void
ResponseCollector. remove(Address member)
void
SeqnoTable. remove(Address member)
void
MutableDigest. resetAt(Address sender)
Resets the seqnos for the sender at 'index' to 0.static boolean
Util. sameHost(Address one, Address two)
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
Util. size(Address addr)
void
AckCollector. suspect(Address member)
void
ResponseCollector. suspect(Address member)
void
AckCollector. unsuspect(Address member)
static void
Util. writeAddress(Address addr, java.io.DataOutputStream out)
Method parameters in org.jgroups.util with type arguments of type Address Modifier and Type Method Description static java.util.Vector<Address>
Util. determineLeftMembers(java.util.Vector<Address> old_mbrs, java.util.Vector<Address> new_mbrs)
Returns all members that left between 2 views.void
RspList. putAll(java.util.Map<? extends Address,? extends Rsp> m)
void
AckCollector. reset(ViewId v, java.util.List<Address> members)
void
ResponseCollector. reset(java.util.Collection<Address> members)
boolean
SeqnoTable. retainAll(java.util.Collection<Address> members)
static boolean
Util. startFlush(Channel c, java.util.List<Address> flushParticipants)
static boolean
Util. startFlush(Channel c, java.util.List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling)
Constructors in org.jgroups.util with parameters of type Address Constructor Description Digest(Address sender, long low, long highest_delivered)
Digest(Address sender, long low, long highest_delivered, long highest_received)
Rsp(Address sender)
Rsp(Address sender, boolean suspected)
Rsp(Address sender, java.lang.Object retval)
Constructor parameters in org.jgroups.util with type arguments of type Address Constructor Description Digest(java.util.Map<Address,Digest.Entry> map)
Creates a new digest from an existing map by copying the keys and values from mapMutableDigest(java.util.Map<Address,Digest.Entry> map)
ResponseCollector(java.util.Collection<Address> members)
-