aboutsummaryrefslogtreecommitdiffstats
path: root/meta-openstack/recipes-devtools/python/python-swift/swift_setup.sh
blob: c1d02ede0ad48e53dc16b9ba6c9f5f5fa4b24c10 (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
#!/bin/bash

#set -x

SWIFT_RING_BUILDER=/usr/bin/swift-ring-builder


for_each_dev_in_cluster ()
{
    local cmd=$1

    dev_id=0
    while read line; do
        line=`echo $line | sed -e 's/^ *//g' -e 's/ *$//g'`
        [ -z "$line" ] && continue

        dev=`echo $line | cut -d ',' -f 1 | sed -e 's/^ *//g' -e 's/ *$//g'`
        dev_format=`echo $line | cut -d ',' -f 2 | sed -e 's/^ *//g' -e 's/ *$//g'`
        zone=`echo $line | cut -d ',' -f 3 | sed -e 's/^ *//g' -e 's/ *$//g'`
        ring_names=`echo $line | cut -d ',' -f 4 | sed -e 's/^ *//g' -e 's/ *$//g'`
        weight=`echo $line | cut -d ',' -f 5 | sed -e 's/^ *//g' -e 's/ *$//g'`

        [[ "${dev:0:1}" == "#" ]] && continue
        if [ ! -z $dev ] && [ ! -e $dev ]; then
            continue
        fi
        dev_id=$((dev_id+1))
        $cmd "$dev" "$dev_format" "$dev_id" "$zone" "$ring_names" "$weight" $2 $3 $4
    done < $cluster_conf
}


mount_dev ()
{
    local dev=$1
    local dev_id=$3
    local zone=$4

    mkdir -p $swift_home/node/z${zone}d${dev_id}
    [ -z "$dev" ] && return 1
    if [ -b $dev ]; then
        mount $dev $swift_home/node/z${zone}d${dev_id}
    else
        loopdev=`losetup --show -f $dev`
        mount $loopdev $swift_home/node/z${zone}d${dev_id}
    fi
}


unmount_dev ()
{
    local dev=$1

    [ -z "$dev" ] && return 1
    if [ -b $dev ]; then
        umount $dev
    else
        loopdev=`losetup -j $dev | cut -d ":" -f 1 | tail -1`
        if [ ! -z $loopdev ]; then
            umount $loopdev
            losetup -d $loopdev
        fi
    fi
}


format_dev ()
{
    local dev=$1
    local dev_format=$2

    [ -z "$dev" ] && return 1
    if [ -b $dev ]; then
        mkfs.${dev_format} $dev
    else
        loopdev=`losetup --show -f $dev`
        mkfs.${dev_format} $loopdev
        sleep 2
        losetup -d $loopdev
    fi
}


add_dev ()
{
    local dev_id=$3
    local zone=$4
    local ring_names=$5
    local weight=$6

    account_port=6002
    container_port=6001
    object_port=6000

    for ring in $ring_names; do
        eval builder_port=\$${ring}_port
        [ -z $builder_port ] && continue
        $SWIFT_RING_BUILDER $swift_home/${ring}.builder add -r 1 -z $zone -i $host_ip -p $builder_port -d z${zone}d${dev_id} -w $weight
    done
}


cluster_create_rings ()
{
    if [ ! -f $SWIFT_RING_BUILDER ]; then
        echo "ERROR: Swift packages are not installed on this machine"
        return 1
    fi

    if [ -e $swift_home/account.builder -o -e $swift_home/container.builder -o -e $swift_home/object.builder ]; then
        echo "ERROR: Swift cluster has been created"
        return 1
    fi

    sed "s/^swift_hash_path_suffix =.*/swift_hash_path_suffix = `uuidgen`/" -i $swift_home/swift.conf

    # Create 3 ring builders: each ring has 2^12 partition
    $SWIFT_RING_BUILDER $swift_home/account.builder create 12 $cluster_replica 1
    $SWIFT_RING_BUILDER $swift_home/container.builder create 12 $cluster_replica 1
    $SWIFT_RING_BUILDER $swift_home/object.builder create 12 $cluster_replica 1
}


cluster_add_devs ()
{
    for_each_dev_in_cluster add_dev

    $SWIFT_RING_BUILDER $swift_home/account.builder rebalance
    $SWIFT_RING_BUILDER $swift_home/container.builder rebalance
    $SWIFT_RING_BUILDER $swift_home/object.builder rebalance
}


cluster_delete_all ()
{
    for_each_dev_in_cluster unmount_dev
    rm -rf $swift_home/*.ring.gz
    rm -rf $swift_home/*.builder
    rm -rf $swift_home/node
}


help ()
{
    cat << EOF
usage:  swift_setup.sh [-hcirk] <command>

 -h : View this help
 -c : Swift cluster config file, default is /etc/swift/cluster.conf
 -i : IP address of this machine, default is 127.0.0.1
 -r : The number of Swift replications
 -k : Location where Swift builder and ring files stay, default is /etc/swift

<command> can be one of the followings:

 createrings : Create Swift account, container, and object builder
       clean : Delete all Swift build and ring files
   mountdevs : Mount all devices specified in cluster config file
 unmountdevs : Un-mount all devices specified in cluster config file
  formatdevs : Format all devices specified in cluster config file
     adddevs : Add all devices specified in cluster config file into
               Swift rings

swift_setup.sh script helps to create or expand Swift cluster with
storage devices in this machine.

The Swift cluster config file (default is /etc/swift/cluster.conf) describes
how storage devices in this machine can be added into Swift cluster.

Each line of cluster config file specifies how one storage device can be
added into Swift cluster with the following format:

    <dev file>, <dev format>, <zone>, <ring names>, <weight>

 <dev file>: full path to a block device or full path to regular
             file which is used for backing up a loopback device.
             If <dev file> is empty string then this device is
             backed up by a directory in local filesystem.
 <dev format>: the disk format type, e.g. ext4, xfs...
 <zone>: the zone id which this block device belongs to
 <ring names>: a list (separated by space) ring name ("account", "container",
               or "object") which this device is added to
 <weight>: weight of this device in Swift zone


Example 1: To add storage devices in this machine into an existing
Swift Cluster:

    $ /etc/init.d/swift stop
    $ Sync the Swift builders and rings files into this machine
    $ Modify /etc/cluster.conf to specify what storage devices
      are added into cluster
    $ swift_setup.sh formatdevs
    $ swift_setup.sh mountdevs
    $ swift_setup.sh -i <IP of this machine> adddevs
    $ swift_setup.sh unmountdevs
    $ /etc/init.d/swift start

Example 2: To create an new Swift cluster:

    $ /etc/init.d/swift stop
    $ Modify /etc/cluster.conf to reflect the desired cluster
    $ swift_setup.sh clean
    $ swift_setup.sh createrings
    $ swift_setup.sh formatdevs
    $ swift_setup.sh mountdevs
    $ swift_setup.sh -i <IP of this machine> adddevs
    $ swift_setup.sh unmountdevs
    $ /etc/init.d/swift start
EOF
}


cluster_conf="/etc/swift/cluster.conf"
swift_home="/etc/swift"
host_ip="127.0.0.1"
cluster_replica="2"

while getopts "?hc:r:i:k:" opt; do
    case $opt in
        c)
            cluster_conf=$OPTARG
            ;;
        r)
            cluster_replica=$OPTARG
            ;;
        i)
            host_ip=$OPTARG
            ;;
        k)
            swift_home=$OPTARG
            ;;
        ?|h)
            help
            exit 0
            ;;
    esac
done

# Move aside the optional arguments
shift $(( $OPTIND - 1 ))


case "$1" in
    createrings)
        cluster_create_rings
        ;;
    clean)
        for_each_dev_in_cluster unmount_dev
        cluster_delete_all
        ;;
    mountdevs)
        for_each_dev_in_cluster mount_dev
        ;;
    unmountdevs)
        for_each_dev_in_cluster unmount_dev
        ;;
    formatdevs)
        for_each_dev_in_cluster format_dev
        ;;
    adddevs)
        cluster_add_devs
        ;;
    *)
        help
        exit 0
        ;;
esac

exit 0