2010-12-02 01:48:02 +03:00
# Hey Emacs, this is a -*- shell-script -*- !!!
2007-06-01 14:54:26 +04:00
# utility functions for ctdb event scripts
2009-11-19 07:00:17 +03:00
PATH=/bin:/usr/bin:/usr/sbin:/sbin:$PATH
2009-11-13 10:28:25 +03:00
2010-12-15 02:08:16 +03:00
[ -z "$CTDB_VARDIR" ] && {
2011-10-13 22:26:05 +04:00
if [ -d "/var/lib/ctdb" ] ; then
export CTDB_VARDIR="/var/lib/ctdb"
else
export CTDB_VARDIR="/var/ctdb"
fi
2010-12-15 02:08:16 +03:00
}
2011-06-07 09:57:29 +04:00
[ -z "$CTDB_ETCDIR" ] && {
export CTDB_ETCDIR="/etc"
}
2010-12-15 02:08:16 +03:00
2007-06-03 16:07:07 +04:00
#######################################
# pull in a system config file, if any
2010-08-31 11:40:40 +04:00
_loadconfig() {
2009-11-13 10:28:25 +03:00
2009-11-20 08:45:36 +03:00
if [ -z "$1" ] ; then
2009-11-19 07:00:17 +03:00
foo="${service_config:-${service_name}}"
if [ -n "$foo" ] ; then
loadconfig "$foo"
fi
2010-01-22 09:19:12 +03:00
elif [ "$1" != "ctdb" ] ; then
loadconfig "ctdb"
2009-11-13 10:28:25 +03:00
fi
2011-06-07 09:57:29 +04:00
if [ -f $CTDB_ETCDIR/sysconfig/$1 ]; then
. $CTDB_ETCDIR/sysconfig/$1
elif [ -f $CTDB_ETCDIR/default/$1 ]; then
. $CTDB_ETCDIR/default/$1
2009-11-20 08:45:36 +03:00
elif [ -f $CTDB_BASE/sysconfig/$1 ]; then
. $CTDB_BASE/sysconfig/$1
2007-06-03 16:07:07 +04:00
fi
}
2010-08-31 11:40:40 +04:00
loadconfig () {
_loadconfig "$@"
}
2011-08-17 03:00:46 +04:00
##############################################################
2013-04-17 07:12:32 +04:00
# CTDB_SCRIPT_DEBUGLEVEL can be overwritten by setting it in a
# configuration file.
2011-08-17 03:44:11 +04:00
debug ()
{
2013-04-17 07:12:32 +04:00
if [ ${CTDB_SCRIPT_DEBUGLEVEL:-2} -ge 4 ] ; then
2011-08-17 03:44:11 +04:00
# If there are arguments then echo them. Otherwise expect to
# use stdin, which allows us to pass lots of debug using a
# here document.
if [ -n "$1" ] ; then
echo "DEBUG: $*"
elif ! tty -s ; then
sed -e 's@^@DEBUG: @'
fi
fi
}
2012-03-07 09:09:56 +04:00
die ()
{
_msg="$1"
_rc="${2:-1}"
echo "$_msg"
exit $_rc
}
2012-10-16 10:04:48 +04:00
# Log given message or stdin to either syslog or a CTDB log file
# $1 is the tag passed to logger if syslog is in use.
script_log ()
2012-09-03 09:37:01 +04:00
{
2012-10-16 10:04:48 +04:00
_tag="$1" ; shift
2012-09-03 09:37:01 +04:00
_using_syslog=false
if [ "$CTDB_SYSLOG" = "yes" -o -z "$CTDB_LOGFILE" ] ; then
_using_syslog=true
fi
case "$CTDB_OPTIONS" in
*--syslog*) _using_syslog=true ;;
esac
2012-10-16 10:04:48 +04:00
if $_using_syslog ; then
2013-04-23 07:56:15 +04:00
logger -t "ctdbd: ${_tag}" $*
2012-10-16 10:04:48 +04:00
else
{
if [ -n "$*" ] ; then
echo "$*"
else
cat
fi
} >>"${CTDB_LOGFILE:-/var/log/log.ctdb}"
fi
}
# When things are run in the background in an eventscript then logging
# output might get lost. This is the "solution". :-)
background_with_logging ()
{
2012-09-03 09:37:01 +04:00
(
"$@" 2>&1 </dev/null |
2013-04-22 07:48:06 +04:00
script_log "${script_name}&"
2012-09-03 09:37:01 +04:00
)&
return 0
}
2011-08-23 10:32:34 +04:00
##############################################################
# check number of args for different events
ctdb_check_args ()
{
case "$1" in
takeip|releaseip)
if [ $# != 4 ]; then
echo "ERROR: must supply interface, IP and maskbits"
exit 1
fi
;;
updateip)
if [ $# != 5 ]; then
echo "ERROR: must supply old interface, new interface, IP and maskbits"
exit 1
fi
;;
esac
}
2009-01-16 15:26:57 +03:00
##############################################################
# determine on what type of system (init style) we are running
detect_init_style() {
# only do detection if not already set:
test "x$CTDB_INIT_STYLE" != "x" && return
if [ -x /sbin/startproc ]; then
CTDB_INIT_STYLE="suse"
elif [ -x /sbin/start-stop-daemon ]; then
2009-09-15 13:33:35 +04:00
CTDB_INIT_STYLE="debian"
2009-01-16 15:26:57 +03:00
else
CTDB_INIT_STYLE="redhat"
fi
}
2007-06-01 14:54:26 +04:00
2007-06-02 12:51:05 +04:00
######################################################
# simulate /sbin/service on platforms that don't have it
2011-06-07 09:57:29 +04:00
# _service() makes it easier to hook the service() function for
# testing.
_service ()
{
2009-11-13 10:28:25 +03:00
_service_name="$1"
_op="$2"
2009-01-16 15:31:02 +03:00
# do nothing, when no service was specified
2009-11-20 08:45:36 +03:00
[ -z "$_service_name" ] && return
2009-01-16 15:31:02 +03:00
2007-06-02 12:51:05 +04:00
if [ -x /sbin/service ]; then
2011-06-07 09:57:29 +04:00
$_nice /sbin/service "$_service_name" "$_op"
elif [ -x $CTDB_ETCDIR/init.d/$_service_name ]; then
$_nice $CTDB_ETCDIR/init.d/$_service_name "$_op"
elif [ -x $CTDB_ETCDIR/rc.d/init.d/$_service_name ]; then
$_nice $CTDB_ETCDIR/rc.d/init.d/$_service_name "$_op"
2007-06-02 12:51:05 +04:00
fi
}
2011-06-07 09:57:29 +04:00
service()
{
_nice=""
_service "$@"
}
2008-02-13 00:20:20 +03:00
######################################################
# simulate /sbin/service (niced) on platforms that don't have it
2011-06-07 09:57:29 +04:00
nice_service()
{
_nice="nice"
_service "$@"
2008-02-13 00:20:20 +03:00
}
2007-06-17 05:57:42 +04:00
2011-06-28 08:54:33 +04:00
######################################################
# wrapper around /proc/ settings to allow them to be hooked
# for testing
# 1st arg is relative path under /proc/, 2nd arg is value to set
set_proc ()
{
echo "$2" >"/proc/$1"
}
######################################################
# wrapper around getting file contents from /proc/ to allow
# this to be hooked for testing
# 1st arg is relative path under /proc/
get_proc ()
{
cat "/proc/$1"
}
2010-12-17 08:25:04 +03:00
######################################################
# Check that an RPC service is healthy -
# this includes allowing a certain number of failures
# before marking the NFS service unhealthy.
#
# usage: nfs_check_rpc_service SERVICE_NAME [ triple ...]
#
# each triple is a set of 3 arguments: an operator, a
# fail count limit and an action string.
#
# For example:
#
# nfs_check_rpc_service "lockd" \
# -ge 15 "verbose restart unhealthy" \
# -eq 10 "restart:bs"
#
# says that if lockd is down for 15 iterations then do
# a verbose restart of lockd and mark the node unhealthy.
# Before this, after 10 iterations of failure, the
# service is restarted silently in the background.
# Order is important: the number of failures need to be
# specified in reverse order because processing stops
# after the first condition that is true.
######################################################
nfs_check_rpc_service ()
{
_prog_name="$1" ; shift
2012-05-08 08:53:58 +04:00
_v=""
case "$1" in
-*) : ;;
*) _v="$1" ; shift ;;
esac
_version=${_v:-1}
2010-12-17 08:25:04 +03:00
_rpc_prog="$_prog_name"
_restart=""
_opts=""
case "$_prog_name" in
knfsd)
_rpc_prog=nfs
2012-05-08 08:53:58 +04:00
_version=${_v:-3}
2010-12-17 08:25:04 +03:00
_restart="echo 'Trying to restart NFS service'"
_restart="${_restart}; startstop_nfs restart"
;;
2012-05-16 11:24:21 +04:00
ganesha)
_rpc_prog=nfs
_version=${_v:-3}
_restart="echo 'Trying to restart Ganesha NFS service'"
_restart="${_restart}; startstop_ganesha restart"
;;
2010-12-17 08:25:04 +03:00
mountd)
_opts="${MOUNTD_PORT:+ -p }${MOUNTD_PORT}"
;;
rquotad)
_opts="${RQUOTAD_PORT:+ -p }${RQUOTAD_PORT}"
;;
lockd)
_rpc_prog=nlockmgr
2012-05-08 08:53:58 +04:00
_version=${_v:-4}
2010-12-17 08:25:04 +03:00
_restart="echo 'Trying to restart lock manager service'"
_restart="${_restart}; startstop_nfslock restart"
;;
statd)
_rpc_prog=status
_opts="${STATD_HOSTNAME:+ -n }${STATD_HOSTNAME}"
_opts="${_opts}${STATD_PORT:+ -p }${STATD_PORT}"
_opts="${_opts}${STATD_OUTGOING_PORT:+ -o }${STATD_OUTGOING_PORT}"
;;
*)
echo "Internal error: unknown RPC program \"$_prog_name\"."
exit 1
esac
_service_name="nfs_${_prog_name}"
if ctdb_check_rpc "$_rpc_prog" $_version >/dev/null ; then
ctdb_counter_init "$_service_name"
return 0
fi
ctdb_counter_incr "$_service_name"
while [ -n "$3" ] ; do
ctdb_check_counter "quiet" "$1" "$2" "$_service_name" || {
for _action in $3 ; do
case "$_action" in
verbose)
echo "$ctdb_check_rpc_out"
;;
restart|restart:*)
# No explicit command specified, construct rpc command.
if [ -z "$_restart" ] ; then
_p="rpc.${_prog_name}"
_restart="echo 'Trying to restart $_prog_name [${_p}${_opts}]'"
_restart="${_restart}; killall -q -9 $_p"
_restart="${_restart}; $_p $_opts"
fi
# Process restart flags...
_flags="${_action#restart:}"
# There may not have been a colon...
[ "$_flags" != "$_action" ] || _flags=""
# q=quiet - everything to /dev/null
if [ "${_flags#*q}" != "$_flags" ] ; then
_restart="{ ${_restart} ; } >/dev/null 2>&1"
fi
# s=stealthy - last command to /dev/null
if [ "${_flags#*s}" != "$_flags" ] ; then
_restart="${_restart} >/dev/null 2>&1"
fi
# b=background - the whole thing, easy and reliable
if [ "${_flags#*b}" != "$_flags" ] ; then
_restart="{ ${_restart} ; } &"
fi
# Do it!
eval "${_restart}"
;;
unhealthy)
exit 1
;;
*)
echo "Internal error: unknown action \"$_action\"."
exit 1
esac
done
# Only process the first action group.
break
}
shift 3
done
}
2007-06-06 06:08:42 +04:00
######################################################
# check that a rpc server is registered with portmap
# and responding to requests
2010-12-17 08:25:04 +03:00
# usage: ctdb_check_rpc SERVICE_NAME VERSION
2007-06-06 06:08:42 +04:00
######################################################
2010-12-17 08:25:04 +03:00
ctdb_check_rpc ()
{
2009-11-20 08:45:36 +03:00
progname="$1"
2010-12-17 08:25:04 +03:00
version="$2"
2010-11-16 11:31:18 +03:00
2010-12-17 08:25:04 +03:00
if ! ctdb_check_rpc_out=$(rpcinfo -u localhost $progname $version 2>&1) ; then
2010-11-16 11:31:18 +03:00
ctdb_check_rpc_out="ERROR: $progname failed RPC check:
$ctdb_check_rpc_out"
echo "$ctdb_check_rpc_out"
return 1
fi
2007-06-06 06:08:42 +04:00
}
######################################################
# check a set of directories is available
2009-10-12 09:32:49 +04:00
# return 1 on a missing directory
2008-07-23 09:35:46 +04:00
# usage: ctdb_check_directories_probe SERVICE_NAME <directories...>
2007-06-06 06:08:42 +04:00
######################################################
2008-07-23 09:35:46 +04:00
ctdb_check_directories_probe() {
2009-11-20 08:45:36 +03:00
while IFS="" read d ; do
case "$d" in
*%*)
continue
;;
*)
2010-03-26 18:40:00 +03:00
[ -d "${d}/." ] || return 1
2009-11-20 08:45:36 +03:00
esac
done
2008-07-23 09:35:46 +04:00
}
######################################################
# check a set of directories is available
# usage: ctdb_check_directories SERVICE_NAME <directories...>
######################################################
ctdb_check_directories() {
2009-11-20 08:45:36 +03:00
n="${1:-${service_name}}"
ctdb_check_directories_probe || {
echo "ERROR: $n directory \"$d\" not available"
exit 1
}
2007-06-06 06:08:42 +04:00
}
######################################################
# check a set of tcp ports
2009-11-20 08:45:36 +03:00
# usage: ctdb_check_tcp_ports <ports...>
2007-06-06 06:08:42 +04:00
######################################################
2011-08-05 10:39:57 +04:00
# This flag file is created when a service is initially started. It
# is deleted the first time TCP port checks for that service succeed.
# Until then ctdb_check_tcp_ports() prints a more subtle "error"
# message if a port check fails.
_ctdb_check_tcp_common ()
{
_ctdb_service_started_file="$ctdb_fail_dir/$service_name.started"
}
ctdb_check_tcp_init ()
{
_ctdb_check_tcp_common
mkdir -p "${_ctdb_service_started_file%/*}" # dirname
touch "$_ctdb_service_started_file"
}
2011-07-05 05:32:06 +04:00
ctdb_check_tcp_ports()
{
2011-08-17 06:12:20 +04:00
if [ -z "$1" ] ; then
echo "INTERNAL ERROR: ctdb_check_tcp_ports - no ports specified"
exit 1
fi
# Set default value for CTDB_TCP_PORT_CHECKS if unset.
# If any of these defaults are unsupported then this variable can
# be overridden in /etc/sysconfig/ctdb or via a file in
# /etc/ctdb/rc.local.d/.
2011-08-17 08:02:45 +04:00
: ${CTDB_TCP_PORT_CHECKERS:=ctdb nmap netstat}
2011-08-17 06:12:20 +04:00
for _c in $CTDB_TCP_PORT_CHECKERS ; do
ctdb_check_tcp_ports_$_c "$@"
case "$?" in
0)
2011-08-19 08:20:58 +04:00
_ctdb_check_tcp_common
2011-08-17 06:12:20 +04:00
rm -f "$_ctdb_service_started_file"
return 0
;;
1)
_ctdb_check_tcp_common
if [ ! -f "$_ctdb_service_started_file" ] ; then
echo "ERROR: $service_name tcp port $_p is not responding"
debug <<EOF
$ctdb_check_tcp_ports_debug
EOF
else
echo "INFO: $service_name tcp port $_p is not responding"
fi
return 1
;;
127)
debug <<EOF
ctdb_check_ports - checker $_c not implemented
output from checker was:
$ctdb_check_tcp_ports_debug
EOF
;;
*)
esac
done
2011-08-05 10:39:57 +04:00
2011-08-17 06:12:20 +04:00
echo "INTERNAL ERROR: ctdb_check_ports - no working checkers in CTDB_TCP_PORT_CHECKERS=\"$CTDB_TCP_PORT_CHECKERS\""
return 127
}
ctdb_check_tcp_ports_netstat ()
{
2011-07-05 05:32:06 +04:00
_cmd='netstat -l -t -n'
2011-08-17 06:12:20 +04:00
_ns=$($_cmd 2>&1)
if [ $? -eq 127 ] ; then
# netstat probably not installed - unlikely?
ctdb_check_tcp_ports_debug="$_ns"
return 127
fi
2011-07-05 05:32:06 +04:00
for _p ; do # process each function argument (port)
for _a in '0\.0\.0\.0' '::' ; do
_pat="[[:space:]]${_a}:${_p}[[:space:]]+[^[:space:]]+[[:space:]]+LISTEN"
if echo "$_ns" | grep -E -q "$_pat" ; then
# We matched the port, so process next port
continue 2
fi
done
2011-08-17 06:12:20 +04:00
# We didn't match the port, so flag an error.
ctdb_check_tcp_ports_debug="$_cmd shows this output:
$_ns"
2011-07-05 05:32:06 +04:00
return 1
2009-11-20 08:45:36 +03:00
done
2011-08-05 10:39:57 +04:00
2011-08-17 06:12:20 +04:00
return 0
}
ctdb_check_tcp_ports_nmap ()
{
# nmap wants a comma-separated list of ports
_ports=""
for _p ; do
_ports="${_ports}${_ports:+,}${_p}"
done
_cmd="nmap -n -oG - -PS 127.0.0.1 -p $_ports"
_nmap_out=$($_cmd 2>&1)
if [ $? -eq 127 ] ; then
# nmap probably not installed
ctdb_check_tcp_ports_debug="$_nmap_out"
return 127
fi
# get the port-related output
_port_info=$(echo "$_nmap_out" | sed -n -r -e 's@^.*Ports:[[:space:]]@@p')
for _p ; do
# looking for something like this:
# 445/open/tcp//microsoft-ds///
# possibly followed by a comma
_t="$_p/open/tcp//"
case "$_port_info" in
# The info we're after must be either at the beginning of
# the string or it must follow a space.
$_t*|*\ $_t*) : ;;
*)
# Nope, flag an error...
ctdb_check_tcp_ports_debug="$_cmd shows this output:
$_nmap_out"
return 1
esac
done
2011-08-05 10:39:57 +04:00
return 0
2007-06-06 06:08:42 +04:00
}
2007-06-17 06:05:29 +04:00
2011-08-17 08:02:45 +04:00
# Use the new "ctdb checktcpport" command to check the port.
# This is very cheap.
ctdb_check_tcp_ports_ctdb ()
{
for _p ; do # process each function argument (port)
_cmd="ctdb checktcpport $_p"
_out=$($_cmd 2>&1)
2011-08-19 07:55:55 +04:00
_ret=$?
case "$_ret" in
2011-08-17 08:02:45 +04:00
0)
ctdb_check_tcp_ports_debug="\"$_cmd\" was able to bind to port"
return 1
;;
98)
# Couldn't bind, something already listening, next port...
continue
;;
*)
2011-08-19 07:55:55 +04:00
ctdb_check_tcp_ports_debug="$_cmd (exited with $_ret) with output:
2011-08-17 08:02:45 +04:00
$_out"
# assume not implemented
return 127
esac
done
return 0
}
2009-05-19 02:47:19 +04:00
######################################################
# check a unix socket
# usage: ctdb_check_unix_socket SERVICE_NAME <socket_path>
######################################################
ctdb_check_unix_socket() {
2009-11-20 08:45:36 +03:00
socket_path="$1"
[ -z "$socket_path" ] && return
2009-05-19 02:47:19 +04:00
2009-11-20 08:45:36 +03:00
if ! netstat --unix -a -n | grep -q "^unix.*LISTEN.*${socket_path}$"; then
echo "ERROR: $service_name socket $socket_path not found"
return 1
2009-05-19 02:47:19 +04:00
fi
}
2007-06-17 06:05:29 +04:00
######################################################
# check a command returns zero status
# usage: ctdb_check_command SERVICE_NAME <command>
######################################################
ctdb_check_command() {
service_name="$1"
wait_cmd="$2"
[ -z "$wait_cmd" ] && return;
$wait_cmd > /dev/null 2>&1 || {
2008-01-16 14:06:44 +03:00
echo "ERROR: $service_name - $wait_cmd returned error"
2007-06-17 06:05:29 +04:00
exit 1
}
}
2007-10-11 01:27:38 +04:00
################################################
# kill off any TCP connections with the given IP
################################################
kill_tcp_connections() {
_IP="$1"
_failed=0
_killcount=0
2010-09-03 06:35:25 +04:00
connfile="$CTDB_VARDIR/state/connections.$_IP"
2013-04-22 00:52:49 +04:00
mkdir -p "${connfile%/*}" # dirname
2008-07-09 04:03:21 +04:00
netstat -tn |egrep "^tcp.*[[:space:]]+$_IP:.*ESTABLISHED" | awk '{print $4" "$5}' > $connfile
2008-08-20 06:50:50 +04:00
netstat -tn |egrep "^tcp.*[[:space:]]+::ffff:$_IP:.*ESTABLISHED" | awk '{print $4" "$5}' >> $connfile
2008-08-20 03:47:00 +04:00
2007-10-11 01:27:38 +04:00
while read dest src; do
2008-08-20 03:47:00 +04:00
srcip=`echo $src | sed -e "s/:[^:]*$//"`
srcport=`echo $src | sed -e "s/^.*://"`
destip=`echo $dest | sed -e "s/:[^:]*$//"`
destport=`echo $dest | sed -e "s/^.*://"`
2008-01-16 14:06:44 +03:00
echo "Killing TCP connection $srcip:$srcport $destip:$destport"
2008-08-01 08:17:50 +04:00
ctdb killtcp $srcip:$srcport $destip:$destport >/dev/null 2>&1 || _failed=1
case $destport in
2009-11-06 01:54:03 +03:00
# we only do one-way killtcp for CIFS
139|445) : ;;
2008-08-01 08:17:50 +04:00
# for all others we do 2-way
*)
ctdb killtcp $destip:$destport $srcip:$srcport >/dev/null 2>&1 || _failed=1
;;
esac
2007-10-11 01:27:38 +04:00
_killcount=`expr $_killcount + 1`
2008-08-20 03:47:00 +04:00
done < $connfile
2011-04-13 06:08:09 +04:00
rm -f $connfile
2008-08-20 03:47:00 +04:00
2007-10-11 01:27:38 +04:00
[ $_failed = 0 ] || {
2008-01-16 14:06:44 +03:00
echo "Failed to send killtcp control"
2007-10-11 01:27:38 +04:00
return;
}
[ $_killcount -gt 0 ] || {
return;
}
2009-03-24 06:05:31 +03:00
_count=0
while netstat -tn |egrep "^tcp.*[[:space:]]+$_IP:.*ESTABLISHED" > /dev/null; do
sleep 1
_count=`expr $_count + 1`
[ $_count -gt 3 ] && {
echo "Timed out killing tcp connections for IP $_IP"
return;
}
done
echo "killed $_killcount TCP connections to released IP $_IP"
}
##################################################################
# kill off the local end for any TCP connections with the given IP
##################################################################
kill_tcp_connections_local_only() {
_IP="$1"
_failed=0
_killcount=0
2010-09-03 06:35:25 +04:00
connfile="$CTDB_VARDIR/state/connections.$_IP"
2013-04-22 00:52:49 +04:00
mkdir -p "${connfile%/*}" # dirname
2009-03-24 06:05:31 +03:00
netstat -tn |egrep "^tcp.*[[:space:]]+$_IP:.*ESTABLISHED" | awk '{print $4" "$5}' > $connfile
netstat -tn |egrep "^tcp.*[[:space:]]+::ffff:$_IP:.*ESTABLISHED" | awk '{print $4" "$5}' >> $connfile
while read dest src; do
srcip=`echo $src | sed -e "s/:[^:]*$//"`
srcport=`echo $src | sed -e "s/^.*://"`
destip=`echo $dest | sed -e "s/:[^:]*$//"`
destport=`echo $dest | sed -e "s/^.*://"`
echo "Killing TCP connection $srcip:$srcport $destip:$destport"
ctdb killtcp $srcip:$srcport $destip:$destport >/dev/null 2>&1 || _failed=1
_killcount=`expr $_killcount + 1`
done < $connfile
2011-04-13 06:08:09 +04:00
rm -f $connfile
2009-03-24 06:05:31 +03:00
[ $_failed = 0 ] || {
echo "Failed to send killtcp control"
return;
}
[ $_killcount -gt 0 ] || {
return;
}
2007-10-11 01:27:38 +04:00
_count=0
2008-07-09 04:03:21 +04:00
while netstat -tn |egrep "^tcp.*[[:space:]]+$_IP:.*ESTABLISHED" > /dev/null; do
2007-10-11 01:27:38 +04:00
sleep 1
_count=`expr $_count + 1`
[ $_count -gt 3 ] && {
2008-01-16 14:06:44 +03:00
echo "Timed out killing tcp connections for IP $_IP"
2007-10-11 01:27:38 +04:00
return;
}
done
2008-01-16 14:06:44 +03:00
echo "killed $_killcount TCP connections to released IP $_IP"
2007-10-11 01:27:38 +04:00
}
2009-12-18 11:43:20 +03:00
##################################################################
# tickle any TCP connections with the given IP
##################################################################
tickle_tcp_connections() {
_IP="$1"
_failed=0
_killcount=0
2010-09-03 06:35:25 +04:00
connfile="$CTDB_VARDIR/state/connections.$_IP"
2013-04-22 00:52:49 +04:00
mkdir -p "${connfile%/*}" # dirname
2009-12-18 11:43:20 +03:00
netstat -tn |egrep "^tcp.*[[:space:]]+$_IP:.*ESTABLISHED" | awk '{print $4" "$5}' > $connfile
netstat -tn |egrep "^tcp.*[[:space:]]+::ffff:$_IP:.*ESTABLISHED" | awk '{print $4" "$5}' >> $connfile
while read dest src; do
srcip=`echo $src | sed -e "s/:[^:]*$//"`
srcport=`echo $src | sed -e "s/^.*://"`
destip=`echo $dest | sed -e "s/:[^:]*$//"`
destport=`echo $dest | sed -e "s/^.*://"`
echo "Tickle TCP connection $srcip:$srcport $destip:$destport"
ctdb tickle $srcip:$srcport $destip:$destport >/dev/null 2>&1 || _failed=1
echo "Tickle TCP connection $destip:$destport $srcip:$srcport"
ctdb tickle $destip:$destport $srcip:$srcport >/dev/null 2>&1 || _failed=1
done < $connfile
2011-04-13 06:08:09 +04:00
rm -f $connfile
2009-12-18 11:43:20 +03:00
[ $_failed = 0 ] || {
echo "Failed to send tickle control"
return;
}
}
2008-02-11 01:35:37 +03:00
########################################################
2012-05-16 11:24:21 +04:00
# start/stop the Ganesha nfs service
########################################################
startstop_ganesha()
{
2013-01-09 14:41:39 +04:00
_service_name="nfs-ganesha-$CTDB_CLUSTER_FILESYSTEM_TYPE"
2012-05-16 11:24:21 +04:00
case "$1" in
start)
service "$_service_name" start
;;
stop)
service "$_service_name" stop
;;
restart)
service "$_service_name" restart
;;
esac
}
########################################################
2008-02-11 01:35:37 +03:00
# start/stop the nfs service on different platforms
########################################################
startstop_nfs() {
PLATFORM="unknown"
2011-06-07 09:57:29 +04:00
[ -x $CTDB_ETCDIR/init.d/nfsserver ] && {
2008-02-11 01:35:37 +03:00
PLATFORM="sles"
}
2011-06-07 09:57:29 +04:00
[ -x $CTDB_ETCDIR/init.d/nfslock ] && {
2008-02-11 01:35:37 +03:00
PLATFORM="rhel"
}
case $PLATFORM in
sles)
case $1 in
start)
service nfsserver start
;;
stop)
service nfsserver stop > /dev/null 2>&1
;;
2010-08-19 01:18:22 +04:00
restart)
2011-06-28 08:58:13 +04:00
set_proc "fs/nfsd/threads" 0
2011-01-11 09:06:48 +03:00
service nfsserver stop > /dev/null 2>&1
pkill -9 nfsd
service nfsserver start
2010-08-19 01:18:22 +04:00
;;
2008-02-11 01:35:37 +03:00
esac
;;
rhel)
case $1 in
start)
service nfslock start
service nfs start
;;
stop)
2011-01-14 01:31:05 +03:00
service nfs stop
service nfslock stop
2008-02-11 01:35:37 +03:00
;;
2010-08-19 01:18:22 +04:00
restart)
2011-06-28 08:58:13 +04:00
set_proc "fs/nfsd/threads" 0
2011-01-11 09:06:48 +03:00
service nfs stop > /dev/null 2>&1
service nfslock stop > /dev/null 2>&1
pkill -9 nfsd
service nfslock start
service nfs start
2010-08-19 01:18:22 +04:00
;;
2008-02-11 01:35:37 +03:00
esac
;;
*)
echo "Unknown platform. NFS is not supported with ctdb"
exit 1
;;
esac
}
2008-02-11 01:52:09 +03:00
########################################################
# start/stop the nfs lockmanager service on different platforms
########################################################
startstop_nfslock() {
PLATFORM="unknown"
2011-06-07 09:57:29 +04:00
[ -x $CTDB_ETCDIR/init.d/nfsserver ] && {
2008-02-11 01:52:09 +03:00
PLATFORM="sles"
}
2011-06-07 09:57:29 +04:00
[ -x $CTDB_ETCDIR/init.d/nfslock ] && {
2008-02-11 01:52:09 +03:00
PLATFORM="rhel"
}
case $PLATFORM in
sles)
# for sles there is no service for lockmanager
# so we instead just shutdown/restart nfs
case $1 in
start)
service nfsserver start
;;
stop)
service nfsserver stop > /dev/null 2>&1
;;
2010-10-14 01:12:41 +04:00
restart)
service nfsserver stop
service nfsserver start
;;
2008-02-11 01:52:09 +03:00
esac
;;
rhel)
case $1 in
start)
service nfslock start
;;
stop)
service nfslock stop > /dev/null 2>&1
;;
2010-10-14 01:12:41 +04:00
restart)
service nfslock stop
service nfslock start
;;
2008-02-11 01:52:09 +03:00
esac
;;
*)
echo "Unknown platform. NFS locking is not supported with ctdb"
exit 1
;;
esac
}
2008-04-10 00:50:12 +04:00
2010-01-20 13:10:48 +03:00
add_ip_to_iface()
{
2012-03-07 09:18:12 +04:00
_iface=$1
_ip=$2
_maskbits=$3
2010-01-20 13:10:48 +03:00
2012-03-07 09:18:12 +04:00
_lockfile="${CTDB_VARDIR}/state/interface_modify_${_iface}.flock"
2013-04-22 00:52:49 +04:00
mkdir -p "${_lockfile%/*}" # dirname
2012-03-07 09:18:12 +04:00
[ -f "$_lockfile" ] || touch "$_lockfile"
(
# Note: use of return/exit/die() below only gets us out of the
# sub-shell, which is actually what we want. That is, the
# function should just return non-zero.
flock --timeout 30 0 || \
die "add_ip_to_iface: unable to get lock for ${_iface}"
# Ensure interface is up
ip link set "$_iface" up || \
die "Failed to bringup interface $_iface"
2010-01-20 13:10:48 +03:00
2012-03-07 09:18:12 +04:00
ip addr add "$_ip/$_maskbits" brd + dev "$_iface" || \
die "Failed to add $_ip/$_maskbits on dev $_iface"
) <"$_lockfile"
# Do nothing here - return above only gets us out of the subshell
# and doing anything here will affect the return code.
2010-01-20 13:10:48 +03:00
}
delete_ip_from_iface()
{
2012-03-07 09:18:12 +04:00
_iface=$1
_ip=$2
_maskbits=$3
_lockfile="${CTDB_VARDIR}/state/interface_modify_${_iface}.flock"
2013-04-22 00:52:49 +04:00
mkdir -p "${_lockfile%/*}" # dirname
2012-03-07 09:18:12 +04:00
[ -f "$_lockfile" ] || touch "$_lockfile"
(
# Note: use of return/exit/die() below only gets us out of the
# sub-shell, which is actually what we want. That is, the
# function should just return non-zero.
flock --timeout 30 0 || \
die "delete_ip_from_iface: unable to get lock for ${_iface}"
2010-01-20 13:10:48 +03:00
2012-03-07 09:18:12 +04:00
_im="$_ip/$_maskbits" # shorthand for readability
# "ip addr del" will delete all secondary IPs if this is the
# primary. To work around this _very_ annoying behaviour we
# have to keep a record of the secondaries and re-add them
# afterwards. Yuck!
_secondaries=""
if ip addr list dev "$_iface" primary | grep -Fq "inet $_im " ; then
_secondaries=$(ip addr list dev "$_iface" secondary | \
awk '$1 == "inet" { print $2 }')
fi
local _rc=0
ip addr del "$_im" dev "$_iface" || {
echo "Failed to del $_ip on dev $_iface"
_rc=1
2010-01-20 13:10:48 +03:00
}
2012-03-07 09:18:12 +04:00
if [ -n "$_secondaries" ] ; then
for _i in $_secondaries; do
if ip addr list dev "$_iface" | grep -Fq "inet $_i" ; then
echo "Kept secondary $_i on dev $_iface"
else
echo "Re-adding secondary address $_i to dev $_iface"
ip addr add $_i brd + dev $_iface || {
echo "Failed to re-add address $_i to dev $_iface"
_rc=1
}
fi
done
fi
return $_rc
) <"$_lockfile"
# Do nothing here - return above only gets us out of the subshell
# and doing anything here will affect the return code.
2010-02-12 11:48:01 +03:00
}
2013-01-04 04:23:29 +04:00
# If the given IP is hosted then print 2 items: maskbits and iface
ip_maskbits_iface ()
{
_addr="$1"
ip addr show to "${_addr}/32" 2>/dev/null | \
awk '$1 == "inet" { print gensub(".*/", "", 1, $2), $NF }'
}
drop_ip ()
{
_addr="${1%/*}" # Remove optional maskbits
_log_tag="$2"
set -- $(ip_maskbits_iface $_addr)
if [ -n "$1" ] ; then
_maskbits="$1"
_iface="$2"
if [ -n "$_log_tag" ] ; then
script_log "$_log_tag" \
"Removing public address $_addr/$_maskbits from device $_iface"
fi
ip addr del $_addr/$_maskbits dev $_iface >/dev/null 2>&1
fi
}
drop_all_public_ips ()
{
_log_tag="$1"
while read _ip _x ; do
drop_ip "$_ip" "$_log_tag"
2013-01-03 08:07:07 +04:00
done <"${CTDB_PUBLIC_ADDRESSES:-/dev/null}"
}
2009-09-30 15:05:16 +04:00
########################################################
# some simple logic for counting events - per eventscript
2009-11-19 07:00:17 +03:00
# usage: ctdb_counter_init
# ctdb_counter_incr
# ctdb_check_counter_limit <limit>
2012-10-17 16:21:33 +04:00
# ctdb_check_counter_limit fails when count >= <limit>
2009-09-30 15:05:16 +04:00
########################################################
_ctdb_counter_common () {
2011-01-14 01:29:16 +03:00
_service_name="${1:-${service_name}}"
2010-12-15 02:48:00 +03:00
_counter_file="$ctdb_fail_dir/$_service_name"
2009-09-30 15:05:16 +04:00
mkdir -p "${_counter_file%/*}" # dirname
}
ctdb_counter_init () {
2010-12-16 02:11:33 +03:00
_ctdb_counter_common "$1"
2009-09-30 15:05:16 +04:00
2009-11-19 08:48:19 +03:00
>"$_counter_file"
2009-09-30 15:05:16 +04:00
}
ctdb_counter_incr () {
2010-12-16 02:11:33 +03:00
_ctdb_counter_common "$1"
2009-09-30 15:05:16 +04:00
# unary counting!
echo -n 1 >> "$_counter_file"
}
2009-11-13 10:28:25 +03:00
ctdb_check_counter_limit () {
2010-12-16 02:11:33 +03:00
_ctdb_counter_common
2009-09-30 15:05:16 +04:00
2009-11-19 08:48:19 +03:00
_limit="${1:-${service_fail_limit}}"
_quiet="$2"
2009-09-30 15:05:16 +04:00
# unary counting!
_size=$(stat -c "%s" "$_counter_file" 2>/dev/null || echo 0)
2009-11-19 08:48:19 +03:00
if [ $_size -ge $_limit ] ; then
echo "ERROR: more than $_limit consecutive failures for $service_name, marking cluster unhealthy"
2009-11-13 10:28:25 +03:00
exit 1
2009-11-19 08:48:19 +03:00
elif [ $_size -gt 0 -a -z "$_quiet" ] ; then
echo "WARNING: less than $_limit consecutive failures ($_size) for $service_name, not unhealthy yet"
2009-11-13 10:28:25 +03:00
fi
}
2010-12-17 08:10:56 +03:00
ctdb_check_counter () {
_msg="${1:-error}" # "error" - anything else is silent on fail
_op="${2:--ge}" # an integer operator supported by test
_limit="${3:-${service_fail_limit}}"
shift 3
_ctdb_counter_common "$1"
# unary counting!
_size=$(stat -c "%s" "$_counter_file" 2>/dev/null || echo 0)
if [ $_size $_op $_limit ] ; then
if [ "$_msg" = "error" ] ; then
echo "ERROR: $_limit consecutive failures for $_service_name, marking node unhealthy"
exit 1
else
return 1
fi
fi
}
2010-11-17 05:50:56 +03:00
2009-11-13 10:28:25 +03:00
########################################################
2010-12-15 02:21:39 +03:00
ctdb_status_dir="$CTDB_VARDIR/status"
ctdb_fail_dir="$CTDB_VARDIR/failcount"
2010-12-15 02:45:17 +03:00
2010-12-15 02:49:48 +03:00
ctdb_setup_service_state_dir ()
{
service_state_dir="$CTDB_VARDIR/state/${1:-${service_name}}"
mkdir -p "$service_state_dir" || {
echo "Error creating state dir \"$service_state_dir\""
exit 1
}
}
2010-12-15 02:45:17 +03:00
########################################################
# Managed status history, for auto-start/stop
ctdb_managed_dir="$CTDB_VARDIR/managed_history"
_ctdb_managed_common ()
{
_service_name="${1:-${service_name}}"
_ctdb_managed_file="$ctdb_managed_dir/$_service_name"
}
ctdb_service_managed ()
{
_ctdb_managed_common "$@"
mkdir -p "$ctdb_managed_dir"
touch "$_ctdb_managed_file"
}
ctdb_service_unmanaged ()
{
_ctdb_managed_common "$@"
rm -f "$_ctdb_managed_file"
}
is_ctdb_previously_managed_service ()
{
_ctdb_managed_common "$@"
[ -f "$_ctdb_managed_file" ]
}
########################################################
# Check and set status
2009-11-13 10:28:25 +03:00
2009-11-25 08:34:49 +03:00
log_status_cat ()
{
2010-03-10 12:39:31 +03:00
echo "node is \"$1\", \"${script_name}\" reports problem: $(cat $2)"
2009-11-25 08:34:49 +03:00
}
2009-11-13 10:28:25 +03:00
ctdb_checkstatus ()
{
2009-11-25 08:42:14 +03:00
if [ -r "$ctdb_status_dir/$script_name/unhealthy" ] ; then
log_status_cat "unhealthy" "$ctdb_status_dir/$script_name/unhealthy"
2009-11-13 10:28:25 +03:00
return 1
2009-11-25 08:42:14 +03:00
elif [ -r "$ctdb_status_dir/$script_name/banned" ] ; then
log_status_cat "banned" "$ctdb_status_dir/$script_name/banned"
2009-11-13 10:28:25 +03:00
return 2
else
return 0
fi
}
ctdb_setstatus ()
{
2009-11-25 08:42:14 +03:00
d="$ctdb_status_dir/$script_name"
2009-11-13 10:28:25 +03:00
case "$1" in
unhealthy|banned)
mkdir -p "$d"
cat "$2" >"$d/$1"
;;
*)
for i in "banned" "unhealthy" ; do
rm -f "$d/$i"
done
;;
esac
}
2010-12-15 11:19:21 +03:00
##################################################################
# Reconfigure a service on demand
_ctdb_service_reconfigure_common ()
{
2013-04-29 20:59:41 +04:00
_d="$ctdb_status_dir/${service_name}"
2010-12-15 11:19:21 +03:00
mkdir -p "$_d"
_ctdb_service_reconfigure_flag="$_d/reconfigure"
}
2009-11-13 10:28:25 +03:00
ctdb_service_needs_reconfigure ()
{
2013-04-29 20:59:41 +04:00
_ctdb_service_reconfigure_common
2010-12-15 11:19:21 +03:00
[ -e "$_ctdb_service_reconfigure_flag" ]
2009-09-30 15:05:16 +04:00
}
2009-11-13 10:28:25 +03:00
ctdb_service_set_reconfigure ()
{
2013-04-29 20:59:41 +04:00
_ctdb_service_reconfigure_common
2010-12-15 11:19:21 +03:00
>"$_ctdb_service_reconfigure_flag"
2009-11-13 10:28:25 +03:00
}
ctdb_service_unset_reconfigure ()
{
2013-04-29 20:59:41 +04:00
_ctdb_service_reconfigure_common
2010-12-15 11:19:21 +03:00
rm -f "$_ctdb_service_reconfigure_flag"
2009-11-13 10:28:25 +03:00
}
ctdb_service_reconfigure ()
{
2013-04-29 20:59:41 +04:00
echo "Reconfiguring service \"${service_name}\"..."
ctdb_service_unset_reconfigure
service_reconfigure || return $?
ctdb_counter_init
2010-12-15 11:19:21 +03:00
}
2012-12-04 08:00:44 +04:00
# Default service_reconfigure() function does nothing.
2010-12-15 11:19:21 +03:00
service_reconfigure ()
{
2012-12-04 08:00:44 +04:00
:
2010-12-15 11:19:21 +03:00
}
2011-05-16 08:23:28 +04:00
ctdb_reconfigure_try_lock ()
{
2013-04-29 20:59:41 +04:00
_ctdb_service_reconfigure_common
2011-05-16 08:23:28 +04:00
_lock="${_d}/reconfigure_lock"
2013-04-22 00:52:49 +04:00
mkdir -p "${_lock%/*}" # dirname
2011-05-16 08:23:28 +04:00
touch "$_lock"
(
flock 0
# This is overkill but will work if we need to extend this to
# allow certain events to run multiple times in parallel
# (e.g. takeip) and write multiple PIDs to the file.
read _locker_event
if [ -n "$_locker_event" ] ; then
while read _pid ; do
if [ -n "$_pid" -a "$_pid" != $$ ] && \
kill -0 "$_pid" 2>/dev/null ; then
exit 1
fi
done
fi
printf "%s\n%s\n" "$event_name" $$ >"$_lock"
exit 0
) <"$_lock"
}
ctdb_replay_monitor_status ()
{
echo "Replaying previous status for this script due to reconfigure..."
2011-08-31 09:34:43 +04:00
# Leading colon (':') is missing in some versions...
_out=$(ctdb scriptstatus -Y | grep -E "^:?monitor:${script_name}:")
# Output looks like this:
# :monitor:60.nfs:1:ERROR:1314764004.030861:1314764004.035514:foo bar:
# This is the cheapest way of getting fields in the middle.
set -- $(IFS=":" ; echo $_out)
_code="$3"
_status="$4"
# The error output field can include colons so we'll try to
# preserve them. The weak checking at the beginning tries to make
# this work for both broken (no leading ':') and fixed output.
_out="${_out%:}"
_err_out="${_out#*monitor:${script_name}:*:*:*:*:}"
case "$_status" in
OK) : ;; # Do nothing special.
TIMEDOUT)
# Recast this as an error, since we can't exit with the
# correct negative number.
_code=1
_err_out="[Replay of TIMEDOUT scriptstatus - note incorrect return code.] ${_err_out}"
;;
DISABLED)
# Recast this as an OK, since we can't exit with the
# correct negative number.
_code=0
_err_out="[Replay of DISABLED scriptstatus - note incorrect return code.] ${_err_out}"
;;
*) : ;; # Must be ERROR, do nothing special.
esac
echo "$_err_out"
exit $_code
2011-05-16 08:23:28 +04:00
}
2010-12-15 11:19:21 +03:00
ctdb_service_check_reconfigure ()
{
2011-05-16 08:23:28 +04:00
# We only care about some events in this function. For others we
# return now.
2011-01-14 01:31:56 +03:00
case "$event_name" in
2011-05-16 08:23:28 +04:00
monitor|ipreallocated|reconfigure) : ;;
*) return 0 ;;
2011-01-14 01:31:56 +03:00
esac
2010-12-16 01:50:44 +03:00
2013-04-29 20:59:41 +04:00
if ctdb_reconfigure_try_lock ; then
2011-05-16 08:23:28 +04:00
# No events covered by this function are running, so proceed
# with gay abandon.
case "$event_name" in
reconfigure)
2013-04-29 20:59:41 +04:00
(ctdb_service_reconfigure)
2011-05-16 08:23:28 +04:00
exit $?
;;
ipreallocated)
2013-04-29 20:59:41 +04:00
if ctdb_service_needs_reconfigure ; then
ctdb_service_reconfigure
2011-05-16 08:23:28 +04:00
fi
;;
monitor)
2013-04-29 20:59:41 +04:00
if ctdb_service_needs_reconfigure ; then
ctdb_service_reconfigure
2011-05-16 08:23:28 +04:00
# Given that the reconfigure might not have
# resulted in the service being stable yet, we
# replay the previous status since that's the best
# information we have.
ctdb_replay_monitor_status
fi
;;
esac
else
# Somebody else is running an event we don't want to collide
# with. We proceed with caution.
case "$event_name" in
reconfigure)
# Tell whoever called us to retry.
exit 2
;;
ipreallocated)
# Defer any scheduled reconfigure and just run the
# rest of the ipreallocated event, as per the
# eventscript. There's an assumption here that the
# event doesn't depend on any scheduled reconfigure.
# This is true in the current code.
return 0
;;
monitor)
# There is most likely a reconfigure in progress so
# the service is possibly unstable. As above, we
# defer any scheduled reconfigured. We also replay
# the previous monitor status since that's the best
# information we have.
ctdb_replay_monitor_status
;;
esac
2009-11-13 10:28:25 +03:00
fi
}
2010-12-15 11:19:21 +03:00
##################################################################
# Does CTDB manage this service? - and associated auto-start/stop
2009-11-13 10:28:25 +03:00
ctdb_compat_managed_service ()
{
2013-04-29 21:13:36 +04:00
if [ "$1" = "yes" -a "$2" = "$service_name" ] ; then
2010-11-18 08:19:45 +03:00
CTDB_MANAGED_SERVICES="$CTDB_MANAGED_SERVICES $2"
2009-11-13 10:28:25 +03:00
fi
}
is_ctdb_managed_service ()
{
2010-11-18 08:19:45 +03:00
# $t is used just for readability and to allow better accurate
# matching via leading/trailing spaces
2009-11-13 10:28:25 +03:00
t=" $CTDB_MANAGED_SERVICES "
2013-04-29 21:13:36 +04:00
# Return 0 if "<space>$service_name<space>" appears in $t
if [ "${t#* ${service_name} }" != "${t}" ] ; then
2010-11-18 08:19:45 +03:00
return 0
fi
# If above didn't match then update $CTDB_MANAGED_SERVICES for
# backward compatibility and try again.
2009-11-13 10:28:25 +03:00
ctdb_compat_managed_service "$CTDB_MANAGES_VSFTPD" "vsftpd"
ctdb_compat_managed_service "$CTDB_MANAGES_SAMBA" "samba"
ctdb_compat_managed_service "$CTDB_MANAGES_SCP" "scp"
2010-11-18 07:40:19 +03:00
ctdb_compat_managed_service "$CTDB_MANAGES_WINBIND" "winbind"
2011-07-26 01:35:49 +04:00
ctdb_compat_managed_service "$CTDB_MANAGES_HTTPD" "apache2"
2009-11-13 10:28:25 +03:00
ctdb_compat_managed_service "$CTDB_MANAGES_HTTPD" "httpd"
ctdb_compat_managed_service "$CTDB_MANAGES_ISCSI" "iscsi"
ctdb_compat_managed_service "$CTDB_MANAGES_CLAMD" "clamd"
2009-11-25 08:34:49 +03:00
ctdb_compat_managed_service "$CTDB_MANAGES_NFS" "nfs"
2010-12-06 03:26:43 +03:00
ctdb_compat_managed_service "$CTDB_MANAGES_NFS" "nfs-ganesha-gpfs"
2009-11-13 10:28:25 +03:00
2010-11-18 08:19:45 +03:00
t=" $CTDB_MANAGED_SERVICES "
2013-04-29 21:13:36 +04:00
# Return 0 if "<space>$service_name<space>" appears in $t
[ "${t#* ${service_name} }" != "${t}" ]
2009-11-13 10:28:25 +03:00
}
ctdb_start_stop_service ()
{
2012-08-21 09:52:03 +04:00
# Allow service-start/service-stop pseudo-events to start/stop
# services when we're not auto-starting/stopping and we're not
# monitoring.
case "$event_name" in
service-start)
2013-04-29 21:13:36 +04:00
if is_ctdb_managed_service ; then
2012-08-21 09:52:03 +04:00
die 'service-start event not permitted when service is managed'
fi
if [ "$CTDB_SERVICE_AUTOSTARTSTOP" = "yes" ] ; then
die 'service-start event not permitted with $CTDB_SERVICE_AUTOSTARTSTOP = yes'
fi
2013-04-29 21:13:36 +04:00
ctdb_service_start
2012-08-21 09:52:03 +04:00
exit $?
;;
service-stop)
2013-04-29 21:13:36 +04:00
if is_ctdb_managed_service ; then
2012-08-21 09:52:03 +04:00
die 'service-stop event not permitted when service is managed'
fi
if [ "$CTDB_SERVICE_AUTOSTARTSTOP" = "yes" ] ; then
die 'service-stop event not permitted with $CTDB_SERVICE_AUTOSTARTSTOP = yes'
fi
2013-04-29 21:13:36 +04:00
ctdb_service_stop
2012-08-21 09:52:03 +04:00
exit $?
;;
esac
2011-08-08 07:13:59 +04:00
# Do nothing unless configured to...
[ "$CTDB_SERVICE_AUTOSTARTSTOP" = "yes" ] || return 0
2011-01-11 09:12:03 +03:00
[ "$event_name" = "monitor" ] || return 0
2013-04-29 21:13:36 +04:00
if is_ctdb_managed_service ; then
if ! is_ctdb_previously_managed_service ; then
echo "Starting service \"$service_name\" - now managed"
background_with_logging ctdb_service_start
2010-12-15 08:34:00 +03:00
exit $?
2009-11-13 10:28:25 +03:00
fi
2010-11-18 07:40:19 +03:00
else
2013-04-29 21:13:36 +04:00
if is_ctdb_previously_managed_service ; then
echo "Stopping service \"$service_name\" - no longer managed"
background_with_logging ctdb_service_stop
2010-12-15 08:34:00 +03:00
exit $?
2009-11-13 10:28:25 +03:00
fi
fi
}
ctdb_service_start ()
{
2010-12-15 08:34:00 +03:00
# The service is marked managed if we've ever tried to start it.
ctdb_service_managed "$@"
2011-08-11 03:39:25 +04:00
# Here we only want $1. If no argument is passed then
# service_start needs to know.
service_start "$@" || return $?
ctdb_counter_init "$@"
2011-08-05 10:39:57 +04:00
ctdb_check_tcp_init
2009-11-13 10:28:25 +03:00
}
ctdb_service_stop ()
{
2010-12-15 08:34:00 +03:00
ctdb_service_unmanaged "$@"
2011-08-11 03:39:25 +04:00
service_stop "$@"
}
# Default service_start() and service_stop() functions.
# These may be overridden in an eventscript. When overriding, the
# following convention must be followed. If these functions are
# called with no arguments then they may use internal logic to
# determine whether the service is managed and, therefore, whether
# they should take any action. However, if the service name is
# specified as an argument then an attempt must be made to start or
# stop the service. This is because the auto-start/stop code calls
# them with the service name as an argument.
service_start ()
{
service "${1:-${service_name}}" start
}
service_stop ()
{
service "${1:-${service_name}}" stop
2009-11-13 10:28:25 +03:00
}
2011-08-11 03:39:25 +04:00
##################################################################
2009-12-01 09:43:47 +03:00
ctdb_standard_event_handler ()
{
case "$1" in
status)
ctdb_checkstatus
exit
;;
setstatus)
2010-03-10 12:39:31 +03:00
shift
2009-12-01 09:43:47 +03:00
ctdb_setstatus "$@"
exit
;;
esac
}
2010-07-12 09:41:42 +04:00
# iptables doesn't like being re-entered, so flock-wrap it.
iptables()
{
2011-06-28 09:04:58 +04:00
flock -w 30 $CTDB_VARDIR/iptables-ctdb.flock /sbin/iptables "$@"
2010-07-12 09:41:42 +04:00
}
2010-08-26 08:59:59 +04:00
########################################################
# tickle handling
########################################################
update_tickles ()
{
_port="$1"
2013-04-17 07:26:04 +04:00
tickledir="$CTDB_VARDIR/state/tickles"
mkdir -p "$tickledir"
2010-08-26 08:59:59 +04:00
# Who am I?
_pnn=$(ctdb pnn) ; _pnn=${_pnn#PNN:}
# What public IPs do I hold?
_ips=$(ctdb -Y ip | awk -F: -v pnn=$_pnn '$3 == pnn {print $2}')
# IPs as a regexp choice
_ipschoice="($(echo $_ips | sed -e 's/ /|/g' -e 's/\./\\\\./g'))"
# Record connections to our public IPs in a temporary file
_my_connections="${tickledir}/${_port}.connections"
rm -f "$_my_connections"
netstat -tn |
awk -v destpat="^${_ipschoice}:${_port}\$" \
'$1 == "tcp" && $6 == "ESTABLISHED" && $4 ~ destpat {print $5, $4}' |
sort >"$_my_connections"
# Record our current tickles in a temporary file
_my_tickles="${tickledir}/${_port}.tickles"
rm -f "$_my_tickles"
for _i in $_ips ; do
ctdb -Y gettickles $_i $_port |
awk -F: 'NR > 1 { printf "%s:%s %s:%s\n", $2, $3, $4, $5 }'
done |
sort >"$_my_tickles"
# Add tickles for connections that we haven't already got tickles for
comm -23 "$_my_connections" "$_my_tickles" |
while read _src _dst ; do
ctdb addtickle $_src $_dst
done
# Remove tickles for connections that are no longer there
comm -13 "$_my_connections" "$_my_tickles" |
while read _src _dst ; do
ctdb deltickle $_src $_dst
done
rm -f "$_my_connections" "$_my_tickles"
}
2008-04-10 00:50:12 +04:00
########################################################
# load a site local config file
########################################################
2011-06-28 09:06:10 +04:00
[ -n "$CTDB_RC_LOCAL" -a -x "$CTDB_RC_LOCAL" ] && {
. "$CTDB_RC_LOCAL"
}
2008-04-10 01:01:22 +04:00
[ -x $CTDB_BASE/rc.local ] && {
2008-04-10 00:50:12 +04:00
. $CTDB_BASE/rc.local
}
2008-08-20 03:47:00 +04:00
2009-10-19 09:22:15 +04:00
[ -d $CTDB_BASE/rc.local.d ] && {
for i in $CTDB_BASE/rc.local.d/* ; do
[ -x "$i" ] && . "$i"
done
}
2009-12-01 09:43:47 +03:00
script_name="${0##*/}" # basename
service_name="$script_name" # default is just the script name
2009-11-19 08:48:19 +03:00
service_fail_limit=1
2011-01-11 09:12:03 +03:00
event_name="$1"