Lines Matching refs:recv_ring
1992 struct ring_elt *recv_ring; in send_tcp_maerts() local
2048 recv_ring = NULL; in send_tcp_maerts()
2109 if (recv_ring == NULL) { in send_tcp_maerts()
2114 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_maerts()
2297 recv_ring->buffer_ptr, in send_tcp_maerts()
2310 access_buffer(recv_ring->buffer_ptr, in send_tcp_maerts()
2330 recv_ring = recv_ring->next; in send_tcp_maerts()
4239 struct ring_elt *recv_ring; in recv_tcp_stream() local
4369 recv_ring = allocate_buffer_ring(recv_width, in recv_tcp_stream()
4472 while ((len = recv(s_data, recv_ring->buffer_ptr, recv_size, 0)) != 0) { in recv_tcp_stream()
4484 access_buffer(recv_ring->buffer_ptr, in recv_tcp_stream()
4492 recv_ring = recv_ring->next; in recv_tcp_stream()
4976 struct ring_elt *recv_ring; in send_tcp_rr() local
5051 recv_ring = NULL; in send_tcp_rr()
5097 if (recv_ring == NULL) { in send_tcp_rr()
5098 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_rr()
5331 temp_message_ptr = recv_ring->buffer_ptr; in send_tcp_rr()
5348 recv_ring = recv_ring->next; in send_tcp_rr()
6276 struct ring_elt *recv_ring; in recv_udp_stream() local
6346 recv_ring = allocate_buffer_ring(recv_width, in recv_udp_stream()
6480 len = recvfrom(s_data, recv_ring->buffer_ptr, in recv_udp_stream()
6491 recv_ring = recv_ring->next; in recv_udp_stream()
6513 recv_ring->buffer_ptr, in recv_udp_stream()
6518 recv_ring->buffer_ptr, in recv_udp_stream()
6532 recv_ring = recv_ring->next; in recv_udp_stream()
6634 struct ring_elt *recv_ring; in send_udp_rr() local
6689 recv_ring = NULL; in send_udp_rr()
6723 if (recv_ring == NULL) { in send_udp_rr()
6724 recv_ring = allocate_buffer_ring(recv_width, in send_udp_rr()
6931 recv_ring->buffer_ptr, in send_udp_rr()
6942 recv_ring = recv_ring->next; in send_udp_rr()
7227 struct ring_elt *recv_ring; in recv_udp_rr() local
7301 recv_ring = allocate_buffer_ring(recv_width, in recv_udp_rr()
7439 recv_ring->buffer_ptr, in recv_udp_rr()
7453 recv_ring = recv_ring->next; in recv_udp_rr()
7541 struct ring_elt *recv_ring; in recv_tcp_rr() local
7623 recv_ring = allocate_buffer_ring(recv_width, in recv_tcp_rr()
7788 temp_message_ptr = recv_ring->buffer_ptr; in recv_tcp_rr()
7819 recv_ring = recv_ring->next; in recv_tcp_rr()
8014 struct ring_elt *recv_ring; in send_tcp_conn_rr() local
8084 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_conn_rr()
8334 temp_message_ptr = recv_ring->buffer_ptr; in send_tcp_conn_rr()
8388 recv_ring = recv_ring->next; in send_tcp_conn_rr()
9094 struct ring_elt *recv_ring; in send_tcp_tran_rr() local
9177 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_tran_rr()
9429 temp_message_ptr = recv_ring->buffer_ptr; in send_tcp_tran_rr()
9447 recv_ring = recv_ring->next; in send_tcp_tran_rr()
10169 struct ring_elt *recv_ring; in send_tcp_nbrr() local
10226 recv_ring = NULL; in send_tcp_nbrr()
10263 if (recv_ring == NULL) { in send_tcp_nbrr()
10264 recv_ring = allocate_buffer_ring(recv_width, in send_tcp_nbrr()
10450 temp_message_ptr = recv_ring->buffer_ptr; in send_tcp_nbrr()
10476 recv_ring = recv_ring->next; in send_tcp_nbrr()
10754 struct ring_elt *recv_ring; in recv_tcp_nbrr() local
10835 recv_ring = allocate_buffer_ring(recv_width, in recv_tcp_nbrr()
11022 temp_message_ptr = recv_ring->buffer_ptr; in recv_tcp_nbrr()
11057 recv_ring = recv_ring->next; in recv_tcp_nbrr()