#include "lib/trace.h"
#include "lib/memory.h"
#include "lib/finject.h"
#include "layout/pdclust.h"
#include "layout/linear_enum.h"
#include "pool/pool.h"
#include "rpc/rpclib.h"
#include "conf/helpers.h"
#include "cas/client.h"
#include "dix/imask.h"
#include "dix/layout.h"
#include "dix/meta.h"
#include "dix/client.h"
#include "dix/fid_convert.h"
#include "ut/ut.h"
#include "ut/misc.h"

Include dependency graph for client_ut.c:

Data Structures
struct	cl_ctx

struct	dix_rep_arr

struct	dix_rep

Macros
#define	M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DIX

#define	SERVER_LOG_FILE_NAME "dix_ut.errlog"

#define	DFID(x, y) M0_FID_TINIT('x', (x), (y))

#define	BYTES(bit) ((bit + 7) / 8)

Enumerations
enum	{ DIX_M0T1FS_LAYOUT_P = 9, DIX_M0T1FS_LAYOUT_N = 1, DIX_M0T1FS_LAYOUT_K = 3, DIX_M0T1FS_LAYOUT_S = 3 }

enum	{ COUNT = 10, COUNT_INDEX = 3 }

enum	{ MAX_RPCS_IN_FLIGHT = 10, RECV_QUEUE_LEN = 10 }

enum	ut_dix_req_type { REQ_CREATE, REQ_DELETE, REQ_LOOKUP, REQ_NEXT, REQ_GET, REQ_PUT, REQ_DEL }

enum	ut_pg_unit { PG_UNIT_DATA, PG_UNIT_PARITY0, PG_UNIT_PARITY1, PG_UNIT_SPARE0, PG_UNIT_SPARE1 }

enum	{ CASE_1, CASE_2, CASE_3, CASE_4 }

Functions
void	imask (void)

static char	get_bit (void *buffer, m0_bcount_t pos)

void	imask_apply (void)

static void	imask_empty (void)

static void	imask_infini (void)

static void	imask_short (void)

static void	imask_invalid (void)

static void	layout_check (struct m0_dix_linst *dli)

static void	layout_create (struct m0_layout_domain domain, struct m0_pool_version pver)

void	pdclust_map (void)

void	meta_val_encdec (void)

void	meta_val_encdec_n (void)

void	layout_encdec (void)

static uint64_t	dix_key (uint32_t seq_num)

static uint64_t	dix_val (uint32_t seq_num)

static void	dix__vals_check (struct dix_rep_arr *rep, uint32_t start_key, uint32_t first_val, uint32_t last_val)

static void	dix_vals_check (struct dix_rep_arr *rep, uint32_t count)

static void	dix_index_init (struct m0_dix *index, uint32_t id)

static void	dix_predictable_index_init (struct m0_dix *index, uint32_t id)

static void	dix_index_fini (struct m0_dix *index)

static void	dix__kv_alloc_and_fill (struct m0_bufvec keys, struct m0_bufvec vals, uint32_t first, uint32_t last)

static void	dix_kv_alloc_and_fill (struct m0_bufvec keys, struct m0_bufvec vals, uint32_t count)

static void	dix_kv_destroy (struct m0_bufvec keys, struct m0_bufvec vals)

static void	dix_rep_free (struct dix_rep_arr *rep)

static struct m0_pooldev *	dix_pm_disk_find (struct m0_poolmach *pm, uint32_t sdev_idx)

static void	dix_pm_disk_state_set (struct m0_poolmach *pm, uint32_t sdev_idx, enum m0_pool_nd_state state)

static struct m0_poolmach *	dix_srv_poolmach (void)

static enum m0_pool_nd_state	dix_disk_state (uint32_t sdev_idx)

static void	dix_disk_state_set (uint32_t sdev_idx, enum m0_pool_nd_state state)

static void	dix_disk_failure_set (uint32_t sdev_idx, enum m0_pool_nd_state state)

static void	dix_disk_online_set (uint32_t sdev_idx)

static void	dix_predictable_sdev_ids_fill (struct m0_dix *index)

static uint32_t	dix_sdev_id (enum ut_pg_unit unit)

static void	dix_cctg_id_fill (struct m0_dix index, uint32_t sdev_idx, struct m0_cas_id cctg_id)

