Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
sal-distributed-datastore: use lambdas
[controller.git]
/
opendaylight
/
md-sal
/
sal-distributed-datastore
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
datastore
/
TransactionRateLimitingCallback.java
diff --git
a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionRateLimitingCallback.java
b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionRateLimitingCallback.java
index 8ba2cb9ad936d8636c0b60bf6e40db0493d842d0..f35e30a06ccb1c8a95b4ff843ac22abedc21d168 100644
(file)
--- a/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionRateLimitingCallback.java
+++ b/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionRateLimitingCallback.java
@@
-17,12
+17,12
@@
import org.opendaylight.controller.cluster.datastore.utils.ActorContext;
/**
* TransactionRateLimitingCallback computes the new transaction rate limit on the successful completion of a
/**
* 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 static Ticker TICKER = Ticker.systemTicker();
- private
static
enum State {
+ private enum State {
STOPPED,
RUNNING,
PAUSED
STOPPED,
RUNNING,
PAUSED
@@
-33,7
+33,7
@@
public class TransactionRateLimitingCallback implements OperationCallback{
private long elapsedTime;
private volatile State state = State.STOPPED;
private long elapsedTime;
private volatile State state = State.STOPPED;
- TransactionRateLimitingCallback(ActorContext actorContext){
+ TransactionRateLimitingCallback(ActorContext actorContext)
{
commitTimer = actorContext.getOperationTimer(ActorContext.COMMIT);
}
commitTimer = actorContext.getOperationTimer(ActorContext.COMMIT);
}
@@
-45,7
+45,7
@@
public class TransactionRateLimitingCallback implements OperationCallback{
@Override
public void pause() {
@Override
public void pause() {
- if(state == State.RUNNING) {
+ if
(state == State.RUNNING) {
elapsedTime += TICKER.read() - startTime;
state = State.PAUSED;
}
elapsedTime += TICKER.read() - startTime;
state = State.PAUSED;
}
@@
-53,7
+53,7
@@
public class TransactionRateLimitingCallback implements OperationCallback{
@Override
public void resume() {
@Override
public void resume() {
- if(state != State.RUNNING) {
+ if
(state != State.RUNNING) {
startTime = TICKER.read();
state = State.RUNNING;
}
startTime = TICKER.read();
state = State.RUNNING;
}
@@
-78,4
+78,4
@@
public class TransactionRateLimitingCallback implements OperationCallback{
static void setTicker(Ticker ticker) {
TICKER = ticker;
}
static void setTicker(Ticker ticker) {
TICKER = ticker;
}
-}
\ No newline at end of file
+}