se.sics.isl.inet
Class InetConnection

java.lang.Object
  se.sics.isl.inet.InetConnection

public abstract class InetConnection
extends java.lang.Object

Constructor Summary

InetConnection(java.lang.String name, java.net.Socket socket)

InetConnection(java.lang.String name, java.lang.String host, int port)

Method Summary

void	close()
void	closeImmediately()
protected abstract void	connectionClosed()
protected abstract void	connectionOpened()
protected void	deliverMessage(java.lang.Object message)
protected abstract void	doDeliverMessage(java.lang.Object message)
protected abstract void	doReadMessages()
protected abstract void	doSendMessage(java.lang.Object message)
long	getConnectTime()
java.io.InputStream	getInputStream()
java.lang.String	getName()
java.io.OutputStream	getOutputStream()
java.lang.String	getRemoteHost()
int	getRemotePort()
ThreadPool	getThreadPool()
java.lang.String	getUserName()
boolean	isClosed()
boolean	isDeliveryBuffered()
boolean	isServerConnection()
boolean	isWriteBuffered()
void	sendMessage(java.lang.Object message)
void	setDeliveryBuffered(boolean isDeliveryBuffered)
void	setThreadPool(ThreadPool threadPool)
void	setUserName(java.lang.String userName)
void	setWriteBuffered(boolean isWriteBuffered)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

InetConnection

public InetConnection(java.lang.String name,
                      java.net.Socket socket)

InetConnection

public InetConnection(java.lang.String name,
                      java.lang.String host,
                      int port)

Method Detail

getName

public java.lang.String getName()

getUserName

public java.lang.String getUserName()

setUserName

public void setUserName(java.lang.String userName)

getRemoteHost

public java.lang.String getRemoteHost()

getRemotePort

public int getRemotePort()

getConnectTime

public long getConnectTime()

getInputStream

public java.io.InputStream getInputStream()

getOutputStream

public java.io.OutputStream getOutputStream()

isServerConnection

public boolean isServerConnection()

isDeliveryBuffered

public boolean isDeliveryBuffered()

setDeliveryBuffered

public void setDeliveryBuffered(boolean isDeliveryBuffered)

isWriteBuffered

public boolean isWriteBuffered()

setWriteBuffered

public void setWriteBuffered(boolean isWriteBuffered)

getThreadPool

public ThreadPool getThreadPool()

setThreadPool

public void setThreadPool(ThreadPool threadPool)

start

public final void start()
                 throws java.io.IOException

Throws:

java.io.IOException

isClosed

public boolean isClosed()

close

public void close()

closeImmediately

public void closeImmediately()

sendMessage

public void sendMessage(java.lang.Object message)

deliverMessage

protected void deliverMessage(java.lang.Object message)

connectionOpened

protected abstract void connectionOpened()
                                  throws java.io.IOException

Throws:

java.io.IOException

connectionClosed

protected abstract void connectionClosed()
                                  throws java.io.IOException

Throws:

java.io.IOException

doReadMessages

protected abstract void doReadMessages()
                                throws java.io.IOException

Throws:

java.io.IOException

doDeliverMessage

protected abstract void doDeliverMessage(java.lang.Object message)

doSendMessage

protected abstract void doSendMessage(java.lang.Object message)
                               throws java.io.IOException

Throws:

java.io.IOException