From 930817d4f1e01c7e08fd7e8ad79bf781cb53034a Mon Sep 17 00:00:00 2001 From: Michael Vorburger Date: Wed, 1 Feb 2017 17:03:16 +0100 Subject: [PATCH] Support multithreading DataBrokerTestCustomizer (AbstractDataBrokerTest) https://bugs.opendaylight.org/show_bug.cgi?id=7538 has full background Bug: 7538 Change-Id: Ic3f2169e18928e3010e45bddb43186cc53d897f4 Signed-off-by: Michael Vorburger --- .../md/sal/binding/test/DataBrokerTestCustomizer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/DataBrokerTestCustomizer.java b/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/DataBrokerTestCustomizer.java index 23600a3710..8d34cbd2cd 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/DataBrokerTestCustomizer.java +++ b/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/DataBrokerTestCustomizer.java @@ -10,6 +10,7 @@ package org.opendaylight.controller.md.sal.binding.test; import com.google.common.collect.ImmutableMap; import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.MoreExecutors; +import java.util.concurrent.Executors; import javassist.ClassPool; import org.opendaylight.controller.md.sal.binding.api.DataBroker; import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService; @@ -83,9 +84,8 @@ public class DataBrokerTestCustomizer { return new BindingDOMNotificationPublishServiceAdapter(bindingToNormalized, domNotificationRouter); } - public ListeningExecutorService getCommitCoordinatorExecutor() { - return MoreExecutors.newDirectExecutorService(); + return MoreExecutors.listeningDecorator(Executors.newSingleThreadExecutor()); } public DataBroker createDataBroker() { @@ -101,7 +101,7 @@ public class DataBrokerTestCustomizer { } private DOMDataBroker getDOMDataBroker() { - if(domDataBroker == null) { + if (domDataBroker == null) { domDataBroker = createDOMDataBroker(); } return domDataBroker; -- 2.36.6