com.gigaspaces.internal.remoting.routing.clustered

Class SpaceProxyLoadBalancingStrategy

java.lang.Object

com.gigaspaces.internal.remoting.routing.clustered.SpaceProxyLoadBalancingStrategy

Direct Known Subclasses:

LazyLoadBalancingStrategy, RoundRobinLoadBalancingStrategy

public abstract class SpaceProxyLoadBalancingStrategy
extends Object

Since:

9.1.2

Author:

Niv Ingberg

Field Summary

Fields

Modifier and Type	Field and Description
protected RemoteOperationsExecutorsCluster	_cluster
protected Object	_lock
protected org.slf4j.Logger	_logger

Constructor Summary

Constructors

Constructor and Description
SpaceProxyLoadBalancingStrategy(RemoteOperationsExecutorsCluster cluster)

Method Summary

Modifier and Type	Method and Description
RemoteOperationsExecutorProxy	findActiveMember(RemoteOperationRequest<?> request, long initialFailureTime, RemoteOperationsExecutorProxy oldCandidate)
RemoteOperationsExecutorProxy	findActiveMemberUninterruptibly(RemoteOperationRequest<?> request, long initialFailureTime, RemoteOperationsExecutorProxy proxy)
RemoteOperationsExecutorProxy	findAnyAvailableMember(boolean activeOnly)
abstract RemoteOperationsExecutorProxy	getCandidate(RemoteOperationRequest<?> request)
void	onMemberConnected(RemoteOperationsExecutorProxy connectedMember)
void	onMemberDisconnected(String disconnectedMemberName)
protected abstract void	updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy) This method MUST be called from within a synchronized block.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_cluster

protected final RemoteOperationsExecutorsCluster _cluster

_logger

protected final org.slf4j.Logger _logger

_lock

protected final Object _lock

Constructor Detail

SpaceProxyLoadBalancingStrategy

public SpaceProxyLoadBalancingStrategy(RemoteOperationsExecutorsCluster cluster)

Method Detail

getCandidate

public abstract RemoteOperationsExecutorProxy getCandidate(RemoteOperationRequest<?> request)

findActiveMember

public RemoteOperationsExecutorProxy findActiveMember(RemoteOperationRequest<?> request,
                                                      long initialFailureTime,
                                                      RemoteOperationsExecutorProxy oldCandidate)
                                               throws InterruptedException

Throws:

InterruptedException

findActiveMemberUninterruptibly

public RemoteOperationsExecutorProxy findActiveMemberUninterruptibly(RemoteOperationRequest<?> request,
                                                                     long initialFailureTime,
                                                                     RemoteOperationsExecutorProxy proxy)

findAnyAvailableMember

public RemoteOperationsExecutorProxy findAnyAvailableMember(boolean activeOnly)

onMemberConnected

public void onMemberConnected(RemoteOperationsExecutorProxy connectedMember)

onMemberDisconnected

public void onMemberDisconnected(String disconnectedMemberName)

updateActiveProxy

protected abstract void updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy)

This method MUST be called from within a synchronized block.