idman.mngt
Class Worker

java.lang.Object
  |
  +--idman.mngt.Worker

All Implemented Interfaces:

org.ssonet.net.ConnectionListener, java.lang.Runnable, org.ssonet.net.SSONETContextListener

Direct Known Subclasses:

WorkerImpl

public abstract class Worker

extends java.lang.Object

implements java.lang.Runnable, org.ssonet.net.SSONETContextListener, org.ssonet.net.ConnectionListener

Vermittler für den Aufbau und Betrieb einer Verbindung.

Version:

$Id: Worker.java,v 1.7 2004/02/10 16:56:43 tk4 Exp $

Author:

Thomas Kriegelstein

Field Summary

protected idman.mngt.Context	context
static boolean	debug Debugflag.
protected idman.mngt.RemoteSocketFactory	factory
protected java.lang.Thread	fromremote
protected int	localPort
protected java.net.Socket	localSock
protected java.net.Socket	remoteSock
protected java.lang.Thread	runner
protected java.net.ServerSocket	serv
protected boolean	stop
protected java.lang.Thread	toremote

Fields inherited from interface org.ssonet.net.ConnectionListener

FINISHED_STATE, INIT_STATE, MECHANISMS_NEGOTIATION, NOT_STARTED_STATE, RUNNING_STATE, SECURITY_GOAL_NEGOTIATION

Constructor Summary

Worker(idman.mngt.RemoteSocketFactory factory, idman.mngt.Context context)
Konstruktor.

Method Summary

void	connectionStateChanged(org.ssonet.net.SSONETContext context, int currentState)
void	contextChanged(org.ssonet.net.SSONETContext c)
protected java.net.Socket	createSocket(java.net.InetAddress where, int port) Erzeugt einen SSONETClientSocket.
int	getLocalPort() Liefert den Port auf den der Worker eine Verbindung annimmt.
void	replaceContext(org.ssonet.net.SSONETContext o, org.ssonet.net.SSONETContext n)
void	start() Startet die Bearbeitung.
void	stop() Stoppt die Bearbeitung.
void	waitRunning(org.ssonet.net.SSONETContext context)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Methods inherited from interface org.ssonet.net.ConnectionListener

decideSecurityGoal, negotiationRequestReceived

Field Detail

debug

public static boolean debug

Debugflag.

remoteSock

protected java.net.Socket remoteSock

localPort

protected int localPort

localSock

protected java.net.Socket localSock

serv

protected java.net.ServerSocket serv

factory

protected idman.mngt.RemoteSocketFactory factory

context

protected idman.mngt.Context context

runner

protected java.lang.Thread runner

fromremote

protected java.lang.Thread fromremote

toremote

protected java.lang.Thread toremote

stop

protected boolean stop

Constructor Detail

Worker

public Worker(idman.mngt.RemoteSocketFactory factory,
              idman.mngt.Context context)

Konstruktor.

Parameters:

factory - Fabrik um mit SSL geschützte oder normale Sockets verwenden zu können.

context - Verbindungsdaten.

Method Detail

connectionStateChanged

public void connectionStateChanged(org.ssonet.net.SSONETContext context,
                                   int currentState)

Specified by:

connectionStateChanged in interface org.ssonet.net.ConnectionListener

waitRunning

public void waitRunning(org.ssonet.net.SSONETContext context)

contextChanged

public void contextChanged(org.ssonet.net.SSONETContext c)

Specified by:

contextChanged in interface org.ssonet.net.SSONETContextListener

replaceContext

public void replaceContext(org.ssonet.net.SSONETContext o,
                           org.ssonet.net.SSONETContext n)

Specified by:

replaceContext in interface org.ssonet.net.SSONETContextListener

getLocalPort

public int getLocalPort()
                 throws java.net.UnknownHostException,
                        java.net.SocketException,
                        java.io.IOException

Liefert den Port auf den der Worker eine Verbindung annimmt.

Returns:

Port für Verbindungsannahme.

java.net.UnknownHostException

java.net.SocketException

java.io.IOException

start

public void start()

Startet die Bearbeitung.

stop

public void stop()

Stoppt die Bearbeitung.

createSocket

protected java.net.Socket createSocket(java.net.InetAddress where,
                                       int port)
                                throws java.net.SocketException,
                                       java.io.IOException

Erzeugt einen SSONETClientSocket.

Parameters:

where - Zieladresse der Verbindung.

port - Zielport der Verbindung.

Returns:

Eine Verbindung.

Throws:

java.net.SocketException - Bei Fehler mit dem Netzwerk.

java.io.IOException - Bei Fehlern mit der Pufferung.