File bug-938545_pacemaker-fencing-concurrent-device-active-pids.patch of Package pacemaker.9287

commit 1672823db5c481712692db71bc14e7b4bceba86c
Author: Gao,Yan <ygao@suse.com>
Date:   Thu Jan 21 11:19:20 2016 +0100

    Refactor: fencing: Functionize adding and removing active pids of device

Index: pacemaker/fencing/commands.c
===================================================================
--- pacemaker.orig/fencing/commands.c
+++ pacemaker/fencing/commands.c
@@ -248,6 +248,22 @@ get_action_limit(stonith_device_t * devi
     return action_limit;
 }
 
+static void
+device_add_active_pid(stonith_device_t * device, GPid pid)
+{
+    CRM_CHECK(device != NULL, return);
+
+    device->active_pids = g_list_append(device->active_pids, GINT_TO_POINTER(pid));
+}
+
+static void
+device_remove_active_pid(stonith_device_t * device, GPid pid)
+{
+    CRM_CHECK(device != NULL, return);
+
+    device->active_pids = g_list_remove(device->active_pids, GINT_TO_POINTER(pid));
+}
+
 static gboolean
 stonith_device_execute(stonith_device_t * device)
 {
@@ -341,7 +357,7 @@ stonith_device_execute(stonith_device_t
         crm_debug("Operation %s%s%s on %s now running with pid=%d, timeout=%ds",
                   cmd->action, cmd->victim ? " for node " : "", cmd->victim ? cmd->victim : "",
                   device->id, exec_rc, cmd->timeout);
-        device->active_pids = g_list_append(device->active_pids, GINT_TO_POINTER(exec_rc));
+        device_add_active_pid(device, exec_rc);
 
     } else {
         crm_warn("Operation %s%s%s on %s failed: %s (%d)",
@@ -878,7 +894,7 @@ status_search_cb(GPid pid, int rc, const
         return;
     }
 
-    dev->active_pids = g_list_remove(dev->active_pids, GINT_TO_POINTER(pid));
+    device_remove_active_pid(dev, pid);
     mainloop_set_trigger(dev->work);
 
     if (rc == 1 /* unkown */ ) {
@@ -915,7 +931,7 @@ dynamic_list_search_cb(GPid pid, int rc,
         return;
     }
 
-    dev->active_pids = g_list_remove(dev->active_pids, GINT_TO_POINTER(pid));
+    device_remove_active_pid(dev, pid);
     mainloop_set_trigger(dev->work);
 
     /* If we successfully got the targets earlier, don't disable. */
@@ -1612,7 +1628,7 @@ unfence_cb(GPid pid, int rc, const char
     log_operation(cmd, rc, pid, NULL, output);
 
     if(dev) {
-        dev->active_pids = g_list_remove(dev->active_pids, GINT_TO_POINTER(pid));
+        device_remove_active_pid(dev, pid);
         mainloop_set_trigger(dev->work);
     } else {
         crm_trace("Device %s does not exist", cmd->device);
@@ -1660,7 +1676,7 @@ st_child_done(GPid pid, int rc, const ch
     /* The device is ready to do something else now */
     device = g_hash_table_lookup(device_list, cmd->device);
     if (device) {
-        device->active_pids = g_list_remove(device->active_pids, GINT_TO_POINTER(pid));
+        device_remove_active_pid(device, pid);
         if (rc == pcmk_ok &&
             (safe_str_eq(cmd->action, "list") ||
              safe_str_eq(cmd->action, "monitor") || safe_str_eq(cmd->action, "status"))) {