Wrapper class used to assign a load balancer. More...

Inheritance diagram for XrdCl::AssignLBHandler:

Collaboration diagram for XrdCl::AssignLBHandler:

Public Member Functions
	AssignLBHandler (std::shared_ptr< FileSystemData > &fs, ResponseHandler *userHandler)

virtual	~AssignLBHandler ()

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

Public Member Functions inherited from XrdCl::ResponseHandler
virtual	~ResponseHandler ()

virtual void	HandleResponse (XRootDStatus status, AnyObject response)

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 class used to assign a load balancer.

Definition at line 882 of file XrdClFileSystem.cc.

Constructor & Destructor Documentation

◆ AssignLBHandler()

XrdCl::AssignLBHandler::AssignLBHandler	(	std::shared_ptr< FileSystemData > &	fs,
		ResponseHandler *	userHandler )

inline

Definition at line 888 of file XrdClFileSystem.cc.

889 :

890 pFS(fs), pUserHandler(userHandler) {}

◆ ~AssignLBHandler()

virtual XrdCl::AssignLBHandler::~AssignLBHandler ( )

inlinevirtual

Definition at line 892 of file XrdClFileSystem.cc.

892{}

Member Function Documentation

◆ HandleResponseWithHosts()

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

virtual

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 from XrdCl::ResponseHandler.

Definition at line 1034 of file XrdClFileSystem.cc.

  {
    if( status->IsOK() )
    {
      HostList::reverse_iterator it;
      for( it = hostList->rbegin(); it != hostList->rend(); ++it )
        if( it->loadBalancer )
        {
          pFS->AssignLoadBalancer( it->url );
          break;
        }
    }
 
    bool finalrsp = !( status->IsOK() && status->code == suContinue );
 
    SyncResponseHandler * syncHandler = dynamic_cast<SyncResponseHandler*>( pUserHandler );
    if( !syncHandler )
      pUserHandler->HandleResponseWithHosts( status, response, hostList );
 
    if( finalrsp )
    {
      if( syncHandler )
        pUserHandler->HandleResponseWithHosts( status, response, hostList );
      delete this;
    }
  }

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

Here is the call graph for this function:

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

XrdClFileSystem.cc