Project JXTA

net.jxta.impl.meter
Class GenericServiceMonitor

java.lang.Object
  extended bynet.jxta.impl.meter.GenericServiceMonitor
All Implemented Interfaces:
Module, ServiceMonitor, ServiceMonitorImpl
Direct Known Subclasses:
EndpointServiceMonitor, RendezvousServiceMonitor, ResolverServiceMonitor, TransportServiceMonitor

public abstract class GenericServiceMonitor
extends Object
implements ServiceMonitorImpl, Module


Field Summary
protected  ServiceMetric cumulativeServiceMetric
           
protected  ServiceMetric[] deltaServiceMetrics
           
protected  ModuleImplAdvertisement implAdvertisement
           
protected  MonitorManager monitorManager
           
protected  long reportRate
           
protected  int reportRateIndex
           
 
Fields inherited from interface net.jxta.platform.Module
START_AGAIN_PROGRESS, START_AGAIN_STALLED, START_OK
 
Constructor Summary
GenericServiceMonitor()
           
 
Method Summary
 void beginCumulativeReport()
           
 void beginPulse(ServiceMonitorPulseInfo pulseInfo)
           
protected abstract  ServiceMetric collectServiceMetrics()
          Get the service metrics accrued since the last pulse Return null if there were no metrices since the last call
protected  ServiceMetric createServiceMetric()
           
 ServiceMonitorFilter createSupportedCumulativeServiceMonitorFilter(ServiceMonitorFilter serviceMonitorFilter)
           
 ServiceMonitorFilter createSupportedServiceMonitorFilter(ServiceMonitorFilter serviceMonitorFilter, long reportRate)
           
 void destroy()
           
 void endCumulativeReport()
           
 void endPulse(ServiceMonitorPulseInfo pulseInfo)
           
protected  ServiceMetric getCumulativeServiceMetric()
           
 ServiceMetric getCumulativeServiceMetric(ServiceMonitorFilter serviceMonitorFilter, long fromTime, long toTime)
           
 ModuleClassID getModuleClassID()
           
 PeerGroup getPeerGroup()
           
 ServiceMetric getServiceMetric(ServiceMonitorFilter serviceMonitorFilter, long fromTime, long toTime, int reportIndex, long reportRate)
           
protected  void init()
           
 void init(MonitorManager monitorManager)
           
 void init(PeerGroup group, ID assignedID, Advertisement advertisement)
           
 void resetPulseRate(ServiceMonitorPulseInfo pulseInfo, int oldPulseRateIndex)
           
 void serviceMonitorFilterDeregistered(ServiceMonitorFilter serviceMonitorFilter, int reportRateIndex, long reportRate, boolean retiredRate)
           
 void serviceMonitorFilterRegistered(ServiceMonitorFilter serviceMonitorFilter, int reportRateIndex, long reportRate, boolean newRate)
           
 int startApp(String[] args)
           
 void stopApp()
           
 void validateCumulativeServiceMonitorFilter(ServiceMonitorFilter serviceMonitorFilter)
           
 void validateServiceMonitorFilter(ServiceMonitorFilter serviceMonitorFilter, long reportRate)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

monitorManager

protected MonitorManager monitorManager

reportRate

protected long reportRate

reportRateIndex

protected int reportRateIndex

cumulativeServiceMetric

protected ServiceMetric cumulativeServiceMetric

deltaServiceMetrics

protected ServiceMetric[] deltaServiceMetrics

implAdvertisement

protected ModuleImplAdvertisement implAdvertisement
Constructor Detail

GenericServiceMonitor

public GenericServiceMonitor()
Method Detail

init

public void init(PeerGroup group,
                 ID assignedID,
                 Advertisement advertisement)
Specified by:
init in interface Module

init

public void init(MonitorManager monitorManager)
Specified by:
init in interface ServiceMonitorImpl

startApp

public int startApp(String[] args)
Specified by:
startApp in interface Module

stopApp

public void stopApp()
Specified by:
stopApp in interface Module

init

protected void init()

getModuleClassID

public ModuleClassID getModuleClassID()
Specified by:
getModuleClassID in interface ServiceMonitor

getPeerGroup

public PeerGroup getPeerGroup()

getCumulativeServiceMetric

protected ServiceMetric getCumulativeServiceMetric()

resetPulseRate

public void resetPulseRate(ServiceMonitorPulseInfo pulseInfo,
                           int oldPulseRateIndex)
Specified by:
resetPulseRate in interface ServiceMonitorImpl

validateCumulativeServiceMonitorFilter

public void validateCumulativeServiceMonitorFilter(ServiceMonitorFilter serviceMonitorFilter)
Specified by:
validateCumulativeServiceMonitorFilter in interface ServiceMonitor

createSupportedCumulativeServiceMonitorFilter

public ServiceMonitorFilter createSupportedCumulativeServiceMonitorFilter(ServiceMonitorFilter serviceMonitorFilter)
Specified by:
createSupportedCumulativeServiceMonitorFilter in interface ServiceMonitor

validateServiceMonitorFilter

public void validateServiceMonitorFilter(ServiceMonitorFilter serviceMonitorFilter,
                                         long reportRate)
Specified by:
validateServiceMonitorFilter in interface ServiceMonitor

createSupportedServiceMonitorFilter

public ServiceMonitorFilter createSupportedServiceMonitorFilter(ServiceMonitorFilter serviceMonitorFilter,
                                                                long reportRate)
Specified by:
createSupportedServiceMonitorFilter in interface ServiceMonitor

createServiceMetric

protected ServiceMetric createServiceMetric()

collectServiceMetrics

protected abstract ServiceMetric collectServiceMetrics()
Get the service metrics accrued since the last pulse Return null if there were no metrices since the last call


beginPulse

public void beginPulse(ServiceMonitorPulseInfo pulseInfo)
Specified by:
beginPulse in interface ServiceMonitorImpl

endPulse

public void endPulse(ServiceMonitorPulseInfo pulseInfo)
Specified by:
endPulse in interface ServiceMonitorImpl

beginCumulativeReport

public void beginCumulativeReport()
Specified by:
beginCumulativeReport in interface ServiceMonitor

endCumulativeReport

public void endCumulativeReport()
Specified by:
endCumulativeReport in interface ServiceMonitor

getServiceMetric

public ServiceMetric getServiceMetric(ServiceMonitorFilter serviceMonitorFilter,
                                      long fromTime,
                                      long toTime,
                                      int reportIndex,
                                      long reportRate)
Specified by:
getServiceMetric in interface ServiceMonitor

getCumulativeServiceMetric

public ServiceMetric getCumulativeServiceMetric(ServiceMonitorFilter serviceMonitorFilter,
                                                long fromTime,
                                                long toTime)
Specified by:
getCumulativeServiceMetric in interface ServiceMonitor

serviceMonitorFilterRegistered

public void serviceMonitorFilterRegistered(ServiceMonitorFilter serviceMonitorFilter,
                                           int reportRateIndex,
                                           long reportRate,
                                           boolean newRate)
Specified by:
serviceMonitorFilterRegistered in interface ServiceMonitor

serviceMonitorFilterDeregistered

public void serviceMonitorFilterDeregistered(ServiceMonitorFilter serviceMonitorFilter,
                                             int reportRateIndex,
                                             long reportRate,
                                             boolean retiredRate)
Specified by:
serviceMonitorFilterDeregistered in interface ServiceMonitor

destroy

public void destroy()
Specified by:
destroy in interface ServiceMonitor

JXTA J2SE