static struct m0_rpc_session *	cctg_rpc_sess (uint32_t sdev_idx)

static int	dix_cctg_records_del (struct m0_dix index, struct m0_bufvec keys, uint32_t sdev_idx)

static void	dix_cctg_records_put (struct m0_dix index, struct m0_bufvec keys, struct m0_bufvec *vals, uint32_t sdev_idx)

static bool	dix_cctg_has_replica (struct m0_dix index, struct m0_bufvec keys, struct m0_bufvec *vals, uint32_t sdev_idx)

static void	dix_records_erase (struct m0_dix index, struct m0_bufvec keys)

static bool	dix_rec_is_deleted (struct m0_dix index, struct m0_bufvec keys)

static int	dix_client_init (struct cl_ctx cctx, const char cl_ep_addr, const char srv_ep_addr, const char dbname, struct m0_net_xprt *xprt)

static void	dix_client_fini (struct cl_ctx *cctx)

static void	dixc_ut_init (struct m0_rpc_server_ctx sctx, struct cl_ctx cctx)

static void	dixc_ut_fini (struct m0_rpc_server_ctx sctx, struct cl_ctx cctx)

static int	ut_pver_find (struct m0_reqh reqh, struct m0_fid out)

static void	ut_service_init (void)

static void	ut_service_fini (void)

static void	dix_meta_create (void)

static int	dix_common_idx_flagged_op (const struct m0_dix *indices, uint32_t indices_nr, enum ut_dix_req_type type, uint32_t flags)

static int	dix_common_idx_op (const struct m0_dix *indices, uint32_t indices_nr, enum ut_dix_req_type type)

static int	dix_common_rec_op (const struct m0_dix index, const struct m0_bufvec keys, struct m0_bufvec vals, const uint32_t recs_nr, uint32_t flags, struct dix_rep_arr *rep, enum ut_dix_req_type type)

static int	dix_ut_put (const struct m0_dix index, const struct m0_bufvec keys, struct m0_bufvec vals, uint32_t flags, struct dix_rep_arr rep)

static int	dix_ut_get (const struct m0_dix index, const struct m0_bufvec keys, struct dix_rep_arr *rep)

static int	dix_ut_del (const struct m0_dix index, const struct m0_bufvec keys, struct dix_rep_arr *rep)

static int	dix_ut_next (const struct m0_dix index, const struct m0_bufvec start_keys, const uint32_t recs_nr, uint32_t flags, struct dix_rep_arr rep)

static void	dix_index_create_and_fill (const struct m0_dix index, const struct m0_bufvec keys, struct m0_bufvec *vals, uint32_t flags)

static void	dix_create (void)

static void	dix_create_crow (void)

static void	dix_create_dgmode (void)

static void	dix_delete (void)

static void	dix_delete_crow (void)

static void	dix_delete_dgmode (void)

static int	dix_list_op (const struct m0_fid start_fid, uint32_t indices_nr, struct m0_fid out_fids, uint32_t *out_fids_nr)

static void	dix_list (void)

static void	dix_cctgs_lookup (void)

static void	dix_put (void)

static void	dix_put_overwrite (void)

static void	dix_put_crow (void)

static void	dix_put_dgmode (void)

static void	dix_get (void)

static void	dix_dgmode_disks_prep (enum ut_pg_unit unit1, enum m0_pool_nd_state state1, enum ut_pg_unit unit2, enum m0_pool_nd_state state2, struct m0_dix index, struct m0_bufvec keys, struct m0_bufvec *vals)

static void	dix_dgmode_disks_unprep (enum ut_pg_unit unit1, enum m0_pool_nd_state state1, enum ut_pg_unit unit2, enum m0_pool_nd_state state2, struct m0_dix index, struct m0_bufvec keys, struct m0_bufvec *vals)

static void	dix_get_dgmode (void)

static void	dix_get_resend (void)

static void	dix_next (void)

static void	dix_next_crow (void)

static void	dix_next_dgmode (void)

static void	dix_del (void)

static void	dix_records_restore (struct m0_dix index, struct m0_bufvec keys, struct m0_bufvec *vals)

static void	dix_del_dgmode (void)

static void	dix_null_value (void)

static void	local_failures (void)

static void	keys_alloc (struct m0_bufvec cas_reps, struct m0_bufvec dix_reps)

static void	crep_val_set (struct m0_bufvec *reps, uint32_t idx, uint64_t val)

static void	drep_val_set (struct m0_bufvec *reps, uint32_t idx, uint64_t val)

static int	case_1_data (struct m0_bufvec cas_reps, struct m0_bufvec dix_reps, uint32_t *recs_nr, struct m0_bufvec start_keys, uint32_t *ctx_nr)

static int	case_2_data (struct m0_bufvec cas_reps, struct m0_bufvec dix_reps, uint32_t *recs_nr, struct m0_bufvec start_keys, uint32_t *ctx_nr)

static int	case_3_data (struct m0_bufvec cas_reps, struct m0_bufvec dix_reps, uint32_t *recs_nr, struct m0_bufvec start_keys, uint32_t *ctx_nr)

static int	case_4_data (struct m0_bufvec cas_reps, struct m0_bufvec dix_reps, uint32_t *recs_nr, struct m0_bufvec start_keys, uint32_t *ctx_nr)

static int	dix_rep_cmp (struct m0_dix_next_reply a, struct m0_dix_next_reply b)

static void	case_data_free (struct m0_bufvec cas_reps, struct m0_bufvec dix_reps, uint32_t recs_nr, struct m0_bufvec start_keys)

static void	results_check (struct m0_dix_req req, struct m0_bufvec dix_reps)

void	next_merge (void)

static void	server_is_down (void)

Variables
static char *	dix_startup_cmd []

static const char *	cdbnames [] = { "dix1" }

static const char *	cl_ep_addrs [] = { "0@lo:12345:34:2" }

static const char *	srv_ep_addrs [] = { "0@lo:12345:34:1" }

static struct cl_ctx	dix_ut_cctx

static struct m0_rpc_server_ctx	dix_ut_sctx

static const char *	ut_profile = "<0x7000000000000001:0>"

static int(*	cases [])(struct m0_bufvec cas_reps, struct m0_bufvec dix_reps, uint32_t *recs_nr, struct m0_bufvec start_keys, uint32_t *ctx_nr)

struct m0_ut_suite	dix_client_ut

Macro Definition Documentation

◆ BYTES

#define BYTES ( bit ) ((bit + 7) / 8)

Definition at line 163 of file client_ut.c.

◆ DFID

#define DFID	(	x,
		y
	)	M0_FID_TINIT('x', (x), (y))

Definition at line 135 of file client_ut.c.

◆ M0_TRACE_SUBSYSTEM

#define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DIX

Definition at line 23 of file client_ut.c.

◆ SERVER_LOG_FILE_NAME

#define SERVER_LOG_FILE_NAME "dix_ut.errlog"

Definition at line 110 of file client_ut.c.

Enumeration Type Documentation

◆ anonymous enum

anonymous enum

Enumerator
DIX_M0T1FS_LAYOUT_P
DIX_M0T1FS_LAYOUT_N
DIX_M0T1FS_LAYOUT_K
DIX_M0T1FS_LAYOUT_S

Definition at line 41 of file client_ut.c.

◆ anonymous enum

anonymous enum

Enumerator
COUNT
COUNT_INDEX

Definition at line 48 of file client_ut.c.

◆ anonymous enum

anonymous enum

Enumerator
MAX_RPCS_IN_FLIGHT
RECV_QUEUE_LEN

Definition at line 53 of file client_ut.c.

◆ anonymous enum

anonymous enum

Enumerator
CASE_1
CASE_2
CASE_3
CASE_4

Definition at line 2550 of file client_ut.c.

◆ ut_dix_req_type

enum ut_dix_req_type

Enumerator
REQ_CREATE
REQ_DELETE
REQ_LOOKUP
REQ_NEXT
REQ_GET
REQ_PUT
REQ_DEL

Definition at line 63 of file client_ut.c.

◆ ut_pg_unit

enum ut_pg_unit

Enumerator
PG_UNIT_DATA
PG_UNIT_PARITY0
PG_UNIT_PARITY1
PG_UNIT_SPARE0
PG_UNIT_SPARE1

Definition at line 73 of file client_ut.c.

Function Documentation

◆ case_1_data()

static int case_1_data	(	struct m0_bufvec *	cas_reps,
		struct m0_bufvec *	dix_reps,
		uint32_t **	recs_nr,
		struct m0_bufvec *	start_keys,
		uint32_t *	ctx_nr
	)

