/**
* TransactionRateLimitingCallback computes the new transaction rate limit on the successful completion of a
- * transaction
+ * transaction.
*/
-public class TransactionRateLimitingCallback implements OperationCallback{
+public class TransactionRateLimitingCallback implements OperationCallback {
private static Ticker TICKER = Ticker.systemTicker();
private enum State {
private long elapsedTime;
private volatile State state = State.STOPPED;
- TransactionRateLimitingCallback(ActorContext actorContext){
+ TransactionRateLimitingCallback(ActorContext actorContext) {
commitTimer = actorContext.getOperationTimer(ActorContext.COMMIT);
}
@Override
public void pause() {
- if(state == State.RUNNING) {
+ if (state == State.RUNNING) {
elapsedTime += TICKER.read() - startTime;
state = State.PAUSED;
}
@Override
public void resume() {
- if(state != State.RUNNING) {
+ if (state != State.RUNNING) {
startTime = TICKER.read();
state = State.RUNNING;
}
static void setTicker(Ticker ticker) {
TICKER = ticker;
}
-}
\ No newline at end of file
+}