#include "ut/ut.h"
#include "lib/misc.h"
#include "lib/finject.h"
#include "lib/semaphore.h"
#include "lib/byteorder.h"
#include "fop/fop.h"
#include "reqh/reqh.h"
#include "reqh/reqh_service.h"
#include "be/ut/helper.h"
#include "cas/cas.h"
#include "cas/cas_xc.h"
#include "rpc/at.h"
#include "fdmi/fdmi.h"
#include "rpc/rpc_machine.h"

Include dependency graph for service_ut.c:

Data Structures
struct	meta_rec

struct	fopsem

struct	record

Macros
#define	M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_CAS

#define	IFID(x, y) M0_FID_TINIT('i', (x), (y))

#define	TFID(x, y) M0_FID_TINIT('T', (x), (y))

#define	CB(x) m0_byteorder_cpu_to_be64(x)

#define	BC(x) m0_byteorder_be64_to_cpu(x)

Enumerations
enum	{ N = 4096 }

enum	{ BSET = true, BUNSET = false, BANY = 2 }

enum	{ EMPTYVAL = 0, NOVAL = (uint64_t)-1 }

enum	{ INSERTS = 1500, MULTI_INS = 15 }

enum	{ BIG_ROWS_NUMBER = 2000, SMALL_ROWS_NUMBER = 257 }

Functions
static void	cb_done (struct m0_fom *fom)

static void	cb_fini (struct m0_fom *fom)

static int	cid_enc (struct m0_cas_id cid, struct m0_rpc_at_buf at_buf)

static void	rep_clear (void)

static int	at_inline_fill (struct m0_rpc_at_buf dst, struct m0_rpc_at_buf src)

static void	reqh_init (bool mkfs, bool use_small_credits)

static void	_init (bool mkfs, bool use_small_credits)

static void	init (void)

static void	service_stop (void)

static void	fini (void)

static void	reinit_nomkfs (void)

static void	init_fini (void)

static void	init_fail (void)

M0_INTERNAL int	m0_cas_module_init (void)

M0_INTERNAL void	m0_cas_module_fini (void)

static void	reinit (void)

static void	restart (void)

static void	fop_release (struct m0_ref *ref)

static void	fop_submit (struct m0_fop_type ft, const struct m0_fid index, struct m0_cas_rec *rec)

static void	meta_fop_submit (struct m0_fop_type fopt, struct meta_rec meta_recs, int meta_recs_num)

static bool	rec_check (const struct m0_cas_rec *rec, int rc, int key, int val)

static bool	rep_check (int recno, uint64_t rc, int key, int val)

static void	meta_cid_submit (struct m0_fop_type fopt, struct m0_cas_id cid)

static void	meta_fid_submit (struct m0_fop_type fopt, struct m0_fid fid)

static void	meta_lookup_none (void)

static void	meta_lookup_2none (void)

static void	meta_lookup_Nnone (void)

static void	create (void)

static void	cctg_create (void)

static void	cctg_create_lookup (void)

static void	cctg_create_delete (void)

static void	create_lookup (void)

static void	create_create (void)

static void	create_delete (void)

static void	recreate (void)

static void	meta_cur_1 (void)

static void	meta_cur_eot (void)

static void	meta_cur_0 (void)

static void	meta_cur_empty (void)

static void	meta_cur_none (void)

static void	meta_cur_all (void)

static void	meta_random (void)

static void	meta_invalid (void)

static void	index_op_rc (struct m0_fop_type ft, struct m0_fid index, uint64_t key, uint64_t val, uint64_t rc)

static void	index_op (struct m0_fop_type ft, struct m0_fid index, uint64_t key, uint64_t val)

static void	insert (void)

static void	insert_lookup (void)

static void	insert_delete (void)

static void	lookup_none (void)

static void	empty_value (void)

static void	insert_2 (void)

static void	delete_2 (void)

static void	insert_odd (struct m0_fid *index)

static void	lookup_all (struct m0_fid *index)

static void	lookup_N (void)

static void	lookup_restart (void)

static void	cur_N (void)

static void	meta_mt_thread (int idx)

static void	meta_mt (void)

static void	meta_insert_fail (void)

static void	meta_lookup_fail (void)

static void	meta_delete_fail (void)

static void	insert_fail (void)

static void	lookup_fail (void)

static void	delete_fail (void)

static void	multi_values_insert (struct record *recs, int recs_count)

static void	cur_fail (void)

static void	multi_values_lookup (struct record *recs, int recs_count)

static void	multi_values_delete (struct record *recs, int recs_count)

static void	multi_insert (void)

static void	multi_lookup (void)

static void	multi_delete (void)

static void	multi_insert_fail (void)

static void	multi_lookup_fail (void)

static void	multi_delete_fail (void)

static void	server_restart_nomkfs (void)

static void	multi_create_drop (void)

static void	create_insert_drop_with_fail (bool inject_fail)

static void	create_insert_drop ()

static void	create_insert_drop_fail ()

static void	init_cgc_fail_fini (void)

Variables
static struct m0_reqh	reqh

static struct m0_be_ut_backend	be

static struct m0_be_seg *	seg0

static struct m0_reqh_service *	cas

static struct m0_reqh_service *	fdmi

static struct m0_rpc_machine	rpc_machine

static struct m0_cas_rep	rep

static struct m0_cas_rec	repv [N]

static struct m0_fid	ifid = IFID(2, 3)

static bool	mt

void(*	cas__ut_cb_done )(struct m0_fom *fom)

void(*	cas__ut_cb_fini )(struct m0_fom *fom)

static struct m0_fop_type *	ft []

static struct m0_thread	t [8]

struct m0_ut_suite	cas_service_ut

Data Structures

Macros

Enumerations

Functions

Variables