Index-dix

Data Structures
struct	dix_inst
struct	dix_req

Macros
#define	OI_IFID(oi)   (struct m0_fid *)&(oi)->oi_idx->in_entity.en_id

Functions
static bool	dixreq_clink_cb (struct m0_clink *cl)
static bool	dixreq_clink_dtx_cb (struct m0_clink *cl)
static bool	dix_meta_req_clink_cb (struct m0_clink *cl)
static void	dix_req_immed_failure (struct dix_req *req, int rc)
static void	dixreq_completed_post (struct dix_req *req, int rc)
static bool	idx_is_distributed (const struct m0_op_idx *oi)
static void	idx_sync_record_update (struct m0_op *op, struct m0_rpc_session *rpc_session, struct m0_be_tx_remid *remid)
static void	cas_sync_record_update (struct m0_cas_req *creq, struct m0_rpc_session *rpc_session, struct m0_be_tx_remid *remid)
static void	dix_sync_record_update (struct m0_dix_req *dreq, struct m0_rpc_session *rpc_session, struct m0_be_tx_remid *remid)
static struct dix_inst *	dix_inst (const struct m0_op_idx *oi)
static struct m0_dix_cli *	op_dixc (const struct m0_op_idx *oi)
M0_INTERNAL struct dix_inst *	ent_dix_inst (const struct m0_entity *ent)
M0_INTERNAL struct m0_dix_cli *	ent_dixc (const struct m0_entity *ent)
M0_INTERNAL struct m0_dix_cli *	ol_dixc (const struct m0_op_layout *ol)
static struct m0_reqh_service_ctx *	svc_find (const struct m0_op_idx *oi)
static void	cas_list_reply_copy (struct m0_cas_req *req, int32_t *rcs, struct m0_bufvec *bvec)
static void	cas_get_reply_copy (struct m0_cas_req *req, int32_t *rcs, struct m0_bufvec *bvec)
static void	cas_next_reply_copy (struct m0_cas_req *req, int32_t *rcs, struct m0_bufvec *keys, struct m0_bufvec *vals)
static bool	casreq_clink_cb (struct m0_clink *cl)
static void	cas_req_prepare (struct dix_req *req, struct m0_cas_id *cid, struct m0_op_idx *oi)
static void	cas_index_cancel (struct dix_req *dix_req)
static void	cas_index_create_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	cas_index_delete_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	cas_index_lookup_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	cas_index_list_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	cas_put_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	cas_get_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	cas_del_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	cas_next_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	dix_build (const struct m0_op_idx *oi, struct m0_dix *out)
static void	cas_req_init (struct dix_req *req, struct m0_op_idx *oi)
static int	dix_mreq_create (struct m0_op_idx *oi, struct dix_req **out)
static void	to_dix_map (const struct m0_op *op, const struct m0_dix_req *req)
static int	dix_req_create (struct m0_op_idx *oi, struct dix_req **out)
static void	dix_req_destroy (struct dix_req *req)
static void	dixreq_completed_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static int	dix_list_reply_copy (struct m0_dix_meta_req *req, int32_t *rcs, struct m0_bufvec *bvec)
static void	dix_get_reply_copy (struct m0_dix_req *dreq, int32_t *rcs, struct m0_bufvec *bvec)
static void	dix_next_reply_copy (struct m0_dix_req *req, int32_t *rcs, struct m0_bufvec *keys, struct m0_bufvec *vals)
static void	dixreq_stable_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	dixreq_stable_post (struct dix_req *req, int rc)
static void	dixreq_executed_post (struct dix_req *req, int rc)
static void	dix_req_exec (struct dix_req *req, void(*exec_fn)(struct m0_sm_group *grp, struct m0_sm_ast *ast))
static uint32_t	dix_set_cas_flags (struct m0_op_idx *oi)
static void	dix_index_create_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static bool	dix_iname_args_are_valid (const struct m0_op_idx *oi)
static void	dix_index_delete_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	dix_index_lookup_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	dix_index_list_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	dix_dreq_prepare (struct dix_req *req, struct m0_dix *dix, struct m0_op_idx *oi)
static void	dix_put_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	dix_get_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	dix_del_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	dix_next_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
static void	idx_op_cancel_ast (struct m0_sm_group *grp, struct m0_sm_ast *ast)
M0_INTERNAL int	m0__idx_cancel (struct m0_op_idx *oi)
static void	dix_set_idx_flags (struct m0_op_idx *oi)
static int	dix_index_create (struct m0_op_idx *oi)
static int	dix_index_delete (struct m0_op_idx *oi)
static int	dix_index_lookup (struct m0_op_idx *oi)
static int	dix_index_list (struct m0_op_idx *oi)
static int	dix_put (struct m0_op_idx *oi)
static int	dix_get (struct m0_op_idx *oi)
static int	dix_del (struct m0_op_idx *oi)
static int	dix_next (struct m0_op_idx *oi)
static int	dix_root_idx_pver (struct m0_client *m0c, struct m0_fid *out)
static int	dix_client_init (struct dix_inst *inst, struct m0_client *m0c, struct m0_idx_dix_config *config)
static int	idx_dix_init (void *svc)
static int	idx_dix_fini (void *svc)
M0_INTERNAL void	m0_idx_dix_register (void)

