Bug-5644: Fix checkstyle invocation for l2switch builds

[l2switch.git] / hosttracker / implementation / src / main / java / org / opendaylight / l2switch / hosttracker / plugin / internal / OperationProcessor.java

diff --git a/hosttracker/implementation/src/main/java/org/opendaylight/l2switch/hosttracker/plugin/internal/OperationProcessor.java b/hosttracker/implementation/src/main/java/org/opendaylight/l2switch/hosttracker/plugin/internal/OperationProcessor.java
index e8f380fe2077f93039be6ac811316b66c0bb8a42..56fb4bf1b4ad6f553951e8ebb2c5a2df4c3d65ef 100644 (file)
--- a/hosttracker/implementation/src/main/java/org/opendaylight/l2switch/hosttracker/plugin/internal/OperationProcessor.java
+++ b/hosttracker/implementation/src/main/java/org/opendaylight/l2switch/hosttracker/plugin/internal/OperationProcessor.java
@@ -7,9 +7,11 @@
  */
 package org.opendaylight.l2switch.hosttracker.plugin.internal;
 
+import com.google.common.base.Preconditions;
+import com.google.common.util.concurrent.FutureCallback;
+import com.google.common.util.concurrent.Futures;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
-
 import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain;
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
@@ -20,18 +22,12 @@ import org.opendaylight.controller.md.sal.common.api.data.TransactionChainListen
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.google.common.base.Preconditions;
-import com.google.common.util.concurrent.FutureCallback;
-import com.google.common.util.concurrent.Futures;
-
-public class OperationProcessor implements AutoCloseable, Runnable,
-        TransactionChainListener {
+public class OperationProcessor implements AutoCloseable, Runnable, TransactionChainListener {
     private static final int NUM_RETRY_SUBMIT = 2;
     private static final int OPS_PER_CHAIN = 256;
     private static final int QUEUE_DEPTH = 512;
 
-    private static final Logger log = LoggerFactory
-            .getLogger(OperationProcessor.class);
+    private static final Logger LOG = LoggerFactory.getLogger(OperationProcessor.class);
     private final DataBroker dataBroker;
     private final BlockingQueue<HostTrackerOperation> queue;
     private BindingTransactionChain transactionChain;
@@ -43,8 +39,8 @@ public class OperationProcessor implements AutoCloseable, Runnable,
     }
 
     @Override
-    public void onTransactionChainFailed(TransactionChain<?, ?> chain,
-            AsyncTransaction<?, ?> transaction, Throwable cause) {
+    public void onTransactionChainFailed(TransactionChain<?, ?> chain, AsyncTransaction<?, ?> transaction,
+            Throwable cause) {
         chainFailure();
     }
 
@@ -58,8 +54,7 @@ public class OperationProcessor implements AutoCloseable, Runnable,
         while (!done) {
             try {
                 HostTrackerOperation op = queue.take();
-                ReadWriteTransaction tx = transactionChain
-                        .newReadWriteTransaction();
+                ReadWriteTransaction tx = transactionChain.newReadWriteTransaction();
 
                 int ops = 0;
                 while ((op != null) && (ops < OPS_PER_CHAIN)) {
@@ -84,16 +79,16 @@ public class OperationProcessor implements AutoCloseable, Runnable,
     }
 
     private void chainFailure() {
-        try{
+        try {
             transactionChain.close();
             transactionChain = dataBroker.createTransactionChain(this);
             clearQueue();
-        }catch(IllegalStateException e){
-            log.warn(e.getLocalizedMessage());
+        } catch (IllegalStateException e) {
+            LOG.warn(e.getLocalizedMessage());
         }
     }
 
-    public void enqueueOperation(HostTrackerOperation op){
+    public void enqueueOperation(HostTrackerOperation op) {
         try {
             queue.put(op);
         } catch (InterruptedException e) {
@@ -104,24 +99,24 @@ public class OperationProcessor implements AutoCloseable, Runnable,
     public void submitTransaction(final ReadWriteTransaction tx, final int tries) {
         Futures.addCallback(tx.submit(), new FutureCallback<Object>() {
             public void onSuccess(Object o) {
-                log.trace("tx {} succeeded", tx.getIdentifier());
+                LOG.trace("tx {} succeeded", tx.getIdentifier());
             }
 
             public void onFailure(Throwable t) {
                 if (t instanceof OptimisticLockFailedException) {
                     if ((tries - 1) > 0) {
-                        log.warn("tx {} failed, retrying", tx.getIdentifier());
+                        LOG.warn("tx {} failed, retrying", tx.getIdentifier());
                         // do retry
                         submitTransaction(tx, tries - 1);
                     } else {
-                        log.warn("tx {} failed, out of retries", tx.getIdentifier());
+                        LOG.warn("tx {} failed, out of retries", tx.getIdentifier());
                         // out of retries
                         chainFailure();
                     }
                 } else {
                     // failed due to another type of
                     // TransactionCommitFailedException.
-                    log.warn("tx {} failed: {}", t.getMessage());
+                    LOG.warn("tx {} failed: {}", tx.getIdentifier(), t.getMessage());
                     chainFailure();
                 }
             }