mirrors/ryu
1
0
Fork 0
mirror of https://github.com/faucetsdn/ryu.git synced 2026-01-25 10:32:03 +01:00
Code Issues Projects Releases Wiki Activity

apgw: fix traceroute notificaiton

Browse Source 
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
This commit is contained in:
FUJITA Tomonori 2014-03-06 21:56:12 +09:00
parent bf21ed0b0b
commit a3fda22167
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
ryu/controller/api.py
View File

@ -99,8 +99,8 @@ class RpcOFPManager(app_manager.RyuApp):
error = None
result = None
try:
msgid, target_method, params = data
if _type == rpc.MessageType.REQUEST:
msgid, target_method, params = data
if target_method == "ofp":
result = self._handle_ofprotocol(msgid, params)
elif target_method == "monitor_port":
@ -112,10 +112,15 @@ class RpcOFPManager(app_manager.RyuApp):
else:
error = 'Unknown method %s' % (target_method)
elif _type == rpc.MessageType.NOTIFY:
target_method, params = data
if target_method == 'traceroute':
result = self._register_traceroute(msgid, params)
try:
self._register_traceroute(params)
except RPCError as e:
self.logger.error(_({'error': str(e)}))
else:
error = 'Unknown method %s' % (target_method)
self.logger.error(_({'unknown method': target_method}))
continue
except RPCError as e:
error = str(e)
except PendingRPC as e:
@ -489,7 +494,7 @@ class RpcOFPManager(app_manager.RyuApp):
dp.send_msg(ofmsg)
return result
def _register_traceroute(self, msgid, params):
def _register_traceroute(self, params):
try:
param_dict = params[0]
except: