blob: d6aa92d62747293139acd16053420e03f02437ec [file] [log] [blame]
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -07001#
Zsolt Haraszti3eb27a52017-01-03 21:56:48 -08002# Copyright 2017 the original author or authors.
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -07003#
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#
16import structlog
Zsolt Haraszti2bdb6b32016-11-03 16:56:17 -070017from twisted.internet.defer import inlineCallbacks, returnValue
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070018
19import loxi.of13 as ofp
20from converter import to_loxi, pb2dict, to_grpc
21
22log = structlog.get_logger()
23
24
25class OpenFlowProtocolError(Exception): pass
26
27
28class OpenFlowProtocolHandler(object):
29
sathishgbbb90992017-06-23 09:52:29 +053030 ofp_version = [4] # OFAgent supported versions
31
Zsolt Haraszticd22adc2016-10-25 00:13:06 -070032 def __init__(self, datapath_id, device_id, agent, cxn, rpc):
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070033 """
34 The upper half of the OpenFlow protocol, focusing on message
35 exchanges.
36 :param agent: Reference to the Agent() instance, can be used to
37 indicate critical errors to break the connection.
38 :param cxn: The lower level message serdes part of the OF protocol.
39 :param rpc: The application level stub on which RPC calls
40 are made as result of processing incoming OpenFlow request messages.
41 """
42 self.datapath_id = datapath_id
Zsolt Haraszticd22adc2016-10-25 00:13:06 -070043 self.device_id = device_id
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070044 self.agent = agent
45 self.cxn = cxn
46 self.rpc = rpc
sgovindacc736782017-05-02 20:06:37 +053047 self.role = None
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070048
49 @inlineCallbacks
Zsolt Haraszti2bdb6b32016-11-03 16:56:17 -070050 def start(self):
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070051 """A new call is made after a fresh reconnect"""
52
Zsolt Haraszti2bdb6b32016-11-03 16:56:17 -070053 log.debug('starting')
54
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070055 try:
sathishgbbb90992017-06-23 09:52:29 +053056 support = False
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070057 # send initial hello message
sathishgbbb90992017-06-23 09:52:29 +053058 self.cxn.send(ofp.message.hello(elements=[ofp.common.hello_elem_versionbitmap(
59 bitmaps = [ofp.common.hello_elem_bitmap(self.ofp_version)])]))
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070060 # expect to receive a hello message
61 msg = yield self.cxn.recv_class(ofp.message.hello)
sathishgbbb90992017-06-23 09:52:29 +053062 # supports only ofp_versions till 31 and single bitmap.
63 if msg:
64 support = ofp.util.verify_version_support(msg,self.ofp_version)
65 if not support:
66 self.cxn.send(ofp.message.hello_failed_error_msg(
67 xid=msg.xid, code=ofp.OFPHFC_INCOMPATIBLE,
68 data='i support only 1.3'))
69 log.error('peer-do-not-support-OpenFlow-version',self.ofp_version)
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070070
sathishgbbb90992017-06-23 09:52:29 +053071 while support:
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070072 req = yield self.cxn.recv_any()
73 handler = self.main_handlers.get(req.type, None)
74 if handler:
75 handler(self, req)
76 else:
77 log.error('cannot-handle',
78 request=req, xid=req.xid, type=req.type)
79
80 except Exception, e:
81 log.exception('exception', e=e)
82
Zsolt Haraszti2bdb6b32016-11-03 16:56:17 -070083 log.info('started')
84 returnValue(self)
85
86 def stop(self):
87 log.debug('stopping')
88 pass # nothing to do yet
89 log.info('stopped')
90
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070091 def handle_echo_request(self, req):
92 self.cxn.send(ofp.message.echo_reply(xid=req.xid))
93
94 @inlineCallbacks
95 def handle_feature_request(self, req):
Zsolt Haraszticd22adc2016-10-25 00:13:06 -070096 device_info = yield self.rpc.get_device_info(self.device_id)
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -070097 kw = pb2dict(device_info.switch_features)
98 self.cxn.send(ofp.message.features_reply(
99 xid=req.xid,
100 datapath_id=self.datapath_id,
101 **kw))
102
103 def handle_stats_request(self, req):
104 handler = self.stats_handlers.get(req.stats_type, None)
105 if handler:
106 handler(self, req)
107 else:
108 raise OpenFlowProtocolError(
109 'Cannot handle stats request type "{}"'.format(req.stats_type))
110
111 def handle_barrier_request(self, req):
alshabibc3fb4942017-01-26 15:34:24 -0800112 # not really doing barrier yet, but we respond
113 # see https://jira.opencord.org/browse/CORD-823
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700114 self.cxn.send(ofp.message.barrier_reply(xid=req.xid))
115
116 def handle_experimenter_request(self, req):
117 raise NotImplementedError()
118
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700119 def handle_flow_mod_request(self, req):
sgovindacc736782017-05-02 20:06:37 +0530120 if self.role == ofp.OFPCR_ROLE_MASTER or self.role == ofp.OFPCR_ROLE_EQUAL:
121 try:
122 grpc_req = to_grpc(req)
123 except Exception, e:
124 log.exception('failed-to-convert', e=e)
125 else:
126 return self.rpc.update_flow_table(self.device_id, grpc_req)
127
128 elif self.role == ofp.OFPCR_ROLE_SLAVE:
129 self.cxn.send(ofp.message.bad_request_error_msg(code=ofp.OFPBRC_IS_SLAVE))
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700130
131 def handle_get_async_request(self, req):
132 raise NotImplementedError()
133
134 def handle_get_config_request(self, req):
135 self.cxn.send(ofp.message.get_config_reply(
136 xid=req.xid,
137 miss_send_len=ofp.OFPCML_NO_BUFFER
138 ))
139
Zsolt Haraszti8a774382016-10-24 18:25:54 -0700140 @inlineCallbacks
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700141 def handle_group_mod_request(self, req):
sgovindacc736782017-05-02 20:06:37 +0530142 if self.role == ofp.OFPCR_ROLE_MASTER or self.role == ofp.OFPCR_ROLE_EQUAL:
143 yield self.rpc.update_group_table(self.device_id, to_grpc(req))
144 elif self.role == ofp.OFPCR_ROLE_SLAVE:
145 self.cxn.send(ofp.message.bad_request_error_msg(code=ofp.OFPBRC_IS_SLAVE))
146
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700147
148 def handle_meter_mod_request(self, req):
149 raise NotImplementedError()
150
151 def handle_role_request(self, req):
sgovindacc736782017-05-02 20:06:37 +0530152 if req.role == ofp.OFPCR_ROLE_MASTER or req.role == ofp.OFPCR_ROLE_SLAVE:
sathishg00433e52017-05-23 16:07:41 +0530153 if self.agent.generation_is_defined and (
154 ((req.generation_id - self.agent.cached_generation_id) & 0xffffffffffffffff) if abs(
155 req.generation_id - self.agent.cached_generation_id) > 0x7fffffffffffffff else (
156 req.generation_id - self.agent.cached_generation_id)) < 0:
157 self.cxn.send(ofp.message.bad_request_error_msg(code=ofp.OFPRRFC_STALE))
158 else:
159 self.agent.generation_is_defined = True
160 self.agent.cached_generation_id = req.generation_id
161 self.role = req.role
162 self.cxn.send(ofp.message.role_reply(
163 xid=req.xid, role=req.role, generation_id=req.generation_id))
sgovindacc736782017-05-02 20:06:37 +0530164 elif req.role == ofp.OFPCR_ROLE_EQUAL:
sathishg00433e52017-05-23 16:07:41 +0530165 self.role = req.role
166 self.cxn.send(ofp.message.role_reply(
167 xid=req.xid, role=req.role))
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700168
169 def handle_packet_out_request(self, req):
sgovindacc736782017-05-02 20:06:37 +0530170 if self.role == ofp.OFPCR_ROLE_MASTER or self.role == ofp.OFPCR_ROLE_EQUAL:
171 self.rpc.send_packet_out(self.device_id, to_grpc(req))
172
173 elif self.role == ofp.OFPCR_ROLE_SLAVE:
174 self.cxn.send(ofp.message.bad_request_error_msg(code=ofp.OFPBRC_IS_SLAVE))
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700175
176 def handle_set_config_request(self, req):
alshabibc3fb4942017-01-26 15:34:24 -0800177 # Handle set config appropriately
178 # https://jira.opencord.org/browse/CORD-826
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700179 pass
180
Jonathan Hart8d21c322018-04-17 07:42:02 -0700181 @inlineCallbacks
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700182 def handle_port_mod_request(self, req):
Jonathan Hart8d21c322018-04-17 07:42:02 -0700183 if self.role == ofp.OFPCR_ROLE_MASTER or self.role == ofp.OFPCR_ROLE_EQUAL:
184 port = yield self.rpc.get_port(self.device_id, str(req.port_no))
185
186 if port.ofp_port.config & ofp.OFPPC_PORT_DOWN != \
187 req.config & ofp.OFPPC_PORT_DOWN:
188 if req.config & ofp.OFPPC_PORT_DOWN:
189 self.rpc.disable_port(self.device_id, port.id)
190 else:
191 self.rpc.enable_port(self.device_id, port.id)
192
193 elif self.role == ofp.OFPCR_ROLE_SLAVE:
194 self.cxn.send(ofp.message.bad_request_error_msg(code=ofp.OFPBRC_IS_SLAVE))
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700195
196 def handle_table_mod_request(self, req):
197 raise NotImplementedError()
198
199 def handle_queue_get_config_request(self, req):
200 raise NotImplementedError()
201
202 def handle_set_async_request(self, req):
203 raise NotImplementedError()
204
205 def handle_aggregate_request(self, req):
206 raise NotImplementedError
207
208 @inlineCallbacks
209 def handle_device_description_request(self, req):
Zsolt Haraszticd22adc2016-10-25 00:13:06 -0700210 device_info = yield self.rpc.get_device_info(self.device_id)
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700211 kw = pb2dict(device_info.desc)
212 self.cxn.send(ofp.message.desc_stats_reply(xid=req.xid, **kw))
213
214 def handle_experimenter_stats_request(self, req):
215 raise NotImplementedError()
216
217 @inlineCallbacks
218 def handle_flow_stats_request(self, req):
Zsolt Haraszti3578a1c2017-01-10 15:29:02 -0800219 try:
220 flow_stats = yield self.rpc.list_flows(self.device_id)
221 self.cxn.send(ofp.message.flow_stats_reply(
222 xid=req.xid, entries=[to_loxi(f) for f in flow_stats]))
223 except Exception, e:
224 log.exception('failed-flow-stats-request', req=req)
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700225
Zsolt Haraszti8a774382016-10-24 18:25:54 -0700226 @inlineCallbacks
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700227 def handle_group_stats_request(self, req):
Zsolt Haraszticd22adc2016-10-25 00:13:06 -0700228 group_stats = yield self.rpc.list_groups(self.device_id)
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700229 self.cxn.send(ofp.message.group_stats_reply(
alshabibf4fb2682017-01-12 00:32:56 -0600230 xid=req.xid, entries=[to_loxi(g.stats) for g in group_stats]))
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700231
alshabibf4fb2682017-01-12 00:32:56 -0600232 @inlineCallbacks
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700233 def handle_group_descriptor_request(self, req):
alshabibf4fb2682017-01-12 00:32:56 -0600234 group_stats = yield self.rpc.list_groups(self.device_id)
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700235 self.cxn.send(ofp.message.group_desc_stats_reply(
alshabibf4fb2682017-01-12 00:32:56 -0600236 xid=req.xid, entries=[to_loxi(g.desc) for g in group_stats]))
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700237
238 def handle_group_features_request(self, req):
239 raise NotImplementedError()
240
241 def handle_meter_stats_request(self, req):
alshabibc3fb4942017-01-26 15:34:24 -0800242 meter_stats = [] # see https://jira.opencord.org/browse/CORD-825
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700243 self.cxn.send(ofp.message.meter_stats_reply(
244 xid=req.xid, entries=meter_stats))
245
246 def handle_meter_config_request(self, req):
247 raise NotImplementedError()
248
249 def handle_meter_features_request(self, req):
alshabib81824e32016-12-21 21:43:45 -0800250 self.cxn.send(ofp.message.bad_request_error_msg())
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700251
252 def handle_port_stats_request(self, req):
alshabibc3fb4942017-01-26 15:34:24 -0800253 port_stats = [] # see https://jira.opencord.org/browse/CORD-825
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700254 self.cxn.send(ofp.message.port_stats_reply(
255 xid=req.xid,entries=port_stats))
256
257 @inlineCallbacks
258 def handle_port_desc_request(self, req):
Zsolt Haraszticd22adc2016-10-25 00:13:06 -0700259 port_list = yield self.rpc.get_port_list(self.device_id)
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700260 self.cxn.send(ofp.message.port_desc_stats_reply(
261 xid=req.xid,
262 #flags=None,
Zsolt Haraszti66862032016-11-28 14:28:39 -0800263 entries=[to_loxi(port.ofp_port) for port in port_list]
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700264 ))
265
266 def handle_queue_stats_request(self, req):
267 raise NotImplementedError()
268
269 def handle_table_stats_request(self, req):
alshabibc3fb4942017-01-26 15:34:24 -0800270 table_stats = [] # see https://jira.opencord.org/browse/CORD-825
Zsolt Haraszti023ea7c2016-10-16 19:30:34 -0700271 self.cxn.send(ofp.message.table_stats_reply(
272 xid=req.xid, entries=table_stats))
273
274 def handle_table_features_request(self, req):
275 raise NotImplementedError()
276
277 stats_handlers = {
278 ofp.OFPST_AGGREGATE: handle_aggregate_request,
279 ofp.OFPST_DESC: handle_device_description_request,
280 ofp.OFPST_EXPERIMENTER: handle_experimenter_stats_request,
281 ofp.OFPST_FLOW: handle_flow_stats_request,
282 ofp.OFPST_GROUP: handle_group_stats_request,
283 ofp.OFPST_GROUP_DESC: handle_group_descriptor_request,
284 ofp.OFPST_GROUP_FEATURES: handle_group_features_request,
285 ofp.OFPST_METER: handle_meter_stats_request,
286 ofp.OFPST_METER_CONFIG: handle_meter_config_request,
287 ofp.OFPST_METER_FEATURES: handle_meter_features_request,
288 ofp.OFPST_PORT: handle_port_stats_request,
289 ofp.OFPST_PORT_DESC: handle_port_desc_request,
290 ofp.OFPST_QUEUE: handle_queue_stats_request,
291 ofp.OFPST_TABLE: handle_table_stats_request,
292 ofp.OFPST_TABLE_FEATURES: handle_table_features_request
293 }
294
295 main_handlers = {
296 ofp.OFPT_BARRIER_REQUEST: handle_barrier_request,
297 ofp.OFPT_ECHO_REQUEST: handle_echo_request,
298 ofp.OFPT_FEATURES_REQUEST: handle_feature_request,
299 ofp.OFPT_EXPERIMENTER: handle_experimenter_request,
300 ofp.OFPT_FLOW_MOD: handle_flow_mod_request,
301 ofp.OFPT_GET_ASYNC_REQUEST: handle_get_async_request,
302 ofp.OFPT_GET_CONFIG_REQUEST: handle_get_config_request,
303 ofp.OFPT_GROUP_MOD: handle_group_mod_request,
304 ofp.OFPT_METER_MOD: handle_meter_mod_request,
305 ofp.OFPT_PACKET_OUT: handle_packet_out_request,
306 ofp.OFPT_PORT_MOD: handle_port_mod_request,
307 ofp.OFPT_QUEUE_GET_CONFIG_REQUEST: handle_queue_get_config_request,
308 ofp.OFPT_ROLE_REQUEST: handle_role_request,
309 ofp.OFPT_SET_ASYNC: handle_set_async_request,
310 ofp.OFPT_SET_CONFIG: handle_set_config_request,
311 ofp.OFPT_STATS_REQUEST: handle_stats_request,
312 ofp.OFPT_TABLE_MOD: handle_table_mod_request,
313 }
314
Zsolt Haraszticd22adc2016-10-25 00:13:06 -0700315 def forward_packet_in(self, ofp_packet_in):
sgovindacc736782017-05-02 20:06:37 +0530316 if self.role == ofp.OFPCR_ROLE_MASTER or self.role == ofp.OFPCR_ROLE_EQUAL:
317 log.info('sending-packet-in', ofp_packet_in=ofp_packet_in)
318 self.cxn.send(to_loxi(ofp_packet_in))
Zsolt Haraszti217a12e2016-12-19 16:37:55 -0800319
320 def forward_port_status(self, ofp_port_status):
321 self.cxn.send(to_loxi(ofp_port_status))