XrdCl::PipelineHandler Class Reference

#include <XrdClOperations.hh>

Inheritance diagram for XrdCl::PipelineHandler:

Collaboration diagram for XrdCl::PipelineHandler:

Public Member Functions
	PipelineHandler (ResponseHandler *handler)
	PipelineHandler ()
	Default Constructor. More...
void	HandleResponseWithHosts (XRootDStatus *status, AnyObject *response, HostList *hostList)
	Callback function. More...
void	HandleResponse (XRootDStatus *status, AnyObject *response)
	Callback function. More...
	~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	PreparePipelineStart ()
	Called by a pipeline on the handler of its first operation before Run. More...
Public Member Functions inherited from XrdCl::ResponseHandler
virtual	~ResponseHandler ()

Private Member Functions
void	HandleResponseImpl (XRootDStatus *status, AnyObject *response, HostList *hostList=nullptr)
	Callback function implementation;. More...
void	dealloc (XRootDStatus *status, AnyObject *response, HostList *hostList)

Private Attributes
std::unique_ptr< ResponseHandler >	responseHandler
	The handler of our operation. More...
std::unique_ptr< Operation < true > >	currentOperation
	The operation the handler is assigned to. More...
std::unique_ptr< Operation < true > >	nextOperation
	Next operation in the pipeline. More...
Timeout	timeout
	Pipeline timeout. More...
std::promise< XRootDStatus >	prms
	The promise that there will be a result (traveling along the pipeline) More...
std::function< void(const XRootDStatus &)>	final

Friends
template<bool >
class	Operation

Additional Inherited Members
Static Public Member Functions inherited from XrdCl::ResponseHandler
static ResponseHandler *	Wrap (std::function< void(XRootDStatus &, AnyObject &)> func)
static ResponseHandler *	Wrap (std::function< void(XRootDStatus *, AnyObject *)> func)

Detailed Description

Wrapper for ResponseHandler, used only internally to run next operation after previous one is finished

Constructor & Destructor Documentation

XrdCl::PipelineHandler::PipelineHandler

(

ResponseHandler *

handler

)

Constructor.

Parameters

handler

: the handler of our operation

XrdCl::PipelineHandler::PipelineHandler ( )

inline

Default Constructor.

XrdCl::PipelineHandler::~PipelineHandler ( )

inline

Destructor.

Member Function Documentation

void XrdCl::PipelineHandler::AddOperation

(

Operation< true > *

operation

)

Add new operation to the pipeline

Parameters

operation

: operation to add

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

Parameters

prms	: a promis that the pipeline will have a result
final	: a callable that should be called at the end of pipeline

void XrdCl::PipelineHandler::Assign

(

std::function< void(const XRootDStatus &)>

final

)

Assign the finalization routine.

void XrdCl::PipelineHandler::dealloc ( XRootDStatus *  status, AnyObject *  response, HostList *  hostList  )

inlineprivate

void XrdCl::PipelineHandler::HandleResponse ( XRootDStatus *  status, AnyObject *  response  )

virtual

Callback function.

Reimplemented from XrdCl::ResponseHandler.

Referenced by XrdCl::ParallelOperation< HasHndl >::Ctx::Handle(), XrdCl::OpenFileImpl< HasHndl >::RunImpl(), XrdCl::CloseFileImpl< HasHndl >::RunImpl(), XrdCl::ZipStatImpl< HasHndl >::RunImpl(), and XrdCl::ZipListImpl< HasHndl >::RunImpl().

void XrdCl::PipelineHandler::HandleResponseImpl ( XRootDStatus *  status, AnyObject *  response, HostList *  hostList = nullptr  )

private

Callback function implementation;.

void XrdCl::PipelineHandler::HandleResponseWithHosts ( XRootDStatus *  status, AnyObject *  response, HostList *  hostList  )

virtual

Callback function.

Reimplemented from XrdCl::ResponseHandler.

void XrdCl::PipelineHandler::PreparePipelineStart

(

)

Called by a pipeline on the handler of its first operation before Run.

Referenced by XrdCl::Pipeline::Run().

Friends And Related Function Documentation

template<bool >

friend class Operation

friend

Member Data Documentation

std::unique_ptr<Operation<true> > XrdCl::PipelineHandler::currentOperation

private

The operation the handler is assigned to.

std::function<void(const XRootDStatus&)> XrdCl::PipelineHandler::final

private

The lambda/function/functor that should be called at the end of the pipeline (traveling along the pipeline)

std::unique_ptr<Operation<true> > XrdCl::PipelineHandler::nextOperation

private

Next operation in the pipeline.

std::promise<XRootDStatus> XrdCl::PipelineHandler::prms

private

The promise that there will be a result (traveling along the pipeline)

std::unique_ptr<ResponseHandler> XrdCl::PipelineHandler::responseHandler

private

The handler of our operation.

Timeout XrdCl::PipelineHandler::timeout

private

Pipeline timeout.

---

The documentation for this class was generated from the following file:

• XrdClOperations.hh