Signed-off-by: YAMAMOTO Takashi <[email protected]>
---
 ryu/app/tunnel_port_updater.py | 13 +++----------
 1 file changed, 3 insertions(+), 10 deletions(-)

diff --git a/ryu/app/tunnel_port_updater.py b/ryu/app/tunnel_port_updater.py
index 2946737..56d9601 100644
--- a/ryu/app/tunnel_port_updater.py
+++ b/ryu/app/tunnel_port_updater.py
@@ -29,7 +29,6 @@ from ryu.controller import (conf_switch,
                             network,
                             tunnels)
 from ryu.lib import dpid as dpid_lib
-from ryu.lib import synchronized
 from ryu.lib.ovs import bridge as ovs_bridge
 
 
@@ -381,9 +380,7 @@ class TunnelPortUpdater(app_manager.RyuApp):
         self._add_tunnel_ports(tunnel_dp,
                                self.tunnel_requests.get_remote(dpid))
 
-    @handler.set_ev_cls(conf_switch.EventConfSwitchSet,
-                        conf_switch.CONF_SWITCH_EV_DISPATCHER)
-    @synchronized.synchronized(_LOCK)
+    @handler.set_ev_cls(conf_switch.EventConfSwitchSet)
     def conf_switch_set_handler(self, ev):
         LOG.debug('conf_switch_set_handler %s %s %s',
                   dpid_lib.dpid_to_str(ev.dpid), ev.key, ev.value)
@@ -399,9 +396,7 @@ class TunnelPortUpdater(app_manager.RyuApp):
             for tunnel_dp in self.tunnel_dpset.values():
                 tunnel_dp.request_update_remote(ev.dpid, ev.value)
 
-    @handler.set_ev_cls(conf_switch.EventConfSwitchDel,
-                        conf_switch.CONF_SWITCH_EV_DISPATCHER)
-    @synchronized.synchronized(_LOCK)
+    @handler.set_ev_cls(conf_switch.EventConfSwitchDel)
     def conf_switch_del_handler(self, ev):
         # TODO:XXX
         pass
@@ -459,9 +454,7 @@ class TunnelPortUpdater(app_manager.RyuApp):
             tunnel_dp.request_del_tunnel_port(remote_dp.tunnel_ip)
             remote_dp.request_del_tunnel_port(tunnel_dp.tunnel_ip)
 
-    @handler.set_ev_cls(network.EventNetworkPort,
-                        network.NETWORK_TENANT_EV_DISPATCHER)
-    @synchronized.synchronized(_LOCK)
+    @handler.set_ev_cls(network.EventNetworkPort)
     def network_port_handler(self, ev):
         LOG.debug('network_port_handler %s', ev)
         if ev.network_id in rest_nw_id.RESERVED_NETWORK_IDS:
-- 
1.7.12


------------------------------------------------------------------------------
Free Next-Gen Firewall Hardware Offer
Buy your Sophos next-gen firewall before the end March 2013 
and get the hardware for free! Learn more.
http://p.sf.net/sfu/sophos-d2d-feb
_______________________________________________
Ryu-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ryu-devel

Reply via email to