mam.internetworking
Class SocketDaemon

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--mam.internetworking.SocketDaemon

public class SocketDaemon

extends Thread

implements SocketSenderListener

Constructor Summary

SocketDaemon(URL localUrl, int port, InetAddress localAddress, RoutingTable routingTable)

Method Summary
protected InetAddress	getAddress()
protected URL	getLocalUrl()
protected int	getPort()
protected RoutingTable	getRoutingTable()
protected void	handleRoutesQuery(RoutesQueryMessage queryMessage)
protected void	handleRoutesUpdate(RoutesUpdateMessage updateMessage)
void	handleSocketSenderEvent(SocketSenderEvent event)
protected void	handleWrappedObjectMessage(WrappedObjectMessage wrappedObjectMessage)
synchronized void	process(Socket socket)
(package private) void	processRoutableMessage(RoutableMessage routableMessage)
void	run()
protected void	sendMessage(URL destinationUrl, RoutableMessage message)
protected void	setRoutingTable(RoutingTable routingTable)
void	signalQuit()
String	toDebugString()

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Detail

Log

static Category Log

InetAddress m_address

byte[] m_buffer

private URL m_localUrl

int m_port

boolean m_quit

RoutingTable m_routingTable

ServerSocket m_serverSocket

public SocketDaemon(URL localUrl, int port, InetAddress localAddress, RoutingTable routingTable)
               throws java.io.IOException,
                      java.lang.SecurityException

protected InetAddress getAddress()

protected URL getLocalUrl()

protected int getPort()

protected RoutingTable getRoutingTable()

protected void handleRoutesQuery(RoutesQueryMessage queryMessage)

protected void handleRoutesUpdate(RoutesUpdateMessage updateMessage)

public void handleSocketSenderEvent(SocketSenderEvent event)

protected void handleWrappedObjectMessage(WrappedObjectMessage wrappedObjectMessage)

public synchronized void process(Socket socket)

void processRoutableMessage(RoutableMessage routableMessage)

public void run()

protected void sendMessage(URL destinationUrl, RoutableMessage message)

protected void setRoutingTable(RoutingTable routingTable)

public void signalQuit()

public String toDebugString()