#include "lib/list.h"
#include "motr/init.h"
#include "lib/memory.h"
#include "lib/misc.h"
#include "cob/cob.h"
#include "ioservice/io_fops.h"
#include "rpc/rpc.h"
#include "rpc/rpc_opcodes.h"
#include "lib/thread.h"

Include dependency graph for bulkio_common.h:

Data Structures
struct	bulkio_params

struct	thrd_arg

Macros
#define	__MOTR_IOSERVICE_ST_COMMON_H__

#define	IO_CLIENT_DBNAME "bulk_c_db"

#define	IO_SERVER_DBFILE "bulkio_st.db"

#define	IO_SERVER_LOGFILE "bulkio_st.log"

#define	IO_SERVER_STOBFILE "bulk_st_stob"

Enumerations
enum	IO_UT_VALUES { IO_FIDS_NR = 2, IO_SEGS_NR = 16, IO_SEG_SIZE = 4096, IO_SEQ_LEN = 8, IO_FOPS_NR = 16, IO_FID_SINGLE = 1, IO_FOP_SINGLE = 1, IO_XPRT_NR = 1, IO_CLIENT_SVC_ID = 2, IO_SERVER_SVC_ID = 1, IO_ADDR_LEN = 32, IO_STR_LEN = 16, IO_SEG_STEP = 64, IO_RPC_ITEM_TIMEOUT = 300, IO_SEG_START_OFFSET = IO_SEG_SIZE, IO_CLIENT_COBDOM_ID = 21, IO_SERVER_COBDOM_ID = 29, IO_RPC_MAX_IN_FLIGHT = 32 }

Functions
int	bulkio_client_start (struct bulkio_params bp, const char caddr, const char *saddr)

void	bulkio_client_stop (struct m0_rpc_client_ctx *cctx)

int	bulkio_server_start (struct bulkio_params bp, const char saddr)

void	bulkio_server_stop (struct m0_rpc_server_ctx *sctx)

void	bulkio_params_init (struct bulkio_params *bp)

void	bulkio_params_fini (struct bulkio_params *bp)

void	bulkio_test (struct bulkio_params *bp, int fids_nr, int fops_nr, int segs_nr)

int	m0_bufvec_alloc_aligned (struct m0_bufvec *bufvec, uint32_t num_segs, m0_bcount_t seg_size, unsigned shift)

int	io_fsync_send_fop (struct m0_be_tx_remid remid, struct thrd_arg t)

void	io_fops_rpc_submit (struct thrd_arg *t)

void	io_fops_destroy (struct bulkio_params *bp)

void	io_fops_create (struct bulkio_params *bp, enum M0_RPC_OPCODES op, int fids_nr, int fops_nr, int segs_nr)

void	cob_attr_default_fill (struct m0_cob_attr *attr)

Variables
static const struct m0_fid	CONF_PVER_FID = M0_FID_TINIT('v', 1, 24)

static const struct m0_fid	CONF_PVER_FID1 = M0_FID_TINIT('v', 1, 25)

static const struct m0_fid	CONF_PROFILE_FID = M0_FID_TINIT('p', 1, 0)

Macro Definition Documentation

◆ __MOTR_IOSERVICE_ST_COMMON_H__

#define __MOTR_IOSERVICE_ST_COMMON_H__

Definition at line 26 of file bulkio_common.h.

◆ IO_CLIENT_DBNAME

#define IO_CLIENT_DBNAME "bulk_c_db"

Definition at line 59 of file bulkio_common.h.

◆ IO_SERVER_DBFILE

#define IO_SERVER_DBFILE "bulkio_st.db"

Definition at line 60 of file bulkio_common.h.

◆ IO_SERVER_LOGFILE

#define IO_SERVER_LOGFILE "bulkio_st.log"

Definition at line 61 of file bulkio_common.h.

◆ IO_SERVER_STOBFILE

#define IO_SERVER_STOBFILE "bulk_st_stob"

Definition at line 62 of file bulkio_common.h.

Enumeration Type Documentation

◆ IO_UT_VALUES

enum IO_UT_VALUES

