|
Motr
M0
|
#include "ioservice/cob_foms.c"#include "lib/trace.h"#include "ioservice/ut/bulkio_common.h"#include "mdservice/fsync_fops.h"#include "rpc/rpclib.h"#include "rpc/rpc_opcodes.h"#include "rpc/rpc_machine.h"#include "stob/type.h"#include "stob/ad.h"#include "stob/linux.h"#include "ut/cs_fop.h"#include "ut/misc.h"#include "ut/ut.h"
Go to the source code of this file.
Data Structures | |
| struct | cobfoms_ut |
| struct | cobthread_arg |
Macros | |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_COB |
| #define | SERVER_EP_ADDR "0@lo:12345:34:1" |
| #define | CLIENT_EP_ADDR "0@lo:12345:34:*" |
| #define | SERVER_ENDP M0_NET_XPRT_PREFIX_DEFAULT":"SERVER_EP_ADDR |
Enumerations | |
| enum | cob_fom_type { COB_CREATE = 1, COB_DELETE = 2 } |
| enum | { CLIENT_COB_DOM_ID = 12, CLIENT_RPC_CONN_TIMEOUT = 200, CLIENT_MAX_RPCS_IN_FLIGHT = 8, COB_NAME_STRLEN = 34, GOB_FID_CONTAINER_ID = 1000, GOB_FID_KEY_ID = 5678, COB_FOP_SINGLE = 1, COB_FOP_NR = 5, POOL_WIDTH = 10, COB_TEST_KEY = 111 } |
| enum | { FID_UT_CONTAINER_BITS_MAX = 32, FID_UT_KEY_BITS_MAX = 64, FID_UT_DEVICE_ID_BITS_MAX = 24 } |
Functions | |
| static struct m0_fom * | cd_fom_alloc () |
| static void | cd_fom_dealloc (struct m0_fom *fom) |
| static void | fom_dtx_init (struct m0_fom *fom, struct m0_sm_group *grp, enum m0_cob_op opcode) |
| static void | fom_stob_tx_credit (struct m0_fom *fom, enum m0_cob_op opcode) |
| static void | fom_dtx_done (struct m0_fom *fom, struct m0_sm_group *grp) |
| static void | cd_stob_delete_test () |
| static void | cobfoms_utinit (void) |
| static void | cobfoms_utfini (void) |
| static void | cobfops_populate_internal (struct m0_fop *fop, uint64_t gob_fid_key) |
| static void | cobfops_populate (uint64_t index) |
| static void | cobfops_create (void) |
| static void | cobfops_destroy (struct m0_fop_type *ftype1, struct m0_fop_type *ftype2) |
| static void | cobfops_threads_init (void) |
| static void | cobfops_threads_fini (void) |
| static void | cobfops_send_wait (struct cobthread_arg *arg) |
| static void | cobfoms_fops_dispatch (struct m0_fop_type *ftype, uint64_t flags, int expected_rc) |
| static void | cobfoms_fop_thread_init (uint64_t fop_nr, uint64_t thread_nr) |
| static void | cobfoms_fop_thread_fini (struct m0_fop_type *ftype1, struct m0_fop_type *ftype2) |
| static void | cobfoms_send_internal (struct m0_fop_type *ftype1, struct m0_fop_type *ftype2, uint64_t flags, int rc1, int rc2, uint64_t nr) |
| static void | cobfoms_single (void) |
| static void | cobfoms_multiple (void) |
| static void | cobfoms_preexisting_cob (void) |
| static void | cobfoms_del_nonexist_cob (void) |
| static void | cobfoms_fsync_send_fop (struct m0_be_tx_remid *remid, int expected_rc) |
| static void | cobfoms_fsync_nonexist_tx (void) |
| static void | cobfoms_fsync_create_delete (void) |
| static void | fom_create (struct m0_fom **fom, enum cob_fom_type fomtype) |
| static void | fom_fini (struct m0_fom *fom, enum cob_fom_type fomtype) |
| static void | fop_alloc (struct m0_fom *fom, enum cob_fom_type fomtype) |
| static void | fom_fini_test (enum cob_fom_type fomtype) |
| static void | fom_get_test (enum cob_fom_type fomtype) |
| static void | fom_create_test (enum cob_fom_type fomtype) |
| static void | cc_fom_dealloc (struct m0_fom *fom) |
| static struct m0_fom * | cc_fom_alloc () |
| static void | cc_fom_create_test () |
| static void | cc_fom_fini_test () |
| static void | cc_fom_get_test () |
| static void | cc_stob_create_test () |
| static void | cob_verify (struct m0_fom *fom, const bool exists) |
| static void | md_cob_fop_create_delete_test (bool create_p, const struct m0_fid *pver, int expected_reply_rc) |
| static void | md_cob_create_delete () |
| static void | cc_cob_create_test () |
| static void | cc_fom_state_test (void) |
| static void | cc_fom_populate_test () |
| static void | cd_fom_create_test () |
| static void | cd_fom_fini_test () |
| static void | cd_fom_get_test () |
| static void | cd_fom_populate_test () |
| static struct m0_fom * | cob_testdata_create () |
| static void | cob_testdata_cleanup (struct m0_fom *fom) |
| static void | cd_cob_delete_test () |
| static void | cd_fom_state_test (void) |
| static void | dummy_locality_setup () |
| static void | cob_create_api_test (void) |
| static void | cob_delete_api_test (void) |
| static void | fid_convert_ut_check (uint32_t container, uint64_t key, uint32_t device_id) |
| static void | fid_convert_ut (void) |
Variables | |
| struct m0_fop_type | m0_fop_cob_create_fopt |
| struct m0_fop_type | m0_fop_cob_delete_fopt |
| struct m0_fop_type | m0_fop_fsync_ios_fopt |
| struct m0_reqh_service_type | m0_ios_type |
| static struct cobfoms_ut * | cut |
| static struct m0_fom_locality | dummy_loc |
| static struct m0_cob * | test_cob = NULL |
| static struct m0_fom_type | ft |
| static bool | cc_cob_create_test_done = false |
| static char | COB_FOP_NR_STR [] = { '0' + COB_FOP_NR, '\0'} |
| static const char * | SERVER_LOGFILE = "cobfoms_ut.log" |
| static char * | server_args [] |
| const struct m0_sm_conf | cob_ops_conf |
| struct m0_ut_suite | cobfoms_ut |
| #define CLIENT_EP_ADDR "0@lo:12345:34:*" |
Definition at line 84 of file cob_foms.c.
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_COB |
Definition at line 25 of file cob_foms.c.
| #define SERVER_ENDP M0_NET_XPRT_PREFIX_DEFAULT":"SERVER_EP_ADDR |
Definition at line 85 of file cob_foms.c.
| #define SERVER_EP_ADDR "0@lo:12345:34:1" |
Definition at line 83 of file cob_foms.c.
| anonymous enum |
| Enumerator | |
|---|---|
| CLIENT_COB_DOM_ID | |
| CLIENT_RPC_CONN_TIMEOUT | |
| CLIENT_MAX_RPCS_IN_FLIGHT | |
| COB_NAME_STRLEN | |
| GOB_FID_CONTAINER_ID | |
| GOB_FID_KEY_ID | |
| COB_FOP_SINGLE | |
| COB_FOP_NR | |
| POOL_WIDTH | |
| COB_TEST_KEY | |
Definition at line 68 of file cob_foms.c.
| anonymous enum |
| Enumerator | |
|---|---|
| FID_UT_CONTAINER_BITS_MAX | |
| FID_UT_KEY_BITS_MAX | |
| FID_UT_DEVICE_ID_BITS_MAX | |
Definition at line 1474 of file cob_foms.c.
| enum cob_fom_type |
| Enumerator | |
|---|---|
| COB_CREATE | |
| COB_DELETE | |
Definition at line 63 of file cob_foms.c.
|
static |
Definition at line 876 of file cob_foms.c.


