alma.acs.monitoring.blobber

Class BlobberImpl

java.lang.Object

alma.acs.component.ComponentImplBase

alma.acs.monitoring.blobber.BlobberImpl

All Implemented Interfaces:

ComponentLifecycle

public class BlobberImpl
extends ComponentImplBase

Implementation of the blobber component.

Author:

apersson, hsommer

Field Summary

Fields

Modifier and Type	Field and Description
protected AlarmSource	alarmSource
protected ThreadLoopRunner	blobberLoopRunner We use this convenience class from ACS to execute the blobber code at fixed intervals.
protected BlobberPlugin	blobberPlugin
protected int	collectorIntervalSec Default interval between collecting data.
protected long	componentActivationStartNanos Similar to componentActivationTimesNanosMap, but used to compute the total component activation.
protected java.util.Map<java.lang.String,java.lang.Long>	componentActivationTimesNanosMap There have been problems with slow blobber activation (http://ictjira.alma.cl/browse/ICT-462).
protected BlobberWorker	myWorker The code that gets run at fixed time intervals.

Fields inherited from class alma.acs.component.ComponentImplBase

m_containerServices, m_instanceName, m_logger

Constructor Summary

Constructors

Constructor and Description
BlobberImpl()

Method Summary

Modifier and Type	Method and Description
CollectorListStatus	addCollector(java.lang.String inComponentName)
void	cleanUp() Stops the blobber loop, but does not forcibly stop the running blobber.
CollectorListStatus	containsCollector(java.lang.String inComponentName)
protected BlobberPlugin	createBlobberPlugin() Creates (using reflection) an instance of alma.acs.monitoring.blobber.BlobberPluginAlmaImpl that ARCHIVE/TMCDB/ modules must provide.
protected BlobberWorker	createWorker() Factored out from initialize(ContainerServices) for testing with mock BlobberWorker
void	execute() Repeatedly runs the blobber worker code in a separate thread (every 60 seconds).
void	initialize(ContainerServices inContainerServices) Initializes the component: creates the BlobberPlugin and the BlobberWorker objects.
protected void	logComponentActivationTimes() Creates an INFO log from the times collected in componentActivationTimesNanosMap and then nulls that map.
CollectorListStatus	removeCollector(java.lang.String inComponentName)

Methods inherited from class alma.acs.component.ComponentImplBase

aboutToAbort, componentState, name

Methods inherited from class java.lang.Object

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

Field Detail

myWorker

protected BlobberWorker myWorker

The code that gets run at fixed time intervals.

collectorIntervalSec

protected int collectorIntervalSec

Default interval between collecting data.

See Also:

BlobberPlugin.getCollectorIntervalSec()

blobberLoopRunner

protected ThreadLoopRunner blobberLoopRunner

We use this convenience class from ACS to execute the blobber code at fixed intervals.

blobberPlugin

protected BlobberPlugin blobberPlugin

alarmSource

protected AlarmSource alarmSource

componentActivationTimesNanosMap

protected java.util.Map<java.lang.String,java.lang.Long> componentActivationTimesNanosMap

There have been problems with slow blobber activation (http://ictjira.alma.cl/browse/ICT-462). Note that also non-ACS code gets run (plugin, DAOs, JMX setup and possibly invocations). During startup we feed this map with "activity" - "time elapsed in ns" pairs and log a single profiling message in the end of execute().

See Also:

logComponentActivationTimes()

componentActivationStartNanos

protected long componentActivationStartNanos

Similar to componentActivationTimesNanosMap, but used to compute the total component activation.

Constructor Detail

BlobberImpl

public BlobberImpl()

Method Detail

initialize

public void initialize(ContainerServices inContainerServices)
                throws ComponentLifecycleException

Initializes the component: creates the BlobberPlugin and the BlobberWorker objects.

Raises an alarm (FF="Monitoring", FM="MonitorArchiver", FC="2") if initialization fails. This makes sense because the blobber runs as an autostart component, and the manager being the client that activates this blobber would not know the alarm details.

Specified by:

initialize in interface ComponentLifecycle

Overrides:

initialize in class ComponentImplBase

Parameters:

inContainerServices - callback object for services provided by the container

Throws:

ComponentLifecycleException

See Also:

ComponentImplBase.initialize(alma.acs.container.ContainerServices)

createBlobberPlugin

protected BlobberPlugin createBlobberPlugin()
                                     throws AcsJCouldntCreateObjectEx

Creates (using reflection) an instance of alma.acs.monitoring.blobber.BlobberPluginAlmaImpl that ARCHIVE/TMCDB/ modules must provide.

Overriding this method allows other projects or unit tests that should run without alma archive code to create a different implementation of BlobberPlugin.

Throws:

AcsJCouldntCreateObjectEx

createWorker

protected BlobberWorker createWorker()
                              throws AcsJCouldntCreateObjectEx

Factored out from initialize(ContainerServices) for testing with mock BlobberWorker

Throws:

AcsJCouldntCreateObjectEx

execute

public void execute()

Repeatedly runs the blobber worker code in a separate thread (every 60 seconds). If any execution of the blobber worker takes longer than 60 s, then subsequent executions may start late, but will not concurrently execute.

Specified by:

execute in interface ComponentLifecycle

Overrides:

execute in class ComponentImplBase

See Also:

ComponentImplBase.execute()

logComponentActivationTimes

protected void logComponentActivationTimes()

Creates an INFO log from the times collected in componentActivationTimesNanosMap and then nulls that map.

cleanUp

public void cleanUp()

Stops the blobber loop, but does not forcibly stop the running blobber. However this method returns after 30 seconds, even if the blobber has not yet finished by then.

Specified by:

cleanUp in interface ComponentLifecycle

Overrides:

cleanUp in class ComponentImplBase

See Also:

ComponentImplBase.cleanUp()

addCollector

public CollectorListStatus addCollector(java.lang.String inComponentName)

containsCollector

public CollectorListStatus containsCollector(java.lang.String inComponentName)

removeCollector

public CollectorListStatus removeCollector(java.lang.String inComponentName)