Lines Matching refs:recv_ring
2470 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()
5157 access_buffer(recv_ring->buffer_ptr, in recv_tcp_stream()
5165 recv_ring = recv_ring->next; in recv_tcp_stream()
5666 struct ring_elt *recv_ring; in send_tcp_rr() local
5741 recv_ring = NULL; in send_tcp_rr()
5787 if (recv_ring == NULL) { in send_tcp_rr()
5788 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_rr()
6031 temp_message_ptr = recv_ring->buffer_ptr; in send_tcp_rr()
6048 recv_ring = recv_ring->next; in send_tcp_rr()
7034 struct ring_elt *recv_ring; in recv_udp_stream() local
7104 recv_ring = allocate_buffer_ring(recv_width, in recv_udp_stream()
7238 len = recvfrom(s_data, recv_ring->buffer_ptr, in recv_udp_stream()
7249 recv_ring = recv_ring->next; in recv_udp_stream()
7271 recv_ring->buffer_ptr, in recv_udp_stream()
7276 recv_ring->buffer_ptr, in recv_udp_stream()
7290 recv_ring = recv_ring->next; in recv_udp_stream()
7406 struct ring_elt *recv_ring; in send_udp_rr() local
7461 recv_ring = NULL; in send_udp_rr()
7495 if (recv_ring == NULL) { in send_udp_rr()
7496 recv_ring = allocate_buffer_ring(recv_width, in send_udp_rr()
7713 recv_ring->buffer_ptr, in send_udp_rr()
7724 recv_ring = recv_ring->next; in send_udp_rr()
8045 struct ring_elt *recv_ring; in recv_udp_rr() local
8119 recv_ring = allocate_buffer_ring(recv_width, in recv_udp_rr()
8257 recv_ring->buffer_ptr, in recv_udp_rr()
8271 recv_ring = recv_ring->next; in recv_udp_rr()
8359 struct ring_elt *recv_ring; in recv_tcp_rr() local
8441 recv_ring = allocate_buffer_ring(recv_width, in recv_tcp_rr()
8607 temp_message_ptr = recv_ring->buffer_ptr; in recv_tcp_rr()
8638 recv_ring = recv_ring->next; in recv_tcp_rr()
8834 struct ring_elt *recv_ring; in send_tcp_conn_rr() local
8904 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_conn_rr()
9154 temp_message_ptr = recv_ring->buffer_ptr; in send_tcp_conn_rr()
9217 recv_ring = recv_ring->next; in send_tcp_conn_rr()
9932 struct ring_elt *recv_ring; in send_tcp_tran_rr() local
10015 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_tran_rr()
10267 temp_message_ptr = recv_ring->buffer_ptr; in send_tcp_tran_rr()
10285 recv_ring = recv_ring->next; in send_tcp_tran_rr()
11007 struct ring_elt *recv_ring; in send_tcp_nbrr() local
11064 recv_ring = NULL; in send_tcp_nbrr()
11101 if (recv_ring == NULL) { in send_tcp_nbrr()
11102 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_nbrr()
11298 temp_message_ptr = recv_ring->buffer_ptr; in send_tcp_nbrr()
11324 recv_ring = recv_ring->next; in send_tcp_nbrr()
11608 struct ring_elt *recv_ring; in recv_tcp_nbrr() local
11689 recv_ring = allocate_buffer_ring(recv_width, in recv_tcp_nbrr()
11876 temp_message_ptr = recv_ring->buffer_ptr; in recv_tcp_nbrr()
11911 recv_ring = recv_ring->next; in recv_tcp_nbrr()