From db101c10d767b236a15acd653eec8fb53094ed46 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Jaime=20Caama=C3=B1o=20Ruiz?= Date: Mon, 14 Aug 2017 19:46:29 +0200 Subject: [PATCH] BUG 9003: Fix port chain event triggered two times MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Change-Id: I4dd83824808d3faa2f515901d9171bb8e812d681 Signed-off-by: Jaime Caamaño Ruiz --- .../sfc/translator/portchain/NeutronPortChainListener.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/vpnservice/sfc/translator/src/main/java/org/opendaylight/netvirt/sfc/translator/portchain/NeutronPortChainListener.java b/vpnservice/sfc/translator/src/main/java/org/opendaylight/netvirt/sfc/translator/portchain/NeutronPortChainListener.java index b23a602717..994737847a 100644 --- a/vpnservice/sfc/translator/src/main/java/org/opendaylight/netvirt/sfc/translator/portchain/NeutronPortChainListener.java +++ b/vpnservice/sfc/translator/src/main/java/org/opendaylight/netvirt/sfc/translator/portchain/NeutronPortChainListener.java @@ -14,8 +14,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.ExecutionException; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.ThreadFactory; import org.opendaylight.controller.md.sal.binding.api.DataBroker; @@ -60,7 +58,6 @@ public class NeutronPortChainListener extends DelegatingDataTreeListener PORT_CHAIN_IID = InstanceIdentifier.create(Neutron.class).child(PortChains.class).child(PortChain.class); - private final ExecutorService eventProcessor; private final SfcMdsalHelper sfcMdsalHelper; private final NeutronMdsalHelper neutronMdsalHelper; private final OvsdbMdsalHelper ovsdbMdsalHelper; @@ -73,7 +70,6 @@ public class NeutronPortChainListener extends DelegatingDataTreeListener path, final PortChain newPortChain) { processPortChain(newPortChain); - eventProcessor.submit(() -> processPortChain(newPortChain)); } private void processPortChain(PortChain newPortChain) { -- 2.36.6