Lines Matching full:cons
49 * @cons consumer cursor
55 union smc_host_cursor cons, size_t len) in smc_rx_update_consumer() argument
62 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
66 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
78 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
86 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
98 union smc_host_cursor cons; in smc_rx_update_cons() local
100 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
101 smc_rx_update_consumer(smc, cons, len); in smc_rx_update_cons()
222 union smc_host_cursor cons; in smc_rx_recv_urg() local
240 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
241 if (smc_curs_diff(conn->rmb_desc->len, &cons, in smc_rx_recv_urg()
248 smc_rx_update_consumer(smc, cons, 0); in smc_rx_recv_urg()
288 union smc_host_cursor cons; in smc_rx_recvmsg() local
384 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recvmsg()
387 smc_curs_add(conn->rmb_desc->len, &cons, splbytes); in smc_rx_recvmsg()
397 cons.count); in smc_rx_recvmsg()
399 chunk_off = cons.count; in smc_rx_recvmsg()
438 if (msg && smc_rx_update_consumer(smc, cons, copylen)) in smc_rx_recvmsg()