|
||||||||||
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 deploy and control test plans among CLIF servers. It relies on a FractalRMI registry to find CLIF servers. 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()
Constructor. |
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)
|
void |
collect(java.lang.String[] selBladesId,
CollectListener listener)
Collects latest test data for selected blades |
java.util.Map |
getCurrentParameters(java.lang.String bladeId)
Return current changeable parameters |
java.util.Map |
getDefinitions()
|
java.lang.String |
getFcState()
|
BladeState |
getGlobalState(java.lang.String[] selBladesId)
Get global state for these blades. |
java.lang.String[] |
getStatLabels(java.lang.String bladeId)
Retrieve the ActionStat of a specific host. |
long[] |
getStats(java.lang.String bladeId)
Retrieve the execution statistics of a specific blade. |
void |
init(java.io.Serializable testId)
Initialize the test for every blade |
void |
join()
Waits for the end of the test |
void |
join(java.lang.String[] selBladesId)
Waits for the end of the test for selected blades |
java.lang.String[] |
listFc()
|
java.lang.Object |
lookupFc(java.lang.String clientItfName)
|
void |
resume()
Resume the test (if suspended) |
void |
resume(java.lang.String[] selBladesId)
Resume the test (if suspended) for selected blades |
void |
setBladeState(java.lang.String id,
BladeState state)
Inform that the state of a host has changed. |
void |
setDefinitions(java.util.Map definitions)
|
void |
start()
Starts the test plan (i.e. all blades) |
void |
start(java.lang.String[] selBladesId)
Starts the test plan for selected blades |
void |
startFc()
|
void |
stop()
Final stop of the test |
void |
stop(java.lang.String[] selBladesId)
Final stop of the test for selected blades |
void |
stopFc()
|
void |
suspend()
Suspend the test |
void |
suspend(java.lang.String[] selBladesId)
Suspend the test for selected blades |
void |
unbindFc(java.lang.String clientItfName)
|
void |
waitEndOfRun(java.lang.String[] selBladesId)
Wait until blades stop or complete. |
boolean |
waitForState(java.lang.String[] selBladesId,
BladeState state)
Wait until the state is goaled. |
void |
waitStationaryState(java.lang.String[] selBladesId)
Wait until blades are stationary. |
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 report from
public java.lang.String[] getStatLabels(java.lang.String bladeId)
getStatLabels
in interface TestControl
bladeId
- The blade identifier to get the statistics labels from
public java.util.Map getCurrentParameters(java.lang.String bladeId)
TestControl
getCurrentParameters
in interface TestControl
bladeId
- The identifier of the target bladepublic void changeParameter(java.lang.String bladeId, java.lang.String name, java.io.Serializable value) throws ClifException
changeParameter
in interface TestControl
ClifException
public void collect(java.lang.String[] selBladesId, CollectListener listener)
collect
in interface TestControl
selBladesId
- selected blades ids 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
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
- selected blades idspublic void stop()
stop
in interface ActivityControl
public void stop(java.lang.String[] selBladesId)
stop
in interface TestControl
selBladesId
- selected blades idspublic void suspend()
suspend
in interface ActivityControl
public void suspend(java.lang.String[] selBladesId)
suspend
in interface TestControl
selBladesId
- selected blades idspublic void resume()
resume
in interface ActivityControl
public void resume(java.lang.String[] selBladesId)
resume
in interface TestControl
selBladesId
- selected blades idspublic void join()
join
in interface ActivityControl
public void join(java.lang.String[] selBladesId)
join
in interface TestControl
selBladesId
- selected blades idspublic 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 scenario globally unique identifier objectstate
- The new state of the bladepublic void waitStationaryState(java.lang.String[] selBladesId)
waitStationaryState
in interface SupervisorInfo
selBladesId
- Ids of the blades to testpublic boolean waitForState(java.lang.String[] selBladesId, BladeState state)
SupervisorInfo
waitForState
in interface SupervisorInfo
public BladeState getGlobalState(java.lang.String[] selBladesId)
getGlobalState
in interface SupervisorInfo
selBladesId
- Ids of the blades to test
public void waitEndOfRun(java.lang.String[] selBladesId)
waitEndOfRun
in interface SupervisorInfo
selBladesId
- Ids of the blades to testpublic void setDefinitions(java.util.Map definitions)
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 |