|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.ow2.clif.storage.lib.filestorage.ConsoleFileStorageImpl
public class ConsoleFileStorageImpl
Part of the storage. This part is deployed in the console
Field Summary | |
---|---|
protected java.util.Map<java.lang.String,StorageProxyAdmin> |
distributedStorage
|
protected java.math.BigInteger |
eventIteratorKey
|
protected java.util.Map<java.math.BigInteger,org.ow2.clif.storage.lib.filestorage.ConsoleFileStorageImpl.EventIterator> |
eventIterators
|
protected java.io.BufferedWriter |
test
|
protected java.lang.String |
testDirname
|
protected java.io.Serializable |
testId
|
Fields inherited from interface org.ow2.clif.storage.api.StorageAdmin |
---|
STORAGE_ADMIN |
Fields inherited from interface org.ow2.clif.storage.api.StorageRead |
---|
STORAGE_READ |
Constructor Summary | |
---|---|
ConsoleFileStorageImpl()
|
Method Summary | |
---|---|
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 testPlan)
Inform the storage system the beginning of a new test |
void |
terminate()
Terminate the storage system |
void |
unbindFc(java.lang.String clientItfName)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
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 java.util.Map<java.math.BigInteger,org.ow2.clif.storage.lib.filestorage.ConsoleFileStorageImpl.EventIterator> eventIterators
protected java.math.BigInteger eventIteratorKey
Constructor Detail |
---|
public ConsoleFileStorageImpl()
Method Detail |
---|
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 testPlan) throws ClifException
newTest
in interface StorageAdmin
testPlan
- Map of scenario deployment definitions, indexed by a unique identifiertestId
- test identifier object
ClifException
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 retained
ClifException
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 identifier
ClifException
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 type
public 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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |