lnetst.h

非常经典的一个分布式系统

#define LST_OPC_SESSION         1
#define LST_OPC_GROUP           2
#define LST_OPC_NODES           3
#define LST_OPC_BATCHCLI        4
#define LST_OPC_BATCHSRV        5

typedef struct {
        int                     lstio_dbg_key;          /* IN: session key */
        int                     lstio_dbg_type;         /* IN: debug sessin|batch|group|nodes list */
        int                     lstio_dbg_flags;        /* IN: reserved debug flags */
        int                     lstio_dbg_timeout;      /* IN: timeout of debug */

        int                     lstio_dbg_nmlen;        /* IN: len of name */
        char                   *lstio_dbg_namep;        /* IN: name of group|batch */
        int                     lstio_dbg_count;        /* IN: # of test nodes to debug */
        lnet_process_id_t      *lstio_dbg_idsp;         /* IN: id of test nodes */
        struct list_head       *lstio_dbg_resultp;      /* OUT: list head of result buffer */
} lstio_debug_args_t;

typedef struct {
        int                     lstio_grp_key;          /* IN: session key */
        int                     lstio_grp_nmlen;        /* IN: name length */
        char                   *lstio_grp_namep;        /* IN: group name */
} lstio_group_add_args_t;

typedef struct {
        int                     lstio_grp_key;          /* IN: session key */
        int                     lstio_grp_nmlen;        /* IN: name length */
        char                   *lstio_grp_namep;        /* IN: group name */
} lstio_group_del_args_t;

#define LST_GROUP_CLEAN         1                       /* remove inactive nodes in the group */
#define LST_GROUP_REFRESH       2                       /* refresh inactive nodes in the group */
#define LST_GROUP_RMND          3                       /* delete nodes from the group */

typedef struct {
        int                     lstio_grp_key;          /* IN: session key */
        int                     lstio_grp_opc;          /* IN: OPC */
        int                     lstio_grp_args;         /* IN: arguments */
        int                     lstio_grp_nmlen;        /* IN: name length */
        char                   *lstio_grp_namep;        /* IN: group name */
        int                     lstio_grp_count;        /* IN: # of nodes id */
        lnet_process_id_t      *lstio_grp_idsp;         /* IN: array of nodes */
        struct list_head       *lstio_grp_resultp;      /* OUT: list head of result buffer */
} lstio_group_update_args_t;

typedef struct {
        int                     lstio_grp_key;          /* IN: session key */
        int                     lstio_grp_nmlen;        /* IN: name length */
        char                   *lstio_grp_namep;        /* IN: group name */
        int                     lstio_grp_count;        /* IN: # of nodes */
        lnet_process_id_t      *lstio_grp_idsp;         /* IN: nodes */
        struct list_head       *lstio_grp_resultp;      /* OUT: list head of result buffer */
} lstio_group_nodes_args_t;

typedef struct {
        int                     lstio_grp_key;          /* IN: session key */
        int                     lstio_grp_idx;          /* IN: group idx */
        int                     lstio_grp_nmlen;        /* IN: name len */
        char                   *lstio_grp_namep;        /* OUT: name */
} lstio_group_list_args_t;

typedef struct {
        int                     lstio_grp_key;          /* IN: session key */
        int                     lstio_grp_nmlen;        /* IN: name len */
        char                   *lstio_grp_namep;        /* IN: name */
        lstcon_ndlist_ent_t    *lstio_grp_entp;         /* OUT: description of group */

        int                    *lstio_grp_idxp;         /* IN/OUT: node index */
        int                    *lstio_grp_ndentp;       /* IN/OUT: # of nodent */
        lstcon_node_ent_t      *lstio_grp_dentsp;       /* OUT: nodent array */
} lstio_group_info_args_t;

#define LST_DEFAULT_BATCH       "batch"                 /* default batch name */

typedef struct {
        int                     lstio_bat_key;          /* IN: session key */
        int                     lstio_bat_nmlen;        /* IN: name length */
        char                   *lstio_bat_namep;        /* IN: batch name */
} lstio_batch_add_args_t;

typedef struct {
        int                     lstio_bat_key;          /* IN: session key */
        int                     lstio_bat_nmlen;        /* IN: name length */
        char                   *lstio_bat_namep;        /* IN: batch name */
} lstio_batch_del_args_t;

typedef struct {
        int                     lstio_bat_key;          /* IN: session key */
        int                     lstio_bat_timeout;      /* IN: timeout for the batch */
        int                     lstio_bat_nmlen;        /* IN: name length */
        char                   *lstio_bat_namep;        /* IN: batch name */
        struct list_head       *lstio_bat_resultp;      /* OUT: list head of result buffer */
} lstio_batch_run_args_t;

typedef struct {
        int                     lstio_bat_key;          /* IN: session key */
        int                     lstio_bat_force;        /* IN: abort unfinished test RPC */
        int                     lstio_bat_nmlen;        /* IN: name length */
        char                   *lstio_bat_namep;        /* IN: batch name */
        struct list_head       *lstio_bat_resultp;      /* OUT: list head of result buffer */
} lstio_batch_stop_args_t;

