org.yamcs.algorithms

Class AlgorithmManager

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.algorithms.AlgorithmManager

All Implemented Interfaces:

com.google.common.util.concurrent.Service, DVParameterConsumer, ParameterProvider

public class AlgorithmManager
extends com.google.common.util.concurrent.AbstractService
implements ParameterProvider, DVParameterConsumer

Manages the provision of requested parameters that require the execution of one or more XTCE algorithms.

Upon initialization it will scan all algorithms, and schedule any that are to be triggered periodically. OutputParameters of all algorithms will be indexed, so that AlgorithmManager knows what parameters it can provide to the ParameterRequestManager.

Algorithms and any needed algorithms that require earlier execution, will be activated as soon as a request for one of its output parameters is registered.

Algorithms default to JavaScript, but this can be overridden to other scripting languages as long as they are included in the classpath. As a design choice all algorithms within the same AlgorithmManager, share the same language.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
AlgorithmManager(String yamcsInstance)
AlgorithmManager(String yamcsInstance, Map<String,Object> config)
AlgorithmManager(String yamcsInstance, Map<String,Object> config, Yamcs.ReplayRequest rr)
AlgorithmManager(String yamcsInstance, Yamcs.ReplayRequest rr)

Method Summary

Modifier and Type	Method and Description
void	activateAlgorithm(Algorithm algorithm, AlgorithmExecutionContext execCtx, AlgorithmExecListener listener) Activate an algorithm in a context if not already active.
boolean	canProvide(Parameter p)
boolean	canProvide(Yamcs.NamedObjectId itemId) Returns whether or not a given parameter can be provided by this provider
AlgorithmExecutionContext	createContext(String name) Create a new algorithm execution context.
void	deactivateAlgorithm(Algorithm algorithm, AlgorithmExecutionContext execCtx)
protected void	doStart()
protected void	doStop()
Parameter	getParameter(Yamcs.NamedObjectId paraId) Returns the parameterDefinition corresponding to the parameter id
int	getSubscriptionId()
void	init(YProcessor yproc) Called before the startup to pass on the processor and initialize whatever needed
void	setParameterListener(ParameterRequestManager parameterRequestManager) Send parameters to this listener.
void	startProviding(Parameter paramDef) Adds a new parameter to the list of parameters that have to provided
void	startProvidingAll() start providing all known parameters
void	stopProviding(Parameter paramDef) Removes a parameter from the list of parameters that have to be provided
ArrayList<ParameterValue>	updateParameters(int subscriptionId, ArrayList<ParameterValue> items)
ArrayList<ParameterValue>	updateParameters(List<ParameterValue> items, AlgorithmExecutionContext ctx) Update parameters in context and run the affected algorithms

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Constructor Detail

AlgorithmManager

public AlgorithmManager(String yamcsInstance)
                 throws ConfigurationException

Throws:

ConfigurationException

AlgorithmManager

public AlgorithmManager(String yamcsInstance,
                        Map<String,Object> config)
                 throws ConfigurationException

Throws:

ConfigurationException

AlgorithmManager

public AlgorithmManager(String yamcsInstance,
                        Yamcs.ReplayRequest rr)
                 throws ConfigurationException

Throws:

ConfigurationException

AlgorithmManager

public AlgorithmManager(String yamcsInstance,
                        Map<String,Object> config,
                        Yamcs.ReplayRequest rr)
                 throws ConfigurationException

Throws:

ConfigurationException

Method Detail

init

public void init(YProcessor yproc)

Description copied from interface: ParameterProvider

Called before the startup to pass on the processor and initialize whatever needed

Specified by:

init in interface ParameterProvider

getSubscriptionId

public int getSubscriptionId()

startProviding

public void startProviding(Parameter paramDef)

Description copied from interface: ParameterProvider

Adds a new parameter to the list of parameters that have to provided

Specified by:

startProviding in interface ParameterProvider

createContext

public AlgorithmExecutionContext createContext(String name)

Create a new algorithm execution context.

Parameters:

name - - name of the context

Returns:

the newly created context

activateAlgorithm

public void activateAlgorithm(Algorithm algorithm,
                              AlgorithmExecutionContext execCtx,
                              AlgorithmExecListener listener)

Activate an algorithm in a context if not already active. If already active, the listener is added to the listener list.

Parameters:

algorithm -

execCtx -

listener -

deactivateAlgorithm

public void deactivateAlgorithm(Algorithm algorithm,
                                AlgorithmExecutionContext execCtx)

startProvidingAll

public void startProvidingAll()

Description copied from interface: ParameterProvider

start providing all known parameters

Specified by:

startProvidingAll in interface ParameterProvider

stopProviding

public void stopProviding(Parameter paramDef)

Description copied from interface: ParameterProvider

Removes a parameter from the list of parameters that have to be provided

Specified by:

stopProviding in interface ParameterProvider

canProvide

public boolean canProvide(Parameter p)

Specified by:

canProvide in interface ParameterProvider

canProvide

public boolean canProvide(Yamcs.NamedObjectId itemId)

Description copied from interface: ParameterProvider

Returns whether or not a given parameter can be provided by this provider

Specified by:

canProvide in interface ParameterProvider

Returns:

getParameter

public Parameter getParameter(Yamcs.NamedObjectId paraId)
                       throws InvalidIdentification

Description copied from interface: ParameterProvider

Returns the parameterDefinition corresponding to the parameter id

Specified by:

getParameter in interface ParameterProvider

Parameters:

paraId - - id of the parameter that is returned

Returns:

Throws:

InvalidIdentification

updateParameters

public ArrayList<ParameterValue> updateParameters(int subscriptionId,
                                                  ArrayList<ParameterValue> items)

Specified by:

updateParameters in interface DVParameterConsumer

updateParameters

public ArrayList<ParameterValue> updateParameters(List<ParameterValue> items,
                                                  AlgorithmExecutionContext ctx)

Update parameters in context and run the affected algorithms

Parameters:

items -

ctx -

Returns:

the parameters resulting from running the algorithms

setParameterListener

public void setParameterListener(ParameterRequestManager parameterRequestManager)

Description copied from interface: ParameterProvider

Send parameters to this listener. Normally is the channel.parameterRequestManager but something different may be used for unit tests or special applications (PacketViewer)

Specified by:

setParameterListener in interface ParameterProvider

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService