Lines Matching full:cons
54 * @cons consumer cursor
60 union smc_host_cursor cons, size_t len) in smc_rx_update_consumer() argument
67 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
71 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
83 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
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()
305 if (smc_curs_diff(conn->rmb_desc->len, &cons, 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()
450 smc_curs_add(conn->rmb_desc->len, &cons, peeked_bytes); in smc_rx_recvmsg()
453 smc_curs_add(conn->rmb_desc->len, &cons, splbytes); in smc_rx_recvmsg()
463 cons.count); in smc_rx_recvmsg()
465 chunk_off = cons.count; in smc_rx_recvmsg()
504 if (msg && smc_rx_update_consumer(smc, cons, copylen)) in smc_rx_recvmsg()