From 6c3422f3166d9e6354e7bbe586ec54ebddf591bf Mon Sep 17 00:00:00 2001 From: manuedelf Date: Mon, 30 Nov 2020 10:02:17 +0100 Subject: [PATCH] Add getDataBroker to NetworkTransactionService In order to prepare flexgrid add getDataBroker method to be able to retrieve version of PceOpticalNode. JIRA: TRNSPRTPCE-230 Signed-off-by: manuedelf Change-Id: Ica0a27cdf7d4ded89b89642f70b0ca4677fe4fbd --- .../common/network/NetworkTransactionImpl.java | 11 +++++++++++ .../common/network/NetworkTransactionService.java | 7 +++++++ .../transportpce/common/network/RequestProcessor.java | 8 ++++++++ 3 files changed, 26 insertions(+) diff --git a/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionImpl.java b/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionImpl.java index 11a1898b2..3f39eb110 100644 --- a/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionImpl.java +++ b/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionImpl.java @@ -11,6 +11,7 @@ package org.opendaylight.transportpce.common.network; import com.google.common.util.concurrent.FluentFuture; import com.google.common.util.concurrent.ListenableFuture; import org.eclipse.jdt.annotation.NonNull; +import org.opendaylight.mdsal.binding.api.DataBroker; import org.opendaylight.mdsal.common.api.CommitInfo; import org.opendaylight.mdsal.common.api.LogicalDatastoreType; import org.opendaylight.yangtools.yang.binding.DataObject; @@ -60,5 +61,15 @@ public class NetworkTransactionImpl implements NetworkTransactionService { requestProcessor.merge(store, path, data); } + /* + * (non-Javadoc) + * + * @see org.opendaylight.transportpce.common.network.NetworkTransactionService#getDataBroker() + */ + @Override + public DataBroker getDataBroker() { + return requestProcessor.getDataBroker(); + } + } diff --git a/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionService.java b/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionService.java index 4fe79f3cf..af75889fe 100644 --- a/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionService.java +++ b/common/src/main/java/org/opendaylight/transportpce/common/network/NetworkTransactionService.java @@ -12,6 +12,7 @@ import com.google.common.util.concurrent.FluentFuture; import com.google.common.util.concurrent.ListenableFuture; import java.util.Optional; import org.eclipse.jdt.annotation.NonNull; +import org.opendaylight.mdsal.binding.api.DataBroker; import org.opendaylight.mdsal.common.api.CommitInfo; import org.opendaylight.mdsal.common.api.LogicalDatastoreType; import org.opendaylight.yangtools.yang.binding.DataObject; @@ -33,4 +34,10 @@ public interface NetworkTransactionService { FluentFuture commit(); void close(); + + /** + * the Databroker related to NetworkTransactionService. + * @return the Databroker related to NetworkTransactionService. + */ + DataBroker getDataBroker(); } diff --git a/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java b/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java index 54a88c5af..810902dd4 100644 --- a/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java +++ b/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java @@ -130,4 +130,12 @@ public class RequestProcessor { rwTx = dataBroker.newReadWriteTransaction(); return rwTx; } + + /** + * Return the dataBroker related to RequestProcessor. + * @return the dataBroker + */ + public DataBroker getDataBroker() { + return dataBroker; + } } -- 2.36.6