6#ifndef __XRD_TPC_STATE_HH__
7#define __XRD_TPC_STATE_HH__
26 m_recv_status_line(false),
27 m_recv_all_headers(false),
36 m_is_transfer_state(true)
45 m_recv_status_line(false),
46 m_recv_all_headers(false),
56 m_is_transfer_state(false),
57 tpcForwardCreds(tpcForwardCreds)
59 InstallHandlers(curl);
65 State (off_t start_offset,
Stream &stream,
CURL *curl,
bool push,
bool tpcForwardCreds) :
67 m_recv_status_line(false),
68 m_recv_all_headers(false),
70 m_start_offset(start_offset),
78 m_is_transfer_state(true),
79 tpcForwardCreds(tpcForwardCreds)
81 InstallHandlers(curl);
92 void SetContentLength(
const off_t content_length) { m_content_length = content_length; }
147 bool InstallHandlers(
CURL *curl);
154 static size_t HeaderCB(
char *buffer,
size_t size,
size_t nitems,
156 int Header(
const std::string &header);
157 static size_t WriteCB(
void *buffer,
size_t size,
size_t nitems,
void *userdata);
158 ssize_t Write(
char *buffer,
size_t size);
159 static size_t ReadCB(
void *buffer,
size_t size,
size_t nitems,
void *userdata);
160 int Read(
char *buffer,
size_t size);
163 bool m_recv_status_line;
164 bool m_recv_all_headers;
166 off_t m_start_offset;
169 off_t m_content_length;
173 struct curl_slist *m_headers;
174 std::vector<std::string> m_headers_copy;
175 std::string m_resp_protocol;
176 std::string m_error_buf;
177 bool m_is_transfer_state;
178 bool tpcForwardCreds =
false;
State(off_t start_offset, Stream &stream, CURL *curl, bool push, bool tpcForwardCreds)
int GetStatusCode() const
off_t BytesTransferred() const
bool BodyTransferInProgress() const
void SetErrorMessage(const std::string &error_msg)
void SetTransferParameters(off_t offset, size_t size)
std::string GetErrorMessage() const
std::string GetConnectionDescription()
void SetupHeaders(XrdHttpExtReq &req)
void SetContentLength(const off_t content_length)
off_t GetContentLength() const
void SetErrorCode(int error_code)
State(CURL *curl, bool tpcForwardCreds)
int AvailableBuffers() const