Variables
static struct m0_idx_query_ops	dix_query_ops
static struct m0_idx_service_ops	dix_svc_ops

Detailed Description

Macro Definition Documentation

OI_IFID

#define OI_IFID

(

oi

)

(struct m0_fid *)&(oi)->oi_idx->in_entity.en_id

Definition at line 49 of file idx_dix.c.

Function Documentation

cas_del_ast()

static void cas_del_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 485 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_get_ast()

static void cas_get_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 469 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_get_reply_copy()

static void cas_get_reply_copy ( struct m0_cas_req *  req, int32_t *  rcs, struct m0_bufvec *  bvec  )

static

Definition at line 244 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_index_cancel()

static void cas_index_cancel ( struct dix_req *  dix_req )

static

Definition at line 375 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_index_create_ast()

static void cas_index_create_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 385 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_index_delete_ast()

static void cas_index_delete_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 401 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_index_list_ast()

static void cas_index_list_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 433 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_index_lookup_ast()

static void cas_index_lookup_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 417 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_list_reply_copy()

static void cas_list_reply_copy ( struct m0_cas_req *  req, int32_t *  rcs, struct m0_bufvec *  bvec  )

static

Definition at line 222 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_next_ast()

static void cas_next_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Todo:

Currently there is no way to pass several starting keys along with number of consecutive records for each key through m0_idx_op().

Definition at line 504 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_next_reply_copy()

static void cas_next_reply_copy ( struct m0_cas_req *  req, int32_t *  rcs, struct m0_bufvec *  keys, struct m0_bufvec *  vals  )

static

Definition at line 267 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_put_ast()

static void cas_put_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 448 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_req_init()

static void cas_req_init ( struct dix_req *  req, struct m0_op_idx *  oi  )

static

Definition at line 591 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_req_prepare()

static void cas_req_prepare ( struct dix_req *  req, struct m0_cas_id *  cid, struct m0_op_idx *  oi  )

static

Definition at line 366 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cas_sync_record_update()

static void cas_sync_record_update ( struct m0_cas_req *  creq, struct m0_rpc_session *  rpc_session, struct m0_be_tx_remid *  remid  )

static

Definition at line 135 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

casreq_clink_cb()

static bool casreq_clink_cb ( struct m0_clink *  cl )

static

Definition at line 292 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_build()

static void dix_build ( const struct m0_op_idx *  oi, struct m0_dix *  out  )

static

Definition at line 547 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_client_init()

static int dix_client_init ( struct dix_inst *  inst, struct m0_client *  m0c, struct m0_idx_dix_config *  config  )

static

Definition at line 1450 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_del()

static int dix_del ( struct m0_op_idx *  oi )

static

Definition at line 1390 of file idx_dix.c.

Here is the call graph for this function:

dix_del_ast()

static void dix_del_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 1154 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_dreq_prepare()

static void dix_dreq_prepare ( struct dix_req *  req, struct m0_dix *  dix, struct m0_op_idx *  oi  )

