| /net/smc/ |
| A D | smc_rx.c | 91 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
103 union smc_host_cursor cons; in smc_rx_update_cons() local
105 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
106 smc_rx_update_consumer(smc, cons, len); in smc_rx_update_cons()
286 union smc_host_cursor cons; in smc_rx_recv_urg() local
304 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
312 smc_rx_update_consumer(smc, cons, 0); in smc_rx_recv_urg()
352 union smc_host_cursor cons; in smc_rx_recvmsg() local
448 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recvmsg()
463 cons.count); in smc_rx_recvmsg()
[all …]
|
| A D | smc_cdc.h | 47 union smc_cdc_cursor cons; /* piggy backed "ack" */ member
73 union smcd_cdc_cursor cons; member
217 smc_host_cursor_to_cdc(&peer->cons, &local->cons, save, conn); in smc_host_msg_to_cdc()
250 smc_cdc_cursor_to_host(&local->cons, &peer->cons, conn); in smcr_cdc_msg_to_host()
265 temp.wrap = peer->cons.wrap; in smcd_cdc_msg_to_host()
266 temp.count = peer->cons.count; in smcd_cdc_msg_to_host()
267 smc_curs_copy(&local->cons, &temp, conn); in smcd_cdc_msg_to_host()
268 local->prod_flags = peer->cons.prod_flags; in smcd_cdc_msg_to_host()
269 local->conn_state_flags = peer->cons.conn_state_flags; in smcd_cdc_msg_to_host()
|
| A D | smc_cdc.c | 249 curs.acurs.counter = atomic64_read(&conn->local_tx_ctrl.cons.acurs); in smcd_cdc_msg_send()
250 cdc.cons.wrap = curs.wrap; in smcd_cdc_msg_send()
251 cdc.cons.count = curs.count; in smcd_cdc_msg_send()
252 cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags; in smcd_cdc_msg_send()
253 cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags; in smcd_cdc_msg_send()
338 smc_curs_copy(&cons_old, &conn->local_rx_ctrl.cons, conn); in smc_cdc_msg_recv_action()
342 &conn->local_rx_ctrl.cons); in smc_cdc_msg_recv_action()
363 &conn->local_rx_ctrl.cons); in smc_cdc_msg_recv_action()
370 &conn->local_rx_ctrl.cons, conn); in smc_cdc_msg_recv_action()
454 smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn); in smcd_cdc_rx_tsklet()
|
| A D | smc_tx.c | 467 union smc_host_cursor sent, prep, prod, cons; in smc_tx_rdma_writes() local
490 smc_curs_copy(&cons, &conn->local_rx_ctrl.cons, conn); in smc_tx_rdma_writes()
500 if (prod.wrap == cons.wrap) { in smc_tx_rdma_writes()
694 union smc_host_cursor cfed, cons, prod; in smc_tx_consumer_update() local
698 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_tx_consumer_update()
700 to_confirm = smc_curs_diff(conn->rmb_desc->len, &cfed, &cons); in smc_tx_consumer_update()
|
| A D | smc_diag.c | 118 .rx_cons.wrap = conn->local_rx_ctrl.cons.wrap, in __smc_diag_dump()
119 .rx_cons.count = conn->local_rx_ctrl.cons.count, in __smc_diag_dump()
123 .tx_cons.wrap = conn->local_tx_ctrl.cons.wrap, in __smc_diag_dump()
124 .tx_cons.count = conn->local_tx_ctrl.cons.count, in __smc_diag_dump()
|
| A D | smc_core.c | 1009 union smc_host_cursor cons; in smc_write_space() local
1013 smc_curs_copy(&cons, &conn->local_rx_ctrl.cons, conn); in smc_write_space()
1015 space = buffer_len - smc_curs_diff(buffer_len, &cons, &prod); in smc_write_space()
1023 union smc_host_cursor cons, fin; in smc_switch_cursor() local
1031 smc_curs_copy(&cons, &conn->local_rx_ctrl.cons, conn); in smc_switch_cursor()
1033 if (smc_curs_comp(conn->peer_rmbe_size, &cons, &fin) < 0) { in smc_switch_cursor()
1037 diff = smc_curs_diff(conn->peer_rmbe_size, &fin, &cons); in smc_switch_cursor()
|
| A D | smc.h | 175 union smc_host_cursor cons; /* consumer cursor, member
|
| A D | af_smc.c | 3190 union smc_host_cursor cons, urg; in smc_ioctl() local
3253 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_ioctl()
3256 &cons, &urg) == 1; in smc_ioctl()
|
| /net/9p/ |
| A D | trans_xen.c | 105 RING_IDX cons, prod; in p9_xen_write_todo() local
107 cons = ring->intf->out_cons; in p9_xen_write_todo()
118 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_request() local
142 cons = ring->intf->out_cons; in p9_xen_request()
153 masked_cons = xen_9pfs_mask(cons, XEN_9PFS_RING_SIZE(ring)); in p9_xen_request()
174 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_response() local
183 cons = ring->intf->in_cons; in p9_xen_response()
204 cons += h.size; in p9_xen_response()
206 ring->intf->in_cons = cons; in p9_xen_response()
231 cons += h.size; in p9_xen_response()
[all …]
|