xrootd
|
#include <XrdClientReadV.hh>
Static Public Member Functions | |
static kXR_int64 | ReqReadV (XrdClientConn *xrdc, char *handle, char *destbuf, XrdClientVector< XrdClientReadVinfo > &reqvect, int firstreq, int nreq, int streamtosend) |
static kXR_int32 | UnpackReadVResp (char *destbuf, char *respdata, kXR_int32 respdatalen, readahead_list *buflis, int nbuf) |
static kXR_int32 | SubmitToCacheReadVResp (XrdClientConn *xrdc, char *respdata, kXR_int32 respdatalen) |
static void | PreProcessChunkRequest (XrdClientVector< XrdClientReadVinfo > &reqvect, kXR_int64 offs, kXR_int32 len, kXR_int64 filelen) |
static void | PreProcessChunkRequest (XrdClientVector< XrdClientReadVinfo > &reqvect, kXR_int64 offs, kXR_int32 len, kXR_int64 filelen, kXR_int32 spltsize) |
static void XrdClientReadV::PreProcessChunkRequest | ( | XrdClientVector< XrdClientReadVinfo > & | reqvect, |
kXR_int64 | offs, | ||
kXR_int32 | len, | ||
kXR_int64 | filelen | ||
) | [static] |
Referenced by XrdClient::ReadV().
void XrdClientReadV::PreProcessChunkRequest | ( | XrdClientVector< XrdClientReadVinfo > & | reqvect, |
kXR_int64 | offs, | ||
kXR_int32 | len, | ||
kXR_int64 | filelen, | ||
kXR_int32 | spltsize | ||
) | [static] |
kXR_int64 XrdClientReadV::ReqReadV | ( | XrdClientConn * | xrdc, |
char * | handle, | ||
char * | destbuf, | ||
XrdClientVector< XrdClientReadVinfo > & | reqvect, | ||
int | firstreq, | ||
int | nreq, | ||
int | streamtosend | ||
) | [static] |
References clientMarshallReadAheadList(), clientUnMarshallReadAheadList(), ServerResponseHeader::dlen, ClientReadVRequest::dlen, FALSE, ClientRequest::header, Info, XrdClientDebug::kHIDEBUG, kOK, XrdClientDebug::kUSERDEBUG, kXR_readv, XrdClientConn::LastServerResp, readahead_list::offset, ClientRequest::readv, READV_MAXCHUNKS, ClientRequestHdr::requestid, readahead_list::rlen, XrdClientConn::SendGenCommand(), XrdClientConn::SetSID(), ClientRequestHdr::streamid, XrdClientConn::SubmitPlaceholderToCache(), UnpackReadVResp(), and XrdClientConn::WriteToServer_Async().
Referenced by XrdClient::ReadV().
int XrdClientReadV::SubmitToCacheReadVResp | ( | XrdClientConn * | xrdc, |
char * | respdata, | ||
kXR_int32 | respdatalen | ||
) | [static] |
References ntohll, readahead_list::offset, readahead_list::rlen, and XrdClientConn::SubmitRawDataToCache().
Referenced by XrdClient::ProcessUnsolicitedMsg().
kXR_int32 XrdClientReadV::UnpackReadVResp | ( | char * | destbuf, |
char * | respdata, | ||
kXR_int32 | respdatalen, | ||
readahead_list * | buflis, | ||
int | nbuf | ||
) | [static] |
References Error, ntohll, readahead_list::offset, and readahead_list::rlen.
Referenced by ReqReadV().