static

Definition at line 1108 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_get()

static int dix_get ( struct m0_op_idx *  oi )

static

Definition at line 1373 of file idx_dix.c.

Here is the call graph for this function:

dix_get_ast()

static void dix_get_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 1138 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_get_reply_copy()

static void dix_get_reply_copy ( struct m0_dix_req *  dreq, int32_t *  rcs, struct m0_bufvec *  bvec  )

static

Definition at line 747 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_iname_args_are_valid()

static bool dix_iname_args_are_valid ( const struct m0_op_idx *  oi )

static

Definition at line 1040 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_index_create()

static int dix_index_create ( struct m0_op_idx *  oi )

static

Definition at line 1277 of file idx_dix.c.

Here is the call graph for this function:

dix_index_create_ast()

static void dix_index_create_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 1019 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_index_delete()

static int dix_index_delete ( struct m0_op_idx *  oi )

static

Definition at line 1297 of file idx_dix.c.

Here is the call graph for this function:

dix_index_delete_ast()

static void dix_index_delete_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 1048 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_index_list()

static int dix_index_list ( struct m0_op_idx *  oi )

static

Definition at line 1340 of file idx_dix.c.

Here is the call graph for this function:

dix_index_list_ast()

static void dix_index_list_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 1091 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_index_lookup()

static int dix_index_lookup ( struct m0_op_idx *  oi )

static

Definition at line 1317 of file idx_dix.c.

Here is the call graph for this function:

dix_index_lookup_ast()

static void dix_index_lookup_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 1068 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_inst()

static struct dix_inst* dix_inst ( const struct m0_op_idx *  oi )

static

Definition at line 170 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_list_reply_copy()

static int dix_list_reply_copy ( struct m0_dix_meta_req *  req, int32_t *  rcs, struct m0_bufvec *  bvec  )

static

Definition at line 721 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_meta_req_clink_cb()

static bool dix_meta_req_clink_cb ( struct m0_clink *  cl )

static

Definition at line 802 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_mreq_create()

static int dix_mreq_create ( struct m0_op_idx *  oi, struct dix_req **  out  )

static

Definition at line 602 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_next()

static int dix_next ( struct m0_op_idx *  oi )

static

Definition at line 1402 of file idx_dix.c.

Here is the call graph for this function:

dix_next_ast()

static void dix_next_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Todo:

Currently there is no way to pass several starting keys along with number of consecutive records for each key through m0_idx_op().

Definition at line 1173 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_next_reply_copy()

static void dix_next_reply_copy ( struct m0_dix_req *  req, int32_t *  rcs, struct m0_bufvec *  keys, struct m0_bufvec *  vals  )

static

Definition at line 770 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_put()

static int dix_put ( struct m0_op_idx *  oi )

static

Definition at line 1354 of file idx_dix.c.

Here is the call graph for this function:

dix_put_ast()

static void dix_put_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 1118 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_req_create()

static int dix_req_create ( struct m0_op_idx *  oi, struct dix_req **  out  )

static

Definition at line 638 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_req_destroy()

static void dix_req_destroy ( struct dix_req *  req )

static

Definition at line 673 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_req_exec()

static void dix_req_exec ( struct dix_req *  req, void(*)(struct m0_sm_group *grp, struct m0_sm_ast *ast)  exec_fn  )

static

Definition at line 994 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_req_immed_failure()

static void dix_req_immed_failure ( struct dix_req *  req, int  rc  )

static

Definition at line 985 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_root_idx_pver()

static int dix_root_idx_pver ( struct m0_client *  m0c, struct m0_fid *  out  )

static

Definition at line 1430 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_set_cas_flags()

static uint32_t dix_set_cas_flags ( struct m0_op_idx *  oi )

static

Definition at line 1005 of file idx_dix.c.

Here is the caller graph for this function:

dix_set_idx_flags()

static void dix_set_idx_flags ( struct m0_op_idx *  oi )

static

Definition at line 1264 of file idx_dix.c.

Here is the caller graph for this function:

dix_sync_record_update()

