com.bigdata.service

Class AbstractFederation.StartDeferredTasksTask

java.lang.Object

com.bigdata.service.AbstractFederation.StartDeferredTasksTask

All Implemented Interfaces:

Runnable

Enclosing class:

AbstractFederation<T>

protected class AbstractFederation.StartDeferredTasksTask
extends Object
implements Runnable

This task starts an (optional) AbstractStatisticsCollector, an (optional) httpd service, and the (required) AbstractFederation.ReportTask.

Note: The AbstractFederation.ReportTask will relay any collected performance counters to the ILoadBalancerService, but it also lets the ILoadBalancerService know which services exist, which is important for some of its functions.

Author:

Bryan Thompson

Method Summary

Methods

Modifier and Type	Method and Description
void	run()
protected void	startDeferredTasks() Starts performance counter collection.
protected void	startGangliaService(AbstractStatisticsCollector statisticsCollector) Start embedded Ganglia peer.
protected void	startHttpdService() Start the local httpd service (if enabled).
protected void	startPlatformStatisticsCollection() Start collecting performance counters from the OS (if enabled).
protected void	startQueueStatisticsCollection() Setup sampling on the client's thread pool.
protected void	startReportTask() Start task to report service and counters to the load balancer.

Methods inherited from class java.lang.Object

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

Method Detail

run

public void run()

Specified by:

run in interface Runnable

startDeferredTasks

protected void startDeferredTasks()
                           throws IOException

Starts performance counter collection.

Throws:

IOException - if IService.getServiceUUID() throws this exception (it never should since it is a local method call).

startQueueStatisticsCollection

protected void startQueueStatisticsCollection()

Setup sampling on the client's thread pool. This collects interesting statistics about the thread pool for reporting to the load balancer service.

startPlatformStatisticsCollection

protected void startPlatformStatisticsCollection()

Start collecting performance counters from the OS (if enabled).

startGangliaService

protected void startGangliaService(AbstractStatisticsCollector statisticsCollector)

Start embedded Ganglia peer. It will develop a snapshot of the cluster metrics in memory and will self-report metrics from the performance counter hierarchy to the ganglia network.

Parameters:

statisticsCollector - Performance counters will be harvested from here.

See Also:

(Ganglia Integration).

startReportTask

protected void startReportTask()

Start task to report service and counters to the load balancer.

startHttpdService

protected void startHttpdService()
                          throws UnsupportedEncodingException

Start the local httpd service (if enabled). The service is started on the AbstractFederation.getHttpdPort(), on a randomly assigned port if the port is 0, or NOT started if the port is -1. If the service is started, then the URL for the service is reported to the load balancer and also written into the file system. When started, the httpd service will be shutdown with the federation.

Throws:

UnsupportedEncodingException