Lines Matching refs:recv_ring
716 struct ring_elt *recv_ring; in recv_stream_stream() local
857 recv_ring = allocate_buffer_ring(recv_width, in recv_stream_stream()
941 message_int_ptr = (int *)recv_ring->buffer_ptr; in recv_stream_stream()
953 while ((len = recv(s_data, recv_ring->buffer_ptr, recv_size, 0)) != 0) { in recv_stream_stream()
963 recv_ring = recv_ring->next; in recv_stream_stream()
966 message_int_ptr = (int *)(recv_ring->buffer_ptr); in recv_stream_stream()
1079 struct ring_elt *recv_ring; in send_stream_rr() local
1140 recv_ring = allocate_buffer_ring(recv_width, in send_stream_rr()
1295 temp_message_ptr = recv_ring->buffer_ptr; in send_stream_rr()
1312 recv_ring = recv_ring->next; in send_stream_rr()
1929 struct ring_elt *recv_ring; in recv_dg_stream() local
1992 recv_ring = allocate_buffer_ring(recv_width, in recv_dg_stream()
2104 recv_ring->buffer_ptr, in recv_dg_stream()
2115 recv_ring = recv_ring->next; in recv_dg_stream()
2738 struct ring_elt *recv_ring; in recv_dg_rr() local
2806 recv_ring = allocate_buffer_ring(recv_width, in recv_dg_rr()
2923 recv_ring->buffer_ptr, in recv_dg_rr()
2927 recv_ring->buffer_ptr, in recv_dg_rr()
2943 recv_ring = recv_ring->next; in recv_dg_rr()
3027 struct ring_elt *recv_ring; in recv_stream_rr() local
3104 recv_ring = allocate_buffer_ring(recv_width, in recv_stream_rr()
3232 temp_message_ptr = recv_ring->buffer_ptr; in recv_stream_rr()
3265 recv_ring = recv_ring->next; in recv_stream_rr()