|
||||||||||
| 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 scheitert| Method Detail |
|---|
public void process(SystemObject client,
long id,
int operation,
byte[] data)
process in interface TaskManagerInterfaceclient - Empfänger an den das Ergebnis der Anfrage gesendet werden sollid - Id der Anfrageoperation - Operationscode (gültige Werte sind ProtocolRelatedOperationdata - Byte-Feld mit serialisierten Anfragedatenpublic void shutdown()
TaskManagerInterface
shutdown in interface TaskManagerInterfaceTaskManagerInterface.shutdown()public boolean isTerminated()
true falls der Taskmanager beendet wurde.public java.lang.Long[] getActiveProtocols()
TaskManagerInterface
getActiveProtocols in interface TaskManagerInterfaceTaskManagerInterface.getActiveProtocols()public java.lang.Long[][] getWaitingProtocols()
TaskManagerInterface
getWaitingProtocols in interface TaskManagerInterfaceTaskManagerInterface.getWaitingProtocols()
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||