-
Notifications
You must be signed in to change notification settings - Fork 6
/
openflow
executable file
·388 lines (345 loc) · 15.6 KB
/
openflow
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
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
#!/usr/bin/env python
# -*- coding: utf-8 -*-
# PYTHON_ARGCOMPLETE_OK
##
# Copyright 2015 Telefónica Investigación y Desarrollo, S.A.U.
# This file is part of openmano
# All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
#
# For those usages not covered by the Apache License, Version 2.0 please
# contact with: [email protected]
##
'''
This program is useful to interact directly with Openflow Controllers
to clear rules, add and delete rules, list rules, etc.
'''
__author__="Gerardo Garcia, Alfonso Tierno, Pablo Montes"
__date__ ="$09-oct-2014 09:09:48$"
#import time
import os
import sys
import argparse
import argcomplete
import imp
import yaml
import requests
import logging
from openflow_thread import change_db2of, FlowBadFormat
def of_switches(args):
r,c = ofconnector.get_of_switches()
if r<0:
print c
return r
else:
for s in c:
print " %s %s" % (s[0], s[1])
return 0
def of_list(args):
r,c = ofconnector.get_of_rules(not args.no_translate)
if r<0:
print c
return r
if args.verbose > 0:
print yaml.safe_dump(c, indent=4, default_flow_style=False)
return 0
print " switch priority name ingress_port dst_mac vlan_id actions"
for name,rule in c.iteritems():
action_list=[]
for action in rule["actions"]:
action_list.append(action[0]+"="+str(action[1]))
if "vlan_id" in rule:
vlan=str(rule["vlan_id"])
else:
vlan="any"
print "%s %s %s %s %s %s %s" % \
(rule["switch"], str(rule["priority"]).ljust(6), name.ljust(40), rule["ingress_port"].ljust(8), \
rule.get("dst_mac","any").ljust(18), vlan.ljust(4), ",".join(action_list) )
return 0
def of_clear(args):
if not args.force:
r = raw_input("Clear all Openflow rules (y/N)? ")
if not (len(r)>0 and r[0].lower()=="y"):
return 0
r,c = ofconnector.clear_all_flows()
if r<0:
print c
return r
return 0
def of_port_list(args):
r,c = ofconnector.obtain_port_correspondence()
if r<0:
print c
return r
yaml.safe_dump({"ports": c}, sys.stdout, indent=2, default_flow_style=False)
#def of_dump(args):
# args.verbose = 3
# args.no_translate=False
# of_list(args)
return 0
def of_reinstall(args):
try:
URLrequest = "http://%s:%s/openvim/networks/all/openflow" %(vim_host, vim_admin_port)
print URLrequest
openvim_response = requests.put(URLrequest)
print openvim_response.text
return 0
except requests.exceptions.RequestException as e:
print " Exception GET at '"+URLrequest+"' " + str(e)
return -1
def of_install(args):
line_number=1
try:
f = open(args.file, "r")
text = f.read()
f.close()
lines=text.split("\n")
heads=lines[0].split()
for line in lines[1:]:
line_number += 1
rule={}
items= line.split()
if len(items)==0 or items[0][0]=="#": #empty line or commented
continue
for i in range(0,len(items)):
rule[ heads[i] ] = items[i]
if rule["vlan_id"] == "any":
del rule["vlan_id"]
if rule["dst_mac"] == "any":
del rule["dst_mac"]
if 'priority' in rule and (rule['priority']==None or rule['priority']=="None" ):
del rule['priority']
try:
change_db2of(rule)
except FlowBadFormat as e:
print "Format error at line %d: %s" % (line_number, str(e))
continue
r,c = ofconnector.new_flow(rule)
if r<0:
error="ERROR: "+c
else:
error="OK"
print "%s %s %s input=%s dst_mac=%s vlan_id=%s %s" % \
(rule["switch"], str(rule.get("priority")).ljust(6), rule["name"].ljust(20), rule["ingress_port"].ljust(3), \
rule.get("dst_mac","any").ljust(18), rule.get("vlan_id","any").ljust(4), error )
return 0
except IOError as e:
print " Error opening file '" + args.file + "': " + e.args[1]
return -1
except yaml.YAMLError as exc:
error_pos = ""
if hasattr(exc, 'problem_mark'):
mark = exc.problem_mark
error_pos = " at position: (%s:%s)" % (mark.line+1, mark.column+1)
print " Error yaml/json format error at " + error_pos
return -1
def of_add(args):
if args.act==None and args.actions==None:
print "openflow add: error: one of the arguments --actions or [--setvlan,--stripvlan],--out is required"
return -1
elif args.act!=None and args.actions!=None:
print "openflow add: error: Use either --actions option or [--setvlan,--stripvlan],--out options; but not both"
return -1
rule={"name":args.name, "priority":args.priority,
"ingress_port": args.inport
}
if args.matchvlan:
rule["vlan_id"] = args.matchvlan
if args.matchmac:
rule["dst_mac"] = args.matchmac
if args.actions:
rule["actions"] = args.actions
try:
change_db2of(rule)
except FlowBadFormat as e:
print "Format error at --actions: '%s' Expected 'vlan=<None/vlan_id>,out=<egress_port>,...'" % str(e)
return -1
elif args.act:
rule["actions"]=[]
error_msj = "openflow add: error: --setvlan,--stripvlan options must be followed by an --out option"
previous_option_vlan=False # indicates if the previous option was a set or strip vlan to avoid consecutive ones and to force an out options afterwards
for action in args.act:
if action==None or type(action)==int:
if previous_option_vlan: #consecutive vlan options
print error_msj
return -1
previous_option_vlan=True
rule["actions"].append( ("vlan", action) )
else:
previous_option_vlan=False
rule["actions"].append( ("out", action) )
if previous_option_vlan:
print error_msj
return -1
#print rule
#return
r,c = ofconnector.new_flow(rule)
if r<0:
print c
return -1
return 0
def of_delete(args):
if not args.force:
r = raw_input("Clear rule %s (y/N)? " %(args.name))
if not (len(r)>0 and r[0].lower()=="y"):
return 0
r,c = ofconnector.del_flow(args.name)
if r<0:
print c
return -1
return 0
def config(args):
print "OPENVIM_HOST: %s" %(vim_host)
print "OPENVIM_ADMIN_PORT: %s" %(vim_admin_port)
print "OF_CONTROLLER_TYPE: %s" %(of_controller_type)
if of_controller_module or (of_controller_type!="floodlight" and of_controller_type!="opendaylight"):
print "OF_CONTROLLER_MODULE: %s" %(of_controller_module)
print "OF_CONTROLLER_USER: %s" %(of_controller_user)
print "OF_CONTROLLER_PASSWORD: %s" %(of_controller_password)
#print "OF_CONTROLLER_VERSION: %s" %(of_controller_version)
print "OF_CONTROLLER_IP: %s" %(of_controller_ip)
print "OF_CONTROLLER_PORT: %s" %(of_controller_port)
print "OF_CONTROLLER_DPID: %s" %(of_controller_dpid)
return
version="0.8"
global vim_host
global vim_admin_port
global of_controller_type
global of_controller_user
global of_controller_password
global of_controller_ip
global of_controller_port
global of_controller_dpid
global of_controller_module
global ofconnector
if __name__=="__main__":
#print "test_ofconnector version", version, "Jul 2015"
#print "(c) Copyright Telefonica"
vim_host = os.getenv('OPENVIM_HOST',"localhost")
vim_admin_port = os.getenv('OPENVIM_ADMIN_PORT',"8085")
of_controller_type = os.getenv('OF_CONTROLLER_TYPE',"floodlight")
of_controller_user = os.getenv('OF_CONTROLLER_USER',None)
of_controller_password = os.getenv('OF_CONTROLLER_PASSWORD',None)
#of_controller_version = os.getenv('OF_CONTROLLER_VERSION',"0.90")
of_controller_ip = os.getenv('OF_CONTROLLER_IP',"localhost")
of_controller_port = os.getenv('OF_CONTROLLER_PORT',"7070")
of_controller_dpid = os.getenv('OF_CONTROLLER_DPID','00:01:02:03:e4:05:e6:07')
of_controller_module = os.getenv('OF_CONTROLLER_MODULE',None)
main_parser = argparse.ArgumentParser(description='User program to interact with Openflow controller')
main_parser.add_argument('--version', action='version', version='%(prog)s ' + version )
#main_parser = argparse.ArgumentParser()
subparsers = main_parser.add_subparsers(help='commands')
config_parser = subparsers.add_parser('config', help="prints configuration values")
config_parser.set_defaults(func=config)
add_parser = subparsers.add_parser('add', help="adds an openflow rule")
add_parser.add_argument('--verbose', '-v', action='count')
add_parser.add_argument("name", action="store", help="name of the rule")
add_parser.add_argument("--inport", required=True, action="store", type=str, help="match rule: ingress-port")
add_parser.add_argument("--actions", action="store", type=str, help="action with the format: vlan=<None/vlan-id>,out=<egress-port>,...")
add_parser.add_argument("--priority", action="store", type=int, help="rule priority")
add_parser.add_argument("--matchmac", action="store", help="match rule: mac address")
add_parser.add_argument("--matchvlan", action="store", type=int, help="match rule: vlan id")
add_parser.add_argument("--stripvlan", action="append_const", dest="act", const=None, help="alternative to --actions. Use before --out to strip vlan")
add_parser.add_argument("--setvlan", action="append", dest="act", type=int, help="alternative to --actions. Use before --out to set vlan")
add_parser.add_argument("--out", action="append", dest="act", type=str, help="alternative to --actions. out=<egress-port> can be used several times")
add_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
add_parser.set_defaults(func=of_add)
delete_parser = subparsers.add_parser('delete', help="delete an openflow rule")
delete_parser.add_argument('--verbose', '-v', action='count')
delete_parser.add_argument("-f", "--force", action="store_true", help="force deletion without asking")
delete_parser.add_argument("name", action="store", help="name of the rule to be deleted")
delete_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
delete_parser.set_defaults(func=of_delete)
switches_parser = subparsers.add_parser('switches', help="list all switches controlled by the OFC")
switches_parser.add_argument('--verbose', '-v', action='count')
switches_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
switches_parser.set_defaults(func=of_switches)
list_parser = subparsers.add_parser('list', help="list openflow rules")
list_parser.add_argument('--verbose', '-v', action='count')
list_parser.add_argument("--no-translate", "-n", action="store_true", help="Skip translation from openflow index to switch port name")
list_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
list_parser.set_defaults(func=of_list)
#dump_parser = subparsers.add_parser('dump', help="dump openflow rules")
#dump_parser.set_defaults(func=of_dump)
clear_parser = subparsers.add_parser('clear', help="clear all openflow rules")
clear_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
clear_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
clear_parser.set_defaults(func=of_clear)
install_parser = subparsers.add_parser('install', help="install openflow rules from file")
install_parser.add_argument("file", action="store", help="file with rules generated using 'openflow list > rules.txt'")
install_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
install_parser.set_defaults(func=of_install)
reinstall_parser = subparsers.add_parser('reinstall', help="reinstall openflow rules from VIM rules")
reinstall_parser.set_defaults(func=of_reinstall)
reinstall_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
portlist_parser = subparsers.add_parser('port-list', help="list the physical to openflow port correspondence")
portlist_parser.set_defaults(func=of_port_list)
portlist_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
argcomplete.autocomplete(main_parser)
args = main_parser.parse_args()
module_info=None
try:
if args.func is not config:
params={ "of_ip": of_controller_ip,
"of_port": of_controller_port,
"of_dpid": of_controller_dpid,
"of_user": of_controller_user,
"of_password": of_controller_password,
}
if "debug" in args and args.debug:
streamformat = "%(asctime)s %(name)s %(levelname)s: %(message)s"
logging.basicConfig(format=streamformat, level= logging.DEBUG)
logger = logging.getLogger('vim')
logger.setLevel(logging.DEBUG)
params["of_debug"]="DEBUG"
else:
#logger = logging.getLogger('vim').addHandler(logging.NullHandler())
#logger.setLevel(logging.CRITICAL)
params["of_debug"]="CRITICAL"
if of_controller_type=='opendaylight':
module = "ODL"
elif of_controller_module != None:
module = of_controller_module
else:
module = of_controller_type
module_info = imp.find_module(module)
of_conn = imp.load_module("of_conn", *module_info)
try:
ofconnector = of_conn.OF_conn(params)
except Exception as e:
print "Cannot open the Openflow controller '%s': %s" % (type(e).__name__, str(e))
result = -1
exit()
result = args.func(args)
if result == None:
result = 0
#for some reason it fails if call exit inside try instance. Need to call exit at the end !?
except (IOError, ImportError) as e:
print "Cannot open openflow controller module '%s'; %s: %s" % (module, type(e).__name__, str(e))
result = -1
#except Exception as e:
# print "Cannot open the Openflow controller '%s': %s" % (type(e).__name__, str(e))
# result = -1
except requests.exceptions.ConnectionError as e:
print "Cannot connect to server; %s: %s" % (type(e).__name__, str(e))
result = -2
except (KeyboardInterrupt):
print 'Exiting openVIM'
result = -3
except (SystemExit):
result = -4
#close open file
if module_info and module_info[0]:
file.close(module_info[0])
exit(result)