com.cloudtran.jmx
Class ClientTimes

java.lang.Object
  extended by javax.management.StandardMBean
      extended by com.cloudtran.jmx.AbstractMBean
          extended by com.cloudtran.jmx.ClientTimes
All Implemented Interfaces:
ClientTimesData, ClientTimesMBean, DynamicMBean, MBeanRegistration

public class ClientTimes
extends AbstractMBean
implements ClientTimesMBean


Field Summary
static AtomicLong commitCount
           
static AtomicLong numberOfIterationsDoneSoFar
           
static AtomicInteger numberOfThreadsRunning
           
static AtomicInteger numberOfThreadsWaitingToRun
           
static AtomicLong saveCount
           
static AtomicLong startCount
           
static long waitTimeBeforeTxStart
           
 
Constructor Summary
ClientTimes()
           
 
Method Summary
 long getCommitPerSec()
           
 int getNumberOfIterations()
           
 long getNumberOfIterationsDoneSoFar()
           
 int getNumberOfThreadsAllowedToRun()
           
static void getPermitToContinue()
           
 long getSavePerSec()
           
 long getStartPerSec()
           
 String getThreadStateInfo()
           
 long getTxCommited()
           
 String restartTest()
           
 void setNumberOfIterations(int newValue)
           
 void setNumberOfThreadsAllowedToRun(int newValue)
           
static void signalRunning(boolean waited)
           
static void signalWaitingToRun(boolean signaledRunning)
           
static void signalWorkerThreadReadyToFinsih()
           
static void signalWorkerThreadReseted()
           
 void startThreads()
           
 void stopAllThreads()
           
 
Methods inherited from class javax.management.StandardMBean
getAttribute, getAttributes, getImplementation, getImplementationClass, getMBeanInfo, getMBeanInterface, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

startCount

public static AtomicLong startCount

saveCount

public static AtomicLong saveCount

commitCount

public static AtomicLong commitCount

numberOfIterationsDoneSoFar

public static AtomicLong numberOfIterationsDoneSoFar

waitTimeBeforeTxStart

public static volatile long waitTimeBeforeTxStart

numberOfThreadsWaitingToRun

public static final AtomicInteger numberOfThreadsWaitingToRun

numberOfThreadsRunning

public static final AtomicInteger numberOfThreadsRunning
Constructor Detail

ClientTimes

public ClientTimes()
            throws NotCompliantMBeanException
Throws:
NotCompliantMBeanException
Method Detail

signalWaitingToRun

public static void signalWaitingToRun(boolean signaledRunning)

signalRunning

public static void signalRunning(boolean waited)

signalWorkerThreadReseted

public static void signalWorkerThreadReseted()

signalWorkerThreadReadyToFinsih

public static void signalWorkerThreadReadyToFinsih()

getCommitPerSec

public long getCommitPerSec()
Specified by:
getCommitPerSec in interface ClientTimesData

getSavePerSec

public long getSavePerSec()
Specified by:
getSavePerSec in interface ClientTimesData

getStartPerSec

public long getStartPerSec()
Specified by:
getStartPerSec in interface ClientTimesData

getTxCommited

public long getTxCommited()
Specified by:
getTxCommited in interface ClientTimesData

getNumberOfThreadsAllowedToRun

public int getNumberOfThreadsAllowedToRun()
Specified by:
getNumberOfThreadsAllowedToRun in interface ClientTimesMBean

setNumberOfThreadsAllowedToRun

public void setNumberOfThreadsAllowedToRun(int newValue)
Specified by:
setNumberOfThreadsAllowedToRun in interface ClientTimesMBean

getNumberOfIterations

public int getNumberOfIterations()
Specified by:
getNumberOfIterations in interface ClientTimesMBean

setNumberOfIterations

public void setNumberOfIterations(int newValue)
Specified by:
setNumberOfIterations in interface ClientTimesMBean

startThreads

public void startThreads()
Specified by:
startThreads in interface ClientTimesMBean

stopAllThreads

public void stopAllThreads()
Specified by:
stopAllThreads in interface ClientTimesMBean

getNumberOfIterationsDoneSoFar

public long getNumberOfIterationsDoneSoFar()
Specified by:
getNumberOfIterationsDoneSoFar in interface ClientTimesMBean

getPermitToContinue

public static void getPermitToContinue()
                                throws InterruptedException
Throws:
InterruptedException

restartTest

public String restartTest()
Specified by:
restartTest in interface ClientTimesMBean

getThreadStateInfo

public String getThreadStateInfo()
Specified by:
getThreadStateInfo in interface ClientTimesMBean