XrdCl::ResponseHandler Class Reference

Handle an async response. More...

#include <XrdClXRootDResponses.hh>

Inheritance diagram for XrdCl::ResponseHandler:

Collaboration diagram for XrdCl::ResponseHandler:

Public Member Functions
virtual	~ResponseHandler ()
virtual void	HandleResponse (XRootDStatus *status, AnyObject *response)
virtual void	HandleResponseWithHosts (XRootDStatus *status, AnyObject *response, HostList *hostList)

Static Public Member Functions
static ResponseHandler *	Wrap (std::function< void(XRootDStatus &, AnyObject &)> func)
static ResponseHandler *	Wrap (std::function< void(XRootDStatus *, AnyObject *)> func)

Detailed Description

Handle an async response.

Definition at line 1185 of file XrdClXRootDResponses.hh.

Constructor & Destructor Documentation

~ResponseHandler()

virtual XrdCl::ResponseHandler::~ResponseHandler ( )

inlinevirtual

Definition at line 1188 of file XrdClXRootDResponses.hh.

{}

Member Function Documentation

HandleResponse()

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

inlinevirtual

Called when a response to associated request arrives or an error occurs

Parameters

status	status of the request
response	an object associated with the response (request dependent)

Reimplemented in XrdCl::ChunkHandler, XrdCl::EcPgReadResponseHandler, XrdCl::FutureWrapper< Response >, XrdCl::FutureWrapper< void >, XrdCl::MetalinkReadHandler, XrdCl::PipelineHandler, XrdCl::SyncResponseHandler, XrdCl::TaskWrapper< Response, Return >, XrdCl::TaskWrapper< void, Return >, XrdCl::UnpackXAttr, XrdCl::UnpackXAttrStatus, XrdCl::ZipListHandler, XrdPosixFile, XrdPosixFileRH, and XrdSsiEvent.

Definition at line 1215 of file XrdClXRootDResponses.hh.

      {
        (void)status; (void)response;
      }

Referenced by XrdCl::EcHandler::Close(), XrdClHttp::File::Close(), XrdCl::ZipArchive::CloseArchive(), XrdClHttp::File::Fcntl(), HandleResponseWithHosts(), XrdClHttp::Filesystem::Locate(), XrdClS3::Filesystem::MkDir(), XrdEc::Reader::Open(), XrdCl::ZipArchive::OpenArchive(), XrdCl::FileStateHandler::PgWrite(), XrdClHttp::File::Read(), XrdCl::ZipArchive::ReadFromImpl, XrdClS3::Filesystem::RmDir(), XrdClHttp::File::Stat(), XrdClHttp::File::VectorRead(), XrdEc::Reader::VectorRead(), Wrap(), and Wrap().

Here is the caller graph for this function:

HandleResponseWithHosts()

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

inlinevirtual

Called when a response to associated request arrives or an error occurs

Parameters

status	status of the request
response	an object associated with the response (request dependent)
hostList	list of hosts the request was redirected to

Reimplemented in XrdCl::AssignLastURLHandler, XrdCl::AssignLBHandler, XrdCl::ExOpenFuncWrapper, XrdCl::FunctionWrapper< Response >, XrdCl::FunctionWrapper< void >, XrdCl::MetalinkOpenHandler, XrdCl::NullResponseHandler, XrdCl::PipelineHandler, and XrdCl::RawWrapper.

Definition at line 1199 of file XrdClXRootDResponses.hh.

      {
        delete hostList;
        HandleResponse( status, response );
      }

References HandleResponse().

Referenced by XrdCl::AssignLastURLHandler::HandleResponseWithHosts(), XrdCl::AssignLBHandler::HandleResponseWithHosts(), XrdCl::LocalFileTask::Run(), and XrdCl::FileStateHandler::Stat().

Here is the call graph for this function:

Here is the caller graph for this function:

Wrap() [1/2]

ResponseHandler * XrdCl::ResponseHandler::Wrap ( std::function< void(XRootDStatus &, AnyObject &)> func )

static

Factory function for generating handler objects from lambdas

Parameters

func	: the callback, must not throw

Returns

: ResponseHandler wrapper with the user callback

Definition at line 760 of file XrdClXRootDResponses.cc.

  {
    struct FuncHandler : public ResponseHandler
    {
      FuncHandler( std::function<void(XRootDStatus&, AnyObject&)> func ) : func( std::move( func ) )
      {
      }
 
      void HandleResponse( XRootDStatus *status, AnyObject *response )
      {
        // make sure the arguments will be released
        std::unique_ptr<XRootDStatus> stptr( status );
        std::unique_ptr<AnyObject> rspptr( response );
        // if there is no response provide a null reference placeholder
        static AnyObject nullref;
        if( response == nullptr )
          response = &nullref;
        // call the user completion handler
        func( *status, *response );
        // check if this is a final respons
        bool finalrsp = !( status->IsOK() && status->code == suContinue );
        // deallocate the wrapper if final
        if( finalrsp )
          delete this;
      }
 
      std::function<void(XRootDStatus&, AnyObject&)> func;
    };
 
    return new FuncHandler( func );
  }

References XrdCl::Status::code, HandleResponse(), XrdCl::Status::IsOK(), and XrdCl::suContinue.

Referenced by XrdCl::EcHandler::Close(), and XrdCl::FileStateHandler::PgWrite().

Here is the call graph for this function:

Here is the caller graph for this function:

Wrap() [2/2]

ResponseHandler * XrdCl::ResponseHandler::Wrap ( std::function< void(XRootDStatus *, AnyObject *)> func )

static

Factory function for generating handler objects from lambdas

Parameters

func	: the callback, must not throw

Returns

: ResponseHandler wrapper with the user callback

Definition at line 792 of file XrdClXRootDResponses.cc.

  {
    struct FuncHandler : public ResponseHandler
    {
      FuncHandler( std::function<void(XRootDStatus*, AnyObject*)> func ) : func( std::move( func ) )
      {
      }
 
      void HandleResponse( XRootDStatus *status, AnyObject *response )
      {
        // check if this is a final respons
        bool finalrsp = !( status->IsOK() && status->code == suContinue );
        // call the user completion handler
        func( status, response );
        // deallocate the wrapper if final
        if( finalrsp )
          delete this;
      }
 
      std::function<void(XRootDStatus*, AnyObject*)> func;
    };
 
    return new FuncHandler( func );
  }

References XrdCl::Status::code, HandleResponse(), XrdCl::Status::IsOK(), and XrdCl::suContinue.

Here is the call graph for this function:

---

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

• XrdClXRootDResponses.hh
• XrdClXRootDResponses.cc