XrdAdaptor::ClientRequest Class Reference

#include <XrdRequest.h>

Inheritance diagram for XrdAdaptor::ClientRequest:

Public Member Functions
	ClientRequest (RequestManager &manager, void *into, IOSize size, IOOffset off)
	ClientRequest (RequestManager &manager, std::shared_ptr< std::vector< IOPosBuffer > > iolist, IOSize size=0)
std::future< IOSize >	get_future ()
size_t	getCount () const
std::shared_ptr< Source >	getCurrentSource () const
IOSize	getSize () const
virtual void	HandleResponse (XrdCl::XRootDStatus *status, XrdCl::AnyObject *response) override
void	setStatistics (std::shared_ptr< XrdReadStatistics > stats)
virtual	~ClientRequest ()

Private Attributes
unsigned	m_failure_count
void *	m_into
std::shared_ptr< std::vector < IOPosBuffer > >	m_iolist
RequestManager &	m_manager
IOOffset	m_off
std::promise< IOSize >	m_promise
QualityMetricWatch	m_qmw
std::shared_ptr< ClientRequest >	m_self_reference
IOSize	m_size
std::shared_ptr< Source >	m_source
std::shared_ptr < XrdReadStatistics >	m_stats

Friends
class	Source

Detailed Description

Definition at line 22 of file XrdRequest.h.

Constructor & Destructor Documentation

XrdAdaptor::ClientRequest::ClientRequest ( RequestManager &  manager, void *  into, IOSize  size, IOOffset  off  )

inline

Definition at line 28 of file XrdRequest.h.

        : m_failure_count(0),
          m_into(into),
          m_size(size),
          m_off(off),
          m_iolist(nullptr),
          m_manager(manager)
    {
    }

XrdAdaptor::ClientRequest::ClientRequest ( RequestManager &  manager, std::shared_ptr< std::vector< IOPosBuffer > >  iolist, IOSize  size = 0  )

inline

Definition at line 38 of file XrdRequest.h.

References m_iolist, and m_size.

        : m_failure_count(0),
          m_into(nullptr),
          m_size(size),
          m_off(0),
          m_iolist(iolist),
          m_manager(manager)
    {
        if (m_iolist->size() && !m_size)
        {
            for (IOPosBuffer const & buf : *m_iolist)
            {
                m_size += buf.size();
            }
        }
    }

XrdAdaptor::ClientRequest::~ClientRequest ( )

virtual

Definition at line 20 of file XrdRequest.cc.

{}

Member Function Documentation

std::future<IOSize> XrdAdaptor::ClientRequest::get_future ( )

inline

Definition at line 62 of file XrdRequest.h.

References m_promise.

    {
        return m_promise.get_future();
    }

size_t XrdAdaptor::ClientRequest::getCount ( void  ) const

inline

Definition at line 74 of file XrdRequest.h.

References m_into, and m_iolist.

{return m_into ? 1 : m_iolist->size();}

std::shared_ptr<Source> XrdAdaptor::ClientRequest::getCurrentSource ( ) const

inline

Returns a pointer to the current source; may be nullptr if there is no outstanding IO

Definition at line 80 of file XrdRequest.h.

References m_source.

{return m_source;}

IOSize XrdAdaptor::ClientRequest::getSize ( ) const

inline

Definition at line 72 of file XrdRequest.h.

References m_size.

{return m_size;}

void XrdAdaptor::ClientRequest::HandleResponse ( XrdCl::XRootDStatus *  status, XrdCl::AnyObject *  response  )

overridevirtual

Handle the response from the Xrootd server.

Definition at line 23 of file XrdRequest.cc.

References cms::Exception::addAdditionalInfo(), cms::Exception::addContext(), FAKE_ERROR_COUNTER, edm::errors::FileReadError, g_fakeError, XrdAdaptor::XrootdException::getCode(), XrdAdaptor::Source::PrettyID(), source, contentValuesCheck::ss, ntuplemaker::status, and XrdAdaptor::QualityMetricWatch::swap().

