xref: /aosp_15_r20/external/curl/lib/request.c (revision 6236dae45794135f37c4eb022389c904c8b0090d)
1*6236dae4SAndroid Build Coastguard Worker /***************************************************************************
2*6236dae4SAndroid Build Coastguard Worker  *                                  _   _ ____  _
3*6236dae4SAndroid Build Coastguard Worker  *  Project                     ___| | | |  _ \| |
4*6236dae4SAndroid Build Coastguard Worker  *                             / __| | | | |_) | |
5*6236dae4SAndroid Build Coastguard Worker  *                            | (__| |_| |  _ <| |___
6*6236dae4SAndroid Build Coastguard Worker  *                             \___|\___/|_| \_\_____|
7*6236dae4SAndroid Build Coastguard Worker  *
8*6236dae4SAndroid Build Coastguard Worker  * Copyright (C) Daniel Stenberg, <[email protected]>, et al.
9*6236dae4SAndroid Build Coastguard Worker  *
10*6236dae4SAndroid Build Coastguard Worker  * This software is licensed as described in the file COPYING, which
11*6236dae4SAndroid Build Coastguard Worker  * you should have received as part of this distribution. The terms
12*6236dae4SAndroid Build Coastguard Worker  * are also available at https://curl.se/docs/copyright.html.
13*6236dae4SAndroid Build Coastguard Worker  *
14*6236dae4SAndroid Build Coastguard Worker  * You may opt to use, copy, modify, merge, publish, distribute and/or sell
15*6236dae4SAndroid Build Coastguard Worker  * copies of the Software, and permit persons to whom the Software is
16*6236dae4SAndroid Build Coastguard Worker  * furnished to do so, under the terms of the COPYING file.
17*6236dae4SAndroid Build Coastguard Worker  *
18*6236dae4SAndroid Build Coastguard Worker  * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
19*6236dae4SAndroid Build Coastguard Worker  * KIND, either express or implied.
20*6236dae4SAndroid Build Coastguard Worker  *
21*6236dae4SAndroid Build Coastguard Worker  * SPDX-License-Identifier: curl
22*6236dae4SAndroid Build Coastguard Worker  *
23*6236dae4SAndroid Build Coastguard Worker  ***************************************************************************/
24*6236dae4SAndroid Build Coastguard Worker 
25*6236dae4SAndroid Build Coastguard Worker #include "curl_setup.h"
26*6236dae4SAndroid Build Coastguard Worker 
27*6236dae4SAndroid Build Coastguard Worker #include "urldata.h"
28*6236dae4SAndroid Build Coastguard Worker #include "cfilters.h"
29*6236dae4SAndroid Build Coastguard Worker #include "dynbuf.h"
30*6236dae4SAndroid Build Coastguard Worker #include "doh.h"
31*6236dae4SAndroid Build Coastguard Worker #include "multiif.h"
32*6236dae4SAndroid Build Coastguard Worker #include "progress.h"
33*6236dae4SAndroid Build Coastguard Worker #include "request.h"
34*6236dae4SAndroid Build Coastguard Worker #include "sendf.h"
35*6236dae4SAndroid Build Coastguard Worker #include "transfer.h"
36*6236dae4SAndroid Build Coastguard Worker #include "url.h"
37*6236dae4SAndroid Build Coastguard Worker 
38*6236dae4SAndroid Build Coastguard Worker /* The last 3 #include files should be in this order */
39*6236dae4SAndroid Build Coastguard Worker #include "curl_printf.h"
40*6236dae4SAndroid Build Coastguard Worker #include "curl_memory.h"
41*6236dae4SAndroid Build Coastguard Worker #include "memdebug.h"
42*6236dae4SAndroid Build Coastguard Worker 
Curl_req_init(struct SingleRequest * req)43*6236dae4SAndroid Build Coastguard Worker void Curl_req_init(struct SingleRequest *req)
44*6236dae4SAndroid Build Coastguard Worker {
45*6236dae4SAndroid Build Coastguard Worker   memset(req, 0, sizeof(*req));
46*6236dae4SAndroid Build Coastguard Worker }
47*6236dae4SAndroid Build Coastguard Worker 
Curl_req_soft_reset(struct SingleRequest * req,struct Curl_easy * data)48*6236dae4SAndroid Build Coastguard Worker CURLcode Curl_req_soft_reset(struct SingleRequest *req,
49*6236dae4SAndroid Build Coastguard Worker                              struct Curl_easy *data)
50*6236dae4SAndroid Build Coastguard Worker {
51*6236dae4SAndroid Build Coastguard Worker   CURLcode result;
52*6236dae4SAndroid Build Coastguard Worker 
53*6236dae4SAndroid Build Coastguard Worker   req->done = FALSE;
54*6236dae4SAndroid Build Coastguard Worker   req->upload_done = FALSE;
55*6236dae4SAndroid Build Coastguard Worker   req->upload_aborted = FALSE;
56*6236dae4SAndroid Build Coastguard Worker   req->download_done = FALSE;
57*6236dae4SAndroid Build Coastguard Worker   req->eos_written = FALSE;
58*6236dae4SAndroid Build Coastguard Worker   req->eos_read = FALSE;
59*6236dae4SAndroid Build Coastguard Worker   req->eos_sent = FALSE;
60*6236dae4SAndroid Build Coastguard Worker   req->ignorebody = FALSE;
61*6236dae4SAndroid Build Coastguard Worker   req->shutdown = FALSE;
62*6236dae4SAndroid Build Coastguard Worker   req->bytecount = 0;
63*6236dae4SAndroid Build Coastguard Worker   req->writebytecount = 0;
64*6236dae4SAndroid Build Coastguard Worker   req->header = TRUE; /* assume header */
65*6236dae4SAndroid Build Coastguard Worker   req->headerline = 0;
66*6236dae4SAndroid Build Coastguard Worker   req->headerbytecount = 0;
67*6236dae4SAndroid Build Coastguard Worker   req->allheadercount =  0;
68*6236dae4SAndroid Build Coastguard Worker   req->deductheadercount = 0;
69*6236dae4SAndroid Build Coastguard Worker 
70*6236dae4SAndroid Build Coastguard Worker   result = Curl_client_start(data);
71*6236dae4SAndroid Build Coastguard Worker   if(result)
72*6236dae4SAndroid Build Coastguard Worker     return result;
73*6236dae4SAndroid Build Coastguard Worker 
74*6236dae4SAndroid Build Coastguard Worker   if(!req->sendbuf_init) {
75*6236dae4SAndroid Build Coastguard Worker     Curl_bufq_init2(&req->sendbuf, data->set.upload_buffer_size, 1,
76*6236dae4SAndroid Build Coastguard Worker                     BUFQ_OPT_SOFT_LIMIT);
77*6236dae4SAndroid Build Coastguard Worker     req->sendbuf_init = TRUE;
78*6236dae4SAndroid Build Coastguard Worker   }
79*6236dae4SAndroid Build Coastguard Worker   else {
80*6236dae4SAndroid Build Coastguard Worker     Curl_bufq_reset(&req->sendbuf);
81*6236dae4SAndroid Build Coastguard Worker     if(data->set.upload_buffer_size != req->sendbuf.chunk_size) {
82*6236dae4SAndroid Build Coastguard Worker       Curl_bufq_free(&req->sendbuf);
83*6236dae4SAndroid Build Coastguard Worker       Curl_bufq_init2(&req->sendbuf, data->set.upload_buffer_size, 1,
84*6236dae4SAndroid Build Coastguard Worker                       BUFQ_OPT_SOFT_LIMIT);
85*6236dae4SAndroid Build Coastguard Worker     }
86*6236dae4SAndroid Build Coastguard Worker   }
87*6236dae4SAndroid Build Coastguard Worker 
88*6236dae4SAndroid Build Coastguard Worker   return CURLE_OK;
89*6236dae4SAndroid Build Coastguard Worker }
90*6236dae4SAndroid Build Coastguard Worker 
Curl_req_start(struct SingleRequest * req,struct Curl_easy * data)91*6236dae4SAndroid Build Coastguard Worker CURLcode Curl_req_start(struct SingleRequest *req,
92*6236dae4SAndroid Build Coastguard Worker                         struct Curl_easy *data)
93*6236dae4SAndroid Build Coastguard Worker {
94*6236dae4SAndroid Build Coastguard Worker   req->start = Curl_now();
95*6236dae4SAndroid Build Coastguard Worker   return Curl_req_soft_reset(req, data);
96*6236dae4SAndroid Build Coastguard Worker }
97*6236dae4SAndroid Build Coastguard Worker 
98*6236dae4SAndroid Build Coastguard Worker static CURLcode req_flush(struct Curl_easy *data);
99*6236dae4SAndroid Build Coastguard Worker 
Curl_req_done(struct SingleRequest * req,struct Curl_easy * data,bool aborted)100*6236dae4SAndroid Build Coastguard Worker CURLcode Curl_req_done(struct SingleRequest *req,
101*6236dae4SAndroid Build Coastguard Worker                        struct Curl_easy *data, bool aborted)
102*6236dae4SAndroid Build Coastguard Worker {
103*6236dae4SAndroid Build Coastguard Worker   (void)req;
104*6236dae4SAndroid Build Coastguard Worker   if(!aborted)
105*6236dae4SAndroid Build Coastguard Worker     (void)req_flush(data);
106*6236dae4SAndroid Build Coastguard Worker   Curl_client_reset(data);
107*6236dae4SAndroid Build Coastguard Worker #ifndef CURL_DISABLE_DOH
108*6236dae4SAndroid Build Coastguard Worker   Curl_doh_close(data);
109*6236dae4SAndroid Build Coastguard Worker #endif
110*6236dae4SAndroid Build Coastguard Worker   return CURLE_OK;
111*6236dae4SAndroid Build Coastguard Worker }
112*6236dae4SAndroid Build Coastguard Worker 
Curl_req_hard_reset(struct SingleRequest * req,struct Curl_easy * data)113*6236dae4SAndroid Build Coastguard Worker void Curl_req_hard_reset(struct SingleRequest *req, struct Curl_easy *data)
114*6236dae4SAndroid Build Coastguard Worker {
115*6236dae4SAndroid Build Coastguard Worker   struct curltime t0 = {0, 0};
116*6236dae4SAndroid Build Coastguard Worker 
117*6236dae4SAndroid Build Coastguard Worker   /* This is a bit ugly. `req->p` is a union and we assume we can
118*6236dae4SAndroid Build Coastguard Worker    * free this safely without leaks. */
119*6236dae4SAndroid Build Coastguard Worker   Curl_safefree(req->p.ftp);
120*6236dae4SAndroid Build Coastguard Worker   Curl_safefree(req->newurl);
121*6236dae4SAndroid Build Coastguard Worker   Curl_client_reset(data);
122*6236dae4SAndroid Build Coastguard Worker   if(req->sendbuf_init)
123*6236dae4SAndroid Build Coastguard Worker     Curl_bufq_reset(&req->sendbuf);
124*6236dae4SAndroid Build Coastguard Worker 
125*6236dae4SAndroid Build Coastguard Worker #ifndef CURL_DISABLE_DOH
126*6236dae4SAndroid Build Coastguard Worker   Curl_doh_close(data);
127*6236dae4SAndroid Build Coastguard Worker #endif
128*6236dae4SAndroid Build Coastguard Worker   /* Can no longer memset() this struct as we need to keep some state */
129*6236dae4SAndroid Build Coastguard Worker   req->size = -1;
130*6236dae4SAndroid Build Coastguard Worker   req->maxdownload = -1;
131*6236dae4SAndroid Build Coastguard Worker   req->bytecount = 0;
132*6236dae4SAndroid Build Coastguard Worker   req->writebytecount = 0;
133*6236dae4SAndroid Build Coastguard Worker   req->start = t0;
134*6236dae4SAndroid Build Coastguard Worker   req->headerbytecount = 0;
135*6236dae4SAndroid Build Coastguard Worker   req->allheadercount =  0;
136*6236dae4SAndroid Build Coastguard Worker   req->deductheadercount = 0;
137*6236dae4SAndroid Build Coastguard Worker   req->headerline = 0;
138*6236dae4SAndroid Build Coastguard Worker   req->offset = 0;
139*6236dae4SAndroid Build Coastguard Worker   req->httpcode = 0;
140*6236dae4SAndroid Build Coastguard Worker   req->keepon = 0;
141*6236dae4SAndroid Build Coastguard Worker   req->upgr101 = UPGR101_INIT;
142*6236dae4SAndroid Build Coastguard Worker   req->timeofdoc = 0;
143*6236dae4SAndroid Build Coastguard Worker   req->location = NULL;
144*6236dae4SAndroid Build Coastguard Worker   req->newurl = NULL;
145*6236dae4SAndroid Build Coastguard Worker #ifndef CURL_DISABLE_COOKIES
146*6236dae4SAndroid Build Coastguard Worker   req->setcookies = 0;
147*6236dae4SAndroid Build Coastguard Worker #endif
148*6236dae4SAndroid Build Coastguard Worker   req->header = FALSE;
149*6236dae4SAndroid Build Coastguard Worker   req->content_range = FALSE;
150*6236dae4SAndroid Build Coastguard Worker   req->download_done = FALSE;
151*6236dae4SAndroid Build Coastguard Worker   req->eos_written = FALSE;
152*6236dae4SAndroid Build Coastguard Worker   req->eos_read = FALSE;
153*6236dae4SAndroid Build Coastguard Worker   req->eos_sent = FALSE;
154*6236dae4SAndroid Build Coastguard Worker   req->upload_done = FALSE;
155*6236dae4SAndroid Build Coastguard Worker   req->upload_aborted = FALSE;
156*6236dae4SAndroid Build Coastguard Worker   req->ignorebody = FALSE;
157*6236dae4SAndroid Build Coastguard Worker   req->http_bodyless = FALSE;
158*6236dae4SAndroid Build Coastguard Worker   req->chunk = FALSE;
159*6236dae4SAndroid Build Coastguard Worker   req->ignore_cl = FALSE;
160*6236dae4SAndroid Build Coastguard Worker   req->upload_chunky = FALSE;
161*6236dae4SAndroid Build Coastguard Worker   req->getheader = FALSE;
162*6236dae4SAndroid Build Coastguard Worker   req->no_body = data->set.opt_no_body;
163*6236dae4SAndroid Build Coastguard Worker   req->authneg = FALSE;
164*6236dae4SAndroid Build Coastguard Worker   req->shutdown = FALSE;
165*6236dae4SAndroid Build Coastguard Worker #ifdef USE_HYPER
166*6236dae4SAndroid Build Coastguard Worker   req->bodywritten = FALSE;
167*6236dae4SAndroid Build Coastguard Worker #endif
168*6236dae4SAndroid Build Coastguard Worker }
169*6236dae4SAndroid Build Coastguard Worker 
Curl_req_free(struct SingleRequest * req,struct Curl_easy * data)170*6236dae4SAndroid Build Coastguard Worker void Curl_req_free(struct SingleRequest *req, struct Curl_easy *data)
171*6236dae4SAndroid Build Coastguard Worker {
172*6236dae4SAndroid Build Coastguard Worker   /* This is a bit ugly. `req->p` is a union and we assume we can
173*6236dae4SAndroid Build Coastguard Worker    * free this safely without leaks. */
174*6236dae4SAndroid Build Coastguard Worker   Curl_safefree(req->p.ftp);
175*6236dae4SAndroid Build Coastguard Worker   Curl_safefree(req->newurl);
176*6236dae4SAndroid Build Coastguard Worker   if(req->sendbuf_init)
177*6236dae4SAndroid Build Coastguard Worker     Curl_bufq_free(&req->sendbuf);
178*6236dae4SAndroid Build Coastguard Worker   Curl_client_cleanup(data);
179*6236dae4SAndroid Build Coastguard Worker 
180*6236dae4SAndroid Build Coastguard Worker #ifndef CURL_DISABLE_DOH
181*6236dae4SAndroid Build Coastguard Worker   Curl_doh_cleanup(data);
182*6236dae4SAndroid Build Coastguard Worker #endif
183*6236dae4SAndroid Build Coastguard Worker }
184*6236dae4SAndroid Build Coastguard Worker 
xfer_send(struct Curl_easy * data,const char * buf,size_t blen,size_t hds_len,size_t * pnwritten)185*6236dae4SAndroid Build Coastguard Worker static CURLcode xfer_send(struct Curl_easy *data,
186*6236dae4SAndroid Build Coastguard Worker                           const char *buf, size_t blen,
187*6236dae4SAndroid Build Coastguard Worker                           size_t hds_len, size_t *pnwritten)
188*6236dae4SAndroid Build Coastguard Worker {
189*6236dae4SAndroid Build Coastguard Worker   CURLcode result = CURLE_OK;
190*6236dae4SAndroid Build Coastguard Worker   bool eos = FALSE;
191*6236dae4SAndroid Build Coastguard Worker 
192*6236dae4SAndroid Build Coastguard Worker   *pnwritten = 0;
193*6236dae4SAndroid Build Coastguard Worker   DEBUGASSERT(hds_len <= blen);
194*6236dae4SAndroid Build Coastguard Worker #ifdef DEBUGBUILD
195*6236dae4SAndroid Build Coastguard Worker   {
196*6236dae4SAndroid Build Coastguard Worker     /* Allow debug builds to override this logic to force short initial
197*6236dae4SAndroid Build Coastguard Worker        sends */
198*6236dae4SAndroid Build Coastguard Worker     size_t body_len = blen - hds_len;
199*6236dae4SAndroid Build Coastguard Worker     char *p = getenv("CURL_SMALLREQSEND");
200*6236dae4SAndroid Build Coastguard Worker     if(p) {
201*6236dae4SAndroid Build Coastguard Worker       size_t body_small = (size_t)strtoul(p, NULL, 10);
202*6236dae4SAndroid Build Coastguard Worker       if(body_small && body_small < body_len)
203*6236dae4SAndroid Build Coastguard Worker         blen = hds_len + body_small;
204*6236dae4SAndroid Build Coastguard Worker     }
205*6236dae4SAndroid Build Coastguard Worker   }
206*6236dae4SAndroid Build Coastguard Worker #endif
207*6236dae4SAndroid Build Coastguard Worker   /* Make sure this does not send more body bytes than what the max send
208*6236dae4SAndroid Build Coastguard Worker      speed says. The headers do not count to the max speed. */
209*6236dae4SAndroid Build Coastguard Worker   if(data->set.max_send_speed) {
210*6236dae4SAndroid Build Coastguard Worker     size_t body_bytes = blen - hds_len;
211*6236dae4SAndroid Build Coastguard Worker     if((curl_off_t)body_bytes > data->set.max_send_speed)
212*6236dae4SAndroid Build Coastguard Worker       blen = hds_len + (size_t)data->set.max_send_speed;
213*6236dae4SAndroid Build Coastguard Worker   }
214*6236dae4SAndroid Build Coastguard Worker 
215*6236dae4SAndroid Build Coastguard Worker   if(data->req.eos_read &&
216*6236dae4SAndroid Build Coastguard Worker     (Curl_bufq_is_empty(&data->req.sendbuf) ||
217*6236dae4SAndroid Build Coastguard Worker      Curl_bufq_len(&data->req.sendbuf) == blen)) {
218*6236dae4SAndroid Build Coastguard Worker     DEBUGF(infof(data, "sending last upload chunk of %zu bytes", blen));
219*6236dae4SAndroid Build Coastguard Worker     eos = TRUE;
220*6236dae4SAndroid Build Coastguard Worker   }
221*6236dae4SAndroid Build Coastguard Worker   result = Curl_xfer_send(data, buf, blen, eos, pnwritten);
222*6236dae4SAndroid Build Coastguard Worker   if(!result) {
223*6236dae4SAndroid Build Coastguard Worker     if(eos && (blen == *pnwritten))
224*6236dae4SAndroid Build Coastguard Worker       data->req.eos_sent = TRUE;
225*6236dae4SAndroid Build Coastguard Worker     if(*pnwritten) {
226*6236dae4SAndroid Build Coastguard Worker       if(hds_len)
227*6236dae4SAndroid Build Coastguard Worker         Curl_debug(data, CURLINFO_HEADER_OUT, (char *)buf,
228*6236dae4SAndroid Build Coastguard Worker                    CURLMIN(hds_len, *pnwritten));
229*6236dae4SAndroid Build Coastguard Worker       if(*pnwritten > hds_len) {
230*6236dae4SAndroid Build Coastguard Worker         size_t body_len = *pnwritten - hds_len;
231*6236dae4SAndroid Build Coastguard Worker         Curl_debug(data, CURLINFO_DATA_OUT, (char *)buf + hds_len, body_len);
232*6236dae4SAndroid Build Coastguard Worker         data->req.writebytecount += body_len;
233*6236dae4SAndroid Build Coastguard Worker         Curl_pgrsSetUploadCounter(data, data->req.writebytecount);
234*6236dae4SAndroid Build Coastguard Worker       }
235*6236dae4SAndroid Build Coastguard Worker     }
236*6236dae4SAndroid Build Coastguard Worker   }
237*6236dae4SAndroid Build Coastguard Worker   return result;
238*6236dae4SAndroid Build Coastguard Worker }
239*6236dae4SAndroid Build Coastguard Worker 
req_send_buffer_flush(struct Curl_easy * data)240*6236dae4SAndroid Build Coastguard Worker static CURLcode req_send_buffer_flush(struct Curl_easy *data)
241*6236dae4SAndroid Build Coastguard Worker {
242*6236dae4SAndroid Build Coastguard Worker   CURLcode result = CURLE_OK;
243*6236dae4SAndroid Build Coastguard Worker   const unsigned char *buf;
244*6236dae4SAndroid Build Coastguard Worker   size_t blen;
245*6236dae4SAndroid Build Coastguard Worker 
246*6236dae4SAndroid Build Coastguard Worker   while(Curl_bufq_peek(&data->req.sendbuf, &buf, &blen)) {
247*6236dae4SAndroid Build Coastguard Worker     size_t nwritten, hds_len = CURLMIN(data->req.sendbuf_hds_len, blen);
248*6236dae4SAndroid Build Coastguard Worker     result = xfer_send(data, (const char *)buf, blen, hds_len, &nwritten);
249*6236dae4SAndroid Build Coastguard Worker     if(result)
250*6236dae4SAndroid Build Coastguard Worker       break;
251*6236dae4SAndroid Build Coastguard Worker 
252*6236dae4SAndroid Build Coastguard Worker     Curl_bufq_skip(&data->req.sendbuf, nwritten);
253*6236dae4SAndroid Build Coastguard Worker     if(hds_len) {
254*6236dae4SAndroid Build Coastguard Worker       data->req.sendbuf_hds_len -= CURLMIN(hds_len, nwritten);
255*6236dae4SAndroid Build Coastguard Worker     }
256*6236dae4SAndroid Build Coastguard Worker     /* leave if we could not send all. Maybe network blocking or
257*6236dae4SAndroid Build Coastguard Worker      * speed limits on transfer */
258*6236dae4SAndroid Build Coastguard Worker     if(nwritten < blen)
259*6236dae4SAndroid Build Coastguard Worker       break;
260*6236dae4SAndroid Build Coastguard Worker   }
261*6236dae4SAndroid Build Coastguard Worker   return result;
262*6236dae4SAndroid Build Coastguard Worker }
263*6236dae4SAndroid Build Coastguard Worker 
Curl_req_set_upload_done(struct Curl_easy * data)264*6236dae4SAndroid Build Coastguard Worker CURLcode Curl_req_set_upload_done(struct Curl_easy *data)
265*6236dae4SAndroid Build Coastguard Worker {
266*6236dae4SAndroid Build Coastguard Worker   DEBUGASSERT(!data->req.upload_done);
267*6236dae4SAndroid Build Coastguard Worker   data->req.upload_done = TRUE;
268*6236dae4SAndroid Build Coastguard Worker   data->req.keepon &= ~(KEEP_SEND|KEEP_SEND_TIMED); /* we are done sending */
269*6236dae4SAndroid Build Coastguard Worker 
270*6236dae4SAndroid Build Coastguard Worker   Curl_pgrsTime(data, TIMER_POSTRANSFER);
271*6236dae4SAndroid Build Coastguard Worker   Curl_creader_done(data, data->req.upload_aborted);
272*6236dae4SAndroid Build Coastguard Worker 
273*6236dae4SAndroid Build Coastguard Worker   if(data->req.upload_aborted) {
274*6236dae4SAndroid Build Coastguard Worker     Curl_bufq_reset(&data->req.sendbuf);
275*6236dae4SAndroid Build Coastguard Worker     if(data->req.writebytecount)
276*6236dae4SAndroid Build Coastguard Worker       infof(data, "abort upload after having sent %" FMT_OFF_T " bytes",
277*6236dae4SAndroid Build Coastguard Worker             data->req.writebytecount);
278*6236dae4SAndroid Build Coastguard Worker     else
279*6236dae4SAndroid Build Coastguard Worker       infof(data, "abort upload");
280*6236dae4SAndroid Build Coastguard Worker   }
281*6236dae4SAndroid Build Coastguard Worker   else if(data->req.writebytecount)
282*6236dae4SAndroid Build Coastguard Worker     infof(data, "upload completely sent off: %" FMT_OFF_T " bytes",
283*6236dae4SAndroid Build Coastguard Worker           data->req.writebytecount);
284*6236dae4SAndroid Build Coastguard Worker   else if(!data->req.download_done) {
285*6236dae4SAndroid Build Coastguard Worker     DEBUGASSERT(Curl_bufq_is_empty(&data->req.sendbuf));
286*6236dae4SAndroid Build Coastguard Worker     infof(data, Curl_creader_total_length(data) ?
287*6236dae4SAndroid Build Coastguard Worker           "We are completely uploaded and fine" :
288*6236dae4SAndroid Build Coastguard Worker           "Request completely sent off");
289*6236dae4SAndroid Build Coastguard Worker   }
290*6236dae4SAndroid Build Coastguard Worker 
291*6236dae4SAndroid Build Coastguard Worker   return Curl_xfer_send_close(data);
292*6236dae4SAndroid Build Coastguard Worker }
293*6236dae4SAndroid Build Coastguard Worker 
req_flush(struct Curl_easy * data)294*6236dae4SAndroid Build Coastguard Worker static CURLcode req_flush(struct Curl_easy *data)
295*6236dae4SAndroid Build Coastguard Worker {
296*6236dae4SAndroid Build Coastguard Worker   CURLcode result;
297*6236dae4SAndroid Build Coastguard Worker 
298*6236dae4SAndroid Build Coastguard Worker   if(!data || !data->conn)
299*6236dae4SAndroid Build Coastguard Worker     return CURLE_FAILED_INIT;
300*6236dae4SAndroid Build Coastguard Worker 
301*6236dae4SAndroid Build Coastguard Worker   if(!Curl_bufq_is_empty(&data->req.sendbuf)) {
302*6236dae4SAndroid Build Coastguard Worker     result = req_send_buffer_flush(data);
303*6236dae4SAndroid Build Coastguard Worker     if(result)
304*6236dae4SAndroid Build Coastguard Worker       return result;
305*6236dae4SAndroid Build Coastguard Worker     if(!Curl_bufq_is_empty(&data->req.sendbuf)) {
306*6236dae4SAndroid Build Coastguard Worker       DEBUGF(infof(data, "Curl_req_flush(len=%zu) -> EAGAIN",
307*6236dae4SAndroid Build Coastguard Worker              Curl_bufq_len(&data->req.sendbuf)));
308*6236dae4SAndroid Build Coastguard Worker       return CURLE_AGAIN;
309*6236dae4SAndroid Build Coastguard Worker     }
310*6236dae4SAndroid Build Coastguard Worker   }
311*6236dae4SAndroid Build Coastguard Worker   else if(Curl_xfer_needs_flush(data)) {
312*6236dae4SAndroid Build Coastguard Worker     DEBUGF(infof(data, "Curl_req_flush(), xfer send_pending"));
313*6236dae4SAndroid Build Coastguard Worker     return Curl_xfer_flush(data);
314*6236dae4SAndroid Build Coastguard Worker   }
315*6236dae4SAndroid Build Coastguard Worker 
316*6236dae4SAndroid Build Coastguard Worker   if(data->req.eos_read && !data->req.eos_sent) {
317*6236dae4SAndroid Build Coastguard Worker     char tmp;
318*6236dae4SAndroid Build Coastguard Worker     size_t nwritten;
319*6236dae4SAndroid Build Coastguard Worker     result = xfer_send(data, &tmp, 0, 0, &nwritten);
320*6236dae4SAndroid Build Coastguard Worker     if(result)
321*6236dae4SAndroid Build Coastguard Worker       return result;
322*6236dae4SAndroid Build Coastguard Worker     DEBUGASSERT(data->req.eos_sent);
323*6236dae4SAndroid Build Coastguard Worker   }
324*6236dae4SAndroid Build Coastguard Worker 
325*6236dae4SAndroid Build Coastguard Worker   if(!data->req.upload_done && data->req.eos_read && data->req.eos_sent) {
326*6236dae4SAndroid Build Coastguard Worker     DEBUGASSERT(Curl_bufq_is_empty(&data->req.sendbuf));
327*6236dae4SAndroid Build Coastguard Worker     if(data->req.shutdown) {
328*6236dae4SAndroid Build Coastguard Worker       bool done;
329*6236dae4SAndroid Build Coastguard Worker       result = Curl_xfer_send_shutdown(data, &done);
330*6236dae4SAndroid Build Coastguard Worker       if(result && data->req.shutdown_err_ignore) {
331*6236dae4SAndroid Build Coastguard Worker         infof(data, "Shutdown send direction error: %d. Broken server? "
332*6236dae4SAndroid Build Coastguard Worker               "Proceeding as if everything is ok.", result);
333*6236dae4SAndroid Build Coastguard Worker         result = CURLE_OK;
334*6236dae4SAndroid Build Coastguard Worker         done = TRUE;
335*6236dae4SAndroid Build Coastguard Worker       }
336*6236dae4SAndroid Build Coastguard Worker 
337*6236dae4SAndroid Build Coastguard Worker       if(result)
338*6236dae4SAndroid Build Coastguard Worker         return result;
339*6236dae4SAndroid Build Coastguard Worker       if(!done)
340*6236dae4SAndroid Build Coastguard Worker         return CURLE_AGAIN;
341*6236dae4SAndroid Build Coastguard Worker     }
342*6236dae4SAndroid Build Coastguard Worker     return Curl_req_set_upload_done(data);
343*6236dae4SAndroid Build Coastguard Worker   }
344*6236dae4SAndroid Build Coastguard Worker   return CURLE_OK;
345*6236dae4SAndroid Build Coastguard Worker }
346*6236dae4SAndroid Build Coastguard Worker 
add_from_client(void * reader_ctx,unsigned char * buf,size_t buflen,CURLcode * err)347*6236dae4SAndroid Build Coastguard Worker static ssize_t add_from_client(void *reader_ctx,
348*6236dae4SAndroid Build Coastguard Worker                                unsigned char *buf, size_t buflen,
349*6236dae4SAndroid Build Coastguard Worker                                CURLcode *err)
350*6236dae4SAndroid Build Coastguard Worker {
351*6236dae4SAndroid Build Coastguard Worker   struct Curl_easy *data = reader_ctx;
352*6236dae4SAndroid Build Coastguard Worker   size_t nread;
353*6236dae4SAndroid Build Coastguard Worker   bool eos;
354*6236dae4SAndroid Build Coastguard Worker 
355*6236dae4SAndroid Build Coastguard Worker   *err = Curl_client_read(data, (char *)buf, buflen, &nread, &eos);
356*6236dae4SAndroid Build Coastguard Worker   if(*err)
357*6236dae4SAndroid Build Coastguard Worker     return -1;
358*6236dae4SAndroid Build Coastguard Worker   if(eos)
359*6236dae4SAndroid Build Coastguard Worker     data->req.eos_read = TRUE;
360*6236dae4SAndroid Build Coastguard Worker   return (ssize_t)nread;
361*6236dae4SAndroid Build Coastguard Worker }
362*6236dae4SAndroid Build Coastguard Worker 
363*6236dae4SAndroid Build Coastguard Worker #ifndef USE_HYPER
364*6236dae4SAndroid Build Coastguard Worker 
req_send_buffer_add(struct Curl_easy * data,const char * buf,size_t blen,size_t hds_len)365*6236dae4SAndroid Build Coastguard Worker static CURLcode req_send_buffer_add(struct Curl_easy *data,
366*6236dae4SAndroid Build Coastguard Worker                                     const char *buf, size_t blen,
367*6236dae4SAndroid Build Coastguard Worker                                     size_t hds_len)
368*6236dae4SAndroid Build Coastguard Worker {
369*6236dae4SAndroid Build Coastguard Worker   CURLcode result = CURLE_OK;
370*6236dae4SAndroid Build Coastguard Worker   ssize_t n;
371*6236dae4SAndroid Build Coastguard Worker   n = Curl_bufq_write(&data->req.sendbuf,
372*6236dae4SAndroid Build Coastguard Worker                       (const unsigned char *)buf, blen, &result);
373*6236dae4SAndroid Build Coastguard Worker   if(n < 0)
374*6236dae4SAndroid Build Coastguard Worker     return result;
375*6236dae4SAndroid Build Coastguard Worker   /* We rely on a SOFTLIMIT on sendbuf, so it can take all data in */
376*6236dae4SAndroid Build Coastguard Worker   DEBUGASSERT((size_t)n == blen);
377*6236dae4SAndroid Build Coastguard Worker   data->req.sendbuf_hds_len += hds_len;
378*6236dae4SAndroid Build Coastguard Worker   return CURLE_OK;
379*6236dae4SAndroid Build Coastguard Worker }
380*6236dae4SAndroid Build Coastguard Worker 
Curl_req_send(struct Curl_easy * data,struct dynbuf * req)381*6236dae4SAndroid Build Coastguard Worker CURLcode Curl_req_send(struct Curl_easy *data, struct dynbuf *req)
382*6236dae4SAndroid Build Coastguard Worker {
383*6236dae4SAndroid Build Coastguard Worker   CURLcode result;
384*6236dae4SAndroid Build Coastguard Worker   const char *buf;
385*6236dae4SAndroid Build Coastguard Worker   size_t blen, nwritten;
386*6236dae4SAndroid Build Coastguard Worker 
387*6236dae4SAndroid Build Coastguard Worker   if(!data || !data->conn)
388*6236dae4SAndroid Build Coastguard Worker     return CURLE_FAILED_INIT;
389*6236dae4SAndroid Build Coastguard Worker 
390*6236dae4SAndroid Build Coastguard Worker   buf = Curl_dyn_ptr(req);
391*6236dae4SAndroid Build Coastguard Worker   blen = Curl_dyn_len(req);
392*6236dae4SAndroid Build Coastguard Worker   if(!Curl_creader_total_length(data)) {
393*6236dae4SAndroid Build Coastguard Worker     /* Request without body. Try to send directly from the buf given. */
394*6236dae4SAndroid Build Coastguard Worker     data->req.eos_read = TRUE;
395*6236dae4SAndroid Build Coastguard Worker     result = xfer_send(data, buf, blen, blen, &nwritten);
396*6236dae4SAndroid Build Coastguard Worker     if(result)
397*6236dae4SAndroid Build Coastguard Worker       return result;
398*6236dae4SAndroid Build Coastguard Worker     buf += nwritten;
399*6236dae4SAndroid Build Coastguard Worker     blen -= nwritten;
400*6236dae4SAndroid Build Coastguard Worker   }
401*6236dae4SAndroid Build Coastguard Worker 
402*6236dae4SAndroid Build Coastguard Worker   if(blen) {
403*6236dae4SAndroid Build Coastguard Worker     /* Either we have a request body, or we could not send the complete
404*6236dae4SAndroid Build Coastguard Worker      * request in one go. Buffer the remainder and try to add as much
405*6236dae4SAndroid Build Coastguard Worker      * body bytes as room is left in the buffer. Then flush. */
406*6236dae4SAndroid Build Coastguard Worker     result = req_send_buffer_add(data, buf, blen, blen);
407*6236dae4SAndroid Build Coastguard Worker     if(result)
408*6236dae4SAndroid Build Coastguard Worker       return result;
409*6236dae4SAndroid Build Coastguard Worker 
410*6236dae4SAndroid Build Coastguard Worker     return Curl_req_send_more(data);
411*6236dae4SAndroid Build Coastguard Worker   }
412*6236dae4SAndroid Build Coastguard Worker   return CURLE_OK;
413*6236dae4SAndroid Build Coastguard Worker }
414*6236dae4SAndroid Build Coastguard Worker #endif /* !USE_HYPER */
415*6236dae4SAndroid Build Coastguard Worker 
Curl_req_sendbuf_empty(struct Curl_easy * data)416*6236dae4SAndroid Build Coastguard Worker bool Curl_req_sendbuf_empty(struct Curl_easy *data)
417*6236dae4SAndroid Build Coastguard Worker {
418*6236dae4SAndroid Build Coastguard Worker   return !data->req.sendbuf_init || Curl_bufq_is_empty(&data->req.sendbuf);
419*6236dae4SAndroid Build Coastguard Worker }
420*6236dae4SAndroid Build Coastguard Worker 
Curl_req_want_send(struct Curl_easy * data)421*6236dae4SAndroid Build Coastguard Worker bool Curl_req_want_send(struct Curl_easy *data)
422*6236dae4SAndroid Build Coastguard Worker {
423*6236dae4SAndroid Build Coastguard Worker   /* Not done and
424*6236dae4SAndroid Build Coastguard Worker    * - KEEP_SEND and not PAUSEd.
425*6236dae4SAndroid Build Coastguard Worker    * - or request has buffered data to send
426*6236dae4SAndroid Build Coastguard Worker    * - or transfer connection has pending data to send */
427*6236dae4SAndroid Build Coastguard Worker   return !data->req.done &&
428*6236dae4SAndroid Build Coastguard Worker          (((data->req.keepon & KEEP_SENDBITS) == KEEP_SEND) ||
429*6236dae4SAndroid Build Coastguard Worker            !Curl_req_sendbuf_empty(data) ||
430*6236dae4SAndroid Build Coastguard Worker            Curl_xfer_needs_flush(data));
431*6236dae4SAndroid Build Coastguard Worker }
432*6236dae4SAndroid Build Coastguard Worker 
Curl_req_done_sending(struct Curl_easy * data)433*6236dae4SAndroid Build Coastguard Worker bool Curl_req_done_sending(struct Curl_easy *data)
434*6236dae4SAndroid Build Coastguard Worker {
435*6236dae4SAndroid Build Coastguard Worker   return data->req.upload_done && !Curl_req_want_send(data);
436*6236dae4SAndroid Build Coastguard Worker }
437*6236dae4SAndroid Build Coastguard Worker 
Curl_req_send_more(struct Curl_easy * data)438*6236dae4SAndroid Build Coastguard Worker CURLcode Curl_req_send_more(struct Curl_easy *data)
439*6236dae4SAndroid Build Coastguard Worker {
440*6236dae4SAndroid Build Coastguard Worker   CURLcode result;
441*6236dae4SAndroid Build Coastguard Worker 
442*6236dae4SAndroid Build Coastguard Worker   /* Fill our send buffer if more from client can be read. */
443*6236dae4SAndroid Build Coastguard Worker   if(!data->req.upload_aborted &&
444*6236dae4SAndroid Build Coastguard Worker      !data->req.eos_read &&
445*6236dae4SAndroid Build Coastguard Worker      !(data->req.keepon & KEEP_SEND_PAUSE) &&
446*6236dae4SAndroid Build Coastguard Worker      !Curl_bufq_is_full(&data->req.sendbuf)) {
447*6236dae4SAndroid Build Coastguard Worker     ssize_t nread = Curl_bufq_sipn(&data->req.sendbuf, 0,
448*6236dae4SAndroid Build Coastguard Worker                                    add_from_client, data, &result);
449*6236dae4SAndroid Build Coastguard Worker     if(nread < 0 && result != CURLE_AGAIN)
450*6236dae4SAndroid Build Coastguard Worker       return result;
451*6236dae4SAndroid Build Coastguard Worker   }
452*6236dae4SAndroid Build Coastguard Worker 
453*6236dae4SAndroid Build Coastguard Worker   result = req_flush(data);
454*6236dae4SAndroid Build Coastguard Worker   if(result == CURLE_AGAIN)
455*6236dae4SAndroid Build Coastguard Worker     result = CURLE_OK;
456*6236dae4SAndroid Build Coastguard Worker 
457*6236dae4SAndroid Build Coastguard Worker   return result;
458*6236dae4SAndroid Build Coastguard Worker }
459*6236dae4SAndroid Build Coastguard Worker 
Curl_req_abort_sending(struct Curl_easy * data)460*6236dae4SAndroid Build Coastguard Worker CURLcode Curl_req_abort_sending(struct Curl_easy *data)
461*6236dae4SAndroid Build Coastguard Worker {
462*6236dae4SAndroid Build Coastguard Worker   if(!data->req.upload_done) {
463*6236dae4SAndroid Build Coastguard Worker     Curl_bufq_reset(&data->req.sendbuf);
464*6236dae4SAndroid Build Coastguard Worker     data->req.upload_aborted = TRUE;
465*6236dae4SAndroid Build Coastguard Worker     /* no longer KEEP_SEND and KEEP_SEND_PAUSE */
466*6236dae4SAndroid Build Coastguard Worker     data->req.keepon &= ~KEEP_SENDBITS;
467*6236dae4SAndroid Build Coastguard Worker     return Curl_req_set_upload_done(data);
468*6236dae4SAndroid Build Coastguard Worker   }
469*6236dae4SAndroid Build Coastguard Worker   return CURLE_OK;
470*6236dae4SAndroid Build Coastguard Worker }
471*6236dae4SAndroid Build Coastguard Worker 
Curl_req_stop_send_recv(struct Curl_easy * data)472*6236dae4SAndroid Build Coastguard Worker CURLcode Curl_req_stop_send_recv(struct Curl_easy *data)
473*6236dae4SAndroid Build Coastguard Worker {
474*6236dae4SAndroid Build Coastguard Worker   /* stop receiving and ALL sending as well, including PAUSE and HOLD.
475*6236dae4SAndroid Build Coastguard Worker    * We might still be paused on receive client writes though, so
476*6236dae4SAndroid Build Coastguard Worker    * keep those bits around. */
477*6236dae4SAndroid Build Coastguard Worker   data->req.keepon &= ~(KEEP_RECV|KEEP_SENDBITS);
478*6236dae4SAndroid Build Coastguard Worker   return Curl_req_abort_sending(data);
479*6236dae4SAndroid Build Coastguard Worker }
480