#include <XrdClHttpOps.hh>

Inheritance diagram for XrdClHttp::CurlQueryOp:

Collaboration diagram for XrdClHttp::CurlQueryOp:

Public Member Functions
	CurlQueryOp (XrdCl::ResponseHandler handler, const std::string &url, struct timespec timeout, XrdCl::Log log, bool response_info, CreateConnCalloutType callout, int queryCode, HeaderCallout *header_callout)
virtual	~CurlQueryOp ()
void	Success () override
Public Member Functions inherited from XrdClHttp::CurlStatOp
	CurlStatOp (XrdCl::ResponseHandler handler, const std::string &url, struct timespec timeout, XrdCl::Log log, bool response_info, CreateConnCalloutType callout, HeaderCallout *header_callout)
virtual	~CurlStatOp ()
std::pair< int64_t, bool >	GetStatInfo ()
virtual HttpVerb	GetVerb () const override
virtual void	OptionsDone () override
RedirectAction	Redirect (std::string &target) override
void	ReleaseHandle () override
virtual bool	RequiresOptions () const override
bool	Setup (CURL *curl, CurlWorker &) override
void	Success () override
Public Member Functions inherited from XrdClHttp::CurlOperation
	CurlOperation (const CurlOperation &)=delete
	CurlOperation (XrdCl::ResponseHandler handler, const std::string &url, std::chrono::steady_clock::time_point expiry, XrdCl::Log log, CreateConnCalloutType, HeaderCallout *header_callout)
	CurlOperation (XrdCl::ResponseHandler handler, const std::string &url, struct timespec timeout, XrdCl::Log log, CreateConnCalloutType, HeaderCallout *header_callout)
virtual	~CurlOperation ()
virtual bool	ContinueHandle ()
virtual void	Fail (uint16_t errCode, uint32_t errNum, const std::string &)
bool	FinishSetup (CURL *curl)
std::pair< XErrorCode, std::string >	GetCallbackError () const
CreateConnCalloutType	GetConnCalloutFunc () const
std::string	GetCurlErrorMessage () const
CURL *	GetCurlHandle () const
OpError	GetError () const
std::chrono::steady_clock::time_point	GetHeaderExpiry () const
std::chrono::steady_clock::time_point	GetOperationExpiry ()
std::unique_ptr< ResponseInfo >	GetResponseInfo ()
int	GetStatusCode () const
std::string	GetStatusMessage () const
bool	GetTriedBoker () const
const std::string &	GetUrl () const
bool	HasFailed () const
bool	HeaderTimeoutExpired (const std::chrono::steady_clock::time_point &now)
bool	IsDone () const
bool	IsPaused () const
bool	IsRedirect () const
std::unique_ptr< ResponseInfo >	MoveResponseInfo ()
bool	OperationTimeoutExpired (const std::chrono::steady_clock::time_point &now)
virtual void	SetContinueQueue (std::shared_ptr< XrdClHttp::HandlerQueue > queue)
void	SetTriedBoker ()
bool	StartConnectionCallout (std::string &err)
std::tuple< uint64_t, std::chrono::steady_clock::duration, std::chrono::steady_clock::duration, std::chrono::steady_clock::duration >	StatisticsReset ()
bool	TransferStalled (uint64_t xfer_bytes, const std::chrono::steady_clock::time_point &now)
bool	UseConnectionCallout ()
virtual int	WaitSocket ()
virtual int	WaitSocketCallback (std::string &err)

Public Attributes
int	m_queryCode
std::string	m_queryVal

