com.bigdata.service

Class AbstractServiceLoadHelperWithoutScores

java.lang.Object

com.bigdata.service.AbstractServiceLoadHelper

com.bigdata.service.AbstractServiceLoadHelperWithoutScores

All Implemented Interfaces:

IServiceLoadHelper

Direct Known Subclasses:

LoadBalancerService.ServiceLoadHelperWithoutScores

public abstract class AbstractServiceLoadHelperWithoutScores
extends AbstractServiceLoadHelper

Implementation that may be used when service scores are not yet available.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected static boolean	INFO
protected static org.apache.log4j.Logger	log

Fields inherited from class com.bigdata.service.AbstractServiceLoadHelper

joinTimeout

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractServiceLoadHelperWithoutScores(long joinTimeout)

Method Summary

Methods

Modifier and Type	Method and Description
UUID[]	getUnderUtilizedDataServices(int minCount, int maxCount, UUID exclude) Computes the under-utilized services in the case where where minCount is non-zero and we do not have pre-computed #serviceScores on hand.

Methods inherited from class com.bigdata.service.AbstractServiceLoadHelper

awaitJoin, getActiveServices, isActiveDataService, isUnderUtilizedDataService

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

INFO

protected static final boolean INFO

Constructor Detail

AbstractServiceLoadHelperWithoutScores

protected AbstractServiceLoadHelperWithoutScores(long joinTimeout)

Parameters:

joinTimeout -

Method Detail

getUnderUtilizedDataServices

public UUID[] getUnderUtilizedDataServices(int minCount,
                                  int maxCount,
                                  UUID exclude)
                                    throws TimeoutException,
                                           InterruptedException

Computes the under-utilized services in the case where where minCount is non-zero and we do not have pre-computed #serviceScores on hand. If there are also no active services, then this awaits the join of at least one service. Once it has at least one service that is not the optionally excluded service, it returns the "under-utilized" services.

Returns:

Throws:

TimeoutException - If the result could not be obtained before the timeout was triggered.

InterruptedException

See Also:

ILoadBalancerService.getUnderUtilizedDataServices(int, int, UUID)