package system.net;
import java.io.IOException;
import system.debug.DebugManager;
import system.debug.ExceptionManager;
public abstract class TCPServerSocket
{
private int port;
private boolean listening = true;
public TCPServerSocket(int pPort)
{
port = pPort;
}
public void startServerSocket()
{
try
{
}
{
ExceptionManager.addException(e, "Cant open ServerSocket on port " + port);
}
DebugManager.
addDebugEvent(getClass
().
getSimpleName(),
String.
valueOf(serverSocket
));
DebugManager.addDebugEvent(getClass().getSimpleName(), "Awaiting new connections... ");
try
{
while (listening)
{
newConnection(new TCPClient(serverSocket.accept()));
}
serverSocket.close();
}
{
ExceptionManager.addException(e, "Opening of connection socket failed!");
}
}
abstract public void newConnection(TCPClient socket);
public void stopListening()
{
listening = false;
}
}