X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Ffld%2Ffld_internal.h;h=fbb050a3470d3c0f287c1d58b7e619954e4f62b5;hb=0c00b4a10c951a7a5cba075a3e8181662dab50b8;hp=6179b3ee86b531b4fcf28ba1864b566aeb9f5131;hpb=22464d1230ed58461f51d881f512d5e16644a735;p=fs%2Flustre-release.git

diff --git a/lustre/fld/fld_internal.h b/lustre/fld/fld_internal.h
index 6179b3e..fbb050a 100644
--- a/lustre/fld/fld_internal.h
+++ b/lustre/fld/fld_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.
@@ -28,7 +26,8 @@
 /*
  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
  * Use is subject to license terms.
- * Copyright (c) 2011 Whamcloud, Inc.
+ *
+ * Copyright (c) 2012, 2013, Intel Corporation.
  */
 /*
  * This file is part of Lustre, http://www.lustre.org/
@@ -80,11 +79,11 @@ struct fld_cache_entry {
 };
 
 struct fld_cache {
-        /**
-         * Cache guard, protects fci_hash mostly because others immutable after
-         * init is finished.
-         */
-        cfs_spinlock_t           fci_lock;
+	/**
+	 * Cache guard, protects fci_hash mostly because others immutable after
+	 * init is finished.
+	 */
+	rwlock_t		 fci_lock;
 
         /**
          * Cache shrink threshold */
@@ -113,6 +112,7 @@ struct fld_cache {
         /**
          * Cache name used for debug and messages. */
         char                     fci_name[80];
+	unsigned int		 fci_no_shrink:1;
 };
 
 enum fld_op {
@@ -149,35 +149,23 @@ struct fld_thread_info {
         struct lu_seq_range fti_irange;
 };
 
+extern struct lu_context_key fld_thread_key;
 
-struct thandle *fld_trans_create(struct lu_server_fld *fld,
-                                const struct lu_env *env);
-int fld_trans_start(struct lu_server_fld *fld,
-                    const struct lu_env *env, struct thandle *th);
-
-void fld_trans_stop(struct lu_server_fld *fld,
-                    const struct lu_env *env, struct thandle* th);
-
-int fld_index_init(struct lu_server_fld *fld,
-                   const struct lu_env *env,
-                   struct dt_device *dt);
+int fld_index_init(const struct lu_env *env, struct lu_server_fld *fld,
+		   struct dt_device *dt);
 
-void fld_index_fini(struct lu_server_fld *fld,
-                    const struct lu_env *env);
+void fld_index_fini(const struct lu_env *env, struct lu_server_fld *fld);
 
-int fld_index_create(struct lu_server_fld *fld,
-                     const struct lu_env *env,
-                     const struct lu_seq_range *range,
-                     struct thandle *th);
+int fld_declare_index_create(const struct lu_env *env,
+			     struct lu_server_fld *fld,
+			     const struct lu_seq_range *new,
+			     struct thandle *th);
 
-int fld_index_delete(struct lu_server_fld *fld,
-                     const struct lu_env *env,
-                     struct lu_seq_range *range,
-                     struct thandle *th);
+int fld_index_create(const struct lu_env *env, struct lu_server_fld *fld,
+		     const struct lu_seq_range *new, struct thandle *th);
 
-int fld_index_lookup(struct lu_server_fld *fld,
-                     const struct lu_env *env,
-                     seqno_t seq, struct lu_seq_range *range);
+int fld_index_lookup(const struct lu_env *env, struct lu_server_fld *fld,
+		     seqno_t seq, struct lu_seq_range *range);
 
 int fld_client_rpc(struct obd_export *exp,
                    struct lu_seq_range *range, __u32 fld_op);
@@ -196,15 +184,33 @@ void fld_cache_fini(struct fld_cache *cache);
 
 void fld_cache_flush(struct fld_cache *cache);
 
-void fld_cache_insert(struct fld_cache *cache,
-                      const struct lu_seq_range *range);
+int fld_cache_insert(struct fld_cache *cache,
+		     const struct lu_seq_range *range);
+
+struct fld_cache_entry
+*fld_cache_entry_create(const struct lu_seq_range *range);
 
+int fld_cache_insert_nolock(struct fld_cache *cache,
+			    struct fld_cache_entry *f_new);
 void fld_cache_delete(struct fld_cache *cache,
                       const struct lu_seq_range *range);
-
+void fld_cache_delete_nolock(struct fld_cache *cache,
+			     const struct lu_seq_range *range);
 int fld_cache_lookup(struct fld_cache *cache,
                      const seqno_t seq, struct lu_seq_range *range);
 
+struct fld_cache_entry*
+fld_cache_entry_lookup(struct fld_cache *cache, struct lu_seq_range *range);
+void fld_cache_entry_delete(struct fld_cache *cache,
+			    struct fld_cache_entry *node);
+void fld_dump_cache_entries(struct fld_cache *cache);
+
+struct fld_cache_entry
+*fld_cache_entry_lookup_nolock(struct fld_cache *cache,
+			      struct lu_seq_range *range);
+int fld_write_range(const struct lu_env *env, struct dt_object *dt,
+		    const struct lu_seq_range *range, struct thandle *th);
+
 static inline const char *
 fld_target_name(struct lu_fld_target *tar)
 {
@@ -215,5 +221,5 @@ fld_target_name(struct lu_fld_target *tar)
 }
 
 extern cfs_proc_dir_entry_t *fld_type_proc_dir;
-
+extern struct file_operations fld_proc_seq_fops;
 #endif /* __FLD_INTERNAL_H */