org.diirt.datasource.timecache

Class PVCacheImpl

java.lang.Object

org.diirt.datasource.timecache.PVCacheImpl

All Implemented Interfaces:

PVCache, DataStorageListener

public class PVCacheImpl
extends Object
implements PVCache, DataStorageListener

PVCache first implementation. Handles the communication between a list of sources, a storage and registered queries threw PVCacheListener. Manages a list of requested intervals which are intersected with new requested TimeInterval. Manages a list a completed intervals which is the result of the concatenation of the lists of completed intervals per sources. When data is lost from storage, the IntervalsList generated from the TimestampsSet is subtracted to all requested/completed intervals lists.

Author:

Fred Arnaud (Sopra Group) - ITER

Constructor Summary

Constructors

Constructor and Description
PVCacheImpl(String channelName, Collection<DataSource> dataSources, DataStorage storage)

Method Summary

Modifier and Type	Method and Description
void	addListener(PVCacheListener listener) Add a PVCacheListener to be notified when new samples are available.
void	dataLoss(TimestampsSet lostSet) Informs that the specified set of Timestamp have been removed from storage.
void	flush()
String	getChannelName()
IntervalsList	getCompletedIntervalsList() Get the completed intervals list.
PVCacheStatistics	getStatistics()
DataStorage	getStorage()
boolean	isProcessingSources()
boolean	isStatisticsEnabled()
void	removeListener(PVCacheListener listener) Remove a PVCacheListener.
DataRequestThread	retrieveDataAsync(TimeInterval newIntervalToRetrieve) Asynchronously retrieves samples from sources for the requested TimeInterval and asynchronously requests DataStorage for immediately available samples.
SortedSet<Data>	retrieveDataSync(TimeInterval interval) Synchronously requests DataStorage for immediately available samples.
void	setRetrievalGap(TimeDuration retrievalGap)
void	setStatisticsEnabled(boolean enabled)
void	startLiveDataProcessing() Start processing live data samples.
void	stopLiveDataProcessing() Stop processing live data samples.

Methods inherited from class java.lang.Object

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

Constructor Detail

PVCacheImpl

public PVCacheImpl(String channelName,
                   Collection<DataSource> dataSources,
                   DataStorage storage)

Method Detail

startLiveDataProcessing

public void startLiveDataProcessing()

Start processing live data samples. NOT IMPLEMENTED IN FIRST VERSION.

Specified by:

startLiveDataProcessing in interface PVCache

stopLiveDataProcessing

public void stopLiveDataProcessing()

Stop processing live data samples. NOT IMPLEMENTED IN FIRST VERSION.

Specified by:

stopLiveDataProcessing in interface PVCache

addListener

public void addListener(PVCacheListener listener)

Add a PVCacheListener to be notified when new samples are available.

Specified by:

addListener in interface PVCache

Parameters:

listener - to be added

removeListener

public void removeListener(PVCacheListener listener)

Remove a PVCacheListener.

Specified by:

removeListener in interface PVCache

Parameters:

listener - to be removed

retrieveDataAsync

public DataRequestThread retrieveDataAsync(TimeInterval newIntervalToRetrieve)

Asynchronously retrieves samples from sources for the requested TimeInterval and asynchronously requests DataStorage for immediately available samples.

Specified by:

retrieveDataAsync in interface PVCache

Parameters:

newIntervalToRetrieve - TimeInterval to be retrieved.

retrieveDataSync

public SortedSet<Data> retrieveDataSync(TimeInterval interval)

Synchronously requests DataStorage for immediately available samples.

Specified by:

retrieveDataSync in interface PVCache

Parameters:

interval - TimeInterval to be retrieved.

dataLoss

public void dataLoss(TimestampsSet lostSet)

Informs that the specified set of Timestamp have been removed from storage.

Specified by:

dataLoss in interface DataStorageListener

Parameters:

lostSet - TimestampsSet of lost Timestamp.

getCompletedIntervalsList

public IntervalsList getCompletedIntervalsList()

Get the completed intervals list. An TimeInterval is completed when all DataSource have finished responding.

Specified by:

getCompletedIntervalsList in interface PVCache

Returns:

IntervalsList the list of completed intervals.

setStatisticsEnabled

public void setStatisticsEnabled(boolean enabled)

Specified by:

setStatisticsEnabled in interface PVCache

isStatisticsEnabled

public boolean isStatisticsEnabled()

Specified by:

isStatisticsEnabled in interface PVCache

getStatistics

public PVCacheStatistics getStatistics()

Specified by:

getStatistics in interface PVCache

isProcessingSources

public boolean isProcessingSources()

Specified by:

isProcessingSources in interface PVCache

getChannelName

public String getChannelName()

Specified by:

getChannelName in interface PVCache

flush

public void flush()

Specified by:

flush in interface PVCache

setRetrievalGap

public void setRetrievalGap(TimeDuration retrievalGap)

getStorage

public DataStorage getStorage()