/curl/lib/ |
H A D | transfer.c | 166 if(!data || !data->conn) in xfer_recv_shutdown() 178 if(!data || !data->conn) in xfer_recv_shutdown_started() 190 if(!data || !data->conn) in Curl_xfer_send_shutdown() 439 result = data->conn->datastream(data, data->conn, &didwhat, in Curl_sendrecv() 530 data->state.in = data->set.in_set; in Curl_init_CONNECT() 543 if(!data->state.url && !data->set.uh) { in Curl_pretransfer() 556 if(!data->state.url && data->set.uh) { in Curl_pretransfer() 575 data->state.list_only = data->set.list_only; in Curl_pretransfer() 577 data->state.httpreq = data->set.method; in Curl_pretransfer() 591 data->state.httpwant = data->set.httpwant; in Curl_pretransfer() [all …]
|
H A D | curl_trc.h | 74 #define infof(data, ...) \ argument 83 #define CURL_TRC_READ(data, ...) \ argument 88 #define CURL_TRC_FTP(data, ...) \ argument 93 #define CURL_TRC_SMTP(data, ...) \ argument 133 ((data) && (data)->set.verbose && \ 186 (void)data; (void)fmt; in Curl_infof() 200 (void)data; (void)fmt; in Curl_trc_write() 205 (void)data; (void)fmt; in Curl_trc_read() 211 (void)data; (void)fmt; in Curl_trc_ftp() 217 (void)data; (void)fmt; in Curl_trc_smtp() [all …]
|
H A D | setopt.c | 102 memcpy(nblob->data, blob->data, blob->len); in Curl_setblobopt() 1483 data->state.resolve = data->set.resolve; in setopt_slist() 1582 if(data->share->cookies == data->cookies) in setopt_pointers() 1587 if(data->share->hsts == data->hsts) in setopt_pointers() 1595 if(data->psl == &data->share->psl) in setopt_pointers() 1596 data->psl = data->multi ? &data->multi->psl : NULL; in setopt_pointers() 1624 data->cookies = data->share->cookies; in setopt_pointers() 1631 data->hsts = data->share->hsts; in setopt_pointers() 1642 data->psl = &data->share->psl; in setopt_pointers() 1875 Curl_cookie_init(data, NULL, data->cookies, data->set.cookiesession); in setopt_cptr() [all …]
|
H A D | request.c | 108 Curl_doh_close(data); in Curl_req_done() 126 Curl_doh_close(data); in Curl_req_hard_reset() 233 Curl_pgrsSetUploadCounter(data, data->req.writebytecount); in xfer_send() 271 Curl_creader_done(data, data->req.upload_aborted); in Curl_req_set_upload_done() 286 infof(data, Curl_creader_total_length(data) ? in Curl_req_set_upload_done() 298 if(!data || !data->conn) in req_flush() 316 if(data->req.eos_read && !data->req.eos_sent) { in req_flush() 325 if(!data->req.upload_done && data->req.eos_read && data->req.eos_sent) { in req_flush() 387 if(!data || !data->conn) in Curl_req_send() 418 return !data->req.sendbuf_init || Curl_bufq_is_empty(&data->req.sendbuf); in Curl_req_sendbuf_empty() [all …]
|
H A D | c-hyper.c | 82 struct Curl_easy *data = io_ctx->data; in Curl_hyper_recv() local 116 struct Curl_easy *data = io_ctx->data; in Curl_hyper_send() local 234 if(data->state.hconnect && (data->req.httpcode/100 != 2) && in hyper_body_chunk() 456 data->req.newurl = strdup(data->state.url); in Curl_hyper_stream() 690 Curl_pgrsSetUploadCounter(data, data->req.writebytecount); in uploadstreamed() 706 if(!data->req.upload_done && data->req.eos_read) { in uploadstreamed() 794 result = status_line(data, data->conn, in http1xx_cb() 904 h->io_ctx.data = data; in Curl_http() 1023 if((data->state.use_range && data->state.aptr.rangeline)) { in Curl_http() 1091 result = Curl_hyper_header(data, headers, data->state.aptr.te); in Curl_http() [all …]
|
H A D | rtsp.c | 88 (void)data; in rtsp_getsock_do() 151 (void)data; in rtsp_conncheck() 184 (void) data; in rtsp_disconnect() 207 failf(data, in rtsp_done() 350 failf(data, in rtsp_do() 406 if(data->state.referer && !Curl_checkheaders(data, STRCONST("Referer"))) in rtsp_do() 517 result = Curl_creader_set_buf(data, data->set.postfields, plen); in rtsp_do() 595 Curl_pgrsSetUploadCounter(data, data->req.writebytecount); in rtsp_do() 617 (data->req.bytecount < data->req.size); in rtp_write_body_junk() 618 body_remain = in_body ? (data->req.size - data->req.bytecount) : 0; in rtp_write_body_junk() [all …]
|
H A D | multi.c | 558 data->psl = &data->share->psl; in curl_multi_add_handle() 1167 multi_getsock(data, &data->last_poll); in curl_multi_fdset() 1209 multi_getsock(data, &data->last_poll); in curl_multi_waitfds() 1286 multi_getsock(data, &data->last_poll); 2008 Curl_req_soft_reset(&data->req, data); 2329 multistate(data, data->conn ? 2958 data->set.fmultidone(data, result); 3101 if(!data->state.done && data->conn) 3365 if(singlesocket(data->multi, data)) 4115 if(data && data->multi) [all …]
|
H A D | sendf.h | 64 void Curl_client_cleanup(struct Curl_easy *data); 70 void Curl_client_reset(struct Curl_easy *data); 76 CURLcode Curl_client_start(struct Curl_easy *data); 110 CURLcode (*do_init)(struct Curl_easy *data, 112 CURLcode (*do_write)(struct Curl_easy *data, 115 void (*do_close)(struct Curl_easy *data, 147 void Curl_cwriter_free(struct Curl_easy *data, 159 CURLcode Curl_cwriter_add(struct Curl_easy *data, 217 CURLcode (*resume_from)(struct Curl_easy *data, 222 void (*done)(struct Curl_easy *data, [all …]
|
H A D | ftp.c | 166 CURL_TRC_FTP(data, "[%s] -> [%s]", FTP_DSTATE(data), in _ftp_state() 520 Curl_pgrsSetUploadSize(data, data->state.infilesize); in InitiateTransfer() 544 (void)data; in ftp_endofresp() 766 (void)data; in ftp_domore_getsock() 1218 Curl_expire(data, data->set.accepttimeout ? in ftp_state_use_port() 2324 result = ftp_state_rest(data, data->conn); in ftp_state_size_resp() 2493 size = data->req.size = data->req.maxdownload; in ftp_state_get_resp() 3236 data->set.chunk_end(data->set.wildcardptr); in ftp_done() 3375 (data->req.size != data->req.bytecount) && in ftp_done() 3816 data->set.out = data; in init_wc_data() [all …]
|
H A D | sendf.c | 189 (void)data; in Curl_cwriter_def_init() 204 (void) data; in Curl_cwriter_def_close() 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() 342 data->set.max_filesize, data->req.bytecount); in cw_download_write() 540 (void)data; in Curl_creader_def_init() 548 (void)data; in Curl_creader_def_close() 570 (void)data; in Curl_creader_def_needs_rewind() 586 (void)data; in Curl_creader_def_resume_from() [all …]
|
H A D | http.c | 201 data->set.proxyheaders : data->set.headers; in Curl_checkProxyheaders() 559 if(http_should_fail(data, data->req.httpcode)) { in Curl_http_auth_act() 1893 data->state.mimepost = &data->set.mimepost; in set_post_reader() 1905 result = Curl_getformdata(data, data->state.formp, data->set.httppost, in set_post_reader() 1911 data->state.mimepost = data->state.formp; in set_post_reader() 2080 Curl_use_http_1_1plus(data, data->conn) && in Curl_http_req_set_reader() 2092 if(Curl_use_http_1_1plus(data, data->conn)) { in Curl_http_req_set_reader() 2134 Curl_use_http_1_1plus(data, data->conn) && in addexpect() 2255 if(data->cookies && data->state.cookie_engine) { in Curl_http_cookies() 2264 rc = Curl_cookie_getlist(data, data->cookies, host, data->state.up.path, in Curl_http_cookies() [all …]
|
H A D | cfilters.h | 286 void Curl_conn_cf_add(struct Curl_easy *data, 458 struct Curl_easy *data, 597 void Curl_pollset_set(struct Curl_easy *data, 601 #define Curl_pollset_add_in(data, ps, sock) \ argument 603 #define Curl_pollset_add_out(data, ps, sock) \ argument 648 struct Curl_easy *data; member 663 #define CF_DATA_SAVE(save, cf, data) \ argument 668 CF_CTX_CALL_DATA(cf).data = (struct Curl_easy *)data; \ 680 #define CF_DATA_SAVE(save, cf, data) \ argument 683 CF_CTX_CALL_DATA(cf).data = (struct Curl_easy *)data; \ [all …]
|
H A D | speedcheck.c | 33 void Curl_speedinit(struct Curl_easy *data) in Curl_speedinit() argument 44 if(data->req.keepon & KEEP_RECV_PAUSE) in Curl_speedcheck() 48 if((data->progress.current_speed >= 0) && data->set.low_speed_time) { in Curl_speedcheck() 49 if(data->progress.current_speed < data->set.low_speed_limit) { in Curl_speedcheck() 50 if(!data->state.keeps_speed.tv_sec) in Curl_speedcheck() 52 data->state.keeps_speed = now; in Curl_speedcheck() 59 failf(data, in Curl_speedcheck() 62 data->set.low_speed_limit, in Curl_speedcheck() 63 data->set.low_speed_time); in Curl_speedcheck() 70 data->state.keeps_speed.tv_sec = 0; in Curl_speedcheck() [all …]
|
H A D | smtp.c | 216 (void)data; in smtp_endofresp() 711 result = Curl_creader_set_mime(data, &data->set.mimepost); in smtp_perform_mail() 714 data->state.infilesize = Curl_creader_total_length(data); in smtp_perform_mail() 1163 Curl_pgrsSetUploadSize(data, data->state.infilesize); in smtp_state_data_resp() 1413 else if(!data->set.connect_only && data->set.mail_rcpt && in smtp_done() 1414 (data->state.upload || IS_MIME_POST(data))) { in smtp_done() 1467 if((data->state.upload || IS_MIME_POST(data)) && data->set.mail_rcpt) in smtp_perform() 1526 (void)data; in smtp_disconnect() 1799 (void)data; in cr_eob_init() 1810 (void)data; in cr_eob_close() [all …]
|
H A D | getinfo.c | 50 struct PureInfo *info = &data->info; in Curl_initinfo() 89 Curl_ssl_free_certinfo(data); in Curl_initinfo() 99 *param_charp = data->state.url ? data->state.url : (char *)""; in getinfo_char() 104 if(data->set.opt_no_body) in getinfo_char() 108 switch(data->state.httpreq) { in getinfo_char() 303 if(data->info.httpcode == 304) in getinfo_long() 353 data->info.used_proxy in getinfo_long() 446 *param_offt = data->id; in getinfo_offt() 449 *param_offt = data->conn ? in getinfo_offt() 450 data->conn->connection_id : data->state.recent_conn_id; in getinfo_offt() [all …]
|
H A D | cfilters.c | 65 (void)data; in Curl_cf_def_shutdown() 92 (void)data; in Curl_cf_def_adjust_pollset() 313 (void)data; in Curl_conn_cf_add() 438 cf_cntrl_update_info(data, data->conn); in Curl_conn_connect() 439 conn_report_connect_stats(data, data->conn); in Curl_conn_connect() 441 Curl_verboseconnect(data, data->conn, sockindex); in Curl_conn_connect() 444 conn_report_connect_stats(data, data->conn); in Curl_conn_connect() 728 return cf_cntrl_all(data->conn, data, FALSE, in Curl_conn_ev_data_setup() 734 return cf_cntrl_all(data->conn, data, FALSE, in Curl_conn_ev_data_idle() 765 return cf_cntrl_all(data->conn, data, FALSE, in Curl_conn_ev_data_pause() [all …]
|
H A D | cf-h1-proxy.c | 99 (void)data; in tunnel_reinit() 404 if(data->set.proxyauth && data->state.authproxy.avail && in recv_CONNECT_resp() 596 h->io_ctx.data = data; in start_CONNECT() 684 if(data->set.verbose) { in start_CONNECT() 730 data->set.str[STRING_USERAGENT] && *data->set.str[STRING_USERAGENT]) { in start_CONNECT() 843 *done = data->req.done; in recv_CONNECT_resp() 927 Curl_req_soft_reset(&data->req, data); in H1_CONNECT() 961 failf(data, "CONNECT tunnel failed, response %d", data->req.httpcode); in H1_CONNECT() 1014 Curl_req_soft_reset(&data->req, data); in cf_h1_proxy_connect() 1053 tunnel_free(cf, data); in cf_h1_proxy_destroy() [all …]
|
H A D | progress.c | 253 data->progress.ul.limit.start = data->progress.start; in Curl_pgrsStartNow() 254 data->progress.dl.limit.start = data->progress.start; in Curl_pgrsStartNow() 261 Curl_ratelimit(data, data->progress.start); in Curl_pgrsStartNow() 340 data->progress.dl.limit.start_size = data->progress.dl.cur_size; in Curl_ratelimit() 347 data->progress.ul.limit.start_size = data->progress.ul.cur_size; in Curl_ratelimit() 523 fprintf(data->set.err, in progress_meter() 553 fprintf(data->set.err, in progress_meter() 573 fflush(data->set.err); in progress_meter() 592 result = data->set.fxferinfo(data->set.progress_client, in pgrsupdate() 608 result = data->set.fprogress(data->set.progress_client, in pgrsupdate() [all …]
|
H A D | imap.c | 782 curl_mime_headers(&data->set.mimepost, data->set.headers, 0); in imap_perform_append() 783 result = Curl_mime_prepare_headers(data, &data->set.mimepost, NULL, in imap_perform_append() 792 result = Curl_creader_set_mime(data, &data->set.mimepost); in imap_perform_append() 795 data->state.infilesize = Curl_creader_client_length(data); in imap_perform_append() 800 result = Curl_creader_set_fread(data, data->state.infilesize); in imap_perform_append() 1267 Curl_pgrsSetUploadSize(data, data->state.infilesize); in imap_state_append_resp() 1305 (void)data; in imap_statemachine() 1519 if(!data->state.upload && !IS_MIME_POST(data)) in imap_done() 1585 if(data->state.upload || IS_MIME_POST(data)) in imap_perform() 1659 (void)data; in imap_disconnect() [all …]
|
/curl/tests/unit/ |
H A D | unit1399.c | 84 struct Curl_easy data; variable 87 data.progress.t_nslookup = 0; 88 data.progress.t_connect = 0; 89 data.progress.t_appconnect = 0; 90 data.progress.t_pretransfer = 0; 91 data.progress.t_starttransfer = 0; 92 data.progress.t_redirect = 0; 98 Curl_pgrsTime(&data, TIMER_CONNECT); 103 expect_timer_seconds(&data, 2); 106 data.progress.t_redirect = data.progress.t_starttransfer + 1; [all …]
|
/curl/tests/data/ |
H A D | test1060 | 23 And you should ignore this data. aaaaaaaaaaaaaaaa 24 And you should ignore this data. aaaaaaaaaaaaaaaa 25 And you should ignore this data. aaaaaaaaaaaaaaaa 26 And you should ignore this data. aaaaaaaaaaaaaaaa 27 And you should ignore this data. aaaaaaaaaaaaaaaa 28 And you should ignore this data. aaaaaaaaaaaaaaaa 29 And you should ignore this data. aaaaaaaaaaaaaaaa 30 And you should ignore this data. aaaaaaaaaaaaaaaa 31 And you should ignore this data. aaaaaaaaaaaaaaaa 32 And you should ignore this data. aaaaaaaaaaaaaaaa [all …]
|
H A D | test1061 | 25 And you should ignore this data. aaaaaaaaaaaaaaaa 26 And you should ignore this data. aaaaaaaaaaaaaaaa 27 And you should ignore this data. aaaaaaaaaaaaaaaa 28 And you should ignore this data. aaaaaaaaaaaaaaaa 29 And you should ignore this data. aaaaaaaaaaaaaaaa 30 And you should ignore this data. aaaaaaaaaaaaaaaa 31 And you should ignore this data. aaaaaaaaaaaaaaaa 32 And you should ignore this data. aaaaaaaaaaaaaaaa 33 And you should ignore this data. aaaaaaaaaaaaaaaa 34 And you should ignore this data. aaaaaaaaaaaaaaaa [all …]
|
/curl/lib/vssh/ |
H A D | wolfssh.c | 225 (void)data; in wscp_send() 239 (void)data; in wscp_recv() 633 seekerr = data->set.seek_func(data->set.seek_client, in wssh_statemach_act() 672 data->state.infilesize -= data->state.resume_from; in wssh_statemach_act() 673 data->req.size = data->state.infilesize; in wssh_statemach_act() 680 data->req.size = data->state.infilesize; in wssh_statemach_act() 681 Curl_pgrsSetUploadSize(data, data->state.infilesize); in wssh_statemach_act() 776 if(data->state.use_range || data->state.resume_from) { in wssh_statemach_act() 927 (void)data; in wscp_perform() 1087 (void)data; [all …]
|
H A D | libssh.c | 365 failf(data, in myssh_is_known() 376 failf(data, in myssh_is_known() 1298 seekerr = data->set.seek_func(data->set.seek_client, in myssh_statemach_act() 1337 data->state.infilesize -= data->state.resume_from; in myssh_statemach_act() 1338 data->req.size = data->state.infilesize; in myssh_statemach_act() 1339 Curl_pgrsSetUploadSize(data, data->state.infilesize); in myssh_statemach_act() 1349 data->req.size = data->state.infilesize; in myssh_statemach_act() 1350 Curl_pgrsSetUploadSize(data, data->state.infilesize); in myssh_statemach_act() 1705 data->req.size = size - data->state.resume_from; in myssh_statemach_act() 1706 data->req.maxdownload = size - data->state.resume_from; in myssh_statemach_act() [all …]
|
H A D | libssh2.c | 641 (void)data; in ssh_knownhost() 1221 seekerr = data->set.seek_func(data->set.seek_client, in sftp_upload_init() 1260 data->state.infilesize -= data->state.resume_from; in sftp_upload_init() 1261 data->req.size = data->state.infilesize; in sftp_upload_init() 1262 Curl_pgrsSetUploadSize(data, data->state.infilesize); in sftp_upload_init() 1268 data->req.size = data->state.infilesize; in sftp_upload_init() 1269 Curl_pgrsSetUploadSize(data, data->state.infilesize); in sftp_upload_init() 1275 data->conn->sockfd = data->conn->writesockfd; in sftp_upload_init() 1613 data->conn->writesockfd = data->conn->sockfd; in sftp_download_stat() 2710 data->req.size = data->state.infilesize; in ssh_statemachine() [all …]
|