org.epics.pvmanager

Class PVWriterDirector<T>

java.lang.Object

org.epics.pvmanager.PVWriterDirector<T>

Type Parameters:

T - value type for the writer managed by this director

public class PVWriterDirector<T>
extends Object

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

This class is responsible for the correct writer 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 connection status or errors
• Managing the write process, both synchronous and asynchronous
• 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	close()
void	connectExpression(WriteExpression<?> expression) Connects the given expression.
void	connectStatic(Exception ex, boolean connection, String channelName) Simulate a static connection in which the channel name has one exception and the connection will never change.
void	disconnectExpression(WriteExpression<?> expression) Disconnects the given expression.

Methods inherited from class java.lang.Object

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

Method Detail

connectStatic

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

Simulate a static connection in which the channel name 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

connectExpression

public void connectExpression(WriteExpression<?> 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

disconnectExpression

public void disconnectExpression(WriteExpression<?> expression)

Disconnects the given expression.

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

Parameters:

expression - the expression to disconnect

close

public void close()