LU-7988 hsm: run HSM coordinator once per second at most

[fs/lustre-release.git] / lustre / include / lustre_nrs_tbf.h

diff --git a/lustre/include/lustre_nrs_tbf.h b/lustre/include/lustre_nrs_tbf.h
index bac1ccf..6e0c736 100644 (file)
--- a/lustre/include/lustre_nrs_tbf.h
+++ b/lustre/include/lustre_nrs_tbf.h
@@ -42,11 +42,16 @@
 struct nrs_tbf_head;
 struct nrs_tbf_cmd;
 
+#define NRS_TBF_MATCH_FULL     0x0000001
+#define NRS_TBF_MATCH_WILDCARD 0x0000002
+
 struct nrs_tbf_jobid {
        char            *tj_id;
+       __u32            tj_match_flag;
        struct list_head tj_linkage;
 };
 
+#define NRS_TBF_KEY_LEN        (LNET_NIDSTR_SIZE + LUSTRE_JOBID_SIZE + 3 + 2)
 struct nrs_tbf_client {
        /** Resource object for policy instance. */
        struct ptlrpc_nrs_resource       tc_res;
@@ -58,6 +63,8 @@ struct nrs_tbf_client {
        char                             tc_jobid[LUSTRE_JOBID_SIZE];
        /** opcode of the client. */
        __u32                            tc_opcode;
+       /** Hash key of the client. */
+       char                             tc_key[NRS_TBF_KEY_LEN];
        /** Reference number of the client. */
        atomic_t                         tc_ref;
        /** Lock to protect rule and linkage. */
@@ -117,6 +124,10 @@ struct nrs_tbf_rule {
        struct cfs_bitmap               *tr_opcodes;
        /** Opcode list string of the rule.*/
        char                            *tr_opcodes_str;
+       /** Condition list of the rule.*/
+       struct list_head                tr_conds;
+       /** Generic condition string of the rule. */
+       char                            *tr_conds_str;
        /** RPC/s limit. */
        __u64                            tr_rpc_rate;
        /** Time to wait for next token. */
@@ -156,6 +167,7 @@ struct nrs_tbf_ops {
 #define NRS_TBF_TYPE_JOBID     "jobid"
 #define NRS_TBF_TYPE_NID       "nid"
 #define NRS_TBF_TYPE_OPCODE    "opcode"
+#define NRS_TBF_TYPE_GENERIC   "generic"
 #define NRS_TBF_TYPE_MAX_LEN   20
 
 enum nrs_tbf_flag {
@@ -163,6 +175,7 @@ enum nrs_tbf_flag {
        NRS_TBF_FLAG_JOBID      = 0x0000001,
        NRS_TBF_FLAG_NID        = 0x0000002,
        NRS_TBF_FLAG_OPCODE     = 0x0000004,
+       NRS_TBF_FLAG_GENERIC    = 0x0000008,
 };
 
 struct nrs_tbf_type {
@@ -259,6 +272,8 @@ struct nrs_tbf_cmd {
                        char                    *ts_jobids_str;
                        struct cfs_bitmap       *ts_opcodes;
                        char                    *ts_opcodes_str;
+                       struct list_head         ts_conds;
+                       char                    *ts_conds_str;
                        __u32                    ts_valid_type;
                        __u32                    ts_rule_flags;
                        char                    *ts_next_name;
@@ -270,6 +285,31 @@ struct nrs_tbf_cmd {
        } u;
 };
 
+enum nrs_tbf_field {
+       NRS_TBF_FIELD_NID,
+       NRS_TBF_FIELD_JOBID,
+       NRS_TBF_FIELD_OPCODE,
+       NRS_TBF_FIELD_MAX
+};
+
+struct nrs_tbf_expression {
+       enum nrs_tbf_field       te_field;
+       struct list_head         te_cond;
+       struct cfs_bitmap       *te_opcodes;
+       struct list_head         te_linkage;
+};
+
+struct nrs_tbf_conjunction {
+       /**
+        * link to disjunction.
+        */
+       struct list_head tc_linkage;
+       /**
+        * list of logical conjunction
+        */
+       struct list_head tc_expressions;
+};
+
 struct nrs_tbf_req {
        /**
         * Linkage to queue.