LU-7340 mdd: changelogs garbage collection

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

diff --git a/lustre/include/lustre_log.h b/lustre/include/lustre_log.h
index 393ce28..e259ed3 100644 (file)
--- a/lustre/include/lustre_log.h
+++ b/lustre/include/lustre_log.h
@@ -15,11 +15,7 @@
  *
  * You should have received a copy of the GNU General Public License
  * version 2 along with this program; If not, see
- * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
- *
- * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
- * CA 95054 USA or visit www.sun.com if you need additional information or
- * have any questions.
+ * http://www.gnu.org/licenses/gpl-2.0.html
  *
  * GPL HEADER END
  */
@@ -27,11 +23,10 @@
  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
  * Use is subject to license terms.
  *
- * Copyright (c) 2012, 2014, Intel Corporation.
+ * Copyright (c) 2012, 2016, Intel Corporation.
  */
 /*
  * This file is part of Lustre, http://www.lustre.org/
- * Lustre is a trademark of Sun Microsystems, Inc.
  *
  * lustre/include/lustre_log.h
  *
@@ -57,8 +52,9 @@
  */
 
 #include <obd_class.h>
-#include <lustre/lustre_idl.h>
 #include <dt_object.h>
+#include <uapi/linux/lustre/lustre_idl.h>
+#include <uapi/linux/lustre/lustre_log_user.h>
 
 #define LOG_NAME_LIMIT(logname, name)                   \
         snprintf(logname, sizeof(logname), "LOGS/%s", name)
@@ -82,37 +78,6 @@ struct cat_handle_data {
        struct llog_handle     *chd_next_log;   /* llog to be used next */
 };
 
-static inline void logid_to_fid(struct llog_logid *id, struct lu_fid *fid)
-{
-       /* For compatibility purposes we identify pre-OSD (~< 2.3.51 MDS)
-        * logid's by non-zero ogen (inode generation) and convert them
-        * into IGIF */
-       if (id->lgl_ogen == 0) {
-               fid->f_seq = id->lgl_oi.oi.oi_seq;
-               fid->f_oid = id->lgl_oi.oi.oi_id;
-               fid->f_ver = 0;
-       } else {
-               lu_igif_build(fid, id->lgl_oi.oi.oi_id, id->lgl_ogen);
-       }
-}
-
-static inline void fid_to_logid(struct lu_fid *fid, struct llog_logid *id)
-{
-       id->lgl_oi.oi.oi_seq = fid->f_seq;
-       id->lgl_oi.oi.oi_id = fid->f_oid;
-       id->lgl_ogen = 0;
-}
-
-static inline void logid_set_id(struct llog_logid *log_id, __u64 id)
-{
-       log_id->lgl_oi.oi.oi_id = id;
-}
-
-static inline __u64 logid_id(struct llog_logid *log_id)
-{
-       return log_id->lgl_oi.oi.oi_id;
-}
-
 struct llog_handle;
 
 /* llog.c  -  general API */
@@ -139,6 +104,9 @@ int llog_is_empty(const struct lu_env *env, struct llog_ctxt *ctxt,
 int llog_backup(const struct lu_env *env, struct obd_device *obd,
                struct llog_ctxt *ctxt, struct llog_ctxt *bak_ctxt,
                char *name, char *backup);
+int llog_read_header(const struct lu_env *env, struct llog_handle *handle,
+                    const struct obd_uuid *uuid);
+__u64 llog_size(const struct lu_env *env, struct llog_handle *llh);
 
 /* llog_process flags */
 #define LLOG_FLAG_NODEAMON 0x0001
@@ -186,16 +154,16 @@ int llog_cat_cancel_records(const struct lu_env *env,
                            struct llog_handle *cathandle, int count,
                            struct llog_cookie *cookies);
 int llog_cat_process_or_fork(const struct lu_env *env,
-                            struct llog_handle *cat_llh, llog_cb_t cb,
-                            void *data, int startcat, int startidx, bool fork);
+                            struct llog_handle *cat_llh, llog_cb_t cat_cb,
+                            llog_cb_t cb, void *data, int startcat,
+                            int startidx, bool fork);
 int llog_cat_process(const struct lu_env *env, struct llog_handle *cat_llh,
                     llog_cb_t cb, void *data, int startcat, int startidx);
+__u64 llog_cat_size(const struct lu_env *env, struct llog_handle *cat_llh);
+__u32 llog_cat_free_space(struct llog_handle *cat_llh);
 int llog_cat_reverse_process(const struct lu_env *env,
                             struct llog_handle *cat_llh, llog_cb_t cb,
                             void *data);
-int llog_cat_init_and_process(const struct lu_env *env,
-                             struct llog_handle *llh);
-
 /* llog_obd.c */
 int llog_setup(const struct lu_env *env, struct obd_device *obd,
               struct obd_llog_group *olg, int index,
@@ -296,9 +264,13 @@ struct llog_handle {
        struct rw_semaphore      lgh_lock;
        struct mutex             lgh_hdr_mutex; /* protect lgh_hdr data */
        struct llog_logid        lgh_id; /* id of this log */
-       struct llog_log_hdr     *lgh_hdr;
+       struct llog_log_hdr     *lgh_hdr; /* may be vmalloc'd */
        size_t                  lgh_hdr_size;
        struct dt_object        *lgh_obj;
+       /* For a Catalog, is the last/newest used index for a plain slot.
+        * Used in conjunction with llh_cat_idx to handle Catalog wrap-around
+        * case, after it will have reached LLOG_HDR_BITMAP_SIZE, llh_cat_idx
+        * will become its upper limit */
        int                      lgh_last_idx;
        int                      lgh_cur_idx; /* used during llog_process */
        __u64                    lgh_cur_offset; /* used during llog_process */
@@ -311,6 +283,9 @@ struct llog_handle {
        void                    *private_data;
        struct llog_operations  *lgh_logops;
        atomic_t                 lgh_refcount;
+
+       int                     lgh_max_size;
+       __u32                   lgh_stale:1;
 };
 
 /* llog_osd.c */
@@ -528,6 +503,11 @@ static inline int llog_connect(struct llog_ctxt *ctxt,
        RETURN(rc);
 }
 
+static inline int llog_is_full(struct llog_handle *llh)
+{
+       return llh->lgh_last_idx >= LLOG_HDR_BITMAP_SIZE(llh->lgh_hdr) - 1;
+}
+
 struct llog_cfg_rec {
        struct llog_rec_hdr     lcr_hdr;
        struct lustre_cfg       lcr_cfg;