tunnel_port_updater: g/c _LOCK
Signed-off-by: YAMAMOTO Takashi <yamamoto@valinux.co.jp> Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
This commit is contained in:
parent
5cff2a3630
commit
134334137f
@ -350,7 +350,6 @@ class TunnelPortUpdater(app_manager.RyuApp):
|
|||||||
'network': network.Network,
|
'network': network.Network,
|
||||||
'tunnels': tunnels.Tunnels,
|
'tunnels': tunnels.Tunnels,
|
||||||
}
|
}
|
||||||
_LOCK = 'lock'
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
def __init__(self, *args, **kwargs):
|
||||||
super(TunnelPortUpdater, self).__init__(args, kwargs)
|
super(TunnelPortUpdater, self).__init__(args, kwargs)
|
||||||
@ -366,8 +365,6 @@ class TunnelPortUpdater(app_manager.RyuApp):
|
|||||||
self.network_api.update_network(
|
self.network_api.update_network(
|
||||||
_TUNNEL_TYPE_TO_NW_ID[self.tunnel_type])
|
_TUNNEL_TYPE_TO_NW_ID[self.tunnel_type])
|
||||||
|
|
||||||
setattr(self, self._LOCK, gevent.coros.Semaphore())
|
|
||||||
|
|
||||||
def _ovsdb_update(self, dpid, ovsdb_addr, ovs_tunnel_addr):
|
def _ovsdb_update(self, dpid, ovsdb_addr, ovs_tunnel_addr):
|
||||||
self.logger.debug('_ovsdb_update %s %s %s',
|
self.logger.debug('_ovsdb_update %s %s %s',
|
||||||
dpid_lib.dpid_to_str(dpid), ovsdb_addr,
|
dpid_lib.dpid_to_str(dpid), ovsdb_addr,
|
||||||
|
Loading…
Reference in New Issue
Block a user