diff --git a/script/lsb/booth-arbitrator b/script/lsb/booth-arbitrator index 1ecb464..6ced640 100755 --- a/script/lsb/booth-arbitrator +++ b/script/lsb/booth-arbitrator @@ -1,119 +1,143 @@ #!/bin/bash # # BOOTH daemon init script for LSB-compliant Linux distributions. # # booth-arbitrator BOOTH arbitrator daemon # # chkconfig: - 20 20 # processname: boothd # pidfile: /var/run/booth.pid # description: Cluster Ticket Registry ### BEGIN INIT INFO # Provides: booth # Required-Start: $network $syslog # Required-Stop: $network $syslog # Should-Start: # Should-Stop: # Default-Start: 3 5 # Default-Stop: 0 6 # Short-Description: start and stop BOOTH arbitrator daemon ### END INIT INFO prog="boothd" exec="/usr/sbin/$prog" type="arbitrator" lockfile="/var/run/booth.pid" +BOOTH_DAEMON_STARTED=0 +BOOTH_DAEMON_STARTING=1 +BOOTH_DAEMON_EXIST=2 +BOOTH_DAEMON_NOT_RUNNING=3 +BOOTH_ERROR_GENERIC=4 + . /etc/rc.status internal_status() { checkproc $exec > /dev/null 2>&1 return $? } check_status() { - internal_status - if [ "$?" -eq 0 ];then - pidnum=$(cat $lockfile) + internal_status ; rc=$? + + if [ $rc == 0 ];then + pidnum=$(cat $lockfile|awk '{print $1}') + daemonstate=$(cat $lockfile |awk '{print $2}') if cat /proc/$pidnum/cmdline |grep $type > /dev/null 2>&1 ; then - return 0 #arbitrator daemon is Running + case $daemonstate in + $BOOTH_DAEMON_STARTED) return $BOOTH_DAEMON_STARTED;; + $BOOTH_DAEMON_STARTING) return $BOOTH_DAEMON_STARTING;; #arbitrator daemon is Running + *) return $BOOTH_ERROR_GENERIC;; + esac else - return 1 #site daemon is Running + return $BOOTH_DAEMON_EXIST #site daemon is Running fi else - return 2 #BOOTH daemon is not running + return $BOOTH_DAEMON_NOT_RUNNING #BOOTH daemon is not running fi } status() { echo -n "BOOTH arbitrator daemon is " if check_status; then echo "Running" return 0 else echo "Stopped" return 7 fi } start() { [ -x $exec ] || exit 5 - check_status - rc=$? + check_status; rc=$? case "$rc" in - 0) + $BOOTH_DAEMON_STARTED) echo "BOOTH arbitrator daemon is Running" - return 1 + return 0 + ;; + $BOOTH_DAEMON_STARTING) + echo "BOOTH arbitrator daemon is Running" + return 0 ;; - 1) + $BOOTH_DAEMON_EXIST) echo "BOOTH site daemon is Running" return 1 ;; - 2) + $BOOTH_DAEMON_NOT_RUNNING) echo -n $"Starting BOOTH arbitrator daemon: " startproc $exec $type rc_status -v ;; esac } stop() { - if check_status; then - echo -n $"Stopping BOOTH arbitrator daemon: " - killproc -p $lockfile $prog -TERM - rc_status -v - else + check_status; rc=$? + case $rc in + $BOOTH_DAEMON_STARTED);; + $BOOTH_DAEMON_STARTING);; + $BOOTH_DAEMON_EXIST) + echo "BOOTH site daemon is running." + return $OCF_ERR_GENERIC;; + $BOOTH_DAEMON_NOT_RUNNING) echo "BOOTH arbitrator daemon is not running." - return 1 - fi + return $OCF_SUCCESS + ;; + *) return $OCF_ERR_GENERIC;; + esac + + echo -n $"Stopping BOOTH arbitrator daemon: " + killproc -p $lockfile $prog -TERM + rc_status -v } wait_for_stop() { while [ -e $lockfile ]; do sleep .5 done } restart() { stop wait_for_stop start } case "$1" in start|stop|restart) $1 ;; reload|force-reload) restart ;; condrestart|try-restart) [ ! -f "$lockfile" ] || restart ;; status) status $prog ;; *) echo $"Usage: $0 {start|stop|restart|try-restart|condrestart|reload|force-reload|status}" exit 2 esac diff --git a/script/ocf/booth-site b/script/ocf/booth-site index 566a8f0..2575643 100755 --- a/script/ocf/booth-site +++ b/script/ocf/booth-site @@ -1,186 +1,249 @@ #!/bin/sh # # Resource Agent for BOOTH site daemon. # # This program is free software; you can redistribute it and/or modify # it under the terms of version 2 of the GNU General Public License as # published by the Free Software Foundation. # # This program is distributed in the hope that it would be useful, but # WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. # # Further, this software is distributed without any warranty that it is # free of the rightful claim of any third person regarding infringement # or the like. Any license provided herein, whether implied or # otherwise, applies only to this software file. Patent licenses, if # any, provided herein do not apply to combinations of this program with # other software, or any other product whatsoever. # # You should have received a copy of the GNU General Public License # along with this program; if not, write the Free Software Foundation, # Inc., 59 Temple Place - Suite 330, Boston MA 02111-1307, USA. # ####################################################################### # Initialization: +lockfile="/var/run/booth.pid" + +BOOTH_DAEMON_STARTED=0 +BOOTH_DAEMON_STARTING=1 +BOOTH_DAEMON_EXIST=2 +BOOTH_DAEMON_NOT_RUNNING=3 +BOOTH_ERROR_GENERIC=4 + . ${OCF_ROOT}/resource.d/heartbeat/.ocf-shellfuncs ####################################################################### meta_data() { cat < 1.0 + This Resource Agent can control the BOOTH site daemon. It assumes that the binary boothd is in your default PATH. In most cases, it should be run as a primitive resource. BOOTH site daemon Any additional options to start the BOOTH daemon with BOOTH Options The type of BOOTH daemon which should be started BOOTH Type The daemon to start The daemon to start END } ####################################################################### booth_usage() { cat </dev/null 2>&1; rc=$? + + case $rc in + 0) return $OCF_SUCCESS;; + 1) return $OCF_NOT_RUNNING;; + *) return $OCF_ERR_GENERIC;; + esac } -booth_stop() { - booth_monitor; rc=$? - - if [ $rc = $OCF_NOT_RUNNING ]; then - return $OCF_SUCCESS - fi - - killall -TERM ${OCF_RESKEY_daemon}; rc=$? +booth_check_daemon_state(){ + booth_check_daemon_exist ; rc=$? + + case $rc in + $OCF_SUCCESS) + pidnum=$(cat $lockfile |awk '{print $1}') + daemonstate=$(cat $lockfile |awk '{print $2}') + if cat /proc/$pidnum/cmdline |grep $OCF_RESKEY_type >/dev/null 2>&1; then + case $daemonstate in + $BOOTH_DAEMON_STARTED) return $BOOTH_DAEMON_STARTED;; + $BOOTH_DAEMON_STARTING) return $BOOTH_DAEMON_STARTING;; + *) return $BOOTH_ERROR_GENERIC;; + esac + else + return $BOOTH_DAEMON_EXIST; + fi + ;; + $OCF_NOT_RUNNING) return $BOOTH_DAEMON_NOT_RUNNING;; + $OCF_ERR_GENERIC) return $BOOTH_ERROR_GENERIC;; + *) return $BOOTH_ERROR_GENERIC;; + esac +} - if [ $rc != 0 ]; then - return $OCF_ERR_GENERIC - fi +booth_start() { + booth_check_daemon_state; rc=$? + + case $rc in + $BOOTH_DAEMON_STARTED) return $OCF_SUCCESS;; + $BOOTH_DAEMON_STARTING) + while [ $rc != $BOOTH_DAEMON_STARTED ]; do + sleep 1 + booth_check_daemon_state ; rc=$? + done + return $OCF_SUCCESS;; + $BOOTH_DAEMON_EXIST) return $OCF_ERR_GENERIC;; + $BOOTH_DAEMON_NOT_RUNNING) ;; + *) return $OCF_ERR_GENERIC;; + esac + + ${OCF_RESKEY_daemon} $OCF_RESKEY_type $OCF_RESKEY_args - rc=$OCF_SUCCESS - while [ $rc = $OCF_SUCCESS ]; do - booth_monitor; rc=$? sleep 1 - done - - if [ $rc = $OCF_NOT_RUNNING ]; then - rc=$OCF_SUCCESS - fi + rc=$BOOTH_DAEMON_STARTING + while [ $rc != $BOOTH_DAEMON_STARTED ]; do + booth_check_daemon_state; rc=$? + sleep 1 + done + + return $OCF_SUCCESS +} - return $rc +booth_stop() { + booth_check_daemon_state; rc=$? + + case $rc in + $BOOTH_DAEMON_STARTED) ;; + $BOOTH_DAEMON_STARTING) ;; + $BOOTH_DAEMON_EXIST) return $OCF_ERR_GENERIC;; + $BOOTH_DAEMON_NOT_RUNNING) return $OCF_SUCCESS;; + *) return $OCF_ERR_GENERIC;; + esac + + killall -TERM ${OCF_RESKEY_daemon}; rc=$? + + if [ $rc != 0 ]; then + return $OCF_ERR_GENERIC + fi + + rc=$BOOTH_DAEMON_STARTED + while [ $rc != $BOOTH_DAEMON_NOT_RUNNING ]; do + booth_check_daemon_state; rc=$? + sleep 1 + done + + if [ $rc = $BOOTH_DAEMON_NOT_RUNNING ]; then + rc=$OCF_SUCCESS + else + rc=$OCF_ERR_GENERIC + fi + + return $rc } booth_monitor() { - killall -0 ${OCF_RESKEY_daemon}; rc=$? - - case $rc in - 0) return $OCF_SUCCESS;; - 1) return $OCF_NOT_RUNNING;; - *) return $OCF_ERR_GENERIC;; - esac + booth_check_daemon_state; rc=$? + + case $rc in + $BOOTH_DAEMON_STARTED) return $OCF_SUCCESS;; + $BOOTH_DAEMON_STARTING) return $OCF_NOT_RUNNING;; + $BOOTH_DAEMON_EXIST) return $OCF_NOT_RUNNING;; + $BOOTH_DAEMON_NOT_RUNNING) return $OCF_NOT_RUNNING;; + *) return $OCF_ERR_GENERIC;; + esac } booth_validate() { check_binary ${OCF_RESKEY_daemon} case ${OCF_RESKEY_CRM_meta_globally_unique} in yes|Yes|true|True|1) ocf_log err "$OCF_RESOURCE_INSTANCE must be configured with the globally_unique=false meta attribute" exit $OCF_ERR_CONFIGURED ;; esac return $OCF_SUCCESS } # Set OCF_RESKEY_daemon to boothd as default if not set if [ ! ${OCF_RESKEY_daemon} ]; then OCF_RESKEY_daemon=boothd fi # Set OCF_RESKEY_type to site as default if not set if [ ! ${OCF_RESKEY_type} ]; then OCF_RESKEY_type=site fi case $__OCF_ACTION in meta-data) meta_data exit $OCF_SUCCESS ;; start) booth_validate; booth_start;; stop) booth_stop;; monitor) booth_validate; booth_monitor;; validate-all) booth_validate;; usage|help) booth_usage exit $OCF_SUCCESS ;; *) booth_usage exit $OCF_ERR_UNIMPLEMENTED ;; esac rc=$? exit $rc