static

Definition at line 2620 of file client_ut.c.

Here is the call graph for this function:

◆ case_2_data()

static int case_2_data	(	struct m0_bufvec *	cas_reps,
		struct m0_bufvec *	dix_reps,
		uint32_t **	recs_nr,
		struct m0_bufvec *	start_keys,
		uint32_t *	ctx_nr
	)

static

Definition at line 2724 of file client_ut.c.

Here is the call graph for this function:

◆ case_3_data()

static int case_3_data	(	struct m0_bufvec *	cas_reps,
		struct m0_bufvec *	dix_reps,
		uint32_t **	recs_nr,
		struct m0_bufvec *	start_keys,
		uint32_t *	ctx_nr
	)

static

Definition at line 2831 of file client_ut.c.

Here is the call graph for this function:

◆ case_4_data()

static int case_4_data	(	struct m0_bufvec *	cas_reps,
		struct m0_bufvec *	dix_reps,
		uint32_t **	recs_nr,
		struct m0_bufvec *	start_keys,
		uint32_t *	ctx_nr
	)

static

Definition at line 2932 of file client_ut.c.

Here is the call graph for this function:

◆ case_data_free()

static void case_data_free	(	struct m0_bufvec *	cas_reps,
		struct m0_bufvec *	dix_reps,
		uint32_t *	recs_nr,
		struct m0_bufvec *	start_keys
	)

static

Definition at line 3027 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ cctg_rpc_sess()

static struct m0_rpc_session* cctg_rpc_sess ( uint32_t sdev_idx )

static

Definition at line 873 of file client_ut.c.

Here is the caller graph for this function:

◆ crep_val_set()

static void crep_val_set	(	struct m0_bufvec *	reps,
		uint32_t	idx,
		uint64_t	val
	)

static

Definition at line 2592 of file client_ut.c.

Here is the caller graph for this function:

◆ dix__kv_alloc_and_fill()

static void dix__kv_alloc_and_fill	(	struct m0_bufvec *	keys,
		struct m0_bufvec *	vals,
		uint32_t	first,
		uint32_t	last
	)

static

Definition at line 645 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix__vals_check()

static void dix__vals_check	(	struct dix_rep_arr *	rep,
		uint32_t	start_key,
		uint32_t	first_val,
		uint32_t	last_val
	)

static

Definition at line 586 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_cctg_has_replica()

static bool dix_cctg_has_replica	(	struct m0_dix *	index,
		struct m0_bufvec *	keys,
		struct m0_bufvec *	vals,
		uint32_t	sdev_idx
	)

static

Definition at line 952 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_cctg_id_fill()

static void dix_cctg_id_fill	(	struct m0_dix *	index,
		uint32_t	sdev_idx,
		struct m0_cas_id *	cctg_id
	)

static

Definition at line 859 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_cctg_records_del()

static int dix_cctg_records_del	(	struct m0_dix *	index,
		struct m0_bufvec *	keys,
		uint32_t	sdev_idx
	)

static

Definition at line 883 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_cctg_records_put()

static void dix_cctg_records_put	(	struct m0_dix *	index,
		struct m0_bufvec *	keys,
		struct m0_bufvec *	vals,
		uint32_t	sdev_idx
	)

static

Definition at line 918 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_cctgs_lookup()

static void dix_cctgs_lookup ( void )

static

Definition at line 1674 of file client_ut.c.

Here is the call graph for this function:

◆ dix_client_fini()

static void dix_client_fini ( struct cl_ctx * cctx )

static

Definition at line 1102 of file client_ut.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 cl_ctx *	cctx,
		const char *	cl_ep_addr,
		const char *	srv_ep_addr,
		const char *	dbname,
		struct m0_net_xprt *	xprt
	)

static

Definition at line 1019 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_common_idx_flagged_op()

static int dix_common_idx_flagged_op	(	const struct m0_dix *	indices,
		uint32_t	indices_nr,
		enum ut_dix_req_type	type,
		uint32_t	flags
	)

static

Definition at line 1231 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_common_idx_op()

static int dix_common_idx_op	(	const struct m0_dix *	indices,
		uint32_t	indices_nr,
		enum ut_dix_req_type	type
	)

static

Definition at line 1271 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_common_rec_op()

static int dix_common_rec_op	(	const struct m0_dix *	index,
		const struct m0_bufvec *	keys,
		struct m0_bufvec *	vals,
		const uint32_t *	recs_nr,
		uint32_t	flags,
		struct dix_rep_arr *	rep,
		enum ut_dix_req_type	type
	)

static

Definition at line 1277 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_create()

static void dix_create ( void )

static

Definition at line 1438 of file client_ut.c.

Here is the call graph for this function:

◆ dix_create_crow()

static void dix_create_crow ( void )

static

Definition at line 1455 of file client_ut.c.

Here is the call graph for this function:

◆ dix_create_dgmode()

static void dix_create_dgmode ( void )

static

Definition at line 1473 of file client_ut.c.

Here is the call graph for this function:

◆ dix_del()

static void dix_del ( void )

static

Definition at line 2297 of file client_ut.c.

Here is the call graph for this function:

◆ dix_del_dgmode()

static void dix_del_dgmode ( void )

static

Definition at line 2347 of file client_ut.c.

Here is the call graph for this function:

◆ dix_delete()

static void dix_delete ( void )

static

Definition at line 1514 of file client_ut.c.

Here is the call graph for this function:

◆ dix_delete_crow()

static void dix_delete_crow ( void )

static

Definition at line 1533 of file client_ut.c.

Here is the call graph for this function:

◆ dix_delete_dgmode()

static void dix_delete_dgmode ( void )

static

Definition at line 1573 of file client_ut.c.

Here is the call graph for this function:

◆ dix_dgmode_disks_prep()

static void dix_dgmode_disks_prep	(	enum ut_pg_unit	unit1,
		enum m0_pool_nd_state	state1,
		enum ut_pg_unit	unit2,
		enum m0_pool_nd_state	state2,
		struct m0_dix *	index,
		struct m0_bufvec *	keys,
		struct m0_bufvec *	vals
	)

static

Definition at line 1932 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_dgmode_disks_unprep()

static void dix_dgmode_disks_unprep	(	enum ut_pg_unit	unit1,
		enum m0_pool_nd_state	state1,
		enum ut_pg_unit	unit2,
		enum m0_pool_nd_state	state2,
		struct m0_dix *	index,
		struct m0_bufvec *	keys,
		struct m0_bufvec *	vals
	)

static

Definition at line 1973 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_disk_failure_set()

static void dix_disk_failure_set	(	uint32_t	sdev_idx,
		enum m0_pool_nd_state	state
	)

static

Definition at line 756 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_disk_online_set()

static void dix_disk_online_set ( uint32_t sdev_idx )

static

Definition at line 779 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_disk_state()

static enum m0_pool_nd_state dix_disk_state ( uint32_t sdev_idx )

static

Definition at line 730 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_disk_state_set()

static void dix_disk_state_set	(	uint32_t	sdev_idx,
		enum m0_pool_nd_state	state
	)

static

Definition at line 745 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_get()

static void dix_get ( void )

static

Definition at line 1897 of file client_ut.c.

Here is the call graph for this function:

◆ dix_get_dgmode()

static void dix_get_dgmode ( void )

static

Definition at line 2012 of file client_ut.c.

Here is the call graph for this function:

◆ dix_get_resend()

static void dix_get_resend ( void )

static

Definition at line 2089 of file client_ut.c.

Here is the call graph for this function:

◆ dix_index_create_and_fill()

static void dix_index_create_and_fill	(	const struct m0_dix *	index,
		const struct m0_bufvec *	keys,
		struct m0_bufvec *	vals,
		uint32_t	flags
	)

static

Definition at line 1420 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_index_fini()

static void dix_index_fini ( struct m0_dix * index )

static

Definition at line 640 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_index_init()

static void dix_index_init	(	struct m0_dix *	index,
		uint32_t	id
	)

static

Definition at line 611 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_key()

static uint64_t dix_key ( uint32_t seq_num )

static

Definition at line 576 of file client_ut.c.

Here is the caller graph for this function:

◆ dix_kv_alloc_and_fill()

static void dix_kv_alloc_and_fill	(	struct m0_bufvec *	keys,
		struct m0_bufvec *	vals,
		uint32_t	count
	)

static

Definition at line 664 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_kv_destroy()

static void dix_kv_destroy	(	struct m0_bufvec *	keys,
		struct m0_bufvec *	vals
	)

static

Definition at line 671 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_list()

static void dix_list ( void )

static

Definition at line 1641 of file client_ut.c.

Here is the call graph for this function:

◆ dix_list_op()

static int dix_list_op	(	const struct m0_fid *	start_fid,
		uint32_t	indices_nr,
		struct m0_fid *	out_fids,
		uint32_t *	out_fids_nr
	)

static

Definition at line 1611 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_meta_create()

static void dix_meta_create ( void )

static

Definition at line 1225 of file client_ut.c.

Here is the call graph for this function:

◆ dix_next()

static void dix_next ( void )

static

Definition at line 2127 of file client_ut.c.

Here is the call graph for this function:

◆ dix_next_crow()

static void dix_next_crow ( void )

static

Definition at line 2184 of file client_ut.c.

Here is the call graph for this function:

◆ dix_next_dgmode()

static void dix_next_dgmode ( void )

static

Definition at line 2237 of file client_ut.c.

Here is the call graph for this function:

◆ dix_null_value()

static void dix_null_value ( void )

static

Definition at line 2454 of file client_ut.c.

Here is the call graph for this function:

◆ dix_pm_disk_find()

static struct m0_pooldev* dix_pm_disk_find	(	struct m0_poolmach *	pm,
		uint32_t	sdev_idx
	)

static

Definition at line 691 of file client_ut.c.

Here is the caller graph for this function:

◆ dix_pm_disk_state_set()

static void dix_pm_disk_state_set	(	struct m0_poolmach *	pm,
		uint32_t	sdev_idx,
		enum m0_pool_nd_state	state
	)

static

Definition at line 704 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_predictable_index_init()

static void dix_predictable_index_init	(	struct m0_dix *	index,
		uint32_t	id
	)

static

Definition at line 624 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_predictable_sdev_ids_fill()

static void dix_predictable_sdev_ids_fill ( struct m0_dix * index )

static

Definition at line 799 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_put()

static void dix_put ( void )

static

Definition at line 1710 of file client_ut.c.

Here is the call graph for this function:

◆ dix_put_crow()

static void dix_put_crow ( void )

static

Definition at line 1790 of file client_ut.c.

Here is the call graph for this function:

◆ dix_put_dgmode()

static void dix_put_dgmode ( void )

static

Definition at line 1817 of file client_ut.c.

Here is the call graph for this function:

◆ dix_put_overwrite()

static void dix_put_overwrite ( void )

static

Definition at line 1733 of file client_ut.c.

Here is the call graph for this function:

◆ dix_rec_is_deleted()

static bool dix_rec_is_deleted	(	struct m0_dix *	index,
		struct m0_bufvec *	keys
	)

static

Definition at line 1007 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_records_erase()

static void dix_records_erase	(	struct m0_dix *	index,
		struct m0_bufvec *	keys
	)

static

Definition at line 998 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_records_restore()

static void dix_records_restore	(	struct m0_dix *	index,
		struct m0_bufvec *	keys,
		struct m0_bufvec *	vals
	)

static

Definition at line 2333 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_rep_cmp()

static int dix_rep_cmp	(	struct m0_dix_next_reply *	a,
		struct m0_dix_next_reply *	b
	)

static

Definition at line 3014 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_rep_free()

static void dix_rep_free ( struct dix_rep_arr * rep )

static

Definition at line 678 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_sdev_id()

static uint32_t dix_sdev_id ( enum ut_pg_unit unit )

static

Definition at line 835 of file client_ut.c.

Here is the caller graph for this function:

◆ dix_srv_poolmach()

static struct m0_poolmach* dix_srv_poolmach ( void )

static

Definition at line 719 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_ut_del()

static int dix_ut_del	(	const struct m0_dix *	index,
		const struct m0_bufvec *	keys,
		struct dix_rep_arr *	rep
	)

static

Definition at line 1403 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_ut_get()

static int dix_ut_get	(	const struct m0_dix *	index,
		const struct m0_bufvec *	keys,
		struct dix_rep_arr *	rep
	)

static

Definition at line 1396 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_ut_next()

static int dix_ut_next	(	const struct m0_dix *	index,
		const struct m0_bufvec *	start_keys,
		const uint32_t *	recs_nr,
		uint32_t	flags,
		struct dix_rep_arr *	rep
	)

static

Definition at line 1410 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_ut_put()

