LU-13004 ptlrpc: Allow BULK_BUF_KIOV to accept a kvec

[fs/lustre-release.git] / lustre / ptlrpc / sec_gc.c

diff --git a/lustre/ptlrpc/sec_gc.c b/lustre/ptlrpc/sec_gc.c
index 042a632..652a11b 100644 (file)
--- a/lustre/ptlrpc/sec_gc.c
+++ b/lustre/ptlrpc/sec_gc.c
@@ -48,19 +48,18 @@
 
 #define SEC_GC_INTERVAL (30 * 60)
 
-static struct mutex sec_gc_mutex;
-static spinlock_t sec_gc_list_lock;
-static struct list_head sec_gc_list;
-
-static spinlock_t sec_gc_ctx_list_lock;
-static struct list_head sec_gc_ctx_list;
+static DEFINE_MUTEX(sec_gc_mutex);
+static DEFINE_SPINLOCK(sec_gc_list_lock);
+static DEFINE_SPINLOCK(sec_gc_ctx_list_lock);
+static LIST_HEAD(sec_gc_list);
+static LIST_HEAD(sec_gc_ctx_list);
 
 static atomic_t sec_gc_wait_del = ATOMIC_INIT(0);
 
 void sptlrpc_gc_add_sec(struct ptlrpc_sec *sec)
 {
-        LASSERT(sec->ps_policy->sp_cops->gc_ctx);
-        LASSERT(sec->ps_gc_interval > 0);
+       LASSERT(sec->ps_policy->sp_cops->gc_ctx);
+       LASSERT(sec->ps_gc_interval > 0);
        LASSERT(list_empty(&sec->ps_gc_list));
 
        sec->ps_gc_next = ktime_get_real_seconds() + sec->ps_gc_interval;
@@ -138,20 +137,20 @@ static void sec_process_ctx_list(void)
 
 static void sec_do_gc(struct ptlrpc_sec *sec)
 {
-        LASSERT(sec->ps_policy->sp_cops->gc_ctx);
+       LASSERT(sec->ps_policy->sp_cops->gc_ctx);
 
-        if (unlikely(sec->ps_gc_next == 0)) {
-                CDEBUG(D_SEC, "sec %p(%s) has 0 gc time\n",
-                      sec, sec->ps_policy->sp_name);
-                return;
-        }
+       if (unlikely(sec->ps_gc_next == 0)) {
+               CDEBUG(D_SEC, "sec %p(%s) has 0 gc time\n",
+                      sec, sec->ps_policy->sp_name);
+               return;
+       }
 
-        CDEBUG(D_SEC, "check on sec %p(%s)\n", sec, sec->ps_policy->sp_name);
+       CDEBUG(D_SEC, "check on sec %p(%s)\n", sec, sec->ps_policy->sp_name);
 
        if (sec->ps_gc_next > ktime_get_real_seconds())
-                return;
+               return;
 
-        sec->ps_policy->sp_cops->gc_ctx(sec);
+       sec->ps_policy->sp_cops->gc_ctx(sec);
        sec->ps_gc_next = ktime_get_real_seconds() + sec->ps_gc_interval;
 }
 
@@ -161,7 +160,8 @@ static void sec_gc_main(struct work_struct *ws)
 
        sec_process_ctx_list();
 again:
-       /* go through sec list do gc.
+       /*
+        * go through sec list do gc.
         * FIXME here we iterate through the whole list each time which
         * is not optimal. we perhaps want to use balanced binary tree
         * to trace each sec as order of expiry time.
@@ -170,7 +170,8 @@ again:
         */
        mutex_lock(&sec_gc_mutex);
        list_for_each_entry(sec, &sec_gc_list, ps_gc_list) {
-               /* if someone is waiting to be deleted, let it
+               /*
+                * if someone is waiting to be deleted, let it
                 * proceed as soon as possible.
                 */
                if (atomic_read(&sec_gc_wait_del)) {
@@ -190,13 +191,6 @@ again:
 
 int sptlrpc_gc_init(void)
 {
-       mutex_init(&sec_gc_mutex);
-       spin_lock_init(&sec_gc_list_lock);
-       spin_lock_init(&sec_gc_ctx_list_lock);
-
-       INIT_LIST_HEAD(&sec_gc_list);
-       INIT_LIST_HEAD(&sec_gc_ctx_list);
-
        schedule_delayed_work(&sec_gc_work, cfs_time_seconds(SEC_GC_INTERVAL));
        return 0;
 }