Lines Matching refs:cons
56 union smc_host_cursor cons, size_t len) in smc_rx_update_consumer() argument
63 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
67 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
79 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
87 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
99 union smc_host_cursor cons; in smc_rx_update_cons() local
101 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
102 smc_rx_update_consumer(smc, cons, len); in smc_rx_update_cons()
223 union smc_host_cursor cons; in smc_rx_recv_urg() local
241 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
242 if (smc_curs_diff(conn->rmb_desc->len, &cons, in smc_rx_recv_urg()
249 smc_rx_update_consumer(smc, cons, 0); in smc_rx_recv_urg()
289 union smc_host_cursor cons; in smc_rx_recvmsg() local
385 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recvmsg()
388 smc_curs_add(conn->rmb_desc->len, &cons, splbytes); in smc_rx_recvmsg()
398 cons.count); in smc_rx_recvmsg()
400 chunk_off = cons.count; in smc_rx_recvmsg()
439 if (msg && smc_rx_update_consumer(smc, cons, copylen)) in smc_rx_recvmsg()