Package org.opendaylight.ovsdb.hwvtepsouthbound.transact

Class AbstractTransactCommand<T extends org.opendaylight.yangtools.yang.binding.Identifiable<I> & org.opendaylight.yangtools.yang.binding.DataObject,I extends org.opendaylight.yangtools.yang.binding.Identifier<T>,A extends org.opendaylight.yangtools.yang.binding.Augmentation<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>>

java.lang.Object

org.opendaylight.ovsdb.hwvtepsouthbound.transact.AbstractTransactCommand<T,I,A>

All Implemented Interfaces:

TransactCommand<T>

Direct Known Subclasses:

LogicalRouterRemoveCommand, LogicalRouterUpdateCommand, LogicalSwitchRemoveCommand, LogicalSwitchUcastsRemoveCommand, LogicalSwitchUpdateCommand, McastMacsLocalRemoveCommand, McastMacsLocalUpdateCommand, McastMacsRemoteRemoveCommand, McastMacsRemoteUpdateCommand, PhysicalPortRemoveCommand, PhysicalPortUpdateCommand, PhysicalSwitchRemoveCommand, PhysicalSwitchUpdateCommand, PlainLogicalSwitchRemoveCmd, TunnelRemoveCommand, TunnelUpdateCommand, UcastMacsLocalRemoveCommand, UcastMacsLocalUpdateCommand, UcastMacsRemoteRemoveCommand, UcastMacsRemoteUpdateCommand

public abstract class AbstractTransactCommand<T extends org.opendaylight.yangtools.yang.binding.Identifiable<I> & org.opendaylight.yangtools.yang.binding.DataObject,I extends org.opendaylight.yangtools.yang.binding.Identifier<T>,A extends org.opendaylight.yangtools.yang.binding.Augmentation<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>>
extends Object
implements TransactCommand<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected TransactionBuilder	deviceTransaction
protected HwvtepOperationalState	hwvtepOperationalState
protected static UUID	TXUUID

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractTransactCommand()
	AbstractTransactCommand(HwvtepOperationalState state, Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> changes)

Method Summary

Modifier and Type	Method	Description
<K extends org.opendaylight.yangtools.yang.binding.Identifiable> void	addJobToQueue(DependentJob<K> job)
protected boolean	areEqual(T obj1, T obj2)
protected A	augmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node node)
protected boolean	cascadeDelete()	Tells if this object needs to be deleted if its dependent object gets deleted Ex : LocalUcastMac and LocalMacstMac.
void	clearConfigData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls, org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)
void	doDeviceTransaction(TransactionBuilder transaction, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> nodeIid, T data, org.opendaylight.yangtools.yang.binding.InstanceIdentifier key, Object... extraData)
protected @NonNull Map<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>,List<T>>	extractRemoved(Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> modification, Class<T> class1)
protected @NonNull Map<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>,List<T>>	extractUpdated(Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> modification, Class<T> class1)
<T> HwvtepDeviceInfo.DeviceData	fetchDeviceData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls, org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)
Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>>	getChanges()
protected Type	getClassType()
AbstractTransactCommand	getClone()
HwvtepDeviceInfo.DeviceData	getConfigData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls, org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)
HwvtepConnectionInstance	getConnectionInstance()
protected Map<I,T>	getData(A augmentation)
protected List<T>	getData(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node node)
org.opendaylight.mdsal.binding.api.DataBroker	getDataBroker()
protected UnMetDependencyGetter<T>	getDependencyGetter()
protected HwvtepDeviceInfo	getDeviceInfo()
HwvtepDeviceInfo.DeviceData	getDeviceOpData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls, org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)
protected TransactionBuilder	getDeviceTransaction()
protected String	getKeyStr(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> iid)
protected String	getLsKeyStr(org.opendaylight.yangtools.yang.binding.InstanceIdentifier iid)
protected String	getNodeKeyStr(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> iid)
HwvtepOperationalState	getOperationalState()
HwvtepTableReader	getTableReader()
protected boolean	isDeleteCmd()
void	markKeyAsInTransit(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls, org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)
HwvtepOperationalState	newOperState()
protected void	onCommandFailed()
protected void	onCommandSucceeded()
void	onConfigUpdate(TransactionBuilder transaction, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> nodeIid, T data, org.opendaylight.yangtools.yang.binding.InstanceIdentifier key, Object... extraData)
void	onFailure(TransactionBuilder deviceTx)
void	onSuccess(TransactionBuilder deviceTx)
void	updateConfigData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls, org.opendaylight.yangtools.yang.binding.InstanceIdentifier key, Object data)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.opendaylight.ovsdb.hwvtepsouthbound.transact.TransactCommand

execute, retry

Field Detail

TXUUID

protected static final UUID TXUUID

hwvtepOperationalState

protected volatile HwvtepOperationalState hwvtepOperationalState

deviceTransaction

protected volatile TransactionBuilder deviceTransaction

Constructor Detail

AbstractTransactCommand

protected AbstractTransactCommand()

AbstractTransactCommand

public AbstractTransactCommand(HwvtepOperationalState state,
                               Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> changes)

Method Detail

getOperationalState

public HwvtepOperationalState getOperationalState()

getDataBroker

public org.opendaylight.mdsal.binding.api.DataBroker getDataBroker()

getChanges

public Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> getChanges()

doDeviceTransaction

public void doDeviceTransaction(TransactionBuilder transaction,
                                org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> nodeIid,
                                T data,
                                org.opendaylight.yangtools.yang.binding.InstanceIdentifier key,
                                Object... extraData)

Specified by:

doDeviceTransaction in interface TransactCommand<T extends org.opendaylight.yangtools.yang.binding.Identifiable<I> & org.opendaylight.yangtools.yang.binding.DataObject>

onConfigUpdate

public void onConfigUpdate(TransactionBuilder transaction,
                           org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> nodeIid,
                           T data,
                           org.opendaylight.yangtools.yang.binding.InstanceIdentifier key,
                           Object... extraData)

Specified by:

onConfigUpdate in interface TransactCommand<T extends org.opendaylight.yangtools.yang.binding.Identifiable<I> & org.opendaylight.yangtools.yang.binding.DataObject>

augmentation

protected A augmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node node)

getData

protected Map<I,T> getData(A augmentation)

getData

protected List<T> getData(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node node)

extractRemoved

protected @NonNull Map<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>,List<T>> extractRemoved(Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> modification,
                                                                                                                                                                                                                                   Class<T> class1)

extractUpdated

protected @NonNull Map<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>,List<T>> extractUpdated(Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> modification,
                                                                                                                                                                                                                                   Class<T> class1)

getClassType

protected Type getClassType()

areEqual

protected boolean areEqual(T obj1,
                           T obj2)

getDependencyGetter

protected UnMetDependencyGetter<T> getDependencyGetter()

cascadeDelete

protected boolean cascadeDelete()

Tells if this object needs to be deleted if its dependent object gets deleted Ex : LocalUcastMac and LocalMacstMac.

Returns:

true if this object needs to be deleted if its dependent object gets deleted

isDeleteCmd

protected boolean isDeleteCmd()

getDeviceInfo

protected HwvtepDeviceInfo getDeviceInfo()

getDeviceTransaction

protected TransactionBuilder getDeviceTransaction()

onSuccess

public void onSuccess(TransactionBuilder deviceTx)

Specified by:

onSuccess in interface TransactCommand<T extends org.opendaylight.yangtools.yang.binding.Identifiable<I> & org.opendaylight.yangtools.yang.binding.DataObject>

onFailure

public void onFailure(TransactionBuilder deviceTx)

Specified by:

onFailure in interface TransactCommand<T extends org.opendaylight.yangtools.yang.binding.Identifiable<I> & org.opendaylight.yangtools.yang.binding.DataObject>

onCommandSucceeded

protected void onCommandSucceeded()

onCommandFailed

protected void onCommandFailed()

fetchDeviceData

public <T> HwvtepDeviceInfo.DeviceData fetchDeviceData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls,
                                                       org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)

addJobToQueue

public <K extends org.opendaylight.yangtools.yang.binding.Identifiable> void addJobToQueue(DependentJob<K> job)

markKeyAsInTransit

public void markKeyAsInTransit(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls,
                               org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)

getDeviceOpData

public HwvtepDeviceInfo.DeviceData getDeviceOpData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls,
                                                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)

clearConfigData

public void clearConfigData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls,
                            org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)

getConfigData

public HwvtepDeviceInfo.DeviceData getConfigData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls,
                                                 org.opendaylight.yangtools.yang.binding.InstanceIdentifier key)

updateConfigData

public void updateConfigData(Class<? extends org.opendaylight.yangtools.yang.binding.Identifiable> cls,
                             org.opendaylight.yangtools.yang.binding.InstanceIdentifier key,
                             Object data)

getClone

public AbstractTransactCommand getClone()

getTableReader

public HwvtepTableReader getTableReader()

getConnectionInstance

public HwvtepConnectionInstance getConnectionInstance()

newOperState

public HwvtepOperationalState newOperState()

getNodeKeyStr

protected String getNodeKeyStr(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> iid)

getKeyStr

protected String getKeyStr(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> iid)

getLsKeyStr

protected String getLsKeyStr(org.opendaylight.yangtools.yang.binding.InstanceIdentifier iid)