Modifier and Type | Method and Description |
---|---|
ClusterNode |
GroupCommunicationService.getClusterNode()
Gets the object that represents this node in the current group.
|
Modifier and Type | Method and Description |
---|---|
List<ClusterNode> |
GroupCommunicationService.getClusterNodes()
Gets the member nodes that comprise the current group membership.
|
Modifier and Type | Method and Description |
---|---|
void |
GroupRpcDispatcher.callAsyncMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
ClusterNode targetNode)
Calls method on target node only.
|
void |
GroupRpcDispatcher.callAsyncMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
ClusterNode targetNode,
boolean unordered)
Calls method on target node only.
|
<T> T |
GroupRpcDispatcher.callMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
ClusterNode targetNode)
Calls method on target node only.
|
<T> T |
GroupRpcDispatcher.callMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
long methodTimeout,
ClusterNode targetNode)
Calls method on target node only.
|
<T> T |
GroupRpcDispatcher.callMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
long methodTimeout,
ClusterNode targetNode,
boolean unordered)
Calls method synchronously on target node only.
|
String |
ClusteringApiMessages.cannotAcquireHeldLock(ClusterNode node)
A message indicating that a lock could not be acquired because it's held by the node.
|
boolean |
ResponseFilter.isAcceptable(Object response,
ClusterNode sender)
Determines whether a response from a given sender should be added to the response list of the request
|
IllegalStateException |
ClusteringApiMessages.receivedUnlockForRemoteNode(ClusterNode caller)
Creates an exception indicating an unlock should not be invoked for remote nodes.
|
Modifier and Type | Method and Description |
---|---|
void |
GroupMembershipListener.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers)
Called when a partition topology change occurs.
|
void |
GroupMembershipListener.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers)
Called when a partition topology change occurs.
|
void |
GroupMembershipListener.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers)
Called when a partition topology change occurs.
|
void |
GroupMembershipListener.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups)
Specialized notification issued instead of
the standard one when a
network-partition merge occurs. |
void |
GroupMembershipListener.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups)
Specialized notification issued instead of
the standard one when a
network-partition merge occurs. |
void |
GroupMembershipListener.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups)
Specialized notification issued instead of
the standard one when a
network-partition merge occurs. |
void |
GroupMembershipListener.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups)
Specialized notification issued instead of
the standard one when a
network-partition merge occurs. |
Modifier and Type | Class and Description |
---|---|
class |
ClusterNodeImpl
Replacement for a JG IpAddress that doesn't base its representation on the JG address but on the computed node name added to
the IPAddress instead.
|
Modifier and Type | Field and Description |
---|---|
protected List<ClusterNode> |
CoreGroupCommunicationService.GroupView.allMembers |
protected List<ClusterNode> |
CoreGroupCommunicationService.GroupView.deadMembers |
protected List<ClusterNode> |
CoreGroupCommunicationService.GroupView.newMembers |
protected List<List<ClusterNode>> |
CoreGroupCommunicationService.GroupView.originatingGroups |
Modifier and Type | Method and Description |
---|---|
ClusterNode |
CoreGroupCommunicationService.getClusterNode() |
ClusterNode |
ClusterNodeFactory.getClusterNode(org.jgroups.Address address) |
Modifier and Type | Method and Description |
---|---|
List<ClusterNode> |
CoreGroupCommunicationService.getClusterNodes() |
Modifier and Type | Method and Description |
---|---|
void |
CoreGroupCommunicationService.callAsyncMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
ClusterNode targetNode)
Calls method on target node only.
|
void |
CoreGroupCommunicationService.callAsyncMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
ClusterNode targetNode,
boolean unordered)
Calls method on target node only.
|
<T> T |
CoreGroupCommunicationService.callMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
ClusterNode targetNode)
Calls method on target node only.
|
<T> T |
CoreGroupCommunicationService.callMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
long methodTimeout,
ClusterNode targetNode)
Calls method on target node only.
|
<T> T |
CoreGroupCommunicationService.callMethodOnNode(String serviceName,
String methodName,
Object[] args,
Class<?>[] types,
long methodTimeout,
ClusterNode targetNode,
boolean unordered)
Calls method synchronously on target node only.
|
int |
ClusterNodeImpl.compareTo(ClusterNode o) |
IllegalStateException |
ClusteringImplMessages.duplicateViewFound(ClusterNode newNode,
ClusterNode currentNode)
Creates an exception indicating a duplicate view was found.
|
IllegalArgumentException |
ClusteringImplMessages.invalidTargetNodeInstance(ClusterNode targetNode,
Class<? extends ClusterNode> type)
Creates an exception indicating the target node is not an instance of the type parameter.
|
Modifier and Type | Method and Description |
---|---|
IllegalArgumentException |
ClusteringImplMessages.invalidTargetNodeInstance(ClusterNode targetNode,
Class<? extends ClusterNode> type)
Creates an exception indicating the target node is not an instance of the type parameter.
|
void |
ClusteringImplLogger.newClusterCurrentView(String groupName,
long viewId,
int difference,
boolean isMerge,
Collection<ClusterNode> allMembers)
Logs an informational message with information on a new cluster view.
|
String |
ClusteringImplMessages.viewCreated(Collection<ClusterNode> allMembers,
long id,
CoreGroupCommunicationService.GroupView oldView)
A message indicating a new view was created.
|
Modifier and Type | Field and Description |
---|---|
ClusterNode |
RemoteLockResponse.holder |
ClusterNode |
RemoteLockResponse.responder |
Modifier and Type | Method and Description |
---|---|
ClusterNode |
ClusterLockState.getHolder() |
ClusterNode |
AbstractClusterLockSupport.getLocalClusterNode() |
ClusterNode |
LocalLockHandler.getLocalNode(ClusterNode localNode) |
ClusterNode |
LocalLockHandler.getLockHolder(Serializable lockName)
Gets the node the holds the given lock on this node, or
null if no node holds the lock on this node. |
ClusterNode |
TimeoutException.getOwner() |
Modifier and Type | Method and Description |
---|---|
List<ClusterNode> |
AbstractClusterLockSupport.getCurrentView() |
Modifier and Type | Method and Description |
---|---|
ClusterNode |
LocalLockHandler.getLocalNode(ClusterNode localNode) |
protected RemoteLockResponse |
AbstractClusterLockSupport.getLock(Serializable categoryName,
ClusterLockState category,
ClusterNode caller,
long timeout)
Always call this with a lock on the Category.
|
protected abstract RemoteLockResponse |
AbstractClusterLockSupport.getRemoteLockResponseForUnknownLock(Serializable lockName,
ClusterNode caller,
long timeout) |
protected RemoteLockResponse |
NonGloballyExclusiveClusterLockSupport.getRemoteLockResponseForUnknownLock(Serializable lockName,
ClusterNode caller,
long timeout) |
protected RemoteLockResponse |
YieldingGloballyExclusiveClusterLockSupport.getRemoteLockResponseForUnknownLock(Serializable lockName,
ClusterNode caller,
long timeout) |
protected abstract RemoteLockResponse |
AbstractClusterLockSupport.handleLockSuccess(ClusterLockState lockState,
ClusterNode caller) |
protected RemoteLockResponse |
NonGloballyExclusiveClusterLockSupport.handleLockSuccess(ClusterLockState lockState,
ClusterNode caller) |
protected RemoteLockResponse |
YieldingGloballyExclusiveClusterLockSupport.handleLockSuccess(ClusterLockState lockState,
ClusterNode caller) |
void |
ClusterLockState.lock(ClusterNode holder) |
void |
LocalLockHandler.lockFromCluster(Serializable lockName,
ClusterNode caller,
long timeout)
Try to acquire the local lock within the given timeout.
|
protected void |
AbstractClusterLockSupport.recordLockHolder(ClusterLockState lockState,
ClusterNode caller) |
void |
AbstractClusterLockSupport.RpcTarget.releaseRemoteLock(Serializable categoryName,
ClusterNode caller) |
RemoteLockResponse |
AbstractClusterLockSupport.RpcTarget.remoteLock(Serializable categoryName,
ClusterNode caller,
long timeout) |
void |
LocalLockHandler.setLocalNode(ClusterNode localNode) |
void |
LocalLockHandler.unlockFromCluster(Serializable lockName,
ClusterNode caller)
Release the lock.
|
protected abstract RemoteLockResponse |
AbstractClusterLockSupport.yieldLock(ClusterLockState lockState,
ClusterNode caller,
long timeout) |
protected RemoteLockResponse |
NonGloballyExclusiveClusterLockSupport.yieldLock(ClusterLockState lockState,
ClusterNode caller,
long timeout) |
protected RemoteLockResponse |
YieldingGloballyExclusiveClusterLockSupport.yieldLock(ClusterLockState lockState,
ClusterNode caller,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractClusterLockSupport.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers) |
void |
AbstractClusterLockSupport.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers) |
void |
AbstractClusterLockSupport.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers) |
void |
AbstractClusterLockSupport.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups) |
void |
AbstractClusterLockSupport.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups) |
void |
AbstractClusterLockSupport.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups) |
void |
AbstractClusterLockSupport.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups) |
Constructor and Description |
---|
RemoteLockResponse(ClusterNode responder,
RemoteLockResponse.Flag flag) |
RemoteLockResponse(ClusterNode responder,
RemoteLockResponse.Flag flag,
ClusterNode holder) |
TimeoutException(ClusterNode owner) |
Modifier and Type | Method and Description |
---|---|
Set<ClusterNode> |
ServiceProviderRegistry.getServiceProviders(String service)
Returns the set of nodes that provide the specified service.
|
Set<ClusterNode> |
ServiceProviderRegistryService.getServiceProviders(String service) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceProviderRegistryService.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers) |
void |
ServiceProviderRegistryService.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers) |
void |
ServiceProviderRegistryService.membershipChanged(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers) |
void |
ServiceProviderRegistryService.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups) |
void |
ServiceProviderRegistryService.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups) |
void |
ServiceProviderRegistryService.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups) |
void |
ServiceProviderRegistryService.membershipChangedDuringMerge(List<ClusterNode> deadMembers,
List<ClusterNode> newMembers,
List<ClusterNode> allMembers,
List<List<ClusterNode>> originatingGroups) |
void |
ServiceProviderRegistryService.modified(org.infinispan.notifications.cachelistener.event.CacheEntryModifiedEvent<String,Map<ClusterNode,Void>> event) |
void |
ServiceProviderRegistry.Listener.serviceProvidersChanged(Set<ClusterNode> nodes,
boolean merge)
Indicates that the set of nodes providing a given service has changed.
|
Modifier and Type | Method and Description |
---|---|
ClusterNode |
SingletonElectionPolicy.elect(List<ClusterNode> nodes)
Elect a single node from the specified list of candidate nodes.
|
Modifier and Type | Method and Description |
---|---|
ClusterNode |
SingletonElectionPolicy.elect(List<ClusterNode> nodes)
Elect a single node from the specified list of candidate nodes.
|
void |
SingletonService.serviceProvidersChanged(Set<ClusterNode> nodes,
boolean merge) |
Modifier and Type | Method and Description |
---|---|
ClusterNode |
PreferredSingletonElectionPolicy.elect(List<ClusterNode> candidates) |
ClusterNode |
SimpleSingletonElectionPolicy.elect(List<ClusterNode> candidates) |
Modifier and Type | Method and Description |
---|---|
boolean |
NamePreference.preferred(ClusterNode node) |
boolean |
SocketAddressPreference.preferred(ClusterNode node) |
boolean |
Preference.preferred(ClusterNode node) |
Modifier and Type | Method and Description |
---|---|
ClusterNode |
PreferredSingletonElectionPolicy.elect(List<ClusterNode> candidates) |
ClusterNode |
SimpleSingletonElectionPolicy.elect(List<ClusterNode> candidates) |
Copyright © 2013 JBoss, a division of Red Hat, Inc.. All Rights Reserved.