diff --git a/crm/pengine/regression.sh b/crm/pengine/regression.sh
index 31a7d534a0..da6c2e396e 100755
--- a/crm/pengine/regression.sh
+++ b/crm/pengine/regression.sh
@@ -1,181 +1,182 @@
#!/bin/bash
# Copyright (C) 2004 Andrew Beekhof <andrew@beekhof.net>
#
# This program is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
#
# This software is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# General Public License for more details.
#
# You should have received a copy of the GNU General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
#
. regression.core.sh
create_mode="true"
echo Generating test outputs for these tests...
#do_test bad7
echo ""
echo Done.
echo ""
echo Performing the following tests...
create_mode="false"
do_test 594 "Bugzilla 594"
do_test 662 "Bugzilla 662"
do_test 696 "Bugzilla 696"
do_test 726 "Bugzilla 726"
do_test 735 "Bugzilla 735"
do_test 764 "Bugzilla 764"
do_test 797 "Bugzilla 797"
+do_test 829 "Bugzilla 829"
echo ""
do_test date-1 "Dates"
echo ""
do_test simple1 "Offline "
do_test simple2 "Start "
do_test simple3 "Start 2 "
do_test simple4 "Start Failed"
do_test simple6 "Stop Start "
do_test simple7 "Shutdown "
#do_test simple8 "Stonith "
#do_test simple9 "Lower version"
#do_test simple10 "Higher version"
do_test simple11 "Priority (ne)"
do_test simple12 "Priority (eq)"
echo ""
do_test rsc_dep1 "Must not "
do_test rsc_dep3 "Must "
do_test rsc_dep5 "Must not 3 "
do_test rsc_dep7 "Must 3 "
do_test rsc_dep10 "Must (but cant)"
do_test rsc_dep2 "Must (running) "
do_test rsc_dep8 "Must (running : alt) "
do_test rsc_dep4 "Must (running + move)"
echo ""
do_test order1 "Order start 1 "
do_test order2 "Order start 2 "
do_test order3 "Order stop "
do_test order4 "Order (multiple) "
do_test order5 "Order (move) "
do_test order6 "Order (move w/ restart) "
#echo ""
#do_test agent1 "version: lt (empty)"
#do_test agent2 "version: eq "
#do_test agent3 "version: gt "
echo ""
do_test attrs1 "string: eq (and) "
do_test attrs2 "string: lt / gt (and)"
do_test attrs3 "string: ne (or) "
do_test attrs4 "string: exists "
do_test attrs5 "string: not_exists "
do_test attrs6 "is_dc: true "
do_test attrs7 "is_dc: false "
echo ""
do_test mon-rsc-1 "Schedule Monitor - start"
do_test mon-rsc-2 "Schedule Monitor - move "
do_test mon-rsc-3 "Schedule Monitor - pending start "
do_test mon-rsc-4 "Schedule Monitor - move/pending start"
echo ""
do_test rec-rsc-0 "Resource Recover - no start "
do_test rec-rsc-1 "Resource Recover - start "
do_test rec-rsc-2 "Resource Recover - monitor "
do_test rec-rsc-3 "Resource Recover - stop - ignore"
do_test rec-rsc-4 "Resource Recover - stop - block "
do_test rec-rsc-5 "Resource Recover - stop - fence "
do_test rec-rsc-6 "Resource Recover - multiple - restart"
do_test rec-rsc-7 "Resource Recover - multiple - stop "
do_test rec-rsc-8 "Resource Recover - multiple - block "
echo ""
do_test quorum-1 "No quorum - ignore"
do_test quorum-2 "No quorum - freeze"
do_test quorum-3 "No quorum - stop "
do_test quorum-4 "No quorum - start anyway"
do_test quorum-5 "No quorum - start anyway (group)"
do_test quorum-6 "No quorum - start anyway (clone)"
echo ""
do_test rec-node-1 "Node Recover - Startup - no fence"
do_test rec-node-2 "Node Recover - Startup - fence "
do_test rec-node-3 "Node Recover - HA down - no fence"
do_test rec-node-4 "Node Recover - HA down - fence "
do_test rec-node-5 "Node Recover - CRM down - no fence"
do_test rec-node-6 "Node Recover - CRM down - fence "
do_test rec-node-7 "Node Recover - no quorum - ignore "
do_test rec-node-8 "Node Recover - no quorum - freeze "
do_test rec-node-9 "Node Recover - no quorum - stop "
do_test rec-node-10 "Node Recover - no quorum - stop w/fence"
echo ""
do_test multi1 "Multiple Active (stop/start)"
#echo ""
#do_test complex1 "Complex "
echo ""
do_test group1 "Group "
do_test group2 "Group + Native "
do_test group3 "Group + Group "
do_test group4 "Group + Native (nothing)"
do_test group5 "Group + Native (move) "
do_test group6 "Group + Group (move) "
echo ""
do_test inc0 "Incarnation start "
do_test inc1 "Incarnation start order "
do_test inc2 "Incarnation silent restart, stop, move "
do_test inc3 "Inter-incarnation ordering, silent restart, stop, move"
do_test inc4 "Inter-incarnation ordering, silent restart, stop, move (ordered)"
do_test inc5 "Inter-incarnation ordering, silent restart, stop, move (restart 1)"
do_test inc6 "Inter-incarnation ordering, silent restart, stop, move (restart 2)"
#do_test inc7 "Inter-incarnation ordering, silent restart, stop, move (ordered subset)"
echo ""
do_test managed-0 "Managed (reference)"
do_test managed-1 "Not managed - down "
do_test managed-2 "Not managed - up "
echo ""
do_test interleave-0 "Interleave (reference)"
do_test interleave-1 "coloc - not interleaved"
do_test interleave-2 "coloc - interleaved "
do_test interleave-3 "coloc - interleaved (2)"
echo ""
do_test notify-0 "Notify reference"
do_test notify-1 "Notify simple"
do_test notify-2 "Notify simple, confirm"
do_test notify-3 "Notify move, confirm"
#do_test notify-2 "Notify - 764"
echo ""
do_test bad1 "Bad node "
do_test bad2 "Bad rsc "
do_test bad3 "No rsc class "
do_test bad4 "Bad data "
do_test bad5 "Bad data "
do_test bad6 "Bad lrm_rsc "
echo ""
test_results
diff --git a/crm/pengine/testcases/594.dot b/crm/pengine/testcases/594.dot
index 56bb60a995..8a6cd9bb66 100644
--- a/crm/pengine/testcases/594.dot
+++ b/crm/pengine/testcases/594.dot
@@ -1,49 +1,50 @@
digraph "g" {
size = "30,30"
"rsc_hadev3_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
"DoFencing:child_DoFencing:2_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
"DcIPaddr_monitor_5000" [ tooltip="hadev1" style=bold color="green" fontcolor="black" ]
"DoFencing:child_DoFencing:0_monitor_5000" [ tooltip="hadev1" style=bold color="green" fontcolor="black" ]
"rsc_hadev2_monitor_5000" [ tooltip="hadev1" style=bold color="green" fontcolor="black" ]
"rsc_hadev1_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
"DoFencing:child_DoFencing:1_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
"DcIPaddr_stop_0" [ tooltip="hadev2" style=bold color="green" fontcolor="black" ]
"DcIPaddr_start_0" [ tooltip="hadev1" style=bold color="green" fontcolor="black" ]
"rsc_hadev3_stop_0" [ style="dashed" color="blue" fontcolor="black" ]
"rsc_hadev3_start_0" [ style="dashed" color="blue" fontcolor="black" ]
"rsc_hadev2_stop_0" [ tooltip="hadev2" style=bold color="green" fontcolor="black" ]
"rsc_hadev2_start_0" [ tooltip="hadev1" style=bold color="green" fontcolor="black" ]
"rsc_hadev1_stop_0" [ style="dashed" color="blue" fontcolor="black" ]
"rsc_hadev1_start_0" [ style="dashed" color="blue" fontcolor="black" ]
"DoFencing:child_DoFencing:0_stop_0" [ tooltip="hadev2" style=bold color="green" fontcolor="black" ]
"DoFencing:child_DoFencing:0_start_0" [ tooltip="hadev1" style=bold color="green" fontcolor="black" ]
"DoFencing:child_DoFencing:1_stop_0" [ tooltip="hadev1" style=bold color="green" fontcolor="black" ]
"DoFencing:child_DoFencing:2_stop_0" [ tooltip="hadev1" style=bold color="green" fontcolor="black" ]
"DoFencing_start_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
"DoFencing_running_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
"DoFencing_stop_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
"DoFencing_stopped_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
+"stonith" [ tooltip="hadev3" style=bold color="green" fontcolor="black" ]
"do_shutdown" [ tooltip="hadev2" style=bold color="green" fontcolor="black" ]
"rsc_hadev3_start_0" -> "rsc_hadev3_monitor_5000" [ style = dashed]
"DcIPaddr_start_0" -> "DcIPaddr_monitor_5000" [ style = bold]
"DoFencing:child_DoFencing:0_start_0" -> "DoFencing:child_DoFencing:0_monitor_5000" [ style = bold]
"rsc_hadev2_start_0" -> "rsc_hadev2_monitor_5000" [ style = bold]
"rsc_hadev1_start_0" -> "rsc_hadev1_monitor_5000" [ style = dashed]
"DcIPaddr_stop_0" -> "DcIPaddr_start_0" [ style = bold]
"rsc_hadev3_stop_0" -> "rsc_hadev3_start_0" [ style = dashed]
"rsc_hadev2_stop_0" -> "rsc_hadev2_start_0" [ style = bold]
"rsc_hadev1_stop_0" -> "rsc_hadev1_start_0" [ style = dashed]
"DoFencing_stop_0" -> "DoFencing:child_DoFencing:0_stop_0" [ style = bold]
"DoFencing:child_DoFencing:0_stop_0" -> "DoFencing:child_DoFencing:0_start_0" [ style = bold]
"DoFencing_start_0" -> "DoFencing:child_DoFencing:0_start_0" [ style = bold]
"DoFencing_stop_0" -> "DoFencing:child_DoFencing:1_stop_0" [ style = bold]
"DoFencing_stop_0" -> "DoFencing:child_DoFencing:2_stop_0" [ style = bold]
"DoFencing_stopped_0" -> "DoFencing_start_0" [ style = bold]
"DoFencing:child_DoFencing:0_start_0" -> "DoFencing_running_0" [ style = bold]
"DoFencing:child_DoFencing:0_stop_0" -> "DoFencing_stopped_0" [ style = bold]
"DoFencing:child_DoFencing:1_stop_0" -> "DoFencing_stopped_0" [ style = bold]
"DoFencing:child_DoFencing:2_stop_0" -> "DoFencing_stopped_0" [ style = bold]
"DcIPaddr_stop_0" -> "do_shutdown" [ style = bold]
"rsc_hadev2_stop_0" -> "do_shutdown" [ style = bold]
"DoFencing:child_DoFencing:0_stop_0" -> "do_shutdown" [ style = bold]
}
diff --git a/crm/pengine/testcases/594.exp b/crm/pengine/testcases/594.exp
index 15d06a74b8..89e6b2b1dc 100644
--- a/crm/pengine/testcases/594.exp
+++ b/crm/pengine/testcases/594.exp
@@ -1,247 +1,258 @@
<transition_graph global_timeout="60s" transition_id="0">
<synapse id="0">
<action_set>
<rsc_op id="3" rsc_id="DcIPaddr" operation="monitor" operation_key="DcIPaddr_monitor_5000" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false">
<primitive id="DcIPaddr" class="ocf" type="IPaddr" provider="heartbeat"/>
<attributes>
<nvpair name="timeout" value="20s"/>
<nvpair name="interval" value="5s"/>
<nvpair name="ip" value="127.0.0.10"/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<rsc_op id="9" rsc_id="DcIPaddr" operation="start" operation_key="DcIPaddr_start_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="1">
<action_set>
<rsc_op id="8" rsc_id="DcIPaddr" operation="stop" operation_key="DcIPaddr_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false">
<primitive id="DcIPaddr" class="ocf" type="IPaddr" provider="heartbeat"/>
<attributes>
<nvpair name="ip" value="127.0.0.10"/>
</attributes>
</rsc_op>
</action_set>
<inputs/>
</synapse>
<synapse id="2">
<action_set>
<rsc_op id="9" rsc_id="DcIPaddr" operation="start" operation_key="DcIPaddr_start_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false">
<primitive id="DcIPaddr" class="ocf" type="IPaddr" provider="heartbeat"/>
<attributes>
<nvpair name="ip" value="127.0.0.10"/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<rsc_op id="8" rsc_id="DcIPaddr" operation="stop" operation_key="DcIPaddr_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="3">
<action_set>
<rsc_op id="5" rsc_id="rsc_hadev2" operation="monitor" operation_key="rsc_hadev2_monitor_5000" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false">
<primitive id="rsc_hadev2" class="ocf" type="IPaddr" provider="heartbeat"/>
<attributes>
<nvpair name="timeout" value="20s"/>
<nvpair name="interval" value="5s"/>
<nvpair name="ip" value="127.0.0.22"/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<rsc_op id="13" rsc_id="rsc_hadev2" operation="start" operation_key="rsc_hadev2_start_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="4">
<action_set>
<rsc_op id="12" rsc_id="rsc_hadev2" operation="stop" operation_key="rsc_hadev2_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false">
<primitive id="rsc_hadev2" class="ocf" type="IPaddr" provider="heartbeat"/>
<attributes>
<nvpair name="ip" value="127.0.0.22"/>
</attributes>
</rsc_op>
</action_set>
<inputs/>
</synapse>
<synapse id="5">
<action_set>
<rsc_op id="13" rsc_id="rsc_hadev2" operation="start" operation_key="rsc_hadev2_start_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false">
<primitive id="rsc_hadev2" class="ocf" type="IPaddr" provider="heartbeat"/>
<attributes>
<nvpair name="ip" value="127.0.0.22"/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<rsc_op id="12" rsc_id="rsc_hadev2" operation="stop" operation_key="rsc_hadev2_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="6">
<action_set>
<rsc_op id="4" rsc_id="DoFencing:child_DoFencing:0" operation="monitor" operation_key="DoFencing:child_DoFencing:0_monitor_5000" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false">
<primitive id="DoFencing:child_DoFencing:0" class="stonith" type="ssh"/>
<attributes>
<nvpair name="timeout" value="20s"/>
<nvpair name="interval" value="5s"/>
<nvpair name="clone" value="0"/>
<nvpair name="clone_max" value="3"/>
<nvpair name="hostlist" value="hadev3 hadev2 hadev1 "/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<rsc_op id="17" rsc_id="DoFencing:child_DoFencing:0" operation="start" operation_key="DoFencing:child_DoFencing:0_start_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="7">
<action_set>
<rsc_op id="16" rsc_id="DoFencing:child_DoFencing:0" operation="stop" operation_key="DoFencing:child_DoFencing:0_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false">
<primitive id="DoFencing:child_DoFencing:0" class="stonith" type="ssh"/>
<attributes>
<nvpair name="clone" value="0"/>
<nvpair name="clone_max" value="3"/>
<nvpair name="hostlist" value="hadev3 hadev2 hadev1 "/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<pseudo_event id="22" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="8">
<action_set>
<rsc_op id="17" rsc_id="DoFencing:child_DoFencing:0" operation="start" operation_key="DoFencing:child_DoFencing:0_start_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false">
<primitive id="DoFencing:child_DoFencing:0" class="stonith" type="ssh"/>
<attributes>
<nvpair name="clone" value="0"/>
<nvpair name="clone_max" value="3"/>
<nvpair name="hostlist" value="hadev3 hadev2 hadev1 "/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<rsc_op id="16" rsc_id="DoFencing:child_DoFencing:0" operation="stop" operation_key="DoFencing:child_DoFencing:0_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false"/>
</trigger>
<trigger>
<pseudo_event id="20" rsc_id="DoFencing" operation="start" operation_key="DoFencing_start_0" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="9">
<action_set>
<rsc_op id="18" rsc_id="DoFencing:child_DoFencing:1" operation="stop" operation_key="DoFencing:child_DoFencing:1_stop_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false">
<primitive id="DoFencing:child_DoFencing:1" class="stonith" type="ssh"/>
<attributes>
<nvpair name="clone" value="1"/>
<nvpair name="clone_max" value="3"/>
<nvpair name="hostlist" value="hadev3 hadev2 hadev1 "/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<pseudo_event id="22" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="10">
<action_set>
<rsc_op id="19" rsc_id="DoFencing:child_DoFencing:2" operation="stop" operation_key="DoFencing:child_DoFencing:2_stop_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false">
<primitive id="DoFencing:child_DoFencing:2" class="stonith" type="ssh"/>
<attributes>
<nvpair name="clone" value="2"/>
<nvpair name="clone_max" value="3"/>
<nvpair name="hostlist" value="hadev3 hadev2 hadev1 "/>
</attributes>
</rsc_op>
</action_set>
<inputs>
<trigger>
<pseudo_event id="22" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="11">
<action_set>
<pseudo_event id="20" rsc_id="DoFencing" operation="start" operation_key="DoFencing_start_0" allow_fail="false">
<attributes/>
</pseudo_event>
</action_set>
<inputs>
<trigger>
<pseudo_event id="23" rsc_id="DoFencing" operation="stopped" operation_key="DoFencing_stopped_0" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="12">
<action_set>
<pseudo_event id="21" rsc_id="DoFencing" operation="running" operation_key="DoFencing_running_0" allow_fail="false">
<attributes/>
</pseudo_event>
</action_set>
<inputs>
<trigger>
<rsc_op id="17" rsc_id="DoFencing:child_DoFencing:0" operation="start" operation_key="DoFencing:child_DoFencing:0_start_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="13">
<action_set>
<pseudo_event id="22" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false">
<attributes/>
</pseudo_event>
</action_set>
<inputs/>
</synapse>
<synapse id="14">
<action_set>
<pseudo_event id="23" rsc_id="DoFencing" operation="stopped" operation_key="DoFencing_stopped_0" allow_fail="false">
<attributes/>
</pseudo_event>
</action_set>
<inputs>
<trigger>
<rsc_op id="16" rsc_id="DoFencing:child_DoFencing:0" operation="stop" operation_key="DoFencing:child_DoFencing:0_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false"/>
</trigger>
<trigger>
<rsc_op id="18" rsc_id="DoFencing:child_DoFencing:1" operation="stop" operation_key="DoFencing:child_DoFencing:1_stop_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false"/>
</trigger>
<trigger>
<rsc_op id="19" rsc_id="DoFencing:child_DoFencing:2" operation="stop" operation_key="DoFencing:child_DoFencing:2_stop_0" on_node="hadev1" on_node_uuid="6125a0df-456a-4395-829a-418e9a380d36" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
<synapse id="15">
<action_set>
- <crm_event id="24" operation="do_shutdown" operation_key="do_shutdown" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false">
+ <crm_event id="24" operation="stonith" operation_key="stonith" allow_fail="false">
+ <attributes>
+ <nvpair name="on_node" value="hadev3"/>
+ <nvpair name="on_node_uuid" value="879e65f8-4b38-4c56-9552-4752ad436669"/>
+ </attributes>
+ </crm_event>
+ </action_set>
+ <inputs/>
+ </synapse>
+ <synapse id="16">
+ <action_set>
+ <crm_event id="25" operation="do_shutdown" operation_key="do_shutdown" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false">
<attributes/>
</crm_event>
</action_set>
<inputs>
<trigger>
<rsc_op id="8" rsc_id="DcIPaddr" operation="stop" operation_key="DcIPaddr_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false"/>
</trigger>
<trigger>
<rsc_op id="12" rsc_id="rsc_hadev2" operation="stop" operation_key="rsc_hadev2_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false"/>
</trigger>
<trigger>
<rsc_op id="16" rsc_id="DoFencing:child_DoFencing:0" operation="stop" operation_key="DoFencing:child_DoFencing:0_stop_0" on_node="hadev2" on_node_uuid="190b75b6-5585-42d9-8cde-eb6041843ae3" allow_fail="false"/>
</trigger>
</inputs>
</synapse>
</transition_graph>
diff --git a/crm/pengine/testcases/829.dot b/crm/pengine/testcases/829.dot
new file mode 100644
index 0000000000..9a490ec893
--- /dev/null
+++ b/crm/pengine/testcases/829.dot
@@ -0,0 +1,67 @@
+digraph "g" {
+ size = "30,30"
+"rsc_c001n08_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
+"DoFencing:child_DoFencing:1_monitor_5000" [ tooltip="c001n08" style=bold color="green" fontcolor="black" ]
+"DcIPaddr_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
+"DoFencing:child_DoFencing:3_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
+"DoFencing:child_DoFencing:0_monitor_5000" [ tooltip="c001n01" style=bold color="green" fontcolor="black" ]
+"rsc_c001n01_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
+"rsc_c001n02_monitor_5000" [ tooltip="c001n03" style=bold color="green" fontcolor="black" ]
+"DoFencing:child_DoFencing:2_monitor_5000" [ tooltip="c001n03" style=bold color="green" fontcolor="black" ]
+"rsc_c001n03_monitor_5000" [ style="dashed" color="blue" fontcolor="black" ]
+"DcIPaddr_stop_0" [ style="dashed" color="blue" fontcolor="black" ]
+"DcIPaddr_start_0" [ style="dashed" color="blue" fontcolor="black" ]
+"rsc_c001n08_stop_0" [ style="dashed" color="blue" fontcolor="black" ]
+"rsc_c001n08_start_0" [ style="dashed" color="blue" fontcolor="black" ]
+"rsc_c001n02_stop_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
+"rsc_c001n02_start_0" [ tooltip="c001n03" style=bold color="green" fontcolor="black" ]
+"rsc_c001n03_stop_0" [ style="dashed" color="blue" fontcolor="black" ]
+"rsc_c001n03_start_0" [ style="dashed" color="blue" fontcolor="black" ]
+"rsc_c001n01_stop_0" [ style="dashed" color="blue" fontcolor="black" ]
+"rsc_c001n01_start_0" [ style="dashed" color="blue" fontcolor="black" ]
+"DoFencing:child_DoFencing:0_stop_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
+"DoFencing:child_DoFencing:0_start_0" [ tooltip="c001n01" style=bold color="green" fontcolor="black" ]
+"DoFencing:child_DoFencing:1_stop_0" [ tooltip="c001n03" style=bold color="green" fontcolor="black" ]
+"DoFencing:child_DoFencing:1_start_0" [ tooltip="c001n08" style=bold color="green" fontcolor="black" ]
+"DoFencing:child_DoFencing:2_stop_0" [ tooltip="c001n01" style=bold color="green" fontcolor="black" ]
+"DoFencing:child_DoFencing:2_start_0" [ tooltip="c001n03" style=bold color="green" fontcolor="black" ]
+"DoFencing:child_DoFencing:3_stop_0" [ tooltip="c001n08" style=bold color="green" fontcolor="black" ]
+"DoFencing_start_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
+"DoFencing_running_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
+"DoFencing_stop_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
+"DoFencing_stopped_0" [ tooltip="" style=bold color="green" fontcolor="orange" ]
+"stonith" [ tooltip="c001n02" style=bold color="green" fontcolor="black" ]
+"rsc_c001n08_start_0" -> "rsc_c001n08_monitor_5000" [ style = dashed]
+"DoFencing:child_DoFencing:1_start_0" -> "DoFencing:child_DoFencing:1_monitor_5000" [ style = bold]
+"DcIPaddr_start_0" -> "DcIPaddr_monitor_5000" [ style = dashed]
+"DoFencing:child_DoFencing:0_start_0" -> "DoFencing:child_DoFencing:0_monitor_5000" [ style = bold]
+"rsc_c001n01_start_0" -> "rsc_c001n01_monitor_5000" [ style = dashed]
+"rsc_c001n02_start_0" -> "rsc_c001n02_monitor_5000" [ style = bold]
+"DoFencing:child_DoFencing:2_start_0" -> "DoFencing:child_DoFencing:2_monitor_5000" [ style = bold]
+"rsc_c001n03_start_0" -> "rsc_c001n03_monitor_5000" [ style = dashed]
+"DcIPaddr_stop_0" -> "DcIPaddr_start_0" [ style = dashed]
+"rsc_c001n08_stop_0" -> "rsc_c001n08_start_0" [ style = dashed]
+"stonith" -> "rsc_c001n02_stop_0" [ style = bold]
+"rsc_c001n02_stop_0" -> "rsc_c001n02_start_0" [ style = bold]
+"rsc_c001n03_stop_0" -> "rsc_c001n03_start_0" [ style = dashed]
+"rsc_c001n01_stop_0" -> "rsc_c001n01_start_0" [ style = dashed]
+"DoFencing_stop_0" -> "DoFencing:child_DoFencing:0_stop_0" [ style = bold]
+"stonith" -> "DoFencing:child_DoFencing:0_stop_0" [ style = bold]
+"DoFencing:child_DoFencing:0_stop_0" -> "DoFencing:child_DoFencing:0_start_0" [ style = bold]
+"DoFencing_start_0" -> "DoFencing:child_DoFencing:0_start_0" [ style = bold]
+"DoFencing_stop_0" -> "DoFencing:child_DoFencing:1_stop_0" [ style = bold]
+"DoFencing:child_DoFencing:1_stop_0" -> "DoFencing:child_DoFencing:1_start_0" [ style = bold]
+"DoFencing_start_0" -> "DoFencing:child_DoFencing:1_start_0" [ style = bold]
+"DoFencing_stop_0" -> "DoFencing:child_DoFencing:2_stop_0" [ style = bold]
+"DoFencing:child_DoFencing:2_stop_0" -> "DoFencing:child_DoFencing:2_start_0" [ style = bold]
+"DoFencing_start_0" -> "DoFencing:child_DoFencing:2_start_0" [ style = bold]
+"DoFencing_stop_0" -> "DoFencing:child_DoFencing:3_stop_0" [ style = bold]
+"DoFencing_stopped_0" -> "DoFencing_start_0" [ style = bold]
+"DoFencing:child_DoFencing:0_start_0" -> "DoFencing_running_0" [ style = bold]
+"DoFencing:child_DoFencing:1_start_0" -> "DoFencing_running_0" [ style = bold]
+"DoFencing:child_DoFencing:2_start_0" -> "DoFencing_running_0" [ style = bold]
+"DoFencing:child_DoFencing:0_stop_0" -> "DoFencing_stopped_0" [ style = bold]
+"DoFencing:child_DoFencing:1_stop_0" -> "DoFencing_stopped_0" [ style = bold]
+"DoFencing:child_DoFencing:2_stop_0" -> "DoFencing_stopped_0" [ style = bold]
+"DoFencing:child_DoFencing:3_stop_0" -> "DoFencing_stopped_0" [ style = bold]
+}
diff --git a/crm/pengine/testcases/829.exp b/crm/pengine/testcases/829.exp
new file mode 100644
index 0000000000..5bf21fabb4
--- /dev/null
+++ b/crm/pengine/testcases/829.exp
@@ -0,0 +1,305 @@
+ <transition_graph global_timeout="3m" transition_id="0">
+ <synapse id="0">
+ <action_set>
+ <rsc_op id="7" rsc_id="rsc_c001n02" operation="monitor" operation_key="rsc_c001n02_monitor_5000" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false">
+ <primitive id="rsc_c001n02" class="ocf" type="IPaddr" provider="heartbeat" is_managed="1"/>
+ <attributes>
+ <nvpair name="timeout" value="20s"/>
+ <nvpair name="interval" value="5s"/>
+ <nvpair name="is_managed" value="1"/>
+ <nvpair name="ip" value="127.0.0.12"/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <rsc_op id="15" rsc_id="rsc_c001n02" operation="start" operation_key="rsc_c001n02_start_0" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="1">
+ <action_set>
+ <pseudo_event id="14" rsc_id="rsc_c001n02" operation="stop" operation_key="rsc_c001n02_stop_0" allow_fail="false">
+ <attributes/>
+ </pseudo_event>
+ </action_set>
+ <inputs>
+ <trigger>
+ <crm_event id="31" operation="stonith" operation_key="stonith" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="2">
+ <action_set>
+ <rsc_op id="15" rsc_id="rsc_c001n02" operation="start" operation_key="rsc_c001n02_start_0" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false">
+ <primitive id="rsc_c001n02" class="ocf" type="IPaddr" provider="heartbeat" is_managed="1"/>
+ <attributes>
+ <nvpair name="is_managed" value="1"/>
+ <nvpair name="ip" value="127.0.0.12"/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <pseudo_event id="14" rsc_id="rsc_c001n02" operation="stop" operation_key="rsc_c001n02_stop_0" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="3">
+ <action_set>
+ <rsc_op id="5" rsc_id="DoFencing:child_DoFencing:0" operation="monitor" operation_key="DoFencing:child_DoFencing:0_monitor_5000" on_node="c001n01" on_node_uuid="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:0" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="timeout" value="20s"/>
+ <nvpair name="interval" value="5s"/>
+ <nvpair name="clone" value="0"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <rsc_op id="21" rsc_id="DoFencing:child_DoFencing:0" operation="start" operation_key="DoFencing:child_DoFencing:0_start_0" on_node="c001n01" on_node_uuid="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="4">
+ <action_set>
+ <pseudo_event id="20" rsc_id="DoFencing:child_DoFencing:0" operation="stop" operation_key="DoFencing:child_DoFencing:0_stop_0" allow_fail="false">
+ <attributes/>
+ </pseudo_event>
+ </action_set>
+ <inputs>
+ <trigger>
+ <pseudo_event id="29" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <crm_event id="31" operation="stonith" operation_key="stonith" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="5">
+ <action_set>
+ <rsc_op id="21" rsc_id="DoFencing:child_DoFencing:0" operation="start" operation_key="DoFencing:child_DoFencing:0_start_0" on_node="c001n01" on_node_uuid="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:0" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="timeout" value="20s"/>
+ <nvpair name="clone" value="0"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <pseudo_event id="20" rsc_id="DoFencing:child_DoFencing:0" operation="stop" operation_key="DoFencing:child_DoFencing:0_stop_0" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <pseudo_event id="27" rsc_id="DoFencing" operation="start" operation_key="DoFencing_start_0" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="6">
+ <action_set>
+ <rsc_op id="2" rsc_id="DoFencing:child_DoFencing:1" operation="monitor" operation_key="DoFencing:child_DoFencing:1_monitor_5000" on_node="c001n08" on_node_uuid="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:1" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="timeout" value="20s"/>
+ <nvpair name="interval" value="5s"/>
+ <nvpair name="clone" value="1"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <rsc_op id="23" rsc_id="DoFencing:child_DoFencing:1" operation="start" operation_key="DoFencing:child_DoFencing:1_start_0" on_node="c001n08" on_node_uuid="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="7">
+ <action_set>
+ <rsc_op id="22" rsc_id="DoFencing:child_DoFencing:1" operation="stop" operation_key="DoFencing:child_DoFencing:1_stop_0" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:1" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="clone" value="1"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <pseudo_event id="29" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="8">
+ <action_set>
+ <rsc_op id="23" rsc_id="DoFencing:child_DoFencing:1" operation="start" operation_key="DoFencing:child_DoFencing:1_start_0" on_node="c001n08" on_node_uuid="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:1" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="timeout" value="20s"/>
+ <nvpair name="clone" value="1"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <rsc_op id="22" rsc_id="DoFencing:child_DoFencing:1" operation="stop" operation_key="DoFencing:child_DoFencing:1_stop_0" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <pseudo_event id="27" rsc_id="DoFencing" operation="start" operation_key="DoFencing_start_0" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="9">
+ <action_set>
+ <rsc_op id="8" rsc_id="DoFencing:child_DoFencing:2" operation="monitor" operation_key="DoFencing:child_DoFencing:2_monitor_5000" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:2" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="timeout" value="20s"/>
+ <nvpair name="interval" value="5s"/>
+ <nvpair name="clone" value="2"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <rsc_op id="25" rsc_id="DoFencing:child_DoFencing:2" operation="start" operation_key="DoFencing:child_DoFencing:2_start_0" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="10">
+ <action_set>
+ <rsc_op id="24" rsc_id="DoFencing:child_DoFencing:2" operation="stop" operation_key="DoFencing:child_DoFencing:2_stop_0" on_node="c001n01" on_node_uuid="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:2" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="clone" value="2"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <pseudo_event id="29" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="11">
+ <action_set>
+ <rsc_op id="25" rsc_id="DoFencing:child_DoFencing:2" operation="start" operation_key="DoFencing:child_DoFencing:2_start_0" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:2" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="timeout" value="20s"/>
+ <nvpair name="clone" value="2"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <rsc_op id="24" rsc_id="DoFencing:child_DoFencing:2" operation="stop" operation_key="DoFencing:child_DoFencing:2_stop_0" on_node="c001n01" on_node_uuid="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <pseudo_event id="27" rsc_id="DoFencing" operation="start" operation_key="DoFencing_start_0" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="12">
+ <action_set>
+ <rsc_op id="26" rsc_id="DoFencing:child_DoFencing:3" operation="stop" operation_key="DoFencing:child_DoFencing:3_stop_0" on_node="c001n08" on_node_uuid="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" allow_fail="false">
+ <primitive id="DoFencing:child_DoFencing:3" class="stonith" type="ssh"/>
+ <attributes>
+ <nvpair name="clone" value="3"/>
+ <nvpair name="clone_max" value="4"/>
+ <nvpair name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </rsc_op>
+ </action_set>
+ <inputs>
+ <trigger>
+ <pseudo_event id="29" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="13">
+ <action_set>
+ <pseudo_event id="27" rsc_id="DoFencing" operation="start" operation_key="DoFencing_start_0" allow_fail="false">
+ <attributes/>
+ </pseudo_event>
+ </action_set>
+ <inputs>
+ <trigger>
+ <pseudo_event id="30" rsc_id="DoFencing" operation="stopped" operation_key="DoFencing_stopped_0" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="14">
+ <action_set>
+ <pseudo_event id="28" rsc_id="DoFencing" operation="running" operation_key="DoFencing_running_0" allow_fail="false">
+ <attributes/>
+ </pseudo_event>
+ </action_set>
+ <inputs>
+ <trigger>
+ <rsc_op id="21" rsc_id="DoFencing:child_DoFencing:0" operation="start" operation_key="DoFencing:child_DoFencing:0_start_0" on_node="c001n01" on_node_uuid="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <rsc_op id="23" rsc_id="DoFencing:child_DoFencing:1" operation="start" operation_key="DoFencing:child_DoFencing:1_start_0" on_node="c001n08" on_node_uuid="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <rsc_op id="25" rsc_id="DoFencing:child_DoFencing:2" operation="start" operation_key="DoFencing:child_DoFencing:2_start_0" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="15">
+ <action_set>
+ <pseudo_event id="29" rsc_id="DoFencing" operation="stop" operation_key="DoFencing_stop_0" allow_fail="false">
+ <attributes/>
+ </pseudo_event>
+ </action_set>
+ <inputs/>
+ </synapse>
+ <synapse id="16">
+ <action_set>
+ <pseudo_event id="30" rsc_id="DoFencing" operation="stopped" operation_key="DoFencing_stopped_0" allow_fail="false">
+ <attributes/>
+ </pseudo_event>
+ </action_set>
+ <inputs>
+ <trigger>
+ <pseudo_event id="20" rsc_id="DoFencing:child_DoFencing:0" operation="stop" operation_key="DoFencing:child_DoFencing:0_stop_0" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <rsc_op id="22" rsc_id="DoFencing:child_DoFencing:1" operation="stop" operation_key="DoFencing:child_DoFencing:1_stop_0" on_node="c001n03" on_node_uuid="5d9a8c11-8684-43ea-9180-5e221530c193" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <rsc_op id="24" rsc_id="DoFencing:child_DoFencing:2" operation="stop" operation_key="DoFencing:child_DoFencing:2_stop_0" on_node="c001n01" on_node_uuid="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" allow_fail="false"/>
+ </trigger>
+ <trigger>
+ <rsc_op id="26" rsc_id="DoFencing:child_DoFencing:3" operation="stop" operation_key="DoFencing:child_DoFencing:3_stop_0" on_node="c001n08" on_node_uuid="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" allow_fail="false"/>
+ </trigger>
+ </inputs>
+ </synapse>
+ <synapse id="17">
+ <action_set>
+ <crm_event id="31" operation="stonith" operation_key="stonith" allow_fail="false">
+ <attributes>
+ <nvpair name="on_node" value="c001n02"/>
+ <nvpair name="on_node_uuid" value="e9bdfde9-01b0-421f-acd8-8a65a53e775f"/>
+ </attributes>
+ </crm_event>
+ </action_set>
+ <inputs/>
+ </synapse>
+ </transition_graph>
+
diff --git a/crm/pengine/testcases/829.xml b/crm/pengine/testcases/829.xml
new file mode 100644
index 0000000000..2c1f0464e3
--- /dev/null
+++ b/crm/pengine/testcases/829.xml
@@ -0,0 +1,202 @@
+<cib cib_feature_revision="1" have_quorum="true" generated="true" admin_epoch="0" epoch="4" num_updates="98" num_peers="4" origin="c001n08" ccm_transition="5" dc_uuid="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" debug_source="finalize_join">
+ <configuration>
+ <crm_config>
+ <nvpair id="transition_idle_timeout" name="transition_idle_timeout" value="3m"/>
+ <nvpair id="symmetric_cluster" name="symetric_cluster" value="true"/>
+ <nvpair id="suppress_cib_writes" name="suppress_cib_writes" value="1"/>
+ <nvpair id="no_quorum_policy" name="no_quorum_policy" value="stop"/>
+ <nvpair id="stonith_enabled" name="stonith_enabled" value="true"/>
+ </crm_config>
+ <nodes>
+ <node id="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" uname="c001n08" type="member"/>
+ <node id="e9bdfde9-01b0-421f-acd8-8a65a53e775f" uname="c001n02" type="member"/>
+ <node id="5d9a8c11-8684-43ea-9180-5e221530c193" uname="c001n03" type="member"/>
+ <node id="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" uname="c001n01" type="member"/>
+ </nodes>
+ <resources>
+ <primitive id="DcIPaddr" class="ocf" type="IPaddr" provider="heartbeat" is_managed="1">
+ <operations>
+ <op id="1" name="monitor" interval="5s" timeout="20s"/>
+ </operations>
+ <instance_attributes>
+ <attributes>
+ <nvpair id="1" name="ip" value="127.0.0.10"/>
+ </attributes>
+ </instance_attributes>
+ </primitive>
+ <primitive id="rsc_c001n08" class="ocf" type="IPaddr" provider="heartbeat" is_managed="1">
+ <operations>
+ <op id="1" name="monitor" interval="5s" timeout="20s"/>
+ </operations>
+ <instance_attributes>
+ <attributes>
+ <nvpair id="1" name="ip" value="127.0.0.11"/>
+ </attributes>
+ </instance_attributes>
+ </primitive>
+ <primitive id="rsc_c001n02" class="ocf" type="IPaddr" provider="heartbeat" is_managed="1">
+ <operations>
+ <op id="1" name="monitor" interval="5s" timeout="20s"/>
+ </operations>
+ <instance_attributes>
+ <attributes>
+ <nvpair id="1" name="ip" value="127.0.0.12"/>
+ </attributes>
+ </instance_attributes>
+ </primitive>
+ <primitive id="rsc_c001n03" class="ocf" type="IPaddr" provider="heartbeat" is_managed="1">
+ <operations>
+ <op id="1" name="monitor" interval="5s" timeout="20s"/>
+ </operations>
+ <instance_attributes>
+ <attributes>
+ <nvpair id="1" name="ip" value="127.0.0.13"/>
+ </attributes>
+ </instance_attributes>
+ </primitive>
+ <primitive id="rsc_c001n01" class="ocf" type="IPaddr" provider="heartbeat" is_managed="1">
+ <operations>
+ <op id="1" name="monitor" interval="5s" timeout="20s"/>
+ </operations>
+ <instance_attributes>
+ <attributes>
+ <nvpair id="1" name="ip" value="127.0.0.14"/>
+ </attributes>
+ </instance_attributes>
+ </primitive>
+ <clone id="DoFencing">
+ <instance_attributes>
+ <attributes>
+ <nvpair id="1" name="clone_max" value="4"/>
+ <nvpair id="2" name="clone_node_max" value="1"/>
+ </attributes>
+ </instance_attributes>
+ <primitive id="child_DoFencing" class="stonith" type="ssh">
+ <operations>
+ <op id="1" name="monitor" interval="5s" timeout="20s" prereq="nothing"/>
+ <op id="2" name="start" timeout="20s" prereq="nothing"/>
+ </operations>
+ <instance_attributes>
+ <attributes>
+ <nvpair id="1" name="hostlist" value="c001n08 c001n02 c001n03 c001n01 "/>
+ </attributes>
+ </instance_attributes>
+ </primitive>
+ </clone>
+ </resources>
+ <constraints>
+ <rsc_location id="run_DcIPaddr" rsc="DcIPaddr">
+ <rule id="cant_run_DcIPaddr" score="-INFINITY" boolean_op="and">
+ <expression id="dc_ip_expr" attribute="#is_dc" operation="eq" value="false"/>
+ </rule>
+ </rsc_location>
+ <rsc_location id="run_rsc_c001n08" rsc="rsc_c001n08">
+ <rule id="pref_run_rsc_c001n08" score="100" boolean_op="and">
+ <expression id="rsc_c001n08_loc_expr" attribute="#uname" operation="eq" value="c001n08"/>
+ </rule>
+ </rsc_location>
+ <rsc_location id="run_rsc_c001n02" rsc="rsc_c001n02">
+ <rule id="pref_run_rsc_c001n02" score="100" boolean_op="and">
+ <expression id="rsc_c001n02_loc_expr" attribute="#uname" operation="eq" value="c001n02"/>
+ </rule>
+ </rsc_location>
+ <rsc_location id="run_rsc_c001n03" rsc="rsc_c001n03">
+ <rule id="pref_run_rsc_c001n03" score="100" boolean_op="and">
+ <expression id="rsc_c001n03_loc_expr" attribute="#uname" operation="eq" value="c001n03"/>
+ </rule>
+ </rsc_location>
+ <rsc_location id="run_rsc_c001n01" rsc="rsc_c001n01">
+ <rule id="pref_run_rsc_c001n01" score="100" boolean_op="and">
+ <expression id="rsc_c001n01_loc_expr" attribute="#uname" operation="eq" value="c001n01"/>
+ </rule>
+ </rsc_location>
+ </constraints>
+ </configuration>
+ <status>
+ <node_state id="6427cb5a-c7a5-4bdf-9892-a04ce56f4e6b" uname="c001n08" in_ccm="true" join="member" origin="do_lrm_query" crmd="online" ha="active" expected="member">
+ <lrm>
+ <lrm_resources>
+ <lrm_resource id="rsc_c001n08" last_op="monitor" rsc_state="running" rc_code="0" op_status="0">
+ <lrm_rsc_op id="rsc_c001n08_start_0" operation="start" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="9" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="rsc_c001n08_monitor_5000" operation="monitor" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="10" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ <lrm_resource id="DoFencing:child_DoFencing:0" last_op="stop" rsc_state="stopped" rc_code="0" op_status="0">
+ <lrm_rsc_op id="DoFencing:child_DoFencing:0_start_0" operation="start" origin="build_active_RAs" transition_key="0:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:0:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="2" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:0_stop_0" operation="stop" origin="build_active_RAs" transition_key="1:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:1:75be675e-8d68-4581-9ead-957421c47590" rsc_state="stopped" call_id="5" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ <lrm_resource id="DoFencing:child_DoFencing:1" last_op="stop" rsc_state="stopped" rc_code="0" op_status="0">
+ <lrm_rsc_op id="DoFencing:child_DoFencing:1_start_0" operation="start" origin="build_active_RAs" transition_key="1:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:1:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="6" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:1_monitor_5000" operation="monitor" origin="build_active_RAs" transition_key="1:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:1:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="7" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:1_stop_0" operation="stop" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="stopped" call_id="13" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ <lrm_resource id="DcIPaddr" last_op="monitor" rsc_state="running" rc_code="0" op_status="0">
+ <lrm_rsc_op id="DcIPaddr_start_0" operation="start" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="8" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DcIPaddr_monitor_5000" operation="monitor" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="11" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ <lrm_resource id="DoFencing:child_DoFencing:3" rsc_state="running" op_status="0" rc_code="0" last_op="monitor">
+ <lrm_rsc_op id="DoFencing:child_DoFencing:3_start_0" operation="start" op_status="0" call_id="14" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:3_monitor_5000" operation="monitor" op_status="0" call_id="15" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ </lrm_resource>
+ </lrm_resources>
+ </lrm>
+ </node_state>
+ <node_state id="e9bdfde9-01b0-421f-acd8-8a65a53e775f" uname="c001n02" crmd="online" origin="ghash_update_cib_node" in_ccm="false" join="down" ha="active" expected="member">
+ <lrm>
+ <lrm_resources>
+ <lrm_resource id="DoFencing:child_DoFencing:0" last_op="monitor" rsc_state="running" rc_code="0" op_status="0">
+ <lrm_rsc_op id="DoFencing:child_DoFencing:0_start_0" operation="start" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="16" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:0_stop_0" operation="stop" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="stopped" call_id="5" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:0_monitor_5000" operation="monitor" op_status="0" call_id="17" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ </lrm_resource>
+ <lrm_resource id="rsc_c001n01" last_op="stop" rsc_state="stopped" rc_code="0" op_status="0">
+ <lrm_rsc_op id="rsc_c001n01_start_0" operation="start" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="7" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="rsc_c001n01_monitor_5000" operation="monitor" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="10" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="rsc_c001n01_stop_0" operation="stop" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="stopped" call_id="13" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ <lrm_resource id="rsc_c001n02" last_op="monitor" rsc_state="running" rc_code="0" op_status="0">
+ <lrm_rsc_op id="rsc_c001n02_start_0" operation="start" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="6" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="rsc_c001n02_monitor_5000" operation="monitor" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="11" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ <lrm_resource id="DoFencing:child_DoFencing:2" last_op="stop" rsc_state="stopped" rc_code="0" op_status="0">
+ <lrm_rsc_op id="DoFencing:child_DoFencing:2_start_0" operation="start" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="8" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:2_monitor_5000" operation="monitor" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="9" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:2_stop_0" operation="stop" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="stopped" call_id="15" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ </lrm_resources>
+ </lrm>
+ </node_state>
+ <node_state id="5d9a8c11-8684-43ea-9180-5e221530c193" uname="c001n03" crmd="online" origin="do_lrm_query" in_ccm="true" join="member" ha="active" expected="member">
+ <lrm>
+ <lrm_resources>
+ <lrm_resource id="DoFencing:child_DoFencing:0" last_op="stop" rsc_state="stopped" rc_code="0" op_status="0">
+ <lrm_rsc_op id="DoFencing:child_DoFencing:0_start_0" operation="start" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="3" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:0_monitor_5000" operation="monitor" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="4" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:0_stop_0" operation="stop" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="stopped" call_id="7" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ <lrm_resource id="rsc_c001n03" last_op="monitor" rsc_state="running" rc_code="0" op_status="0">
+ <lrm_rsc_op id="rsc_c001n03_start_0" operation="start" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="2" rc_code="0" op_status="0"/>
+ <lrm_rsc_op id="rsc_c001n03_monitor_5000" operation="monitor" origin="build_active_RAs" transition_key="2:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:2:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running" call_id="5" rc_code="0" op_status="0"/>
+ </lrm_resource>
+ <lrm_resource id="DoFencing:child_DoFencing:1" rsc_state="running" op_status="0" rc_code="0" last_op="monitor">
+ <lrm_rsc_op id="DoFencing:child_DoFencing:1_start_0" operation="start" op_status="0" call_id="8" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:1_monitor_5000" operation="monitor" op_status="0" call_id="9" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ </lrm_resource>
+ </lrm_resources>
+ </lrm>
+ </node_state>
+ <node_state id="de937e3d-0309-4b5d-b85c-f96edc1ed8e3" uname="c001n01" crmd="online" origin="do_lrm_query" in_ccm="true" join="member" ha="active" expected="member">
+ <lrm>
+ <lrm_resources>
+ <lrm_resource id="rsc_c001n01" rsc_state="running" op_status="0" rc_code="0" last_op="monitor">
+ <lrm_rsc_op id="rsc_c001n01_start_0" operation="start" op_status="0" call_id="2" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ <lrm_rsc_op id="rsc_c001n01_monitor_5000" operation="monitor" op_status="0" call_id="5" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ </lrm_resource>
+ <lrm_resource id="DoFencing:child_DoFencing:2" rsc_state="running" op_status="0" rc_code="0" last_op="monitor">
+ <lrm_rsc_op id="DoFencing:child_DoFencing:2_start_0" operation="start" op_status="0" call_id="3" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ <lrm_rsc_op id="DoFencing:child_DoFencing:2_monitor_5000" operation="monitor" op_status="0" call_id="4" rc_code="0" origin="do_update_resource" transition_key="3:75be675e-8d68-4581-9ead-957421c47590" transition_magic="0:3:75be675e-8d68-4581-9ead-957421c47590" rsc_state="running"/>
+ </lrm_resource>
+ </lrm_resources>
+ </lrm>
+ </node_state>
+ </status>
+</cib>
diff --git a/crm/pengine/unpack.c b/crm/pengine/unpack.c
index 90e64cd774..1555a1cb4c 100644
--- a/crm/pengine/unpack.c
+++ b/crm/pengine/unpack.c
@@ -1,1314 +1,1319 @@
-/* $Id: unpack.c,v 1.118 2005/08/24 09:28:36 andrew Exp $ */
+/* $Id: unpack.c,v 1.119 2005/08/25 09:27:22 andrew Exp $ */
/*
* Copyright (C) 2004 Andrew Beekhof <andrew@beekhof.net>
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* General Public License for more details.
*
* You should have received a copy of the GNU General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
#include <portability.h>
#include <crm/crm.h>
#include <crm/cib.h>
#include <crm/msg_xml.h>
#include <crm/common/xml.h>
#include <crm/common/msg.h>
#include <clplumbing/cl_misc.h>
#include <lrm/lrm_api.h>
#include <glib.h>
#include <heartbeat.h> /* for ONLINESTATUS */
#include <pengine.h>
#include <pe_utils.h>
#include <pe_rules.h>
gint sort_op_by_callid(gconstpointer a, gconstpointer b);
gboolean unpack_rsc_to_attr(crm_data_t *xml_obj, pe_working_set_t *data_set);
gboolean unpack_rsc_to_node(crm_data_t *xml_obj, pe_working_set_t *data_set);
gboolean unpack_rsc_order(crm_data_t *xml_obj, pe_working_set_t *data_set);
gboolean unpack_rsc_colocation(crm_data_t *xml_obj, pe_working_set_t *data_set);
gboolean unpack_rsc_location(crm_data_t *xml_obj, pe_working_set_t *data_set);
gboolean unpack_lrm_rsc_state(
node_t *node, crm_data_t * lrm_state, pe_working_set_t *data_set);
gboolean add_node_attrs(
crm_data_t * attrs, node_t *node, pe_working_set_t *data_set);
gboolean unpack_rsc_op(
resource_t *rsc, node_t *node, crm_data_t *xml_op,
gboolean *running, int *max_call_id, pe_working_set_t *data_set);
gboolean determine_online_status(
crm_data_t * node_state, node_t *this_node, pe_working_set_t *data_set);
gboolean rsc_colocation_new(
const char *id, enum con_strength strength,
resource_t *rsc_lh, resource_t *rsc_rh);
gboolean create_ordering(
const char *id, enum con_strength strength,
resource_t *rsc_lh, resource_t *rsc_rh, pe_working_set_t *data_set);
rsc_to_node_t *rsc2node_new(
const char *id, resource_t *rsc,
double weight, node_t *node, pe_working_set_t *data_set);
const char *param_value(
GHashTable *hash, crm_data_t * parent, const char *name);
rsc_to_node_t *generate_location_rule(
resource_t *rsc, crm_data_t *location_rule, pe_working_set_t *data_set);
gboolean
unpack_config(crm_data_t * config, pe_working_set_t *data_set)
{
/* const char *attr_filter[] = { */
/* "default_resource_stickiness", */
/* "transition_idle_timeout", */
/* "stonith_enabled", */
/* "symmetric_cluster" */
/* }; */
const char *value = NULL;
GHashTable *config_hash = g_hash_table_new_full(
g_str_hash,g_str_equal, g_hash_destroy_str,g_hash_destroy_str);
unpack_instance_attributes(
config, "cluster_property_set", NULL, config_hash,
NULL, 0, data_set);
#if CRM_DEPRECATED_SINCE_2_0_1
param_value(config_hash, config, "transition_idle_timeout");
param_value(config_hash, config, "default_resource_stickiness");
param_value(config_hash, config, "stonith_enabled");
param_value(config_hash, config, "symmetric_cluster");
param_value(config_hash, config, "no_quorum_policy");
#endif
value = g_hash_table_lookup(config_hash, "transition_idle_timeout");
if(value != NULL) {
long tmp = crm_get_msec(value);
if(tmp > 0) {
crm_free(data_set->transition_idle_timeout);
data_set->transition_idle_timeout = crm_strdup(value);
} else {
crm_err("Invalid value for %s: %s",
"transition_idle_timeout",
data_set->transition_idle_timeout);
}
}
crm_debug_4("%s set to: %s",
"transition_idle_timeout", data_set->transition_idle_timeout);
value = g_hash_table_lookup(config_hash, "default_resource_stickiness");
data_set->default_resource_stickiness = crm_atoi(value, "0");
value = g_hash_table_lookup(config_hash, "stonith_enabled");
if(value != NULL) {
cl_str_to_boolean(value, &data_set->stonith_enabled);
}
crm_info("STONITH of failed nodes is %s",
data_set->stonith_enabled?"enabled":"disabled");
value = g_hash_table_lookup(config_hash, "symmetric_cluster");
if(value != NULL) {
cl_str_to_boolean(value, &data_set->symmetric_cluster);
}
if(data_set->symmetric_cluster) {
crm_info("Cluster is symmetric"
" - resources can run anywhere by default");
}
value = g_hash_table_lookup(config_hash, "no_quorum_policy");
if(safe_str_eq(value, "ignore")) {
data_set->no_quorum_policy = no_quorum_ignore;
} else if(safe_str_eq(value, "freeze")) {
data_set->no_quorum_policy = no_quorum_freeze;
} else {
data_set->no_quorum_policy = no_quorum_stop;
}
switch (data_set->no_quorum_policy) {
case no_quorum_freeze:
crm_info("On loss of CCM Quorum: Freeze resources");
break;
case no_quorum_stop:
crm_info("On loss of CCM Quorum: Stop ALL resources");
break;
case no_quorum_ignore:
crm_warn("On loss of CCM Quorum: Ignore");
break;
}
g_hash_table_destroy(config_hash);
return TRUE;
}
const char *
param_value(GHashTable *hash, crm_data_t * parent, const char *name)
{
const char *value = NULL;
crm_data_t * a_default = NULL;
if(parent != NULL) {
a_default = find_entity(parent, XML_CIB_TAG_NVPAIR, name);
}
if(a_default == NULL) {
crm_warn("Option %s not set", name);
return NULL;
}
value = crm_element_value(a_default, XML_NVPAIR_ATTR_VALUE);
if(value && hash) {
if(g_hash_table_lookup(hash, name) == NULL) {
g_hash_table_insert(
hash, crm_strdup(name), crm_strdup(value));
}
}
return value;
}
gboolean
unpack_nodes(crm_data_t * xml_nodes, pe_working_set_t *data_set)
{
node_t *new_node = NULL;
const char *id = NULL;
const char *uname = NULL;
const char *type = NULL;
crm_debug("Begining unpack... %s",
xml_nodes?crm_element_name(xml_nodes):"<none>");
xml_child_iter(
xml_nodes, xml_obj, XML_CIB_TAG_NODE,
new_node = NULL;
id = crm_element_value(xml_obj, XML_ATTR_ID);
uname = crm_element_value(xml_obj, XML_ATTR_UNAME);
type = crm_element_value(xml_obj, XML_ATTR_TYPE);
crm_debug_3("Processing node %s/%s", uname, id);
if(id == NULL) {
pe_err("Must specify id tag in <node>");
continue;
}
if(type == NULL) {
pe_err("Must specify type tag in <node>");
continue;
}
crm_malloc0(new_node, sizeof(node_t));
if(new_node == NULL) {
return FALSE;
}
new_node->weight = 0;
new_node->fixed = FALSE;
crm_malloc0(new_node->details,
sizeof(struct node_shared_s));
if(new_node->details == NULL) {
crm_free(new_node);
return FALSE;
}
crm_debug_3("Creaing node for entry %s/%s", uname, id);
new_node->details->id = id;
new_node->details->uname = uname;
new_node->details->type = node_ping;
new_node->details->online = FALSE;
new_node->details->shutdown = FALSE;
new_node->details->running_rsc = NULL;
new_node->details->attrs = g_hash_table_new_full(
g_str_hash, g_str_equal,
g_hash_destroy_str, g_hash_destroy_str);
/* if(data_set->have_quorum == FALSE */
/* && data_set->no_quorum_policy == no_quorum_stop) { */
/* /\* start shutting resources down *\/ */
/* new_node->weight = -INFINITY; */
/* } */
if(data_set->stonith_enabled) {
/* all nodes are unclean until we've seen their
* status entry
*/
new_node->details->unclean = TRUE;
} else {
/* blind faith... */
new_node->details->unclean = FALSE;
}
if(safe_str_eq(type, "member")) {
new_node->details->type = node_member;
}
add_node_attrs(xml_obj, new_node, data_set);
if(crm_is_true(g_hash_table_lookup(
new_node->details->attrs, "standby"))) {
crm_info("Node %s is in standby-mode",
new_node->details->uname);
new_node->weight = -INFINITY;
}
data_set->nodes = g_list_append(data_set->nodes, new_node);
crm_debug_3("Done with node %s",
crm_element_value(xml_obj, XML_ATTR_UNAME));
crm_action_debug_3(print_node("Added", new_node, FALSE));
);
data_set->nodes = g_list_sort(data_set->nodes, sort_node_weight);
return TRUE;
}
gboolean
unpack_resources(crm_data_t * xml_resources, pe_working_set_t *data_set)
{
crm_debug("Begining unpack... %s",
xml_resources?crm_element_name(xml_resources):"<none>");
xml_child_iter(
xml_resources, xml_obj, NULL,
resource_t *new_rsc = NULL;
crm_debug_2("Begining unpack... %s",
xml_obj?crm_element_name(xml_obj):"<none>");
if(common_unpack(xml_obj, &new_rsc, NULL, data_set)) {
data_set->resources = g_list_append(
data_set->resources, new_rsc);
crm_action_debug_3(
print_resource("Added", new_rsc, FALSE));
} else {
pe_err("Failed unpacking %s %s",
crm_element_name(xml_obj),
crm_element_value(xml_obj, XML_ATTR_ID));
}
);
data_set->resources = g_list_sort(
data_set->resources, sort_rsc_priority);
return TRUE;
}
gboolean
unpack_constraints(crm_data_t * xml_constraints, pe_working_set_t *data_set)
{
crm_data_t *lifetime = NULL;
crm_debug("Begining unpack... %s",
xml_constraints?crm_element_name(xml_constraints):"<none>");
xml_child_iter(
xml_constraints, xml_obj, NULL,
const char *id = crm_element_value(xml_obj, XML_ATTR_ID);
if(id == NULL) {
pe_err("Constraint <%s...> must have an id",
crm_element_name(xml_obj));
continue;
}
crm_debug_3("Processing constraint %s %s",
crm_element_name(xml_obj),id);
lifetime = cl_get_struct(xml_obj, "lifetime");
if(test_ruleset(lifetime, NULL, data_set) == FALSE) {
crm_info("Constraint %s %s is not active",
crm_element_name(xml_obj), id);
} else if(safe_str_eq(XML_CONS_TAG_RSC_ORDER,
crm_element_name(xml_obj))) {
unpack_rsc_order(xml_obj, data_set);
} else if(safe_str_eq(XML_CONS_TAG_RSC_DEPEND,
crm_element_name(xml_obj))) {
unpack_rsc_colocation(xml_obj, data_set);
} else if(safe_str_eq(XML_CONS_TAG_RSC_LOCATION,
crm_element_name(xml_obj))) {
unpack_rsc_location(xml_obj, data_set);
} else {
pe_err("Unsupported constraint type: %s",
crm_element_name(xml_obj));
}
);
return TRUE;
}
rsc_to_node_t *
rsc2node_new(const char *id, resource_t *rsc,
double weight, node_t *node, pe_working_set_t *data_set)
{
rsc_to_node_t *new_con = NULL;
if(rsc == NULL || id == NULL) {
pe_err("Invalid constraint %s for rsc=%p", crm_str(id), rsc);
return NULL;
}
crm_malloc0(new_con, sizeof(rsc_to_node_t));
if(new_con != NULL) {
new_con->id = id;
new_con->rsc_lh = rsc;
new_con->node_list_rh = NULL;
new_con->weight = weight;
if(node != NULL) {
node_t *copy = node_copy(node);
new_con->node_list_rh = g_list_append(NULL, copy);
}
data_set->placement_constraints = g_list_append(
data_set->placement_constraints, new_con);
}
return new_con;
}
/* remove nodes that are down, stopping */
/* create +ve rsc_to_node constraints between resources and the nodes they are running on */
/* anything else? */
gboolean
unpack_status(crm_data_t * status, pe_working_set_t *data_set)
{
const char *uname = NULL;
crm_data_t * lrm_rsc = NULL;
crm_data_t * lrm_agents = NULL;
crm_data_t * attrs = NULL;
node_t *this_node = NULL;
crm_debug_3("Begining unpack");
xml_child_iter(
status, node_state, XML_CIB_TAG_STATE,
/* id = crm_element_value(node_state, XML_ATTR_ID); */
uname = crm_element_value(node_state, XML_ATTR_UNAME);
attrs = find_xml_node(node_state, XML_LRM_TAG_ATTRIBUTES,FALSE);
lrm_rsc = find_xml_node(node_state, XML_CIB_TAG_LRM, FALSE);
lrm_agents = find_xml_node(lrm_rsc, XML_LRM_TAG_AGENTS, FALSE);
lrm_rsc = find_xml_node(lrm_rsc, XML_LRM_TAG_RESOURCES, FALSE);
crm_debug_3("Processing node %s", uname);
this_node = pe_find_node(data_set->nodes, uname);
if(uname == NULL) {
/* error */
continue;
} else if(this_node == NULL) {
pe_warn("Node %s in status section no longer exists",
uname);
continue;
}
/* Mark the node as provisionally clean
* - at least we have seen it in the current cluster's lifetime
*/
this_node->details->unclean = FALSE;
crm_debug_3("Adding runtime node attrs");
add_node_attrs(node_state, this_node, data_set);
crm_debug_3("determining node state");
determine_online_status(node_state, this_node, data_set);
if(this_node->details->online || data_set->stonith_enabled) {
/* offline nodes run no resources...
* unless stonith is enabled in which case we need to
* make sure rsc start events happen after the stonith
*/
crm_debug_3("Processing lrm resource entries");
unpack_lrm_rsc_state(this_node, lrm_rsc, data_set);
}
);
return TRUE;
}
gboolean
determine_online_status(
crm_data_t * node_state, node_t *this_node, pe_working_set_t *data_set)
{
gboolean online = FALSE;
const char *uname = crm_element_value(node_state,XML_ATTR_UNAME);
const char *exp_state =
crm_element_value(node_state, XML_CIB_ATTR_EXPSTATE);
const char *join_state =
crm_element_value(node_state, XML_CIB_ATTR_JOINSTATE);
const char *crm_state =
crm_element_value(node_state, XML_CIB_ATTR_CRMDSTATE);
const char *ccm_state =
crm_element_value(node_state, XML_CIB_ATTR_INCCM);
const char *ha_state =
crm_element_value(node_state, XML_CIB_ATTR_HASTATE);
const char *shutdown =
crm_element_value(node_state, XML_CIB_ATTR_SHUTDOWN);
if(this_node == NULL) {
return online;
}
+ if(safe_str_eq(exp_state, CRMD_JOINSTATE_MEMBER)) {
+ this_node->details->expected_up = TRUE;
+ }
if(shutdown != NULL) {
this_node->details->shutdown = TRUE;
- }
- if(safe_str_eq(join_state, CRMD_JOINSTATE_MEMBER)) {
- this_node->details->expected_up = TRUE;
+#if 0
+ this_node->details->expected_up = FALSE;
+#endif
}
if(data_set->stonith_enabled == FALSE) {
if(!crm_is_true(ccm_state) || safe_str_eq(ha_state,DEADSTATUS)){
crm_debug_2("Node is down: ha_state=%s, ccm_state=%s",
crm_str(ha_state), crm_str(ccm_state));
} else if(!crm_is_true(ccm_state)
|| safe_str_eq(ha_state, DEADSTATUS)) {
} else if(safe_str_neq(join_state, CRMD_JOINSTATE_DOWN)
&& safe_str_eq(crm_state, ONLINESTATUS)) {
online = TRUE;
} else if(this_node->details->expected_up == FALSE) {
crm_debug_2("CRMd is down: ha_state=%s, ccm_state=%s",
crm_str(ha_state), crm_str(ccm_state));
crm_debug_2("\tcrm_state=%s, join_state=%s, expected=%s",
crm_str(crm_state), crm_str(join_state),
crm_str(exp_state));
} else {
/* mark it unclean */
this_node->details->unclean = TRUE;
pe_err("Node %s is partially & un-expectedly down",
uname);
- crm_debug_2("\tcrm_state=%s, join_state=%s, expected=%s",
- crm_str(crm_state), crm_str(join_state),
- crm_str(exp_state));
+ crm_info("\tha_state=%s, ccm_state=%s,"
+ " crm_state=%s, join_state=%s, expected=%s",
+ crm_str(ha_state), crm_str(ccm_state),
+ crm_str(crm_state), crm_str(join_state),
+ crm_str(exp_state));
}
} else {
if(crm_is_true(ccm_state)
&& (ha_state == NULL || safe_str_eq(ha_state, ACTIVESTATUS))
&& safe_str_eq(crm_state, ONLINESTATUS)
&& safe_str_neq(join_state, CRMD_JOINSTATE_DOWN)) {
online = TRUE;
} else if(this_node->details->expected_up == FALSE) {
crm_debug_2("CRMd on %s is down: ha_state=%s, ccm_state=%s",
uname, crm_str(ha_state), crm_str(ccm_state));
crm_debug_2("\tcrm_state=%s, join_state=%s, expected=%s",
crm_str(crm_state), crm_str(join_state),
crm_str(exp_state));
} else {
/* mark it unclean */
this_node->details->unclean = TRUE;
pe_err("Node %s is un-expectedly down", uname);
- crm_debug_2("\tha_state=%s, ccm_state=%s",
- crm_str(ha_state), crm_str(ccm_state));
- crm_debug_2("\tcrm_state=%s, join_state=%s, expected=%s",
- crm_str(crm_state), crm_str(join_state),
- crm_str(exp_state));
+ crm_info("\tha_state=%s, ccm_state=%s,"
+ " crm_state=%s, join_state=%s, expected=%s",
+ crm_str(ha_state), crm_str(ccm_state),
+ crm_str(crm_state), crm_str(join_state),
+ crm_str(exp_state));
}
}
if(online) {
crm_debug_2("Node %s is online", uname);
this_node->details->online = TRUE;
} else {
/* remove node from contention */
crm_debug_2("Node %s is down", uname);
this_node->weight = -INFINITY;
this_node->fixed = TRUE;
}
if(this_node->details->unclean) {
pe_warn("Node %s is unclean", uname);
}
if(this_node->details->shutdown) {
/* dont run resources here */
this_node->weight = -INFINITY;
this_node->fixed = TRUE;
crm_debug_2("Node %s is due for shutdown", uname);
}
return online;
}
gboolean
unpack_lrm_rsc_state(node_t *node, crm_data_t * lrm_rsc_list,
pe_working_set_t *data_set)
{
const char *rsc_id = NULL;
const char *node_id = node->details->uname;
const char *rsc_state = NULL;
int max_call_id = -1;
gboolean running = FALSE;
resource_t *rsc = NULL;
GListPtr op_list = NULL;
GListPtr sorted_op_list = NULL;
CRM_DEV_ASSERT(node != NULL);
if(crm_assert_failed) {
return FALSE;
}
xml_child_iter(
lrm_rsc_list, rsc_entry, XML_LRM_TAG_RESOURCE,
rsc_id = crm_element_value(rsc_entry, XML_ATTR_ID);
rsc_state = crm_element_value(rsc_entry, XML_LRM_ATTR_RSCSTATE);
rsc = pe_find_resource(data_set->resources, rsc_id);
crm_debug_3("[%s] Processing %s on %s (%s)",
crm_element_name(rsc_entry),
rsc_id, node_id, rsc_state);
if(rsc == NULL) {
pe_err("Could not find a match for resource"
" %s in %s's status section",
rsc_id, node_id);
crm_log_xml_debug(rsc_entry, "Invalid status entry");
continue;
}
running = FALSE;
max_call_id = -1;
op_list = NULL;
sorted_op_list = NULL;
xml_child_iter(
rsc_entry, rsc_op, XML_LRM_TAG_RSC_OP,
op_list = g_list_append(op_list, rsc_op);
);
if(op_list == NULL) {
continue;
}
sorted_op_list = g_list_sort(op_list, sort_op_by_callid);
slist_iter(
rsc_op, crm_data_t, sorted_op_list, lpc,
unpack_rsc_op(rsc, node, rsc_op,
&running, &max_call_id, data_set);
);
/* no need to free the contents */
g_list_free(sorted_op_list);
if(running) {
native_add_running(rsc, node, data_set);
}
);
return TRUE;
}
#define sort_return(an_int) crm_free(a_uuid); crm_free(b_uuid); return an_int
gint
sort_op_by_callid(gconstpointer a, gconstpointer b)
{
char *a_uuid = NULL;
char *b_uuid = NULL;
const char *a_task_id = cl_get_string(a, XML_LRM_ATTR_CALLID);
const char *b_task_id = cl_get_string(b, XML_LRM_ATTR_CALLID);
const char *a_key = cl_get_string(a, XML_ATTR_TRANSITION_MAGIC);
const char *b_key = cl_get_string(b, XML_ATTR_TRANSITION_MAGIC);
int a_id = -1;
int b_id = -1;
int a_status = -1;
int b_status = -1;
int a_call_id = -1;
int b_call_id = -1;
CRM_DEV_ASSERT(a_task_id != NULL && b_task_id != NULL);
a_call_id = atoi(a_task_id);
b_call_id = atoi(b_task_id);
if(a_call_id == -1 && b_call_id == -1) {
/* both are pending ops so it doesnt matter since
* stops are never pending
*/
sort_return(0);
} else if(a_call_id >= 0 && a_call_id < b_call_id) {
crm_debug_2("%s (%d) < %s (%d) : call id",
ID(a), a_call_id, ID(b), b_call_id);
sort_return(-1);
} else if(b_call_id >= 0 && a_call_id > b_call_id) {
crm_debug_2("%s (%d) > %s (%d) : call id",
ID(a), a_call_id, ID(b), b_call_id);
sort_return(1);
}
crm_debug_3("%s (%d) == %s (%d) : continuing",
ID(a), a_call_id, ID(b), b_call_id);
/* now process pending ops */
CRM_DEV_ASSERT(a_key != NULL && b_key != NULL);
CRM_DEV_ASSERT(decode_transition_magic(a_key,&a_uuid,&a_id,&a_status));
CRM_DEV_ASSERT(decode_transition_magic(b_key,&b_uuid,&b_id,&b_status));
/* try and determin the relative age of the operation...
* some pending operations (ie. a start) may have been supuerceeded
* by a subsequent stop
*
* [a|b]_id == -1 means its a shutdown operation and _always_ comes last
*/
if(safe_str_neq(a_uuid, b_uuid) || a_id == b_id) {
/*
* some of the logic in here may be redundant...
*
* if the UUID from the TE doesnt match then one better
* be a pending operation.
* pending operations dont survive between elections and joins
* because we query the LRM directly
*/
CRM_DEV_ASSERT(a_call_id == -1 || b_call_id == -1);
CRM_DEV_ASSERT(a_call_id >= 0 || b_call_id >= 0);
if(b_call_id == -1) {
crm_debug_2("%s (%d) < %s (%d) : transition + call id",
ID(a), a_call_id, ID(b), b_call_id);
sort_return(-1);
}
if(a_call_id == -1) {
crm_debug_2("%s (%d) > %s (%d) : transition + call id",
ID(a), a_call_id, ID(b), b_call_id);
sort_return(1);
}
} else if((a_id >= 0 && a_id < b_id) || b_id == -1) {
crm_debug_2("%s (%d) < %s (%d) : transition",
ID(a), a_id, ID(b), b_id);
sort_return(-1);
} else if((b_id >= 0 && a_id > b_id) || a_id == -1) {
crm_debug_2("%s (%d) > %s (%d) : transition",
ID(a), a_id, ID(b), b_id);
sort_return(1);
}
/* we should never end up here */
crm_err("%s (%d:%d:%s) ?? %s (%d:%d:%s) : default",
ID(a), a_call_id, a_id, a_uuid, ID(b), b_call_id, b_id, b_uuid);
CRM_DEV_ASSERT(FALSE);
sort_return(0);
}
gboolean
unpack_rsc_op(resource_t *rsc, node_t *node, crm_data_t *xml_op,
gboolean *running, int *max_call_id, pe_working_set_t *data_set)
{
const char *id = NULL;
const char *task = NULL;
const char *task_id = NULL;
const char *task_status = NULL;
int task_id_i = -1;
int task_status_i = -2;
action_t *action = NULL;
gboolean is_stop_action = FALSE;
CRM_DEV_ASSERT(rsc != NULL); if(crm_assert_failed) { return FALSE; }
CRM_DEV_ASSERT(node != NULL); if(crm_assert_failed) { return FALSE; }
CRM_DEV_ASSERT(xml_op != NULL); if(crm_assert_failed) { return FALSE; }
id = ID(xml_op);
task = crm_element_value(xml_op, XML_LRM_ATTR_TASK);
task_id = crm_element_value(xml_op, XML_LRM_ATTR_CALLID);
task_status = crm_element_value(xml_op, XML_LRM_ATTR_OPSTATUS);
CRM_DEV_ASSERT(id != NULL);
if(crm_assert_failed) { return FALSE; }
CRM_DEV_ASSERT(task != NULL);
if(crm_assert_failed) { return FALSE; }
CRM_DEV_ASSERT(task_status != NULL);
if(crm_assert_failed) { return FALSE; }
task_status_i = atoi(task_status);
CRM_DEV_ASSERT(task_status_i <= LRM_OP_ERROR);
if(crm_assert_failed) {return FALSE;}
CRM_DEV_ASSERT(task_status_i >= LRM_OP_PENDING);
if(crm_assert_failed) {return FALSE;}
if(safe_str_eq(task, CRMD_ACTION_NOTIFY)) {
/* safe to ignore these */
return TRUE;
}
crm_debug_2("Unpacking task %s/%s (call_id=%s, status=%s) on %s",
rsc->id, task, task_id, task_status, node->details->uname);
if(safe_str_eq(task, CRMD_ACTION_STOP)) {
is_stop_action = TRUE;
}
if(task_status_i != LRM_OP_PENDING) {
task_id_i = crm_atoi(task_id, "-1");
CRM_DEV_ASSERT(task_id != NULL);
if(crm_assert_failed) { return FALSE; }
CRM_DEV_ASSERT(task_id_i >= 0);
if(crm_assert_failed) { return FALSE; }
if(task_id_i == *max_call_id) {
crm_debug_2("Already processed this call");
return TRUE;
}
CRM_DEV_ASSERT(task_id_i > *max_call_id);
if(crm_assert_failed) { return FALSE; }
}
if(*max_call_id < task_id_i) {
*max_call_id = task_id_i;
}
if(node->details->unclean) {
crm_debug_2("Node %s (where %s is running) is unclean."
" Further action depends on the value of %s",
node->details->uname, rsc->id, XML_RSC_ATTR_STOPFAIL);
}
switch(task_status_i) {
case LRM_OP_PENDING:
/*
* TODO: this may need some more thought
* Some cases:
* - PE reinvoked with pending action that will succeed
* - PE reinvoked with pending action that will fail
* - After DC election
* - After startup
*
* pending start - required start
* pending stop - required stop
* pending <any> on unavailable node - stonith
*
* For now this should do
*/
if(is_stop_action) {
/* re-issue the stop and return */
stop_action(rsc, node, FALSE);
*running = TRUE;
rsc->recover = TRUE;
} else if(safe_str_eq(task, CRMD_ACTION_START)) {
rsc->start_pending = TRUE;
*running = TRUE;
/* make sure it is re-issued but,
* only if we have quorum
*/
if(data_set->have_quorum == TRUE
|| data_set->no_quorum_policy == no_quorum_ignore){
/* do not specify the node, we may want
* to start it elsewhere
*/
start_action(rsc, NULL, FALSE);
}
} else if(*running == TRUE) {
crm_debug_2("Re-issuing pending recurring task:"
" %s for %s on %s",
task, rsc->id, node->details->id);
/* do not specify the node, we may want
* to start it elsewhere
*/
custom_action(rsc, crm_strdup(id),
task, NULL, FALSE, data_set);
}
break;
case LRM_OP_DONE:
crm_debug_3("%s/%s completed on %s",
rsc->id, task, node->details->uname);
if(is_stop_action) {
*running = FALSE;
} else if(safe_str_eq(task, CRMD_ACTION_START)) {
crm_debug_3("%s active on %s",
rsc->id, node->details->uname);
*running = TRUE;
} else if(*running) {
/* make sure its already created and is optional
*
* creating it now tells create_recurring_actions()
* that it can safely leave it optional
*/
custom_action(rsc, crm_strdup(id),
task, NULL, TRUE, data_set);
}
break;
case LRM_OP_ERROR:
case LRM_OP_TIMEOUT:
case LRM_OP_NOTSUPPORTED:
crm_debug_2("Processing failed op (%s) for %s on %s",
task, rsc->id, node->details->uname);
action = custom_action(
rsc, crm_strdup(id), task, NULL, TRUE, data_set);
if(action->on_fail == action_fail_nothing) {
/* pretend the op completed */
if(is_stop_action) {
*running = FALSE;
} else {
*running = TRUE;
}
break;
}
if(task_status_i == LRM_OP_NOTSUPPORTED
|| is_stop_action
|| safe_str_eq(task, CRMD_ACTION_START) ) {
crm_warn("Handling failed %s for %s on %s",
task, rsc->id, node->details->uname);
rsc2node_new("dont_run__failed_stopstart",
rsc, -INFINITY, node, data_set);
}
if(action->on_fail == action_fail_fence) {
/* treat it as if it is still running
* but also mark the node as unclean
*/
rsc->unclean = TRUE;
node->details->unclean = TRUE;
stop_action(rsc, node, FALSE);
*running = TRUE;
} else if(action->on_fail == action_fail_block) {
/* let this depend on the stop action
* which will fail but make sure the
* transition continues...
*/
rsc->unclean = TRUE;
*running = TRUE;
} else if(action->on_fail == action_fail_stop) {
*running = TRUE;
stop_action(rsc, node, FALSE);
}
break;
case LRM_OP_CANCELLED:
/* do nothing?? */
pe_err("Dont know what to do for cancelled ops yet");
break;
}
return TRUE;
}
gboolean
rsc_colocation_new(const char *id, enum con_strength strength,
resource_t *rsc_lh, resource_t *rsc_rh)
{
rsc_colocation_t *new_con = NULL;
rsc_colocation_t *inverted_con = NULL;
if(rsc_lh == NULL || rsc_rh == NULL){
/* error */
return FALSE;
}
crm_malloc0(new_con, sizeof(rsc_colocation_t));
if(new_con == NULL) {
return FALSE;
}
new_con->id = id;
new_con->rsc_lh = rsc_lh;
new_con->rsc_rh = rsc_rh;
new_con->strength = strength;
inverted_con = invert_constraint(new_con);
crm_debug_4("Adding constraint %s (%p) to %s",
new_con->id, new_con, rsc_lh->id);
rsc_lh->rsc_cons = g_list_insert_sorted(
rsc_lh->rsc_cons, new_con, sort_cons_strength);
crm_debug_4("Adding constraint %s (%p) to %s",
inverted_con->id, inverted_con, rsc_rh->id);
rsc_rh->rsc_cons = g_list_insert_sorted(
rsc_rh->rsc_cons, inverted_con, sort_cons_strength);
return TRUE;
}
/* LHS before RHS */
gboolean
custom_action_order(
resource_t *lh_rsc, char *lh_action_task, action_t *lh_action,
resource_t *rh_rsc, char *rh_action_task, action_t *rh_action,
enum pe_ordering type, pe_working_set_t *data_set)
{
order_constraint_t *order = NULL;
if((lh_action == NULL && lh_rsc == NULL)
|| (rh_action == NULL && rh_rsc == NULL)){
pe_err("Invalid inputs lh_rsc=%p, lh_a=%p,"
" rh_rsc=%p, rh_a=%p",
lh_rsc, lh_action, rh_rsc, rh_action);
crm_free(lh_action_task);
crm_free(rh_action_task);
return FALSE;
}
crm_malloc0(order, sizeof(order_constraint_t));
if(order == NULL) { return FALSE; }
order->id = data_set->order_id++;
order->type = type;
order->lh_rsc = lh_rsc;
order->rh_rsc = rh_rsc;
order->lh_action = lh_action;
order->rh_action = rh_action;
order->lh_action_task = lh_action_task;
order->rh_action_task = rh_action_task;
data_set->ordering_constraints = g_list_append(
data_set->ordering_constraints, order);
if(lh_rsc != NULL && rh_rsc != NULL) {
crm_debug_4("Created ordering constraint %d (%s):"
" %s/%s before %s/%s",
order->id, ordering_type2text(order->type),
lh_rsc->id, lh_action_task,
rh_rsc->id, rh_action_task);
} else if(lh_rsc != NULL) {
crm_debug_4("Created ordering constraint %d (%s):"
" %s/%s before action %d (%s)",
order->id, ordering_type2text(order->type),
lh_rsc->id, lh_action_task,
rh_action->id, rh_action_task);
} else if(rh_rsc != NULL) {
crm_debug_4("Created ordering constraint %d (%s):"
" action %d (%s) before %s/%s",
order->id, ordering_type2text(order->type),
lh_action->id, lh_action_task,
rh_rsc->id, rh_action_task);
} else {
crm_debug_4("Created ordering constraint %d (%s):"
" action %d (%s) before action %d (%s)",
order->id, ordering_type2text(order->type),
lh_action->id, lh_action_task,
rh_action->id, rh_action_task);
}
return TRUE;
}
gboolean
unpack_rsc_colocation(crm_data_t * xml_obj, pe_working_set_t *data_set)
{
enum con_strength strength_e = pecs_ignore;
const char *id = crm_element_value(xml_obj, XML_ATTR_ID);
const char *id_rh = crm_element_value(xml_obj, XML_CONS_ATTR_TO);
const char *id_lh = crm_element_value(xml_obj, XML_CONS_ATTR_FROM);
const char *score = crm_element_value(xml_obj, XML_RULE_ATTR_SCORE);
resource_t *rsc_lh = pe_find_resource(data_set->resources, id_lh);
resource_t *rsc_rh = pe_find_resource(data_set->resources, id_rh);
if(rsc_lh == NULL) {
pe_err("No resource (con=%s, rsc=%s)", id, id_lh);
return FALSE;
} else if(rsc_rh == NULL) {
pe_err("No resource (con=%s, rsc=%s)", id, id_rh);
return FALSE;
}
/* the docs indicate that only +/- INFINITY are allowed,
* but no-one ever reads the docs so all positive values will
* count as "must" and negative values as "must not"
*/
if(score == NULL || score[0] != '-') {
strength_e = pecs_must;
} else {
strength_e = pecs_must_not;
}
return rsc_colocation_new(id, strength_e, rsc_lh, rsc_rh);
}
gboolean
unpack_rsc_order(crm_data_t * xml_obj, pe_working_set_t *data_set)
{
gboolean type_is_after = TRUE;
gboolean action_is_start = TRUE;
gboolean symmetrical_bool = TRUE;
const char *id = crm_element_value(xml_obj, XML_ATTR_ID);
const char *type = crm_element_value(xml_obj, XML_ATTR_TYPE);
const char *id_rh = crm_element_value(xml_obj, XML_CONS_ATTR_TO);
const char *id_lh = crm_element_value(xml_obj, XML_CONS_ATTR_FROM);
const char *action = crm_element_value(xml_obj, XML_CONS_ATTR_ACTION);
const char *symmetrical = crm_element_value(
xml_obj, XML_CONS_ATTR_SYMMETRICAL);
resource_t *rsc_lh = pe_find_resource(data_set->resources, id_lh);
resource_t *rsc_rh = pe_find_resource(data_set->resources, id_rh);
if(xml_obj == NULL) {
pe_err("No constraint object to process.");
return FALSE;
} else if(id == NULL) {
pe_err("%s constraint must have an id",
crm_element_name(xml_obj));
return FALSE;
} else if(rsc_lh == NULL || rsc_rh == NULL) {
pe_err("Constraint %s needs two sides lh: %p rh: %p"
" (NULL indicates missing side)",
id, rsc_lh, rsc_rh);
return FALSE;
}
cl_str_to_boolean(symmetrical, &symmetrical_bool);
if(safe_str_eq(type, "before")) {
type_is_after = FALSE;
}
if(safe_str_eq(action, task2text(stop_rsc))) {
action_is_start = FALSE;
}
if((type_is_after && action_is_start)
|| (type_is_after == FALSE && action_is_start == FALSE)){
if(symmetrical_bool || action_is_start == FALSE) {
if(rsc_lh->restart_type == pe_restart_restart){
order_stop_stop(rsc_lh, rsc_rh, pe_ordering_recover);
}
order_stop_stop(rsc_lh, rsc_rh, pe_ordering_optional);
}
if(symmetrical_bool || action_is_start) {
if(rsc_lh->restart_type == pe_restart_restart){
order_start_start(rsc_rh, rsc_lh, pe_ordering_recover);
}
order_start_start(rsc_rh, rsc_lh, pe_ordering_optional);
}
} else {
if(symmetrical_bool || action_is_start == FALSE) {
if(rsc_rh->restart_type == pe_restart_restart){
order_stop_stop(rsc_rh, rsc_lh, pe_ordering_recover);
}
order_stop_stop(rsc_rh, rsc_lh, pe_ordering_optional);
}
if(symmetrical_bool || action_is_start) {
if(rsc_rh->restart_type == pe_restart_restart){
order_start_start(rsc_lh, rsc_rh, pe_ordering_recover);
}
order_start_start(rsc_lh, rsc_rh, pe_ordering_optional);
}
}
return TRUE;
}
gboolean
add_node_attrs(crm_data_t *xml_obj, node_t *node, pe_working_set_t *data_set)
{
g_hash_table_insert(node->details->attrs,
crm_strdup("#"XML_ATTR_UNAME),
crm_strdup(node->details->uname));
g_hash_table_insert(node->details->attrs,
crm_strdup("#"XML_ATTR_ID),
crm_strdup(node->details->id));
if(safe_str_eq(node->details->id, data_set->dc_uuid)) {
data_set->dc_node = node;
node->details->is_dc = TRUE;
g_hash_table_insert(node->details->attrs,
crm_strdup("#"XML_ATTR_DC),
crm_strdup(XML_BOOLEAN_TRUE));
} else {
g_hash_table_insert(node->details->attrs,
crm_strdup("#"XML_ATTR_DC),
crm_strdup(XML_BOOLEAN_FALSE));
}
unpack_instance_attributes(
xml_obj, XML_TAG_ATTR_SETS, node, node->details->attrs,
NULL, 0, data_set);
return TRUE;
}
gboolean
unpack_rsc_location(crm_data_t * xml_obj, pe_working_set_t *data_set)
{
const char *id_lh = crm_element_value(xml_obj, "rsc");
const char *id = crm_element_value(xml_obj, XML_ATTR_ID);
resource_t *rsc_lh = pe_find_resource(data_set->resources, id_lh);
if(rsc_lh == NULL) {
pe_warn("No resource (con=%s, rsc=%s)", id, id_lh);
return FALSE;
} else if(rsc_lh->is_managed == FALSE) {
crm_debug_2("Ignoring constraint %s: resource %s not managed",
id, id_lh);
return FALSE;
}
xml_child_iter(
xml_obj, rule_xml, XML_TAG_RULE,
crm_debug_2("Unpacking %s/%s", id, ID(rule_xml));
generate_location_rule(rsc_lh, rule_xml, data_set);
);
return TRUE;
}
rsc_to_node_t *
generate_location_rule(
resource_t *rsc, crm_data_t *rule_xml, pe_working_set_t *data_set)
{
const char *rule_id = NULL;
const char *score = NULL;
const char *boolean = NULL;
GListPtr match_L = NULL;
float score_f = 0.0;
gboolean do_and = TRUE;
gboolean accept = TRUE;
rsc_to_node_t *location_rule = NULL;
rule_id = crm_element_value(rule_xml, XML_ATTR_ID);
score = crm_element_value(rule_xml, XML_RULE_ATTR_SCORE);
boolean = crm_element_value(rule_xml, XML_RULE_ATTR_BOOLEAN_OP);
crm_debug("processing rule: %s", rule_id);
score_f = char2score(score);
if(safe_str_eq(boolean, "or")) {
do_and = FALSE;
}
location_rule = rsc2node_new(rule_id, rsc, score_f, NULL, data_set);
if(location_rule == NULL) {
return NULL;
}
if(do_and) {
match_L = node_list_dup(data_set->nodes, FALSE);
}
xml_child_iter(
rule_xml, expr, XML_TAG_EXPRESSION,
slist_iter(
node, node_t, data_set->nodes, lpc,
accept = test_expression(expr, node, data_set);
if(!do_and && accept) {
if(pe_find_node(match_L, node->details->uname) == NULL) {
node_t *dup = node_copy(node);
match_L = g_list_append(match_L, dup);
crm_debug_5("node %s matched",
node->details->uname);
}
crm_debug_5("node %s already matched",
node->details->uname);
} else if(do_and && !accept) {
/* remove it */
node_t *delete = pe_find_node(
match_L, node->details->uname);
if(delete != NULL) {
match_L = g_list_remove(match_L,delete);
crm_debug_5("node %s did not match",
node->details->uname);
}
crm_free(delete);
}
);
);
location_rule->node_list_rh = match_L;
if(location_rule->node_list_rh == NULL) {
crm_debug_2("No matching nodes for rule %s", rule_id);
return NULL;
}
crm_debug_2("%s: %d nodes matched",
rule_id, g_list_length(location_rule->node_list_rh));
crm_action_debug_3(print_rsc_to_node("Added", location_rule, FALSE));
return location_rule;
}