1#!/bin/bash 2# 3# Test NBD client unexpected disconnect 4# 5# Copyright Red Hat, Inc. 2014 6# 7# This program is free software; you can redistribute it and/or modify 8# it under the terms of the GNU General Public License as published by 9# the Free Software Foundation; either version 2 of the License, or 10# (at your option) any later version. 11# 12# This program is distributed in the hope that it will be useful, 13# but WITHOUT ANY WARRANTY; without even the implied warranty of 14# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 15# GNU General Public License for more details. 16# 17# You should have received a copy of the GNU General Public License 18# along with this program. If not, see <http://www.gnu.org/licenses/>. 19# 20 21# creator 22owner=stefanha@redhat.com 23 24seq=`basename $0` 25echo "QA output created by $seq" 26 27here=`pwd` 28tmp=/tmp/$$ 29status=1 # failure is the default! 30 31# get standard environment, filters and checks 32. ./common.rc 33. ./common.filter 34 35_supported_fmt generic 36_supported_proto nbd 37_supported_os Linux 38 39# Pick a TCP port based on our pid. This way multiple instances of this test 40# can run in parallel without conflicting. 41choose_tcp_port() { 42 echo $((($$ % 31744) + 1024)) # 1024 <= port < 32768 43} 44 45wait_for_tcp_port() { 46 while ! (netstat --tcp --listening --numeric | \ 47 grep "$1.*0\\.0\\.0\\.0:\\*.*LISTEN") 2>&1 >/dev/null; do 48 sleep 0.1 49 done 50} 51 52_filter_nbd() 53{ 54 # nbd.c error messages contain function names and line numbers that are 55 # prone to change. Message ordering depends on timing between send and 56 # receive callbacks sometimes, making them unreliable. 57 # 58 # Filter out the TCP port number since this changes between runs. 59 sed -e 's#^.*nbd/.*\.c:.*##g' \ 60 -e 's#nbd:127\.0\.0\.1:[^:]*:#nbd:127\.0\.0\.1:PORT:#g' \ 61 -e 's#\(exportname=foo\|PORT\): Failed to .*$#\1#' 62} 63 64check_disconnect() { 65 event=$1 66 when=$2 67 negotiation=$3 68 echo "=== Check disconnect $when $event ===" 69 echo 70 71 port=$(choose_tcp_port) 72 73 cat > "$TEST_DIR/nbd-fault-injector.conf" <<EOF 74[inject-error] 75event=$event 76when=$when 77EOF 78 79 if [ "$negotiation" = "--classic-negotiation" ]; then 80 extra_args=--classic-negotiation 81 nbd_url="nbd:127.0.0.1:$port" 82 else 83 nbd_url="nbd:127.0.0.1:$port:exportname=foo" 84 fi 85 86 $PYTHON nbd-fault-injector.py $extra_args "127.0.0.1:$port" "$TEST_DIR/nbd-fault-injector.conf" 2>&1 >/dev/null & 87 wait_for_tcp_port "127\\.0\\.0\\.1:$port" 88 $QEMU_IO -c "read 0 512" "$nbd_url" 2>&1 | _filter_qemu_io | _filter_nbd 89 90 echo 91} 92 93for event in neg1 "export" neg2 request reply data; do 94 for when in before after; do 95 check_disconnect "$event" "$when" 96 done 97 98 # Also inject short replies from the NBD server 99 case "$event" in 100 neg1) 101 for when in 8 16; do 102 check_disconnect "$event" "$when" 103 done 104 ;; 105 "export") 106 for when in 4 12 16; do 107 check_disconnect "$event" "$when" 108 done 109 ;; 110 neg2) 111 for when in 8 10; do 112 check_disconnect "$event" "$when" 113 done 114 ;; 115 reply) 116 for when in 4 8; do 117 check_disconnect "$event" "$when" 118 done 119 ;; 120 esac 121done 122 123# Also check classic negotiation without export information 124for when in before 8 16 24 28 after; do 125 check_disconnect "neg-classic" "$when" --classic-negotiation 126done 127 128# success, all done 129echo "*** done" 130rm -f $seq.full 131status=0 132