19 #ifndef SRC_XRDCL_XRDCLASYNCRAWREADERINTFC_HH_
20 #define SRC_XRDCL_XRDCLASYNCRAWREADERINTFC_HH_
76 this->
chstatus.resize( chunks->size() );
101 uint32_t &bytesRead )
104 while( toBeRead > 0 )
107 Status status = socket.
Read( buffer + shift, toBeRead, btsRead );
112 bytesRead += btsRead;
Base class for any message's body reader.
virtual XRootDStatus GetResponse(AnyObject *&response)=0
Get the response.
std::vector< ChunkStatus > chstatus
XRootDStatus ReadBytesAsync(Socket &socket, char *buffer, uint32_t toBeRead, uint32_t &bytesRead)
void SetDataLength(int dlen)
Sets response data length.
virtual XRootDStatus Read(Socket &socket, uint32_t &btsret)=0
AsyncRawReaderIntfc(const URL &url, const Message &request)
Stage
Stages of reading out a response from the socket.
std::vector< char > buffer_t
virtual ~AsyncRawReaderIntfc()
Destructor.
void SetChunkList(ChunkList *chunks)
Sets the chunk list with user buffers.
The message representation used throughout the system.
virtual XRootDStatus Read(char *buffer, size_t size, int &bytesRead)
const uint16_t stOK
Everything went OK.
std::vector< ChunkInfo > ChunkList
List of chunks.
Procedure execution status.
uint16_t code
Error type, or additional hints on what to do.
bool IsOK() const
We're fine.