org.diirt.datasource.timecache.impl

Class SimpleMemoryStorage

java.lang.Object

org.diirt.datasource.timecache.impl.SimpleMemoryStorage

All Implemented Interfaces:

DataSource, DataStorage

public class SimpleMemoryStorage
extends Object
implements DataStorage

DataStorage first implementation which handles only memory.

Author:

Fred Arnaud (Sopra Group) - ITER

Constructor Summary

Constructors

Constructor and Description
SimpleMemoryStorage()
SimpleMemoryStorage(int chunkSize)

Method Summary

Modifier and Type	Method and Description
void	addListener(DataStorageListener listener) Adds a DataStorageListener to be notified when data is lost.
void	clearAll()
SortedSet<Data>	getAvailableData(TimeInterval interval) Returns all available Data within the requested TimeInterval.
DataChunk	getData(String channelName, Timestamp from) Read samples from source ordered by Timestamp and starting with the specified one.
int	getStoredSampleCount()
boolean	hasAvailableData(TimeInterval interval) Returns true if some data is available within the requested interval, false otherwise.
void	removeListener(DataStorageListener listener) Removes a DataStorageListener.
SortedSet<Data>	storeData(DataChunk chunk) Stores all Data of the specified DataChunk and returns the corresponding set of Data ordered by Timestamp.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleMemoryStorage

public SimpleMemoryStorage()

SimpleMemoryStorage

public SimpleMemoryStorage(int chunkSize)

Method Detail

getData

public DataChunk getData(String channelName,
                         Timestamp from)

Read samples from source ordered by Timestamp and starting with the specified one. Polled by DataRequestThread.

Specified by:

getData in interface DataSource

Parameters:

channelName - channel to read.

from - lowest Timestamp of the first returned sample.

Returns:

DataChunk a chunk of ordered samples with all Timestamp superior to the specified argument.

getAvailableData

public SortedSet<Data> getAvailableData(TimeInterval interval)

Returns all available Data within the requested TimeInterval.

Specified by:

getAvailableData in interface DataStorage

hasAvailableData

public boolean hasAvailableData(TimeInterval interval)

Returns true if some data is available within the requested interval, false otherwise.

Specified by:

hasAvailableData in interface DataStorage

storeData

public SortedSet<Data> storeData(DataChunk chunk)

Stores all Data of the specified DataChunk and returns the corresponding set of Data ordered by Timestamp.

Specified by:

storeData in interface DataStorage

Parameters:

chunk - to store.

Returns:

set of Data ordered by Timestamp.

addListener

public void addListener(DataStorageListener listener)

Adds a DataStorageListener to be notified when data is lost.

Specified by:

addListener in interface DataStorage

Parameters:

listener - to be added.

removeListener

public void removeListener(DataStorageListener listener)

Removes a DataStorageListener.

Specified by:

removeListener in interface DataStorage

Parameters:

listener - to be removed

getStoredSampleCount

public int getStoredSampleCount()

clearAll

public void clearAll()

Specified by:

clearAll in interface DataStorage