xrootd
|
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. | |
barrier_t | barrier |
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::barrier, XrdCl::ParallelOperation< HasHndl >::Ctx::handler, XrdCl::PipelineHandler::HandleResponse(), and XrdCl::ParallelOperation< HasHndl >::barrier_t::wait().
Referenced by XrdCl::ParallelOperation< HasHndl >::Ctx::Examine(), and XrdCl::ParallelOperation< HasHndl >::Ctx::~Ctx().
barrier_t XrdCl::ParallelOperation< HasHndl >::Ctx::barrier |
wait barrier that assures handler is called only after RunImpl started all pipelines
Referenced by XrdCl::ParallelOperation< HasHndl >::Ctx::Handle().
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().