Package org.opennms.netmgt.icmp.jna

Class AbstractPinger<T extends java.net.InetAddress>

java.lang.Object

org.opennms.netmgt.icmp.jna.AbstractPinger<T>

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

V4Pinger, V6Pinger

public abstract class AbstractPinger<T extends java.net.InetAddress>
extends java.lang.Object
implements java.lang.Runnable

JnaPinger

Author:

brozow

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.atomic.AtomicReference<java.lang.Throwable>	m_throwable
static double	NANOS_PER_MILLI

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractPinger(int pingerId, NativeDatagramSocket pingSocket)

Method Summary

Modifier and Type	Method	Description
void	addPingReplyListener(PingReplyListener listener)
void	closeSocket()
protected int	getPingerId()
protected NativeDatagramSocket	getPingSocket()
boolean	isFinished()
protected void	notifyPingListeners(java.net.InetAddress address, EchoPacket echoReply)
abstract void	ping(T addr, int identifier, int sequenceNumber, long threadId, long count, long interval, int packetSize)
protected void	setThrowable(java.lang.Throwable e)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Field Detail

NANOS_PER_MILLI

public static final double NANOS_PER_MILLI

See Also:

Constant Field Values

m_throwable

protected final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> m_throwable

Constructor Detail

AbstractPinger

protected AbstractPinger(int pingerId,
                         NativeDatagramSocket pingSocket)

Method Detail

getPingSocket

protected NativeDatagramSocket getPingSocket()

Returns:

the pingSocket

getPingerId

protected int getPingerId()

isFinished

public boolean isFinished()

start

public void start()

stop

public void stop()
          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

closeSocket

public void closeSocket()

ping

public abstract void ping(T addr,
                          int identifier,
                          int sequenceNumber,
                          long threadId,
                          long count,
                          long interval,
                          int packetSize)
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

addPingReplyListener

public void addPingReplyListener(PingReplyListener listener)

notifyPingListeners

protected void notifyPingListeners(java.net.InetAddress address,
                                   EchoPacket echoReply)

setThrowable

protected void setThrowable(java.lang.Throwable e)