|
Motr
M0
|
#include "lib/trace.h"#include <sys/stat.h>#include <stdlib.h>#include "lib/errno.h"#include "lib/assert.h"#include "lib/getopts.h"#include "lib/misc.h"#include "lib/memory.h"#include "lib/time.h"#include "lib/atomic.h"#include "fop/fop.h"#include "motr/init.h"#include "module/instance.h"#include "rpc/rpclib.h"#include "rpc/rpc_opcodes.h"#include "sns/cm/cm.h"#include "sns/cm/trigger_fop.h"#include "dix/cm/cm.h"#include "dix/cm/trigger_fop.h"#include "cm/repreb/trigger_fop.h"#include "cm/repreb/trigger_fop_xc.h"#include "repair_cli.h"
Go to the source code of this file.
Macros | |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_SNSCM |
Enumerations | |
| enum | { MAX_FAILURES_NR = 10 } |
Functions | |
| static void | usage (void) |
| static void | repair_reply_received (struct m0_rpc_item *item) |
| int | main (int argc, char *argv[]) |
Variables | |
| struct m0_mutex | repair_wait_mutex |
| struct m0_chan | repair_wait |
| int32_t | srv_cnt = 0 |
| struct m0_atomic64 | srv_rep_cnt |
| struct m0_rpc_client_ctx | cl_ctx |
| const char * | cl_ep_addr |
| const char * | srv_ep_addr [MAX_SERVERS] |
| struct m0_fop_type | m0_sns_repair_trigger_fopt |
| struct m0_fop_type | m0_sns_repair_quiesce_fopt |
| struct m0_fop_type | m0_sns_repair_status_fopt |
| struct m0_fop_type | m0_sns_rebalance_trigger_fopt |
| struct m0_fop_type | m0_sns_rebalance_quiesce_fopt |
| struct m0_fop_type | m0_sns_rebalance_status_fopt |
| struct m0_fop_type | m0_dix_repair_trigger_fopt |
| struct m0_fop_type | m0_dix_repair_quiesce_fopt |
| struct m0_fop_type | m0_dix_repair_status_fopt |
| struct m0_fop_type | m0_dix_rebalance_trigger_fopt |
| struct m0_fop_type | m0_dix_rebalance_quiesce_fopt |
| struct m0_fop_type | m0_dix_rebalance_status_fopt |
| static const struct m0_rpc_item_ops | repair_item_ops |
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_SNSCM |
Definition at line 23 of file repair_main.c.
| anonymous enum |
| Enumerator | |
|---|---|
| MAX_FAILURES_NR | |
Definition at line 57 of file repair_main.c.
| int main | ( | int | argc, |
| char * | argv[] | ||
| ) |
|
static |
|
static |
| struct m0_rpc_client_ctx cl_ctx |
| const char* cl_ep_addr |
Definition at line 39 of file repair_cli.c.
| struct m0_fop_type m0_sns_rebalance_quiesce_fopt |
Definition at line 42 of file trigger_fop_common.c.
| struct m0_fop_type m0_sns_rebalance_status_fopt |
Definition at line 43 of file trigger_fop_common.c.
| struct m0_fop_type m0_sns_rebalance_trigger_fopt |
Definition at line 41 of file trigger_fop_common.c.
| struct m0_fop_type m0_sns_repair_quiesce_fopt |
Definition at line 39 of file trigger_fop_common.c.
| struct m0_fop_type m0_sns_repair_status_fopt |
Definition at line 40 of file trigger_fop_common.c.
| struct m0_fop_type m0_sns_repair_trigger_fopt |
Definition at line 38 of file trigger_fop_common.c.
|
static |
Definition at line 122 of file repair_main.c.
| struct m0_chan repair_wait |
Definition at line 54 of file repair_main.c.
| struct m0_mutex repair_wait_mutex |
Definition at line 53 of file repair_main.c.
| int32_t srv_cnt = 0 |
Definition at line 55 of file repair_main.c.
| const char* srv_ep_addr[MAX_SERVERS] |
Definition at line 40 of file repair_cli.c.
| struct m0_atomic64 srv_rep_cnt |
Definition at line 56 of file repair_main.c.