blob: 4f06b2fb4f0017f3d70652003cd6cb0173df157e [file] [log] [blame]
A R Karthick41adfce2016-06-10 09:51:25 -07001#
Chetan Gaonkercfcce782016-05-10 10:10:42 -07002# Copyright 2016-present Ciena Corporation
3#
4# Licensed under the Apache License, Version 2.0 (the "License");
5# you may not use this file except in compliance with the License.
6# You may obtain a copy of the License at
A R Karthick41adfce2016-06-10 09:51:25 -07007#
Chetan Gaonkercfcce782016-05-10 10:10:42 -07008# http://www.apache.org/licenses/LICENSE-2.0
A R Karthick41adfce2016-06-10 09:51:25 -07009#
Chetan Gaonkercfcce782016-05-10 10:10:42 -070010# Unless required by applicable law or agreed to in writing, software
11# distributed under the License is distributed on an "AS IS" BASIS,
12# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13# See the License for the specific language governing permissions and
14# limitations under the License.
15#
Chetan Gaonker3533faa2016-04-25 17:50:14 -070016import os,time
17import io
18import json
A R Karthickd44cea12016-07-20 12:16:41 -070019import yaml
Chetan Gaonker3533faa2016-04-25 17:50:14 -070020from pyroute2 import IPRoute
21from itertools import chain
22from nsenter import Namespace
23from docker import Client
24from shutil import copy
A.R Karthick95d044e2016-06-10 18:44:36 -070025from OnosCtrl import OnosCtrl
Chetan Gaonker3533faa2016-04-25 17:50:14 -070026
27class docker_netns(object):
28
29 dckr = Client()
30 def __init__(self, name):
31 pid = int(self.dckr.inspect_container(name)['State']['Pid'])
32 if pid == 0:
33 raise Exception('no container named {0}'.format(name))
34 self.pid = pid
35
36 def __enter__(self):
37 pid = self.pid
38 if not os.path.exists('/var/run/netns'):
39 os.mkdir('/var/run/netns')
40 os.symlink('/proc/{0}/ns/net'.format(pid), '/var/run/netns/{0}'.format(pid))
41 return str(pid)
42
43 def __exit__(self, type, value, traceback):
44 pid = self.pid
45 os.unlink('/var/run/netns/{0}'.format(pid))
46
47flatten = lambda l: chain.from_iterable(l)
48
49class Container(object):
50 dckr = Client()
51 def __init__(self, name, image, tag = 'latest', command = 'bash', quagga_config = None):
52 self.name = name
53 self.image = image
54 self.tag = tag
A R Karthickd44cea12016-07-20 12:16:41 -070055 if tag:
56 self.image_name = image + ':' + tag
57 else:
58 self.image_name = image
Chetan Gaonker3533faa2016-04-25 17:50:14 -070059 self.id = None
60 self.command = command
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -070061 self.quagga_config = quagga_config
Chetan Gaonker3533faa2016-04-25 17:50:14 -070062
63 @classmethod
64 def build_image(cls, dockerfile, tag, force=True, nocache=False):
65 f = io.BytesIO(dockerfile.encode('utf-8'))
66 if force or not cls.image_exists(tag):
67 print('Build {0}...'.format(tag))
68 for line in cls.dckr.build(fileobj=f, rm=True, tag=tag, decode=True, nocache=nocache):
69 if 'stream' in line:
70 print(line['stream'].strip())
71
72 @classmethod
73 def image_exists(cls, name):
74 return name in [ctn['RepoTags'][0] for ctn in cls.dckr.images()]
75
76 @classmethod
77 def create_host_config(cls, port_list = None, host_guest_map = None, privileged = False):
78 port_bindings = None
79 binds = None
80 if port_list:
81 port_bindings = {}
82 for p in port_list:
83 port_bindings[str(p)] = str(p)
84
85 if host_guest_map:
86 binds = []
87 for h, g in host_guest_map:
88 binds.append('{0}:{1}'.format(h, g))
89
90 return cls.dckr.create_host_config(binds = binds, port_bindings = port_bindings, privileged = privileged)
91
92 @classmethod
93 def cleanup(cls, image):
A R Karthick09b1f4e2016-05-12 14:31:50 -070094 cnt_list = filter(lambda c: c['Image'] == image, cls.dckr.containers(all=True))
Chetan Gaonker3533faa2016-04-25 17:50:14 -070095 for cnt in cnt_list:
96 print('Cleaning container %s' %cnt['Id'])
A.R Karthick95d044e2016-06-10 18:44:36 -070097 if cnt.has_key('State') and cnt['State'] == 'running':
A R Karthick09b1f4e2016-05-12 14:31:50 -070098 cls.dckr.kill(cnt['Id'])
Chetan Gaonker3533faa2016-04-25 17:50:14 -070099 cls.dckr.remove_container(cnt['Id'], force=True)
100
101 @classmethod
102 def remove_container(cls, name, force=True):
103 try:
104 cls.dckr.remove_container(name, force = force)
105 except: pass
106
107 def exists(self):
108 return '/{0}'.format(self.name) in list(flatten(n['Names'] for n in self.dckr.containers()))
109
110 def img_exists(self):
111 return self.image_name in [ctn['RepoTags'][0] for ctn in self.dckr.images()]
112
113 def ip(self):
114 cnt_list = filter(lambda c: c['Image'] == self.image_name, self.dckr.containers())
115 cnt_settings = cnt_list.pop()
116 return cnt_settings['NetworkSettings']['Networks']['bridge']['IPAddress']
117
118 def kill(self, remove = True):
119 self.dckr.kill(self.name)
120 self.dckr.remove_container(self.name, force=True)
121
A R Karthick41adfce2016-06-10 09:51:25 -0700122 def start(self, rm = True, ports = None, volumes = None, host_config = None,
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700123 environment = None, tty = False, stdin_open = True):
124
125 if rm and self.exists():
126 print('Removing container:', self.name)
127 self.dckr.remove_container(self.name, force=True)
128
A R Karthick41adfce2016-06-10 09:51:25 -0700129 ctn = self.dckr.create_container(image=self.image_name, ports = ports, command=self.command,
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700130 detach=True, name=self.name,
A R Karthick41adfce2016-06-10 09:51:25 -0700131 environment = environment,
132 volumes = volumes,
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700133 host_config = host_config, stdin_open=stdin_open, tty = tty)
134 self.dckr.start(container=self.name)
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -0700135 if self.quagga_config:
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700136 self.connect_to_br()
137 self.id = ctn['Id']
138 return ctn
139
140 def connect_to_br(self):
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -0700141 index = 0
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700142 with docker_netns(self.name) as pid:
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -0700143 for quagga_config in self.quagga_config:
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700144 ip = IPRoute()
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -0700145 br = ip.link_lookup(ifname=quagga_config['bridge'])
146 if len(br) == 0:
Chetan Gaonker5a0fda32016-05-10 14:09:07 -0700147 ip.link_create(ifname=quagga_config['bridge'], kind='bridge')
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -0700148 br = ip.link_lookup(ifname=quagga_config['bridge'])
149 br = br[0]
150 ip.link('set', index=br, state='up')
151 ifname = '{0}-{1}'.format(self.name, index)
152 ifs = ip.link_lookup(ifname=ifname)
153 if len(ifs) > 0:
154 ip.link_remove(ifs[0])
155 peer_ifname = '{0}-{1}'.format(pid, index)
Chetan Gaonker5a0fda32016-05-10 14:09:07 -0700156 ip.link_create(ifname=ifname, kind='veth', peer=peer_ifname)
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -0700157 host = ip.link_lookup(ifname=ifname)[0]
158 ip.link('set', index=host, master=br)
159 ip.link('set', index=host, state='up')
160 guest = ip.link_lookup(ifname=peer_ifname)[0]
161 ip.link('set', index=guest, net_ns_fd=pid)
162 with Namespace(pid, 'net'):
163 ip = IPRoute()
164 ip.link('set', index=guest, ifname='eth{}'.format(index+1))
165 ip.addr('add', index=guest, address=quagga_config['ip'], mask=quagga_config['mask'])
166 ip.link('set', index=guest, state='up')
167 index += 1
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700168
169 def execute(self, cmd, tty = True, stream = False, shell = False):
170 res = 0
171 if type(cmd) == str:
172 cmds = (cmd,)
173 else:
174 cmds = cmd
175 if shell:
176 for c in cmds:
177 res += os.system('docker exec {0} {1}'.format(self.name, c))
178 return res
179 for c in cmds:
180 i = self.dckr.exec_create(container=self.name, cmd=c, tty = tty, privileged = True)
181 self.dckr.exec_start(i['Id'], stream = stream, detach=True)
182 result = self.dckr.exec_inspect(i['Id'])
183 res += 0 if result['ExitCode'] == None else result['ExitCode']
184 return res
185
Chetan Gaonker462d9fa2016-05-03 16:39:10 -0700186def get_mem():
187 with open('/proc/meminfo', 'r') as fd:
188 meminfo = fd.readlines()
189 mem = 0
190 for m in meminfo:
191 if m.startswith('MemTotal:') or m.startswith('SwapTotal:'):
192 mem += int(m.split(':')[1].strip().split()[0])
193
Chetan Gaonkerc0421e82016-05-04 17:23:08 -0700194 mem = max(mem/1024/1024/2, 1)
Chetan Gaonker6d0a7b02016-05-03 16:57:28 -0700195 mem = min(mem, 16)
Chetan Gaonker462d9fa2016-05-03 16:39:10 -0700196 return str(mem) + 'G'
197
A R Karthickd44cea12016-07-20 12:16:41 -0700198class OnosCord(Container):
199 """Use this when running the cord tester agent on the onos compute node"""
200 onos_cord_dir = os.path.join(os.getenv('HOME'), 'cord-tester-cord')
201 onos_config_dir_guest = '/root/onos/config'
202 onos_config_dir = os.path.join(onos_cord_dir, 'config')
203 docker_yaml = os.path.join(onos_cord_dir, 'docker-compose.yml')
204
A R Karthickbd9b8a32016-07-21 09:56:45 -0700205 def __init__(self, onos_ip, conf, boot_delay = 60):
206 self.onos_ip = onos_ip
A R Karthickd44cea12016-07-20 12:16:41 -0700207 self.cord_conf_dir = conf
A R Karthickbd9b8a32016-07-21 09:56:45 -0700208 self.boot_delay = boot_delay
A R Karthickd44cea12016-07-20 12:16:41 -0700209 if os.access(self.cord_conf_dir, os.F_OK) and not os.access(self.onos_cord_dir, os.F_OK):
210 os.mkdir(self.onos_cord_dir)
211 os.mkdir(self.onos_config_dir)
212 ##copy the config file from cord-tester-config
213 cmd = 'cp {}/* {}'.format(self.cord_conf_dir, self.onos_cord_dir)
214 os.system(cmd)
215
216 ##update the docker yaml with the config volume
217 with open(self.docker_yaml, 'r') as f:
218 yaml_config = yaml.load(f)
219 image = yaml_config['services'].keys()[0]
220 name = 'cordtestercord_{}_1'.format(image)
221 volumes = yaml_config['services'][image]['volumes']
222 config_volumes = filter(lambda e: e.find(self.onos_config_dir_guest) >= 0, volumes)
223 if not config_volumes:
224 config_volume = '{}:{}'.format(self.onos_config_dir, self.onos_config_dir_guest)
225 volumes.append(config_volume)
226 docker_yaml_changed = '{}-changed'.format(self.docker_yaml)
227 with open(docker_yaml_changed, 'w') as wf:
228 yaml.dump(yaml_config, wf)
229
230 os.rename(docker_yaml_changed, self.docker_yaml)
231 self.volumes = volumes
232
233 super(OnosCord, self).__init__(name, image, tag = '')
234 cord_conf_dir_basename = os.path.basename(self.cord_conf_dir.replace('-', ''))
235 self.xos_onos_name = '{}_{}_1'.format(cord_conf_dir_basename, image)
236 ##Create an container instance of xos onos
237 self.xos_onos = Container(self.xos_onos_name, image, tag = '')
238
239 def start(self, restart = False, network_cfg = None):
240 if restart is True:
241 if self.exists():
242 ##Kill the existing instance
243 print('Killing container %s' %self.name)
244 self.kill()
245 if self.xos_onos.exists():
246 print('Killing container %s' %self.xos_onos.name)
247 self.xos_onos.kill()
248
249 if network_cfg is not None:
250 json_data = json.dumps(network_cfg, indent=4)
251 with open('{}/network-cfg.json'.format(self.onos_config_dir), 'w') as f:
252 f.write(json_data)
253
254 #start the container using docker-compose
255 cmd = 'cd {} && docker-compose up -d'.format(self.onos_cord_dir)
256 os.system(cmd)
A R Karthickbd9b8a32016-07-21 09:56:45 -0700257 #Delay to make sure ONOS fully boots
258 time.sleep(self.boot_delay)
259 Onos.install_cord_apps(onos_ip = self.onos_ip)
A R Karthickd44cea12016-07-20 12:16:41 -0700260
261 def build_image(self):
262 build_cmd = 'cd {} && docker-compose build'.format(self.onos_cord_dir)
263 os.system(build_cmd)
264
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700265class Onos(Container):
266
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -0700267 quagga_config = ( { 'bridge' : 'quagga-br', 'ip': '10.10.0.4', 'mask' : 16 }, )
Chetan Gaonker462d9fa2016-05-03 16:39:10 -0700268 SYSTEM_MEMORY = (get_mem(),) * 2
269 JAVA_OPTS = '-Xms{} -Xmx{} -XX:+UseConcMarkSweepGC -XX:+CMSIncrementalMode'.format(*SYSTEM_MEMORY)#-XX:+PrintGCDetails -XX:+PrintGCTimeStamps'
A.R Karthick95d044e2016-06-10 18:44:36 -0700270 env = { 'ONOS_APPS' : 'drivers,openflow,proxyarp,vrouter', 'JAVA_OPTS' : JAVA_OPTS }
271 onos_cord_apps = ( ('cord-config', '1.0-SNAPSHOT'),
272 ('aaa', '1.0-SNAPSHOT'),
273 ('igmp', '1.0-SNAPSHOT'),
A R Karthickbd9b8a32016-07-21 09:56:45 -0700274 ('vtn', '1.0-SNAPSHOT'),
A.R Karthick95d044e2016-06-10 18:44:36 -0700275 )
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700276 ports = [ 8181, 8101, 9876, 6653, 6633, 2000, 2620 ]
277 host_config_dir = os.path.join(os.path.dirname(os.path.realpath(__file__)), '..', 'setup/onos-config')
278 guest_config_dir = '/root/onos/config'
A.R Karthick95d044e2016-06-10 18:44:36 -0700279 cord_apps_dir = os.path.join(os.path.dirname(os.path.realpath(__file__)), '..', 'apps')
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700280 host_guest_map = ( (host_config_dir, guest_config_dir), )
Chetan Gaonker503032a2016-05-12 12:06:29 -0700281 NAME = 'cord-onos'
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700282
A R Karthick41adfce2016-06-10 09:51:25 -0700283 def __init__(self, name = NAME, image = 'onosproject/onos', tag = 'latest',
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700284 boot_delay = 60, restart = False, network_cfg = None):
285 if restart is True:
286 ##Find the right image to restart
287 running_image = filter(lambda c: c['Names'][0] == '/{}'.format(name), self.dckr.containers())
288 if running_image:
289 image_name = running_image[0]['Image']
290 try:
291 image = image_name.split(':')[0]
292 tag = image_name.split(':')[1]
293 except: pass
294
295 super(Onos, self).__init__(name, image, tag = tag, quagga_config = self.quagga_config)
296 if restart is True and self.exists():
297 self.kill()
298 if not self.exists():
299 self.remove_container(name, force=True)
300 host_config = self.create_host_config(port_list = self.ports,
301 host_guest_map = self.host_guest_map)
302 volumes = []
303 for _,g in self.host_guest_map:
304 volumes.append(g)
305 if network_cfg is not None:
A R Karthick81acbff2016-06-17 14:45:16 -0700306 json_data = json.dumps(network_cfg, indent=4)
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700307 with open('{}/network-cfg.json'.format(self.host_config_dir), 'w') as f:
308 f.write(json_data)
309 print('Starting ONOS container %s' %self.name)
A R Karthick41adfce2016-06-10 09:51:25 -0700310 self.start(ports = self.ports, environment = self.env,
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700311 host_config = host_config, volumes = volumes, tty = True)
312 print('Waiting %d seconds for ONOS to boot' %(boot_delay))
313 time.sleep(boot_delay)
314
A R Karthickd44cea12016-07-20 12:16:41 -0700315 self.install_cord_apps()
316
A.R Karthick95d044e2016-06-10 18:44:36 -0700317 @classmethod
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700318 def install_cord_apps(cls, onos_ip = None):
A.R Karthick95d044e2016-06-10 18:44:36 -0700319 for app, version in cls.onos_cord_apps:
320 app_file = '{}/{}-{}.oar'.format(cls.cord_apps_dir, app, version)
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700321 ok, code = OnosCtrl.install_app(app_file, onos_ip = onos_ip)
A.R Karthick95d044e2016-06-10 18:44:36 -0700322 ##app already installed (conflicts)
323 if code in [ 409 ]:
324 ok = True
325 print('ONOS app %s, version %s %s' %(app, version, 'installed' if ok else 'failed to install'))
326 time.sleep(2)
327
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700328class Radius(Container):
329 ports = [ 1812, 1813 ]
A R Karthick41adfce2016-06-10 09:51:25 -0700330 env = {'TIMEZONE':'America/Los_Angeles',
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700331 'DEBUG': 'true', 'cert_password':'whatever', 'primary_shared_secret':'radius_password'
332 }
Chetan Gaonker7f4bf742016-05-04 15:56:08 -0700333 host_db_dir = os.path.join(os.path.dirname(os.path.realpath(__file__)), '..', 'setup/radius-config/db')
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700334 guest_db_dir = os.path.join(os.path.sep, 'opt', 'db')
Chetan Gaonker7f4bf742016-05-04 15:56:08 -0700335 host_config_dir = os.path.join(os.path.dirname(os.path.realpath(__file__)), '..', 'setup/radius-config/freeradius')
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700336 guest_config_dir = os.path.join(os.path.sep, 'etc', 'freeradius')
Chetan Gaonker7f4bf742016-05-04 15:56:08 -0700337 start_command = os.path.join(guest_config_dir, 'start-radius.py')
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700338 host_guest_map = ( (host_db_dir, guest_db_dir),
339 (host_config_dir, guest_config_dir)
340 )
Chetan Gaonker503032a2016-05-12 12:06:29 -0700341 IMAGE = 'cord-test/radius'
342 NAME = 'cord-radius'
343
344 def __init__(self, name = NAME, image = IMAGE, tag = 'latest',
345 boot_delay = 10, restart = False, update = False):
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700346 super(Radius, self).__init__(name, image, tag = tag, command = self.start_command)
Chetan Gaonker503032a2016-05-12 12:06:29 -0700347 if update is True or not self.img_exists():
Chetan Gaonker7f4bf742016-05-04 15:56:08 -0700348 self.build_image(image)
349 if restart is True and self.exists():
350 self.kill()
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700351 if not self.exists():
352 self.remove_container(name, force=True)
353 host_config = self.create_host_config(port_list = self.ports,
354 host_guest_map = self.host_guest_map)
355 volumes = []
356 for _,g in self.host_guest_map:
357 volumes.append(g)
A R Karthick41adfce2016-06-10 09:51:25 -0700358 self.start(ports = self.ports, environment = self.env,
359 volumes = volumes,
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700360 host_config = host_config, tty = True)
Chetan Gaonker7f4bf742016-05-04 15:56:08 -0700361 time.sleep(boot_delay)
362
363 @classmethod
364 def build_image(cls, image):
365 print('Building Radius image %s' %image)
366 dockerfile = '''
367FROM hbouvier/docker-radius
368MAINTAINER chetan@ciena.com
369LABEL RUN docker pull hbouvier/docker-radius
370LABEL RUN docker run -it --name cord-radius hbouvier/docker-radius
A R Karthickc762df42016-05-25 10:09:21 -0700371RUN apt-get update && \
372 apt-get -y install python python-pexpect strace
Chetan Gaonker7f4bf742016-05-04 15:56:08 -0700373WORKDIR /root
374CMD ["/etc/freeradius/start-radius.py"]
375'''
376 super(Radius, cls).build_image(dockerfile, image)
377 print('Done building image %s' %image)
Chetan Gaonker3533faa2016-04-25 17:50:14 -0700378
Chetan Gaonker6cf6e472016-04-26 14:41:51 -0700379class Quagga(Container):
A R Karthick41adfce2016-06-10 09:51:25 -0700380 quagga_config = ( { 'bridge' : 'quagga-br', 'ip': '10.10.0.3', 'mask' : 16 },
Chetan Gaonker8e25e1b2016-05-02 13:42:21 -0700381 { 'bridge' : 'quagga-br', 'ip': '192.168.10.3', 'mask': 16 },
382 )
Chetan Gaonker6cf6e472016-04-26 14:41:51 -0700383 ports = [ 179, 2601, 2602, 2603, 2604, 2605, 2606 ]
384 host_quagga_config = os.path.join(os.path.dirname(os.path.realpath(__file__)), '..', 'setup/quagga-config')
385 guest_quagga_config = '/root/config'
386 quagga_config_file = os.path.join(guest_quagga_config, 'testrib.conf')
387 host_guest_map = ( (host_quagga_config, guest_quagga_config), )
Chetan Gaonker503032a2016-05-12 12:06:29 -0700388 IMAGE = 'cord-test/quagga'
389 NAME = 'cord-quagga'
390
A R Karthick41adfce2016-06-10 09:51:25 -0700391 def __init__(self, name = NAME, image = IMAGE, tag = 'latest',
Chetan Gaonker503032a2016-05-12 12:06:29 -0700392 boot_delay = 15, restart = False, config_file = quagga_config_file, update = False):
Chetan Gaonker6cf6e472016-04-26 14:41:51 -0700393 super(Quagga, self).__init__(name, image, tag = tag, quagga_config = self.quagga_config)
Chetan Gaonker503032a2016-05-12 12:06:29 -0700394 if update is True or not self.img_exists():
Chetan Gaonker6cf6e472016-04-26 14:41:51 -0700395 self.build_image(image)
396 if restart is True and self.exists():
397 self.kill()
398 if not self.exists():
399 self.remove_container(name, force=True)
A R Karthick41adfce2016-06-10 09:51:25 -0700400 host_config = self.create_host_config(port_list = self.ports,
401 host_guest_map = self.host_guest_map,
Chetan Gaonker6cf6e472016-04-26 14:41:51 -0700402 privileged = True)
403 volumes = []
404 for _,g in self.host_guest_map:
405 volumes.append(g)
406 self.start(ports = self.ports,
A R Karthick41adfce2016-06-10 09:51:25 -0700407 host_config = host_config,
Chetan Gaonker6cf6e472016-04-26 14:41:51 -0700408 volumes = volumes, tty = True)
409 print('Starting Quagga on container %s' %self.name)
410 self.execute('{0}/start.sh {1}'.format(self.guest_quagga_config, config_file))
411 time.sleep(boot_delay)
412
413 @classmethod
414 def build_image(cls, image):
Chetan Gaonker2a6601b2016-05-02 17:28:26 -0700415 onos_quagga_ip = Onos.quagga_config[0]['ip']
Chetan Gaonker6cf6e472016-04-26 14:41:51 -0700416 print('Building Quagga image %s' %image)
417 dockerfile = '''
A R Karthick41adfce2016-06-10 09:51:25 -0700418FROM ubuntu:14.04
419MAINTAINER chetan@ciena.com
Chetan Gaonker6cf6e472016-04-26 14:41:51 -0700420WORKDIR /root
421RUN useradd -M quagga
422RUN mkdir /var/log/quagga && chown quagga:quagga /var/log/quagga
423RUN mkdir /var/run/quagga && chown quagga:quagga /var/run/quagga
424RUN apt-get update && apt-get install -qy git autoconf libtool gawk make telnet libreadline6-dev
425RUN git clone git://git.sv.gnu.org/quagga.git quagga && \
426(cd quagga && git checkout HEAD && ./bootstrap.sh && \
427sed -i -r 's,htonl.*?\(INADDR_LOOPBACK\),inet_addr\("{0}"\),g' zebra/zebra_fpm.c && \
428./configure --enable-fpm --disable-doc --localstatedir=/var/run/quagga && make && make install)
429RUN ldconfig
430'''.format(onos_quagga_ip)
431 super(Quagga, cls).build_image(dockerfile, image)
432 print('Done building image %s' %image)
A R Karthick81acbff2016-06-17 14:45:16 -0700433
434def reinitContainerClients():
435 docker_netns.dckr = Client()
436 Container.dckr = Client()