/third_party/curl/lib/ |
D | openldap.c | 238 rc = ldap_init_fd(conn->sock[FIRSTSOCKET], li->proto, hosturl, &li->ld); in oldap_connect() 251 FIRSTSOCKET, &li->ssldone); in oldap_connect() 274 FIRSTSOCKET, in oldap_connecting() 286 li->recv = conn->recv[FIRSTSOCKET]; in oldap_connecting() 287 li->send = conn->send[FIRSTSOCKET]; in oldap_connecting() 360 conn->recv[FIRSTSOCKET] = oldap_recv; in oldap_connecting() 376 if(conn->ssl[FIRSTSOCKET].use) { in oldap_disconnect() 431 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in oldap_do() 730 return Curl_ssl_data_pending(data->conn, FIRSTSOCKET); in ldapsb_tls_ctrl() 746 ret = (li->recv)(data, FIRSTSOCKET, buf, len, &err); in ldapsb_tls_read() [all …]
|
D | curl_rtmp.c | 227 r->m_sb.sb_socket = (int)conn->sock[FIRSTSOCKET]; in rtmp_connect() 251 conn->recv[FIRSTSOCKET] = rtmp_recv; in rtmp_connect() 252 conn->send[FIRSTSOCKET] = rtmp_send; in rtmp_connect() 266 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in rtmp_do() 269 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in rtmp_do()
|
D | dict.c | 187 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in dict_do() 250 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); /* no upload */ in dict_do() 296 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in dict_do() 318 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in dict_do()
|
D | pingpong.c | 85 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in Curl_pp_statemach() 104 if(Curl_ssl_data_pending(conn, FIRSTSOCKET)) in Curl_pp_statemach() 109 else if(!pp->sendleft && Curl_ssl_data_pending(conn, FIRSTSOCKET)) in Curl_pp_statemach() 210 result = Curl_write(data, conn->sock[FIRSTSOCKET], s, write_len, in Curl_pp_vsendf() 462 socks[0] = conn->sock[FIRSTSOCKET]; in Curl_pp_getsock() 479 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in Curl_pp_flushsend()
|
D | gopher.c | 118 CURLcode result = Curl_ssl_connect(data, conn, FIRSTSOCKET); in gopher_connecting() 130 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in gopher_do() 234 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in gopher_do()
|
D | mqtt.c | 117 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_send() 146 sock[0] = conn->sock[FIRSTSOCKET]; in mqtt_getsock() 147 return GETSOCK_READSOCK(FIRSTSOCKET); in mqtt_getsock() 355 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_verify_connack() 445 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_verify_suback() 585 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_read_publish() 702 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_doing()
|
D | rtsp.c | 85 socks[0] = conn->sock[FIRSTSOCKET]; in rtsp_getsock_do() 147 sval = SOCKET_READABLE(check->sock[FIRSTSOCKET], 0); in rtsp_connisdead() 321 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, -1); in rtsp_do() 579 &data->info.request_size, 0, FIRSTSOCKET); in rtsp_do() 585 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, putsize?FIRSTSOCKET:-1); in rtsp_do()
|
D | telnet.c | 311 bytes_written = swrite(conn->sock[FIRSTSOCKET], buf, 3); in send_negotiation() 910 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 922 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 955 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption() 1009 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer, 3); in sendsuboption() 1018 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer + 7, 2); in sendsuboption() 1228 pfd[0].fd = conn->sock[FIRSTSOCKET]; in send_telnet_data() 1237 result = Curl_write(data, conn->sock[FIRSTSOCKET], in send_telnet_data() 1272 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in telnet_do()
|
D | pop3.c | 374 Curl_ssl_connect_nonblocking(data, conn, FALSE, FIRSTSOCKET, in pop3_perform_upgrade_tls() 749 if(!data->set.use_ssl || conn->ssl[FIRSTSOCKET].use) in pop3_state_capa_resp() 923 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in pop3_state_command_resp() 954 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in pop3_statemachine() 1035 FIRSTSOCKET, &pop3c->ssldone); in pop3_multi_statemach() 1191 *connected = conn->bits.tcpconnect[FIRSTSOCKET]; in pop3_perform()
|
D | url.h | 74 !conn->bits.proxy_ssl_connected[FIRSTSOCKET])
|
D | http.c | 1504 result = Curl_proxy_connect(data, FIRSTSOCKET); in Curl_http_connect() 1548 socks[0] = conn->sock[FIRSTSOCKET]; in http_getsock_do() 1583 0, FIRSTSOCKET); in add_haproxy_protocol_header() 1603 result = Curl_ssl_connect_nonblocking(data, conn, FALSE, FIRSTSOCKET, done); in https_connecting() 2431 FIRSTSOCKET); in Curl_http_bodysend() 2436 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, in Curl_http_bodysend() 2437 http->postsize?FIRSTSOCKET:-1); in Curl_http_bodysend() 2452 FIRSTSOCKET); in Curl_http_bodysend() 2457 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, -1); in Curl_http_bodysend() 2522 FIRSTSOCKET); in Curl_http_bodysend() [all …]
|
D | http2.c | 104 sock[0] = conn->sock[FIRSTSOCKET]; in http2_getsock() 109 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in http2_getsock() 114 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in http2_getsock() 174 sval = SOCKET_READABLE(conn->sock[FIRSTSOCKET], 0); in http2_connisdead() 196 data, FIRSTSOCKET, httpc->inbuf, H2_BUFSIZE, &result); in http2_connisdead() 385 written = ((Curl_send*)c->send_underlying)(data, FIRSTSOCKET, in send_callback() 1740 data, FIRSTSOCKET, httpc->inbuf, H2_BUFSIZE, err); in http2_recv() 2272 httpc->recv_underlying = conn->recv[FIRSTSOCKET]; in Curl_http2_switched() 2273 httpc->send_underlying = conn->send[FIRSTSOCKET]; in Curl_http2_switched() 2274 conn->recv[FIRSTSOCKET] = http2_recv; in Curl_http2_switched() [all …]
|
D | url.c | 747 Curl_ssl_close(data, conn, FIRSTSOCKET); in conn_shutdown() 753 if(CURL_SOCKET_BAD != conn->sock[FIRSTSOCKET]) in conn_shutdown() 754 Curl_closesocket(data, conn, conn->sock[FIRSTSOCKET]); in conn_shutdown() 1008 dead = SocketIsDead(conn->sock[FIRSTSOCKET]); in extract_if_dead() 1211 if(check->sock[FIRSTSOCKET] == CURL_SOCKET_BAD) { in ConnectionExists() 1277 if(check->proxy_ssl[FIRSTSOCKET].state != ssl_connection_complete) in ConnectionExists() 1284 if(check->ssl[FIRSTSOCKET].state != ssl_connection_complete) in ConnectionExists() 1398 if(check->ssl[FIRSTSOCKET].state != ssl_connection_complete) { in ConnectionExists() 1711 conn->sock[FIRSTSOCKET] = CURL_SOCKET_BAD; /* no file descriptor */ in allocate_conn() 3560 Curl_conninfo_local(data, conn->sock[FIRSTSOCKET], [all …]
|
D | smtp.c | 401 FIRSTSOCKET, in smtp_perform_upgrade_tls() 869 if(data->set.use_ssl <= CURLUSESSL_TRY || conn->ssl[FIRSTSOCKET].use) in smtp_state_ehlo_resp() 934 if(data->set.use_ssl && !conn->ssl[FIRSTSOCKET].use) { in smtp_state_ehlo_resp() 1145 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in smtp_state_data_resp() 1177 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in smtp_statemachine() 1267 FIRSTSOCKET, &smtpc->ssldone); in smtp_multi_statemach() 1500 *connected = conn->bits.tcpconnect[FIRSTSOCKET]; in smtp_perform()
|
D | connect.c | 588 if(sockindex == FIRSTSOCKET) { in trynextip() 841 if(sockindex == FIRSTSOCKET) in post_SOCKS() 864 DEBUGASSERT(sockindex >= FIRSTSOCKET && sockindex <= SECONDARYSOCKET); in Curl_is_connected() 1483 return c->sock[FIRSTSOCKET]; in Curl_getconnectinfo() 1494 if(conn->ssl[FIRSTSOCKET].use) { in Curl_connalive() 1501 else if(conn->sock[FIRSTSOCKET] == CURL_SOCKET_BAD) in Curl_connalive() 1506 if(recv((RECV_TYPE_ARG1)conn->sock[FIRSTSOCKET], (RECV_TYPE_ARG2)&buf, in Curl_connalive()
|
D | smb.c | 308 result = Curl_read(data, FIRSTSOCKET, buf + smbc->got, len, &bytes_read); in smb_recv_message() 382 result = Curl_write(data, FIRSTSOCKET, data->state.ulbuf, in smb_send() 408 result = Curl_write(data, FIRSTSOCKET, in smb_flush() 672 FIRSTSOCKET, &ssl_done); in smb_connection_state() 957 socks[0] = conn->sock[FIRSTSOCKET]; in smb_getsock()
|
D | krb5.c | 93 result = Curl_write(data, conn->sock[FIRSTSOCKET], sptr, write_len, in ftpsend() 215 if(getsockname(conn->sock[FIRSTSOCKET], in krb5_auth() 864 conn->recv[FIRSTSOCKET] = sec_recv; in choose_mech() 865 conn->send[FIRSTSOCKET] = sec_send; in choose_mech()
|
D | imap.c | 479 FIRSTSOCKET, &imapc->ssldone); in imap_perform_upgrade_tls() 938 else if(data->set.use_ssl && !conn->ssl[FIRSTSOCKET].use) { in imap_state_capability_resp() 1198 Curl_setup_transfer(data, FIRSTSOCKET, size, FALSE, -1); in imap_state_fetch_resp() 1246 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in imap_state_append_resp() 1277 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in imap_statemachine() 1373 FIRSTSOCKET, &imapc->ssldone); in imap_multi_statemach() 1590 *connected = conn->bits.tcpconnect[FIRSTSOCKET]; in imap_perform()
|
D | ftp.c | 371 curl_socket_t ctrl_sock = conn->sock[FIRSTSOCKET]; in ReceivedServerConnect() 623 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in Curl_GetFTPResponse() 675 else if(!Curl_conn_data_pending(conn, FIRSTSOCKET)) { in Curl_GetFTPResponse() 832 socks[0] = conn->sock[FIRSTSOCKET]; in ftp_domore_getsock() 1060 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port() 1146 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port() 1977 Curl_conninfo_remote(data, conn, conn->sock[FIRSTSOCKET]); in ftp_state_pasv_resp() 2666 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ftp_statemachine() 2758 result = Curl_ssl_connect(data, conn, FIRSTSOCKET); in ftp_statemachine() 2824 result = Curl_ssl_shutdown(data, conn, FIRSTSOCKET); in ftp_statemachine() [all …]
|
/third_party/curl/lib/vssh/ |
D | wolfssh.c | 366 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_connect() 378 conn->recv[FIRSTSOCKET] = wscp_recv; in wssh_connect() 379 conn->send[FIRSTSOCKET] = wscp_send; in wssh_connect() 382 conn->recv[FIRSTSOCKET] = wsftp_recv; in wssh_connect() 383 conn->send[FIRSTSOCKET] = wsftp_send; in wssh_connect() 684 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in wssh_statemach_act() 789 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in wssh_statemach_act() 950 *connected = conn->bits.tcpconnect[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() [all …]
|
D | libssh.c | 674 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in myssh_statemach_act() 1332 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in myssh_statemach_act() 1738 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in myssh_statemach_act() 1862 Curl_setup_transfer(data, -1, data->req.size, FALSE, FIRSTSOCKET); in myssh_statemach_act() 1906 Curl_setup_transfer(data, FIRSTSOCKET, bytecount, FALSE, -1); in myssh_statemach_act() 2051 sock[0] = conn->sock[FIRSTSOCKET]; in myssh_getsock() 2054 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in myssh_getsock() 2057 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in myssh_getsock() 2130 curl_socket_t fd_read = conn->sock[FIRSTSOCKET]; in myssh_block_statemach() 2169 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in myssh_connect() [all …]
|
D | libssh2.c | 800 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ssh_statemach_act() 2007 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in ssh_statemach_act() 2418 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in ssh_statemach_act() 2564 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in ssh_statemach_act() 2635 Curl_setup_transfer(data, FIRSTSOCKET, bytecount, FALSE, -1); in ssh_statemach_act() 2879 sock[0] = conn->sock[FIRSTSOCKET]; in ssh_getsock() 2882 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in ssh_getsock() 2885 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in ssh_getsock() 2975 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ssh_block_statemach() 3093 sock = conn->sock[FIRSTSOCKET]; in ssh_connect() [all …]
|
/third_party/curl/lib/vquic/ |
D | quiche.c | 74 socks[0] = conn->sock[FIRSTSOCKET]; in quiche_getsock() 78 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in quiche_getsock() 82 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in quiche_getsock() 267 conn->ssl[FIRSTSOCKET].state = ssl_connection_complete; in Curl_quic_connect()
|
/third_party/curl/lib/vtls/ |
D | vtls.c | 634 Curl_ssl->associate_connection(data, conn, FIRSTSOCKET); in Curl_ssl_associate_conn() 644 Curl_ssl->disassociate_connection(data, FIRSTSOCKET); in Curl_ssl_detach_conn() 668 struct ssl_connect_data *connssl = &conn->ssl[FIRSTSOCKET]; in Curl_ssl_getsock() 672 socks[0] = conn->sock[FIRSTSOCKET]; in Curl_ssl_getsock() 677 socks[0] = conn->sock[FIRSTSOCKET]; in Curl_ssl_getsock()
|
D | rustls.c | 492 struct ssl_connect_data *const connssl = &conn->ssl[FIRSTSOCKET]; in cr_getsock() 493 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in cr_getsock()
|