Public Member Functions | |
Ctx (PipelineHandler *handler, PolicyExecutor *policy) | |
~Ctx () | |
Destructor. | |
void | Examine (const XRootDStatus &st) |
void | Handle (const XRootDStatus &st) |
Public Attributes | |
std::atomic< PipelineHandler * > | handler |
PipelineHandler of the ParallelOperation. | |
std::unique_ptr< PolicyExecutor > | policy |
Policy defining when the user handler should be called. |
Helper class for handling the PipelineHandler of the ParallelOperation (RAII).
Guarantees that the handler will be executed exactly once.
XrdCl::ParallelOperation< HasHndl >::Ctx::Ctx | ( | PipelineHandler * | handler, | |
PolicyExecutor * | policy | |||
) | [inline] |
Constructor.
handler | : the PipelineHandler of the Parallel operation |
XrdCl::ParallelOperation< HasHndl >::Ctx::~Ctx | ( | ) | [inline] |
Destructor.
References XrdCl::ParallelOperation< HasHndl >::Ctx::Handle().
void XrdCl::ParallelOperation< HasHndl >::Ctx::Examine | ( | const XRootDStatus & | st | ) | [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.
void XrdCl::ParallelOperation< HasHndl >::Ctx::Handle | ( | const XRootDStatus & | st | ) | [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().