alma.acs.monitoring.controller

Class ControllerImpl

java.lang.Object

alma.acs.component.ComponentImplBase

alma.acs.monitoring.controller.ControllerImpl

All Implemented Interfaces:

ComponentLifecycle

public class ControllerImpl
extends ComponentImplBase

The monitor collector components contact the controller, to get assigned to a blobber.

Field Summary

Fields

Modifier and Type	Field and Description
protected alma.acs.monitoring.controller.BlobberList	blobberList List of known blobbers, either just the component names or also the references.
protected java.util.Map<java.lang.String,java.lang.String>	collector2BlobberName Maps names of MonitorCollector components to the corresponding Blobber components.

Fields inherited from class alma.acs.component.ComponentImplBase

m_containerServices, m_instanceName, m_logger

Constructor Summary

Constructors

Constructor and Description
ControllerImpl()

Method Summary

Modifier and Type	Method and Description
void	cleanUp() Called after the last functional call to the component has finished.
void	deregisterCollector(java.lang.String collectorCompName)
protected java.lang.String	findBlobberAssignedToCollector(java.lang.String collectorCompName, boolean trustLocalCache)
protected void	getBlobberRef(alma.acs.monitoring.controller.BlobberList.BlobberInfo blobberInfo, boolean skipKnownProblematicBlobber) Retrieves the blobber component reference for the given blobber name, unless we have it already.
protected BlobberOperations	getBlobberRefFromContainerServices(java.lang.String blobberName) Broken out from #getBlobberRef(BlobberInfo, boolean), to allow mock impl in tests.
protected java.lang.String[]	getConfiguredBlobberCompNames() Broken out from initialize(ContainerServices) to allow mock impl.
void	initialize(ContainerServices inContainerServices) Subclass must call super.initialize(containerServices) unless it overrides as well all other methods which access the member vars of this class.
void	registerCollector(java.lang.String collectorCompName) Note that a collector may call this method before all blobber containers have started.
void	registerKnownCollectors(java.lang.String blobberCompName)

Methods inherited from class alma.acs.component.ComponentImplBase

aboutToAbort, componentState, execute, name

Methods inherited from class java.lang.Object

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

Field Detail

blobberList

protected final alma.acs.monitoring.controller.BlobberList blobberList

List of known blobbers, either just the component names or also the references.

collector2BlobberName

protected final java.util.Map<java.lang.String,java.lang.String> collector2BlobberName

Maps names of MonitorCollector components to the corresponding Blobber components. The blobber name is expected to be contained in #myBlobberList.

Constructor Detail

ControllerImpl

public ControllerImpl()

Method Detail

initialize

public void initialize(ContainerServices inContainerServices)
                throws ComponentLifecycleException

Description copied from class: ComponentImplBase

Subclass must call super.initialize(containerServices) unless it overrides as well all other methods which access the member vars of this class.

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:

ComponentLifecycle.initialize(ContainerServices)

getConfiguredBlobberCompNames

protected java.lang.String[] getConfiguredBlobberCompNames()
                                                    throws AcsJContainerServicesEx

Broken out from initialize(ContainerServices) to allow mock impl.

Throws:

AcsJContainerServicesEx

cleanUp

public void cleanUp()

Description copied from interface: ComponentLifecycle

Called after the last functional call to the component has finished. The component should then orderly release resources etc.

Specified by:

cleanUp in interface ComponentLifecycle

Overrides:

cleanUp in class ComponentImplBase

registerCollector

public void registerCollector(java.lang.String collectorCompName)
                       throws CollectorRegistrationFailedEx

Note that a collector may call this method before all blobber containers have started. Thus we may get blobber activation failures in the beginning that later go away.

Throws:

CollectorRegistrationFailedEx - If the collector cannot be registered with any of the available blobbers. Here we only log this problem; the calling collector is expected to raise an alarm.

See Also:

alma.MonitorArchiver.ControllerOperations#registerCollector(java.lang.String)

deregisterCollector

public void deregisterCollector(java.lang.String collectorCompName)

registerKnownCollectors

public void registerKnownCollectors(java.lang.String blobberCompName)

See Also:

alma.MonitorArchiver.ControllerOperations#registerKnownCollectors(java.lang.String)

getBlobberRef

protected void getBlobberRef(alma.acs.monitoring.controller.BlobberList.BlobberInfo blobberInfo,
                             boolean skipKnownProblematicBlobber)

Retrieves the blobber component reference for the given blobber name, unless we have it already. In case of success, the blobber reference is stored in the given blobberInfo object, otherwise the reference field stays null.

Parameters:

blobberInfo -

skipKnownProblematicBlobber - If true then we skip the blobber reference retrieval if the last failure occurred less than 30 s ago.

getBlobberRefFromContainerServices

protected BlobberOperations getBlobberRefFromContainerServices(java.lang.String blobberName)
                                                        throws AcsJContainerServicesEx

Broken out from #getBlobberRef(BlobberInfo, boolean), to allow mock impl in tests.

Throws:

AcsJContainerServicesEx

findBlobberAssignedToCollector

protected java.lang.String findBlobberAssignedToCollector(java.lang.String collectorCompName,
                                                          boolean trustLocalCache)

Parameters:

collectorCompName -

trustLocalCache -

Returns:

Name of blobber that is assigned to the give collector, or null if no blobber was found.