|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.sf.sparql.benchmarking.monitoring.StreamProgressListener
public class StreamProgressListener
A Progress Listener that prints informational messages to a
PrintStream
Constructor Summary | |
---|---|
protected |
StreamProgressListener()
Creates a Progress Listener without a stream |
protected |
StreamProgressListener(boolean closeOnFinish)
Creates a Progress Listener without a stream |
|
StreamProgressListener(OutputStream output)
Creates a new Progress Listener for the given stream |
|
StreamProgressListener(OutputStream output,
boolean closeOnFinish)
Creates a new Progress Listener for the given stream |
|
StreamProgressListener(PrintStream output)
Creates a new Progress Listener for the given stream |
|
StreamProgressListener(PrintStream output,
boolean closeOnFinish)
Creates a new Progress Listener for the given stream |
Method Summary | ||
---|---|---|
|
afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run)
Invoked after each run of an operation |
|
|
afterOperationMix(Runner<T> runner,
T options,
OperationMix mix,
OperationMixRun run)
Invoked after each run of an operation mix |
|
|
beforeOperation(Runner<T> runner,
T options,
Operation operation)
Invoked before each run of an operation |
|
|
beforeOperationMix(Runner<T> runner,
T options,
OperationMix mix)
Invoked before each run of an operation mix |
|
|
finish(Runner<T> runner,
T options,
boolean ok)
Invoked when test runs finish |
|
protected boolean |
hasSwitchedThreads()
|
|
protected OutputStream |
openStream()
Internal method called only when this class is derived from and the protected constructors which do not take a stream argument have been used |
|
|
progress(Runner<T> runner,
T options,
String message)
Invoked when an informational progress message is available |
|
void |
setForceThreadedOutput(boolean force)
Sets whether to force threaded output i.e. |
|
|
start(Runner<T> runner,
T options)
Invoked when test runs start |
|
protected void |
updateThread()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected StreamProgressListener(boolean closeOnFinish)
Usable only by derived classes, the openStream()
method will be
called to open a stream at the time benchmarking starts
closeOnFinish
- Whether the Output Stream should be closed when the listener
receives the #handleFinished(boolean)
callprotected StreamProgressListener()
Usable only by derived classes, the openStream()
method will be
called to open a stream at the time benchmarking starts
public StreamProgressListener(PrintStream output, boolean closeOnFinish)
output
- Output StreamcloseOnFinish
- Whether the Output Stream should be closed when the listener
receives the finish(Runner, Options, boolean)
callpublic StreamProgressListener(PrintStream output)
output
- Output Streampublic StreamProgressListener(OutputStream output)
output
- Output Streampublic StreamProgressListener(OutputStream output, boolean closeOnFinish)
output
- Output StreamcloseOnFinish
- Whether the stream should be closed when the
finish(Runner, Options, boolean)
event is receivedMethod Detail |
---|
public void setForceThreadedOutput(boolean force)
force
- True if thread disambiguated output should be forced
regardless of the parallel threads declared by the
Options
protected OutputStream openStream()
public <T extends Options> void progress(Runner<T> runner, T options, String message)
ProgressListener
progress
in interface ProgressListener
runner
- Runneroptions
- Optionsmessage
- Messageprotected final boolean hasSwitchedThreads()
protected void updateThread()
public <T extends Options> void beforeOperation(Runner<T> runner, T options, Operation operation)
ProgressListener
beforeOperation
in interface ProgressListener
runner
- Runneroptions
- Optionsoperation
- Operationpublic <T extends Options> void afterOperation(Runner<T> runner, T options, Operation operation, OperationRun run)
ProgressListener
afterOperation
in interface ProgressListener
runner
- Runneroptions
- Optionsoperation
- Operationrun
- Run informationpublic <T extends Options> void beforeOperationMix(Runner<T> runner, T options, OperationMix mix)
ProgressListener
beforeOperationMix
in interface ProgressListener
runner
- Runneroptions
- Optionsmix
- Operation Mixpublic <T extends Options> void afterOperationMix(Runner<T> runner, T options, OperationMix mix, OperationMixRun run)
ProgressListener
afterOperationMix
in interface ProgressListener
runner
- Runneroptions
- Optionsmix
- Operation mixrun
- Mix run informationpublic <T extends Options> void start(Runner<T> runner, T options)
ProgressListener
start
in interface ProgressListener
runner
- Runneroptions
- Optionspublic <T extends Options> void finish(Runner<T> runner, T options, boolean ok)
ProgressListener
finish
in interface ProgressListener
runner
- Runneroptions
- Optionsok
- Indicates whether running finished normally, if false then
some error condition caused running to be halted
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |