org.opendaylight.ovsdb.southbound

Class OvsdbConnectionInstance

java.lang.Object

org.opendaylight.ovsdb.southbound.OvsdbConnectionInstance

public class OvsdbConnectionInstance
extends Object

Method Summary

Modifier and Type	Method and Description
void	cancelMonitor(MonitorHandle handler)
void	closeDeviceOwnershipCandidateRegistration()
void	createTransactInvokers()
<T extends TypedBaseTable<?>> T	createTypedRowWrapper(Class<T> klazz)
<T extends TypedBaseTable<?>> T	createTypedRowWrapper(DatabaseSchema dbSchema, Class<T> klazz)
void	disconnect()
org.opendaylight.controller.md.sal.common.api.clustering.Entity	getConnectedEntity()
OvsdbConnectionInfo	getConnectionInfo()
com.google.common.util.concurrent.ListenableFuture<List<String>>	getDatabases()
DatabaseSchema	getDatabaseSchema(String dbName)
Boolean	getHasDeviceOwnership()
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>	getInstanceIdentifier()
ConnectionInfo	getMDConnectionInfo()
org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId	getNodeId()
org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey	getNodeKey()
OvsdbClient	getOvsdbClient()
OvsdbNodeAugmentation	getOvsdbNodeAugmentation()
com.google.common.util.concurrent.ListenableFuture<DatabaseSchema>	getSchema(String database)
<T extends TypedBaseTable<?>> T	getTypedRowWrapper(Class<T> klazz, Row<GenericTableSchema> row)
Boolean	hasOvsdbClient(OvsdbClient otherClient)
boolean	isActive()
void	lock(String lockId, LockAquisitionCallback lockedCallBack, LockStolenCallback stolenCallback)
<E extends TableSchema<E>> TableUpdates	monitor(DatabaseSchema schema, List<MonitorRequest> monitorRequests, MonitorCallBack callbackArgument)
<E extends TableSchema<E>> TableUpdates	monitor(DatabaseSchema schema, List<MonitorRequest> monitorRequests, MonitorHandle monitorHandle, MonitorCallBack callbackArgument)
void	registerCallbacks(InstanceIdentifierCodec instanceIdentifierCodec)
void	setConnectedEntity(org.opendaylight.controller.md.sal.common.api.clustering.Entity entity)
void	setDeviceOwnershipCandidateRegistration(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipCandidateRegistration registration)
void	setHasDeviceOwnership(Boolean hasDeviceOwnership)
void	setInstanceIdentifier(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> iid)
void	setMDConnectionInfo(ConnectionInfo key)
void	setOvsdbNodeAugmentation(OvsdbNodeAugmentation ovsdbNodeCreateData)
com.google.common.util.concurrent.ListenableFuture<Boolean>	steal(String lockId)
com.google.common.util.concurrent.ListenableFuture<List<OperationResult>>	transact(DatabaseSchema dbSchema, List<Operation> operations)
void	transact(TransactCommand command, BridgeOperationalState state, org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> events, InstanceIdentifierCodec instanceIdentifierCodec) Apply the given command to the given events, based on the given bridge state.
void	transact(TransactCommand command, BridgeOperationalState state, Collection<org.opendaylight.controller.md.sal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> modifications, InstanceIdentifierCodec instanceIdentifierCodec) Apply the given command to the given modifications, based on the given bridge state.
TransactionBuilder	transactBuilder(DatabaseSchema dbSchema)
com.google.common.util.concurrent.ListenableFuture<Boolean>	unLock(String lockId)

Methods inherited from class java.lang.Object

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

Method Detail

transact

public void transact(TransactCommand command,
                     BridgeOperationalState state,
                     org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> events,
                     InstanceIdentifierCodec instanceIdentifierCodec)

Apply the given command to the given events, based on the given bridge state.

Parameters:

command - The command to run.

state - The current bridge state.

events - The events to process.

instanceIdentifierCodec - The instance identifier codec to use.

transact

public void transact(TransactCommand command,
                     BridgeOperationalState state,
                     Collection<org.opendaylight.controller.md.sal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>> modifications,
                     InstanceIdentifierCodec instanceIdentifierCodec)

