/curl/lib/ |
H A D | asyn-thread.c | 139 destroy_async_data(&data->state.async); in Curl_resolver_cancel() 176 return &(data->state.async.tdata->tsd); in conn_thread_sync_data() 454 data->state.async.tdata = td; in init_resolve_thread() 512 td = data->state.async.tdata; in thread_wait_resolv() 524 data->state.async.done = TRUE; in thread_wait_resolv() 527 *entry = data->state.async.dns; in thread_wait_resolv() 529 if(!data->state.async.dns && report) in thread_wait_resolv() 533 destroy_async_data(&data->state.async); in thread_wait_resolv() 535 if(!data->state.async.dns && report) in thread_wait_resolv() 605 if(!data->state.async.dns) { in Curl_resolver_is_resolved() [all …]
|
H A D | easy.c | 756 data->state.os_errno = 0; in easy_perform() 950 outcurl->state.cookielist = NULL; in curl_easy_duphandle() 960 if(data->state.cookielist) { in curl_easy_duphandle() 961 outcurl->state.cookielist = Curl_slist_duplicate(data->state.cookielist); in curl_easy_duphandle() 962 if(!outcurl->state.cookielist) in curl_easy_duphandle() 967 if(data->state.url) { in curl_easy_duphandle() 968 outcurl->state.url = strdup(data->state.url); in curl_easy_duphandle() 969 if(!outcurl->state.url) in curl_easy_duphandle() 974 if(data->state.referer) { in curl_easy_duphandle() 975 outcurl->state.referer = strdup(data->state.referer); in curl_easy_duphandle() [all …]
|
H A D | cf-haproxy.c | 49 int state; member 56 ctx->state = HAPROXY_INIT; in cf_haproxy_ctx_reset() 78 DEBUGASSERT(ctx->state == HAPROXY_INIT); in cf_haproxy_date_out_set() 124 switch(ctx->state) { in cf_haproxy_connect() 129 ctx->state = HAPROXY_SEND; in cf_haproxy_connect() 150 ctx->state = HAPROXY_DONE; in cf_haproxy_connect() 158 *done = (!result) && (ctx->state == HAPROXY_DONE); in cf_haproxy_connect() 224 ctx->state = HAPROXY_INIT; in cf_haproxy_create()
|
H A D | curl_fnmatch.c | 76 parsekey_state state = CURLFNM_PKW_INIT; in parsekeyword() local 86 switch(state) { in parsekeyword() 91 state = CURLFNM_PKW_DDOT; in parsekeyword() 167 setcharset_state state = CURLFNM_SCHS_DEFAULT; in setcharset() local 177 switch(state) { in setcharset() 183 state = CURLFNM_SCHS_RIGHTBR; in setcharset() 226 state = CURLFNM_SCHS_RIGHTBRLEFTBR; in setcharset() 236 state = CURLFNM_SCHS_DEFAULT; in setcharset() 247 state = CURLFNM_SCHS_DEFAULT; in setcharset()
|
H A D | mime.c | 280 state->state = tok; in mimesetstate() 281 state->ptr = ptr; in mimesetstate() 282 state->offset = 0; in mimesetstate() 925 switch(part->state.state) { in readback_part() 949 mimesetstate(&part->state, part->state.state, hdr->next); in readback_part() 1009 switch(mime->state.state) { in mime_subparts_read() 1075 if(part->state.state > targetstate) { in mime_part_rewind() 1110 if(mime->state.state == MIMESTATE_BEGIN) in mime_subparts_seek() 1142 part->state.state = MIMESTATE_BEGIN; in cleanup_part_content() 1778 if(part->state.state == MIMESTATE_CURLHEADERS) in Curl_mime_prepare_headers() [all …]
|
H A D | sha256.c | 311 unsigned long state[8], curlen; member 355 S[i] = md->state[i]; in sha256_compress() 384 md->state[i] = md->state[i] + S[i]; in sha256_compress() 395 md->state[0] = 0x6A09E667UL; in my_sha256_init() 396 md->state[1] = 0xBB67AE85UL; in my_sha256_init() 397 md->state[2] = 0x3C6EF372UL; in my_sha256_init() 398 md->state[3] = 0xA54FF53AUL; in my_sha256_init() 399 md->state[4] = 0x510E527FUL; in my_sha256_init() 400 md->state[5] = 0x9B05688CUL; in my_sha256_init() 401 md->state[6] = 0x1F83D9ABUL; in my_sha256_init() [all …]
|
H A D | smtp.c | 240 (smtpc->state == SMTP_EHLO || smtpc->state == SMTP_COMMAND)) { in smtp_endofresp() 310 if(smtpc->state != newstate) in smtp_state() 315 smtpc->state = newstate; in smtp_state() 412 if(smtpc->state != SMTP_UPGRADETLS) in smtp_perform_upgrade_tls() 1206 if(smtpc->state == SMTP_UPGRADETLS) in smtp_statemachine() 1220 if(smtpc->state != SMTP_QUIT && smtpcode != 1) in smtp_statemachine() 1227 switch(smtpc->state) { in smtp_statemachine() 1299 *done = (smtpc->state == SMTP_STOP) ? TRUE : FALSE; in smtp_multi_statemach() 1311 while(smtpc->state != SMTP_STOP && !result) in smtp_block_statemach() 1856 if(data->state.infilesize > 0) in cr_eob_read() [all …]
|
H A D | ftp.c | 161 if(ftpc->state != newstate) in _ftp_state() 171 ftpc->state = newstate; in _ftp_state() 959 if(FTP_STOP == ftpc->state) { in ftp_domore_getsock() 1477 else if(data->state.upload) in ftp_state_prepare_transfer() 1742 data->state.infilesize -= data->state.resume_from; in ftp_state_ul_setup() 2380 if(data->state.resume_from) { in ftp_state_retr() 2840 switch(ftpc->state) { in ftp_statemachine() 3407 if(data->state.wildcardmatch) { in ftp_done() 3536 else if(data->state.upload) { in ftp_done() 3742 if(ftpc->state) { in ftp_do_more() [all …]
|
H A D | mqtt.c | 268 data->state.aptr.user : ""; in mqtt_connect() 272 data->state.aptr.passwd : ""; in mqtt_connect() 344 Curl_safefree(data->state.aptr.user); in mqtt_connect() 345 Curl_safefree(data->state.aptr.passwd); in mqtt_connect() 421 char *path = data->state.up.path; in mqtt_get_topic() 611 statenames[state], in mqstate() 612 statenames[mqtt->state], in mqstate() 615 mqtt->state = state; in mqstate() 616 if(state == MQTT_FIRST) in mqstate() 631 switch(mqtt->state) { in mqtt_read_publish() [all …]
|
H A D | imap.c | 280 switch(imapc->state) { in imap_endofresp() 333 switch(imapc->state) { in imap_endofresp() 416 if(imapc->state != newstate) in imap_state() 421 imapc->state = newstate; in imap_state() 489 if(imapc->state != IMAP_UPGRADETLS) in imap_perform_upgrade_tls() 516 if(!data->state.aptr.user) { in imap_perform_login() 806 if(data->state.infilesize < 0) { in imap_perform_append() 1308 if(imapc->state == IMAP_UPGRADETLS) in imap_statemachine() 1329 switch(imapc->state) { in imap_statemachine() 1414 while(imapc->state != IMAP_STOP && !result) in imap_block_statemach() [all …]
|
H A D | getinfo.c | 99 *param_charp = data->state.url ? data->state.url : (char *)""; in getinfo_char() 108 switch(data->state.httpreq) { in getinfo_char() 143 *param_charp = data->state.most_recent_ftp_entrypath; in getinfo_char() 152 *param_charp = data->state.referer; in getinfo_char() 263 *param_longp = data->state.followlocation; in getinfo_long() 274 *param_longp = data->state.os_errno; in getinfo_long() 311 *param_longp = data->state.rtsp_next_client_CSeq; in getinfo_long() 314 *param_longp = data->state.rtsp_next_server_CSeq; in getinfo_long() 317 *param_longp = data->state.rtsp_CSeq_recv; in getinfo_long() 450 data->conn->connection_id : data->state.recent_conn_id; in getinfo_offt()
|
H A D | mime.h | 92 enum mimestate state; /* Current state token. */ member 106 struct mime_state state; /* Current readback state. */ member 127 struct mime_state state; /* Current readback state. */ member
|
H A D | connect.c | 311 data->state.lastconnect_id = -1; in Curl_getconnectinfo() 390 cf_connect_state state; member 947 switch(ctx->state) { in cf_he_connect() 954 ctx->state = SCFST_WAITING; in cf_he_connect() 964 ctx->state = SCFST_DONE; in cf_he_connect() 1001 ctx->state = SCFST_INIT; in cf_he_close() 1240 cf_setup_state state; member 1338 ctx->state = CF_SETUP_CNNCT_SSL; in cf_setup_connect() 1343 ctx->state = CF_SETUP_DONE; in cf_setup_connect() 1356 ctx->state = CF_SETUP_INIT; in cf_setup_close() [all …]
|
H A D | pop3.c | 276 if(pop3c->state == POP3_CAPA) { in pop3_endofresp() 365 if(pop3c->state != newstate) in pop3_state() 367 (void *)pop3c, names[pop3c->state], names[newstate]); in pop3_state() 370 pop3c->state = newstate; in pop3_state() 441 if(pop3c->state != POP3_UPGRADETLS) in pop3_perform_upgrade_tls() 466 if(!data->state.aptr.user) { in pop3_perform_user() 500 if(!data->state.aptr.user) { in pop3_perform_apop() 1040 if(pop3c->state == POP3_UPGRADETLS) in pop3_statemachine() 1057 switch(pop3c->state) { in pop3_statemachine() 1122 *done = (pop3c->state == POP3_STOP) ? TRUE : FALSE; in pop3_multi_statemach() [all …]
|
H A D | http_aws_sigv4.c | 195 if(data->state.aptr.host) { in make_headers() 198 if(strlen(data->state.aptr.host) > FULL_HOST_LEN) { in make_headers() 202 strcpy(full_host, data->state.aptr.host); in make_headers() 614 const char *user = data->state.aptr.user ? data->state.aptr.user : ""; in Curl_output_aws_sigv4() 758 result = canon_query(data, data->state.up.query, &canonical_query); in Curl_output_aws_sigv4() 762 result = canon_string(data->state.up.path, strlen(data->state.up.path), in Curl_output_aws_sigv4() 825 data->state.aptr.passwd ? in Curl_output_aws_sigv4() 826 data->state.aptr.passwd : ""); in Curl_output_aws_sigv4() 861 Curl_safefree(data->state.aptr.userpwd); in Curl_output_aws_sigv4() 862 data->state.aptr.userpwd = auth_headers; in Curl_output_aws_sigv4() [all …]
|
H A D | smb.c | 373 enum smb_req_state state; member 394 if(smbc->state != newstate) in conn_state() 399 smbc->state = newstate; in conn_state() 420 if(req->state != newstate) in request_state() 425 req->state = newstate; in request_state() 453 if(!data->state.aptr.user) in smb_connect() 723 if(data->state.upload) { in smb_send_open() 886 switch(smbc->state) { in smb_connection_state() 955 if(data->state.upload && (data->state.infilesize < 0)) { in smb_request_state() 983 switch(req->state) { in smb_request_state() [all …]
|
H A D | socks.c | 83 enum connect_t state; member 170 enum connect_t oldstate = sx->state; in socksstate() 196 if(oldstate == state) in socksstate() 200 sx->state = state; in socksstate() 295 switch(sx->state) { in do_SOCKS4() 348 data->state.async.dns = dns; in do_SOCKS4() 349 data->state.async.done = TRUE; in do_SOCKS4() 594 switch(sx->state) { in do_SOCKS5() 819 data->state.async.dns = dns; in do_SOCKS5() 1154 if(sx->state == CONNECT_INIT) { in socks_proxy_cf_connect() [all …]
|
H A D | multi.c | 180 if(oldstate == state) in mstate() 184 data->mstate = state; in mstate() 196 if(state == MSTATE_COMPLETED) { in mstate() 207 if(finit[state]) in mstate() 208 finit[state](data); in mstate() 522 data->state.os_errno = 0; in curl_multi_add_handle() 702 if(data->state.done) in multi_done() 1970 data->state.async.dns = dns; 2143 if(wc->state == CURLWC_DONE || wc->state == CURLWC_SKIP) { 3540 node = &data->state.expires[eid]; [all …]
|
H A D | openldap.c | 226 if(ldapc->state != newstate) in oldap_state() 231 ldapc->state = newstate; in oldap_state() 273 if(!data->state.up.user && !data->state.up.password && in oldap_url_parse() 274 !data->state.up.options) in oldap_url_parse() 275 rc = ldap_url_parse(data->state.url, ludp); in oldap_url_parse() 422 if(data->state.aptr.user) { in oldap_perform_bind() 737 if(li->state != OLDAP_SSL && li->state != OLDAP_TLS) { in oldap_connecting() 780 switch(li->state) { in oldap_connecting() 814 else if(data->state.aptr.user) in oldap_connecting() 843 *done = li->state == OLDAP_STOP; in oldap_connecting() [all …]
|
H A D | curl_sasl.c | 198 sasl->state = SASL_STOP; /* Not yet running */ in Curl_sasl_init() 260 if(sasl->state != newstate) in sasl_state() 262 (void *)sasl, names[sasl->state], names[newstate]); in sasl_state() 267 sasl->state = newstate; in sasl_state() 328 if(data->state.aptr.user) in Curl_sasl_can_authenticate() 381 else if(data->state.aptr.user) { in Curl_sasl_start() 555 if(sasl->state == SASL_FINAL) { in Curl_sasl_continue() 563 if(sasl->state != SASL_CANCEL && sasl->state != SASL_OAUTH2_RESP && in Curl_sasl_continue() 570 switch(sasl->state) { in Curl_sasl_continue()
|
/curl/tests/libtest/ |
H A D | libntlmconnect.c | 99 enum HandleState state = ReadyForNewHandle; in test() local 133 if(state == ReadyForNewHandle) { in test() 157 state = NeedSocketForNewHandle; in test() 164 __FILE__, __LINE__, running, state); in test() 168 if(!running && state == NoMoreHandles) in test() 179 if(state == NeedSocketForNewHandle) { in test() 185 state = num_handles < MAX_EASY_HANDLES ? ReadyForNewHandle in test() 188 __FILE__, __LINE__, state); in test()
|
H A D | lib677.c | 40 int state = 0; in test() local 73 waitfd.events = state ? CURL_WAIT_POLLIN : CURL_WAIT_POLLOUT; in test() 83 if(!state) { in test() 101 state++; in test() 125 if(state) { in test()
|
H A D | lib1915.c | 49 struct state { struct 59 struct state *s = (struct state *)userp; in hstsread() argument 103 struct state st = {0}; in test()
|
/curl/docs/examples/ |
H A D | hsts-preload.c | 43 struct state { struct 54 struct state *s = (struct state *)userp; in hstsread() argument 87 struct state st = {0}; in main()
|
/curl/src/ |
H A D | tool_operate.c | 433 struct State *state = &config->state; in single_transfer_cleanup() local 434 if(state->urls) { in single_transfer_cleanup() 441 if(state->inglob) { in single_transfer_cleanup() 835 struct State *state = &config->state; in single_transfer() local 861 if(!state->urlnode) { in single_transfer() 882 state->up = 0; in single_transfer() 941 result = glob_url(&state->urls, urlnode->url, &state->urlnum, in single_transfer() 954 if(state->up < state->infilenum) { in single_transfer() 2402 state->li++; in single_transfer() 2409 state->up++; in single_transfer() [all …]
|