/third_party/curl/lib/ |
H A D | gopher.c | 123 result = Curl_conn_connect(data, FIRSTSOCKET, TRUE, done); in gopher_connecting() 135 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in gopher_do() 188 result = Curl_nwrite(data, FIRSTSOCKET, sel, k, &amount); in gopher_do() 230 result = Curl_nwrite(data, FIRSTSOCKET, "\r\n", 2, &amount); in gopher_do() 239 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in gopher_do()
|
H A D | curl_rtmp.c | 229 r->m_sb.sb_socket = (int)conn->sock[FIRSTSOCKET]; in rtmp_connect() 253 conn->recv[FIRSTSOCKET] = rtmp_recv; in rtmp_connect() 254 conn->send[FIRSTSOCKET] = rtmp_send; in rtmp_connect() 268 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in rtmp_do() 271 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in rtmp_do()
|
H A D | pingpong.c | 88 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in Curl_pp_statemach() 107 if(Curl_conn_data_pending(data, FIRSTSOCKET)) in Curl_pp_statemach() 112 else if(!pp->sendleft && Curl_conn_data_pending(data, FIRSTSOCKET)) in Curl_pp_statemach() 202 result = Curl_nwrite(data, FIRSTSOCKET, s, write_len, &bytes_written); in Curl_pp_vsendf() 383 socks[0] = conn->sock[FIRSTSOCKET]; in Curl_pp_getsock() 399 CURLcode result = Curl_nwrite(data, FIRSTSOCKET, in Curl_pp_flushsend()
|
H A D | http.c | 1514 return Curl_conn_connect(data, FIRSTSOCKET, FALSE, done); in Curl_http_connect() 1526 socks[0] = Curl_conn_get_socket(data, FIRSTSOCKET); in Curl_http_getsock_do() 1605 if(Curl_conn_is_http3(data, conn, FIRSTSOCKET)) in get_http_string() 1607 if(Curl_conn_is_http2(data, conn, FIRSTSOCKET)) in get_http_string() 2506 FIRSTSOCKET); in Curl_http_bodysend() 2511 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, in Curl_http_bodysend() 2512 http->postsize?FIRSTSOCKET:-1); in Curl_http_bodysend() 2528 FIRSTSOCKET); in Curl_http_bodysend() 2533 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, -1); in Curl_http_bodysend() 2586 FIRSTSOCKET); in Curl_http_bodysend() [all...] |
H A D | openldap.c | 485 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in oldap_ssl_connect() 495 li->recv = conn->recv[FIRSTSOCKET]; in oldap_ssl_connect() 496 li->send = conn->send[FIRSTSOCKET]; in oldap_ssl_connect() 557 rc = ldap_init_fd(conn->sock[FIRSTSOCKET], li->proto, hosturl, &li->ld); in oldap_connect() 796 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in oldap_connecting() 839 conn->recv[FIRSTSOCKET] = oldap_recv; in oldap_connecting() 919 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in oldap_do() 1164 return Curl_conn_data_pending(data, FIRSTSOCKET); in ldapsb_tls_ctrl() 1180 ret = (li->recv)(data, FIRSTSOCKET, buf, len, &err); in ldapsb_tls_read() 1199 ret = (li->send)(data, FIRSTSOCKET, bu in ldapsb_tls_write() [all...] |
H A D | smtp.c | 400 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in smtp_perform_upgrade_tls() 401 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in smtp_perform_upgrade_tls() 406 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in smtp_perform_upgrade_tls() 893 || Curl_conn_is_ssl(conn, FIRSTSOCKET)) in smtp_state_ehlo_resp() 958 if(data->set.use_ssl && !Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in smtp_state_ehlo_resp() 1165 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in smtp_state_data_resp() 1197 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in smtp_statemachine() 1286 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in smtp_multi_statemach() 1518 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in smtp_perform()
|
H A D | telnet.c | 315 bytes_written = swrite(conn->sock[FIRSTSOCKET], buf, 3); in send_negotiation() 951 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 963 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 995 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 1049 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer, 3); in sendsuboption() 1058 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer + 7, 2); in sendsuboption() 1264 pfd[0].fd = conn->sock[FIRSTSOCKET]; in send_telnet_data() 1273 result = Curl_nwrite(data, FIRSTSOCKET, outbuf + total_written, in send_telnet_data() 1303 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in telnet_do()
|
H A D | imap.c | 478 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in imap_perform_upgrade_tls() 479 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in imap_perform_upgrade_tls() 484 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in imap_perform_upgrade_tls() 955 else if(data->set.use_ssl && !Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in imap_state_capability_resp() 1221 Curl_setup_transfer(data, FIRSTSOCKET, size, FALSE, -1); in imap_state_fetch_resp() 1269 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in imap_state_append_resp() 1300 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in imap_statemachine() 1395 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in imap_multi_statemach() 1611 *connected = Curl_conn_is_connected(conn, FIRSTSOCKET); in imap_perform()
|
H A D | mqtt.c | 123 result = Curl_nwrite(data, FIRSTSOCKET, buf, len, &n); in mqtt_send() 150 sock[0] = conn->sock[FIRSTSOCKET]; in mqtt_getsock() 151 return GETSOCK_READSOCK(FIRSTSOCKET); in mqtt_getsock() 369 result = Curl_read(data, data->conn->sock[FIRSTSOCKET], in mqtt_recv_atleast() 625 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_read_publish() 747 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_doing()
|
H A D | pop3.c | 373 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in pop3_perform_upgrade_tls() 374 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in pop3_perform_upgrade_tls() 379 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in pop3_perform_upgrade_tls() 763 if(!data->set.use_ssl || Curl_conn_is_ssl(conn, FIRSTSOCKET)) in pop3_state_capa_resp() 937 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in pop3_state_command_resp() 973 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in pop3_statemachine() 1056 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in pop3_multi_statemach() 1211 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in pop3_perform()
|
H A D | rtsp.c | 90 socks[0] = conn->sock[FIRSTSOCKET]; in rtsp_getsock_do() 313 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, -1); in rtsp_do() 570 &data->info.request_size, 0, FIRSTSOCKET); in rtsp_do() 576 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, putsize?FIRSTSOCKET:-1); in rtsp_do()
|
H A D | krb5.c | 93 result = Curl_nwrite(data, FIRSTSOCKET, sptr, write_len, in ftpsend() 215 if(getsockname(conn->sock[FIRSTSOCKET], in krb5_auth() 874 conn->recv[FIRSTSOCKET] = sec_recv; in choose_mech() 875 conn->send[FIRSTSOCKET] = sec_send; in choose_mech()
|
H A D | smb.c | 488 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in smb_recv_message() 571 result = Curl_nwrite(data, FIRSTSOCKET, data->state.ulbuf, in smb_send() 597 result = Curl_nwrite(data, FIRSTSOCKET, in smb_flush() 856 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssl_done); in smb_connection_state() 1143 socks[0] = conn->sock[FIRSTSOCKET]; in smb_getsock()
|
H A D | ftp.c | 362 curl_socket_t ctrl_sock = conn->sock[FIRSTSOCKET]; in ReceivedServerConnect() 624 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in Curl_GetFTPResponse() 676 else if(!Curl_conn_data_pending(data, FIRSTSOCKET)) { in Curl_GetFTPResponse() 835 socks[0] = conn->sock[FIRSTSOCKET]; in ftp_domore_getsock() 1041 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port() 1123 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port() 2695 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ftp_statemachine() 2789 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in ftp_statemachine() 2790 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in ftp_statemachine() 2796 result = Curl_conn_connect(data, FIRSTSOCKET, TRU in ftp_statemachine() [all...] |
H A D | curl_sasl.c | 363 Curl_conn_get_host(data, FIRSTSOCKET, &hostname, &disp_hostname, &port); in Curl_sasl_start() 550 Curl_conn_get_host(data, FIRSTSOCKET, &hostname, &disp_hostname, &port); in Curl_sasl_continue()
|
H A D | multi.c | 748 || (premature && !Curl_conn_is_multiplex(conn, FIRSTSOCKET))) { in multi_done() 754 Curl_conn_is_multiplex(conn, FIRSTSOCKET))); in multi_done() 1003 if(conn && conn->sock[FIRSTSOCKET] != CURL_SOCKET_BAD) { in connecting_getsock() 1005 socks[0] = conn->sock[FIRSTSOCKET]; in connecting_getsock() 1771 if(Curl_conn_is_connected(conn, FIRSTSOCKET) 2141 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &connected);
|
H A D | transfer.c | 381 Curl_conn_data_pending(data, FIRSTSOCKET); in data_pending() 489 is_multiplex = Curl_conn_is_multiplex(conn, FIRSTSOCKET); in readwrite_data() 1620 writesockindex = FIRSTSOCKET; in Curl_setup_transfer()
|
H A D | connect.c | 298 return c->sock[FIRSTSOCKET]; in Curl_getconnectinfo() 321 is_multiplex = Curl_conn_is_multiplex(conn, FIRSTSOCKET); in Curl_conncontrol() 527 if(cf->sockindex == FIRSTSOCKET) { in baller_start_next()
|
H A D | cfilters.c | 619 struct Curl_cfilter *cf = conn->cfilter[FIRSTSOCKET]; in conn_report_connect_stats() 639 struct Curl_cfilter *cf = conn->cfilter[FIRSTSOCKET]; in Curl_conn_is_alive()
|
H A D | url.c | 567 Curl_conn_close(data, FIRSTSOCKET); in conn_shutdown() 1032 if(!Curl_conn_is_connected(check, FIRSTSOCKET)) { in ConnectionExists() 1295 Curl_conn_get_max_concurrent(data, check, FIRSTSOCKET)) { in ConnectionExists() 1356 conn->sock[FIRSTSOCKET] = CURL_SOCKET_BAD; /* no file descriptor */ in allocate_conn() 3624 conn->recv[FIRSTSOCKET] = Curl_conn_recv; 3625 conn->send[FIRSTSOCKET] = Curl_conn_send; 3850 result = Curl_conn_setup(data, conn, FIRSTSOCKET, conn->dns_entry,
|
H A D | getinfo.c | 546 tsi->internals = Curl_ssl_get_internals(data, FIRSTSOCKET, info, 0); in getinfo_slist()
|
/third_party/curl/lib/vssh/ |
H A D | wolfssh.c | 367 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_connect() 379 conn->recv[FIRSTSOCKET] = wscp_recv; in wssh_connect() 380 conn->send[FIRSTSOCKET] = wscp_send; in wssh_connect() 383 conn->recv[FIRSTSOCKET] = wsftp_recv; in wssh_connect() 384 conn->send[FIRSTSOCKET] = wsftp_send; in wssh_connect() 681 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in wssh_statemach_act() 786 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in wssh_statemach_act() 947 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in wsftp_perform() 1018 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_block_statemach() 1138 sock[0] = conn->sock[FIRSTSOCKET]; in wssh_getsock() [all...] |
H A D | libssh.c | 674 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in myssh_statemach_act() 1352 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in myssh_statemach_act() 1726 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in myssh_statemach_act() 1850 Curl_setup_transfer(data, -1, data->req.size, FALSE, FIRSTSOCKET); in myssh_statemach_act() 1894 Curl_setup_transfer(data, FIRSTSOCKET, bytecount, FALSE, -1); in myssh_statemach_act() 1955 /* conn->sock[FIRSTSOCKET] is closed by ssh_disconnect behind our back, in myssh_statemach_act() 1958 Curl_conn_forget_socket(data, FIRSTSOCKET); in myssh_statemach_act() 2044 sock[0] = conn->sock[FIRSTSOCKET]; in myssh_getsock() 2047 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in myssh_getsock() 2050 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in myssh_getsock() [all...] |
H A D | libssh2.c | 971 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ssh_statemach_act() 2198 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in ssh_statemach_act() 2596 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in ssh_statemach_act() 2742 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in ssh_statemach_act() 2813 Curl_setup_transfer(data, FIRSTSOCKET, bytecount, FALSE, -1); in ssh_statemach_act() 3053 sock[0] = conn->sock[FIRSTSOCKET]; in ssh_getsock() 3056 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in ssh_getsock() 3059 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in ssh_getsock() 3149 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ssh_block_statemach() 3267 sock = conn->sock[FIRSTSOCKET]; in ssh_connect() [all...] |
/third_party/curl/lib/vquic/ |
H A D | curl_msh3.c | 732 if(cf->sockindex == FIRSTSOCKET) { in cf_msh3_active() 952 if(cf->sockindex == FIRSTSOCKET) in cf_msh3_close()
|