blob: 542443d6108e12f4f32232ac2f30609a05495bfe (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
#!/bin/bash
# SPDX-license-identifier: Apache-2.0
##############################################################################
# Copyright (c) 2018
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
set -o errexit
set -o nounset
set -o pipefail
source /etc/environment
function print_msg {
local msg=$1
local RED='\033[0;31m'
local NC='\033[0m'
echo -e "${RED} $msg ---------------------------------------${NC}"
}
function _get_ovn_central_address {
ansible_ifconfig=$(ansible ovn-central[0] -i $test_folder/../hosting_providers/vagrant/inventory/hosts.ini -m shell -a "ifconfig eth1 |grep \"inet addr\" |awk '{print \$2}' |awk -F: '{print \$2}'")
if [[ $ansible_ifconfig != *CHANGED* ]]; then
echo "Fail to get the OVN central IP address from eth1 nic"
exit
fi
echo "$(echo ${ansible_ifconfig#*>>} | tr '\n' ':')6641"
}
# init_network() - This function creates the OVN resouces required by the test
function init_network {
local fname=$1
local router_name="ovn4nfv-master"
name=$(cat $fname | yq '.spec.name' | xargs)
subnet=$(cat $fname | yq '.spec.subnet' | xargs)
gateway=$(cat $fname | yq '.spec.gateway' | xargs)
ovn_central_address=$(_get_ovn_central_address)
router_mac=$(printf '00:00:00:%02X:%02X:%02X' $((RANDOM%256)) $((RANDOM%256)) $((RANDOM%256)))
ovn-nbctl --may-exist --db tcp:$ovn_central_address ls-add $name -- set logical_switch $name other-config:subnet=$subnet external-ids:gateway_ip=$gateway
ovn-nbctl --may-exist --db tcp:$ovn_central_address lrp-add $router_name rtos-$name $router_mac $gateway
ovn-nbctl --may-exist --db tcp:$ovn_central_address lsp-add $name stor-$name -- set logical_switch_port stor-$name type=router options:router-port=rtos-$name addresses=\"$router_mac\"
}
# cleanup_network() - This function removes the OVN resources created for the test
function cleanup_network {
local fname=$1
name=$(cat $fname | yq '.spec.name' | xargs)
ovn_central_address=$(_get_ovn_central_address)
for cmd in "ls-del $name" "lrp-del rtos-$name" "lsp-del stor-$name"; do
ovn-nbctl --if-exist --db tcp:$ovn_central_address $cmd
done
}
function _checks_args {
if [[ -z $1 ]]; then
echo "Missing CSAR ID argument"
exit 1
fi
if [[ -z $CSAR_DIR ]]; then
echo "CSAR_DIR global environment value is empty"
exit 1
fi
mkdir -p ${CSAR_DIR}/${1}
}
# destroy_deployment() - This function ensures that a specific deployment is
# destroyed in Kubernetes
function destroy_deployment {
local deployment_name=$1
echo "$(date +%H:%M:%S) - $deployment_name : Destroying deployment"
kubectl delete deployment $deployment_name --ignore-not-found=true --now
while kubectl get deployment $deployment_name &>/dev/null; do
echo "$(date +%H:%M:%S) - $deployment_name : Destroying deployment"
done
}
# recreate_deployment() - This function destroys an existing deployment and
# creates an new one based on its yaml file
function recreate_deployment {
local deployment_name=$1
destroy_deployment $deployment_name
kubectl create -f $deployment_name.yaml
}
# wait_deployment() - Wait process to Running status on the Deployment's pods
function wait_deployment {
local deployment_name=$1
status_phase=""
while [[ $status_phase != "Running" ]]; do
new_phase=$(kubectl get pods | grep $deployment_name | awk '{print $3}')
if [[ $new_phase != $status_phase ]]; then
echo "$(date +%H:%M:%S) - $deployment_name : $new_phase"
status_phase=$new_phase
fi
if [[ $new_phase == "Err"* ]]; then
exit 1
fi
done
}
# setup() - Base testing setup shared among functional tests
function setup {
for deployment_name in $@; do
recreate_deployment $deployment_name
done
sleep 5
for deployment_name in $@; do
wait_deployment $deployment_name
done
}
# teardown() - Base testing teardown function
function teardown {
for deployment_name in $@; do
destroy_deployment $deployment_name
done
}
if ! $(kubectl version &>/dev/null); then
echo "This funtional test requires kubectl client"
exit 1
fi
test_folder=$(pwd)
|
