com.bigdata.service

Class AbstractServiceLoadHelper

java.lang.Object

com.bigdata.service.AbstractServiceLoadHelper

All Implemented Interfaces:

IServiceLoadHelper

Direct Known Subclasses:

AbstractServiceLoadHelperWithoutScores, AbstractServiceLoadHelperWithScores

public abstract class AbstractServiceLoadHelper
extends Object
implements IServiceLoadHelper

Base class for abstract implementations with integration points for the LoadBalancerService.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected long	joinTimeout

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractServiceLoadHelper(long joinTimeout)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	awaitJoin(long timeout, TimeUnit unit) Await the join of an IDataService.
protected abstract UUID[]	getActiveServices() Return an array of service UUIDs for all of the active IDataServices that we know about right now (snapshot).
protected abstract boolean	isActiveDataService(UUID serviceUUID) Return true iff the given serviceUUID identifies an active IDataService.
protected abstract boolean	isUnderUtilizedDataService(ServiceScore score, ServiceScore[] scores) Return true iff the service is under-utilized.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.service.IServiceLoadHelper

getUnderUtilizedDataServices

Field Detail

joinTimeout

protected final long joinTimeout

Constructor Detail

AbstractServiceLoadHelper

protected AbstractServiceLoadHelper(long joinTimeout)

Parameters:

joinTimeout -

Method Detail

isUnderUtilizedDataService

protected abstract boolean isUnderUtilizedDataService(ServiceScore score,
                                 ServiceScore[] scores)

Return true iff the service is under-utilized.

Parameters:

score - The score for the service.

scores - The set of scores for the known services.

isActiveDataService

protected abstract boolean isActiveDataService(UUID serviceUUID)

Return true iff the given serviceUUID identifies an active IDataService.

Parameters:

serviceUUID - The service UUID.

awaitJoin

protected abstract void awaitJoin(long timeout,
             TimeUnit unit)
                           throws InterruptedException

Await the join of an IDataService.

Parameters:

timeout - The timeout.

unit - The unit for the timeout.

Throws:

InterruptedException

getActiveServices

protected abstract UUID[] getActiveServices()

Return an array of service UUIDs for all of the active IDataServices that we know about right now (snapshot).

Returns:

The array and never null.