DIX copy machine Copy packet

Collaboration diagram for DIX copy machine Copy packet:

Functions
M0_INTERNAL int	m0_dix_cm_cp_sw_check (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_send_wait (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_repair_cp_send (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_rebalance_cp_send (struct m0_cm_cp *cp)
M0_INTERNAL struct m0_dix_cm_cp *	cp2dixcp (const struct m0_cm_cp *cp)
static struct m0_dix_cm *	cp2dixcm (struct m0_cm_cp *cp)
M0_INTERNAL bool	m0_dix_cm_cp_invariant (const struct m0_cm_cp *cp)
M0_INTERNAL uint64_t	m0_dix_cm_cp_home_loc_helper (const struct m0_cm_cp *cp)
M0_INTERNAL struct m0_cm_cp *	m0_dix_cm_cp_alloc (struct m0_cm *cm)
static void	dix_cm_cp_dtx_fini (struct m0_cm_cp *cp)
static int	dix_cm_cp_dtx_failure (struct m0_cm_cp *cp)
static int	dix_cm_cp_incoming_kv (struct m0_rpc_at_buf *ab_key, struct m0_rpc_at_buf *ab_val, struct m0_buf *key, struct m0_buf *val)
static void	dixcpx_to_dixcp (const struct m0_dix_cpx *dix_cpx, struct m0_dix_cm_cp *dix_cp)
static void	dix_cm_cp_reply_send (struct m0_cm_cp *cp, struct m0_fop_type *ft, int rc)
static int	dix_cm_fom_tx_wait (struct m0_fom *fom)
M0_INTERNAL int	m0_dix_cm_cp_init (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_fail (struct m0_cm_cp *cp, struct m0_fop_type *ft)
static int	dix_cm_repair_cp_fail (struct m0_cm_cp *cp)
static int	dix_cm_rebalance_cp_fail (struct m0_cm_cp *cp)
M0_INTERNAL void	m0_dix_cm_cp_complete (struct m0_cm_cp *cp)
M0_INTERNAL void	m0_dix_cm_cp_free (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_fini (struct m0_cm_cp *cp)
M0_INTERNAL void	m0_dix_cm_cp_tgt_info_fill (struct m0_dix_cm_cp *dix_cp, const struct m0_fid *cctg_fid)
M0_INTERNAL void	m0_dix_cm_cp_setup (struct m0_dix_cm_cp *dix_cp, const struct m0_fid *cctg_fid, uint64_t failed_unit_index)
M0_INTERNAL int	m0_dix_cm_cp_dup (struct m0_cm_cp *src, struct m0_cm_cp **dest)
M0_INTERNAL int	m0_dix_cm_cp_read (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_xform (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_write_pre (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_tx_open (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_write (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_tx_done (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_io_wait (struct m0_cm_cp *cp, struct m0_fop_type *ft)
static int	dix_cm_repair_cp_io_wait (struct m0_cm_cp *cp)
static int	dix_cm_rebalance_cp_io_wait (struct m0_cm_cp *cp)
static void	dix_cp_reply_received (struct m0_rpc_item *item)
static int	dixcp_to_dixcpx (struct m0_dix_cm_cp *dix_cp, struct m0_dix_cpx *dix_cpx)
static void	dix_cp_fop_release (struct m0_ref *ref)
M0_INTERNAL int	m0_dix_cm_cp_send (struct m0_cm_cp *cp, struct m0_fop_type *ft)
M0_INTERNAL int	m0_dix_cm_cp_recv_init (struct m0_cm_cp *cp)
M0_INTERNAL int	m0_dix_cm_cp_recv_wait (struct m0_cm_cp *cp)

Variables
struct m0_fop_type	m0_dix_repair_cpx_reply_fopt
struct m0_fop_type	m0_dix_rebalance_cpx_reply_fopt
M0_INTERNAL const struct m0_cm_cp_ops	m0_dix_cm_repair_cp_ops
M0_INTERNAL const struct m0_cm_cp_ops	m0_dix_cm_rebalance_cp_ops
static const struct m0_rpc_item_ops	dix_cp_item_ops
struct m0_fop_type	m0_dix_rebalance_cpx_fopt
struct m0_fop_type	m0_dix_repair_cpx_fopt

Detailed Description

Function Documentation

cp2dixcm()

static struct m0_dix_cm* cp2dixcm ( struct m0_cm_cp *  cp )

static

Definition at line 55 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

cp2dixcp()

M0_INTERNAL struct m0_dix_cm_cp* cp2dixcp

(

const struct m0_cm_cp *

cp

)

Returns DIX copy packet context by embedded context.

Parameters

cp	Base copy packet.

DIX CP context.

Definition at line 50 of file cp.c.

Here is the caller graph for this function:

dix_cm_cp_dtx_failure()

static int dix_cm_cp_dtx_failure ( struct m0_cm_cp *  cp )

static

Definition at line 108 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_cm_cp_dtx_fini()

static void dix_cm_cp_dtx_fini ( struct m0_cm_cp *  cp )

static

Definition at line 100 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_cm_cp_incoming_kv()

static int dix_cm_cp_incoming_kv ( struct m0_rpc_at_buf *  ab_key, struct m0_rpc_at_buf *  ab_val, struct m0_buf *  key, struct m0_buf *  val  )

static

Definition at line 117 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_cm_cp_reply_send()

static void dix_cm_cp_reply_send ( struct m0_cm_cp *  cp, struct m0_fop_type *  ft, int  rc  )

static

Definition at line 155 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_cm_fom_tx_wait()

static int dix_cm_fom_tx_wait ( struct m0_fom *  fom )

static

Definition at line 169 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_cm_rebalance_cp_fail()

static int dix_cm_rebalance_cp_fail ( struct m0_cm_cp *  cp )

static

Definition at line 254 of file cp.c.

Here is the call graph for this function:

dix_cm_rebalance_cp_io_wait()

static int dix_cm_rebalance_cp_io_wait ( struct m0_cm_cp *  cp )

static

Definition at line 520 of file cp.c.

Here is the call graph for this function:

dix_cm_repair_cp_fail()

static int dix_cm_repair_cp_fail ( struct m0_cm_cp *  cp )

static

Definition at line 249 of file cp.c.

Here is the call graph for this function:

dix_cm_repair_cp_io_wait()

static int dix_cm_repair_cp_io_wait ( struct m0_cm_cp *  cp )

static

Definition at line 515 of file cp.c.

Here is the call graph for this function:

dix_cp_fop_release()

static void dix_cp_fop_release ( struct m0_ref *  ref )

static

Definition at line 125 of file net.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dix_cp_reply_received()

static void dix_cp_reply_received ( struct m0_rpc_item *  item )

static

Definition at line 93 of file net.c.

Here is the call graph for this function:

dixcp_to_dixcpx()

static int dixcp_to_dixcpx ( struct m0_dix_cm_cp *  dix_cp, struct m0_dix_cpx *  dix_cpx  )

static

Definition at line 58 of file net.c.

Here is the call graph for this function:

Here is the caller graph for this function:

dixcpx_to_dixcp()

static void dixcpx_to_dixcp ( const struct m0_dix_cpx *  dix_cpx, struct m0_dix_cm_cp *  dix_cp  )

static

Converts onwire copy packet structure to in-memory copy packet structure.

Definition at line 136 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

m0_dix_cm_cp_alloc()

M0_INTERNAL struct m0_cm_cp* m0_dix_cm_cp_alloc

(

struct m0_cm *

cm

)

Allocates DIX copy packet and returnes embedded base copy packet.

Parameters

cm	Base copy machine.

Embedded base copy packet on success or NULL on failure.

Definition at line 90 of file cp.c.

Here is the caller graph for this function:

m0_dix_cm_cp_complete()

M0_INTERNAL void m0_dix_cm_cp_complete

(

struct m0_cm_cp *

cp

)

Calculates read/write statistics.

Parameters

cp	Base copy packet.

Definition at line 259 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_dup()

M0_INTERNAL int m0_dix_cm_cp_dup	(	struct m0_cm_cp *	src,
		struct m0_cm_cp **	dst
	)

Duplicates DIX copy packet.

Parameters

[in]	src	Base copy packet embedded into DIX copy packet to be copied.
[out]	dst	A copy of source copy packet.

0 on success or negative error code.

Definition at line 320 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_fail()

M0_INTERNAL int m0_dix_cm_cp_fail	(	struct m0_cm_cp *	cp,
		struct m0_fop_type *	ft
	)

Unlocks locked catalogues, sends reply and moves copy packet FOM to the final state.

Parameters

cp	Copy packet embedded into DIX CP.
ft	Reply FOP type.

M0_FSO_WAIT.

Definition at line 230 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

m0_dix_cm_cp_fini()

M0_INTERNAL int m0_dix_cm_cp_fini

(

struct m0_cm_cp *

cp

)

Wakes up pump FOM in case of local copy packet or finalises catalogues lock links otherwise

Parameters

cp	Base copy packet.

Always return 0 for now.

Definition at line 286 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_free()

M0_INTERNAL void m0_dix_cm_cp_free

(

struct m0_cm_cp *

cp

)

Removes embedded base copy packet from aggregation group (if such presented) and frees DIX copy packet.

Parameters

cp	Base copy packet.

Definition at line 277 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_home_loc_helper()

M0_INTERNAL uint64_t m0_dix_cm_cp_home_loc_helper

(

const struct m0_cm_cp *

cp

)

Uses device id to select a request handler locality for copy packet FOM.

Definition at line 74 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_init()

M0_INTERNAL int m0_dix_cm_cp_init

(

struct m0_cm_cp *

cp

)

Initialises DIX copy packet by embedded context, allocates corresponding aggregation group and sets up next phase of copy packet FOM.

Parameters

cp	Base copy packet.

M0_FSO_AGAIN.

Definition at line 175 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_invariant()

M0_INTERNAL bool m0_dix_cm_cp_invariant

(

const struct m0_cm_cp *

cp

)

DIX copy packet invariant.

Definition at line 62 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_io_wait()

M0_INTERNAL int m0_dix_cm_cp_io_wait	(	struct m0_cm_cp *	cp,
		struct m0_fop_type *	ft
	)

Checks I/O completion and sends reply.

Parameters

cp	Base copy packet.
ft	Reply FOP type.

M0_FSO_AGAIN, M0_FSO_WAIT or negative error code.

Definition at line 479 of file cp.c.

Here is the call graph for this function:

Here is the caller graph for this function:

m0_dix_cm_cp_read()

M0_INTERNAL int m0_dix_cm_cp_read

(

struct m0_cm_cp *

cp

)

Does nothing but transition of copy packet FOM to M0_CCP_IO_WAIT state as all data is aleady read by DIX iterator.

Parameters

cp	Base copy packet.

M0_FSO_AGAIN.

Definition at line 337 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_recv_init()

M0_INTERNAL int m0_dix_cm_cp_recv_init

(

struct m0_cm_cp *

cp

)

Loads key or value depending on transmission phase using RPC AT buffers.

Parameters

cp	Base copy packet.

M0_FSO_AGAIN, M0_FSO_WAIT or negative error code.

Definition at line 219 of file net.c.

Here is the call graph for this function:

m0_dix_cm_cp_recv_wait()

M0_INTERNAL int m0_dix_cm_cp_recv_wait

(

struct m0_cm_cp *

cp

)

Manages key/value transmission phases and locks meta catalogue if key/value are loaded.

Parameters

cp	Base copy packet.

M0_FSO_AGAIN or M0_FSO_WAIT.

Definition at line 233 of file net.c.

Here is the call graph for this function:

m0_dix_cm_cp_send()

M0_INTERNAL int m0_dix_cm_cp_send	(	struct m0_cm_cp *	cp,
		struct m0_fop_type *	ft
	)

Allocates, initialises and sends the FOP which carries a DIX copy packet.

Parameters

cp	Base copy packet embedded into DIX copy packet to be sent.
ft	FOP type.

M0_FSO_AGAIN or M0_FSO_WAIT.

Definition at line 139 of file net.c.

Here is the call graph for this function:

Here is the caller graph for this function:

m0_dix_cm_cp_send_wait()

M0_INTERNAL int m0_dix_cm_cp_send_wait

(

struct m0_cm_cp *

cp

)

Transmits copy packet FOM into M0_CCP_FINI phase on success or into M0_CCP_FINI on error.

Parameters

cp	Base copy packet embedded into sent DIX copy packet.

M0_FSO_AGAIN or M0_FSO_WAIT.

Definition at line 204 of file net.c.

Here is the call graph for this function:

m0_dix_cm_cp_setup()

M0_INTERNAL void m0_dix_cm_cp_setup	(	struct m0_dix_cm_cp *	dix_cp,
		const struct m0_fid *	cctg_fid,
		uint64_t	failed_unit_index
	)

Fills remote target info and initialises copy packet indices bitmap to all 1.

Parameters

dix_cp	DIX copy packet to be sent.
cctg_fid	Target component catalogue fid.
failed_unit_index	Index of failed storage unit (not used for now).

Definition at line 310 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_sw_check()

M0_INTERNAL int m0_dix_cm_cp_sw_check

(

struct m0_cm_cp *

cp

)

Unconditionally transmits copy packet FOM into M0_CCP_SEND phase.

Note

In DIX we do not care about sliding window and always ready to send.

Parameters

cp	Base copy packet.

M0_FSO_AGAIN.

Definition at line 256 of file net.c.

Here is the call graph for this function:

m0_dix_cm_cp_tgt_info_fill()

M0_INTERNAL void m0_dix_cm_cp_tgt_info_fill	(	struct m0_dix_cm_cp *	dix_cp,
		const struct m0_fid *	cctg_fid
	)

Fills target component catalogue fid of DIX copy packet.

Parameters

dix_cp	DIX copy packet to be sent.
cctg_fid	Target component catalogue fid.

Definition at line 304 of file cp.c.

Here is the caller graph for this function:

m0_dix_cm_cp_tx_done()

M0_INTERNAL int m0_dix_cm_cp_tx_done

(

struct m0_cm_cp *

cp

)

Definition at line 452 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_tx_open()

M0_INTERNAL int m0_dix_cm_cp_tx_open

(

struct m0_cm_cp *

cp

)

Definition at line 393 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_write()

M0_INTERNAL int m0_dix_cm_cp_write

(

struct m0_cm_cp *

cp

)

Initialises ctg operation and does insertion of key/value into catalogue.

Parameters

cp	Base copy packet.

M0_FSO_AGAIN, M0_FSO_WAIT or negative error code.

Definition at line 413 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_write_pre()

M0_INTERNAL int m0_dix_cm_cp_write_pre

(

struct m0_cm_cp *

cp

)

Locks catalogue for key/value insertion.

Parameters

cp	Base copy packet.

M0_FSO_AGAIN, M0_FSO_WAIT or negative error code.

Definition at line 357 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_cp_xform()

M0_INTERNAL int m0_dix_cm_cp_xform

(

struct m0_cm_cp *

cp

)

Initialises ctg operation and does lookup in meta catalogue.

Parameters

cp	Base copy packet.

M0_FSO_AGAIN or M0_FSO_WAIT.

Definition at line 346 of file cp.c.

Here is the call graph for this function:

m0_dix_cm_rebalance_cp_send()

M0_INTERNAL int m0_dix_cm_rebalance_cp_send

(

struct m0_cm_cp *

cp

)

See also

m0_dix_cm_cp_send()

Definition at line 37 of file net.c.

Here is the call graph for this function:

m0_dix_cm_repair_cp_send()

M0_INTERNAL int m0_dix_cm_repair_cp_send

(

struct m0_cm_cp *

cp

)

See also

m0_dix_cm_cp_send()

Definition at line 37 of file net.c.

Here is the call graph for this function:

Variable Documentation

dix_cp_item_ops

const struct m0_rpc_item_ops dix_cp_item_ops

static

Initial value:

= {
        .rio_replied = dix_cp_reply_received,
}

Definition at line 53 of file net.c.

m0_dix_cm_rebalance_cp_ops

M0_INTERNAL const struct m0_cm_cp_ops m0_dix_cm_rebalance_cp_ops

Initial value:

= {
        .co_action = {
                [M0_CCP_INIT]         = &m0_dix_cm_cp_init,
                [M0_CCP_READ]         = &m0_dix_cm_cp_read,
                [M0_CCP_WRITE_PRE]    = &m0_dix_cm_cp_write_pre,
                [M0_CCP_TX_OPEN]      = &m0_dix_cm_cp_tx_open,
                [M0_CCP_WRITE]        = &m0_dix_cm_cp_write,
                [M0_CCP_TX_DONE]      = &m0_dix_cm_cp_tx_done,
                [M0_CCP_IO_WAIT]      = &dix_cm_rebalance_cp_io_wait,
                [M0_CCP_XFORM]        = &m0_dix_cm_cp_xform,
                [M0_CCP_SW_CHECK]     = &m0_dix_cm_cp_sw_check,
                [M0_CCP_SEND]         = &m0_dix_cm_rebalance_cp_send,
                [M0_CCP_SEND_WAIT]    = &m0_dix_cm_cp_send_wait,
                [M0_CCP_RECV_INIT]    = &m0_dix_cm_cp_recv_init,
                [M0_CCP_RECV_WAIT]    = &m0_dix_cm_cp_recv_wait,
                [M0_CCP_FAIL]         = &dix_cm_rebalance_cp_fail,
                [M0_CCP_FINI]         = &m0_dix_cm_cp_fini,
        },
        .co_action_nr            = M0_CCP_NR,
        .co_phase_next           = NULL,
        .co_invariant            = &m0_dix_cm_cp_invariant,
        .co_home_loc_helper      = &m0_dix_cm_cp_home_loc_helper,
        .co_complete             = &m0_dix_cm_cp_complete,
        .co_free                 = &m0_dix_cm_cp_free,
}

Definition at line 551 of file cp.c.

m0_dix_cm_repair_cp_ops

M0_INTERNAL const struct m0_cm_cp_ops m0_dix_cm_repair_cp_ops

Initial value:

= {
        .co_action = {
                [M0_CCP_INIT]         = &m0_dix_cm_cp_init,
                [M0_CCP_READ]         = &m0_dix_cm_cp_read,
                [M0_CCP_WRITE_PRE]    = &m0_dix_cm_cp_write_pre,
                [M0_CCP_TX_OPEN]      = &m0_dix_cm_cp_tx_open,
                [M0_CCP_WRITE]        = &m0_dix_cm_cp_write,
                [M0_CCP_TX_DONE]      = &m0_dix_cm_cp_tx_done,
                [M0_CCP_IO_WAIT]      = &dix_cm_repair_cp_io_wait,
                [M0_CCP_XFORM]        = &m0_dix_cm_cp_xform,
                [M0_CCP_SW_CHECK]     = &m0_dix_cm_cp_sw_check,
                [M0_CCP_SEND]         = &m0_dix_cm_repair_cp_send,
                [M0_CCP_SEND_WAIT]    = &m0_dix_cm_cp_send_wait,
                [M0_CCP_RECV_INIT]    = &m0_dix_cm_cp_recv_init,
                [M0_CCP_RECV_WAIT]    = &m0_dix_cm_cp_recv_wait,
                [M0_CCP_FAIL]         = &dix_cm_repair_cp_fail,
                [M0_CCP_FINI]         = &m0_dix_cm_cp_fini,
        },
        .co_action_nr            = M0_CCP_NR,
        .co_phase_next           = NULL,
        .co_invariant            = &m0_dix_cm_cp_invariant,
        .co_home_loc_helper      = &m0_dix_cm_cp_home_loc_helper,
        .co_complete             = &m0_dix_cm_cp_complete,
        .co_free                 = &m0_dix_cm_cp_free,
}

Definition at line 525 of file cp.c.

m0_dix_rebalance_cpx_fopt

struct m0_fop_type m0_dix_rebalance_cpx_fopt

Definition at line 32 of file rebalance_cp_onwire.c.

m0_dix_rebalance_cpx_reply_fopt

struct m0_fop_type m0_dix_rebalance_cpx_reply_fopt

Definition at line 33 of file rebalance_cp_onwire.c.

m0_dix_repair_cpx_fopt

struct m0_fop_type m0_dix_repair_cpx_fopt

Definition at line 32 of file repair_cp_onwire.c.

m0_dix_repair_cpx_reply_fopt

struct m0_fop_type m0_dix_repair_cpx_reply_fopt

Definition at line 33 of file repair_cp_onwire.c.