commit de46fbde374c2cf92a93cef7fe376f4220d77e06
author Andrea Campanella <andrea@opennetworking.org> Thu Mar 08 08:23:32 2018 -0800
committer Ray Milkey <ray@opennetworking.org> Thu Mar 08 17:27:31 2018 +0000
tree afd692c633e2e229643102d749952345b6884688
parent 2ff88a9a089f1ee53b441cec0c00b111b17d401e

T3 fixing sonar problems

Change-Id: I6d9985eb19928dc5e090d3de7619ccb4441dc7f2

src/main/java/org/onosproject/t3/impl/Generator.java

diff --git a/src/main/java/org/onosproject/t3/impl/Generator.java b/src/main/java/org/onosproject/t3/impl/Generator.java
index 1f6bf22..95e4d4e 100644
--- a/src/main/java/org/onosproject/t3/impl/Generator.java
+++ b/src/main/java/org/onosproject/t3/impl/Generator.java
@@ -31,15 +31,19 @@
 
         synchronized void set() {
             isSet = true;
-            notify();
+            notifyAll();
         }
 
         synchronized void await() throws InterruptedException {
             try {
+
                 if (isSet) {
                     return;
                 }
-                wait();
+
+                while (!isSet) {
+                    wait();
+                }
             } finally {
                 isSet = false;
             }
@@ -113,8 +117,10 @@
 
     private void startProducer() {
         assert producer == null;
-        if (threadGroup == null) {
-            threadGroup = new ThreadGroup("onos-t3-generator");
+        synchronized (this) {
+            if (threadGroup == null) {
+                threadGroup = new ThreadGroup("onos-t3-generator");
+            }
         }
         producer = new Thread(threadGroup, () -> {
             try {