#!/bin/sh
#
# /etc/init.d/elasticsearch -- startup script for Elasticsearch
#
# Written by Miquel van Smoorenburg <miquels@cistron.nl>.
# Modified for Debian GNU/Linux by Ian Murdock <imurdock@gnu.ai.mit.edu>.
# Modified for Tomcat by Stefan Gybas <sgybas@debian.org>.
# Modified for Tomcat6 by Thierry Carrez <thierry.carrez@ubuntu.com>.
# Additional improvements by Jason Brittain <jason.brittain@mulesoft.com>.
# Modified by Nicolas Huray for Elasticsearch <nicolas.huray@gmail.com>.
# Modified by Igor Denisenko for Elastica <im.denisenko@yahoo.com>
#
### BEGIN INIT INFO
# Provides:          elasticsearch
# Required-Start:    $network $remote_fs $named
# Required-Stop:     $network $remote_fs $named
# Default-Start:     2 3 4 5
# Default-Stop:      0 1 6
# Short-Description: Starts elasticsearch
# Description:       Starts elasticsearch using start-stop-daemon
### END INIT INFO

PATH="/bin:/usr/bin:/sbin:/usr/sbin"
NAME="elasticsearch"
DESC="Elasticsearch Server"

if [ `id -u` -ne 0 ]; then
    echo "You need root privileges to run this script"
    exit 1
fi


. /lib/lsb/init-functions

if [ -r /etc/default/rcS ]; then
    . /etc/default/rcS
fi


# Run Elasticsearch as this user ID and group ID
ES_USER="elasticsearch"
ES_GROUP="elasticsearch"

# The first existing directory is used for JAVA_HOME (if JAVA_HOME is not defined)
JDK_DIRS="/usr/lib/jvm/java-8-oracle/ /usr/lib/jvm/j2sdk1.8-oracle/ /usr/lib/jvm/jdk-7-oracle-x64 /usr/lib/jvm/java-7-oracle /usr/lib/jvm/j2sdk1.7-oracle/ /usr/lib/jvm/java-7-openjdk /usr/lib/jvm/java-7-openjdk-amd64/ /usr/lib/jvm/java-7-openjdk-armhf /usr/lib/jvm/java-7-openjdk-i386/ /usr/lib/jvm/default-java"

# Look for the right JVM to use
for jdir in $JDK_DIRS; do
    if [ -r "$jdir/bin/java" -a -z "${JAVA_HOME}" ]; then
        JAVA_HOME="$jdir"
    fi
done
export JAVA_HOME

# Directory where the Elasticsearch binary distribution resides
ES_HOME="/usr/share/$NAME"

# Heap size defaults to 256m min, 1g max
# Be modest. Entire cluster will allocate (3*ES_HEAP_SIZE) memory
ES_HEAP_SIZE="256m"
export ES_HEAP_SIZE

# Heap new generation
# ES_HEAP_NEWSIZE=
# export ES_HEAP_NEWSIZE

# max direct memory
# ES_DIRECT_SIZE=
# export ES_DIRECT_SIZE

# Additional Java OPTS
ES_JAVA_OPTS="-server"
export ES_JAVA_OPTS

# Maximum number of open files
MAX_OPEN_FILES="65535"

# Maximum amount of locked memory
MAX_LOCKED_MEMORY="unlimited"

# Elasticsearch log directory
LOG_DIR="/var/log/$NAME"

# Elasticsearch data directory
DATA_DIR="/var/lib/$NAME"

# Elasticsearch work directory
WORK_DIR="/tmp/$NAME"

# Elasticsearch configuration directory
CONF_DIR="/etc/$NAME"

# Define other required variables
DAEMON="$ES_HOME/bin/elasticsearch"

# Check DAEMON exists
if [ ! -x $DAEMON ]; then
	exit 0
fi

checkJava() {
    if [ -x "$JAVA_HOME/bin/java" ]; then
        JAVA="$JAVA_HOME/bin/java"
    else
        JAVA=`which java`
    fi

    if [ ! -x "$JAVA" ]; then
        echo "Could not find any executable java binary. Please install java in your PATH or set JAVA_HOME"
        exit 1
    fi
}

