blob: da263c6d9669045e841d73dd59859cdfaad53720 (
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
|
#!/usr/bin/env bash
rgw_flags="--debug-rgw=20 --debug-ms=1"
function _assert {
src=$1; shift
lineno=$1; shift
[ "$@" ] || echo "$src: $lineno: assert failed: $@" || exit 1
}
assert="eval _assert \$BASH_SOURCE \$LINENO"
function var_to_python_json_index {
echo "['$1']" | sed "s/\./'\]\['/g"
}
function json_extract {
var=""
[ "$1" != "" ] && var=$(var_to_python_json_index $1)
shift
python3 - <<END
import json
s='$@'
data = json.loads(s)
print(data$var)
END
}
function python_array_len {
python3 - <<END
arr=$@
print(len(arr))
END
}
function project_python_array_field {
var=$(var_to_python_json_index $1)
shift
python3 - <<END
arr=$@
s='( '
for x in arr:
s += '"' + str(x$var) + '" '
s += ')'
print(s)
END
}
x() {
# echo "x " "$@" >&2
eval "$@"
}
script_dir=`dirname $0`
root_path=`(cd $script_dir/../..; pwd)`
mstart=$root_path/mstart.sh
mstop=$root_path/mstop.sh
mrun=$root_path/mrun
mrgw=$root_path/mrgw.sh
url=http://localhost
function start_ceph_cluster {
[ $# -ne 1 ] && echo "start_ceph_cluster() needs 1 param" && exit 1
echo "$mstart $1"
}
function rgw_admin {
[ $# -lt 1 ] && echo "rgw_admin() needs 1 param" && exit 1
echo "$mrun $1 radosgw-admin"
}
function rgw {
[ $# -lt 2 ] && echo "rgw() needs at least 2 params" && exit 1
name=$1
port=$2
ssl_port=0 #ssl port not used
shift 2
echo "$mrgw $name $port $ssl_port $rgw_flags $@"
}
function init_first_zone {
[ $# -ne 7 ] && echo "init_first_zone() needs 7 params" && exit 1
cid=$1
realm=$2
zg=$3
zone=$4
endpoints=$5
access_key=$6
secret=$7
# initialize realm
x $(rgw_admin $cid) realm create --rgw-realm=$realm
# create zonegroup, zone
x $(rgw_admin $cid) zonegroup create --rgw-zonegroup=$zg --master --default
x $(rgw_admin $cid) zone create --rgw-zonegroup=$zg --rgw-zone=$zone --access-key=${access_key} --secret=${secret} --endpoints=$endpoints --default
x $(rgw_admin $cid) user create --uid=zone.user --display-name=ZoneUser --access-key=${access_key} --secret=${secret} --system
x $(rgw_admin $cid) period update --commit
}
function init_zone_in_existing_zg {
[ $# -ne 8 ] && echo "init_zone_in_existing_zg() needs 8 params" && exit 1
cid=$1
realm=$2
zg=$3
zone=$4
master_zg_zone1_port=$5
endpoints=$6
access_key=$7
secret=$8
x $(rgw_admin $cid) realm pull --url=$url:$master_zg_zone1_port --access-key=${access_key} --secret=${secret} --default
x $(rgw_admin $cid) zonegroup default --rgw-zonegroup=$zg
x $(rgw_admin $cid) zone create --rgw-zonegroup=$zg --rgw-zone=$zone --access-key=${access_key} --secret=${secret} --endpoints=$endpoints
x $(rgw_admin $cid) period update --commit
}
function init_first_zone_in_slave_zg {
[ $# -ne 8 ] && echo "init_first_zone_in_slave_zg() needs 8 params" && exit 1
cid=$1
realm=$2
zg=$3
zone=$4
master_zg_zone1_port=$5
endpoints=$6
access_key=$7
secret=$8
# create zonegroup, zone
x $(rgw_admin $cid) realm pull --url=$url:$master_zg_zone1_port --access-key=${access_key} --secret=${secret}
x $(rgw_admin $cid) realm default --rgw-realm=$realm
x $(rgw_admin $cid) zonegroup create --rgw-realm=$realm --rgw-zonegroup=$zg --endpoints=$endpoints --default
x $(rgw_admin $cid) zonegroup default --rgw-zonegroup=$zg
x $(rgw_admin $cid) zone create --rgw-zonegroup=$zg --rgw-zone=$zone --access-key=${access_key} --secret=${secret} --endpoints=$endpoints
x $(rgw_admin $cid) zone default --rgw-zone=$zone
x $(rgw_admin $cid) zonegroup add --rgw-zonegroup=$zg --rgw-zone=$zone
x $(rgw_admin $cid) period update --commit
}
function call_rgw_admin {
cid=$1
shift 1
x $(rgw_admin $cid) "$@"
}
function get_mstart_parameters {
[ $# -ne 1 ] && echo "get_mstart_parameters() needs 1 param" && exit 1
# bash arrays start from zero
index="$1"
index=$((index-1))
if [ -n "$DEV_LIST" ]; then
IFS=', ' read -r -a dev_list <<< "$DEV_LIST"
if [ ${#dev_list[@]} -gt "$index" ]; then
local dev_name=${dev_list["$index"]}
parameters="--bluestore-devs $dev_name"
fi
fi
if [ -n "$DB_DEV_LIST" ]; then
IFS=', ' read -r -a db_dev_list <<< "$DB_DEV_LIST"
if [ ${#db_dev_list[@]} -gt "$index" ]; then
local dev_name=${db_dev_list["$index"]}
parameters="$parameters"" -o bluestore_block_db_path=$dev_name"
fi
fi
if [ -n "$WAL_DEV_LIST" ]; then
IFS=', ' read -r -a wal_dev_list <<< "$WAL_DEV_LIST"
if [ ${#wal_dev_list[@]} -gt "$index" ]; then
local dev_name=${wal_dev_list["$index"]}
parameters="$parameters"" -o bluestore_block_wal_path=$dev_name"
fi
fi
echo "$parameters"
}
|
