X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fobdclass%2Fllog_internal.h;h=05330f8ec737699e1eff77ba31510dbb5d0acd54;hb=9fb46705ae86aa2c0ac29427f0ff24f923560eb7;hp=d83733e1c62fab3b7a272c4abd33cc97ab075b89;hpb=a928591d58b5d0dbbcc9a7f534dca2b6df22da9e;p=fs%2Flustre-release.git diff --git a/lustre/obdclass/llog_internal.h b/lustre/obdclass/llog_internal.h index d83733e..05330f8 100644 --- a/lustre/obdclass/llog_internal.h +++ b/lustre/obdclass/llog_internal.h @@ -1,6 +1,4 @@ -/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*- - * vim:expandtab:shiftwidth=8:tabstop=8: - * +/* * GPL HEADER START * * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. @@ -26,7 +24,7 @@ * GPL HEADER END */ /* - * Copyright 2008 Sun Microsystems, Inc. All rights reserved + * Copyright (c) 2003, 2010, Oracle and/or its affiliates. All rights reserved. * Use is subject to license terms. */ /* @@ -45,11 +43,50 @@ struct llog_process_info { void *lpi_cbdata; void *lpi_catdata; int lpi_rc; - struct completion lpi_completion; + int lpi_flags; + struct completion lpi_completion; + const struct lu_env *lpi_env; + }; -int llog_cat_id2handle(struct llog_handle *cathandle, struct llog_handle **res, - struct llog_logid *logid); -int class_config_dump_handler(struct llog_handle * handle, - struct llog_rec_hdr *rec, void *data); +struct llog_thread_info { + struct lu_attr lgi_attr; + struct lu_fid lgi_fid; + struct llog_logid lgi_logid; + struct dt_object_format lgi_dof; + struct llog_process_data lgi_lpd; + struct lustre_mdt_attrs lgi_lma_attr; + + struct lu_buf lgi_buf; + loff_t lgi_off; + + struct llog_rec_hdr lgi_lrh; + struct llog_rec_tail lgi_tail; + struct llog_logid_rec lgi_lid; +}; + +extern struct lu_context_key llog_thread_key; + +static inline struct llog_thread_info *llog_info(const struct lu_env *env) +{ + struct llog_thread_info *lgi; + + lgi = lu_context_key_get(&env->le_ctx, &llog_thread_key); + LASSERT(lgi); + return lgi; +} + +int llog_info_init(void); +void llog_info_fini(void); + +int llog_cat_id2handle(const struct lu_env *env, struct llog_handle *cathandle, + struct llog_handle **res, struct llog_logid *logid); +int class_config_dump_handler(const struct lu_env *env, + struct llog_handle *handle, + struct llog_rec_hdr *rec, void *data); +int class_config_parse_rec(struct llog_rec_hdr *rec, char *buf, int size); +int llog_process_or_fork(const struct lu_env *env, + struct llog_handle *loghandle, + llog_cb_t cb, void *data, void *catdata, bool fork); +int llog_cat_set_first_idx(struct llog_handle *cathandle, int index); #endif