9b7495013600a53152a1c1ca9824f4d43f4c28c1
[sliver-openvswitch.git] / planetlab / scripts / sliver-ovs.in
1 #!/bin/bash
2 # -*-shell-mode-*-
3
4 ### expected to be run as root
5
6 COMMAND=$0
7
8 #################### global vars
9 RUN_DIR=@RUNDIR@
10 DB_CONF_FILE=@DBDIR@/conf.db
11 DB_SCHEMA=@pkgdatadir@/vswitch.ovsschema
12 DB_LOG=@LOGDIR@/ovs-db.log
13 ##
14 DB_SOCKET=$RUN_DIR/db.sock
15 ##
16 SWITCH_LOG=@LOGDIR@/ovs-switch.log
17
18 #################### helper functions
19
20 function kill_pltap_ovs () {
21     killall pltap-ovs 2>/dev/null || :
22 }
23
24 function error {
25     echo "$@" >&2
26     exit 1
27 }
28
29 function get_params {
30     params=$1; shift
31     err_msg="$COMMAND $SUBCOMMAND $(echo $params | perl -pe 's/\S+/<$&>/g')"
32     for p in $(echo $params); do
33         [[ -z "$@" ]] && error "$err_msg"
34         pname=$(echo -n $p|perl -pe 's/\W/_/g')
35         eval $pname="$1"; shift
36     done
37     [[ -n "$@" ]] && error "$err_msg"
38 }
39
40 function is_switch_running {
41     ovs-appctl --target=ovs-vswitchd version >& /dev/null
42 }
43
44 function is_db_running {
45     ovs-appctl --target=ovsdb-server version >& /dev/null
46 }
47
48 function tapname () {
49     IP=$1; shift
50     echo $(ip addr show to "$IP/32" | perl -ne '/^\s*\d+:\s*([\w-]+):/ && print $1')
51 }
52     
53 function wait_server () {
54     pid_file=$1; shift
55     server_name=$1; shift
56     timeout=$1; shift
57
58     expire=$(($(date +%s) + $timeout))
59
60     ## wait for it to be up - xxx todo - could use a timeout of some kind
61     while [ ! -f "$pid_file" ]; do
62         echo "Waiting for $server_name to start... $(($expire - $(date +%s)))s left" >&2
63         sleep 1;
64         [ $(date +%s) -ge $expire ] && return 1
65     done
66     cat "$pid_file"
67 }
68
69 function wait_device () {
70     tapname=$1; shift
71     timeout=$1; shift
72
73     expire=$(($(date +%s) + $timeout))
74
75     while ! ip link show up | egrep -q "^[0-9]+: +$tapname:"; do
76         echo "Waiting for $tapname to come UP...$(($expire - $(date +%s)))s left" >&2
77         sleep 1
78         [ $(date +%s) -ge $expire ] && return 1
79     done
80     return 0
81 }
82
83 ######################################## startup
84 function start_db () {
85     get_params "" "$@"
86
87     ## init conf
88     conf_dir=$(dirname $DB_CONF_FILE)
89     [ -d $conf_dir ] || mkdir -p $conf_dir
90     [ -f $DB_CONF_FILE ] || ovsdb-tool create $DB_CONF_FILE $DB_SCHEMA
91
92     ## init run
93     [ -d $RUN_DIR ] || mkdir -p $RUN_DIR
94
95     ## check 
96     [ -f $DB_CONF_FILE ] || { echo "Could not initialize $DB_CONF_FILE - exiting" ; exit 1 ; }
97     [ -d $RUN_DIR ] || { echo "Could not initialize $RUN_DIR - exiting" ; exit 1 ; }
98
99     ## run the stuff
100     if [ ! -f "$RUN_DIR/ovsdb-server.pid" ]; then
101         ovsdb-server $DB_CONF_FILE \
102             --remote=punix:$DB_SOCKET \
103             --remote=db:Open_vSwitch,manager_options \
104             --private-key=db:SSL,private_key \
105             --certificate=db:SSL,certificate \
106             --bootstrap-ca-cert=db:SSL,ca_cert \
107             --pidfile \
108             --log-file=$DB_LOG \
109             --detach >& /dev/null
110     else
111         echo 'ovsdb-server appears to be running already, *not* starting'
112     fi
113     wait_server $RUN_DIR/ovsdb-server.pid ovsdb-server 30
114 }
115
116 function start_switch () {
117     get_params "" "$@"
118
119     # ensure ovsdb-server is running
120     is_db_running || { echo "ovsdb-server not running" >&2 ; exit 1 ; }
121
122     if [ ! -f "$RUN_DIR/ovs-vswitchd.pid" ] ; then
123         ovs-vswitchd \
124             --pidfile \
125             --log-file=$SWITCH_LOG \
126             --detach \
127             unix:$DB_SOCKET >& /dev/null
128     else
129         echo 'ovs-vswitchd appears to be running already, *not* starting'
130     fi
131     wait_server $RUN_DIR/ovs-vswitchd.pid ovs-vswitchd 30
132 }
133
134 function stop_db () { 
135     ovs-appctl --target=ovsdb-server exit || :
136 }
137
138 function stop_switch () { 
139     ovs-appctl --target=ovs-vswitchd exit || :
140 }
141
142 function status () {
143     pids=$(pgrep '^ovs')
144     [ -n "$pids" ] && ps $pids
145 }
146
147 function start () {
148     start_db
149     start_switch
150 }
151
152 function stop () {
153     stop_switch
154     stop_db
155 }
156
157 #################### create functions
158 function create_bridge () {
159     
160     get_params "bridge IP/PREFIX" "$@"
161
162     IP=${IP_PREFIX%/*}
163     PREFIX=${IP_PREFIX#*/}
164
165     # ensure ovs-vswitchd is running
166     is_switch_running || { echo "ovs-vswitchd not running" >&2 ; exit 1 ; }
167
168     set -e
169     ovs-vsctl --db=unix:$DB_SOCKET -- --may-exist add-br "$bridge" \
170         -- set bridge "$bridge" datapath_type=planetlab \
171         -- set interface "$bridge" options:local_ip="$IP" option:local_netmask="$PREFIX"
172     ovs-appctl netdev-pltap/get-tapname "$bridge"
173 }
174
175 function create_port () {
176
177     get_params "bridge port" "$@"
178
179     # ensure ovs-vswitchd is running
180     is_switch_running || { echo "ovs-vswitchd not running" >&2 ; exit 1 ; }
181
182     set -e
183     ovs-vsctl --db=unix:$DB_SOCKET -- --may-exist add-port "$bridge" "$port" -- set interface "$port" type=tunnel
184     ovs-appctl --target=ovs-vswitchd netdev-tunnel/get-port "$port"
185 }
186
187 function set_remote_endpoint () {
188
189     get_params "local_port remote_ip remote_UDP_port" "$@"
190
191     # ensure ovs-vswitchd is running
192     is_switch_running || { echo "ovs-vswitchd not running" >&2 ; exit 1 ; }
193
194     set -e
195     ovs-vsctl --db=unix:$DB_SOCKET set interface $local_port \
196         options:remote_ip=$remote_ip \
197         options:remote_port=$remote_UDP_port
198 }
199
200 function set_controller () {
201
202     get_params "bridge_name controller" "$@"
203
204     # ensure ovs-vswitchd is running
205     is_switch_running || { echo "ovs-vswitchd not running" >&2 ; exit 1 ; }
206
207     set -e
208     ovs-vsctl --db=unix:$DB_SOCKET set-controller "$bridge_name" "$controller"
209 }
210
211 #################### del functions
212 function del_bridge () {
213     
214     get_params "bridge_name" "$@"
215
216     W=
217     if ! is_switch_running; then
218         # we can delete the bridge even if ovs-vswitchd is not running,
219         # but we need a running ovsdb-server
220         is_db_running || { echo "ovsdb-server not running" >&2; exit 1; }
221         W="--no-wait"
222     fi
223
224     ovs-vsctl --db=unix:$DB_SOCKET $W -- --if-exists del-br $bridge_name
225 }
226
227 function del_port () {
228     
229     get_params "port" "$@"
230
231     W=
232     if ! is_switch_running; then
233         # we can delete the port even if ovs-vswitchd is not running,
234         # but we need a running ovsdb-server
235         is_db_running || { echo "ovsdb-server not running" >&2; exit 1; }
236         W="--no-wait"
237     fi
238
239     ovs-vsctl --db=unix:$DB_SOCKET $W -- --if-exists del-port "$port"
240 }
241
242 function show () {
243
244     get_params "" "$@"
245
246     is_db_running || { echo "ovsdb-server not running" >&2; exit 1; }
247
248     ovs-vsctl --db=unix:$DB_SOCKET show
249 }
250
251 ####################
252 SUPPORTED_SUBCOMMANDS="start stop status 
253 start_db stop_db start_switch stop_switch
254 create_bridge create_port del_bridge del_port
255 show set_remote_endpoint"
256
257 function main () {
258         message="Usage: $COMMAND <subcommand> ...
259 Supported subcommands are (dash or underscore is the same):
260 $SUPPORTED_SUBCOMMANDS"
261         [[ -z "$@" ]] && error "$message"
262
263         SUBCOMMAND=$1; shift
264         # support dashes instead of underscores
265         SUBCOMMAND=$(echo $SUBCOMMAND | sed -e s,-,_,g)
266         found=""
267         for supported in $SUPPORTED_SUBCOMMANDS; do [ "$SUBCOMMAND" = "$supported" ] && found=yes; done
268
269         [ -z "$found" ] && error $message
270
271         $SUBCOMMAND "$@"
272 }
273
274 main "$@"