public abstract class AbstractDumbInsert extends java.lang.Object implements BladeControl, org.objectweb.fractal.api.control.BindingController, java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
protected java.lang.Object |
activity_lock |
protected long |
arg_duration_ms |
protected long |
arg_period_ms |
protected long |
baseTime_ms |
protected BladeInsertResponse |
bir |
protected java.lang.Object |
dc_lock |
protected DataCollectorWrite |
dcw |
protected java.util.Map<java.lang.String,java.lang.Object> |
eventStorageStatesMap |
protected java.lang.Thread |
poller |
protected java.lang.String |
probeId |
protected java.lang.Object |
sr_lock |
protected boolean |
started |
protected boolean |
stopped |
protected BooleanHolder |
storeAlarmEvents |
protected BooleanHolder |
storeLifeCycleEvents |
protected BooleanHolder |
storeProbeEvents |
protected boolean |
suspended |
protected boolean |
terminated |
BLADE_CONTROL, BLADE_INSERT_CONTROL
Constructor and Description |
---|
AbstractDumbInsert() |
Modifier and Type | Method and Description |
---|---|
void |
bindFc(java.lang.String clientItfName,
java.lang.Object serverItf) |
void |
changeParameter(java.lang.String parameter,
java.io.Serializable value)
Sets the parameter
parameter of this blade with the value
value . |
protected void |
close()
Override this method when you are willing to release some resources
when the probe ends its activity.
|
protected abstract ProbeEvent |
doProbe()
Define this method to perform your measure and return it
|
java.util.Map<java.lang.String,java.io.Serializable> |
getCurrentParameters()
Returns a
Map which maps the defined parameters to their values. |
java.lang.String |
getHelpMessage()
Gives probe help.
|
java.lang.String |
getId() |
void |
init(java.io.Serializable testId)
Initialize the activity
|
void |
join()
Waits until the end of the activity
|
java.lang.String[] |
listFc() |
java.lang.Object |
lookupFc(java.lang.String clientItfName) |
void |
resume()
Resume the activity (if suspended)
|
void |
run() |
void |
setArgument(java.lang.String arg)
Sets sampling period duration parameters.
|
protected void |
setExtraArguments(java.util.List<java.lang.String> extraArgs)
Override this method when you are willing to pass some extra parameters to the Insert,
below the sampling period and duration standard arguments.
|
void |
setId(java.lang.String id)
Sets this scenario's unique identifier
|
void |
start()
Initial start of the activity
|
void |
stop()
Final stop of the activity
|
void |
suspend()
Suspend the activity
|
void |
unbindFc(java.lang.String clientItfName) |
protected java.lang.String probeId
protected java.lang.Object activity_lock
protected BladeInsertResponse bir
protected java.lang.Object sr_lock
protected DataCollectorWrite dcw
protected java.lang.Object dc_lock
protected long arg_period_ms
protected long arg_duration_ms
protected long baseTime_ms
protected volatile boolean started
protected volatile boolean stopped
protected volatile boolean suspended
protected volatile boolean terminated
protected java.lang.Thread poller
protected final BooleanHolder storeLifeCycleEvents
protected final BooleanHolder storeAlarmEvents
protected final BooleanHolder storeProbeEvents
protected final java.util.Map<java.lang.String,java.lang.Object> eventStorageStatesMap
protected abstract ProbeEvent doProbe()
public java.lang.String getHelpMessage()
protected void setExtraArguments(java.util.List<java.lang.String> extraArgs) throws ClifException
ClifException
protected void close() throws ClifException
ClifException
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 init(java.io.Serializable testId)
ActivityControl
init
in interface ActivityControl
testId
- unique identifier of the new testpublic void start()
ActivityControl
start
in interface ActivityControl
public void stop()
ActivityControl
stop
in interface ActivityControl
public void suspend()
ActivityControl
suspend
in interface ActivityControl
public void resume()
ActivityControl
resume
in interface ActivityControl
public void join()
ActivityControl
join
in interface ActivityControl
public void setArgument(java.lang.String arg) throws ClifException
setArgument
in interface BladeControl
arg
- should hold 2 integer parameters (separated with usual separators) setting
(1) the observation polling period in ms, and (2) the test duration in seconds.ClifException
public void setId(java.lang.String id)
setId
in interface BladeControl
public java.lang.String getId()
getId
in interface BladeControl
public void run()
run
in interface java.lang.Runnable
public void changeParameter(java.lang.String parameter, java.io.Serializable value) throws ClifException
BladeControl
parameter
of this blade with the value
value
.
This method allows to change parameters independently of the activity of
the blade. However, some parameters can depend on the state of the blade.changeParameter
in interface BladeControl
ClifException
public java.util.Map<java.lang.String,java.io.Serializable> getCurrentParameters()
BladeControl
Map
which maps the defined parameters to their values.getCurrentParameters
in interface BladeControl