+#!/bin/sh
# utility functions for ctdb event scripts
#######################################
. /etc/sysconfig/$name
elif [ -f /etc/default/$name ]; then
. /etc/default/$name
- elif [ -f /etc/ctdb/sysconfig/$name ]; then
- . /etc/ctdb/sysconfig/$name
+ elif [ -f $CTDB_BASE/sysconfig/$name ]; then
+ . $CTDB_BASE/sysconfig/$name
fi
}
fi
}
+######################################################
+# simulate /sbin/service (niced) on platforms that don't have it
+nice_service() {
+ service_name="$1"
+ op="$2"
+ if [ -x /sbin/service ]; then
+ nice /sbin/service "$service_name" "$op"
+ elif [ -x /etc/init.d/$service_name ]; then
+ nice /etc/init.d/$service_name "$op"
+ elif [ -x /etc/rc.d/init.d/$service_name ]; then
+ nice /etc/rc.d/init.d/$service_name "$op"
+ fi
+}
######################################################
# wait for a command to return a zero exit status
wait_cmd="$2"
[ -z "$wait_cmd" ] && return;
all_ok=0
- echo "`/bin/date` Waiting for service $service_name to start"
+ echo "Waiting for service $service_name to start"
while [ $all_ok -eq 0 ]; do
$wait_cmd > /dev/null 2>&1 && all_ok=1
ctdb status > /dev/null 2>&1 || {
}
[ $all_ok -eq 1 ] || sleep 1
done
- echo "`/bin/date` Local service $service_name is up"
+ echo "Local service $service_name is up"
}
wait_ports="$*"
[ -z "$wait_ports" ] && return;
all_ok=0
- echo "`/bin/date` Waiting for tcp service $service_name to start"
+ echo "Waiting for tcp service $service_name to start"
while [ $all_ok -eq 0 ]; do
all_ok=1
for p in $wait_ports; do
elif [ -x /usr/bin/nc ]; then
/usr/bin/nc -z 127.0.0.1 $p > /dev/null || all_ok=0
elif [ -x /usr/bin/netstat ]; then
- (/usr/bin/netstat -a -n | egrep "0.0.0.0:$p\s*LISTEN" > /dev/null) || all_ok=0
+ (netstat -a -n | egrep "0.0.0.0:$p\s*LISTEN" > /dev/null) || all_ok=0
+ elif [ -x /bin/netstat ]; then
+ (netstat -a -n | egrep "0.0.0.0:$p\s*LISTEN" > /dev/null) || all_ok=0
else
- echo "`date` - No tool to check tcp ports availabe. can not check in ctdb_wait_tcp_ports"
+ echo "No tool to check tcp ports availabe. can not check in ctdb_wait_tcp_ports"
return
fi
done
exit 1
}
done
- echo "`/bin/date` Local tcp services for $service_name are up"
+ echo "Local tcp services for $service_name are up"
}
wait_dirs="$*"
[ -z "$wait_dirs" ] && return;
all_ok=0
- echo "`/bin/date` Waiting for local directories for $service_name"
+ echo "Waiting for local directories for $service_name"
while [ $all_ok -eq 0 ]; do
all_ok=1
for d in $wait_dirs; do
exit 1
}
done
- echo "`/bin/date` Local directories for $service_name are available"
+ echo "Local directories for $service_name are available"
}
prognum="$2"
version="$3"
rpcinfo -u localhost $prognum $version > /dev/null || {
- echo "`date` ERROR: $service_name not responding to rpc requests"
+ echo "ERROR: $service_name not responding to rpc requests"
exit 1
}
}
[ -z "$wait_dirs" ] && return;
for d in $wait_dirs; do
[ -d $d ] || {
- echo "`date` ERROR: $service_name directory $d not available"
+ echo "ERROR: $service_name directory $d not available"
exit 1
}
done
elif [ -x /usr/bin/nc ]; then
/usr/bin/nc -z 127.0.0.1 $p > /dev/null || all_ok=0
elif [ -x /usr/bin/netstat ]; then
- (/usr/bin/netstat -a -n | egrep "0.0.0.0:$p .*LISTEN" > /dev/null ) || all_ok=0
+ (netstat -a -n | egrep "0.0.0.0:$p .*LISTEN" > /dev/null ) || all_ok=0
+ elif [ -x /bin/netstat ]; then
+ (netstat -a -n | egrep "0.0.0.0:$p .*LISTEN" > /dev/null ) || all_ok=0
fi
[ $all_ok -eq 1 ] || {
- echo "`date` ERROR: $service_name tcp port $p is not responding"
+ echo "ERROR: $service_name tcp port $p is not responding"
exit 1
}
done
wait_cmd="$2"
[ -z "$wait_cmd" ] && return;
$wait_cmd > /dev/null 2>&1 || {
- echo "`date` ERROR: $service_name - $wait_cmd returned error"
+ echo "ERROR: $service_name - $wait_cmd returned error"
exit 1
}
}
+
+################################################
+# kill off any TCP connections with the given IP
+################################################
+kill_tcp_connections() {
+ _IP="$1"
+ _failed=0
+
+ _killcount=0
+ connfile="$CTDB_BASE/state/connections.$_IP"
+ netstat -tn |egrep "^tcp.*\s+$_IP:.*ESTABLISHED" | awk '{print $4" "$5}' > $connfile
+ while read dest src; do
+ srcip=`echo $src | cut -d: -f1`
+ srcport=`echo $src | cut -d: -f2`
+ destip=`echo $dest | cut -d: -f1`
+ destport=`echo $dest | cut -d: -f2`
+ ctdb killtcp $srcip:$srcport $destip:$destport >/dev/null 2>&1 || _failed=1
+ echo "Killing TCP connection $srcip:$srcport $destip:$destport"
+ _killcount=`expr $_killcount + 1`
+ done < $connfile
+ /bin/rm -f $connfile
+ [ $_failed = 0 ] || {
+ echo "Failed to send killtcp control"
+ return;
+ }
+ [ $_killcount -gt 0 ] || {
+ return;
+ }
+ _count=0
+ while netstat -tn |egrep "^tcp.*\s+$_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"
+}
+
+########################################################
+# start/stop the nfs service on different platforms
+########################################################
+startstop_nfs() {
+ PLATFORM="unknown"
+ [ -x /etc/init.d/nfsserver ] && {
+ PLATFORM="sles"
+ }
+ [ -x /etc/init.d/nfslock ] && {
+ PLATFORM="rhel"
+ }
+
+ case $PLATFORM in
+ sles)
+ case $1 in
+ start)
+ service nfsserver start
+ ;;
+ stop)
+ service nfsserver stop > /dev/null 2>&1
+ ;;
+ esac
+ ;;
+ rhel)
+ case $1 in
+ start)
+ service nfslock start
+ service nfs start
+ ;;
+ stop)
+ service nfs stop > /dev/null 2>&1
+ service nfslock stop > /dev/null 2>&1
+ ;;
+ esac
+ ;;
+ *)
+ echo "Unknown platform. NFS is not supported with ctdb"
+ exit 1
+ ;;
+ esac
+}
+
+########################################################
+# start/stop the nfs lockmanager service on different platforms
+########################################################
+startstop_nfslock() {
+ PLATFORM="unknown"
+ [ -x /etc/init.d/nfsserver ] && {
+ PLATFORM="sles"
+ }
+ [ -x /etc/init.d/nfslock ] && {
+ 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
+ ;;
+ esac
+ ;;
+ rhel)
+ case $1 in
+ start)
+ service nfslock start
+ ;;
+ stop)
+ service nfslock stop > /dev/null 2>&1
+ ;;
+ esac
+ ;;
+ *)
+ echo "Unknown platform. NFS locking is not supported with ctdb"
+ exit 1
+ ;;
+ esac
+}
+
+########################################################
+# load a site local config file
+########################################################
+
+[ -x $CTDB_BASE/rc.local ] && {
+ . $CTDB_BASE/rc.local
+}
git.samba.org / sahlberg / ctdb.git / blobdiff