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;
std::vector< char > buffer_t
Definition: XrdClAsyncRawReaderIntfc.hh:132
Definition: XrdClAnyObject.hh:32
const uint16_t stOK
Everything went OK.
Definition: XrdClStatus.hh:31
ChunkList * chunks
Definition: XrdClAsyncRawReaderIntfc.hh:157
std::vector< ChunkInfo > ChunkList
List of chunks.
Definition: XrdClXRootDResponses.hh:1055
Definition: XrdClAsyncRawReaderIntfc.hh:140
The message representation used throughout the system.
Definition: XrdClMessage.hh:29
bool sizeerr
Definition: XrdClAsyncRawReaderIntfc.hh:125
Stage
Stages of reading out a response from the socket.
Definition: XrdClAsyncRawReaderIntfc.hh:137
void SetDataLength(int dlen)
Sets response data length.
Definition: XrdClAsyncRawReaderIntfc.hh:63
const URL & url
Definition: XrdClAsyncRawReaderIntfc.hh:154
size_t chidx
Definition: XrdClAsyncRawReaderIntfc.hh:163
const uint16_t suDone
Definition: XrdClStatus.hh:38
Definition: XrdClAsyncRawReaderIntfc.hh:139
size_t choff
Definition: XrdClAsyncRawReaderIntfc.hh:164
uint16_t code
Error type, or additional hints on what to do.
Definition: XrdClStatus.hh:147
uint32_t msgbtsrd
Definition: XrdClAsyncRawReaderIntfc.hh:160
Stage readstage
Definition: XrdClAsyncRawReaderIntfc.hh:149
Definition: XrdClAsyncRawReaderIntfc.hh:141
Procedure execution status.
Definition: XrdClStatus.hh:114
ChunkStatus()
Definition: XrdClAsyncRawReaderIntfc.hh:124
Definition: XrdClAsyncRawReaderIntfc.hh:143
Definition: XrdClAsyncRawReaderIntfc.hh:142
Definition: XrdClAsyncRawReaderIntfc.hh:122
virtual XRootDStatus Read(Socket &socket, uint32_t &btsret)=0
size_t chlen
Definition: XrdClAsyncRawReaderIntfc.hh:165
Request status.
Definition: XrdClXRootDResponses.hh:218
AsyncRawReaderIntfc(const URL &url, const Message &request)
Definition: XrdClAsyncRawReaderIntfc.hh:38
uint32_t dlen
Definition: XrdClAsyncRawReaderIntfc.hh:159
virtual XRootDStatus GetResponse(AnyObject *&response)=0
Get the response.
URL representation.
Definition: XrdClURL.hh:30
bool done
Definition: XrdClAsyncRawReaderIntfc.hh:126
const Message & request
Definition: XrdClAsyncRawReaderIntfc.hh:155
const uint16_t suRetry
Definition: XrdClStatus.hh:40
buffer_t discardbuff
Definition: XrdClAsyncRawReaderIntfc.hh:167
virtual ~AsyncRawReaderIntfc()
Destructor.
Definition: XrdClAsyncRawReaderIntfc.hh:56
bool IsOK() const
We're fine.
Definition: XrdClStatus.hh:124
void SetChunkList(ChunkList *chunks)
Sets the chunk list with user buffers.
Definition: XrdClAsyncRawReaderIntfc.hh:72
std::vector< ChunkStatus > chstatus
Definition: XrdClAsyncRawReaderIntfc.hh:158
uint32_t rawbtsrd
Definition: XrdClAsyncRawReaderIntfc.hh:161
Base class for any message's body reader.
Definition: XrdClAsyncRawReaderIntfc.hh:34
A network socket.
Definition: XrdClSocket.hh:42
XRootDStatus ReadBytesAsync(Socket &socket, char *buffer, uint32_t toBeRead, uint32_t &bytesRead)
Definition: XrdClAsyncRawReaderIntfc.hh:98
bool dataerr
Definition: XrdClAsyncRawReaderIntfc.hh:168
virtual XRootDStatus Read(char *buffer, size_t size, int &bytesRead)