Whamcloud - gitweb
git://git.whamcloud.com
/
fs
/
lustre-release.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
LU-6838 llog: limit file size of plain logs
[fs/lustre-release.git]
/
lustre
/
include
/
lustre_log.h
diff --git
a/lustre/include/lustre_log.h
b/lustre/include/lustre_log.h
index
71bff91
..
fe107c7
100644
(file)
--- a/
lustre/include/lustre_log.h
+++ b/
lustre/include/lustre_log.h
@@
-106,6
+106,7
@@
int llog_backup(const struct lu_env *env, struct obd_device *obd,
char *name, char *backup);
int llog_read_header(const struct lu_env *env, struct llog_handle *handle,
const struct obd_uuid *uuid);
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
/* llog_process flags */
#define LLOG_FLAG_NODEAMON 0x0001
@@
-153,16
+154,15
@@
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 *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);
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);
int llog_cat_reverse_process(const struct lu_env *env,
struct llog_handle *cat_llh, llog_cb_t cb,
void *data);
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,
/* llog_obd.c */
int llog_setup(const struct lu_env *env, struct obd_device *obd,
struct obd_llog_group *olg, int index,
@@
-263,7
+263,7
@@
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 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.
size_t lgh_hdr_size;
struct dt_object *lgh_obj;
/* For a Catalog, is the last/newest used index for a plain slot.
@@
-275,6
+275,7
@@
struct llog_handle {
__u64 lgh_cur_offset; /* used during llog_process */
/* used during llog_osd_write_rec */
__u64 lgh_write_offset;
__u64 lgh_cur_offset; /* used during llog_process */
/* used during llog_osd_write_rec */
__u64 lgh_write_offset;
+ int lgh_max_size;
struct llog_ctxt *lgh_ctxt;
union {
struct plain_handle_data phd;
struct llog_ctxt *lgh_ctxt;
union {
struct plain_handle_data phd;