aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--fs/dlm/debug_fs.c14
-rw-r--r--fs/dlm/dlm_internal.h2
-rw-r--r--fs/dlm/lock.c21
-rw-r--r--fs/dlm/netlink.c1
4 files changed, 19 insertions, 19 deletions
diff --git a/fs/dlm/debug_fs.c b/fs/dlm/debug_fs.c
index 8fc24f4507a3..19e4f9eb44e1 100644
--- a/fs/dlm/debug_fs.c
+++ b/fs/dlm/debug_fs.c
@@ -162,21 +162,21 @@ static int print_resource(struct dlm_rsb *res, struct seq_file *s)
162 162
163static void print_lock(struct seq_file *s, struct dlm_lkb *lkb, struct dlm_rsb *r) 163static void print_lock(struct seq_file *s, struct dlm_lkb *lkb, struct dlm_rsb *r)
164{ 164{
165 unsigned int waiting = 0; 165 u64 xid = 0;
166 uint64_t xid = 0; 166 u64 us;
167 167
168 if (lkb->lkb_flags & DLM_IFL_USER) { 168 if (lkb->lkb_flags & DLM_IFL_USER) {
169 if (lkb->lkb_ua) 169 if (lkb->lkb_ua)
170 xid = lkb->lkb_ua->xid; 170 xid = lkb->lkb_ua->xid;
171 } 171 }
172 172
173 if (lkb->lkb_timestamp) 173 /* microseconds since lkb was added to current queue */
174 waiting = jiffies_to_msecs(jiffies - lkb->lkb_timestamp); 174 us = ktime_to_us(ktime_sub(ktime_get(), lkb->lkb_timestamp));
175 175
176 /* id nodeid remid pid xid exflags flags sts grmode rqmode time_ms 176 /* id nodeid remid pid xid exflags flags sts grmode rqmode time_us
177 r_nodeid r_len r_name */ 177 r_nodeid r_len r_name */
178 178
179 seq_printf(s, "%x %d %x %u %llu %x %x %d %d %d %u %u %d \"%s\"\n", 179 seq_printf(s, "%x %d %x %u %llu %x %x %d %d %d %llu %u %d \"%s\"\n",
180 lkb->lkb_id, 180 lkb->lkb_id,
181 lkb->lkb_nodeid, 181 lkb->lkb_nodeid,
182 lkb->lkb_remid, 182 lkb->lkb_remid,
@@ -187,7 +187,7 @@ static void print_lock(struct seq_file *s, struct dlm_lkb *lkb, struct dlm_rsb *
187 lkb->lkb_status, 187 lkb->lkb_status,
188 lkb->lkb_grmode, 188 lkb->lkb_grmode,
189 lkb->lkb_rqmode, 189 lkb->lkb_rqmode,
190 waiting, 190 (unsigned long long)us,
191 r->res_nodeid, 191 r->res_nodeid,
192 r->res_length, 192 r->res_length,
193 r->res_name); 193 r->res_name);
diff --git a/fs/dlm/dlm_internal.h b/fs/dlm/dlm_internal.h
index 868e4c9ef127..e69135c83d5d 100644
--- a/fs/dlm/dlm_internal.h
+++ b/fs/dlm/dlm_internal.h
@@ -245,7 +245,7 @@ struct dlm_lkb {
245 struct list_head lkb_astqueue; /* need ast to be sent */ 245 struct list_head lkb_astqueue; /* need ast to be sent */
246 struct list_head lkb_ownqueue; /* list of locks for a process */ 246 struct list_head lkb_ownqueue; /* list of locks for a process */
247 struct list_head lkb_time_list; 247 struct list_head lkb_time_list;
248 unsigned long lkb_timestamp; 248 ktime_t lkb_timestamp;
249 unsigned long lkb_timeout_cs; 249 unsigned long lkb_timeout_cs;
250 250
251 char *lkb_lvbptr; 251 char *lkb_lvbptr;
diff --git a/fs/dlm/lock.c b/fs/dlm/lock.c
index 7b758dadbdd6..dfc57ae27045 100644
--- a/fs/dlm/lock.c
+++ b/fs/dlm/lock.c
@@ -742,6 +742,8 @@ static void add_lkb(struct dlm_rsb *r, struct dlm_lkb *lkb, int status)
742 742
743 DLM_ASSERT(!lkb->lkb_status, dlm_print_lkb(lkb);); 743 DLM_ASSERT(!lkb->lkb_status, dlm_print_lkb(lkb););
744 744
745 lkb->lkb_timestamp = ktime_get();
746
745 lkb->lkb_status = status; 747 lkb->lkb_status = status;
746 748
747 switch (status) { 749 switch (status) {
@@ -1011,10 +1013,8 @@ static void add_timeout(struct dlm_lkb *lkb)
1011{ 1013{
1012 struct dlm_ls *ls = lkb->lkb_resource->res_ls; 1014 struct dlm_ls *ls = lkb->lkb_resource->res_ls;
1013 1015
1014 if (is_master_copy(lkb)) { 1016 if (is_master_copy(lkb))
1015 lkb->lkb_timestamp = jiffies;
1016 return; 1017 return;
1017 }
1018 1018
1019 if (test_bit(LSFL_TIMEWARN, &ls->ls_flags) && 1019 if (test_bit(LSFL_TIMEWARN, &ls->ls_flags) &&
1020 !(lkb->lkb_exflags & DLM_LKF_NODLCKWT)) { 1020 !(lkb->lkb_exflags & DLM_LKF_NODLCKWT)) {
@@ -1029,7 +1029,6 @@ static void add_timeout(struct dlm_lkb *lkb)
1029 DLM_ASSERT(list_empty(&lkb->lkb_time_list), dlm_print_lkb(lkb);); 1029 DLM_ASSERT(list_empty(&lkb->lkb_time_list), dlm_print_lkb(lkb););
1030 mutex_lock(&ls->ls_timeout_mutex); 1030 mutex_lock(&ls->ls_timeout_mutex);
1031 hold_lkb(lkb); 1031 hold_lkb(lkb);
1032 lkb->lkb_timestamp = jiffies;
1033 list_add_tail(&lkb->lkb_time_list, &ls->ls_timeout); 1032 list_add_tail(&lkb->lkb_time_list, &ls->ls_timeout);
1034 mutex_unlock(&ls->ls_timeout_mutex); 1033 mutex_unlock(&ls->ls_timeout_mutex);
1035} 1034}
@@ -1057,6 +1056,7 @@ void dlm_scan_timeout(struct dlm_ls *ls)
1057 struct dlm_rsb *r; 1056 struct dlm_rsb *r;
1058 struct dlm_lkb *lkb; 1057 struct dlm_lkb *lkb;
1059 int do_cancel, do_warn; 1058 int do_cancel, do_warn;
1059 s64 wait_us;
1060 1060
1061 for (;;) { 1061 for (;;) {
1062 if (dlm_locking_stopped(ls)) 1062 if (dlm_locking_stopped(ls))
@@ -1067,14 +1067,15 @@ void dlm_scan_timeout(struct dlm_ls *ls)
1067 mutex_lock(&ls->ls_timeout_mutex); 1067 mutex_lock(&ls->ls_timeout_mutex);
1068 list_for_each_entry(lkb, &ls->ls_timeout, lkb_time_list) { 1068 list_for_each_entry(lkb, &ls->ls_timeout, lkb_time_list) {
1069 1069
1070 wait_us = ktime_to_us(ktime_sub(ktime_get(),
1071 lkb->lkb_timestamp));
1072
1070 if ((lkb->lkb_exflags & DLM_LKF_TIMEOUT) && 1073 if ((lkb->lkb_exflags & DLM_LKF_TIMEOUT) &&
1071 time_after_eq(jiffies, lkb->lkb_timestamp + 1074 wait_us >= (lkb->lkb_timeout_cs * 10000))
1072 lkb->lkb_timeout_cs * HZ/100))
1073 do_cancel = 1; 1075 do_cancel = 1;
1074 1076
1075 if ((lkb->lkb_flags & DLM_IFL_WATCH_TIMEWARN) && 1077 if ((lkb->lkb_flags & DLM_IFL_WATCH_TIMEWARN) &&
1076 time_after_eq(jiffies, lkb->lkb_timestamp + 1078 wait_us >= dlm_config.ci_timewarn_cs * 10000)
1077 dlm_config.ci_timewarn_cs * HZ/100))
1078 do_warn = 1; 1079 do_warn = 1;
1079 1080
1080 if (!do_cancel && !do_warn) 1081 if (!do_cancel && !do_warn)
@@ -1120,12 +1121,12 @@ void dlm_scan_timeout(struct dlm_ls *ls)
1120void dlm_adjust_timeouts(struct dlm_ls *ls) 1121void dlm_adjust_timeouts(struct dlm_ls *ls)
1121{ 1122{
1122 struct dlm_lkb *lkb; 1123 struct dlm_lkb *lkb;
1123 long adj = jiffies - ls->ls_recover_begin; 1124 u64 adj_us = jiffies_to_usecs(jiffies - ls->ls_recover_begin);
1124 1125
1125 ls->ls_recover_begin = 0; 1126 ls->ls_recover_begin = 0;
1126 mutex_lock(&ls->ls_timeout_mutex); 1127 mutex_lock(&ls->ls_timeout_mutex);
1127 list_for_each_entry(lkb, &ls->ls_timeout, lkb_time_list) 1128 list_for_each_entry(lkb, &ls->ls_timeout, lkb_time_list)
1128 lkb->lkb_timestamp += adj; 1129 lkb->lkb_timestamp = ktime_add_us(lkb->lkb_timestamp, adj_us);
1129 mutex_unlock(&ls->ls_timeout_mutex); 1130 mutex_unlock(&ls->ls_timeout_mutex);
1130} 1131}
1131 1132
diff --git a/fs/dlm/netlink.c b/fs/dlm/netlink.c
index 18bda83cc892..46e582c8d603 100644
--- a/fs/dlm/netlink.c
+++ b/fs/dlm/netlink.c
@@ -115,7 +115,6 @@ static void fill_data(struct dlm_lock_data *data, struct dlm_lkb *lkb)
115 data->status = lkb->lkb_status; 115 data->status = lkb->lkb_status;
116 data->grmode = lkb->lkb_grmode; 116 data->grmode = lkb->lkb_grmode;
117 data->rqmode = lkb->lkb_rqmode; 117 data->rqmode = lkb->lkb_rqmode;
118 data->timestamp = lkb->lkb_timestamp;
119 if (lkb->lkb_ua) 118 if (lkb->lkb_ua)
120 data->xid = lkb->lkb_ua->xid; 119 data->xid = lkb->lkb_ua->xid;
121 if (r) { 120 if (r) {