Additional Inherited Members
Public Types inherited from XrdClHttp::CurlOperation
using	HeaderList = std::vector<std::pair<std::string, std::string>>
enum class	HttpVerb { COPY , DELETE , HEAD , GET , MKCOL , OPTIONS , PROPFIND , PUT , Count }
enum	OpError { ErrNone , ErrHeaderTimeout , ErrCallback , ErrOperationTimeout , ErrTransferClientStall , ErrTransferStall , ErrTransferSlow }
enum class	RedirectAction { Fail , Reinvoke , ReinvokeAfterAllow }
Static Public Member Functions inherited from XrdClHttp::CurlOperation
static void	CleanupDnsCache ()
static int	GetDefaultSlowRateBytesSec ()
static int	GetDefaultStallTimeout ()
static const std::string	GetVerbString (HttpVerb)
static void	SetSlowRateBytesSec (int rate)
static void	SetStallTimeout (const std::chrono::steady_clock::duration &stall_interval)
static void	SetStallTimeout (int stall_interval)
Protected Member Functions inherited from XrdClHttp::CurlStatOp
void	SuccessImpl (bool returnObj)
Protected Member Functions inherited from XrdClHttp::CurlOperation
int	FailCallback (XErrorCode ecode, const std::string &emsg)
void	SetDone (bool has_failed)
void	SetPaused (bool paused)
void	UpdateBytes (uint64_t bytes)
Protected Attributes inherited from XrdClHttp::CurlOperation
std::unique_ptr< CURL, void()(CURL )>	m_curl
XrdCl::ResponseHandler *	m_handler {nullptr}
HeaderCallout *	m_header_callout
std::chrono::steady_clock::time_point	m_header_expiry
HeaderParser	m_headers
std::vector< std::pair< std::string, std::string > >	m_headers_list
XrdCl::Log *	m_logger
int	m_minimum_rate {m_minimum_transfer_rate}
std::chrono::steady_clock::time_point	m_operation_expiry
const std::string	m_url
Static Protected Attributes inherited from XrdClHttp::CurlOperation
static constexpr int	m_default_minimum_rate {1024 * 256}
static int	m_minimum_transfer_rate {CurlOperation::m_default_minimum_rate}

Detailed Description

Definition at line 594 of file XrdClHttpOps.hh.

Constructor & Destructor Documentation

◆ CurlQueryOp()

XrdClHttp::CurlQueryOp::CurlQueryOp	(	XrdCl::ResponseHandler *	handler,
		const std::string &	url,
		struct timespec	timeout,
		XrdCl::Log *	log,
		bool	response_info,
		CreateConnCalloutType	callout,
		int	queryCode,
		HeaderCallout *	header_callout )

inline

Definition at line 596 of file XrdClHttpOps.hh.

                                                                                                                        :
    CurlStatOp(handler, url, timeout, log, response_info, callout, header_callout),
    m_queryCode(queryCode)
    {
    }

References XrdClHttp::CurlStatOp::CurlStatOp(), and m_queryCode.

Here is the call graph for this function:

◆ ~CurlQueryOp()

virtual XrdClHttp::CurlQueryOp::~CurlQueryOp ( )

inlinevirtual

Definition at line 603 of file XrdClHttpOps.hh.

603{}

Member Function Documentation

◆ Success()

void CurlQueryOp::Success ( )

overridevirtual

Implements XrdClHttp::CurlOperation.

Definition at line 28 of file XrdClHttpOpQuery.cc.

{
    SetDone(false);
    m_logger->Debug(kLogXrdClHttp, "CurlQueryOp::Success");
 
    if (m_queryCode == XrdCl::QueryCode::XAttr) {
        XrdCl::Buffer *qInfo = new XrdCl::Buffer();
        qInfo->FromString(m_headers.GetETag());
        auto obj = new XrdCl::AnyObject();
        obj->Set(qInfo);
 
        m_handler->HandleResponse(new XrdCl::XRootDStatus(), obj);
        m_handler = nullptr;
    }
    else {
        m_logger->Error(kLogXrdClHttp, "Invalid information query type code");
        Fail(XrdCl::errInvalidArgs, XrdCl::errErrorResponse, "Unsupported query code");
    }
}

References XrdCl::errErrorResponse, XrdCl::errInvalidArgs, XrdClHttp::CurlOperation::Fail(), XrdCl::Buffer::FromString(), XrdClHttp::kLogXrdClHttp, XrdClHttp::CurlOperation::m_handler, XrdClHttp::CurlOperation::m_headers, XrdClHttp::CurlOperation::m_logger, m_queryCode, XrdClHttp::CurlOperation::SetDone(), and XrdCl::QueryCode::XAttr.

Here is the call graph for this function:

Member Data Documentation

◆ m_queryCode

int XrdClHttp::CurlQueryOp::m_queryCode

Definition at line 607 of file XrdClHttpOps.hh.

Referenced by CurlQueryOp(), and Success().

◆ m_queryVal

std::string XrdClHttp::CurlQueryOp::m_queryVal

Definition at line 608 of file XrdClHttpOps.hh.

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

	XRootD

Public Member Functions

Public Attributes

Additional Inherited Members