| /external/netperf/src/ |
| D | nettest_sctp.c | 379 int send_socket; in send_sctp_stream() local
457 send_socket = create_data_socket(local_res); in send_sctp_stream()
459 if (send_socket == INVALID_SOCKET){ in send_sctp_stream()
602 if (connect(send_socket, in send_sctp_stream()
609 sctp_enable_events(send_socket, SCTP_ASSOC_CHANGE_EV); in send_sctp_stream()
613 if (!set_nonblock(send_socket)) { in send_sctp_stream()
710 while ((len=sctp_sendmsg(send_socket, in send_sctp_stream()
777 get_sctp_info(send_socket, &sctp_mss); in send_sctp_stream()
780 shutdown(send_socket, SHUT_WR); in send_sctp_stream()
791 FD_SET(send_socket, &readfds); in send_sctp_stream()
[all …]
|
| D | nettest_bsd.c | 1755 SOCKET send_socket; in send_tcp_stream() local
1836 send_socket = create_data_socket(local_res); in send_tcp_stream()
1838 if (send_socket == INVALID_SOCKET){ in send_tcp_stream()
1984 if (connect(send_socket, in send_tcp_stream()
1998 win_kludge_socket = send_socket; in send_tcp_stream()
2076 if((len=send(send_socket, in send_tcp_stream()
2127 get_tcp_info(send_socket,&tcp_mss); in send_tcp_stream()
2130 if (shutdown(send_socket,SHUT_WR) == SOCKET_ERROR && !times_up) { in send_tcp_stream()
2140 recv(send_socket, send_ring->buffer_ptr, send_size, 0); in send_tcp_stream()
2153 close(send_socket); in send_tcp_stream()
[all …]
|
| D | nettest_xti.c | 516 SOCKET send_socket; in send_xti_tcp_stream() local
647 send_socket = create_xti_endpoint(loc_xti_device); in send_xti_tcp_stream()
649 if (send_socket == INVALID_SOCKET) { in send_xti_tcp_stream()
663 if (t_bind(send_socket, NULL, NULL) == SOCKET_ERROR) { in send_xti_tcp_stream()
826 if (t_connect(send_socket, in send_xti_tcp_stream()
914 if((len=t_snd(send_socket, in send_xti_tcp_stream()
926 t_look(send_socket)); in send_xti_tcp_stream()
980 get_xti_info(send_socket,info_struct); in send_xti_tcp_stream()
983 if (t_sndrel(send_socket) == -1) { in send_xti_tcp_stream()
998 t_rcvrel(send_socket); in send_xti_tcp_stream()
[all …]
|
| D | nettest_unix.c | 253 SOCKET send_socket; in send_stream_stream() local
307 send_socket = create_unix_socket(AF_UNIX, in send_stream_stream()
310 if (send_socket == INVALID_SOCKET){ in send_stream_stream()
426 if (connect(send_socket, in send_stream_stream()
494 if((len=send(send_socket, in send_stream_stream()
528 if (close(send_socket) == -1) { in send_stream_stream()
1073 SOCKET send_socket; in send_stream_rr() local
1145 send_socket = create_unix_socket(AF_UNIX, in send_stream_rr()
1148 if (send_socket == INVALID_SOCKET){ in send_stream_rr()
1230 if (connect(send_socket, in send_stream_rr()
[all …]
|
| D | nettest_sdp.c | 220 SOCKET send_socket; in send_sdp_stream() local
299 send_socket = create_data_socket(local_res); in send_sdp_stream()
301 if (send_socket == INVALID_SOCKET){ in send_sdp_stream()
447 if (connect(send_socket, in send_sdp_stream()
529 if((len=send(send_socket, in send_sdp_stream()
580 get_sdp_info(send_socket,&sdp_mss); in send_sdp_stream()
583 if (shutdown(send_socket,SHUT_WR) == SOCKET_ERROR) { in send_sdp_stream()
593 recv(send_socket, send_ring->buffer_ptr, send_size, 0); in send_sdp_stream()
606 close(send_socket); in send_sdp_stream()
2303 SOCKET send_socket; in send_sdp_rr() local
[all …]
|
| D | netlib.c | 782 int netperf_sendfile(SOCKET send_socket, struct ring_elt *send_ring) { in netperf_sendfile() argument
806 len=sendfile(send_socket, in netperf_sendfile()
818 len = sendfilev(send_socket, &sv, 1, &scratch_len); in netperf_sendfile()
822 send_socket, in netperf_sendfile()
831 send_socket, in netperf_sendfile()
837 len=sendfile(send_socket, in netperf_sendfile()
|
| D | netlib.h | 655 extern int netperf_sendfile(SOCKET send_socket, struct ring_elt *send_ring);
|
| D | nettest_omni.c | 2811 connect_data_socket(SOCKET send_socket, struct addrinfo *remote_res, int dont_give_up) in connect_data_socket() argument
2816 if ((ret = connect(send_socket, in connect_data_socket()
|
| /external/webrtc/webrtc/base/ |
| D | virtualsocket_unittest.cc | 657 AsyncSocket* send_socket = in BandwidthTest() local
661 ASSERT_EQ(0, send_socket->Bind(initial_addr)); in BandwidthTest()
663 EXPECT_EQ(send_socket->GetLocalAddress().family(), initial_addr.family()); in BandwidthTest()
665 ASSERT_EQ(0, send_socket->Connect(recv_socket->GetLocalAddress())); in BandwidthTest()
671 Sender sender(pthMain, send_socket, 80 * 1024); in BandwidthTest()
699 AsyncSocket* send_socket = in DelayTest() local
703 ASSERT_EQ(0, send_socket->Bind(initial_addr)); in DelayTest()
705 EXPECT_EQ(send_socket->GetLocalAddress().family(), initial_addr.family()); in DelayTest()
707 ASSERT_EQ(0, send_socket->Connect(recv_socket->GetLocalAddress())); in DelayTest()
712 Sender sender(pthMain, send_socket, 100 * 2 * 1024); in DelayTest()
|