/curl/lib/ |
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_conn_send(data, FIRSTSOCKET, s, write_len, FALSE, in Curl_pp_vsendf() 392 socks[0] = conn->sock[FIRSTSOCKET]; in Curl_pp_getsock() 420 result = Curl_conn_send(data, FIRSTSOCKET, in Curl_pp_flushsend()
|
H A D | gopher.c | 125 result = Curl_conn_connect(data, FIRSTSOCKET, TRUE, done); in gopher_connecting() 137 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in gopher_do()
|
H A D | curl_rtmp.c | 237 r->m_sb.sb_socket = (int)conn->sock[FIRSTSOCKET]; in rtmp_connect() 261 conn->recv[FIRSTSOCKET] = rtmp_recv; in rtmp_connect() 262 conn->send[FIRSTSOCKET] = rtmp_send; in rtmp_connect()
|
H A D | openldap.c | 475 CURLcode result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in oldap_ssl_connect() 485 li->recv = conn->recv[FIRSTSOCKET]; in oldap_ssl_connect() 486 li->send = conn->send[FIRSTSOCKET]; in oldap_ssl_connect() 548 rc = ldap_init_fd(conn->sock[FIRSTSOCKET], li->proto, hosturl, &li->ld); in oldap_connect() 787 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in oldap_connecting() 830 conn->recv[FIRSTSOCKET] = oldap_recv; in oldap_connecting() 1155 return Curl_conn_data_pending(data, FIRSTSOCKET); in ldapsb_tls_ctrl() 1171 ret = (li->recv)(data, FIRSTSOCKET, buf, len, &err); in ldapsb_tls_read() 1190 ret = (li->send)(data, FIRSTSOCKET, buf, len, FALSE, &err); in ldapsb_tls_write()
|
H A D | telnet.c | 316 bytes_written = swrite(conn->sock[FIRSTSOCKET], buf, 3); in send_negotiation() 946 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 958 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 990 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 1044 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer, 3); in sendsuboption() 1053 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer + 7, 2); in sendsuboption() 1263 pfd[0].fd = conn->sock[FIRSTSOCKET]; in send_telnet_data() 1302 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in telnet_do()
|
H A D | pop3.c | 431 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in pop3_perform_upgrade_tls() 432 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in pop3_perform_upgrade_tls() 437 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in pop3_perform_upgrade_tls() 823 if(!data->set.use_ssl || Curl_conn_is_ssl(conn, FIRSTSOCKET)) in pop3_state_capa_resp() 1049 result = Curl_pp_readresp(data, FIRSTSOCKET, pp, &pop3code, &nread); in pop3_statemachine() 1115 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in pop3_multi_statemach() 1270 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in pop3_perform()
|
H A D | smtp.c | 403 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in smtp_perform_upgrade_tls() 404 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in smtp_perform_upgrade_tls() 409 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in smtp_perform_upgrade_tls() 895 || Curl_conn_is_ssl(conn, FIRSTSOCKET)) in smtp_state_ehlo_resp() 960 if(data->set.use_ssl && !Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in smtp_state_ehlo_resp() 1214 result = Curl_pp_readresp(data, FIRSTSOCKET, pp, &smtpcode, &nread); in smtp_statemachine() 1291 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in smtp_multi_statemach() 1480 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in smtp_perform()
|
H A D | transfer.c | 127 Curl_conn_data_pending(data, FIRSTSOCKET); in data_pending() 289 is_multiplex = Curl_conn_is_multiplex(conn, FIRSTSOCKET); in sendrecv_dl() 804 writesockindex = FIRSTSOCKET; in xfer_setup() 849 int recv_index = (send_recv & CURL_XFER_RECV) ? FIRSTSOCKET : -1; in Curl_xfer_setup1() 850 int send_index = (send_recv & CURL_XFER_SEND) ? FIRSTSOCKET : -1; in Curl_xfer_setup1()
|
H A D | imap.c | 480 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in imap_perform_upgrade_tls() 481 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in imap_perform_upgrade_tls() 486 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in imap_perform_upgrade_tls() 957 else if(data->set.use_ssl && !Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in imap_state_capability_resp() 1317 result = Curl_pp_readresp(data, FIRSTSOCKET, pp, &imapcode, &nread); 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 | http_negotiate.c | 115 data, FIRSTSOCKET, &neg_ctx->channel_binding_data); in Curl_input_negotiate()
|
H A D | ftp.c | 428 curl_socket_t ctrl_sock = conn->sock[FIRSTSOCKET]; in ftp_check_ctrl_on_data_wait() 629 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in Curl_GetFTPResponse() 683 else if(!Curl_conn_data_pending(data, FIRSTSOCKET)) { in Curl_GetFTPResponse() 705 result = ftp_readresp(data, FIRSTSOCKET, pp, ftpcode, &nread); in Curl_GetFTPResponse() 780 socks[0] = conn->sock[FIRSTSOCKET]; in ftp_domore_getsock() 983 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port() 1063 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port() 2660 result = ftp_readresp(data, FIRSTSOCKET, pp, &ftpcode, &nread); in ftp_statemachine() 2744 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in ftp_statemachine() 2822 result = Curl_ssl_cfilter_remove(data, FIRSTSOCKET, in ftp_statemachine() [all …]
|
H A D | krb5.c | 216 if(getsockname(conn->sock[FIRSTSOCKET], in krb5_auth() 893 conn->recv[FIRSTSOCKET] = sec_recv; in choose_mech() 894 conn->send[FIRSTSOCKET] = sec_send; in choose_mech()
|
H A D | http.c | 1140 return Curl_conn_connect(data, FIRSTSOCKET, FALSE, done); in Curl_http_connect() 1152 socks[0] = Curl_conn_get_socket(data, FIRSTSOCKET); in Curl_http_getsock_do() 1221 if(Curl_conn_is_http3(data, conn, FIRSTSOCKET)) in get_http_string() 1223 if(Curl_conn_is_http2(data, conn, FIRSTSOCKET)) in get_http_string() 2494 DEBUGASSERT(Curl_conn_is_http3(data, conn, FIRSTSOCKET)); in Curl_http() 2498 if(!Curl_conn_is_http2(data, conn, FIRSTSOCKET) && in Curl_http() 2501 result = Curl_http2_switch(data, conn, FIRSTSOCKET); in Curl_http() 2514 if(Curl_http2_may_switch(data, conn, FIRSTSOCKET)) { in Curl_http() 2516 result = Curl_http2_switch(data, conn, FIRSTSOCKET); in Curl_http() 3641 && !Curl_conn_is_http2(data, conn, FIRSTSOCKET) in http_on_response() [all …]
|
H A D | conncache.c | 870 if(!conn->connect_only && Curl_conn_is_connected(conn, FIRSTSOCKET)) in cpool_run_conn_shutdown() 871 r1 = Curl_conn_shutdown(data, FIRSTSOCKET, &done1); in cpool_run_conn_shutdown() 1051 Curl_conn_close(data, FIRSTSOCKET); in cpool_close_and_destroy() 1096 if(s == conn->sock[FIRSTSOCKET] || s == conn->sock[SECONDARYSOCKET]) { in Curl_cpool_multi_socket()
|
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 | cfilters.c | 781 struct Curl_cfilter *cf = conn->cfilter[FIRSTSOCKET]; in conn_report_connect_stats() 801 struct Curl_cfilter *cf = conn->cfilter[FIRSTSOCKET]; in Curl_conn_is_alive() 845 return FIRSTSOCKET; in Curl_conn_sockindex()
|
H A D | multi.c | 651 || (mdctx->premature && !Curl_conn_is_multiplex(conn, FIRSTSOCKET))) { in multi_done_locked() 657 Curl_conn_is_multiplex(conn, FIRSTSOCKET))); in multi_done_locked() 964 sockfd = Curl_conn_get_socket(data, FIRSTSOCKET); in connecting_getsock() 982 sockfd = Curl_conn_get_socket(data, FIRSTSOCKET); in protocol_getsock() 1135 Curl_conn_is_ip_connected(data, FIRSTSOCKET)) { in multi_getsock() 1778 if(Curl_conn_is_connected(conn, FIRSTSOCKET) 2580 Curl_conn_is_multiplex(data->conn, FIRSTSOCKET)) { 2702 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &connected); 2705 Curl_conn_is_multiplex(data->conn, FIRSTSOCKET)) {
|
H A D | mqtt.c | 151 sock[0] = conn->sock[FIRSTSOCKET]; in mqtt_getsock() 152 return GETSOCK_READSOCK(FIRSTSOCKET); in mqtt_getsock()
|
H A D | connect.c | 318 return conn->sock[FIRSTSOCKET]; in Curl_getconnectinfo() 341 is_multiplex = Curl_conn_is_multiplex(conn, FIRSTSOCKET); in Curl_conncontrol() 548 if(cf->sockindex == FIRSTSOCKET) { in baller_start_next()
|
H A D | url.c | 830 result = Curl_conn_keep_alive(data, conn, FIRSTSOCKET); in Curl_conn_upkeep() 911 if(!Curl_conn_is_connected(conn, FIRSTSOCKET) || in url_match_conn() 1183 Curl_conn_get_max_concurrent(data, conn, FIRSTSOCKET)) { in url_match_conn() 1320 conn->sock[FIRSTSOCKET] = CURL_SOCKET_BAD; /* no file descriptor */ in allocate_conn() 3563 conn->recv[FIRSTSOCKET] = Curl_cf_recv; 3564 conn->send[FIRSTSOCKET] = Curl_cf_send; 3771 result = Curl_conn_setup(data, conn, FIRSTSOCKET, conn->dns_entry,
|
H A D | easy.c | 1247 result = Curl_conn_recv(data, FIRSTSOCKET, buffer, buflen, &n1); in curl_easy_recv() 1298 result = Curl_conn_send(data, FIRSTSOCKET, buffer, buflen, FALSE, n); in Curl_senddata()
|
H A D | getinfo.c | 573 tsi->internals = Curl_ssl_get_internals(data, FIRSTSOCKET, info, 0); in getinfo_slist()
|
/curl/lib/vssh/ |
H A D | wolfssh.c | 370 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_connect() 382 conn->recv[FIRSTSOCKET] = wscp_recv; in wssh_connect() 383 conn->send[FIRSTSOCKET] = wscp_send; in wssh_connect() 386 conn->recv[FIRSTSOCKET] = wsftp_recv; in wssh_connect() 387 conn->send[FIRSTSOCKET] = wsftp_send; in wssh_connect() 950 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in wsftp_perform() 1021 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_block_statemach() 1141 sock[0] = conn->sock[FIRSTSOCKET]; in wssh_getsock() 1144 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in wssh_getsock() 1146 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in wssh_getsock()
|
H A D | libssh.c | 670 curl_socket_t sock = conn->sock[FIRSTSOCKET]; 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() 2053 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in myssh_getsock() 2166 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in myssh_connect() 2178 conn->recv[FIRSTSOCKET] = scp_recv; in myssh_connect() 2179 conn->send[FIRSTSOCKET] = scp_send; in myssh_connect() 2182 conn->recv[FIRSTSOCKET] = sftp_recv; in myssh_connect() [all …]
|
H A D | libssh2.c | 2014 conn->sockfd = conn->sock[FIRSTSOCKET]; in ssh_statemachine() 3023 sock[0] = conn->sock[FIRSTSOCKET]; in ssh_getsock() 3026 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in ssh_getsock() 3029 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in ssh_getsock() 3239 sock = conn->sock[FIRSTSOCKET]; in ssh_connect() 3312 sshc->tls_recv = conn->recv[FIRSTSOCKET]; in ssh_connect() 3313 sshc->tls_send = conn->send[FIRSTSOCKET]; in ssh_connect() 3318 conn->recv[FIRSTSOCKET] = scp_recv; in ssh_connect() 3319 conn->send[FIRSTSOCKET] = scp_send; in ssh_connect() 3322 conn->recv[FIRSTSOCKET] = sftp_recv; in ssh_connect() [all …]
|