{
    std::unique_ptr<XrdCl::AnyObject> response(resp);
    std::unique_ptr<XrdCl::XRootDStatus> status(stat);
    std::shared_ptr<ClientRequest> self_ref = m_self_reference;
    m_self_reference.reset();
    {
        QualityMetricWatch qmw;
        m_qmw.swap(qmw);
    }
    m_stats.reset();

    if ((!FAKE_ERROR_COUNTER || ((++g_fakeError % FAKE_ERROR_COUNTER) != 0)) && (status->IsOK() && resp))
    {
        if (m_into)
        {
            XrdCl::ChunkInfo *read_info;
            response->Get(read_info);
            m_promise.set_value(read_info->length);
        }
        else
        {
            XrdCl::VectorReadInfo *read_info;
            response->Get(read_info);
            m_promise.set_value(read_info->GetSize());
        }
    }
    else
    {
        Source *source = m_source.get();
        edm::LogWarning("XrdAdaptorInternal") << "XrdRequestManager::handle(name='"
          << m_manager.getFilename() << ") failure when reading from "
          << (source ? source->PrettyID() : "(unknown source)")
          << "; failed with error '" << status->ToStr() << "' (errno="
          << status->errNo << ", code=" << status->code << ").";
        m_failure_count++;
        try
        {
            try
            {
                m_manager.requestFailure(self_ref, *status);
                return;
            }
            catch (XrootdException& ex)
            {
                if (ex.getCode() == XrdCl::errInvalidResponse)
                {
                    m_promise.set_exception(std::current_exception());
                }
                else throw;
            }
        }
        catch (edm::Exception& ex)
        {
            ex.addContext("XrdAdaptor::ClientRequest::HandleResponse() failure while running connection recovery");
            std::stringstream ss;
            ss << "Original error: '" << status->ToStr() << "' (errno="
              << status->errNo << ", code=" << status->code << ", source=" << (source ? source->PrettyID() : "(unknown source)") << ").";
            ex.addAdditionalInfo(ss.str());
            m_promise.set_exception(std::current_exception());
            edm::LogWarning("XrdAdaptorInternal") << "Caught a CMSSW exception when running connection recovery.";
        }
        catch (...)
        {
            edm::Exception ex(edm::errors::FileReadError);
            ex << "XrdRequestManager::handle(name='" << m_manager.getFilename()
               << ") failed with error '" << status->ToStr()
               << "' (errno=" << status->errNo << ", code="
               << status->code << ").  Unknown exception occurred when running"
               << " connection recovery.";
            ex.addContext("Calling XrdRequestManager::handle()");
            m_manager.addConnections(ex);
            ex.addAdditionalInfo("Original source of error is " + (source ? source->PrettyID() : "(unknown source)"));
            m_promise.set_exception(std::make_exception_ptr(ex));
            edm::LogWarning("XrdAdaptorInternal") << "Caught a new exception when running connection recovery.";
        }
    }
}

void XrdAdaptor::ClientRequest::setStatistics ( std::shared_ptr< XrdReadStatistics >  stats )

inline

Definition at line 55 of file XrdRequest.h.

References m_stats.

    {
        m_stats = stats;
    }

Friends And Related Function Documentation

friend class Source

friend

Definition at line 24 of file XrdRequest.h.

Member Data Documentation

unsigned XrdAdaptor::ClientRequest::m_failure_count

private

Definition at line 83 of file XrdRequest.h.

void* XrdAdaptor::ClientRequest::m_into

private

Definition at line 84 of file XrdRequest.h.

Referenced by getCount().

std::shared_ptr<std::vector<IOPosBuffer> > XrdAdaptor::ClientRequest::m_iolist

private

Definition at line 87 of file XrdRequest.h.

Referenced by ClientRequest(), and getCount().

RequestManager& XrdAdaptor::ClientRequest::m_manager

private

Definition at line 88 of file XrdRequest.h.

IOOffset XrdAdaptor::ClientRequest::m_off

private

Definition at line 86 of file XrdRequest.h.

std::promise<IOSize> XrdAdaptor::ClientRequest::m_promise

private

Definition at line 99 of file XrdRequest.h.

Referenced by get_future().

QualityMetricWatch XrdAdaptor::ClientRequest::m_qmw

private

Definition at line 101 of file XrdRequest.h.

std::shared_ptr<ClientRequest> XrdAdaptor::ClientRequest::m_self_reference

private

Definition at line 97 of file XrdRequest.h.

IOSize XrdAdaptor::ClientRequest::m_size

private

Definition at line 85 of file XrdRequest.h.

Referenced by ClientRequest(), and getSize().

std::shared_ptr<Source> XrdAdaptor::ClientRequest::m_source

private

Definition at line 89 of file XrdRequest.h.

Referenced by getCurrentSource().

std::shared_ptr<XrdReadStatistics> XrdAdaptor::ClientRequest::m_stats

private

Definition at line 90 of file XrdRequest.h.

Referenced by setStatistics().