|
static |
Definition at line 727 of file cob_foms.c.


|
static |
Definition at line 745 of file cob_foms.c.


|
static |
Definition at line 717 of file cob_foms.c.


|
static |
Definition at line 753 of file cob_foms.c.


|
static |
Definition at line 761 of file cob_foms.c.


|
static |
Definition at line 1007 of file cob_foms.c.


|
static |
Definition at line 957 of file cob_foms.c.


|
static |
Definition at line 769 of file cob_foms.c.


|
static |
Definition at line 1184 of file cob_foms.c.


|
static |
Definition at line 1042 of file cob_foms.c.


|
static |
Definition at line 1060 of file cob_foms.c.


|
static |
Definition at line 1033 of file cob_foms.c.


|
static |
Definition at line 1068 of file cob_foms.c.


|
static |
Definition at line 1076 of file cob_foms.c.


|
static |
Definition at line 1084 of file cob_foms.c.


|
static |
Definition at line 1247 of file cob_foms.c.


|
static |
Definition at line 1142 of file cob_foms.c.


|
static |
|
static |
|
static |
Definition at line 1134 of file cob_foms.c.


|
static |
Definition at line 1104 of file cob_foms.c.


|
static |
Definition at line 798 of file cob_foms.c.


|
static |
|
static |
Definition at line 372 of file cob_foms.c.


