com.bigdata.service

Class LoadBalancerService.RoundRobinServiceLoadHelper

java.lang.Object

com.bigdata.service.AbstractRoundRobinServiceLoadHelper

com.bigdata.service.LoadBalancerService.RoundRobinServiceLoadHelper

All Implemented Interfaces:

IServiceLoadHelper

Enclosing class:

LoadBalancerService

protected class LoadBalancerService.RoundRobinServiceLoadHelper
extends AbstractRoundRobinServiceLoadHelper

Integration with the LoadBalancerService.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields inherited from class com.bigdata.service.AbstractRoundRobinServiceLoadHelper

INFO, log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	LoadBalancerService.RoundRobinServiceLoadHelper()

Method Summary

Methods

Modifier and Type	Method and Description
protected UUID[]	awaitServices(int minCount, long timeout) Await the availability of at least the specified #of IDataServices.

Methods inherited from class com.bigdata.service.AbstractRoundRobinServiceLoadHelper

getUnderUtilizedDataServices

Methods inherited from class java.lang.Object

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

Constructor Detail

LoadBalancerService.RoundRobinServiceLoadHelper

protected LoadBalancerService.RoundRobinServiceLoadHelper()

Method Detail

awaitServices

protected UUID[] awaitServices(int minCount,
                   long timeout)
                        throws InterruptedException,
                               TimeoutException

Description copied from class: AbstractRoundRobinServiceLoadHelper

Await the availability of at least the specified #of IDataServices.

Specified by:

awaitServices in class AbstractRoundRobinServiceLoadHelper

Parameters:

minCount - The minimum #of data services.

timeout - The timeout (ms).

Returns:

An array #of the UUIDs of the IDataServices that have been discovered. Note that at least minDataServices elements will be present in this array but that ALL discovered data services may be reported.

Throws:

InterruptedException

TimeoutException

See Also:

AbstractScaleOutFederation.awaitServices(int, long)