commit 2712419ddbc3139714849faef71e0c0d2e3b4d3e
author Sho SHIMIZU <sshimizu@us.fujitsu.com> Tue Aug 30 14:47:12 2016 -0700
committer Sho SHIMIZU <sshimizu@us.fujitsu.com> Wed Aug 31 07:31:15 2016 -0700
tree 31ad2b6436026c622d02ac5d17fd81dbbb480cba
parent b837cb72cf3910045504a32422d4d263ac2618a7

Use primitive boolean because of being synchronized already

Change-Id: Ie9d454fe03a92a9f865d45882de5749f55f2f2f9

core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java

diff --git a/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java b/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
index 2301505..2cebdd9 100644
--- a/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
+++ b/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
@@ -74,7 +74,6 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.concurrent.atomic.AtomicBoolean;
 
 import static com.google.common.base.Preconditions.checkNotNull;
 import static com.google.common.base.Strings.isNullOrEmpty;
@@ -598,7 +597,7 @@
         private final List<Set<FlowRuleOperation>> stages;
         private final FlowRuleOperationsContext context;
         private final FlowRuleOperations fops;
-        private final AtomicBoolean hasFailed = new AtomicBoolean(false);
+        private boolean hasFailed = false;
 
         private final Set<DeviceId> pendingDevices = new HashSet<>();
 
@@ -612,7 +611,7 @@
         public synchronized void run() {
             if (stages.size() > 0) {
                 process(stages.remove(0));
-            } else if (!hasFailed.get() && context != null) {
+            } else if (!hasFailed && context != null) {
                 context.onSuccess(fops);
             }
         }
@@ -664,7 +663,7 @@
 
 
         synchronized void fail(DeviceId devId, Set<? extends FlowRule> failures) {
-            hasFailed.set(true);
+            hasFailed = true;
             pendingDevices.remove(devId);
             if (pendingDevices.isEmpty()) {
                 operationsService.execute(this);