|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Address | |
---|---|
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.blocks.locking | |
org.jgroups.blocks.mux | |
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.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 |
---|
Subinterfaces of Address in org.jgroups | |
---|---|
interface |
PhysicalAddress
Represents a physical (as opposed to logical) address |
Fields in org.jgroups declared as Address | |
---|---|
protected Address |
Message.dest_addr
|
protected Address |
JChannel.local_addr
|
static Address |
Global.NULL_ADDR
|
protected Address |
Message.src_addr
|
Fields in org.jgroups with type parameters of type Address | |
---|---|
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 | |
---|---|
Address |
Membership.elementAt(int index)
Returns the component at the specified index |
abstract Address |
Channel.getAddress()
Returns the channel's own address. |
Address |
JChannel.getAddress()
Returns the local address of the channel (null if the channel is closed) |
Address |
ViewId.getCoordAddress()
returns the address of the member that issued this view |
Address |
View.getCreator()
returns the creator of this view if this view was created with the empty constructur, null will be returned |
Address |
Message.getDest()
|
abstract Address |
Channel.getLocalAddress()
Deprecated. Use Channel.getAddress() instead |
Address |
JChannel.getLocalAddress()
Deprecated. |
Address |
Message.getSrc()
|
Methods in org.jgroups that return types with arguments of type Address | |
---|---|
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 | |
---|---|
void |
Membership.add(Address... mbrs)
|
void |
Membership.add(Address new_member)
Adds a new member to this membership. |
void |
ChannelListenerAdapter.channelReconnected(Address addr)
|
void |
ChannelListener.channelReconnected(Address addr)
Deprecated. |
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 state |
void |
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. |
void |
JChannel.connect(java.lang.String cluster_name,
Address target,
java.lang.String state_id,
long timeout,
boolean useFlushIfPresent)
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 membership |
boolean |
View.containsMember(Address mbr)
returns true, if this view contains a certain member |
abstract java.lang.String |
Channel.getName(Address member)
Returns the logical name of a given member. |
java.lang.String |
JChannel.getName(Address member)
|
abstract boolean |
Channel.getState(Address target,
long timeout)
Retrieve the state of the group. |
boolean |
JChannel.getState(Address target,
long timeout)
Retrieves a full state from the target member. |
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,
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. |
void |
Membership.remove(Address old_member)
removes an member from the membership. |
abstract void |
Channel.send(Address dst,
Address src,
byte[] buf)
|
void |
JChannel.send(Address dst,
Address src,
byte[] buf)
|
abstract void |
Channel.send(Address dst,
Address src,
byte[] buf,
int offset,
int length)
|
void |
JChannel.send(Address dst,
Address src,
byte[] buf,
int offset,
int length)
|
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 value |
void |
Message.setDest(Address new_dest)
|
void |
Message.setSrc(Address new_src)
|
void |
MembershipListener.suspect(Address suspected_mbr)
Called whenever a member is suspected of having crashed, but has not yet been excluded. |
void |
ExtendedReceiverAdapter.suspect(Address suspected_mbr)
|
void |
ReceiverAdapter.suspect(Address mbr)
|
void |
Message.writeToNoAddrs(Address src,
java.io.DataOutputStream out)
Writes the message to the output stream, but excludes the dest and src addresses unless the src address given as argument is different from the message's src address |
Method parameters in org.jgroups with type arguments of type Address | |
---|---|
void |
Membership.add(java.util.Collection<Address> v)
Adds a list of members to this membership |
void |
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.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 membership |
void |
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 the Clear 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 | |
---|---|
MergeView(Address creator,
long id,
java.util.Vector<Address> members,
java.util.Vector<View> subgroups)
Creates a new view |
|
Message(Address dest)
Public constructor |
|
Message(Address dest,
Address src,
byte[] buf)
Public constructor |
|
Message(Address dest,
Address src,
byte[] buf,
int offset,
int length)
Constructs a message. |
|
Message(Address dest,
Address src,
java.lang.Object obj)
Public constructor |
|
View(Address creator,
long id,
java.util.Collection<Address> members)
Creates a new view |
|
ViewId(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 | |
---|---|
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 view |
|
MergeView(ViewId vid,
java.util.Vector<Address> members,
java.util.Vector<View> subgroups)
Creates a new view |
|
View(Address creator,
long id,
java.util.Collection<Address> members)
Creates a new view |
|
View(ViewId vid,
java.util.Collection<Address> members)
|
|
View(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 | |
---|---|
protected Address |
MessageDispatcher.local_addr
|
protected Address |
RequestCorrelator.local_addr
The address of this group member |
protected Address |
UnicastRequest.target
|
Fields in org.jgroups.blocks with type parameters of type Address | |
---|---|
protected java.util.Map<Address,V> |
AbstractConnectionMap.conns
|
java.util.Collection<? extends Address> |
RequestCorrelator.MultiDestinationHeader.exclusion_list
Contains a list of members who should not receive the request (others will drop). |
protected java.util.Collection<Address> |
MessageDispatcher.members
|
Methods in org.jgroups.blocks that return Address | |
---|---|
Address |
TCPConnectionMap.getLocalAddress()
|
Address |
ReplCache.getLocalAddress()
|
Address |
DistributedQueue.getLocalAddress()
|
Address |
NotificationBus.getLocalAddress()
Deprecated. |
Address |
PartitionedHashMap.getLocalAddress()
|
Address |
ReplicatedTree.getLocalAddress()
|
Address |
BasicConnectionTable.getLocalAddress()
|
Address |
ReplicatedHashMap.getLocalAddress()
|
Address |
RequestCorrelator.getLocalAddress()
|
Address |
PartitionedHashMap.HashFunction.hash(K key,
java.util.List<Address> membership)
Defines a hash function to pick the right node from the list of cluster nodes. |
Address |
PartitionedHashMap.ConsistentHashFunction.hash(K key,
java.util.List<Address> members)
|
Address |
PartitionedHashMap.ArrayBasedConsistentHashFunction.hash(K key,
java.util.List<Address> members)
|
Methods in org.jgroups.blocks that return types with arguments of type Address | |
---|---|
java.util.Collection<Address> |
RequestOptions.getExclusionList()
|
java.util.Vector<Address> |
ReplicatedTree.getMembers()
|
java.util.List<Address> |
ReplCache.HashFunction.hash(K key,
short replication_count)
Function that, given a key and a replication count, returns replication_count number of different addresses of nodes. |
java.util.List<Address> |
ReplCache.ConsistentHashFunction.hash(K key,
short replication_count)
|
Methods in org.jgroups.blocks with parameters of type Address | ||
---|---|---|
void |
AbstractConnectionMap.addConnection(Address address,
V conn)
|
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
MethodCall call)
Deprecated. |
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
MethodCall method_call,
int mode,
long timeout)
Deprecated. |
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
MethodCall method_call,
int mode,
long timeout,
boolean oob)
Deprecated. |
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
MethodCall call,
RequestOptions options)
|
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
int mode,
long timeout)
Deprecated. |
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
RequestOptions options)
|
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.String[] signature,
int mode,
long timeout)
Deprecated. |
|
|
RpcDispatcher.callRemoteMethodWithFuture(Address dest,
MethodCall call)
Deprecated. |
|
|
RpcDispatcher.callRemoteMethodWithFuture(Address dest,
MethodCall method_call,
int mode,
long timeout,
boolean oob)
Deprecated. |
|
|
RpcDispatcher.callRemoteMethodWithFuture(Address dest,
MethodCall call,
RequestOptions options)
|
|
void |
RpcDispatcher.channelReconnected(Address new_addr)
|
|
void |
AbstractConnectionMap.ConnectionMapListener.connectionClosed(Address address)
|
|
void |
BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
|
|
boolean |
TCPConnectionMap.connectionEstablishedTo(Address addr)
|
|
void |
BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
|
|
void |
AbstractConnectionMap.ConnectionMapListener.connectionOpened(Address address,
V conn)
|
|
protected RequestCorrelator |
MessageDispatcher.createRequestCorrelator(java.lang.Object transport,
RequestHandler handler,
Address local_addr)
|
|
java.io.Serializable |
NotificationBus.getCacheFromMember(Address mbr,
long timeout,
int max_tries)
Deprecated. Determines the coordinator and asks it for its cache. |
|
V |
ConnectionMap.getConnection(Address dest)
|
|
boolean |
AbstractConnectionMap.hasConnection(Address address)
|
|
boolean |
AbstractConnectionMap.hasOpenConnection(Address address)
|
|
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 request |
|
void |
NotificationBus.Consumer.memberJoined(Address mbr)
|
|
void |
NotificationBus.Consumer.memberLeft(Address mbr)
|
|
protected void |
AbstractConnectionMap.notifyConnectionClosed(Address address)
|
|
protected void |
AbstractConnectionMap.notifyConnectionOpened(Address address,
V conn)
|
|
protected void |
PullPushAdapter.notifySuspect(Address suspected_mbr)
Deprecated. |
|
void |
TCPConnectionMap.receive(Address sender,
byte[] data,
int offset,
int length)
Calls the receiver callback. |
|
void |
TCPConnectionMap.Receiver.receive(Address sender,
byte[] data,
int offset,
int length)
|
|
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)
|
|
abstract void |
Request.receiveResponse(java.lang.Object response_value,
Address sender)
|
|
void |
MultiRequest.receiveResponse(java.lang.Object response_value,
Address sender)
Callback (called by RequestCorrelator or Transport). |
|
void |
UnicastRequest.receiveResponse(java.lang.Object response_value,
Address sender)
Callback (called by RequestCorrelator or Transport). |
|
void |
RequestCorrelator.receiveSuspect(Address mbr)
Event.SUSPECT event received from a layer below. |
|
void |
AbstractConnectionMap.removeConnection(Address address)
|
|
void |
BasicConnectionTable.removeConnection(Address addr)
Remove addr from connection table. |
|
protected void |
ConnectionTableNIO.runRequest(Address addr,
java.nio.ByteBuffer buf)
|
|
void |
TCPConnectionMap.send(Address dest,
byte[] data,
int offset,
int length)
|
|
void |
BasicConnectionTable.send(Address dest,
byte[] data,
int offset,
int length)
|
|
void |
NotificationBus.sendNotification(Address dest,
java.io.Serializable n)
Deprecated. Pack the argument in a Info, serialize that one into the message buffer and send the message |
|
void |
RequestCorrelator.sendUnicastRequest(long id,
Address target,
Message msg,
RspCollector coll)
Sends a request to a single destination |
|
RequestOptions |
RequestOptions.setExclusionList(Address... mbrs)
|
|
void |
RequestCorrelator.setLocalAddress(Address local_addr)
|
|
void |
VotingAdapter.suspect(Address suspected)
Callback for notification that one node is suspected |
|
void |
MembershipListenerAdapter.suspect(Address suspected_mbr)
Notify membership listener that some node was suspected. |
|
void |
ReplCache.suspect(Address suspected_mbr)
|
|
void |
GroupRequest.suspect(Address suspected_member)
Callback (called by RequestCorrelator or Transport). |
|
void |
RspCollector.suspect(Address mbr)
|
|
void |
DistributedTree.suspect(Address suspected_mbr)
Called when a member is suspected |
|
void |
DistributedQueue.suspect(Address suspected_mbr)
Called when a member is suspected |
|
void |
NotificationBus.suspect(Address suspected_mbr)
Deprecated. |
|
void |
DistributedLockManager.suspect(Address suspected_mbr)
Deprecated. |
|
abstract void |
Request.suspect(Address mbr)
|
|
void |
PartitionedHashMap.suspect(Address suspected_mbr)
|
|
void |
PartitionedHashMap.ArrayBasedConsistentHashFunction.suspect(Address suspected_mbr)
|
|
void |
ReplicatedHashMap.suspect(Address suspected_mbr)
Called when a member is suspected |
|
void |
MultiRequest.suspect(Address suspected_member)
Callback (called by RequestCorrelator or Transport). |
|
void |
UnicastRequest.suspect(Address suspected_member)
Callback (called by RequestCorrelator or Transport). |
Method parameters in org.jgroups.blocks with type arguments of type Address | |
---|---|
RspList |
RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests,
MethodCall method_call,
RequestOptions options)
Invokes a method in all members contained in dests (or all members if dests is null). |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
RequestOptions options)
|
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests,
MethodCall method_call,
int mode,
long timeout)
Deprecated. |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
int mode,
long timeout)
Deprecated. |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
int mode,
long timeout,
boolean use_anycasting)
Deprecated. |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
int mode,
long timeout,
boolean use_anycasting,
RspFilter filter)
Deprecated. |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.String[] signature,
int mode,
long timeout)
Deprecated. |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.String[] signature,
int mode,
long timeout,
boolean use_anycasting)
Deprecated. |
NotifyingFuture<RspList> |
RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests,
MethodCall method_call,
RequestOptions options)
|
NotifyingFuture<RspList> |
RpcDispatcher.callRemoteMethodsWithFuture(java.util.Vector<Address> dests,
MethodCall method_call)
Deprecated. |
NotifyingFuture<RspList> |
RpcDispatcher.callRemoteMethodsWithFuture(java.util.Vector<Address> dests,
MethodCall method_call,
int mode,
long timeout,
boolean use_anycasting,
boolean oob,
RspFilter filter)
Deprecated. |
protected GroupRequest |
MessageDispatcher.cast(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
boolean block_for_results)
|
RspList |
MessageDispatcher.castMessage(java.util.Collection<Address> dests,
Message msg,
RequestOptions options)
Sends a message to the members listed in dests. |
NotifyingFuture<RspList> |
MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests,
Message msg,
RequestOptions options)
|
Address |
PartitionedHashMap.HashFunction.hash(K key,
java.util.List<Address> membership)
Defines a hash function to pick the right node from the list of cluster nodes. |
Address |
PartitionedHashMap.ConsistentHashFunction.hash(K key,
java.util.List<Address> members)
|
Address |
PartitionedHashMap.ArrayBasedConsistentHashFunction.hash(K key,
java.util.List<Address> members)
|
void |
ReplCache.HashFunction.installNodes(java.util.List<Address> nodes)
When the topology changes, this method will be called. |
void |
ReplCache.ConsistentHashFunction.installNodes(java.util.List<Address> new_nodes)
|
void |
TCPConnectionMap.retainAll(java.util.Collection<Address> members)
|
void |
AbstractConnectionMap.retainAll(java.util.Collection<Address> current_mbrs)
Removes all connections which are not in current_mbrs |
void |
BasicConnectionTable.retainAll(java.util.Collection<Address> current_mbrs)
Removes all connections from ConnectionTable which are not in current_mbrs |
void |
RequestCorrelator.sendRequest(long id,
java.util.Collection<Address> dest_mbrs,
Message msg,
RspCollector coll,
RequestOptions options)
Sends a request to a group. |
void |
RequestCorrelator.sendRequest(long id,
java.util.List<Address> dest_mbrs,
Message msg,
RspCollector coll)
|
void |
ReplicatedHashMap.Notification.viewChange(View view,
java.util.Vector<Address> new_mbrs,
java.util.Vector<Address> old_mbrs)
|
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 | |
---|---|
GroupRequest(Message m,
RequestCorrelator corr,
Address target,
RequestOptions options)
|
|
MultiRequest(Message m,
RequestCorrelator corr,
Address target,
RequestOptions options,
int expected_mbrs)
|
|
RequestCorrelator(java.lang.Object transport,
RequestHandler handler,
Address local_addr)
|
|
RequestCorrelator(short id,
java.lang.Object transport,
RequestHandler handler,
Address local_addr)
|
|
RequestCorrelator(java.lang.String name,
java.lang.Object transport,
RequestHandler handler,
Address local_addr)
Deprecated. |
|
RequestCorrelator(java.lang.String name,
java.lang.Object transport,
RequestHandler handler,
Address local_addr,
boolean concurrent_processing)
Deprecated. |
|
RequestCorrelator(java.lang.String name,
java.lang.Object transport,
RequestHandler handler,
boolean deadlock_detection,
Address local_addr)
Deprecated. |
|
RequestCorrelator(java.lang.String name,
java.lang.Object transport,
RequestHandler handler,
boolean deadlock_detection,
Address local_addr,
boolean concurrent_processing)
Deprecated. |
|
UnicastRequest(Message m,
RequestCorrelator corr,
Address target,
RequestOptions options)
|
|
UnicastRequest(Message m,
Transport transport,
Address target,
RequestOptions options)
|
Constructor parameters in org.jgroups.blocks with type arguments of type Address | |
---|---|
GroupRequest(Message msg,
RequestCorrelator corr,
java.util.Collection<Address> targets,
RequestOptions options)
|
|
GroupRequest(Message m,
Transport transport,
java.util.Collection<Address> mbrs,
RequestOptions options)
|
|
MultiRequest(Message m,
RequestCorrelator corr,
java.util.Collection<Address> mbrs,
RequestOptions options,
int expected_mbrs)
|
|
MultiRequest(Message m,
Transport transport,
java.util.Collection<Address> mbrs,
RequestOptions options,
int expected_mbrs)
|
|
RequestCorrelator.MultiDestinationHeader(byte type,
long id,
boolean rsp_expected,
short corr_id,
java.util.Collection<Address> exclusion_list)
|
Uses of Address in org.jgroups.blocks.locking |
---|
Fields in org.jgroups.blocks.locking declared as Address | |
---|---|
protected Address |
Owner.address
|
Methods in org.jgroups.blocks.locking that return Address | |
---|---|
Address |
Owner.getAddress()
|
Constructors in org.jgroups.blocks.locking with parameters of type Address | |
---|---|
Owner(Address address,
long thread_id)
|
Uses of Address in org.jgroups.blocks.mux |
---|
Methods in org.jgroups.blocks.mux with parameters of type Address | |
---|---|
protected RequestCorrelator |
MuxRpcDispatcher.createRequestCorrelator(java.lang.Object transport,
RequestHandler handler,
Address localAddr)
|
protected RequestCorrelator |
MuxMessageDispatcher.createRequestCorrelator(java.lang.Object transport,
RequestHandler handler,
Address localAddr)
|
boolean |
NoMuxHandlerRspFilter.isAcceptable(java.lang.Object response,
Address sender)
|
void |
MuxRequestCorrelator.sendUnicastRequest(long id,
Address target,
Message msg,
RspCollector coll)
|
Method parameters in org.jgroups.blocks.mux with type arguments of type Address | |
---|---|
protected GroupRequest |
MuxRpcDispatcher.cast(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
boolean blockForResults)
|
protected GroupRequest |
MuxMessageDispatcher.cast(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
boolean blockForResults)
|
void |
MuxRequestCorrelator.sendRequest(long requestId,
java.util.Collection<Address> dest_mbrs,
Message msg,
RspCollector coll,
RequestOptions options)
|
Constructors in org.jgroups.blocks.mux with parameters of type Address | |
---|---|
MuxRequestCorrelator(short id,
java.lang.Object transport,
RequestHandler handler,
Address localAddr)
|
Uses of Address in org.jgroups.debug |
---|
Methods in org.jgroups.debug that return Address | |
---|---|
Address |
Simulator.getLocalAddress()
|
Methods in org.jgroups.debug with parameters of type Address | |
---|---|
void |
Simulator.addMember(Address addr)
|
void |
Simulator.addMember(Address addr,
Simulator s)
|
boolean |
Simulator.checkForDropMessage(Message msg,
Address dest)
|
boolean |
Simulator.DropMessage.drop(Message msg,
Address dest)
|
boolean |
Simulator.receiverDropFault(Message msg,
Address src)
|
boolean |
Simulator.senderDropFault(Message msg,
Address dest)
|
void |
Simulator.setLocalAddress(Address addr)
|
void |
Simulator.simulatePartition(Address[] partition)
|
Uses of Address in org.jgroups.demos |
---|
Fields in org.jgroups.demos declared as Address | |
---|---|
protected Address |
RelayDemoRpc.local_addr
|
Methods in org.jgroups.demos with parameters of type Address | |
---|---|
void |
Draw.channelReconnected(Address addr)
|
static java.lang.String |
RelayDemoRpc.handleMessage(java.lang.String msg,
Address sender)
|
void |
NotificationBusDemo.memberJoined(Address mbr)
|
void |
NotificationBusDemo.memberLeft(Address mbr)
|
void |
Topology.suspect(Address suspected_mbr)
|
void |
QuoteClient.suspect(Address suspected_mbr)
|
void |
QuoteServer.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 | |
---|---|
Address |
Node.addr
|
Methods in org.jgroups.demos.wb with parameters of type Address | |
---|---|
void |
Whiteboard.addNode(java.lang.String lbl,
Address addr,
int xloc,
int yloc)
|
void |
GraphPanel.addNode(java.lang.String lbl,
Address addr,
int xloc,
int yloc)
|
void |
Whiteboard.suspect(Address obj)
|
Uses of Address in org.jgroups.mux |
---|
Methods in org.jgroups.mux that return Address | |
---|---|
Address |
MuxChannel.getAddress()
Deprecated. |
Methods in org.jgroups.mux with parameters of type Address | |
---|---|
void |
MuxChannel.connect(java.lang.String cluster_name,
Address target,
java.lang.String state_id,
long timeout)
Deprecated. |
boolean |
MuxChannel.getState(Address target,
java.lang.String state_id,
long timeout,
boolean useFlushIfPresent)
Deprecated. |
void |
MuxChannel.send(Address dst,
Address src,
java.io.Serializable obj)
Deprecated. |
Constructors in org.jgroups.mux with parameters of type Address | |
---|---|
ServiceInfo(byte type,
java.lang.String service,
Address host,
byte[] state)
|
Uses of Address in org.jgroups.protocols |
---|
Fields in org.jgroups.protocols declared as Address | |
---|---|
protected Address |
Executing.Owner.address
|
protected Address |
RELAY.coord
|
protected Address |
CENTRAL_EXECUTOR.coord
|
protected Address |
CENTRAL_LOCK.coord
|
protected Address |
Discovery.local_addr
|
protected Address |
DAISYCHAIN.local_addr
|
protected Address |
RELAY.local_addr
|
protected Address |
SCOPE.local_addr
|
protected Address |
TP.local_addr
The address (host and port) of this member. |
protected Address |
Executing.local_addr
|
protected Address |
STOMP.local_addr
|
protected Address |
Locking.local_addr
|
protected Address |
FD.local_addr
|
protected Address |
DAISYCHAIN.next
|
protected Address |
RELAY.RelayHeader.original_sender
|
protected Address |
FD.ping_dest
|
Fields in org.jgroups.protocols with type parameters of type Address | |
---|---|
protected java.util.Queue<Address> |
Executing._consumersAvailable
This is stored on the coordinator side. |
protected java.util.Queue<Address> |
Executing._runRequests
This is stored on the coordinator side. |
protected java.util.List<Address> |
CENTRAL_EXECUTOR.backups
|
protected java.util.List<Address> |
CENTRAL_LOCK.backups
|
protected java.util.Map<Address,java.lang.String> |
STOMP.endpoints
|
protected java.util.List<Address> |
PEER_LOCK.PeerLock.grants
|
protected LazyRemovalCache<Address,PhysicalAddress> |
TP.logical_addr_cache
Cache which maintains mappings between logical and physical addresses. |
protected java.util.Vector<Address> |
Discovery.members
|
protected java.util.Set<Address> |
TP.members
The members of this group (updated when a member joins or leaves). |
protected java.util.List<Address> |
FD.members
|
protected java.util.List<Address> |
FD.pingable_mbrs
Members from which we select ping_dest. |
protected static LazyRemovalCache.Printable<Address,PhysicalAddress> |
TP.print_function
|
protected java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.ConcurrentMap<java.lang.Short,SCOPE.MessageQueue>> |
SCOPE.queues
Used to find the correct AckReceiverWindow on message reception and deliver it in the right order |
protected java.util.Map<Address,FlowControl.Credit> |
FlowControl.received
Keeps track of credits per member at the receiver. |
protected java.util.Map<Address,FlowControl.Credit> |
UFC.sent
Map: keys are members, values are credits left. |
protected BoundedList<Address> |
FD.suspect_history
|
protected java.util.Set<Address> |
FD_SOCK.suspected_mbrs
|
protected java.util.Set<Address> |
FD_ALL.suspected_mbrs
|
protected java.util.Map<Address,java.lang.String> |
RELAY.ViewData.uuids
|
protected AgeOutCache<Address> |
TP.who_has_cache
Cache keeping track of WHO_HAS requests for physical addresses (given a logical address) and expiring them after 5000ms |
Methods in org.jgroups.protocols that return Address | |
---|---|
Address |
TP.ProtocolAdapter.getAddress()
|
Address |
Executing.Owner.getAddress()
|
Address |
PingData.getAddress()
|
Address |
CENTRAL_EXECUTOR.getCoord()
|
Address |
CENTRAL_LOCK.getCoord()
|
Address |
PingData.getCoordAddress()
|
Address |
SEQUENCER.getCoordinator()
|
protected Address |
ENCRYPT.getKeyServerAddr()
|
protected Address |
ENCRYPT.getLocal_addr()
|
Address |
SEQUENCER.getLocalAddress()
|
Address |
SEQUENCER.SequencerHeader.getOriginalSender()
|
Methods in org.jgroups.protocols that return types with arguments of type Address | |
---|---|
AgeOutCache<Address> |
UNICAST2.getAgeOutCache()
|
AgeOutCache<Address> |
UNICAST.getAgeOutCache()
|
java.util.Set<Address> |
TP.ProtocolAdapter.getMembers()
|
java.util.Collection<Address> |
PingData.getMembers()
|
Methods in org.jgroups.protocols with parameters of type Address | |
---|---|
void |
DISCARD.addIgnoreMember(Address sender)
Messages from this sender will get dropped |
protected void |
TP.addPhysicalAddressToCache(Address logical_addr,
PhysicalAddress physical_addr)
|
protected java.lang.String |
FILE_PING.addressAsString(Address address)
|
protected void |
FD.Broadcaster.addSuspectedMember(Address mbr)
Adds a suspected member. |
void |
FD.BroadcastTask.addSuspectedMember(Address suspect)
|
protected long |
FlowControl.adjustCredit(java.util.Map<Address,FlowControl.Credit> map,
Address sender,
int length)
Check whether sender has enough credits left. |
void |
FRAG2.clearFragmentsFor(Address mbr)
|
void |
SCOPE.clearQueue(Address member)
|
void |
TUNNEL.TUNNELPolicy.connect(java.util.List<RouterStub> stubs,
java.lang.String group,
Address addr,
java.lang.String logical_name,
java.util.List<PhysicalAddress> phys_addrs)
|
protected void |
TCPGOSSIP.connect(RouterStub stub,
java.lang.String group,
Address logical_addr)
|
protected void |
TCPGOSSIP.connectAllStubs(java.lang.String group,
Address logical_addr)
|
static RELAY.RelayHeader |
RELAY.RelayHeader.createDisseminateHeader(Address original_sender)
|
void |
Discovery.discoveryRequestReceived(Address sender,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
|
void |
TCPPING.discoveryRequestReceived(Address sender,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
|
protected void |
TP.dispatchToThreadPool(java.util.concurrent.Executor pool,
Address sender,
byte[] data,
int offset,
int length)
|
protected void |
TP.doSend(Buffer buf,
Address dest,
boolean multicast)
|
void |
UNICAST2.expired(Address key)
Called by AgeOutCache, to removed expired connections |
void |
UNICAST.expired(Address key)
Called by AgeOutCache, to removed expired connections |
protected SCOPE.MessageQueue |
SCOPE.getOrCreateQueue(Address sender,
short scope)
|
protected PhysicalAddress |
TP.getPhysicalAddressFromCache(Address logical_addr)
|
protected void |
Executing.handleConsumerFoundResponse(Address consumer)
|
protected void |
Executing.handleConsumerReadyRequest(Address source)
|
protected void |
MFC.handleCredit(Address sender,
long increase)
|
protected void |
UFC.handleCredit(Address sender,
long increase)
|
protected abstract void |
FlowControl.handleCredit(Address sender,
long increase)
|
protected void |
FlowControl.handleCreditRequest(java.util.Map<Address,FlowControl.Credit> map,
Address sender,
long requested_credits)
|
protected java.lang.Object |
MFC.handleDownMessage(Event evt,
Message msg,
Address dest,
int length)
|
protected java.lang.Object |
UFC.handleDownMessage(Event evt,
Message msg,
Address dest,
int length)
|
protected abstract java.lang.Object |
FlowControl.handleDownMessage(Event evt,
Message msg,
Address dest,
int length)
|
protected void |
Executing.handleExceptionResponse(Address source,
Executing.Request req)
|
protected void |
Executing.handleInterruptRequest(Address source,
short requestId)
|
protected void |
PEER_LOCK.PeerLock.handleLockGrantedResponse(Owner owner,
Address sender)
|
protected void |
Locking.ClientLock.handleLockGrantedResponse(Owner owner,
Address sender)
|
protected void |
Locking.handleLockGrantedResponse(java.lang.String lock_name,
Owner owner,
Address sender)
|
protected void |
Executing.handleNewConsumer(Address sender)
|
protected void |
Executing.handleNewRunRequest(Address sender)
|
protected void |
Executing.handleRemoveConsumer(Address sender)
|
protected void |
Executing.handleRemoveRunRequest(Address sender)
|
protected void |
Executing.handleTaskRejectedResponse(Address source,
short requestId)
|
protected void |
Executing.handleTaskRequest(Address source)
|
protected void |
Executing.handleTaskSubmittedRequest(java.lang.Runnable runnable,
Address source,
short requestId)
|
protected void |
Executing.handleValueResponse(Address source,
Executing.Request req)
|
protected boolean |
RELAY.isLocal(Address dest)
Does the payload match the 'site' ID. |
protected void |
TP.receive(Address sender,
byte[] data,
int offset,
int length)
Subclasses must call this method when a unicast or multicast message has been received. |
void |
BasicTCP.receive(Address sender,
byte[] data,
int offset,
int length)
ConnectionMap.Receiver interface |
protected void |
TP.registerLocalAddress(Address addr)
Associates the address with the physical address fetched from the cache |
protected void |
S3_PING.remove(java.lang.String clustername,
Address addr)
|
protected void |
FILE_PING.remove(java.lang.String clustername,
Address addr)
|
protected void |
JDBC_PING.remove(java.lang.String clustername,
Address addr)
|
void |
UNICAST2.removeConnection(Address mbr)
Removes and resets from connection table (which is already locked). |
void |
UNICAST.removeConnection(Address mbr)
Removes and resets from connection table (which is already locked). |
void |
DISCARD.removeIgnoredMember(Address member)
|
protected void |
TP.removeLogicalAddressFromCache(Address logical_addr)
|
void |
SCOPE.removeScope(Address member,
short scope)
|
void |
UNICAST2.retransmit(long first_seqno,
long last_seqno,
Address sender)
|
void |
SMACK.retransmit(long seqno,
Message msg,
Address dest)
|
void |
TCP.send(Address dest,
byte[] data,
int offset,
int length)
|
void |
TCP_NIO.send(Address dest,
byte[] data,
int offset,
int length)
|
abstract void |
BasicTCP.send(Address dest,
byte[] data,
int offset,
int length)
|
protected void |
TUNNEL.send(Message msg,
Address dest,
boolean multicast)
|
protected void |
TP.send(Message msg,
Address dest,
boolean multicast)
Serializes and sends a message. |
protected void |
CENTRAL_LOCK.sendCreateLockRequest(Address dest,
java.lang.String lock_name,
Owner owner)
|
protected void |
FlowControl.sendCredit(Address dest,
long credits)
|
protected void |
FlowControl.sendCreditRequest(Address dest,
java.lang.Long credits_needed)
We cannot send this request as OOB messages, as the credit request needs to queue up behind the regular messages; if a receiver cannot process the regular messages, that is a sign that the sender should be throttled ! |
protected void |
CENTRAL_LOCK.sendDeleteLockRequest(Address dest,
java.lang.String lock_name)
|
protected void |
AUTH.sendJoinRejectionMessage(Address dest,
java.lang.String error_msg)
|
protected void |
AUTH.sendMergeRejectionMessage(Address dest,
java.lang.String error_msg)
|
protected abstract void |
Executing.sendNewConsumerRequest(Address source)
|
protected void |
CENTRAL_EXECUTOR.sendNewConsumerRequest(Address sender)
|
protected abstract void |
Executing.sendNewRunRequest(Address source)
|
protected void |
CENTRAL_EXECUTOR.sendNewRunRequest(Address sender)
|
protected void |
AUTH.sendRejectionMessage(byte type,
Address dest,
java.lang.String error_msg)
|
protected abstract void |
Executing.sendRemoveConsumerRequest(Address source)
|
protected void |
CENTRAL_EXECUTOR.sendRemoveConsumerRequest(Address sender)
|
protected abstract void |
Executing.sendRemoveRunRequest(Address source)
|
protected void |
CENTRAL_EXECUTOR.sendRemoveRunRequest(Address sender)
|
protected void |
Executing.sendRequest(Address dest,
Executing.Type type,
short requestId,
java.lang.Object object)
|
protected void |
Locking.sendRequest(Address dest,
Locking.Type type,
java.lang.String lock_name,
Owner owner,
long timeout,
boolean is_trylock)
|
protected void |
UNICAST2.sendStableMessage(Address dest,
long low,
long high)
|
protected void |
TP.sendToSingleMember(Address dest,
byte[] buf,
int offset,
int length)
|
protected void |
SHARED_LOOPBACK.sendToSingleMember(Address dest,
byte[] buf,
int offset,
int length)
|
void |
TUNNEL.TUNNELPolicy.sendToSingleMember(java.util.List<RouterStub> stubs,
java.lang.String group,
Address dest,
byte[] data,
int offset,
int length)
|
protected void |
RELAY.sendViewOnLocalCluster(Address dest,
RELAY.ViewData data,
boolean use_seperate_thread)
|
protected void |
RELAY.sendViewOnLocalCluster(Address dest,
View remote_view,
View global_view,
boolean use_seperate_thread)
|
protected void |
TP.setInAllThreadFactories(java.lang.String cluster_name,
Address local_address,
java.lang.String pattern)
|
protected void |
ENCRYPT.setKeyServerAddr(Address keyServerAddr)
|
protected void |
ENCRYPT.setLocal_addr(Address local_addr)
|
void |
DISCARD.setLocalAddress(Address localAddress)
|
protected void |
UNICAST2.stable(Address sender,
long highest_delivered,
long highest_seen)
Purge all messages in window for local_addr, which are <= low. |
protected static void |
TP.writeMessageList(Address dest,
Address src,
java.util.List<Message> msgs,
java.io.DataOutputStream dos,
boolean multicast)
Write a lits of messages with the same destination and *mostly* the same src addresses. |
Method parameters in org.jgroups.protocols with type arguments of type Address | |
---|---|
protected long |
FlowControl.adjustCredit(java.util.Map<Address,FlowControl.Credit> map,
Address sender,
int length)
Check whether sender has enough credits left. |
protected void |
CENTRAL_LOCK.copyLocksTo(java.util.List<Address> new_joiners)
|
protected void |
CENTRAL_EXECUTOR.copyQueueTo(java.util.List<Address> new_joiners)
|
protected void |
FlowControl.handleCreditRequest(java.util.Map<Address,FlowControl.Credit> map,
Address sender,
long requested_credits)
|
protected void |
Locking.ServerLock.handleView(java.util.List<Address> members)
|
protected void |
MFC.handleViewChange(java.util.Vector<Address> mbrs)
|
protected void |
UFC.handleViewChange(java.util.Vector<Address> mbrs)
|
protected void |
FlowControl.handleViewChange(java.util.Vector<Address> mbrs)
|
protected View |
Discovery.makeView(java.util.Vector<Address> mbrs)
|
protected static java.lang.String |
FlowControl.printMap(java.util.Map<Address,FlowControl.Credit> m)
|
void |
TCP.retainAll(java.util.Collection<Address> members)
|
void |
TCP_NIO.retainAll(java.util.Collection<Address> members)
|
abstract void |
BasicTCP.retainAll(java.util.Collection<Address> members)
|
protected void |
PEER_LOCK.PeerLock.retainAll(java.util.List<Address> members)
|
Constructors in org.jgroups.protocols with parameters of type Address | |
---|---|
Executing.Owner(Address address,
short requestId)
|
|
FD_SOCK.FdHeader(byte type,
Address mbr)
|
|
FD_SOCK.FdHeader(byte type,
Address mbr,
IpAddress sock_addr)
|
|
FD.FdHeader(byte type,
java.util.Collection<Address> mbrs,
Address from)
|
|
HTOTAL.HTotalHeader(Address dest,
Address src)
|
|
PingData(Address own_addr,
View view,
boolean is_server)
|
|
PingData(Address own_addr,
View view,
boolean is_server,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
|
|
SEQUENCER.SequencerHeader(byte type,
Address original_sender,
long seqno)
|
|
TP.ProtocolAdapter(java.lang.String cluster_name,
Address local_addr,
short transport_id,
Protocol up,
Protocol down,
java.lang.String pattern)
|
Constructor parameters in org.jgroups.protocols with type arguments of type Address | |
---|---|
DISCARD.DiscardHeader(java.util.Set<Address> ignoredAddresses)
|
|
FD_SOCK.FdHeader(byte type,
java.util.Map<Address,IpAddress> cachedAddrs)
|
|
FD_SOCK.FdHeader(byte type,
java.util.Set<Address> mbrs)
|
|
FD.FdHeader(byte type,
java.util.Collection<Address> mbrs,
Address from)
|
Uses of Address in org.jgroups.protocols.pbcast |
---|
Fields in org.jgroups.protocols.pbcast declared as Address | |
---|---|
protected Address |
GMS.local_addr
|
Methods in org.jgroups.protocols.pbcast that return Address | |
---|---|
protected Address |
GMS.determineCoordinator()
|
Address |
GMS.GmsHeader.getMember()
|
Address |
NakAckHeader.getSender()
|
Address |
MergeData.getSender()
|
Methods in org.jgroups.protocols.pbcast with parameters of type Address | |
---|---|
static NakAckHeader |
NakAckHeader.createXmitRequestHeader(long low,
long high,
Address orginal_sender)
|
double |
NAKACK.getSmoothedAverageRetransmissionTime(Address sender)
Returns the smoothed average retransmission time for a given sender |
NakReceiverWindow |
NAKACK.getWindow(Address mbr)
Please don't use this method; it is only provided for unit testing ! |
void |
Merger.handleDigestResponse(Address sender,
Digest digest)
|
void |
ServerGmsImpl.handleDigestResponse(Address sender,
Digest digest)
|
void |
GmsImpl.handleDigestResponse(Address sender,
Digest digest)
|
void |
Merger.handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs)
Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender. |
void |
ServerGmsImpl.handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs)
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,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs)
|
void |
ClientGmsImpl.join(Address address,
boolean useFlushIfPresent)
|
void |
ParticipantGmsImpl.join(Address mbr,
boolean useFlushIfPresent)
|
abstract void |
GmsImpl.join(Address mbr,
boolean useFlushIfPresent)
|
void |
CoordGmsImpl.join(Address mbr,
boolean useFlushIfPresent)
|
void |
ClientGmsImpl.joinWithStateTransfer(Address local_addr,
boolean useFlushIfPresent)
|
void |
ParticipantGmsImpl.joinWithStateTransfer(Address mbr,
boolean useFlushIfPresent)
|
abstract void |
GmsImpl.joinWithStateTransfer(Address local_addr,
boolean useFlushIfPresent)
|
void |
CoordGmsImpl.joinWithStateTransfer(Address mbr,
boolean useFlushIfPresent)
|
void |
ClientGmsImpl.leave(Address mbr)
|
void |
ParticipantGmsImpl.leave(Address mbr)
Loop: determine coord. |
abstract void |
GmsImpl.leave(Address mbr)
|
void |
CoordGmsImpl.leave(Address mbr)
The coordinator itself wants to leave the group |
void |
NAKACK.messageGapDetected(long from,
long to,
Address src)
Called when a message gap is detected |
void |
NAKACK.missingMessageReceived(long seqno,
Address original_sender)
|
void |
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 |
Merger.sendMergeRejectedResponse(Address sender,
MergeId merge_id)
|
protected void |
GmsImpl.sendMergeRejectedResponse(Address sender,
MergeId merge_id)
|
void |
ParticipantGmsImpl.suspect(Address mbr)
|
void |
GmsImpl.suspect(Address mbr)
|
void |
CoordGmsImpl.suspect(Address mbr)
|
void |
ParticipantGmsImpl.unsuspect(Address mbr)
Removes previously suspected member from list of currently suspected members |
void |
GmsImpl.unsuspect(Address mbr)
|
protected 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 | |
---|---|
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 false |
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 |
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.getNextView(java.util.Collection<Address> new_mbrs,
java.util.Collection<Address> old_mbrs,
java.util.Collection<Address> suspected_mbrs)
Computes the next view. |
void |
Merger.handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs)
Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender. |
void |
ServerGmsImpl.handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs)
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,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs)
|
protected boolean |
GmsImpl.iWouldBeCoordinator(java.util.Vector<Address> new_mbrs)
Returns potential coordinator based on lexicographic ordering of member addresses. |
View |
GMS.makeView(java.util.Vector<Address> mbrs)
|
static View |
GMS.makeView(java.util.Vector<Address> mbrs,
ViewId vid)
|
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 Address | |
---|---|
GMS.GmsHeader(byte type,
Address mbr)
|
|
GMS.GmsHeader(byte type,
Address mbr,
boolean useFlushIfPresent)
Used for JOIN_REQ or LEAVE_REQ header |
|
MergeData(Address sender,
View view,
Digest digest)
|
|
STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest)
|
|
STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest,
java.lang.String state_id)
|
|
STREAMING_STATE_TRANSFER.StateHeader(byte type,
Address sender,
IpAddress bind_addr,
Digest digest,
java.lang.String state_id)
|
|
STREAMING_STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest)
|
|
STREAMING_STATE_TRANSFER.StateHeader(byte type,
Address sender,
java.lang.String state_id)
|
Constructor parameters in org.jgroups.protocols.pbcast with type arguments of type Address | |
---|---|
FLUSH.FlushHeader(byte type,
long viewID,
java.util.Collection<? extends Address> flushView)
|
|
GMS.GmsHeader(byte type,
java.util.Collection<Address> mbrs)
|
Uses of Address in org.jgroups.stack |
---|
Classes in org.jgroups.stack that implement Address | |
---|---|
class |
IpAddress
Network-dependent address (Internet). |
Fields in org.jgroups.stack declared as Address | |
---|---|
protected Address |
Retransmitter.Task.msg_sender
|
protected Address |
Retransmitter.sender
|
Address |
StateTransferInfo.target
|
Methods in org.jgroups.stack that return Address | |
---|---|
Address |
AddressGenerator.generateAddress()
|
Address |
GossipData.getAddress()
|
Methods in org.jgroups.stack that return types with arguments of type Address | |
---|---|
java.util.List<Address> |
GossipData.getMembers()
|
Methods in org.jgroups.stack with parameters of type Address | |
---|---|
void |
AckMcastSenderWindow.ack(long seqno,
Address sender)
An ACK has been received from sender . |
int |
IpAddress.compareTo(Address o)
implements the java.lang.Comparable interface |
void |
RouterStub.connect(java.lang.String group,
Address addr,
java.lang.String logical_name,
java.util.List<PhysicalAddress> phys_addrs)
Register this process with the router under group . |
void |
RouterStub.disconnect(java.lang.String group,
Address addr)
|
void |
NakReceiverWindow.Listener.messageGapDetected(long from,
long to,
Address src)
|
void |
NakReceiverWindow.Listener.missingMessageReceived(long seqno,
Address original_sender)
|
void |
AckMcastSenderWindow.remove(Address obj)
Remove obj from all receiver sets and wake up
retransmission thread. |
void |
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 numbers first_seqno and last_seqno . |
void |
AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno,
Message msg,
Address dest)
Retranmit the given msg |
void |
RouterStub.sendToMember(java.lang.String group,
Address dest,
byte[] data,
int offset,
int length)
|
void |
ProtocolStack.startStack(java.lang.String cluster_name,
Address local_addr)
Start all layers. |
void |
AckMcastSenderWindow.suspect(Address suspected)
Process with address suspected is suspected: remove it
from all receiver sets. |
Method parameters in org.jgroups.stack with type arguments of type Address | |
---|---|
void |
GossipData.setMembers(java.util.List<Address> mbrs)
|
Constructors in org.jgroups.stack with parameters of type Address | |
---|---|
AckSenderWindow(AckSenderWindow.RetransmitCommand com,
Interval interval,
TimeScheduler sched,
Address sender)
|
|
DefaultRetransmitter.SeqnoTask(long seqno,
Interval intervals,
Retransmitter.RetransmitCommand cmd,
Address msg_sender)
|
|
DefaultRetransmitter(Address sender,
Retransmitter.RetransmitCommand cmd,
TimeScheduler sched)
Create a new Retransmitter associated with the given sender address |
|
GossipData(byte type,
java.lang.String group,
Address addr)
|
|
GossipData(byte type,
java.lang.String group,
Address addr,
byte[] buffer)
|
|
GossipData(byte type,
java.lang.String group,
Address addr,
byte[] buffer,
int offset,
int length)
|
|
GossipData(byte type,
java.lang.String group,
Address addr,
java.util.List<Address> mbrs)
|
|
GossipData(byte type,
java.lang.String group,
Address addr,
java.util.List<Address> mbrs,
java.util.List<PhysicalAddress> physical_addrs)
|
|
GossipData(byte type,
java.lang.String group,
Address addr,
java.lang.String logical_name,
java.util.List<PhysicalAddress> phys_addrs)
|
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
long lowest_seqno,
TimeScheduler sched)
Creates a new instance with the given retransmit command |
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
long lowest_seqno,
TimeScheduler sched,
boolean use_range_based_retransmitter)
|
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
long lowest_seqno,
TimeScheduler sched,
boolean use_range_based_retransmitter,
int num_rows,
int msgs_per_row,
double resize_factor,
long max_compaction_time,
boolean automatic_purging)
|
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
TimeScheduler sched)
Creates a new instance with the given retransmit command |
|
RangeBasedRetransmitter.RangeTask(Seqno range,
Interval intervals,
Retransmitter.RetransmitCommand cmd,
Address msg_sender)
|
|
RangeBasedRetransmitter(Address sender,
Retransmitter.RetransmitCommand cmd,
TimeScheduler sched)
Create a new Retransmitter associated with the given sender address |
|
Retransmitter.Task(Interval intervals,
Retransmitter.RetransmitCommand cmd,
Address msg_sender)
|
|
Retransmitter(Address sender,
Retransmitter.RetransmitCommand cmd,
TimeScheduler sched)
Create a new Retransmitter associated with the given sender address |
|
RouterStubManager(Protocol owner,
java.lang.String channelName,
Address logicalAddress,
long interval)
|
|
StateTransferInfo(Address target)
|
|
StateTransferInfo(Address target,
java.io.InputStream is,
java.lang.String state_id)
|
|
StateTransferInfo(Address target,
long timeout)
|
|
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)
|
Constructor parameters in org.jgroups.stack with type arguments of type Address | |
---|---|
GossipData(byte type,
java.lang.String group,
Address addr,
java.util.List<Address> mbrs)
|
|
GossipData(byte type,
java.lang.String group,
Address addr,
java.util.List<Address> mbrs,
java.util.List<PhysicalAddress> physical_addrs)
|
Uses of Address in org.jgroups.util |
---|
Classes in org.jgroups.util that implement Address | |
---|---|
class |
AdditionalDataUUID
Subclass of UUID which adds a string as payload. |
class |
PayloadUUID
Subclass of UUID which adds a string as payload. |
class |
SingletonAddress
Address with a cluster name. |
class |
TopologyUUID
Subclass of UUID which adds 3 strings (siteId, rackId and machineId)as payload. |
class |
UUID
Logical address which is unique over space and time. |
Fields in org.jgroups.util declared as Address | |
---|---|
protected Address |
SingletonAddress.addr
|
Fields in org.jgroups.util with type parameters of type Address | |
---|---|
protected static LazyRemovalCache<Address,java.lang.String> |
UUID.cache
Keeps track of associations between logical addresses (UUIDs) and logical names |
protected java.util.Map<Address,java.lang.Long> |
CreditMap.credits
|
protected static LazyRemovalCache.Printable<Address,java.lang.String> |
UUID.print_function
|
protected java.util.Map<Address,Digest.Entry> |
Digest.senders
Map<Address, Entry> |
Methods in org.jgroups.util that return Address | |
---|---|
static Address |
Util.createRandomAddress()
|
static Address |
Util.createRandomAddress(java.lang.String name)
|
Address |
SingletonAddress.getAddress()
|
Address |
Rsp.getSender()
|
static Address |
Util.readAddress(java.io.DataInputStream in)
|
Methods in org.jgroups.util that return types with arguments of type Address | |
---|---|
static java.util.Vector<Address> |
Util.determineLeftMembers(java.util.List<Address> old_mbrs,
java.util.List<Address> new_mbrs)
Returns all members that left between 2 views. |
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.util.List<Address> |
Util.determineNewMembers(java.util.List<Address> old_mbrs,
java.util.List<Address> new_mbrs)
Returns the members which joined between 2 subsequent views |
java.util.Set<java.util.Map.Entry<Address,Rsp>> |
RspList.entrySet()
|
static java.util.Map<Address,java.lang.String> |
UUID.getContents()
Returns a copy of the cache's contents |
java.util.List<Tuple<Address,java.lang.Long>> |
CreditMap.getMembersWithCreditsLessThan(long min_credits)
|
java.util.List<Address> |
CreditMap.getMembersWithInsufficientCredits(long credit_needed)
|
java.util.Map<Address,T> |
ResponseCollector.getResults()
|
java.util.Map<Address,Digest.Entry> |
MutableDigest.getSenders()
|
java.util.Map<Address,Digest.Entry> |
Digest.getSenders()
Returns an unmodifiable map, so modifications will result in exceptions |
java.util.Vector<Address> |
RspList.getSuspectedMembers()
|
java.util.Set<Address> |
CreditMap.keys()
|
java.util.Set<Address> |
RspList.keySet()
|
static java.util.List<Address> |
Util.leftMembers(java.util.Collection<Address> old_list,
java.util.Collection<Address> new_list)
|
static java.util.List<Address> |
Util.leftMembers(View one,
View two)
Returns a list of members which left from view one to two |
static java.util.List<Address> |
Util.newMembers(java.util.List<Address> old_list,
java.util.List<Address> new_list)
|
static java.util.Vector<Address> |
Util.pickSubset(java.util.Vector<Address> members,
double subset_percentage)
Selects a random subset of members according to subset_percentage and returns them. |
static java.util.Collection<? extends Address> |
Util.readAddresses(java.io.DataInputStream in,
java.lang.Class cl)
|
Methods in org.jgroups.util with parameters of type Address | |
---|---|
boolean |
SeqnoTable.add(Address member,
long seqno)
|
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)
|
static void |
UUID.add(Address uuid,
java.lang.String logical_name)
|
void |
ResponseCollector.add(Address member,
T data)
|
void |
RspList.addNotReceived(Address sender)
|
void |
RspList.addRsp(Address sender,
java.lang.Object retval)
|
void |
RspList.addSuspect(Address sender)
|
int |
UUID.compareTo(Address other)
Compares this UUID with the specified UUID. |
int |
SingletonAddress.compareTo(Address o)
|
boolean |
Digest.contains(Address sender)
|
static MergeId |
MergeId.create(Address addr)
|
static View |
Util.createView(Address coord,
long id,
Address... members)
|
static View |
Util.createView(Address coord,
long id,
Address... members)
|
protected void |
CreditMap.decrementAndAdd(Address member,
long new_credits)
Decrements credits bytes from all elements and add new_credits to member (if non null). |
void |
FIFOMessageQueue.done(Address sender,
K dest)
Deprecated. |
static java.lang.String |
UUID.get(Address logical_addr)
|
java.lang.Long |
CreditMap.get(Address member)
|
Digest.Entry |
Digest.get(Address sender)
Returns the Entry for the given sender. |
long |
SeqnoTable.getHighestReceived(Address member)
|
long |
SeqnoTable.getNextToReceive(Address member)
|
static int |
Util.getRank(View view,
Address addr)
|
long |
Digest.highestDeliveredSeqnoAt(Address sender)
|
long |
Digest.highestReceivedSeqnoAt(Address sender)
|
void |
MutableDigest.incrementHighestDeliveredSeqno(Address sender)
Increments the sender's highest delivered seqno by 1 |
static boolean |
Util.isCoordinator(View view,
Address local_addr)
|
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)
Deprecated. |
Rsp |
RspList.put(Address key,
Rsp value)
|
java.lang.Long |
CreditMap.putIfAbsent(Address key)
|
void |
ResponseCollector.remove(Address member)
|
static void |
UUID.remove(Address addr)
|
void |
SeqnoTable.remove(Address member)
|
java.lang.Long |
CreditMap.remove(Address key)
|
void |
CreditMap.replenish(Address sender,
long new_credits)
|
void |
ResponseCollector.reset(Address... members)
|
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 host |
boolean |
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 |
ResponseCollector.suspect(Address member)
|
void |
AckCollector.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 | |
---|---|
static void |
UUID.add(java.util.Map<Address,java.lang.String> map)
|
static byte[] |
Util.collectionToByteBuffer(java.util.Collection<Address> c)
|
static java.util.Vector<Address> |
Util.determineLeftMembers(java.util.List<Address> old_mbrs,
java.util.List<Address> new_mbrs)
Returns all members that left between 2 views. |
static java.util.Vector<Address> |
Util.determineLeftMembers(java.util.List<Address> old_mbrs,
java.util.List<Address> new_mbrs)
Returns all members that left between 2 views. |
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.util.List<Address> |
Util.determineNewMembers(java.util.List<Address> old_mbrs,
java.util.List<Address> new_mbrs)
Returns the members which joined between 2 subsequent views |
static java.util.List<Address> |
Util.determineNewMembers(java.util.List<Address> old_mbrs,
java.util.List<Address> new_mbrs)
Returns the members which joined between 2 subsequent views |
static java.util.List<Address> |
Util.leftMembers(java.util.Collection<Address> old_list,
java.util.Collection<Address> new_list)
|
static java.util.List<Address> |
Util.leftMembers(java.util.Collection<Address> old_list,
java.util.Collection<Address> new_list)
|
static java.util.List<Address> |
Util.newMembers(java.util.List<Address> old_list,
java.util.List<Address> new_list)
|
static java.util.List<Address> |
Util.newMembers(java.util.List<Address> old_list,
java.util.List<Address> new_list)
|
static java.util.Vector<Address> |
Util.pickSubset(java.util.Vector<Address> members,
double subset_percentage)
Selects a random subset of members according to subset_percentage and returns them. |
void |
RspList.putAll(java.util.Map<? extends Address,? extends Rsp> m)
|
static void |
UUID.removeAll(java.util.Collection<Address> mbrs)
|
void |
ResponseCollector.reset(java.util.Collection<Address> members)
|
void |
AckCollector.reset(java.util.Collection<Address> members)
|
static void |
UUID.retainAll(java.util.Collection<Address> logical_addrs)
|
boolean |
SeqnoTable.retainAll(java.util.Collection<Address> members)
|
static long |
Util.size(java.util.Collection<? extends Address> addrs)
Returns the marshalled size of a Collection of Addresses. |
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)
|
static void |
Util.writeAddresses(java.util.Collection<? extends Address> v,
java.io.DataOutputStream out)
Writes a Vector of Addresses. |
Constructors in org.jgroups.util with parameters of type Address | |
---|---|
Digest(Address sender,
long low,
long highest_delivered)
|
|
Digest(Address sender,
long low,
long highest_delivered,
long highest_received)
|
|
ResponseCollector(Address... members)
|
|
Rsp(Address sender)
|
|
Rsp(Address sender,
boolean suspected)
|
|
Rsp(Address sender,
T retval)
|
|
SingletonAddress(java.lang.String cluster_name,
Address addr)
|
Constructor parameters in org.jgroups.util with type arguments of type Address | |
---|---|
Digest(java.util.Map<Address,Digest.Entry> map)
Creates a new digest from an existing map by copying the keys and values from map |
|
MutableDigest(java.util.Map<Address,Digest.Entry> map)
|
|
ResponseCollector(java.util.Collection<Address> members)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |