Added Xid and waitTimeout getter and setter. 40/17240/3
authorJozef Gloncak <jgloncak@cisco.com>
Fri, 27 Mar 2015 14:27:16 +0000 (15:27 +0100)
committermichal rehak <mirehak@cisco.com>
Tue, 31 Mar 2015 10:51:23 +0000 (10:51 +0000)
Getter and setter methods for Xid and waitTimout fields
were added to interface RequestContext .

Change-Id: I85cc92f6729aac37b3a2e1cba51a67e08f3a2026
Signed-off-by: Jozef Gloncak <jgloncak@cisco.com>
openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/RequestContext.java
openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/rpc/RequestContextImpl.java

index 8d9664b3d973871e0762b59d9eae2576490ebd10..2122997a729567c3d8784d2e7ad831dae33525f8 100644 (file)
@@ -18,8 +18,29 @@ import org.opendaylight.yangtools.yang.binding.DataObject;
  */
 public interface RequestContext<T extends DataObject> extends RequestFutureContext<T>, AutoCloseable {
 
-    @Override
-    void close();
+    /**
+     * Returns xid generated for this request.
+     * @return
+     */
+    Xid getXid();
 
+    /**
+     * Sets xid generated for this request.
+     * @return
+     */
+    void setXid(Xid xid);
+
+    /**
+     * Returns request timeout value.
+     * @return
+     */
+    long getWaitTimeout();
+
+
+    /**
+     * Sets request timeout value.
+     * @return
+     */
+    void setWaitTimeout(long waitTimeout);
 
 }
index d8237c90c26ec845f3a17811c582740206b5ee0b..2f51384c1307a484e049393ee0e492b0cd871978 100644 (file)
@@ -7,6 +7,8 @@
  */
 package org.opendaylight.openflowplugin.impl.rpc;
 
+import org.opendaylight.openflowplugin.api.openflow.device.Xid;
+
 import com.google.common.util.concurrent.SettableFuture;
 import org.opendaylight.openflowplugin.api.openflow.device.RequestContext;
 import org.opendaylight.openflowplugin.api.openflow.rpc.RpcContext;
@@ -20,6 +22,8 @@ public class RequestContextImpl<T extends DataObject> implements RequestContext<
 
     private final RpcContext rpcContext;
     private SettableFuture<RpcResult<T>> rpcResultFuture;
+    private long waitTimeout;
+    private Xid xid;
 
     public RequestContextImpl(RpcContext rpcContext) {
         this.rpcContext = rpcContext;
@@ -37,4 +41,24 @@ public class RequestContextImpl<T extends DataObject> implements RequestContext<
         }
         return rpcResultFuture;
     }
+
+    @Override
+    public Xid getXid() {
+        return xid;
+    }
+
+    @Override
+    public void setXid(Xid xid) {
+        this.xid = xid;
+    }
+
+    @Override
+    public long getWaitTimeout() {
+        return waitTimeout;
+    }
+
+    @Override
+    public void setWaitTimeout(long waitTimeout) {
+        this.waitTimeout = waitTimeout;
+    }
 }