org.apache.sling.event.impl.jobs
Class StatisticsImpl

java.lang.Object
  extended by org.apache.sling.event.impl.jobs.StatisticsImpl
All Implemented Interfaces:
Statistics
Direct Known Subclasses:
AbstractJobQueue, DefaultJobManager

public class StatisticsImpl
extends Object
implements Statistics

Implementation of the statistics.


Constructor Summary
StatisticsImpl()
           
StatisticsImpl(long startTime)
           
 
Method Summary
 void add(StatisticsImpl other)
          Add another statistics information.
 void addActive(long queueTime)
          Add a job from the queue to status active
 void cancelledJob()
          Add a cancelled job.
 void clearQueued()
          Clear all queued
 void copyFrom(StatisticsImpl other)
          Create a new statistics object with exactly the same values.
 void decQueued()
          Job not processed by us
 void failedJob()
          Add a failed job.
 void finishedJob(long jobTime)
          Add a finished job
 long getAverageProcessingTime()
          The average processing time of a job - this only counts finished jobs.
 long getAverageWaitingTime()
          The average waiting time of a job in the queue.
 long getLastActivatedJobTime()
          The time a job has been started last.
 long getLastFinishedJobTime()
          The time a job has been finished/failed/cancelled last.
 long getNumberOfActiveJobs()
          Number of jobs currently in processing.
 long getNumberOfCancelledJobs()
          Number of permanently failing or cancelled jobs.
 long getNumberOfFailedJobs()
          Number of failing jobs.
 long getNumberOfFinishedJobs()
          Number of successfully finished jobs.
 long getNumberOfJobs()
          This just adds Statistics.getNumberOfActiveJobs() and Statistics.getNumberOfQueuedJobs()
 long getNumberOfProcessedJobs()
          Number of already processed jobs.
 long getNumberOfQueuedJobs()
          Number of jobs currently waiting in a queue.
 long getStartTime()
          The time this service has been started
 void incQueued()
          New job in the qeue
 void reset()
          Clear all collected statistics and set the starting time to the current time.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StatisticsImpl

public StatisticsImpl()

StatisticsImpl

public StatisticsImpl(long startTime)
Method Detail

getStartTime

public long getStartTime()
Description copied from interface: Statistics
The time this service has been started

Specified by:
getStartTime in interface Statistics
See Also:
Statistics.getStartTime()

getNumberOfProcessedJobs

public long getNumberOfProcessedJobs()
Description copied from interface: Statistics
Number of already processed jobs. This adds Statistics.getNumberOfFinishedJobs(), Statistics.getNumberOfCancelledJobs() and Statistics.getNumberOfFailedJobs()

Specified by:
getNumberOfProcessedJobs in interface Statistics
See Also:
Statistics.getNumberOfProcessedJobs()

getNumberOfActiveJobs

public long getNumberOfActiveJobs()
Description copied from interface: Statistics
Number of jobs currently in processing.

Specified by:
getNumberOfActiveJobs in interface Statistics
See Also:
Statistics.getNumberOfActiveJobs()

getNumberOfQueuedJobs

public long getNumberOfQueuedJobs()
Description copied from interface: Statistics
Number of jobs currently waiting in a queue.

Specified by:
getNumberOfQueuedJobs in interface Statistics
See Also:
Statistics.getNumberOfQueuedJobs()

getNumberOfJobs

public long getNumberOfJobs()
Description copied from interface: Statistics
This just adds Statistics.getNumberOfActiveJobs() and Statistics.getNumberOfQueuedJobs()

Specified by:
getNumberOfJobs in interface Statistics
See Also:
Statistics.getNumberOfJobs()

getAverageWaitingTime

public long getAverageWaitingTime()
Description copied from interface: Statistics
The average waiting time of a job in the queue.

Specified by:
getAverageWaitingTime in interface Statistics
See Also:
Statistics.getAverageWaitingTime()

getAverageProcessingTime

public long getAverageProcessingTime()
Description copied from interface: Statistics
The average processing time of a job - this only counts finished jobs.

Specified by:
getAverageProcessingTime in interface Statistics
See Also:
Statistics.getAverageProcessingTime()

getNumberOfFinishedJobs

public long getNumberOfFinishedJobs()
Description copied from interface: Statistics
Number of successfully finished jobs.

Specified by:
getNumberOfFinishedJobs in interface Statistics
See Also:
Statistics.getNumberOfFinishedJobs()

getNumberOfCancelledJobs

public long getNumberOfCancelledJobs()
Description copied from interface: Statistics
Number of permanently failing or cancelled jobs.

Specified by:
getNumberOfCancelledJobs in interface Statistics
See Also:
Statistics.getNumberOfCancelledJobs()

getNumberOfFailedJobs

public long getNumberOfFailedJobs()
Description copied from interface: Statistics
Number of failing jobs.

Specified by:
getNumberOfFailedJobs in interface Statistics
See Also:
Statistics.getNumberOfFailedJobs()

getLastActivatedJobTime

public long getLastActivatedJobTime()
Description copied from interface: Statistics
The time a job has been started last.

Specified by:
getLastActivatedJobTime in interface Statistics
See Also:
Statistics.getLastActivatedJobTime()

getLastFinishedJobTime

public long getLastFinishedJobTime()
Description copied from interface: Statistics
The time a job has been finished/failed/cancelled last.

Specified by:
getLastFinishedJobTime in interface Statistics
See Also:
Statistics.getLastFinishedJobTime()

finishedJob

public void finishedJob(long jobTime)
Add a finished job

Parameters:
jobTime - The processing time for this job.

failedJob

public void failedJob()
Add a failed job.


cancelledJob

public void cancelledJob()
Add a cancelled job.


incQueued

public void incQueued()
New job in the qeue


decQueued

public void decQueued()
Job not processed by us


clearQueued

public void clearQueued()
Clear all queued


addActive

public void addActive(long queueTime)
Add a job from the queue to status active

Parameters:
queueTime - The time the job stayed in the queue.

add

public void add(StatisticsImpl other)
Add another statistics information.


copyFrom

public void copyFrom(StatisticsImpl other)
Create a new statistics object with exactly the same values.


reset

public void reset()
Description copied from interface: Statistics
Clear all collected statistics and set the starting time to the current time. Note that not all fields are cleared, last waiting time or number of active and queued jobs is not cleared as these are currently used.

Specified by:
reset in interface Statistics
See Also:
Statistics.reset()


Copyright © 2007-2013 The Apache Software Foundation. All Rights Reserved.