diff --git a/cts/cli/regression.tools.exp b/cts/cli/regression.tools.exp
index 0a92999e7c..9a26c2c707 100644
--- a/cts/cli/regression.tools.exp
+++ b/cts/cli/regression.tools.exp
@@ -1,3473 +1,3473 @@
Created new pacemaker configuration
Setting up shadow instance
A new shadow instance was created. To begin using it paste the following into your shell:
CIB_shadow=cts-cli ; export CIB_shadow
=#=#=#= Begin test: Validate CIB =#=#=#=
=#=#=#= Current cib after: Validate CIB =#=#=#=
=#=#=#= End test: Validate CIB - OK (0) =#=#=#=
* Passed: cibadmin - Validate CIB
=#=#=#= Begin test: Configure something before erasing =#=#=#=
=#=#=#= Current cib after: Configure something before erasing =#=#=#=
=#=#=#= End test: Configure something before erasing - OK (0) =#=#=#=
* Passed: crm_attribute - Configure something before erasing
=#=#=#= Begin test: Require --force for CIB erasure =#=#=#=
The supplied command is considered dangerous. To prevent accidental destruction of the cluster, the --force flag is required in order to proceed.
=#=#=#= Current cib after: Require --force for CIB erasure =#=#=#=
=#=#=#= End test: Require --force for CIB erasure - Operation not safe (107) =#=#=#=
* Passed: cibadmin - Require --force for CIB erasure
=#=#=#= Begin test: Allow CIB erasure with --force =#=#=#=
=#=#=#= Current cib after: Allow CIB erasure with --force =#=#=#=
=#=#=#= End test: Allow CIB erasure with --force - OK (0) =#=#=#=
* Passed: cibadmin - Allow CIB erasure with --force
=#=#=#= Begin test: Query CIB =#=#=#=
=#=#=#= Current cib after: Query CIB =#=#=#=
=#=#=#= End test: Query CIB - OK (0) =#=#=#=
* Passed: cibadmin - Query CIB
=#=#=#= Begin test: Set cluster option =#=#=#=
=#=#=#= Current cib after: Set cluster option =#=#=#=
=#=#=#= End test: Set cluster option - OK (0) =#=#=#=
* Passed: crm_attribute - Set cluster option
=#=#=#= Begin test: Query new cluster option =#=#=#=
=#=#=#= Current cib after: Query new cluster option =#=#=#=
=#=#=#= End test: Query new cluster option - OK (0) =#=#=#=
* Passed: cibadmin - Query new cluster option
=#=#=#= Begin test: Query cluster options =#=#=#=
=#=#=#= Current cib after: Query cluster options =#=#=#=
=#=#=#= End test: Query cluster options - OK (0) =#=#=#=
* Passed: cibadmin - Query cluster options
=#=#=#= Begin test: Set no-quorum policy =#=#=#=
=#=#=#= Current cib after: Set no-quorum policy =#=#=#=
=#=#=#= End test: Set no-quorum policy - OK (0) =#=#=#=
* Passed: crm_attribute - Set no-quorum policy
=#=#=#= Begin test: Delete nvpair =#=#=#=
=#=#=#= Current cib after: Delete nvpair =#=#=#=
=#=#=#= End test: Delete nvpair - OK (0) =#=#=#=
* Passed: cibadmin - Delete nvpair
=#=#=#= Begin test: Create operation should fail =#=#=#=
Call failed: File exists
=#=#=#= Current cib after: Create operation should fail =#=#=#=
=#=#=#= End test: Create operation should fail - Requested item already exists (108) =#=#=#=
* Passed: cibadmin - Create operation should fail
=#=#=#= Begin test: Modify cluster options section =#=#=#=
=#=#=#= Current cib after: Modify cluster options section =#=#=#=
=#=#=#= End test: Modify cluster options section - OK (0) =#=#=#=
* Passed: cibadmin - Modify cluster options section
=#=#=#= Begin test: Query updated cluster option =#=#=#=
=#=#=#= Current cib after: Query updated cluster option =#=#=#=
=#=#=#= End test: Query updated cluster option - OK (0) =#=#=#=
* Passed: cibadmin - Query updated cluster option
=#=#=#= Begin test: Set duplicate cluster option =#=#=#=
=#=#=#= Current cib after: Set duplicate cluster option =#=#=#=
=#=#=#= End test: Set duplicate cluster option - OK (0) =#=#=#=
* Passed: crm_attribute - Set duplicate cluster option
=#=#=#= Begin test: Setting multiply defined cluster option should fail =#=#=#=
Multiple attributes match name=cluster-delay
Value: 60s (id=cib-bootstrap-options-cluster-delay)
Value: 40s (id=duplicate-cluster-delay)
Please choose from one of the matches above and supply the 'id' with --attr-id
=#=#=#= Current cib after: Setting multiply defined cluster option should fail =#=#=#=
=#=#=#= End test: Setting multiply defined cluster option should fail - Multiple items match request (109) =#=#=#=
* Passed: crm_attribute - Setting multiply defined cluster option should fail
=#=#=#= Begin test: Set cluster option with -s =#=#=#=
=#=#=#= Current cib after: Set cluster option with -s =#=#=#=
=#=#=#= End test: Set cluster option with -s - OK (0) =#=#=#=
* Passed: crm_attribute - Set cluster option with -s
=#=#=#= Begin test: Delete cluster option with -i =#=#=#=
Deleted crm_config option: id=(null) name=cluster-delay
=#=#=#= Current cib after: Delete cluster option with -i =#=#=#=
=#=#=#= End test: Delete cluster option with -i - OK (0) =#=#=#=
* Passed: crm_attribute - Delete cluster option with -i
=#=#=#= Begin test: Create node1 and bring it online =#=#=#=
Current cluster status:
Performing requested modifications
+ Bringing node node1 online
Transition Summary:
Executing cluster transition:
Revised cluster status:
Online: [ node1 ]
=#=#=#= Current cib after: Create node1 and bring it online =#=#=#=
=#=#=#= End test: Create node1 and bring it online - OK (0) =#=#=#=
* Passed: crm_simulate - Create node1 and bring it online
=#=#=#= Begin test: Create node attribute =#=#=#=
=#=#=#= Current cib after: Create node attribute =#=#=#=
=#=#=#= End test: Create node attribute - OK (0) =#=#=#=
* Passed: crm_attribute - Create node attribute
=#=#=#= Begin test: Query new node attribute =#=#=#=
=#=#=#= Current cib after: Query new node attribute =#=#=#=
=#=#=#= End test: Query new node attribute - OK (0) =#=#=#=
* Passed: cibadmin - Query new node attribute
=#=#=#= Begin test: Set a transient (fail-count) node attribute =#=#=#=
=#=#=#= Current cib after: Set a transient (fail-count) node attribute =#=#=#=
=#=#=#= End test: Set a transient (fail-count) node attribute - OK (0) =#=#=#=
* Passed: crm_attribute - Set a transient (fail-count) node attribute
=#=#=#= Begin test: Query a fail count =#=#=#=
scope=status name=fail-count-foo value=3
=#=#=#= Current cib after: Query a fail count =#=#=#=
=#=#=#= End test: Query a fail count - OK (0) =#=#=#=
* Passed: crm_failcount - Query a fail count
=#=#=#= Begin test: Delete a transient (fail-count) node attribute =#=#=#=
Deleted status attribute: id=status-node1-fail-count-foo name=fail-count-foo
=#=#=#= Current cib after: Delete a transient (fail-count) node attribute =#=#=#=
=#=#=#= End test: Delete a transient (fail-count) node attribute - OK (0) =#=#=#=
* Passed: crm_attribute - Delete a transient (fail-count) node attribute
=#=#=#= Begin test: Digest calculation =#=#=#=
Digest: =#=#=#= Current cib after: Digest calculation =#=#=#=
=#=#=#= End test: Digest calculation - OK (0) =#=#=#=
* Passed: cibadmin - Digest calculation
=#=#=#= Begin test: Replace operation should fail =#=#=#=
Call failed: Update was older than existing configuration
=#=#=#= Current cib after: Replace operation should fail =#=#=#=
=#=#=#= End test: Replace operation should fail - Update was older than existing configuration (103) =#=#=#=
* Passed: cibadmin - Replace operation should fail
=#=#=#= Begin test: Default standby value =#=#=#=
scope=status name=standby value=off
=#=#=#= Current cib after: Default standby value =#=#=#=
=#=#=#= End test: Default standby value - OK (0) =#=#=#=
* Passed: crm_standby - Default standby value
=#=#=#= Begin test: Set standby status =#=#=#=
=#=#=#= Current cib after: Set standby status =#=#=#=
=#=#=#= End test: Set standby status - OK (0) =#=#=#=
* Passed: crm_standby - Set standby status
=#=#=#= Begin test: Query standby value =#=#=#=
scope=nodes name=standby value=true
=#=#=#= Current cib after: Query standby value =#=#=#=
=#=#=#= End test: Query standby value - OK (0) =#=#=#=
* Passed: crm_standby - Query standby value
=#=#=#= Begin test: Delete standby value =#=#=#=
Deleted nodes attribute: id=nodes-node1-standby name=standby
=#=#=#= Current cib after: Delete standby value =#=#=#=
=#=#=#= End test: Delete standby value - OK (0) =#=#=#=
* Passed: crm_standby - Delete standby value
=#=#=#= Begin test: Create a resource =#=#=#=
=#=#=#= Current cib after: Create a resource =#=#=#=
=#=#=#= End test: Create a resource - OK (0) =#=#=#=
* Passed: cibadmin - Create a resource
=#=#=#= Begin test: Create a resource meta attribute =#=#=#=
Set 'dummy' option: id=dummy-meta_attributes-is-managed set=dummy-meta_attributes name=is-managed value=false
=#=#=#= Current cib after: Create a resource meta attribute =#=#=#=
=#=#=#= End test: Create a resource meta attribute - OK (0) =#=#=#=
* Passed: crm_resource - Create a resource meta attribute
=#=#=#= Begin test: Query a resource meta attribute =#=#=#=
false
=#=#=#= Current cib after: Query a resource meta attribute =#=#=#=
=#=#=#= End test: Query a resource meta attribute - OK (0) =#=#=#=
* Passed: crm_resource - Query a resource meta attribute
=#=#=#= Begin test: Remove a resource meta attribute =#=#=#=
Deleted 'dummy' option: id=dummy-meta_attributes-is-managed name=is-managed
=#=#=#= Current cib after: Remove a resource meta attribute =#=#=#=
=#=#=#= End test: Remove a resource meta attribute - OK (0) =#=#=#=
* Passed: crm_resource - Remove a resource meta attribute
=#=#=#= Begin test: Create another resource meta attribute =#=#=#=
Set 'dummy' option: id=dummy-meta_attributes-target-role set=dummy-meta_attributes name=target-role value=Stopped
=#=#=#= End test: Create another resource meta attribute - OK (0) =#=#=#=
* Passed: crm_resource - Create another resource meta attribute
=#=#=#= Begin test: Show why a resource is not running =#=#=#=
Resource dummy is not running
* Configuration specifies 'dummy' should remain stopped
=#=#=#= End test: Show why a resource is not running - OK (0) =#=#=#=
* Passed: crm_resource - Show why a resource is not running
=#=#=#= Begin test: Remove another resource meta attribute =#=#=#=
Deleted 'dummy' option: id=dummy-meta_attributes-target-role name=target-role
=#=#=#= End test: Remove another resource meta attribute - OK (0) =#=#=#=
* Passed: crm_resource - Remove another resource meta attribute
=#=#=#= Begin test: Create a resource attribute =#=#=#=
Set 'dummy' option: id=dummy-instance_attributes-delay set=dummy-instance_attributes name=delay value=10s
=#=#=#= Current cib after: Create a resource attribute =#=#=#=
=#=#=#= End test: Create a resource attribute - OK (0) =#=#=#=
* Passed: crm_resource - Create a resource attribute
=#=#=#= Begin test: List the configured resources =#=#=#=
dummy (ocf::pacemaker:Dummy): Stopped
=#=#=#= Current cib after: List the configured resources =#=#=#=
=#=#=#= End test: List the configured resources - OK (0) =#=#=#=
* Passed: crm_resource - List the configured resources
=#=#=#= Begin test: List IDs of instantiated resources =#=#=#=
dummy
=#=#=#= End test: List IDs of instantiated resources - OK (0) =#=#=#=
* Passed: crm_resource - List IDs of instantiated resources
=#=#=#= Begin test: Show XML configuration of resource =#=#=#=
dummy (ocf::pacemaker:Dummy): Stopped
xml:
=#=#=#= End test: Show XML configuration of resource - OK (0) =#=#=#=
* Passed: crm_resource - Show XML configuration of resource
=#=#=#= Begin test: Require a destination when migrating a resource that is stopped =#=#=#=
Resource 'dummy' not moved: active in 0 locations.
To prevent 'dummy' from running on a specific location, specify a node.
Error performing operation: Invalid argument
=#=#=#= Current cib after: Require a destination when migrating a resource that is stopped =#=#=#=
=#=#=#= End test: Require a destination when migrating a resource that is stopped - Incorrect usage (64) =#=#=#=
* Passed: crm_resource - Require a destination when migrating a resource that is stopped
=#=#=#= Begin test: Don't support migration to non-existent locations =#=#=#=
Error performing operation: Node not found
=#=#=#= Current cib after: Don't support migration to non-existent locations =#=#=#=
=#=#=#= End test: Don't support migration to non-existent locations - No such object (105) =#=#=#=
* Passed: crm_resource - Don't support migration to non-existent locations
=#=#=#= Begin test: Create a fencing resource =#=#=#=
=#=#=#= Current cib after: Create a fencing resource =#=#=#=
=#=#=#= End test: Create a fencing resource - OK (0) =#=#=#=
* Passed: cibadmin - Create a fencing resource
=#=#=#= Begin test: Bring resources online =#=#=#=
Current cluster status:
Online: [ node1 ]
dummy (ocf::pacemaker:Dummy): Stopped
Fence (stonith:fence_true): Stopped
Transition Summary:
* Start dummy ( node1 )
* Start Fence ( node1 )
Executing cluster transition:
* Resource action: dummy monitor on node1
* Resource action: Fence monitor on node1
* Resource action: dummy start on node1
* Resource action: Fence start on node1
Revised cluster status:
Online: [ node1 ]
dummy (ocf::pacemaker:Dummy): Started node1
Fence (stonith:fence_true): Started node1
=#=#=#= Current cib after: Bring resources online =#=#=#=
=#=#=#= End test: Bring resources online - OK (0) =#=#=#=
* Passed: crm_simulate - Bring resources online
=#=#=#= Begin test: Try to move a resource to its existing location =#=#=#=
-Error performing operation: Situation already as requested
+Error performing operation: Already in requested state
=#=#=#= Current cib after: Try to move a resource to its existing location =#=#=#=
=#=#=#= End test: Try to move a resource to its existing location - Requested item already exists (108) =#=#=#=
* Passed: crm_resource - Try to move a resource to its existing location
=#=#=#= Begin test: Move a resource from its existing location =#=#=#=
WARNING: Creating rsc_location constraint 'cli-ban-dummy-on-node1' with a score of -INFINITY for resource dummy on node1.
This will prevent dummy from running on node1 until the constraint is removed using the clear option or by editing the CIB with an appropriate tool
This will be the case even if node1 is the last node in the cluster
=#=#=#= Current cib after: Move a resource from its existing location =#=#=#=
=#=#=#= End test: Move a resource from its existing location - OK (0) =#=#=#=
* Passed: crm_resource - Move a resource from its existing location
=#=#=#= Begin test: Clear out constraints generated by --move =#=#=#=
Removing constraint: cli-ban-dummy-on-node1
=#=#=#= Current cib after: Clear out constraints generated by --move =#=#=#=
=#=#=#= End test: Clear out constraints generated by --move - OK (0) =#=#=#=
* Passed: crm_resource - Clear out constraints generated by --move
=#=#=#= Begin test: Default ticket granted state =#=#=#=
false
=#=#=#= Current cib after: Default ticket granted state =#=#=#=
=#=#=#= End test: Default ticket granted state - OK (0) =#=#=#=
* Passed: crm_ticket - Default ticket granted state
=#=#=#= Begin test: Set ticket granted state =#=#=#=
=#=#=#= Current cib after: Set ticket granted state =#=#=#=
=#=#=#= End test: Set ticket granted state - OK (0) =#=#=#=
* Passed: crm_ticket - Set ticket granted state
=#=#=#= Begin test: Query ticket granted state =#=#=#=
false
=#=#=#= Current cib after: Query ticket granted state =#=#=#=
=#=#=#= End test: Query ticket granted state - OK (0) =#=#=#=
* Passed: crm_ticket - Query ticket granted state
=#=#=#= Begin test: Delete ticket granted state =#=#=#=
=#=#=#= Current cib after: Delete ticket granted state =#=#=#=
=#=#=#= End test: Delete ticket granted state - OK (0) =#=#=#=
* Passed: crm_ticket - Delete ticket granted state
=#=#=#= Begin test: Make a ticket standby =#=#=#=
=#=#=#= Current cib after: Make a ticket standby =#=#=#=
=#=#=#= End test: Make a ticket standby - OK (0) =#=#=#=
* Passed: crm_ticket - Make a ticket standby
=#=#=#= Begin test: Query ticket standby state =#=#=#=
true
=#=#=#= Current cib after: Query ticket standby state =#=#=#=
=#=#=#= End test: Query ticket standby state - OK (0) =#=#=#=
* Passed: crm_ticket - Query ticket standby state
=#=#=#= Begin test: Activate a ticket =#=#=#=
=#=#=#= Current cib after: Activate a ticket =#=#=#=
=#=#=#= End test: Activate a ticket - OK (0) =#=#=#=
* Passed: crm_ticket - Activate a ticket
=#=#=#= Begin test: Delete ticket standby state =#=#=#=
=#=#=#= Current cib after: Delete ticket standby state =#=#=#=
=#=#=#= End test: Delete ticket standby state - OK (0) =#=#=#=
* Passed: crm_ticket - Delete ticket standby state
=#=#=#= Begin test: Ban a resource on unknown node =#=#=#=
Error performing operation: Node not found
=#=#=#= Current cib after: Ban a resource on unknown node =#=#=#=
=#=#=#= End test: Ban a resource on unknown node - No such object (105) =#=#=#=
* Passed: crm_resource - Ban a resource on unknown node
=#=#=#= Begin test: Create two more nodes and bring them online =#=#=#=
Current cluster status:
Online: [ node1 ]
dummy (ocf::pacemaker:Dummy): Started node1
Fence (stonith:fence_true): Started node1
Performing requested modifications
+ Bringing node node2 online
+ Bringing node node3 online
Transition Summary:
* Move Fence ( node1 -> node2 )
Executing cluster transition:
* Resource action: dummy monitor on node3
* Resource action: dummy monitor on node2
* Resource action: Fence stop on node1
* Resource action: Fence monitor on node3
* Resource action: Fence monitor on node2
* Resource action: Fence start on node2
Revised cluster status:
Online: [ node1 node2 node3 ]
dummy (ocf::pacemaker:Dummy): Started node1
Fence (stonith:fence_true): Started node2
=#=#=#= Current cib after: Create two more nodes and bring them online =#=#=#=
=#=#=#= End test: Create two more nodes and bring them online - OK (0) =#=#=#=
* Passed: crm_simulate - Create two more nodes and bring them online
=#=#=#= Begin test: Ban dummy from node1 =#=#=#=
WARNING: Creating rsc_location constraint 'cli-ban-dummy-on-node1' with a score of -INFINITY for resource dummy on node1.
This will prevent dummy from running on node1 until the constraint is removed using the clear option or by editing the CIB with an appropriate tool
This will be the case even if node1 is the last node in the cluster
=#=#=#= Current cib after: Ban dummy from node1 =#=#=#=
=#=#=#= End test: Ban dummy from node1 - OK (0) =#=#=#=
* Passed: crm_resource - Ban dummy from node1
=#=#=#= Begin test: Show where a resource is running =#=#=#=
resource dummy is running on: node1
=#=#=#= End test: Show where a resource is running - OK (0) =#=#=#=
* Passed: crm_resource - Show where a resource is running
=#=#=#= Begin test: Show constraints on a resource =#=#=#=
* dummy
: Node node1 (score=-INFINITY, id=cli-ban-dummy-on-node1)
=#=#=#= End test: Show constraints on a resource - OK (0) =#=#=#=
* Passed: crm_resource - Show constraints on a resource
=#=#=#= Begin test: Ban dummy from node2 =#=#=#=
WARNING: Creating rsc_location constraint 'cli-ban-dummy-on-node2' with a score of -INFINITY for resource dummy on node2.
This will prevent dummy from running on node2 until the constraint is removed using the clear option or by editing the CIB with an appropriate tool
This will be the case even if node2 is the last node in the cluster
=#=#=#= Current cib after: Ban dummy from node2 =#=#=#=
=#=#=#= End test: Ban dummy from node2 - OK (0) =#=#=#=
* Passed: crm_resource - Ban dummy from node2
=#=#=#= Begin test: Relocate resources due to ban =#=#=#=
Current cluster status:
Online: [ node1 node2 node3 ]
dummy (ocf::pacemaker:Dummy): Started node1
Fence (stonith:fence_true): Started node2
Transition Summary:
* Move dummy ( node1 -> node3 )
Executing cluster transition:
* Resource action: dummy stop on node1
* Resource action: dummy start on node3
Revised cluster status:
Online: [ node1 node2 node3 ]
dummy (ocf::pacemaker:Dummy): Started node3
Fence (stonith:fence_true): Started node2
=#=#=#= Current cib after: Relocate resources due to ban =#=#=#=
=#=#=#= End test: Relocate resources due to ban - OK (0) =#=#=#=
* Passed: crm_simulate - Relocate resources due to ban
=#=#=#= Begin test: Move dummy to node1 =#=#=#=
=#=#=#= Current cib after: Move dummy to node1 =#=#=#=
=#=#=#= End test: Move dummy to node1 - OK (0) =#=#=#=
* Passed: crm_resource - Move dummy to node1
=#=#=#= Begin test: Clear implicit constraints for dummy on node2 =#=#=#=
Removing constraint: cli-ban-dummy-on-node2
=#=#=#= Current cib after: Clear implicit constraints for dummy on node2 =#=#=#=
=#=#=#= End test: Clear implicit constraints for dummy on node2 - OK (0) =#=#=#=
* Passed: crm_resource - Clear implicit constraints for dummy on node2
=#=#=#= Begin test: Drop the status section =#=#=#=
=#=#=#= End test: Drop the status section - OK (0) =#=#=#=
* Passed: cibadmin - Drop the status section
=#=#=#= Begin test: Create a clone =#=#=#=
=#=#=#= End test: Create a clone - OK (0) =#=#=#=
* Passed: cibadmin - Create a clone
=#=#=#= Begin test: Create a resource meta attribute =#=#=#=
Performing update of 'is-managed' on 'test-clone', the parent of 'test-primitive'
Set 'test-clone' option: id=test-clone-meta_attributes-is-managed set=test-clone-meta_attributes name=is-managed value=false
=#=#=#= Current cib after: Create a resource meta attribute =#=#=#=
=#=#=#= End test: Create a resource meta attribute - OK (0) =#=#=#=
* Passed: crm_resource - Create a resource meta attribute
=#=#=#= Begin test: Create a resource meta attribute in the primitive =#=#=#=
Set 'test-primitive' option: id=test-primitive-meta_attributes-is-managed set=test-primitive-meta_attributes name=is-managed value=false
=#=#=#= Current cib after: Create a resource meta attribute in the primitive =#=#=#=
=#=#=#= End test: Create a resource meta attribute in the primitive - OK (0) =#=#=#=
* Passed: crm_resource - Create a resource meta attribute in the primitive
=#=#=#= Begin test: Update resource meta attribute with duplicates =#=#=#=
Multiple attributes match name=is-managed
Value: false (id=test-primitive-meta_attributes-is-managed)
Value: false (id=test-clone-meta_attributes-is-managed)
A value for 'is-managed' already exists in child 'test-primitive', performing update on that instead of 'test-clone'
Set 'test-primitive' option: id=test-primitive-meta_attributes-is-managed name=is-managed value=true
=#=#=#= Current cib after: Update resource meta attribute with duplicates =#=#=#=
=#=#=#= End test: Update resource meta attribute with duplicates - OK (0) =#=#=#=
* Passed: crm_resource - Update resource meta attribute with duplicates
=#=#=#= Begin test: Update resource meta attribute with duplicates (force clone) =#=#=#=
Set 'test-clone' option: id=test-clone-meta_attributes-is-managed name=is-managed value=true
=#=#=#= Current cib after: Update resource meta attribute with duplicates (force clone) =#=#=#=
=#=#=#= End test: Update resource meta attribute with duplicates (force clone) - OK (0) =#=#=#=
* Passed: crm_resource - Update resource meta attribute with duplicates (force clone)
=#=#=#= Begin test: Update child resource meta attribute with duplicates =#=#=#=
Multiple attributes match name=is-managed
Value: true (id=test-primitive-meta_attributes-is-managed)
Value: true (id=test-clone-meta_attributes-is-managed)
Set 'test-primitive' option: id=test-primitive-meta_attributes-is-managed name=is-managed value=false
=#=#=#= Current cib after: Update child resource meta attribute with duplicates =#=#=#=
=#=#=#= End test: Update child resource meta attribute with duplicates - OK (0) =#=#=#=
* Passed: crm_resource - Update child resource meta attribute with duplicates
=#=#=#= Begin test: Delete resource meta attribute with duplicates =#=#=#=
Multiple attributes match name=is-managed
Value: false (id=test-primitive-meta_attributes-is-managed)
Value: true (id=test-clone-meta_attributes-is-managed)
A value for 'is-managed' already exists in child 'test-primitive', performing delete on that instead of 'test-clone'
Deleted 'test-primitive' option: id=test-primitive-meta_attributes-is-managed name=is-managed
=#=#=#= Current cib after: Delete resource meta attribute with duplicates =#=#=#=
=#=#=#= End test: Delete resource meta attribute with duplicates - OK (0) =#=#=#=
* Passed: crm_resource - Delete resource meta attribute with duplicates
=#=#=#= Begin test: Delete resource meta attribute in parent =#=#=#=
Performing delete of 'is-managed' on 'test-clone', the parent of 'test-primitive'
Deleted 'test-clone' option: id=test-clone-meta_attributes-is-managed name=is-managed
=#=#=#= Current cib after: Delete resource meta attribute in parent =#=#=#=
=#=#=#= End test: Delete resource meta attribute in parent - OK (0) =#=#=#=
* Passed: crm_resource - Delete resource meta attribute in parent
=#=#=#= Begin test: Create a resource meta attribute in the primitive =#=#=#=
Set 'test-primitive' option: id=test-primitive-meta_attributes-is-managed set=test-primitive-meta_attributes name=is-managed value=false
=#=#=#= Current cib after: Create a resource meta attribute in the primitive =#=#=#=
=#=#=#= End test: Create a resource meta attribute in the primitive - OK (0) =#=#=#=
* Passed: crm_resource - Create a resource meta attribute in the primitive
=#=#=#= Begin test: Update existing resource meta attribute =#=#=#=
A value for 'is-managed' already exists in child 'test-primitive', performing update on that instead of 'test-clone'
Set 'test-primitive' option: id=test-primitive-meta_attributes-is-managed name=is-managed value=true
=#=#=#= Current cib after: Update existing resource meta attribute =#=#=#=
=#=#=#= End test: Update existing resource meta attribute - OK (0) =#=#=#=
* Passed: crm_resource - Update existing resource meta attribute
=#=#=#= Begin test: Create a resource meta attribute in the parent =#=#=#=
Set 'test-clone' option: id=test-clone-meta_attributes-is-managed set=test-clone-meta_attributes name=is-managed value=true
=#=#=#= Current cib after: Create a resource meta attribute in the parent =#=#=#=
=#=#=#= End test: Create a resource meta attribute in the parent - OK (0) =#=#=#=
* Passed: crm_resource - Create a resource meta attribute in the parent
=#=#=#= Begin test: Copy resources =#=#=#=
=#=#=#= End test: Copy resources - OK (0) =#=#=#=
* Passed: cibadmin - Copy resources
=#=#=#= Begin test: Delete resource parent meta attribute (force) =#=#=#=
Deleted 'test-clone' option: id=test-clone-meta_attributes-is-managed name=is-managed
=#=#=#= Current cib after: Delete resource parent meta attribute (force) =#=#=#=
=#=#=#= End test: Delete resource parent meta attribute (force) - OK (0) =#=#=#=
* Passed: crm_resource - Delete resource parent meta attribute (force)
=#=#=#= Begin test: Restore duplicates =#=#=#=
=#=#=#= Current cib after: Restore duplicates =#=#=#=
=#=#=#= End test: Restore duplicates - OK (0) =#=#=#=
* Passed: cibadmin - Restore duplicates
=#=#=#= Begin test: Delete resource child meta attribute =#=#=#=
Multiple attributes match name=is-managed
Value: true (id=test-primitive-meta_attributes-is-managed)
Value: true (id=test-clone-meta_attributes-is-managed)
Deleted 'test-primitive' option: id=test-primitive-meta_attributes-is-managed name=is-managed
=#=#=#= Current cib after: Delete resource child meta attribute =#=#=#=
=#=#=#= End test: Delete resource child meta attribute - OK (0) =#=#=#=
* Passed: crm_resource - Delete resource child meta attribute
=#=#=#= Begin test: Create a resource meta attribute in dummy1 =#=#=#=
Set 'dummy1' option: id=dummy1-meta_attributes-is-managed set=dummy1-meta_attributes name=is-managed value=true
=#=#=#= Current cib after: Create a resource meta attribute in dummy1 =#=#=#=
=#=#=#= End test: Create a resource meta attribute in dummy1 - OK (0) =#=#=#=
* Passed: crm_resource - Create a resource meta attribute in dummy1
=#=#=#= Begin test: Create a resource meta attribute in dummy-group =#=#=#=
Set 'dummy1' option: id=dummy1-meta_attributes-is-managed name=is-managed value=false
Set 'dummy-group' option: id=dummy-group-meta_attributes-is-managed set=dummy-group-meta_attributes name=is-managed value=false
=#=#=#= Current cib after: Create a resource meta attribute in dummy-group =#=#=#=
=#=#=#= End test: Create a resource meta attribute in dummy-group - OK (0) =#=#=#=
* Passed: crm_resource - Create a resource meta attribute in dummy-group
=#=#=#= Begin test: Specify a lifetime when moving a resource =#=#=#=
Migration will take effect until:
=#=#=#= Current cib after: Specify a lifetime when moving a resource =#=#=#=
=#=#=#= End test: Specify a lifetime when moving a resource - OK (0) =#=#=#=
* Passed: crm_resource - Specify a lifetime when moving a resource
=#=#=#= Begin test: Try to move a resource previously moved with a lifetime =#=#=#=
=#=#=#= Current cib after: Try to move a resource previously moved with a lifetime =#=#=#=
=#=#=#= End test: Try to move a resource previously moved with a lifetime - OK (0) =#=#=#=
* Passed: crm_resource - Try to move a resource previously moved with a lifetime
=#=#=#= Begin test: Ban dummy from node1 for a short time =#=#=#=
WARNING: Creating rsc_location constraint 'cli-ban-dummy-on-node1' with a score of -INFINITY for resource dummy on node1.
This will prevent dummy from running on node1 until the constraint is removed using the clear option or by editing the CIB with an appropriate tool
This will be the case even if node1 is the last node in the cluster
Migration will take effect until:
=#=#=#= Current cib after: Ban dummy from node1 for a short time =#=#=#=
=#=#=#= End test: Ban dummy from node1 for a short time - OK (0) =#=#=#=
* Passed: crm_resource - Ban dummy from node1 for a short time
=#=#=#= Begin test: Remove expired constraints =#=#=#=
Removing constraint: cli-ban-dummy-on-node1
=#=#=#= Current cib after: Remove expired constraints =#=#=#=
=#=#=#= End test: Remove expired constraints - OK (0) =#=#=#=
* Passed: crm_resource - Remove expired constraints
=#=#=#= Begin test: Clear all implicit constraints for dummy =#=#=#=
Removing constraint: cli-prefer-dummy
=#=#=#= Current cib after: Clear all implicit constraints for dummy =#=#=#=
=#=#=#= End test: Clear all implicit constraints for dummy - OK (0) =#=#=#=
* Passed: crm_resource - Clear all implicit constraints for dummy
=#=#=#= Begin test: Delete a resource =#=#=#=
=#=#=#= Current cib after: Delete a resource =#=#=#=
=#=#=#= End test: Delete a resource - OK (0) =#=#=#=
* Passed: crm_resource - Delete a resource
=#=#=#= Begin test: Create an XML patchset =#=#=#=
=#=#=#= End test: Create an XML patchset - Error occurred (1) =#=#=#=
* Passed: crm_diff - Create an XML patchset
diff --git a/tools/Makefile.am b/tools/Makefile.am
index 4609b0f581..0f1abdab9b 100644
--- a/tools/Makefile.am
+++ b/tools/Makefile.am
@@ -1,167 +1,168 @@
#
# Copyright 2004-2019 the Pacemaker project contributors
#
# The version control history for this file may have further details.
#
# This source code is licensed under the GNU General Public License version 2
# or later (GPLv2+) WITHOUT ANY WARRANTY.
#
include $(top_srcdir)/mk/common.mk
if BUILD_SYSTEMD
systemdsystemunit_DATA = crm_mon.service
endif
noinst_HEADERS = crm_mon.h crm_resource.h
pcmkdir = $(datadir)/$(PACKAGE)
pcmk_DATA = report.common report.collector
sbin_SCRIPTS = crm_report crm_standby crm_master crm_failcount
if BUILD_CIBSECRETS
sbin_SCRIPTS += cibsecret
endif
noinst_SCRIPTS = pcmk_simtimes
EXTRA_DIST = crm_diff.8.inc \
crm_error.8.inc \
crm_mon.sysconfig \
crm_mon.8.inc \
crm_node.8.inc \
+ crm_resource.8.inc \
crm_rule.8.inc \
crm_simulate.8.inc \
fix-manpages \
stonith_admin.8.inc
sbin_PROGRAMS = attrd_updater \
cibadmin \
crmadmin \
crm_simulate \
crm_attribute \
crm_diff \
crm_error \
crm_mon \
crm_node \
crm_resource \
crm_rule \
crm_shadow \
crm_verify \
crm_ticket \
iso8601 \
stonith_admin
if BUILD_SERVICELOG
sbin_PROGRAMS += notifyServicelogEvent
endif
if BUILD_OPENIPMI_SERVICELOG
sbin_PROGRAMS += ipmiservicelogd
endif
## SOURCES
# A few tools are just thin wrappers around crm_attribute.
# This makes their help get updated when crm_attribute changes
# (see mk/common.mk).
MAN8DEPS = crm_attribute
crmadmin_SOURCES = crmadmin.c
crmadmin_LDADD = $(top_builddir)/lib/pengine/libpe_status.la \
$(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
crm_error_SOURCES = crm_error.c
crm_error_LDADD = $(top_builddir)/lib/common/libcrmcommon.la
cibadmin_SOURCES = cibadmin.c
cibadmin_LDADD = $(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
crm_shadow_SOURCES = crm_shadow.c
crm_shadow_LDADD = $(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
crm_node_SOURCES = crm_node.c
crm_node_LDADD = $(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
crm_simulate_SOURCES = crm_simulate.c
crm_simulate_LDADD = $(top_builddir)/lib/pengine/libpe_status.la \
$(top_builddir)/lib/pacemaker/libpacemaker.la \
$(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
crm_diff_SOURCES = crm_diff.c
crm_diff_LDADD = $(top_builddir)/lib/common/libcrmcommon.la
crm_mon_SOURCES = crm_mon.c crm_mon_curses.c crm_mon_print.c crm_mon_runtime.c crm_mon_xml.c
crm_mon_LDADD = $(top_builddir)/lib/pengine/libpe_status.la \
$(top_builddir)/lib/fencing/libstonithd.la \
$(top_builddir)/lib/pacemaker/libpacemaker.la \
$(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la \
$(CURSESLIBS)
crm_verify_SOURCES = crm_verify.c
crm_verify_LDADD = $(top_builddir)/lib/pengine/libpe_status.la \
$(top_builddir)/lib/pacemaker/libpacemaker.la \
$(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
crm_attribute_SOURCES = crm_attribute.c
crm_attribute_LDADD = $(top_builddir)/lib/cluster/libcrmcluster.la \
$(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
crm_resource_SOURCES = crm_resource.c \
crm_resource_ban.c \
crm_resource_print.c \
crm_resource_runtime.c
crm_resource_LDADD = $(top_builddir)/lib/pengine/libpe_rules.la \
$(top_builddir)/lib/fencing/libstonithd.la \
$(top_builddir)/lib/lrmd/liblrmd.la \
$(top_builddir)/lib/services/libcrmservice.la \
$(top_builddir)/lib/pengine/libpe_status.la \
$(top_builddir)/lib/pacemaker/libpacemaker.la \
$(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
crm_rule_SOURCES = crm_rule.c
crm_rule_LDADD = $(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/pengine/libpe_rules.la \
$(top_builddir)/lib/pengine/libpe_status.la \
$(top_builddir)/lib/common/libcrmcommon.la
iso8601_SOURCES = iso8601.c
iso8601_LDADD = $(top_builddir)/lib/common/libcrmcommon.la
attrd_updater_SOURCES = attrd_updater.c
attrd_updater_LDADD = $(top_builddir)/lib/common/libcrmcommon.la
crm_ticket_SOURCES = crm_ticket.c
crm_ticket_LDADD = $(top_builddir)/lib/pengine/libpe_rules.la \
$(top_builddir)/lib/pengine/libpe_status.la \
$(top_builddir)/lib/pacemaker/libpacemaker.la \
$(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/common/libcrmcommon.la
stonith_admin_SOURCES = stonith_admin.c
stonith_admin_LDADD = $(top_builddir)/lib/pacemaker/libpacemaker.la \
$(top_builddir)/lib/cib/libcib.la \
$(top_builddir)/lib/pengine/libpe_status.la \
$(top_builddir)/lib/fencing/libstonithd.la \
$(top_builddir)/lib/common/libcrmcommon.la
if BUILD_SERVICELOG
notifyServicelogEvent_SOURCES = notifyServicelogEvent.c
notifyServicelogEvent_CFLAGS = $(SERVICELOG_CFLAGS)
notifyServicelogEvent_LDADD = $(top_builddir)/lib/common/libcrmcommon.la $(SERVICELOG_LIBS)
endif
if BUILD_OPENIPMI_SERVICELOG
ipmiservicelogd_SOURCES = ipmiservicelogd.c
ipmiservicelogd_CFLAGS = $(OPENIPMI_SERVICELOG_CFLAGS) $(SERVICELOG_CFLAGS)
ipmiservicelogd_LDFLAGS = $(top_builddir)/lib/common/libcrmcommon.la $(OPENIPMI_SERVICELOG_LIBS) $(SERVICELOG_LIBS)
endif
CLEANFILES = $(man8_MANS)
diff --git a/tools/crm_resource.8.inc b/tools/crm_resource.8.inc
new file mode 100644
index 0000000000..a92fac6261
--- /dev/null
+++ b/tools/crm_resource.8.inc
@@ -0,0 +1,5 @@
+[synopsis]
+crm_resource | [options]
+
+/Pacemaker cluster resources/
+.SH OPTIONS
diff --git a/tools/crm_resource.c b/tools/crm_resource.c
index a573d96411..2281b745e4 100644
--- a/tools/crm_resource.c
+++ b/tools/crm_resource.c
@@ -1,1579 +1,1773 @@
/*
* Copyright 2004-2020 the Pacemaker project contributors
*
* The version control history for this file may have further details.
*
* This source code is licensed under the GNU General Public License version 2
* or later (GPLv2+) WITHOUT ANY WARRANTY.
*/
#include
+#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
+#define SUMMARY "crm_resource - perform tasks related to Pacemaker cluster resources"
+
+struct {
+ const char *attr_set_type;
+ int cib_options;
+ gboolean clear_expired;
+ char *extra_arg;
+ char *extra_option;
+ int find_flags; /* Flags to use when searching for resource */
+ gboolean force;
+ char *host_uname;
+ char *interval_spec;
+ char *operation;
+ GHashTable *override_params;
+ char *prop_id;
+ char *prop_name;
+ char *prop_set;
+ char *prop_value;
+ gboolean recursive;
+ gchar **remainder;
+ gboolean require_crmd; /* whether command requires controller connection */
+ gboolean require_dataset; /* whether command requires populated dataset instance */
+ gboolean require_resource; /* whether command requires that resource be specified */
+ int resource_verbose;
+ char rsc_cmd;
+ char *rsc_id;
+ char *rsc_long_cmd;
+ char *rsc_type;
+ gboolean promoted_role_only;
+ int timeout_ms;
+ char *v_agent;
+ char *v_class;
+ char *v_provider;
+ gboolean validate_cmdline; /* whether we are just validating based on command line options */
+ GHashTable *validate_options;
+ char *xml_file;
+} options = {
+ .attr_set_type = XML_TAG_ATTR_SETS,
+ .cib_options = cib_sync_call,
+ .require_dataset = TRUE,
+ .require_resource = TRUE,
+ .rsc_cmd = 'L'
+};
+
+gboolean agent_provider_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean attr_set_type_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean class_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean cleanup_refresh_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean delete_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean expired_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean extra_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean fail_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean flag_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean get_param_prop_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean list_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean set_delete_param_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean set_prop_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean timeout_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean validate_restart_force_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean wait_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+gboolean why_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error);
+
bool BE_QUIET = FALSE;
-bool scope_master = FALSE;
-int cib_options = cib_sync_call;
static crm_exit_t exit_code = CRM_EX_OK;
// Things that should be cleaned up on exit
+static GError *error = NULL;
static GMainLoop *mainloop = NULL;
static cib_t *cib_conn = NULL;
static pcmk_ipc_api_t *controld_api = NULL;
static pe_working_set_t *data_set = NULL;
#define MESSAGE_TIMEOUT_S 60
+#define INDENT " "
+
// Clean up and exit
static crm_exit_t
bye(crm_exit_t ec)
{
+ if (error != NULL) {
+ fprintf(stderr, "%s\n", error->message);
+ g_clear_error(&error);
+ }
+
if (cib_conn != NULL) {
cib_t *save_cib_conn = cib_conn;
cib_conn = NULL; // Ensure we can't free this twice
save_cib_conn->cmds->signoff(save_cib_conn);
cib_delete(save_cib_conn);
}
if (controld_api != NULL) {
pcmk_ipc_api_t *save_controld_api = controld_api;
controld_api = NULL; // Ensure we can't free this twice
pcmk_free_ipc_api(save_controld_api);
}
if (mainloop != NULL) {
g_main_loop_unref(mainloop);
mainloop = NULL;
}
pe_free_working_set(data_set);
data_set = NULL;
crm_exit(ec);
return ec;
}
static void
quit_main_loop(crm_exit_t ec)
{
exit_code = ec;
if (mainloop != NULL) {
GMainLoop *mloop = mainloop;
mainloop = NULL; // Don't re-enter this block
pcmk_quit_main_loop(mloop, 10);
g_main_loop_unref(mloop);
}
}
static gboolean
resource_ipc_timeout(gpointer data)
{
// Start with newline because "Waiting for ..." message doesn't have one
- fprintf(stderr, "\nAborting because no messages received in %d seconds\n",
- MESSAGE_TIMEOUT_S);
- crm_err("No messages received in %d seconds", MESSAGE_TIMEOUT_S);
+ if (error != NULL) {
+ g_clear_error(&error);
+ }
+
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_TIMEOUT,
+ "\nAborting because no messages received in %d seconds", MESSAGE_TIMEOUT_S);
+
quit_main_loop(CRM_EX_TIMEOUT);
return FALSE;
}
static void
controller_event_callback(pcmk_ipc_api_t *api, enum pcmk_ipc_event event_type,
crm_exit_t status, void *event_data, void *user_data)
{
switch (event_type) {
case pcmk_ipc_event_disconnect:
if (exit_code == CRM_EX_DISCONNECT) { // Unexpected
crm_info("Connection to controller was terminated");
}
quit_main_loop(exit_code);
break;
case pcmk_ipc_event_reply:
if (status != CRM_EX_OK) {
fprintf(stderr, "\nError: bad reply from controller: %s\n",
crm_exit_str(status));
pcmk_disconnect_ipc(api);
quit_main_loop(status);
} else {
fprintf(stderr, ".");
if ((pcmk_controld_api_replies_expected(api) == 0)
&& mainloop && g_main_loop_is_running(mainloop)) {
fprintf(stderr, " OK\n");
crm_debug("Got all the replies we expected");
pcmk_disconnect_ipc(api);
quit_main_loop(CRM_EX_OK);
}
}
break;
default:
break;
}
}
static void
start_mainloop(pcmk_ipc_api_t *capi)
{
unsigned int count = pcmk_controld_api_replies_expected(capi);
if (count > 0) {
fprintf(stderr, "Waiting for %d %s from the controller",
count, pcmk__plural_alt(count, "reply", "replies"));
exit_code = CRM_EX_DISCONNECT; // For unexpected disconnects
mainloop = g_main_loop_new(NULL, FALSE);
g_timeout_add(MESSAGE_TIMEOUT_S * 1000, resource_ipc_timeout, NULL);
g_main_loop_run(mainloop);
}
}
static int
compare_id(gconstpointer a, gconstpointer b)
{
return strcmp((const char *)a, (const char *)b);
}
static GListPtr
build_constraint_list(xmlNode *root)
{
GListPtr retval = NULL;
xmlNode *cib_constraints = NULL;
xmlXPathObjectPtr xpathObj = NULL;
int ndx = 0;
cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, root);
xpathObj = xpath_search(cib_constraints, "//" XML_CONS_TAG_RSC_LOCATION);
for (ndx = 0; ndx < numXpathResults(xpathObj); ndx++) {
xmlNode *match = getXpathResult(xpathObj, ndx);
retval = g_list_insert_sorted(retval, (gpointer) ID(match), compare_id);
}
freeXpathObject(xpathObj);
return retval;
}
/* short option letters still available: eEJkKXyYZ */
-static pcmk__cli_option_t long_options[] = {
- // long option, argument type, storage, short option, description, flags
- {
- "help", no_argument, NULL, '?',
- "\t\tDisplay this text and exit", pcmk__option_default
- },
- {
- "version", no_argument, NULL, '$',
- "\t\tDisplay version information and exit", pcmk__option_default
- },
- {
- "verbose", no_argument, NULL, 'V',
- "\t\tIncrease debug output (may be specified multiple times)",
- pcmk__option_default
- },
- {
- "quiet", no_argument, NULL, 'Q',
- "\t\tBe less descriptive in results", pcmk__option_default
- },
- {
- "resource", required_argument, NULL, 'r',
- "\tResource ID", pcmk__option_default
- },
- {
- "-spacer-", no_argument, NULL, '-',
- "\nQueries:", pcmk__option_default
- },
- {
- "list", no_argument, NULL, 'L',
- "\t\tList all cluster resources with status", pcmk__option_default
- },
- {
- "list-raw", no_argument, NULL, 'l',
- "\t\tList IDs of all instantiated resources (individual members rather "
- "than groups etc.)",
- pcmk__option_default
- },
- {
- "list-cts", no_argument, NULL, 'c',
- NULL, pcmk__option_hidden
- },
- {
- "list-operations", no_argument, NULL, 'O',
- "\tList active resource operations, optionally filtered by --resource "
- "and/or --node",
- pcmk__option_default
- },
- {
- "list-all-operations", no_argument, NULL, 'o',
- "List all resource operations, optionally filtered by --resource "
- "and/or --node",
- pcmk__option_default
- },
- {
- "list-standards", no_argument, NULL, 0,
- "\tList supported standards", pcmk__option_default
- },
- {
- "list-ocf-providers", no_argument, NULL, 0,
- "List all available OCF providers", pcmk__option_default
- },
- {
- "list-agents", required_argument, NULL, 0,
- "List all agents available for the named standard and/or provider",
- pcmk__option_default
- },
- {
- "list-ocf-alternatives", required_argument, NULL, 0,
- "List all available providers for the named OCF agent",
- pcmk__option_default
- },
- {
- "show-metadata", required_argument, NULL, 0,
- "Show the metadata for the named class:provider:agent",
- pcmk__option_default
- },
- {
- "query-xml", no_argument, NULL, 'q',
- "\tShow XML configuration of resource (after any template expansion)",
- pcmk__option_default
- },
- {
- "query-xml-raw", no_argument, NULL, 'w',
- "\tShow XML configuration of resource (before any template expansion)",
- pcmk__option_default
- },
- {
- "get-parameter", required_argument, NULL, 'g',
- "Display named parameter for resource (use instance attribute unless "
- "--meta or --utilization is specified)",
- pcmk__option_default
- },
- {
- "get-property", required_argument, NULL, 'G',
- "Display named property of resource ('class', 'type', or 'provider') "
- "(requires --resource)",
- pcmk__option_hidden
- },
- {
- "locate", no_argument, NULL, 'W',
- "\t\tShow node(s) currently running resource",
- pcmk__option_default
- },
- {
- "stack", no_argument, NULL, 'A',
- "\t\tDisplay the prerequisites and dependents of a resource",
- pcmk__option_default
- },
- {
- "constraints", no_argument, NULL, 'a',
- "\tDisplay the (co)location constraints that apply to a resource",
- pcmk__option_default
- },
- {
- "why", no_argument, NULL, 'Y',
- "\t\tShow why resources are not running, optionally filtered by "
- "--resource and/or --node",
- pcmk__option_default
- },
- {
- "-spacer-", no_argument, NULL, '-',
- "\nCommands:", pcmk__option_default
- },
- {
- "validate", no_argument, NULL, 0,
- "\t\tValidate resource configuration by calling agent's validate-all "
- "action. The configuration may be specified either by giving an "
- "existing resource name with -r, or by specifying --class, "
- "--agent, and --provider arguments, along with any number of "
- "--option arguments.",
- pcmk__option_default
- },
- {
- "cleanup", no_argument, NULL, 'C',
- "\t\tIf resource has any past failures, clear its history and "
- "fail count. Optionally filtered by --resource, --node, "
- "--operation, and --interval (otherwise all). --operation and "
- "--interval apply to fail counts, but entire history is always "
- "cleared, to allow current state to be rechecked. If the named "
- "resource is part of a group, or one numbered instance of a clone "
- "or bundled resource, the clean-up applies to the whole collective "
- "resource unless --force is given.",
- pcmk__option_default
- },
- {
- "refresh", no_argument, NULL, 'R',
- "\t\tDelete resource's history (including failures) so its current "
- "state is rechecked. Optionally filtered by --resource and --node "
- "(otherwise all). If the named resource is part of a group, or one "
- "numbered instance of a clone or bundled resource, the refresh "
- "applies to the whole collective resource unless --force is given.",
- pcmk__option_default
- },
- {
- "set-parameter", required_argument, NULL, 'p',
- "Set named parameter for resource (requires -v). Use instance "
- "attribute unless --meta or --utilization is specified.",
- pcmk__option_default
- },
- {
- "delete-parameter", required_argument, NULL, 'd',
- "Delete named parameter for resource. Use instance attribute unless "
- "--meta or --utilization is specified.",
- pcmk__option_default
- },
- {
- "set-property", required_argument, NULL, 'S',
- "Set named property of resource ('class', 'type', or 'provider') "
- "(requires -r, -t, -v)",
- pcmk__option_hidden
- },
- {
- "-spacer-", no_argument, NULL, '-',
- "\nResource location:", pcmk__option_default
- },
- {
- "move", no_argument, NULL, 'M',
- "\t\tCreate a constraint to move resource. If --node is specified, the "
- "constraint will be to move to that node, otherwise it will be to "
- "ban the current node. Unless --force is specified, this will "
- "return an error if the resource is already running on the "
- "specified node. If --force is specified, this will always ban the "
- "current node. Optional: --lifetime, --master. NOTE: This may "
- "prevent the resource from running on its previous location until "
- "the implicit constraint expires or is removed with --clear.",
- pcmk__option_default
- },
- {
- "ban", no_argument, NULL, 'B',
- "\t\tCreate a constraint to keep resource off a node. Optional: "
- "--node, --lifetime, --master. NOTE: This will prevent the "
- "resource from running on the affected node until the implicit "
- "constraint expires or is removed with --clear. If --node is not "
- "specified, it defaults to the node currently running the resource "
- "for primitives and groups, or the master for promotable clones "
- "with promoted-max=1 (all other situations result in an error as "
- "there is no sane default).",
- pcmk__option_default
- },
- {
- "clear", no_argument, NULL, 'U',
- "\t\tRemove all constraints created by the --ban and/or --move "
- "commands. Requires: --resource. Optional: --node, --master, "
- "--expired. If --node is not specified, all constraints created "
- "by --ban and --move will be removed for the named resource. If "
- "--node and --force are specified, any constraint created by "
- "--move will be cleared, even if it is not for the specified node. "
- "If --expired is specified, only those constraints whose lifetimes "
- "have expired will be removed.",
- pcmk__option_default
- },
- {
- "expired", no_argument, NULL, 'e',
- "\t\tModifies the --clear argument to remove constraints with "
- "expired lifetimes.",
- pcmk__option_default
- },
- {
- "lifetime", required_argument, NULL, 'u',
- "\tLifespan (as ISO 8601 duration) of created constraints (with -B, "
- "-M) (see https://en.wikipedia.org/wiki/ISO_8601#Durations)",
- pcmk__option_default
- },
- {
- "master", no_argument, NULL, 0,
- "\t\tLimit scope of command to Master role (with -B, -M, -U). For -B "
- "and -M, the previous master may remain active in the Slave role.",
- pcmk__option_default
- },
- {
- "-spacer-", no_argument, NULL, '-',
- "\nAdvanced Commands:", pcmk__option_default
- },
- {
- "delete", no_argument, NULL, 'D',
- "\t\t(Advanced) Delete a resource from the CIB. Required: -t",
- pcmk__option_default
- },
- {
- "fail", no_argument, NULL, 'F',
- "\t\t(Advanced) Tell the cluster this resource has failed",
- pcmk__option_default
- },
- {
- "restart", no_argument, NULL, 0,
- "\t\t(Advanced) Tell the cluster to restart this resource and "
- "anything that depends on it",
- pcmk__option_default
- },
- {
- "wait", no_argument, NULL, 0,
- "\t\t(Advanced) Wait until the cluster settles into a stable state",
- pcmk__option_default
- },
- {
- "force-demote", no_argument, NULL, 0,
- "\t(Advanced) Bypass the cluster and demote a resource on the local "
- "node. Unless --force is specified, this will refuse to do so if "
- "the cluster believes the resource is a clone instance already "
- "running on the local node.",
- pcmk__option_default
- },
- {
- "force-stop", no_argument, NULL, 0,
- "\t(Advanced) Bypass the cluster and stop a resource on the local node",
- pcmk__option_default
- },
- {
- "force-start", no_argument, NULL, 0,
- "\t(Advanced) Bypass the cluster and start a resource on the local "
- "node. Unless --force is specified, this will refuse to do so if "
- "the cluster believes the resource is a clone instance already "
- "running on the local node.",
- pcmk__option_default
- },
- {
- "force-promote", no_argument, NULL, 0,
- "\t(Advanced) Bypass the cluster and promote a resource on the local "
- "node. Unless --force is specified, this will refuse to do so if "
- "the cluster believes the resource is a clone instance already "
- "running on the local node.",
- pcmk__option_default
- },
- {
- "force-check", no_argument, NULL, 0,
- "\t(Advanced) Bypass the cluster and check the state of a resource on "
- "the local node",
- pcmk__option_default
- },
- {
- "-spacer-", no_argument, NULL, '-',
- "\nValidate Options:", pcmk__option_default
- },
- {
- "class", required_argument, NULL, 0,
- "\tThe standard the resource agent confirms to (for example, ocf). "
- "Use with --agent, --provider, --option, and --validate.",
- pcmk__option_default
- },
- {
- "agent", required_argument, NULL, 0,
- "\tThe agent to use (for example, IPaddr). Use with --class, "
- "--provider, --option, and --validate.",
- pcmk__option_default
- },
- {
- "provider", required_argument, NULL, 0,
- "\tThe vendor that supplies the resource agent (for example, "
- "heartbeat). Use with --class, --agent, --option, and --validate.",
- pcmk__option_default
- },
- {
- "option", required_argument, NULL, 0,
- "\tSpecify a device configuration parameter as NAME=VALUE (may be "
- "specified multiple times). Use with --validate and without the "
- "-r option.",
- pcmk__option_default
- },
- {
- "-spacer-", no_argument, NULL, '-',
- "\nAdditional Options:", pcmk__option_default
- },
- {
- "node", required_argument, NULL, 'N',
- "\tNode name", pcmk__option_default
- },
- {
- "recursive", no_argument, NULL, 0,
- "\tFollow colocation chains when using --set-parameter",
- pcmk__option_default
- },
- {
- "resource-type", required_argument, NULL, 't',
- "Resource XML element (primitive, group, etc.) (with -D)",
- pcmk__option_default
- },
- {
- "parameter-value", required_argument, NULL, 'v',
- "Value to use with -p", pcmk__option_default
- },
- {
- "meta", no_argument, NULL, 'm',
- "\t\tUse resource meta-attribute instead of instance attribute "
- "(with -p, -g, -d)",
- pcmk__option_default
- },
- {
- "utilization", no_argument, NULL, 'z',
- "\tUse resource utilization attribute instead of instance attribute "
- "(with -p, -g, -d)",
- pcmk__option_default
- },
- {
- "operation", required_argument, NULL, 'n',
- "\tOperation to clear instead of all (with -C -r)",
- pcmk__option_default
- },
- {
- "interval", required_argument, NULL, 'I',
- "\tInterval of operation to clear (default 0) (with -C -r -n)",
- pcmk__option_default
- },
- {
- "set-name", required_argument, NULL, 's',
- "\t(Advanced) XML ID of attributes element to use (with -p, -d)",
- pcmk__option_default
- },
- {
- "nvpair", required_argument, NULL, 'i',
- "\t(Advanced) XML ID of nvpair element to use (with -p, -d)",
- pcmk__option_default
- },
- {
- "timeout", required_argument, NULL, 'T',
- "\t(Advanced) Abort if command does not finish in this time (with "
- "--restart, --wait, --force-*)",
- pcmk__option_default
- },
- {
- "force", no_argument, NULL, 'f',
- "\t\tIf making CIB changes, do so regardless of quorum. See help for "
- "individual commands for additional behavior.",
- pcmk__option_default
- },
- {
- "xml-file", required_argument, NULL, 'x',
- NULL, pcmk__option_hidden
- },
-
- /* legacy options */
- {
- "host-uname", required_argument, NULL, 'H',
- NULL, pcmk__option_hidden
- },
-
- {
- "-spacer-", 1, NULL, '-',
- "\nExamples:", pcmk__option_paragraph
- },
- {
- "-spacer-", 1, NULL, '-',
- "List the available OCF agents:", pcmk__option_paragraph
- },
- {
- "-spacer-", 1, NULL, '-',
- " crm_resource --list-agents ocf", pcmk__option_example
- },
- {
- "-spacer-", 1, NULL, '-',
- "List the available OCF agents from the linux-ha project:",
- pcmk__option_paragraph
- },
- {
- "-spacer-", 1, NULL, '-',
- " crm_resource --list-agents ocf:heartbeat", pcmk__option_example
- },
- {
- "-spacer-", 1, NULL, '-',
- "Move 'myResource' to a specific node:", pcmk__option_paragraph
- },
- {
- "-spacer-", 1, NULL, '-',
- " crm_resource --resource myResource --move --node altNode",
- pcmk__option_example
- },
- {
- "-spacer-", 1, NULL, '-',
- "Allow (but not force) 'myResource' to move back to its original "
- "location:",
- pcmk__option_paragraph
- },
- {
- "-spacer-", 1, NULL, '-',
- " crm_resource --resource myResource --clear", pcmk__option_example
- },
- {
- "-spacer-", 1, NULL, '-',
- "Stop 'myResource' (and anything that depends on it):",
- pcmk__option_paragraph
- },
- {
- "-spacer-", 1, NULL, '-',
- " crm_resource --resource myResource --set-parameter target-role "
- "--meta --parameter-value Stopped",
- pcmk__option_example
- },
- {
- "-spacer-", 1, NULL, '-',
- "Tell the cluster not to manage 'myResource' (the cluster will not "
- "attempt to start or stop the resource under any circumstances; "
- "useful when performing maintenance tasks on a resource):",
- pcmk__option_paragraph
- },
- {
- "-spacer-", 1, NULL, '-',
- " crm_resource --resource myResource --set-parameter is-managed "
- "--meta --parameter-value false",
- pcmk__option_example
- },
- {
- "-spacer-", 1, NULL, '-',
- "Erase the operation history of 'myResource' on 'aNode' (the cluster "
- "will 'forget' the existing resource state, including any "
- "errors, and attempt to recover the resource; useful when a "
- "resource had failed permanently and has been repaired "
- "by an administrator):",
- pcmk__option_paragraph
- },
- {
- "-spacer-", 1, NULL, '-',
- " crm_resource --resource myResource --cleanup --node aNode",
- pcmk__option_example
- },
- { 0, 0, 0, 0 }
+static GOptionEntry query_entries[] = {
+ { "list", 'L', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, list_cb,
+ "List all cluster resources with status",
+ NULL },
+ { "list-raw", 'l', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, list_cb,
+ "List IDs of all instantiated resources (individual members\n"
+ INDENT "rather than groups etc.)",
+ NULL },
+ { "list-cts", 'c', G_OPTION_FLAG_HIDDEN|G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, list_cb,
+ NULL,
+ NULL },
+ { "list-operations", 'O', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, list_cb,
+ "List active resource operations, optionally filtered by\n"
+ INDENT "--resource and/or --node",
+ NULL },
+ { "list-all-operations", 'o', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, list_cb,
+ "List all resource operations, optionally filtered by\n"
+ INDENT "--resource and/or --node",
+ NULL },
+ { "list-standards", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, extra_cb,
+ "List supported standards",
+ NULL },
+ { "list-ocf-providers", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, extra_cb,
+ "List all available OCF providers",
+ NULL },
+ { "list-agents", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, extra_cb,
+ "List all agents available for the named standard and/or provider",
+ "STD/PROV" },
+ { "list-ocf-alternatives", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, extra_cb,
+ "List all available providers for the named OCF agent",
+ "AGENT" },
+ { "show-metadata", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, extra_cb,
+ "Show the metadata for the named class:provider:agent",
+ "SPEC" },
+ { "query-xml", 'q', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, flag_cb,
+ "Show XML configuration of resource (after any template expansion)",
+ NULL },
+ { "query-xml-raw", 'w', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, flag_cb,
+ "Show XML configuration of resource (before any template expansion)",
+ NULL },
+ { "get-parameter", 'g', G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, get_param_prop_cb,
+ "Display named parameter for resource (use instance attribute\n"
+ INDENT "unless --meta or --utilization is specified)",
+ "PARAM" },
+ { "get-property", 'G', G_OPTION_FLAG_HIDDEN, G_OPTION_ARG_CALLBACK, get_param_prop_cb,
+ "Display named property of resource ('class', 'type', or 'provider') "
+ "(requires --resource)",
+ "PROPERTY" },
+ { "locate", 'W', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, flag_cb,
+ "Show node(s) currently running resource",
+ NULL },
+ { "stack", 'A', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, flag_cb,
+ "Display the prerequisites and dependents of a resource",
+ NULL },
+ { "constraints", 'a', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, flag_cb,
+ "Display the (co)location constraints that apply to a resource",
+ NULL },
+ { "why", 'Y', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, why_cb,
+ "Show why resources are not running, optionally filtered by\n"
+ INDENT "--resource and/or --node",
+ NULL },
+
+ { NULL }
};
+static GOptionEntry command_entries[] = {
+ { "validate", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, validate_restart_force_cb,
+ "Validate resource configuration by calling agent's validate-all\n"
+ INDENT "action. The configuration may be specified either by giving an\n"
+ INDENT "existing resource name with -r, or by specifying --class,\n"
+ INDENT "--agent, and --provider arguments, along with any number of\n"
+ INDENT "--option arguments.",
+ NULL },
+ { "cleanup", 'C', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, cleanup_refresh_cb,
+ "If resource has any past failures, clear its history and fail\n"
+ INDENT "count. Optionally filtered by --resource, --node, --operation\n"
+ INDENT "and --interval (otherwise all). --operation and --interval\n"
+ INDENT "apply to fail counts, but entire history is always clear, to\n"
+ INDENT "allow current state to be rechecked. If the named resource is\n"
+ INDENT "part of a group, or one numbered instance of a clone or bundled\n"
+ INDENT "resource, the clean-up applies to the whole collective resource\n"
+ INDENT "unless --force is given.",
+ NULL },
+ { "refresh", 'R', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, cleanup_refresh_cb,
+ "Delete resource's history (including failures) so its current state\n"
+ INDENT "is rechecked. Optionally filtered by --resource and --node\n"
+ INDENT "(otherwise all). If the named resource is part of a group, or one\n"
+ INDENT "numbered instance of a clone or bundled resource, the refresh\n"
+ INDENT "applies to the whole collective resource unless --force is given.",
+ NULL },
+ { "set-parameter", 'p', G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, set_delete_param_cb,
+ "Set named parameter for resource (requires -v). Use instance\n"
+ INDENT "attribute unless --meta or --utilization is specified.",
+ "PARAM" },
+ { "delete-parameter", 'd', G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, set_delete_param_cb,
+ "Delete named parameter for resource. Use instance attribute\n"
+ INDENT "unless --meta or --utilization is specified.",
+ "PARAM" },
+ { "set-property", 'S', G_OPTION_FLAG_HIDDEN, G_OPTION_ARG_CALLBACK, set_prop_cb,
+ "Set named property of resource ('class', 'type', or 'provider') "
+ "(requires -r, -t, -v)",
+ "PROPERTY" },
+
+ { NULL }
+};
-int
-main(int argc, char **argv)
-{
- char rsc_cmd = 'L';
+static GOptionEntry location_entries[] = {
+ { "move", 'M', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, flag_cb,
+ "Create a constraint to move resource. If --node is specified,\n"
+ INDENT "the constraint will be to move to that node, otherwise it\n"
+ INDENT "will be to ban the current node. Unless --force is specified\n"
+ INDENT "this will return an error if the resource is already running\n"
+ INDENT "on the specified node. If --force is specified, this will\n"
+ INDENT "always ban the current node.\n"
+ INDENT "Optional: --lifetime, --master. NOTE: This may prevent the\n"
+ INDENT "resource from running on its previous location until the\n"
+ INDENT "implicit constraint expires or is removed with --clear.",
+ NULL },
+ { "ban", 'B', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, flag_cb,
+ "Create a constraint to keep resource off a node.\n"
+ INDENT "Optional: --node, --lifetime, --master.\n"
+ INDENT "NOTE: This will prevent the resource from running on the\n"
+ INDENT "affected node until the implicit constraint expires or is\n"
+ INDENT "removed with --clear. If --node is not specified, it defaults\n"
+ INDENT "to the node currently running the resource for primitives\n"
+ INDENT "and groups, or the master for promotable clones with\n"
+ INDENT "promoted-max=1 (all other situations result in an error as\n"
+ INDENT "there is no sane default).",
+ NULL },
+ { "clear", 'U', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, flag_cb,
+ "Remove all constraints created by the --ban and/or --move\n"
+ INDENT "commands. Requires: --resource. Optional: --node, --master,\n"
+ INDENT "--expired. If --node is not specified, all constraints created\n"
+ INDENT "by --ban and --move will be removed for the named resource. If\n"
+ INDENT "--node and --force are specified, any constraint created by\n"
+ INDENT "--move will be cleared, even if it is not for the specified\n"
+ INDENT "node. If --expired is specified, only those constraints whose\n"
+ INDENT "lifetimes have expired will be removed.",
+ NULL },
+ { "expired", 'e', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, expired_cb,
+ "Modifies the --clear argument to remove constraints with\n"
+ INDENT "expired lifetimes.",
+ NULL },
+ { "lifetime", 'u', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &move_lifetime,
+ "Lifespan (as ISO 8601 duration) of created constraints (with\n"
+ INDENT "-B, -M) see https://en.wikipedia.org/wiki/ISO_8601#Durations)",
+ "TIMESPEC" },
+ { "master", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_NONE, &options.promoted_role_only,
+ "Limit scope of command to Master role (with -B, -M, -U). For\n"
+ INDENT "-B and -M the previous master may remain active in the Slave role.",
+ NULL },
+
+ { NULL }
+};
- const char *v_class = NULL;
- const char *v_agent = NULL;
- const char *v_provider = NULL;
- char *name = NULL;
- char *value = NULL;
- GHashTable *validate_options = NULL;
-
- const char *rsc_id = NULL;
- const char *host_uname = NULL;
- const char *prop_name = NULL;
- const char *prop_value = NULL;
- const char *rsc_type = NULL;
- const char *prop_id = NULL;
- const char *prop_set = NULL;
- const char *rsc_long_cmd = NULL;
- const char *longname = NULL;
- const char *operation = NULL;
- const char *interval_spec = NULL;
- const char *cib_file = getenv("CIB_file");
- const char *xml_file = NULL;
- GHashTable *override_params = NULL;
+static GOptionEntry advanced_entries[] = {
+ { "delete", 'D', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, delete_cb,
+ "(Advanced) Delete a resource from the CIB. Required: -t",
+ NULL },
+ { "fail", 'F', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, fail_cb,
+ "(Advanced) Tell the cluster this resource has failed",
+ NULL },
+ { "restart", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, validate_restart_force_cb,
+ "(Advanced) Tell the cluster to restart this resource and\n"
+ INDENT "anything that depends on it",
+ NULL },
+ { "wait", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, wait_cb,
+ "(Advanced) Wait until the cluster settles into a stable state",
+ NULL },
+ { "force-demote", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, validate_restart_force_cb,
+ "(Advanced) Bypass the cluster and demote a resource on the local\n"
+ INDENT "node. Unless --force is specified, this will refuse to do so if\n"
+ INDENT "the cluster believes the resource is a clone instance already\n"
+ INDENT "running on the local node.",
+ NULL },
+ { "force-stop", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, validate_restart_force_cb,
+ "(Advanced) Bypass the cluster and stop a resource on the local node",
+ NULL },
+ { "force-start", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, validate_restart_force_cb,
+ "(Advanced) Bypass the cluster and start a resource on the local\n"
+ INDENT "node. Unless --force is specified, this will refuse to do so if\n"
+ INDENT "the cluster believes the resource is a clone instance already\n"
+ INDENT "running on the local node.",
+ NULL },
+ { "force-promote", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, validate_restart_force_cb,
+ "(Advanced) Bypass the cluster and promote a resource on the local\n"
+ INDENT "node. Unless --force is specified, this will refuse to do so if\n"
+ INDENT "the cluster believes the resource is a clone instance already\n"
+ INDENT "running on the local node.",
+ NULL },
+ { "force-check", 0, G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, validate_restart_force_cb,
+ "(Advanced) Bypass the cluster and check the state of a resource on\n"
+ INDENT "the local node",
+ NULL },
+
+ { NULL }
+};
- xmlNode *cib_xml_copy = NULL;
- pe_resource_t *rsc = NULL;
- bool recursive = FALSE;
-
- bool validate_cmdline = FALSE; /* whether we are just validating based on command line options */
- bool require_resource = TRUE; /* whether command requires that resource be specified */
- bool require_dataset = TRUE; /* whether command requires populated dataset instance */
- bool require_crmd = FALSE; // whether command requires controller connection
- bool clear_expired = FALSE;
-
- int rc = pcmk_ok;
- int is_ocf_rc = 0;
- int option_index = 0;
- int timeout_ms = 0;
- int argerr = 0;
- int flag;
- int find_flags = 0; // Flags to use when searching for resource
+static GOptionEntry validate_entries[] = {
+ { "class", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, class_cb,
+ "The standard the resource agent confirms to (for example, ocf).\n"
+ INDENT "Use with --agent, --provider, --option, and --validate.",
+ "CLASS" },
+ { "agent", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, agent_provider_cb,
+ "The agent to use (for example, IPaddr). Use with --class,\n"
+ INDENT "--provider, --option, and --validate.",
+ "AGENT" },
+ { "provider", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, agent_provider_cb,
+ "The vendor that supplies the resource agent (for example,\n"
+ INDENT "heartbeat). Use with --class, --agent, --option, and --validate.",
+ "PROVIDER" },
+ { "option", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, extra_cb,
+ "Specify a device configuration parameter as NAME=VALUE (may be\n"
+ INDENT "specified multiple times). Use with --validate and without the\n"
+ INDENT "-r option.",
+ "PARAM" },
+
+ { NULL }
+};
- crm_log_cli_init("crm_resource");
- pcmk__set_cli_options(NULL, "| [options]", long_options,
- "perform tasks related to Pacemaker "
- "cluster resources");
+static GOptionEntry addl_entries[] = {
+ { "node", 'N', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &options.host_uname,
+ "Node name",
+ "NAME" },
+ { "recursive", 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_NONE, &options.recursive,
+ "Follow colocation chains when using --set-parameter",
+ NULL },
+ { "resource-type", 't', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &options.rsc_type,
+ "Resource XML element (primitive, group, etc.) (with -D)",
+ "ELEMENT" },
+ { "parameter-value", 'v', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &options.prop_value,
+ "Value to use with -p",
+ "PARAM" },
+ { "meta", 'm', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, attr_set_type_cb,
+ "Use resource meta-attribute instead of instance attribute\n"
+ INDENT "(with -p, -g, -d)",
+ NULL },
+ { "utilization", 'z', G_OPTION_FLAG_NO_ARG, G_OPTION_ARG_CALLBACK, attr_set_type_cb,
+ "Use resource utilization attribute instead of instance attribute\n"
+ INDENT "(with -p, -g, -d)",
+ NULL },
+ { "operation", 'n', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &options.operation,
+ "Operation to clear instead of all (with -C -r)",
+ "OPERATION" },
+ { "interval", 'I', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &options.interval_spec,
+ "Interval of operation to clear (default 0) (with -C -r -n)",
+ "N" },
+ { "set-name", 's', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &options.prop_set,
+ "(Advanced) XML ID of attributes element to use (with -p, -d)",
+ "ID" },
+ { "nvpair", 'i', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &options.prop_id,
+ "(Advanced) XML ID of nvpair element to use (with -p, -d)",
+ "ID" },
+ { "timeout", 'T', G_OPTION_FLAG_NONE, G_OPTION_ARG_CALLBACK, timeout_cb,
+ "(Advanced) Abort if command does not finish in this time (with\n"
+ INDENT "--restart, --wait, --force-*)",
+ "N" },
+ { "force", 'f', G_OPTION_FLAG_NONE, G_OPTION_ARG_NONE, &options.force,
+ "If making CIB changes, do so regardless of quorum. See help for\n"
+ INDENT "individual commands for additional behavior.",
+ NULL },
+ { "xml-file", 'x', G_OPTION_FLAG_HIDDEN, G_OPTION_ARG_FILENAME, &options.xml_file,
+ NULL,
+ "FILE" },
+ { "host-uname", 'H', G_OPTION_FLAG_HIDDEN, G_OPTION_ARG_STRING, &options.host_uname,
+ NULL,
+ "HOST" },
+
+ { NULL }
+};
- validate_options = crm_str_table_new();
+gboolean
+agent_provider_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.validate_cmdline = TRUE;
+ options.require_resource = FALSE;
- while (1) {
- flag = pcmk__next_cli_option(argc, argv, &option_index, &longname);
- if (flag == -1)
- break;
+ if(safe_str_eq(option_name, "--provider") == TRUE) {
+ if (options.v_provider) {
+ free(options.v_provider);
+ }
+ options.v_provider = strdup(optarg);
+ } else {
+ if (options.v_agent) {
+ free(options.v_agent);
+ }
+ options.v_agent = strdup(optarg);
+ }
- switch (flag) {
- case 0: /* long options with no short equivalent */
- if (safe_str_eq("master", longname)) {
- scope_master = TRUE;
-
- } else if(safe_str_eq(longname, "recursive")) {
- recursive = TRUE;
-
- } else if (safe_str_eq("wait", longname)) {
- rsc_cmd = flag;
- rsc_long_cmd = longname;
- require_resource = FALSE;
- require_dataset = FALSE;
-
- } else if (pcmk__str_any_of(longname, "validate", "restart",
- "force-demote", "force-stop", "force-start",
- "force-promote", "force-check", NULL)) {
- rsc_cmd = flag;
- rsc_long_cmd = longname;
- find_flags = pe_find_renamed|pe_find_anon;
- crm_log_args(argc, argv);
-
- } else if (pcmk__str_any_of(longname, "list-ocf-providers",
- "list-ocf-alternatives", "list-standards",
- NULL)) {
- const char *text = NULL;
- lrmd_list_t *list = NULL;
- lrmd_list_t *iter = NULL;
- lrmd_t *lrmd_conn = lrmd_api_new();
-
- if (pcmk__str_any_of(longname, "list-ocf-providers",
- "list-ocf-alternatives", NULL)) {
- rc = lrmd_conn->cmds->list_ocf_providers(lrmd_conn, optarg, &list);
- text = "OCF providers";
-
- } else if (safe_str_eq("list-standards", longname)) {
- rc = lrmd_conn->cmds->list_standards(lrmd_conn, &list);
- text = "standards";
- }
-
- if (rc > 0) {
- for (iter = list; iter != NULL; iter = iter->next) {
- printf("%s\n", iter->val);
- }
- lrmd_list_freeall(list);
-
- } else if (optarg) {
- fprintf(stderr, "No %s found for %s\n", text, optarg);
- exit_code = CRM_EX_NOSUCH;
-
- } else {
- fprintf(stderr, "No %s found\n", text);
- exit_code = CRM_EX_NOSUCH;
- }
-
- lrmd_api_delete(lrmd_conn);
- return bye(exit_code);
-
- } else if (safe_str_eq("show-metadata", longname)) {
- char *standard = NULL;
- char *provider = NULL;
- char *type = NULL;
- char *metadata = NULL;
- lrmd_t *lrmd_conn = lrmd_api_new();
-
- rc = crm_parse_agent_spec(optarg, &standard, &provider, &type);
- if (rc == pcmk_ok) {
- rc = lrmd_conn->cmds->get_metadata(lrmd_conn, standard,
- provider, type,
- &metadata, 0);
- } else {
- fprintf(stderr,
- "'%s' is not a valid agent specification\n",
- optarg);
- rc = -ENXIO;
- }
-
- if (metadata) {
- printf("%s\n", metadata);
- } else {
- fprintf(stderr, "Metadata query for %s failed: %s\n",
- optarg, pcmk_strerror(rc));
- exit_code = crm_errno2exit(rc);
- }
- lrmd_api_delete(lrmd_conn);
- return bye(exit_code);
-
- } else if (safe_str_eq("list-agents", longname)) {
- lrmd_list_t *list = NULL;
- lrmd_list_t *iter = NULL;
- char *provider = strchr (optarg, ':');
- lrmd_t *lrmd_conn = lrmd_api_new();
-
- if (provider) {
- *provider++ = 0;
- }
- rc = lrmd_conn->cmds->list_agents(lrmd_conn, &list, optarg, provider);
-
- if (rc > 0) {
- for (iter = list; iter != NULL; iter = iter->next) {
- printf("%s\n", iter->val);
- }
- lrmd_list_freeall(list);
- } else {
- fprintf(stderr, "No agents found for standard=%s, provider=%s\n",
- optarg, (provider? provider : "*"));
- exit_code = CRM_EX_NOSUCH;
- }
- lrmd_api_delete(lrmd_conn);
- return bye(exit_code);
-
- } else if (safe_str_eq("class", longname)) {
- if (!(pcmk_get_ra_caps(optarg) & pcmk_ra_cap_params)) {
- if (BE_QUIET == FALSE) {
- fprintf(stdout, "Standard %s does not support parameters\n",
- optarg);
- }
- return bye(exit_code);
-
- } else {
- v_class = optarg;
- }
-
- validate_cmdline = TRUE;
- require_resource = FALSE;
-
- } else if (safe_str_eq("agent", longname)) {
- validate_cmdline = TRUE;
- require_resource = FALSE;
- v_agent = optarg;
-
- } else if (safe_str_eq("provider", longname)) {
- validate_cmdline = TRUE;
- require_resource = FALSE;
- v_provider = optarg;
-
- } else if (safe_str_eq("option", longname)) {
- crm_info("Scanning: --option %s", optarg);
- rc = pcmk_scan_nvpair(optarg, &name, &value);
- if (rc != 2) {
- fprintf(stderr, "Invalid option: --option %s: %s", optarg, pcmk_strerror(rc));
- argerr++;
- } else {
- crm_info("Got: '%s'='%s'", name, value);
- }
-
- g_hash_table_replace(validate_options, name, value);
-
- } else {
- crm_err("Unhandled long option: %s", longname);
- }
- break;
- case 'V':
- resource_verbose++;
- crm_bump_log_level(argc, argv);
- break;
- case '$':
- case '?':
- pcmk__cli_help(flag, CRM_EX_OK);
- break;
- case 'x':
- xml_file = optarg;
- break;
- case 'Q':
- BE_QUIET = TRUE;
- break;
- case 'm':
- attr_set_type = XML_TAG_META_SETS;
- break;
- case 'z':
- attr_set_type = XML_TAG_UTILIZATION;
- break;
- case 'u':
- move_lifetime = strdup(optarg);
- break;
- case 'f':
- do_force = TRUE;
- crm_log_args(argc, argv);
- break;
- case 'i':
- prop_id = optarg;
- break;
- case 's':
- prop_set = optarg;
- break;
- case 'r':
- rsc_id = optarg;
- break;
- case 'v':
- prop_value = optarg;
- break;
- case 't':
- rsc_type = optarg;
- break;
- case 'T':
- timeout_ms = crm_get_msec(optarg);
- break;
- case 'e':
- clear_expired = TRUE;
- require_resource = FALSE;
- break;
-
- case 'C':
- case 'R':
- crm_log_args(argc, argv);
- require_resource = FALSE;
- if (cib_file == NULL) {
- require_crmd = TRUE;
- }
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_anon;
- break;
-
- case 'n':
- operation = optarg;
- break;
-
- case 'I':
- interval_spec = optarg;
- break;
-
- case 'D':
- require_dataset = FALSE;
- crm_log_args(argc, argv);
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_any;
- break;
-
- case 'F':
- require_crmd = TRUE;
- crm_log_args(argc, argv);
- rsc_cmd = flag;
- break;
-
- case 'U':
- case 'B':
- case 'M':
- crm_log_args(argc, argv);
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_anon;
- break;
-
- case 'c':
- case 'L':
- case 'l':
- case 'O':
- case 'o':
- require_resource = FALSE;
- rsc_cmd = flag;
- break;
-
- case 'Y':
- require_resource = FALSE;
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_anon;
- break;
-
- case 'q':
- case 'w':
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_any;
- break;
-
- case 'W':
- case 'A':
- case 'a':
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_anon;
- break;
-
- case 'S':
- require_dataset = FALSE;
- crm_log_args(argc, argv);
- prop_name = optarg;
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_any;
- break;
-
- case 'p':
- case 'd':
- crm_log_args(argc, argv);
- prop_name = optarg;
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_any;
- break;
-
- case 'G':
- case 'g':
- prop_name = optarg;
- rsc_cmd = flag;
- find_flags = pe_find_renamed|pe_find_any;
- break;
-
- case 'H':
- case 'N':
- crm_trace("Option %c => %s", flag, optarg);
- host_uname = optarg;
- break;
-
- default:
- CMD_ERR("Argument code 0%o (%c) is not (?yet?) supported", flag, flag);
- ++argerr;
- break;
+ return TRUE;
+}
+
+gboolean
+attr_set_type_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ if (crm_str_eq(option_name, "-m", TRUE) || crm_str_eq(option_name, "--meta", TRUE)) {
+ options.attr_set_type = XML_TAG_META_SETS;
+ } else if (crm_str_eq(option_name, "-z", TRUE) || crm_str_eq(option_name, "--utilization", TRUE)) {
+ options.attr_set_type = XML_TAG_UTILIZATION;
+ }
+
+ return TRUE;
+}
+
+gboolean
+class_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ if (!(pcmk_get_ra_caps(optarg) & pcmk_ra_cap_params)) {
+ if (BE_QUIET == FALSE) {
+ g_set_error(error, G_OPTION_ERROR, CRM_EX_INVALID_PARAM,
+ "Standard %s does not support parameters\n", optarg);
+ }
+ return FALSE;
+
+ } else {
+ if (options.v_class != NULL) {
+ free(options.v_class);
}
+
+ options.v_class = strdup(optarg);
}
- // Catch the case where the user didn't specify a command
- if (rsc_cmd == 'L') {
- require_resource = FALSE;
+ options.validate_cmdline = TRUE;
+ options.require_resource = FALSE;
+ return TRUE;
+}
+
+gboolean
+cleanup_refresh_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ if (crm_str_eq(option_name, "-C", TRUE) || crm_str_eq(option_name, "--cleanup", TRUE)) {
+ options.rsc_cmd = 'C';
+ } else {
+ options.rsc_cmd = 'R';
}
- // --expired without --clear/-U doesn't make sense
- if (clear_expired == TRUE && rsc_cmd != 'U') {
- CMD_ERR("--expired requires --clear or -U");
- argerr++;
+ options.require_resource = FALSE;
+ if (getenv("CIB_file") == NULL) {
+ options.require_crmd = TRUE;
}
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ return TRUE;
+}
- if (optind < argc
- && argv[optind] != NULL
- && rsc_cmd == 0
- && rsc_long_cmd) {
+gboolean
+delete_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.require_dataset = FALSE;
+ options.rsc_cmd = 'D';
+ options.find_flags = pe_find_renamed|pe_find_any;
+ return TRUE;
+}
- override_params = crm_str_table_new();
- while (optind < argc && argv[optind] != NULL) {
- char *name = calloc(1, strlen(argv[optind]));
- char *value = calloc(1, strlen(argv[optind]));
- int rc = sscanf(argv[optind], "%[^=]=%s", name, value);
+gboolean
+expired_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.clear_expired = TRUE;
+ options.require_resource = FALSE;
+ return TRUE;
+}
- if(rc == 2) {
- g_hash_table_replace(override_params, name, value);
+gboolean
+extra_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ if (options.extra_option) {
+ free(options.extra_option);
+ }
- } else {
- CMD_ERR("Error parsing '%s' as a name=value pair for --%s", argv[optind], rsc_long_cmd);
- free(value);
- free(name);
- argerr++;
- }
- optind++;
- }
+ if (options.extra_arg) {
+ free(options.extra_arg);
+ }
- } else if (optind < argc && argv[optind] != NULL && rsc_cmd == 0) {
- CMD_ERR("non-option ARGV-elements: ");
- while (optind < argc && argv[optind] != NULL) {
- CMD_ERR("[%d of %d] %s ", optind, argc, argv[optind]);
- optind++;
- argerr++;
- }
+ options.extra_option = strdup(option_name);
+
+ if (optarg) {
+ options.extra_arg = strdup(optarg);
}
- if (optind > argc) {
- ++argerr;
+ return TRUE;
+}
+
+gboolean
+fail_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.require_crmd = TRUE;
+ options.rsc_cmd = 'F';
+ return TRUE;
+}
+
+gboolean
+flag_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ if (crm_str_eq(option_name, "-U", TRUE) || crm_str_eq(option_name, "--clear", TRUE)) {
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ options.rsc_cmd = 'U';
+ } else if (crm_str_eq(option_name, "-B", TRUE) || crm_str_eq(option_name, "--ban", TRUE)) {
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ options.rsc_cmd = 'B';
+ } else if (crm_str_eq(option_name, "-M", TRUE) || crm_str_eq(option_name, "--move", TRUE)) {
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ options.rsc_cmd = 'M';
+ } else if (crm_str_eq(option_name, "-q", TRUE) || crm_str_eq(option_name, "--query-xml", TRUE)) {
+ options.find_flags = pe_find_renamed|pe_find_any;
+ options.rsc_cmd = 'q';
+ } else if (crm_str_eq(option_name, "-w", TRUE) || crm_str_eq(option_name, "--query-xml-raw", TRUE)) {
+ options.find_flags = pe_find_renamed|pe_find_any;
+ options.rsc_cmd = 'w';
+ } else if (crm_str_eq(option_name, "-W", TRUE) || crm_str_eq(option_name, "--locate", TRUE)) {
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ options.rsc_cmd = 'W';
+ } else if (crm_str_eq(option_name, "-A", TRUE) || crm_str_eq(option_name, "--stack", TRUE)) {
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ options.rsc_cmd = 'A';
+ } else {
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ options.rsc_cmd = 'a';
}
- // Sanity check validating from command line parameters. If everything checks out,
- // go ahead and run the validation. This way we don't need a CIB connection.
- if (validate_cmdline == TRUE) {
- // -r cannot be used with any of --class, --agent, or --provider
- if (rsc_id != NULL) {
- CMD_ERR("--resource cannot be used with --class, --agent, and --provider");
- argerr++;
-
- // If --class, --agent, or --provider are given, --validate must also be given.
- } else if (!safe_str_eq(rsc_long_cmd, "validate")) {
- CMD_ERR("--class, --agent, and --provider require --validate");
- argerr++;
-
- // Not all of --class, --agent, and --provider need to be given. Not all
- // classes support the concept of a provider. Check that what we were given
- // is valid.
- } else if (crm_str_eq(v_class, "stonith", TRUE)) {
- if (v_provider != NULL) {
- CMD_ERR("stonith does not support providers");
- argerr++;
-
- } else if (stonith_agent_exists(v_agent, 0) == FALSE) {
- CMD_ERR("%s is not a known stonith agent", v_agent ? v_agent : "");
- argerr++;
- }
+ return TRUE;
+}
- } else if (resources_agent_exists(v_class, v_provider, v_agent) == FALSE) {
- CMD_ERR("%s:%s:%s is not a known resource",
- v_class ? v_class : "",
- v_provider ? v_provider : "",
- v_agent ? v_agent : "");
- argerr++;
- }
+gboolean
+get_param_prop_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ if (crm_str_eq(option_name, "-g", TRUE) || crm_str_eq(option_name, "--get-parameter", TRUE)) {
+ options.rsc_cmd = 'g';
+ } else {
+ options.rsc_cmd = 'G';
+ }
- if (argerr == 0) {
- rc = cli_resource_execute_from_params("test", v_class, v_provider, v_agent,
- "validate-all", validate_options,
- override_params, timeout_ms);
- exit_code = crm_errno2exit(rc);
- return bye(exit_code);
- }
+ if (options.prop_name) {
+ free(options.prop_name);
}
- if (argerr) {
- CMD_ERR("Invalid option(s) supplied, use --help for valid usage");
- return bye(CRM_EX_USAGE);
+ options.prop_name = strdup(optarg);
+ options.find_flags = pe_find_renamed|pe_find_any;
+ return TRUE;
+}
+
+gboolean
+list_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ if (crm_str_eq(option_name, "-c", TRUE) || crm_str_eq(option_name, "--list-cts", TRUE)) {
+ options.rsc_cmd = 'c';
+ } else if (crm_str_eq(option_name, "-L", TRUE) || crm_str_eq(option_name, "--list", TRUE)) {
+ options.rsc_cmd = 'L';
+ } else if (crm_str_eq(option_name, "-l", TRUE) || crm_str_eq(option_name, "--list-raw", TRUE)) {
+ options.rsc_cmd = 'l';
+ } else if (crm_str_eq(option_name, "-O", TRUE) || crm_str_eq(option_name, "--list-operations", TRUE)) {
+ options.rsc_cmd = 'O';
+ } else {
+ options.rsc_cmd = 'o';
}
- if (do_force) {
- crm_debug("Forcing...");
- cib_options |= cib_quorum_override;
+ options.require_resource = FALSE;
+ return TRUE;
+}
+
+gboolean
+set_delete_param_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ if (crm_str_eq(option_name, "-p", TRUE) || crm_str_eq(option_name, "--set-parameter", TRUE)) {
+ options.rsc_cmd = 'p';
+ } else {
+ options.rsc_cmd = 'd';
}
- if (require_resource && !rsc_id) {
- CMD_ERR("Must supply a resource id with -r");
- rc = -ENXIO;
- goto bail;
+ if (options.prop_name) {
+ free(options.prop_name);
}
- if (find_flags && rsc_id) {
- require_dataset = TRUE;
+ options.prop_name = strdup(optarg);
+ options.find_flags = pe_find_renamed|pe_find_any;
+ return TRUE;
+}
+
+gboolean
+set_prop_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.require_dataset = FALSE;
+
+ if (options.prop_name) {
+ free(options.prop_name);
}
- // Establish a connection to the CIB
- cib_conn = cib_new();
- if ((cib_conn == NULL) || (cib_conn->cmds == NULL)) {
- CMD_ERR("Could not create CIB connection: %s", pcmk_strerror(rc));
- goto bail;
+ options.prop_name = strdup(optarg);
+ options.rsc_cmd = 'S';
+ options.find_flags = pe_find_renamed|pe_find_any;
+ return TRUE;
+}
+
+gboolean
+timeout_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.timeout_ms = crm_get_msec(optarg);
+ return TRUE;
+}
+
+gboolean
+validate_restart_force_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.rsc_cmd = 0;
+ if (options.rsc_long_cmd) {
+ free(options.rsc_long_cmd);
}
- rc = cib_conn->cmds->signon(cib_conn, crm_system_name, cib_command);
- if (rc != pcmk_ok) {
- CMD_ERR("Could not connect to the CIB: %s", pcmk_strerror(rc));
- goto bail;
+ options.rsc_long_cmd = strdup(option_name+2);
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ return TRUE;
+}
+
+gboolean
+wait_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.rsc_cmd = 0;
+ if (options.rsc_long_cmd) {
+ free(options.rsc_long_cmd);
}
+ options.rsc_long_cmd = strdup("wait");
+ options.require_resource = FALSE;
+ options.require_dataset = FALSE;
+ return TRUE;
+}
- /* Populate working set from XML file if specified or CIB query otherwise */
- if (require_dataset) {
- if (xml_file != NULL) {
- cib_xml_copy = filename2xml(xml_file);
- } else {
- rc = cib_conn->cmds->query(cib_conn, NULL, &cib_xml_copy, cib_scope_local | cib_sync_call);
- }
+gboolean
+why_cb(const gchar *option_name, const gchar *optarg, gpointer data, GError **error) {
+ options.require_resource = FALSE;
+ options.rsc_cmd = 'Y';
+ options.find_flags = pe_find_renamed|pe_find_anon;
+ return TRUE;
+}
- if(rc != pcmk_ok) {
- goto bail;
- }
+static int
+ban_or_move(pe_resource_t *rsc, crm_exit_t *exit_code)
+{
+ int rc = pcmk_rc_ok;
+ pe_node_t *current = NULL;
+ unsigned int nactive = 0;
- /* Populate the working set instance */
- data_set = pe_new_working_set();
- if (data_set == NULL) {
- rc = -ENOMEM;
- goto bail;
+ current = pe__find_active_requires(rsc, &nactive);
+
+ if (nactive == 1) {
+ rc = cli_resource_ban(options.rsc_id, current->details->uname, NULL,
+ cib_conn, options.cib_options, options.promoted_role_only);
+
+ } else if (is_set(rsc->flags, pe_rsc_promotable)) {
+ int count = 0;
+ GListPtr iter = NULL;
+
+ current = NULL;
+ for(iter = rsc->children; iter; iter = iter->next) {
+ pe_resource_t *child = (pe_resource_t *)iter->data;
+ enum rsc_role_e child_role = child->fns->state(child, TRUE);
+
+ if(child_role == RSC_ROLE_MASTER) {
+ count++;
+ current = pe__current_node(child);
+ }
}
- set_bit(data_set->flags, pe_flag_no_counts);
- set_bit(data_set->flags, pe_flag_no_compat);
- rc = update_working_set_xml(data_set, &cib_xml_copy);
- if (rc != pcmk_ok) {
- goto bail;
+
+ if(count == 1 && current) {
+ rc = cli_resource_ban(options.rsc_id, current->details->uname, NULL,
+ cib_conn, options.cib_options, options.promoted_role_only);
+
+ } else {
+ rc = EINVAL;
+ *exit_code = CRM_EX_USAGE;
+ g_set_error(&error, PCMK__EXITC_ERROR, *exit_code,
+ "Resource '%s' not moved: active in %d locations (promoted in %d).\n"
+ "To prevent '%s' from running on a specific location, "
+ "specify a node."
+ "To prevent '%s' from being promoted at a specific "
+ "location, specify a node and the master option.",
+ options.rsc_id, nactive, count, options.rsc_id, options.rsc_id);
}
- cluster_status(data_set);
+
+ } else {
+ rc = EINVAL;
+ *exit_code = CRM_EX_USAGE;
+ g_set_error(&error, PCMK__EXITC_ERROR, *exit_code,
+ "Resource '%s' not moved: active in %d locations.\n"
+ "To prevent '%s' from running on a specific location, "
+ "specify a node.",
+ options.rsc_id, nactive, options.rsc_id);
}
- // If command requires that resource exist if specified, find it
- if (find_flags && rsc_id) {
- rsc = pe_find_resource_with_flags(data_set->resources, rsc_id,
- find_flags);
- if (rsc == NULL) {
- CMD_ERR("Resource '%s' not found", rsc_id);
- rc = -ENXIO;
- goto bail;
+ return rc;
+}
+
+static void
+cleanup(pe_resource_t *rsc)
+{
+ int rc = pcmk_rc_ok;
+
+ if (options.force == FALSE) {
+ rsc = uber_parent(rsc);
+ }
+
+ crm_debug("Erasing failures of %s (%s requested) on %s",
+ rsc->id, options.rsc_id, (options.host_uname? options.host_uname: "all nodes"));
+ rc = cli_resource_delete(controld_api, options.host_uname, rsc, options.operation,
+ options.interval_spec, TRUE, data_set, options.force);
+
+ if ((rc == pcmk_rc_ok) && !BE_QUIET) {
+ // Show any reasons why resource might stay stopped
+ cli_resource_check(cib_conn, rsc);
+ }
+
+ if (rc == pcmk_rc_ok) {
+ start_mainloop(controld_api);
+ }
+}
+
+static int
+clear_constraints(xmlNodePtr *cib_xml_copy)
+{
+ GListPtr before = NULL;
+ GListPtr after = NULL;
+ GListPtr remaining = NULL;
+ GListPtr ele = NULL;
+ pe_node_t *dest = NULL;
+ int rc = pcmk_rc_ok;
+
+ if (BE_QUIET == FALSE) {
+ before = build_constraint_list(data_set->input);
+ }
+
+ if (options.clear_expired) {
+ rc = cli_resource_clear_all_expired(data_set->input, cib_conn, options.cib_options,
+ options.rsc_id, options.host_uname,
+ options.promoted_role_only);
+
+ } else if (options.host_uname) {
+ dest = pe_find_node(data_set->nodes, options.host_uname);
+ if (dest == NULL) {
+ rc = pcmk_rc_node_unknown;
+ if (BE_QUIET == FALSE) {
+ g_list_free(before);
+ }
+ return rc;
}
+ rc = cli_resource_clear(options.rsc_id, dest->details->uname, NULL,
+ cib_conn, options.cib_options, TRUE, options.force);
+
+ } else {
+ rc = cli_resource_clear(options.rsc_id, NULL, data_set->nodes,
+ cib_conn, options.cib_options, TRUE, options.force);
}
- // Establish a connection to the controller if needed
- if (require_crmd) {
- rc = pcmk_new_ipc_api(&controld_api, pcmk_ipc_controld);
+ if (BE_QUIET == FALSE) {
+ rc = cib_conn->cmds->query(cib_conn, NULL, cib_xml_copy, cib_scope_local | cib_sync_call);
+ rc = pcmk_legacy2rc(rc);
+
if (rc != pcmk_rc_ok) {
- CMD_ERR("Error connecting to the controller: %s", pcmk_rc_str(rc));
- rc = pcmk_rc2legacy(rc);
- goto bail;
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "Could not get modified CIB: %s\n", pcmk_strerror(rc));
+ g_list_free(before);
+ return rc;
}
- pcmk_register_ipc_callback(controld_api, controller_event_callback,
- NULL);
- rc = pcmk_connect_ipc(controld_api, pcmk_ipc_dispatch_main);
- if (rc != pcmk_rc_ok) {
- CMD_ERR("Error connecting to the controller: %s", pcmk_rc_str(rc));
- rc = pcmk_rc2legacy(rc);
- goto bail;
+
+ data_set->input = *cib_xml_copy;
+ cluster_status(data_set);
+
+ after = build_constraint_list(data_set->input);
+ remaining = subtract_lists(before, after, (GCompareFunc) strcmp);
+
+ for (ele = remaining; ele != NULL; ele = ele->next) {
+ printf("Removing constraint: %s\n", (char *) ele->data);
}
+
+ g_list_free(before);
+ g_list_free(after);
+ g_list_free(remaining);
}
- /* Handle rsc_cmd appropriately */
- if (rsc_cmd == 'L') {
- rc = pcmk_ok;
- cli_resource_print_list(data_set, FALSE);
+ return rc;
+}
- } else if (rsc_cmd == 'l') {
- int found = 0;
- GListPtr lpc = NULL;
+static int
+delete()
+{
+ int rc = pcmk_rc_ok;
+ xmlNode *msg_data = NULL;
+
+ if (options.rsc_type == NULL) {
+ rc = ENXIO;
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "You need to specify a resource type with -t");
+ return rc;
+ }
- rc = pcmk_ok;
- for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
- rsc = (pe_resource_t *) lpc->data;
+ msg_data = create_xml_node(NULL, options.rsc_type);
+ crm_xml_add(msg_data, XML_ATTR_ID, options.rsc_id);
- found++;
- cli_resource_print_raw(rsc);
- }
+ rc = cib_conn->cmds->remove(cib_conn, XML_CIB_TAG_RESOURCES, msg_data,
+ options.cib_options);
+ rc = pcmk_legacy2rc(rc);
+ free_xml(msg_data);
+ return rc;
+}
- if (found == 0) {
- printf("NO resources configured\n");
- rc = -ENXIO;
+static int
+list_agents(const char *spec, crm_exit_t *exit_code)
+{
+ int rc = pcmk_rc_ok;
+ lrmd_list_t *list = NULL;
+ lrmd_list_t *iter = NULL;
+ char *provider = strchr (spec, ':');
+ lrmd_t *lrmd_conn = lrmd_api_new();
+
+ if (provider) {
+ *provider++ = 0;
+ }
+ rc = lrmd_conn->cmds->list_agents(lrmd_conn, &list, spec, provider);
+
+ if (rc > 0) {
+ for (iter = list; iter != NULL; iter = iter->next) {
+ printf("%s\n", iter->val);
}
+ lrmd_list_freeall(list);
+ rc = pcmk_rc_ok;
+ } else {
+ *exit_code = CRM_EX_NOSUCH;
+ rc = pcmk_rc_error;
+ g_set_error(&error, PCMK__EXITC_ERROR, *exit_code,
+ "No agents found for standard=%s, provider=%s",
+ spec, (provider? provider : "*"));
+ }
- } else if (rsc_cmd == 0 && rsc_long_cmd && safe_str_eq(rsc_long_cmd, "restart")) {
- /* We don't pass data_set because rsc needs to stay valid for the entire
- * lifetime of cli_resource_restart(), but it will reset and update the
- * working set multiple times, so it needs to use its own copy.
- */
- rc = cli_resource_restart(rsc, host_uname, timeout_ms, cib_conn);
+ lrmd_api_delete(lrmd_conn);
+ return rc;
+}
- } else if (rsc_cmd == 0 && rsc_long_cmd && safe_str_eq(rsc_long_cmd, "wait")) {
- rc = wait_till_stable(timeout_ms, cib_conn);
+static int
+list_providers(const char *command, const char *spec, crm_exit_t *exit_code)
+{
+ int rc = pcmk_rc_ok;
+ const char *text = NULL;
+ lrmd_list_t *list = NULL;
+ lrmd_list_t *iter = NULL;
+ lrmd_t *lrmd_conn = lrmd_api_new();
+
+ if (pcmk__str_any_of(command, "--list-ocf-providers",
+ "--list-ocf-alternatives", NULL)) {
+ rc = lrmd_conn->cmds->list_ocf_providers(lrmd_conn, spec, &list);
+ text = "OCF providers";
+
+ } else if (safe_str_eq("--list-standards", command)) {
+ rc = lrmd_conn->cmds->list_standards(lrmd_conn, &list);
+ text = "standards";
+ }
- } else if (rsc_cmd == 0 && rsc_long_cmd) {
- // validate, force-(stop|start|demote|promote|check)
- rc = cli_resource_execute(rsc, rsc_id, rsc_long_cmd, override_params,
- timeout_ms, cib_conn, data_set);
- if (rc >= 0) {
- is_ocf_rc = 1;
+ if (rc > 0) {
+ for (iter = list; iter != NULL; iter = iter->next) {
+ printf("%s\n", iter->val);
}
+ lrmd_list_freeall(list);
+ rc = pcmk_rc_ok;
- } else if (rsc_cmd == 'A' || rsc_cmd == 'a') {
- GListPtr lpc = NULL;
- xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS,
- data_set->input);
+ } else if (spec) {
+ *exit_code = CRM_EX_NOSUCH;
+ rc = pcmk_rc_error;
+ g_set_error(&error, PCMK__EXITC_ERROR, *exit_code,
+ "No %s found for %s", text, spec);
- unpack_constraints(cib_constraints, data_set);
+ } else {
+ *exit_code = CRM_EX_NOSUCH;
+ rc = pcmk_rc_error;
+ g_set_error(&error, PCMK__EXITC_ERROR, *exit_code,
+ "No %s found", text);
+ }
- // Constraints apply to group/clone, not member/instance
- rsc = uber_parent(rsc);
+ lrmd_api_delete(lrmd_conn);
+ return rc;
+}
- for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
- pe_resource_t *r = (pe_resource_t *) lpc->data;
+static int
+list_raw()
+{
+ int rc = pcmk_rc_ok;
+ int found = 0;
+ GListPtr lpc = NULL;
- clear_bit(r->flags, pe_rsc_allocating);
- }
+ for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
+ pe_resource_t *rsc = (pe_resource_t *) lpc->data;
- cli_resource_print_colocation(rsc, TRUE, rsc_cmd == 'A', 1);
+ found++;
+ cli_resource_print_raw(rsc);
+ }
- fprintf(stdout, "* %s\n", rsc->id);
- cli_resource_print_location(rsc, NULL);
+ if (found == 0) {
+ printf("NO resources configured\n");
+ rc = ENXIO;
+ }
- for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
- pe_resource_t *r = (pe_resource_t *) lpc->data;
+ return rc;
+}
- clear_bit(r->flags, pe_rsc_allocating);
- }
+static void
+list_stacks_and_constraints(pe_resource_t *rsc)
+{
+ GListPtr lpc = NULL;
+ xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS,
+ data_set->input);
- cli_resource_print_colocation(rsc, FALSE, rsc_cmd == 'A', 1);
+ unpack_constraints(cib_constraints, data_set);
- } else if (rsc_cmd == 'c') {
- GListPtr lpc = NULL;
+ // Constraints apply to group/clone, not member/instance
+ rsc = uber_parent(rsc);
- rc = pcmk_ok;
- for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
- rsc = (pe_resource_t *) lpc->data;
- cli_resource_print_cts(rsc);
- }
- cli_resource_print_cts_constraints(data_set);
+ for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
+ pe_resource_t *r = (pe_resource_t *) lpc->data;
- } else if (rsc_cmd == 'F') {
- rc = cli_resource_fail(controld_api, host_uname, rsc_id, data_set);
- if (rc == pcmk_rc_ok) {
- start_mainloop(controld_api);
- }
- rc = pcmk_rc2legacy(rc);
+ clear_bit(r->flags, pe_rsc_allocating);
+ }
- } else if (rsc_cmd == 'O') {
- rc = cli_resource_print_operations(rsc_id, host_uname, TRUE, data_set);
+ cli_resource_print_colocation(rsc, TRUE, options.rsc_cmd == 'A', 1);
- } else if (rsc_cmd == 'o') {
- rc = cli_resource_print_operations(rsc_id, host_uname, FALSE, data_set);
+ fprintf(stdout, "* %s\n", rsc->id);
+ cli_resource_print_location(rsc, NULL);
- } else if (rsc_cmd == 'W') {
- rc = cli_resource_search(rsc, rsc_id, data_set);
- if (rc >= 0) {
- rc = pcmk_ok;
- }
+ for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
+ pe_resource_t *r = (pe_resource_t *) lpc->data;
- } else if (rsc_cmd == 'q') {
- rc = cli_resource_print(rsc, data_set, TRUE);
+ clear_bit(r->flags, pe_rsc_allocating);
+ }
- } else if (rsc_cmd == 'w') {
- rc = cli_resource_print(rsc, data_set, FALSE);
+ cli_resource_print_colocation(rsc, FALSE, options.rsc_cmd == 'A', 1);
+}
- } else if (rsc_cmd == 'Y') {
- pe_node_t *dest = NULL;
+static int
+populate_working_set(xmlNodePtr *cib_xml_copy)
+{
+ int rc = pcmk_rc_ok;
- if (host_uname) {
- dest = pe_find_node(data_set->nodes, host_uname);
- if (dest == NULL) {
- rc = -pcmk_err_node_unknown;
- goto bail;
+ if (options.xml_file != NULL) {
+ *cib_xml_copy = filename2xml(options.xml_file);
+ } else {
+ rc = cib_conn->cmds->query(cib_conn, NULL, cib_xml_copy, cib_scope_local | cib_sync_call);
+ rc = pcmk_legacy2rc(rc);
+ }
+
+ if(rc != pcmk_rc_ok) {
+ return rc;
+ }
+
+ /* Populate the working set instance */
+ data_set = pe_new_working_set();
+ if (data_set == NULL) {
+ rc = ENOMEM;
+ return rc;
+ }
+
+ set_bit(data_set->flags, pe_flag_no_counts);
+ set_bit(data_set->flags, pe_flag_no_compat);
+
+ rc = update_working_set_xml(data_set, cib_xml_copy);
+ if (rc != pcmk_rc_ok) {
+ return rc;
+ }
+
+ cluster_status(data_set);
+ return rc;
+}
+
+static int
+refresh()
+{
+ int rc = pcmk_rc_ok;
+ const char *router_node = options.host_uname;
+ int attr_options = pcmk__node_attr_none;
+
+ if (options.host_uname) {
+ pe_node_t *node = pe_find_node(data_set->nodes, options.host_uname);
+
+ if (pe__is_guest_or_remote_node(node)) {
+ node = pe__current_node(node->details->remote_rsc);
+ if (node == NULL) {
+ rc = ENXIO;
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "No cluster connection to Pacemaker Remote node %s detected",
+ options.host_uname);
+ return rc;
}
+ router_node = node->details->uname;
+ attr_options |= pcmk__node_attr_remote;
}
- cli_resource_why(cib_conn, data_set->resources, rsc, dest);
- rc = pcmk_ok;
+ }
- } else if (rsc_cmd == 'U') {
- GListPtr before = NULL;
- GListPtr after = NULL;
- GListPtr remaining = NULL;
- GListPtr ele = NULL;
- pe_node_t *dest = NULL;
+ if (controld_api == NULL) {
+ printf("Dry run: skipping clean-up of %s due to CIB_file\n",
+ options.host_uname? options.host_uname : "all nodes");
+ rc = pcmk_rc_ok;
+ return rc;
+ }
- if (BE_QUIET == FALSE) {
- before = build_constraint_list(data_set->input);
- }
+ crm_debug("Re-checking the state of all resources on %s", options.host_uname?options.host_uname:"all nodes");
- if (clear_expired == TRUE) {
- rc = cli_resource_clear_all_expired(data_set->input, cib_conn, rsc_id, host_uname, scope_master);
+ rc = pcmk__node_attr_request_clear(NULL, options.host_uname,
+ NULL, NULL, NULL,
+ NULL, attr_options);
- } else if (host_uname) {
- dest = pe_find_node(data_set->nodes, host_uname);
- if (dest == NULL) {
- rc = -pcmk_err_node_unknown;
- if (BE_QUIET == FALSE) {
- g_list_free(before);
- }
- goto bail;
- }
- rc = cli_resource_clear(rsc_id, dest->details->uname, NULL, cib_conn, TRUE);
+ if (pcmk_controld_api_reprobe(controld_api, options.host_uname,
+ router_node) == pcmk_rc_ok) {
+ start_mainloop(controld_api);
+ }
+
+ return rc;
+}
+
+static void
+refresh_resource(pe_resource_t *rsc)
+{
+ int rc = pcmk_rc_ok;
+
+ if (options.force == FALSE) {
+ rsc = uber_parent(rsc);
+ }
+
+ crm_debug("Re-checking the state of %s (%s requested) on %s",
+ rsc->id, options.rsc_id, (options.host_uname? options.host_uname: "all nodes"));
+ rc = cli_resource_delete(controld_api, options.host_uname, rsc, NULL, 0, FALSE,
+ data_set, options.force);
+
+ if ((rc == pcmk_rc_ok) && !BE_QUIET) {
+ // Show any reasons why resource might stay stopped
+ cli_resource_check(cib_conn, rsc);
+ }
+ if (rc == pcmk_rc_ok) {
+ start_mainloop(controld_api);
+ }
+}
+
+static int
+set_option(const char *arg)
+{
+ int rc = pcmk_rc_ok;
+ char *name = NULL;
+ char *value = NULL;
+
+ crm_info("Scanning: --option %s", arg);
+ rc = pcmk_scan_nvpair(arg, &name, &value);
+
+ if (rc != 2) {
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "Invalid option: --option %s: %s", arg, pcmk_strerror(rc));
+ } else {
+ crm_info("Got: '%s'='%s'", name, value);
+ g_hash_table_replace(options.validate_options, name, value);
+ }
+
+ return rc;
+}
+
+static int
+set_property()
+{
+ int rc = pcmk_rc_ok;
+ xmlNode *msg_data = NULL;
+
+ if ((options.rsc_type == NULL) || !strlen(options.rsc_type)) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "Must specify -t with resource type");
+ rc = ENXIO;
+ return rc;
+
+ } else if ((options.prop_value == NULL) || !strlen(options.prop_value)) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "Must supply -v with new value");
+ rc = EINVAL;
+ return rc;
+ }
+
+ CRM_LOG_ASSERT(options.prop_name != NULL);
+
+ msg_data = create_xml_node(NULL, options.rsc_type);
+ crm_xml_add(msg_data, XML_ATTR_ID, options.rsc_id);
+ crm_xml_add(msg_data, options.prop_name, options.prop_value);
+
+ rc = cib_conn->cmds->modify(cib_conn, XML_CIB_TAG_RESOURCES, msg_data,
+ options.cib_options);
+ rc = pcmk_legacy2rc(rc);
+ free_xml(msg_data);
+
+ return rc;
+}
+
+static int
+show_metadata(const char *spec, crm_exit_t *exit_code)
+{
+ int rc = pcmk_rc_ok;
+ char *standard = NULL;
+ char *provider = NULL;
+ char *type = NULL;
+ char *metadata = NULL;
+ lrmd_t *lrmd_conn = lrmd_api_new();
+
+ rc = crm_parse_agent_spec(spec, &standard, &provider, &type);
+ rc = pcmk_legacy2rc(rc);
+
+ if (rc == pcmk_rc_ok) {
+ rc = lrmd_conn->cmds->get_metadata(lrmd_conn, standard,
+ provider, type,
+ &metadata, 0);
+ rc = pcmk_legacy2rc(rc);
+
+ if (metadata) {
+ printf("%s\n", metadata);
} else {
- rc = cli_resource_clear(rsc_id, NULL, data_set->nodes, cib_conn, TRUE);
+ *exit_code = crm_errno2exit(rc);
+ g_set_error(&error, PCMK__EXITC_ERROR, *exit_code,
+ "Metadata query for %s failed: %s", spec, pcmk_rc_str(rc));
}
+ } else {
+ rc = ENXIO;
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "'%s' is not a valid agent specification", spec);
+ }
- if (BE_QUIET == FALSE) {
- rc = cib_conn->cmds->query(cib_conn, NULL, &cib_xml_copy, cib_scope_local | cib_sync_call);
- if (rc != pcmk_ok) {
- CMD_ERR("Could not get modified CIB: %s\n", pcmk_strerror(rc));
- g_list_free(before);
- goto bail;
- }
+ lrmd_api_delete(lrmd_conn);
+ return rc;
+}
- data_set->input = cib_xml_copy;
- cluster_status(data_set);
+static void
+validate_cmdline(crm_exit_t *exit_code)
+{
+ // -r cannot be used with any of --class, --agent, or --provider
+ if (options.rsc_id != NULL) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "--resource cannot be used with --class, --agent, and --provider");
+
+ // If --class, --agent, or --provider are given, --validate must also be given.
+ } else if (!safe_str_eq(options.rsc_long_cmd, "validate")) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "--class, --agent, and --provider require --validate");
+
+ // Not all of --class, --agent, and --provider need to be given. Not all
+ // classes support the concept of a provider. Check that what we were given
+ // is valid.
+ } else if (crm_str_eq(options.v_class, "stonith", TRUE)) {
+ if (options.v_provider != NULL) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "stonith does not support providers");
+
+ } else if (stonith_agent_exists(options.v_agent, 0) == FALSE) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "%s is not a known stonith agent", options.v_agent ? options.v_agent : "");
+ }
- after = build_constraint_list(data_set->input);
- remaining = subtract_lists(before, after, (GCompareFunc) strcmp);
+ } else if (resources_agent_exists(options.v_class, options.v_provider, options.v_agent) == FALSE) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "%s:%s:%s is not a known resource",
+ options.v_class ? options.v_class : "",
+ options.v_provider ? options.v_provider : "",
+ options.v_agent ? options.v_agent : "");
+ }
- for (ele = remaining; ele != NULL; ele = ele->next) {
- printf("Removing constraint: %s\n", (char *) ele->data);
- }
+ if (error == NULL) {
+ *exit_code = cli_resource_execute_from_params("test", options.v_class, options.v_provider, options.v_agent,
+ "validate-all", options.validate_options,
+ options.override_params, options.timeout_ms,
+ options.resource_verbose, options.force);
+ }
+}
- g_list_free(before);
- g_list_free(after);
- g_list_free(remaining);
- }
+static GOptionContext *
+build_arg_context(pcmk__common_args_t *args) {
+ GOptionContext *context = NULL;
+
+ GOptionEntry extra_prog_entries[] = {
+ { "quiet", 'Q', G_OPTION_FLAG_NONE, G_OPTION_ARG_NONE, &(args->quiet),
+ "Be less descriptive in output.",
+ NULL },
+ { "resource", 'r', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING, &options.rsc_id,
+ "Resource ID",
+ "ID" },
+ { G_OPTION_REMAINING, 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING_ARRAY, &options.remainder,
+ NULL,
+ NULL },
+
+ { NULL }
+ };
+
+ const char *description = "Examples:\n\n"
+ "List the available OCF agents:\n\n"
+ "\t# crm_resource --list-agents ocf\n\n"
+ "List the available OCF agents from the linux-ha project:\n\n"
+ "\t# crm_resource --list-agents ocf:heartbeat\n\n"
+ "Move 'myResource' to a specific node:\n\n"
+ "\t# crm_resource --resource myResource --move --node altNode\n\n"
+ "Allow (but not force) 'myResource' to move back to its original "
+ "location:\n\n"
+ "\t# crm_resource --resource myResource --clear\n\n"
+ "Stop 'myResource' (and anything that depends on it):\n\n"
+ "\t# crm_resource --resource myResource --set-parameter target-role "
+ "--meta --parameter-value Stopped\n\n"
+ "Tell the cluster not to manage 'myResource' (the cluster will not "
+ "attempt to start or stop the\n"
+ "resource under any circumstances; useful when performing maintenance "
+ "tasks on a resource):\n\n"
+ "\t# crm_resource --resource myResource --set-parameter is-managed "
+ "--meta --parameter-value false\n\n"
+ "Erase the operation history of 'myResource' on 'aNode' (the cluster "
+ "will 'forget' the existing\n"
+ "resource state, including any errors, and attempt to recover the"
+ "resource; useful when a resource\n"
+ "had failed permanently and has been repaired by an administrator):\n\n"
+ "\t# crm_resource --resource myResource --cleanup --node aNode\n\n";
+
+ context = pcmk__build_arg_context(args, NULL, NULL, NULL);
+ g_option_context_set_description(context, description);
+
+ /* Add the -Q option, which cannot be part of the globally supported options
+ * because some tools use that flag for something else.
+ */
+ pcmk__add_main_args(context, extra_prog_entries);
+
+ pcmk__add_arg_group(context, "queries", "Queries:",
+ "Show query help", query_entries);
+ pcmk__add_arg_group(context, "commands", "Commands:",
+ "Show command help", command_entries);
+ pcmk__add_arg_group(context, "locations", "Locations:",
+ "Show location help", location_entries);
+ pcmk__add_arg_group(context, "validate", "Validate:",
+ "Show validate help", validate_entries);
+ pcmk__add_arg_group(context, "advanced", "Advanced:",
+ "Show advanced option help", advanced_entries);
+ pcmk__add_arg_group(context, "additional", "Additional Options:",
+ "Show additional options", addl_entries);
+ return context;
+}
- } else if (rsc_cmd == 'M' && host_uname) {
- rc = cli_resource_move(rsc, rsc_id, host_uname, cib_conn, data_set);
+int
+main(int argc, char **argv)
+{
+ xmlNode *cib_xml_copy = NULL;
+ pe_resource_t *rsc = NULL;
- } else if (rsc_cmd == 'B' && host_uname) {
- pe_node_t *dest = pe_find_node(data_set->nodes, host_uname);
+ int rc = pcmk_rc_ok;
- if (dest == NULL) {
- rc = -pcmk_err_node_unknown;
- goto bail;
+ pcmk__common_args_t *args = pcmk__new_common_args(SUMMARY);
+ GOptionContext *context = NULL;
+ gchar **processed_args = NULL;
+
+ context = build_arg_context(args);
+ crm_log_cli_init("crm_resource");
+
+ processed_args = pcmk__cmdline_preproc(argv, "GINSTdginpstuv");
+
+ if (!g_option_context_parse_strv(context, &processed_args, &error)) {
+ fprintf(stderr, "%s: %s\n", g_get_prgname(), error->message);
+ exit_code = CRM_EX_USAGE;
+ goto done;
+ }
+
+ if (pcmk__str_any_of(options.extra_option, "--list-ocf-providers", "--list-ocf-alternatives",
+ "--list-standards", NULL)) {
+ rc = list_providers(options.extra_option, options.extra_arg, &exit_code);
+ goto done;
+ } else if (safe_str_eq(options.extra_option, "--show-metadata")) {
+ rc = show_metadata(options.extra_arg, &exit_code);
+ goto done;
+ } else if (safe_str_eq(options.extra_option, "--list-agents")) {
+ rc = list_agents(options.extra_arg, &exit_code);
+ goto done;
+ } else if (safe_str_eq(options.extra_option, "--option")) {
+ rc = set_option(options.extra_arg);
+ if (rc != pcmk_rc_ok) {
+ goto done;
}
- rc = cli_resource_ban(rsc_id, dest->details->uname, NULL, cib_conn);
+ }
- } else if (rsc_cmd == 'B' || rsc_cmd == 'M') {
- pe_node_t *current = NULL;
- unsigned int nactive = 0;
+ for (int i = 0; i < args->verbosity; i++) {
+ crm_bump_log_level(argc, argv);
+ }
- current = pe__find_active_requires(rsc, &nactive);
+ options.resource_verbose = args->verbosity;
+ BE_QUIET = args->quiet;
- if (nactive == 1) {
- rc = cli_resource_ban(rsc_id, current->details->uname, NULL, cib_conn);
+ options.validate_options = crm_str_table_new();
+ crm_log_args(argc, argv);
- } else if (is_set(rsc->flags, pe_rsc_promotable)) {
- int count = 0;
- GListPtr iter = NULL;
+ if (options.host_uname) {
+ crm_trace("Option host => %s", options.host_uname);
+ }
- current = NULL;
- for(iter = rsc->children; iter; iter = iter->next) {
- pe_resource_t *child = (pe_resource_t *)iter->data;
- enum rsc_role_e child_role = child->fns->state(child, TRUE);
+ // Catch the case where the user didn't specify a command
+ if (options.rsc_cmd == 'L') {
+ options.require_resource = FALSE;
+ }
- if(child_role == RSC_ROLE_MASTER) {
- count++;
- current = pe__current_node(child);
- }
- }
+ // --expired without --clear/-U doesn't make sense
+ if (options.clear_expired && options.rsc_cmd != 'U') {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE, "--expired requires --clear or -U");
+ goto done;
+ }
+
+ if (options.remainder && options.rsc_cmd == 0 && options.rsc_long_cmd) {
+ options.override_params = crm_str_table_new();
+
+ for (gchar **s = options.remainder; *s; s++) {
+ char *name = calloc(1, strlen(*s));
+ char *value = calloc(1, strlen(*s));
+ int rc = sscanf(*s, "%[^=]=%s", name, value);
- if(count == 1 && current) {
- rc = cli_resource_ban(rsc_id, current->details->uname, NULL, cib_conn);
+ if (rc == 2) {
+ g_hash_table_replace(options.override_params, name, value);
} else {
- rc = -EINVAL;
- exit_code = CRM_EX_USAGE;
- CMD_ERR("Resource '%s' not moved: active in %d locations (promoted in %d).",
- rsc_id, nactive, count);
- CMD_ERR("To prevent '%s' from running on a specific location, "
- "specify a node.", rsc_id);
- CMD_ERR("To prevent '%s' from being promoted at a specific "
- "location, specify a node and the master option.",
- rsc_id);
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "Error parsing '%s' as a name=value pair for --%s", argv[optind], options.rsc_long_cmd);
+ free(value);
+ free(name);
+ goto done;
}
+ }
- } else {
- rc = -EINVAL;
- exit_code = CRM_EX_USAGE;
- CMD_ERR("Resource '%s' not moved: active in %d locations.", rsc_id, nactive);
- CMD_ERR("To prevent '%s' from running on a specific location, "
- "specify a node.", rsc_id);
+ } else if (options.remainder && options.rsc_cmd == 0) {
+ gchar **strv = NULL;
+ gchar *msg = NULL;
+ int i = 1;
+ int len = 0;
+
+ for (gchar **s = options.remainder; *s; s++) {
+ len++;
}
- } else if (rsc_cmd == 'G') {
- rc = cli_resource_print_property(rsc, prop_name, data_set);
+ strv = calloc(len, sizeof(char *));
+ strv[0] = strdup("non-option ARGV-elements:");
- } else if (rsc_cmd == 'S') {
- xmlNode *msg_data = NULL;
+ for (gchar **s = options.remainder; *s; s++) {
+ strv[i] = crm_strdup_printf("[%d of %d] %s\n", i, len, *s);
+ i++;
+ }
- if ((rsc_type == NULL) || !strlen(rsc_type)) {
- CMD_ERR("Must specify -t with resource type");
- rc = -ENXIO;
- goto bail;
+ msg = g_strjoinv("", strv);
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE, "%s", msg);
- } else if ((prop_value == NULL) || !strlen(prop_value)) {
- CMD_ERR("Must supply -v with new value");
- rc = -EINVAL;
- goto bail;
+ for(i = 0; i < len; i++) {
+ free(strv[i]);
}
- CRM_LOG_ASSERT(prop_name != NULL);
+ g_free(msg);
+ g_free(strv);
+ goto done;
+ }
- msg_data = create_xml_node(NULL, rsc_type);
- crm_xml_add(msg_data, XML_ATTR_ID, rsc_id);
- crm_xml_add(msg_data, prop_name, prop_value);
+ if (args->version) {
+ /* FIXME: When crm_resource is converted to use formatted output, this can go. */
+ pcmk__cli_help('v', CRM_EX_USAGE);
+ }
- rc = cib_conn->cmds->modify(cib_conn, XML_CIB_TAG_RESOURCES, msg_data, cib_options);
- free_xml(msg_data);
+ if (optind > argc) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "Invalid option(s) supplied, use --help for valid usage");
+ exit_code = CRM_EX_USAGE;
+ goto done;
+ }
- } else if (rsc_cmd == 'g') {
- rc = cli_resource_print_attribute(rsc, prop_name, data_set);
+ // Sanity check validating from command line parameters. If everything checks out,
+ // go ahead and run the validation. This way we don't need a CIB connection.
+ if (options.validate_cmdline) {
+ validate_cmdline(&exit_code);
+ goto done;
+ }
- } else if (rsc_cmd == 'p') {
- if (prop_value == NULL || strlen(prop_value) == 0) {
- CMD_ERR("You need to supply a value with the -v option");
- rc = -EINVAL;
- goto bail;
- }
+ if (error != NULL) {
+ exit_code = CRM_EX_USAGE;
+ goto done;
+ }
- /* coverity[var_deref_model] False positive */
- rc = cli_resource_update_attribute(rsc, rsc_id, prop_set, prop_id,
- prop_name, prop_value, recursive,
- cib_conn, data_set);
+ if (options.force) {
+ crm_debug("Forcing...");
+ options.cib_options |= cib_quorum_override;
+ }
- } else if (rsc_cmd == 'd') {
- /* coverity[var_deref_model] False positive */
- rc = cli_resource_delete_attribute(rsc, rsc_id, prop_set, prop_id,
- prop_name, cib_conn, data_set);
+ if (options.require_resource && !options.rsc_id) {
+ rc = ENXIO;
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "Must supply a resource id with -r");
+ goto done;
+ }
- } else if ((rsc_cmd == 'C') && rsc) {
- if (do_force == FALSE) {
- rsc = uber_parent(rsc);
- }
+ if (options.find_flags && options.rsc_id) {
+ options.require_dataset = TRUE;
+ }
- crm_debug("Erasing failures of %s (%s requested) on %s",
- rsc->id, rsc_id, (host_uname? host_uname: "all nodes"));
- rc = cli_resource_delete(controld_api, host_uname, rsc, operation,
- interval_spec, TRUE, data_set);
+ // Establish a connection to the CIB
+ cib_conn = cib_new();
+ if ((cib_conn == NULL) || (cib_conn->cmds == NULL)) {
+ rc = pcmk_rc_error;
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_DISCONNECT,
+ "Could not create CIB connection");
+ goto done;
+ }
+ rc = cib_conn->cmds->signon(cib_conn, crm_system_name, cib_command);
+ rc = pcmk_legacy2rc(rc);
+ if (rc != pcmk_rc_ok) {
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "Could not connect to the CIB: %s", pcmk_rc_str(rc));
+ goto done;
+ }
- if ((rc == pcmk_ok) && !BE_QUIET) {
- // Show any reasons why resource might stay stopped
- cli_resource_check(cib_conn, rsc);
+ /* Populate working set from XML file if specified or CIB query otherwise */
+ if (options.require_dataset) {
+ rc = populate_working_set(&cib_xml_copy);
+ if (rc != pcmk_rc_ok) {
+ goto done;
}
+ }
- if (rc == pcmk_ok) {
- start_mainloop(controld_api);
+ // If command requires that resource exist if specified, find it
+ if (options.find_flags && options.rsc_id) {
+ rsc = pe_find_resource_with_flags(data_set->resources, options.rsc_id,
+ options.find_flags);
+ if (rsc == NULL) {
+ rc = ENXIO;
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "Resource '%s' not found", options.rsc_id);
+ goto done;
}
+ }
- } else if (rsc_cmd == 'C') {
- rc = cli_cleanup_all(controld_api, host_uname, operation, interval_spec,
- data_set);
- if (rc == pcmk_ok) {
- start_mainloop(controld_api);
+ // Establish a connection to the controller if needed
+ if (options.require_crmd) {
+ rc = pcmk_new_ipc_api(&controld_api, pcmk_ipc_controld);
+ if (rc != pcmk_rc_ok) {
+ CMD_ERR("Error connecting to the controller: %s", pcmk_rc_str(rc));
+ goto done;
}
-
- } else if ((rsc_cmd == 'R') && rsc) {
- if (do_force == FALSE) {
- rsc = uber_parent(rsc);
+ pcmk_register_ipc_callback(controld_api, controller_event_callback,
+ NULL);
+ rc = pcmk_connect_ipc(controld_api, pcmk_ipc_dispatch_main);
+ if (rc != pcmk_rc_ok) {
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "Error connecting to the controller: %s", pcmk_rc_str(rc));
+ goto done;
}
+ }
+
+ /* Handle rsc_cmd appropriately */
+ if (options.rsc_cmd == 'L') {
+ rc = pcmk_rc_ok;
+ cli_resource_print_list(data_set, FALSE);
- crm_debug("Re-checking the state of %s (%s requested) on %s",
- rsc->id, rsc_id, (host_uname? host_uname: "all nodes"));
- rc = cli_resource_delete(controld_api, host_uname, rsc, NULL, 0, FALSE,
- data_set);
+ } else if (options.rsc_cmd == 'l') {
+ rc = list_raw();
- if ((rc == pcmk_ok) && !BE_QUIET) {
- // Show any reasons why resource might stay stopped
- cli_resource_check(cib_conn, rsc);
+ } else if (options.rsc_cmd == 0 && options.rsc_long_cmd && safe_str_eq(options.rsc_long_cmd, "restart")) {
+ /* We don't pass data_set because rsc needs to stay valid for the entire
+ * lifetime of cli_resource_restart(), but it will reset and update the
+ * working set multiple times, so it needs to use its own copy.
+ */
+ rc = cli_resource_restart(rsc, options.host_uname, options.timeout_ms,
+ cib_conn, options.cib_options, options.promoted_role_only,
+ options.force);
+
+ } else if (options.rsc_cmd == 0 && options.rsc_long_cmd && safe_str_eq(options.rsc_long_cmd, "wait")) {
+ rc = wait_till_stable(options.timeout_ms, cib_conn);
+
+ } else if (options.rsc_cmd == 0 && options.rsc_long_cmd) {
+ // validate, force-(stop|start|demote|promote|check)
+ exit_code = cli_resource_execute(rsc, options.rsc_id, options.rsc_long_cmd, options.override_params,
+ options.timeout_ms, cib_conn, data_set, options.resource_verbose,
+ options.force);
+
+ } else if (options.rsc_cmd == 'A' || options.rsc_cmd == 'a') {
+ list_stacks_and_constraints(rsc);
+
+ } else if (options.rsc_cmd == 'c') {
+ GListPtr lpc = NULL;
+
+ rc = pcmk_rc_ok;
+ for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
+ rsc = (pe_resource_t *) lpc->data;
+ cli_resource_print_cts(rsc);
}
+ cli_resource_print_cts_constraints(data_set);
- if (rc == pcmk_ok) {
+ } else if (options.rsc_cmd == 'F') {
+ rc = cli_resource_fail(controld_api, options.host_uname, options.rsc_id, data_set);
+ if (rc == pcmk_rc_ok) {
start_mainloop(controld_api);
}
- } else if (rsc_cmd == 'R') {
- const char *router_node = host_uname;
- int attr_options = pcmk__node_attr_none;
+ } else if (options.rsc_cmd == 'O') {
+ rc = cli_resource_print_operations(options.rsc_id, options.host_uname, TRUE, data_set);
- if (host_uname) {
- pe_node_t *node = pe_find_node(data_set->nodes, host_uname);
+ } else if (options.rsc_cmd == 'o') {
+ rc = cli_resource_print_operations(options.rsc_id, options.host_uname, FALSE, data_set);
- if (pe__is_guest_or_remote_node(node)) {
- node = pe__current_node(node->details->remote_rsc);
- if (node == NULL) {
- CMD_ERR("No cluster connection to Pacemaker Remote node %s detected",
- host_uname);
- rc = -ENXIO;
- goto bail;
- }
- router_node = node->details->uname;
- attr_options |= pcmk__node_attr_remote;
+ } else if (options.rsc_cmd == 'W') {
+ rc = cli_resource_search(rsc, options.rsc_id, data_set);
+ if (rc >= 0) {
+ rc = pcmk_rc_ok;
+ }
+
+ } else if (options.rsc_cmd == 'q') {
+ rc = cli_resource_print(rsc, data_set, TRUE);
+
+ } else if (options.rsc_cmd == 'w') {
+ rc = cli_resource_print(rsc, data_set, FALSE);
+
+ } else if (options.rsc_cmd == 'Y') {
+ pe_node_t *dest = NULL;
+
+ if (options.host_uname) {
+ dest = pe_find_node(data_set->nodes, options.host_uname);
+ if (dest == NULL) {
+ rc = pcmk_rc_node_unknown;
+ goto done;
}
}
+ cli_resource_why(cib_conn, data_set->resources, rsc, dest);
+ rc = pcmk_rc_ok;
- if (controld_api == NULL) {
- printf("Dry run: skipping clean-up of %s due to CIB_file\n",
- host_uname? host_uname : "all nodes");
- rc = pcmk_ok;
- goto bail;
+ } else if (options.rsc_cmd == 'U') {
+ rc = clear_constraints(&cib_xml_copy);
+
+ } else if (options.rsc_cmd == 'M' && options.host_uname) {
+ rc = cli_resource_move(rsc, options.rsc_id, options.host_uname, cib_conn,
+ options.cib_options, data_set, options.promoted_role_only,
+ options.force);
+
+ } else if (options.rsc_cmd == 'B' && options.host_uname) {
+ pe_node_t *dest = pe_find_node(data_set->nodes, options.host_uname);
+
+ if (dest == NULL) {
+ rc = pcmk_rc_node_unknown;
+ goto done;
}
+ rc = cli_resource_ban(options.rsc_id, dest->details->uname, NULL,
+ cib_conn, options.cib_options, options.promoted_role_only);
- crm_debug("Re-checking the state of all resources on %s", host_uname?host_uname:"all nodes");
+ } else if (options.rsc_cmd == 'B' || options.rsc_cmd == 'M') {
+ rc = ban_or_move(rsc, &exit_code);
- rc = pcmk_rc2legacy(pcmk__node_attr_request_clear(NULL, host_uname,
- NULL, NULL, NULL,
- NULL, attr_options));
+ } else if (options.rsc_cmd == 'G') {
+ rc = cli_resource_print_property(rsc, options.prop_name, data_set);
- if (pcmk_controld_api_reprobe(controld_api, host_uname,
- router_node) == pcmk_rc_ok) {
- start_mainloop(controld_api);
+ } else if (options.rsc_cmd == 'S') {
+ rc = set_property();
+
+ } else if (options.rsc_cmd == 'g') {
+ rc = cli_resource_print_attribute(rsc, options.prop_name, options.attr_set_type, data_set);
+
+ } else if (options.rsc_cmd == 'p') {
+ if (options.prop_value == NULL || strlen(options.prop_value) == 0) {
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "You need to supply a value with the -v option");
+ rc = EINVAL;
+ goto done;
}
- } else if (rsc_cmd == 'D') {
- xmlNode *msg_data = NULL;
+ /* coverity[var_deref_model] False positive */
+ rc = cli_resource_update_attribute(rsc, options.rsc_id, options.prop_set, options.attr_set_type,
+ options.prop_id, options.prop_name, options.prop_value,
+ options.recursive, cib_conn, options.cib_options, data_set,
+ options.force);
+
+ } else if (options.rsc_cmd == 'd') {
+ /* coverity[var_deref_model] False positive */
+ rc = cli_resource_delete_attribute(rsc, options.rsc_id, options.prop_set, options.attr_set_type,
+ options.prop_id, options.prop_name, cib_conn,
+ options.cib_options, data_set, options.force);
- if (rsc_type == NULL) {
- CMD_ERR("You need to specify a resource type with -t");
- rc = -ENXIO;
- goto bail;
+ } else if ((options.rsc_cmd == 'C') && rsc) {
+ cleanup(rsc);
+
+ } else if (options.rsc_cmd == 'C') {
+ rc = cli_cleanup_all(controld_api, options.host_uname, options.operation, options.interval_spec,
+ data_set);
+ if (rc == pcmk_rc_ok) {
+ start_mainloop(controld_api);
}
- msg_data = create_xml_node(NULL, rsc_type);
- crm_xml_add(msg_data, XML_ATTR_ID, rsc_id);
+ } else if ((options.rsc_cmd == 'R') && rsc) {
+ refresh_resource(rsc);
+
+ } else if (options.rsc_cmd == 'R') {
+ rc = refresh();
- rc = cib_conn->cmds->remove(cib_conn, XML_CIB_TAG_RESOURCES, msg_data, cib_options);
- free_xml(msg_data);
+ } else if (options.rsc_cmd == 'D') {
+ rc = delete();
} else {
- CMD_ERR("Unknown command: %c", rsc_cmd);
+ g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE,
+ "Unknown command: %c", options.rsc_cmd);
}
- bail:
-
- if (is_ocf_rc) {
- exit_code = rc;
+done:
+ if (rc != pcmk_rc_ok) {
+ if (rc == pcmk_rc_no_quorum) {
+ g_prefix_error(&error, "To ignore quorum, use the force option.\n");
+ }
- } else if (rc != pcmk_ok) {
- CMD_ERR("Error performing operation: %s", pcmk_strerror(rc));
- if (rc == -pcmk_err_no_quorum) {
- CMD_ERR("To ignore quorum, use the force option");
+ if (error != NULL) {
+ char *msg = crm_strdup_printf("%s\nError performing operation: %s",
+ error->message, pcmk_rc_str(rc));
+ g_clear_error(&error);
+ g_set_error(&error, PCMK__RC_ERROR, rc, "%s", msg);
+ free(msg);
+ } else {
+ g_set_error(&error, PCMK__RC_ERROR, rc,
+ "Error performing operation: %s", pcmk_rc_str(rc));
}
+
if (exit_code == CRM_EX_OK) {
- exit_code = crm_errno2exit(rc);
+ exit_code = pcmk_rc2exitc(rc);
}
}
+ free(options.extra_arg);
+ free(options.extra_option);
+ free(options.host_uname);
+ free(options.interval_spec);
+ free(options.operation);
+ free(options.prop_id);
+ free(options.prop_name);
+ free(options.prop_set);
+ free(options.prop_value);
+ free(options.rsc_id);
+ free(options.rsc_long_cmd);
+ free(options.rsc_type);
+ free(options.v_agent);
+ free(options.v_class);
+ free(options.v_provider);
+ free(options.xml_file);
+
+ if (options.remainder) {
+ for (gchar **s = options.remainder; *s; s++) {
+ g_free(*s);
+ }
+ }
+
+ if (options.override_params != NULL) {
+ g_hash_table_destroy(options.override_params);
+ }
+
+ /* options.validate_options does not need to be destroyed here. See the
+ * comments in cli_resource_execute_from_params.
+ */
+
+ g_strfreev(processed_args);
+ g_option_context_free(context);
+
return bye(exit_code);
}
diff --git a/tools/crm_resource.h b/tools/crm_resource.h
index cb7f506f3b..c479b6231e 100644
--- a/tools/crm_resource.h
+++ b/tools/crm_resource.h
@@ -1,104 +1,102 @@
/*
* Copyright 2004-2020 the Pacemaker project contributors
*
* The version control history for this file may have further details.
*
* This source code is licensed under the GNU Lesser General Public License
* version 2.1 or later (LGPLv2.1+) WITHOUT ANY WARRANTY.
*/
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
-extern bool print_pending;
-
-extern bool scope_master;
-extern bool do_force;
extern bool BE_QUIET;
-extern int resource_verbose;
-
-extern int cib_options;
extern char *move_lifetime;
-extern const char *attr_set_type;
-
/* ban */
-int cli_resource_prefer(const char *rsc_id, const char *host, cib_t * cib_conn);
-int cli_resource_ban(const char *rsc_id, const char *host, GListPtr allnodes, cib_t * cib_conn);
-int cli_resource_clear(const char *rsc_id, const char *host, GListPtr allnodes, cib_t * cib_conn,
- bool clear_ban_constraints);
-int cli_resource_clear_all_expired(xmlNode *root, cib_t *cib_conn, const char *rsc, const char *node, bool scope_master);
+int cli_resource_prefer(const char *rsc_id, const char *host, cib_t * cib_conn,
+ int cib_options, gboolean promoted_role_only);
+int cli_resource_ban(const char *rsc_id, const char *host, GListPtr allnodes,
+ cib_t * cib_conn, int cib_options, gboolean promoted_role_only);
+int cli_resource_clear(const char *rsc_id, const char *host, GListPtr allnodes,
+ cib_t * cib_conn, int cib_options, bool clear_ban_constraints, gboolean force);
+int cli_resource_clear_all_expired(xmlNode *root, cib_t *cib_conn, int cib_options,
+ const char *rsc, const char *node, gboolean promoted_role_only);
/* print */
void cli_resource_print_cts(pe_resource_t * rsc);
void cli_resource_print_raw(pe_resource_t * rsc);
void cli_resource_print_cts_constraints(pe_working_set_t * data_set);
void cli_resource_print_location(pe_resource_t * rsc, const char *prefix);
void cli_resource_print_colocation(pe_resource_t * rsc, bool dependents, bool recursive, int offset);
int cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set,
bool expanded);
int cli_resource_print_list(pe_working_set_t * data_set, bool raw);
-int cli_resource_print_attribute(pe_resource_t *rsc, const char *attr,
+int cli_resource_print_attribute(pe_resource_t *rsc, const char *attr, const char *attr_set_type,
pe_working_set_t *data_set);
int cli_resource_print_property(pe_resource_t *rsc, const char *attr,
pe_working_set_t *data_set);
int cli_resource_print_operations(const char *rsc_id, const char *host_uname, bool active, pe_working_set_t * data_set);
/* runtime */
void cli_resource_check(cib_t * cib, pe_resource_t *rsc);
int cli_resource_fail(pcmk_ipc_api_t *controld_api,
const char *host_uname, const char *rsc_id,
pe_working_set_t *data_set);
int cli_resource_search(pe_resource_t *rsc, const char *requested_name,
pe_working_set_t *data_set);
int cli_resource_delete(pcmk_ipc_api_t *controld_api,
const char *host_uname, pe_resource_t *rsc,
const char *operation, const char *interval_spec,
- bool just_failures, pe_working_set_t *data_set);
+ bool just_failures, pe_working_set_t *data_set,
+ gboolean force);
int cli_cleanup_all(pcmk_ipc_api_t *controld_api, const char *node_name,
const char *operation, const char *interval_spec,
pe_working_set_t *data_set);
int cli_resource_restart(pe_resource_t *rsc, const char *host, int timeout_ms,
- cib_t *cib);
+ cib_t *cib, int cib_options, gboolean promoted_role_only,
+ gboolean force);
int cli_resource_move(pe_resource_t *rsc, const char *rsc_id,
- const char *host_name, cib_t *cib,
- pe_working_set_t *data_set);
-int cli_resource_execute_from_params(const char *rsc_name, const char *rsc_class,
- const char *rsc_prov, const char *rsc_type,
- const char *rsc_action, GHashTable *params,
- GHashTable *override_hash, int timeout_ms);
-int cli_resource_execute(pe_resource_t *rsc, const char *requested_name,
- const char *rsc_action, GHashTable *override_hash,
- int timeout_ms, cib_t *cib,
- pe_working_set_t *data_set);
+ const char *host_name, cib_t *cib, int cib_options,
+ pe_working_set_t *data_set, gboolean promoted_role_only,
+ gboolean force);
+crm_exit_t cli_resource_execute_from_params(const char *rsc_name, const char *rsc_class,
+ const char *rsc_prov, const char *rsc_type,
+ const char *rsc_action, GHashTable *params,
+ GHashTable *override_hash, int timeout_ms,
+ int resource_verbose, gboolean force);
+crm_exit_t cli_resource_execute(pe_resource_t *rsc, const char *requested_name,
+ const char *rsc_action, GHashTable *override_hash,
+ int timeout_ms, cib_t *cib, pe_working_set_t *data_set,
+ int resource_verbose, gboolean force);
int cli_resource_update_attribute(pe_resource_t *rsc, const char *requested_name,
- const char *attr_set, const char *attr_id,
- const char *attr_name, const char *attr_value,
- bool recursive, cib_t *cib,
- pe_working_set_t *data_set);
+ const char *attr_set, const char *attr_set_type,
+ const char *attr_id, const char *attr_name,
+ const char *attr_value, gboolean recursive, cib_t *cib,
+ int cib_options, pe_working_set_t *data_set, gboolean force);
int cli_resource_delete_attribute(pe_resource_t *rsc, const char *requested_name,
- const char *attr_set, const char *attr_id,
- const char *attr_name, cib_t *cib,
- pe_working_set_t *data_set);
+ const char *attr_set, const char *attr_set_type,
+ const char *attr_id, const char *attr_name, cib_t *cib,
+ int cib_options, pe_working_set_t *data_set, gboolean force);
GList* subtract_lists(GList *from, GList *items, GCompareFunc cmp);
int update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml);
int wait_till_stable(int timeout_ms, cib_t * cib);
void cli_resource_why(cib_t *cib_conn, GListPtr resources, pe_resource_t *rsc,
pe_node_t *node);
diff --git a/tools/crm_resource_ban.c b/tools/crm_resource_ban.c
index f74712405b..0b18aaa9b9 100644
--- a/tools/crm_resource_ban.c
+++ b/tools/crm_resource_ban.c
@@ -1,441 +1,462 @@
/*
* Copyright 2004-2020 the Pacemaker project contributors
*
* The version control history for this file may have further details.
*
* This source code is licensed under the GNU General Public License version 2
* or later (GPLv2+) WITHOUT ANY WARRANTY.
*/
#include
#define XPATH_MAX 1024
char *move_lifetime = NULL;
static char *
parse_cli_lifetime(const char *input)
{
char *later_s = NULL;
crm_time_t *now = NULL;
crm_time_t *later = NULL;
crm_time_t *duration = NULL;
if (input == NULL) {
return NULL;
}
duration = crm_time_parse_duration(move_lifetime);
if (duration == NULL) {
CMD_ERR("Invalid duration specified: %s", move_lifetime);
CMD_ERR("Please refer to"
" https://en.wikipedia.org/wiki/ISO_8601#Durations"
" for examples of valid durations");
return NULL;
}
now = crm_time_new(NULL);
later = crm_time_add(now, duration);
if (later == NULL) {
CMD_ERR("Unable to add %s to current time", move_lifetime);
CMD_ERR("Please report to " PACKAGE_BUGREPORT " as possible bug");
crm_time_free(now);
crm_time_free(duration);
return NULL;
}
crm_time_log(LOG_INFO, "now ", now,
crm_time_log_date | crm_time_log_timeofday | crm_time_log_with_timezone);
crm_time_log(LOG_INFO, "later ", later,
crm_time_log_date | crm_time_log_timeofday | crm_time_log_with_timezone);
crm_time_log(LOG_INFO, "duration", duration, crm_time_log_date | crm_time_log_timeofday);
later_s = crm_time_as_string(later, crm_time_log_date | crm_time_log_timeofday | crm_time_log_with_timezone);
printf("Migration will take effect until: %s\n", later_s);
crm_time_free(duration);
crm_time_free(later);
crm_time_free(now);
return later_s;
}
+// \return Standard Pacemaker return code
int
-cli_resource_ban(const char *rsc_id, const char *host, GListPtr allnodes, cib_t * cib_conn)
+cli_resource_ban(const char *rsc_id, const char *host, GListPtr allnodes, cib_t * cib_conn,
+ int cib_options, gboolean promoted_role_only)
{
char *later_s = NULL;
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
xmlNode *fragment = NULL;
xmlNode *location = NULL;
if(host == NULL) {
GListPtr n = allnodes;
- for(; n && rc == pcmk_ok; n = n->next) {
+ for(; n && rc == pcmk_rc_ok; n = n->next) {
pe_node_t *target = n->data;
- rc = cli_resource_ban(rsc_id, target->details->uname, NULL, cib_conn);
+ rc = cli_resource_ban(rsc_id, target->details->uname, NULL, cib_conn,
+ cib_options, promoted_role_only);
}
return rc;
}
later_s = parse_cli_lifetime(move_lifetime);
if(move_lifetime && later_s == NULL) {
- return -EINVAL;
+ return EINVAL;
}
fragment = create_xml_node(NULL, XML_CIB_TAG_CONSTRAINTS);
location = create_xml_node(fragment, XML_CONS_TAG_RSC_LOCATION);
crm_xml_set_id(location, "cli-ban-%s-on-%s", rsc_id, host);
if (BE_QUIET == FALSE) {
CMD_ERR("WARNING: Creating rsc_location constraint '%s'"
" with a score of -INFINITY for resource %s"
" on %s.", ID(location), rsc_id, host);
CMD_ERR("\tThis will prevent %s from %s on %s until the constraint "
"is removed using the clear option or by editing the CIB "
"with an appropriate tool",
- rsc_id, (scope_master? "being promoted" : "running"), host);
+ rsc_id, (promoted_role_only? "being promoted" : "running"), host);
CMD_ERR("\tThis will be the case even if %s is"
" the last node in the cluster", host);
}
crm_xml_add(location, XML_LOC_ATTR_SOURCE, rsc_id);
- if(scope_master) {
+ if(promoted_role_only) {
crm_xml_add(location, XML_RULE_ATTR_ROLE, RSC_ROLE_MASTER_S);
} else {
crm_xml_add(location, XML_RULE_ATTR_ROLE, RSC_ROLE_STARTED_S);
}
if (later_s == NULL) {
/* Short form */
crm_xml_add(location, XML_CIB_TAG_NODE, host);
crm_xml_add(location, XML_RULE_ATTR_SCORE, CRM_MINUS_INFINITY_S);
} else {
xmlNode *rule = create_xml_node(location, XML_TAG_RULE);
xmlNode *expr = create_xml_node(rule, XML_TAG_EXPRESSION);
crm_xml_set_id(rule, "cli-ban-%s-on-%s-rule", rsc_id, host);
crm_xml_add(rule, XML_RULE_ATTR_SCORE, CRM_MINUS_INFINITY_S);
crm_xml_add(rule, XML_RULE_ATTR_BOOLEAN_OP, "and");
crm_xml_set_id(expr, "cli-ban-%s-on-%s-expr", rsc_id, host);
crm_xml_add(expr, XML_EXPR_ATTR_ATTRIBUTE, CRM_ATTR_UNAME);
crm_xml_add(expr, XML_EXPR_ATTR_OPERATION, "eq");
crm_xml_add(expr, XML_EXPR_ATTR_VALUE, host);
crm_xml_add(expr, XML_EXPR_ATTR_TYPE, "string");
expr = create_xml_node(rule, "date_expression");
crm_xml_set_id(expr, "cli-ban-%s-on-%s-lifetime", rsc_id, host);
crm_xml_add(expr, "operation", "lt");
crm_xml_add(expr, "end", later_s);
}
crm_log_xml_notice(fragment, "Modify");
rc = cib_conn->cmds->update(cib_conn, XML_CIB_TAG_CONSTRAINTS, fragment, cib_options);
+ rc = pcmk_legacy2rc(rc);
free_xml(fragment);
free(later_s);
return rc;
}
-
+// \return Standard Pacemaker return code
int
-cli_resource_prefer(const char *rsc_id, const char *host, cib_t * cib_conn)
+cli_resource_prefer(const char *rsc_id, const char *host, cib_t * cib_conn,
+ int cib_options, gboolean promoted_role_only)
{
char *later_s = parse_cli_lifetime(move_lifetime);
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
xmlNode *location = NULL;
xmlNode *fragment = NULL;
if(move_lifetime && later_s == NULL) {
- return -EINVAL;
+ return EINVAL;
}
if(cib_conn == NULL) {
free(later_s);
- return -ENOTCONN;
+ return ENOTCONN;
}
fragment = create_xml_node(NULL, XML_CIB_TAG_CONSTRAINTS);
location = create_xml_node(fragment, XML_CONS_TAG_RSC_LOCATION);
crm_xml_set_id(location, "cli-prefer-%s", rsc_id);
crm_xml_add(location, XML_LOC_ATTR_SOURCE, rsc_id);
- if(scope_master) {
+ if(promoted_role_only) {
crm_xml_add(location, XML_RULE_ATTR_ROLE, RSC_ROLE_MASTER_S);
} else {
crm_xml_add(location, XML_RULE_ATTR_ROLE, RSC_ROLE_STARTED_S);
}
if (later_s == NULL) {
/* Short form */
crm_xml_add(location, XML_CIB_TAG_NODE, host);
crm_xml_add(location, XML_RULE_ATTR_SCORE, CRM_INFINITY_S);
} else {
xmlNode *rule = create_xml_node(location, XML_TAG_RULE);
xmlNode *expr = create_xml_node(rule, XML_TAG_EXPRESSION);
crm_xml_set_id(rule, "cli-prefer-rule-%s", rsc_id);
crm_xml_add(rule, XML_RULE_ATTR_SCORE, CRM_INFINITY_S);
crm_xml_add(rule, XML_RULE_ATTR_BOOLEAN_OP, "and");
crm_xml_set_id(expr, "cli-prefer-expr-%s", rsc_id);
crm_xml_add(expr, XML_EXPR_ATTR_ATTRIBUTE, CRM_ATTR_UNAME);
crm_xml_add(expr, XML_EXPR_ATTR_OPERATION, "eq");
crm_xml_add(expr, XML_EXPR_ATTR_VALUE, host);
crm_xml_add(expr, XML_EXPR_ATTR_TYPE, "string");
expr = create_xml_node(rule, "date_expression");
crm_xml_set_id(expr, "cli-prefer-lifetime-end-%s", rsc_id);
crm_xml_add(expr, "operation", "lt");
crm_xml_add(expr, "end", later_s);
}
crm_log_xml_info(fragment, "Modify");
rc = cib_conn->cmds->update(cib_conn, XML_CIB_TAG_CONSTRAINTS, fragment, cib_options);
+ rc = pcmk_legacy2rc(rc);
free_xml(fragment);
free(later_s);
return rc;
}
/* Nodes can be specified two different ways in the CIB, so we have two different
* functions to try clearing out any constraints on them:
*
* (1) The node could be given by attribute=/value= in an expression XML node.
* That's what resource_clear_node_in_expr handles. That XML looks like this:
*
*
*
*
*
*
*
*
* (2) The mode could be given by node= in an rsc_location XML node. That's
* what resource_clear_node_in_location handles. That XML looks like this:
*
*
+ *
+ * \return Standard Pacemaker return code
*/
static int
-resource_clear_node_in_expr(const char *rsc_id, const char *host, cib_t * cib_conn)
+resource_clear_node_in_expr(const char *rsc_id, const char *host, cib_t * cib_conn,
+ int cib_options)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
char *xpath_string = NULL;
xpath_string = crm_strdup_printf("//rsc_location[@id='cli-prefer-%s'][rule[@id='cli-prefer-rule-%s']/expression[@attribute='#uname' and @value='%s']]",
rsc_id, rsc_id, host);
rc = cib_conn->cmds->remove(cib_conn, xpath_string, NULL, cib_xpath | cib_options);
if (rc == -ENXIO) {
- rc = pcmk_ok;
+ rc = pcmk_rc_ok;
+ } else {
+ rc = pcmk_legacy2rc(rc);
}
free(xpath_string);
return rc;
}
+// \return Standard Pacemaker return code
static int
resource_clear_node_in_location(const char *rsc_id, const char *host, cib_t * cib_conn,
- bool clear_ban_constraints)
+ int cib_options, bool clear_ban_constraints, gboolean force)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
xmlNode *fragment = NULL;
xmlNode *location = NULL;
fragment = create_xml_node(NULL, XML_CIB_TAG_CONSTRAINTS);
if (clear_ban_constraints == TRUE) {
location = create_xml_node(fragment, XML_CONS_TAG_RSC_LOCATION);
crm_xml_set_id(location, "cli-ban-%s-on-%s", rsc_id, host);
}
location = create_xml_node(fragment, XML_CONS_TAG_RSC_LOCATION);
crm_xml_set_id(location, "cli-prefer-%s", rsc_id);
- if (do_force == FALSE) {
+ if (force == FALSE) {
crm_xml_add(location, XML_CIB_TAG_NODE, host);
}
crm_log_xml_info(fragment, "Delete");
rc = cib_conn->cmds->remove(cib_conn, XML_CIB_TAG_CONSTRAINTS, fragment, cib_options);
if (rc == -ENXIO) {
- rc = pcmk_ok;
+ rc = pcmk_rc_ok;
+ } else {
+ rc = pcmk_legacy2rc(rc);
}
free(fragment);
return rc;
}
+// \return Standard Pacemaker return code
int
cli_resource_clear(const char *rsc_id, const char *host, GListPtr allnodes, cib_t * cib_conn,
- bool clear_ban_constraints)
+ int cib_options, bool clear_ban_constraints, gboolean force)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
if(cib_conn == NULL) {
- return -ENOTCONN;
+ return ENOTCONN;
}
if (host) {
- rc = resource_clear_node_in_expr(rsc_id, host, cib_conn);
+ rc = resource_clear_node_in_expr(rsc_id, host, cib_conn, cib_options);
/* rc does not tell us whether the previous operation did anything, only
* whether it failed or not. Thus, as long as it did not fail, we need
* to try the second clear method.
*/
- if (rc == pcmk_ok) {
- rc = resource_clear_node_in_location(rsc_id, host, cib_conn, clear_ban_constraints);
+ if (rc == pcmk_rc_ok) {
+ rc = resource_clear_node_in_location(rsc_id, host, cib_conn,
+ cib_options, clear_ban_constraints,
+ force);
}
} else {
GListPtr n = allnodes;
/* Iterate over all nodes, attempting to clear the constraint from each.
* On the first error, abort.
*/
for(; n; n = n->next) {
pe_node_t *target = n->data;
- rc = cli_resource_clear(rsc_id, target->details->uname, NULL, cib_conn, clear_ban_constraints);
- if (rc != pcmk_ok) {
+ rc = cli_resource_clear(rsc_id, target->details->uname, NULL,
+ cib_conn, cib_options, clear_ban_constraints,
+ force);
+ if (rc != pcmk_rc_ok) {
break;
}
}
}
return rc;
}
static char *
-build_clear_xpath_string(xmlNode *constraint_node, const char *rsc, const char *node, bool scope_master)
+build_clear_xpath_string(xmlNode *constraint_node, const char *rsc, const char *node, gboolean promoted_role_only)
{
int offset = 0;
char *xpath_string = NULL;
char *first_half = NULL;
char *rsc_role_substr = NULL;
char *date_substr = NULL;
if (pcmk__starts_with(ID(constraint_node), "cli-ban-")) {
date_substr = crm_strdup_printf("//date_expression[@id='%s-lifetime']",
ID(constraint_node));
} else if (pcmk__starts_with(ID(constraint_node), "cli-prefer-")) {
date_substr = crm_strdup_printf("//date_expression[@id='cli-prefer-lifetime-end-%s']",
crm_element_value(constraint_node, "rsc"));
} else {
return NULL;
}
first_half = calloc(1, XPATH_MAX);
offset += snprintf(first_half + offset, XPATH_MAX - offset, "//rsc_location");
- if (node != NULL || rsc != NULL || scope_master == TRUE) {
+ if (node != NULL || rsc != NULL || promoted_role_only == TRUE) {
offset += snprintf(first_half + offset, XPATH_MAX - offset, "[");
if (node != NULL) {
- if (rsc != NULL || scope_master == TRUE) {
+ if (rsc != NULL || promoted_role_only == TRUE) {
offset += snprintf(first_half + offset, XPATH_MAX - offset, "@node='%s' and ", node);
} else {
offset += snprintf(first_half + offset, XPATH_MAX - offset, "@node='%s'", node);
}
}
- if (rsc != NULL && scope_master == TRUE) {
+ if (rsc != NULL && promoted_role_only == TRUE) {
rsc_role_substr = crm_strdup_printf("@rsc='%s' and @role='%s'", rsc, RSC_ROLE_MASTER_S);
offset += snprintf(first_half + offset, XPATH_MAX - offset, "@rsc='%s' and @role='%s']", rsc, RSC_ROLE_MASTER_S);
} else if (rsc != NULL) {
rsc_role_substr = crm_strdup_printf("@rsc='%s'", rsc);
offset += snprintf(first_half + offset, XPATH_MAX - offset, "@rsc='%s']", rsc);
- } else if (scope_master == TRUE) {
+ } else if (promoted_role_only == TRUE) {
rsc_role_substr = crm_strdup_printf("@role='%s'", RSC_ROLE_MASTER_S);
offset += snprintf(first_half + offset, XPATH_MAX - offset, "@role='%s']", RSC_ROLE_MASTER_S);
} else {
offset += snprintf(first_half + offset, XPATH_MAX - offset, "]");
}
}
if (node != NULL) {
if (rsc_role_substr != NULL) {
xpath_string = crm_strdup_printf("%s|//rsc_location[%s]/rule[expression[@attribute='#uname' and @value='%s']]%s",
first_half, rsc_role_substr, node, date_substr);
} else {
xpath_string = crm_strdup_printf("%s|//rsc_location/rule[expression[@attribute='#uname' and @value='%s']]%s",
first_half, node, date_substr);
}
} else {
xpath_string = crm_strdup_printf("%s%s", first_half, date_substr);
}
free(first_half);
free(date_substr);
free(rsc_role_substr);
return xpath_string;
}
+// \return Standard Pacemaker return code
int
-cli_resource_clear_all_expired(xmlNode *root, cib_t *cib_conn, const char *rsc, const char *node, bool scope_master)
+cli_resource_clear_all_expired(xmlNode *root, cib_t *cib_conn, int cib_options,
+ const char *rsc, const char *node, gboolean promoted_role_only)
{
xmlXPathObject *xpathObj = NULL;
xmlNode *cib_constraints = NULL;
crm_time_t *now = crm_time_new(NULL);
int i;
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, root);
xpathObj = xpath_search(cib_constraints, "//" XML_CONS_TAG_RSC_LOCATION);
for (i = 0; i < numXpathResults(xpathObj); i++) {
xmlNode *constraint_node = getXpathResult(xpathObj, i);
xmlNode *date_expr_node = NULL;
crm_time_t *end = NULL;
char *xpath_string = NULL;
- xpath_string = build_clear_xpath_string(constraint_node, rsc, node, scope_master);
+ xpath_string = build_clear_xpath_string(constraint_node, rsc, node, promoted_role_only);
if (xpath_string == NULL) {
continue;
}
date_expr_node = get_xpath_object(xpath_string, constraint_node, LOG_DEBUG);
if (date_expr_node == NULL) {
free(xpath_string);
continue;
}
/* And then finally, see if the date expression is expired. If so,
* clear the constraint.
*/
end = crm_time_new(crm_element_value(date_expr_node, "end"));
if (crm_time_compare(now, end) == 1) {
xmlNode *fragment = NULL;
xmlNode *location = NULL;
fragment = create_xml_node(NULL, XML_CIB_TAG_CONSTRAINTS);
location = create_xml_node(fragment, XML_CONS_TAG_RSC_LOCATION);
crm_xml_set_id(location, "%s", ID(constraint_node));
crm_log_xml_info(fragment, "Delete");
rc = cib_conn->cmds->remove(cib_conn, XML_CIB_TAG_CONSTRAINTS,
fragment, cib_options);
- if (rc != pcmk_ok) {
+ rc = pcmk_legacy2rc(rc);
+
+ if (rc != pcmk_rc_ok) {
free(xpath_string);
goto bail;
}
free_xml(fragment);
}
crm_time_free(end);
free(xpath_string);
}
- rc = pcmk_ok;
-
bail:
freeXpathObject(xpathObj);
crm_time_free(now);
return rc;
}
diff --git a/tools/crm_resource_print.c b/tools/crm_resource_print.c
index 8d77f979af..0e57d5d3b7 100644
--- a/tools/crm_resource_print.c
+++ b/tools/crm_resource_print.c
@@ -1,330 +1,335 @@
/*
* Copyright 2004-2020 the Pacemaker project contributors
*
* The version control history for this file may have further details.
*
* This source code is licensed under the GNU General Public License version 2
* or later (GPLv2+) WITHOUT ANY WARRANTY.
*/
#include
#define cons_string(x) x?x:"NA"
void
cli_resource_print_cts_constraints(pe_working_set_t * data_set)
{
xmlNode *xml_obj = NULL;
xmlNode *lifetime = NULL;
xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input);
for (xml_obj = __xml_first_child_element(cib_constraints); xml_obj != NULL;
xml_obj = __xml_next_element(xml_obj)) {
const char *id = crm_element_value(xml_obj, XML_ATTR_ID);
if (id == NULL) {
continue;
}
// @COMPAT lifetime is deprecated
lifetime = first_named_child(xml_obj, "lifetime");
if (pe_evaluate_rules(lifetime, NULL, data_set->now, NULL) == FALSE) {
continue;
}
if (safe_str_eq(XML_CONS_TAG_RSC_DEPEND, crm_element_name(xml_obj))) {
printf("Constraint %s %s %s %s %s %s %s\n",
crm_element_name(xml_obj),
cons_string(crm_element_value(xml_obj, XML_ATTR_ID)),
cons_string(crm_element_value(xml_obj, XML_COLOC_ATTR_SOURCE)),
cons_string(crm_element_value(xml_obj, XML_COLOC_ATTR_TARGET)),
cons_string(crm_element_value(xml_obj, XML_RULE_ATTR_SCORE)),
cons_string(crm_element_value(xml_obj, XML_COLOC_ATTR_SOURCE_ROLE)),
cons_string(crm_element_value(xml_obj, XML_COLOC_ATTR_TARGET_ROLE)));
} else if (safe_str_eq(XML_CONS_TAG_RSC_LOCATION, crm_element_name(xml_obj))) {
/* unpack_location(xml_obj, data_set); */
}
}
}
void
cli_resource_print_cts(pe_resource_t * rsc)
{
GListPtr lpc = NULL;
const char *host = NULL;
bool needs_quorum = TRUE;
const char *rtype = crm_element_value(rsc->xml, XML_ATTR_TYPE);
const char *rprov = crm_element_value(rsc->xml, XML_AGENT_ATTR_PROVIDER);
const char *rclass = crm_element_value(rsc->xml, XML_AGENT_ATTR_CLASS);
pe_node_t *node = pe__current_node(rsc);
if (safe_str_eq(rclass, PCMK_RESOURCE_CLASS_STONITH)) {
needs_quorum = FALSE;
} else {
// @TODO check requires in resource meta-data and rsc_defaults
}
if (node != NULL) {
host = node->details->uname;
}
printf("Resource: %s %s %s %s %s %s %s %s %d %lld 0x%.16llx\n",
crm_element_name(rsc->xml), rsc->id,
rsc->clone_name ? rsc->clone_name : rsc->id, rsc->parent ? rsc->parent->id : "NA",
rprov ? rprov : "NA", rclass, rtype, host ? host : "NA", needs_quorum, rsc->flags,
rsc->flags);
for (lpc = rsc->children; lpc != NULL; lpc = lpc->next) {
pe_resource_t *child = (pe_resource_t *) lpc->data;
cli_resource_print_cts(child);
}
}
void
cli_resource_print_raw(pe_resource_t * rsc)
{
GListPtr lpc = NULL;
GListPtr children = rsc->children;
if (children == NULL) {
printf("%s\n", rsc->id);
}
for (lpc = children; lpc != NULL; lpc = lpc->next) {
pe_resource_t *child = (pe_resource_t *) lpc->data;
cli_resource_print_raw(child);
}
}
+// \return Standard Pacemaker return code
int
cli_resource_print_list(pe_working_set_t * data_set, bool raw)
{
int found = 0;
GListPtr lpc = NULL;
int opts = pe_print_printf | pe_print_rsconly | pe_print_pending;
for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
pe_resource_t *rsc = (pe_resource_t *) lpc->data;
if (is_set(rsc->flags, pe_rsc_orphan)
&& rsc->fns->active(rsc, TRUE) == FALSE) {
continue;
}
rsc->fns->print(rsc, NULL, opts, stdout);
found++;
}
if (found == 0) {
printf("NO resources configured\n");
- return -ENXIO;
+ return ENXIO;
}
- return 0;
+ return pcmk_rc_ok;
}
+// \return Standard Pacemaker return code
int
cli_resource_print_operations(const char *rsc_id, const char *host_uname, bool active,
pe_working_set_t * data_set)
{
pe_resource_t *rsc = NULL;
int opts = pe_print_printf | pe_print_rsconly | pe_print_suppres_nl | pe_print_pending;
GListPtr ops = find_operations(rsc_id, host_uname, active, data_set);
GListPtr lpc = NULL;
for (lpc = ops; lpc != NULL; lpc = lpc->next) {
xmlNode *xml_op = (xmlNode *) lpc->data;
const char *op_rsc = crm_element_value(xml_op, "resource");
const char *status_s = crm_element_value(xml_op, XML_LRM_ATTR_OPSTATUS);
const char *op_key = crm_element_value(xml_op, XML_LRM_ATTR_TASK_KEY);
int status = crm_parse_int(status_s, "0");
time_t last_change = 0;
rsc = pe_find_resource(data_set->resources, op_rsc);
if(rsc) {
rsc->fns->print(rsc, "", opts, stdout);
} else {
fprintf(stdout, "Unknown resource %s", op_rsc);
}
fprintf(stdout, ": %s (node=%s, call=%s, rc=%s",
op_key ? op_key : ID(xml_op),
crm_element_value(xml_op, XML_ATTR_UNAME),
crm_element_value(xml_op, XML_LRM_ATTR_CALLID),
crm_element_value(xml_op, XML_LRM_ATTR_RC));
if (crm_element_value_epoch(xml_op, XML_RSC_OP_LAST_CHANGE,
&last_change) == pcmk_ok) {
fprintf(stdout, ", " XML_RSC_OP_LAST_CHANGE "=%s, exec=%sms",
crm_strip_trailing_newline(ctime(&last_change)),
crm_element_value(xml_op, XML_RSC_OP_T_EXEC));
}
fprintf(stdout, "): %s\n", services_lrm_status_str(status));
}
- return pcmk_ok;
+ return pcmk_rc_ok;
}
void
cli_resource_print_location(pe_resource_t * rsc, const char *prefix)
{
GListPtr lpc = NULL;
GListPtr list = rsc->rsc_location;
int offset = 0;
if (prefix) {
offset = strlen(prefix) - 2;
}
for (lpc = list; lpc != NULL; lpc = lpc->next) {
pe__location_t *cons = lpc->data;
GListPtr lpc2 = NULL;
for (lpc2 = cons->node_list_rh; lpc2 != NULL; lpc2 = lpc2->next) {
pe_node_t *node = (pe_node_t *) lpc2->data;
char *score = score2char(node->weight);
fprintf(stdout, "%s: Node %-*s (score=%s, id=%s)\n",
prefix ? prefix : " ", 71 - offset, node->details->uname, score, cons->id);
free(score);
}
}
}
void
cli_resource_print_colocation(pe_resource_t * rsc, bool dependents, bool recursive, int offset)
{
char *prefix = NULL;
GListPtr lpc = NULL;
GListPtr list = rsc->rsc_cons;
prefix = calloc(1, (offset * 4) + 1);
memset(prefix, ' ', offset * 4);
if (dependents) {
list = rsc->rsc_cons_lhs;
}
if (is_set(rsc->flags, pe_rsc_allocating)) {
/* Break colocation loops */
printf("loop %s\n", rsc->id);
free(prefix);
return;
}
set_bit(rsc->flags, pe_rsc_allocating);
for (lpc = list; lpc != NULL; lpc = lpc->next) {
rsc_colocation_t *cons = (rsc_colocation_t *) lpc->data;
char *score = NULL;
pe_resource_t *peer = cons->rsc_rh;
if (dependents) {
peer = cons->rsc_lh;
}
if (is_set(peer->flags, pe_rsc_allocating)) {
if (dependents == FALSE) {
fprintf(stdout, "%s%-*s (id=%s - loop)\n", prefix, 80 - (4 * offset), peer->id,
cons->id);
}
continue;
}
if (dependents && recursive) {
cli_resource_print_colocation(peer, dependents, recursive, offset + 1);
}
score = score2char(cons->score);
if (cons->role_rh > RSC_ROLE_STARTED) {
fprintf(stdout, "%s%-*s (score=%s, %s role=%s, id=%s)\n", prefix, 80 - (4 * offset),
peer->id, score, dependents ? "needs" : "with", role2text(cons->role_rh),
cons->id);
} else {
fprintf(stdout, "%s%-*s (score=%s, id=%s)\n", prefix, 80 - (4 * offset),
peer->id, score, cons->id);
}
cli_resource_print_location(peer, prefix);
free(score);
if (!dependents && recursive) {
cli_resource_print_colocation(peer, dependents, recursive, offset + 1);
}
}
free(prefix);
}
+// \return Standard Pacemaker return code
int
cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set, bool expanded)
{
char *rsc_xml = NULL;
int opts = pe_print_printf | pe_print_pending;
rsc->fns->print(rsc, NULL, opts, stdout);
rsc_xml = dump_xml_formatted((!expanded && rsc->orig_xml)?
rsc->orig_xml : rsc->xml);
fprintf(stdout, "%sxml:\n%s\n", expanded ? "" : "raw ", rsc_xml);
free(rsc_xml);
- return 0;
+ return pcmk_rc_ok;
}
+// \return Standard Pacemaker return code
int
-cli_resource_print_attribute(pe_resource_t *rsc, const char *attr, pe_working_set_t * data_set)
+cli_resource_print_attribute(pe_resource_t *rsc, const char *attr, const char *attr_set_type,
+ pe_working_set_t * data_set)
{
- int rc = -ENXIO;
+ int rc = ENXIO;
unsigned int count = 0;
GHashTable *params = NULL;
const char *value = NULL;
pe_node_t *current = pe__find_active_on(rsc, &count, NULL);
if (count > 1) {
CMD_ERR("%s is active on more than one node,"
" returning the default value for %s", rsc->id, crm_str(attr));
current = NULL;
}
params = crm_str_table_new();
if (safe_str_eq(attr_set_type, XML_TAG_ATTR_SETS)) {
get_rsc_attributes(params, rsc, current, data_set);
} else if (safe_str_eq(attr_set_type, XML_TAG_META_SETS)) {
/* No need to redirect to the parent */
get_meta_attributes(params, rsc, current, data_set);
} else {
pe__unpack_dataset_nvpairs(rsc->xml, XML_TAG_UTILIZATION, NULL, params,
NULL, FALSE, data_set);
}
crm_debug("Looking up %s in %s", attr, rsc->id);
value = g_hash_table_lookup(params, attr);
if (value != NULL) {
fprintf(stdout, "%s\n", value);
- rc = 0;
+ rc = pcmk_rc_ok;
} else {
CMD_ERR("Attribute '%s' not found for '%s'", attr, rsc->id);
}
g_hash_table_destroy(params);
return rc;
}
-
+// \return Standard Pacemaker return code
int
cli_resource_print_property(pe_resource_t *rsc, const char *attr, pe_working_set_t * data_set)
{
const char *value = crm_element_value(rsc->xml, attr);
if (value != NULL) {
fprintf(stdout, "%s\n", value);
- return 0;
+ return pcmk_rc_ok;
}
- return -ENXIO;
+ return ENXIO;
}
diff --git a/tools/crm_resource_runtime.c b/tools/crm_resource_runtime.c
index 185a9a3a28..8bf31213e9 100644
--- a/tools/crm_resource_runtime.c
+++ b/tools/crm_resource_runtime.c
@@ -1,2089 +1,2113 @@
/*
* Copyright 2004-2020 the Pacemaker project contributors
*
* The version control history for this file may have further details.
*
* This source code is licensed under the GNU General Public License version 2
* or later (GPLv2+) WITHOUT ANY WARRANTY.
*/
#include
#include
-int resource_verbose = 0;
-bool do_force = FALSE;
-
-const char *attr_set_type = XML_TAG_ATTR_SETS;
-
static int
do_find_resource(const char *rsc, pe_resource_t * the_rsc, pe_working_set_t * data_set)
{
int found = 0;
GListPtr lpc = NULL;
for (lpc = the_rsc->running_on; lpc != NULL; lpc = lpc->next) {
pe_node_t *node = (pe_node_t *) lpc->data;
if (BE_QUIET) {
fprintf(stdout, "%s\n", node->details->uname);
} else {
const char *state = "";
if (!pe_rsc_is_clone(the_rsc) && the_rsc->fns->state(the_rsc, TRUE) == RSC_ROLE_MASTER) {
state = "Master";
}
fprintf(stdout, "resource %s is running on: %s %s\n", rsc, node->details->uname, state);
}
found++;
}
if (BE_QUIET == FALSE && found == 0) {
fprintf(stderr, "resource %s is NOT running\n", rsc);
}
return found;
}
int
cli_resource_search(pe_resource_t *rsc, const char *requested_name,
pe_working_set_t *data_set)
{
int found = 0;
pe_resource_t *parent = uber_parent(rsc);
if (pe_rsc_is_clone(rsc)) {
for (GListPtr iter = rsc->children; iter != NULL; iter = iter->next) {
found += do_find_resource(requested_name, iter->data, data_set);
}
/* The anonymous clone children's common ID is supplied */
} else if (pe_rsc_is_clone(parent)
&& is_not_set(rsc->flags, pe_rsc_unique)
&& rsc->clone_name
&& safe_str_eq(requested_name, rsc->clone_name)
&& safe_str_neq(requested_name, rsc->id)) {
for (GListPtr iter = parent->children; iter; iter = iter->next) {
found += do_find_resource(requested_name, iter->data, data_set);
}
} else {
found += do_find_resource(requested_name, rsc, data_set);
}
return found;
}
#define XPATH_MAX 1024
+// \return Standard Pacemaker return code
static int
-find_resource_attr(cib_t * the_cib, const char *attr, const char *rsc, const char *set_type,
+find_resource_attr(cib_t * the_cib, const char *attr, const char *rsc, const char *attr_set_type,
const char *set_name, const char *attr_id, const char *attr_name, char **value)
{
int offset = 0;
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
xmlNode *xml_search = NULL;
char *xpath_string = NULL;
if(value) {
*value = NULL;
}
if(the_cib == NULL) {
- return -ENOTCONN;
+ return ENOTCONN;
}
xpath_string = calloc(1, XPATH_MAX);
offset +=
snprintf(xpath_string + offset, XPATH_MAX - offset, "%s", get_object_path("resources"));
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "//*[@id=\"%s\"]", rsc);
- if (set_type) {
- offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "/%s", set_type);
+ if (attr_set_type) {
+ offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "/%s", attr_set_type);
if (set_name) {
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "[@id=\"%s\"]", set_name);
}
}
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "//nvpair[");
if (attr_id) {
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "@id=\"%s\"", attr_id);
}
if (attr_name) {
if (attr_id) {
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, " and ");
}
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "@name=\"%s\"", attr_name);
}
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "]");
CRM_LOG_ASSERT(offset > 0);
rc = the_cib->cmds->query(the_cib, xpath_string, &xml_search,
cib_sync_call | cib_scope_local | cib_xpath);
+ rc = pcmk_legacy2rc(rc);
- if (rc != pcmk_ok) {
+ if (rc != pcmk_rc_ok) {
goto bail;
}
crm_log_xml_debug(xml_search, "Match");
if (xml_has_children(xml_search)) {
xmlNode *child = NULL;
- rc = -EINVAL;
+ rc = EINVAL;
printf("Multiple attributes match name=%s\n", attr_name);
for (child = __xml_first_child(xml_search); child != NULL; child = __xml_next(child)) {
printf(" Value: %s \t(id=%s)\n",
crm_element_value(child, XML_NVPAIR_ATTR_VALUE), ID(child));
}
} else if(value) {
const char *tmp = crm_element_value(xml_search, attr);
if (tmp) {
*value = strdup(tmp);
}
}
bail:
free(xpath_string);
free_xml(xml_search);
return rc;
}
/* PRIVATE. Use the find_matching_attr_resources instead. */
static void
find_matching_attr_resources_recursive(GList/* */ ** result, pe_resource_t * rsc, const char * rsc_id,
- const char * attr_set, const char * attr_id,
+ const char * attr_set, const char * attr_set_type, const char * attr_id,
const char * attr_name, cib_t * cib, const char * cmd, int depth)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
char *lookup_id = clone_strip(rsc->id);
char *local_attr_id = NULL;
/* visit the children */
for(GList *gIter = rsc->children; gIter; gIter = gIter->next) {
- find_matching_attr_resources_recursive(result, (pe_resource_t*)gIter->data, rsc_id, attr_set, attr_id, attr_name, cib, cmd, depth+1);
+ find_matching_attr_resources_recursive(result, (pe_resource_t*)gIter->data,
+ rsc_id, attr_set, attr_set_type,
+ attr_id, attr_name, cib, cmd, depth+1);
/* do it only once for clones */
if(pe_clone == rsc->variant) {
break;
}
}
rc = find_resource_attr(cib, XML_ATTR_ID, lookup_id, attr_set_type, attr_set, attr_id, attr_name, &local_attr_id);
/* Post-order traversal.
* The root is always on the list and it is the last item. */
- if((0 == depth) || (pcmk_ok == rc)) {
+ if((0 == depth) || (pcmk_rc_ok == rc)) {
/* push the head */
*result = g_list_append(*result, rsc);
}
free(local_attr_id);
free(lookup_id);
}
/* The result is a linearized pre-ordered tree of resources. */
static GList/**/ *
-find_matching_attr_resources(pe_resource_t * rsc, const char * rsc_id, const char * attr_set, const char * attr_id,
- const char * attr_name, cib_t * cib, const char * cmd)
+find_matching_attr_resources(pe_resource_t * rsc, const char * rsc_id, const char * attr_set,
+ const char * attr_set_type, const char * attr_id,
+ const char * attr_name, cib_t * cib, const char * cmd, gboolean force)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
char *lookup_id = NULL;
char *local_attr_id = NULL;
GList * result = NULL;
/* If --force is used, update only the requested resource (clone or primitive).
* Otherwise, if the primitive has the attribute, use that.
* Otherwise use the clone. */
- if(do_force == TRUE) {
+ if(force == TRUE) {
return g_list_append(result, rsc);
}
if(rsc->parent && pe_clone == rsc->parent->variant) {
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
char *local_attr_id = NULL;
rc = find_resource_attr(cib, XML_ATTR_ID, rsc_id, attr_set_type, attr_set, attr_id, attr_name, &local_attr_id);
free(local_attr_id);
- if(rc != pcmk_ok) {
+ if(rc != pcmk_rc_ok) {
rsc = rsc->parent;
if (BE_QUIET == FALSE) {
printf("Performing %s of '%s' on '%s', the parent of '%s'\n", cmd, attr_name, rsc->id, rsc_id);
}
}
return g_list_append(result, rsc);
} else if(rsc->parent == NULL && rsc->children && pe_clone == rsc->variant) {
pe_resource_t *child = rsc->children->data;
if(child->variant == pe_native) {
lookup_id = clone_strip(child->id); /* Could be a cloned group! */
rc = find_resource_attr(cib, XML_ATTR_ID, lookup_id, attr_set_type, attr_set, attr_id, attr_name, &local_attr_id);
- if(rc == pcmk_ok) {
+ if(rc == pcmk_rc_ok) {
rsc = child;
if (BE_QUIET == FALSE) {
printf("A value for '%s' already exists in child '%s', performing %s on that instead of '%s'\n", attr_name, lookup_id, cmd, rsc_id);
}
}
free(local_attr_id);
free(lookup_id);
}
return g_list_append(result, rsc);
}
/* If the resource is a group ==> children inherit the attribute if defined. */
- find_matching_attr_resources_recursive(&result, rsc, rsc_id, attr_set, attr_id, attr_name, cib, cmd, 0);
+ find_matching_attr_resources_recursive(&result, rsc, rsc_id, attr_set,
+ attr_set_type, attr_id, attr_name,
+ cib, cmd, 0);
return result;
}
+// \return Standard Pacemaker return code
int
cli_resource_update_attribute(pe_resource_t *rsc, const char *requested_name,
- const char *attr_set, const char *attr_id,
- const char *attr_name, const char *attr_value,
- bool recursive, cib_t *cib,
- pe_working_set_t *data_set)
+ const char *attr_set, const char *attr_set_type,
+ const char *attr_id, const char *attr_name,
+ const char *attr_value, gboolean recursive, cib_t *cib,
+ int cib_options, pe_working_set_t *data_set, gboolean force)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
static bool need_init = TRUE;
char *local_attr_id = NULL;
char *local_attr_set = NULL;
GList/**/ *resources = NULL;
const char *common_attr_id = attr_id;
if(attr_id == NULL
- && do_force == FALSE
+ && force == FALSE
&& find_resource_attr(
- cib, XML_ATTR_ID, uber_parent(rsc)->id, NULL, NULL, NULL, attr_name, NULL) == -EINVAL) {
+ cib, XML_ATTR_ID, uber_parent(rsc)->id, NULL, NULL, NULL, attr_name, NULL) == EINVAL) {
printf("\n");
}
if (safe_str_eq(attr_set_type, XML_TAG_ATTR_SETS)) {
- if (do_force == FALSE) {
+ if (force == FALSE) {
rc = find_resource_attr(cib, XML_ATTR_ID, uber_parent(rsc)->id,
XML_TAG_META_SETS, attr_set, attr_id,
attr_name, &local_attr_id);
- if (rc == pcmk_ok && BE_QUIET == FALSE) {
+ if (rc == pcmk_rc_ok && BE_QUIET == FALSE) {
printf("WARNING: There is already a meta attribute for '%s' called '%s' (id=%s)\n",
uber_parent(rsc)->id, attr_name, local_attr_id);
printf(" Delete '%s' first or use the force option to override\n",
local_attr_id);
}
free(local_attr_id);
- if (rc == pcmk_ok) {
- return -ENOTUNIQ;
+ if (rc == pcmk_rc_ok) {
+ return ENOTUNIQ;
}
}
resources = g_list_append(resources, rsc);
} else {
- resources = find_matching_attr_resources(rsc, requested_name, attr_set,
- attr_id, attr_name, cib, "update");
+ resources = find_matching_attr_resources(rsc, requested_name, attr_set, attr_set_type,
+ attr_id, attr_name, cib, "update", force);
}
/* If either attr_set or attr_id is specified,
* one clearly intends to modify a single resource.
* It is the last item on the resource list.*/
for(GList *gIter = (attr_set||attr_id) ? g_list_last(resources) : resources
; gIter; gIter = gIter->next) {
char *lookup_id = NULL;
xmlNode *xml_top = NULL;
xmlNode *xml_obj = NULL;
local_attr_id = NULL;
local_attr_set = NULL;
rsc = (pe_resource_t*)gIter->data;
attr_id = common_attr_id;
lookup_id = clone_strip(rsc->id); /* Could be a cloned group! */
rc = find_resource_attr(cib, XML_ATTR_ID, lookup_id, attr_set_type, attr_set, attr_id, attr_name,
&local_attr_id);
- if (rc == pcmk_ok) {
+ if (rc == pcmk_rc_ok) {
crm_debug("Found a match for name=%s: id=%s", attr_name, local_attr_id);
attr_id = local_attr_id;
- } else if (rc != -ENXIO) {
+ } else if (rc != ENXIO) {
free(lookup_id);
free(local_attr_id);
g_list_free(resources);
return rc;
} else {
const char *tag = crm_element_name(rsc->xml);
if (attr_set == NULL) {
local_attr_set = crm_strdup_printf("%s-%s", lookup_id,
attr_set_type);
attr_set = local_attr_set;
}
if (attr_id == NULL) {
local_attr_id = crm_strdup_printf("%s-%s", attr_set, attr_name);
attr_id = local_attr_id;
}
xml_top = create_xml_node(NULL, tag);
crm_xml_add(xml_top, XML_ATTR_ID, lookup_id);
xml_obj = create_xml_node(xml_top, attr_set_type);
crm_xml_add(xml_obj, XML_ATTR_ID, attr_set);
}
xml_obj = crm_create_nvpair_xml(xml_obj, attr_id, attr_name, attr_value);
if (xml_top == NULL) {
xml_top = xml_obj;
}
crm_log_xml_debug(xml_top, "Update");
rc = cib->cmds->modify(cib, XML_CIB_TAG_RESOURCES, xml_top, cib_options);
- if (rc == pcmk_ok && BE_QUIET == FALSE) {
+ rc = pcmk_legacy2rc(rc);
+
+ if (rc == pcmk_rc_ok && BE_QUIET == FALSE) {
printf("Set '%s' option: id=%s%s%s%s%s value=%s\n", lookup_id, local_attr_id,
attr_set ? " set=" : "", attr_set ? attr_set : "",
attr_name ? " name=" : "", attr_name ? attr_name : "", attr_value);
}
free_xml(xml_top);
free(lookup_id);
free(local_attr_id);
free(local_attr_set);
if(recursive && safe_str_eq(attr_set_type, XML_TAG_META_SETS)) {
GListPtr lpc = NULL;
if(need_init) {
xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input);
need_init = FALSE;
unpack_constraints(cib_constraints, data_set);
for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) {
pe_resource_t *r = (pe_resource_t *) lpc->data;
clear_bit(r->flags, pe_rsc_allocating);
}
}
crm_debug("Looking for dependencies %p", rsc->rsc_cons_lhs);
set_bit(rsc->flags, pe_rsc_allocating);
for (lpc = rsc->rsc_cons_lhs; lpc != NULL; lpc = lpc->next) {
rsc_colocation_t *cons = (rsc_colocation_t *) lpc->data;
pe_resource_t *peer = cons->rsc_lh;
crm_debug("Checking %s %d", cons->id, cons->score);
if (cons->score > 0 && is_not_set(peer->flags, pe_rsc_allocating)) {
/* Don't get into colocation loops */
crm_debug("Setting %s=%s for dependent resource %s", attr_name, attr_value, peer->id);
- cli_resource_update_attribute(peer, peer->id, NULL, NULL,
- attr_name, attr_value, recursive,
- cib, data_set);
+ cli_resource_update_attribute(peer, peer->id, NULL, attr_set_type,
+ NULL, attr_name, attr_value, recursive,
+ cib, cib_options, data_set, force);
}
}
}
}
g_list_free(resources);
return rc;
}
+// \return Standard Pacemaker return code
int
cli_resource_delete_attribute(pe_resource_t *rsc, const char *requested_name,
- const char *attr_set, const char *attr_id,
- const char *attr_name, cib_t *cib,
- pe_working_set_t *data_set)
+ const char *attr_set, const char *attr_set_type,
+ const char *attr_id, const char *attr_name, cib_t *cib,
+ int cib_options, pe_working_set_t *data_set, gboolean force)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
GList/**/ *resources = NULL;
if(attr_id == NULL
- && do_force == FALSE
+ && force == FALSE
&& find_resource_attr(
- cib, XML_ATTR_ID, uber_parent(rsc)->id, NULL, NULL, NULL, attr_name, NULL) == -EINVAL) {
+ cib, XML_ATTR_ID, uber_parent(rsc)->id, NULL, NULL, NULL, attr_name, NULL) == EINVAL) {
printf("\n");
}
if(safe_str_eq(attr_set_type, XML_TAG_META_SETS)) {
- resources = find_matching_attr_resources(rsc, requested_name, attr_set,
- attr_id, attr_name, cib, "delete");
+ resources = find_matching_attr_resources(rsc, requested_name, attr_set, attr_set_type,
+ attr_id, attr_name, cib, "delete", force);
} else {
resources = g_list_append(resources, rsc);
}
for(GList *gIter = resources; gIter; gIter = gIter->next) {
char *lookup_id = NULL;
xmlNode *xml_obj = NULL;
char *local_attr_id = NULL;
rsc = (pe_resource_t*)gIter->data;
lookup_id = clone_strip(rsc->id);
rc = find_resource_attr(cib, XML_ATTR_ID, lookup_id, attr_set_type, attr_set, attr_id, attr_name,
&local_attr_id);
- if (rc == -ENXIO) {
+ if (rc == ENXIO) {
free(lookup_id);
- rc = pcmk_ok;
+ rc = pcmk_rc_ok;
continue;
- } else if (rc != pcmk_ok) {
+ } else if (rc != pcmk_rc_ok) {
free(lookup_id);
g_list_free(resources);
return rc;
}
if (attr_id == NULL) {
attr_id = local_attr_id;
}
xml_obj = crm_create_nvpair_xml(NULL, attr_id, attr_name, NULL);
crm_log_xml_debug(xml_obj, "Delete");
CRM_ASSERT(cib);
rc = cib->cmds->remove(cib, XML_CIB_TAG_RESOURCES, xml_obj, cib_options);
+ rc = pcmk_legacy2rc(rc);
- if (rc == pcmk_ok && BE_QUIET == FALSE) {
+ if (rc == pcmk_rc_ok && BE_QUIET == FALSE) {
printf("Deleted '%s' option: id=%s%s%s%s%s\n", lookup_id, local_attr_id,
attr_set ? " set=" : "", attr_set ? attr_set : "",
attr_name ? " name=" : "", attr_name ? attr_name : "");
}
free(lookup_id);
free_xml(xml_obj);
free(local_attr_id);
}
g_list_free(resources);
return rc;
}
// \return Standard Pacemaker return code
static int
send_lrm_rsc_op(pcmk_ipc_api_t *controld_api, bool do_fail_resource,
const char *host_uname, const char *rsc_id,
pe_working_set_t *data_set)
{
const char *router_node = host_uname;
const char *rsc_api_id = NULL;
const char *rsc_long_id = NULL;
const char *rsc_class = NULL;
const char *rsc_provider = NULL;
const char *rsc_type = NULL;
bool cib_only = false;
pe_resource_t *rsc = pe_find_resource(data_set->resources, rsc_id);
if (rsc == NULL) {
CMD_ERR("Resource %s not found", rsc_id);
return ENXIO;
} else if (rsc->variant != pe_native) {
CMD_ERR("We can only process primitive resources, not %s", rsc_id);
return EINVAL;
}
rsc_class = crm_element_value(rsc->xml, XML_AGENT_ATTR_CLASS);
rsc_provider = crm_element_value(rsc->xml, XML_AGENT_ATTR_PROVIDER),
rsc_type = crm_element_value(rsc->xml, XML_ATTR_TYPE);
if ((rsc_class == NULL) || (rsc_type == NULL)) {
CMD_ERR("Resource %s does not have a class and type", rsc_id);
return EINVAL;
}
if (host_uname == NULL) {
CMD_ERR("Please specify a node name");
return EINVAL;
} else {
pe_node_t *node = pe_find_node(data_set->nodes, host_uname);
if (node == NULL) {
CMD_ERR("Node %s not found", host_uname);
return pcmk_rc_node_unknown;
}
if (!(node->details->online)) {
if (do_fail_resource) {
CMD_ERR("Node %s is not online", host_uname);
return ENOTCONN;
} else {
cib_only = true;
}
}
if (!cib_only && pe__is_guest_or_remote_node(node)) {
node = pe__current_node(node->details->remote_rsc);
if (node == NULL) {
CMD_ERR("No cluster connection to Pacemaker Remote node %s detected",
host_uname);
return ENOTCONN;
}
router_node = node->details->uname;
}
}
if (rsc->clone_name) {
rsc_api_id = rsc->clone_name;
rsc_long_id = rsc->id;
} else {
rsc_api_id = rsc->id;
}
if (do_fail_resource) {
return pcmk_controld_api_fail(controld_api, host_uname, router_node,
rsc_api_id, rsc_long_id,
rsc_class, rsc_provider, rsc_type);
} else {
return pcmk_controld_api_refresh(controld_api, host_uname, router_node,
rsc_api_id, rsc_long_id, rsc_class,
rsc_provider, rsc_type, cib_only);
}
}
/*!
* \internal
* \brief Get resource name as used in failure-related node attributes
*
* \param[in] rsc Resource to check
*
* \return Newly allocated string containing resource's fail name
* \note The caller is responsible for freeing the result.
*/
static inline char *
rsc_fail_name(pe_resource_t *rsc)
{
const char *name = (rsc->clone_name? rsc->clone_name : rsc->id);
return is_set(rsc->flags, pe_rsc_unique)? strdup(name) : clone_strip(name);
}
// \return Standard Pacemaker return code
static int
clear_rsc_history(pcmk_ipc_api_t *controld_api, const char *host_uname,
const char *rsc_id, pe_working_set_t *data_set)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
/* Erase the resource's entire LRM history in the CIB, even if we're only
* clearing a single operation's fail count. If we erased only entries for a
* single operation, we might wind up with a wrong idea of the current
* resource state, and we might not re-probe the resource.
*/
rc = send_lrm_rsc_op(controld_api, false, host_uname, rsc_id, data_set);
if (rc != pcmk_rc_ok) {
return rc;
}
crm_trace("Processing %d mainloop inputs",
pcmk_controld_api_replies_expected(controld_api));
while (g_main_context_iteration(NULL, FALSE)) {
crm_trace("Processed mainloop input, %d still remaining",
pcmk_controld_api_replies_expected(controld_api));
}
return rc;
}
+// \return Standard Pacemaker return code
static int
clear_rsc_failures(pcmk_ipc_api_t *controld_api, const char *node_name,
const char *rsc_id, const char *operation,
const char *interval_spec, pe_working_set_t *data_set)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
const char *failed_value = NULL;
const char *failed_id = NULL;
const char *interval_ms_s = NULL;
GHashTable *rscs = NULL;
GHashTableIter iter;
/* Create a hash table to use as a set of resources to clean. This lets us
* clean each resource only once (per node) regardless of how many failed
* operations it has.
*/
rscs = g_hash_table_new_full(crm_str_hash, g_str_equal, NULL, NULL);
// Normalize interval to milliseconds for comparison to history entry
if (operation) {
interval_ms_s = crm_strdup_printf("%u",
crm_parse_interval_spec(interval_spec));
}
for (xmlNode *xml_op = __xml_first_child(data_set->failed); xml_op != NULL;
xml_op = __xml_next(xml_op)) {
failed_id = crm_element_value(xml_op, XML_LRM_ATTR_RSCID);
if (failed_id == NULL) {
// Malformed history entry, should never happen
continue;
}
// No resource specified means all resources match
if (rsc_id) {
pe_resource_t *fail_rsc = pe_find_resource_with_flags(data_set->resources,
failed_id,
pe_find_renamed|pe_find_anon);
if (!fail_rsc || safe_str_neq(rsc_id, fail_rsc->id)) {
continue;
}
}
// Host name should always have been provided by this point
failed_value = crm_element_value(xml_op, XML_ATTR_UNAME);
if (safe_str_neq(node_name, failed_value)) {
continue;
}
// No operation specified means all operations match
if (operation) {
failed_value = crm_element_value(xml_op, XML_LRM_ATTR_TASK);
if (safe_str_neq(operation, failed_value)) {
continue;
}
// Interval (if operation was specified) defaults to 0 (not all)
failed_value = crm_element_value(xml_op, XML_LRM_ATTR_INTERVAL_MS);
if (safe_str_neq(interval_ms_s, failed_value)) {
continue;
}
}
/* not available until glib 2.32
g_hash_table_add(rscs, (gpointer) failed_id);
*/
g_hash_table_insert(rscs, (gpointer) failed_id, (gpointer) failed_id);
}
g_hash_table_iter_init(&iter, rscs);
while (g_hash_table_iter_next(&iter, (gpointer *) &failed_id, NULL)) {
crm_debug("Erasing failures of %s on %s", failed_id, node_name);
rc = clear_rsc_history(controld_api, node_name, failed_id, data_set);
if (rc != pcmk_rc_ok) {
- return pcmk_rc2legacy(rc);
+ return rc;
}
}
g_hash_table_destroy(rscs);
return rc;
}
+// \return Standard Pacemaker return code
static int
clear_rsc_fail_attrs(pe_resource_t *rsc, const char *operation,
const char *interval_spec, pe_node_t *node)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
int attr_options = pcmk__node_attr_none;
char *rsc_name = rsc_fail_name(rsc);
if (pe__is_guest_or_remote_node(node)) {
attr_options |= pcmk__node_attr_remote;
}
rc = pcmk__node_attr_request_clear(NULL, node->details->uname, rsc_name,
operation, interval_spec, NULL,
attr_options);
free(rsc_name);
return rc;
}
+// \return Standard Pacemaker return code
int
cli_resource_delete(pcmk_ipc_api_t *controld_api, const char *host_uname,
pe_resource_t *rsc, const char *operation,
const char *interval_spec, bool just_failures,
- pe_working_set_t *data_set)
+ pe_working_set_t *data_set, gboolean force)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
pe_node_t *node = NULL;
if (rsc == NULL) {
- return -ENXIO;
+ return ENXIO;
} else if (rsc->children) {
GListPtr lpc = NULL;
for (lpc = rsc->children; lpc != NULL; lpc = lpc->next) {
pe_resource_t *child = (pe_resource_t *) lpc->data;
rc = cli_resource_delete(controld_api, host_uname, child, operation,
- interval_spec, just_failures, data_set);
- if (rc != pcmk_ok) {
+ interval_spec, just_failures, data_set,
+ force);
+ if (rc != pcmk_rc_ok) {
return rc;
}
}
- return pcmk_ok;
+ return pcmk_rc_ok;
} else if (host_uname == NULL) {
GListPtr lpc = NULL;
GListPtr nodes = g_hash_table_get_values(rsc->known_on);
- if(nodes == NULL && do_force) {
+ if(nodes == NULL && force) {
nodes = pcmk__copy_node_list(data_set->nodes, false);
} else if(nodes == NULL && rsc->exclusive_discover) {
GHashTableIter iter;
pe_node_t *node = NULL;
g_hash_table_iter_init(&iter, rsc->allowed_nodes);
while (g_hash_table_iter_next(&iter, NULL, (void**)&node)) {
if(node->weight >= 0) {
nodes = g_list_prepend(nodes, node);
}
}
} else if(nodes == NULL) {
nodes = g_hash_table_get_values(rsc->allowed_nodes);
}
for (lpc = nodes; lpc != NULL; lpc = lpc->next) {
node = (pe_node_t *) lpc->data;
if (node->details->online) {
rc = cli_resource_delete(controld_api, node->details->uname,
rsc, operation, interval_spec,
- just_failures, data_set);
+ just_failures, data_set, force);
}
- if (rc != pcmk_ok) {
+ if (rc != pcmk_rc_ok) {
g_list_free(nodes);
return rc;
}
}
g_list_free(nodes);
- return pcmk_ok;
+ return pcmk_rc_ok;
}
node = pe_find_node(data_set->nodes, host_uname);
if (node == NULL) {
printf("Unable to clean up %s because node %s not found\n",
rsc->id, host_uname);
- return -ENODEV;
+ return ENODEV;
}
if (!node->details->rsc_discovery_enabled) {
printf("Unable to clean up %s because resource discovery disabled on %s\n",
rsc->id, host_uname);
- return -EOPNOTSUPP;
+ return EOPNOTSUPP;
}
if (controld_api == NULL) {
printf("Dry run: skipping clean-up of %s on %s due to CIB_file\n",
rsc->id, host_uname);
- return pcmk_ok;
+ return pcmk_rc_ok;
}
rc = clear_rsc_fail_attrs(rsc, operation, interval_spec, node);
if (rc != pcmk_rc_ok) {
printf("Unable to clean up %s failures on %s: %s\n",
rsc->id, host_uname, pcmk_rc_str(rc));
- return pcmk_rc2legacy(rc);
+ return rc;
}
if (just_failures) {
rc = clear_rsc_failures(controld_api, host_uname, rsc->id, operation,
interval_spec, data_set);
} else {
rc = clear_rsc_history(controld_api, host_uname, rsc->id, data_set);
- rc = pcmk_rc2legacy(rc);
}
- if (rc != pcmk_ok) {
+ if (rc != pcmk_rc_ok) {
printf("Cleaned %s failures on %s, but unable to clean history: %s\n",
rsc->id, host_uname, pcmk_strerror(rc));
} else {
printf("Cleaned up %s on %s\n", rsc->id, host_uname);
}
return rc;
}
+// \return Standard Pacemaker return code
int
cli_cleanup_all(pcmk_ipc_api_t *controld_api, const char *node_name,
const char *operation, const char *interval_spec,
pe_working_set_t *data_set)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
int attr_options = pcmk__node_attr_none;
const char *display_name = node_name? node_name : "all nodes";
if (controld_api == NULL) {
printf("Dry run: skipping clean-up of %s due to CIB_file\n",
display_name);
- return pcmk_ok;
+ return rc;
}
if (node_name) {
pe_node_t *node = pe_find_node(data_set->nodes, node_name);
if (node == NULL) {
CMD_ERR("Unknown node: %s", node_name);
- return -ENXIO;
+ return ENXIO;
}
if (pe__is_guest_or_remote_node(node)) {
attr_options |= pcmk__node_attr_remote;
}
}
rc = pcmk__node_attr_request_clear(NULL, node_name, NULL, operation,
interval_spec, NULL, attr_options);
if (rc != pcmk_rc_ok) {
printf("Unable to clean up all failures on %s: %s\n",
display_name, pcmk_rc_str(rc));
- return pcmk_rc2legacy(rc);
+ return rc;
}
if (node_name) {
rc = clear_rsc_failures(controld_api, node_name, NULL,
operation, interval_spec, data_set);
- if (rc != pcmk_ok) {
+ if (rc != pcmk_rc_ok) {
printf("Cleaned all resource failures on %s, but unable to clean history: %s\n",
node_name, pcmk_strerror(rc));
return rc;
}
} else {
for (GList *iter = data_set->nodes; iter; iter = iter->next) {
pe_node_t *node = (pe_node_t *) iter->data;
rc = clear_rsc_failures(controld_api, node->details->uname, NULL,
operation, interval_spec, data_set);
- if (rc != pcmk_ok) {
+ if (rc != pcmk_rc_ok) {
printf("Cleaned all resource failures on all nodes, but unable to clean history: %s\n",
pcmk_strerror(rc));
return rc;
}
}
}
printf("Cleaned up all resources on %s\n", display_name);
- return pcmk_ok;
+ return rc;
}
void
cli_resource_check(cib_t * cib_conn, pe_resource_t *rsc)
{
bool printed = false;
char *role_s = NULL;
char *managed = NULL;
pe_resource_t *parent = uber_parent(rsc);
find_resource_attr(cib_conn, XML_NVPAIR_ATTR_VALUE, parent->id,
NULL, NULL, NULL, XML_RSC_ATTR_MANAGED, &managed);
find_resource_attr(cib_conn, XML_NVPAIR_ATTR_VALUE, parent->id,
NULL, NULL, NULL, XML_RSC_ATTR_TARGET_ROLE, &role_s);
if(role_s) {
enum rsc_role_e role = text2role(role_s);
free(role_s);
if(role == RSC_ROLE_UNKNOWN) {
// Treated as if unset
} else if(role == RSC_ROLE_STOPPED) {
printf("\n * Configuration specifies '%s' should remain stopped\n",
parent->id);
printed = true;
} else if (is_set(parent->flags, pe_rsc_promotable)
&& (role == RSC_ROLE_SLAVE)) {
printf("\n * Configuration specifies '%s' should not be promoted\n",
parent->id);
printed = true;
}
}
if (managed && !crm_is_true(managed)) {
printf("%s * Configuration prevents cluster from stopping or starting unmanaged '%s'\n",
(printed? "" : "\n"), parent->id);
printed = true;
}
free(managed);
if (rsc->lock_node) {
printf("%s * '%s' is locked to node %s due to shutdown\n",
(printed? "" : "\n"), parent->id, rsc->lock_node->details->uname);
}
if (printed) {
printf("\n");
}
}
// \return Standard Pacemaker return code
int
cli_resource_fail(pcmk_ipc_api_t *controld_api, const char *host_uname,
const char *rsc_id, pe_working_set_t *data_set)
{
crm_notice("Failing %s on %s", rsc_id, host_uname);
return send_lrm_rsc_op(controld_api, true, host_uname, rsc_id, data_set);
}
static GHashTable *
generate_resource_params(pe_resource_t * rsc, pe_working_set_t * data_set)
{
GHashTable *params = NULL;
GHashTable *meta = NULL;
GHashTable *combined = NULL;
GHashTableIter iter;
if (!rsc) {
crm_err("Resource does not exist in config");
return NULL;
}
params = crm_str_table_new();
meta = crm_str_table_new();
combined = crm_str_table_new();
get_rsc_attributes(params, rsc, NULL /* TODO: Pass in local node */ , data_set);
get_meta_attributes(meta, rsc, NULL /* TODO: Pass in local node */ , data_set);
if (params) {
char *key = NULL;
char *value = NULL;
g_hash_table_iter_init(&iter, params);
while (g_hash_table_iter_next(&iter, (gpointer *) & key, (gpointer *) & value)) {
g_hash_table_insert(combined, strdup(key), strdup(value));
}
g_hash_table_destroy(params);
}
if (meta) {
char *key = NULL;
char *value = NULL;
g_hash_table_iter_init(&iter, meta);
while (g_hash_table_iter_next(&iter, (gpointer *) & key, (gpointer *) & value)) {
char *crm_name = crm_meta_name(key);
g_hash_table_insert(combined, crm_name, strdup(value));
}
g_hash_table_destroy(meta);
}
return combined;
}
static bool resource_is_running_on(pe_resource_t *rsc, const char *host)
{
bool found = TRUE;
GListPtr hIter = NULL;
GListPtr hosts = NULL;
if(rsc == NULL) {
return FALSE;
}
rsc->fns->location(rsc, &hosts, TRUE);
for (hIter = hosts; host != NULL && hIter != NULL; hIter = hIter->next) {
pe_node_t *node = (pe_node_t *) hIter->data;
if(strcmp(host, node->details->uname) == 0) {
crm_trace("Resource %s is running on %s\n", rsc->id, host);
goto done;
} else if(strcmp(host, node->details->id) == 0) {
crm_trace("Resource %s is running on %s\n", rsc->id, host);
goto done;
}
}
if(host != NULL) {
crm_trace("Resource %s is not running on: %s\n", rsc->id, host);
found = FALSE;
} else if(host == NULL && hosts == NULL) {
crm_trace("Resource %s is not running\n", rsc->id);
found = FALSE;
}
done:
g_list_free(hosts);
return found;
}
/*!
* \internal
* \brief Create a list of all resources active on host from a given list
*
* \param[in] host Name of host to check whether resources are active
* \param[in] rsc_list List of resources to check
*
* \return New list of resources from list that are active on host
*/
static GList *
get_active_resources(const char *host, GList *rsc_list)
{
GList *rIter = NULL;
GList *active = NULL;
for (rIter = rsc_list; rIter != NULL; rIter = rIter->next) {
pe_resource_t *rsc = (pe_resource_t *) rIter->data;
/* Expand groups to their members, because if we're restarting a member
* other than the first, we can't otherwise tell which resources are
* stopping and starting.
*/
if (rsc->variant == pe_group) {
active = g_list_concat(active,
get_active_resources(host, rsc->children));
} else if (resource_is_running_on(rsc, host)) {
active = g_list_append(active, strdup(rsc->id));
}
}
return active;
}
GList*
subtract_lists(GList *from, GList *items, GCompareFunc cmp)
{
GList *item = NULL;
GList *result = g_list_copy(from);
for (item = items; item != NULL; item = item->next) {
GList *candidate = NULL;
for (candidate = from; candidate != NULL; candidate = candidate->next) {
crm_info("Comparing %s with %s", (const char *) candidate->data,
(const char *) item->data);
if(cmp(candidate->data, item->data) == 0) {
result = g_list_remove(result, candidate->data);
break;
}
}
}
return result;
}
static void dump_list(GList *items, const char *tag)
{
int lpc = 0;
GList *item = NULL;
for (item = items; item != NULL; item = item->next) {
crm_trace("%s[%d]: %s", tag, lpc, (char*)item->data);
lpc++;
}
}
static void display_list(GList *items, const char *tag)
{
GList *item = NULL;
for (item = items; item != NULL; item = item->next) {
fprintf(stdout, "%s%s\n", tag, (const char *)item->data);
}
}
/*!
* \internal
* \brief Upgrade XML to latest schema version and use it as working set input
*
* This also updates the working set timestamp to the current time.
*
* \param[in] data_set Working set instance to update
* \param[in] xml XML to use as input
*
- * \return pcmk_ok on success, -ENOKEY if unable to upgrade XML
+ * \return Standard Pacemaker return code
* \note On success, caller is responsible for freeing memory allocated for
* data_set->now.
* \todo This follows the example of other callers of cli_config_update()
- * and returns -ENOKEY ("Required key not available") if that fails,
- * but perhaps -pcmk_err_schema_validation would be better in that case.
+ * and returns ENOKEY ("Required key not available") if that fails,
+ * but perhaps pcmk_rc_schema_validation would be better in that case.
*/
int
update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml)
{
if (cli_config_update(xml, NULL, FALSE) == FALSE) {
- return -ENOKEY;
+ return ENOKEY;
}
data_set->input = *xml;
data_set->now = crm_time_new(NULL);
- return pcmk_ok;
+ return pcmk_rc_ok;
}
/*!
* \internal
* \brief Update a working set's XML input based on a CIB query
*
* \param[in] data_set Data set instance to initialize
* \param[in] cib Connection to the CIB manager
*
- * \return pcmk_ok on success, -errno on failure
+ * \return Standard Pacemaker return code
* \note On success, caller is responsible for freeing memory allocated for
* data_set->input and data_set->now.
*/
static int
update_working_set_from_cib(pe_working_set_t * data_set, cib_t *cib)
{
xmlNode *cib_xml_copy = NULL;
- int rc;
+ int rc = pcmk_rc_ok;
rc = cib->cmds->query(cib, NULL, &cib_xml_copy, cib_scope_local | cib_sync_call);
- if (rc != pcmk_ok) {
+ rc = pcmk_legacy2rc(rc);
+
+ if (rc != pcmk_rc_ok) {
fprintf(stderr, "Could not obtain the current CIB: %s (%d)\n", pcmk_strerror(rc), rc);
return rc;
}
rc = update_working_set_xml(data_set, &cib_xml_copy);
- if (rc != pcmk_ok) {
+ if (rc != pcmk_rc_ok) {
fprintf(stderr, "Could not upgrade the current CIB XML\n");
free_xml(cib_xml_copy);
return rc;
}
- return pcmk_ok;
+
+ return rc;
}
+// \return Standard Pacemaker return code
static int
update_dataset(cib_t *cib, pe_working_set_t * data_set, bool simulate)
{
char *pid = NULL;
char *shadow_file = NULL;
cib_t *shadow_cib = NULL;
- int rc;
+ int rc = pcmk_rc_ok;
pe_reset_working_set(data_set);
rc = update_working_set_from_cib(data_set, cib);
- if (rc != pcmk_ok) {
+ if (rc != pcmk_rc_ok) {
return rc;
}
if(simulate) {
pid = pcmk__getpid_s();
shadow_cib = cib_shadow_new(pid);
shadow_file = get_shadow_file(pid);
if (shadow_cib == NULL) {
fprintf(stderr, "Could not create shadow cib: '%s'\n", pid);
- rc = -ENXIO;
+ rc = ENXIO;
goto cleanup;
}
rc = write_xml_file(data_set->input, shadow_file, FALSE);
if (rc < 0) {
fprintf(stderr, "Could not populate shadow cib: %s (%d)\n", pcmk_strerror(rc), rc);
goto cleanup;
}
rc = shadow_cib->cmds->signon(shadow_cib, crm_system_name, cib_command);
- if(rc != pcmk_ok) {
+ rc = pcmk_legacy2rc(rc);
+
+ if (rc != pcmk_rc_ok) {
fprintf(stderr, "Could not connect to shadow cib: %s (%d)\n", pcmk_strerror(rc), rc);
goto cleanup;
}
pcmk__schedule_actions(data_set, data_set->input, NULL);
run_simulation(data_set, shadow_cib, NULL, TRUE);
rc = update_dataset(shadow_cib, data_set, FALSE);
} else {
cluster_status(data_set);
}
cleanup:
/* Do not free data_set->input here, we need rsc->xml to be valid later on */
cib_delete(shadow_cib);
free(pid);
if(shadow_file) {
unlink(shadow_file);
free(shadow_file);
}
return rc;
}
static int
max_delay_for_resource(pe_working_set_t * data_set, pe_resource_t *rsc)
{
int delay = 0;
int max_delay = 0;
if(rsc && rsc->children) {
GList *iter = NULL;
for(iter = rsc->children; iter; iter = iter->next) {
pe_resource_t *child = (pe_resource_t *)iter->data;
delay = max_delay_for_resource(data_set, child);
if(delay > max_delay) {
double seconds = delay / 1000.0;
crm_trace("Calculated new delay of %.1fs due to %s", seconds, child->id);
max_delay = delay;
}
}
} else if(rsc) {
char *key = crm_strdup_printf("%s_%s_0", rsc->id, RSC_STOP);
pe_action_t *stop = custom_action(rsc, key, RSC_STOP, NULL, TRUE, FALSE, data_set);
const char *value = g_hash_table_lookup(stop->meta, XML_ATTR_TIMEOUT);
max_delay = value? (int) crm_parse_ll(value, NULL) : -1;
pe_free_action(stop);
}
return max_delay;
}
static int
max_delay_in(pe_working_set_t * data_set, GList *resources)
{
int max_delay = 0;
GList *item = NULL;
for (item = resources; item != NULL; item = item->next) {
int delay = 0;
pe_resource_t *rsc = pe_find_resource(data_set->resources, (const char *)item->data);
delay = max_delay_for_resource(data_set, rsc);
if(delay > max_delay) {
double seconds = delay / 1000.0;
crm_trace("Calculated new delay of %.1fs due to %s", seconds, rsc->id);
max_delay = delay;
}
}
return 5 + (max_delay / 1000);
}
#define waiting_for_starts(d, r, h) ((d != NULL) || \
(resource_is_running_on((r), (h)) == FALSE))
/*!
* \internal
* \brief Restart a resource (on a particular host if requested).
*
* \param[in] rsc The resource to restart
* \param[in] host The host to restart the resource on (or NULL for all)
* \param[in] timeout_ms Consider failed if actions do not complete in this time
* (specified in milliseconds, but a two-second
* granularity is actually used; if 0, a timeout will be
* calculated based on the resource timeout)
* \param[in] cib Connection to the CIB manager
*
- * \return pcmk_ok on success, -errno on failure (exits on certain failures)
+ * \return Standard Pacemaker return code (exits on certain failures)
*/
int
cli_resource_restart(pe_resource_t *rsc, const char *host, int timeout_ms,
- cib_t *cib)
+ cib_t *cib, int cib_options, gboolean promoted_role_only, gboolean force)
{
- int rc = 0;
+ int rc = pcmk_rc_ok;
int lpc = 0;
int before = 0;
int step_timeout_s = 0;
int sleep_interval = 2;
int timeout = timeout_ms / 1000;
bool stop_via_ban = FALSE;
char *rsc_id = NULL;
char *orig_target_role = NULL;
GList *list_delta = NULL;
GList *target_active = NULL;
GList *current_active = NULL;
GList *restart_target_active = NULL;
pe_working_set_t *data_set = NULL;
if(resource_is_running_on(rsc, host) == FALSE) {
const char *id = rsc->clone_name?rsc->clone_name:rsc->id;
if(host) {
printf("%s is not running on %s and so cannot be restarted\n", id, host);
} else {
printf("%s is not running anywhere and so cannot be restarted\n", id);
}
- return -ENXIO;
+ return ENXIO;
}
- /* We might set the target-role meta-attribute */
- attr_set_type = XML_TAG_META_SETS;
-
rsc_id = strdup(rsc->id);
if ((pe_rsc_is_clone(rsc) || pe_bundle_replicas(rsc)) && host) {
stop_via_ban = TRUE;
}
/*
grab full cib
determine originally active resources
disable or ban
poll cib and watch for affected resources to get stopped
without --timeout, calculate the stop timeout for each step and wait for that
if we hit --timeout or the service timeout, re-enable or un-ban, report failure and indicate which resources we couldn't take down
if everything stopped, re-enable or un-ban
poll cib and watch for affected resources to get started
without --timeout, calculate the start timeout for each step and wait for that
if we hit --timeout or the service timeout, report (different) failure and indicate which resources we couldn't bring back up
report success
Optimizations:
- use constraints to determine ordered list of affected resources
- Allow a --no-deps option (aka. --force-restart)
*/
data_set = pe_new_working_set();
if (data_set == NULL) {
crm_perror(LOG_ERR, "Could not allocate working set");
- rc = -ENOMEM;
+ rc = ENOMEM;
goto done;
}
set_bit(data_set->flags, pe_flag_no_counts);
set_bit(data_set->flags, pe_flag_no_compat);
rc = update_dataset(cib, data_set, FALSE);
- if(rc != pcmk_ok) {
+ if(rc != pcmk_rc_ok) {
fprintf(stdout, "Could not get new resource list: %s (%d)\n", pcmk_strerror(rc), rc);
goto done;
}
restart_target_active = get_active_resources(host, data_set->resources);
current_active = get_active_resources(host, data_set->resources);
dump_list(current_active, "Origin");
if (stop_via_ban) {
/* Stop the clone or bundle instance by banning it from the host */
BE_QUIET = TRUE;
- rc = cli_resource_ban(rsc_id, host, NULL, cib);
+ rc = cli_resource_ban(rsc_id, host, NULL, cib, cib_options, promoted_role_only);
} else {
/* Stop the resource by setting target-role to Stopped.
* Remember any existing target-role so we can restore it later
* (though it only makes any difference if it's Slave).
*/
char *lookup_id = clone_strip(rsc->id);
find_resource_attr(cib, XML_NVPAIR_ATTR_VALUE, lookup_id, NULL, NULL,
NULL, XML_RSC_ATTR_TARGET_ROLE, &orig_target_role);
free(lookup_id);
- rc = cli_resource_update_attribute(rsc, rsc_id, NULL, NULL,
+ rc = cli_resource_update_attribute(rsc, rsc_id, NULL, XML_TAG_META_SETS, NULL,
XML_RSC_ATTR_TARGET_ROLE,
- RSC_STOPPED, FALSE, cib, data_set);
+ RSC_STOPPED, FALSE, cib, cib_options,
+ data_set, force);
}
- if(rc != pcmk_ok) {
+ if(rc != pcmk_rc_ok) {
fprintf(stderr, "Could not set target-role for %s: %s (%d)\n", rsc_id, pcmk_strerror(rc), rc);
if (current_active) {
g_list_free_full(current_active, free);
}
if (restart_target_active) {
g_list_free_full(restart_target_active, free);
}
goto done;
}
rc = update_dataset(cib, data_set, TRUE);
- if(rc != pcmk_ok) {
+ if(rc != pcmk_rc_ok) {
fprintf(stderr, "Could not determine which resources would be stopped\n");
goto failure;
}
target_active = get_active_resources(host, data_set->resources);
dump_list(target_active, "Target");
list_delta = subtract_lists(current_active, target_active, (GCompareFunc) strcmp);
fprintf(stdout, "Waiting for %d resources to stop:\n", g_list_length(list_delta));
display_list(list_delta, " * ");
step_timeout_s = timeout / sleep_interval;
while (list_delta != NULL) {
before = g_list_length(list_delta);
if(timeout_ms == 0) {
step_timeout_s = max_delay_in(data_set, list_delta) / sleep_interval;
}
/* We probably don't need the entire step timeout */
for(lpc = 0; (lpc < step_timeout_s) && (list_delta != NULL); lpc++) {
sleep(sleep_interval);
if(timeout) {
timeout -= sleep_interval;
crm_trace("%ds remaining", timeout);
}
rc = update_dataset(cib, data_set, FALSE);
- if(rc != pcmk_ok) {
+ if(rc != pcmk_rc_ok) {
fprintf(stderr, "Could not determine which resources were stopped\n");
goto failure;
}
if (current_active) {
g_list_free_full(current_active, free);
}
current_active = get_active_resources(host, data_set->resources);
g_list_free(list_delta);
list_delta = subtract_lists(current_active, target_active, (GCompareFunc) strcmp);
dump_list(current_active, "Current");
dump_list(list_delta, "Delta");
}
crm_trace("%d (was %d) resources remaining", g_list_length(list_delta), before);
if(before == g_list_length(list_delta)) {
/* aborted during stop phase, print the contents of list_delta */
fprintf(stderr, "Could not complete shutdown of %s, %d resources remaining\n", rsc_id, g_list_length(list_delta));
display_list(list_delta, " * ");
- rc = -ETIME;
+ rc = ETIME;
goto failure;
}
}
if (stop_via_ban) {
- rc = cli_resource_clear(rsc_id, host, NULL, cib, TRUE);
+ rc = cli_resource_clear(rsc_id, host, NULL, cib, cib_options, TRUE, force);
} else if (orig_target_role) {
- rc = cli_resource_update_attribute(rsc, rsc_id, NULL, NULL,
- XML_RSC_ATTR_TARGET_ROLE,
+ rc = cli_resource_update_attribute(rsc, rsc_id, NULL, XML_TAG_META_SETS,
+ NULL, XML_RSC_ATTR_TARGET_ROLE,
orig_target_role, FALSE, cib,
- data_set);
+ cib_options, data_set, force);
free(orig_target_role);
orig_target_role = NULL;
} else {
- rc = cli_resource_delete_attribute(rsc, rsc_id, NULL, NULL,
+ rc = cli_resource_delete_attribute(rsc, rsc_id, NULL, XML_TAG_META_SETS, NULL,
XML_RSC_ATTR_TARGET_ROLE, cib,
- data_set);
+ cib_options, data_set, force);
}
- if(rc != pcmk_ok) {
+ if(rc != pcmk_rc_ok) {
fprintf(stderr, "Could not unset target-role for %s: %s (%d)\n", rsc_id, pcmk_strerror(rc), rc);
goto done;
}
if (target_active) {
g_list_free_full(target_active, free);
}
target_active = restart_target_active;
list_delta = subtract_lists(target_active, current_active, (GCompareFunc) strcmp);
fprintf(stdout, "Waiting for %d resources to start again:\n", g_list_length(list_delta));
display_list(list_delta, " * ");
step_timeout_s = timeout / sleep_interval;
while (waiting_for_starts(list_delta, rsc, host)) {
before = g_list_length(list_delta);
if(timeout_ms == 0) {
step_timeout_s = max_delay_in(data_set, list_delta) / sleep_interval;
}
/* We probably don't need the entire step timeout */
for (lpc = 0; (lpc < step_timeout_s) && waiting_for_starts(list_delta, rsc, host); lpc++) {
sleep(sleep_interval);
if(timeout) {
timeout -= sleep_interval;
crm_trace("%ds remaining", timeout);
}
rc = update_dataset(cib, data_set, FALSE);
- if(rc != pcmk_ok) {
+ if(rc != pcmk_rc_ok) {
fprintf(stderr, "Could not determine which resources were started\n");
goto failure;
}
if (current_active) {
g_list_free_full(current_active, free);
}
/* It's OK if dependent resources moved to a different node,
* so we check active resources on all nodes.
*/
current_active = get_active_resources(NULL, data_set->resources);
g_list_free(list_delta);
list_delta = subtract_lists(target_active, current_active, (GCompareFunc) strcmp);
dump_list(current_active, "Current");
dump_list(list_delta, "Delta");
}
if(before == g_list_length(list_delta)) {
/* aborted during start phase, print the contents of list_delta */
fprintf(stdout, "Could not complete restart of %s, %d resources remaining\n", rsc_id, g_list_length(list_delta));
display_list(list_delta, " * ");
- rc = -ETIME;
+ rc = ETIME;
goto failure;
}
}
- rc = pcmk_ok;
+ rc = pcmk_rc_ok;
goto done;
failure:
if (stop_via_ban) {
- cli_resource_clear(rsc_id, host, NULL, cib, TRUE);
+ cli_resource_clear(rsc_id, host, NULL, cib, cib_options, TRUE, force);
} else if (orig_target_role) {
- cli_resource_update_attribute(rsc, rsc_id, NULL, NULL,
- XML_RSC_ATTR_TARGET_ROLE,
- orig_target_role, FALSE, cib, data_set);
+ cli_resource_update_attribute(rsc, rsc_id, NULL, XML_TAG_META_SETS, NULL,
+ XML_RSC_ATTR_TARGET_ROLE, orig_target_role,
+ FALSE, cib, cib_options, data_set, force);
free(orig_target_role);
} else {
- cli_resource_delete_attribute(rsc, rsc_id, NULL, NULL,
- XML_RSC_ATTR_TARGET_ROLE, cib, data_set);
+ cli_resource_delete_attribute(rsc, rsc_id, NULL, XML_TAG_META_SETS, NULL,
+ XML_RSC_ATTR_TARGET_ROLE, cib, cib_options,
+ data_set, force);
}
done:
if (list_delta) {
g_list_free(list_delta);
}
if (current_active) {
g_list_free_full(current_active, free);
}
if (target_active && (target_active != restart_target_active)) {
g_list_free_full(target_active, free);
}
if (restart_target_active) {
g_list_free_full(restart_target_active, free);
}
free(rsc_id);
pe_free_working_set(data_set);
return rc;
}
-static inline int action_is_pending(pe_action_t *action)
+static inline bool action_is_pending(pe_action_t *action)
{
if(is_set(action->flags, pe_action_optional)) {
- return FALSE;
+ return false;
} else if(is_set(action->flags, pe_action_runnable) == FALSE) {
- return FALSE;
+ return false;
} else if(is_set(action->flags, pe_action_pseudo)) {
- return FALSE;
+ return false;
} else if(safe_str_eq("notify", action->task)) {
- return FALSE;
+ return false;
}
- return TRUE;
+ return true;
}
/*!
* \internal
* \brief Return TRUE if any actions in a list are pending
*
* \param[in] actions List of actions to check
*
* \return TRUE if any actions in the list are pending, FALSE otherwise
*/
static bool
actions_are_pending(GListPtr actions)
{
GListPtr action;
for (action = actions; action != NULL; action = action->next) {
pe_action_t *a = (pe_action_t *)action->data;
if (action_is_pending(a)) {
crm_notice("Waiting for %s (flags=0x%.8x)", a->uuid, a->flags);
return TRUE;
}
}
return FALSE;
}
/*!
* \internal
* \brief Print pending actions to stderr
*
* \param[in] actions List of actions to check
*
* \return void
*/
static void
print_pending_actions(GListPtr actions)
{
GListPtr action;
fprintf(stderr, "Pending actions:\n");
for (action = actions; action != NULL; action = action->next) {
pe_action_t *a = (pe_action_t *) action->data;
if (action_is_pending(a)) {
fprintf(stderr, "\tAction %d: %s", a->id, a->uuid);
if (a->node) {
fprintf(stderr, "\ton %s", a->node->details->uname);
}
fprintf(stderr, "\n");
}
}
}
/* For --wait, timeout (in seconds) to use if caller doesn't specify one */
#define WAIT_DEFAULT_TIMEOUT_S (60 * 60)
/* For --wait, how long to sleep between cluster state checks */
#define WAIT_SLEEP_S (2)
/*!
* \internal
* \brief Wait until all pending cluster actions are complete
*
* This waits until either the CIB's transition graph is idle or a timeout is
* reached.
*
* \param[in] timeout_ms Consider failed if actions do not complete in this time
* (specified in milliseconds, but one-second granularity
* is actually used; if 0, a default will be used)
* \param[in] cib Connection to the CIB manager
*
- * \return pcmk_ok on success, -errno on failure
+ * \return Standard Pacemaker return code
*/
int
wait_till_stable(int timeout_ms, cib_t * cib)
{
pe_working_set_t *data_set = NULL;
- int rc = -1;
+ int rc = pcmk_rc_ok;
int timeout_s = timeout_ms? ((timeout_ms + 999) / 1000) : WAIT_DEFAULT_TIMEOUT_S;
time_t expire_time = time(NULL) + timeout_s;
time_t time_diff;
bool printed_version_warning = BE_QUIET; // i.e. don't print if quiet
data_set = pe_new_working_set();
if (data_set == NULL) {
- return -ENOMEM;
+ return ENOMEM;
}
set_bit(data_set->flags, pe_flag_no_counts);
set_bit(data_set->flags, pe_flag_no_compat);
do {
/* Abort if timeout is reached */
time_diff = expire_time - time(NULL);
if (time_diff > 0) {
crm_info("Waiting up to %ld seconds for cluster actions to complete", time_diff);
} else {
print_pending_actions(data_set->actions);
pe_free_working_set(data_set);
- return -ETIME;
+ return ETIME;
}
- if (rc == pcmk_ok) { /* this avoids sleep on first loop iteration */
+ if (rc == pcmk_rc_ok) { /* this avoids sleep on first loop iteration */
sleep(WAIT_SLEEP_S);
}
/* Get latest transition graph */
pe_reset_working_set(data_set);
rc = update_working_set_from_cib(data_set, cib);
- if (rc != pcmk_ok) {
+ if (rc != pcmk_rc_ok) {
pe_free_working_set(data_set);
return rc;
}
pcmk__schedule_actions(data_set, data_set->input, NULL);
if (!printed_version_warning) {
/* If the DC has a different version than the local node, the two
* could come to different conclusions about what actions need to be
* done. Warn the user in this case.
*
* @TODO A possible long-term solution would be to reimplement the
* wait as a new controller operation that would be forwarded to the
* DC. However, that would have potential problems of its own.
*/
const char *dc_version = g_hash_table_lookup(data_set->config_hash,
"dc-version");
if (safe_str_neq(dc_version, PACEMAKER_VERSION "-" BUILD_VERSION)) {
printf("warning: wait option may not work properly in "
"mixed-version cluster\n");
printed_version_warning = TRUE;
}
}
} while (actions_are_pending(data_set->actions));
pe_free_working_set(data_set);
- return pcmk_ok;
+ return rc;
}
-int
+crm_exit_t
cli_resource_execute_from_params(const char *rsc_name, const char *rsc_class,
const char *rsc_prov, const char *rsc_type,
const char *action, GHashTable *params,
- GHashTable *override_hash, int timeout_ms)
+ GHashTable *override_hash, int timeout_ms,
+ int resource_verbose, gboolean force)
{
GHashTable *params_copy = NULL;
- int rc = pcmk_ok;
+ crm_exit_t exit_code = CRM_EX_OK;
svc_action_t *op = NULL;
if (safe_str_eq(rsc_class, PCMK_RESOURCE_CLASS_STONITH)) {
CMD_ERR("Sorry, the %s option doesn't support %s resources yet",
action, rsc_class);
crm_exit(CRM_EX_UNIMPLEMENT_FEATURE);
}
/* If no timeout was provided, grab the default. */
if (timeout_ms == 0) {
timeout_ms = crm_get_msec(CRM_DEFAULT_OP_TIMEOUT_S);
}
/* add meta_timeout env needed by some resource agents */
g_hash_table_insert(params, strdup("CRM_meta_timeout"),
crm_strdup_printf("%d", timeout_ms));
/* add crm_feature_set env needed by some resource agents */
g_hash_table_insert(params, strdup(XML_ATTR_CRM_VERSION), strdup(CRM_FEATURE_SET));
/* resources_action_create frees the params hash table it's passed, but we
* may need to reuse it in a second call to resources_action_create. Thus
* we'll make a copy here so that gets freed and the original remains for
* reuse.
*/
params_copy = crm_str_table_dup(params);
op = resources_action_create(rsc_name, rsc_class, rsc_prov, rsc_type, action, 0,
timeout_ms, params_copy, 0);
if (op == NULL) {
/* Re-run with stderr enabled so we can display a sane error message */
crm_enable_stderr(TRUE);
params_copy = crm_str_table_dup(params);
op = resources_action_create(rsc_name, rsc_class, rsc_prov, rsc_type, action, 0,
timeout_ms, params_copy, 0);
/* Callers of cli_resource_execute expect that the params hash table will
* be freed. That function uses this one, so for that reason and for
* making the two act the same, we should free the hash table here too.
*/
g_hash_table_destroy(params);
/* We know op will be NULL, but this makes static analysis happy */
services_action_free(op);
crm_exit(CRM_EX_DATAERR);
- return rc; // Never reached, but helps static analysis
+ return exit_code; // Never reached, but helps static analysis
}
setenv("HA_debug", resource_verbose > 0 ? "1" : "0", 1);
if(resource_verbose > 1) {
setenv("OCF_TRACE_RA", "1", 1);
}
/* A resource agent using the standard ocf-shellfuncs library will not print
* messages to stderr if it doesn't have a controlling terminal (e.g. if
* crm_resource is called via script or ssh). This forces it to do so.
*/
setenv("OCF_TRACE_FILE", "/dev/stderr", 0);
if (override_hash) {
GHashTableIter iter;
char *name = NULL;
char *value = NULL;
g_hash_table_iter_init(&iter, override_hash);
while (g_hash_table_iter_next(&iter, (gpointer *) & name, (gpointer *) & value)) {
printf("Overriding the cluster configuration for '%s' with '%s' = '%s'\n",
rsc_name, name, value);
g_hash_table_replace(op->params, strdup(name), strdup(value));
}
}
if (services_action_sync(op)) {
int more, lpc, last;
char *local_copy = NULL;
- rc = op->rc;
+ exit_code = op->rc;
if (op->status == PCMK_LRM_OP_DONE) {
printf("Operation %s for %s (%s:%s:%s) returned: '%s' (%d)\n",
action, rsc_name, rsc_class, rsc_prov ? rsc_prov : "", rsc_type,
services_ocf_exitcode_str(op->rc), op->rc);
} else {
printf("Operation %s for %s (%s:%s:%s) failed: '%s' (%d)\n",
action, rsc_name, rsc_class, rsc_prov ? rsc_prov : "", rsc_type,
services_lrm_status_str(op->status), op->status);
}
/* hide output for validate-all if not in verbose */
if (resource_verbose == 0 && safe_str_eq(action, "validate-all"))
goto done;
if (op->stdout_data) {
local_copy = strdup(op->stdout_data);
more = strlen(local_copy);
last = 0;
for (lpc = 0; lpc < more; lpc++) {
if (local_copy[lpc] == '\n' || local_copy[lpc] == 0) {
local_copy[lpc] = 0;
printf(" > stdout: %s\n", local_copy + last);
last = lpc + 1;
}
}
free(local_copy);
}
if (op->stderr_data) {
local_copy = strdup(op->stderr_data);
more = strlen(local_copy);
last = 0;
for (lpc = 0; lpc < more; lpc++) {
if (local_copy[lpc] == '\n' || local_copy[lpc] == 0) {
local_copy[lpc] = 0;
printf(" > stderr: %s\n", local_copy + last);
last = lpc + 1;
}
}
free(local_copy);
}
} else {
- rc = op->rc == 0 ? pcmk_err_generic : op->rc;
+ exit_code = op->rc == 0 ? CRM_EX_ERROR : op->rc;
}
done:
services_action_free(op);
/* See comment above about why we free params here. */
g_hash_table_destroy(params);
- return rc;
+ return exit_code;
}
-int
+crm_exit_t
cli_resource_execute(pe_resource_t *rsc, const char *requested_name,
const char *rsc_action, GHashTable *override_hash,
- int timeout_ms, cib_t * cib, pe_working_set_t *data_set)
+ int timeout_ms, cib_t * cib, pe_working_set_t *data_set,
+ int resource_verbose, gboolean force)
{
- int rc = pcmk_ok;
+ crm_exit_t exit_code = CRM_EX_OK;
const char *rid = NULL;
const char *rtype = NULL;
const char *rprov = NULL;
const char *rclass = NULL;
const char *action = NULL;
GHashTable *params = NULL;
if (safe_str_eq(rsc_action, "validate")) {
action = "validate-all";
} else if (safe_str_eq(rsc_action, "force-check")) {
action = "monitor";
} else if (safe_str_eq(rsc_action, "force-stop")) {
action = rsc_action+6;
} else if (pcmk__str_any_of(rsc_action, "force-start", "force-demote",
"force-promote", NULL)) {
action = rsc_action+6;
if(pe_rsc_is_clone(rsc)) {
- rc = cli_resource_search(rsc, requested_name, data_set);
- if(rc > 0 && do_force == FALSE) {
+ int rc = cli_resource_search(rsc, requested_name, data_set);
+ if(rc > 0 && force == FALSE) {
CMD_ERR("It is not safe to %s %s here: the cluster claims it is already active",
action, rsc->id);
CMD_ERR("Try setting target-role=Stopped first or specifying "
"the force option");
crm_exit(CRM_EX_UNSAFE);
}
}
} else {
action = rsc_action;
}
if(pe_rsc_is_clone(rsc)) {
/* Grab the first child resource in the hope it's not a group */
rsc = rsc->children->data;
}
if(rsc->variant == pe_group) {
CMD_ERR("Sorry, the %s option doesn't support group resources",
rsc_action);
crm_exit(CRM_EX_UNIMPLEMENT_FEATURE);
}
rclass = crm_element_value(rsc->xml, XML_AGENT_ATTR_CLASS);
rprov = crm_element_value(rsc->xml, XML_AGENT_ATTR_PROVIDER);
rtype = crm_element_value(rsc->xml, XML_ATTR_TYPE);
params = generate_resource_params(rsc, data_set);
if (timeout_ms == 0) {
timeout_ms = pe_get_configured_timeout(rsc, action, data_set);
}
rid = pe_rsc_is_anon_clone(rsc->parent)? requested_name : rsc->id;
- rc = cli_resource_execute_from_params(rid, rclass, rprov, rtype, action,
- params, override_hash, timeout_ms);
- return rc;
+ exit_code = cli_resource_execute_from_params(rid, rclass, rprov, rtype, action,
+ params, override_hash, timeout_ms,
+ resource_verbose, force);
+ return exit_code;
}
+// \return Standard Pacemaker return code
int
cli_resource_move(pe_resource_t *rsc, const char *rsc_id, const char *host_name,
- cib_t *cib, pe_working_set_t *data_set)
+ cib_t *cib, int cib_options, pe_working_set_t *data_set,
+ gboolean promoted_role_only, gboolean force)
{
- int rc = pcmk_ok;
+ int rc = pcmk_rc_ok;
unsigned int count = 0;
pe_node_t *current = NULL;
pe_node_t *dest = pe_find_node(data_set->nodes, host_name);
bool cur_is_dest = FALSE;
if (dest == NULL) {
- return -pcmk_err_node_unknown;
+ return pcmk_rc_node_unknown;
}
- if (scope_master && is_not_set(rsc->flags, pe_rsc_promotable)) {
+ if (promoted_role_only && is_not_set(rsc->flags, pe_rsc_promotable)) {
pe_resource_t *p = uber_parent(rsc);
if (is_set(p->flags, pe_rsc_promotable)) {
CMD_ERR("Using parent '%s' for move instead of '%s'.", rsc->id, rsc_id);
rsc_id = p->id;
rsc = p;
} else {
CMD_ERR("Ignoring master option: %s is not promotable", rsc_id);
- scope_master = FALSE;
+ promoted_role_only = FALSE;
}
}
current = pe__find_active_requires(rsc, &count);
if (is_set(rsc->flags, pe_rsc_promotable)) {
GListPtr iter = NULL;
unsigned int master_count = 0;
pe_node_t *master_node = NULL;
for(iter = rsc->children; iter; iter = iter->next) {
pe_resource_t *child = (pe_resource_t *)iter->data;
enum rsc_role_e child_role = child->fns->state(child, TRUE);
if(child_role == RSC_ROLE_MASTER) {
rsc = child;
master_node = pe__current_node(child);
master_count++;
}
}
- if (scope_master || master_count) {
+ if (promoted_role_only || master_count) {
count = master_count;
current = master_node;
}
}
if (count > 1) {
if (pe_rsc_is_clone(rsc)) {
current = NULL;
} else {
- return -pcmk_err_multiple;
+ return pcmk_rc_multiple;
}
}
if (current && (current->details == dest->details)) {
cur_is_dest = TRUE;
- if (do_force) {
+ if (force) {
crm_info("%s is already %s on %s, reinforcing placement with location constraint.",
- rsc_id, scope_master?"promoted":"active", dest->details->uname);
+ rsc_id, promoted_role_only?"promoted":"active", dest->details->uname);
} else {
- return -pcmk_err_already;
+ return pcmk_rc_already;
}
}
/* Clear any previous prefer constraints across all nodes. */
- cli_resource_clear(rsc_id, NULL, data_set->nodes, cib, FALSE);
+ cli_resource_clear(rsc_id, NULL, data_set->nodes, cib, cib_options, FALSE, force);
/* Clear any previous ban constraints on 'dest'. */
- cli_resource_clear(rsc_id, dest->details->uname, data_set->nodes, cib, TRUE);
+ cli_resource_clear(rsc_id, dest->details->uname, data_set->nodes, cib,
+ cib_options, TRUE, force);
/* Record an explicit preference for 'dest' */
- rc = cli_resource_prefer(rsc_id, dest->details->uname, cib);
+ rc = cli_resource_prefer(rsc_id, dest->details->uname, cib, cib_options,
+ promoted_role_only);
crm_trace("%s%s now prefers node %s%s",
- rsc->id, scope_master?" (master)":"", dest->details->uname, do_force?"(forced)":"");
+ rsc->id, promoted_role_only?" (master)":"", dest->details->uname, force?"(forced)":"");
/* only ban the previous location if current location != destination location.
* it is possible to use -M to enforce a location without regard of where the
* resource is currently located */
- if(do_force && (cur_is_dest == FALSE)) {
+ if(force && (cur_is_dest == FALSE)) {
/* Ban the original location if possible */
if(current) {
- (void)cli_resource_ban(rsc_id, current->details->uname, NULL, cib);
+ (void)cli_resource_ban(rsc_id, current->details->uname, NULL, cib,
+ cib_options, promoted_role_only);
} else if(count > 1) {
CMD_ERR("Resource '%s' is currently %s in %d locations. "
"One may now move to %s",
- rsc_id, (scope_master? "promoted" : "active"),
+ rsc_id, (promoted_role_only? "promoted" : "active"),
count, dest->details->uname);
CMD_ERR("To prevent '%s' from being %s at a specific location, "
"specify a node.",
- rsc_id, (scope_master? "promoted" : "active"));
+ rsc_id, (promoted_role_only? "promoted" : "active"));
} else {
crm_trace("Not banning %s from its current location: not active", rsc_id);
}
}
return rc;
}
static void
cli_resource_why_without_rsc_and_host(cib_t *cib_conn,GListPtr resources)
{
GListPtr lpc = NULL;
GListPtr hosts = NULL;
for (lpc = resources; lpc != NULL; lpc = lpc->next) {
pe_resource_t *rsc = (pe_resource_t *) lpc->data;
rsc->fns->location(rsc, &hosts, TRUE);
if (hosts == NULL) {
printf("Resource %s is not running\n", rsc->id);
} else {
printf("Resource %s is running\n", rsc->id);
}
cli_resource_check(cib_conn, rsc);
g_list_free(hosts);
hosts = NULL;
}
}
static void
cli_resource_why_with_rsc_and_host(cib_t *cib_conn, GListPtr resources,
pe_resource_t *rsc, const char *host_uname)
{
if (resource_is_running_on(rsc, host_uname)) {
printf("Resource %s is running on host %s\n",rsc->id,host_uname);
} else {
printf("Resource %s is not running on host %s\n", rsc->id, host_uname);
}
cli_resource_check(cib_conn, rsc);
}
static void
cli_resource_why_without_rsc_with_host(cib_t *cib_conn,GListPtr resources,pe_node_t *node)
{
const char* host_uname = node->details->uname;
GListPtr allResources = node->details->allocated_rsc;
GListPtr activeResources = node->details->running_rsc;
GListPtr unactiveResources = subtract_lists(allResources,activeResources,(GCompareFunc) strcmp);
GListPtr lpc = NULL;
for (lpc = activeResources; lpc != NULL; lpc = lpc->next) {
pe_resource_t *rsc = (pe_resource_t *) lpc->data;
printf("Resource %s is running on host %s\n",rsc->id,host_uname);
cli_resource_check(cib_conn,rsc);
}
for(lpc = unactiveResources; lpc != NULL; lpc = lpc->next) {
pe_resource_t *rsc = (pe_resource_t *) lpc->data;
printf("Resource %s is assigned to host %s but not running\n",
rsc->id, host_uname);
cli_resource_check(cib_conn,rsc);
}
g_list_free(allResources);
g_list_free(activeResources);
g_list_free(unactiveResources);
}
static void
cli_resource_why_with_rsc_without_host(cib_t *cib_conn, GListPtr resources,
pe_resource_t *rsc)
{
GListPtr hosts = NULL;
rsc->fns->location(rsc, &hosts, TRUE);
printf("Resource %s is %srunning\n", rsc->id, (hosts? "" : "not "));
cli_resource_check(cib_conn, rsc);
g_list_free(hosts);
}
void cli_resource_why(cib_t *cib_conn, GListPtr resources, pe_resource_t *rsc,
pe_node_t *node)
{
const char *host_uname = (node == NULL)? NULL : node->details->uname;
if ((rsc == NULL) && (host_uname == NULL)) {
cli_resource_why_without_rsc_and_host(cib_conn, resources);
} else if ((rsc != NULL) && (host_uname != NULL)) {
cli_resource_why_with_rsc_and_host(cib_conn, resources, rsc,
host_uname);
} else if ((rsc == NULL) && (host_uname != NULL)) {
cli_resource_why_without_rsc_with_host(cib_conn, resources, node);
} else if ((rsc != NULL) && (host_uname == NULL)) {
cli_resource_why_with_rsc_without_host(cib_conn, resources, rsc);
}
}