25 #ifndef __MOTR_BE_TX_BULK_H__ 26 #define __MOTR_BE_TX_BULK_H__ 79 uint64_t worker_index,
85 uint64_t worker_index,
M0_INTERNAL void m0_be_tx_bulk_run(struct m0_be_tx_bulk *tb, struct m0_be_op *op)
M0_INTERNAL int m0_be_tx_bulk_init(struct m0_be_tx_bulk *tb, struct m0_be_tx_bulk_cfg *tb_cfg)
M0_INTERNAL void m0_be_tx_bulk_end(struct m0_be_tx_bulk *tb)
struct m0_be_queue * btb_q
struct m0_be_domain * tbc_dom
void(* tbc_do)(struct m0_be_tx_bulk *tb, struct m0_be_tx *tx, struct m0_be_op *op, void *datum, void *user, uint64_t worker_index, uint64_t partition)
uint64_t tbc_partitions_nr
M0_INTERNAL int m0_be_tx_bulk_status(struct m0_be_tx_bulk *tb)
uint64_t tbc_work_items_per_tx_max
M0_INTERNAL bool m0_be_tx_bulk_put(struct m0_be_tx_bulk *tb, struct m0_be_op *op, struct m0_be_tx_credit *credit, m0_bcount_t payload_credit, uint64_t partition, void *user)
M0_INTERNAL void m0_be_tx_bulk_fini(struct m0_be_tx_bulk *tb)
struct m0_be_op btb_kill_put_op
void(* tbc_done)(struct m0_be_tx_bulk *tb, void *datum, void *user, uint64_t worker_index, uint64_t partition)
struct m0_be_tx_bulk_cfg btb_cfg
bool btb_termination_in_progress
struct m0_be_queue_cfg tbc_q_cfg
struct be_tx_bulk_worker * btb_worker