fix CheckedFutures deprecated warnings

[transportpce.git] / common / src / main / java / org / opendaylight / transportpce / common / network / RequestProcessor.java

diff --git a/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java b/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java
index f64c18195c6e51a8ebc7073372fe82fcbcb5c186..02d5a8644fb5a8b0964068bd4c181c437b9df945 100644 (file)
--- a/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java
+++ b/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java
@@ -8,7 +8,6 @@
 package org.opendaylight.transportpce.common.network;
 
 import com.google.common.base.Optional;
-import com.google.common.util.concurrent.CheckedFuture;
 import com.google.common.util.concurrent.ListenableFuture;
 
 import java.util.concurrent.locks.ReentrantReadWriteLock;
@@ -18,15 +17,12 @@ import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
 
 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
 
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
-
 public class RequestProcessor {
 
     private static final Logger LOG = LoggerFactory.getLogger(RequestProcessor.class);
@@ -47,12 +43,12 @@ public class RequestProcessor {
 
     }
 
-    public <T extends DataObject> CheckedFuture<Optional<T>,
-        ReadFailedException> read(LogicalDatastoreType store,InstanceIdentifier<T> path) {
+    public <T extends DataObject> ListenableFuture<Optional<T>>
+         read(LogicalDatastoreType store,InstanceIdentifier<T> path) {
 
-        CheckedFuture<Optional<T>, ReadFailedException> result = null;
+        ListenableFuture<Optional<T>> result = null;
         acquireReadLock();
-        LOG.debug("Number of threads in queue to read " + lock.getQueueLength());
+        LOG.debug("Number of threads in queue to read {}", lock.getQueueLength());
         result = rwTx.read(store, path);
 
         releaseReadLock();
@@ -62,7 +58,7 @@ public class RequestProcessor {
     public <T extends DataObject> void delete(LogicalDatastoreType store, InstanceIdentifier<?> path) {
 
         acquireLock();
-        LOG.info("Number of delete requests waiting in queue :" + lock.getQueueLength());
+        LOG.info("Number of delete requests waiting in queue :{}", lock.getQueueLength());
         rwTx.delete(store, path);
     }
 
@@ -70,7 +66,7 @@ public class RequestProcessor {
         InstanceIdentifier<T> path, T data, boolean createMissingParents) {
 
         acquireLock();
-        LOG.debug("Number of put requests waiting in queue :" + lock.getQueueLength());
+        LOG.debug("Number of put requests waiting in queue :{}", lock.getQueueLength());
         rwTx.put(store, path, data, createMissingParents);
     }
 
@@ -78,7 +74,7 @@ public class RequestProcessor {
         InstanceIdentifier<T> path, T data) {
 
         acquireLock();
-        LOG.debug("Number of put requests waiting in queue :" + lock.getQueueLength());
+        LOG.debug("Number of put requests waiting in queue :{}", lock.getQueueLength());
         rwTx.put(store, path, data);
     }
 
@@ -87,7 +83,7 @@ public class RequestProcessor {
         InstanceIdentifier<T> path, T data, boolean createMissingParents) {
 
         acquireLock();
-        LOG.debug("Number of merge requests waiting in queue :" + lock.getQueueLength());
+        LOG.debug("Number of merge requests waiting in queue :{}", lock.getQueueLength());
         rwTx.merge(store, path, data, createMissingParents);
     }
 
@@ -95,7 +91,7 @@ public class RequestProcessor {
         InstanceIdentifier<T> path, T data) {
 
         acquireLock();
-        LOG.debug("Number of merge requests waiting in queue :" + lock.getQueueLength());
+        LOG.debug("Number of merge requests waiting in queue :{}", lock.getQueueLength());
         rwTx.merge(store, path, data);
     }
 
@@ -115,33 +111,33 @@ public class RequestProcessor {
     private void acquireLock() {
         if (!lock.writeLock().isHeldByCurrentThread()) {
             lock.writeLock().lock();
-            LOG.debug("Number of write lock requests waiting in queue :" + lock.getQueueLength());
-            LOG.info("Write Lock acquired by : " + Thread.currentThread().getName());
+            LOG.debug("Number of write lock requests waiting in queue :{}", lock.getQueueLength());
+            LOG.info("Write Lock acquired by : {}", Thread.currentThread().getName());
             rwTx = resetRwTx();
         } else {
-            LOG.debug("Lock already acquired by : " + Thread.currentThread().getName());
+            LOG.debug("Lock already acquired by : {}", Thread.currentThread().getName());
         }
     }
 
     private void acquireReadLock() {
         if (lock.getReadHoldCount() > 0) {
-            LOG.info("Read Lock already acquired by : " + Thread.currentThread().getName());
+            LOG.info("Read Lock already acquired by : {}", Thread.currentThread().getName());
         } else {
             lock.readLock().lock();
             rwTx = resetRwTx();
-            LOG.info("Read Lock acquired by : " + Thread.currentThread().getName());
+            LOG.info("Read Lock acquired by : {}", Thread.currentThread().getName());
         }
     }
 
     private void releaseLock() {
         if (lock.writeLock().isHeldByCurrentThread()) {
-            LOG.info("Write Lock released by : " + Thread.currentThread().getName());
+            LOG.info("Write Lock released by : {}", Thread.currentThread().getName());
             lock.writeLock().unlock();
         }
     }
 
     private void releaseReadLock() {
-        LOG.info("Read Lock released by : " + Thread.currentThread().getName());
+        LOG.info("Read Lock released by : {}", Thread.currentThread().getName());
         lock.readLock().unlock();
     }