Class OpTrackerImpl<D>

java.lang.Object

io.nosqlbench.engine.api.activityapi.core.ops.fluent.OpTrackerImpl<D>

Type Parameters:

D - The payload data type of the associated Op, based on OpImpl

All Implemented Interfaces:

ActivityDefObserver, OpEvents<D>, OpTracker<D>

public class OpTrackerImpl<D>
extends Object
implements OpTracker<D>, ActivityDefObserver

This tracker keeps track of the state of operations associated with it.

Constructor Summary

Constructors

Constructor	Description
OpTrackerImpl(Activity activity, long slot)
OpTrackerImpl(String name, int slot, com.codahale.metrics.Timer cycleServiceTimer, com.codahale.metrics.Timer cycleResponseTimer, com.codahale.metrics.Counter pendingOpsCounter)

Method Summary

Modifier and Type	Method	Description
boolean	awaitCompletion(long timeout)
int	getMaxPendingOps()	The maximum pending ops determines how many ops an activity is allowed to have in flight at any one time.
int	getPendingOps()
boolean	isFull()
TrackedOp<D>	newOp(long cycle, OpEvents<D> strideTracker)
void	onActivityDefUpdate(ActivityDef activityDef)
void	onOpFailure(FailedOp<D> op)
void	onOpSkipped(SkippedOp<D> op)
void	onOpStarted(StartedOp<D> op)
void	onOpSuccess(SucceededOp<D> op)
void	setCycleOpFunction(LongFunction<D> newOpFunction)	The cycle op function is the function which can map a cycle number into an operation of some sort.
void	setMaxPendingOps(int maxPendingOps)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

OpTrackerImpl

public OpTrackerImpl(Activity activity,
 long slot)

OpTrackerImpl

public OpTrackerImpl(String name,
 int slot,
 com.codahale.metrics.Timer cycleServiceTimer,
 com.codahale.metrics.Timer cycleResponseTimer,
 com.codahale.metrics.Counter pendingOpsCounter)

Method Details

onOpStarted

public void onOpStarted(StartedOp<D> op)

Specified by:

onOpStarted in interface OpEvents<D>

onOpSuccess

public void onOpSuccess(SucceededOp<D> op)

Specified by:

onOpSuccess in interface OpEvents<D>

onOpSkipped

public void onOpSkipped(SkippedOp<D> op)

Specified by:

onOpSkipped in interface OpEvents<D>

onOpFailure

public void onOpFailure(FailedOp<D> op)

Specified by:

onOpFailure in interface OpEvents<D>

setMaxPendingOps

public void setMaxPendingOps(int maxPendingOps)

Specified by:

setMaxPendingOps in interface OpTracker<D>

isFull

public boolean isFull()

Specified by:

isFull in interface OpTracker<D>

getPendingOps

public int getPendingOps()

Specified by:

getPendingOps in interface OpTracker<D>

setCycleOpFunction

public void setCycleOpFunction(LongFunction<D> newOpFunction)

Description copied from interface: OpTracker

The cycle op function is the function which can map a cycle number into an operation of some sort.

Specified by:

setCycleOpFunction in interface OpTracker<D>

Parameters:

newOpFunction -

newOp

public TrackedOp<D> newOp(long cycle,
 OpEvents<D> strideTracker)

Specified by:

newOp in interface OpTracker<D>

getMaxPendingOps

public int getMaxPendingOps()

Description copied from interface: OpTracker

The maximum pending ops determines how many ops an activity is allowed to have in flight at any one time. When

Specified by:

getMaxPendingOps in interface OpTracker<D>

Returns:

awaitCompletion

public boolean awaitCompletion(long timeout)

Specified by:

awaitCompletion in interface OpTracker<D>

toString

public String toString()

Overrides:

toString in class Object

onActivityDefUpdate

public void onActivityDefUpdate(ActivityDef activityDef)

Specified by:

onActivityDefUpdate in interface ActivityDefObserver