Motr
M0
|
![]() |
Modules | |
sliding window update fom | |
Data Structures | |
struct | m0_cm_sw |
struct | m0_cm_local_ep |
struct | m0_cm_sw_onwire |
struct | m0_cm_sw_onwire_rep |
struct | m0_cm_sw_update |
Functions | |
M0_INTERNAL bool | m0_cm_sw_is_set (const struct m0_cm_sw *sw) |
M0_INTERNAL bool | m0_cm_sw_cmp (const struct m0_cm_sw *sw0, const struct m0_cm_sw *sw1) |
M0_INTERNAL void | m0_cm_sw_set (struct m0_cm_sw *dst, const struct m0_cm_ag_id *lo, const struct m0_cm_ag_id *hi) |
M0_INTERNAL void | m0_cm_sw_copy (struct m0_cm_sw *dst, const struct m0_cm_sw *src) |
M0_INTERNAL int | m0_cm_sw_onwire_init (struct m0_cm *cm, struct m0_cm_sw_onwire *sw_onwire, uint64_t proxy_id, const char *ep, const struct m0_cm_sw *sw, const struct m0_cm_sw *out_interval) |
M0_INTERNAL int | m0_cm_sw_local_update (struct m0_cm *cm) |
M0_INTERNAL int | m0_cm_sw_remote_update (struct m0_cm *cm) |
struct m0_cm_sw | M0_XCA_DOMAIN (rpc) |
M0_INTERNAL void | m0_cm_sw_update_init (struct m0_cm_type *cmtype) |
M0_INTERNAL void | m0_cm_sw_update_start (struct m0_cm *cm) |
M0_INTERNAL void | m0_cm_sw_update_complete (struct m0_cm *cm) |
M0_INTERNAL void | m0_cm_sw_update_fom_wakeup (struct m0_cm_sw_update *swu) |
Variables | |
struct m0_cm_sw_update | M0_XCA_DOMAIN |
M0_INTERNAL bool m0_cm_sw_is_set | ( | const struct m0_cm_sw * | sw | ) |
M0_INTERNAL int m0_cm_sw_local_update | ( | struct m0_cm * | cm | ) |
Updates local sliding window, creates new aggregation groups as many as possible and adds them to the sliding window. This is invoked from sliding window update fom. See sliding window update fom for more details.
Definition at line 117 of file sw.c.
M0_INTERNAL int m0_cm_sw_onwire_init | ( | struct m0_cm * | cm, |
struct m0_cm_sw_onwire * | sw_onwire, | ||
uint64_t | proxy_id, | ||
const char * | ep, | ||
const struct m0_cm_sw * | sw, | ||
const struct m0_cm_sw * | out_interval | ||
) |
M0_INTERNAL int m0_cm_sw_remote_update | ( | struct m0_cm * | cm | ) |
Sends local sliding window updates to remote replicas. This is invoked from m0_cm_ready(), once the local copy machine sliding window is updated. See copy machine proxy for more details.
Definition at line 130 of file sw.c.
M0_INTERNAL void m0_cm_sw_set | ( | struct m0_cm_sw * | dst, |
const struct m0_cm_ag_id * | lo, | ||
const struct m0_cm_ag_id * | hi | ||
) |
M0_INTERNAL void m0_cm_sw_update_complete | ( | struct m0_cm * | cm | ) |
M0_INTERNAL void m0_cm_sw_update_fom_wakeup | ( | struct m0_cm_sw_update * | swu | ) |
M0_INTERNAL void m0_cm_sw_update_init | ( | struct m0_cm_type * | cmtype | ) |
Definition at line 158 of file sw_update_fom.c.
M0_INTERNAL void m0_cm_sw_update_start | ( | struct m0_cm * | cm | ) |
Starts sliding window update FOM by submitting the corresponding FOM to request handler.
Definition at line 165 of file sw_update_fom.c.
struct m0_cm_sw M0_XCA_DOMAIN | ( | rpc | ) |
struct m0_cm_sw_update M0_XCA_DOMAIN |