typedef struct {
        int                     lstio_bat_key;          /* IN: session key */
        int                     lstio_bat_testidx;      /* IN: test index */
        int                     lstio_bat_client;       /* IN: is test client? */
        int                     lstio_bat_timeout;      /* IN: timeout for waiting */
        int                     lstio_bat_nmlen;        /* IN: name length */
        char                   *lstio_bat_namep;        /* IN: batch name */
        struct list_head       *lstio_bat_resultp;      /* OUT: list head of result buffer */
} lstio_batch_query_args_t;

typedef struct {
        int                     lstio_bat_key;          /* IN: session key */
        int                     lstio_bat_idx;          /* IN: index */
        int                     lstio_bat_nmlen;        /* IN: name length */
        char                   *lstio_bat_namep;        /* IN: batch name */
} lstio_batch_list_args_t;

typedef struct {
        int                     lstio_bat_key;          /* IN: session key */
        int                     lstio_bat_nmlen;        /* IN: name length */
        char                   *lstio_bat_namep;        /* IN: name */
        int                     lstio_bat_server;       /* IN: query server or not */
        int                     lstio_bat_testidx;      /* IN: test index */
        lstcon_test_batch_ent_t *lstio_bat_entp;        /* OUT: batch ent */

        int                    *lstio_bat_idxp;         /* IN/OUT: index of node */
        int                    *lstio_bat_ndentp;       /* IN/OUT: # of nodent */
        lstcon_node_ent_t      *lstio_bat_dentsp;       /* array of nodent */
} lstio_batch_info_args_t;

/* add stat in session */
typedef struct {
        int                     lstio_sta_key;          /* IN: session key */
        int                     lstio_sta_timeout;      /* IN: timeout for stat requst */
        int                     lstio_sta_nmlen;        /* IN: group name length */
        char                   *lstio_sta_namep;        /* IN: group name */
        int                     lstio_sta_count;        /* IN: # of pid */
        lnet_process_id_t      *lstio_sta_idsp;         /* IN: pid */
        struct list_head       *lstio_sta_resultp;      /* OUT: list head of result buffer */
} lstio_stat_args_t;

typedef enum {
        LST_TEST_BULK   = 1,
        LST_TEST_PING   = 2
} lst_test_type_t;

/* create a test in a batch */
#define LST_MAX_CONCUR          1024                    /* Max concurrency of test */

typedef struct {
        int                     lstio_tes_key;          /* IN: session key */
        int                     lstio_tes_bat_nmlen;    /* IN: batch name len */
        char                   *lstio_tes_bat_name;     /* IN: batch name */
        int                     lstio_tes_type;         /* IN: test type */
        int                     lstio_tes_oneside;      /* IN: one sided test */
        int                     lstio_tes_loop;         /* IN: loop count */
        int                     lstio_tes_concur;       /* IN: concurrency */

        int                     lstio_tes_dist;         /* IN: node distribution in destination groups */
        int                     lstio_tes_span;         /* IN: node span in destination groups */
        int                     lstio_tes_sgrp_nmlen;   /* IN: source group name length */
        char                   *lstio_tes_sgrp_name;    /* IN: group name */
        int                     lstio_tes_dgrp_nmlen;   /* IN: destination group name length */
        char                   *lstio_tes_dgrp_name;    /* IN: group name */

        int                     lstio_tes_param_len;    /* IN: param buffer len */
        void                   *lstio_tes_param;        /* IN: parameter for specified test:
                                                               lstio_bulk_param_t,
                                                               lstio_ping_param_t,
                                                               ... more */
        int                    *lstio_tes_retp;         /* OUT: private returned value */
        struct list_head       *lstio_tes_resultp;      /* OUT: list head of result buffer */
} lstio_test_args_t;

typedef enum {
        LST_BRW_READ    = 1,
        LST_BRW_WRITE   = 2
} lst_brw_type_t;

typedef enum {
        LST_BRW_CHECK_NONE   = 1,
        LST_BRW_CHECK_SIMPLE = 2,
        LST_BRW_CHECK_FULL   = 3
} lst_brw_flags_t;

typedef struct {
        int                     blk_opc;                /* bulk operation code */
        int                     blk_size;               /* size (bytes) */
        int                     blk_time;               /* time of running the test*/
        int                     blk_flags;              /* reserved flags */
} lst_test_bulk_param_t;

typedef struct {
        int                     png_size;               /* size of ping message */
        int                     png_time;               /* time */
        int                     png_loop;               /* loop */
        int                     png_flags;              /* reserved flags */
} lst_test_ping_param_t;

/* more tests */

typedef struct {
        __u32 errors;
        __u32 rpcs_sent;
        __u32 rpcs_rcvd;
        __u32 rpcs_dropped;
        __u32 rpcs_expired;
        __u64 bulk_get;
        __u64 bulk_put;
} srpc_counters_t;

typedef struct {
        __u32 active_tests;
        __u32 active_batches;
        __u32 zombie_sessions;
        __u32 brw_errors;
        __u32 ping_errors;
} sfw_counters_t;

#endif