com.ireasoning.protocol
Class ListenThread

java.lang.Object
  java.lang.Thread
      com.ireasoning.protocol.ListenThread

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

SnmpSessionListenThread

public class ListenThread

extends Thread

Nested Class Summary

protected class

ListenThread.Item

Field Summary

protected Timer	_asyncTimer
protected boolean	_isTimerRunning
protected Hashtable	_pendingRequests
protected Session	_session
protected com.ireasoning.protocol.ListenThread.Task	_task

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

ListenThread(Session session)

Method Summary

protected boolean	receivedMsg(Msg msg)
protected void	resend(Object pdu)
void	run()
void	setTimeoutForAsyncRequests(int timeout)
void	stopTimer()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

_session

protected Session _session

_asyncTimer

protected Timer _asyncTimer

_pendingRequests

protected Hashtable _pendingRequests

_task

protected com.ireasoning.protocol.ListenThread.Task _task

_isTimerRunning

protected boolean _isTimerRunning

Constructor Detail

ListenThread

public ListenThread(Session session)

Method Detail

resend

protected void resend(Object pdu)

receivedMsg

protected boolean receivedMsg(Msg msg)

Returns:

false if received message is invalid, so that it won't be processed further.

stopTimer

public void stopTimer()

setTimeoutForAsyncRequests

public void setTimeoutForAsyncRequests(int timeout)

run

public void run()