cp.c File Reference

#include "lib/trace.h"
#include "lib/misc.h"
#include "lib/memory.h"
#include "lib/errno.h"
#include "motr/magic.h"
#include "reqh/reqh.h"
#include "net/buffer_pool.h"
#include "rpc/rpc_opcodes.h"
#include "rpc/bulk.h"
#include "cm/cp.h"
#include "cm/ag.h"
#include "cm/proxy.h"
#include "cm/cm.h"
#include "fop/fop.h"
#include "fop/fom.h"

Include dependency graph for cp.c:

Go to the source code of this file.

Macros
#define	M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_CM

Functions
	M0_TL_DESCR_DEFINE (cp_data_buf, "copy packet data buffers", M0_INTERNAL, struct m0_net_buffer, nb_extern_linkage, nb_magic, M0_NET_BUFFER_LINK_MAGIC, CM_CP_DATA_BUF_HEAD_MAGIX)
	M0_TL_DEFINE (cp_data_buf, M0_INTERNAL, struct m0_net_buffer)
	M0_TL_DESCR_DEFINE (proxy_cps, "copy packets in proxy", M0_INTERNAL, struct m0_cm_cp, c_cm_proxy_linkage, c_magix, CM_CP_MAGIX, CM_PROXY_CP_HEAD_MAGIX)
	M0_TL_DEFINE (proxy_cps, M0_INTERNAL, struct m0_cm_cp)
	M0_BOB_DEFINE (static, &cp_bob, m0_cm_cp)
M0_INTERNAL void	m0_cm_cp_fom_fini (struct m0_fom *fom)
static uint64_t	cp_fom_locality (const struct m0_fom *fom)
static int	cp_fom_tick (struct m0_fom *fom)
M0_INTERNAL int	m0_cm_cp_fom_create (struct m0_fop *fop, struct m0_fop *r_fop, struct m0_fom **m, struct m0_reqh *reqh)
M0_INTERNAL void	m0_cm_cp_init (struct m0_cm_type *cmtype, const struct m0_fom_type_ops *ft_ops)
M0_INTERNAL bool	m0_cm_cp_invariant (const struct m0_cm_cp *cp)
M0_INTERNAL void	m0_cm_cp_only_init (struct m0_cm *cm, struct m0_cm_cp *cp)
M0_INTERNAL void	m0_cm_cp_fom_init (struct m0_cm *cm, struct m0_cm_cp *cp, struct m0_fop *fop, struct m0_fop *r_fop)
	M0_TL_DECLARE (rpcbulk, M0_INTERNAL, struct m0_rpc_bulk_buf)
	M0_TL_DESCR_DECLARE (rpcbulk, M0_EXTERN)
M0_INTERNAL void	m0_cm_cp_only_fini (struct m0_cm_cp *cp)
M0_INTERNAL void	m0_cm_cp_fini (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_cm_cp_enqueue (struct m0_cm *cm, struct m0_cm_cp *cp)
M0_INTERNAL void	m0_cm_cp_buf_add (struct m0_cm_cp *cp, struct m0_net_buffer *nb)
M0_INTERNAL void	m0_cm_cp_buf_release (struct m0_cm_cp *cp)
M0_INTERNAL uint64_t	m0_cm_cp_nr (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_cm_cp_bufvec_merge (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_cm_cp_bufvec_split (struct m0_cm_cp *cp)
M0_INTERNAL void	m0_cm_cp_buf_move (struct m0_cm_cp *src, struct m0_cm_cp *dest)
M0_INTERNAL int	m0_cm_cp_dup (struct m0_cm_cp *src, struct m0_cm_cp **dest)
M0_INTERNAL void	m0_cm_cp_data_copy (struct m0_cm_cp *src, struct m0_cm_cp *dst)

Variables
static const struct m0_bob_type	cp_bob
static const struct m0_fom_ops	cp_fom_ops
static struct m0_sm_state_descr	m0_cm_cp_state_descr []
static const struct m0_sm_conf	m0_cm_cp_sm_conf

Macro Definition Documentation

M0_TRACE_SUBSYSTEM

#define M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_CM

Definition at line 23 of file cp.c.