mirror of
https://github.com/processone/ejabberd.git
synced 2024-11-28 16:34:13 +01:00
73 lines
1.2 KiB
Bash
73 lines
1.2 KiB
Bash
is_set() {
|
|
local var=$1
|
|
|
|
[[ -n $var ]]
|
|
}
|
|
|
|
|
|
is_zero() {
|
|
local var=$1
|
|
|
|
[[ -z $var ]]
|
|
}
|
|
|
|
|
|
file_exist() {
|
|
local file=$1
|
|
|
|
[[ -e $file ]]
|
|
}
|
|
|
|
|
|
is_true() {
|
|
local var=${1,,}
|
|
local choices=("yes" "1" "y" "true")
|
|
for ((i=0;i < ${#choices[@]};i++)) {
|
|
[[ "${choices[i]}" == $var ]] && return 0
|
|
}
|
|
return 1
|
|
}
|
|
|
|
|
|
log() {
|
|
local message=$1
|
|
echo $message
|
|
}
|
|
|
|
|
|
# overwrite this function to get hostname from other sources
|
|
# like dns or etcd
|
|
get_nodename() {
|
|
log ${HOSTNAME}
|
|
}
|
|
|
|
|
|
join_cluster() {
|
|
local cluster_node=$1
|
|
|
|
is_zero ${cluster_node} \
|
|
&& exit 0
|
|
|
|
log "Join cluster..."
|
|
|
|
local erlang_node_name=${ERLANG_NODE%@*}
|
|
local erlang_cluster_node="${erlang_node_name}@${cluster_node}"
|
|
|
|
response=$(${EJABBERDCTL} ping ${erlang_cluster_node})
|
|
while [ "$response" != "pong" ]; do
|
|
log "Waiting for ${erlang_cluster_node}..."
|
|
sleep 2
|
|
response=$(${EJABBERDCTL} ping ${erlang_cluster_node})
|
|
done
|
|
|
|
log "Join cluster at ${erlang_cluster_node}... "
|
|
NO_WARNINGS=true ${EJABBERDCTL} join_cluster $erlang_cluster_node
|
|
|
|
if [ $? -eq 0 ]; then
|
|
touch ${CLUSTER_NODE_FILE}
|
|
else
|
|
log "cloud not join cluster"
|
|
exit 1
|
|
fi
|
|
}
|