LU-2240 fld: Move range lookup to fld.

[fs/lustre-release.git] / lustre / fld / fld_internal.h

diff --git a/lustre/fld/fld_internal.h b/lustre/fld/fld_internal.h
index cdd5e3e..eb951cc 100644 (file)
--- 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.
@@ -81,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.
+        */
+       spinlock_t               fci_lock;
 
         /**
          * Cache shrink threshold */
@@ -114,6 +112,7 @@ struct fld_cache {
         /**
          * Cache name used for debug and messages. */
         char                     fci_name[80];
+       int                     fci_no_shrink:1;
 };
 
 enum fld_op {
@@ -150,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);
+int fld_index_init(const struct lu_env *env, struct lu_server_fld *fld,
+                  struct dt_device *dt);
 
-void fld_trans_stop(struct lu_server_fld *fld,
-                    const struct lu_env *env, struct thandle* th);
+void fld_index_fini(const struct lu_env *env, struct lu_server_fld *fld);
 
-int fld_index_init(struct lu_server_fld *fld,
-                   const struct lu_env *env,
-                   struct dt_device *dt);
+int fld_declare_index_create(const struct lu_env *env,
+                            struct lu_server_fld *fld,
+                            const struct lu_seq_range *new,
+                            struct thandle *th);
 
-void fld_index_fini(struct lu_server_fld *fld,
-                    const struct lu_env *env);
+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_create(struct lu_server_fld *fld,
-                     const struct lu_env *env,
-                     const struct lu_seq_range *range,
-                     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_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);
@@ -197,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)
 {
@@ -216,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 */