Motr
M0
|
Data Structures | |
struct | m0_dtm0_domain_cfg |
struct | m0_dtm0_domain_create_cfg |
struct | m0_dtm0_domain |
struct | m0_dtx0 |
struct | m0_dtm0_log_cfg |
struct | m0_dtm0_log_create_cfg |
struct | m0_dtm0_log |
struct | m0_dtm0_log_record |
struct | m0_dtm0_msg_redo |
struct | m0_dtm0_msg_eol |
struct | m0_dtm0_msg_persistent |
struct | m0_dtm0_msg |
struct | m0_dtm0_net_cfg |
struct | m0_dtm0_net |
struct | m0_dtm0_pmach |
struct | m0_dtm0_pmach_cfg |
struct | m0_dtm0_pruner |
struct | m0_dtm0_pruner_cfg |
struct | m0_dtm0_remach |
struct | m0_dtm0_remach_cfg |
struct | m0_ut_dtm0_helper |
Macros | |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
#define | DTM0_DOMAIN_LEVEL(level) |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
#define | SERVER_ENDPOINT_ADDR "0@lo:12345:34:1" |
#define | SERVER_ENDPOINT M0_NET_XPRT_PREFIX_DEFAULT":"SERVER_ENDPOINT_ADDR |
#define | DTM0_UT_CONF_PROCESS "<0x7200000000000001:5>" |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
Enumerations | |
enum | m0_avi_dtm0_labels { M0_AVI_DTX0_SM_STATE = M0_AVI_DTM0_RANGE_START, M0_AVI_DTX0_SM_COUNTER, M0_AVI_DTX0_SM_COUNTER_END = M0_AVI_DTX0_SM_COUNTER + 0x100 } |
enum | dtm0_domain_level { M0_DTM0_DOMAIN_LEVEL_INIT, M0_DTM0_DOMAIN_LEVEL_LOG_MKFS, M0_DTM0_DOMAIN_LEVEL_LOG_INIT, M0_DTM0_DOMAIN_LEVEL_REMACH_INIT, M0_DTM0_DOMAIN_LEVEL_PMACH_INIT, M0_DTM0_DOMAIN_LEVEL_SERVICE_INIT, M0_DTM0_DOMAIN_LEVEL_NET_INIT, M0_DTM0_DOMAIN_LEVEL_REMACH_START, M0_DTM0_DOMAIN_LEVEL_PMACH_START, M0_DTM0_DOMAIN_LEVEL_PRUNER_INIT, M0_DTM0_DOMAIN_LEVEL_READY } |
enum | m0_dtx0_state { M0_DTX0_STATE_INIT, M0_DTX0_STATE_EXECUTED, M0_DTX0_STATE_STABLE } |
enum | m0_dtm0_msg_type { M0_DMT_REDO, M0_DMT_PERSISTENT, M0_DMT_EOL } |
enum | { DTM0_UT_DRLINK_SIMPLE_POST_NR = 0x100 } |
enum | { MAX_RPCS_IN_FLIGHT = 10 } |
Functions | |
M0_INTERNAL int | m0_dtm0_domain_cfg_default_dup (struct m0_dtm0_domain_cfg *dod_cfg) |
M0_INTERNAL struct m0_dtm0_domain_cfg * | m0_dtm0_domain_cfg_dup (struct m0_dtm0_domain_cfg *dod_cfg) |
M0_INTERNAL void | m0_dtm0_domain_cfg_free (struct m0_dtm0_domain_cfg *dod_cfg) |
M0_BOB_DEFINE (static, &dtm0_domain_bob_type, m0_dtm0_domain) | |
static struct m0_dtm0_domain * | dtm0_module2domain (struct m0_module *module) |
static int | dtm0_domain_level_enter (struct m0_module *module) |
static void | dtm0_domain_level_leave (struct m0_module *module) |
M0_INTERNAL int | m0_dtm0_domain_init (struct m0_dtm0_domain *dod, struct m0_dtm0_domain_cfg *dod_cfg) |
M0_INTERNAL void | m0_dtm0_domain_fini (struct m0_dtm0_domain *dod) |
M0_INTERNAL int | m0_dtm0_domain_create (struct m0_dtm0_domain *dod, struct m0_dtm0_domain_create_cfg *dc_cfg) |
M0_INTERNAL void | m0_dtm0_domain_destroy (struct m0_dtm0_domain *dod) |
M0_INTERNAL int | m0_dtx0_init (struct m0_dtx0 *dtx0, struct m0_dtm0_domain *dod) |
M0_INTERNAL void | m0_dtx0_fini (struct m0_dtx0 *dtx0) |
M0_INTERNAL int | m0_dtx0_set (struct m0_dtx0 *dtx0, const struct m0_dtm0_tx_desc *txd, const struct m0_buf *buf) |
M0_INTERNAL void | m0_dtx0_timestamp_set (struct m0_dtx0 *dtx0) |
M0_INTERNAL int | m0_dtx0_participants_set (struct m0_dtx0 *dtx0, const struct m0_fid *rdtm_svcs, int rdtm_svcs_nr) |
M0_INTERNAL int | m0_dtx0_buf_set (struct m0_dtx0 *dtx0, const struct m0_buf *buf) |
M0_INTERNAL void | m0_dtx0_credit (struct m0_dtx0 *dtx0, struct m0_be_tx_credit *accum) |
M0_INTERNAL int | m0_dtx0_log_update (struct m0_dtx0 *dtx0, struct m0_be_tx *tx, struct m0_be_op *op, bool is_redo) |
M0_INTERNAL void | m0_dtx0_cancel (struct m0_dtx0 *dtx0) |
M0_INTERNAL int | m0_dtm0_log_init (struct m0_dtm0_log *dol, struct m0_dtm0_log_cfg *dol_cfg) |
M0_INTERNAL void | m0_dtm0_log_fini (struct m0_dtm0_log *dol) |
M0_INTERNAL int | m0_dtm0_log__create (struct m0_dtm0_log *dol, struct m0_dtm0_log_create_cfg *dlc_cfg) |
M0_INTERNAL void | m0_dtm0_log_destroy (struct m0_dtm0_log *dol) |
M0_INTERNAL void | m0_dtm0_log_update_credit (struct m0_dtm0_log *dol, struct m0_dtm0_log_record *rec, struct m0_be_tx_credit *accum) |
M0_INTERNAL int | m0_dtm0_log_update (struct m0_dtm0_log *dol, struct m0_be_tx *tx, struct m0_be_op *op, const struct m0_dtm0_log_record *rec, bool is_redo) |
M0_INTERNAL int | m0_dtm0_net_init (struct m0_dtm0_net *dnet, struct m0_dtm0_net_cfg *dnet_cfg) |
M0_INTERNAL void | m0_dtm0_net_fini (struct m0_dtm0_net *dnet) |
M0_INTERNAL void | m0_dtm0_net_send (struct m0_dtm0_net *dnet, struct m0_be_op *op, const struct m0_fid *target, const struct m0_dtm0_msg *msg) |
M0_INTERNAL void | m0_dtm0_net_recv (struct m0_dtm0_net *dnet, struct m0_be_op *op, struct m0_fid *source, struct m0_dtm0_msg *msg, enum m0_dtm0_msg_type type) |
M0_INTERNAL int | m0_dtm0_pmach_init (struct m0_dtm0_pmach *drm, struct m0_dtm0_pmach_cfg *drm_cfg) |
M0_INTERNAL void | m0_dtm0_pmach_fini (struct m0_dtm0_pmach *drm) |
M0_INTERNAL void | m0_dtm0_pmach_start (struct m0_dtm0_pmach *drm) |
M0_INTERNAL void | m0_dtm0_pmach_stop (struct m0_dtm0_pmach *drm) |
M0_INTERNAL int | m0_dtm0_pruner_init (struct m0_dtm0_pruner *dpn, struct m0_dtm0_pruner_cfg *dpn_cfg) |
M0_INTERNAL void | m0_dtm0_pruner_fini (struct m0_dtm0_pruner *dpn) |
M0_INTERNAL void | m0_dtm0_pruner_start (struct m0_dtm0_pruner *dpn) |
M0_INTERNAL void | m0_dtm0_pruner_stop (struct m0_dtm0_pruner *dpn) |
M0_INTERNAL int | m0_dtm0_remach_init (struct m0_dtm0_remach *drm, struct m0_dtm0_remach_cfg *drm_cfg) |
M0_INTERNAL void | m0_dtm0_remach_fini (struct m0_dtm0_remach *drm) |
M0_INTERNAL void | m0_dtm0_remach_start (struct m0_dtm0_remach *drm) |
M0_INTERNAL void | m0_dtm0_remach_stop (struct m0_dtm0_remach *drm) |
void | m0_dtm0_ut_domain_init_fini (void) |
void | m0_dtm0_ut_drlink_simple (void) |
M0_INTERNAL void | m0_ut_dtm0_helper_init (struct m0_ut_dtm0_helper *udh) |
M0_INTERNAL void | m0_ut_dtm0_helper_fini (struct m0_ut_dtm0_helper *udh) |
Variables | |
static const struct m0_bob_type | dtm0_domain_bob_type |
static const struct m0_modlev | levels_dtm0_domain [] |
struct m0_dtm0_log_cfg | M0_XCA_DOMAIN |
enum { ... } | M0_XCA_DOMAIN |
char * | ut_dtm0_helper_argv [] |
static const char * | ut_dtm0_client_endpoint = "0@lo:12345:34:2" |
const char * | ut_dtm0_helper_log = "dtm0_ut_server.log" |
#define DTM0_DOMAIN_LEVEL | ( | level | ) |
#define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DTM0 |
Definition at line 28 of file cfg_default.c.
#define SERVER_ENDPOINT M0_NET_XPRT_PREFIX_DEFAULT":"SERVER_ENDPOINT_ADDR |
enum dtm0_domain_level |
enum m0_avi_dtm0_labels |
enum m0_dtm0_msg_type |
enum m0_dtx0_state |
|
static |
|
static |
|
static |
M0_BOB_DEFINE | ( | static | , |
& | dtm0_domain_bob_type, | ||
m0_dtm0_domain | |||
) |
M0_INTERNAL int m0_dtm0_domain_cfg_default_dup | ( | struct m0_dtm0_domain_cfg * | dod_cfg | ) |
Definition at line 37 of file cfg_default.c.
M0_INTERNAL struct m0_dtm0_domain_cfg * m0_dtm0_domain_cfg_dup | ( | struct m0_dtm0_domain_cfg * | dod_cfg | ) |
Definition at line 55 of file cfg_default.c.
M0_INTERNAL void m0_dtm0_domain_cfg_free | ( | struct m0_dtm0_domain_cfg * | dod_cfg | ) |
M0_INTERNAL int m0_dtm0_domain_create | ( | struct m0_dtm0_domain * | dod, |
struct m0_dtm0_domain_create_cfg * | dc_cfg | ||
) |
M0_INTERNAL void m0_dtm0_domain_destroy | ( | struct m0_dtm0_domain * | dod | ) |
M0_INTERNAL void m0_dtm0_domain_fini | ( | struct m0_dtm0_domain * | dod | ) |
M0_INTERNAL int m0_dtm0_domain_init | ( | struct m0_dtm0_domain * | dod, |
struct m0_dtm0_domain_cfg * | dod_cfg | ||
) |
M0_INTERNAL int m0_dtm0_log__create | ( | struct m0_dtm0_log * | dol, |
struct m0_dtm0_log_create_cfg * | dlc_cfg | ||
) |
M0_INTERNAL void m0_dtm0_log_destroy | ( | struct m0_dtm0_log * | dol | ) |
M0_INTERNAL void m0_dtm0_log_fini | ( | struct m0_dtm0_log * | dol | ) |
M0_INTERNAL int m0_dtm0_log_init | ( | struct m0_dtm0_log * | dol, |
struct m0_dtm0_log_cfg * | dol_cfg | ||
) |
M0_INTERNAL int m0_dtm0_log_update | ( | struct m0_dtm0_log * | dol, |
struct m0_be_tx * | tx, | ||
struct m0_be_op * | op, | ||
const struct m0_dtm0_log_record * | rec, | ||
bool | is_redo | ||
) |
M0_INTERNAL void m0_dtm0_log_update_credit | ( | struct m0_dtm0_log * | dol, |
struct m0_dtm0_log_record * | rec, | ||
struct m0_be_tx_credit * | accum | ||
) |
M0_INTERNAL void m0_dtm0_net_fini | ( | struct m0_dtm0_net * | dnet | ) |
M0_INTERNAL int m0_dtm0_net_init | ( | struct m0_dtm0_net * | dnet, |
struct m0_dtm0_net_cfg * | dnet_cfg | ||
) |
M0_INTERNAL void m0_dtm0_net_recv | ( | struct m0_dtm0_net * | dnet, |
struct m0_be_op * | op, | ||
struct m0_fid * | source, | ||
struct m0_dtm0_msg * | msg, | ||
enum m0_dtm0_msg_type | type | ||
) |
M0_INTERNAL void m0_dtm0_net_send | ( | struct m0_dtm0_net * | dnet, |
struct m0_be_op * | op, | ||
const struct m0_fid * | target, | ||
const struct m0_dtm0_msg * | msg | ||
) |
M0_INTERNAL void m0_dtm0_pmach_fini | ( | struct m0_dtm0_pmach * | drm | ) |
M0_INTERNAL int m0_dtm0_pmach_init | ( | struct m0_dtm0_pmach * | drm, |
struct m0_dtm0_pmach_cfg * | drm_cfg | ||
) |
M0_INTERNAL void m0_dtm0_pmach_start | ( | struct m0_dtm0_pmach * | drm | ) |
M0_INTERNAL void m0_dtm0_pmach_stop | ( | struct m0_dtm0_pmach * | drm | ) |
M0_INTERNAL void m0_dtm0_pruner_fini | ( | struct m0_dtm0_pruner * | dpn | ) |
M0_INTERNAL int m0_dtm0_pruner_init | ( | struct m0_dtm0_pruner * | dpn, |
struct m0_dtm0_pruner_cfg * | dpn_cfg | ||
) |
M0_INTERNAL void m0_dtm0_pruner_start | ( | struct m0_dtm0_pruner * | dpn | ) |
M0_INTERNAL void m0_dtm0_pruner_stop | ( | struct m0_dtm0_pruner * | dpn | ) |
M0_INTERNAL void m0_dtm0_remach_fini | ( | struct m0_dtm0_remach * | drm | ) |
M0_INTERNAL int m0_dtm0_remach_init | ( | struct m0_dtm0_remach * | drm, |
struct m0_dtm0_remach_cfg * | drm_cfg | ||
) |
M0_INTERNAL void m0_dtm0_remach_start | ( | struct m0_dtm0_remach * | drm | ) |
M0_INTERNAL void m0_dtm0_remach_stop | ( | struct m0_dtm0_remach * | drm | ) |
void m0_dtm0_ut_domain_init_fini | ( | void | ) |
void m0_dtm0_ut_drlink_simple | ( | void | ) |
M0_INTERNAL void m0_dtx0_cancel | ( | struct m0_dtx0 * | dtx0 | ) |
M0_INTERNAL void m0_dtx0_credit | ( | struct m0_dtx0 * | dtx0, |
struct m0_be_tx_credit * | accum | ||
) |
M0_INTERNAL int m0_dtx0_init | ( | struct m0_dtx0 * | dtx0, |
struct m0_dtm0_domain * | dod | ||
) |
M0_INTERNAL int m0_dtx0_log_update | ( | struct m0_dtx0 * | dtx0, |
struct m0_be_tx * | tx, | ||
struct m0_be_op * | op, | ||
bool | is_redo | ||
) |
M0_INTERNAL int m0_dtx0_participants_set | ( | struct m0_dtx0 * | dtx0, |
const struct m0_fid * | rdtm_svcs, | ||
int | rdtm_svcs_nr | ||
) |
M0_INTERNAL int m0_dtx0_set | ( | struct m0_dtx0 * | dtx0, |
const struct m0_dtm0_tx_desc * | txd, | ||
const struct m0_buf * | buf | ||
) |
M0_INTERNAL void m0_dtx0_timestamp_set | ( | struct m0_dtx0 * | dtx0 | ) |
M0_INTERNAL void m0_ut_dtm0_helper_fini | ( | struct m0_ut_dtm0_helper * | udh | ) |
M0_INTERNAL void m0_ut_dtm0_helper_init | ( | struct m0_ut_dtm0_helper * | udh | ) |
|
static |
|
static |
enum { ... } M0_XCA_DOMAIN |
struct m0_dtm0_log_cfg M0_XCA_DOMAIN |
|
static |
char* ut_dtm0_helper_argv[] |