#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] |
1.7.0