Motr  M0
cp.c File Reference
#include "lib/trace.h"
#include "lib/memory.h"
#include "lib/misc.h"
#include "fop/fom.h"
#include "reqh/reqh.h"
#include "dix/cm/cp.h"
#include "dix/cm/cm.h"
#include "dix/cm/dix_cp_onwire.h"
#include "dix/fid_convert.h"
Include dependency graph for cp.c:

Go to the source code of this file.

Macros

#define M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_DIXCM
 

Functions

M0_INTERNAL int m0_dix_cm_cp_sw_check (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_send_wait (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_repair_cp_send (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_rebalance_cp_send (struct m0_cm_cp *cp)
 
M0_INTERNAL struct m0_dix_cm_cpcp2dixcp (const struct m0_cm_cp *cp)
 
static struct m0_dix_cmcp2dixcm (struct m0_cm_cp *cp)
 
M0_INTERNAL bool m0_dix_cm_cp_invariant (const struct m0_cm_cp *cp)
 
M0_INTERNAL uint64_t m0_dix_cm_cp_home_loc_helper (const struct m0_cm_cp *cp)
 
M0_INTERNAL struct m0_cm_cpm0_dix_cm_cp_alloc (struct m0_cm *cm)
 
static void dix_cm_cp_dtx_fini (struct m0_cm_cp *cp)
 
static int dix_cm_cp_dtx_failure (struct m0_cm_cp *cp)
 
static int dix_cm_cp_incoming_kv (struct m0_rpc_at_buf *ab_key, struct m0_rpc_at_buf *ab_val, struct m0_buf *key, struct m0_buf *val)
 
static void dixcpx_to_dixcp (const struct m0_dix_cpx *dix_cpx, struct m0_dix_cm_cp *dix_cp)
 
static void dix_cm_cp_reply_send (struct m0_cm_cp *cp, struct m0_fop_type *ft, int rc)
 
static int dix_cm_fom_tx_wait (struct m0_fom *fom)
 
M0_INTERNAL int m0_dix_cm_cp_init (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_fail (struct m0_cm_cp *cp, struct m0_fop_type *ft)
 
static int dix_cm_repair_cp_fail (struct m0_cm_cp *cp)
 
static int dix_cm_rebalance_cp_fail (struct m0_cm_cp *cp)
 
M0_INTERNAL void m0_dix_cm_cp_complete (struct m0_cm_cp *cp)
 
M0_INTERNAL void m0_dix_cm_cp_free (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_fini (struct m0_cm_cp *cp)
 
M0_INTERNAL void m0_dix_cm_cp_tgt_info_fill (struct m0_dix_cm_cp *dix_cp, const struct m0_fid *cctg_fid)
 
M0_INTERNAL void m0_dix_cm_cp_setup (struct m0_dix_cm_cp *dix_cp, const struct m0_fid *cctg_fid, uint64_t failed_unit_index)
 
M0_INTERNAL int m0_dix_cm_cp_dup (struct m0_cm_cp *src, struct m0_cm_cp **dest)
 
M0_INTERNAL int m0_dix_cm_cp_read (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_xform (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_write_pre (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_tx_open (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_write (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_tx_done (struct m0_cm_cp *cp)
 
M0_INTERNAL int m0_dix_cm_cp_io_wait (struct m0_cm_cp *cp, struct m0_fop_type *ft)
 
static int dix_cm_repair_cp_io_wait (struct m0_cm_cp *cp)
 
static int dix_cm_rebalance_cp_io_wait (struct m0_cm_cp *cp)
 

Variables

struct m0_fop_type m0_dix_repair_cpx_reply_fopt
 
struct m0_fop_type m0_dix_rebalance_cpx_reply_fopt
 
M0_INTERNAL const struct m0_cm_cp_ops m0_dix_cm_repair_cp_ops
 
M0_INTERNAL const struct m0_cm_cp_ops m0_dix_cm_rebalance_cp_ops
 

Macro Definition Documentation

◆ M0_TRACE_SUBSYSTEM

#define M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_DIXCM

Definition at line 23 of file cp.c.