Class ThroughputLatencyBenchmarkStrategy

  • All Implemented Interfaces:
    controller.IBenchmarkStrategy, controller.IWorkerStatusListener

    public class ThroughputLatencyBenchmarkStrategy
    extends java.lang.Object
    implements controller.IBenchmarkStrategy, controller.IWorkerStatusListener
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void executeBenchmark​(controller.WorkerHandler[] workers, java.util.Properties benchmarkParameters)  
      void onEnded​(int workerId)  
      void onError​(int workerId, java.lang.String errorMessage)  
      void onReady​(int workerId)  
      void onResult​(int workerId, worker.IProcessingResult processingResult)  
      void saveClientMeasurements​(long[] latencies)  
      void saveServerMeasurements​(long[] clients, long[] nRequests, long[] delta)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ThroughputLatencyBenchmarkStrategy

        public ThroughputLatencyBenchmarkStrategy()
    • Method Detail

      • executeBenchmark

        public void executeBenchmark​(controller.WorkerHandler[] workers,
                                     java.util.Properties benchmarkParameters)
        Specified by:
        executeBenchmark in interface controller.IBenchmarkStrategy
      • onReady

        public void onReady​(int workerId)
        Specified by:
        onReady in interface controller.IWorkerStatusListener
      • onEnded

        public void onEnded​(int workerId)
        Specified by:
        onEnded in interface controller.IWorkerStatusListener
      • onError

        public void onError​(int workerId,
                            java.lang.String errorMessage)
        Specified by:
        onError in interface controller.IWorkerStatusListener
      • onResult

        public void onResult​(int workerId,
                             worker.IProcessingResult processingResult)
        Specified by:
        onResult in interface controller.IWorkerStatusListener
      • saveServerMeasurements

        public void saveServerMeasurements​(long[] clients,
                                           long[] nRequests,
                                           long[] delta)
      • saveClientMeasurements

        public void saveClientMeasurements​(long[] latencies)