X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Finclude%2Flustre_fld.h;h=3d8288b7da89ab5984f4fe264814f1c1fbf7cc69;hb=bb0e7e7d04a7319f56092d2412a5c8b88467541d;hp=8e329c8e982c6cb78b27f6db87bb13a414d403d3;hpb=aafe85fac4aa0589185048c57a0cce2b8c6618ee;p=fs%2Flustre-release.git diff --git a/lustre/include/lustre_fld.h b/lustre/include/lustre_fld.h index 8e329c8..3d8288b 100644 --- a/lustre/include/lustre_fld.h +++ b/lustre/include/lustre_fld.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,7 +23,7 @@ * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved. * Use is subject to license terms. * - * Copyright (c) 2011, 2013, Intel Corporation. + * Copyright (c) 2011, 2015, Intel Corporation. */ /* * This file is part of Lustre, http://www.lustre.org/ @@ -42,19 +38,19 @@ * @{ */ -#include -#include -#include - +#include #include +#include +#include +struct lu_env; struct lu_client_fld; struct lu_server_fld; struct lu_fld_hash; struct fld_cache; - -extern const struct dt_index_features fld_index_features; -extern const char fld_index_name[]; +struct thandle; +struct dt_device; +struct dt_object; /* * FLD (Fid Location Database) interface. @@ -64,18 +60,18 @@ enum { LUSTRE_CLI_FLD_HASH_RRB }; - struct lu_fld_target { - cfs_list_t ft_chain; - struct obd_export *ft_exp; - struct lu_server_fld *ft_srv; - __u64 ft_idx; + struct list_head ft_chain; + struct obd_export *ft_exp; + struct lu_server_fld *ft_srv; + __u64 ft_idx; }; struct lu_server_fld { - /** - * Fld dir proc entry. */ - cfs_proc_dir_entry_t *lsf_proc_dir; + /** + * Fld dir debugfs entry. + */ + struct dentry *lsf_debugfs_entry; /** * /fld file object device */ @@ -94,20 +90,34 @@ struct lu_server_fld { * Protect index modifications */ struct mutex lsf_lock; - /** - * Fld service name in form "fld-srv-lustre-MDTXXX" */ - char lsf_name[80]; + /** + * Fld service name in form "fld-srv-lustre-MDTXXX" + */ + char lsf_name[LUSTRE_MDT_MAXNAMELEN]; + + int (*lsf_seq_lookup)(const struct lu_env *env, + struct lu_server_fld *fld, u64 seq, + struct lu_seq_range *range); + + /** + * Just reformatted or upgraded, and this flag is being + * used to check whether the local FLDB is needs to be + * synced with global FLDB(in MDT0), and it is only needed + * if the MDT is upgraded from < 2.6 to 2.6, i.e. when the + * local FLDB is being invited */ + unsigned int lsf_new:1; }; struct lu_client_fld { - /** - * Client side proc entry. */ - cfs_proc_dir_entry_t *lcf_proc_dir; + /** + * Client side debugfs entry. + */ + struct dentry *lcf_debugfs_entry; - /** - * List of exports client FLD knows about. */ - cfs_list_t lcf_targets; + /** + * List of exports client FLD knows about. */ + struct list_head lcf_targets; /** * Current hash to be used to chose an export. */ @@ -125,42 +135,26 @@ struct lu_client_fld { * Client FLD cache. */ struct fld_cache *lcf_cache; - /** - * Client fld proc entry name. */ - char lcf_name[80]; - - const struct lu_context *lcf_ctx; - - int lcf_flags; -}; - -/** - * number of blocks to reserve for particular operations. Should be function of - * ... something. Stub for now. - */ -enum { - /* one insert operation can involve two delete and one insert */ - FLD_TXN_INDEX_INSERT_CREDITS = 60, - FLD_TXN_INDEX_DELETE_CREDITS = 20, + /** + * Client fld debugfs entry name. + */ + char lcf_name[LUSTRE_MDT_MAXNAMELEN]; }; -int fld_query(struct com_thread_info *info); - /* Server methods */ int fld_server_init(const struct lu_env *env, struct lu_server_fld *fld, - struct dt_device *dt, const char *prefix, int mds_node_id, - __u32 lsr_flags); + struct dt_device *dt, const char *prefix, int type); void fld_server_fini(const struct lu_env *env, struct lu_server_fld *fld); int fld_declare_server_create(const struct lu_env *env, struct lu_server_fld *fld, - struct lu_seq_range *new, + const struct lu_seq_range *range, struct thandle *th); int fld_server_create(const struct lu_env *env, struct lu_server_fld *fld, - struct lu_seq_range *add_range, + const struct lu_seq_range *add_range, struct thandle *th); int fld_insert_entry(const struct lu_env *env, @@ -168,7 +162,13 @@ int fld_insert_entry(const struct lu_env *env, const struct lu_seq_range *range); int fld_server_lookup(const struct lu_env *env, struct lu_server_fld *fld, - seqno_t seq, struct lu_seq_range *range); + u64 seq, struct lu_seq_range *range); + +int fld_local_lookup(const struct lu_env *env, struct lu_server_fld *fld, + u64 seq, struct lu_seq_range *range); + +int fld_update_from_controller(const struct lu_env *env, + struct lu_server_fld *fld); /* Client methods */ int fld_client_init(struct lu_client_fld *fld, @@ -178,15 +178,14 @@ void fld_client_fini(struct lu_client_fld *fld); void fld_client_flush(struct lu_client_fld *fld); -int fld_client_lookup(struct lu_client_fld *fld, seqno_t seq, mdsno_t *mds, +int fld_client_lookup(struct lu_client_fld *fld, u64 seq, u32 *mds, __u32 flags, const struct lu_env *env); int fld_client_create(struct lu_client_fld *fld, struct lu_seq_range *range, const struct lu_env *env); -int fld_client_delete(struct lu_client_fld *fld, - seqno_t seq, +int fld_client_delete(struct lu_client_fld *fld, u64 seq, const struct lu_env *env); int fld_client_add_target(struct lu_client_fld *fld, @@ -195,7 +194,7 @@ int fld_client_add_target(struct lu_client_fld *fld, int fld_client_del_target(struct lu_client_fld *fld, __u64 idx); -void fld_client_proc_fini(struct lu_client_fld *fld); +void fld_client_debugfs_fini(struct lu_client_fld *fld); /** @} fld */