*/
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);
}
*/
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;
private final RpcContext rpcContext;
private SettableFuture<RpcResult<T>> rpcResultFuture;
+ private long waitTimeout;
+ private Xid xid;
public RequestContextImpl(RpcContext rpcContext) {
this.rpcContext = rpcContext;
}
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;
+ }
}