Home
last modified time | relevance | path

Searched refs:recv_ring (Results 1 – 7 of 7) sorted by relevance

/external/netperf/src/
Dnettest_sctp.c1061 struct ring_elt *recv_ring; in recv_sctp_stream() local
1193 recv_ring = allocate_buffer_ring(recv_width, in recv_sctp_stream()
1307 message_int_ptr = (int *)recv_ring->buffer_ptr; in recv_sctp_stream()
1322 recv_ring->buffer_ptr, recv_size, in recv_sctp_stream()
1353 if (sctp_process_event(s_data, recv_ring->buffer_ptr) == SCTP_CLOSE) in recv_sctp_stream()
1363 recv_ring = recv_ring->next; in recv_sctp_stream()
1370 message_int_ptr = (int *)(recv_ring->buffer_ptr); in recv_sctp_stream()
2218 struct ring_elt *recv_ring; in recv_sctp_stream_1toMany() local
2349 recv_ring = allocate_buffer_ring(recv_width, in recv_sctp_stream_1toMany()
2442 message_int_ptr = (int *)recv_ring->buffer_ptr; in recv_sctp_stream_1toMany()
[all …]
Dnettest_unix.c715 struct ring_elt *recv_ring; in recv_stream_stream() local
856 recv_ring = allocate_buffer_ring(recv_width, in recv_stream_stream()
940 message_int_ptr = (int *)recv_ring->buffer_ptr; in recv_stream_stream()
952 while ((len = recv(s_data, recv_ring->buffer_ptr, recv_size, 0)) != 0) { in recv_stream_stream()
962 recv_ring = recv_ring->next; in recv_stream_stream()
965 message_int_ptr = (int *)(recv_ring->buffer_ptr); in recv_stream_stream()
1078 struct ring_elt *recv_ring; in send_stream_rr() local
1139 recv_ring = allocate_buffer_ring(recv_width, in send_stream_rr()
1294 temp_message_ptr = recv_ring->buffer_ptr; in send_stream_rr()
1311 recv_ring = recv_ring->next; in send_stream_rr()
[all …]
Dnettest_sdp.c915 struct ring_elt *recv_ring; in send_sdp_maerts() local
971 recv_ring = NULL; in send_sdp_maerts()
1035 if (recv_ring == NULL) { in send_sdp_maerts()
1040 recv_ring = allocate_buffer_ring(recv_width, in send_sdp_maerts()
1223 recv_ring->buffer_ptr, in send_sdp_maerts()
1236 access_buffer(recv_ring->buffer_ptr, in send_sdp_maerts()
1256 recv_ring = recv_ring->next; in send_sdp_maerts()
1579 struct ring_elt *recv_ring; in recv_sdp_stream() local
1712 recv_ring = allocate_buffer_ring(recv_width, in recv_sdp_stream()
1814 while ((len = recv(s_data, recv_ring->buffer_ptr, recv_size, 0)) != 0) { in recv_sdp_stream()
[all …]
Dnettest_xti.c1255 struct ring_elt *recv_ring; in recv_xti_tcp_stream() local
1430 recv_ring = allocate_buffer_ring(recv_width, in recv_xti_tcp_stream()
1549 access_buffer(recv_ring->buffer_ptr, in recv_xti_tcp_stream()
1560 recv_ring->buffer_ptr, in recv_xti_tcp_stream()
1567 recv_ring = recv_ring->next; in recv_xti_tcp_stream()
1571 access_buffer(recv_ring->buffer_ptr, in recv_xti_tcp_stream()
1728 struct ring_elt *recv_ring; in send_xti_tcp_rr() local
1835 recv_ring = NULL; in send_xti_tcp_rr()
1872 if (recv_ring == NULL) { in send_xti_tcp_rr()
1873 recv_ring = allocate_buffer_ring(recv_width, in send_xti_tcp_rr()
[all …]
Dnettest_bsd.c2470 struct ring_elt *recv_ring; in send_tcp_maerts() local
2533 recv_ring = NULL; in send_tcp_maerts()
2594 if (recv_ring == NULL) { in send_tcp_maerts()
2599 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_maerts()
2792 recv_ring->buffer_ptr, in send_tcp_maerts()
2805 access_buffer(recv_ring->buffer_ptr, in send_tcp_maerts()
2825 recv_ring = recv_ring->next; in send_tcp_maerts()
4895 struct ring_elt *recv_ring; in recv_tcp_stream() local
5025 recv_ring = allocate_buffer_ring(recv_width, in recv_tcp_stream()
5143 while (!times_up && ((len = recv(s_data, recv_ring->buffer_ptr, recv_size, 0)) != 0)) { in recv_tcp_stream()
[all …]
Dnettest_omni.c2968 recv_data_no_copy(SOCKET data_socket, struct ring_elt *recv_ring, uint32_t bytes_to_recv, struct so… in recv_data_no_copy() argument
3020 recv_ring, in recv_data_no_copy()
3137 recv_data(SOCKET data_socket, struct ring_elt *recv_ring, uint32_t bytes_to_recv, struct sockaddr *… in recv_data() argument
3148 …ret = recv_data_no_copy(data_socket, recv_ring, bytes_to_recv, source, sourcelen, flags, num_recei… in recv_data()
3160 temp_message_ptr = recv_ring->buffer_ptr; in recv_data()
3167 recv_ring, in recv_data()
3711 struct ring_elt *recv_ring; in send_omni_inner() local
3789 recv_ring = NULL; in send_omni_inner()
3891 if (NULL == recv_ring) { in send_omni_inner()
3913 recv_ring = allocate_buffer_ring(recv_width, in send_omni_inner()
[all …]
Dnettest_dlpi.c938 struct ring_elt *recv_ring; in recv_dlpi_co_stream() local