org.epics.pvmanager

Class PVDirector<T>

java.lang.Object

org.epics.pvmanager.PVDirector<T>

Type Parameters:

T - value type for the reader managed by this director

public class PVDirector<T>
extends Object

Orchestrates the different elements of pvmanager to make a reader functional.

This class is responsible for the correct read operation, including:

• Setting up the collector for notifications
• Setting up the collector for connection notification
• Building connection recipes and forwarding them to the datasource
• Managing the scanning task and notification for new values, connection status or errors
• Disconnecting the expressions from the datasources if the reader is closed or if it's garbage collected

Author:

carcassi

Method Summary

Methods

Modifier and Type	Method and Description
void	connectReadExpression(DesiredRateExpression<?> expression) Connects the given expression.
void	connectStaticRead(Exception ex, boolean connection, String channelName) Simulate a static connection in which the channel has one exception and the connection will never change.
void	disconnectReadExpression(DesiredRateExpression<?> expression) Disconnects the given expression.
void	registerCollector(Collector<?,?> collector)

Methods inherited from class java.lang.Object

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

Method Detail

registerCollector

public void registerCollector(Collector<?,?> collector)

connectReadExpression

public void connectReadExpression(DesiredRateExpression<?> expression)

Connects the given expression.

This can be used for dynamic expression to add and connect child expressions. The added expression will be automatically closed when the associated reader is closed, if it's not disconnected first.

Parameters:

expression - the expression to connect

connectStaticRead

public void connectStaticRead(Exception ex,
                     boolean connection,
                     String channelName)

Simulate a static connection in which the channel has one exception and the connection will never change.

This is a temporary method an will be subject to change in the future. The aim is to allow to connect expressions that are not channels but can influence exception and connection state. For example, to report problems encountered during expression creation as runtime problems through the normal exception/connection methods.

In the future, this should be generalized to allow fully fledged expressions that connect/disconnect and can report errors.

Parameters:

ex - the exception to queue

connection - the connection flag

channelName - the channel name

disconnectReadExpression

public void disconnectReadExpression(DesiredRateExpression<?> expression)

Disconnects the given expression.

This can be used for dynamic expression, to remove and disconnects child expressions.

Parameters:

expression - the expression to disconnect