summaryrefslogtreecommitdiffstats
path: root/tests/run.sh
blob: d476f33e03301cb953f1949a6a8021a5908a0527 (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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
#!/bin/bash -e
##############################################################################
# Copyright (c) 2016 NEC Corporation and others.
#
# 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
##############################################################################

[[ "${CI_DEBUG:-true}" == "true" ]] && set -x

IMAGE_URL=https://launchpad.net/cirros/trunk/0.3.0/+download/cirros-0.3.0-x86_64-disk.img
IMAGE_NAME=cirros
IMAGE_FILE="${IMAGE_NAME}.img"
IMAGE_FORMAT=qcow2
VM_NAME=doctor_vm1
VM_FLAVOR=m1.tiny
ALARM_NAME=doctor_alarm1
INSPECTOR_PORT=12345
CONSUMER_PORT=12346
TEST_USER=demo
TEST_PW=demo
TEST_PROJECT=demo
TEST_ROLE=_member_

SUPPORTED_INSTALLER_TYPES="apex local"
INSTALLER_TYPE=${INSTALLER_TYPE:-apex}
INSTALLER_IP=${INSTALLER_IP:-none}
COMPUTE_HOST=${COMPUTE_HOST:-overcloud-novacompute-0}
COMPUTE_IP=${COMPUTE_IP:-none}
COMPUTE_USER=${COMPUTE_USER:-heat-admin}
ssh_opts="-o UserKnownHostsFile=/dev/null -o StrictHostKeyChecking=no"

if [[ ! "$SUPPORTED_INSTALLER_TYPES" =~ "$INSTALLER_TYPE" ]] ; then
    echo "ERROR: INSTALLER_TYPE=$INSTALLER_TYPE is not supported."
    exit 1
fi

prepare_compute_ssh() {
    ssh_opts_cpu="$ssh_opts"

    if [[ "$INSTALLER_TYPE" == "apex" ]] ; then
        if [[ "$INSTALLER_IP" == "none" ]] ; then
            instack_mac=$(sudo virsh domiflist instack | awk '/default/{print $5}')
            INSTALLER_IP=$(/usr/sbin/arp -e | grep ${instack_mac} | awk '{print $1}')
        fi

        if [[ "$COMPUTE_IP" == "none" ]] ; then
            COMPUTE_IP=$(sudo ssh $ssh_opts $INSTALLER_IP \
                         "source stackrc; \
                          nova show $COMPUTE_HOST \
                          | awk '/ ctlplane network /{print \$5}'")
        fi

        # get ssh key from installer node
        sudo scp $ssh_opts root@"$INSTALLER_IP":/home/stack/.ssh/id_rsa instack_key
        sudo chown $(whoami):$(whoami) instack_key
        chmod 400 instack_key
        ssh_opts_cpu+=" -i instack_key"
    elif [[ "$INSTALLER_TYPE" == "local" ]] ; then
        if [[ "$COMPUTE_IP" == "none" ]] ; then
            COMPUTE_IP=$(getent hosts "$COMPUTE_HOST" | awk '{ print $1 }')
            if [[ -z "$COMPUTE_IP" ]]; then
                echo "ERROR: Could not resolve $COMPUTE_HOST. Either manually set COMPUTE_IP or enable DNS resolution."
                exit 1
            fi
        fi

        echo "INSTALLER_TYPE set to 'local'. Assuming SSH keys already exchanged with $COMPUTE_HOST"
    fi

    # verify connectivity to target compute host
    ping -c 1 "$COMPUTE_IP"
}

download_image() {
    [ -e "$IMAGE_FILE" ] && return 0
    wget "$IMAGE_URL" -o "$IMAGE_FILE"
}

register_image() {
    glance image-list | grep -q " $IMAGE_NAME " && return 0
    glance image-create --name "$IMAGE_NAME" \
                        --visibility public \
                        --disk-format "$IMAGE_FORMAT" \
                        --container-format bare \
                        --file "$IMAGE_FILE"
}

create_test_user() {
    openstack user list | grep -q "$TEST_USER" || {
        openstack user create "$TEST_USER" --password "$TEST_PW"
    }
    openstack project list | grep -q "$TEST_PROJECT" || {
        openstack project create "$TEST_PROJECT"
    }
    openstack user role list "$TEST_USER" --project "$TEST_PROJECT" \
    | grep -q "$TEST_ROLE" || {
        openstack role add "$TEST_ROLE" --user "$TEST_USER" \
                           --project "$TEST_PROJECT"
    }
}

boot_vm() {
    nova list | grep -q " $VM_NAME " && return 0
    (
        # test VM done with test user, so can test non-admin
        export OS_USERNAME="$TEST_USER"
        export OS_PASSWORD="$TEST_PW"
        export OS_TENANT_NAME="$TEST_PROJECT"
        nova boot --flavor "$VM_FLAVOR" \
                  --image "$IMAGE_NAME" \
                  "$VM_NAME"
        sleep 1
    )

}

create_alarm() {
    ceilometer alarm-list | grep -q " $ALARM_NAME " && return 0
    vm_id=$(nova list | grep " $VM_NAME " | awk '{print $2}')
    ceilometer alarm-event-create --name "$ALARM_NAME" \
        --alarm-action "http://localhost:$CONSUMER_PORT/failure" \
        --description "VM failure" \
        --enabled True \
        --repeat-actions False \
        --severity "moderate" \
        --event-type compute.instance.update \
        -q "traits.state=string::error; traits.instance_id=string::$vm_id"
}

start_monitor() {
    pgrep -f "python monitor.py" && return 0
    sudo python monitor.py "$COMPUTE_HOST" "$COMPUTE_IP" \
        "http://127.0.0.1:$INSPECTOR_PORT/events" > monitor.log 2>&1 &
}

stop_monitor() {
    pgrep -f "python monitor.py" || return 0
    sudo kill $(pgrep -f "python monitor.py")
    cat monitor.log
}

start_inspector() {
    pgrep -f "python inspector.py" && return 0
    python inspector.py "$INSPECTOR_PORT" > inspector.log 2>&1 &
}

stop_inspector() {
    pgrep -f "python inspector.py" || return 0
    kill $(pgrep -f "python inspector.py")
    cat inspector.log
}

start_consumer() {
    pgrep -f "python consumer.py" && return 0
    python consumer.py "$CONSUMER_PORT" > consumer.log 2>&1 &
}

stop_consumer() {
    pgrep -f "python consumer.py" || return 0
    kill $(pgrep -f "python consumer.py")
    cat consumer.log
}

wait_for_vm_launch() {
    echo "waiting for vm launch..."
    while true
    do
        state=$(nova list | grep " $VM_NAME " | awk '{print $6}')
        [[ "$state" == "ACTIVE" ]] && return 0
        sleep 1
    done
}

inject_failure() {
    echo "disabling network of compute host [$COMPUTE_HOST] for 3 mins..."
    cat > disable_network.sh << 'END_TXT'
#!/bin/bash -x
dev=$(sudo ip route | awk '/^default/{print $5}')
sleep 1
sudo ip link set $dev down
sleep 180
sudo ip link set $dev up
sleep 1
END_TXT
    chmod +x disable_network.sh
    scp $ssh_opts_cpu disable_network.sh "$COMPUTE_USER@$COMPUTE_IP:"
    ssh $ssh_opts_cpu "$COMPUTE_USER@$COMPUTE_IP" 'nohup ./disable_network.sh > disable_network.log 2>&1 &'
}

calculate_notification_time() {
    detected=$(grep "doctor monitor detected at" monitor.log | awk '{print $5}')
    notified=$(grep "doctor consumer notified at" consumer.log | awk '{print $5}')
    echo "$notified $detected" | \
        awk '{d = $1 - $2; if (d < 1 && d > 0) print d " OK"; else print d " NG"}'
}

check_host_status_down() {
    (
        # Switching to test user
        export OS_USERNAME="$TEST_USER"
        export OS_PASSWORD="$TEST_PW"
        export OS_TENANT_NAME="$TEST_PROJECT"

        host_status_line=$(nova show $VM_NAME | grep "host_status")
        [[ $? -ne 0 ]] && {
            echo "ERROR: host_status not configured for owner in Nova policy.json"
        }

        host_status=$(echo $host_status_line | awk '{print $4}')
        [[ "$host_status" == "DOWN" ]] && {
            echo "$VM_NAME showing host_status: $host_status"
        }
        echo "ERROR: host_status not reported by: nova show $VM_NAME"
    )
}

cleanup() {
    set +e
    echo "cleanup..."
    stop_monitor
    stop_inspector
    stop_consumer

    python ./nova_force_down.py "$COMPUTE_HOST" --unset
    sleep 1
    nova delete "$VM_NAME"
    sleep 1
    alarm_id=$(ceilometer alarm-list | grep " $ALARM_NAME " | awk '{print $2}')
    sleep 1
    [ -n "$alarm_id" ] && ceilometer alarm-delete "$alarm_id"
    sleep 1
    image_id=$(glance image-list | grep " $IMAGE_NAME " | awk '{print $2}')
    sleep 1
    [ -n "$image_id" ] && glance image-delete "$image_id"
    openstack role remove "$TEST_ROLE" --user "$TEST_USER" \
                              --project "$TEST_PROJECT"
    openstack project delete "$TEST_PROJECT"
    openstack user delete "$TEST_USER"

    #TODO: add host status check via nova admin api
    echo "waiting disabled compute host back to be enabled..."
    sleep 180
    ssh $ssh_opts_cpu "$COMPUTE_USER@$COMPUTE_IP" \
        "[ -e disable_network.log ] && cat disable_network.log"
}


echo "Note: doctor/tests/run.sh has been executed."

prepare_compute_ssh

trap cleanup EXIT

echo "preparing VM image..."
download_image
register_image

echo "starting doctor sample components..."
start_monitor
start_inspector
start_consumer

echo "creating test user..."
create_test_user

echo "creating VM and alarm..."
boot_vm
create_alarm
wait_for_vm_launch

sleep 60
echo "injecting host failure..."
inject_failure
sleep 10

check_host_status_down
calculate_notification_time

echo "done"