case "$1" in
  start)
    checkJava

    if [ -n "$MAX_LOCKED_MEMORY" -a -z "$ES_HEAP_SIZE" ]; then
        log_failure_msg "MAX_LOCKED_MEMORY is set - ES_HEAP_SIZE must also be set"
        exit 1
    fi


    mkdir -p "$LOG_DIR" "$DATA_DIR" "$WORK_DIR"
    chown "$ES_USER":"$ES_GROUP" "$LOG_DIR" "$DATA_DIR" "$WORK_DIR"

    if [ -n "$MAX_OPEN_FILES" ];then
        ulimit -n $MAX_OPEN_FILES
    fi

    if [ -n "$MAX_LOCKED_MEMORY" ];then
        ulimit -l $MAX_LOCKED_MEMORY
    fi

    ulimit -s 1024

    for node in 0 1; do
        log_daemon_msg "Starting elasticsearch node #$node"

        PID_FILE="/var/run/$NAME-$node.pid"
        CONF_FILE="$CONF_DIR/config-$node.yml"

        DAEMON="$ES_HOME/bin/elasticsearch"
        DAEMON_OPTS="
            -Des.config=$CONF_FILE    \
            -Des.path.home=$ES_HOME   \
            -Des.path.logs=$LOG_DIR   \
            -Des.path.data=$DATA_DIR  \
            -Des.path.work=$WORK_DIR  \
            -Des.path.conf=$CONF_DIR  \
            -p $PID_FILE
        "

        pid=`pidofproc -p $PID_FILE elasticsearch`
        if [ -n "$pid" ] ; then
            log_begin_msg "Elasticsearch node #$node already running"
            continue
        fi

        touch "$PID_FILE"
        chown "$ES_USER":"$ES_GROUP" "$PID_FILE"

        # Start Daemon
        start-stop-daemon --start -b --user "$ES_USER" -c "$ES_USER" --pidfile "$PID_FILE" --exec "$DAEMON" -- "$DAEMON_OPTS"
        return=$?
        if [ $return -eq 0 ]; then
            i=0
            timeout=10
            # Wait for the process to be properly started before exiting
            until { cat "$PID_FILE" | xargs kill -0; } >/dev/null 2>&1
            do
                sleep 1
                i=$(($i + 1))
                [ $i -gt $timeout ] && log_end_msg 1
            done
        else
            log_end_msg $return
        fi
    done
    ;;      
  stop)
    for node in 0 1; do
        log_daemon_msg "Stopping elasticsearch node #$node"

        PID_FILE="/var/run/$NAME-$node.pid"

        if [ -f "$PID_FILE" ]; then 
            start-stop-daemon --stop --pidfile "$PID_FILE" \
                --user "$ES_USER" \
                --retry=TERM/20/KILL/5 >/dev/null
            if [ $? -eq 1 ]; then
                log_progress_msg "$DESC is not running but pid file exists, cleaning up"
            elif [ $? -eq 3 ]; then
                PID="`cat $PID_FILE`"
                log_failure_msg "Failed to stop $DESC (pid $PID)"
                exit 1
            fi
            rm -f "$PID_FILE"
        else
            log_progress_msg "(not running)"
        fi
    done

    log_end_msg 0
    ;;
  status)
    for node in 0 1; do
        PID_FILE="/var/run/$NAME-$node.pid"
        status_of_proc -p $PID_FILE "Elasticsearch node #$node" "Elasticsearch node #$node"
    done
    exit 0
    ;;
  restart|force-reload)
    for node in 0 1; do
        PID_FILE="/var/run/$NAME-$node.pid"
        if [ -f "$PID_FILE" ]; then
            $0 stop
            sleep 1
        fi
    done
    $0 start
    ;;
  *)
    log_success_msg "Usage: $0 {start|stop|restart|force-reload|status}"
    exit 1
    ;;
esac

exit 0