summaryrefslogtreecommitdiff
path: root/xendomains-wait-disks.sh
blob: 15ae50716d474448ca2a55c08e272599431e3199 (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
#!/bin/bash
#
# Generates xendomains unit
#

read_conf_from_file() {
	${sbindir}/xl create --quiet --dryrun --defconfig "$1"
}

big2littleendian_32bit(){
	echo ${1:6:2}${1:4:2}${1:2:2}${1:0:2}
}

read_hex() {
	local out_var=$1; shift
	local input=$1; shift
	local pos_var=$1; shift
	local length=$1; shift
	local hex=$(dd bs=1 skip=${!pos_var} count=$length status=none <$input | xxd -p -c$length -l$length)
	read -r $pos_var <<<"$((${!pos_var} + $length))"
	read -r $out_var <<<"$hex"
}

hex2dec() {
	local hex=$1; shift
	local little_endian=$1; shift
	if $little_endian; then
		hex=$(big2littleendian_32bit $hex)
	fi
	echo $((0x$hex))
}

read_conf_from_image(){
	local pos=0 length=0
	
	local magic_header byte_order mandatory_flags optional_flags optional_data_len config_len config_json

	read_hex magic_header $1 pos 32
	# "Xen saved domain, xl format\n \0 \r"
	if [ "$magic_header" != "58656e20736176656420646f6d61696e2c20786c20666f726d61740a2000200d" ]; then
		log $err "Unknown file format in $1. Wrong magic header: '0x$magic_header'"
		return 1
	fi

	read_hex byte_order $1 pos 4
	case "$byte_order" in
	04030201) little_endian=true;;
	01020304) little_endian=false;;
 	*) log $err "Unknown byte order 0x$byte_order in $1"; return 1;;
	esac

	#define XL_MANDATORY_FLAG_JSON (1U << 0) /* config data is in JSON format */
	#define XL_MANDATORY_FLAG_STREAMv2 (1U << 1) /* stream is v2 */
	read_hex mandatory_flags $1 pos 4
	if [ "$(($(hex2dec $mandatory_flags $little_endian) & 0x3))" -ne 3 ]; then
		log $err "Unknown config format or stream version. Mandatory flags are 0x$mandatory_flag"
		return 1
	fi

	read_hex optional_flags $1 pos 4
	read_hex optional_data_len $1 pos 4
	optional_data_len=$(hex2dec $optional_data_len $little_endian)

	# I'll not use but saved memory dump will begin at $((pos+optional_data_len))
	read_hex config_len $1 pos 4
	config_len=$(hex2dec $config_len $little_endian)

	# null terminated string
	read_hex config_json $1 pos $config_len
	xxd -p -r <<<"$config_json"
}

log() {
	local msg_loglevel=$1; shift
	if [ "$msg_loglevel" -gt "$LOGLEVEL" ]; then
		return 0
	fi
	echo "$@" >&2
}


emerg=0; alert=1; crit=2; err=3
warning=4; notice=5; info=6; debug=7
LOGLEVEL=${LOGLEVEL:-4}
if [ "$SYSTEMD_LOG_LEVEL" ]; then
	LOGLEVEL=${!SYSTEMD_LOG_LEVEL}
fi
log $debug "Using loglevel $LOGLEVEL"
trap "log $err Error on \$LINENO: \$(caller)" ERR

log $debug "loading /etc/xen/scripts/hotplugpath.sh..."
. /etc/xen/scripts/hotplugpath.sh

#log $debug "testing for ${sbindir}/xl..."
#CMD=${sbindir}/xl
#if ! $CMD list &> /dev/null; then
#	log $err "${sbindir}/xl list failed!"
#	log $err "$($CMD list &>&1)"
#	exit $?
#fi
#log $debug "${sbindir}/xl list OK!"

log $debug "loading /etc/sysconfig/xendomains..."
XENDOM_CONFIG=/etc/sysconfig/xendomains
if ! test -r $XENDOM_CONFIG; then
	echo "$XENDOM_CONFIG not existing" >&2;
        exit 6
fi

. $XENDOM_CONFIG

doms_conf=()
doms_restore=()
doms_source=()

log $debug "Reading saved domains..."
if [ "$XENDOMAINS_RESTORE" = "true" ] && [ -d "$XENDOMAINS_SAVE" ]; then
        for dom in $XENDOMAINS_SAVE/*; do
		log $debug "Trying $dom..."
        	if ! [ -r $dom ] ; then
			log $debug "Not readable $dom..."
			continue
		fi
	
		log $debug "Reading conf from $dom..."
		if ! dom_conf=$(read_conf_from_image $dom); then
			log $error "Cannot read conf from $dom"
			continue
		fi

		log $debug "Adding $dom to the list"
		doms_conf+=("$dom_conf")
		doms_restore+=(true)
		doms_source+=("$dom")
	done
fi

log $debug "Reading auto domains..."
if [ -d "$XENDOMAINS_AUTO" ]; then
	for dom in $XENDOMAINS_AUTO/*; do
		log $debug "Trying $dom..."
	 	if ! [ -r $dom ] ; then
			log $debug "Not readable $dom..."
			continue
		fi

		log $debug "Reading conf from $dom..."
		if ! dom_conf=$(read_conf_from_file $dom); then
			echo 123
			log $error "Cannot read conf from $dom"
			continue
		fi

		log $debug "Adding $dom to the list"
		doms_conf+=("$dom_conf")
		doms_restore+=(false)
		doms_source+=("$dom")
	done
fi

log $debug "We have ${#doms_conf[*]} to check"
for i in ${!doms_conf[*]}; do
	log $debug "Doing dom $i..."

	dom_conf="${doms_conf[i]}"
	dom_restore="${doms_restore[i]}"
	dom_source="${doms_source[i]}"

	dom_name=$(sed -n 's/^.*(name \(.*\))$/\1/p;s/^.*"name": "\(.*\)",$/\1/p' <<<"$dom_conf")
        readarray -t required_disks <<<"$(sed -n -e '/^    "disks": \[/,/    \],/{ /"pdev_path":/ { s/.*"pdev_path": "//;s/".*//p } }' <<<"$dom_conf")"

	log $debug "dom $i is named $dom_name..."
	for disk in "${required_disks[@]}"; do
		disk_control_var=control_$(tr -d -c '[a-zA-Z0-9_]' <<<"$disk")
		if [ "${!disk_control_var:-0}" -eq 1 ]; then
			log $debug "$disk for $dom_name is already being checked"
			continue
		fi
		declare $disk_control_var=1
		log $debug "waiting for $disk for $dom_name"
		(
			j=0 found_loglevel=$debug
			while true; do
				if [ -e "$disk" ]; then
					log $found_loglevel "disk $disk found (after $j seconds)"
					exit 0
				fi
				if [ "$(( j++ % 5))" -eq 0 ]; then
					log $warning "still waiting for $disk for $dom_name..."
					found_loglevel=$warning
				fi
				sleep 1
			done
		) &
	done
done

wait
log $debug "Exiting normally"