#include <XrdClZipListHandler.hh>

Inheritance diagram for XrdCl::ZipListHandler:

Collaboration diagram for XrdCl::ZipListHandler:

Public Member Functions
	ZipListHandler (const URL &url, const std::string &path, DirListFlags::Flags flags, ResponseHandler *handler, uint16_t timeout=0)
	~ZipListHandler ()
	Destructor.
virtual void	HandleResponse (XrdCl::XRootDStatus statusptr, XrdCl::AnyObject responseptr)
	Handle the server response.
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 44 of file XrdClZipListHandler.hh.

Constructor & Destructor Documentation

◆ ZipListHandler()

XrdCl::ZipListHandler::ZipListHandler	(	const URL &	url,
		const std::string &	path,
		DirListFlags::Flags	flags,
		ResponseHandler *	handler,
		uint16_t	timeout = 0 )

inline

Constructor

Parameters

url	: endpoint URL
path	: path to the ZIP
flags	: listing flags
handler	: the original response handler
timeout	: operation timeout

Definition at line 73 of file XrdClZipListHandler.hh.

                                                         :
        pUrl( url ), pFlags( flags ), pHandler( handler ),
        pTimeout( timeout ), pStartTime( time( 0 ) ), pStep( STAT )
      {
        if( !pTimeout )
        {
          int val = DefaultRequestTimeout;
          DefaultEnv::GetEnv()->GetInt( "RequestTimeout", val );
          pTimeout = val;
        }
 
        pUrl.SetPath( path );
      }

References XrdCl::DefaultRequestTimeout, XrdCl::DefaultEnv::GetEnv(), and XrdCl::Env::GetInt().

Here is the call graph for this function:

◆ ~ZipListHandler()

XrdCl::ZipListHandler::~ZipListHandler ( )

inline

Destructor.

Definition at line 94 of file XrdClZipListHandler.hh.

      {
 
      }

Member Function Documentation

◆ HandleResponse()

void XrdCl::ZipListHandler::HandleResponse	(	XrdCl::XRootDStatus *	statusptr,
		XrdCl::AnyObject *	responseptr )

virtual

Handle the server response.

Reimplemented from XrdCl::ResponseHandler.

Definition at line 30 of file XrdClZipListHandler.cc.

  {
    std::unique_ptr<XRootDStatus> status( statusptr );
    std::unique_ptr<AnyObject>    response( responseptr );
 
    if( pStep == DONE )
    {
      delete this;
      return;
    }
 
    if( !status->IsOK() )
    {
      pHandler->HandleResponse( status.release(), response.release() );
      delete this;
      return;
    }
 
    time_t took = time( 0 ) - pStartTime;
    if( took > pTimeout )
    {
      *status = XRootDStatus( stError, errOperationExpired );
      pHandler->HandleResponse( status.release(), 0 );
      if( pZip.IsOpen() )
      {
        DoZipClose( 1 );
        pStep = DONE;
      }
      else
        delete this;
      return;
    }
    uint16_t left = pTimeout - took;
 
    switch( pStep )
    {
      case STAT:
      {
        StatInfo *info = 0;
        response->Get( info );
 
        if( info->TestFlags( StatInfo::IsDir ) )
          DoDirList( left );
        else
          DoZipOpen( left );
 
        break;
      }
 
      case OPEN:
      {
        DirectoryList *list = 0;
        XRootDStatus st = pZip.List( list );
        if( !st.IsOK() )
        {
          pHandler->HandleResponse( new XRootDStatus( st ), 0 );
          pStep = DONE;
        }
        else
        {
          pDirList.reset( list );
          DoZipClose( left );
        }
        break;
      }
 
      case CLOSE:
      {
        AnyObject *resp = new AnyObject();
        resp->Set( pDirList.release() );
        pHandler->HandleResponse( new XRootDStatus(), resp );
        pStep = DONE;
        break;
      }
    }
 
    if( pStep == DONE )
      delete this;
  }

References XrdCl::errOperationExpired, XrdCl::StatInfo::IsDir, XrdCl::Status::IsOK(), XrdCl::AnyObject::Set(), XrdCl::stError, and XrdCl::StatInfo::TestFlags().