No OneTemporary
Actions

Size

30 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/.editorconfig b/.editorconfig
	new file mode 100644
	index 000000000..16ca113b1
	--- /dev/null
	+++ b/.editorconfig
	@@ -0,0 +1,41 @@
	+# EditorConfig is awesome: https://EditorConfig.org
	+
	+# EditorConfig helps developers define and maintain consistent
	+# coding styles between different editors and IDEs.
	+
	+# This file is the top-most EditorConfig file
	+root = true
	+
	+[*]
	+# UTF-8 character set
	+charset = utf-8
	+# Use for spell checking
	+spelling_language = en-US
	+# Unix-style newlines
	+end_of_line = lf
	+# Soft tabs
	+#indent_style = space
	+# Two-space indentation
	+#indent_size = 2
	+# Trim trailing whitespace
	+#trim_trailing_whitespace = true
	+# Newline ending every file
	+#insert_final_newline = true
	+
	+[heartbeat/aws-vpc-move-ip]
	+charset = utf-8
	+end_of_line = lf
	+indent_style = space
	+indent_size = 2
	+trim_trailing_whitespace = true
	+insert_final_newline = true
	+max_line_length = 80
	+# --language-variant
	+shell_variant = posix
	+binary_next_line = true
	+# --case-indent
	+switch_case_indent = true
	+space_redirects = true
	+keep_padding = true
	+# --func-next-line
	+function_next_line = true
	\ No newline at end of file
	diff --git a/heartbeat/aws-vpc-move-ip b/heartbeat/aws-vpc-move-ip
	index a895ddb29..ecf25bbec 100755
	--- a/heartbeat/aws-vpc-move-ip
	+++ b/heartbeat/aws-vpc-move-ip
	@@ -1,570 +1,587 @@
	#!/bin/sh

	# OCF resource agent to move an IP address within a VPC in the AWS
	#
	# Copyright (c) 2017 Markus Guertler (SUSE)
	# Based on code of Adam Gandelman (GitHub ec2-resource-agents/elasticip)
	# 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.

	###############################################################################

	# Initialization:
	: ${OCF_FUNCTIONS_DIR=${OCF_ROOT}/lib/heartbeat}
	. ${OCF_FUNCTIONS_DIR}/ocf-shellfuncs

	# Defaults
	OCF_RESKEY_awscli_default="/usr/bin/aws"
	OCF_RESKEY_auth_type_default="key"
	OCF_RESKEY_profile_default="default"
	OCF_RESKEY_region_default=""
	OCF_RESKEY_ip_default=""
	OCF_RESKEY_address_default=""
	OCF_RESKEY_routing_table_default=""
	OCF_RESKEY_routing_table_role_default=""
	OCF_RESKEY_interface_default="eth0"
	OCF_RESKEY_iflabel_default=""
	OCF_RESKEY_monapi_default="false"
	OCF_RESKEY_lookup_type_default="InstanceId"
	OCF_RESKEY_curl_retries_default="5"
	OCF_RESKEY_curl_sleep_default="3"

	: ${OCF_RESKEY_awscli=${OCF_RESKEY_awscli_default}}
	: ${OCF_RESKEY_auth_type=${OCF_RESKEY_auth_type_default}}
	: ${OCF_RESKEY_profile=${OCF_RESKEY_profile_default}}
	: ${OCF_RESKEY_region=${OCF_RESKEY_region_default}}
	: ${OCF_RESKEY_ip=${OCF_RESKEY_ip_default}}
	: ${OCF_RESKEY_address=${OCF_RESKEY_address_default}}
	: ${OCF_RESKEY_routing_table=${OCF_RESKEY_routing_table_default}}
	: ${OCF_RESKEY_routing_table_role=${OCF_RESKEY_routing_table_role_default}}
	: ${OCF_RESKEY_interface=${OCF_RESKEY_interface_default}}
	: ${OCF_RESKEY_iflabel=${OCF_RESKEY_iflabel_default}}
	: ${OCF_RESKEY_monapi=${OCF_RESKEY_monapi_default}}
	: ${OCF_RESKEY_lookup_type=${OCF_RESKEY_lookup_type_default}}
	: ${OCF_RESKEY_curl_retries=${OCF_RESKEY_curl_retries_default}}
	: ${OCF_RESKEY_curl_sleep=${OCF_RESKEY_curl_sleep_default}}

	MAC_FILE="/sys/class/net/${OCF_RESKEY_interface}/address"
	# Note: On nitro-based EC2 instances this can be used to get the EC2 instance ID.
	DMI_FILE="/sys/devices/virtual/dmi/id/board_asset_tag"
	# EC2 IMDS endpoints, IPv6 endpoint is only supported on nitro-based instances.
	EC2_IMDS_V4="169.254.169.254"
	EC2_IMDS_V6="[fd00:ec2::254]"
	EC2_IMDS_TOKEN_TTL="600"

	###############################################################################
	#
	# Functions
	#
	###############################################################################

	usgae() {
	echo "usage: $(basename "$0") {start\|stop\|monitor\|status\|meta-data\|validate-all}"
	}

	metadata() {
	-cat <<END
	+ cat <<END
	<?xml version="1.0"?>
	<!DOCTYPE resource-agent SYSTEM "ra-api-1.dtd">
	<resource-agent name="aws-vpc-move-ip" version="2.0">
	<version>1.0</version>
	<longdesc lang="en">
	Resource Agent to move IP addresses within a VPC of the Amazon Webservices EC2
	by changing an entry in an specific routing table

	Credentials needs to be setup by running "aws configure", or by using AWS Policies.

	See https://aws.amazon.com/cli/ for more information about awscli.
	</longdesc>
	<shortdesc lang="en">Move IP within a VPC of the AWS EC2</shortdesc>

	<parameters>
	<parameter name="awscli">
	<longdesc lang="en">
	Path to command line tools for AWS
	</longdesc>
	<shortdesc lang="en">Path to AWS CLI tools</shortdesc>
	<content type="string" default="${OCF_RESKEY_awscli_default}" />
	</parameter>

	<parameter name="auth_type">
	<longdesc lang="en">
	Authentication type "key" for AccessKey and SecretAccessKey set via "aws configure",
	or "role" to use AWS Policies.
	</longdesc>
	<shortdesc lang="en">Authentication type</shortdesc>
	<content type="string" default="${OCF_RESKEY_auth_type_default}" />
	</parameter>

	<parameter name="profile">
	<longdesc lang="en">
	Valid AWS CLI profile name (see ~/.aws/config and 'aws configure')
	</longdesc>
	<shortdesc lang="en">profile name</shortdesc>
	<content type="string" default="${OCF_RESKEY_profile_default}" />
	</parameter>

	<parameter name="region">
	<longdesc lang="en">
	Valid AWS region name (e.g., 'us-west-2')
	</longdesc>
	<shortdesc lang="en">region name</shortdesc>
	<content type="string" default="${OCF_RESKEY_region_default}" />
	</parameter>

	<parameter name="ip" required="1">
	<longdesc lang="en">
	VPC private IP address
	</longdesc>
	<shortdesc lang="en">VPC private IP</shortdesc>
	<content type="string" default="${OCF_RESKEY_ip_default}" />
	</parameter>

	<parameter name="address">
	<longdesc lang="en">
	Deprecated IP address param. Use the ip param instead.
	</longdesc>
	<shortdesc lang="en">Deprecated VPC private IP Address</shortdesc>
	<content type="string" default="${OCF_RESKEY_address_default}" />
	</parameter>

	<parameter name="routing_table" required="1">
	<longdesc lang="en">
	Name of the routing table(s), where the route for the IP address should be changed. If declaring multiple routing tables they should be separated by comma. Example: rtb-XXXXXXXX,rtb-YYYYYYYYY
	</longdesc>
	<shortdesc lang="en">routing table name(s)</shortdesc>
	<content type="string" default="${OCF_RESKEY_routing_table_default}" />
	</parameter>

	<parameter name="routing_table_role" required="0">
	<longdesc lang="en">
	Role to use to query/update the route table
	</longdesc>
	<shortdesc lang="en">route table query/update role</shortdesc>
	<content type="string" default="${OCF_RESKEY_routing_table_role_default}" />
	</parameter>

	<parameter name="interface" required="1">
	<longdesc lang="en">
	Name of the network interface, i.e. eth0
	</longdesc>
	<shortdesc lang="en">network interface name</shortdesc>
	<content type="string" default="${OCF_RESKEY_interface_default}" />
	</parameter>

	<parameter name="iflabel">
	<longdesc lang="en">
	You can specify an additional label for your IP address here.
	This label is appended to your interface name.

	The kernel allows alphanumeric labels up to a maximum length of 15
	characters including the interface name and colon (e.g. eth0:foobar1234)
	</longdesc>
	<shortdesc lang="en">Interface label</shortdesc>
	<content type="string" default="${OCF_RESKEY_iflabel_default}"/>
	</parameter>

	<parameter name="monapi">
	<longdesc lang="en">
	Enable enhanced monitoring using AWS API calls to check route table entry
	</longdesc>
	<shortdesc lang="en">Enhanced Monitoring</shortdesc>
	<content type="boolean" default="${OCF_RESKEY_monapi_default}" />
	</parameter>

	<parameter name="lookup_type" required="0">
	<longdesc lang="en">
	Name of resource type to lookup in route table.
	"InstanceId" : EC2 instance ID. (default)
	"NetworkInterfaceId" : ENI ID. (useful in shared VPC setups).
	</longdesc>
	<shortdesc lang="en">lookup type for route table resource</shortdesc>
	<content type="string" default="${OCF_RESKEY_lookup_type_default}" />
	</parameter>

	<parameter name="curl_retries" unique="0">
	<longdesc lang="en">
	curl retries before failing
	</longdesc>
	<shortdesc lang="en">curl retries</shortdesc>
	<content type="integer" default="${OCF_RESKEY_curl_retries_default}" />
	</parameter>

	<parameter name="curl_sleep" unique="0">
	<longdesc lang="en">
	curl sleep between tries
	</longdesc>
	<shortdesc lang="en">curl sleep</shortdesc>
	<content type="integer" default="${OCF_RESKEY_curl_sleep_default}" />
	</parameter>
	</parameters>

	<actions>
	<action name="start" timeout="180s" />
	<action name="stop" timeout="180s" />
	<action name="monitor" depth="0" timeout="30s" interval="60s" />
	<action name="validate-all" timeout="5s" />
	<action name="meta-data" timeout="5s" />
	</actions>
	</resource-agent>
	END
	}

	-ec2ip_execute_cmd_as_role(){
	- cmd=$1
	- role=$2
	+ec2ip_execute_cmd_as_role() {
	+ ocf_log debug "function: ec2ip_execute_cmd_as_role"

	- output="$($AWSCLI_CMD sts assume-role --role-arn $role --role-session-name AWSCLI-RouteTableUpdate --output=text)"
	+ cmd=$1
	+ role=$2

	- AWS_ACCESS_KEY_ID="$(echo $output \| awk -F" " '$4=="CREDENTIALS" {print $5}')"
	- AWS_SECRET_ACCESS_KEY="$(echo $output \| awk -F" " '$4=="CREDENTIALS" {print $7}')"
	- AWS_SESSION_TOKEN="$(echo $output \| awk -F" " '$4=="CREDENTIALS" {print $8}')"
	+ trap 'unset output AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY AWS_SESSION_TOKEN' EXIT
	+
	+ output="$($AWSCLI_CMD sts assume-role --role-arn $role --role-session-name AWSCLI-RouteTableUpdate --output=text)"
	+
	+ AWS_ACCESS_KEY_ID="$(echo "$output" \| awk -F" " '$4=="CREDENTIALS" {print $5}')"
	+ AWS_SECRET_ACCESS_KEY="$(echo "$output" \| awk -F" " '$4=="CREDENTIALS" {print $7}')"
	+ AWS_SESSION_TOKEN="$(echo "$output" \| awk -F" " '$4=="CREDENTIALS" {print $8}')"
	export AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY AWS_SESSION_TOKEN

	- #Execute command
	- ocf_log debug "Assumed IAM Role: ${role}"
	- ocf_log debug "$($OCF_RESKEY_awscli sts get-caller-identity)"
	- ocf_log debug "execute command: $cmd"
	+ #Execute command
	+ ocf_log debug "Assumed IAM Role: ${role}"
	+ ocf_log debug "$($OCF_RESKEY_awscli sts get-caller-identity)"
	+ ocf_log debug "execute command: $cmd"

	- response="$($cmd)"
	- unset output AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY AWS_SESSION_TOKEN
	- echo $response
	+ response="$($cmd)"
	+ echo "$response"
	}

	-ec2ip_set_address_param_compat(){
	- # Include backward compatibility for the deprecated address parameter
	- if [ -z "$OCF_RESKEY_ip" ] && [ -n "$OCF_RESKEY_address" ]; then
	- OCF_RESKEY_ip="$OCF_RESKEY_address"
	- fi
	+ec2ip_set_address_param_compat() {
	+ # Include backward compatibility for the deprecated address parameter
	+ if [ -z "$OCF_RESKEY_ip" ] && [ -n "$OCF_RESKEY_address" ]; then
	+ OCF_RESKEY_ip="$OCF_RESKEY_address"
	+ fi
	}

	ec2ip_validate() {
	- ocf_log debug "function: ec2ip_validate"
	+ ocf_log debug "function: ec2ip_validate"

	- # check_binary will exit with OCF_ERR_INSTALLED when a binary is missing.
	- ocf_log debug "EC2: Check for required binaries."
	- for commands in "${OCF_RESKEY_awscli}" curl ip cat grep awk sed; do
	- check_binary "$commands"
	- done
	+ # check_binary will exit with OCF_ERR_INSTALLED when a binary is missing.
	+ ocf_log debug "EC2: Check for required binaries."
	+ for commands in "${OCF_RESKEY_awscli}" curl ip cat grep awk sed; do
	+ check_binary "$commands"
	+ done

	- if [ "${OCF_RESKEY_auth_type}" = "key" ] && [ -z "$OCF_RESKEY_profile" ]; then
	- ocf_exit_reason "Required 'profile' parameter not set."
	- return $OCF_ERR_CONFIGURED
	- fi
	+ if [ "${OCF_RESKEY_auth_type}" = "key" ] && [ -z "$OCF_RESKEY_profile" ]; then
	+ ocf_exit_reason "Required 'profile' parameter not set."
	+ return $OCF_ERR_CONFIGURED
	+ fi

	- if [ -n "$OCF_RESKEY_iflabel" ]; then
	- label=${OCF_RESKEY_interface}:${OCF_RESKEY_iflabel}
	- if [ ${#label} -gt 15 ]; then
	- ocf_exit_reason "Optional 'label' parameter exceeds 15 character limit: $label"
	- exit $OCF_ERR_CONFIGURED
	- fi
	- fi
	+ if [ -n "$OCF_RESKEY_iflabel" ]; then
	+ label=${OCF_RESKEY_interface}:${OCF_RESKEY_iflabel}
	+ if [ ${#label} -gt 15 ]; then
	+ ocf_exit_reason "Optional 'label' parameter exceeds 15 character limit: $label"
	+ exit $OCF_ERR_CONFIGURED
	+ fi
	+ fi

	# Try to get the EC2 instance ID from DMI first before falling back to IMDS.
	ocf_log debug "EC2: Attempt to get EC2 instance ID file."
	if [ -r "$DMI_FILE" ] && [ -s "$DMI_FILE" ]; then
	EC2_INSTANCE_ID="$(cat "$DMI_FILE")"
	case "$EC2_INSTANCE_ID" in
	- i-0*) return "$OCF_SUCCESS" ;;
	+ i-0*) return "$OCF_SUCCESS" ;;
	esac
	fi

	ocf_log debug "EC2: Unable to get EC2 Instnace ID from local file, fallback to the IMDS."

	ocf_log debug "EC2: Attempt to get IMDSv2 session token from the IMDS."
	- TOKEN=$(curl_retry "$OCF_RESKEY_curl_retries" "$OCF_RESKEY_curl_sleep" "--show-error -sX PUT -H 'X-aws-ec2-metadata-token-ttl-seconds: $EC2_IMDS_TOKEN_TTL'" "http://$EC2_IMDS_V4/latest/api/token")
	- [ $? -ne 0 ] && exit $OCF_ERR_GENERIC
	+ TOKEN=$(curl_retry "$OCF_RESKEY_curl_retries" "$OCF_RESKEY_curl_sleep" "--show-error -sX PUT -H 'X-aws-ec2-metadata-token-ttl-seconds: $EC2_IMDS_TOKEN_TTL'" "http://$EC2_IMDS_V4/latest/api/token")
	+ [ $? -ne 0 ] && exit $OCF_ERR_GENERIC

	ocf_log debug "EC2: Attempt to get EC2 instance ID from the IMDS."
	- EC2_INSTANCE_ID=$(curl_retry "$OCF_RESKEY_curl_retries" "$OCF_RESKEY_curl_sleep" "--show-error -s -H 'X-aws-ec2-metadata-token: $TOKEN'" "http://$EC2_IMDS_V4/latest/meta-data/instance-id")
	- [ $? -ne 0 ] && exit $OCF_ERR_GENERIC
	+ EC2_INSTANCE_ID=$(curl_retry "$OCF_RESKEY_curl_retries" "$OCF_RESKEY_curl_sleep" "--show-error -s -H 'X-aws-ec2-metadata-token: $TOKEN'" "http://$EC2_IMDS_V4/latest/meta-data/instance-id")
	+ [ $? -ne 0 ] && exit $OCF_ERR_GENERIC

	- if [ -z "${EC2_INSTANCE_ID}" ]; then
	- ocf_exit_reason "Unable to get EC2 Instance ID."
	- return $OCF_ERR_GENERIC
	- fi
	+ if [ -z "${EC2_INSTANCE_ID}" ]; then
	+ ocf_exit_reason "Unable to get EC2 Instance ID."
	+ return $OCF_ERR_GENERIC
	+ fi

	- return $OCF_SUCCESS
	+ return $OCF_SUCCESS
	}

	ec2ip_monitor() {
	+ ocf_log debug "function: ec2ip_monitor"
	+
	+ MON_RES=""
	+
	+ if [ "${OCF_RESKEY_lookup_type}" = "NetworkInterfaceId" ]; then
	+ EC2_ID="$(ec2ip_get_instance_eni)"
	+ RESOURCE_TYPE="interface"
	+ else
	+ EC2_ID="$EC2_INSTANCE_ID"
	+ RESOURCE_TYPE="instance"
	+ fi
	+
	+ if ocf_is_true "${OCF_RESKEY_monapi}" \|\| [ "$__OCF_ACTION" = "start" ] \|\| ocf_is_probe; then
	+ for rtb in $(echo $OCF_RESKEY_routing_table \| sed -e 's/,/ /g'); do
	+ ocf_log info "Monitor: EC2 API call to check VPC route table $rtb."
	+ if [ -z "${OCF_RESKEY_routing_table_role}" ]; then
	+ cmd="$AWSCLI_CMD --output text ec2 describe-route-tables --route-table-ids $rtb --query RouteTables[*].Routes[?DestinationCidrBlock=='$OCF_RESKEY_ip/32'].$OCF_RESKEY_lookup_type"
	+ ocf_log debug "execute command: $cmd"
	+ ROUTE_TO_INSTANCE="$($cmd)"
	+ else
	+ cmd="$OCF_RESKEY_awscli --output text ec2 describe-route-tables --route-table-ids $rtb --query RouteTables[*].Routes[?DestinationCidrBlock=='$OCF_RESKEY_ip/32'].$OCF_RESKEY_lookup_type"
	+ ROUTE_TO_INSTANCE="$(ec2ip_execute_cmd_as_role "$cmd" $OCF_RESKEY_routing_table_role)"
	+ fi
	+ ocf_log debug "Overlay IP address routes to resource: ${ROUTE_TO_INSTANCE}"
	+ if [ -z "$ROUTE_TO_INSTANCE" ]; then
	+ ROUTE_TO_INSTANCE="<unknown>"
	+ fi
	+
	+ if [ "$EC2_ID" != "$ROUTE_TO_INSTANCE" ]; then
	+ ocf_log warn "Overlay IP address routes to $ROUTE_TO_INSTANCE ($RESOURCE_TYPE) and not $EC2_ID in VPC route table $rtb."
	+ MON_RES="$MON_RES $rtb"
	+ fi
	+ sleep 1
	+ done

	- MON_RES=""
	-
	- if [ "${OCF_RESKEY_lookup_type}" = "NetworkInterfaceId" ]; then
	- EC2_ID="$(ec2ip_get_instance_eni)"
	- RESOURCE_TYPE="interface"
	- else
	- EC2_ID="$EC2_INSTANCE_ID"
	- RESOURCE_TYPE="instance"
	- fi
	-
	- if ocf_is_true "${OCF_RESKEY_monapi}" \|\| [ "$__OCF_ACTION" = "start" ] \|\| ocf_is_probe; then
	- for rtb in $(echo $OCF_RESKEY_routing_table \| sed -e 's/,/ /g'); do
	- ocf_log info "Monitor: EC2 API call to check VPC route table $rtb."
	- if [ -z "${OCF_RESKEY_routing_table_role}" ]; then
	- cmd="$AWSCLI_CMD --output text ec2 describe-route-tables --route-table-ids $rtb --query RouteTables[*].Routes[?DestinationCidrBlock=='$OCF_RESKEY_ip/32'].$OCF_RESKEY_lookup_type"
	- ocf_log debug "execute command: $cmd"
	- ROUTE_TO_INSTANCE="$($cmd)"
	- else
	- cmd="$OCF_RESKEY_awscli --output text ec2 describe-route-tables --route-table-ids $rtb --query RouteTables[*].Routes[?DestinationCidrBlock=='$OCF_RESKEY_ip/32'].$OCF_RESKEY_lookup_type"
	- ROUTE_TO_INSTANCE="$(ec2ip_execute_cmd_as_role "$cmd" $OCF_RESKEY_routing_table_role)"
	- fi
	- ocf_log debug "Overlay IP routes to:${ROUTE_TO_INSTANCE}"
	- if [ -z "$ROUTE_TO_INSTANCE" ]; then
	- ROUTE_TO_INSTANCE="<unknown>"
	- fi
	-
	- if [ "$EC2_ID" != "$ROUTE_TO_INSTANCE" ]; then
	- ocf_log warn "not routed to this $RESOURCE_TYPE ($EC2_ID) but to $RESOURCE_TYPE $ROUTE_TO_INSTANCE on $rtb"
	- MON_RES="$MON_RES $rtb"
	- fi
	- sleep 1
	- done
	-
	- if [ ! -z "$MON_RES" ]; then
	- return $OCF_NOT_RUNNING
	- fi
	-
	- else
	- ocf_log debug "Monitor: Enhanced monitoring disabled. Skipping EC2 API calls."
	- fi
	-
	- cmd="ip addr show to $OCF_RESKEY_ip up"
	- ocf_log debug "execute command: $cmd"
	- RESULT=$($cmd \| grep "$OCF_RESKEY_ip")
	- if [ -z "$RESULT" ]; then
	- if [ "$__OCF_ACTION" = "monitor" ] && ! ocf_is_probe; then
	- level="error"
	- else
	- level="info"
	- fi
	-
	- ocf_log "$level" "Overlay IP address $OCF_RESKEY_ip not configured on network interface."
	- return $OCF_NOT_RUNNING
	- fi
	-
	- ocf_log debug "VPC route table contains route entry and overlay IP address configured on network interface."
	- return $OCF_SUCCESS
	+ if [ ! -z "$MON_RES" ]; then
	+ return $OCF_NOT_RUNNING
	+ fi
	+
	+ else
	+ ocf_log debug "Monitor: Enhanced monitoring disabled. Skipping EC2 API calls."
	+ fi
	+
	+ cmd="ip addr show to $OCF_RESKEY_ip up"
	+ ocf_log debug "execute command: $cmd"
	+ RESULT=$($cmd \| grep "$OCF_RESKEY_ip")
	+ if [ -z "$RESULT" ]; then
	+ if [ "$__OCF_ACTION" = "monitor" ] && ! ocf_is_probe; then
	+ level="error"
	+ else
	+ level="info"
	+ fi
	+
	+ ocf_log "$level" "Overlay IP address $OCF_RESKEY_ip not configured on network interface."
	+ return $OCF_NOT_RUNNING
	+ fi
	+
	+ ocf_log debug "VPC route table contains route entry and overlay IP address configured on network interface."
	+ return $OCF_SUCCESS
	}

	ec2ip_drop() {
	- cmd="ip addr delete ${OCF_RESKEY_ip}/32 dev $OCF_RESKEY_interface"
	- ocf_log debug "execute command: $cmd"
	- output=$($cmd 2>&1)
	- rc=$?
	- if [ "$rc" -gt 0 ]; then
	- if [ "$__OCF_ACTION" = "start" ]; then
	- # Expected to fail during start
	- level="debug"
	- else
	- level="warn"
	- fi
	-
	- ocf_log "$level" "command failed. rc $rc"
	- ocf_log "$level" "stdout and stderr: $output"
	- return $OCF_ERR_GENERIC
	- else
	- ocf_log debug "stdout and stderr: $output"
	- fi
	-
	- # delete remaining route-entries if any
	- ip route show to exact ${OCF_RESKEY_ip}/32 dev $OCF_RESKEY_interface \| xargs -r ip route delete
	- ip route show table local to exact ${OCF_RESKEY_ip}/32 dev $OCF_RESKEY_interface \| xargs -r ip route delete
	-
	- return $OCF_SUCCESS
	+ ocf_log debug "function: ec2ip_drop"
	+
	+ cmd="ip addr delete ${OCF_RESKEY_ip}/32 dev $OCF_RESKEY_interface"
	+ ocf_log debug "execute command: $cmd"
	+ output=$($cmd 2>&1)
	+ rc=$?
	+ if [ "$rc" -gt 0 ]; then
	+ if [ "$__OCF_ACTION" = "start" ]; then
	+ # Expected to fail during start
	+ level="debug"
	+ else
	+ level="warn"
	+ fi
	+
	+ ocf_log "$level" "command failed. rc $rc"
	+ ocf_log "$level" "stdout and stderr: $output"
	+ return $OCF_ERR_GENERIC
	+ else
	+ ocf_log debug "stdout and stderr: $output"
	+ fi
	+
	+ # Delete any remaining route entries from local route table if they exist.
	+ ocf_log debug "Cleanup any remaining routes in instance route table."
	+ ip route show to exact ${OCF_RESKEY_ip}/32 dev $OCF_RESKEY_interface \| xargs -r ip route delete
	+ ip route show table local to exact ${OCF_RESKEY_ip}/32 dev $OCF_RESKEY_interface \| xargs -r ip route delete
	+
	+ return $OCF_SUCCESS
	}

	ec2ip_get_instance_eni() {
	- if [ -f $MAC_FILE ]; then
	- cmd="cat ${MAC_FILE}"
	- else
	- cmd="ip link show ${OCF_RESKEY_interface} \| awk '/ether/ {print \$2}'"
	- fi
	-
	- ocf_log debug "execute command: $cmd"
	- MAC_ADDR="$(eval $cmd)"
	- rc=$?
	- if [ $rc != 0 ]; then
	- ocf_log warn "command failed. rc: $rc"
	- return $OCF_ERR_GENERIC
	- fi
	- ocf_log debug "MAC address ${MAC_ADDR} associated with network interface ${OCF_RESKEY_interface}."
	-
	- TOKEN=$(curl_retry "$OCF_RESKEY_curl_retries" "$OCF_RESKEY_curl_sleep" "--show-error -sX PUT -H 'X-aws-ec2-metadata-token-ttl-seconds: $EC2_IMDS_TOKEN_TTL'" "http://$EC2_IMDS_V4/latest/api/token")
	- [ $? -ne 0 ] && exit $OCF_ERR_GENERIC
	-
	- cmd="curl_retry \"$OCF_RESKEY_curl_retries\" \"$OCF_RESKEY_curl_sleep\" \"--show-error -s -H 'X-aws-ec2-metadata-token: $TOKEN'\" \"http://$EC2_IMDS_V4/latest/meta-data/network/interfaces/macs/${MAC_ADDR}/interface-id\""
	- EC2_NETWORK_INTERFACE_ID="$(eval $cmd)"
	- [ $? -ne 0 ] && exit $OCF_ERR_GENERIC
	-
	- ocf_log debug "ENI ${EC2_NETWORK_INTERFACE_ID} associated with MAC address ${MAC_ADDR}."
	- echo $EC2_NETWORK_INTERFACE_ID
	+ ocf_log debug "function: ec2ip_get_instance_eni"
	+
	+ if [ -f $MAC_FILE ]; then
	+ cmd="cat ${MAC_FILE}"
	+ else
	+ cmd="ip link show ${OCF_RESKEY_interface} \| awk '/ether/ {print \$2}'"
	+ fi
	+
	+ ocf_log debug "execute command: $cmd"
	+ MAC_ADDR="$(eval $cmd)"
	+ rc=$?
	+ if [ $rc != 0 ]; then
	+ ocf_log warn "command failed. rc: $rc"
	+ return $OCF_ERR_GENERIC
	+ fi
	+ ocf_log debug "MAC address ${MAC_ADDR} associated with network interface ${OCF_RESKEY_interface}."
	+
	+ TOKEN=$(curl_retry "$OCF_RESKEY_curl_retries" "$OCF_RESKEY_curl_sleep" "--show-error -sX PUT -H 'X-aws-ec2-metadata-token-ttl-seconds: $EC2_IMDS_TOKEN_TTL'" "http://$EC2_IMDS_V4/latest/api/token")
	+ [ $? -ne 0 ] && exit $OCF_ERR_GENERIC
	+
	+ cmd="curl_retry \"$OCF_RESKEY_curl_retries\" \"$OCF_RESKEY_curl_sleep\" \"--show-error -s -H 'X-aws-ec2-metadata-token: $TOKEN'\" \"http://$EC2_IMDS_V4/latest/meta-data/network/interfaces/macs/${MAC_ADDR}/interface-id\""
	+ EC2_NETWORK_INTERFACE_ID="$(eval $cmd)"
	+ [ $? -ne 0 ] && exit $OCF_ERR_GENERIC
	+
	+ ocf_log debug "ENI ${EC2_NETWORK_INTERFACE_ID} associated with MAC address ${MAC_ADDR}."
	+ echo $EC2_NETWORK_INTERFACE_ID
	}

	ec2ip_get_and_configure() {
	- EC2_NETWORK_INTERFACE_ID="$(ec2ip_get_instance_eni)"
	-
	- for rtb in $(echo $OCF_RESKEY_routing_table \| sed -e 's/,/ /g'); do
	- if [ -z "${OCF_RESKEY_routing_table_role}" ]; then
	- cmd="$AWSCLI_CMD --output text ec2 replace-route --route-table-id $rtb --destination-cidr-block ${OCF_RESKEY_ip}/32 --network-interface-id $EC2_NETWORK_INTERFACE_ID"
	- ocf_log debug "executing command: $cmd"
	- $cmd
	- else
	- cmd="$OCF_RESKEY_awscli --output text ec2 replace-route --route-table-id $rtb --destination-cidr-block ${OCF_RESKEY_ip}/32 --network-interface-id $EC2_NETWORK_INTERFACE_ID"
	- "$(execute_cmd_as_role "$cmd" $OCF_RESKEY_routing_table_role)"
	- fi
	- rc=$?
	- if [ "$rc" != 0 ]; then
	- ocf_log warn "command failed. rc: $rc"
	- return $OCF_ERR_GENERIC
	- fi
	- sleep 1
	- done
	-
	- # Reconfigure the local ip address
	- ec2ip_drop
	-
	- extra_opts=""
	-
	- if [ -n "$OCF_RESKEY_iflabel" ]; then
	- extra_opts="$extra_opts label $OCF_RESKEY_interface:$OCF_RESKEY_iflabel"
	- fi
	-
	- cmd="ip addr add ${OCF_RESKEY_ip}/32 dev $OCF_RESKEY_interface $extra_opts"
	- ocf_log debug "execute command: $cmd"
	- $cmd
	- rc=$?
	- if [ $rc != 0 ]; then
	- ocf_log warn "command failed. rc: $rc"
	- return $OCF_ERR_GENERIC
	- fi
	-
	- return $OCF_SUCCESS
	+ ocf_log debug "function: ec2ip_get_and_configure"
	+
	+ EC2_NETWORK_INTERFACE_ID="$(ec2ip_get_instance_eni)"
	+
	+ for rtb in $(echo $OCF_RESKEY_routing_table \| sed -e 's/,/ /g'); do
	+ if [ -z "${OCF_RESKEY_routing_table_role}" ]; then
	+ cmd="$AWSCLI_CMD --output text ec2 replace-route --route-table-id $rtb --destination-cidr-block ${OCF_RESKEY_ip}/32 --network-interface-id $EC2_NETWORK_INTERFACE_ID"
	+ ocf_log debug "execute command: $cmd"
	+ $cmd
	+ else
	+ cmd="$OCF_RESKEY_awscli --output text ec2 replace-route --route-table-id $rtb --destination-cidr-block ${OCF_RESKEY_ip}/32 --network-interface-id $EC2_NETWORK_INTERFACE_ID"
	+ "$(execute_cmd_as_role "$cmd" $OCF_RESKEY_routing_table_role)"
	+ fi
	+ rc=$?
	+ if [ "$rc" != 0 ]; then
	+ ocf_log warn "command 'aws' failed. rc: $rc"
	+ return $OCF_ERR_GENERIC
	+ fi
	+ sleep 1
	+ done
	+
	+ # Reconfigure the local ip address
	+ ec2ip_drop
	+
	+ extra_opts=""
	+
	+ if [ -n "$OCF_RESKEY_iflabel" ]; then
	+ extra_opts="$extra_opts label $OCF_RESKEY_interface:$OCF_RESKEY_iflabel"
	+ fi
	+
	+ cmd="ip addr add ${OCF_RESKEY_ip}/32 dev $OCF_RESKEY_interface $extra_opts"
	+ ocf_log debug "execute command: $cmd"
	+ $cmd
	+ rc=$?
	+ if [ $rc != 0 ]; then
	+ ocf_log warn "command 'ip addr add' failed. rc: $rc"
	+ return $OCF_ERR_GENERIC
	+ fi
	+
	+ return $OCF_SUCCESS
	}

	ec2ip_stop() {
	- ocf_log info "EC2: Bring down overlay IP address $OCF_RESKEY_ip."
	-
	- ec2ip_monitor
	- if [ $? = $OCF_NOT_RUNNING ]; then
	- ocf_log info "EC2: Overlay IP Address $OCF_RESKEY_ip already down."
	- return $OCF_SUCCESS
	- fi
	-
	- ec2ip_drop
	- if [ $? != $OCF_SUCCESS ]; then
	- return $OCF_ERR_GENERIC
	- fi
	-
	- ec2ip_monitor
	- if [ $? != $OCF_NOT_RUNNING ]; then
	- ocf_log error "EC2: Unable to bring down overlay IP address $OCF_RESKEY_ip on network interface $OCF_RESKEY_interface."
	- return $OCF_ERR_GENERIC
	- fi
	-
	- ocf_log info "EC2: Brought down overlay IP address $OCF_RESKEY_ip."
	- return $OCF_SUCCESS
	+ ocf_log debug "function: ec2ip_stop"
	+
	+ ocf_log info "EC2: Bring down overlay IP address $OCF_RESKEY_ip."
	+ ec2ip_monitor
	+ if [ $? = $OCF_NOT_RUNNING ]; then
	+ ocf_log info "EC2: Overlay IP Address $OCF_RESKEY_ip already down."
	+ return $OCF_SUCCESS
	+ fi
	+
	+ ec2ip_drop
	+ if [ $? != $OCF_SUCCESS ]; then
	+ return $OCF_ERR_GENERIC
	+ fi
	+
	+ ec2ip_monitor
	+ if [ $? != $OCF_NOT_RUNNING ]; then
	+ ocf_log error "EC2: Unable to bring down overlay IP address $OCF_RESKEY_ip on network interface $OCF_RESKEY_interface."
	+ return $OCF_ERR_GENERIC
	+ fi
	+
	+ ocf_log info "EC2: Brought down overlay IP address $OCF_RESKEY_ip."
	+ return $OCF_SUCCESS
	}

	ec2ip_start() {
	- ocf_log info "EC2: Update VPC route table $OCF_RESKEY_routing_table to route overlay IP address $OCF_RESKEY_ip to instance."
	-
	- ec2ip_monitor
	- if [ $? = $OCF_SUCCESS ]; then
	- ocf_log info "EC2: Overlay IP address $OCF_RESKEY_ip already started."
	- return $OCF_SUCCESS
	- fi
	-
	- ocf_log info "EC2: Update VPC route table $OCF_RESKEY_routing_table and configure overlay IP address $OCF_RESKEY_ip."
	- ec2ip_get_and_configure
	- rc=$?
	- if [ $rc != $OCF_SUCCESS ]; then
	- ocf_log error "command 'aws' failed. rc: $rc"
	- return $OCF_ERR_GENERIC
	- fi
	-
	- ec2ip_monitor
	- if [ $? != $OCF_SUCCESS ]; then
	- ocf_log error "EC2: Unable to configure overlay IP address $OCF_RESKEY_ip on network interface $OCF_RESKEY_interface."
	- return $OCF_ERR_GENERIC
	- fi
	-
	- return $OCF_SUCCESS
	+ ocf_log debug "function: ec2ip_start"
	+
	+ ocf_log info "EC2: Update VPC route table $OCF_RESKEY_routing_table to route overlay IP address $OCF_RESKEY_ip to instance."
	+ ec2ip_monitor
	+ if [ $? = $OCF_SUCCESS ]; then
	+ ocf_log info "EC2: Overlay IP address $OCF_RESKEY_ip already started."
	+ return $OCF_SUCCESS
	+ fi
	+
	+ ocf_log info "EC2: Update VPC route table $OCF_RESKEY_routing_table and configure overlay IP address $OCF_RESKEY_ip."
	+ ec2ip_get_and_configure
	+ rc=$?
	+ if [ $rc != $OCF_SUCCESS ]; then
	+ ocf_log error "command 'aws' failed. rc: $rc"
	+ return $OCF_ERR_GENERIC
	+ fi
	+
	+ ec2ip_monitor
	+ if [ $? != $OCF_SUCCESS ]; then
	+ ocf_log error "EC2: Unable to configure overlay IP address $OCF_RESKEY_ip on network interface $OCF_RESKEY_interface."
	+ return $OCF_ERR_GENERIC
	+ fi
	+
	+ return $OCF_SUCCESS
	}

	###############################################################################
	#
	# MAIN
	#
	###############################################################################

	case $__OCF_ACTION in
	- meta-data)
	- metadata
	- exit $OCF_SUCCESS
	- ;;
	- usage\|help)
	- usage
	- exit $OCF_SUCCESS
	- ;;
	+meta-data)
	+ metadata
	+ exit $OCF_SUCCESS
	+ ;;
	+usage \| help)
	+ usage
	+ exit $OCF_SUCCESS
	+ ;;
	esac

	if ! ocf_is_root; then
	- ocf_log err "Musst be root to perform $__OCF_ACTION operation."
	- exit $OCF_ERR_PERM
	+ ocf_log err "Musst be root to perform $__OCF_ACTION operation."
	+ exit $OCF_ERR_PERM
	fi

	AWSCLI_CMD="${OCF_RESKEY_awscli}"

	if [ "${OCF_RESKEY_auth_type}" = "key" ]; then
	- AWSCLI_CMD="$AWSCLI_CMD --profile ${OCF_RESKEY_profile}"
	+ AWSCLI_CMD="$AWSCLI_CMD --profile ${OCF_RESKEY_profile}"
	elif [ "${OCF_RESKEY_auth_type}" = "xrole" ]; then
	- if [ -z "${OCF_RESKEY_region}" ]; then
	- ocf_exit_reason "region needs to be set when using role-based authentication"
	- exit $OCF_ERR_CONFIGURED
	- fi
	+ if [ -z "${OCF_RESKEY_region}" ]; then
	+ ocf_exit_reason "region needs to be set when using role-based authentication"
	+ exit $OCF_ERR_CONFIGURED
	+ fi
	else
	- ocf_exit_reason "Incorrect auth_type: ${OCF_RESKEY_auth_type}"
	- exit $OCF_ERR_CONFIGURED
	+ ocf_exit_reason "Incorrect auth_type: ${OCF_RESKEY_auth_type}"
	+ exit $OCF_ERR_CONFIGURED
	fi
	if [ -n "${OCF_RESKEY_region}" ]; then
	- AWSCLI_CMD="$AWSCLI_CMD --region ${OCF_RESKEY_region}"
	+ AWSCLI_CMD="$AWSCLI_CMD --region ${OCF_RESKEY_region}"
	fi

	ec2ip_set_address_param_compat

	ec2ip_validate

	case $__OCF_ACTION in
	- start)
	- ec2ip_start;;
	- stop)
	- ec2ip_stop;;
	- monitor)
	- ec2ip_monitor;;
	- validate-all)
	- exit $?;;
	- *)
	- usage
	- exit $OCF_ERR_UNIMPLEMENTED
	- ;;
	+start)
	+ ec2ip_start
	+ ;;
	+stop)
	+ ec2ip_stop
	+ ;;
	+monitor)
	+ ec2ip_monitor
	+ ;;
	+validate-all)
	+ exit $?
	+ ;;
	+*)
	+ usage
	+ exit $OCF_ERR_UNIMPLEMENTED
	+ ;;
	esac

File Metadata

Mime Type: text/x-diff
Expires: Sat, Jan 25, 6:50 AM (1 d, 8 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1321566
Default Alt Text: (30 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions