XrdCl::EcPgReadResponseHandler Class Reference

#include <XrdClEcHandler.hh>

Inheritance diagram for XrdCl::EcPgReadResponseHandler:

Collaboration diagram for XrdCl::EcPgReadResponseHandler:

Public Member Functions
	EcPgReadResponseHandler (ResponseHandler *a)
void	HandleResponse (XRootDStatus *status, AnyObject *rdresp)
Public Member Functions inherited from XrdCl::ResponseHandler
virtual	~ResponseHandler ()
virtual void	HandleResponseWithHosts (XRootDStatus *status, AnyObject *response, HostList *hostList)

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

Definition at line 71 of file XrdClEcHandler.hh.

Constructor & Destructor Documentation

EcPgReadResponseHandler()

XrdCl::EcPgReadResponseHandler::EcPgReadResponseHandler ( ResponseHandler * a )

inline

Definition at line 77 of file XrdClEcHandler.hh.

: realHandler(a) {}

Member Function Documentation

HandleResponse()

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

Definition at line 80 of file XrdClEcHandler.hh.

    {
      if( !status->IsOK() )
      {
        realHandler->HandleResponse( status, rdresp );
        delete this;
        return;
      }
  
      ChunkInfo *chunk = 0;
      rdresp->Get(chunk);
 
      if (!chunk) {
        delete this;
        return;
      }
  
      std::vector<uint32_t> cksums;
      size_t nbpages = chunk->length / XrdSys::PageSize;
      if( chunk->length % XrdSys::PageSize )
        ++nbpages;
      cksums.reserve( nbpages );
 
      size_t  size = chunk->length;
      char   *buffer = reinterpret_cast<char*>( chunk->buffer );
 
      for( size_t pg = 0; pg < nbpages; ++pg )
      {
        size_t pgsize = XrdSys::PageSize;
        if( pgsize > size ) pgsize = size;
        uint32_t crcval = XrdOucCRC::Calc32C( buffer, pgsize );
        cksums.push_back( crcval );
        buffer += pgsize;
        size   -= pgsize;
      }
  
      PageInfo *pages = new PageInfo(chunk->offset, chunk->length, chunk->buffer, std::move(cksums));
      delete rdresp;
      AnyObject *response = new AnyObject();
      response->Set( pages );
      realHandler->HandleResponse( status, response );
  
      delete this;
    }

References XrdCl::ChunkInfo::buffer, XrdOucCRC::Calc32C(), XrdCl::AnyObject::Get(), XrdCl::Status::IsOK(), XrdCl::ChunkInfo::length, XrdCl::ChunkInfo::offset, XrdSys::PageSize, and XrdCl::AnyObject::Set().

Here is the call graph for this function:

---

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

• XrdClEcHandler.hh