|
OpenNMS API 1.2.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.opennms.netmgt.discovery.PingManager
Nested Class Summary | |
(package private) static class |
PingManager.Pinger
|
Field Summary | |
private FifoQueue |
m_discoveredQ
|
private short |
m_filterId
|
private ReplyReceiver |
m_icmpReceiver
|
private PingManager.Pinger[] |
m_pingers
|
private FifoQueue |
m_replyQ
|
private QuantumSemaphore |
m_semaphore
|
private IcmpSocket |
m_socket
|
private int |
m_status
|
private java.lang.Thread |
m_worker
|
private static long |
TID_CONST_KEY
|
Fields inherited from interface org.opennms.core.fiber.PausableFiber |
PAUSE_PENDING, PAUSED, RESUME_PENDING |
Fields inherited from interface org.opennms.core.fiber.Fiber |
RUNNING, START_PENDING, STARTING, STATUS_NAMES, STOP_PENDING, STOPPED |
Constructor Summary | |
(package private) |
PingManager(FifoQueue addressQ,
FifoQueue discoveredQ,
short filterId,
int threads,
int pktsPerSecond)
Constructs a new instance of a ping manager. |
Method Summary | |
java.lang.String |
getName()
Returns the name of this fiber. |
int |
getStatus()
Returns the current manager status. |
void |
pause()
Pauses the currently running manager. |
void |
resume()
Resumes a currently paused manager. |
void |
run()
This is the main method that receives the ICMP replies from the ICMP recever and processes them. |
void |
start()
Starts the ping manager. |
void |
stop()
Stops the currently running ping manager. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private static final long TID_CONST_KEY
private PingManager.Pinger[] m_pingers
private QuantumSemaphore m_semaphore
private IcmpSocket m_socket
private FifoQueue m_replyQ
private FifoQueue m_discoveredQ
private ReplyReceiver m_icmpReceiver
private int m_status
private short m_filterId
private java.lang.Thread m_worker
Constructor Detail |
PingManager(FifoQueue addressQ, FifoQueue discoveredQ, short filterId, int threads, int pktsPerSecond) throws java.io.IOException
start
.
addressQ
- The input address queue.discoveredQ
- The output queue of responding addresses.threads
- The number of pinging fibers to create.pktsPerSecond
- The maximum packets per second that can be generated.
java.io.IOException
- Thrown if the ICMP socket cannot be constructed.Method Detail |
public void start()
start
in interface Fiber
java.lang.IllegalStateException
- Thrown if the fiber has previously been started.public void stop()
stop
in interface Fiber
java.lang.IllegalStateException
- Thrown if the fiber has never been started.public void pause()
pause
in interface PausableFiber
java.lang.IllegalStateException
- Thrown if the fiber is not running.public void resume()
resume
in interface PausableFiber
java.lang.IllegalStateException
- Thrown if the manager is not currently active.public int getStatus()
getStatus
in interface Fiber
public java.lang.String getName()
getName
in interface Fiber
public void run()
run
in interface java.lang.Runnable
|
OpenNMS API 1.2.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |