56 #define READV_MAXCHUNKS 512
57 #define READV_MAXCHUNKSIZE (1024*128)
XErrorCode
Definition: XProtocol.hh:982
XResponseType
Definition: XProtocol.hh:891
void trim(std::string &str)
Definition: XrdHttpProtocol.hh:76
Definition: XrdHttpReq.hh:77
int reqstate
State machine to talk to the bridge.
Definition: XrdHttpReq.hh:265
char fhandle[4]
Definition: XrdHttpReq.hh:258
int PostProcessHTTPReq(bool final=false)
bool keepalive
Definition: XrdHttpReq.hh:208
std::vector< ReadWriteOp > rwOps
The original list of multiple reads to perform.
Definition: XrdHttpReq.hh:203
unsigned int rwOpPartialDone
Definition: XrdHttpReq.hh:237
ReqType
These are the HTTP/DAV requests that we support.
Definition: XrdHttpReq.hh:165
@ rtUnset
Definition: XrdHttpReq.hh:166
@ rtMalformed
Definition: XrdHttpReq.hh:168
@ rtDELETE
Definition: XrdHttpReq.hh:174
@ rtOPTIONS
Definition: XrdHttpReq.hh:172
@ rtMOVE
Definition: XrdHttpReq.hh:177
@ rtHEAD
Definition: XrdHttpReq.hh:170
@ rtGET
Definition: XrdHttpReq.hh:169
@ rtPATCH
Definition: XrdHttpReq.hh:173
@ rtPROPFIND
Definition: XrdHttpReq.hh:175
@ rtPUT
Definition: XrdHttpReq.hh:171
@ rtUnknown
Definition: XrdHttpReq.hh:167
@ rtPOST
Definition: XrdHttpReq.hh:178
@ rtMKCOL
Definition: XrdHttpReq.hh:176
int parseBody(char *body, long long len)
Parse the body of a request, assuming that it's XML and that it's entirely in memory.
std::string httpStatusText
Definition: XrdHttpReq.hh:81
long long length
Definition: XrdHttpReq.hh:209
std::string destination
The destination field specified in the req.
Definition: XrdHttpReq.hh:216
XrdOucString resource
The resource specified by the request, stripped of opaque data.
Definition: XrdHttpReq.hh:190
std::vector< ReadWriteOp > rwOps_split
Definition: XrdHttpReq.hh:206
bool headerok
Tells if we have finished reading the header.
Definition: XrdHttpReq.hh:198
void clientMarshallReadAheadList(int nitems)
virtual bool Redir(XrdXrootd::Bridge::Context &info, int port, const char *hname)
XrdHttpProtocol * prot
Definition: XrdHttpReq.hh:93
std::string m_digest_header
The computed digest for the HTTP response header.
Definition: XrdHttpReq.hh:225
std::string etext
Definition: XrdHttpReq.hh:245
std::string stringresp
If we want to give a string as a response, we compose it here.
Definition: XrdHttpReq.hh:262
XResponseType xrdresp
The last response data we got.
Definition: XrdHttpReq.hh:243
XrdHttpReq(XrdHttpProtocol *protinstance)
Definition: XrdHttpReq.hh:118
std::string requestverb
Definition: XrdHttpReq.hh:183
ReqType request
The request we got.
Definition: XrdHttpReq.hh:182
virtual bool Done(XrdXrootd::Bridge::Context &info)
the result context
long long writtenbytes
In a long write, we track where we have arrived.
Definition: XrdHttpReq.hh:268
XrdOucEnv * opaque
The opaque data, after parsing.
Definition: XrdHttpReq.hh:192
long fileflags
Definition: XrdHttpReq.hh:256
int PostProcessChecksum(std::string &digest_header)
int iovL
byte count
Definition: XrdHttpReq.hh:251
int depth
Definition: XrdHttpReq.hh:210
virtual bool Error(XrdXrootd::Bridge::Context &info, int ecode, const char *etext)
bool fopened
Definition: XrdHttpReq.hh:259
const struct iovec * iovP
The latest data chunks got from the xrd layer. These are valid only inside the callbacks!
Definition: XrdHttpReq.hh:249
int httpStatusCode
Definition: XrdHttpReq.hh:80
std::string m_req_digest
The requested digest type.
Definition: XrdHttpReq.hh:219
XrdOucString resourceplusopaque
The resource specified by the request, including all the opaque data.
Definition: XrdHttpReq.hh:194
std::string hdr2cgistr
Additional opaque info that may come from the hdr2cgi directive.
Definition: XrdHttpReq.hh:228
std::string host
The host field specified in the req.
Definition: XrdHttpReq.hh:214
long filemodtime
Definition: XrdHttpReq.hh:257
int parseFirstLine(char *line, int len)
Parse the first line of the header.
XrdOucString redirdest
Definition: XrdHttpReq.hh:246
long long m_current_chunk_size
Definition: XrdHttpReq.hh:86
void parseResource(char *url)
virtual int File(XrdXrootd::Bridge::Context &info, int dlen)
int parseLine(char *line, int len)
Parse the header.
std::string buildPartialHdrEnd(char *token)
Build the closing part for a multipart response.
int ReqReadV()
Prepare the buffers for sending a readv request.
bool m_transfer_encoding_chunked
Definition: XrdHttpReq.hh:84
void mapXrdErrorToHttpStatus()
bool m_appended_hdr2cgistr
Definition: XrdHttpReq.hh:229
void appendOpaque(XrdOucString &s, XrdSecEntity *secent, char *hash, time_t tnow)
readahead_list * ralist
Definition: XrdHttpReq.hh:146
int iovN
array count
Definition: XrdHttpReq.hh:250
virtual bool Data(XrdXrootd::Bridge::Context &info, const struct iovec *iovP, int iovN, int iovL, bool final)
XrdOucString m_resource_with_digest
Definition: XrdHttpReq.hh:223
long long filesize
Definition: XrdHttpReq.hh:255
long long m_current_chunk_offset
Definition: XrdHttpReq.hh:85
XErrorCode xrderrcode
Definition: XrdHttpReq.hh:244
void clientUnMarshallReadAheadList(int nitems)
std::map< std::string, std::string > allheaders
Definition: XrdHttpReq.hh:187
unsigned int rwOpDone
To coordinate multipart responses across multiple calls.
Definition: XrdHttpReq.hh:237
int parseContentRange(char *)
bool sendcontinue
Definition: XrdHttpReq.hh:211
ClientRequest xrdreq
The last issued xrd request, often pending.
Definition: XrdHttpReq.hh:240
std::string buildPartialHdr(long long bytestart, long long byteend, long long filesize, char *token)
Build a partial header for a multipart response.
Definition: XrdOucEnv.hh:42
Definition: XrdOucString.hh:254
Definition: XrdSecEntity.hh:64
Definition: XrdXrootdBridge.hh:226
Definition: XrdXrootdBridge.hh:294
std::size_t hash(const BasicJsonType &j)
hash a JSON value
Definition: XrdOucJson.hh:5221
Definition: XrdHttpReq.hh:65
long long size
Definition: XrdHttpReq.hh:67
long flags
Definition: XrdHttpReq.hh:69
long id
Definition: XrdHttpReq.hh:68
std::string path
Definition: XrdHttpReq.hh:66
long modtime
Definition: XrdHttpReq.hh:70
Definition: XrdHttpReq.hh:59
long long byteend
Definition: XrdHttpReq.hh:62
long long bytestart
Definition: XrdHttpReq.hh:61
Definition: XProtocol.hh:653
Definition: XProtocol.hh:838