#include <XrdClParallelOperation.hh>

Inheritance diagram for XrdCl::ParallelOperation< HasHndl >:

Collaboration diagram for XrdCl::ParallelOperation< HasHndl >:

Classes
struct	AllPolicy

struct	AnyPolicy

struct	AtLeastPolicy

struct	Ctx

struct	SomePolicy

Public Member Functions
template<bool from>
	ParallelOperation (ParallelOperation< from > &&obj)
	Constructor: copy-move a ParallelOperation in different state. More...

template<class Container >
	ParallelOperation (Container &&container)

std::string	ToString ()

ParallelOperation< HasHndl >	All ()

ParallelOperation< HasHndl >	Any ()

ParallelOperation< HasHndl >	Some (size_t threshold)

ParallelOperation< HasHndl >	AtLeast (size_t threshold)

Public Member Functions inherited from XrdCl::ConcreteOperation< ParallelOperation, HasHndl, Resp< void > >
	ConcreteOperation (Args &&... args)

	ConcreteOperation (ConcreteOperation< ParallelOperation, from, Resp< void >, Args... > &&op)

ParallelOperation< true >	operator>> (Hdlr &&hdlr)

ParallelOperation< true >	operator\| (Operation< true > &op)

ParallelOperation< true >	operator\| (Operation< true > &&op)

ParallelOperation< true >	operator\| (Operation< false > &op)

ParallelOperation< true >	operator\| (Operation< false > &&op)

ParallelOperation< HasHndl >	Recovery (rcvry_func recovery)
	Set recovery procedure in case the operation fails. More...

Operation< HasHndl > *	Move ()

Operation< true > *	ToHandled ()

Public Member Functions inherited from XrdCl::Operation< HasHndl >
	Operation ()
	Constructor. More...

template<bool from>
	Operation (Operation< from > &&op)
	Move constructor between template instances. More...

virtual	~Operation ()
	Destructor. More...

Private Member Functions
XRootDStatus	RunImpl ()

Private Attributes
std::vector< Pipeline >	pipelines

std::unique_ptr< PolicyExecutor >	policy

Friends
template<bool >
class	ParallelOperation

Additional Inherited Members
Protected Member Functions inherited from XrdCl::ConcreteOperation< ParallelOperation, HasHndl, Resp< void > >
ParallelOperation< to >	Transform ()

ParallelOperation< true >	StreamImpl (ResponseHandler *handler)

Protected Member Functions inherited from XrdCl::Operation< HasHndl >
void	Run (std::promise< XRootDStatus > prms, std::function< void(const XRootDStatus &)> final)

void	ForceHandler (const XRootDStatus &status)

void	AddOperation (Operation< true > *op)

Static Protected Member Functions inherited from XrdCl::ConcreteOperation< ParallelOperation, HasHndl, Resp< void > >
static ParallelOperation< true >	PipeImpl (ConcreteOperation< ParallelOperation, true, Resp< void >, Args... > &me, Operation< true > &op)

static ParallelOperation< true >	PipeImpl (ConcreteOperation< ParallelOperation, true, Resp< void >, Args... > &me, Operation< false > &op)

static ParallelOperation< true >	PipeImpl (ConcreteOperation< ParallelOperation, false, Resp< void >, Args... > &me, Operation< true > &op)

static ParallelOperation< true >	PipeImpl (ConcreteOperation< ParallelOperation, false, Resp< void >, Args... > &me, Operation< false > &op)

Protected Attributes inherited from XrdCl::ConcreteOperation< ParallelOperation, HasHndl, Resp< void > >
std::tuple< Args... >	args
	Operation arguments. More...

rcvry_func	recovery
	The recovery routine for this operation. More...

Protected Attributes inherited from XrdCl::Operation< HasHndl >
std::unique_ptr< PipelineHandler >	handler
	Operation handler. More...

bool	valid
	Flag indicating if it is a valid object. More...

Detailed Description

template<bool HasHndl>
class XrdCl::ParallelOperation< HasHndl >

Parallel operations, allows to execute two or more pipelines in parallel.

state : describes current operation configuration state (
See also
Operation)

Constructor & Destructor Documentation

◆ ParallelOperation() [1/2]

template<bool HasHndl>

template<bool from>

XrdCl::ParallelOperation< HasHndl >::ParallelOperation ( ParallelOperation< from > && obj )

inline

Constructor: copy-move a ParallelOperation in different state.

◆ ParallelOperation() [2/2]

template<bool HasHndl>

template<class Container >

XrdCl::ParallelOperation< HasHndl >::ParallelOperation ( Container && container )

inline

Constructor

Container : iterable container type

Parameters

container : iterable container with pipelines

References XrdCl::ParallelOperation< HasHndl >::pipelines.

Member Function Documentation

◆ All()

template<bool HasHndl>

ParallelOperation<HasHndl> XrdCl::ParallelOperation< HasHndl >::All ( )

inline

Set policy to All (default)

All operations need to succeed in order for the parallel operation to be successful.

References XrdCl::ParallelOperation< HasHndl >::policy.

◆ Any()

template<bool HasHndl>

ParallelOperation<HasHndl> XrdCl::ParallelOperation< HasHndl >::Any ( )

inline

Set policy to Any

Just one of the operations needs to succeed in order for the parallel operation to be successful.

References XrdCl::ParallelOperation< HasHndl >::pipelines, and XrdCl::ParallelOperation< HasHndl >::policy.

◆ AtLeast()

template<bool HasHndl>

ParallelOperation<HasHndl> XrdCl::ParallelOperation< HasHndl >::AtLeast ( size_t threshold )

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).

References XrdCl::ParallelOperation< HasHndl >::pipelines, and XrdCl::ParallelOperation< HasHndl >::policy.