No OneTemporary
Actions

Size

47 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/heartbeat/mariadb.in b/heartbeat/mariadb.in
	old mode 100644
	new mode 100755
	index 1dca98ba6..b0b741e0f
	--- a/heartbeat/mariadb.in
	+++ b/heartbeat/mariadb.in
	@@ -1,1039 +1,1082 @@
	#!@BASH_SHELL@
	#
	#
	# MariaDB
	#
	# Description: Manages a MariaDB Promotable database as Linux-HA resource
	#
	# Authors: Alan Robertson: DB2 Script
	# Jakub Janczak: rewrite as MySQL
	# Andrew Beekhof: cleanup and import
	# Sebastian Reitenbach: add OpenBSD defaults, more cleanup
	# Narayan Newton: add Gentoo/Debian defaults
	# Marian Marinov, Florian Haas: add replication capability
	# Yves Trudeau, Baron Schwartz: add VIP support and improve replication
	# Nils Carlson: add GTID support and semi-sync support
	#
	# Support: users@clusterlabs.org
	# License: GNU General Public License (GPL)
	#
	# (c) 2002-2005 International Business Machines, Inc.
	# 2005-2010 Linux-HA contributors
	#
	# See usage() function below for more details...
	#
	# OCF instance parameters:
	# OCF_RESKEY_binary
	# OCF_RESKEY_client_binary
	# OCF_RESKEY_config
	# OCF_RESKEY_datadir
	# OCF_RESKEY_user
	# OCF_RESKEY_group
	# OCF_RESKEY_node_list
	# OCF_RESKEY_test_table
	# OCF_RESKEY_test_user
	# OCF_RESKEY_test_passwd
	# OCF_RESKEY_enable_creation
	# OCF_RESKEY_additional_parameters
	# OCF_RESKEY_log
	# OCF_RESKEY_pid
	# OCF_RESKEY_socket
	# OCF_RESKEY_replication_user
	# OCF_RESKEY_replication_passwd
	# OCF_RESKEY_replication_port
	#######################################################################
	# Initialization:

	OCF_RESKEY_node_list_default=""

	: ${OCF_FUNCTIONS_DIR=${OCF_ROOT}/lib/heartbeat}
	. ${OCF_FUNCTIONS_DIR}/ocf-shellfuncs
	. ${OCF_FUNCTIONS_DIR}/mysql-common.sh
	#######################################################################

	usage() {
	cat <<UEND
	usage: $0 (start\|stop\|validate-all\|meta-data\|monitor\|promote\|demote\|notify)

	$0 manages a MariaDB Database as an HA resource.

	The 'start' operation starts the database.
	The 'stop' operation stops the database.
	The 'status' operation reports whether the database is running
	The 'monitor' operation reports whether the database seems to be working
	The 'promote' operation makes this mysql server run as promoted
	The 'demote' operation makes this mysql server run as unpromoted
	The 'validate-all' operation reports whether the parameters are valid

	UEND
	}

	meta_data() {
	cat <<END
	<?xml version="1.0"?>
	<!DOCTYPE resource-agent SYSTEM "ra-api-1.dtd">
	<resource-agent name="mariadb" version="1.0">
	<version>1.0</version>

	<longdesc lang="en">
	Resource script for MariaDB.

	Manages a complete promotable replication setup with GTID, for simpler
	uses look at the mysql resource agent which supports older replication
	forms which mysql and mariadb have in common.

	The resource must be setup to use notifications. Set 'notify=true' in the metadata
	attributes when defining a MariaDB promotable instance.

	The default behavior is to use uname -n values in the change promoted to command.
	Other IPs can be specified manually by adding a node attribute
	\${INSTANCE_ATTR_NAME}_mysql_master_IP giving the IP to use for replication.
	For example, if the mariadb primitive you are using is p_mariadb, the
	attribute to set will be p_mariadb_mysql_master_IP.
	</longdesc>
	<shortdesc lang="en">Manages a MariaDB promotable instance</shortdesc>
	<parameters>

	<parameter name="binary" unique="0" required="0">
	<longdesc lang="en">
	Location of the MariaDB server binary
	</longdesc>
	<shortdesc lang="en">MariaDB server binary</shortdesc>
	<content type="string" default="${OCF_RESKEY_binary_default}" />
	</parameter>

	<parameter name="client_binary" unique="0" required="0">
	<longdesc lang="en">
	Location of the MariaDB client binary
	</longdesc>
	<shortdesc lang="en">MariaDB client binary</shortdesc>
	<content type="string" default="${OCF_RESKEY_client_binary_default}" />
	</parameter>

	<parameter name="config" unique="0" required="0">
	<longdesc lang="en">
	Configuration file
	</longdesc>
	<shortdesc lang="en">MariaDB config</shortdesc>
	<content type="string" default="${OCF_RESKEY_config_default}" />
	</parameter>

	<parameter name="datadir" unique="0" required="0">
	<longdesc lang="en">
	Directory containing databases
	</longdesc>
	<shortdesc lang="en">MariaDB datadir</shortdesc>
	<content type="string" default="${OCF_RESKEY_datadir_default}" />
	</parameter>

	<parameter name="user" unique="0" required="0">
	<longdesc lang="en">
	User running MariaDB daemon
	</longdesc>
	<shortdesc lang="en">MariaDB user</shortdesc>
	<content type="string" default="${OCF_RESKEY_user_default}" />
	</parameter>

	<parameter name="group" unique="0" required="0">
	<longdesc lang="en">
	Group running MariaDB daemon (for logfile and directory permissions)
	</longdesc>
	<shortdesc lang="en">MariaDB group</shortdesc>
	<content type="string" default="${OCF_RESKEY_group_default}"/>
	</parameter>

	<parameter name="log" unique="0" required="0">
	<longdesc lang="en">
	The logfile to be used for mysqld.
	</longdesc>
	<shortdesc lang="en">MariaDB log file</shortdesc>
	<content type="string" default="${OCF_RESKEY_log_default}"/>
	</parameter>

	<parameter name="node_list" unique="0" required="1">
	<longdesc lang="en">
	All node names of nodes that will execute mariadb.
	Please separate each node name with a space.
	This is required for the promoted selection to function.
	</longdesc>
	<shortdesc lang="en">node list</shortdesc>
	<content type="string" default="${OCF_RESKEY_node_list_default}" />
	</parameter>

	<parameter name="pid" unique="0" required="0">
	<longdesc lang="en">
	The pidfile to be used for mysqld.
	</longdesc>
	<shortdesc lang="en">MariaDB pid file</shortdesc>
	<content type="string" default="${OCF_RESKEY_pid_default}"/>
	</parameter>

	<parameter name="socket" unique="0" required="0">
	<longdesc lang="en">
	The socket to be used for mysqld.
	</longdesc>
	<shortdesc lang="en">MariaDB socket</shortdesc>
	<content type="string" default="${OCF_RESKEY_socket_default}"/>
	</parameter>

	<parameter name="test_table" unique="0" required="0">
	<longdesc lang="en">
	Table to be tested in monitor statement (in database.table notation)
	</longdesc>
	<shortdesc lang="en">MariaDB test table</shortdesc>
	<content type="string" default="${OCF_RESKEY_test_table_default}" />
	</parameter>

	<parameter name="test_user" unique="0" required="0">
	<longdesc lang="en">
	MariaDB test user, must have select privilege on test_table
	</longdesc>
	<shortdesc lang="en">MariaDB test user</shortdesc>
	<content type="string" default="${OCF_RESKEY_test_user_default}" />
	</parameter>

	<parameter name="test_passwd" unique="0" required="0">
	<longdesc lang="en">
	MariaDB test user password
	</longdesc>
	<shortdesc lang="en">MariaDB test user password</shortdesc>
	<content type="string" default="${OCF_RESKEY_test_passwd_default}" />
	</parameter>

	<parameter name="enable_creation" unique="0" required="0">
	<longdesc lang="en">
	If the MariaDB database does not exist, it will be created
	</longdesc>
	<shortdesc lang="en">Create the database if it does not exist</shortdesc>
	<content type="boolean" default="${OCF_RESKEY_enable_creation_default}"/>
	</parameter>

	<parameter name="additional_parameters" unique="0" required="0">
	<longdesc lang="en">
	Additional parameters which are passed to the mysqld on startup.
	(e.g. --skip-external-locking or --skip-grant-tables)
	</longdesc>
	<shortdesc lang="en">Additional parameters to pass to mysqld</shortdesc>
	<content type="string" default="${OCF_RESKEY_additional_parameters_default}"/>
	</parameter>

	<parameter name="replication_user" unique="0" required="0">
	<longdesc lang="en">
	MariaDB replication user. This user is used for starting and stopping
	MariaDB replication, for setting and resetting the promoted host, and for
	setting and unsetting read-only mode. Because of that, this user must
	have SUPER, REPLICATION SLAVE, REPLICATION CLIENT, PROCESS and RELOAD
	privileges on all nodes within the cluster. Mandatory if you define a
	promotable resource.
	</longdesc>
	<shortdesc lang="en">MariaDB replication user</shortdesc>
	<content type="string" default="${OCF_RESKEY_replication_user_default}" />
	</parameter>

	<parameter name="replication_passwd" unique="0" required="0">
	<longdesc lang="en">
	MariaDB replication password. Used for replication client and unpromoted.
	Mandatory if you define a promotable resource.
	</longdesc>
	<shortdesc lang="en">MariaDB replication user password</shortdesc>
	<content type="string" default="${OCF_RESKEY_replication_passwd_default}" />
	</parameter>

	<parameter name="replication_port" unique="0" required="0">
	<longdesc lang="en">
	The port on which the Promoted MariaDB instance is listening.
	</longdesc>
	<shortdesc lang="en">MariaDB replication port</shortdesc>
	<content type="string" default="${OCF_RESKEY_replication_port_default}" />
	</parameter>

	+<parameter name="replication_require_ssl" unique="0" required="0">
	+<longdesc lang="en">
	+Enables SSL connection to local MySQL service for replication user.
	+i.e. if REQUIRE SSL for replication user in MySQL set, this should be set to "true".
	+</longdesc>
	+<shortdesc lang="en">MySQL replication require ssl</shortdesc>
	+<content type="string" default="${OCF_RESKEY_replication_require_ssl_default}" />
	+</parameter>
	+
	+<parameter name="replication_master_ssl_ca" unique="0" required="0">
	+<longdesc lang="en">
	+The SSL CA certificate to be used for replication over SSL.
	+</longdesc>
	+<shortdesc lang="en">MySQL replication SSL CA certificate</shortdesc>
	+<content type="string" default="${OCF_RESKEY_replication_master_ssl_ca_default}" />
	+</parameter>
	+
	+<parameter name="replication_master_ssl_cert" unique="0" required="0">
	+<longdesc lang="en">
	+The SSL CA certificate to be used for replication over SSL.
	+</longdesc>
	+<shortdesc lang="en">MySQL replication SSL certificate</shortdesc>
	+<content type="string" default="${OCF_RESKEY_replication_master_ssl_cert_default}" />
	+</parameter>
	+
	+<parameter name="replication_master_ssl_key" unique="0" required="0">
	+<longdesc lang="en">
	+The SSL certificate key to be used for replication over SSL.
	+</longdesc>
	+<shortdesc lang="en">MySQL replication SSL certificate key</shortdesc>
	+<content type="string" default="${OCF_RESKEY_replication_master_ssl_key_default}" />
	+</parameter>
	+
	</parameters>

	<actions>
	<action name="start" timeout="120s" />
	<action name="stop" timeout="120s" />
	<action name="status" timeout="60s" />
	<action name="monitor" depth="0" timeout="30s" interval="20s" />
	<action name="monitor" role="Promoted" depth="0" timeout="30s" interval="10s" />
	+<action name="monitor" role="Unpromoted" depth="0" timeout="30s" interval="30s" />
	<action name="promote" timeout="120s" />
	<action name="demote" timeout="120s" />
	<action name="notify" timeout="90s" />
	<action name="validate-all" timeout="5s" />
	<action name="meta-data" timeout="5s" />
	</actions>
	</resource-agent>
	END
	}

	# Convenience functions

	greater_than_equal_long()
	{
	# there are values we need to compare in this script
	# that are too large for shell -gt to process
	local true=$(echo "$1 > $2" \| bc)
	if [ "$true" -eq "1" ]; then
	return 0
	else
	return 1
	fi
	}

	greater_than_gtid()
	{
	local gtid1_transaction_id=$(echo $1 \| cut -d - -f 3)
	local gtid2_transaction_id=$(echo $2 \| cut -d - -f 3)

	greater_than_equal_long $gtid1_transaction_id $gtid2_transaction_id
	return $?
	}

	set_gtid() {
	# Sets the GTID in CIB using attrd_updater for this node.

	local gtid=$($MYSQL $MYSQL_OPTIONS_REPL \
	-s -N -e "show global variables like 'gtid_current_pos'" \| cut -f 2)

	# Ensure that we got somethine like a valid GTID
	if ! echo $gtid \| grep -q '-'; then
	ocf_exit_reason "Unable to read GTID from MariaDB"
	ocf_log err "Unable to read GTID from MariaDB"
	return $OCF_ERR_GENERIC
	fi

	${HA_SBIN_DIR}/attrd_updater -p -n ${OCF_RESOURCE_INSTANCE}-gtid -U $gtid
	}

	read_gtid() {
	local node=$1
	local query_result
	local name
	local host
	local value

	# This produces output of the form 'name="var-name" host="node2" value="val"'.
	# This should be set at this point, because we have store our own GTID previously.
	if ! query_result=$(${HA_SBIN_DIR}/attrd_updater -p -N $node -n ${OCF_RESOURCE_INSTANCE}-gtid -Q); then
	ocf_exit_reason "Unable to read GTID from attrd"
	ocf_log err "Unable to read GTID from attrd"
	echo ""
	return
	fi

	# Evaluate the query result to place the variables in the local scope.
	eval ${query_result}

	echo ${value}
	}

	clear_all_gtid() {
	for node in $OCF_RESKEY_node_list; do
	${HA_SBIN_DIR}/attrd_updater -n ${OCF_RESOURCE_INSTANCE}-gtid -N $node -D
	done
	}

	set_waiting_for_first_master() {
	${HA_SBIN_DIR}/attrd_updater -p -n ${OCF_RESOURCE_INSTANCE}-waiting-for-first-master -U true
	}

	waiting_for_first_master() {
	local query_result
	local name
	local host
	local value

	if ! query_result=$(${HA_SBIN_DIR}/attrd_updater -p -n ${OCF_RESOURCE_INSTANCE}-waiting-for-first-master -Q); then
	ocf_exit_reason "Unable to read waiting-for-first-master from attrd"
	ocf_log err "Unable to read waiting-for-first-master from attrd"
	return 1
	fi

	# Evaluate the query result to place the variables in the local scope.
	eval ${query_result}

	if [ "$value" = "true" ]; then
	return 0
	else
	return 1
	fi
	}

	clear_waiting_for_first_master() {
	attrd_updater -n ${OCF_RESOURCE_INSTANCE}-waiting-for-first-master -D
	}

	have_master_with_priority() {
	# Go through each node and validate that at least one has
	# a set priority. Because we unset the priority on reboot
	# a lack of priority indicates that we need to select a
	# new master.
	for node in $OCF_RESKEY_node_list; do
	ocf_promotion_score -G -N $node >/dev/null 2>&1
	rc=$?
	if [ $rc -eq 0 ]; then
	return 0
	fi
	done
	return 1
	}

	attempt_to_set_master() {

	ocf_log info "Attempting to set master"

	local expected_node_count
	if waiting_for_first_master; then
	# Wait for all nodes to come online
	expected_node_count=$OCF_RESKEY_CRM_meta_clone_max
	else
	# We accept one node being down. This is not arbitrary,
	# synchronous replication requires acknowledgement from
	# at least one host, which means only two nodes must have
	# the latest GTID. So a set of n - 1 ensures that we do
	# not lose any writes.
	expected_node_count=$(($OCF_RESKEY_CRM_meta_clone_max-1))
	fi

	# Set the gtid for this node, making it available to other nodes
	set_gtid

	local node_count=0
	local highest_gtid=0
	local master_candidate=""
	for node in $OCF_RESKEY_node_list; do

	local node_gtid=$(read_gtid $node)
	if [ -z "$node_gtid" ]; then
	continue
	fi

	# Got a valid gtid, increment node count
	node_count=$(($node_count+1))

	# Check if this is a good master candidate
	if greater_than_gtid $node_gtid $highest_gtid; then
	master_candidate=$node
	highest_gtid=$node_gtid
	fi
	done

	# If we managed to query a sufficient number of nodes
	# then set a master
	if [ $node_count -ge $expected_node_count ]; then
	ocf_log info "Promoting $master_candidate to master, highest gtid $highest_gtid, queried $node_count nodes."
	ocf_promotion_score -v 100 -N $master_candidate
	else
	ocf_log info "Not enough nodes ($node_count) contributed to select a master, need $expected_node_count nodes."
	fi
	}

	set_read_only() {
	# Sets or unsets read-only mode. Accepts one boolean as its
	# optional argument. If invoked without any arguments, defaults to
	# enabling read only mode. Should only be set in master/slave
	# setups.
	# Returns $OCF_SUCCESS if the operation succeeds, or
	# $OCF_ERR_GENERIC if it fails.
	local ro_val
	if ocf_is_true $1; then
	ro_val="on"
	else
	ro_val="off"
	fi
	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "SET GLOBAL read_only=${ro_val}"
	}

	get_read_only() {
	# Check if read-only is set
	local read_only_state

	read_only_state=$($MYSQL $MYSQL_OPTIONS_REPL \
	-e "SHOW VARIABLES" \| grep -w read_only \| awk '{print $2}')

	if [ "$read_only_state" = "ON" ]; then
	return 0
	else
	return 1
	fi
	}

	is_slave() {
	# Determine whether the machine is currently running as a MariaDB
	# slave, as determined per SHOW SLAVE STATUS. Returns 1 if SHOW
	# SLAVE STATUS creates an empty result set, 0 otherwise.
	local rc

	# Check whether this machine should be slave
	if ! get_read_only; then
	return 1
	fi

	if get_slave_info; then
	# show slave status is not empty
	# Is the slave sql thread running, then we are a slave!
	if [ "$slave_sql" == 'Yes' ]; then
	return 0
	else
	return 1
	fi
	else
	# "SHOW SLAVE STATUS" returns an empty set if instance is not a
	# replication slave
	return 1
	fi
	}

	parse_slave_info() {
	# Extracts field $1 from result of "SHOW SLAVE STATUS\G" from file $2
	sed -ne "s/^.* $1: $.*$$/\1/p" < $2
	}

	get_slave_info() {

	if [ "$master_log_file" -a "$master_host" ]; then
	# variables are already defined, get_slave_info has been run before
	return $OCF_SUCCESS
	else
	local tmpfile=$(mktemp ${HA_RSCTMP}/check_slave.${OCF_RESOURCE_INSTANCE}.XXXXXX)

	$MYSQL $MYSQL_OPTIONS_REPL \
	-e 'SHOW SLAVE STATUS\G' > $tmpfile

	if [ -s $tmpfile ]; then
	master_host=$(parse_slave_info Master_Host $tmpfile)
	master_user=$(parse_slave_info Master_User $tmpfile)
	master_port=$(parse_slave_info Master_Port $tmpfile)
	master_using_gtid=$(parse_slave_info Using_Gtid $tmpfile)
	master_log_file=$(parse_slave_info Master_Log_File $tmpfile)
	slave_sql=$(parse_slave_info Slave_SQL_Running $tmpfile)
	slave_io=$(parse_slave_info Slave_IO_Running $tmpfile)
	last_errno=$(parse_slave_info Last_Errno $tmpfile)
	last_error=$(parse_slave_info Last_Error $tmpfile)
	secs_behind=$(parse_slave_info Seconds_Behind_Master $tmpfile)
	last_io_errno=$(parse_slave_info Last_IO_Errno $tmpfile)
	last_io_error=$(parse_slave_info Last_IO_Error $tmpfile)
	ocf_log debug "MariaDB instance running as a replication slave"
	rm "$tmpfile"
	else
	# Instance produced an empty "SHOW SLAVE STATUS" output --
	# instance is not a slave
	rm "$tmpfile"
	return $OCF_ERR_GENERIC
	fi

	return $OCF_SUCCESS
	fi
	}

	check_slave() {
	# Checks slave status
	local rc new_master

	get_slave_info
	rc=$?

	if [ $rc -eq 0 ]; then

	# Check normal errors
	if [ $last_errno -ne 0 ]; then
	ocf_exit_reason "MariaDB slave replication has failed ($last_errno): $last_error"

	exit $OCF_ERR_GENERIC
	fi

	# Check IO Errors, ignore 2003 which indicates a connection failure to the master
	if [ $last_io_errno -ne 0 ] && [ $last_io_errno -ne 2003 ]; then
	ocf_exit_reason "MariaDB slave io has failed ($last_io_errno): $last_io_error"

	exit $OCF_ERR_GENERIC
	fi

	if [ $last_io_errno -eq 2003 ]; then
	ocf_log warn "MariaDB master not reachable from slave"
	fi

	if [ "$slave_io" != 'Yes' ]; then
	# Not necessarily a bad thing. The master may have
	# temporarily shut down, and the slave may just be
	# reconnecting. A warning can't hurt, though.
	ocf_log warn "MariaDB Slave IO threads currently not running."

	# Sanity check, are we at least on the right master
	new_master=$($CRM_ATTR_REPL_INFO --query -q)

	if [ "$master_host" != "$new_master" ]; then
	# Not pointing to the right master, not good, removing the VIPs
	set_reader_attr 0

	exit $OCF_SUCCESS
	fi

	fi

	if [ "$slave_sql" != 'Yes' ]; then
	# We don't have a replication SQL thread running. Not a
	# good thing. Try to recoved by restarting the SQL thread
	# and remove reader vip. Prevent MariaDB restart.
	ocf_exit_reason "MariaDB Slave SQL threads currently not running."

	# Remove reader vip
	set_reader_attr 0

	# try to restart slave
	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "START SLAVE"

	# Return success to prevent a restart
	exit $OCF_SUCCESS
	fi

	ocf_log debug "MariaDB instance running as a replication slave"
	else
	# Instance produced an empty "SHOW SLAVE STATUS" output --
	# instance is not a slave
	# TODO: Needs to handle when get_slave_info will return too many connections error
	ocf_exit_reason "check_slave invoked on an instance that is not a replication slave."
	exit $OCF_ERR_GENERIC
	fi
	}

	set_master() {
	local new_master=$($CRM_ATTR_REPL_INFO --query -q)
	+ local master_ssl_params

	# Informs the MariaDB server of the master to replicate
	# from. Accepts one mandatory argument which must contain the host
	# name of the new master host. The master must either be unchanged
	# from the laste master the slave replicated from, or freshly
	# reset with RESET MASTER.
	ocf_log info "Changing MariaDB configuration to replicate from $new_master."
	+ if [ -n "$OCF_RESKEY_replication_master_ssl_ca" ] && [ -n "$OCF_RESKEY_replication_master_ssl_cert" ] && [ -n "$OCF_RESKEY_replication_master_ssl_key" ]; then
	+ master_ssl_params="MASTER_SSL=1, \
	+ MASTER_SSL_CA='$OCF_RESKEY_replication_master_ssl_ca', \
	+ MASTER_SSL_CERT='$OCF_RESKEY_replication_master_ssl_cert', \
	+ MASTER_SSL_KEY='$OCF_RESKEY_replication_master_ssl_key', "
	+ fi
	+

	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "CHANGE MASTER TO MASTER_HOST='$new_master', \
	MASTER_PORT=$OCF_RESKEY_replication_port, \
	MASTER_USER='$OCF_RESKEY_replication_user', \
	MASTER_PASSWORD='$OCF_RESKEY_replication_passwd', \
	+ $master_ssl_params \
	MASTER_USE_GTID=current_pos";
	}

	unset_master(){
	# Instructs the MariaDB server to stop replicating from a master
	# host.

	# If we're currently not configured to be replicating from any
	# host, then there's nothing to do. But we do log a warning as
	# no-one but the CRM should be touching the MariaDB master/slave
	# configuration.
	if ! is_slave; then
	ocf_log warn "Attempted to unset the replication master on an instance that is not configured as a replication slave"
	return $OCF_SUCCESS
	fi

	# Stop the slave I/O thread and wait for relay log
	# processing to complete
	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "STOP SLAVE IO_THREAD"
	if [ $? -gt 0 ]; then
	ocf_exit_reason "Error stopping slave IO thread"
	exit $OCF_ERR_GENERIC
	fi

	local tmpfile=$(mktemp ${HA_RSCTMP}/threads.${OCF_RESOURCE_INSTANCE}.XXXXXX)
	while true; do
	$MYSQL $MYSQL_OPTIONS_REPL \
	-e 'SHOW PROCESSLIST\G' > $tmpfile
	if grep -i 'Has read all relay log' $tmpfile >/dev/null; then
	ocf_log info "MariaDB slave has finished processing relay log"
	break
	fi
	if ! grep -q 'system user' $tmpfile; then
	ocf_log info "Slave not runnig - not waiting to finish"
	break
	fi
	ocf_log info "Waiting for MariaDB slave to finish processing relay log"
	sleep 1
	done
	rm -f $tmpfile

	# Now, stop all slave activity and unset the master host
	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "STOP SLAVE"
	if [ $? -gt 0 ]; then
	ocf_exit_reason "Error stopping rest slave threads"
	exit $OCF_ERR_GENERIC
	fi

	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "RESET SLAVE /!50516 ALL /;"
	if [ $? -gt 0 ]; then
	ocf_exit_reason "Failed to reset slave"
	exit $OCF_ERR_GENERIC
	fi
	}

	# Start replication as slave
	start_slave() {
	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "START SLAVE"
	}

	# Set the attribute controlling the readers VIP
	set_reader_attr() {
	local curr_attr_value

	curr_attr_value=$(get_reader_attr)

	if [ "$curr_attr_value" -ne "$1" ]; then
	$CRM_ATTR -l reboot --name ${OCF_RESKEY_reader_attribute} -v $1
	fi

	}

	# get the attribute controlling the readers VIP
	get_reader_attr() {
	local attr_value
	local rc

	attr_value=$($CRM_ATTR -l reboot --name ${OCF_RESKEY_reader_attribute} --query -q)
	rc=$?
	if [ "$rc" -eq "0" ]; then
	echo $attr_value
	else
	echo -1
	fi
	}

	# Determines what IP address is attached to the current host. The output of the
	# crm_attribute command looks like this:
	# scope=nodes name=IP value=10.2.2.161
	# If the ${INSTANCE_ATTR_NAME}_MYSQL_MASTER_IP node attribute is not defined, fallback is to uname -n
	# The ${INSTANCE_ATTR_NAME}_MYSQL_MASTER_IP is the IP address that will be used for the
	# change master to command.
	get_local_ip() {
	local IP
	IP=$($CRM_ATTR -l forever -n ${INSTANCE_ATTR_NAME}_mysql_master_IP -q -G 2>/dev/null)
	if [ ! $? -eq 0 ]; then
	uname -n
	else
	echo $IP
	fi
	}

	#######################################################################

	# Functions invoked by resource manager actions

	mysql_monitor() {
	local rc
	local status_loglevel="err"

	# Set loglevel to info during probe
	if ocf_is_probe; then
	status_loglevel="info"
	fi

	mysql_common_status $status_loglevel
	rc=$?

	# If status returned an error, return that immediately
	if [ $rc -ne $OCF_SUCCESS ]; then
	return $rc
	fi

	# Check if this instance is configured as a slave, and if so
	# check slave status
	if is_slave; then
	if ! check_slave; then
	return $OCF_ERR_GENERIC
	fi
	fi

	if [ -n "$OCF_RESKEY_test_table" ]; then

	# Check for test table
	ocf_run -q $MYSQL $MYSQL_OPTIONS_TEST \
	-e "SELECT COUNT(*) FROM $OCF_RESKEY_test_table"
	rc=$?

	if [ $rc -ne 0 ]; then
	ocf_exit_reason "Failed to select from $test_table";
	return $OCF_ERR_GENERIC;
	fi
	fi

	# Check if we are in read-only mode and there is no master
	# with priority then we attempt to select a master
	if get_read_only && ! have_master_with_priority; then
	attempt_to_set_master
	fi

	if ! get_read_only; then
	ocf_log debug "MariaDB monitor succeeded (master)";
	return $OCF_RUNNING_MASTER
	else
	ocf_log debug "MariaDB monitor succeeded";
	return $OCF_SUCCESS
	fi
	}

	mysql_start() {
	local rc

	if ! ocf_is_ms; then
	ocf_exit_reason "Resource is not configured as master/slave"
	return $OCF_ERR_GENERIC
	fi

	# Initialize the ReaderVIP attribute, monitor will enable it
	set_reader_attr 0

	mysql_common_status info
	if [ $? = $OCF_SUCCESS ]; then
	ocf_log info "MariaDB already running"
	return $OCF_SUCCESS
	fi

	mysql_common_prepare_dirs

	mysql_common_start --skip-slave-start --log-slave-updates
	rc=$?
	if [ $rc != $OCF_SUCCESS ]; then
	return $rc
	fi

	# Enable semi-sync
	ocf_run -q $MYSQL $MYSQL_OPTIONS_TEST \
	-e "SET GLOBAL rpl_semi_sync_slave_enabled='ON', \
	rpl_semi_sync_master_enabled='ON', \
	rpl_semi_sync_master_wait_no_slave='OFF', \
	rpl_semi_sync_master_wait_point='AFTER_SYNC', \
	gtid_strict_mode='ON', \
	sync_binlog=1, \
	sync_master_info=1, \
	innodb_flush_log_at_trx_commit=1;"
	rc=$?
	if [ $rc -ne 0 ]; then
	ocf_exit_reason "Failed to enable semi-sync and set variables";
	return $OCF_ERR_GENERIC;
	fi

	# We're configured as a stateful resource. We must start as
	# slave by default. At this point we don't know if the CRM has
	# already promoted a master. So, we simply start in read only
	# mode and make sure our old score is invalidated.
	set_read_only on
	ocf_promotion_score -D

	# Now, let's see whether there is a master. We might be a new
	# node that is just joining the cluster, and the CRM may have
	# promoted a master before.
	new_master_host=$(echo $OCF_RESKEY_CRM_meta_notify_master_uname\|tr -d " ")
	if [ "$new_master_host" -a "$new_master_host" != ${NODENAME} ]; then
	set_master
	start_slave
	if [ $? -ne 0 ]; then
	ocf_exit_reason "Failed to start slave"
	return $OCF_ERR_GENERIC
	fi
	else
	ocf_log info "No MariaDB master present - clearing replication state, setting gtid in attrd, waiting for first master"
	unset_master
	set_waiting_for_first_master
	fi

	# Initial monitor action
	if [ -n "$OCF_RESKEY_test_table" -a -n "$OCF_RESKEY_test_user" -a -n "$OCF_RESKEY_test_passwd" ]; then
	OCF_CHECK_LEVEL=10
	fi

	mysql_monitor
	rc=$?
	if [ $rc != $OCF_SUCCESS -a $rc != $OCF_RUNNING_MASTER ]; then
	ocf_exit_reason "Failed initial monitor action"
	return $rc
	fi

	ocf_log info "MariaDB started"
	return $OCF_SUCCESS
	}

	mysql_stop() {
	# clear preference for becoming master
	ocf_promotion_score -D

	# Remove VIP capability
	set_reader_attr 0

	mysql_common_stop
	}

	mysql_promote() {
	local master_info

	if ( ! mysql_common_status err ); then
	return $OCF_NOT_RUNNING
	fi
	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "STOP SLAVE"

	set_read_only off \|\| return $OCF_ERR_GENERIC
	# Force the master to wait for timeout period on slave disconnect
	ocf_run -q $MYSQL $MYSQL_OPTIONS_TEST \
	-e "SET GLOBAL rpl_semi_sync_master_wait_no_slave='ON';"

	# Set Master Info in CIB, cluster level attribute
	master_info="$(get_local_ip)"
	${CRM_ATTR_REPL_INFO} -v "$master_info"

	# A master can accept reads
	set_reader_attr 1

	# Clear the gtids in attrd now that there is a master
	clear_all_gtid

	return $OCF_SUCCESS
	}

	mysql_demote() {
	if ! mysql_common_status err; then
	return $OCF_NOT_RUNNING
	fi

	# Return to default no wait setting.
	ocf_run -q $MYSQL $MYSQL_OPTIONS_TEST \
	-e "SET GLOBAL rpl_semi_sync_master_wait_no_slave='OFF';"

	# Return master preference to default, so the cluster manager gets
	# a chance to select a new master
	ocf_promotion_score -D
	}

	mysql_notify() {
	local type_op
	type_op="${OCF_RESKEY_CRM_meta_notify_type}-${OCF_RESKEY_CRM_meta_notify_operation}"

	ocf_log debug "Received $type_op notification."

	case "$type_op" in
	'pre-promote')
	# A master is now being promoted, remove the waiting-for-first-master flag
	clear_waiting_for_first_master
	;;
	'post-promote')
	# The master has completed its promotion. Now is a good
	# time to check whether our replication slave is working
	# correctly.
	new_master_host=$(echo $OCF_RESKEY_CRM_meta_notify_promote_uname\|tr -d " ")
	if [ "$new_master_host" = ${NODENAME} ]; then
	ocf_log info "This will be the new master, ignoring post-promote notification."
	else
	ocf_log info "Resetting replication, uname of master: $new_master_host"
	unset_master
	if [ $? -ne 0 ]; then
	return $OCF_ERR_GENERIC
	fi

	set_master
	if [ $? -ne 0 ]; then
	return $OCF_ERR_GENERIC
	fi

	start_slave
	if [ $? -ne 0 ]; then
	ocf_exit_reason "Failed to start slave"
	return $OCF_ERR_GENERIC
	fi
	fi
	return $OCF_SUCCESS
	;;
	'pre-demote')
	demote_host=$(echo $OCF_RESKEY_CRM_meta_notify_demote_uname\|tr -d " ")
	if [ $demote_host = ${NODENAME} ]; then
	ocf_log info "pre-demote notification for $demote_host"
	set_read_only on
	if [ $? -ne 0 ]; then
	ocf_exit_reason "Failed to set read-only";
	return $OCF_ERR_GENERIC;
	fi

	# Must kill all existing user threads because they are still Read/write
	# in order for the slaves to complete the read of binlogs
	local tmpfile=$(mktemp ${HA_RSCTMP}/threads.${OCF_RESOURCE_INSTANCE}.XXXXXX)
	$MYSQL $MYSQL_OPTIONS_REPL -e "SHOW PROCESSLIST" > $tmpfile
	for thread in $(awk '$0 !~ /Binlog Dump\|system user\|event_scheduler\|SHOW PROCESSLIST/ && $0 ~ /^[0-9]/ {print $1}' $tmpfile)
	do
	ocf_run $MYSQL $MYSQL_OPTIONS_REPL \
	-e "KILL ${thread}"
	done
	rm -f $tmpfile
	else
	ocf_log info "Ignoring post-demote notification execpt for my own demotion."
	fi
	return $OCF_SUCCESS
	;;
	'post-demote')
	demote_host=$(echo $OCF_RESKEY_CRM_meta_notify_demote_uname\|tr -d " ")
	if [ $demote_host = ${NODENAME} ]; then
	ocf_log info "Ignoring post-demote notification for my own demotion."
	return $OCF_SUCCESS
	fi
	ocf_log info "post-demote notification for $demote_host."
	# The former master has just been gracefully demoted.
	unset_master
	;;
	*)
	return $OCF_SUCCESS
	;;
	esac
	}

	mysql_validate() {
	check_binary bc
	}

	#######################################################################

	case "$1" in
	meta-data) meta_data
	exit $OCF_SUCCESS;;
	usage\|help) usage
	exit $OCF_SUCCESS;;
	esac

	mysql_common_validate
	rc=$?
	LSB_STATUS_STOPPED=3
	if [ $rc -ne 0 ]; then
	case "$1" in
	stop) ;;
	monitor)
	mysql_common_status "info"
	if [ $? -eq $OCF_SUCCESS ]; then
	# if validatation fails and pid is active, always treat this as an error
	ocf_exit_reason "environment validation failed, active pid is in unknown state."
	exit $OCF_ERR_GENERIC
	fi
	# validation failed and pid is not active, it's safe to say this instance is inactive.
	exit $OCF_NOT_RUNNING;;

	status) exit $LSB_STATUS_STOPPED;;
	*) exit $rc;;
	esac
	fi

	# What kind of method was invoked?
	case "$1" in
	start) mysql_start;;
	stop) mysql_stop;;
	status) mysql_common_status err;;
	monitor) mysql_monitor;;
	promote) mysql_promote;;
	demote) mysql_demote;;
	notify) mysql_notify;;
	validate-all) mysql_validate;;

	*) usage
	exit $OCF_ERR_UNIMPLEMENTED;;
	esac

	# vi:sw=4:ts=4:et:
	diff --git a/heartbeat/mysql-common.sh b/heartbeat/mysql-common.sh
	old mode 100755
	new mode 100644
	index d6b4e3cdf..9f3ebe83b
	--- a/heartbeat/mysql-common.sh
	+++ b/heartbeat/mysql-common.sh
	@@ -1,332 +1,339 @@
	#!/bin/sh

	#######################################################################

	# Use runuser if available for SELinux.
	if [ -x /sbin/runuser ]; then
	SU=runuser
	else
	SU=su
	fi

	# Attempt to detect a default binary
	OCF_RESKEY_binary_default=$(which mysqld_safe 2> /dev/null)
	if [ "$OCF_RESKEY_binary_default" = "" ]; then
	OCF_RESKEY_binary_default=$(which safe_mysqld 2> /dev/null)
	fi

	# Fill in some defaults if no values are specified
	HOSTOS=`uname`
	if [ "X${HOSTOS}" = "XOpenBSD" ];then
	if [ "$OCF_RESKEY_binary_default" = "" ]; then
	OCF_RESKEY_binary_default="/usr/local/bin/mysqld_safe"
	fi
	OCF_RESKEY_config_default="/etc/my.cnf"
	OCF_RESKEY_datadir_default="/var/mysql"
	OCF_RESKEY_user_default="_mysql"
	OCF_RESKEY_group_default="_mysql"
	OCF_RESKEY_log_default="/var/log/mysqld.log"
	OCF_RESKEY_pid_default="/var/mysql/mysqld.pid"
	OCF_RESKEY_socket_default="/var/run/mysql/mysql.sock"
	else
	if [ "$OCF_RESKEY_binary_default" = "" ]; then
	OCF_RESKEY_binary_default="/usr/bin/safe_mysqld"
	fi
	OCF_RESKEY_config_default="/etc/my.cnf"
	OCF_RESKEY_datadir_default="/var/lib/mysql"
	OCF_RESKEY_user_default="mysql"
	OCF_RESKEY_group_default="mysql"
	OCF_RESKEY_log_default="/var/log/mysqld.log"
	OCF_RESKEY_pid_default="/var/run/mysql/mysqld.pid"
	OCF_RESKEY_socket_default="/var/lib/mysql/mysql.sock"
	fi
	OCF_RESKEY_client_binary_default="mysql"
	OCF_RESKEY_test_user_default="root"
	OCF_RESKEY_test_table_default="mysql.user"
	OCF_RESKEY_test_passwd_default=""
	OCF_RESKEY_enable_creation_default=0
	OCF_RESKEY_additional_parameters_default=""
	OCF_RESKEY_replication_user_default="root"
	OCF_RESKEY_replication_passwd_default=""
	OCF_RESKEY_replication_port_default="3306"
	OCF_RESKEY_replication_require_ssl_default="false"
	OCF_RESKEY_replication_master_ssl_ca_default=""
	OCF_RESKEY_replication_master_ssl_cert_default=""
	OCF_RESKEY_replication_master_ssl_key_default=""
	OCF_RESKEY_max_slave_lag_default="3600"
	OCF_RESKEY_evict_outdated_slaves_default="false"
	OCF_RESKEY_reader_attribute_default="readable"

	: ${OCF_RESKEY_binary=${OCF_RESKEY_binary_default}}
	MYSQL_BINDIR=`dirname ${OCF_RESKEY_binary}`

	: ${OCF_RESKEY_client_binary=${OCF_RESKEY_client_binary_default}}

	: ${OCF_RESKEY_config=${OCF_RESKEY_config_default}}
	: ${OCF_RESKEY_datadir=${OCF_RESKEY_datadir_default}}

	: ${OCF_RESKEY_user=${OCF_RESKEY_user_default}}
	: ${OCF_RESKEY_group=${OCF_RESKEY_group_default}}

	: ${OCF_RESKEY_log=${OCF_RESKEY_log_default}}
	: ${OCF_RESKEY_pid=${OCF_RESKEY_pid_default}}
	: ${OCF_RESKEY_socket=${OCF_RESKEY_socket_default}}

	: ${OCF_RESKEY_test_user=${OCF_RESKEY_test_user_default}}
	: ${OCF_RESKEY_test_table=${OCF_RESKEY_test_table_default}}
	: ${OCF_RESKEY_test_passwd=${OCF_RESKEY_test_passwd_default}}

	: ${OCF_RESKEY_enable_creation=${OCF_RESKEY_enable_creation_default}}
	: ${OCF_RESKEY_additional_parameters=${OCF_RESKEY_additional_parameters_default}}

	: ${OCF_RESKEY_replication_user=${OCF_RESKEY_replication_user_default}}
	: ${OCF_RESKEY_replication_passwd=${OCF_RESKEY_replication_passwd_default}}
	: ${OCF_RESKEY_replication_port=${OCF_RESKEY_replication_port_default}}
	: ${OCF_RESKEY_replication_require_ssl=${OCF_RESKEY_replication_require_ssl_default}}
	: ${OCF_RESKEY_replication_master_ssl_ca=${OCF_RESKEY_replication_master_ssl_ca_default}}
	: ${OCF_RESKEY_replication_master_ssl_cert=${OCF_RESKEY_replication_master_ssl_cert_default}}
	: ${OCF_RESKEY_replication_master_ssl_key=${OCF_RESKEY_replication_master_ssl_key_default}}

	: ${OCF_RESKEY_max_slave_lag=${OCF_RESKEY_max_slave_lag_default}}
	: ${OCF_RESKEY_evict_outdated_slaves=${OCF_RESKEY_evict_outdated_slaves_default}}

	: ${OCF_RESKEY_reader_attribute=${OCF_RESKEY_reader_attribute_default}}

	#######################################################################
	# Convenience variables

	MYSQL=$OCF_RESKEY_client_binary
	if ocf_is_true "$OCF_RESKEY_replication_require_ssl"; then
	- MYSQL_OPTIONS_LOCAL_SSL_OPTIONS="--ssl-mode=REQUIRED"
	+ if [ "${OCF_RESOURCE_TYPE}" = "mariadb" ] ; then
	+ MYSQL_OPTIONS_LOCAL_SSL_OPTIONS="--ssl"
	+ if [ -n "${$OCF_RESKEY_replication_master_ssl_ca}" ] ; then
	+ MYSQL_OPTIONS_LOCAL_SSL_OPTIONS="${MYSQL_OPTIONS_LOCAL_SSL_OPTIONS} --ssl-ca=${$OCF_RESKEY_replication_master_ssl_ca}"
	+ fi
	+ else
	+ MYSQL_OPTIONS_LOCAL_SSL_OPTIONS="--ssl-mode=REQUIRED"
	+ fi
	else
	MYSQL_OPTIONS_LOCAL_SSL_OPTIONS=""
	fi
	MYSQL_OPTIONS_LOCAL="-S $OCF_RESKEY_socket"
	MYSQL_OPTIONS_REPL="$MYSQL_OPTIONS_LOCAL_SSL_OPTIONS $MYSQL_OPTIONS_LOCAL --user=$OCF_RESKEY_replication_user --password=$OCF_RESKEY_replication_passwd"
	MYSQL_OPTIONS_TEST="$MYSQL_OPTIONS_LOCAL --user=$OCF_RESKEY_test_user --password=$OCF_RESKEY_test_passwd"
	MYSQL_TOO_MANY_CONN_ERR=1040

	NODENAME=$(ocf_local_nodename)
	CRM_ATTR="${HA_SBIN_DIR}/crm_attribute -N $NODENAME "
	INSTANCE_ATTR_NAME=`echo ${OCF_RESOURCE_INSTANCE}\| awk -F : '{print $1}'`
	CRM_ATTR_REPL_INFO="${HA_SBIN_DIR}/crm_attribute --type crm_config --name ${INSTANCE_ATTR_NAME}_REPL_INFO -s mysql_replication"

	#######################################################################

	mysql_common_validate()
	{

	if ! have_binary "$OCF_RESKEY_binary"; then
	ocf_exit_reason "Setup problem: couldn't find command: $OCF_RESKEY_binary"
	return $OCF_ERR_INSTALLED;
	fi

	if ! have_binary "$OCF_RESKEY_client_binary"; then
	ocf_exit_reason "Setup problem: couldn't find command: $OCF_RESKEY_client_binary"
	return $OCF_ERR_INSTALLED;
	fi

	if [ ! -f $OCF_RESKEY_config ]; then
	ocf_exit_reason "Config $OCF_RESKEY_config doesn't exist";
	return $OCF_ERR_INSTALLED;
	fi

	if [ ! -d $OCF_RESKEY_datadir ]; then
	ocf_exit_reason "Datadir $OCF_RESKEY_datadir doesn't exist";
	return $OCF_ERR_INSTALLED;
	fi

	getent passwd $OCF_RESKEY_user >/dev/null 2>&1
	if [ ! $? -eq 0 ]; then
	ocf_exit_reason "User $OCF_RESKEY_user doesn't exit";
	return $OCF_ERR_INSTALLED;
	fi

	getent group $OCF_RESKEY_group >/dev/null 2>&1
	if [ ! $? -eq 0 ]; then
	ocf_exit_reason "Group $OCF_RESKEY_group doesn't exist";
	return $OCF_ERR_INSTALLED;
	fi

	return $OCF_SUCCESS
	}

	mysql_common_check_pid() {
	local pid=$1

	if [ -d /proc -a -d /proc/1 ]; then
	[ "u$pid" != "u" -a -d /proc/$pid ]
	else
	kill -s 0 $pid >/dev/null 2>&1
	fi
	return $?
	}

	mysql_common_status() {
	local loglevel=$1
	local pid=$2
	if [ -z "$pid" ]; then
	if [ ! -e $OCF_RESKEY_pid ]; then
	ocf_log $loglevel "MySQL is not running"
	return $OCF_NOT_RUNNING;
	fi

	pid=`cat $OCF_RESKEY_pid`;
	fi

	mysql_common_check_pid $pid


	if [ $? -eq 0 ]; then
	return $OCF_SUCCESS;
	else
	if [ -e $OCF_RESKEY_pid ]; then
	ocf_log $loglevel "MySQL not running: removing old PID file"
	rm -f $OCF_RESKEY_pid
	fi
	return $OCF_NOT_RUNNING;
	fi
	}

	mysql_common_prepare_dirs()
	{
	local rc

	touch $OCF_RESKEY_log
	chown $OCF_RESKEY_user:$OCF_RESKEY_group $OCF_RESKEY_log
	chmod 0640 $OCF_RESKEY_log
	[ -x /sbin/restorecon ] && /sbin/restorecon $OCF_RESKEY_log

	if ocf_is_true "$OCF_RESKEY_enable_creation" && [ ! -d $OCF_RESKEY_datadir/mysql ] ; then
	ocf_log info "Initializing MySQL database: "
	$MYSQL_BINDIR/mysql_install_db --datadir=$OCF_RESKEY_datadir
	rc=$?
	if [ $rc -ne 0 ] ; then
	ocf_exit_reason "Initialization failed: $rc";
	exit $OCF_ERR_GENERIC
	fi
	chown -R $OCF_RESKEY_user:$OCF_RESKEY_group $OCF_RESKEY_datadir
	fi

	pid_dir=`dirname $OCF_RESKEY_pid`
	if [ ! -d $pid_dir ] ; then
	ocf_log info "Creating PID dir: $pid_dir"
	mkdir -p $pid_dir
	chown $OCF_RESKEY_user:$OCF_RESKEY_group $pid_dir
	fi

	socket_dir=`dirname $OCF_RESKEY_socket`
	if [ ! -d $socket_dir ] ; then
	ocf_log info "Creating socket dir: $socket_dir"
	mkdir -p $socket_dir
	chown $OCF_RESKEY_user:$OCF_RESKEY_group $socket_dir
	fi

	# Regardless of whether we just created the directory or it
	# already existed, check whether it is writable by the configured
	# user
	for dir in $pid_dir $socket_dir $OCF_RESKEY_datadir; do
	if ! $SU -s /bin/sh - $OCF_RESKEY_user -c "test -w $dir"; then
	ocf_exit_reason "Directory $dir is not writable by $OCF_RESKEY_user"
	exit $OCF_ERR_PERM;
	fi
	done
	}

	mysql_common_start()
	{
	local mysql_extra_params="$1"
	local pid

	$SU - $OCF_RESKEY_user -s /bin/sh -c \
	"${OCF_RESKEY_binary} --defaults-file=$OCF_RESKEY_config \
	--pid-file=$OCF_RESKEY_pid \
	--socket=$OCF_RESKEY_socket \
	--datadir=$OCF_RESKEY_datadir \
	--log-error=$OCF_RESKEY_log \
	$OCF_RESKEY_additional_parameters \
	$mysql_extra_params >/dev/null 2>&1" &
	pid=$!

	# Spin waiting for the server to come up.
	# Let the CRM/LRM time us out if required.
	start_wait=1
	while [ $start_wait = 1 ]; do
	if ! ps $pid > /dev/null 2>&1; then
	wait $pid
	ocf_exit_reason "MySQL server failed to start (pid=$pid) (rc=$?). Check $OCF_RESKEY_log for details"
	return $OCF_ERR_GENERIC
	fi
	mysql_common_status info
	rc=$?
	if [ $rc = $OCF_SUCCESS ]; then
	start_wait=0
	elif [ $rc != $OCF_NOT_RUNNING ]; then
	ocf_log info "MySQL start failed: $rc"
	return $rc
	fi
	sleep 2
	done

	return $OCF_SUCCESS
	}

	mysql_common_stop()
	{
	local pid
	local rc

	if [ ! -f $OCF_RESKEY_pid ]; then
	ocf_log info "MySQL is not running"
	return $OCF_SUCCESS
	fi

	pid=`cat $OCF_RESKEY_pid 2> /dev/null `

	mysql_common_check_pid $pid
	if [ $? -ne 0 ]; then
	rm -f $OCF_RESKEY_pid
	ocf_log info "MySQL is already stopped"
	return $OCF_SUCCESS;
	fi

	/bin/kill $pid > /dev/null
	rc=$?
	if [ $rc != 0 ]; then
	ocf_exit_reason "MySQL couldn't be stopped"
	return $OCF_ERR_GENERIC
	fi
	# stop waiting
	shutdown_timeout=15
	if [ -n "$OCF_RESKEY_CRM_meta_timeout" ]; then
	shutdown_timeout=$((($OCF_RESKEY_CRM_meta_timeout/1000)-5))
	fi
	count=0
	while [ $count -lt $shutdown_timeout ]
	do
	mysql_common_status info $pid
	rc=$?
	if [ $rc = $OCF_NOT_RUNNING ]; then
	break
	fi
	count=`expr $count + 1`
	sleep 1
	ocf_log debug "MySQL still hasn't stopped yet. Waiting..."
	done

	mysql_common_status info $pid
	if [ $? != $OCF_NOT_RUNNING ]; then
	ocf_log info "MySQL failed to stop after ${shutdown_timeout}s using SIGTERM. Trying SIGKILL..."
	/bin/kill -KILL $pid > /dev/null
	mysql_common_status info $pid
	if [ $? != $OCF_NOT_RUNNING ]; then
	return $OCF_ERR_GENERIC
	fi
	fi

	ocf_log info "MySQL stopped";
	rm -f /var/lock/subsys/mysqld
	rm -f $OCF_RESKEY_socket
	return $OCF_SUCCESS

	}

File Metadata

Mime Type: text/x-diff
Expires: Wed, Jun 25, 6:24 AM (10 h, 53 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1952412
Default Alt Text: (47 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions