xrootd
|
#include <XrdClOperations.hh>
Public Member Functions | |
Pipeline () | |
Default constructor. | |
Pipeline (Operation< true > *op) | |
Constructor. | |
Pipeline (Operation< true > &op) | |
Constructor. | |
Pipeline (Operation< true > &&op) | |
Constructor. | |
Pipeline (Operation< false > *op) | |
Pipeline (Operation< false > &op) | |
Constructor. | |
Pipeline (Operation< false > &&op) | |
Constructor. | |
Pipeline (Pipeline &&pipe) | |
Pipeline & | operator= (Pipeline &&pipe) |
Constructor. | |
Pipeline & | operator|= (Operation< true > &&op) |
Extend pipeline. | |
Pipeline & | operator|= (Operation< false > &&op) |
Extend pipeline. | |
operator Operation< true > & () | |
operator bool () | |
Static Public Member Functions | |
static void | Stop (const XRootDStatus &status=XrdCl::XRootDStatus()) |
static void | Repeat () |
Repeat current operation. | |
static void | Replace (Operation< false > &&opr) |
Replace current operation. | |
static void | Replace (Pipeline p) |
Replace with pipeline. | |
static void | Ignore () |
Ignore error and proceed with the pipeline. | |
Private Member Functions | |
Operation< true > * | operator-> () |
void | Run (Timeout timeout, std::function< void(const XRootDStatus &)> final=nullptr) |
Private Attributes | |
std::unique_ptr< Operation< true > > | operation |
First operation in the pipeline. | |
std::future< XRootDStatus > | ftr |
The future result of the pipeline. | |
Friends | |
template<bool > | |
class | ParallelOperation |
class | PipelineHandler |
std::future< XRootDStatus > | Async (Pipeline, uint16_t) |
A wrapper around operation pipeline. A Pipeline is a once-use-only object - once executed by a Workflow engine it is invalidated.
Takes ownership of given operation pipeline (which is in most would be a temporary object)
|
inline |
Default constructor.
|
inline |
Constructor.
|
inline |
Constructor.
|
inline |
Constructor.
|
inline |
|
inline |
Constructor.
|
inline |
Constructor.
|
inline |
|
static |
Ignore error and proceed with the pipeline.
|
inline |
|
inline |
Conversion to Operation<true>
std::logic_error if pipeline is invalid |
References operation.
|
inlineprivate |
Member access declaration, provides access to the underlying operation.
References operation.
Extend pipeline.
References operation.
Extend pipeline.
References operation.
|
static |
Repeat current operation.
|
static |
Replace current operation.
|
static |
Replace with pipeline.
|
inlineprivate |
Schedules the underlying pipeline for execution.
timeout | : pipeline timeout value |
final | : to be called at the end of the pipeline |
References ftr, XrdCl::Operation< HasHndl >::handler, operation, XrdCl::PipelineHandler::PreparePipelineStart(), and XrdCl::Operation< HasHndl >::Run().
|
static |
Stop the current pipeline
status | : the final status for the pipeline |
|
friend |
Helper function, schedules execution of given pipeline
pipeline | : the pipeline to be executed |
timeout | : the pipeline timeout |
|
friend |
|
friend |
|
private |
The future result of the pipeline.
Referenced by Run().
|
private |
First operation in the pipeline.
Referenced by operator bool(), operator Operation< true > &(), operator->(), operator=(), operator|=(), operator|=(), and Run().