#include "lib/errno.h"
#include "lib/assert.h"
#include "lib/memory.h"
#include "lib/chan.h"
#include "lib/finject.h"
#include "lib/time.h"
#include "lib/misc.h"
#include "fop/fop.h"
#include "fop/fom.h"
#include "fop/fom_generic.h"
#include "rpc/rpc.h"
#include "rpc/rpclib.h"
#include "fop/fop_item_type.h"
#include "ut/cs_fop.h"
#include "ut/cs_fop_xc.h"
#include "rpc/rpc_opcodes.h"
Go to the source code of this file.
◆ ds_phases
Enumerator |
---|
M0_FOPH_DS1_REQ | |
M0_FOPH_DS2_REQ | |
Definition at line 88 of file cs_fop.c.
◆ cs_ds1_req_fop_fom_create()
static int cs_ds1_req_fop_fom_create |
( |
struct m0_fop * |
fop, |
|
|
struct m0_fom ** |
out, |
|
|
struct m0_reqh * |
reqh |
|
) |
| |
|
static |
◆ cs_ds2_req_fop_fom_create()
static int cs_ds2_req_fop_fom_create |
( |
struct m0_fop * |
fop, |
|
|
struct m0_fom ** |
out, |
|
|
struct m0_reqh * |
reqh |
|
) |
| |
|
static |
◆ cs_ds_req_fop_fom_create()
◆ cs_req_fop_fom_tick()
static int cs_req_fop_fom_tick |
( |
struct m0_fom * |
fom | ) |
|
|
static |
◆ cs_ut_find_fom_home_locality()
static size_t cs_ut_find_fom_home_locality |
( |
const struct m0_fom * |
fom | ) |
|
|
static |
◆ cs_ut_fom_fini()
static void cs_ut_fom_fini |
( |
struct m0_fom * |
fom | ) |
|
|
static |
◆ cs_ut_rpc_item_reply_cb()
static void cs_ut_rpc_item_reply_cb |
( |
struct m0_rpc_item * |
item | ) |
|
|
static |
◆ m0_cs_ut_ds1_fop_fini()
void m0_cs_ut_ds1_fop_fini |
( |
void |
| ) |
|
◆ m0_cs_ut_ds1_fop_init()
int m0_cs_ut_ds1_fop_init |
( |
void |
| ) |
|
◆ m0_cs_ut_ds2_fop_fini()
void m0_cs_ut_ds2_fop_fini |
( |
void |
| ) |
|
◆ m0_cs_ut_ds2_fop_init()
int m0_cs_ut_ds2_fop_init |
( |
void |
| ) |
|
◆ m0_ut_fom_phase_set()
void m0_ut_fom_phase_set |
( |
struct m0_fom * |
fom, |
|
|
int |
phase |
|
) |
| |
◆ cs_ds1_rep_fop_fopt
◆ cs_ds1_req_fop_fom_ops
Initial value:= {
}
static void cs_ut_fom_fini(struct m0_fom *fom)
static size_t cs_ut_find_fom_home_locality(const struct m0_fom *fom)
static int cs_req_fop_fom_tick(struct m0_fom *fom)
Definition at line 70 of file cs_fop.c.
◆ cs_ds1_req_fop_fom_type_ops
Initial value:= {
}
static int cs_ds1_req_fop_fom_create(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
Definition at line 96 of file cs_fop.c.
◆ cs_ds1_req_fop_fopt
◆ cs_ds2_rep_fop_fopt
◆ cs_ds2_req_fop_fom_ops
Initial value:= {
}
static void cs_ut_fom_fini(struct m0_fom *fom)
static size_t cs_ut_find_fom_home_locality(const struct m0_fom *fom)
static int cs_req_fop_fom_tick(struct m0_fom *fom)
Definition at line 79 of file cs_fop.c.
◆ cs_ds2_req_fop_fom_type_ops
Initial value:= {
}
static int cs_ds2_req_fop_fom_create(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
Definition at line 103 of file cs_fop.c.
◆ cs_ds2_req_fop_fopt
◆ cs_ds_req_fop_rpc_item_ops
Initial value:= {
}
static void cs_ut_rpc_item_reply_cb(struct m0_rpc_item *item)
Definition at line 47 of file cs_fop.c.
◆ ds1_service_type
◆ ds2_service_type