Code Review
/
dmaap
/
datarouter.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
FINAL unit test covergae commit
[dmaap/datarouter.git]
/
datarouter-node
/
src
/
main
/
java
/
org
/
onap
/
dmaap
/
datarouter
/
node
/
RateLimitedOperation.java
diff --git
a/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/RateLimitedOperation.java
b/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/RateLimitedOperation.java
index
94b694d
..
0270455
100644
(file)
--- a/
datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/RateLimitedOperation.java
+++ b/
datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/RateLimitedOperation.java
@@
-28,7
+28,7
@@
import java.util.Timer;
import java.util.TimerTask;
/**
import java.util.TimerTask;
/**
- * Execute an operation no more frequently than a specified interval
+ * Execute an operation no more frequently than a specified interval
.
*/
public abstract class RateLimitedOperation implements Runnable {
*/
public abstract class RateLimitedOperation implements Runnable {
@@
-41,10
+41,10
@@
public abstract class RateLimitedOperation implements Runnable {
private long mininterval;
/**
private long mininterval;
/**
- * Create a rate limited operation
+ * Create a rate limited operation
.
*
* @param mininterval The minimum number of milliseconds after the last execution starts before a new execution can
*
* @param mininterval The minimum number of milliseconds after the last execution starts before a new execution can
- * begin
+ *
begin
* @param timer The timer used to perform deferred executions
*/
public RateLimitedOperation(long mininterval, Timer timer) {
* @param timer The timer used to perform deferred executions
*/
public RateLimitedOperation(long mininterval, Timer timer) {
@@
-53,7
+53,7
@@
public abstract class RateLimitedOperation implements Runnable {
}
/**
}
/**
- * Request that the operation be performed by this thread or at a later time by the timer
+ * Request that the operation be performed by this thread or at a later time by the timer
.
*/
public void request() {
if (premark()) {
*/
public void request() {
if (premark()) {
@@
-61,7
+61,8
@@
public abstract class RateLimitedOperation implements Runnable {
}
do {
run();
}
do {
run();
- } while (demark());
+ }
+ while (demark());
}
private synchronized boolean premark() {
}
private synchronized boolean premark() {