b=22176 Add .sync_fs super block handler

[fs/lustre-release.git] / lustre / lov / lov_internal.h

diff --git a/lustre/lov/lov_internal.h b/lustre/lov/lov_internal.h
index 4b17d81..9e640b2 100644 (file)
--- a/lustre/lov/lov_internal.h
+++ b/lustre/lov/lov_internal.h
@@ -26,7 +26,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.
  */
 /*
@@ -42,7 +42,7 @@
 
 struct lov_lock_handles {
         struct portals_handle   llh_handle;
-        atomic_t                llh_refcount;
+        cfs_atomic_t            llh_refcount;
         int                     llh_stripe_count;
         struct lustre_handle    llh_handles[0];
 };
@@ -51,7 +51,7 @@ struct lov_request {
         struct obd_info          rq_oi;
         struct lov_request_set  *rq_rqset;
 
-        struct list_head         rq_link;
+        cfs_list_t               rq_link;
 
         int                      rq_idx;        /* index in lov->tgts array */
         int                      rq_stripe;     /* stripe number */
@@ -66,7 +66,7 @@ struct lov_request {
 struct lov_request_set {
         struct ldlm_enqueue_info*set_ei;
         struct obd_info         *set_oi;
-        atomic_t                 set_refcount;
+        cfs_atomic_t             set_refcount;
         struct obd_export       *set_exp;
         /* XXX: There is @set_exp already, however obd_statfs gets obd_device
            only. */
@@ -80,9 +80,9 @@ struct lov_request_set {
         obd_count                set_oabufs;
         struct brw_page         *set_pga;
         struct lov_lock_handles *set_lockh;
-        struct list_head         set_list;
+        cfs_list_t               set_list;
         cfs_waitq_t              set_waitq;
-        spinlock_t               set_lock;
+        cfs_spinlock_t           set_lock;
 };
 
 extern cfs_mem_cache_t *lov_oinfo_slab;
@@ -90,9 +90,9 @@ extern cfs_mem_cache_t *lov_oinfo_slab;
 static inline void lov_llh_addref(void *llhp)
 {
         struct lov_lock_handles *llh = llhp;
-        atomic_inc(&llh->llh_refcount);
+        cfs_atomic_inc(&llh->llh_refcount);
         CDEBUG(D_INFO, "GETting llh %p : new refcount %d\n", llh,
-               atomic_read(&llh->llh_refcount));
+               cfs_atomic_read(&llh->llh_refcount));
 }
 
 static inline struct lov_lock_handles *lov_llh_new(struct lov_stripe_md *lsm)
@@ -103,13 +103,28 @@ static inline struct lov_lock_handles *lov_llh_new(struct lov_stripe_md *lsm)
                   sizeof(*llh->llh_handles) * lsm->lsm_stripe_count);
         if (llh == NULL)
                 return NULL;
-        atomic_set(&llh->llh_refcount, 2);
+        cfs_atomic_set(&llh->llh_refcount, 2);
         llh->llh_stripe_count = lsm->lsm_stripe_count;
         CFS_INIT_LIST_HEAD(&llh->llh_handle.h_link);
         class_handle_hash(&llh->llh_handle, lov_llh_addref);
         return llh;
 }
 
+void lov_finish_set(struct lov_request_set *set);
+
+static inline void lov_get_reqset(struct lov_request_set *set)
+{
+        LASSERT(set != NULL);
+        LASSERT(cfs_atomic_read(&set->set_refcount) > 0);
+        cfs_atomic_inc(&set->set_refcount);
+}
+
+static inline void lov_put_reqset(struct lov_request_set *set)
+{
+        if (cfs_atomic_dec_and_test(&set->set_refcount))
+                lov_finish_set(set);
+}
+
 static inline struct lov_lock_handles *
 lov_handle2llh(struct lustre_handle *handle)
 {
@@ -120,14 +135,14 @@ lov_handle2llh(struct lustre_handle *handle)
 static inline void lov_llh_put(struct lov_lock_handles *llh)
 {
         CDEBUG(D_INFO, "PUTting llh %p : new refcount %d\n", llh,
-               atomic_read(&llh->llh_refcount) - 1);
-        LASSERT(atomic_read(&llh->llh_refcount) > 0 &&
-                atomic_read(&llh->llh_refcount) < 0x5a5a);
-        if (atomic_dec_and_test(&llh->llh_refcount)) {
+               cfs_atomic_read(&llh->llh_refcount) - 1);
+        LASSERT(cfs_atomic_read(&llh->llh_refcount) > 0 &&
+                cfs_atomic_read(&llh->llh_refcount) < 0x5a5a);
+        if (cfs_atomic_dec_and_test(&llh->llh_refcount)) {
                 class_handle_unhash(&llh->llh_handle);
                 /* The structure may be held by other threads because RCU.
                  *   -jxiong */
-                if (atomic_read(&llh->llh_refcount))
+                if (cfs_atomic_read(&llh->llh_refcount))
                         return;
 
                 OBD_FREE_RCU(llh, sizeof *llh +
@@ -185,8 +200,6 @@ int lov_prep_create_set(struct obd_export *exp, struct obd_info *oifo,
                         struct obd_trans_info *oti,
                         struct lov_request_set **reqset);
 int cb_create_update(void *cookie, int rc);
-int lov_update_create_set(struct lov_request_set *set,
-                          struct lov_request *req, int rc);
 int lov_fini_create_set(struct lov_request_set *set, struct lov_stripe_md **ea);
 int lov_prep_brw_set(struct obd_export *exp, struct obd_info *oinfo,
                      obd_count oa_bufs, struct brw_page *pga,
@@ -245,6 +258,10 @@ int lov_fini_statfs(struct obd_device *obd, struct obd_statfs *osfs,
 int lov_fini_statfs_set(struct lov_request_set *set);
 int lov_statfs_interpret(struct ptlrpc_request_set *rqset, void *data, int rc);
 
+int cb_sync_fs_update(void *cookie, int rc);
+int lov_fini_sync_fs_set(struct lov_request_set *set);
+int lov_prep_sync_fs_set(struct obd_device *obd, struct obd_info *oinfo,
+                         struct lov_request_set **reqset);
 /* lov_obd.c */
 void lov_fix_desc(struct lov_desc *desc);
 void lov_fix_desc_stripe_size(__u64 *val);
@@ -304,7 +321,7 @@ static inline void lprocfs_lov_init_vars(struct lprocfs_static_vars *lvars)
 extern struct lu_device_type lov_device_type;
 
 /* pools */
-extern lustre_hash_ops_t pool_hash_operations;
+extern cfs_hash_ops_t pool_hash_operations;
 /* ost_pool methods */
 int lov_ost_pool_init(struct ost_pool *op, unsigned int count);
 int lov_ost_pool_extend(struct ost_pool *op, unsigned int min_count);