static void dix_sync_record_update ( struct m0_dix_req *  dreq, struct m0_rpc_session *  rpc_session, struct m0_be_tx_remid *  remid  )

static

Definition at line 149 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dixreq_clink_cb()

static bool dixreq_clink_cb ( struct m0_clink *  cl )

static

Definition at line 929 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dixreq_clink_dtx_cb()

static bool dixreq_clink_dtx_cb ( struct m0_clink *  cl )

static

Definition at line 874 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dixreq_completed_ast()

static void dixreq_completed_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 690 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dixreq_completed_post()

static void dixreq_completed_post ( struct dix_req *  req, int  rc  )

static

Definition at line 709 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dixreq_executed_post()

static void dixreq_executed_post ( struct dix_req *  req, int  rc  )

static

Definition at line 852 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dixreq_stable_ast()

static void dixreq_stable_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 822 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dixreq_stable_post()

static void dixreq_stable_post ( struct dix_req *  req, int  rc  )

static

Definition at line 836 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ent_dix_inst()

M0_INTERNAL struct dix_inst* ent_dix_inst

(

const struct m0_entity *

ent

)

Definition at line 183 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ent_dixc()

M0_INTERNAL struct m0_dix_cli* ent_dixc

(

const struct m0_entity *

ent

)

Definition at line 191 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

idx_dix_fini()

static int idx_dix_fini ( void *  svc )

static

Definition at line 1533 of file idx_dix.c.

Here is the call graph for this function:

idx_dix_init()

static int idx_dix_init ( void *  svc )

static

Definition at line 1505 of file idx_dix.c.

Here is the call graph for this function:

idx_is_distributed()

static bool idx_is_distributed ( const struct m0_op_idx *  oi )

static

Definition at line 98 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

idx_op_cancel_ast()

static void idx_op_cancel_ast ( struct m0_sm_group *  grp, struct m0_sm_ast *  ast  )

static

Definition at line 1214 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

idx_sync_record_update()

static void idx_sync_record_update ( struct m0_op *  op, struct m0_rpc_session *  rpc_session, struct m0_be_tx_remid *  remid  )

static

Definition at line 107 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

m0__idx_cancel()

M0_INTERNAL int m0__idx_cancel

(

struct m0_op_idx *

oi

)

Cancels fops sent during dix index operation

Parameters

op	idx to be cancelled

Returns

0 if success ot an error code otherwise

Definition at line 1235 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

m0_idx_dix_register()

M0_INTERNAL void m0_idx_dix_register

(

void

)

Definition at line 1553 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ol_dixc()

M0_INTERNAL struct m0_dix_cli* ol_dixc

(

const struct m0_op_layout *

ol

)

Definition at line 196 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

op_dixc()

static struct m0_dix_cli* op_dixc ( const struct m0_op_idx *  oi )

static

Definition at line 178 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

svc_find()

static struct m0_reqh_service_ctx* svc_find ( const struct m0_op_idx *  oi )

static

Todo:

Currently, the implementation of non-distributed indices is very similar to the distributed indices implementation. This makes bug fixing more difficult: every error has to be fixed twice. To solve this issue the implementation should be generalised for both cases in this file. A non-distributed index should be treated as a special type of distributed index (with 1 component catalogue).

Definition at line 212 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

to_dix_map()

static void to_dix_map ( const struct m0_op *  op, const struct m0_dix_req *  req  )

static

Definition at line 630 of file idx_dix.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

dix_query_ops

struct m0_idx_query_ops dix_query_ops

static

Initial value:

= {
        .iqo_namei_create = dix_index_create,
        .iqo_namei_delete = dix_index_delete,
        .iqo_namei_lookup = dix_index_lookup,
        .iqo_namei_list   = dix_index_list,

        .iqo_get          = dix_get,
        .iqo_put          = dix_put,
        .iqo_del          = dix_del,
        .iqo_next         = dix_next,
}

Definition at line 1414 of file idx_dix.c.

dix_svc_ops

struct m0_idx_service_ops dix_svc_ops

static

Initial value:

= {
        .iso_init = idx_dix_init,
        .iso_fini = idx_dix_fini
}

Definition at line 1548 of file idx_dix.c.