|
xrootd
|
Public Member Functions | |
| Ctx (PipelineHandler *handler, PolicyExecutor *policy) | |
| ~Ctx () | |
| Destructor. More... | |
| void | Examine (const XRootDStatus &st) |
| void | Handle (const XRootDStatus &st) |
Public Attributes | |
| std::atomic< PipelineHandler * > | handler |
| PipelineHandler of the ParallelOperation. More... | |
| std::unique_ptr< PolicyExecutor > | policy |
| Policy defining when the user handler should be called. More... | |
Helper class for handling the PipelineHandler of the ParallelOperation (RAII).
Guarantees that the handler will be executed exactly once.
|
inline |
Constructor.
| handler | : the PipelineHandler of the Parallel operation |
|
inline |
Destructor.
References XrdCl::ParallelOperation< HasHndl >::Ctx::Handle().
|
inline |
Forwards the status to the PipelineHandler if the handler haven't been called yet.
| st | : status |
References XrdCl::ParallelOperation< HasHndl >::Ctx::Handle(), and XrdCl::ParallelOperation< HasHndl >::Ctx::policy.
|
inline |
Forwards the status to the PipelineHandler if the handler haven't been called yet.
| st | : status |
References XrdCl::ParallelOperation< HasHndl >::Ctx::handler, and XrdCl::PipelineHandler::HandleResponse().
Referenced by XrdCl::ParallelOperation< HasHndl >::Ctx::Examine(), and XrdCl::ParallelOperation< HasHndl >::Ctx::~Ctx().
| std::atomic<PipelineHandler*> XrdCl::ParallelOperation< HasHndl >::Ctx::handler |
PipelineHandler of the ParallelOperation.
Referenced by XrdCl::ParallelOperation< HasHndl >::Ctx::Handle().
| std::unique_ptr<PolicyExecutor> XrdCl::ParallelOperation< HasHndl >::Ctx::policy |
Policy defining when the user handler should be called.
Referenced by XrdCl::ParallelOperation< HasHndl >::Ctx::Examine().