Lines Matching full:cons
48 * @cons consumer cursor
54 union smc_host_cursor cons, size_t len) in smc_rx_update_consumer() argument
61 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
65 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
77 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
85 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
97 union smc_host_cursor cons; in smc_rx_update_cons() local
99 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
100 smc_rx_update_consumer(smc, cons, len); in smc_rx_update_cons()
221 union smc_host_cursor cons; in smc_rx_recv_urg() local
238 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
239 if (smc_curs_diff(conn->rmb_desc->len, &cons, in smc_rx_recv_urg()
246 smc_rx_update_consumer(smc, cons, 0); in smc_rx_recv_urg()
286 union smc_host_cursor cons; in smc_rx_recvmsg() local
376 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recvmsg()
379 smc_curs_add(conn->rmb_desc->len, &cons, splbytes); in smc_rx_recvmsg()
389 cons.count); in smc_rx_recvmsg()
391 chunk_off = cons.count; in smc_rx_recvmsg()
430 if (msg && smc_rx_update_consumer(smc, cons, copylen)) in smc_rx_recvmsg()