#include <acsRequest.h>
Public Types | |
typedef std::deque< R * > | Queue |
Public Member Functions | |
RequestChainContext (RequestProcessorThread *irpt) | |
virtual | ~RequestChainContext () |
RequestProcessorThread * | getRequestProcessor () |
void | appendRequest (R *request) |
void | appendRequestOrdered (R *request) |
void | prependRequest (R *request) |
void | prependRequestOrdered (R *request) |
void | proceed (R *lastreq=NULL) |
Public Attributes | |
Queue | requests |
Protected Member Functions | |
virtual bool | requestDone (R *request)=0 |
virtual void | chainDone ()=0 |
virtual void | chainAborted ()=0 |
Private Attributes | |
RequestProcessorThread * | rpt |
R * | curreq |
bool | inprocess |
bool | hasAsync |
bool | failed |
int | asyncToComplete |
std::set< ACSServiceType > | asyncStartInProgress |
bool | syncPending |
ACE_Thread_Mutex | mutex |
typedef std::deque<R*> RequestChainContext< R >::Queue |
RequestChainContext< R >::RequestChainContext | ( | RequestProcessorThread * | irpt | ) | [inline] |
virtual RequestChainContext< R >::~RequestChainContext | ( | ) | [inline, virtual] |
void RequestChainContext< R >::appendRequest | ( | R * | request | ) | [inline] |
void RequestChainContext< R >::appendRequestOrdered | ( | R * | request | ) | [inline] |
virtual void RequestChainContext< R >::chainAborted | ( | ) | [protected, pure virtual] |
Implemented in ACSServiceRequestChainContext.
virtual void RequestChainContext< R >::chainDone | ( | ) | [protected, pure virtual] |
Implemented in ACSServiceRequestChainContext.
RequestProcessorThread* RequestChainContext< R >::getRequestProcessor | ( | ) | [inline] |
void RequestChainContext< R >::prependRequest | ( | R * | request | ) | [inline] |
void RequestChainContext< R >::prependRequestOrdered | ( | R * | request | ) | [inline] |
void RequestChainContext< R >::proceed | ( | R * | lastreq = NULL |
) |
virtual bool RequestChainContext< R >::requestDone | ( | R * | request | ) | [protected, pure virtual] |
Implemented in ACSServiceRequestChainContext.
std::set<ACSServiceType> RequestChainContext< R >::asyncStartInProgress [private] |
int RequestChainContext< R >::asyncToComplete [private] |
R* RequestChainContext< R >::curreq [private] |
bool RequestChainContext< R >::failed [private] |
bool RequestChainContext< R >::hasAsync [private] |
bool RequestChainContext< R >::inprocess [private] |
ACE_Thread_Mutex RequestChainContext< R >::mutex [private] |
Queue RequestChainContext< R >::requests |
RequestProcessorThread* RequestChainContext< R >::rpt [private] |
bool RequestChainContext< R >::syncPending [private] |