static int dix_ut_put	(	const struct m0_dix *	index,
		const struct m0_bufvec *	keys,
		struct m0_bufvec *	vals,
		uint32_t	flags,
		struct dix_rep_arr *	rep
	)

static

Definition at line 1387 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dix_val()

static uint64_t dix_val ( uint32_t seq_num )

static

Definition at line 581 of file client_ut.c.

Here is the caller graph for this function:

◆ dix_vals_check()

static void dix_vals_check	(	struct dix_rep_arr *	rep,
		uint32_t	count
	)

static

Definition at line 606 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dixc_ut_fini()

static void dixc_ut_fini	(	struct m0_rpc_server_ctx *	sctx,
		struct cl_ctx *	cctx
	)

static

Definition at line 1145 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dixc_ut_init()

static void dixc_ut_init	(	struct m0_rpc_server_ctx *	sctx,
		struct cl_ctx *	cctx
	)

static

Definition at line 1128 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ drep_val_set()

static void drep_val_set	(	struct m0_bufvec *	reps,
		uint32_t	idx,
		uint64_t	val
	)

static

Definition at line 2601 of file client_ut.c.

Here is the caller graph for this function:

◆ get_bit()

static char get_bit	(	void *	buffer,
		m0_bcount_t	pos
	)

static

Definition at line 165 of file client_ut.c.

Here is the caller graph for this function:

◆ imask()

void imask ( void )

Definition at line 141 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ imask_apply()

void imask_apply ( void )

Definition at line 175 of file client_ut.c.

Here is the call graph for this function:

◆ imask_empty()

static void imask_empty ( void )

static

Definition at line 216 of file client_ut.c.

Here is the call graph for this function:

◆ imask_infini()

static void imask_infini ( void )

static

Definition at line 235 of file client_ut.c.

Here is the call graph for this function:

◆ imask_invalid()

static void imask_invalid ( void )

static

Definition at line 298 of file client_ut.c.

Here is the call graph for this function:

◆ imask_short()

static void imask_short ( void )

static

Definition at line 268 of file client_ut.c.

Here is the call graph for this function:

◆ keys_alloc()

static void keys_alloc	(	struct m0_bufvec *	cas_reps,
		struct m0_bufvec *	dix_reps
	)

static

Definition at line 2557 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ layout_check()

static void layout_check ( struct m0_dix_linst * dli )

static

Definition at line 321 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ layout_create()

static void layout_create	(	struct m0_layout_domain *	domain,
		struct m0_pool_version *	pver
	)

static

Definition at line 345 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ layout_encdec()

void layout_encdec ( void )

Definition at line 488 of file client_ut.c.

Here is the call graph for this function:

◆ local_failures()

static void local_failures ( void )

static

Definition at line 2520 of file client_ut.c.

Here is the call graph for this function:

◆ meta_val_encdec()

void meta_val_encdec ( void )

Definition at line 406 of file client_ut.c.

Here is the call graph for this function:

◆ meta_val_encdec_n()

void meta_val_encdec_n ( void )

Definition at line 443 of file client_ut.c.

Here is the call graph for this function:

◆ next_merge()

void next_merge ( void )

Definition at line 3094 of file client_ut.c.

Here is the call graph for this function:

◆ pdclust_map()

void pdclust_map ( void )

Definition at line 354 of file client_ut.c.

Here is the call graph for this function:

◆ results_check()

static void results_check	(	struct m0_dix_req *	req,
		struct m0_bufvec *	dix_reps
	)

static

Definition at line 3074 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ server_is_down()

static void server_is_down ( void )

static

Definition at line 3149 of file client_ut.c.

Here is the call graph for this function:

◆ ut_pver_find()

static int ut_pver_find	(	struct m0_reqh *	reqh,
		struct m0_fid *	out
	)

static

Definition at line 1152 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ut_service_fini()

static void ut_service_fini ( void )

static

Definition at line 1216 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ut_service_init()

static void ut_service_init ( void )

static

Definition at line 1170 of file client_ut.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

◆ cases

int(* cases[])(struct m0_bufvec *cas_reps, struct m0_bufvec *dix_reps, uint32_t **recs_nr, struct m0_bufvec *start_keys, uint32_t *ctx_nr)

static

Initial value:

= {
        [CASE_1] = case_1_data,
        [CASE_2] = case_2_data,
        [CASE_3] = case_3_data,
        [CASE_4] = case_4_data,
}

