alma.acs.monitoring.blobber

Class BlobberWorker

java.lang.Object

alma.acs.concurrent.ThreadLoopRunner.CancelableRunnable

alma.acs.monitoring.blobber.BlobberWorker

All Implemented Interfaces:

java.lang.Runnable

public class BlobberWorker
extends ThreadLoopRunner.CancelableRunnable

The part of the blobber component that does the real work. It implements Runnable to allow running it repeatedly in a separate thread.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BLOBBER_CHECK_JVM_MEMORY_PROPERTYNAME
protected long	collectIntervalSec The interval between blobber cycles, each harvesting all collectors.
protected ContainerServices	myContainerServices
protected java.util.logging.Logger	myLogger
protected java.util.List<MonitorDAO>	myMonitorDAOList DAOs store the data in the DB or on file, inside proper transaction(s) and performing auto-completion of hardware tables if necessary.

Fields inherited from class alma.acs.concurrent.ThreadLoopRunner.CancelableRunnable

shouldTerminate

Constructor Summary

Constructors

Constructor and Description
BlobberWorker(ContainerServices inContainerServices, BlobberPlugin blobberPlugin)

Method Summary

Modifier and Type	Method and Description
CollectorListStatus	addCollector(java.lang.String inCollectorComponentId) Adds the collector component of the given name to the blobber.
protected boolean	canHandle()
CollectorListStatus	containsCollector(java.lang.String inCollectorComponentId) Checks if the collector list contains the stated collector.
protected int	getMaxCollectorCount()
protected MonitorCollectorOperations	getMonitorCollector(java.lang.String inCollectorName) Gets the reference of the MonitorCollector component that is identified by its name inCollectorName which could for example be "CONTROL/CM01/MONITOR_COLLECTOR".
protected void	initWorker()
CollectorListStatus	removeCollector(java.lang.String inCollectorComponentId) Removes the stated collector from the blobber.
void	run() This method will be called at fixed intervals.
protected void	setMaxCollectorCount(int inCount)
protected void	storeData(BlobData inBlobData) Stores the data using the MonitorPointExpertImpl layer.

Methods inherited from class alma.acs.concurrent.ThreadLoopRunner.CancelableRunnable

cancel

Methods inherited from class java.lang.Object

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

Field Detail

BLOBBER_CHECK_JVM_MEMORY_PROPERTYNAME

public static final java.lang.String BLOBBER_CHECK_JVM_MEMORY_PROPERTYNAME

See Also:

Constant Field Values

myMonitorDAOList

protected java.util.List<MonitorDAO> myMonitorDAOList

DAOs store the data in the DB or on file, inside proper transaction(s) and performing auto-completion of hardware tables if necessary.

myContainerServices

protected ContainerServices myContainerServices

myLogger

protected java.util.logging.Logger myLogger

collectIntervalSec

protected long collectIntervalSec

The interval between blobber cycles, each harvesting all collectors. This is used only for logging, since the cycle gets triggered from outside of this class.

Constructor Detail

BlobberWorker

public BlobberWorker(ContainerServices inContainerServices,
                     BlobberPlugin blobberPlugin)
              throws AcsJCouldntCreateObjectEx

Parameters:

inContainerServices - used for logging and to get references to the collector components.

blobberPlugin -

Throws:

AcsJCouldntCreateObjectEx - If blobberPlugin#createMonitorDAO fails.

Method Detail

initWorker

protected void initWorker()

getMaxCollectorCount

protected int getMaxCollectorCount()

Returns:

The maximum number of collectors that this blobber is allowed to have.

setMaxCollectorCount

protected void setMaxCollectorCount(int inCount)

addCollector

public CollectorListStatus addCollector(java.lang.String inCollectorComponentId)

Adds the collector component of the given name to the blobber. If the collector is already known to the blobber it will not be added again.

HSO TODO: what is meant by the following description? I don't see any of this in the code.
This method will however NOT wait for this, it returns immediately with one exception. When the second collector is added it is first ensured that one access has completed to the firstly added collector in order to wait for the access statistics needed to calculate the capacity of the blobber.

Parameters:

inCollectorComponentId - a String stating the name of the collector to add.

Returns:

a CollectorListStatus stating the result. Values to expect are CollectorListStatus#ADDED, CollectorListStatus#KNOWN or CollectorListStatus#FULL.

canHandle

protected boolean canHandle()

removeCollector

public CollectorListStatus removeCollector(java.lang.String inCollectorComponentId)

Removes the stated collector from the blobber. If the worker is currently working with the specified collector it will finish the operation. This method will however NOT wait for the operation, it returns immediately.

Parameters:

inCollectorComponentId - a String stating the name of the collector to remove.

Returns:

a CollectorListStatus stating the result. Values to expect are CollectorListStatus#UNKNOWN or CollectorListStatus#REMOVED.

containsCollector

public CollectorListStatus containsCollector(java.lang.String inCollectorComponentId)

Checks if the collector list contains the stated collector.

Parameters:

inCollectorComponentId - a String stating the name of the collector to look for.

Returns:

a CollectorListStatus stating the result. Values to expect are CollectorListStatus#KNOWN or CollectorListStatus#UNKNOWN.

getMonitorCollector

protected MonitorCollectorOperations getMonitorCollector(java.lang.String inCollectorName)
                                                  throws AcsJContainerServicesEx

Gets the reference of the MonitorCollector component that is identified by its name inCollectorName which could for example be "CONTROL/CM01/MONITOR_COLLECTOR".

Collector references are cached in collectorName2ComponentReference across blobber cycles.

Throws:

AcsJContainerServicesEx

run

public void run()

This method will be called at fixed intervals. It gathers the data from all registered collectors and stores it in the database, using the layer from module TMCBD/DAO.

See Also:

Runnable.run()

storeData

protected void storeData(BlobData inBlobData)
                  throws java.lang.Exception

Stores the data using the MonitorPointExpertImpl layer.

Throws:

java.lang.Exception