Apply the given command to the given modifications, based on the given bridge state.

Parameters:

command - The command to run.

state - The current bridge state.

modifications - The modifications to process.

instanceIdentifierCodec - The instance identifier codec to use.

transact

public com.google.common.util.concurrent.ListenableFuture<List<OperationResult>> transact(DatabaseSchema dbSchema,
                                                                                          List<Operation> operations)

registerCallbacks

public void registerCallbacks(InstanceIdentifierCodec instanceIdentifierCodec)

createTransactInvokers

public void createTransactInvokers()

getDatabases

public com.google.common.util.concurrent.ListenableFuture<List<String>> getDatabases()

getSchema

public com.google.common.util.concurrent.ListenableFuture<DatabaseSchema> getSchema(String database)

transactBuilder

public TransactionBuilder transactBuilder(DatabaseSchema dbSchema)

monitor

public <E extends TableSchema<E>> TableUpdates monitor(DatabaseSchema schema,
                                                       List<MonitorRequest> monitorRequests,
                                                       MonitorHandle monitorHandle,
                                                       MonitorCallBack callbackArgument)

monitor

public <E extends TableSchema<E>> TableUpdates monitor(DatabaseSchema schema,
                                                       List<MonitorRequest> monitorRequests,
                                                       MonitorCallBack callbackArgument)

cancelMonitor

public void cancelMonitor(MonitorHandle handler)

lock

public void lock(String lockId,
                 LockAquisitionCallback lockedCallBack,
                 LockStolenCallback stolenCallback)

steal

public com.google.common.util.concurrent.ListenableFuture<Boolean> steal(String lockId)

unLock

public com.google.common.util.concurrent.ListenableFuture<Boolean> unLock(String lockId)

isActive

public boolean isActive()

disconnect

public void disconnect()

getDatabaseSchema

public DatabaseSchema getDatabaseSchema(String dbName)

createTypedRowWrapper

public <T extends TypedBaseTable<?>> T createTypedRowWrapper(Class<T> klazz)

createTypedRowWrapper

public <T extends TypedBaseTable<?>> T createTypedRowWrapper(DatabaseSchema dbSchema,
                                                             Class<T> klazz)

getTypedRowWrapper

public <T extends TypedBaseTable<?>> T getTypedRowWrapper(Class<T> klazz,
                                                          Row<GenericTableSchema> row)

getConnectionInfo

public OvsdbConnectionInfo getConnectionInfo()

getMDConnectionInfo

public ConnectionInfo getMDConnectionInfo()

setMDConnectionInfo

public void setMDConnectionInfo(ConnectionInfo key)

getInstanceIdentifier

public org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> getInstanceIdentifier()

getNodeKey

public org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey getNodeKey()

getNodeId

public org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId getNodeId()

setInstanceIdentifier

public void setInstanceIdentifier(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> iid)

getConnectedEntity

public org.opendaylight.controller.md.sal.common.api.clustering.Entity getConnectedEntity()

setConnectedEntity

public void setConnectedEntity(org.opendaylight.controller.md.sal.common.api.clustering.Entity entity)

hasOvsdbClient

public Boolean hasOvsdbClient(OvsdbClient otherClient)

getHasDeviceOwnership

public Boolean getHasDeviceOwnership()

setHasDeviceOwnership

public void setHasDeviceOwnership(Boolean hasDeviceOwnership)

setDeviceOwnershipCandidateRegistration

public void setDeviceOwnershipCandidateRegistration(@Nonnull
                                                    org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipCandidateRegistration registration)

closeDeviceOwnershipCandidateRegistration

public void closeDeviceOwnershipCandidateRegistration()

getOvsdbNodeAugmentation

public OvsdbNodeAugmentation getOvsdbNodeAugmentation()

setOvsdbNodeAugmentation

public void setOvsdbNodeAugmentation(OvsdbNodeAugmentation ovsdbNodeCreateData)

getOvsdbClient

public OvsdbClient getOvsdbClient()