Package 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	Description
protected final RemoteOperationsExecutorsCluster	_cluster
protected final Object	_lock
protected final org.slf4j.Logger	_logger

Constructor Summary

Constructors

Constructor	Description
SpaceProxyLoadBalancingStrategy(RemoteOperationsExecutorsCluster cluster)

Method Summary

Modifier and Type	Method	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 Details

_cluster

protected final RemoteOperationsExecutorsCluster _cluster

_logger

protected final org.slf4j.Logger _logger

_lock

protected final Object _lock

Constructor Details

SpaceProxyLoadBalancingStrategy

public SpaceProxyLoadBalancingStrategy(RemoteOperationsExecutorsCluster cluster)

Method Details

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.