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