Package org.opendaylight.ovsdb.southbound.reconciliation

Class ReconciliationTask

java.lang.Object

org.opendaylight.ovsdb.southbound.reconciliation.ReconciliationTask

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

BridgeConfigReconciliationTask, ConnectionReconciliationTask, TerminationPointConfigReconciliationTask

public abstract class ReconciliationTask
extends Object
implements Runnable

Abstract implementation of a reconciliation task. Each new type of resource configuration reconciliation task should extend this class and implement the abstract methods.

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.opendaylight.yangtools.yang.binding.DataObject	configData
protected final OvsdbConnectionManager	connectionManager
protected final org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>	nodeIid
protected final ReconciliationManager	reconciliationManager

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReconciliationTask(ReconciliationManager reconciliationManager, OvsdbConnectionManager connectionManager, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> nodeIid, org.opendaylight.yangtools.yang.binding.DataObject configData)

Method Summary

Modifier and Type	Method	Description
abstract void	checkReadinessAndProcess()	Extended task should implement the logic that check the readiness of the task for execution.
abstract void	doRetry(boolean wasPreviousAttemptSuccessful)	Extended task should implement the logic that decides whether retry for the task is required or not.
boolean	equals(Object obj)
int	hashCode()
abstract boolean	reconcileConfiguration(OvsdbConnectionManager connectionManagerOfDevice)	Method contains task reconciliation logic.
abstract long	retryDelayInMills()	Method returns the time interval for retrying the failed task.
void	run()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

reconciliationManager

protected final ReconciliationManager reconciliationManager

connectionManager

protected final OvsdbConnectionManager connectionManager

nodeIid

protected final org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> nodeIid

configData

protected final org.opendaylight.yangtools.yang.binding.DataObject configData

Constructor Details

ReconciliationTask

protected ReconciliationTask(ReconciliationManager reconciliationManager,
 OvsdbConnectionManager connectionManager,
 org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> nodeIid,
 org.opendaylight.yangtools.yang.binding.DataObject configData)

Method Details

reconcileConfiguration

public abstract boolean reconcileConfiguration(OvsdbConnectionManager connectionManagerOfDevice)

Method contains task reconciliation logic. Please refer to ConnectionReconciliationTask.reconcileConfiguration(OvsdbConnectionManager) for example.

Parameters:

connectionManagerOfDevice - Connection manager to get connection instance of the device

Returns:

True if reconciliation was successful, else false

doRetry

public abstract void doRetry(boolean wasPreviousAttemptSuccessful)

Extended task should implement the logic that decides whether retry for the task is required or not. If retry is required but it does not requires any delay, submit the task immediately using ReconciliationManager.enqueue(ReconciliationTask). If retry requires delay, use ReconciliationManager.enqueueForRetry(ReconciliationTask) and specify the delay using retryDelayInMills(). If data store operation is required to decide if the task need retry, please implement it as an async operation and submit the task on the callback of the future.

Note:Please do not write blocking data store operations ConnectionReconciliationTask.doRetry(boolean)

Parameters:

wasPreviousAttemptSuccessful - Status of the previous attempt

checkReadinessAndProcess

public abstract void checkReadinessAndProcess()

Extended task should implement the logic that check the readiness of the task for execution. If task is ready for the execution, submit it for immediate execution using ReconciliationManager.enqueue(ReconciliationTask). If task is not ready for execution yet, enqueue it again for delayed execution using ReconciliationManager.enqueueForRetry(ReconciliationTask). To check the readiness of the task, if the data store operation is required, please implement it as an async operation and submit the task on the callback of the future.

Note:Please do not write blocking data store operations ConnectionReconciliationTask.doRetry(boolean)

retryDelayInMills

public abstract long retryDelayInMills()

Method returns the time interval for retrying the failed task. doRetry(boolean)

Returns:

time

run

public void run()

Specified by:

run in interface Runnable

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object