|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
de.bsvrz.ars.ars.mgmt.tasks.Task
de.bsvrz.ars.ars.mgmt.tasks.MultiTask
de.bsvrz.ars.ars.mgmt.tasks.QueryTask
de.bsvrz.ars.ars.mgmt.tasks.ArchiveQueryTask
public class ArchiveQueryTask
Task fuer Bearbeitung von Archivanfragen.
Die Archivanfrage wird analysiert und in ihre Unterabfragen Query
zerlegt.
Die Beantwortung erfolgt streambasiert mit einem Stream pro Unterabfrage.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class de.bsvrz.ars.ars.mgmt.tasks.QueryTask |
---|
QueryTask.SendingState |
Nested classes/interfaces inherited from class java.lang.Thread |
---|
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler |
Field Summary |
---|
Fields inherited from class de.bsvrz.ars.ars.mgmt.tasks.QueryTask |
---|
atgQuery, bosResult, ddResponse, deserializer, gData, gResultData, MIN_CONTAINER_FILES, NA, NN, OA, ON, queryAppObj, queryIdx, sendingState, serializer, serializerVersion, syncObj, t_lsMax, tempMem |
Fields inherited from class de.bsvrz.ars.ars.mgmt.tasks.MultiTask |
---|
resultData, taskMgr |
Fields inherited from class de.bsvrz.ars.ars.mgmt.tasks.Task |
---|
archMgr, didTree, INDEX_MEMORY_SIZE, isTerminated, logger, persMgr, ringOfDeathListener, taskStepListeners |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
ArchiveQueryTask(ArchiveManager archiveMgr,
MultiTaskManager tMgr,
FlowControlTask flowCtrl)
Erzeugt eine neue Query-Task. |
Method Summary | |
---|---|
void |
dataRequest(SystemObject object,
DataDescription dataDescription,
byte state)
|
static int |
getBlockingFactorMux()
|
static int |
getBufferSizeMux()
|
protected void |
init()
Initialisiert den Task fuer eine neue Archivanfrage. |
void |
sendData(byte[] streamDataPacket)
|
static void |
setBlockingFactorMux(int bFMuxParam)
Ueber diese Methode kann die Parametrierung den Blocking-Faktor des StreamMultiplexers auf den parametrierten Wert setzen (Attribut "AnzahlBlocks" in Attributgruppe "ArchivEinstellung"). |
static void |
setBufferSizeMux(int bSMuxParam)
Ueber diese Methode kann die Parametrierung die Puffergroesse des StreamMultiplexers auf den parametrierten Wert setzen (Attribut "AnzahlBytes" in Attributgruppe "ArchivEinstellung"). |
void |
streamAborted(int indexOfStream)
|
static void |
subscribeObjects(ArchiveManager archMgr,
InQueuesMgr.DataReceiver receiver)
Fuehrt alle notwendigen Anmeldungen durch. |
byte[] |
take(int indexOfStream)
|
protected void |
unsubscribeSender()
Meldet den Task als Sender fuer Archiv-Antworten an das angegebene Empfaenger-Applikations-Objekt ab. |
void |
work()
Diese Methode ist zu überschreiben, um die konkrete Aufgabe der Task zu implementieren. |
Methods inherited from class de.bsvrz.ars.ars.mgmt.tasks.QueryTask |
---|
createQueryData, getObjectsFromDAV, isRequestSupported, parseArchiveDataSpec, sendResultData, setT_lsMax, subscribeSender |
Methods inherited from class de.bsvrz.ars.ars.mgmt.tasks.MultiTask |
---|
doWork, getTaskIndex, run, setTaskIndex |
Methods inherited from class de.bsvrz.ars.ars.mgmt.tasks.Task |
---|
addTaskStepListener, getArchMgr, isTaskTerminated, removeTaskStepListener, suspendTaskIfNecessary, terminateTask |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public ArchiveQueryTask(ArchiveManager archiveMgr, MultiTaskManager tMgr, FlowControlTask flowCtrl) throws ConfigurationException
archiveMgr
- tMgr
- Zugeordneter Task-ManagerflowCtrl
-
ConfigurationException
- falls die Zugriffe auf das Datenmodell scheiternMethod Detail |
---|
public static void subscribeObjects(ArchiveManager archMgr, InQueuesMgr.DataReceiver receiver)
davCon
- Verbindung zum Datenverteilerreceiver
- Empfaengerobjektpublic static void setBlockingFactorMux(int bFMuxParam)
blockingFactorMuxParam
- Parametrierter Blocking-Faktor des StreamMultiplexerspublic static void setBufferSizeMux(int bSMuxParam)
bufferSizeMuxParam
- Parametrierte Puffergroesse des StreamMultiplexerspublic static int getBlockingFactorMux()
setBlockingFactorMux(int)
public static int getBufferSizeMux()
setBlockingFactorMux(int)
public void work()
MultiTask
work
in class MultiTask
MultiTask.work()
public void sendData(byte[] streamDataPacket)
StreamMultiplexerDirector#sendData(byte[])
public byte[] take(int indexOfStream)
StreamMultiplexerDirector#take(int)
public void streamAborted(int indexOfStream)
StreamMultiplexerDirector#streamAborted(int)
public void dataRequest(SystemObject object, DataDescription dataDescription, byte state)
dataRequest
in class QueryTask
ClientSenderInterface#dataRequest(SystemObject, DataDescription, byte)
protected void init()
init
in class QueryTask
protected void unsubscribeSender()
unsubscribeSender
in class QueryTask
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |