Motr  M0
copy machine sliding window
Collaboration diagram for copy machine sliding window:

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
 

Detailed Description

Function Documentation

◆ m0_cm_sw_cmp()

M0_INTERNAL bool m0_cm_sw_cmp ( const struct m0_cm_sw sw0,
const struct m0_cm_sw sw1 
)

Definition at line 51 of file sw.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ m0_cm_sw_copy()

M0_INTERNAL void m0_cm_sw_copy ( struct m0_cm_sw dst,
const struct m0_cm_sw src 
)

Definition at line 67 of file sw.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ m0_cm_sw_is_set()

M0_INTERNAL bool m0_cm_sw_is_set ( const struct m0_cm_sw sw)

Definition at line 45 of file sw.c.

Here is the call graph for this function:

◆ m0_cm_sw_local_update()

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.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ m0_cm_sw_onwire_init()

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 
)

Definition at line 76 of file sw.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ m0_cm_sw_remote_update()

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.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ m0_cm_sw_set()

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 
)

Definition at line 57 of file sw.c.

Here is the call graph for this function:

◆ m0_cm_sw_update_complete()

M0_INTERNAL void m0_cm_sw_update_complete ( struct m0_cm cm)

Definition at line 180 of file sw_update_fom.c.

Here is the caller graph for this function:

◆ m0_cm_sw_update_fom_wakeup()

M0_INTERNAL void m0_cm_sw_update_fom_wakeup ( struct m0_cm_sw_update swu)

◆ m0_cm_sw_update_init()

M0_INTERNAL void m0_cm_sw_update_init ( struct m0_cm_type cmtype)

Definition at line 158 of file sw_update_fom.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ m0_cm_sw_update_start()

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.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ M0_XCA_DOMAIN()

struct m0_cm_sw M0_XCA_DOMAIN ( rpc  )

Variable Documentation

◆ M0_XCA_DOMAIN

struct m0_cm_sw_update M0_XCA_DOMAIN