![]() |
XRootD
|
#include <XrdClOperations.hh>
Public Member Functions | |
PipelineHandler () | |
Default Constructor. More... | |
PipelineHandler (ResponseHandler *handler) | |
~PipelineHandler () | |
Destructor. More... | |
void | AddOperation (Operation< true > *operation) |
void | Assign (const Timeout &timeout, std::promise< XRootDStatus > prms, std::function< void(const XRootDStatus &)> final, Operation< true > *opr) |
void | Assign (std::function< void(const XRootDStatus &)> final) |
Assign the finalization routine. More... | |
void | HandleResponse (XRootDStatus *status, AnyObject *response) |
Callback function. More... | |
void | HandleResponseWithHosts (XRootDStatus *status, AnyObject *response, HostList *hostList) |
Callback function. More... | |
void | PreparePipelineStart () |
Called by a pipeline on the handler of its first operation before Run. More... | |
![]() | |
virtual | ~ResponseHandler () |
Friends | |
template<bool > | |
class | Operation |
Additional Inherited Members | |
![]() | |
static ResponseHandler * | Wrap (std::function< void(XRootDStatus &, AnyObject &)> func) |
static ResponseHandler * | Wrap (std::function< void(XRootDStatus *, AnyObject *)> func) |
Wrapper for ResponseHandler, used only internally to run next operation after previous one is finished
Definition at line 63 of file XrdClOperations.hh.
XrdCl::PipelineHandler::PipelineHandler | ( | ResponseHandler * | handler | ) |
Constructor.
handler | : the handler of our operation |
Definition at line 85 of file XrdClOperations.cc.
|
inline |
|
inline |
void XrdCl::PipelineHandler::AddOperation | ( | Operation< true > * | operation | ) |
Add new operation to the pipeline
operation | : operation to add |
Definition at line 93 of file XrdClOperations.cc.
void XrdCl::PipelineHandler::Assign | ( | const Timeout & | timeout, |
std::promise< XRootDStatus > | prms, | ||
std::function< void(const XRootDStatus &)> | final, | ||
Operation< true > * | opr | ||
) |
Set workflow to this and all next handlers. In the last handler it is used to finish workflow execution
prms | : a promis that the pipeline will have a result |
final | : a callable that should be called at the end of pipeline |
Definition at line 189 of file XrdClOperations.cc.
Referenced by PreparePipelineStart().
void XrdCl::PipelineHandler::Assign | ( | std::function< void(const XRootDStatus &)> | final | ) |
Assign the finalization routine.
Definition at line 208 of file XrdClOperations.cc.
|
virtual |
Callback function.
Reimplemented from XrdCl::ResponseHandler.
Definition at line 180 of file XrdClOperations.cc.
|
virtual |
Callback function.
Reimplemented from XrdCl::ResponseHandler.
Definition at line 171 of file XrdClOperations.cc.
void XrdCl::PipelineHandler::PreparePipelineStart | ( | ) |
Called by a pipeline on the handler of its first operation before Run.
Definition at line 216 of file XrdClOperations.cc.
References Assign(), and XrdCl::Operation< HasHndl >::handler.
|
friend |
Definition at line 65 of file XrdClOperations.hh.