|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.ars.ars.mgmt.tasks.FlowControlTask
public class FlowControlTask
KLasse zur Verarbeitung der Steuerungspakete, die von anderen Applikationen zur Flusskontrolle an das Archivsystem geschickt werden. Der Empfaenger einer
Archivantwort kann den Sendefluss des im ArchiveQueryTask
eingesetzten StreamMultiplexer
steuern. Die dazu
versandten Steuerungspakete werden vom InQueuesMgr
empfangen und dann von diesem Task an die entsprechenden Multiplexer
weitergeleitet.
Field Summary | |
---|---|
private Map<SystemObject,Map<Integer,StreamMultiplexer>> |
ctrlMap
Datenhaltung: Anfragendes ApplikationsObjekt -> Anfrage-Index -> StreamMultiplexer. |
private Debug |
logger
|
private Object |
syncObj
Spezielles Objekt zur Synchronisierung. |
Constructor Summary | |
---|---|
FlowControlTask(ArchiveManager archiveMgr)
Erzeugt einen neuen Flusskontroll-Task. |
Method Summary | |
---|---|
private void |
log(byte[] streamTicketPacket)
|
private void |
log(SystemObject queryAppObj,
int queryIdx,
byte[] streamTicketPacket)
|
void |
processFlowCtrl(ResultData resultData)
|
void |
subscribe(SystemObject queryAppObj,
int queryIdx,
StreamMultiplexer mux)
Registriert den angegebenen StreamMultiplexer fuer den Empfang von Steuerpaketen vom angegebenen Anfrage-Applikations-Objekt und Anfrage-Index, die dieser gerade mit einer Archivantwort versorgt. |
void |
unsubscribe(SystemObject queryAppObj,
int queryIdx)
De-Registriert den zuvor unter dem angegebenen Anfrage-Applikations-Objekt und Anfrage-Index registrierten StreamMultiplexer fuer den Empfang von Steuerpaketen. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private Object syncObj
private Debug logger
private Map<SystemObject,Map<Integer,StreamMultiplexer>> ctrlMap
Constructor Detail |
---|
public FlowControlTask(ArchiveManager archiveMgr)
aMgr
- Der Archiv-Managerrodl
- Ring-of-Death-ListenerinputData
- Warteschlange des TasksMethod Detail |
---|
public void processFlowCtrl(ResultData resultData)
public void subscribe(SystemObject queryAppObj, int queryIdx, StreamMultiplexer mux)
queryAppObj
- Anfrage-Applikations-ObjektqueryIdx
- Anfrage-Indexmux
- StreamMultiplexerpublic void unsubscribe(SystemObject queryAppObj, int queryIdx)
queryAppObj
- Anfrage-Applikations-ObjektqueryIdx
- Anfrage-Indexprivate void log(byte[] streamTicketPacket)
private void log(SystemObject queryAppObj, int queryIdx, byte[] streamTicketPacket)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |