public class ConsoleFileStorageImpl extends java.lang.Object implements StorageAdmin, org.objectweb.fractal.api.control.BindingController, StorageRead
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.String,StorageProxyAdmin> |
distributedStorage |
protected StorageRead |
readerImpl |
protected java.io.BufferedWriter |
test |
protected java.lang.String |
testDirname |
protected java.io.Serializable |
testId |
STORAGE_ADMIN
STORAGE_READ
Constructor and Description |
---|
ConsoleFileStorageImpl() |
Modifier and Type | Method and Description |
---|---|
void |
bindFc(java.lang.String clientItfName,
java.lang.Object serverItf) |
void |
closeEventIterator(java.io.Serializable iteratorKey)
Discards the iterator associated to the given key, possibly releasing resources.
|
void |
collect(java.io.Serializable selBladesId,
CollectListener listener)
Collects the latest test data
|
long |
countEvents(java.lang.String testName,
java.lang.String bladeId,
java.lang.String eventTypeLabel,
EventFilter filter)
Counts the number of available events matching a given filter.
|
java.util.Properties |
getBladeProperties(java.lang.String testName,
java.lang.String bladeId)
Gets the java system properties for the given blade from the given test run
|
java.lang.String[] |
getEventFieldLabels(java.lang.String testName,
java.lang.String bladeId,
java.lang.String eventTypeLabel)
Gets the labels of fields hold by a given event type.
|
java.io.Serializable |
getEventIterator(java.lang.String testName,
java.lang.String bladeId,
java.lang.String eventTypeLabel,
EventFilter filter)
Creates an event iterator.
|
BladeEvent[] |
getEvents(java.lang.String testName,
java.lang.String bladeId,
java.lang.String eventTypeLabel,
EventFilter filter,
long fromIndex,
int count)
Retrieves a given number of events matching a given filter, from a given index.
|
BladeEvent[] |
getNextEvents(java.io.Serializable iteratorKey,
int count)
Gets next events from the given event iterator.
|
BladeDescriptor[] |
getTestPlan(java.lang.String testName,
BladeFilter filter)
Gets the test plan definition for a given test run name.
|
TestDescriptor[] |
getTests(TestFilter filter)
Gets a list of test runs matching a given filter.
|
java.lang.String[] |
listFc() |
java.lang.Object |
lookupFc(java.lang.String clientItfName) |
void |
newTest(java.io.Serializable testId,
java.util.Map<java.lang.String,ClifDeployDefinition> testPlan)
Inform the storage system the beginning of a new test
|
void |
terminate()
Terminate the storage system
|
void |
unbindFc(java.lang.String clientItfName) |
protected java.util.Map<java.lang.String,StorageProxyAdmin> distributedStorage
protected java.io.BufferedWriter test
protected java.lang.String testDirname
protected java.io.Serializable testId
protected StorageRead readerImpl
public java.lang.Object lookupFc(java.lang.String clientItfName)
lookupFc
in interface org.objectweb.fractal.api.control.BindingController
public void bindFc(java.lang.String clientItfName, java.lang.Object serverItf)
bindFc
in interface org.objectweb.fractal.api.control.BindingController
public void unbindFc(java.lang.String clientItfName)
unbindFc
in interface org.objectweb.fractal.api.control.BindingController
public java.lang.String[] listFc()
listFc
in interface org.objectweb.fractal.api.control.BindingController
public void newTest(java.io.Serializable testId, java.util.Map<java.lang.String,ClifDeployDefinition> testPlan) throws ClifException
newTest
in interface StorageAdmin
testPlan
- Map of scenario deployment definitions, indexed by a unique identifiertestId
- test identifier objectClifException
DeployDefinition
public void collect(java.io.Serializable selBladesId, CollectListener listener)
StorageAdmin
collect
in interface StorageAdmin
public void terminate()
terminate
in interface StorageAdmin
public TestDescriptor[] getTests(TestFilter filter) throws ClifException
StorageRead
getTests
in interface StorageRead
filter
- only tests matching this filter will be retainedClifException
public BladeDescriptor[] getTestPlan(java.lang.String testName, BladeFilter filter) throws ClifException
StorageRead
getTestPlan
in interface StorageRead
testName
- the test run namefilter
- retains only blades (injectors, probes) accepted by this filter. If null,
all blades are retained.ClifException
public java.util.Properties getBladeProperties(java.lang.String testName, java.lang.String bladeId) throws ClifException
StorageRead
getBladeProperties
in interface StorageRead
testName
- the test run namebladeId
- the blade identifierClifException
TestDescriptor.getName()
,
BladeDescriptor.getId()
public java.lang.String[] getEventFieldLabels(java.lang.String testName, java.lang.String bladeId, java.lang.String eventTypeLabel)
StorageRead
getEventFieldLabels
in interface StorageRead
testName
- the test run namebladeId
- the blade identifier from the given test runeventTypeLabel
- the label of the event typepublic java.io.Serializable getEventIterator(java.lang.String testName, java.lang.String bladeId, java.lang.String eventTypeLabel, EventFilter filter) throws ClifException
StorageRead
getEventIterator
in interface StorageRead
testName
- the test name to retrieve events frombladeId
- the blade identifier in this test to retrieve events fromeventTypeLabel
- the type label of the retrieved eventsfilter
- the filter object to be used for event selection. If null, the iterator
will return all events. The filter object may throw a NoMoreEvent exception, in which
case current iterator step stops and currently selected events are returned.ClifException
- the given test, blade, or event type could not be foundStorageRead.getNextEvents(Serializable, int)
,
StorageRead.closeEventIterator(Serializable)
public BladeEvent[] getNextEvents(java.io.Serializable iteratorKey, int count) throws ClifException
StorageRead
getNextEvents
in interface StorageRead
iteratorKey
- the key for the target event iteratorcount
- the number of event to get (at most)ClifException
StorageRead.getEventIterator(String, String, String, EventFilter)
,
StorageRead.closeEventIterator(Serializable)
public void closeEventIterator(java.io.Serializable iteratorKey)
StorageRead
closeEventIterator
in interface StorageRead
iteratorKey
- the key for the target event iteratorpublic BladeEvent[] getEvents(java.lang.String testName, java.lang.String bladeId, java.lang.String eventTypeLabel, EventFilter filter, long fromIndex, int count) throws ClifException
StorageRead
getEvents
in interface StorageRead
testName
- the test name to retrieve events frombladeId
- the blade identifier in this test to retrieve events fromeventTypeLabel
- the type label of the retrieved eventsfilter
- the filter object to be used for event selection.
If null, all events are selected. If the filter throws a NoMoreEvent exception,
the selection process stops, and currently selected events are returned.fromIndex
- the index of the first event to be considered (in other words, events
in range 0..fromIndex-1 are ignored). If negative and count parameter is greater than zero,
then the latest events will be retrieved.count
- the maximum number of events to retrieve. If negative, the number of retrieved
events is not limited.ClifException
public long countEvents(java.lang.String testName, java.lang.String bladeId, java.lang.String eventTypeLabel, EventFilter filter) throws ClifException
StorageRead
countEvents
in interface StorageRead
testName
- the test name to retrieve events frombladeId
- the blade identifier in this test to retrieve events fromeventTypeLabel
- the type label of the retrieved eventsfilter
- the filter object to be used for event selection. If null, all events
are counted. Counting stops before completion if the filter object throws a NoMoreEvent
exception, in which case count value before exception is returned.ClifException