se.sics.isl.tact
Class TACTConnection

java.lang.Object
  se.sics.isl.tact.TACTConnection

Direct Known Subclasses:

BlockingViewerChannel

public abstract class TACTConnection
extends java.lang.Object

- One thread for receiving and deliverying data - Threadpool for sending data

Constructor Summary

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

TACTConnection(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 abstract void	dataRead(byte[] data, int start, int len)
long	getConnectTime()
int	getMaxBuffer()
java.lang.String	getName()
java.lang.String	getRemoteHost()
int	getRemotePort()
ThreadPool	getThreadPool()
java.lang.String	getUserName()
boolean	isClosed()
void	setMaxBuffer(int maxBuffer)
void	setThreadPool(ThreadPool threadPool)
void	setUserName(java.lang.String userName)
void	start()
void	write(byte[] data)

Methods inherited from class java.lang.Object

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

Constructor Detail

TACTConnection

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

TACTConnection

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

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()

getMaxBuffer

public int getMaxBuffer()

setMaxBuffer

public void setMaxBuffer(int maxBuffer)

getThreadPool

public ThreadPool getThreadPool()

setThreadPool

public void setThreadPool(ThreadPool threadPool)

start

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

Throws:

java.io.IOException

write

public void write(byte[] data)

isClosed

public boolean isClosed()

close

public void close()

closeImmediately

public void closeImmediately()

connectionOpened

protected abstract void connectionOpened()

connectionClosed

protected abstract void connectionClosed()

dataRead

protected abstract void dataRead(byte[] data,
                                 int start,
                                 int len)