Home
last modified time | relevance | path

Searched refs:FIRSTSOCKET (Results 1 – 25 of 33) sorted by relevance

12

/third_party/curl/lib/
Dgopher.c123 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()
Dcurl_rtmp.c229 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()
Ddict.c179 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in dict_do()
243 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); /* no upload */ in dict_do()
289 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in dict_do()
311 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in dict_do()
Dpingpong.c87 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in Curl_pp_statemach()
106 if(Curl_conn_data_pending(data, FIRSTSOCKET)) in Curl_pp_statemach()
111 else if(!pp->sendleft && Curl_conn_data_pending(data, FIRSTSOCKET)) in Curl_pp_statemach()
207 result = Curl_nwrite(data, FIRSTSOCKET, s, write_len, &bytes_written); in Curl_pp_vsendf()
454 socks[0] = conn->sock[FIRSTSOCKET]; in Curl_pp_getsock()
470 CURLcode result = Curl_nwrite(data, FIRSTSOCKET, in Curl_pp_flushsend()
Dopenldap.c504 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in oldap_ssl_connect()
514 li->recv = conn->recv[FIRSTSOCKET]; in oldap_ssl_connect()
515 li->send = conn->send[FIRSTSOCKET]; in oldap_ssl_connect()
556 rc = ldap_init_fd(conn->sock[FIRSTSOCKET], li->proto, hosturl, &li->ld); in oldap_connect()
835 conn->recv[FIRSTSOCKET] = oldap_recv; in oldap_connecting()
906 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in oldap_do()
1157 return Curl_conn_data_pending(data, FIRSTSOCKET); in ldapsb_tls_ctrl()
1173 ret = (li->recv)(data, FIRSTSOCKET, buf, len, &err); in ldapsb_tls_read()
1192 ret = (li->send)(data, FIRSTSOCKET, buf, len, &err); in ldapsb_tls_write()
Dhttp.c1573 return Curl_conn_connect(data, FIRSTSOCKET, FALSE, done); in Curl_http_connect()
1585 socks[0] = Curl_conn_get_socket(data, FIRSTSOCKET); in http_getsock_do()
1664 if(Curl_conn_is_http3(data, conn, FIRSTSOCKET)) in get_http_string()
1666 if(Curl_conn_is_http2(data, conn, FIRSTSOCKET)) in get_http_string()
2560 FIRSTSOCKET); in Curl_http_bodysend()
2565 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, in Curl_http_bodysend()
2566 http->postsize?FIRSTSOCKET:-1); in Curl_http_bodysend()
2582 FIRSTSOCKET); in Curl_http_bodysend()
2587 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, -1); in Curl_http_bodysend()
2653 FIRSTSOCKET); in Curl_http_bodysend()
[all …]
Dtelnet.c313 bytes_written = swrite(conn->sock[FIRSTSOCKET], buf, 3); in send_negotiation()
943 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption()
955 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption()
987 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption()
1041 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer, 3); in sendsuboption()
1050 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer + 7, 2); in sendsuboption()
1260 pfd[0].fd = conn->sock[FIRSTSOCKET]; in send_telnet_data()
1269 result = Curl_nwrite(data, FIRSTSOCKET, in send_telnet_data()
1304 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in telnet_do()
Dmqtt.c123 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()
626 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_read_publish()
756 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_doing()
Dpop3.c372 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in pop3_perform_upgrade_tls()
373 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in pop3_perform_upgrade_tls()
378 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in pop3_perform_upgrade_tls()
771 if(!data->set.use_ssl || Curl_conn_is_ssl(conn, FIRSTSOCKET)) in pop3_state_capa_resp()
945 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in pop3_state_command_resp()
976 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in pop3_statemachine()
1059 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in pop3_multi_statemach()
1215 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in pop3_perform()
Dsmtp.c400 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()
1169 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in smtp_state_data_resp()
1201 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in smtp_statemachine()
1291 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in smtp_multi_statemach()
1524 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in smtp_perform()
Drtsp.c86 socks[0] = conn->sock[FIRSTSOCKET]; in rtsp_getsock_do()
309 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, -1); in rtsp_do()
566 &data->info.request_size, 0, FIRSTSOCKET); in rtsp_do()
572 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, putsize?FIRSTSOCKET:-1); in rtsp_do()
Dimap.c477 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in imap_perform_upgrade_tls()
478 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in imap_perform_upgrade_tls()
483 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in imap_perform_upgrade_tls()
954 else if(data->set.use_ssl && !Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in imap_state_capability_resp()
1226 Curl_setup_transfer(data, FIRSTSOCKET, size, FALSE, -1); in imap_state_fetch_resp()
1274 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in imap_state_append_resp()
1305 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in imap_statemachine()
1401 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone); in imap_multi_statemach()
1619 *connected = Curl_conn_is_connected(conn, FIRSTSOCKET); in imap_perform()
Dkrb5.c94 result = Curl_nwrite(data, FIRSTSOCKET, sptr, write_len, in ftpsend()
216 if(getsockname(conn->sock[FIRSTSOCKET], in krb5_auth()
863 conn->recv[FIRSTSOCKET] = sec_recv; in choose_mech()
864 conn->send[FIRSTSOCKET] = sec_send; in choose_mech()
Dsmb.c488 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()
1150 socks[0] = conn->sock[FIRSTSOCKET]; in smb_getsock()
Dftp.c361 curl_socket_t ctrl_sock = conn->sock[FIRSTSOCKET]; in ReceivedServerConnect()
618 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in Curl_GetFTPResponse()
670 else if(!Curl_conn_data_pending(data, FIRSTSOCKET)) { in Curl_GetFTPResponse()
829 socks[0] = conn->sock[FIRSTSOCKET]; in ftp_domore_getsock()
1042 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port()
1124 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port()
2692 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ftp_statemachine()
2786 if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) { in ftp_statemachine()
2787 result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET); in ftp_statemachine()
2793 result = Curl_conn_connect(data, FIRSTSOCKET, TRUE, &done); in ftp_statemachine()
[all …]
Dcurl_sasl.c355 Curl_conn_get_host(data, FIRSTSOCKET, &hostname, &disp_hostname, &port); in Curl_sasl_start()
542 Curl_conn_get_host(data, FIRSTSOCKET, &hostname, &disp_hostname, &port); in Curl_sasl_continue()
Dcfilters.c604 struct Curl_cfilter *cf = conn->cfilter[FIRSTSOCKET]; in conn_report_connect_stats()
624 struct Curl_cfilter *cf = conn->cfilter[FIRSTSOCKET]; in Curl_conn_is_alive()
Dtransfer.c375 Curl_conn_data_pending(data, FIRSTSOCKET); in data_pending()
449 bool is_http3 = Curl_conn_is_http3(data, conn, FIRSTSOCKET); in readwrite_data()
450 data_eof_handled = is_http3 || Curl_conn_is_http2(data, conn, FIRSTSOCKET); in readwrite_data()
1890 writesockindex = FIRSTSOCKET; in Curl_setup_transfer()
Dconnect.c311 return c->sock[FIRSTSOCKET]; in Curl_getconnectinfo()
334 is_multiplex = Curl_conn_is_multiplex(conn, FIRSTSOCKET); in Curl_conncontrol()
529 if(cf->sockindex == FIRSTSOCKET) { in baller_start_next()
Dmulti.c770 || (premature && !Curl_conn_is_multiplex(conn, FIRSTSOCKET))) { in multi_done()
776 Curl_conn_is_multiplex(conn, FIRSTSOCKET))); in multi_done()
1043 return Curl_conn_get_select_socks(data, FIRSTSOCKET, socks); in protocol_getsock()
1075 return Curl_conn_get_select_socks(data, FIRSTSOCKET, socks); in multi_getsock()
1731 if(Curl_conn_is_connected(conn, FIRSTSOCKET)
2100 result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &connected);
Durl.c697 Curl_conn_close(data, FIRSTSOCKET); in conn_shutdown()
1168 if(!Curl_conn_is_connected(check, FIRSTSOCKET)) { in ConnectionExists()
1447 FIRSTSOCKET)) { in ConnectionExists()
1517 conn->sock[FIRSTSOCKET] = CURL_SOCKET_BAD; /* no file descriptor */ in allocate_conn()
3593 conn->recv[FIRSTSOCKET] = Curl_conn_recv;
3594 conn->send[FIRSTSOCKET] = Curl_conn_send;
3888 result = Curl_conn_setup(data, conn, FIRSTSOCKET, conn->dns_entry,
/third_party/curl/lib/vssh/
Dwolfssh.c369 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_connect()
381 conn->recv[FIRSTSOCKET] = wscp_recv; in wssh_connect()
382 conn->send[FIRSTSOCKET] = wscp_send; in wssh_connect()
385 conn->recv[FIRSTSOCKET] = wsftp_recv; in wssh_connect()
386 conn->send[FIRSTSOCKET] = wsftp_send; in wssh_connect()
688 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in wssh_statemach_act()
793 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in wssh_statemach_act()
954 *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET); in wsftp_perform()
1025 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_block_statemach()
1145 sock[0] = conn->sock[FIRSTSOCKET]; in wssh_getsock()
[all …]
Dlibssh.c683 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in myssh_statemach_act()
1350 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in myssh_statemach_act()
1736 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in myssh_statemach_act()
1860 Curl_setup_transfer(data, -1, data->req.size, FALSE, FIRSTSOCKET); in myssh_statemach_act()
1904 Curl_setup_transfer(data, FIRSTSOCKET, bytecount, FALSE, -1); in myssh_statemach_act()
1968 fake_sclose(conn->sock[FIRSTSOCKET]); in myssh_statemach_act()
1969 conn->sock[FIRSTSOCKET] = CURL_SOCKET_BAD; in myssh_statemach_act()
2056 sock[0] = conn->sock[FIRSTSOCKET]; in myssh_getsock()
2059 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in myssh_getsock()
2062 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in myssh_getsock()
[all …]
Dlibssh2.c973 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ssh_statemach_act()
2191 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in ssh_statemach_act()
2603 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in ssh_statemach_act()
2749 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in ssh_statemach_act()
2820 Curl_setup_transfer(data, FIRSTSOCKET, bytecount, FALSE, -1); in ssh_statemach_act()
3061 sock[0] = conn->sock[FIRSTSOCKET]; in ssh_getsock()
3064 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in ssh_getsock()
3067 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in ssh_getsock()
3157 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ssh_block_statemach()
3275 sock = conn->sock[FIRSTSOCKET]; in ssh_connect()
[all …]
/third_party/curl/lib/vquic/
Dcurl_msh3.c733 if(cf->sockindex == FIRSTSOCKET) { in cf_msh3_active()
947 if(cf->sockindex == FIRSTSOCKET) in cf_msh3_close()

12