Motr  M0
DIXCMAG

Functions

static uint64_t dix_cp_ag_local_cp_nr (const struct m0_cm_aggr_group *ag)
 
static void dix_cp_ag_fini (struct m0_cm_aggr_group *ag)
 
static bool dix_cp_ag_can_fini (const struct m0_cm_aggr_group *ag)
 
static bool dix_cm_ag_is_frozen_on (struct m0_cm_aggr_group *ag, struct m0_cm_proxy *pxy)
 
M0_INTERNAL int m0_dix_cm_ag_alloc (struct m0_cm *cm, const struct m0_cm_ag_id *id, bool has_incoming, struct m0_cm_aggr_group **out)
 

Variables

static const struct m0_cm_aggr_group_ops dix_cm_ag_ops
 

Detailed Description

Function Documentation

◆ dix_cm_ag_is_frozen_on()

static bool dix_cm_ag_is_frozen_on ( struct m0_cm_aggr_group ag,
struct m0_cm_proxy pxy 
)
static
Todo:
What to return here?

Definition at line 61 of file ag.c.

◆ dix_cp_ag_can_fini()

static bool dix_cp_ag_can_fini ( const struct m0_cm_aggr_group ag)
static

Definition at line 56 of file ag.c.

◆ dix_cp_ag_fini()

static void dix_cp_ag_fini ( struct m0_cm_aggr_group ag)
static

Definition at line 47 of file ag.c.

Here is the call graph for this function:

◆ dix_cp_ag_local_cp_nr()

static uint64_t dix_cp_ag_local_cp_nr ( const struct m0_cm_aggr_group ag)
static

Definition at line 41 of file ag.c.

◆ m0_dix_cm_ag_alloc()

M0_INTERNAL int m0_dix_cm_ag_alloc ( struct m0_cm cm,
const struct m0_cm_ag_id id,
bool  has_incoming,
struct m0_cm_aggr_group **  out 
)

Allocates and initialises DIX CM aggregation group.

Parameters
[in]cmBase copy machine.
[in]idAggregation group ID.
[in]has_incomingShows whether incoming copy packets for this aggregation group expected.
[out]outAllocated an initialised aggregation group.

0 on success or -ENOMEM.

See also
m0_cm_aggr_group_init()

Definition at line 88 of file ag.c.

Here is the call graph for this function:

Variable Documentation

◆ dix_cm_ag_ops

const struct m0_cm_aggr_group_ops dix_cm_ag_ops
static
Initial value:
= {
.cago_local_cp_nr = &dix_cp_ag_local_cp_nr,
.cago_fini = &dix_cp_ag_fini,
.cago_ag_can_fini = &dix_cp_ag_can_fini,
.cago_is_frozen_on = &dix_cm_ag_is_frozen_on
}
static bool dix_cm_ag_is_frozen_on(struct m0_cm_aggr_group *ag, struct m0_cm_proxy *pxy)
Definition: ag.c:61
static uint64_t dix_cp_ag_local_cp_nr(const struct m0_cm_aggr_group *ag)
Definition: ag.c:41
static void dix_cp_ag_fini(struct m0_cm_aggr_group *ag)
Definition: ag.c:47
static bool dix_cp_ag_can_fini(const struct m0_cm_aggr_group *ag)
Definition: ag.c:56

Definition at line 68 of file ag.c.