Lines Matching refs:req
84 if(!data->req.writer_stack) { in Curl_client_write()
88 DEBUGASSERT(data->req.writer_stack); in Curl_client_write()
91 result = Curl_cwriter_write(data, data->req.writer_stack, type, buf, blen); in Curl_client_write()
99 struct Curl_cwriter *writer = data->req.writer_stack; in cl_reset_writer()
101 data->req.writer_stack = writer->next; in cl_reset_writer()
104 writer = data->req.writer_stack; in cl_reset_writer()
110 struct Curl_creader *reader = data->req.reader_stack; in cl_reset_reader()
112 data->req.reader_stack = reader->next; in cl_reset_reader()
115 reader = data->req.reader_stack; in cl_reset_reader()
124 data->req.bytecount = 0; in Curl_client_cleanup()
125 data->req.headerline = 0; in Curl_client_cleanup()
130 if(data->req.rewind_read) { in Curl_client_reset()
140 data->req.bytecount = 0; in Curl_client_reset()
141 data->req.headerline = 0; in Curl_client_reset()
146 if(data->req.rewind_read) { in Curl_client_start()
147 struct Curl_creader *r = data->req.reader_stack; in Curl_client_start()
160 data->req.rewind_read = FALSE; in Curl_client_start()
168 return data->req.rewind_read; in Curl_creader_will_rewind()
173 data->req.rewind_read = !!enable; in Curl_creader_set_rewind()
213 remain_diff = limit - data->req.bytecount; in get_max_body_write_len()
265 if(data->req.no_body && nbytes > 0) { in cw_download_write()
270 data->req.download_done = TRUE; in cw_download_write()
282 if(-1 != data->req.maxdownload) { in cw_download_write()
283 size_t wmax = get_max_body_write_len(data, data->req.maxdownload); in cw_download_write()
290 data->req.download_done = TRUE; in cw_download_write()
293 if((type & CLIENTWRITE_EOS) && !data->req.no_body && in cw_download_write()
294 (data->req.maxdownload > data->req.bytecount)) { in cw_download_write()
296 data->req.maxdownload - data->req.bytecount); in cw_download_write()
303 if(data->set.max_filesize && !data->req.ignorebody) { in cw_download_write()
310 if(!data->req.ignorebody && (nwrite || (type & CLIENTWRITE_EOS))) { in cw_download_write()
318 data->req.bytecount += nwrite; in cw_download_write()
320 data->req.bodywritten = TRUE; in cw_download_write()
322 result = Curl_pgrsSetDownloadCounter(data, data->req.bytecount); in cw_download_write()
327 if(!data->req.ignorebody) { in cw_download_write()
334 excess_len, data->req.size, data->req.maxdownload, in cw_download_write()
335 data->req.bytecount); in cw_download_write()
339 else if((nwrite < nbytes) && !data->req.ignorebody) { in cw_download_write()
342 data->set.max_filesize, data->req.bytecount); in cw_download_write()
364 if(type & CLIENTWRITE_BODY && data->set.verbose && !data->req.ignorebody) { in cw_raw_write()
421 for(w = data->req.writer_stack; w; w = w->next) { in Curl_cwriter_count()
433 DEBUGASSERT(!data->req.writer_stack); in do_init_writer_stack()
434 result = Curl_cwriter_create(&data->req.writer_stack, in do_init_writer_stack()
461 struct Curl_cwriter **anchor = &data->req.writer_stack; in Curl_cwriter_add()
482 for(writer = data->req.writer_stack; writer; writer = writer->next) { in Curl_cwriter_get_by_name()
493 for(writer = data->req.writer_stack; writer; writer = writer->next) { in Curl_cwriter_get_by_type()
503 struct Curl_cwriter **anchor = &data->req.writer_stack; in Curl_cwriter_remove_by_name()
718 data->req.keepon |= KEEP_SEND_PAUSE; /* mark socket send as paused */ in cr_in_read()
1104 DEBUGASSERT(!data->req.reader_stack); in do_init_reader_stack()
1106 data->req.reader_stack = r; in do_init_reader_stack()
1147 struct Curl_creader **anchor = &data->req.reader_stack; in Curl_creader_add()
1189 if(!data->req.reader_stack) { in Curl_client_read()
1193 DEBUGASSERT(data->req.reader_stack); in Curl_client_read()
1196 result = Curl_creader_read(data, data->req.reader_stack, buf, blen, in Curl_client_read()
1205 struct Curl_creader *reader = data->req.reader_stack; in Curl_creader_needs_rewind()
1378 struct Curl_creader *r = data->req.reader_stack; in Curl_creader_total_length()
1384 struct Curl_creader *r = data->req.reader_stack; in Curl_creader_client_length()
1392 struct Curl_creader *r = data->req.reader_stack; in Curl_creader_resume_from()
1400 struct Curl_creader *reader = data->req.reader_stack; in Curl_creader_unpause()
1414 struct Curl_creader *reader = data->req.reader_stack; in Curl_creader_is_paused()
1426 struct Curl_creader *reader = data->req.reader_stack; in Curl_creader_done()
1437 for(r = data->req.reader_stack; r; r = r->next) { in Curl_creader_get_by_type()