Enumerator
IO_FIDS_NR
IO_SEGS_NR
IO_SEG_SIZE
IO_SEQ_LEN
IO_FOPS_NR
IO_FID_SINGLE
IO_FOP_SINGLE
IO_XPRT_NR
IO_CLIENT_SVC_ID
IO_SERVER_SVC_ID
IO_ADDR_LEN
IO_STR_LEN
IO_SEG_STEP
IO_RPC_ITEM_TIMEOUT
IO_SEG_START_OFFSET
IO_CLIENT_COBDOM_ID
IO_SERVER_COBDOM_ID
IO_RPC_MAX_IN_FLIGHT

Definition at line 39 of file bulkio_common.h.

Function Documentation

◆ bulkio_client_start()

int bulkio_client_start	(	struct bulkio_params *	bp,
		const char *	caddr,
		const char *	saddr
	)

Definition at line 468 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ bulkio_client_stop()

void bulkio_client_stop ( struct m0_rpc_client_ctx * cctx )

Definition at line 505 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ bulkio_params_fini()

void bulkio_params_fini ( struct bulkio_params * bp )

Definition at line 437 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ bulkio_params_init()

void bulkio_params_init ( struct bulkio_params * bp )

Definition at line 381 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ bulkio_server_start()

int bulkio_server_start	(	struct bulkio_params *	bp,
		const char *	saddr
	)

Definition at line 82 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ bulkio_server_stop()

void bulkio_server_stop ( struct m0_rpc_server_ctx * sctx )

Definition at line 103 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ bulkio_test()

void bulkio_test	(	struct bulkio_params *	bp,
		int	fids_nr,
		int	fops_nr,
		int	segs_nr
	)

◆ cob_attr_default_fill()

void cob_attr_default_fill ( struct m0_cob_attr * attr )

Definition at line 517 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ io_fops_create()

void io_fops_create	(	struct bulkio_params *	bp,
		enum M0_RPC_OPCODES	op,
		int	fids_nr,
		int	fops_nr,
		int	segs_nr
	)

Definition at line 218 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ io_fops_destroy()

void io_fops_destroy ( struct bulkio_params * bp )

Definition at line 266 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ io_fops_rpc_submit()

void io_fops_rpc_submit ( struct thrd_arg * t )

Definition at line 336 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ io_fsync_send_fop()

int io_fsync_send_fop	(	struct m0_be_tx_remid *	remid,
		struct thrd_arg *	t
	)

Sends an fsync fop request through the session provided within an io thread args struct.

Parameters

remid	Remote ID of the transaction that is to be fsynced.
t	Bulkio parameters.

Returns: the rc included in the fsync fop reply.

Sends an fsync fop request to trigger the placing of a specific transaction.

Parameters

remid	remote id of the transaction to be fsync'ed.
t	structure containing the bulkio parameters for the operation. From those parameters only the network session is relevant to the function.

Returns: the rc included in the corresponding fsync fop reply.

Definition at line 289 of file bulkio_common.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

◆ CONF_PROFILE_FID

const struct m0_fid CONF_PROFILE_FID = M0_FID_TINIT('p', 1, 0)

static

Definition at line 66 of file bulkio_common.h.

◆ CONF_PVER_FID

const struct m0_fid CONF_PVER_FID = M0_FID_TINIT('v', 1, 24)

static

Definition at line 64 of file bulkio_common.h.

◆ CONF_PVER_FID1

const struct m0_fid CONF_PVER_FID1 = M0_FID_TINIT('v', 1, 25)

static

Definition at line 65 of file bulkio_common.h.

Data Structures

Macros

Enumerations

Functions

Variables

Macro Definition Documentation

◆ __MOTR_IOSERVICE_ST_COMMON_H__

◆ IO_CLIENT_DBNAME

◆ IO_SERVER_DBFILE

◆ IO_SERVER_LOGFILE

◆ IO_SERVER_STOBFILE

Enumeration Type Documentation

◆ IO_UT_VALUES

Function Documentation

◆ bulkio_client_start()

◆ bulkio_client_stop()

◆ bulkio_params_fini()

◆ bulkio_params_init()

◆ bulkio_server_start()

◆ bulkio_server_stop()

◆ bulkio_test()

◆ cob_attr_default_fill()

◆ io_fops_create()

◆ io_fops_destroy()

◆ io_fops_rpc_submit()

◆ io_fsync_send_fop()

Variable Documentation

◆ CONF_PROFILE_FID

◆ CONF_PVER_FID

◆ CONF_PVER_FID1