Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Bump upstream SNAPSHOTS
[controller.git]
/
opendaylight
/
md-sal
/
sal-akka-raft-example
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
example
/
LogGenerator.java
diff --git
a/opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/LogGenerator.java
b/opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/LogGenerator.java
index 6ef8a07d9dfa9891c2c0805536be75be143c3415..9559f1cff422c75fc116ffbfa321338eda320175 100644
(file)
--- a/
opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/LogGenerator.java
+++ b/
opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/LogGenerator.java
@@
-35,8
+35,9
@@
public class LogGenerator {
}
public static class LoggingThread implements Runnable {
}
public static class LoggingThread implements Runnable {
-
+ private final Random random = new Random();
private final ActorRef clientActor;
private final ActorRef clientActor;
+
private volatile boolean stopLogging = false;
public LoggingThread(final ActorRef clientActor) {
private volatile boolean stopLogging = false;
public LoggingThread(final ActorRef clientActor) {
@@
-45,7
+46,6
@@
public class LogGenerator {
@Override
public void run() {
@Override
public void run() {
- Random random = new Random();
while (true) {
if (stopLogging) {
LOG.info("Logging stopped for client: {}", clientActor.path());
while (true) {
if (stopLogging) {
LOG.info("Logging stopped for client: {}", clientActor.path());