org.opendaylight.ovsdb.utils.mdsal.utils

Class NotifyingDataChangeListener

java.lang.Object

org.opendaylight.ovsdb.utils.mdsal.utils.NotifyingDataChangeListener

All Implemented Interfaces:

AutoCloseable, EventListener, org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener<org.opendaylight.yangtools.yang.binding.DataObject>

public class NotifyingDataChangeListener
extends Object
implements AutoCloseable, org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener<org.opendaylight.yangtools.yang.binding.DataObject>

This class provides methods for checking or waiting for various md-sal operations to complete. Once an instance is created one must invoke the registerDataChangeListener method with a DataBroker.

Field Summary

Fields

Modifier and Type	Field and Description
static int	BIT_ALL
static int	BIT_CREATE
static int	BIT_DELETE
static int	BIT_UPDATE

Constructor Summary

Constructors

Constructor and Description
NotifyingDataChangeListener(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType type, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid, List<NotifyingDataChangeListener> waitList) Create a new NotifyingDataChangeListener
NotifyingDataChangeListener(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType type, int mask, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid, List<NotifyingDataChangeListener> waitList)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	close()
boolean	isCreated(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid)
boolean	isRemoved(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid)
boolean	isUpdated(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid)
void	modify(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType type, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid) Completely reset the state of this NotifyingDataChangeListener.
void	onDataTreeChanged(Collection<org.opendaylight.controller.md.sal.binding.api.DataTreeModification<org.opendaylight.yangtools.yang.binding.DataObject>> changes)
void	registerDataChangeListener(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker)
void	setlisten(Boolean listen)
void	setMask(int mask)
void	waitForCreation()
void	waitForCreation(long timeout)
void	waitForDeletion()
void	waitForDeletion(long timeout)
void	waitForUpdate()
void	waitForUpdate(long timeout)

Methods inherited from class java.lang.Object

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

Field Detail

BIT_CREATE

public static final int BIT_CREATE

See Also:

Constant Field Values

BIT_UPDATE

public static final int BIT_UPDATE

See Also:

Constant Field Values

BIT_DELETE

public static final int BIT_DELETE

See Also:

Constant Field Values

BIT_ALL

public static final int BIT_ALL

See Also:

Constant Field Values

Constructor Detail

NotifyingDataChangeListener

public NotifyingDataChangeListener(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType type,
                                   int mask,
                                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid,
                                   List<NotifyingDataChangeListener> waitList)

NotifyingDataChangeListener

public NotifyingDataChangeListener(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType type,
                                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid,
                                   List<NotifyingDataChangeListener> waitList)

Create a new NotifyingDataChangeListener

Parameters:

type - DataStore type

iid - of the md-sal object we're waiting for

waitList - for tracking outstanding changes

Method Detail

modify

public void modify(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType type,
                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid)
            throws Exception

Completely reset the state of this NotifyingDataChangeListener.

Parameters:

type - DataStore type

iid - of the md-sal object we're waiting for

Throws:

Exception

setlisten

public void setlisten(Boolean listen)

setMask

public void setMask(int mask)

onDataTreeChanged

public void onDataTreeChanged(Collection<org.opendaylight.controller.md.sal.binding.api.DataTreeModification<org.opendaylight.yangtools.yang.binding.DataObject>> changes)

Specified by:

onDataTreeChanged in interface org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener<org.opendaylight.yangtools.yang.binding.DataObject>

isCreated

public boolean isCreated(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid)

isUpdated

public boolean isUpdated(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid)

isRemoved

public boolean isRemoved(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> iid)

clear

public void clear()

registerDataChangeListener

public void registerDataChangeListener(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker)

waitForCreation

public void waitForCreation()
                     throws InterruptedException

Throws:

InterruptedException

waitForCreation

public void waitForCreation(long timeout)
                     throws InterruptedException

Throws:

InterruptedException

waitForUpdate

public void waitForUpdate()
                   throws InterruptedException

Throws:

InterruptedException

waitForUpdate

public void waitForUpdate(long timeout)
                   throws InterruptedException

Throws:

InterruptedException

waitForDeletion

public void waitForDeletion()
                     throws InterruptedException

Throws:

InterruptedException

waitForDeletion

public void waitForDeletion(long timeout)
                     throws InterruptedException

Throws:

InterruptedException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception