1 files changed, 128 insertions, 8 deletions

diff --git a/fs/ocfs2/dlmglue.c b/fs/ocfs2/dlmglue.c
index 394d25a131a5..eae3d643a5e4 100644
--- a/fs/ocfs2/dlmglue.c
+++ b/fs/ocfs2/dlmglue.c
@@ -31,6 +31,7 @@
 #include <linux/pagemap.h>
 #include <linux/debugfs.h>
 #include <linux/seq_file.h>
+#include <linux/time.h>
 
 #define MLOG_MASK_PREFIX ML_DLM_GLUE
 #include <cluster/masklog.h>
@@ -59,6 +60,9 @@ struct ocfs2_mask_waiter {
         struct completion       mw_complete;
         unsigned long           mw_mask;
         unsigned long           mw_goal;
+#ifdef CONFIG_OCFS2_FS_STATS
+        unsigned long long      mw_lock_start;
+#endif
 };
 
 static struct ocfs2_super *ocfs2_get_dentry_osb(struct ocfs2_lock_res *lockres);
@@ -366,6 +370,75 @@ static void ocfs2_remove_lockres_tracking(struct ocfs2_lock_res *res)
         spin_unlock(&ocfs2_dlm_tracking_lock);
 }
 
+#ifdef CONFIG_OCFS2_FS_STATS
+static void ocfs2_init_lock_stats(struct ocfs2_lock_res *res)
+{
+        res->l_lock_num_prmode = 0;
+        res->l_lock_num_prmode_failed = 0;
+        res->l_lock_total_prmode = 0;
+        res->l_lock_max_prmode = 0;
+        res->l_lock_num_exmode = 0;
+        res->l_lock_num_exmode_failed = 0;
+        res->l_lock_total_exmode = 0;
+        res->l_lock_max_exmode = 0;
+        res->l_lock_refresh = 0;
+}
+
+static void ocfs2_update_lock_stats(struct ocfs2_lock_res *res, int level,
+                                    struct ocfs2_mask_waiter *mw, int ret)
+{
+        unsigned long long *num, *sum;
+        unsigned int *max, *failed;
+        struct timespec ts = current_kernel_time();
+        unsigned long long time = timespec_to_ns(&ts) - mw->mw_lock_start;
+
+        if (level == LKM_PRMODE) {
+                num = &res->l_lock_num_prmode;
+                sum = &res->l_lock_total_prmode;
+                max = &res->l_lock_max_prmode;
+                failed = &res->l_lock_num_prmode_failed;
+        } else if (level == LKM_EXMODE) {
+                num = &res->l_lock_num_exmode;
+                sum = &res->l_lock_total_exmode;
+                max = &res->l_lock_max_exmode;
+                failed = &res->l_lock_num_exmode_failed;
+        } else
+                return;
+
+        (*num)++;
+        (*sum) += time;
+        if (time > *max)
+                *max = time;
+        if (ret)
+                (*failed)++;
+}
+
+static inline void ocfs2_track_lock_refresh(struct ocfs2_lock_res *lockres)
+{
+        lockres->l_lock_refresh++;
+}
+
+static inline void ocfs2_init_start_time(struct ocfs2_mask_waiter *mw)
+{
+        struct timespec ts = current_kernel_time();
+        mw->mw_lock_start = timespec_to_ns(&ts);
+}
+#else
+static inline void ocfs2_init_lock_stats(struct ocfs2_lock_res *res)
+{
+}
+static inline void ocfs2_update_lock_stats(struct ocfs2_lock_res *res,
+                           int level, struct ocfs2_mask_waiter *mw, int ret)
+{
+}
+static inline void ocfs2_track_lock_refresh(struct ocfs2_lock_res *lockres)
+{
+}
+static inline void ocfs2_init_start_time(struct ocfs2_mask_waiter *mw)
+{
+}
+#endif
+
 static void ocfs2_lock_res_init_common(struct ocfs2_super *osb,
                                        struct ocfs2_lock_res *res,
                                        enum ocfs2_lock_type type,
@@ -385,6 +458,8 @@ static void ocfs2_lock_res_init_common(struct ocfs2_super *osb,
         res->l_flags         = OCFS2_LOCK_INITIALIZED;
 
         ocfs2_add_lockres_tracking(res, osb->osb_dlm_debug);
+
+        ocfs2_init_lock_stats(res);
 }
 
 void ocfs2_lock_res_init_once(struct ocfs2_lock_res *res)
@@ -1048,6 +1123,7 @@ static void ocfs2_init_mask_waiter(struct ocfs2_mask_waiter *mw)
 {
         INIT_LIST_HEAD(&mw->mw_item);
         init_completion(&mw->mw_complete);
+        ocfs2_init_start_time(mw);
 }
 
 static int ocfs2_wait_for_mask(struct ocfs2_mask_waiter *mw)
@@ -1254,6 +1330,7 @@ out:
                         goto again;
                 mlog_errno(ret);
         }
+        ocfs2_update_lock_stats(lockres, level, &mw, ret);
 
         mlog_exit(ret);
         return ret;
@@ -1554,8 +1631,8 @@ out:
  */
 int ocfs2_file_lock(struct file *file, int ex, int trylock)
 {
-        int ret, level = ex ? LKM_EXMODE : LKM_PRMODE;
-        unsigned int lkm_flags = trylock ? LKM_NOQUEUE : 0;
+        int ret, level = ex ? DLM_LOCK_EX : DLM_LOCK_PR;
+        unsigned int lkm_flags = trylock ? DLM_LKF_NOQUEUE : 0;
         unsigned long flags;
         struct ocfs2_file_private *fp = file->private_data;
         struct ocfs2_lock_res *lockres = &fp->fp_flock;
@@ -1582,7 +1659,7 @@ int ocfs2_file_lock(struct file *file, int ex, int trylock)
                  * Get the lock at NLMODE to start - that way we
                  * can cancel the upconvert request if need be.
                  */
-                ret = ocfs2_lock_create(osb, lockres, LKM_NLMODE, 0);
+                ret = ocfs2_lock_create(osb, lockres, DLM_LOCK_NL, 0);
                 if (ret < 0) {
                         mlog_errno(ret);
                         goto out;
@@ -1597,7 +1674,7 @@ int ocfs2_file_lock(struct file *file, int ex, int trylock)
         }
 
         lockres->l_action = OCFS2_AST_CONVERT;
-        lkm_flags |= LKM_CONVERT;
+        lkm_flags |= DLM_LKF_CONVERT;
         lockres->l_requested = level;
         lockres_or_flags(lockres, OCFS2_LOCK_BUSY);
 
@@ -1664,7 +1741,7 @@ void ocfs2_file_unlock(struct file *file)
         if (!(lockres->l_flags & OCFS2_LOCK_ATTACHED))
                 return;
 
-        if (lockres->l_level == LKM_NLMODE)
+        if (lockres->l_level == DLM_LOCK_NL)
                 return;
 
         mlog(0, "Unlock: \"%s\" flags: 0x%lx, level: %d, act: %d\n",
@@ -1678,11 +1755,11 @@ void ocfs2_file_unlock(struct file *file)
         lockres_or_flags(lockres, OCFS2_LOCK_BLOCKED);
         lockres->l_blocking = DLM_LOCK_EX;
 
-        gen = ocfs2_prepare_downconvert(lockres, LKM_NLMODE);
+        gen = ocfs2_prepare_downconvert(lockres, DLM_LOCK_NL);
         lockres_add_mask_waiter(lockres, &mw, OCFS2_LOCK_BUSY, 0);
         spin_unlock_irqrestore(&lockres->l_lock, flags);
 
-        ret = ocfs2_downconvert_lock(osb, lockres, LKM_NLMODE, 0, gen);
+        ret = ocfs2_downconvert_lock(osb, lockres, DLM_LOCK_NL, 0, gen);
         if (ret) {
                 mlog_errno(ret);
                 return;
@@ -1983,6 +2060,7 @@ static int ocfs2_inode_lock_update(struct inode *inode,
                                 le32_to_cpu(fe->i_flags));
 
                 ocfs2_refresh_inode(inode, fe);
+                ocfs2_track_lock_refresh(lockres);
         }
 
         status = 0;
@@ -2267,6 +2345,7 @@ int ocfs2_super_lock(struct ocfs2_super *osb,
 
                 if (status < 0)
                         mlog_errno(status);
+                ocfs2_track_lock_refresh(lockres);
         }
 bail:
         mlog_exit(status);
@@ -2461,7 +2540,7 @@ static void *ocfs2_dlm_seq_next(struct seq_file *m, void *v, loff_t *pos)
 }
 
 /* So that debugfs.ocfs2 can determine which format is being used */
-#define OCFS2_DLM_DEBUG_STR_VERSION 1
+#define OCFS2_DLM_DEBUG_STR_VERSION 2
 static int ocfs2_dlm_seq_show(struct seq_file *m, void *v)
 {
         int i;
@@ -2502,6 +2581,47 @@ static int ocfs2_dlm_seq_show(struct seq_file *m, void *v)
         for(i = 0; i < DLM_LVB_LEN; i++)
                 seq_printf(m, "0x%x\t", lvb[i]);
 
+#ifdef CONFIG_OCFS2_FS_STATS
+# define lock_num_prmode(_l)            (_l)->l_lock_num_prmode
+# define lock_num_exmode(_l)            (_l)->l_lock_num_exmode
+# define lock_num_prmode_failed(_l)     (_l)->l_lock_num_prmode_failed
+# define lock_num_exmode_failed(_l)     (_l)->l_lock_num_exmode_failed
+# define lock_total_prmode(_l)          (_l)->l_lock_total_prmode
+# define lock_total_exmode(_l)          (_l)->l_lock_total_exmode
+# define lock_max_prmode(_l)            (_l)->l_lock_max_prmode
+# define lock_max_exmode(_l)            (_l)->l_lock_max_exmode
+# define lock_refresh(_l)               (_l)->l_lock_refresh
+#else
+# define lock_num_prmode(_l)            (0ULL)
+# define lock_num_exmode(_l)            (0ULL)
+# define lock_num_prmode_failed(_l)     (0)
+# define lock_num_exmode_failed(_l)     (0)
+# define lock_total_prmode(_l)          (0ULL)
+# define lock_total_exmode(_l)          (0ULL)
+# define lock_max_prmode(_l)            (0)
+# define lock_max_exmode(_l)            (0)
+# define lock_refresh(_l)               (0)
+#endif
+        /* The following seq_print was added in version 2 of this output */
+        seq_printf(m, "%llu\t"
+                   "%llu\t"
+                   "%u\t"
+                   "%u\t"
+                   "%llu\t"
+                   "%llu\t"
+                   "%u\t"
+                   "%u\t"
+                   "%u\t",
+                   lock_num_prmode(lockres),
+                   lock_num_exmode(lockres),
+                   lock_num_prmode_failed(lockres),
+                   lock_num_exmode_failed(lockres),
+                   lock_total_prmode(lockres),
+                   lock_total_exmode(lockres),
+                   lock_max_prmode(lockres),
+                   lock_max_exmode(lockres),
+                   lock_refresh(lockres));
+
         /* End the line */
         seq_printf(m, "\n");
         return 0;