Home
last modified time | relevance | path

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

12

/external/curl/lib/
Dcurl_rtmp.c217 r->m_sb.sb_socket = (int)conn->sock[FIRSTSOCKET]; in rtmp_connect()
241 conn->recv[FIRSTSOCKET] = rtmp_recv; in rtmp_connect()
242 conn->send[FIRSTSOCKET] = rtmp_send; in rtmp_connect()
256 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in rtmp_do()
259 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in rtmp_do()
Dopenldap.c234 rc = ldap_init_fd(conn->sock[FIRSTSOCKET], li->proto, hosturl, &li->ld); in ldap_connect()
246 result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, &li->ssldone); in ldap_connect()
268 CURLcode result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, in ldap_connecting()
280 li->recv = conn->recv[FIRSTSOCKET]; in ldap_connecting()
281 li->send = conn->send[FIRSTSOCKET]; in ldap_connecting()
354 conn->recv[FIRSTSOCKET] = ldap_recv; in ldap_connecting()
416 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in ldap_do()
714 return Curl_ssl_data_pending(conn, FIRSTSOCKET); in ldapsb_tls_ctrl()
727 ret = (li->recv)(conn, FIRSTSOCKET, buf, len, &err); in ldapsb_tls_read()
742 ret = (li->send)(conn, FIRSTSOCKET, buf, len, &err); in ldapsb_tls_write()
Ddict.c188 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in dict_do()
251 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); /* no upload */ in dict_do()
297 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in dict_do()
319 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in dict_do()
Dpingpong.c84 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()
211 result = Curl_write(conn, conn->sock[FIRSTSOCKET], s, write_len, in Curl_pp_vsendf()
465 socks[0] = conn->sock[FIRSTSOCKET]; in Curl_pp_getsock()
481 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in Curl_pp_flushsend()
Dmqtt.c112 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_send()
136 sock[0] = conn->sock[FIRSTSOCKET]; in mqtt_getsock()
137 return GETSOCK_READSOCK(FIRSTSOCKET); in mqtt_getsock()
179 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_verify_connack()
292 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_verify_suback()
424 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_read_publish()
539 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in mqtt_doing()
Dgopher.c82 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in gopher_do()
183 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in gopher_do()
Drtsp.c80 socks[0] = conn->sock[FIRSTSOCKET]; in rtsp_getsock_do()
139 sval = SOCKET_READABLE(check->sock[FIRSTSOCKET], 0); in rtsp_connisdead()
311 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, -1); in rtsp_do()
568 &data->info.request_size, 0, FIRSTSOCKET); in rtsp_do()
574 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, putsize?FIRSTSOCKET:-1); in rtsp_do()
Dtelnet.c311 bytes_written = swrite(conn->sock[FIRSTSOCKET], buf, 3); in send_negotiation()
896 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption()
908 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption()
936 bytes_written = swrite(conn->sock[FIRSTSOCKET], temp, len); in suboption()
991 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer, 3); in sendsuboption()
1000 bytes_written = swrite(conn->sock[FIRSTSOCKET], tn->subbuffer + 7, 2); in sendsuboption()
1210 pfd[0].fd = conn->sock[FIRSTSOCKET]; in send_telnet_data()
1219 result = Curl_write(conn, conn->sock[FIRSTSOCKET], in send_telnet_data()
1257 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in telnet_do()
Dhttp.c1399 result = Curl_proxy_connect(conn, FIRSTSOCKET); in Curl_http_connect()
1441 socks[0] = conn->sock[FIRSTSOCKET]; in http_getsock_do()
1477 0, FIRSTSOCKET); in add_haproxy_protocol_header()
1497 result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, done); in https_connecting()
2699 FIRSTSOCKET); in Curl_http()
2704 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, in Curl_http()
2705 postsize?FIRSTSOCKET:-1); in Curl_http()
2720 FIRSTSOCKET); in Curl_http()
2725 Curl_setup_transfer(data, FIRSTSOCKET, -1, TRUE, -1); in Curl_http()
2790 FIRSTSOCKET); in Curl_http()
[all …]
Dconnect.c584 if(sockindex == FIRSTSOCKET) { in trynextip()
805 if(sockindex == FIRSTSOCKET) in post_SOCKS()
828 DEBUGASSERT(sockindex >= FIRSTSOCKET && sockindex <= SECONDARYSOCKET); in Curl_is_connected()
1415 return c->sock[FIRSTSOCKET]; in Curl_getconnectinfo()
1426 if(conn->ssl[FIRSTSOCKET].use) { in Curl_connalive()
1433 else if(conn->sock[FIRSTSOCKET] == CURL_SOCKET_BAD) in Curl_connalive()
1438 if(recv((RECV_TYPE_ARG1)conn->sock[FIRSTSOCKET], (RECV_TYPE_ARG2)&buf, in Curl_connalive()
Dpop3.c362 CURLcode result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, in pop3_perform_upgrade_tls()
727 if(data->set.use_ssl && !conn->ssl[FIRSTSOCKET].use) { in pop3_state_capa_resp()
912 Curl_setup_transfer(data, FIRSTSOCKET, -1, FALSE, -1); in pop3_state_command_resp()
942 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in pop3_statemach_act()
1020 result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, &pop3c->ssldone); in pop3_multi_statemach()
1179 *connected = conn->bits.tcpconnect[FIRSTSOCKET]; in pop3_perform()
Durl.h90 !conn->bits.proxy_ssl_connected[FIRSTSOCKET])
Durl.c716 Curl_ssl_close(conn, FIRSTSOCKET); in conn_shutdown()
722 if(CURL_SOCKET_BAD != conn->sock[FIRSTSOCKET]) in conn_shutdown()
723 Curl_closesocket(conn, conn->sock[FIRSTSOCKET]); in conn_shutdown()
977 dead = SocketIsDead(conn->sock[FIRSTSOCKET]); in extract_if_dead()
1168 if(check->sock[FIRSTSOCKET] == CURL_SOCKET_BAD) { in ConnectionExists()
1234 if(check->proxy_ssl[FIRSTSOCKET].state != ssl_connection_complete) in ConnectionExists()
1241 if(check->ssl[FIRSTSOCKET].state != ssl_connection_complete) in ConnectionExists()
1321 if(check->ssl[FIRSTSOCKET].state != ssl_connection_complete) { in ConnectionExists()
1629 conn->sock[FIRSTSOCKET] = CURL_SOCKET_BAD; /* no file descriptor */ in allocate_conn()
3571 conn->recv[FIRSTSOCKET] = Curl_recv_plain;
[all …]
Dhttp2.c102 sock[0] = conn->sock[FIRSTSOCKET]; in http2_perform_getsock()
106 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in http2_perform_getsock()
111 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in http2_perform_getsock()
173 sval = SOCKET_READABLE(conn->sock[FIRSTSOCKET], 0); in http2_connisdead()
195 conn, FIRSTSOCKET, httpc->inbuf, H2_BUFSIZE, &result); in http2_connisdead()
360 written = ((Curl_send*)c->send_underlying)(conn, FIRSTSOCKET, in send_callback()
1697 conn, FIRSTSOCKET, httpc->inbuf, H2_BUFSIZE, err); in http2_recv()
2218 httpc->recv_underlying = conn->recv[FIRSTSOCKET]; in Curl_http2_switched()
2219 httpc->send_underlying = conn->send[FIRSTSOCKET]; in Curl_http2_switched()
2220 conn->recv[FIRSTSOCKET] = http2_recv; in Curl_http2_switched()
[all …]
Dsmtp.c387 CURLcode result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, in smtp_perform_upgrade_tls()
849 if(data->set.use_ssl <= CURLUSESSL_TRY || conn->ssl[FIRSTSOCKET].use) in smtp_state_ehlo_resp()
914 if(data->set.use_ssl && !conn->ssl[FIRSTSOCKET].use) { in smtp_state_ehlo_resp()
1132 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in smtp_state_data_resp()
1163 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in smtp_statemach_act()
1252 result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, &smtpc->ssldone); in smtp_multi_statemach()
1487 *connected = conn->bits.tcpconnect[FIRSTSOCKET]; in smtp_perform()
Dkrb5.c92 result = Curl_write(conn, conn->sock[FIRSTSOCKET], sptr, write_len, in ftpsend()
229 if(getsockname(conn->sock[FIRSTSOCKET], in krb5_auth()
870 conn->recv[FIRSTSOCKET] = sec_recv; in choose_mech()
871 conn->send[FIRSTSOCKET] = sec_send; in choose_mech()
Dsmb.c297 result = Curl_read(conn, FIRSTSOCKET, buf + smbc->got, len, &bytes_read); in smb_recv_message()
369 result = Curl_write(conn, FIRSTSOCKET, conn->data->state.ulbuf, in smb_send()
394 result = Curl_write(conn, FIRSTSOCKET, in smb_flush()
654 result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, &ssl_done); in smb_connection_state()
942 socks[0] = conn->sock[FIRSTSOCKET]; in smb_getsock()
Dimap.c467 CURLcode result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, in imap_perform_upgrade_tls()
923 if(data->set.use_ssl && !conn->ssl[FIRSTSOCKET].use) { in imap_state_capability_resp()
1184 Curl_setup_transfer(data, FIRSTSOCKET, size, FALSE, -1); in imap_state_fetch_resp()
1234 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in imap_state_append_resp()
1264 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in imap_statemach_act()
1357 result = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, &imapc->ssldone); in imap_multi_statemach()
1575 *connected = conn->bits.tcpconnect[FIRSTSOCKET]; in imap_perform()
Dftp.c361 curl_socket_t ctrl_sock = conn->sock[FIRSTSOCKET]; in ReceivedServerConnect()
611 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in Curl_GetFTPResponse()
664 else if(!Curl_conn_data_pending(conn, FIRSTSOCKET)) { in Curl_GetFTPResponse()
814 socks[0] = conn->sock[FIRSTSOCKET]; in ftp_domore_getsock()
1042 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port()
1128 if(getsockname(conn->sock[FIRSTSOCKET], sa, &sslen)) { in ftp_state_use_port()
2616 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ftp_statemach_act()
2702 result = Curl_ssl_connect(conn, FIRSTSOCKET); in ftp_statemach_act()
2767 result = Curl_ssl_shutdown(conn, FIRSTSOCKET); in ftp_statemach_act()
3105 result = Curl_ssl_connect(conn, FIRSTSOCKET); in ftp_connect()
Dmulti.c916 return Curl_SOCKS_getsock(conn, sock, FIRSTSOCKET); in waitconnect_getsock()
937 sock[0] = conn->sock[FIRSTSOCKET]; in waitproxyconnect_getsock()
971 socks[0] = conn->sock[FIRSTSOCKET]; in protocol_getsock()
1640 if(conn->bits.tcpconnect[FIRSTSOCKET] && conn->bits.protoconnstart) {
1655 result = Curl_proxy_connect(conn, FIRSTSOCKET);
1956 data->conn->bits.proxy_ssl_connected[FIRSTSOCKET]) &&
1972 result = Curl_is_connected(data->conn, FIRSTSOCKET, &connected);
1978 !data->conn->bits.proxy_ssl_connected[FIRSTSOCKET]) ||
/external/curl/lib/vssh/
Dwolfssh.c355 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_connect()
367 conn->recv[FIRSTSOCKET] = wscp_recv; in wssh_connect()
368 conn->send[FIRSTSOCKET] = wscp_send; in wssh_connect()
371 conn->recv[FIRSTSOCKET] = wsftp_recv; in wssh_connect()
372 conn->send[FIRSTSOCKET] = wsftp_send; in wssh_connect()
673 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in wssh_statemach_act()
778 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in wssh_statemach_act()
937 *connected = conn->bits.tcpconnect[FIRSTSOCKET]; in wsftp_perform()
1008 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in wssh_block_statemach()
1128 sock[0] = conn->sock[FIRSTSOCKET]; in wssh_perform_getsock()
[all …]
Dlibssh.c669 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in myssh_statemach_act()
1313 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in myssh_statemach_act()
1720 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in myssh_statemach_act()
1842 Curl_setup_transfer(data, -1, data->req.size, FALSE, FIRSTSOCKET); in myssh_statemach_act()
1885 Curl_setup_transfer(data, FIRSTSOCKET, bytecount, FALSE, -1); in myssh_statemach_act()
2028 sock[0] = conn->sock[FIRSTSOCKET]; in myssh_perform_getsock()
2031 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in myssh_perform_getsock()
2034 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in myssh_perform_getsock()
2116 curl_socket_t fd_read = conn->sock[FIRSTSOCKET]; in myssh_block_statemach()
2152 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in myssh_connect()
[all …]
Dlibssh2.c803 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ssh_statemach_act()
2012 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in ssh_statemach_act()
2429 Curl_setup_transfer(data, FIRSTSOCKET, data->req.size, FALSE, -1); in ssh_statemach_act()
2575 Curl_setup_transfer(data, -1, -1, FALSE, FIRSTSOCKET); in ssh_statemach_act()
2646 Curl_setup_transfer(data, FIRSTSOCKET, bytecount, FALSE, -1); in ssh_statemach_act()
2893 sock[0] = conn->sock[FIRSTSOCKET]; in ssh_perform_getsock()
2896 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in ssh_perform_getsock()
2899 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in ssh_perform_getsock()
3007 curl_socket_t sock = conn->sock[FIRSTSOCKET]; in ssh_block_statemach()
3108 sock = conn->sock[FIRSTSOCKET]; in ssh_connect()
[all …]
/external/curl/lib/vquic/
Dquiche.c73 socks[0] = conn->sock[FIRSTSOCKET]; in quiche_getsock()
77 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in quiche_getsock()
81 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in quiche_getsock()
256 conn->ssl[FIRSTSOCKET].state = ssl_connection_complete; in Curl_quic_connect()
Dngtcp2.c862 socks[0] = conn->sock[FIRSTSOCKET]; in ng_getsock()
866 bitmap |= GETSOCK_READSOCK(FIRSTSOCKET); in ng_getsock()
870 bitmap |= GETSOCK_WRITESOCK(FIRSTSOCKET); in ng_getsock()
1677 conn->recv[FIRSTSOCKET] = ngh3_stream_recv; in ng_has_connected()
1678 conn->send[FIRSTSOCKET] = ngh3_stream_send; in ng_has_connected()

12