rm_foms.c File Reference

#include "lib/errno.h"
#include "lib/list.h"
#include "lib/memory.h"
#include "lib/misc.h"
#include "lib/trace.h"
#include "lib/finject.h"
#include "fop/fom_generic.h"
#include "rpc/service.h"
#include "rpc/rpc.h"
#include "reqh/reqh.h"
#include "conf/confc.h"
#include "rm/rm_fops.h"
#include "rm/rm_foms.h"
#include "rm/rm_service.h"

Include dependency graph for rm_foms.c:

Go to the source code of this file.

Macros
#define	M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_RM

Enumerations
enum	fop_request_type { FRT_BORROW = M0_RIT_BORROW, FRT_REVOKE = M0_RIT_REVOKE, FRT_CANCEL }

Functions
static int	borrow_fom_create (struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
static void	borrow_fom_fini (struct m0_fom *fom)
static int	revoke_fom_create (struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
static void	revoke_fom_fini (struct m0_fom *fom)
static int	cancel_fom_create (struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
static void	cancel_fom_fini (struct m0_fom *fom)
static int	borrow_fom_tick (struct m0_fom *)
static int	revoke_fom_tick (struct m0_fom *)
static int	cancel_process (struct m0_fom *fom)
static int	cancel_fom_tick (struct m0_fom *)
static size_t	locality (const struct m0_fom *fom)
static void	remote_incoming_complete (struct m0_rm_incoming *in, int32_t rc)
static void	remote_incoming_conflict (struct m0_rm_incoming *in)
static int	request_fom_create (enum m0_rm_incoming_type type, struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
static void	request_fom_fini (struct m0_fom *fom)
static int	reply_prepare (const enum m0_rm_incoming_type type, struct m0_fom *fom)
static void	reply_err_set (enum m0_rm_incoming_type type, struct m0_fom *fom, int rc)
M0_INTERNAL int	m0_rm_reverse_session_get (struct m0_rm_remote_incoming *rem_in, struct m0_rm_remote *remote)
static int	incoming_prepare (enum m0_rm_incoming_type type, struct m0_fom *fom)
static int	remote_create (struct m0_rm_remote **rem, struct m0_rm_remote_incoming *rem_in)
static int	rfom_debtor_subscribe (struct rm_request_fom *rfom, struct m0_rm_remote *debtor)
static int	request_pre_process (struct m0_fom *fom, enum m0_rm_incoming_type type)
static int	request_post_process (struct m0_fom *fom)
static int	request_fom_tick (struct m0_fom *fom, enum m0_rm_incoming_type type)
static int	debtor_subscription_check (struct m0_fom *fom)

Variables
static struct m0_rm_incoming_ops	remote_incoming_ops
static struct m0_fom_ops	rm_fom_borrow_ops
const struct m0_fom_type_ops	rm_borrow_fom_type_ops
static struct m0_fom_ops	rm_fom_revoke_ops
const struct m0_fom_type_ops	rm_revoke_fom_type_ops
static struct m0_fom_ops	rm_fom_cancel_ops
const struct m0_fom_type_ops	rm_cancel_fom_type_ops
struct m0_sm_state_descr	rm_req_phases []
const struct m0_sm_conf	borrow_sm_conf
const struct m0_sm_conf	canoke_sm_conf

Macro Definition Documentation

M0_TRACE_SUBSYSTEM

#define M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_RM

Definition at line 24 of file rm_foms.c.