#include "lib/types.h"
#include "lib/mutex.h"
#include "lib/tlist.h"
#include "lib/semaphore.h"
#include "be/log.h"
#include "be/tx.h"
#include "be/tx_credit.h"
#include "be/tx_group.h"
Go to the source code of this file.
|
M0_INTERNAL bool | m0_be_engine__invariant (struct m0_be_engine *en) |
|
M0_INTERNAL int | m0_be_engine_init (struct m0_be_engine *en, struct m0_be_domain *dom, struct m0_be_engine_cfg *en_cfg) |
|
M0_INTERNAL void | m0_be_engine_fini (struct m0_be_engine *en) |
|
M0_INTERNAL int | m0_be_engine_start (struct m0_be_engine *en) |
|
M0_INTERNAL void | m0_be_engine_stop (struct m0_be_engine *en) |
|
M0_INTERNAL void | m0_be_engine__tx_init (struct m0_be_engine *en, struct m0_be_tx *tx, enum m0_be_tx_state state) |
|
M0_INTERNAL void | m0_be_engine__tx_fini (struct m0_be_engine *en, struct m0_be_tx *tx) |
|
M0_INTERNAL void | m0_be_engine__tx_state_set (struct m0_be_engine *en, struct m0_be_tx *tx, enum m0_be_tx_state state) |
|
M0_INTERNAL void | m0_be_engine__tx_force (struct m0_be_engine *en, struct m0_be_tx *tx) |
|
M0_INTERNAL void | m0_be_engine__tx_group_ready (struct m0_be_engine *en, struct m0_be_tx_group *gr) |
|
M0_INTERNAL void | m0_be_engine__tx_group_discard (struct m0_be_engine *en, struct m0_be_tx_group *gr) |
|
M0_INTERNAL void | m0_be_engine_got_log_space_cb (struct m0_be_log *log) |
|
M0_INTERNAL void | m0_be_engine_full_log_cb (struct m0_be_log *log) |
|
M0_INTERNAL struct m0_be_tx * | m0_be_engine__tx_find (struct m0_be_engine *en, uint64_t id) |
|
M0_INTERNAL int | m0_be_engine__exclusive_open_invariant (struct m0_be_engine *en, struct m0_be_tx *excl) |
|
M0_INTERNAL void | m0_be_engine_tx_size_max (struct m0_be_engine *en, struct m0_be_tx_credit *cred, m0_bcount_t *payload_size) |
|
M0_INTERNAL void | m0_be_engine__group_limits (struct m0_be_engine *en, uint32_t *group_nr, uint32_t *tx_per_group) |
|
◆ __MOTR_BE_ENGINE_H__
#define __MOTR_BE_ENGINE_H__ |