Class BatchedTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
- java.lang.Object
-
- org.opendaylight.netvirt.elan.l2gw.ha.BatchedTransaction<D>
-
- All Implemented Interfaces:
org.opendaylight.mdsal.binding.api.Transaction
,org.opendaylight.mdsal.binding.util.TypedReadTransaction<D>
,org.opendaylight.mdsal.binding.util.TypedReadWriteTransaction<D>
,org.opendaylight.mdsal.binding.util.TypedWriteTransaction<D>
,org.opendaylight.yangtools.concepts.Identifiable<java.lang.Object>
public class BatchedTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore> extends java.lang.Object implements org.opendaylight.mdsal.binding.util.TypedReadWriteTransaction<D>
-
-
Constructor Summary
Constructors Constructor Description BatchedTransaction(java.lang.Class<D> logicalDatastoreType)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static boolean
addCallbackIfInProgress(org.opendaylight.mdsal.common.api.LogicalDatastoreType logicalDatastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, java.lang.Runnable runnable)
void
delete(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> instanceIdentifier)
<T extends @NonNull org.opendaylight.yangtools.yang.binding.DataObject>
com.google.common.util.concurrent.FluentFuture<org.opendaylight.mdsal.binding.api.query.QueryResult<T>>execute(org.opendaylight.mdsal.binding.api.query.QueryExpression<T> query)
com.google.common.util.concurrent.FluentFuture<java.lang.Boolean>
exists(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> path)
com.google.common.util.concurrent.ListenableFuture<java.lang.Void>
getFt(org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier)
java.lang.Object
getIdentifier()
com.google.common.util.concurrent.ListenableFuture<java.lang.Void>
getResult()
org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId
getSrcNodeId()
static boolean
isInProgress(org.opendaylight.mdsal.common.api.LogicalDatastoreType logicalDatastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier)
static <D extends org.opendaylight.mdsal.binding.util.Datastore>
voidmarkUpdateInProgress(java.lang.Class<D> type, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, com.google.common.util.concurrent.ListenableFuture<java.lang.Void> ft)
static <D extends org.opendaylight.mdsal.binding.util.Datastore>
voidmarkUpdateInProgress(java.lang.Class<D> type, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, com.google.common.util.concurrent.ListenableFuture<java.lang.Void> ft, java.lang.String desc)
<T extends org.opendaylight.yangtools.yang.binding.DataObject>
voidmerge(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier, T dataObj)
<T extends org.opendaylight.yangtools.yang.binding.DataObject>
voidmergeParentStructureMerge(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> path, T data)
<T extends org.opendaylight.yangtools.yang.binding.DataObject>
voidmergeParentStructurePut(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> path, T data)
<T extends org.opendaylight.yangtools.yang.binding.DataObject>
voidput(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier, T dataObj)
<T extends org.opendaylight.yangtools.yang.binding.DataObject>
com.google.common.util.concurrent.FluentFuture<java.util.Optional<T>>read(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier)
void
setSrcNodeId(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId srcNodeId)
com.google.common.util.concurrent.ListenableFuture<java.lang.Void>
submit()
boolean
updateMetric()
void
updateMetric(java.lang.Boolean update)
void
waitForCompletion()
-
-
-
Constructor Detail
-
BatchedTransaction
public BatchedTransaction(java.lang.Class<D> logicalDatastoreType)
-
-
Method Detail
-
getResult
public com.google.common.util.concurrent.ListenableFuture<java.lang.Void> getResult()
-
read
public <T extends org.opendaylight.yangtools.yang.binding.DataObject> com.google.common.util.concurrent.FluentFuture<java.util.Optional<T>> read(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier)
- Specified by:
read
in interfaceorg.opendaylight.mdsal.binding.util.TypedReadTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
exists
public com.google.common.util.concurrent.FluentFuture<java.lang.Boolean> exists(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> path)
- Specified by:
exists
in interfaceorg.opendaylight.mdsal.binding.util.TypedReadTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
markUpdateInProgress
public static <D extends org.opendaylight.mdsal.binding.util.Datastore> void markUpdateInProgress(java.lang.Class<D> type, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, com.google.common.util.concurrent.ListenableFuture<java.lang.Void> ft)
-
markUpdateInProgress
public static <D extends org.opendaylight.mdsal.binding.util.Datastore> void markUpdateInProgress(java.lang.Class<D> type, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, com.google.common.util.concurrent.ListenableFuture<java.lang.Void> ft, java.lang.String desc)
-
isInProgress
public static boolean isInProgress(org.opendaylight.mdsal.common.api.LogicalDatastoreType logicalDatastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier)
-
addCallbackIfInProgress
public static boolean addCallbackIfInProgress(org.opendaylight.mdsal.common.api.LogicalDatastoreType logicalDatastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, java.lang.Runnable runnable)
-
waitForCompletion
public void waitForCompletion()
-
put
public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void put(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier, T dataObj)
- Specified by:
put
in interfaceorg.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
mergeParentStructurePut
public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void mergeParentStructurePut(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> path, T data)
- Specified by:
mergeParentStructurePut
in interfaceorg.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
merge
public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void merge(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier, T dataObj)
- Specified by:
merge
in interfaceorg.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
mergeParentStructureMerge
public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void mergeParentStructureMerge(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> path, T data)
- Specified by:
mergeParentStructureMerge
in interfaceorg.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
getFt
public com.google.common.util.concurrent.ListenableFuture<java.lang.Void> getFt(org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier)
-
delete
public void delete(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> instanceIdentifier)
- Specified by:
delete
in interfaceorg.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
submit
public com.google.common.util.concurrent.ListenableFuture<java.lang.Void> submit()
-
getIdentifier
public java.lang.Object getIdentifier()
- Specified by:
getIdentifier
in interfaceorg.opendaylight.yangtools.concepts.Identifiable<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
setSrcNodeId
public void setSrcNodeId(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId srcNodeId)
-
getSrcNodeId
public org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId getSrcNodeId()
-
updateMetric
public boolean updateMetric()
-
updateMetric
public void updateMetric(java.lang.Boolean update)
-
execute
public <T extends @NonNull org.opendaylight.yangtools.yang.binding.DataObject> com.google.common.util.concurrent.FluentFuture<org.opendaylight.mdsal.binding.api.query.QueryResult<T>> execute(org.opendaylight.mdsal.binding.api.query.QueryExpression<T> query)
- Specified by:
execute
in interfaceorg.opendaylight.mdsal.binding.util.TypedReadTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
-
-