org.epics.pvmanager.test

Class CountDownPVWriterListener<T>

java.lang.Object

org.epics.pvmanager.test.CountDownPVWriterListener<T>

All Implemented Interfaces:

PVWriterListener<T>

public class CountDownPVWriterListener<T>
extends Object
implements PVWriterListener<T>

Write listener to wait that a certain number of notifications.

Author:

carcassi

Constructor Summary

Constructors

Constructor and Description
CountDownPVWriterListener(int count)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	await(org.epics.util.time.TimeDuration duration) Waits that the listener count goes to zero.
int	getCount() Current count.
PVWriterEvent<T>	getEvent() The last notified event.
int	getNotificationCount() The total number of notifications on this listener.
String	getThreadName() The thread name for the last notification.
void	pvChanged(PVWriterEvent<T> event) Notified when the value was written.
void	resetCount(int count) Changes the count back to count.

Methods inherited from class java.lang.Object

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

Constructor Detail

CountDownPVWriterListener

public CountDownPVWriterListener(int count)

Method Detail

pvChanged

public void pvChanged(PVWriterEvent<T> event)

Description copied from interface: PVWriterListener

Notified when the value was written.

Specified by:

pvChanged in interface PVWriterListener<T>

Parameters:

event - the writer event

resetCount

public void resetCount(int count)

Changes the count back to count.

Parameters:

count - new value for count

getCount

public int getCount()

Current count.

Returns:

current count

getEvent

public PVWriterEvent<T> getEvent()

The last notified event.

Returns:

the event

getThreadName

public String getThreadName()

The thread name for the last notification.

Returns:

the thread name

getNotificationCount

public int getNotificationCount()

The total number of notifications on this listener.

Returns:

the number of notifications

await

public boolean await(org.epics.util.time.TimeDuration duration)
              throws InterruptedException

Waits that the listener count goes to zero.

Parameters:

duration - time to wait

Returns:

false if count didn't go to zero

Throws:

InterruptedException