cluster-agents 1:1.0.4-0ubuntu2 / usr / share / resource-agents / ocft / caselib

#
# Copyright (c) 2010 Novell Inc, John Shi
#           All Rights Reserved.
#
# 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.


quit()
{
  local ret
  ret="$1"

  while [ $atexit_num -gt 0 ]; do
    atexit$atexit_num
    let atexit_num--
  done

  rm -rf $fakebin

  exit $ret
}

agent_install()
{
  local pkg

  if [ $# -eq 0 ]; then
    return 0
  fi

  for pkg in "$@"; do
    if [ -e /etc/SuSE-release ]; then
      if ! rpm -ql "$pkg" >/dev/null 2>&1; then
        echo -n "${showhost}Installing $pkg ..."
        zypper -q install -y "$pkg" >/dev/null 2>&1
        if ! rpm -ql "$pkg" >/dev/null 2>&1; then
          echo
          echo "${showhost}ERROR: Install '$pkg' failed, break this case."
          quit 2
        fi
        echo "done"
        echo
      fi
    elif [ -e /etc/debian_version ]; then
      if ! dpkg -L "$pkg" >/dev/null 2>&1; then
        echo -n "${showhost}Installing $pkg ..."
        apt-get -y install "$pkg" >/dev/null 2>&1
        if ! dpkg -L "$pkg" >/dev/null 2>&1; then
          echo
          echo "${showhost}ERROR: Install '$pkg' failed, break this case."
          quit 2
        fi
        echo "done"
        echo
      fi
    elif [ -e /etc/redhat-release ]; then
      if ! rpm -ql "$pkg" >/dev/null 2>&1; then
        echo -n "${showhost}Installing $pkg ..."
        yum -y install "$pkg" >/dev/null 2>&1
        if ! rpm -ql "$pkg" >/dev/null 2>&1; then
          echo
          echo "${showhost}ERROR: Install '$pkg' failed, break this case."
          quit 2
        fi
        echo "done"
        echo
      fi
    else
      echo "${showhost}ERROR: Cannot detect your OS type, break this case."
      quit 2
    fi
  done
}

agent_setup()
{
  local agent
  agent="$1"

  if [ ! -e "/tmp/.${agent}_set" ]; then
    touch "/tmp/.${agent}_set"
    echo -n "${showhost}Initialing ${agent}..."
    bash >/dev/null
    echo "done"
    echo
  fi
}

agent_run()
{
  local agent cmd timeout pid i ret aroot
  agent="$1"
  cmd="$2"
  timeout="$3"

  aroot=${MYROOT:-$AGENT_ROOT}

  setsid $aroot/$agent $cmd >/tmp/.ocft_runlog 2>&1 &
  pid=$!

  i=0
  while [ $i -lt $timeout ]; do
    if [ ! -e /proc/$pid ]; then
      break
    fi
    sleep 1
    let i++
  done

  if [ $i -ge $timeout ]; then
    kill -SIGTERM -$pid >/dev/null 2>&1
    sleep 3
    kill -SIGKILL -$pid >/dev/null 2>&1
    echo -n "${showhost}ERROR: The agent was hanging, killed it, "
    echo "maybe you damaged the agent or system's environment, break this CASE."
    echo
    quit 1
  fi

  wait $pid
}

check_success()
{
  local ret msg
  ret="$1"
  msg="$2"

  if [ $ret -ne 0 ]; then
    echo "${showhost}ERROR: '${msg}' failed, the return code is ${ret}, break this CASE."
    quit 1
  fi
}

__maxfd()
{
  (echo 0; ls -1 /proc/$$/fd) | sort -rn | head -1
}

__getfd()
{
  local host rw fd file
  host="$1"
  rw="$2"

  for fd in /proc/$$/fd/*; do
    file=$(basename "$(readlink $fd)")
    if [ "$file" = "${host}_$rw" ]; then
      basename $fd
      break
    fi
  done
}

backbash_start()
{
  local host fd rfd wfd
  host="$1"

  if [ ! -d "$CASES_DIR" ]; then
    echo "${showhost}ERROR: Could not found Directory: ${CASES_DIR}."
    quit 1
  fi

  if lsof $CASES_DIR/${host}_r $CASES_DIR/${host}_w >/dev/null 2>&1; then
    echo "${showhost}ERROR: Connection exist with $host, break this CASE."
    quit 1
  fi
  if [ ! -p "$CASES_DIR/${host}_r" ] || [ ! -p "$CASES_DIR/${host}_w" ]; then
    rm -f $CASES_DIR/${host}_r $CASES_DIR/${host}_w
    if ! mkfifo $CASES_DIR/${host}_r $CASES_DIR/${host}_w >/dev/null 2>&1; then
      echo "${showhost}ERROR: Could not create pipe file: $CASES_DIR/${host}_*, break this CASE."
      quit 1
    fi
  fi

  ssh root@$host '/bin/bash 2>&1
                  sed "s/00/001/g" /tmp/.backbash-log
                  echo 000
                  echo 1' >$CASES_DIR/${host}_r <$CASES_DIR/${host}_w &

  fd=$(__maxfd)
  rfd=$(expr $fd + 1)
  wfd=$(expr $fd + 2)
  eval "exec ${rfd}<$CASES_DIR/${host}_r ${wfd}>$CASES_DIR/${host}_w"
}

backbash()
{
  local host rfd wfd ret
  host="$1"

  rfd=$(__getfd $host r)
  wfd=$(__getfd $host w)

  if [ -z "$rfd" -o -z "$wfd" ]; then
    echo "${showhost}ERROR: Could not found connection with $host, break this CASE."
  fi

  cat >&$wfd <<EOF
{
true
EOF
  cat >&$wfd
  cat >&$wfd <<EOF

} >&/tmp/.backbash-log
sed 's/00/001/g' /tmp/.backbash-log
echo 000
echo 0
EOF
  if [ $? -ne 0 ]; then
    echo "${showhost}ERROR: Broken connection with $host, break this CASE."
    quit 1
  fi

  awk -vlive=2 '{
    if (sub(/000$/, "")) {
      if ($0 != "") {
        gsub("001", "00");
        printf("%s", $0);
      }
      getline live;
      exit;
    }
    gsub("001", "00");
    print;
  } END {
    exit(live);
  }' <&$rfd
  case $? in
      1)
        quit 1
        ;;
      2)
        echo "${showhost}ERROR: Broken connection with $host, break this CASE."
        quit 1
        ;;
  esac
}

backbash_stop()
{
  local host rfd wfd
  host="$1"

  wfd=$(__getfd $host w)
  if [ -n "$wfd" ]; then
    cat >&$wfd <<<'quit 0'
  fi
  rm -f $CASES_DIR/${host}_r $CASES_DIR/${host}_w
}


export OCF_ROOT=/usr/lib/ocf
export OCF_LIB=/usr/lib/ocf/lib//heartbeat
AGENT_ROOT=/usr/lib/ocf/resource.d//heartbeat
CASES_DIR=/var/lib/resource-agents/ocft/cases

atexit_num=0

if [ $EUID -ne 0 ]; then
  echo "${showhost}ERROR: '$0' needs to be run by root, break this CASE."
  quit 3
fi

fakebin=./fakebin

mkdir -p $fakebin >/dev/null 2>&1 &&
ln -sf /bin/true $fakebin/crm_master >/dev/null 2>&1 &&
ln -sf /bin/true $fakebin/crm_mon >/dev/null 2>&1
if [ $? -ne 0 ]; then
  echo "${showhost}ERROR: initialize 'fakebin' failed, break this CASE."
  quit 3
fi
export HA_SBIN_DIR=$fakebin

. $OCF_LIB/ocf-returncodes || {
  echo "${showhost}ERROR: $OCF_LIB/ocf-returncodes not found, break this CASE."
  quit 3
}

while read line; do
  if [ -n "$line" ]; then
    retn=${line%%=*}
    reti=$(eval echo \$$retn)
    retval[reti]=$retn
  fi
done <<<"$(sed 's/#.*//' $OCF_LIB/ocf-returncodes)"