|
@@ -1395,7 +1395,6 @@ static int nodeid_warned(int nodeid, int num_nodes, int *warned)
|
|
void dlm_scan_waiters(struct dlm_ls *ls)
|
|
void dlm_scan_waiters(struct dlm_ls *ls)
|
|
{
|
|
{
|
|
struct dlm_lkb *lkb;
|
|
struct dlm_lkb *lkb;
|
|
- ktime_t zero = 0;
|
|
|
|
s64 us;
|
|
s64 us;
|
|
s64 debug_maxus = 0;
|
|
s64 debug_maxus = 0;
|
|
u32 debug_scanned = 0;
|
|
u32 debug_scanned = 0;
|
|
@@ -1409,7 +1408,7 @@ void dlm_scan_waiters(struct dlm_ls *ls)
|
|
mutex_lock(&ls->ls_waiters_mutex);
|
|
mutex_lock(&ls->ls_waiters_mutex);
|
|
|
|
|
|
list_for_each_entry(lkb, &ls->ls_waiters, lkb_wait_reply) {
|
|
list_for_each_entry(lkb, &ls->ls_waiters, lkb_wait_reply) {
|
|
- if (ktime_equal(lkb->lkb_wait_time, zero))
|
|
|
|
|
|
+ if (!lkb->lkb_wait_time)
|
|
continue;
|
|
continue;
|
|
|
|
|
|
debug_scanned++;
|
|
debug_scanned++;
|
|
@@ -1419,7 +1418,7 @@ void dlm_scan_waiters(struct dlm_ls *ls)
|
|
if (us < dlm_config.ci_waitwarn_us)
|
|
if (us < dlm_config.ci_waitwarn_us)
|
|
continue;
|
|
continue;
|
|
|
|
|
|
- lkb->lkb_wait_time = zero;
|
|
|
|
|
|
+ lkb->lkb_wait_time = 0;
|
|
|
|
|
|
debug_expired++;
|
|
debug_expired++;
|
|
if (us > debug_maxus)
|
|
if (us > debug_maxus)
|