Definition at line 3063 of file client_ut.c.

◆ cdbnames

const char* cdbnames[] = { "dix1" }

static

Definition at line 123 of file client_ut.c.

◆ cl_ep_addrs

const char* cl_ep_addrs[] = { "0@lo:12345:34:2" }

static

Definition at line 124 of file client_ut.c.

◆ dix_client_ut

struct m0_ut_suite dix_client_ut

Definition at line 3164 of file client_ut.c.

◆ dix_startup_cmd

char* dix_startup_cmd[]

static

Initial value:

= {
        "m0d", "-T", "linux",
        "-D", "cs_sdb", "-S", "cs_stob",
        "-A", "linuxstob:cs_addb_stob",
        "-e", M0_NET_XPRT_PREFIX_DEFAULT":0@lo:12345:34:1",
        "-H", "0@lo:12345:34:1",
        "-w", "10", "-F",
        "-f", M0_UT_CONF_PROCESS,
        "-c", M0_SRC_PATH("dix/ut/conf.xc")
}

Definition at line 113 of file client_ut.c.

◆ dix_ut_cctx

struct cl_ctx dix_ut_cctx

static

Definition at line 127 of file client_ut.c.

◆ dix_ut_sctx

struct m0_rpc_server_ctx dix_ut_sctx

static

Initial value:

= {
                .rsx_argv             = dix_startup_cmd,
                .rsx_argc             = ARRAY_SIZE(dix_startup_cmd),
                .rsx_log_file_name    = SERVER_LOG_FILE_NAME
}

Definition at line 128 of file client_ut.c.

◆ srv_ep_addrs

const char* srv_ep_addrs[] = { "0@lo:12345:34:1" }

static

Definition at line 125 of file client_ut.c.

◆ ut_profile

const char* ut_profile = "<0x7000000000000001:0>"

static

Definition at line 134 of file client_ut.c.

Data Structures

Macros

Enumerations

Functions

Variables

Macro Definition Documentation

◆ BYTES

◆ DFID

◆ M0_TRACE_SUBSYSTEM

◆ SERVER_LOG_FILE_NAME

Enumeration Type Documentation

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ ut_dix_req_type

◆ ut_pg_unit

Function Documentation

◆ case_1_data()

◆ case_2_data()

◆ case_3_data()

◆ case_4_data()

◆ case_data_free()

◆ cctg_rpc_sess()

◆ crep_val_set()

◆ dix__kv_alloc_and_fill()

◆ dix__vals_check()

◆ dix_cctg_has_replica()

◆ dix_cctg_id_fill()

◆ dix_cctg_records_del()

◆ dix_cctg_records_put()

◆ dix_cctgs_lookup()

◆ dix_client_fini()

◆ dix_client_init()

◆ dix_common_idx_flagged_op()

◆ dix_common_idx_op()

◆ dix_common_rec_op()

◆ dix_create()

◆ dix_create_crow()

◆ dix_create_dgmode()

◆ dix_del()

◆ dix_del_dgmode()

◆ dix_delete()

◆ dix_delete_crow()

◆ dix_delete_dgmode()

◆ dix_dgmode_disks_prep()

◆ dix_dgmode_disks_unprep()

◆ dix_disk_failure_set()

◆ dix_disk_online_set()

◆ dix_disk_state()

◆ dix_disk_state_set()

◆ dix_get()

◆ dix_get_dgmode()

◆ dix_get_resend()

◆ dix_index_create_and_fill()

◆ dix_index_fini()

◆ dix_index_init()

◆ dix_key()

◆ dix_kv_alloc_and_fill()

◆ dix_kv_destroy()

◆ dix_list()

◆ dix_list_op()

◆ dix_meta_create()

◆ dix_next()

◆ dix_next_crow()

◆ dix_next_dgmode()

◆ dix_null_value()

◆ dix_pm_disk_find()

◆ dix_pm_disk_state_set()

◆ dix_predictable_index_init()

◆ dix_predictable_sdev_ids_fill()

◆ dix_put()

◆ dix_put_crow()

◆ dix_put_dgmode()

◆ dix_put_overwrite()

◆ dix_rec_is_deleted()

◆ dix_records_erase()

◆ dix_records_restore()

◆ dix_rep_cmp()

◆ dix_rep_free()