XrdCl::AsyncDiscardReader Class Reference

Object for discarding data. More...

#include <XrdClAsyncDiscardReader.hh>

Inheritance diagram for XrdCl::AsyncDiscardReader:

Collaboration diagram for XrdCl::AsyncDiscardReader:

Public Member Functions
	AsyncDiscardReader (const URL &url, const Message &request)
XRootDStatus	GetResponse (AnyObject *&response)
XRootDStatus	Read (Socket &socket, uint32_t &btsret)
Public Member Functions inherited from XrdCl::AsyncRawReaderIntfc
	AsyncRawReaderIntfc (const URL &url, const Message &request)
virtual	~AsyncRawReaderIntfc ()
	Destructor.
void	SetChunkList (ChunkList *chunks)
	Sets the chunk list with user buffers.
void	SetDataLength (int dlen)
	Sets response data length.

Additional Inherited Members
Protected Types inherited from XrdCl::AsyncRawReaderIntfc
using	buffer_t = std::vector<char>
enum	Stage {   ReadStart ,   ReadRdLst ,   ReadRaw ,   ReadDiscard ,   ReadDone }
	Stages of reading out a response from the socket. More...
Protected Member Functions inherited from XrdCl::AsyncRawReaderIntfc
XRootDStatus	ReadBytesAsync (Socket &socket, char *buffer, uint32_t toBeRead, uint32_t &bytesRead)
Protected Attributes inherited from XrdCl::AsyncRawReaderIntfc
size_t	chidx
size_t	chlen
size_t	choff
std::vector< ChunkStatus >	chstatus
ChunkList *	chunks
bool	dataerr
buffer_t	discardbuff
uint32_t	dlen
uint32_t	msgbtsrd
uint32_t	rawbtsrd
Stage	readstage
const Message &	request
const URL &	url

Detailed Description

Object for discarding data.

Definition at line 35 of file XrdClAsyncDiscardReader.hh.

Constructor & Destructor Documentation

AsyncDiscardReader()

XrdCl::AsyncDiscardReader::AsyncDiscardReader ( const URL & url, const Message & request )

inline

Constructor

Parameters

url	: channel URL
request	: client request

Definition at line 44 of file XrdClAsyncDiscardReader.hh.

                                                                   :
        AsyncRawReaderIntfc( url, request )
      {
      }

References XrdCl::AsyncRawReaderIntfc::AsyncRawReaderIntfc(), XrdCl::AsyncRawReaderIntfc::request, and XrdCl::AsyncRawReaderIntfc::url.

Referenced by XrdCl::XRootDMsgHandler::XRootDMsgHandler().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

GetResponse()

XRootDStatus XrdCl::AsyncDiscardReader::GetResponse ( AnyObject *& response )

inlinevirtual

Get the response, since we received some unexpected data we always return an error to the end user.

Implements XrdCl::AsyncRawReaderIntfc.

Definition at line 72 of file XrdClAsyncDiscardReader.hh.

      {
        response = nullptr;
        return XRootDStatus( stError, errInvalidResponse );
      }

References XrdCl::XRootDStatus::XRootDStatus(), XrdCl::errInvalidResponse, and XrdCl::stError.

Here is the call graph for this function:

Read()

XRootDStatus XrdCl::AsyncDiscardReader::Read ( Socket & socket, uint32_t & btsret )

inlinevirtual

Readout raw data from socket

Parameters

socket	: the socket
btsret	: number of bytes read

Returns

: operation status

Implements XrdCl::AsyncRawReaderIntfc.

Definition at line 56 of file XrdClAsyncDiscardReader.hh.

      {
        Log  *log = DefaultEnv::GetLog();
        log->Error( XRootDMsg, "[%s] Handling response to %s: "
                               "DiscardReader: we were not expecting "
                               "raw data.", url.GetHostId().c_str(),
                               request.GetObfuscatedDescription().c_str() );
        // Just drop the connection, we don't know if the stream is sane anymore.
        // Recover with a reconnect.
        return XRootDStatus( stError, errCorruptedHeader );
      }

References XrdCl::XRootDStatus::XRootDStatus(), XrdCl::errCorruptedHeader, XrdCl::Log::Error(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), XrdCl::Message::GetObfuscatedDescription(), XrdCl::AsyncRawReaderIntfc::request, XrdCl::stError, XrdCl::AsyncRawReaderIntfc::url, and XrdCl::XRootDMsg.

Here is the call graph for this function:

---

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

• XrdClAsyncDiscardReader.hh