dlm: use INFO for recovery messages
authorDavid Teigland <teigland@redhat.com>
Fri, 14 Feb 2014 17:54:44 +0000 (11:54 -0600)
committerDavid Teigland <teigland@redhat.com>
Fri, 14 Feb 2014 17:54:44 +0000 (11:54 -0600)
The log messages relating to the progress of recovery
are minimal and very often useful.  Change these to
the KERN_INFO level so they are always available.

Signed-off-by: David Teigland <teigland@redhat.com>
fs/dlm/ast.c
fs/dlm/dir.c
fs/dlm/dlm_internal.h
fs/dlm/lock.c
fs/dlm/lockspace.c
fs/dlm/member.c
fs/dlm/recover.c
fs/dlm/recoverd.c

index 42794c00a3672d8c904c8a4d42de4511114ea1a8..dcea1e37a1b7342ee78d245e7398809620d8e789 100644 (file)
@@ -309,6 +309,6 @@ void dlm_callback_resume(struct dlm_ls *ls)
        mutex_unlock(&ls->ls_cb_mutex);
 
        if (count)
-               log_debug(ls, "dlm_callback_resume %d", count);
+               log_rinfo(ls, "dlm_callback_resume %d", count);
 }
 
index 278a75cda4463006d4b2c2e85d75c7728d5b4526..d975851a7e1e2e4794859a36e516050a16856075 100644 (file)
@@ -68,7 +68,7 @@ int dlm_recover_directory(struct dlm_ls *ls)
        uint16_t namelen;
        unsigned int count = 0, count_match = 0, count_bad = 0, count_add = 0;
 
-       log_debug(ls, "dlm_recover_directory");
+       log_rinfo(ls, "dlm_recover_directory");
 
        if (dlm_no_directory(ls))
                goto out_status;
@@ -189,7 +189,7 @@ int dlm_recover_directory(struct dlm_ls *ls)
        error = 0;
        dlm_set_recover_status(ls, DLM_RS_DIR);
 
-       log_debug(ls, "dlm_recover_directory %u in %u new",
+       log_rinfo(ls, "dlm_recover_directory %u in %u new",
                  count, count_add);
  out_free:
        kfree(last_name);
index e7665c31f7b10dda86364567c538c7737a1421db..5eff6ea3e27f19423be38f8372e65031855c0c5a 100644 (file)
@@ -65,6 +65,8 @@ struct dlm_mhandle;
        printk(KERN_ERR "dlm: "fmt"\n" , ##args)
 #define log_error(ls, fmt, args...) \
        printk(KERN_ERR "dlm: %s: " fmt "\n", (ls)->ls_name , ##args)
+#define log_rinfo(ls, fmt, args...) \
+       printk(KERN_INFO "dlm: %s: " fmt "\n", (ls)->ls_name , ##args);
 
 #define log_debug(ls, fmt, args...) \
 do { \
index 5ec4d60525d812aade835112b65490f2bab91d6c..83f3d5520307f86c1e4ba1079b8635358d7bac08 100644 (file)
@@ -5463,7 +5463,7 @@ void dlm_recover_purge(struct dlm_ls *ls)
        up_write(&ls->ls_root_sem);
 
        if (lkb_count)
-               log_debug(ls, "dlm_recover_purge %u locks for %u nodes",
+               log_rinfo(ls, "dlm_recover_purge %u locks for %u nodes",
                          lkb_count, nodes_count);
 }
 
@@ -5537,7 +5537,7 @@ void dlm_recover_grant(struct dlm_ls *ls)
        }
 
        if (lkb_count)
-               log_debug(ls, "dlm_recover_grant %u locks on %u resources",
+               log_rinfo(ls, "dlm_recover_grant %u locks on %u resources",
                          lkb_count, rsb_count);
 }
 
@@ -5696,7 +5696,7 @@ int dlm_recover_master_copy(struct dlm_ls *ls, struct dlm_rcom *rc)
        put_rsb(r);
  out:
        if (error && error != -EEXIST)
-               log_debug(ls, "dlm_recover_master_copy remote %d %x error %d",
+               log_rinfo(ls, "dlm_recover_master_copy remote %d %x error %d",
                          from_nodeid, remid, error);
        rl->rl_result = cpu_to_le32(error);
        return error;
index d5abafd56a6d69e53242f61fd487b6c04798abb5..04d6398c1f1ce3e408a115a8c4f2feca7b2c67e1 100644 (file)
@@ -190,7 +190,7 @@ static int do_uevent(struct dlm_ls *ls, int in)
        else
                kobject_uevent(&ls->ls_kobj, KOBJ_OFFLINE);
 
-       log_debug(ls, "%s the lockspace group...", in ? "joining" : "leaving");
+       log_rinfo(ls, "%s the lockspace group...", in ? "joining" : "leaving");
 
        /* dlm_controld will see the uevent, do the necessary group management
           and then write to sysfs to wake us */
@@ -198,7 +198,7 @@ static int do_uevent(struct dlm_ls *ls, int in)
        error = wait_event_interruptible(ls->ls_uevent_wait,
                        test_and_clear_bit(LSFL_UEVENT_WAIT, &ls->ls_flags));
 
-       log_debug(ls, "group event done %d %d", error, ls->ls_uevent_result);
+       log_rinfo(ls, "group event done %d %d", error, ls->ls_uevent_result);
 
        if (error)
                goto out;
@@ -640,7 +640,7 @@ static int new_lockspace(const char *name, const char *cluster,
 
        dlm_create_debug_file(ls);
 
-       log_debug(ls, "join complete");
+       log_rinfo(ls, "join complete");
        *lockspace = ls;
        return 0;
 
@@ -835,7 +835,7 @@ static int release_lockspace(struct dlm_ls *ls, int force)
        dlm_clear_members(ls);
        dlm_clear_members_gone(ls);
        kfree(ls->ls_node_array);
-       log_debug(ls, "release_lockspace final free");
+       log_rinfo(ls, "release_lockspace final free");
        kobject_put(&ls->ls_kobj);
        /* The ls structure will be freed when the kobject is done with */
 
index 476557b54921793a246cb11b1fc8f19c348aa17d..9c47f1c14a8badb59048a88cf33b674e93a679e4 100644 (file)
@@ -60,18 +60,15 @@ void dlm_slots_copy_out(struct dlm_ls *ls, struct dlm_rcom *rc)
 
 #define SLOT_DEBUG_LINE 128
 
-static void log_debug_slots(struct dlm_ls *ls, uint32_t gen, int num_slots,
-                           struct rcom_slot *ro0, struct dlm_slot *array,
-                           int array_size)
+static void log_slots(struct dlm_ls *ls, uint32_t gen, int num_slots,
+                     struct rcom_slot *ro0, struct dlm_slot *array,
+                     int array_size)
 {
        char line[SLOT_DEBUG_LINE];
        int len = SLOT_DEBUG_LINE - 1;
        int pos = 0;
        int ret, i;
 
-       if (!dlm_config.ci_log_debug)
-               return;
-
        memset(line, 0, sizeof(line));
 
        if (array) {
@@ -95,7 +92,7 @@ static void log_debug_slots(struct dlm_ls *ls, uint32_t gen, int num_slots,
                }
        }
 
-       log_debug(ls, "generation %u slots %d%s", gen, num_slots, line);
+       log_rinfo(ls, "generation %u slots %d%s", gen, num_slots, line);
 }
 
 int dlm_slots_copy_in(struct dlm_ls *ls)
@@ -129,7 +126,7 @@ int dlm_slots_copy_in(struct dlm_ls *ls)
                ro->ro_slot = le16_to_cpu(ro->ro_slot);
        }
 
-       log_debug_slots(ls, gen, num_slots, ro0, NULL, 0);
+       log_slots(ls, gen, num_slots, ro0, NULL, 0);
 
        list_for_each_entry(memb, &ls->ls_nodes, list) {
                for (i = 0, ro = ro0; i < num_slots; i++, ro++) {
@@ -274,7 +271,7 @@ int dlm_slots_assign(struct dlm_ls *ls, int *num_slots, int *slots_size,
 
        gen++;
 
-       log_debug_slots(ls, gen, num, NULL, array, array_size);
+       log_slots(ls, gen, num, NULL, array, array_size);
 
        max_slots = (dlm_config.ci_buffer_size - sizeof(struct dlm_rcom) -
                     sizeof(struct rcom_config)) / sizeof(struct rcom_slot);
@@ -447,7 +444,7 @@ static int ping_members(struct dlm_ls *ls)
                        break;
        }
        if (error)
-               log_debug(ls, "ping_members aborted %d last nodeid %d",
+               log_rinfo(ls, "ping_members aborted %d last nodeid %d",
                          error, ls->ls_recover_nodeid);
        return error;
 }
@@ -539,7 +536,7 @@ int dlm_recover_members(struct dlm_ls *ls, struct dlm_recover *rv, int *neg_out)
           count as a negative change so the "neg" recovery steps will happen */
 
        list_for_each_entry(memb, &ls->ls_nodes_gone, list) {
-               log_debug(ls, "prev removed member %d", memb->nodeid);
+               log_rinfo(ls, "prev removed member %d", memb->nodeid);
                neg++;
        }
 
@@ -551,10 +548,10 @@ int dlm_recover_members(struct dlm_ls *ls, struct dlm_recover *rv, int *neg_out)
                        continue;
 
                if (!node) {
-                       log_debug(ls, "remove member %d", memb->nodeid);
+                       log_rinfo(ls, "remove member %d", memb->nodeid);
                } else {
                        /* removed and re-added */
-                       log_debug(ls, "remove member %d comm_seq %u %u",
+                       log_rinfo(ls, "remove member %d comm_seq %u %u",
                                  memb->nodeid, memb->comm_seq, node->comm_seq);
                }
 
@@ -571,7 +568,7 @@ int dlm_recover_members(struct dlm_ls *ls, struct dlm_recover *rv, int *neg_out)
                if (dlm_is_member(ls, node->nodeid))
                        continue;
                dlm_add_member(ls, node);
-               log_debug(ls, "add member %d", node->nodeid);
+               log_rinfo(ls, "add member %d", node->nodeid);
        }
 
        list_for_each_entry(memb, &ls->ls_nodes, list) {
@@ -591,7 +588,7 @@ int dlm_recover_members(struct dlm_ls *ls, struct dlm_recover *rv, int *neg_out)
                complete(&ls->ls_members_done);
        }
 
-       log_debug(ls, "dlm_recover_members %d nodes", ls->ls_num_nodes);
+       log_rinfo(ls, "dlm_recover_members %d nodes", ls->ls_num_nodes);
        return error;
 }
 
index a6bc63f6e31baa6ac6be822c048206daa8b77ad4..eaea789bf97d0dd862545c202156484a532eedbb 100644 (file)
@@ -526,7 +526,7 @@ int dlm_recover_masters(struct dlm_ls *ls)
        int nodir = dlm_no_directory(ls);
        int error;
 
-       log_debug(ls, "dlm_recover_masters");
+       log_rinfo(ls, "dlm_recover_masters");
 
        down_read(&ls->ls_root_sem);
        list_for_each_entry(r, &ls->ls_root_list, res_root_list) {
@@ -552,7 +552,7 @@ int dlm_recover_masters(struct dlm_ls *ls)
        }
        up_read(&ls->ls_root_sem);
 
-       log_debug(ls, "dlm_recover_masters %u of %u", count, total);
+       log_rinfo(ls, "dlm_recover_masters %u of %u", count, total);
 
        error = dlm_wait_function(ls, &recover_idr_empty);
  out:
@@ -685,7 +685,7 @@ int dlm_recover_locks(struct dlm_ls *ls)
        }
        up_read(&ls->ls_root_sem);
 
-       log_debug(ls, "dlm_recover_locks %d out", count);
+       log_rinfo(ls, "dlm_recover_locks %d out", count);
 
        error = dlm_wait_function(ls, &recover_list_empty);
  out:
@@ -883,7 +883,7 @@ void dlm_recover_rsbs(struct dlm_ls *ls)
        up_read(&ls->ls_root_sem);
 
        if (count)
-               log_debug(ls, "dlm_recover_rsbs %d done", count);
+               log_rinfo(ls, "dlm_recover_rsbs %d done", count);
 }
 
 /* Create a single list of all root rsb's to be used during recovery */
@@ -950,6 +950,6 @@ void dlm_clear_toss(struct dlm_ls *ls)
        }
 
        if (count)
-               log_debug(ls, "dlm_clear_toss %u done", count);
+               log_rinfo(ls, "dlm_clear_toss %u done", count);
 }
 
index 32f9f8926ec3f17a3a69433402e8a0fecb07a1f6..6859b4bf971ece075e6bee500e036807be88854f 100644 (file)
@@ -55,7 +55,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
        unsigned long start;
        int error, neg = 0;
 
-       log_debug(ls, "dlm_recover %llu", (unsigned long long)rv->seq);
+       log_rinfo(ls, "dlm_recover %llu", (unsigned long long)rv->seq);
 
        mutex_lock(&ls->ls_recoverd_active);
 
@@ -76,7 +76,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
        error = dlm_recover_members(ls, rv, &neg);
        if (error) {
-               log_debug(ls, "dlm_recover_members error %d", error);
+               log_rinfo(ls, "dlm_recover_members error %d", error);
                goto fail;
        }
 
@@ -90,7 +90,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
        error = dlm_recover_members_wait(ls);
        if (error) {
-               log_debug(ls, "dlm_recover_members_wait error %d", error);
+               log_rinfo(ls, "dlm_recover_members_wait error %d", error);
                goto fail;
        }
 
@@ -103,7 +103,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
        error = dlm_recover_directory(ls);
        if (error) {
-               log_debug(ls, "dlm_recover_directory error %d", error);
+               log_rinfo(ls, "dlm_recover_directory error %d", error);
                goto fail;
        }
 
@@ -111,11 +111,11 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
        error = dlm_recover_directory_wait(ls);
        if (error) {
-               log_debug(ls, "dlm_recover_directory_wait error %d", error);
+               log_rinfo(ls, "dlm_recover_directory_wait error %d", error);
                goto fail;
        }
 
-       log_debug(ls, "dlm_recover_directory %u out %u messages",
+       log_rinfo(ls, "dlm_recover_directory %u out %u messages",
                  ls->ls_recover_dir_sent_res, ls->ls_recover_dir_sent_msg);
 
        /*
@@ -144,7 +144,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
                error = dlm_recover_masters(ls);
                if (error) {
-                       log_debug(ls, "dlm_recover_masters error %d", error);
+                       log_rinfo(ls, "dlm_recover_masters error %d", error);
                        goto fail;
                }
 
@@ -154,7 +154,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
                error = dlm_recover_locks(ls);
                if (error) {
-                       log_debug(ls, "dlm_recover_locks error %d", error);
+                       log_rinfo(ls, "dlm_recover_locks error %d", error);
                        goto fail;
                }
 
@@ -162,11 +162,11 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
                error = dlm_recover_locks_wait(ls);
                if (error) {
-                       log_debug(ls, "dlm_recover_locks_wait error %d", error);
+                       log_rinfo(ls, "dlm_recover_locks_wait error %d", error);
                        goto fail;
                }
 
-               log_debug(ls, "dlm_recover_locks %u in",
+               log_rinfo(ls, "dlm_recover_locks %u in",
                          ls->ls_recover_locks_in);
 
                /*
@@ -186,7 +186,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
                error = dlm_recover_locks_wait(ls);
                if (error) {
-                       log_debug(ls, "dlm_recover_locks_wait error %d", error);
+                       log_rinfo(ls, "dlm_recover_locks_wait error %d", error);
                        goto fail;
                }
        }
@@ -205,7 +205,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
        error = dlm_recover_done_wait(ls);
        if (error) {
-               log_debug(ls, "dlm_recover_done_wait error %d", error);
+               log_rinfo(ls, "dlm_recover_done_wait error %d", error);
                goto fail;
        }
 
@@ -217,25 +217,25 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
        error = enable_locking(ls, rv->seq);
        if (error) {
-               log_debug(ls, "enable_locking error %d", error);
+               log_rinfo(ls, "enable_locking error %d", error);
                goto fail;
        }
 
        error = dlm_process_requestqueue(ls);
        if (error) {
-               log_debug(ls, "dlm_process_requestqueue error %d", error);
+               log_rinfo(ls, "dlm_process_requestqueue error %d", error);
                goto fail;
        }
 
        error = dlm_recover_waiters_post(ls);
        if (error) {
-               log_debug(ls, "dlm_recover_waiters_post error %d", error);
+               log_rinfo(ls, "dlm_recover_waiters_post error %d", error);
                goto fail;
        }
 
        dlm_recover_grant(ls);
 
-       log_debug(ls, "dlm_recover %llu generation %u done: %u ms",
+       log_rinfo(ls, "dlm_recover %llu generation %u done: %u ms",
                  (unsigned long long)rv->seq, ls->ls_generation,
                  jiffies_to_msecs(jiffies - start));
        mutex_unlock(&ls->ls_recoverd_active);
@@ -245,7 +245,7 @@ static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
 
  fail:
        dlm_release_root_list(ls);
-       log_debug(ls, "dlm_recover %llu error %d",
+       log_rinfo(ls, "dlm_recover %llu error %d",
                  (unsigned long long)rv->seq, error);
        mutex_unlock(&ls->ls_recoverd_active);
        return error;