* 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/
*/
#include <obd_class.h>
-#include <lustre/lustre_idl.h>
#include <dt_object.h>
-#include <lustre_log_user.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)
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
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,
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 */
void *private_data;
struct llog_operations *lgh_logops;
atomic_t lgh_refcount;
+
+ int lgh_max_size;
+ __u32 lgh_stale:1;
};
/* llog_osd.c */
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;