|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.util.Observable
org.ow2.clif.supervisor.lib.SupervisorImpl
public class SupervisorImpl
Supervisor implementation, used to control a deployed test plan (i.e. a set of blades). This class extends the Observable class in order to provide feedback information about the state of the test plan's blades and the occurrence of alarms.
AlarmEvent
,
BladeObservation
Field Summary |
---|
Fields inherited from interface org.ow2.clif.supervisor.api.TestControl |
---|
TEST_CONTROL |
Fields inherited from interface org.ow2.clif.supervisor.api.SupervisorInfo |
---|
SUPERVISOR_INFO |
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController |
---|
STARTED, STOPPED |
Constructor Summary | |
---|---|
SupervisorImpl()
|
Method Summary | |
---|---|
void |
alarm(java.lang.String bladeId,
AlarmEvent alarm)
Forwards the alarm event to observers |
void |
bindFc(java.lang.String clientItfName,
java.lang.Object serverItf)
|
void |
changeParameter(java.lang.String bladeId,
java.lang.String name,
java.io.Serializable value)
Changes a blade parameter value. |
void |
collect(java.lang.String[] selBladesId,
CollectListener listener)
Collects latest test data for selected blades |
java.util.Map |
getCurrentParameters(java.lang.String bladeId)
Gets a Map of blade parameters and their associated values. |
java.util.Map |
getDefinitions()
Gets current test plan definition |
java.lang.String |
getFcState()
|
BladeState |
getGlobalState(java.lang.String[] selBladesId)
Get global state for some blades. |
java.lang.String[] |
getStatLabels(java.lang.String bladeId)
Gets labels describing statistics delivered by a blade |
long[] |
getStats(java.lang.String bladeId)
Retrieve the execution statistics of a blade. |
void |
init(java.io.Serializable testId)
Initializes a new test for every blade in the deployed test plan. |
void |
join()
Waits for the end of activity of all blades of currently deployed test plan. |
void |
join(java.lang.String[] selBladesId)
Waits for the end of execution of a selection of blades from currently deployed test plan. |
java.lang.String[] |
listFc()
|
java.lang.Object |
lookupFc(java.lang.String clientItfName)
|
void |
resume()
Resumes all blades of currently deployed test plan. |
void |
resume(java.lang.String[] selBladesId)
Resumes a selection of blades from currently deployed test plan. |
void |
setBladeState(java.lang.String id,
BladeState state)
Inform that the state of a blade has changed. |
void |
setDefinitions(java.util.Map definitions)
Sets the test plan definition. |
void |
start()
Starts all blades of the currently deployed test plan. |
void |
start(java.lang.String[] selBladesId)
Starts a selection of blades of currently deployed test plan. |
void |
startFc()
|
void |
stop()
Stops all blades of currently deployed test plan. |
void |
stop(java.lang.String[] selBladesId)
Stops a selection of blades from currently deployed test plan. |
void |
stopFc()
|
void |
suspend()
Suspends all blades of currently deployed test plan. |
void |
suspend(java.lang.String[] selBladesId)
Suspends a selection of blades from currently deployed test plan. |
void |
unbindFc(java.lang.String clientItfName)
|
void |
waitEndOfRun(java.lang.String[] selBladesId)
Wait until blades are stopped, completed or aborted. |
boolean |
waitForState(java.lang.String[] selBladesId,
BladeState state)
Waits until blades are all in a given state. |
void |
waitStationaryState(java.lang.String[] selBladesId)
Waits until blades are all in a stationary state. |
Methods inherited from class java.util.Observable |
---|
addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.ow2.clif.supervisor.api.TestControl |
---|
addObserver, deleteObservers |
Constructor Detail |
---|
public SupervisorImpl()
Method Detail |
---|
public void startFc()
startFc
in interface org.objectweb.fractal.api.control.LifeCycleController
public void stopFc()
stopFc
in interface org.objectweb.fractal.api.control.LifeCycleController
public java.lang.String getFcState()
getFcState
in interface org.objectweb.fractal.api.control.LifeCycleController
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 long[] getStats(java.lang.String bladeId)
getStats
in interface TestControl
bladeId
- The blade identifier to get the statistics from
getStatLabels(String)
public java.lang.String[] getStatLabels(java.lang.String bladeId)
getStatLabels
in interface TestControl
bladeId
- the blade identifier
getStats(String)
public java.util.Map getCurrentParameters(java.lang.String bladeId)
getCurrentParameters
in interface TestControl
bladeId
- the blade identifier
public void changeParameter(java.lang.String bladeId, java.lang.String name, java.io.Serializable value) throws ClifException
changeParameter
in interface TestControl
bladeId
- the blade identifiername
- the parameter namevalue
- the new parameter value
ClifException
public void collect(java.lang.String[] selBladesId, CollectListener listener)
collect
in interface TestControl
selBladesId
- selected blades identifiers as a String[]listener
- the listener receives progress
information and it is given the opportunity to
cancel the collection. Ignored if null.public void init(java.io.Serializable testId) throws ClifException
setDefinitions(Map)
must be called before to test
the currently deployed test plan definition.
init
in interface ActivityControl
testId
- the new test's name
ClifException
public void start()
start
in interface ActivityControl
public void start(java.lang.String[] selBladesId)
start
in interface TestControl
selBladesId
- identifiers of blades to be started,
or null for starting all blades.public void stop()
stop
in interface ActivityControl
public void stop(java.lang.String[] selBladesId)
stop
in interface TestControl
selBladesId
- array of target blades identifiers,
or null for designating all bladespublic void suspend()
suspend
in interface ActivityControl
public void suspend(java.lang.String[] selBladesId)
suspend
in interface TestControl
selBladesId
- array of target blades identifiers,
or null for designating all bladespublic void resume()
resume
in interface ActivityControl
public void resume(java.lang.String[] selBladesId)
resume
in interface TestControl
selBladesId
- array of target blades identifiers,
or null for designating all bladespublic void join()
join
in interface ActivityControl
public void join(java.lang.String[] selBladesId)
join
in interface TestControl
selBladesId
- array of target blades identifiers,
or null for designating all bladespublic void alarm(java.lang.String bladeId, AlarmEvent alarm)
alarm
in interface SupervisorInfo
bladeId
- blade identifier of the event sourcealarm
- alarm eventpublic void setBladeState(java.lang.String id, BladeState state)
setBladeState
in interface SupervisorInfo
id
- the globally unique blade identifierstate
- The new state of the bladepublic void waitStationaryState(java.lang.String[] selBladesId) throws java.lang.InterruptedException
waitStationaryState
in interface SupervisorInfo
selBladesId
- array of identifiers of target blades,
or null for designating all blades of currently deployed test plan.
java.lang.InterruptedException
public boolean waitForState(java.lang.String[] selBladesId, BladeState state) throws java.lang.InterruptedException
waitForState
in interface SupervisorInfo
selBladesId
- array of identifiers of target blades,
or null for designating all blades of currently deployed test plan.state
- the requested blade state
java.lang.InterruptedException
public BladeState getGlobalState(java.lang.String[] selBladesId)
getGlobalState
in interface SupervisorInfo
selBladesId
- identifiers of target blades,
or null for designating all blades
public void waitEndOfRun(java.lang.String[] selBladesId) throws java.lang.InterruptedException
waitEndOfRun
in interface SupervisorInfo
selBladesId
- identifiers of target blades,
or null for designating all blades
java.lang.InterruptedException
public void setDefinitions(java.util.Map definitions)
init(Serializable)
.
setDefinitions
in interface SupervisorInfo
public java.util.Map getDefinitions()
getDefinitions
in interface SupervisorInfo
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |