net.c File Reference

#include "lib/trace.h"
#include "lib/memory.h"
#include "cm/proxy.h"
#include "sns/cm/cm.h"
#include "sns/cm/cp.h"
#include "sns/cm/sns_cp_onwire.h"
#include "sns/cm/cm_utils.h"
#include "sns/cm/file.h"
#include "fop/fop.h"
#include "fop/fom.h"
#include "net/net.h"
#include "rpc/item.h"
#include "rpc/rpclib.h"
#include "rpc/session.h"
#include "rpc/conn.h"
#include "rpc/rpc_machine.h"
#include "ioservice/fid_convert.h"

Include dependency graph for net.c:

Go to the source code of this file.

Macros
#define	M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_SNSCM

Functions
static void	cp_reply_received (struct m0_rpc_item *item)
static int	indexvec_prepare (struct m0_io_indexvec *iv, m0_bindex_t idx, uint32_t seg_nr, size_t seg_size)
static int	snscp_to_snscpx (const struct m0_sns_cm_cp *sns_cp, struct m0_sns_cpx *sns_cpx)
static void	cp_fop_release (struct m0_ref *ref)
M0_INTERNAL int	m0_sns_cm_cp_send (struct m0_cm_cp *cp, struct m0_fop_type *ft)
	M0_TL_DESCR_DECLARE (rpcbulk, M0_EXTERN)
	M0_TL_DECLARE (rpcbulk, M0_INTERNAL, struct m0_rpc_bulk_buf)
M0_INTERNAL int	m0_sns_cm_cp_send_wait (struct m0_cm_cp *cp)
static void	cp_buf_acquire (struct m0_cm_cp *cp)
static void	cp_reply_post (struct m0_cm_cp *cp)
static uint32_t	seg_nr_get (const struct m0_sns_cpx *sns_cpx, uint32_t ivec_nr)
static int	ag_cp_recvd_from_proxy (struct m0_cm_aggr_group *ag, struct m0_sns_cm_cp *scp)
static int	snscpx_to_snscp (const struct m0_sns_cpx *sns_cpx, struct m0_sns_cm_cp *sns_cp)
M0_INTERNAL int	m0_sns_cm_cp_recv_init (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_sns_cm_cp_recv_wait (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_sns_cm_cp_sw_check (struct m0_cm_cp *cp)

Variables
static const struct m0_rpc_item_ops	cp_item_ops

Macro Definition Documentation

M0_TRACE_SUBSYSTEM

#define M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_SNSCM

Definition at line 23 of file net.c.