|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.pua.prot.manager.taskmanager.TaskManager
public class TaskManager
Hauptklasse des Task Manager Submodul. Diese Klasse nimmt Anfragen vom Manager Submodul entgegen. Ist es eine Anfrage zur Protokollerstellung, so wird diese einem untätigen Thread zugeordnet. Alle anderen Anfragen werden an den jeweils zuständigen Thread geleitet.
Constructor Summary | |
---|---|
TaskManager(ClientDavInterface dav,
DataManager dataManager,
int maxProtocols,
int maxQueries,
long maxDelay,
ConfigurationObject configAuth)
Erzeugt den Task Manager |
Method Summary | |
---|---|
java.lang.Long[] |
getActiveProtocols()
Liste mit den Protokollen die gerade gesendet / erstellt werden. |
java.lang.Long[][] |
getWaitingProtocols()
Liste mit den Anfrage-Ids und zugehörigen Protokoll-Ids, die momentan in der Warteschlange liegen. |
boolean |
isTerminated()
Zeigt an ob der Taskmanager und alle Subthreads beendet wurden. |
void |
process(SystemObject client,
long id,
int operation,
byte[] data)
Übergeben einer Anfrage an das Task Manager Submodul. |
void |
shutdown()
Fährt den Task-Manager herunter. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TaskManager(ClientDavInterface dav, DataManager dataManager, int maxProtocols, int maxQueries, long maxDelay, ConfigurationObject configAuth) throws FailureException
dav
- Verbindung zum DatenverteilermaxProtocols
- Maximale Anzahl von Threads die gleichzeitig ausgeführt werden dürfen.dataManager
- Daten ManagermaxQueries
- Maximale Größe der Warteschlange für Anufträge zur Protokollerstellung.maxDelay
- Maximale Zeitdauer in ms, für die die Protokollerstellung angehalten werden kann.configAuth
- Konfigurationsverantwortlicher für Anfragen an das Archivsystem.
FailureException
- Keine Verbindung zum Datenverteiler; Anlegen aller Treads scheitertMethod Detail |
---|
public void process(SystemObject client, long id, int operation, byte[] data)
process
in interface TaskManagerInterface
client
- Empfänger an den das Ergebnis der Anfrage gesendet werden sollid
- Id der Anfrageoperation
- Operationscode (gültige Werte sind ProtocolRelatedOperation
data
- Byte-Feld mit serialisierten Anfragedatenpublic void shutdown()
TaskManagerInterface
shutdown
in interface TaskManagerInterface
TaskManagerInterface.shutdown()
public boolean isTerminated()
true
falls der Taskmanager beendet wurde.public java.lang.Long[] getActiveProtocols()
TaskManagerInterface
getActiveProtocols
in interface TaskManagerInterface
TaskManagerInterface.getActiveProtocols()
public java.lang.Long[][] getWaitingProtocols()
TaskManagerInterface
getWaitingProtocols
in interface TaskManagerInterface
TaskManagerInterface.getWaitingProtocols()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |