![]() |
XRootD
|
Object for reading out data from the kXR_read response. More...
#include <XrdClAsyncRawReader.hh>
Public Member Functions | |
AsyncRawReader (const URL &url, const Message &request) | |
XRootDStatus | GetResponse (AnyObject *&response) |
Get the response. More... | |
XRootDStatus | Read (Socket &socket, uint32_t &btsret) |
![]() | |
AsyncRawReaderIntfc (const URL &url, const Message &request) | |
virtual | ~AsyncRawReaderIntfc () |
Destructor. More... | |
void | SetChunkList (ChunkList *chunks) |
Sets the chunk list with user buffers. More... | |
void | SetDataLength (int dlen) |
Sets response data length. More... | |
Additional Inherited Members | |
![]() | |
using | buffer_t = std::vector< char > |
enum | Stage { ReadStart , ReadRdLst , ReadRaw , ReadDiscard , ReadDone } |
Stages of reading out a response from the socket. More... | |
![]() | |
XRootDStatus | ReadBytesAsync (Socket &socket, char *buffer, uint32_t toBeRead, uint32_t &bytesRead) |
![]() | |
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 |
Object for reading out data from the kXR_read response.
Definition at line 34 of file XrdClAsyncRawReader.hh.
Constructor
url | : channel URL |
request | : client request |
Definition at line 43 of file XrdClAsyncRawReader.hh.
|
inlinevirtual |
Get the response.
Implements XrdCl::AsyncRawReaderIntfc.
Definition at line 172 of file XrdClAsyncRawReader.hh.
References XrdCl::AsyncRawReaderIntfc::dataerr, XrdCl::errInvalidResponse, XrdCl::Message::GetVirtReqID(), kXR_virtReadv, XrdCl::AsyncRawReaderIntfc::request, and XrdCl::stError.
|
inlinevirtual |
Readout raw data from socket
socket | : the socket |
btsret | : number of bytes read |
Implements XrdCl::AsyncRawReaderIntfc.
Definition at line 55 of file XrdClAsyncRawReader.hh.
References XrdCl::AsyncRawReaderIntfc::chidx, XrdCl::AsyncRawReaderIntfc::chlen, XrdCl::AsyncRawReaderIntfc::choff, XrdCl::AsyncRawReaderIntfc::chunks, XrdCl::Status::code, XrdCl::AsyncRawReaderIntfc::dlen, XrdCl::errCorruptedHeader, XrdCl::errInternal, XrdCl::Log::Error(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), XrdCl::Message::GetObfuscatedDescription(), XrdCl::Status::IsOK(), XrdCl::AsyncRawReaderIntfc::msgbtsrd, XrdCl::AsyncRawReaderIntfc::rawbtsrd, XrdCl::AsyncRawReaderIntfc::ReadBytesAsync(), XrdCl::AsyncRawReaderIntfc::ReadDiscard, XrdCl::AsyncRawReaderIntfc::ReadDone, XrdCl::AsyncRawReaderIntfc::ReadRaw, XrdCl::AsyncRawReaderIntfc::readstage, XrdCl::AsyncRawReaderIntfc::ReadStart, XrdCl::AsyncRawReaderIntfc::request, XrdCl::stError, XrdCl::suRetry, XrdCl::AsyncRawReaderIntfc::url, and XrdCl::XRootDMsg.