![]() |
XRootD
|
#include <XrdClParallelOperation.hh>
Public Member Functions | |
template<class Container > | |
ParallelOperation (Container &&container) | |
template<bool from> | |
ParallelOperation (ParallelOperation< from > &&obj) | |
Constructor: copy-move a ParallelOperation in different state. More... | |
~ParallelOperation () | |
ParallelOperation< HasHndl > | All () |
ParallelOperation< HasHndl > | Any () |
ParallelOperation< HasHndl > | AtLeast (size_t threshold) |
ParallelOperation< HasHndl > | Some (size_t threshold) |
std::string | ToString () |
![]() | |
ConcreteOperation (Args &&... args) | |
ConcreteOperation (ConcreteOperation< ParallelOperation, from, Resp< void >, Args... > &&op) | |
Operation< HasHndl > * | Move () |
ParallelOperation< true > | operator>> (Hdlr &&hdlr) |
ParallelOperation< true > | operator| (FinalOperation &&fo) |
Adds a final operation to the pipeline. More... | |
ParallelOperation< true > | operator| (Operation< false > &&op) |
ParallelOperation< true > | operator| (Operation< false > &op) |
ParallelOperation< true > | operator| (Operation< true > &&op) |
ParallelOperation< true > | operator| (Operation< true > &op) |
ParallelOperation< HasHndl > | Timeout (uint16_t timeout) |
Set operation timeout. More... | |
Operation< true > * | ToHandled () |
![]() | |
Operation () | |
Constructor. More... | |
template<bool from> | |
Operation (Operation< from > &&op) | |
Move constructor between template instances. More... | |
virtual | ~Operation () |
Destructor. More... | |
Friends | |
template<bool > | |
class | ParallelOperation |
Additional Inherited Members | |
![]() | |
ParallelOperation< true > | StreamImpl (ResponseHandler *handler) |
ParallelOperation< to > | Transform () |
![]() | |
void | AddOperation (Operation< true > *op) |
void | Run (Timeout timeout, std::promise< XRootDStatus > prms, std::function< void(const XRootDStatus &)> final) |
![]() | |
static void | AllocHandler (ConcreteOperation< ParallelOperation, false, Resp< void >, Args... > &me) |
static void | AllocHandler (ConcreteOperation< ParallelOperation, true, Resp< void >, Args... > &me) |
static ParallelOperation< true > | PipeImpl (ConcreteOperation< ParallelOperation, HasHndl, Resp< void >, Args... > &me, Operation< false > &op) |
static ParallelOperation< true > | PipeImpl (ConcreteOperation< ParallelOperation, HasHndl, Resp< void >, Args... > &me, Operation< true > &op) |
![]() | |
std::tuple< Args... > | args |
Operation arguments. More... | |
uint16_t | timeout |
Operation timeout. More... | |
![]() | |
std::unique_ptr< PipelineHandler > | handler |
Operation handler. More... | |
bool | valid |
Flag indicating if it is a valid object. More... | |
Parallel operations, allows to execute two or more pipelines in parallel.
Definition at line 79 of file XrdClParallelOperation.hh.
|
inline |
Constructor: copy-move a ParallelOperation in different state.
Definition at line 89 of file XrdClParallelOperation.hh.
|
inline |
Constructor
container | : iterable container with pipelines |
Definition at line 104 of file XrdClParallelOperation.hh.
|
inline |
Definition at line 115 of file XrdClParallelOperation.hh.
|
inline |
Set policy to All
(default)
All operations need to succeed in order for the parallel operation to be successful.
Definition at line 144 of file XrdClParallelOperation.hh.
|
inline |
Set policy to Any
Just one of the operations needs to succeed in order for the parallel operation to be successful.
Definition at line 156 of file XrdClParallelOperation.hh.
|
inline |
Set policy to At Least
.
At least n (user defined) operations need to succeed in order for the parallel operation to be successful (the user handler will be called only when all operations are resolved).
Definition at line 181 of file XrdClParallelOperation.hh.
|
inline |
n (user defined) operations need to succeed in order for the parallel operation to be successful.
Definition at line 168 of file XrdClParallelOperation.hh.
|
inlinevirtual |
Implements XrdCl::Operation< HasHndl >.
Definition at line 122 of file XrdClParallelOperation.hh.
Definition at line 81 of file XrdClParallelOperation.hh.