blob: 544c76463264d2a95ab220738b704bfb51293dbb [file] [log] [blame]
Zsolt Haraszti80175202016-12-24 00:17:51 -08001#
2# Copyright 2016 the original author or authors.
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
7#
8# http://www.apache.org/licenses/LICENSE-2.0
9#
10# 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#
16
Zsolt Harasztia133a452016-12-22 01:26:57 -080017import sys
Zsolt Haraszti80175202016-12-24 00:17:51 -080018
Zsolt Harasztid036b7e2016-12-23 15:36:01 -080019from google.protobuf.json_format import MessageToDict
Zsolt Harasztia133a452016-12-22 01:26:57 -080020from termcolor import cprint, colored
Zsolt Haraszti80175202016-12-24 00:17:51 -080021
22from cli.table import TablePrinter
23
24
25_printfn = lambda l: sys.stdout.write(l + '\n')
Zsolt Harasztia133a452016-12-22 01:26:57 -080026
27
Zsolt Harasztid036b7e2016-12-23 15:36:01 -080028def pb2dict(pb_msg):
29 d = MessageToDict(pb_msg, including_default_value_fields=1,
30 preserving_proto_field_name=1)
31 return d
32
33
Zsolt Harasztia133a452016-12-22 01:26:57 -080034def p_cookie(cookie):
Gertjan Van Droogenbroeck308a9cf2017-10-11 15:59:51 -050035 cookie = '%x' % int(cookie)
Zsolt Harasztia133a452016-12-22 01:26:57 -080036 if len(cookie) > 8:
Gertjan Van Droogenbroeck308a9cf2017-10-11 15:59:51 -050037 return '~' + cookie[len(cookie)-8:]
Zsolt Harasztia133a452016-12-22 01:26:57 -080038 else:
39 return cookie
40
41'''
42 OFPP_NORMAL = 0x7ffffffa; /* Forward using non-OpenFlow pipeline. */
43 OFPP_FLOOD = 0x7ffffffb; /* Flood using non-OpenFlow pipeline. */
44 OFPP_ALL = 0x7ffffffc; /* All standard ports except input port. */
45 OFPP_CONTROLLER = 0x7ffffffd; /* Send to controller. */
46 OFPP_LOCAL = 0x7ffffffe; /* Local openflow "port". */
47 OFPP_ANY = 0x7fffffff; /* Special value used in some requests when
48'''
49
50
51def p_port(port):
52 if port & 0x7fffffff == 0x7ffffffa:
53 return 'NORMAL'
54 elif port & 0x7fffffff == 0x7ffffffb:
55 return 'FLOOD'
56 elif port & 0x7fffffff == 0x7ffffffc:
57 return 'ALL'
58 elif port & 0x7fffffff == 0x7ffffffd:
59 return 'CONTROLLER'
60 elif port & 0x7fffffff == 0x7ffffffe:
61 return 'LOCAL'
62 elif port & 0x7fffffff == 0x7fffffff:
63 return 'ANY'
64 else:
65 return str(port)
66
67
68def p_vlan_vid(vlan_vid):
69 if vlan_vid == 0:
70 return 'untagged'
71 assert vlan_vid & 4096 == 4096
72 return str(vlan_vid - 4096)
73
74
75def p_ipv4(x):
76 return '.'.join(str(v) for v in [
77 (x >> 24) & 0xff, (x >> 16) & 0xff, (x >> 8) & 0xff, x & 0xff
78 ])
79
80
81field_printers = {
82 'IN_PORT': lambda f: (100, 'in_port', p_port(f['port'])),
83 'VLAN_VID': lambda f: (101, 'vlan_vid', p_vlan_vid(f['vlan_vid'])),
84 'VLAN_PCP': lambda f: (102, 'vlan_pcp', str(f['vlan_pcp'])),
85 'ETH_TYPE': lambda f: (103, 'eth_type', '%X' % f['eth_type']),
Zsolt Haraszti85f12852016-12-24 08:30:58 -080086 'IP_PROTO': lambda f: (104, 'ip_proto', str(f['ip_proto'])),
87 'IPV4_DST': lambda f: (105, 'ipv4_dst', p_ipv4(f['ipv4_dst'])),
88 'UDP_SRC': lambda f: (106, 'udp_src', str(f['udp_src'])),
89 'UDP_DST': lambda f: (107, 'udp_dst', str(f['udp_dst'])),
90 'TCP_SRC': lambda f: (108, 'tcp_src', str(f['tcp_src'])),
91 'TCP_DST': lambda f: (109, 'tcp_dst', str(f['tcp_dst'])),
Zsolt Haraszti6a5107c2017-01-09 23:42:41 -080092 'METADATA': lambda f: (110, 'metadata', str(f['table_metadata'])),
Zsolt Harasztia133a452016-12-22 01:26:57 -080093}
94
95
96def p_field(field):
97 assert field['oxm_class'].endswith('OPENFLOW_BASIC')
98 ofb = field['ofb_field']
99 assert not ofb['has_mask']
100 type = ofb['type'][len('OFPXMT_OFB_'):]
101 weight, field_name, value = field_printers[type](ofb)
102 return 1000 + weight, 'set_' + field_name, value
103
104
105action_printers = {
106 'SET_FIELD': lambda a: p_field(a['set_field']['field']),
107 'POP_VLAN': lambda a: (2000, 'pop_vlan', 'Yes'),
108 'PUSH_VLAN': lambda a: (2001, 'push_vlan', '%x' % a['push']['ethertype']),
109 'GROUP': lambda a: (3000, 'group', p_port(a['group']['group_id'])),
110 'OUTPUT': lambda a: (4000, 'output', p_port(a['output']['port'])),
111}
112
113
Zsolt Haraszti80175202016-12-24 00:17:51 -0800114def print_flows(what, id, type, flows, groups, printfn=_printfn):
Zsolt Harasztia133a452016-12-22 01:26:57 -0800115
Zsolt Haraszti80175202016-12-24 00:17:51 -0800116 header = ''.join([
Zsolt Harasztia133a452016-12-22 01:26:57 -0800117 '{} '.format(what),
118 colored(id, color='green', attrs=['bold']),
119 ' (type: ',
120 colored(type, color='blue'),
121 ')'
Zsolt Haraszti80175202016-12-24 00:17:51 -0800122 ]) + '\nFlows ({}):'.format(len(flows))
Zsolt Harasztia133a452016-12-22 01:26:57 -0800123
Zsolt Haraszti80175202016-12-24 00:17:51 -0800124 table = TablePrinter()
Zsolt Harasztia133a452016-12-22 01:26:57 -0800125 for i, flow in enumerate(flows):
126
Zsolt Haraszti80175202016-12-24 00:17:51 -0800127 table.add_cell(i, 0, 'table_id', value=str(flow['table_id']))
128 table.add_cell(i, 1, 'priority', value=str(flow['priority']))
129 table.add_cell(i, 2, 'cookie', p_cookie(flow['cookie']))
Zsolt Harasztia133a452016-12-22 01:26:57 -0800130
131 assert flow['match']['type'] == 'OFPMT_OXM'
132 for field in flow['match']['oxm_fields']:
133 assert field['oxm_class'].endswith('OPENFLOW_BASIC')
134 ofb = field['ofb_field']
alshabib37494a72017-01-26 11:59:52 -0800135 # see CORD-816 (https://jira.opencord.org/browse/CORD-816)
136 assert not ofb['has_mask'], 'masked match not handled yet'
Zsolt Harasztia133a452016-12-22 01:26:57 -0800137 type = ofb['type'][len('OFPXMT_OFB_'):]
Zsolt Haraszti80175202016-12-24 00:17:51 -0800138 table.add_cell(i, *field_printers[type](ofb))
Zsolt Harasztia133a452016-12-22 01:26:57 -0800139
140 for instruction in flow['instructions']:
Zsolt Haraszti656ecc62016-12-28 15:08:23 -0800141 itype = instruction['type']
Koray Koktenefcdf522018-12-06 00:16:56 +0300142 if itype == 4 or itype == 3:
Zsolt Harasztia133a452016-12-22 01:26:57 -0800143 for action in instruction['actions']['actions']:
Zsolt Haraszti656ecc62016-12-28 15:08:23 -0800144 atype = action['type'][len('OFPAT_'):]
145 table.add_cell(i, *action_printers[atype](action))
146 elif itype == 1:
147 table.add_cell(i, 10000, 'goto-table',
148 instruction['goto_table']['table_id'])
Gamze Abaka61c2e982018-02-14 11:03:36 +0000149 elif itype == 5:
150 table.add_cell(i, 10000, 'clear-actions', [])
Zsolt Haraszti656ecc62016-12-28 15:08:23 -0800151 else:
152 raise NotImplementedError(
153 'not handling instruction type {}'.format(itype))
Zsolt Harasztia133a452016-12-22 01:26:57 -0800154
Zsolt Haraszti80175202016-12-24 00:17:51 -0800155 table.print_table(header, printfn)
Zsolt Harasztia133a452016-12-22 01:26:57 -0800156
Zsolt Harasztia133a452016-12-22 01:26:57 -0800157
Gertjan Van Droogenbroeck308a9cf2017-10-11 15:59:51 -0500158def print_groups(what, id, type, groups, printfn=_printfn):
159 header = ''.join([
160 '{} '.format(what),
161 colored(id, color='green', attrs=['bold']),
162 ' (type: ',
163 colored(type, color='blue'),
164 ')'
165 ]) + '\nGroups ({}):'.format(len(groups))
166
167 table = TablePrinter()
168 for i, group in enumerate(groups):
169 output_ports = []
170 for bucket in group['desc']['buckets']:
171 for action in bucket['actions']:
172 if action['type'] == 'OFPAT_OUTPUT':
173 output_ports.append(action['output']['port'])
174 table.add_cell(i, 0, 'group_id', value=str(group['desc']['group_id']))
175 table.add_cell(i, 1, 'buckets', value=str(dict(output=output_ports)))
176
177 table.print_table(header, printfn)
Zsolt Harasztia133a452016-12-22 01:26:57 -0800178
Zsolt Haraszti80175202016-12-24 00:17:51 -0800179def dict2line(d):
180 assert isinstance(d, dict)
181 return ', '.join('{}: {}'.format(k, v) for k, v in sorted(d.items()))
Lydia Fang01f2e852017-06-28 17:24:58 -0700182
183def enum2name(msg_obj, enum_type, enum_value):
184 descriptor = msg_obj.DESCRIPTOR.enum_types_by_name[enum_type]
185 name = descriptor.values_by_number[enum_value].name
186 return name