#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] |
| 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, XrdClientDebug::kUSERDEBUG, XrdClientConn::LastServerResp, readahead_list::offset, ClientRequest::readv, ClientRequestHdr::requestid, readahead_list::rlen, XrdClientConn::SendGenCommand(), XrdClientConn::SetSID(), ClientRequestHdr::streamid, XrdClientConn::SubmitPlaceholderToCache(), UnpackReadVResp(), and XrdClientConn::WriteToServer_Async().
| 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().
1.7.1