|
static |
Definition at line 361 of file cob_foms.c.


|
static |
Definition at line 325 of file cob_foms.c.


|
static |
Sends several create-delete pairs using sequential fids and then sends an fsync fop request to sync the last one. All the fops involved must succeed.
Definition at line 508 of file cob_foms.c.

|
static |
Tries to fsync a non-existent transaction and checks the right error code is returned.
Definition at line 457 of file cob_foms.c.

|
static |
Sends an fsync fop request to the ioservice to trigger the fsync of a given transaction.
| remid | Remote ID of the transaction to fsync.Any other lingering transaction in the ioservice with an ID lower than txid will be also immediately placed. |
| expected_rc | Expected value for the rc included in the corresponding fsync fop reply. If the received value is different this function asserts. |
Definition at line 467 of file cob_foms.c.


|
static |
|
static |
|
static |
Definition at line 379 of file cob_foms.c.


|
static |
|
static |
|
static |
|
static |
Definition at line 211 of file cob_foms.c.


|
static |
Definition at line 239 of file cob_foms.c.


|
static |
Definition at line 196 of file cob_foms.c.


|
static |
Definition at line 176 of file cob_foms.c.


|
static |
Definition at line 293 of file cob_foms.c.


|
static |
Definition at line 280 of file cob_foms.c.


|
static |
|
static |
Definition at line 1275 of file cob_foms.c.


|
static |
|
static |
Definition at line 1480 of file cob_foms.c.


|
static |
Definition at line 575 of file cob_foms.c.


|
static |
Definition at line 705 of file cob_foms.c.


|
static |
Definition at line 1467 of file cob_foms.c.


|
static |
Definition at line 1452 of file cob_foms.c.


|
static |
Definition at line 604 of file cob_foms.c.


|
static |
Definition at line 667 of file cob_foms.c.


|
static |
Definition at line 688 of file cob_foms.c.


Definition at line 1433 of file cob_foms.c.


|
static |
Definition at line 624 of file cob_foms.c.


|
static |
|
static |
Definition at line 833 of file cob_foms.c.


|
static |
Definition at line 53 of file cob_foms.c.
|
static |
Definition at line 81 of file cob_foms.c.
| const struct m0_sm_conf cob_ops_conf |
Definition at line 99 of file cob_foms.c.
| struct m0_ut_suite cobfoms_ut |
Definition at line 1556 of file cob_foms.c.
|
static |
Definition at line 47 of file cob_foms.c.
|
static |
Definition at line 48 of file cob_foms.c.
|
static |
Definition at line 51 of file cob_foms.c.
| struct m0_fop_type m0_fop_cob_create_fopt |
| struct m0_fop_type m0_fop_cob_delete_fopt |
| struct m0_fop_type m0_fop_fsync_ios_fopt |
|
static |
Definition at line 112 of file cob_foms.c.
|
static |
Definition at line 87 of file cob_foms.c.
Definition at line 50 of file cob_foms.c.